moko-platform/automation/push_manifest_xml.php

#!/usr/bin/env php
<?php

/**
 * Copyright (C) 2026 Moko Consulting <hello@mokoconsulting.tech>
 * SPDX-License-Identifier: GPL-3.0-or-later
 *
 * FILE INFORMATION
 * DEFGROUP: MokoPlatform.Automation
 * INGROUP: MokoPlatform
 * REPO: https://git.mokoconsulting.tech/MokoConsulting/moko-platform
 * PATH: /automation/push_manifest_xml.php
 * BRIEF: Push XML manifests to all governed repositories
 */

declare(strict_types=1);

require_once __DIR__ . '/../vendor/autoload.php';
require_once __DIR__ . '/../lib/Enterprise/CliFramework.php';

use MokoEnterprise\CliFramework;
use MokoEnterprise\MokoStandardsParser;

class PushManifestXmlCli extends CliFramework
{
    private const CRM_PLATFORM_REPOS = ['MokoDolibarr', 'MokoDoliMods'];

    protected function configure(): void
    {
        $this->setDescription('Push XML manifest.xml to all governed repositories');
        $this->addArgument('--repo', 'Filter to a single repo name', '');
        $this->addArgument('--skip', 'Comma-separated list of repos to skip', '');
        $this->addArgument('--force', 'Force overwrite even if already XML', false);
    }

