<?php
/**
 * Comments app — the moderation operations and their REST routes.
 *
 * Every mutation the app performs is ONE function here, shared by the
 * app's dispatched action and the matching public route, so a plugin
 * automating moderation and a moderator clicking Approve run the
 * same code:
 *
 *   - `openstation_comments_window_moderate()`      ↔ POST /comments/bulk
 *   - `openstation_comments_window_create_reply()`  ↔ POST /comments/reply
 *   - `openstation_comments_window_counts()`        ↔ GET /comments/counts
 *
 * `openstation_comments_window_author_insights()` ↔ GET /comments/insights/<email>
 * is a public route for plugins and integrations; the app itself does
 * not call it.
 *
 * SECURITY POSTURE
 * ================
 *
 *   1. Broad cap gate — the route's `permission_callback`, or the
 *      app action's own check (`moderate_comments`, `edit_posts`).
 *   2. Per-target re-validation inside the operation —
 *      `current_user_can( 'edit_comment', $id )` per row,
 *      `edit_post` on the parent's post for a reply.
 *
 * @package OpenStation
 */

defined( 'ABSPATH' ) || exit;

/**
 * Allowed bulk actions, mapped to the function that performs them on a single id.
 *
 * Each callback returns true on success, false on a soft failure (the
 * row is skipped) and throws nothing — a batch never aborts on one
 * bad row.
 *
 * @return array<string,callable>
 */
function openstation_comments_window_bulk_action_map() {
	return array(
		'approve'   => static function ( $id ) {
			return false !== wp_set_comment_status( $id, 'approve' );
		},
		'unapprove' => static function ( $id ) {
			return false !== wp_set_comment_status( $id, 'hold' );
		},
		'spam'      => static function ( $id ) {
			return false !== wp_spam_comment( $id );
		},
		'unspam'    => static function ( $id ) {
			return false !== wp_unspam_comment( $id );
		},
		'trash'     => static function ( $id ) {
			return false !== wp_trash_comment( $id );
		},
		'untrash'   => static function ( $id ) {
			return false !== wp_untrash_comment( $id );
		},
	);
}

/**
 * Run one moderation action over a batch of comment ids.
 *
 * The caller has cleared the broad gate (`moderate_comments`); every
 * row is still re-validated against `edit_comment`.
 *
 * @param int[]  $ids    Comment ids.
 * @param string $action One of the keys of {@see openstation_comments_window_bulk_action_map()}.
 * @return array{processed:int[],skipped:int[]}|WP_Error
 */
function openstation_comments_window_moderate( array $ids, $action ) {
	$ids    = array_values( array_filter( array_map( 'intval', $ids ) ) );
	$action = (string) $action;
	$map    = openstation_comments_window_bulk_action_map();

	if ( ! isset( $map[ $action ] ) ) {
		return new WP_Error(
			'openstation_comments_invalid_action',
			__( 'Unknown bulk action.', 'desktop-mode' ),
			array( 'status' => 400 )
		);
	}

	$cb        = $map[ $action ];
	$processed = array();
	$skipped   = array();

	foreach ( $ids as $id ) {
		if ( ! current_user_can( 'edit_comment', $id ) ) {
			$skipped[] = $id;
			continue;
		}
		if ( $cb( $id ) ) {
			$processed[] = $id;
		} else {
			$skipped[] = $id;
		}
	}

	/**
	 * Fires after a Comments-window bulk action runs.
	 *
	 * @param string $action    Action slug.
	 * @param int[]  $processed Ids successfully acted on.
	 * @param int[]  $skipped   Ids skipped (cap fail or soft error).
	 */
	do_action(
		'openstation_comments_window_after_bulk',
		$action,
		$processed,
		$skipped
	);

	return array(
		'processed' => $processed,
		'skipped'   => $skipped,
	);
}

/**
 * Whether a comment body is empty once its markup is gone — the one
 * definition of "blank" the reply and the edit share.
 *
 * @param string $content Body.
 * @return bool
 */
function openstation_comments_window_is_blank( $content ) {
	return '' === trim( wp_strip_all_tags( (string) $content ) );
}

/**
 * Post a reply under a comment as the current user. Wraps
 * `wp_new_comment()` with the same defaults core's
 * `wp_ajax_replyto_comment` uses, and the same per-target gate:
 * `edit_post` on the parent's post.
 *
 * @param int    $parent_id Parent comment id.
 * @param string $content   Reply body.
 * @return array{id:int,parent:int,content:string,date_gmt:string,author:string,avatarUrl:string}|WP_Error
 */
