<?php
require __DIR__.'/../vendor/autoload.php';
$app=require __DIR__.'/../bootstrap/app.php'; $app->make(\Illuminate\Contracts\Console\Kernel::class)->bootstrap();
\App\Modules\Workshop\WorkshopWorkflow::guard();
$in=json_decode(stream_get_contents(STDIN),true,32,JSON_THROW_ON_ERROR);
app(\App\Shared\Context\CompanyContext::class)->selectFor($in['actor'],$in['tenant'],$in['company'],$in['unit']);
if($in['pause']??false) {
 $paused=false;\Illuminate\Support\Facades\DB::listen(function($q)use(&$paused){if(!$paused&&str_contains($q->sql,'"companies"')&&str_contains($q->sql,'for update')){$paused=true;echo "LOCK_HELD\n";flush();usleep(1200000);}});
}
try {
 $w=app(\App\Modules\Workshop\WorkshopWorkflow::class);
 if($in['method']==='sql') {
  $out=\Illuminate\Support\Facades\DB::transaction(function()use($in){if($in['pause']??false)\Illuminate\Support\Facades\DB::table('companies')->where('id',$in['company'])->lockForUpdate()->firstOrFail();return ['id'=>\Illuminate\Support\Facades\DB::table('wo_entries')->insertGetId($in['sql'])];});
 } elseif($in['method']==='open') $out=$w->open($in['actor'],$in['input'],$in['key']);
 else $out=$w->{$in['method']}($in['id'],$in['actor'],$in['input'],$in['key']);
 echo json_encode(['status'=>200,'result'=>$out],JSON_THROW_ON_ERROR).PHP_EOL;
} catch(\Symfony\Component\HttpKernel\Exception\HttpExceptionInterface $e){echo json_encode(['status'=>$e->getStatusCode()],JSON_THROW_ON_ERROR).PHP_EOL;}
catch(\Illuminate\Database\QueryException $e){if(!str_contains($e->getMessage(),'SGF_WO_'))throw $e;echo json_encode(['status'=>409,'database_guard'=>true],JSON_THROW_ON_ERROR).PHP_EOL;}