<?php
namespace JVBase\integrations;

use Exception;
use WP_Error;

if (!defined('ABSPATH')) {
	exit;
}

class BlueSky extends Integrations
{
	protected string $api_base = 'https://bsky.social/xrpc/';
	protected int $max_description_length = 300;
	protected ?string $access_token = null;
	protected ?string $did = null;

	public function __construct(?int $user_id = null) {
		$this->service_name = 'bluesky';
		$this->title = 'BlueSky';
		$this->icon = 'fediverse-logo';
		$this->canSync = [
			'initial' 	=> true,
			'schedule'	=> true,
		];

		$this->fields = [
			'handle'	=> [
				'type'	=> 'text',
				'placeholder'=> 'your-handle.bsky.social',
				'required'	=> true,
				'label'	=> 'Handle',
			],
			'password'	=> [
				'type'	=> 'text',
				'subtype'=>'password',
				'label'	=> 'Application Password',
				'required'	=> true,
				'hint'	=> '<strong>Security:</strong> Generate an App Password in your BlueSky settings for better security.'
			]
		];
		parent::__construct($user_id);
	}
	protected function initialize(): void
	{
	}


	/**
	 * Setup BlueSky client with credentials
	 */
	protected function setupClient(?int $user_id = null): bool
	{
		$creds = $this->credentials;

		if (empty($creds['identifier']) || empty($creds['password'])) {
			return false;
		}

		try {
			$session = $this->createSession($creds['identifier'], $creds['password']);

			if ($session) {
				$this->access_token = $session['accessJwt'];
				$this->did = $session['did'];
				return true;
			}
		} catch (Exception $e) {
			$this->handleError($e);
		}

		return false;
	}

	/**
	 * Create BlueSky session
	 */
	private function createSession(string $identifier, string $password): ?array
	{
		$response = wp_remote_post($this->api_base . 'com.atproto.server.createSession', [
			'headers' => [
				'Content-Type' => 'application/json',
			],
			'body' => json_encode([
				'identifier' => $identifier,
				'password' => $password
			]),
			'timeout' => 30
		]);

		if (is_wp_error($response)) {
			throw new Exception('Failed to connect to BlueSky: ' . $response->get_error_message());
		}

		$body = json_decode(wp_remote_retrieve_body($response), true);
		$status_code = wp_remote_retrieve_response_code($response);

		if ($status_code !== 200) {
			throw new Exception('BlueSky authentication failed: ' . ($body['message'] ?? 'Unknown error'));
		}

		return $body;
	}

	/**
	 * Publish a post to BlueSky
	 */
	public function publishPost(array $content, ?int $user_id = null): array
	{
		try {
			// Validate content
			$errors = $this->validateContent($content);
			if (!empty($errors)) {
				return [
					'success' => false,
					'error' => implode(', ', $errors)
				];
			}

			// Setup client for this request
			if (!$this->setupClient($user_id)) {
				return [
					'success' => false,
					'error' => 'Failed to authenticate with BlueSky'
				];
			}

			// Check rate limiting
			if (!$this->checkRateLimit()) {
				return [
					'success' => false,
					'error' => 'Rate limit exceeded'
				];
			}

			// Prepare post data
			$post_data = [
				'repo' => $this->did,
				'collection' => 'app.bsky.feed.post',
				'record' => [
					'text' => $this->prepareDescription($content['description'] ?? ''),
					'createdAt' => date('c'),
					'$type' => 'app.bsky.feed.post'
				]
			];

			// Add link if post URL provided
			if (!empty($content['post_url'])) {
				$post_data['record']['text'] .= "\n\n" . $content['post_url'];
			}

			// Upload and attach image if provided
			if (!empty($content['image_path']) && file_exists($content['image_path'])) {
				$image_result = $this->uploadImage($content['image_path']);

				if ($image_result['success']) {
					$post_data['record']['embed'] = [
						'$type' => 'app.bsky.embed.images',
						'images' => [
							[
								'alt' => $content['title'] ?? 'Image',
								'image' => $image_result['blob']
							]
						]
					];
				}
			}

			// Post to BlueSky
			$response = $this->makeApiRequest('com.atproto.repo.createRecord', $post_data);

			if ($response['success']) {
				$this->log("Successfully posted to BlueSky", 'info');

				return [
					'success' => true,
					'platform_id' => $response['data']['uri'] ?? null,
					'post_url' => $this->getPostUrl($response['data']['uri'] ?? ''),
					'data' => $response['data']
				];
			}

			return [
				'success' => false,
				'error' => $response['error'] ?? 'Unknown error'
			];

		} catch (Exception $e) {
			$this->handleError($e);
			return [
				'success' => false,
				'error' => $e->getMessage()
			];
		}
	}

