package agent_execution_test

import (
	"os"
	"strings"
	"testing"
)

func TestWorkerRecoveryAndClaimUseDurableQueueStatements(t *testing.T) {
	data, err := os.ReadFile("../../adapters/postgres/work_repository.go")
	if err != nil {
		t.Fatal(err)
	}
	source := string(data)
	for _, marker := range []string{"FOR UPDATE SKIP LOCKED", "state='CLAIMED'", "state='QUEUED'", "RecoverStaleClaims"} {
		if !strings.Contains(source, marker) {
			t.Fatalf("worker persistence marker missing: %s", marker)
		}
	}
}