function openstation_comments_window_create_reply( $parent_id, $content ) {
	$parent_id = (int) $parent_id;
	$content   = (string) $content;

	$parent = get_comment( $parent_id );
	if ( ! $parent instanceof WP_Comment ) {
		return new WP_Error(
			'openstation_comments_no_parent',
			__( 'Parent comment not found.', 'desktop-mode' ),
			array( 'status' => 404 )
		);
	}

	$post = get_post( (int) $parent->comment_post_ID );
	if ( ! $post instanceof WP_Post || ! current_user_can( 'edit_post', $post->ID ) ) {
		return new WP_Error(
			'openstation_comments_forbidden',
			__( 'You are not allowed to reply to comments on this post.', 'desktop-mode' ),
			array( 'status' => 403 )
		);
	}

	if ( openstation_comments_window_is_blank( $content ) ) {
		return new WP_Error(
			'openstation_comments_empty_reply',
			__( 'Reply cannot be empty.', 'desktop-mode' ),
			array( 'status' => 400 )
		);
	}

	$user = wp_get_current_user();
	if ( ! $user || ! $user->ID ) {
		return new WP_Error(
			'openstation_comments_unauthenticated',
			__( 'You must be logged in to reply.', 'desktop-mode' ),
			array( 'status' => 401 )
		);
	}

	$comment_data = array(
		'comment_post_ID'      => (int) $parent->comment_post_ID,
		'comment_parent'       => $parent_id,
		'user_id'              => (int) $user->ID,
		'comment_author'       => (string) $user->display_name,
		'comment_author_email' => (string) $user->user_email,
		'comment_author_url'   => (string) $user->user_url,
		'comment_content'      => $content,
		'comment_approved'     => 1,
		'comment_type'         => 'comment',
	);

	$new_id = wp_new_comment( wp_slash( $comment_data ), true );
	if ( is_wp_error( $new_id ) ) {
		return $new_id;
	}

	$new = get_comment( $new_id );
	return array(
		'id'        => (int) $new_id,
		'parent'    => $parent_id,
		'content'   => $new ? (string) $new->comment_content : $content,
		'date_gmt'  => $new ? (string) $new->comment_date_gmt : '',
		'author'    => $user->display_name,
		'avatarUrl' => (string) get_avatar_url( (int) $user->ID, array( 'size' => 96 ) ),
	);
}

/**
 * Author insights for the side drawer: total/approved/pending/spam
 * counts, oldest/newest comment timestamps, the linked user (if the
 * email matches a registered user), and a 0–100 reliability score.
 *
 * @param string $email Author email.
 * @return array<string,mixed>|WP_Error
 */
function openstation_comments_window_author_insights( $email ) {
	$email = strtolower( (string) $email );
	if ( '' === $email || ! is_email( $email ) ) {
		return new WP_Error(
			'openstation_comments_invalid_email',
			__( 'Invalid author email.', 'desktop-mode' ),
			array( 'status' => 400 )
		);
	}

	$counts_by_status = array();
	foreach ( array( 'approve', 'hold', 'spam', 'trash' ) as $status ) {
		$counts_by_status[ $status ] = (int) get_comments(
			array(
				'author_email' => $email,
				'status'       => $status,
				'count'        => true,
			)
		);
	}
	$total = array_sum( $counts_by_status );

	// Sample the oldest + newest record without loading every row.
	$edge = static function ( $order ) use ( $email ) {
		$rows = get_comments(
			array(
				'author_email' => $email,
				'status'       => 'all',
				'orderby'      => 'comment_date_gmt',
				'order'        => $order,
				'number'       => 1,
			)
		);
		return isset( $rows[0] ) ? (string) $rows[0]->comment_date_gmt : null;
	};

	$user        = get_user_by( 'email', $email );
	$reliability = 100;
	if ( $total > 0 ) {
		$bad         = $counts_by_status['spam'] + $counts_by_status['trash'];
		$reliability = (int) round( max( 0, min( 100, 100 - ( $bad / $total ) * 100 ) ) );
	}

	return array(
		'email'       => $email,
		'total'       => $total,
		'counts'      => $counts_by_status,
		'oldest'      => $edge( 'ASC' ),
		'newest'      => $edge( 'DESC' ),
		'userId'      => $user ? (int) $user->ID : 0,
		'userName'    => $user ? (string) $user->display_name : '',
		'reliability' => $reliability,
		'avatarUrl'   => (string) get_avatar_url( $email, array( 'size' => 96 ) ),
	);
}

