[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_228":-5,"_231":232,"_233":234},"routes/shell",{"_41":42,"_227":-5,"_228":-5,"_229":230},"routes/repo",{"_34":-7,"_35":36,"_37":38,"_39":40,"_41":42,"_43":32,"_44":32,"_45":32,"_46":32,"_47":32,"_48":32,"_49":50,"_51":50,"_52":32,"_53":-7,"_54":-7,"_55":56,"_57":58,"_59":60,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5,"_26":27,"_28":29,"_29":30,"_31":32,"_33":14},"ref","main","path","apps/server/src/jobs/service.ts","oid","e8c782b70c690a2ff1e4fedc1266efe213315c17","size",17684,"commit","2182c95de44a8f63fd86af1c5874ae0ca298f807","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import type {\n\tBackgroundJob,\n\tBackgroundJobArtifact,\n\tBackgroundJobCursor,\n\tBackgroundJobDetail,\n\tBackgroundJobOrigin,\n\tBackgroundJobProgress,\n\tBackgroundJobState,\n\tBackgroundJobSummary,\n\tBackgroundJobTarget,\n\tClaimedBackgroundJob,\n\tJsonValue,\n\tLease,\n} from \"../storage/model\";\nimport type { StorageAdapter } from \"../storage/port\";\nimport type { JobDefinition, JobRegistry } from \"./registry\";\n\nexport type JobServiceErrorCode =\n\t| \"invalid-request\"\n\t| \"origin-forbidden\"\n\t| \"unknown-job-type\"\n\t| \"unregistered-version\";\n\nexport class JobServiceError extends Error {\n\treadonly code: JobServiceErrorCode;\n\n\tconstructor(code: JobServiceErrorCode, message: string, options?: ErrorOptions) {\n\t\tsuper(message, options);\n\t\tthis.name = \"JobServiceError\";\n\t\tthis.code = code;\n\t}\n}\n\nexport type EnqueueJob = {\n\tchannelId: string;\n\ttype: string;\n\ttargetKey: string;\n\tidempotencyKey: string;\n\tinput: JsonValue;\n\tavailableAt?: Date;\n};\n\nexport type JobMutation = {\n\tchannelId: string;\n\tjobId: string;\n\texpectedRevision: number;\n};\n\nexport type JobIdentity = Pick;\n\nexport type SettleJob = Omit & {\n\tartifact: JsonValue;\n\tguard?: () => Promise;\n};\n\nexport type JobView = {\n\tid: string;\n\tchannelId: string;\n\ttype: string;\n\tversion: number;\n\torigin: BackgroundJobOrigin;\n\ttargetKey: string;\n\ttargetGeneration: number;\n\tstate: BackgroundJobState;\n\trevision: number;\n\tattempts: number;\n\tfailures: number;\n\tavailableAt: Date;\n\treason: string | undefined;\n\tprogress: BackgroundJobProgress[];\n\tcreatedAt: Date;\n\tupdatedAt: Date;\n\tsubject?: string;\n};\n\nexport type JobPage = {\n\trevision: number;\n\tjobs: JobView[];\n\tnext?: BackgroundJobCursor;\n};\n\nexport type JobDetail = {\n\trevision: number;\n\ttarget: BackgroundJobTarget;\n\tjob: JobView;\n\tartifact: BackgroundJobArtifact | undefined;\n};\n\nexport type JobServiceOptions = {\n\tstorage: StorageAdapter;\n\tregistry: JobRegistry;\n\tlease: () => Lease;\n\tnow?: () => Date;\n\tid?: () => string;\n\tpublish?: (channelId: string) => void | Promise;\n\tonChange?: (job: JobView) => void;\n\tpublishTimeoutMs?: number;\n\thookTimeoutMs?: number;\n};\n\nconst MAX_TARGET_KEY = 512;\nconst MAX_IDEMPOTENCY_KEY = 128;\nconst MAX_REASON = 512;\nconst MAX_JSON_DEPTH = 64;\n\nfunction requestText(value: unknown, field: string, maximum: number): asserts value is string {\n\tif (typeof value !== \"string\" || !value || value.length > maximum) {\n\t\tthrow new JobServiceError(\n\t\t\t\"invalid-request\",\n\t\t\t`Background job ${field} must contain between 1 and ${maximum} characters.`,\n\t\t);\n\t}\n}\n\nfunction canonical(\n\tvalue: unknown,\n\tmaximum: number,\n\tfield: string,\n): { value: JsonValue; source: string } {\n\tlet chunks: string[] = [];\n\tlet size = 0;\n\tlet encoder = new TextEncoder();\n\tlet ancestors = new Set