<?php
declare(strict_types=1);

defined( 'ABSPATH' ) || exit;

/** Unregistered one-attempt orchestration. No built-in HTTP, scheduler, URL, or credentials.
 * Caller must authorize the request and independently supply transport and key configuration.
 * Transport receives ONLY the immutable body; it must be bounded/idempotent in the future adapter.
 */
// phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals.NonPrefixedClassFound -- OG_ prefix kept for 0.3.0 by owner decision; namespace move planned for 0.3.x
final class OG_Native_Sending_Worker {
    public static function once(OG_Privacy_Case_Store $store,array $context,int $requestId,callable $transport,array $keys,string $environment='production',array $history=array(),array $revoked=array()): array {
        $claim=$store->nativeSendAttempt($context,$requestId,'claim','',$keys,$environment,$history,$revoked);
        if(($claim['status']??null)!=='native_attempt_claim'){return $claim;}
        $mark=$store->nativeSendAttempt($context,$requestId,'mark',$claim['token'],$keys,$environment,$history,$revoked);
        if(($mark['status']??null)!=='native_attempt_mark'){return $mark;}
        // The transaction has committed and its handle has closed before transport.
        try {$body=$transport($mark['payload']);}catch(Throwable $e){$body=null;}
        $outcome=$store->observeNativeRemoteOutcome($context,$requestId,$body,$keys,$environment,$history,$revoked);
        $attempt=$store->nativeSendAttempt($context,$requestId,'settle',$claim['token'],$keys,$environment,$history,$revoked);
        return array('status'=>'native_worker_observed','outcome'=>$outcome,'attempt'=>$attempt,'erasure_complete'=>false);
    }
}