check_feed.php

<?php

use Symfony\Component\Dotenv\Dotenv;
use SellingPartnerApi\Api\FeedsV20210630Api;

require __DIR__ . '/vendor/autoload.php';

$dotenv = new Dotenv();
$dotenv->load(__DIR__ . '/.env');

// Feed ID to check
$feedId = $argv[1] ?? null;
$detailed = in_array('--detailed', $argv) || in_array('-d', $argv);

if (!$feedId) {
    echo "❌ You must provide a Feed ID\n";
    echo "Usage: php check_feed.php [feedId] [--detailed]\n";
    echo "Example: php check_feed.php 558685020293\n";
    echo "Example: php check_feed.php 558685020293 --detailed\n";
    echo "\nOptions:\n";
    echo "  --detailed, -d    Download and show detailed report results\n";
    exit(1);
}

// Amazon Configuration
$amazonRefresh = $_ENV['AMAZON_REFRESH_TOKEN'];
$amazonClientId = $_ENV['AMAZON_CLIENT_ID'];
$amazonClientSecret = $_ENV['AMAZON_CLIENT_SECRET'];
$amazonAccessKey = $_ENV['AMAZON_ACCESS_KEY'];
$amazonSecretKey = $_ENV['AMAZON_SECRET_KEY'];
$amazonRoleArn = $_ENV['AMAZON_ROLE_ARN'];

$config = new SellingPartnerApi\Configuration([
    'lwaClientId' => $amazonClientId,
    'lwaClientSecret' => $amazonClientSecret,
    'lwaRefreshToken' => $amazonRefresh,
    'awsAccessKeyId' => $amazonAccessKey,
    'awsSecretAccessKey' => $amazonSecretKey,
    'endpoint' => SellingPartnerApi\Endpoint::EU,
    'roleArn' => $amazonRoleArn,
]);