    protected function run(): int
    {
        $giteaUrl  = rtrim(getenv('GITEA_URL') ?: 'https://git.mokoconsulting.tech', '/');
        $giteaOrg  = getenv('GITEA_ORG') ?: 'MokoConsulting';
        $token     = getenv('GA_TOKEN') ?: getenv('GH_TOKEN') ?: '';

        $force      = $this->getArgument('--force');
        $repoFilter = $this->getArgument('--repo') ?: null;
        $skipStr    = $this->getArgument('--skip');
        $skipRepos  = $skipStr !== '' ? array_map('trim', explode(',', $skipStr)) : [];

        $parser = new MokoStandardsParser();
        $tmpBase = sys_get_temp_dir() . '/moko-manifest-push-' . getmypid();

        echo "=== moko-platform XML Manifest Push ===\n";
        echo "Org: {$giteaOrg}\n";
        echo "Mode: " . ($this->dryRun ? "DRY RUN" : "LIVE") . "\n";
        if ($repoFilter) {
            echo "Filter: {$repoFilter}\n";
        }
        echo "\n";

        if (empty($token)) {
            $this->log('ERROR', 'GA_TOKEN or GH_TOKEN environment variable required');
            return 1;
        }

        $repos = $this->fetchRepos($giteaUrl, $giteaOrg, $token);
        echo "Found " . count($repos) . " repositories\n\n";

        $stats = ['created' => 0, 'updated' => 0, 'skipped' => 0, 'failed' => 0];

        foreach ($repos as $repo) {
            $name = $repo['name'];
            if ($repoFilter && $name !== $repoFilter) {
                continue;
            }
            if (in_array($name, $skipRepos, true)) {
                echo "  SKIP {$name} (excluded)\n";
                $stats['skipped']++;
                continue;
            }
            if ($repo['archived'] ?? false) {
                echo "  SKIP {$name} (archived)\n";
                $stats['skipped']++;
                continue;
            }

            $platform      = $this->detectPlatform($repo);
            $defaultBranch = $repo['default_branch'] ?? 'main';
            $httpsUrl = $repo['clone_url'] ?? "{$giteaUrl}/{$giteaOrg}/{$name}.git";
            $authedUrl = preg_replace('#^https://#', "https://gitea-actions:{$token}@", $httpsUrl);

            echo "  {$name} [{$platform}] ... ";

            // Generate XML manifest
            $xmlContent = $parser->generate([
                'name'              => $name,
                'org'               => $giteaOrg,
                'platform'          => $platform,
                'standards_version' => '04.07.00',
                'description'       => $repo['description'] ?? '',
                'license'           => 'GPL-3.0-or-later',
                'topics'            => $repo['topics'] ?? [],
                'language'          => $repo['language'] ?? MokoStandardsParser::platformLanguage($platform),
                'package_type'      => MokoStandardsParser::platformPackageType($platform),
                'last_synced'       => date('c'),
            ]);

            if ($this->dryRun) {
                echo "WOULD WRITE ({$platform})\n";
                $stats['created']++;
                continue;
            }

            // Clone shallow via HTTPS (token-authed)
            $workDir = "{$tmpBase}/{$name}";
            @mkdir($workDir, 0755, true);

            [$ret, $out] = $this->safeExec(
                'git clone --depth 1 --branch ' . escapeshellarg($defaultBranch) . ' '
                . escapeshellarg($authedUrl) . ' ' . escapeshellarg($workDir)
            );
            if ($ret !== 0) {
                echo "FAIL (clone)\n";
                fprintf(STDERR, "    %s\n", $out);
                $stats['failed']++;
                continue;
            }

            // Check if already XML and up-to-date
            $manifestPath = "{$workDir}/.mokogitea/manifest.xml";
            $existingIsXml = file_exists($manifestPath) && str_contains(file_get_contents($manifestPath), '<moko-platform');
            if ($existingIsXml && !$force) {
                $existingPlatform = $parser->extractPlatform(file_get_contents($manifestPath));
                if ($existingPlatform === $platform) {
                    echo "SKIP (already XML)\n";
                    $stats['skipped']++;
                    $this->rmTree($workDir);
                    continue;
                }
            }

            // Write manifest
            @mkdir("{$workDir}/.gitea", 0755, true);
            file_put_contents($manifestPath, $xmlContent);

            // Delete legacy files if present
            $legacyDeleted = [];
            foreach (['.mokostandards', '.github/.mokostandards', '.gitea/.mokostandards', '.mokogitea/.mokostandards'] as $legacy) {
                $legacyPath = "{$workDir}/{$legacy}";
                if (file_exists($legacyPath)) {
                    unlink($legacyPath);
                    $legacyDeleted[] = $legacy;
                }
            }

            // Commit
            $isNew = !$existingIsXml;
            $commitMsg = $isNew
                ? 'chore: add XML manifest.xml'
                : 'chore: update manifest.xml';
            if (!empty($legacyDeleted)) {
                $commitMsg .= "\n\nRemoved legacy: " . implode(', ', $legacyDeleted);
            }

            $this->gitCmd($workDir, 'config', 'user.name', 'gitea-actions[bot]');
            $this->gitCmd($workDir, 'config', 'user.email', 'gitea-actions[bot]@git.mokoconsulting.tech');
            $this->gitCmd($workDir, 'add', '.mokogitea/manifest.xml');
            foreach ($legacyDeleted as $lf) {
                $this->gitCmd($workDir, 'add', $lf);
            }

            [$commitRet, $commitOut] = $this->gitCmd($workDir, 'commit', '-m', $commitMsg);
            if ($commitRet !== 0 && str_contains($commitOut, 'nothing to commit')) {
                echo "SKIP (no changes)\n";
                $stats['skipped']++;
                $this->rmTree($workDir);
                continue;
            }
            if ($commitRet !== 0) {
                echo "FAIL (commit)\n";
                fprintf(STDERR, "    %s\n", $commitOut);
                $stats['failed']++;
                $this->rmTree($workDir);
                continue;
            }

            [$pushRet, $pushOut] = $this->gitCmd($workDir, 'push', 'origin', $defaultBranch);
            if ($pushRet !== 0) {
                echo "FAIL (push)\n";
                fprintf(STDERR, "    %s\n", $pushOut);
                $stats['failed']++;
            } else {
                $action = $isNew ? 'CREATED' : 'UPDATED';
                echo "{$action}\n";
                $stats[$isNew ? 'created' : 'updated']++;
            }

            // Cleanup
            $this->rmTree($workDir);
        }

        // Cleanup tmp base
        @rmdir($tmpBase);

        echo "\n=== Summary ===\n";
        echo "Created: {$stats['created']}\n";
        echo "Updated: {$stats['updated']}\n";
        echo "Skipped: {$stats['skipped']}\n";
        echo "Failed:  {$stats['failed']}\n";

        return 0;
    }