/**
 * Current comment counts as a flat array — the tab chips and the
 * dock badge.
 *
 * @return array<string,int>
 */
function openstation_comments_window_counts() {
	$counts = wp_count_comments();
	return array(
		'pending'  => (int) $counts->moderated,
		'approved' => (int) $counts->approved,
		'spam'     => (int) $counts->spam,
		'trash'    => (int) $counts->trash,
		'total'    => (int) $counts->total_comments,
	);
}

// ------------------------------------------------------------------ routes

/**
 * Register all routes under `desktop-mode/v1`.
 */
function openstation_comments_window_register_rest_routes() {
	register_rest_route(
		'desktop-mode/v1',
		'/comments/bulk',
		array(
			'methods'             => WP_REST_Server::CREATABLE,
			'callback'            => 'openstation_comments_window_rest_bulk',
			'permission_callback' => static function () {
				return current_user_can( 'moderate_comments' );
			},
			'args'                => array(
				'ids'    => array(
					'required' => true,
					'type'     => 'array',
					'items'    => array( 'type' => 'integer' ),
				),
				'action' => array(
					'required' => true,
					'type'     => 'string',
					'enum'     => array_keys( openstation_comments_window_bulk_action_map() ),
				),
			),
		)
	);

	register_rest_route(
		'desktop-mode/v1',
		'/comments/reply',
		array(
			'methods'             => WP_REST_Server::CREATABLE,
			'callback'            => 'openstation_comments_window_rest_reply',
			'permission_callback' => static function () {
				return current_user_can( 'edit_posts' );
			},
			'args'                => array(
				'parent'  => array(
					'required' => true,
					'type'     => 'integer',
				),
				'content' => array(
					'required' => true,
					'type'     => 'string',
				),
			),
		)
	);

	register_rest_route(
		'desktop-mode/v1',
		'/comments/insights/(?P<email>[^/]+)',
		array(
			'methods'             => WP_REST_Server::READABLE,
			'callback'            => 'openstation_comments_window_rest_insights',
			'permission_callback' => static function () {
				return current_user_can( 'moderate_comments' );
			},
			'args'                => array(
				'email' => array(
					'required' => true,
					'type'     => 'string',
				),
			),
		)
	);

	register_rest_route(
		'desktop-mode/v1',
		'/comments/counts',
		array(
			'methods'             => WP_REST_Server::READABLE,
			'callback'            => 'openstation_comments_window_rest_counts',
			'permission_callback' => static function () {
				return current_user_can( 'edit_posts' );
			},
		)
	);
}
add_action( 'rest_api_init', 'openstation_comments_window_register_rest_routes' );

/**
 * POST /comments/bulk.
 *
 * @param WP_REST_Request $request Request.
 * @return WP_REST_Response|WP_Error
 */
function openstation_comments_window_rest_bulk( WP_REST_Request $request ) {
	$action = (string) $request['action'];
	$result = openstation_comments_window_moderate( (array) $request['ids'], $action );
	if ( is_wp_error( $result ) ) {
		return $result;
	}
	return new WP_REST_Response(
		array(
			'action'    => $action,
			'processed' => $result['processed'],
			'skipped'   => $result['skipped'],
			'counts'    => openstation_comments_window_counts(),
		),
		200
	);
}

/**
 * POST /comments/reply.
 *
 * @param WP_REST_Request $request Request.
 * @return WP_REST_Response|WP_Error
 */
function openstation_comments_window_rest_reply( WP_REST_Request $request ) {
	$result = openstation_comments_window_create_reply( (int) $request['parent'], (string) $request['content'] );
	if ( is_wp_error( $result ) ) {
		return $result;
	}
	return new WP_REST_Response( $result, 201 );
}

/**
 * GET /comments/insights/<email>.
 *
 * @param WP_REST_Request $request Request.
 * @return WP_REST_Response|WP_Error
 */
function openstation_comments_window_rest_insights( WP_REST_Request $request ) {
	$result = openstation_comments_window_author_insights( urldecode( (string) $request['email'] ) );
	if ( is_wp_error( $result ) ) {
		return $result;
	}
	return new WP_REST_Response( $result, 200 );
}

/**
 * GET /comments/counts.
 *
 * @return WP_REST_Response
 */
function openstation_comments_window_rest_counts() {
	return new WP_REST_Response( openstation_comments_window_counts(), 200 );
}