	/**
	 * Validate content before posting
	 */
	protected function validateContent(array $content): array
	{
		$errors = [];

		// Check description length
		if (isset($content['description']) && strlen($content['description']) > $this->max_description_length) {
			$errors[] = "Description exceeds {$this->max_description_length} characters";
		}

		// Check image if provided
		if (isset($content['image_path']) && $content['image_path']) {
			if (!file_exists($content['image_path'])) {
				$errors[] = "Image file does not exist";
			} else {
				$mime_type = mime_content_type($content['image_path']);
				$supported_types = ['image/jpeg', 'image/png', 'image/gif'];

				if (!in_array($mime_type, $supported_types)) {
					$errors[] = "Unsupported image type: {$mime_type}";
				}

				$file_size = filesize($content['image_path']);
				$max_size = 5242880; // 5MB
				if ($file_size > $max_size) {
					$errors[] = "Image too large: " . round($file_size / 1048576, 2) . "MB (max: 5MB)";
				}
			}
		}

		return $errors;
	}

	/**
	 * Prepare description with length limits
	 */
	protected function prepareDescription(string $description): string
	{
		if (strlen($description) <= $this->max_description_length) {
			return $description;
		}

		// Truncate intelligently at word boundaries
		$truncated = substr($description, 0, $this->max_description_length - 3);
		$last_space = strrpos($truncated, ' ');

		if ($last_space !== false) {
			$truncated = substr($truncated, 0, $last_space);
		}

		return $truncated . '...';
	}

	/**
	 * Upload image to BlueSky
	 */
	protected function uploadImage(string $image_path): array
	{
		try {
			$mime_type = mime_content_type($image_path);
			$image_data = file_get_contents($image_path);

			$response = wp_remote_post($this->api_base . 'com.atproto.repo.uploadBlob', [
				'headers' => [
					'Authorization' => 'Bearer ' . $this->access_token,
					'Content-Type' => $mime_type,
				],
				'body' => $image_data,
				'timeout' => 60
			]);

			if (is_wp_error($response)) {
				throw new Exception('Failed to upload image: ' . $response->get_error_message());
			}

			$body = json_decode(wp_remote_retrieve_body($response), true);
			$status_code = wp_remote_retrieve_response_code($response);

			if ($status_code === 200 && isset($body['blob'])) {
				return [
					'success' => true,
					'blob' => $body['blob']
				];
			}

			return [
				'success' => false,
				'error' => $body['message'] ?? 'Image upload failed'
			];

		} catch (Exception $e) {
			return [
				'success' => false,
				'error' => $e->getMessage()
			];
		}
	}

	/**
	 * Make API request to BlueSky
	 */
	private function makeApiRequest(string $endpoint, array $data): array
	{
		$response = wp_remote_post($this->api_base . $endpoint, [
			'headers' => [
				'Authorization' => 'Bearer ' . $this->access_token,
				'Content-Type' => 'application/json',
			],
			'body' => json_encode($data),
			'timeout' => 30
		]);

		if (is_wp_error($response)) {
			return [
				'success' => false,
				'error' => $response->get_error_message()
			];
		}

		$body = json_decode(wp_remote_retrieve_body($response), true);
		$status_code = wp_remote_retrieve_response_code($response);

		if ($status_code === 200) {
			return [
				'success' => true,
				'data' => $body
			];
		}

		return [
			'success' => false,
			'error' => $body['message'] ?? "HTTP {$status_code} error"
		];
	}

	/**
	 * Get post URL from BlueSky URI
	 */
	private function getPostUrl(string $uri): string
	{
		if (preg_match('/at:\/\/([^\/]+)\/app\.bsky\.feed\.post\/(.+)/', $uri, $matches)) {
			$did = $matches[1];
			$rkey = $matches[2];
			return "https://bsky.app/profile/{$did}/post/{$rkey}";
		}

		return '';
	}

	/**
	 * Disconnect user from this platform
	 */
	public function disconnectUser(int $user_id): bool
	{
		$key = "user_{$user_id}_{$this->service_name}";
		$credentials_manager = CredentialsManager::getInstance();
		return $credentials_manager->deleteCredentials($key);
	}

	/**
	 * Get display name for this platform
	 */
	public function getDisplayName(): string
	{
		return 'BlueSky';
	}

	/**
	 * Get icon name for this platform
	 */
	public function getIconName(): string
	{
		return 'fediverse'; // Using existing fediverse icon
	}

	/**
	 * Get supported post types
	 */
	public function getSupportedPostTypes(): array
	{
		return ['text', 'image', 'link'];
	}


	public function getServiceDescription(): string
	{
		return "Cross-post content to the BlueSky social network.";
	}

	protected function getRequestHeaders(): array
	{
		// TODO: Implement getRequestHeaders() method.
		return [];
	}

	protected function getApiUrl(string $endpoint, ?string $baseUrl = null): string
	{
		return 'https://bsky.social/xrpc/';
	}

	protected function processIntegrationAction(string $action, array $data):\WP_Error|array
	{
		return [];
	}
}