try {
    $feedsApi = new FeedsV20210630Api($config);

    echo "🔍 Checking Feed ID: {$feedId}\n";
    echo str_repeat("=", 60) . "\n";

    // Get feed information
    $feed = $feedsApi->getFeed($feedId);

    $status = $feed->getProcessingStatus();
    $feedType = $feed->getFeedType();
    $createdTime = $feed->getCreatedTime();
    $marketplaces = implode(', ', $feed->getMarketplaceIds());

    echo "📋 Feed Type: {$feedType}\n";
    echo "📅 Created: {$createdTime}\n";
    echo "🌍 Marketplaces: {$marketplaces}\n";
    echo "\n";

    // Show status with emojis
    switch ($status) {
        case 'DONE':
            echo "✅ Status: COMPLETED SUCCESSFULLY\n";
            if ($feed->getProcessingStartTime()) {
                echo "⏰ Processing started: " . $feed->getProcessingStartTime() . "\n";
            }
            if ($feed->getProcessingEndTime()) {
                echo "⏰ Processing ended: " . $feed->getProcessingEndTime() . "\n";
            }
            if ($feed->getResultFeedDocumentId()) {
                echo "📄 Result document ID: " . $feed->getResultFeedDocumentId() . "\n";
            }
            echo "\n🎉 Your feed was processed successfully!\n";

            // Handle detailed report if requested and available
            if ($detailed && $feed->getResultFeedDocumentId()) {
                echo "\n" . str_repeat("-", 50) . "\n";
                echo "📊 Downloading detailed report...\n";

                try {
                    $resultDocumentId = $feed->getResultFeedDocumentId();
                    $resultDocument = $feedsApi->getFeedDocument($resultDocumentId);

                    // Download report content
                    $document = new SellingPartnerApi\Document($resultDocument, ['contentType' => 'application/json']);
                    $reportContent = $document->download();

                    echo "\n=== DETAILED REPORT ===\n";

                    // Try to parse and format JSON
                    $reportData = json_decode($reportContent, true);
                    if ($reportData) {
                        echo "📈 Summary:\n";
                        if (isset($reportData['summary'])) {
                            $summary = $reportData['summary'];
                            echo "  • Messages processed: " . ($summary['messagesProcessed'] ?? 'N/A') . "\n";
                            echo "  • Messages accepted: " . ($summary['messagesAccepted'] ?? 'N/A') . "\n";
                            echo "  • Messages invalid: " . ($summary['messagesInvalid'] ?? 'N/A') . "\n";
                            echo "  • Errors: " . ($summary['errors'] ?? 'N/A') . "\n";
                            echo "  • Warnings: " . ($summary['warnings'] ?? 'N/A') . "\n";
                        }

                        if (isset($reportData['issues']) && count($reportData['issues']) > 0) {
                            echo "\n⚠️ Issues found:\n";
                            foreach ($reportData['issues'] as $issue) {
                                $code = $issue['code'] ?? 'Unknown';
                                $message = $issue['message'] ?? 'No message';
                                $severity = $issue['severity'] ?? 'Unknown';

                                $severityIcon = match($severity) {
                                    'ERROR' => '❌',
                                    'WARNING' => '⚠️',
                                    'INFO' => 'ℹ️',
                                    default => '❓'
                                };

                                echo "  {$severityIcon} [{$severity}] {$code}: {$message}\n";
                            }
                        } else {
                            echo "\n✅ No issues found in the report.\n";
                        }

                        // Save report to file
                        $reportFileName = "feeds/feed_report_{$feedId}_" . date('Y-m-d_H-i-s') . ".json";
                        file_put_contents($reportFileName, json_encode($reportData, JSON_PRETTY_PRINT));
                        echo "\n📁 Full report saved to: {$reportFileName}\n";

                    } else {
                        echo $reportContent . "\n";
                    }

                } catch (Exception $e) {
                    echo "❌ Error downloading report: " . $e->getMessage() . "\n";
                }
            }
            break;

        case 'IN_QUEUE':
            echo "⏳ Status: IN QUEUE - Waiting for processing\n";
            echo "💡 Check again in a few minutes...\n";
            break;

        case 'IN_PROGRESS':
            echo "⚙️ Status: IN PROGRESS\n";
            if ($feed->getProcessingStartTime()) {
                echo "⏰ Started: " . $feed->getProcessingStartTime() . "\n";
            }
            echo "💡 Processing is in progress...\n";
            break;

        case 'FATAL':
            echo "❌ Status: FATAL ERROR\n";
            echo "⚠️ The feed failed during processing\n";
            if ($feed->getResultFeedDocumentId()) {
                echo "📄 Error report available: " . $feed->getResultFeedDocumentId() . "\n";

                if ($detailed) {
                    echo "\n" . str_repeat("-", 50) . "\n";
                    echo "📊 Downloading error report...\n";

                    try {
                        $resultDocumentId = $feed->getResultFeedDocumentId();
                        $resultDocument = $feedsApi->getFeedDocument($resultDocumentId);

                        $document = new SellingPartnerApi\Document($resultDocument, ['contentType' => 'application/json']);
                        $reportContent = $document->download();

                        echo "\n=== ERROR REPORT ===\n";
                        echo $reportContent . "\n";

                        // Save error report
                        $errorFileName = "feeds/feed_error_{$feedId}_" . date('Y-m-d_H-i-s') . ".json";
                        file_put_contents($errorFileName, $reportContent);
                        echo "\n📁 Error report saved to: {$errorFileName}\n";

                    } catch (Exception $e) {
                        echo "❌ Error downloading error report: " . $e->getMessage() . "\n";
                    }
                }
            }
            break;

        case 'CANCELLED':
            echo "🚫 Status: CANCELLED\n";
            break;

        default:
            echo "❓ Status: {$status}\n";
    }

    echo "\n" . str_repeat("=", 60) . "\n";
    echo "📚 Possible statuses:\n";
    echo "• IN_QUEUE: Waiting for processing\n";
    echo "• IN_PROGRESS: Being processed\n";
    echo "• DONE: Completed successfully\n";
    echo "• CANCELLED: Cancelled\n";
    echo "• FATAL: Fatal error during processing\n";
    echo "\n💡 Use --detailed flag to download and view reports when available\n";

} catch (Exception $e) {
    echo "❌ Error: " . $e->getMessage() . "\n";
    echo "📁 File: " . $e->getFile() . " Line: " . $e->getLine() . "\n";
}