moko-platform/lib/Enterprise/PlatformAdapterFactory.php

<?php
/* Copyright (C) 2026 Moko Consulting <hello@mokoconsulting.tech>
 *
 * This file is part of a Moko Consulting project.
 *
 * SPDX-License-Identifier: GPL-3.0-or-later
 *
 * FILE INFORMATION
 * DEFGROUP: MokoStandards.Enterprise.Platform
 * INGROUP: MokoStandards.Enterprise
 * REPO: https://git.mokoconsulting.tech/MokoConsulting/moko-platform
 * PATH: /lib/Enterprise/PlatformAdapterFactory.php
 * BRIEF: Factory for creating platform-specific GitPlatformAdapter instances
 */

declare(strict_types=1);

namespace MokoEnterprise;

use RuntimeException;

/**
 * Factory for creating GitPlatformAdapter instances.
 *
 * Reads GIT_PLATFORM env var (default: 'github') and constructs
 * the appropriate adapter with correct base URL, auth scheme, and token.
 *
 * Usage:
 * ```php
 * $config = Config::load();
 * $adapter = PlatformAdapterFactory::create($config);
 * $repos = $adapter->listOrgRepos('mokoconsulting-tech');
 * ```
 *
 * @package MokoStandards\Enterprise
 * @version 04.06.10
 */
class PlatformAdapterFactory
{
	/**
	 * Create a GitPlatformAdapter based on configuration.
	 *
	 * @param Config $config Configuration instance
	 * @param string|null $platformOverride Force a specific platform ('github' or 'gitea')
	 * @return GitPlatformAdapter The constructed adapter
	 * @throws RuntimeException If the platform is not supported or token is missing
	 */
	public static function create(Config $config, ?string $platformOverride = null): GitPlatformAdapter
	{
		$platform = $platformOverride ?? $config->getString('platform', 'gitea');

		return match ($platform) {
			'github' => self::createGitHubAdapter($config),
			'gitea'  => self::createGiteaAdapter($config),
			default  => throw new RuntimeException("Unsupported git platform: {$platform}. Use 'github' or 'gitea'."),
		};
	}

	/**
	 * Create a GitHubAdapter with configured ApiClient.
	 *
	 * @param Config $config Configuration instance
	 * @return GitHubAdapter Configured GitHub adapter
	 * @throws RuntimeException If GitHub token is not available
	 */
	private static function createGitHubAdapter(Config $config): GitHubAdapter
	{
		$token = $config->getString('github.token', '');
		if (empty($token)) {
			throw new RuntimeException(
				'GitHub token not found. Set GH_TOKEN, GITHUB_TOKEN, or authenticate with `gh auth login`.'
			);
		}

		$apiClient = new ApiClient(
			baseUrl: 'https://git.mokoconsulting.tech/api/v1',
			authToken: $token,
			maxRequestsPerHour: $config->getInt('github.rate_limit', 5000),
			maxRetries: $config->getInt('github.max_retries', 3),
			authScheme: 'Bearer'
		);

		return new GitHubAdapter($apiClient);
	}

	/**
	 * Create a GiteaAdapter with configured ApiClient.
	 *
	 * @param Config $config Configuration instance
	 * @return GiteaAdapter Configured Gitea adapter
	 * @throws RuntimeException If Gitea token is not available
	 */
	private static function createGiteaAdapter(Config $config): GiteaAdapter
	{
		$token = $config->getString('gitea.token', '');
		if (empty($token)) {
			throw new RuntimeException(
				'Gitea token not found. Set GA_TOKEN environment variable.'
			);
		}

		$giteaUrl = $config->getString('gitea.url', 'https://git.mokoconsulting.tech');
		$apiBaseUrl = rtrim($giteaUrl, '/') . '/api/v1';

		$apiClient = new ApiClient(
			baseUrl: $apiBaseUrl,
			authToken: $token,
			maxRequestsPerHour: $config->getInt('gitea.rate_limit', 5000),
			maxRetries: $config->getInt('gitea.max_retries', 3),
			authScheme: 'token'
		);

		return new GiteaAdapter($apiClient, $apiBaseUrl);
	}

	/**
	 * Create adapters for both platforms (useful during migration).
	 *
	 * @param Config $config Configuration instance
	 * @return array{github: GitHubAdapter, gitea: GiteaAdapter} Both adapters
	 * @throws RuntimeException If either token is missing
	 */
	public static function createBoth(Config $config): array
	{
		return [
			'github' => self::createGitHubAdapter($config),
			'gitea'  => self::createGiteaAdapter($config),
		];
	}

	/**
	 * Sync a file between Gitea (primary) and GitHub (mirror) for a given repo.
	 *
	 * Reads the file from Gitea and pushes it to GitHub, ensuring both platforms
	 * serve identical content. Commonly used for updates.xml sync after releases.
	 *
	 * @param Config $config Configuration instance
	 * @param string $repo Repository name
	 * @param string $branch Branch to sync (default: 'main')
	 * @param string $filePath Path to the file (default: 'updates.xml')
	 * @return bool True if sync succeeded or file was already identical
	 * @throws RuntimeException If either platform is unreachable
	 */
	public static function syncUpdatesBetweenPlatforms(
		Config $config,
		string $repo,
		string $branch = 'main',
		string $filePath = 'updates.xml'
	): bool {
		$adapters = self::createBoth($config);
		$giteaOrg = $config->getString('gitea.organization', 'mokoconsulting-tech');
		$githubOrg = $config->getString('github.organization', 'mokoconsulting-tech');

		// Read from Gitea (primary)
		try {
			$giteaFile = $adapters['gitea']->getFileContents($giteaOrg, $repo, $filePath, $branch);
		} catch (\Exception $e) {
			throw new RuntimeException("Failed to read {$filePath} from Gitea ({$giteaOrg}/{$repo}): " . $e->getMessage());
		}

		$giteaContent = base64_decode($giteaFile['content'] ?? '');
		if (empty($giteaContent)) {
			return false;
		}

		// Read from GitHub (mirror) to check if update is needed
		$githubSha = null;
		try {
			$githubFile = $adapters['github']->getFileContents($githubOrg, $repo, $filePath, $branch);
			$githubContent = base64_decode($githubFile['content'] ?? '');
			$githubSha = $githubFile['sha'] ?? null;

			if ($githubContent === $giteaContent) {
				return true;
			}
		} catch (\Exception $e) {
			$adapters['github']->getApiClient()->resetCircuitBreaker();
		}

		$adapters['github']->createOrUpdateFile(
			$githubOrg,
			$repo,
			$filePath,
			$giteaContent,
			"chore(sync): sync {$filePath} from Gitea primary",
			$githubSha,
			$branch
		);

		return true;
	}
}