    private function detectPlatform(array $repo): string
    {
        $name = $repo['name'] ?? '';
        $nameLower = strtolower($name);
        $description = strtolower($repo['description'] ?? '');
        $topics = $repo['topics'] ?? [];

        if (in_array($name, self::CRM_PLATFORM_REPOS, true)) {
            return 'crm-platform';
        }
        if (in_array('dolibarr-platform', $topics)) {
            return 'crm-platform';
        }
        if (in_array('joomla-template', $topics)) {
            return 'joomla-template';
        }
        if (in_array('joomla', $topics) || in_array('joomla-extension', $topics)) {
            return 'waas-component';
        }
        if (in_array('dolibarr', $topics) || in_array('dolibarr-module', $topics)) {
            return 'crm-module';
        }

        if (str_contains($nameLower, 'template') && (str_contains($nameLower, 'joomla') || str_contains($nameLower, 'tpl'))) {
            return 'joomla-template';
        }
        if (str_contains($nameLower, 'joomla') || str_contains($nameLower, 'waas')) {
            return 'waas-component';
        }
        if (str_contains($nameLower, 'doli') || str_contains($nameLower, 'crm')) {
            return 'crm-module';
        }

        if (str_contains($description, 'joomla template')) {
            return 'joomla-template';
        }
        if (str_contains($description, 'joomla') || str_contains($description, 'component')) {
            return 'waas-component';
        }
        if (str_contains($description, 'dolibarr') || str_contains($description, 'module')) {
            return 'crm-module';
        }

        if (str_contains($nameLower, 'standard')) {
            return 'standards-repository';
        }
        return 'default-repository';
    }

    /**
     * @return array{int, string}
     */
    private function safeExec(string $command, string $cwd = '.'): array
    {
        $proc = proc_open(
            $command,
            [1 => ['pipe', 'w'], 2 => ['pipe', 'w']],
            $pipes,
            $cwd
        );
        if (!is_resource($proc)) {
            return [1, "proc_open failed for: {$command}"];
        }
        $stdout = stream_get_contents($pipes[1]);
        $stderr = stream_get_contents($pipes[2]);
        fclose($pipes[1]);
        fclose($pipes[2]);
        $code = proc_close($proc);
        return [$code, trim($stdout . "\n" . $stderr)];
    }

    private function rmTree(string $dir): void
    {
        if (!is_dir($dir)) {
            return;
        }
        $it = new \RecursiveDirectoryIterator($dir, \FilesystemIterator::SKIP_DOTS);
        $files = new \RecursiveIteratorIterator($it, \RecursiveIteratorIterator::CHILD_FIRST);
        foreach ($files as $file) {
            if ($file->isDir()) {
                @rmdir($file->getPathname());
            } else {
                @chmod($file->getPathname(), 0777);
                @unlink($file->getPathname());
            }
        }
        @rmdir($dir);
    }

    /**
     * @return array{int, string}
     */
    private function gitCmd(string $workDir, string ...$args): array
    {
        $cmd = 'git';
        foreach ($args as $a) {
            $cmd .= ' ' . escapeshellarg($a);
        }
        return $this->safeExec($cmd, $workDir);
    }

    private function fetchRepos(string $url, string $org, string $token): array
    {
        $repos = [];
        $page = 1;
        do {
            $ch = curl_init("{$url}/api/v1/orgs/{$org}/repos?page={$page}&limit=50");
            curl_setopt_array($ch, [
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_HTTPHEADER => ["Authorization: token {$token}"],
                CURLOPT_TIMEOUT => 30,
            ]);
            $body = curl_exec($ch);
            $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            curl_close($ch);

            if ($code !== 200) {
                $this->log('ERROR', "API error (HTTP {$code}) fetching repos page {$page}");
                break;
            }

            $batch = json_decode($body, true);
            if (empty($batch)) {
                break;
            }
            $repos = array_merge($repos, $batch);
            $page++;
        } while (count($batch) >= 50);

        return $repos;
    }
}

$app = new PushManifestXmlCli();
exit($app->execute());