Drive DOTS Desk from your own code
The page reads the pasted C# of one Unity DOTS feature in the browser for free — one or more
files joined into one paste, each introduced by a // file: <path> line — with
its line numbers. It lexes strings (verbatim, interpolated and both), char literals, comments and
preprocessor lines out first, rebuilds the brace structure (types, methods, foreach loops,
lambdas, object initializers), classifies every type by what it implements
(IComponentData, IBufferElementData, ISharedComponentData,
ISystem, SystemBase, IJobEntity, IJob,
IJobParallelFor, IJobFor, IJobChunk, IAspect,
Baker<T>), reads every field with its attributes, decides which methods Burst
compiles, and follows every job instance to its schedule call and what happens to its
JobHandle, every native allocation to its Dispose, every hand-made
EntityCommandBuffer to its Playback, and every structural change to where it
happens. Then it runs 21 deterministic checks drawn from Entities 1.x practice (catalogue ids
DK-01..DK-21, plus DK-22 for context): systems, jobs and aspects that are not partial,
managed fields in unmanaged components and jobs, managed calls (UnityEngine.Time,
UnityEngine.Random, GameObject, managed collections, strings) in
Burst-compiled code, code that could be Burst compiled and is not, API removed in Entities 1.0,
SystemAPI outside a system, dropped JobHandles, containers disposed while a job may still
use them, EntityManager or a plain command buffer in a parallel job, constant
ParallelWriter sort keys, lookups cached in OnCreate and never updated,
missing [ReadOnly], Complete() right after scheduling, structural changes
inside a SystemAPI.Query loop, command buffers never played back or disposed, toggled tag
components, singletons read without RequireForUpdate, native allocations never disposed,
Allocator.Temp memory passed to a job, Unity.Mathematics.Random seeded with
zero, and legacy IAspect or Entities.ForEach code. Nothing is compiled or run,
and it is not the Unity Editor, the Burst compiler or the safety system: every flag is a reading of the
text. Its two paid steps are available over HTTP. You send one JSON object with task set
to "audit" or "fix", the paste as code and the page’s
check as a facts string, and the model replies with one JSON object: an audit that rates
the four areas, answers every flag and gives exact before/after edits per finding, or the whole fixed
file(s) with a list of every change tied to the page’s flags.
Base URL: https://api.skillsafe.ai/v1/app-api. Every call sends
Content-Type: application/json and, once you have a token,
Authorization: Bearer <token>. The paths below (/guest,
/me, /estimate, /run, /jobs/{job_id},
/run-stream) are relative to it, exactly as sdk.js calls them. A
plain-text summary of the app for agents is at /llms.txt. Both lanes run on
the gpt-terra model with a 10% publisher markup. A run needs a signed-in (user) token and
is metered: the platform places a hold on your credits when the run starts and then
charges only what the run used. /estimate is free.
The response envelope
Responses are JSON of the form {"ok": ..., "data": ..., "error": {...}}. The page’s
SDK (sdk.js) decides success from the HTTP status, not from ok: on a
2xx it returns data; otherwise it raises an error whose message is
error.message (or the HTTP status text when the body carries none), with
status, code (error.code) and details
(error.details) attached. A body that is not JSON is treated as {}.
{ "ok": true, "data": { ... } }
{ "ok": false, "error": { "code": "...", "message": "...", "details": { ... } } }
Error codes
Branch on the HTTP status and error.code, show error.message. The page
handles 401 and 402 by name; the rest reach it as a generic failure (“The run failed: ...”).
| HTTP | error.code | What it means / what to do |
|---|---|---|
400 | VALIDATION_ERROR | The body is not a JSON object, a required field (task, code, facts) is missing, or a declared field has the wrong type. Every field is a string; sending facts or audit_handoff as an object is the usual cause. |
401 | UNAUTHORIZED | No token, or one that expired or was revoked. The page forgets the signed-in user and says “Your session expired - sign in again.” Get a new token. |
402 | INSUFFICIENT_CREDITS | The balance cannot cover the run. The page says “Not enough credits for this run.” with a top-up link, and tries never to submit into a 402: it disables the run button when the /me balance is below the estimate’s min_credits. |
404 | NOT_FOUND | A wrong path, or a job id that does not belong to this token. |
409 | CONFLICT | An Idempotency-Key replayed with a different body. Send the original body, or use a new key (the page bumps its :a<attempt> suffix for a retry). |
429 | RATE_LIMITED | Too many requests. Back off with a delay; do not tight-loop, and never resend a metered run without its original Idempotency-Key. |
Failures that do not arrive as an HTTP status:
| What | What happens |
|---|---|
event: error on /run-stream | The SDK raises an error carrying the event’s message, code and job_id. |
Job status: "failed" | Polling stops; the job’s error field says why. |
| Polling past 180 s | The SDK’s own client-side limit (waitForJob, 1 s interval, 180 000 ms default): it throws “job timed out”. The job itself is not cancelled. |
The task field: two lanes
task routes the run, and it takes exactly two values: "audit" and
"fix". Each lane has its own reply contract, and a reply never mixes them. The
skill’s instructions tell the model to do the audit lane when task is missing or
anything else (and the page’s own Dotskit.buildInput turns any lane that is not
"fix" into "audit"), so a typo silently gets you an audit: always send one of
the two values.
task | What it does | verdict | Use it when |
|---|---|---|---|
"audit" | Reviews the code the way a senior Unity DOTS engineer reviews a feature before it goes into a build with Burst and the safety checks on: says what the feature does, its systems and jobs and what runs in parallel, rates the four areas (burst, jobs, structural, memory) as sound, fragile or broken, confirms or dismisses every page flag, adds what text rules cannot see, and gives the verbatim evidence and exact before/after edits for each finding, listed in the order to apply them — what stops the build first (partial, removed API, managed fields, SystemAPI outside a system), then what fails Burst or throws in the safety checks, then leaks and stalls, then hygiene — with a plan that ends in compiling with Burst and Jobs > Burst > Safety Checks on, entering Play mode, and opening the Burst Inspector and the Profiler. | blocked | needs_work | ready | Before a build: does it compile and does Burst accept it, do its jobs keep their handles and read their data safely, does it change structure while iterating, does it free its native memory, and what should change first. |
"fix" | Writes the fixed version of the pasted code: the whole of every file it changes (never a new file), with structural changes moved into an entity command buffer, every JobHandle kept (normally in state.Dependency), containers disposed on the job’s handle, [ReadOnly], partial, [BurstCompile] and RequireForUpdate added where they belong, managed fields made unmanaged and managed calls moved out of Burst code — plus a changes list tied to the page flags, the verify steps (compile with Burst and safety checks on, Play mode with the Console clear, and the check that would have caught the worst problem), and what it left open. No type, component field, public method or update-group attribute is renamed or removed unless the note asks for it. | fixed | partial | When you want the code changed, not a list of findings: a feature you already know throws, or what is left after an audit. |
The page chains the two: after an audit, “Apply every edit and fix the rest” puts
every audit edit into the paste, switches to the fix lane on that edited paste and adds an
audit_handoff string (below) with the audit’s verdict, headline and findings. Over
the API that is a second run with task: "fix", the edited paste as code,
facts recomputed from the edited paste, and that string. The page drops the handoff as
soon as the paste is edited again.
Guards the page applies before a run and the API does not: it refuses to price or run a paste it cannot read as C# (“Nothing was pasted.”, “No C# file was found. Paste the .cs files of the feature - components, systems, jobs, bakers - with a // file: <path>.cs line above each.”, or “No C# type was found: no struct or class declaration in the pasted files.”), and it warns before a run on a paste the checks can say little about (“No ISystem, SystemBase or job was found - only N types: the system and job checks need the code that schedules and runs them.”, or “No component type was pasted: the managed-field and tag checks need the IComponentData structs the systems use.”).
Input fields
This is exactly what the page sends (dotskit.js buildInput(lane, A, note,
handoff), checked by mustBeObject; app.js currentInput
and run), and what input-schema.json declares. The platform’s input
schema is scalar-only, so every value is a string. buildInput emits them in the order
task, code, facts, note,
audit_handoff:
| Field | Type | Required | Meaning |
|---|---|---|---|
task | string | yes | "audit" or "fix" (the lanes above). |
code | string | yes | The pasted C#, each file introduced by a // file: <path> line; line 1 is its first line. Every line in an audit reply is counted in this text. A large paste is cut on whole files, with a // [dots-desk: not sent: ...] line at the end (below). |
facts | string | yes | The page’s free check, Dotskit.facts(A), JSON-encoded into a string: JSON.stringify(facts) in JavaScript, json.dumps(facts) in Python, and so on. Sending the object itself is a 400. The model is told to parse it. |
note | string | no | What the engineer says: the goal, a constraint (“keep the SystemBase for now”, “we are on Entities 1.2”), a fact the code cannot show (“the HUD reads TurretTarget on the main thread”), a question. The page trims it, cuts it at 2,000 characters and sends it only when it is not blank. It is context, not evidence and not instructions: the model tests every claim about the code against code, may use project facts the code cannot show as given, and answers the note in summary. |
audit_handoff | string | no | fix lane only: a JSON string built from an audit reply on this code (recon.js fixHandoff, below). buildInput drops it for the audit lane. |
retry_note | string | no | Sent only by the page’s automatic reformat retry: when a reply does not parse as JSON (even after the page tries to close a cut-off object), the page runs once more with “Your previous reply was not the single valid JSON object the instructions require (...). Reply again with ONLY the JSON object for task '<lane>' - no prose, no code fences; every array present (empty arrays where there is nothing to say).” A normal call never sends it. |
mustBeObject only insists on a plain object that is not wrapped in
{"input": ...}; it is buildInput that leaves a blank note out, which is why
an empty note is simply absent.
The code string
code is the paste itself. A line // file: <path> (a path with a
. or / in it) starts each file, and a --- line just before it
only separates files. Files dropped on the page (or a dropped folder) are joined that way by
Dotskit.joinFiles: each file under its // file: line, trailing whitespace
removed, joined by newlines, ending in a newline. A paste with no file line is read as one file named
after its first struct or class (<Name>.cs), and the page says so (“There is no
// file: line, so the page read this as ...”). The page normalises line endings to
\n. A .cs path is checked as C# (kind: "csharp"); anything else
is other and only carried along. The paste keeps its indentation (four spaces in the
examples).
Send the text you want the reply to quote: every file in an audit reply must be a
path from facts.files, every line must fall inside that file,
every evidence must be copied from it, and every edit’s before must
occur in it exactly once.
The page reads up to 400,000 characters (MAX_TEXT, cut at a line) and 40 files
(MAX_FILES), and sends at most 60,000 characters (MAX_SEND): past that
buildInput drops whole files from the end — the last file that is not C# first,
then the last file — until the rest fits, cuts a single remaining file at a line (“the end
of <path>”) if it still does not, and ends the string with one line naming what it left
out:
// [dots-desk: not sent: Assets/Scripts/Turrets/TurretHud.cs, Assets/Scripts/Turrets/TurretBaker.cs]
The model is told never to quote or rewrite what was not sent, and facts.notes gets the
sentence “Not sent (the paste is over 60,000 characters): ... The page checked them; the run
did not see them.” facts is still computed from the whole paste. The worked
examples below are small, so their code is the paste unchanged.
The facts string
facts is optional to compute but required to send. It is produced by the page’s
free check: Dotskit.analyze splits the paste into files, lexes them, rebuilds their
brace structure, inventories types, systems, jobs, allocations, command buffers and structural
changes and runs the rules, and Dotskit.facts(A) turns that analysis into the object
below (it does not depend on the lane: an audit and a fix run of the same paste carry the same facts).
It is how the model knows which flags to answer, which file paths and line ranges to name, and which
types and methods must survive. Its top-level keys, in the order built:
| Key | Contents |
|---|---|
summary | Counts: csharp_files, types, systems, jobs, burst_methods, allocations. |
files | Every file: path (use it verbatim), kind (csharp, other), line and end_line (the paste lines of the file’s content, without its // file: line). |
types | Every struct and class (up to 60): name, kind, role (component, buffer, shared, managed_component, isystem, systembase, job, aspect, baker, authoring, other), file, line, partial, burst, and when they apply interface and scheduled (a job: parallel, single, run or null when the paste never schedules it), tag (a component with no fields), enableable, nested_in, and for components, jobs and systems their fields (up to 24: name, type, attrs). |
systems | Every ISystem and SystemBase (up to 30): name, kind, file, line, partial, burst_update (OnUpdate carries [BurstCompile]), methods, requires (the RequireForUpdate<T> in OnCreate), singletons (the singletons it reads) and schedules (each job it creates, with each schedule call and where its JobHandle goes: -> state.Dependency, -> <local>, -> dropped, or (implicit dependency) for an IJobEntity scheduled without arguments). |
jobs | Every job struct (up to 30): name, interface, file, line, burst, partial, scheduled. |
allocations | Every native container allocated inside a method (up to 40): name, container, allocator (Temp, TempJob, Persistent, World for state.WorldUpdateAllocator, or (unknown)), file, line, where, disposed, passed_to (job fields). |
command_buffers | Every new EntityCommandBuffer(...) (up to 20): name, file, line, where, played_back, disposed. |
structural_changes | Every create, destroy, instantiate, add, remove or shared-component set (up to 60): call, via (EntityManager or command buffer), file, line, where, in_query_loop. |
functions | Every method with a body (up to 120): name (Type.Method), file, line, burst. |
unreadable | Files whose braces did not balance (up to 20): path, line, error; their structure may be misread. |
flags | Every flag the page raised: uid (F1, F2, ... in severity, file, then line order), id (DK-01..DK-22), sev (high | medium | low | info), file, line, text, detail, and lines (every line an aggregated flag covers, only when it covers more than one). An audit must answer every non-info flag by its uid; a fix must close every high and medium flag or name it in open. |
verdict_candidate | The audit verdict the flags point at (the page’s own reading): blocked with any high flag, needs_work with any medium, otherwise ready. |
notes | Plain sentences about what was not read or not sent (empty for a paste that fits). |
The simplest source is dotskit.js itself: the page loads it as
/dotskit.js, and it also runs in Node (it sets module.exports).
This script prints what the page would send as code and facts (with the
60,000-character cut applied), with the facts decoded so you can read them; the step 4 samples compact
them back into the page’s string byte for byte. Save the paste as
swarm-paste.txt and redirect the output into swarm-check.json:
// build-check.js -- run: node build-check.js swarm-paste.txt > swarm-check.json (dotskit.js saved next to it)
const fs = require("fs");
const Dotskit = require("./dotskit.js");
const A = Dotskit.analyze(fs.readFileSync(process.argv[2], "utf8"));
if (!A.ok) { console.error(A.errors.join("\n")); process.exit(1); }
const inp = Dotskit.buildInput("audit", A, "", null); // code and facts do not depend on the lane
console.log(JSON.stringify({ code: inp.code, facts: JSON.parse(inp.facts) }, null, 2));
console.error(Dotskit.summaryLine(A) + "; " + A.flags.filter((f) => f.sev !== "info").length + " flags (" +
A.counts.high + " high, " + A.counts.medium + " medium, " + A.counts.low + " low); verdict_candidate " + A.candidate);
For the swarm example it reports
3 C# files · 2 systems (2 ISystem, 0 SystemBase) · 1 job · 3 component types · 4 Burst-compiled methods; 5 flags (5 high, 0 medium, 0 low); verdict_candidate blocked;
for the bullets example,
2 C# files · 1 system (1 ISystem, 0 SystemBase) · 1 job · 3 component types · 3 Burst-compiled methods; 4 flags (3 high, 1 medium, 0 low); verdict_candidate blocked.
For both worked examples its code and facts are exactly what the page sends.
Without the page’s check. The platform only checks that facts
is a string, so a minimal object works — "{}", or a hand-built one such as
{"flags": [], "notes": ["No page check was run; read the code directly."]}
— and the model still reads code. But you lose what the check adds: with no
flags there is nothing to confirm, dismiss or close, with no files there are
no paths and line ranges to name, with no systems and jobs the model does
not get the schedule calls and where each JobHandle goes, and with no types and
functions nothing says what must survive a fix. Build it with dotskit.js as
above when you can.
The audit_handoff string
Only for task: "fix", and only for the code the audit was about with every audit edit
applied. The page builds both from the normalised audit reply res
(recon.js normalize, below) and the analysis A of the audited
paste, in recon.js fixHandoff:
const run = Recon.applyFindings(A, res.findings, Dotskit); // every finding's edits, in order, each on top of the last
JSON.stringify({ verdict: res.verdict, headline: res.headline,
findings: res.findings.map(f => ({ id: f.id, severity: f.severity, file: f.file, line: f.line, title: f.title, why: f.why, edits: f.edits.length })),
applied: /* edits that applied */, failed: /* edits that did not */ })
// run.A.text is the edited paste: it becomes code, and facts is recomputed from it
That is {"verdict", "headline", "findings": [{id, severity, file, line, title, why, edits}],
"applied", "failed"}, where each finding’s edits is the number of
edits it carried. applyFindings applies every finding’s edits with
Dotskit.applyEdits, in the order listed: each before must occur exactly once
in its file as the earlier edits left it (leading and trailing blank lines ignored), or that edit is
reported as failed and skipped — it is never guessed. The handoff is a previous reply, not
evidence: the model checks it against code and fixes what is left. This script does the
whole step — the edited paste, its recomputed facts and the handoff string, in the same shape as
build-check.js prints, so the samples read it the same way:
// handoff.js -- run: node handoff.js swarm-paste.txt swarm-reply.txt > swarm-fix-check.json (dotskit.js, recon.js next to it)
const fs = require("fs");
const Dotskit = require("./dotskit.js");
const Recon = require("./recon.js");
const A = Dotskit.analyze(fs.readFileSync(process.argv[2], "utf8")); // the audited paste
const res = Recon.normalize(Recon.parseResult(fs.readFileSync(process.argv[3], "utf8")), "audit");
const ho = Recon.fixHandoff(A, res); // every edit, in order
const B = Dotskit.analyze(ho.text); // facts recomputed from the edited paste
const inp = Dotskit.buildInput("fix", B, "", ho.handoff);
console.log(JSON.stringify({ code: inp.code, facts: JSON.parse(inp.facts), audit_handoff: inp.audit_handoff }, null, 2));
console.error(ho.applied + " edit(s) applied, " + ho.failed + " did not apply");
Save the audit’s output.output as swarm-reply.txt; for the swarm
audit below it reports 11 edit(s) applied, 0 did not apply, and the page sends that fix run
with the audit’s note and the key dots-desk:fix:e06f3253-26e3:a1.
The output contracts
The model is instructed (SKILL.md) to reply with one JSON object and
nothing else — no prose, no code fences — with every array of its lane
present ([] when empty). The run’s output text is that object. In both lanes it
must ground everything in code: other systems, the subscene and its bakers, the system
groups and update order, the package versions and the Player settings are outside the paste and are
never stated as facts unless the note says so — they go into questions; whether a
type that is used but not pasted is a component, a tag or enableable is unknown unless the code shows
it. It never invents a measurement (frame times, entity counts and speedups are facts only when the note
gives them). It must never change what the code offers the rest of the project: every type’s
name, kind and namespace, every component’s fields (a field’s type may change only to make
it unmanaged, such as string to FixedString64Bytes), every public
method’s name and parameters, and every system’s update group and ordering attributes,
unless the note asks for it. It uses an API only when it is sure the API exists with that name and
signature in Entities 1.x (and the version the note gives), and never adds a package the paste does not
use. Every page flag whose sev is not info is answered exactly once (audit
lane: in flag_answers), and an info flag is never reported as a finding.
task: "audit"
task:"audit".verdict:blocked(any finding is high) |needs_work(the worst is medium) |ready(nothing above low; low findings and questions do not stop a build).headline: one sentence.feature: one or two sentences — what the feature does, its systems and jobs, and what runs in parallel.areas[]: exactly four entries, in the order burst, jobs, structural, memory:{area, status, note}withstatussound|fragile|broken(brokenwhen a high finding sits in that area,fragilefor a medium one).burst: it compiles and the source generators and Burst accept it (partial, unmanaged components and job fields, no managed calls in Burst code, no removed API, SystemAPI only in systems, Burst where it could be, legacy API);jobs: every JobHandle kept, containers disposed only after their job, no EntityManager or plain command buffer in parallel jobs, deterministic sort keys, lookups updated,[ReadOnly]where a job only reads, noComplete()right after scheduling;structural: no structural change while iterating, command buffers played back and disposed, toggled tags, singletons required;memory: every TempJob and Persistent allocation disposed, no Temp memory in jobs, Random seeds.findings[]:{id, flags[], file, line, severity, area, title, evidence, why, edits[]}.idis a catalogue id (DK-01..DK-21) orother;flagslists the pageuids it confirms ([]for something the page did not flag);fileis apathfromfacts.files, copied exactly — the file its edits change;lineis the line ofcodewith the offending text, inside that file’sline..end_line;severityishigh(the code does not compile, fails Burst, or throws or corrupts data under the safety checks: not partial, a managed field, a managed call in Burst code, removed API, SystemAPI outside a system, a dropped JobHandle, a container disposed under a running job, EntityManager or a plain command buffer in a parallel job, a lookup never updated, a writable container in a parallel job that only reads it, a structural change while iterating, a command buffer never played back, Temp memory passed to a job, Random seeded with zero) |medium(it runs but leaks, stalls the frame or loses determinism: code that could be Burst compiled and is not, a constant sort key,Complete()right after scheduling, a missing[ReadOnly]in a single-threaded job, a singleton read without RequireForUpdate, TempJob or Persistent memory never disposed, a command buffer never disposed) |low(bounded cost or hygiene: a toggled tag, an aspect,Entities.ForEach);areaisburst|jobs|structural|memory;evidenceis one to three whole, consecutive lines copied verbatim fromcodeas pasted.edits[]:{before, after}on that one file. Eachbeforeis a contiguous, exact slice of the file — whole lines with their indentation, as pasted — that occurs exactly once in the file as it stands when the edit is applied;afteris its replacement, with the same indentation. Findings are applied in the order listed and their edits in order, each on top of the ones before, so a later finding that touches the same lines writes itsbeforeas the earlier one left it. A newusinggoes into the edit of the first finding that needs it, as an edit of an existingusingline. Every line an edit adds follows the house rules itself (a structural change it moves goes into a command buffer, a container it adds to a job is[ReadOnly]when the job only reads it, a Random it seeds is non-zero), so the re-check raises nothing new.editsmay be[]only for a low finding or a change outside the paste.flag_answers[]:{flag, status, reason}, exactly one per non-info page flag,statusconfirmed(a finding lists that uid) |dismissed(with the reason).plan[]: the findings in the order to apply them, ending with compiling in the Editor with Burst enabled and Jobs > Burst > Safety Checks on, entering Play mode and watching the Console, and opening the Burst Inspector and the Profiler (Timeline) for the systems that changed.questions[](only what the paste cannot answer) andsummary(two to four sentences, answeringnoteif one was sent).
task: "fix"
task:"fix".verdict:fixed(openis empty) |partial.headline: one sentence.files[]:{path, content}— every pasted file it changes, whole (every line, without the// file:line, indented as the file already is), under itspathfromfacts.files. Every type, field, method, attribute,usingand comment it was not asked to change is kept; newusinglines go with the others. It never adds a file. When the code raises no high or medium flag and the model finds no such problem itself (an audit’s edits may already have fixed everything), it changes nothing:files,changesandopenare[]and the verdict isfixed.changes[]:{file, function, flags[], change, why}, one per change.functionis the method it is in, asfacts.functionsnames it (Type.Method), or the type’s name for a change to a declaration (a field, an attribute,partial), or(file)for ausingline;flagsare the page flags the change closes. Every high and medium flag appears in theflagsof a change or of anopenitem.verify[]: always compiling in the Editor with Burst enabled and Jobs > Burst > Safety Checks on and entering Play mode with the Console clear, plus the check that would have caught the worst problem (the Burst Inspector showing the job or OnUpdate compiled; the Entities Hierarchy or Systems window showing the entities spawned exactly once; the Profiler Timeline showing no sync point whereComplete()was; the Memory Profiler or the Console showing no leaked native allocation after leaving Play mode).open[]:{item, flags[], reason}for what it left unfixed in the pasted files — a decision for the engineer, or code outside the paste.questions[]andsummary, as in the audit lane; with anaudit_handoff, it fixes what the audit left.
How the page reads a reply (recon.js parseResult and
normalize): it strips a code fence and parses from the first { to the
last }. A reply is read as the lane that was asked for, unless it names the other lane
and carries that lane’s body (a files array for fix, a
findings array for audit). An unknown verdict shows as
needs_work or partial and counts as a disagreement; an unknown
severity becomes medium; ids like DK7 or dk 7
become DK-07; flags keeps only F<n> values; findings
with no file, evidence and title are dropped; feature may also arrive as
service or component, file as path, a
change’s function as func, method or member
and its change as what, and an open item as path;
questions is capped at 10, plan at 30 and verify at 20. An audit
reply carries 9 sections (verdict, headline, feature, areas, findings, flag_answers, plan, questions,
summary) and a fix reply 8 (verdict, headline, files, changes, verify, open, questions, summary), which
is what the page counts when it recovers a partial reply.
Worked examples
Both are examples the page ships (the example buttons on the app page, ids
swarm and bullets), built exactly as the page builds them:
Dotskit.buildInput(lane, Dotskit.analyze(text), note, null), with the real model reply
the page replays for each. The pastes are shown whole; the request bodies cut the long
code, facts and audit_handoff strings with a visible
..., and the replies are pretty-printed excerpts, with ... where entries or
the end of a string were left out. Every value shown is copied from the input or the reply.
Audit: a drone swarm whose move system is not partial, whose component holds a string, which instantiates inside a SystemAPI.Query loop, seeds Random with zero and reads UnityEngine.Time in a Burst job
Three files under Assets/Scripts/Swarm/: SwarmComponents.cs (the
Drone component with a string Callsign, the SwarmSpawner
component and the SwarmSpawned tag), SwarmSpawnSystem.cs (a Burst-compiled
ISystem that walks every spawner without SwarmSpawned in a
SystemAPI.Query foreach, seeds new Random(0), calls
state.EntityManager.Instantiate and SetComponentData for each drone and
state.EntityManager.AddComponent<SwarmSpawned> for the spawner, all inside the loop)
and DroneMoveSystem.cs (an ISystem declared without partial
that schedules the Burst-compiled DroneMoveJob, an IJobEntity whose
Execute reads Time.time). The page’s free check raises 5 flags (5 high,
0 medium, 0 low) (plus the DK-22 context flag); its own reading of the verdict is
blocked. The engineer’s note: “First DOTS feature on the team. The spawner and
the drone movement are going into Friday's playtest build - what breaks with Burst and the safety
checks on, and what do we fix first?”
The code string, whole: 2,369 characters, 89 lines ending in a newline. Save it as
swarm-paste.txt and run
node build-check.js swarm-paste.txt > swarm-check.json:
// file: Assets/Scripts/Swarm/SwarmComponents.cs
using Unity.Entities;
using Unity.Mathematics;
public struct Drone : IComponentData
{
public float Speed;
public float BobHeight;
public string Callsign;
}
public struct SwarmSpawner : IComponentData
{
public Entity Prefab;
public int Count;
public float Radius;
}
// Added to a spawner once it has spawned its swarm.
public struct SwarmSpawned : IComponentData { }
---
// file: Assets/Scripts/Swarm/SwarmSpawnSystem.cs
using Unity.Burst;
using Unity.Entities;
using Unity.Mathematics;
using Unity.Transforms;
[BurstCompile]
public partial struct SwarmSpawnSystem : ISystem
{
[BurstCompile]
public void OnCreate(ref SystemState state)
{
state.RequireForUpdate<SwarmSpawner>();
}
[BurstCompile]
public void OnUpdate(ref SystemState state)
{
foreach (var (spawner, origin, entity) in
SystemAPI.Query<RefRO<SwarmSpawner>, RefRO<LocalTransform>>()
.WithNone<SwarmSpawned>()
.WithEntityAccess())
{
var random = new Random(0);
for (int i = 0; i < spawner.ValueRO.Count; i++)
{
var drone = state.EntityManager.Instantiate(spawner.ValueRO.Prefab);
var offset = random.NextFloat3Direction() * random.NextFloat(0f, spawner.ValueRO.Radius);
state.EntityManager.SetComponentData(drone,
LocalTransform.FromPosition(origin.ValueRO.Position + offset));
}
state.EntityManager.AddComponent<SwarmSpawned>(entity);
}
}
}
---
// file: Assets/Scripts/Swarm/DroneMoveSystem.cs
using Unity.Burst;
using Unity.Entities;
using Unity.Mathematics;
using Unity.Transforms;
using UnityEngine;
[BurstCompile]
public struct DroneMoveSystem : ISystem
{
[BurstCompile]
public void OnUpdate(ref SystemState state)
{
new DroneMoveJob
{
DeltaTime = SystemAPI.Time.DeltaTime
}.ScheduleParallel();
}
}
[BurstCompile]
public partial struct DroneMoveJob : IJobEntity
{
public float DeltaTime;
void Execute(ref LocalTransform transform, in Drone drone)
{
transform.Position += transform.Forward() * drone.Speed * DeltaTime;
transform.Position.y += math.sin(Time.time * 2f) * drone.BobHeight * DeltaTime;
}
}
Its facts, decoded and cut to summary, files, systems, structural_changes, flags (each detail shortened) and verdict_candidate — the full object also carries the 6 types with their fields, the one job, the 4 functions, and empty allocations, command_buffers and unreadable. The request carries it as one compact JSON string of 6,843 characters:
{
"summary": {
"csharp_files": 3,
"types": 6,
"systems": 2,
"jobs": 1,
"burst_methods": 4,
"allocations": 0
},
"files": [
{
"path": "Assets/Scripts/Swarm/SwarmComponents.cs",
"kind": "csharp",
"line": 2,
"end_line": 20
},
{
"path": "Assets/Scripts/Swarm/SwarmSpawnSystem.cs",
"kind": "csharp",
"line": 23,
"end_line": 57
},
{
"path": "Assets/Scripts/Swarm/DroneMoveSystem.cs",
"kind": "csharp",
"line": 60,
"end_line": 90
}
],
"systems": [
{
"name": "SwarmSpawnSystem",
"kind": "ISystem",
"file": "Assets/Scripts/Swarm/SwarmSpawnSystem.cs",
"line": 29,
"burst_update": true,
"requires": [
"SwarmSpawner"
],
"singletons": [],
"schedules": []
},
{
"name": "DroneMoveSystem",
"kind": "ISystem",
"file": "Assets/Scripts/Swarm/DroneMoveSystem.cs",
"line": 67,
"burst_update": true,
"requires": [],
"singletons": [],
"schedules": [
{
"job": "DroneMoveJob",
"line": 72,
"calls": [
"ScheduleParallel() (implicit dependency)"
]
}
]
}
],
"structural_changes": [
{
"call": "Instantiate",
"via": "EntityManager",
"file": "Assets/Scripts/Swarm/SwarmSpawnSystem.cs",
"line": 48,
"where": "SwarmSpawnSystem.OnUpdate",
"in_query_loop": true
},
{
"call": "AddComponent",
"via": "EntityManager",
"file": "Assets/Scripts/Swarm/SwarmSpawnSystem.cs",
"line": 54,
"where": "SwarmSpawnSystem.OnUpdate",
"in_query_loop": true
}
],
"flags": [
{
"uid": "F1",
"id": "DK-02",
"sev": "high",
"file": "Assets/Scripts/Swarm/SwarmComponents.cs",
"line": 9,
"text": "component Drone has a managed field: string Callsign",
"detail": "An unmanaged component (a struct IComponentData or..."
},
{
"uid": "F2",
"id": "DK-20",
"sev": "high",
"file": "Assets/Scripts/Swarm/SwarmSpawnSystem.cs",
"line": 45,
"text": "new Random(0) seeds Unity.Mathematics.Random with zero",
"detail": "Unity.Mathematics.Random is an xorshift generator: state..."
},
{
"uid": "F3",
"id": "DK-14",
"sev": "high",
"file": "Assets/Scripts/Swarm/SwarmSpawnSystem.cs",
"line": 48,
"text": "EntityManager.Instantiate, EntityManager.AddComponent inside the SystemAPI.Query foreach in SwarmSpawnSystem.OnUpdate",
"detail": "A structural change (create, destroy, add or remove a...",
"lines": [
48,
54
]
},
{
"uid": "F4",
"id": "DK-01",
"sev": "high",
"file": "Assets/Scripts/Swarm/DroneMoveSystem.cs",
"line": 67,
"text": "DroneMoveSystem (ISystem) is not partial",
"detail": "The build fails: the system uses SystemAPI or schedules an..."
},
{
"uid": "F5",
"id": "DK-03",
"sev": "high",
"file": "Assets/Scripts/Swarm/DroneMoveSystem.cs",
"line": 87,
"text": "Time.time in DroneMoveJob.Execute, which Burst compiles",
"detail": "Burst compiles only unmanaged code: UnityEngine.Time is..."
},
{
"uid": "F6",
"id": "DK-22",
"sev": "info",
"file": "Assets/Scripts/Swarm/SwarmComponents.cs",
"line": 2,
"text": "context: 3 C# files, 6 types (3 component, 2 ISystem, 1 job), 4 Burst-compiled methods, 1 job instance, 0 native allocations, 0 hand-made command buffers",
"detail": "Only what is pasted is checked: other systems, the..."
}
],
"verdict_candidate": "blocked",
"notes": []
}
The request body (POST /estimate, then POST /run or
/run-stream with Idempotency-Key: dots-desk:audit:ebdd3062-27b2:a1 as the
page sends it):
{
"task": "audit",
"code": "// file: Assets/Scripts/Swarm/SwarmComponents.cs\nusing Unity.Entities;\n...",
"facts": "{\"summary\":{\"csharp_files\":3,\"types\":6,\"systems\":2,\"jobs\":1,\"burst_methods\":4,\"allocations\":0},...",
"note": "First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?"
}
The reply (output.output), an excerpt: the verdict, the headline, the four areas, every
finding’s id, flags, file, line, severity and title, the structural-change finding with its first
two edits, the Random finding with its one edit, one flag answer and the last plan step:
{
"task": "audit",
"verdict": "blocked",
"headline": "Blocked: DroneMoveSystem won't compile, DroneMoveJob fails Burst, and SwarmSpawnSystem throws the first time it spawns a swarm.",
"feature": "SwarmSpawnSystem (ISystem) instantiates SwarmSpawner.Count Drone prefabs in a random radius around each un-spawned...",
"areas": [
{
"area": "burst",
"status": "broken",
"note": "DroneMoveSystem is missing partial, Drone.Callsign is a managed string field, and DroneMoveJob.Execute reads UnityEngine.Time.time - each on its own stops Burst or the build."
},
{
"area": "jobs",
"status": "sound",
"note": "DroneMoveJob is scheduled with the no-argument ScheduleParallel() so state.Dependency is handled for it, and its ref/in query parameters need no lookups or [ReadOnly]."
},
{
"area": "structural",
"status": "broken",
"note": "SwarmSpawnSystem calls EntityManager.Instantiate and EntityManager.AddComponent inside the SystemAPI.Query foreach it is iterating."
},
{
"area": "memory",
"status": "broken",
"note": "The spawn offset's Random is seeded with new Random(0)."
}
],
"findings": [
{
"id": "DK-01",
"flags": [
"F4"
],
"file": "Assets/Scripts/Swarm/DroneMoveSystem.cs",
"line": 67,
"severity": "high",
"area": "burst",
"title": "DroneMoveSystem is not partial",
...
},
{
"id": "DK-02",
"flags": [
"F1"
],
"file": "Assets/Scripts/Swarm/SwarmComponents.cs",
"line": 9,
"severity": "high",
"area": "burst",
"title": "Drone.Callsign is a managed string field",
...
},
{
"id": "DK-03",
"flags": [
"F5"
],
"file": "Assets/Scripts/Swarm/DroneMoveSystem.cs",
"line": 87,
"severity": "high",
"area": "burst",
"title": "DroneMoveJob.Execute reads UnityEngine.Time.time",
...
},
{
"id": "DK-14",
"flags": [
"F3"
],
"file": "Assets/Scripts/Swarm/SwarmSpawnSystem.cs",
"line": 48,
"severity": "high",
"area": "structural",
"title": "Structural changes inside the spawner's query foreach",
"evidence": " var drone = state.EntityManager.Instantiate(spawner.ValueRO.Prefab);",
"why": "The foreach walks the chunks SystemAPI.Query is iterating; EntityManager.Instantiate on line 48 and EntityManager.AddComponent<SwarmSpawned> on line...",
"edits": [
{
"before": " foreach (var (spawner, origin, entity) in",
"after": " var ecb = SystemAPI.GetSingleton<EndSimulationEntityCommandBufferSystem.Singleton>().CreateCommandBuffer(state.WorldUnmanaged);\n\n foreach (var (spawner, origin, entity) in"
},
{
"before": " var drone = state.EntityManager.Instantiate(spawner.ValueRO.Prefab);",
"after": " var drone = ecb.Instantiate(spawner.ValueRO.Prefab);"
},
...
]
},
{
"id": "DK-20",
"flags": [
"F2"
],
"file": "Assets/Scripts/Swarm/SwarmSpawnSystem.cs",
"line": 45,
"severity": "high",
"area": "memory",
"title": "Random seeded with zero",
"evidence": " var random = new Random(0);",
"why": "Unity.Mathematics.Random treats state zero as invalid: with safety checks on it throws \"Seed must be...",
"edits": [
{
"before": " var random = new Random(0);",
"after": " var random = Random.CreateFromIndex((uint)entity.Index);"
}
]
}
],
"flag_answers": [
{
"flag": "F3",
"status": "confirmed",
"reason": "Both the Instantiate on line 48 and the AddComponent on line 54 run inside the SystemAPI.Query foreach with no WithStructuralChanges() and no command buffer."
},
...
],
"plan": [
...,
"Open the Burst Inspector on DroneMoveJob.Execute and both systems' OnUpdate to confirm they compiled, and the Profiler Timeline for a frame with an active spawner to confirm DroneMoveJob still runs in parallel."
],
"questions": [
"FixedString32Bytes holds about 29 UTF-8 bytes - is that enough for every Callsign this...",
...
],
"summary": "Five high-severity problems stand between this and Friday's build, in the order to fix them: DroneMoveSystem..."
}
The reply has 5 findings, all high, and confirms all 5 flags; its verdict is blocked, as
the page read it. The findings carry 11 edits in all: partial added to
DroneMoveSystem (DK-01, F4, 1 edit); using Unity.Collections; added and
Callsign made a FixedString32Bytes (DK-02, F1, 2 edits); an
ElapsedTime field on DroneMoveJob, set from
(float)SystemAPI.Time.ElapsedTime in OnUpdate and read in place of
Time.time (DK-03, F5, 3 edits); an ecb from the
EndSimulationEntityCommandBufferSystem singleton created before the loop, with
Instantiate, SetComponentData and AddComponent<SwarmSpawned>
recorded into it (DK-14, F3 — the aggregated flag on lines 48 and 54, 4 edits); and
Random.CreateFromIndex((uint)entity.Index) in place of new Random(0) (DK-20,
F2, 1 edit). The jobs area is sound: DroneMoveJob is scheduled
with the no-argument ScheduleParallel(), so state.Dependency is handled for
it. Its two questions ask whether FixedString32Bytes is long enough for every callsign and
whether a swarm may start moving the frame after it spawns, which the paste cannot answer.
Handing the audit to the fix lane
On the page, “Apply every edit and fix the rest” on this audit runs
Recon.fixHandoff: all 11 edits apply in order (11 edit(s) applied, 0 did not
apply from handoff.js), the edited paste replaces the original, the free check runs
again on it and the fix lane is selected. The edited paste is 2,625 characters and 94 lines; its facts
raise no flag but the DK-22 context flag, so its verdict_candidate is ready.
The audit_handoff string (2,367 characters), decoded:
{
"verdict": "blocked",
"headline": "Blocked: DroneMoveSystem won't compile, DroneMoveJob fails Burst, and SwarmSpawnSystem throws the first time it spawns a swarm.",
"findings": [
{
"id": "DK-01",
"severity": "high",
"file": "Assets/Scripts/Swarm/DroneMoveSystem.cs",
"line": 67,
"title": "DroneMoveSystem is not partial",
"why": "OnUpdate uses SystemAPI.Time and schedules DroneMoveJob (an...",
"edits": 1
},
...,
{
"id": "DK-14",
"severity": "high",
"file": "Assets/Scripts/Swarm/SwarmSpawnSystem.cs",
"line": 48,
"title": "Structural changes inside the spawner's query foreach",
"why": "The foreach walks the chunks SystemAPI.Query is iterating...",
"edits": 4
},
...
],
"applied": 11,
"failed": 0
}
The fix request the page then sends (Idempotency-Key: dots-desk:fix:e06f3253-26e3:a1),
with the audit’s note carried over; code is the edited paste and facts
is recomputed from it:
{
"task": "fix",
"code": "// file: Assets/Scripts/Swarm/SwarmComponents.cs\nusing Unity.Entities;\n...",
"facts": "{\"summary\":{\"csharp_files\":3,\"types\":6,\"systems\":2,\"jobs\":1,\"burst_methods\":4,\"allocations\":0},...",
"note": "First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?",
"audit_handoff": "{\"verdict\":\"blocked\",\"headline\":\"Blocked: DroneMoveSystem won't compile, DroneMoveJob fails Burst, and SwarmSpawnSystem throws the first time it spawns a swarm.\",..."
}
Over the API you build the same body with handoff.js and send it with
makeInput("fix", "swarm-fix-check.json", note) from step 4. Because every high and medium
flag is already closed in code, the fix lane’s instructions say to change nothing
unless the model finds a problem of that kind itself: then files, changes
and open are [], the verdict is fixed, and summary
says the code needs no fix. The page's saved swarm fix run (the example one click after the audit) came
back exactly that way: verdict fixed, no file, no change, nothing open.
Fix: a bullet system that destroys entities inside its SystemAPI.Query loop, disposes an array its job still reads and reads a singleton it never requires
Two files under Assets/Scripts/Bullets/: BulletComponents.cs
(Bullet, BulletConfig and Target) and
BulletSystem.cs: BulletSystem reads the BulletConfig singleton
without requiring it, destroys expired bullets with state.EntityManager.DestroyEntity
inside its SystemAPI.Query foreach, copies the targets into a TempJob array,
schedules BulletMoveJob in parallel on state.Dependency and then calls
targets.Dispose() at once; the job’s Targets field is not
[ReadOnly]. The free check raises 4 flags (3 high, 1 medium, 0 low); its reading of the
verdict is blocked. This example has no audit before it, so it carries no
audit_handoff. The engineer’s note: “Bullets throw a safety exception every
frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still
prototyping.”
The code string, whole: 2,114 characters, 82 lines ending in a newline. Save it as
bullets-paste.txt and run
node build-check.js bullets-paste.txt > bullets-check.json:
// file: Assets/Scripts/Bullets/BulletComponents.cs
using Unity.Entities;
using Unity.Mathematics;
public struct Bullet : IComponentData
{
public float3 Velocity;
public float Lifetime;
}
public struct BulletConfig : IComponentData
{
public float HitRadius;
}
public struct Target : IComponentData
{
public float Health;
}
---
// file: Assets/Scripts/Bullets/BulletSystem.cs
using Unity.Burst;
using Unity.Collections;
using Unity.Entities;
using Unity.Mathematics;
using Unity.Transforms;
[BurstCompile]
public partial struct BulletSystem : ISystem
{
EntityQuery _targets;
[BurstCompile]
public void OnCreate(ref SystemState state)
{
_targets = SystemAPI.QueryBuilder().WithAll<Target, LocalTransform>().Build();
}
[BurstCompile]
public void OnUpdate(ref SystemState state)
{
var config = SystemAPI.GetSingleton<BulletConfig>();
float dt = SystemAPI.Time.DeltaTime;
foreach (var (bullet, entity) in SystemAPI.Query<RefRW<Bullet>>().WithEntityAccess())
{
bullet.ValueRW.Lifetime -= dt;
if (bullet.ValueRO.Lifetime <= 0f)
state.EntityManager.DestroyEntity(entity);
}
var targets = _targets.ToComponentDataArray<LocalTransform>(Allocator.TempJob);
state.Dependency = new BulletMoveJob
{
Targets = targets,
HitRadiusSq = config.HitRadius * config.HitRadius,
DeltaTime = dt
}.ScheduleParallel(state.Dependency);
targets.Dispose();
}
}
[BurstCompile]
public partial struct BulletMoveJob : IJobEntity
{
public NativeArray<LocalTransform> Targets;
public float HitRadiusSq;
public float DeltaTime;
void Execute(ref LocalTransform transform, ref Bullet bullet)
{
transform.Position += bullet.Velocity * DeltaTime;
for (int i = 0; i < Targets.Length; i++)
{
if (math.distancesq(Targets[i].Position, transform.Position) < HitRadiusSq)
{
bullet.Lifetime = 0f;
break;
}
}
}
}
Its facts, decoded and cut to summary, files, flags and verdict_candidate (the full object also carries the 5 types, BulletSystem with its one ScheduleParallel(state.Dependency) -> state.Dependency, the job, the one TempJob allocation targets passed to BulletMoveJob.Targets, the one structural change and the 3 functions), 5,909 characters as a string:
{
"summary": {
"csharp_files": 2,
"types": 5,
"systems": 1,
"jobs": 1,
"burst_methods": 3,
"allocations": 1
},
"files": [
{
"path": "Assets/Scripts/Bullets/BulletComponents.cs",
"kind": "csharp",
"line": 2,
"end_line": 19
},
{
"path": "Assets/Scripts/Bullets/BulletSystem.cs",
"kind": "csharp",
"line": 22,
"end_line": 83
}
],
"flags": [
{
"uid": "F1",
"id": "DK-14",
"sev": "high",
"file": "Assets/Scripts/Bullets/BulletSystem.cs",
"line": 49,
"text": "EntityManager.DestroyEntity inside the SystemAPI.Query foreach in BulletSystem.OnUpdate",
"detail": "A structural change (create, destroy, add or remove a..."
},
{
"uid": "F2",
"id": "DK-08",
"sev": "high",
"file": "Assets/Scripts/Bullets/BulletSystem.cs",
"line": 59,
"text": "targets.Dispose() right after BulletMoveJob is scheduled with it",
"detail": "The job has only been scheduled; it runs later on a worker..."
},
{
"uid": "F3",
"id": "DK-12",
"sev": "high",
"file": "Assets/Scripts/Bullets/BulletSystem.cs",
"line": 66,
"text": "BulletMoveJob.Targets (NativeArray) is only read but not [ReadOnly] (scheduled in parallel)",
"detail": "In a job scheduled in parallel a writable container is..."
},
{
"uid": "F4",
"id": "DK-17",
"sev": "medium",
"file": "Assets/Scripts/Bullets/BulletSystem.cs",
"line": 42,
"text": "BulletSystem.OnUpdate calls GetSingleton<BulletConfig>() but BulletSystem never requires BulletConfig",
"detail": "GetSingleton throws when there is not exactly one entity..."
},
{
"uid": "F5",
"id": "DK-22",
"sev": "info",
"file": "Assets/Scripts/Bullets/BulletComponents.cs",
"line": 2,
"text": "context: 2 C# files, 5 types (3 component, 1 ISystem, 1 job), 3 Burst-compiled methods, 1 job instance, 1 native allocation, 0 hand-made command buffers",
"detail": "Only what is pasted is checked: other systems, the..."
}
],
"verdict_candidate": "blocked",
"notes": []
}
The request body (Idempotency-Key: dots-desk:fix:3babff4d-228c:a1):
{
"task": "fix",
"code": "// file: Assets/Scripts/Bullets/BulletComponents.cs\nusing Unity.Entities;\n...",
"facts": "{\"summary\":{\"csharp_files\":2,\"types\":5,\"systems\":1,\"jobs\":1,\"burst_methods\":3,\"allocations\":1},...",
"note": "Bullets throw a safety exception every frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still prototyping."
}
The reply (output.output), an excerpt: the verdict, the headline, the middle of the one
returned file (1,916 characters, 65 lines), all four changes, the first and last verification steps, and
the empty open list:
{
"task": "fix",
"verdict": "fixed",
"headline": "BulletSystem now retires bullets through a command buffer, disposes the parallel job's array on its handle, marks that array [ReadOnly], and requires the BulletConfig singleton before updating.",
"files": [
{
"path": "Assets/Scripts/Bullets/BulletSystem.cs",
"content": "...\n var ecb = SystemAPI.GetSingleton<EndSimulationEntityCommandBufferSystem.Singleton>().CreateCommandBuffer(state.WorldUnmanaged);\n\n foreach (var (bullet, entity) in SystemAPI.Query<RefRW<Bullet>>().WithEntityAccess())\n {\n bullet.ValueRW.Lifetime -= dt;\n if (bullet.ValueRO.Lifetime <= 0f)\n ecb.DestroyEntity(entity);\n }\n\n var targets = _targets.ToComponentDataArray<LocalTransform>(Allocator.TempJob);\n state.Dependency = new BulletMoveJob\n {\n Targets = targets,\n HitRadiusSq = config.HitRadius * config.HitRadius,\n DeltaTime = dt\n }.ScheduleParallel(state.Dependency);\n targets.Dispose(state.Dependency);\n..."
}
],
"changes": [
{
"file": "Assets/Scripts/Bullets/BulletSystem.cs",
"function": "BulletSystem.OnUpdate",
"flags": [
"F1"
],
"change": "Replaced the EntityManager.DestroyEntity call inside the query foreach with ecb.DestroyEntity, recording it through an EntityCommandBuffer taken from the EndSimulationEntityCommandBufferSystem singleton.",
"why": "Prevents the 'structural changes are not allowed while iterating' exception thrown when an entity is destroyed mid-iteration."
},
{
"file": "Assets/Scripts/Bullets/BulletSystem.cs",
"function": "BulletSystem.OnUpdate",
"flags": [
"F2"
],
"change": "Changed targets.Dispose() to targets.Dispose(state.Dependency).",
"why": "Frees the native array only after BulletMoveJob (which reads it on a worker thread) has completed, instead of while the scheduled job may still be using it."
},
{
"file": "Assets/Scripts/Bullets/BulletSystem.cs",
"function": "BulletMoveJob",
"flags": [
"F3"
],
"change": "Marked the job's Targets field [ReadOnly].",
"why": "The job only reads Targets; unmarked in a job scheduled in parallel, reading any element outside the job's own index range throws under the safety checks."
},
{
"file": "Assets/Scripts/Bullets/BulletSystem.cs",
"function": "BulletSystem.OnCreate",
"flags": [
"F4"
],
"change": "Added state.RequireForUpdate<BulletConfig>(); in OnCreate.",
"why": "Stops OnUpdate's GetSingleton<BulletConfig>() from throwing on frames where the BulletConfig singleton entity does not yet exist."
}
],
"verify": [
"Compile in the Editor with Burst enabled and Jobs > Burst > Safety Checks on.",
...,
"Open the Burst Inspector and confirm BulletSystem.OnUpdate, BulletSystem.OnCreate and BulletMoveJob.Execute still compile under Burst."
],
"open": [],
"questions": [],
"summary": "Fixed all four flagged problems in BulletSystem.cs: destroying a bullet now goes through an EntityCommandBuffer from..."
}
The four changes close the four flags one each: ecb.DestroyEntity through the
EndSimulationEntityCommandBufferSystem singleton’s buffer (F1),
targets.Dispose(state.Dependency) (F2), [ReadOnly] on
BulletMoveJob.Targets (F3) and state.RequireForUpdate<BulletConfig>() in
OnCreate (F4). The verdict is fixed because open is empty;
BulletComponents.cs needed no change, so it is not returned.
The page checks the reply against the code; the API does not
What comes back from the API is the model’s raw text in output.output. The page
holds it to account in the browser before showing it (recon.js
reconcile, with the facts, the code and the handoff it sent): it applies every edit or
returned file to the paste and re-runs its own checks on the result. None of that happens in the API.
A direct API caller gets the reply unchecked and must do the applying and re-checking itself.
- Both lanes: the reply is the lane you asked for (one written for the other task is a disagreement), and it carries a valid verdict for that lane.
- Audit: the areas table. Exactly four rows, covering Burst, jobs, structural changes and memory once each, each with a valid status.
- Audit: every finding is anchored. Its
idis in the catalogue (DK-01..DK-21, orother; DK-22 is context and never a finding); itsfileis a pasted file; itslineis inside that file; itsevidenceis found line by line in that file ofcode(indentation trimmed) and on or within three lines ofline; every citeduidis a non-info flag the page raised. A finding that carries a high flag at a lower severity, a finding with no valid area, or a medium or high finding with no edit is pointed out. - Audit: every flag is answered once, consistently. Every non-info flag answered exactly once and no other; a
confirmedanswer needs a finding carrying that uid; adismissedone must not be carried by a finding and should give a reason. The verdict must fit the worst severity (blockedwith a high finding,needs_workwith a medium, otherwiseready). - Audit: every edit is put in place and re-checked. The findings’ edits are applied in the listed order, each on top of the ones before (
Dotskit.applyEdits): abeforethat is not found, is found more than once, or changes nothing is a disagreement. After each finding the free check runs again: the code must still read and no new high flag may appear. With every edit applied, every confirmed flag a finding with edits carries must be gone, every type and method of the paste must still exist, and a new medium flag is pointed out. - Fix: the files. At least one file (or none, when the paste raises no high or medium flag), at most one new one; none empty, none with a
// file:line, every path a.csfile; a file indented with tabs when the paste uses spaces is pointed out. - Fix: put into the paste and re-checked. The files replace the pasted files of the same path (or are added) (
Dotskit.replaceFiles) and the free check runs again: the code must read, no high or medium flag of the paste may remain unless anopenitem names it, no new high or medium flag may appear, every type and method must still exist, and a method that was Burst compiled and no longer is is pointed out. - Fix: the changes list matches the code. Every change names a returned file, a method or type of the fixed code (or
(type)or(file)) and real page flags; a high or medium flag no change and no open item names is pointed out. The verdict must fit theopenlist, and an emptyverifyis pointed out.
recon.js also runs in Node, so you can hold a reply to exactly the page’s standard.
Save the page’s /dotskit.js and /recon.js next to this script,
pass the file you built the body from (build-check.js or handoff.js output),
the reply text and the lane; it prints every statement, the count, any flag still raised, and the paste
with every edit (or file) put back:
// recheck.js -- run: node recheck.js swarm-check.json swarm-reply.txt audit > swarm-edited.txt (dotskit.js, recon.js next to it)
const fs = require("fs");
const Recon = require("./recon.js"); // loads ./dotskit.js itself
const sent = JSON.parse(fs.readFileSync(process.argv[2], "utf8")); // code, facts (and audit_handoff) you sent
const lane = process.argv[4] || "audit";
const res = Recon.normalize(Recon.parseResult(fs.readFileSync(process.argv[3], "utf8")), lane); // output.output
const r = Recon.reconcile(res, { facts: sent.facts, code: sent.code, handoff: sent.audit_handoff || null });
r.notes.forEach((n) => console.error(n.kind + ": " + n.text));
console.error(r.disagreements + " disagreement(s) in " + r.statements + " statements checked");
if (r.after) (r.after.flags || []).forEach((f) => console.error("still raised: " + f.id + " " + f.sev + " " + f.file + ":" + f.line + " " + f.text));
if (r.after && r.after.text) console.log(r.after.text.replace(/\n$/, "")); // the paste with every edit (or file) put back
For the swarm audit reply it reports:
ok: The areas table rates Burst, jobs, structural changes and memory once each.
ok: Every one of the 5 findings names a pasted file, a line inside it and evidence copied from it.
ok: The verdict (blocked) fits the worst finding.
ok: Every one of the page's 5 flags is answered once.
ok: All 11 edits applied in order, each before text found exactly once.
ok: Every confirmed flag a finding carries is gone once all edits are applied.
ok: Every type and method of the paste is still there after the edits.
0 disagreement(s) in 7 statements checked
and for the bullets fix reply (node recheck.js bullets-check.json bullets-reply.txt fix):
ok: 1 file returned whole.
ok: With the fixed files in place the free check raises no high or medium flag (0 low).
ok: Every one of the 5 types and 3 methods is still there.
ok: Every one of the 4 changes names a returned file, a method or type of the fixed code and real page flags.
ok: The verdict (fixed) fits the open list.
0 disagreement(s) in 5 statements checked
Neither run prints a still raised: line: with every audit edit (or the fixed file) in
place, the free check raises no flag above info. That is the page’s own local
reading — the same text rules, run again on the edited paste, in your browser or in Node, with no
network call. The page does not compile or run the code. After that, compile in the Editor with Burst
enabled and Jobs > Burst > Safety Checks on, enter Play mode with the Console clear, and open the
Burst Inspector and the Profiler (Timeline) for the systems that changed, plus the checks the
reply’s plan or verify names, before anything goes into a build.
Step 1 — a tiny client helper
One function per language that does what sdk.js does for every call: JSON in,
bearer token if you have one, data out on a 2xx, an error carrying
status, error.code and error.message otherwise. The later
steps assume this helper is in the same file (for Go, Java and C#, the later snippets go inside
main / the top-level statements; Java’s makeInput from step 4 goes
in the class).
BASE="https://api.skillsafe.ai/v1/app-api"
TOKEN="${SKILLSAFE_TOKEN:-YOUR_TOKEN}" # step 2
# api METHOD PATH [extra curl args...] -- prints the whole envelope; pipe to jq
api() {
method="$1"; path="$2"; shift 2
curl -sS -X "$method" "$BASE$path" \
-H "Content-Type: application/json" \
-H "Authorization: Bearer $TOKEN" "$@"
}
# success: jq '.data' failure: jq '.error | {code, message}'
import hashlib, json, os, time, urllib.parse
import requests # pip install requests
BASE = "https://api.skillsafe.ai/v1/app-api"
TOKEN = os.environ.get("SKILLSAFE_TOKEN", "YOUR_TOKEN") # step 2
class ApiError(Exception):
def __init__(self, status, code, message, details=None):
super().__init__(f"{status} {code}: {message}")
self.status, self.code, self.details = status, code, details
def api(method, path, body=None, headers=None):
h = {"Content-Type": "application/json"}
if TOKEN:
h["Authorization"] = "Bearer " + TOKEN
h.update(headers or {})
r = requests.request(method, BASE + path, headers=h,
data=None if body is None else json.dumps(body))
try:
env = r.json()
except ValueError:
env = {}
if not r.ok:
err = env.get("error") or {}
raise ApiError(r.status_code, err.get("code"), err.get("message") or r.reason, err.get("details"))
return env.get("data")
// dots-desk.mjs -- Node 18+ (global fetch), run with: node dots-desk.mjs
import { readFileSync } from "node:fs";
import { createHash } from "node:crypto";
const BASE = "https://api.skillsafe.ai/v1/app-api";
let TOKEN = "YOUR_TOKEN"; // step 2
async function api(method, path, body, headers = {}) {
const h = { "Content-Type": "application/json", ...headers };
if (TOKEN) h.Authorization = "Bearer " + TOKEN;
const res = await fetch(BASE + path, {
method,
headers: h,
body: body === undefined ? undefined : JSON.stringify(body),
});
const json = await res.json().catch(() => ({}));
if (!res.ok) {
const err = new Error((json.error && json.error.message) || res.statusText);
err.status = res.status;
err.code = json.error && json.error.code;
err.details = json.error && json.error.details;
throw err;
}
return json.data;
}
package main
import (
"bufio"
"bytes"
"crypto/sha256"
"encoding/hex"
"encoding/json"
"fmt"
"net/http"
"net/url"
"os"
"strings"
"time"
)
const base = "https://api.skillsafe.ai/v1/app-api"
var token = os.Getenv("SKILLSAFE_TOKEN") // step 2
type apiError struct {
Status int
Code string
Message string
}
func (e *apiError) Error() string { return fmt.Sprintf("%d %s: %s", e.Status, e.Code, e.Message) }
type envelope struct {
OK bool `json:"ok"`
Data json.RawMessage `json:"data"`
Error *struct {
Code string `json:"code"`
Message string `json:"message"`
} `json:"error"`
}
func newRequest(method, path string, body any, headers map[string]string) (*http.Request, error) {
var buf []byte
if body != nil {
b, err := json.Marshal(body)
if err != nil {
return nil, err
}
buf = b
}
req, err := http.NewRequest(method, base+path, bytes.NewReader(buf))
if err != nil {
return nil, err
}
req.Header.Set("Content-Type", "application/json")
if token != "" {
req.Header.Set("Authorization", "Bearer "+token)
}
for k, v := range headers {
req.Header.Set(k, v)
}
return req, nil
}
func errorFrom(res *http.Response, env envelope) error {
e := &apiError{Status: res.StatusCode, Message: http.StatusText(res.StatusCode)}
if env.Error != nil {
e.Code = env.Error.Code
if env.Error.Message != "" {
e.Message = env.Error.Message
}
}
return e
}
// api sends body as JSON and decodes the envelope's data into out (out may be nil).
func api(method, path string, body any, headers map[string]string, out any) error {
req, err := newRequest(method, path, body, headers)
if err != nil {
return err
}
res, err := http.DefaultClient.Do(req)
if err != nil {
return err
}
defer res.Body.Close()
var env envelope
_ = json.NewDecoder(res.Body).Decode(&env)
if res.StatusCode < 200 || res.StatusCode > 299 {
return errorFrom(res, env)
}
if out != nil && len(env.Data) > 0 {
return json.Unmarshal(env.Data, out)
}
return nil
}
func main() {
// steps 2-6 go here; remove any import a step you skip no longer uses
_, _, _, _, _ = bufio.NewScanner, sha256.Sum256, hex.EncodeToString, url.PathEscape, strings.Index
_ = time.Second
}
// DotsDesk.java -- Java 17+, needs com.fasterxml.jackson.core:jackson-databind on the classpath
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.net.URI;
import java.net.URLEncoder;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Path;
import java.security.MessageDigest;
import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class DotsDesk {
static final String BASE = "https://api.skillsafe.ai/v1/app-api";
static String token = System.getenv().getOrDefault("SKILLSAFE_TOKEN", "YOUR_TOKEN"); // step 2
static final HttpClient HTTP = HttpClient.newHttpClient();
static final ObjectMapper JSON = new ObjectMapper();
static class ApiException extends Exception {
final int status;
final String code;
ApiException(int status, String code, String message) {
super(status + " " + code + ": " + message);
this.status = status;
this.code = code;
}
}
static HttpRequest.Builder request(String method, String path, Object body, Map<String, String> headers) throws Exception {
HttpRequest.Builder b = HttpRequest.newBuilder(URI.create(BASE + path))
.header("Content-Type", "application/json")
.method(method, body == null ? HttpRequest.BodyPublishers.noBody()
: HttpRequest.BodyPublishers.ofString(JSON.writeValueAsString(body)));
if (token != null && !token.isEmpty()) b.header("Authorization", "Bearer " + token);
if (headers != null) headers.forEach(b::header);
return b;
}
static ApiException errorFrom(int status, JsonNode env) {
JsonNode err = env.path("error");
return new ApiException(status, err.path("code").asText(null), err.path("message").asText("HTTP " + status));
}
static JsonNode api(String method, String path, Object body, Map<String, String> headers) throws Exception {
HttpResponse<String> res = HTTP.send(request(method, path, body, headers).build(), HttpResponse.BodyHandlers.ofString());
JsonNode env;
try { env = JSON.readTree(res.body()); } catch (Exception e) { env = JSON.createObjectNode(); }
if (env == null) env = JSON.createObjectNode();
if (res.statusCode() / 100 != 2) throw errorFrom(res.statusCode(), env);
return env.path("data");
}
public static void main(String[] args) throws Exception {
// steps 2-6 go here (makeInput from step 4 goes next to api())
}
}
require "digest"
require "json"
require "net/http"
require "uri"
BASE = "https://api.skillsafe.ai/v1/app-api"
$token = ENV.fetch("SKILLSAFE_TOKEN", "YOUR_TOKEN") # step 2
class ApiError < StandardError
attr_reader :status, :code
def initialize(status, code, message)
super("#{status} #{code}: #{message}")
@status = status
@code = code
end
end
def build_request(method, path, body = nil, headers = {})
uri = URI(BASE + path)
req = Net::HTTPGenericRequest.new(method, !body.nil?, true, uri.request_uri)
req["Content-Type"] = "application/json"
req["Authorization"] = "Bearer #{$token}" if $token && !$token.empty?
headers.each { |k, v| req[k] = v }
req.body = JSON.generate(body) unless body.nil?
[uri, req]
end
def api(method, path, body = nil, headers = {})
uri, req = build_request(method, path, body, headers)
res = Net::HTTP.start(uri.host, uri.port, use_ssl: true) { |h| h.request(req) }
env = (JSON.parse(res.body) rescue {})
env = {} unless env.is_a?(Hash)
unless res.is_a?(Net::HTTPSuccess)
err = env["error"] || {}
raise ApiError.new(res.code.to_i, err["code"], err["message"] || res.message)
end
env["data"]
end
<?php
// needs the curl extension
const BASE = "https://api.skillsafe.ai/v1/app-api";
$TOKEN = getenv("SKILLSAFE_TOKEN") ?: "YOUR_TOKEN"; // step 2
class ApiError extends Exception {
public $status;
public $apiCode;
public function __construct($status, $code, $message) {
parent::__construct("$status $code: $message");
$this->status = $status;
$this->apiCode = $code;
}
}
function headers_for(array $extra = []): array {
global $TOKEN;
$h = ["Content-Type: application/json"];
if ($TOKEN) $h[] = "Authorization: Bearer $TOKEN";
foreach ($extra as $k => $v) $h[] = "$k: $v";
return $h;
}
function api(string $method, string $path, $body = null, array $headers = []) {
$ch = curl_init(BASE . $path);
curl_setopt_array($ch, [
CURLOPT_CUSTOMREQUEST => $method,
CURLOPT_HTTPHEADER => headers_for($headers),
CURLOPT_RETURNTRANSFER => true,
]);
if ($body !== null) curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($body, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE));
$raw = curl_exec($ch);
if ($raw === false) throw new RuntimeException(curl_error($ch));
$status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
curl_close($ch);
$env = json_decode($raw);
if (!is_object($env)) $env = new stdClass();
if ($status < 200 || $status > 299) {
$e = $env->error ?? new stdClass();
throw new ApiError($status, $e->code ?? null, $e->message ?? "HTTP $status");
}
return $env->data ?? null;
}
// Program.cs -- .NET 6+ console app (implicit usings on) with top-level statements; steps 2-6 (with the MakeInput local function) go ABOVE this class
using System.Text;
using System.Text.Json;
using System.Text.Json.Nodes;
static class Api
{
public const string Base = "https://api.skillsafe.ai/v1/app-api";
public static string Token = Environment.GetEnvironmentVariable("SKILLSAFE_TOKEN") ?? "YOUR_TOKEN"; // step 2
public static readonly HttpClient Http = new HttpClient();
public class ApiException : Exception
{
public int Status;
public string? Code;
public ApiException(int status, string? code, string message) : base($"{status} {code}: {message}")
{
Status = status;
Code = code;
}
}
public static HttpRequestMessage Request(string method, string path, object? body = null, IDictionary<string, string>? headers = null)
{
var req = new HttpRequestMessage(new HttpMethod(method), Base + path);
if (body != null) req.Content = new StringContent(JsonSerializer.Serialize(body), Encoding.UTF8, "application/json");
if (!string.IsNullOrEmpty(Token)) req.Headers.TryAddWithoutValidation("Authorization", "Bearer " + Token);
if (headers != null) foreach (var kv in headers) req.Headers.TryAddWithoutValidation(kv.Key, kv.Value);
return req;
}
public static ApiException ErrorFrom(HttpResponseMessage res, JsonNode? env)
{
var err = env?["error"];
return new ApiException((int)res.StatusCode, err?["code"]?.GetValue<string>(),
err?["message"]?.GetValue<string>() ?? res.ReasonPhrase ?? "error");
}
public static async Task<JsonNode?> Call(string method, string path, object? body = null, IDictionary<string, string>? headers = null)
{
using var req = Request(method, path, body, headers);
using var res = await Http.SendAsync(req);
var text = await res.Content.ReadAsStringAsync();
JsonNode? env = null;
try { env = JsonNode.Parse(text); } catch (JsonException) { }
if (!res.IsSuccessStatusCode) throw ErrorFrom(res, env);
return env?["data"];
}
}
Step 2 — a token
Two kinds work:
-
Personal — needed for a run. Both lanes are metered in credits on
gpt-terra, so a run needs a signed-in (user) token (the page says “The audit run is metered, so it needs an account.”, or the same of the fix run) unless the estimate sayssponsor_enabled. Sign in and copy your token from /tokens.html, then export it asSKILLSAFE_TOKEN(the samples fall back to the placeholderYOUR_TOKEN). -
Guest — enough for
/meand/estimate.POST /guestwith{"slug": "dots-desk"}and noAuthorizationheader, exactly assdk.jsguest()does. The response’sdatacarriestokenandguest_id. Reuse a token you already hold rather than minting a new one each time.
# personal token (needed for a run): copy it from /tokens.html, then
# export SKILLSAFE_TOKEN=... and skip the rest of this block
# guest token (enough for /me and /estimate): no Authorization header on this one call
TOKEN=$(curl -sS -X POST "$BASE/guest" \
-H "Content-Type: application/json" \
-d '{"slug":"dots-desk"}' | jq -r '.data.token')
echo "guest token: ${TOKEN:0:12}..."
# personal token (needed for a run): set SKILLSAFE_TOKEN (from /tokens.html) and skip this
if TOKEN in ("", "YOUR_TOKEN"):
TOKEN = "" # no Authorization header on /guest
guest = api("POST", "/guest", {"slug": "dots-desk"})
TOKEN = guest["token"]
print("guest", guest.get("guest_id"))
// personal token (needed for a run): paste it from /tokens.html into TOKEN and skip this
if (!TOKEN || TOKEN === "YOUR_TOKEN") {
TOKEN = ""; // no Authorization header on /guest
const guest = await api("POST", "/guest", { slug: "dots-desk" });
TOKEN = guest.token;
console.log("guest", guest.guest_id);
}
// inside main -- personal token (needed for a run): set SKILLSAFE_TOKEN (from /tokens.html) and skip this
if token == "" {
var guest struct {
Token string `json:"token"`
GuestID string `json:"guest_id"`
}
if err := api("POST", "/guest", map[string]string{"slug": "dots-desk"}, nil, &guest); err != nil {
panic(err)
}
token = guest.Token
fmt.Println("guest", guest.GuestID)
}
// inside main -- personal token (needed for a run): set SKILLSAFE_TOKEN (from /tokens.html) and skip this
if (token.isEmpty() || token.equals("YOUR_TOKEN")) {
token = ""; // no Authorization header on /guest
JsonNode guest = api("POST", "/guest", Map.of("slug", "dots-desk"), null);
token = guest.path("token").asText();
System.out.println("guest " + guest.path("guest_id").asText());
}
# personal token (needed for a run): set SKILLSAFE_TOKEN (from /tokens.html) and skip this
if $token.empty? || $token == "YOUR_TOKEN"
$token = "" # no Authorization header on /guest
guest = api("POST", "/guest", { slug: "dots-desk" })
$token = guest["token"]
puts "guest #{guest["guest_id"]}"
end
// personal token (needed for a run): set SKILLSAFE_TOKEN (from /tokens.html) and skip this
if ($TOKEN === "" || $TOKEN === "YOUR_TOKEN") {
$TOKEN = ""; // no Authorization header on /guest
$guest = api("POST", "/guest", ["slug" => "dots-desk"]);
$TOKEN = $guest->token;
echo "guest {$guest->guest_id}\n";
}
// top-level statements (above the Api class) -- personal token (needed for a run): set SKILLSAFE_TOKEN (from /tokens.html) and skip this
if (Api.Token == "" || Api.Token == "YOUR_TOKEN")
{
Api.Token = ""; // no Authorization header on /guest
var guest = await Api.Call("POST", "/guest", new { slug = "dots-desk" });
Api.Token = guest!["token"]!.GetValue<string>();
Console.WriteLine($"guest {guest["guest_id"]}");
}
Step 3 — GET /me
Who the token belongs to and what it can spend. sdk.js documents the shape as
{subject_type, subject_id, credits, profile?}. The page treats the caller as signed
in only when subject_type is "user", shows credits as the
balance (1 credit = $0.0001, so it divides by 10 000 for the dollar figure), and compares it
with the estimate in step 4 before it lets you run.
api GET /me | jq '.data // .error'
me = api("GET", "/me")
print(me["subject_type"], me.get("subject_id"), me.get("credits"))
signed_in = me["subject_type"] == "user"
const me = await api("GET", "/me");
console.log(me.subject_type, me.subject_id, me.credits);
const signedIn = me.subject_type === "user";
var me struct {
SubjectType string `json:"subject_type"`
SubjectID any `json:"subject_id"`
Credits any `json:"credits"`
}
if err := api("GET", "/me", nil, nil, &me); err != nil {
panic(err)
}
fmt.Println(me.SubjectType, me.SubjectID, me.Credits)
signedIn := me.SubjectType == "user"
_ = signedIn
JsonNode me = api("GET", "/me", null, null);
System.out.println(me.path("subject_type").asText() + " " + me.path("subject_id").asText() + " " + me.path("credits"));
boolean signedIn = me.path("subject_type").asText().equals("user");
me = api("GET", "/me")
puts [me["subject_type"], me["subject_id"], me["credits"]].join(" ")
signed_in = me["subject_type"] == "user"
$me = api("GET", "/me");
echo $me->subject_type, " ", $me->subject_id ?? "", " ", $me->credits ?? "", "\n";
$signedIn = $me->subject_type === "user";
var me = await Api.Call("GET", "/me");
Console.WriteLine($"{me?["subject_type"]} {me?["subject_id"]} {me?["credits"]}");
var signedIn = me?["subject_type"]?.GetValue<string>() == "user";
Step 4 — build the input, then POST /estimate
First a small makeInput that does what buildInput does: task,
then code as the paste the page would send, facts as a compact JSON string,
the note when it is not blank, and — for the fix lane only — the
audit_handoff string when the file carries one. It reads the file
build-check.js (or handoff.js) printed. The samples build the
audit input of the swarm example from swarm-check.json; step 6 reuses
makeInput for the bullets (fix) example. Then price it. The body of
/estimate is the same input you will send to /run; no job is created and
nothing is charged — /estimate is free. From the response the page reads:
| Field | Meaning |
|---|---|
hold_credits | A reservation, not a price: the worst case the platform holds while the run is in flight. The page shows it as “reserves N credits ($...) for the audit run” and adds that you are charged only for what the run actually uses, usually far less. What you pay is the job’s charged_credits after settlement (step 5). A balance below the hold is allowed, but the page warns that the reply may be cut short (truncated: true). |
min_credits | The smallest balance that can start a run. Below it the page disables the run button and names the shortfall, because the call would be a 402. |
sponsor_enabled | When true, a caller who is not signed in may run; otherwise the page asks them to sign in. |
warnings | Input warnings. They do not refuse the call; the page shows them next to the price (“input warnings: ...”), so check them before you run. |
The page re-prices whenever the paste, the note or the lane change. The amounts grow with the size
of code and facts, so read them from the call rather than hard-coding them.
# swarm-check.json: printed by build-check.js (see "The facts string").
# (.facts | tojson) turns the facts into ONE compact string, as JSON.stringify does.
BODY=$(jq -c --arg note "First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?" \
'{task: "audit", code, facts: (.facts | tojson), note: $note}' swarm-check.json)
# No page check at hand? facts: "{}" is accepted as a string, but the reply then has no page flags to answer.
# Fix lane after an audit: read handoff.js's output instead and add its string:
# '{task: "fix", code, facts: (.facts | tojson), note: $note} + (if .audit_handoff then {audit_handoff} else {} end)'
api POST /estimate -d "$BODY" \
| jq '.error // (.data | {hold_credits, min_credits, sponsor_enabled, warnings})'
def make_input(task, check_path, note=None):
"""The body the page sends: task, code, facts as a JSON STRING, an optional note, and
(fix lane only) the audit_handoff string -- every value a string."""
with open(check_path, encoding="utf-8") as f:
check = json.load(f) # build-check.js (or handoff.js) output
inp = {
"task": task,
"code": check["code"], # the paste as the page sends it
"facts": json.dumps(check["facts"], separators=(",", ":"), ensure_ascii=False), # a STRING, like JSON.stringify
}
n = (note or "").strip()
if n:
inp["note"] = n[:2000] # optional; the page caps it at 2000 chars
if task == "fix" and check.get("audit_handoff"):
inp["audit_handoff"] = check["audit_handoff"] # optional; already a JSON string
return inp
inp = make_input("audit", "swarm-check.json",
"First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?")
est = api("POST", "/estimate", inp)
print("hold", est.get("hold_credits"), "min", est.get("min_credits"),
"sponsored", est.get("sponsor_enabled"), "warnings", est.get("warnings") or [])
// The body the page sends: task, code, facts as a JSON STRING, an optional note,
// and (fix lane only) the audit_handoff string -- every value a string.
function makeInput(task, checkPath, note) {
const check = JSON.parse(readFileSync(checkPath, "utf8")); // build-check.js (or handoff.js) output
const input = {
task,
code: check.code, // the paste as the page sends it
facts: JSON.stringify(check.facts), // a STRING: the page's free check
};
const n = (note || "").trim();
if (n) input.note = n.length > 2000 ? n.slice(0, 2000) : n; // optional; max 2000 chars
if (task === "fix" && check.audit_handoff) input.audit_handoff = check.audit_handoff; // optional
return input;
}
const input = makeInput("audit", "swarm-check.json",
"First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?");
const est = await api("POST", "/estimate", input);
console.log("hold", est.hold_credits, "min", est.min_credits,
"sponsored", est.sponsor_enabled, "warnings", est.warnings || []);
// makeInput builds the body the page sends: task, code, facts as a JSON STRING,
// an optional note and (fix lane only) the audit_handoff string.
makeInput := func(task, checkPath, note string) map[string]any {
raw, err := os.ReadFile(checkPath) // build-check.js (or handoff.js) output
if err != nil {
panic(err)
}
var check struct {
Code string `json:"code"`
Facts json.RawMessage `json:"facts"`
AuditHandoff string `json:"audit_handoff"`
}
if err := json.Unmarshal(raw, &check); err != nil {
panic(err)
}
var facts bytes.Buffer
if err := json.Compact(&facts, check.Facts); err != nil { // keeps key order; travels as a STRING
panic(err)
}
in := map[string]any{"task": task, "code": check.Code, "facts": facts.String()}
if n := []rune(strings.TrimSpace(note)); len(n) > 0 {
if len(n) > 2000 {
n = n[:2000] // optional; the page caps it at 2000 chars
}
in["note"] = string(n)
}
if task == "fix" && check.AuditHandoff != "" {
in["audit_handoff"] = check.AuditHandoff // optional; already a JSON string
}
return in
}
input := makeInput("audit", "swarm-check.json",
"First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?")
var est struct {
HoldCredits any `json:"hold_credits"`
MinCredits any `json:"min_credits"`
SponsorEnabled bool `json:"sponsor_enabled"`
Warnings []any `json:"warnings"`
}
if err := api("POST", "/estimate", input, nil, &est); err != nil {
panic(err)
}
fmt.Printf("hold %v min %v sponsored %v warnings %v\n", est.HoldCredits, est.MinCredits, est.SponsorEnabled, est.Warnings)
// ---- add to the DotsDesk class, next to api(): the body the page sends
static Map<String, Object> makeInput(String task, String checkPath, String note) throws Exception {
JsonNode check = JSON.readTree(Files.readString(Path.of(checkPath))); // build-check.js (or handoff.js) output
Map<String, Object> in = new LinkedHashMap<>();
in.put("task", task);
in.put("code", check.path("code").asText()); // the paste as the page sends it
in.put("facts", JSON.writeValueAsString(check.path("facts"))); // a STRING, compact
String n = note == null ? "" : note.strip();
if (!n.isEmpty()) in.put("note", n.length() > 2000 ? n.substring(0, 2000) : n); // optional; max 2000 chars
if (task.equals("fix") && check.hasNonNull("audit_handoff")) in.put("audit_handoff", check.get("audit_handoff").asText());
return in;
}
// ---- inside main
Map<String, Object> input = makeInput("audit", "swarm-check.json",
"First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?");
JsonNode est = api("POST", "/estimate", input, null);
System.out.println("hold " + est.path("hold_credits") + " min " + est.path("min_credits")
+ " sponsored " + est.path("sponsor_enabled").asBoolean(false) + " warnings " + est.path("warnings"));
# The body the page sends: task, code, facts as a JSON STRING, an optional note,
# and (fix lane only) the audit_handoff string -- every value a string.
def make_input(task, check_path, note = nil)
check = JSON.parse(File.read(check_path, encoding: "UTF-8")) # build-check.js (or handoff.js) output
input = {
task: task,
code: check["code"], # the paste as the page sends it
facts: JSON.generate(check["facts"]) # a STRING, compact
}
n = note.to_s.strip
input[:note] = n[0, 2000] unless n.empty? # optional; max 2000 chars
input[:audit_handoff] = check["audit_handoff"] if task == "fix" && !check["audit_handoff"].to_s.empty?
input
end
input = make_input("audit", "swarm-check.json",
"First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?")
est = api("POST", "/estimate", input)
puts "hold #{est["hold_credits"]} min #{est["min_credits"]} " \
"sponsored #{est["sponsor_enabled"]} warnings #{(est["warnings"] || []).inspect}"
// The body the page sends: task, code, facts as a JSON STRING, an optional note,
// and (fix lane only) the audit_handoff string -- every value a string.
function make_input(string $task, string $checkPath, string $note = ""): array {
// decode to objects (not arrays) so an empty {} stays {} when re-encoded
$check = json_decode(file_get_contents($checkPath)); // build-check.js (or handoff.js) output
$input = [
"task" => $task,
"code" => $check->code, // the paste as the page sends it
"facts" => json_encode($check->facts, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE), // a STRING
];
$n = trim($note);
if ($n !== "") $input["note"] = mb_substr($n, 0, 2000); // optional; max 2000 chars
if ($task === "fix" && !empty($check->audit_handoff)) $input["audit_handoff"] = $check->audit_handoff;
return $input;
}
$input = make_input("audit", "swarm-check.json",
"First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?");
$est = api("POST", "/estimate", $input);
echo "hold ", $est->hold_credits ?? "-", " min ", $est->min_credits ?? "-",
" sponsored ", json_encode($est->sponsor_enabled ?? false),
" warnings ", json_encode($est->warnings ?? []), "\n";
// The body the page sends: task, code, facts as a JSON STRING, an optional note,
// and (fix lane only) the audit_handoff string -- every value a string.
static Dictionary<string, string> MakeInput(string task, string checkPath, string? note = null)
{
var compact = new JsonSerializerOptions { Encoder = System.Text.Encodings.Web.JavaScriptEncoder.UnsafeRelaxedJsonEscaping };
var check = JsonNode.Parse(File.ReadAllText(checkPath))!; // build-check.js (or handoff.js) output
var input = new Dictionary<string, string>
{
["task"] = task,
["code"] = check["code"]!.GetValue<string>(), // the paste as the page sends it
["facts"] = check["facts"]!.ToJsonString(compact), // a STRING, compact
};
var n = (note ?? "").Trim();
if (n.Length > 0) input["note"] = n.Length > 2000 ? n[..2000] : n; // optional; max 2000 chars
var handoff = check["audit_handoff"]?.GetValue<string>();
if (task == "fix" && !string.IsNullOrEmpty(handoff)) input["audit_handoff"] = handoff;
return input;
}
var input = MakeInput("audit", "swarm-check.json",
"First DOTS feature on the team. The spawner and the drone movement are going into Friday's playtest build - what breaks with Burst and the safety checks on, and what do we fix first?");
var est = await Api.Call("POST", "/estimate", input);
Console.WriteLine($"hold {est?["hold_credits"]} min {est?["min_credits"]} " +
$"sponsored {est?["sponsor_enabled"]} warnings {est?["warnings"]?.ToJsonString() ?? "[]"}");
Step 5 — POST /run, then poll the job (audit)
Send the same input to /run with an Idempotency-Key header, using a
personal token. Its data carries a job_id. Poll
GET /jobs/{job_id} the way sdk.js waitForJob does: every
second until status is succeeded or failed, giving up on
the client side after 180 seconds. On the finished job, read:
output.output— the model’s reply as a string: the JSON object from the output contract of the lane you asked for. Parse it yourself (from the first{to the last}). The samples print the verdict and headline, each area’s status, each finding’sid,file,line,severityand number of edits, then each flag answer. Keep the text:recheck.jsreads it.truncated—truewhen the reply was cut short because the balance ran out. The page then closes the cut-off JSON, shows what arrived as a partial result (“N of 9 sections recovered” for an audit, of 8 for a fix run), and says it was cut short by the available balance.charged_credits— the real cost of the run, as opposed to the estimate’shold_creditsreservation. The page re-reads/meafterwards for the new balance.error— on afailedjob.
Idempotency key. Resending a request with the same key must not start a second
paid run, so derive the key from the input, not from the clock — and include the lane, so an
audit and a fix run of the same paste never share a key. The page uses
dots-desk:<lane>:<inputHash>:a<attempt> (app.js
run), where <lane> is audit or fix,
<inputHash> is a 32-bit djb2 hash of JSON.stringify(input) in hex, a
dash, and the string’s length in hex (app.js inputHash, over the
input without retry_note), and <attempt> is 1
for a normal run and 2 for the automatic reformat retry (which also adds
retry_note). For the two worked examples that is
dots-desk:audit:ebdd3062-27b2:a1 (swarm audit) and dots-desk:fix:3babff4d-228c:a1
(bullets fix); the fix run of the swarm audit handed on (above) is dots-desk:fix:e06f3253-26e3:a1. The format is the page’s
convention, not a requirement: any stable, unique string does. The samples below use the lane and a
SHA-256 prefix.
The page itself uses /run-stream (step 6), not /run; both take the
same body and header.
KEY="dots-desk:audit:$(printf '%s' "$BODY" | shasum -a 256 | cut -c1-16):a1"
JOB=$(api POST /run -H "Idempotency-Key: $KEY" -d "$BODY" | jq -r '.data.job_id')
for i in $(seq 180); do # 1 s interval, 180 s client-side limit
J=$(api GET "/jobs/$JOB")
S=$(printf '%s' "$J" | jq -r '.data.status')
if [ "$S" = "succeeded" ] || [ "$S" = "failed" ]; then break; fi
sleep 1
done
printf '%s' "$J" | jq '.data | {status, truncated, charged_credits, error}'
printf '%s' "$J" | jq -r '.data.output.output' \
| jq '{verdict, headline, areas: [(.areas // [])[] | {area, status}],
findings: [(.findings // [])[] | {id, file, line, severity, edits: ((.edits // []) | length)}],
flag_answers: [(.flag_answers // [])[] | {flag, status}]}'
body = json.dumps(inp)
key = "dots-desk:audit:" + hashlib.sha256(body.encode()).hexdigest()[:16] + ":a1"
job_id = api("POST", "/run", inp, {"Idempotency-Key": key})["job_id"]
deadline = time.time() + 180 # 1 s interval, 180 s client-side limit
while True:
job = api("GET", "/jobs/" + urllib.parse.quote(job_id, safe=""))
if job["status"] in ("succeeded", "failed"):
break
if time.time() > deadline:
raise TimeoutError("job timed out")
time.sleep(1)
if job["status"] == "failed":
raise SystemExit(f"run failed: {job.get('error')}")
print("truncated:", job.get("truncated") is True, "charged:", job.get("charged_credits"))
text = (job.get("output") or {}).get("output") or ""
reply = json.loads(text[text.index("{"): text.rindex("}") + 1])
print(reply["verdict"], "-", reply["headline"])
for s in reply.get("areas", []):
print("area", s["area"], s["status"])
for f in reply.get("findings", []):
print(f["id"], f["file"], f.get("line"), f["severity"], len(f.get("edits") or []), "edit(s)")
for a in reply.get("flag_answers", []):
print("answer", a["flag"], a["status"])
const key = "dots-desk:audit:" +
createHash("sha256").update(JSON.stringify(input)).digest("hex").slice(0, 16) + ":a1";
const { job_id } = await api("POST", "/run", input, { "Idempotency-Key": key });
let job;
const deadline = Date.now() + 180000; // 1 s interval, 180 s client-side limit
for (;;) {
job = await api("GET", "/jobs/" + encodeURIComponent(job_id));
if (job.status === "succeeded" || job.status === "failed") break;
if (Date.now() > deadline) throw new Error("job timed out");
await new Promise((r) => setTimeout(r, 1000));
}
if (job.status === "failed") throw new Error("run failed: " + JSON.stringify(job.error));
console.log("truncated:", job.truncated === true, "charged:", job.charged_credits);
const text = (job.output && job.output.output) || "";
const reply = JSON.parse(text.slice(text.indexOf("{"), text.lastIndexOf("}") + 1));
console.log(reply.verdict, "-", reply.headline);
for (const s of reply.areas || []) console.log("area", s.area, s.status);
for (const f of reply.findings || []) console.log(f.id, f.file, f.line, f.severity, (f.edits || []).length, "edit(s)");
for (const a of reply.flag_answers || []) console.log("answer", a.flag, a.status);
inputJSON, _ := json.Marshal(input)
sum := sha256.Sum256(inputJSON)
key := "dots-desk:audit:" + hex.EncodeToString(sum[:8]) + ":a1"
var started struct {
JobID string `json:"job_id"`
}
if err := api("POST", "/run", input, map[string]string{"Idempotency-Key": key}, &started); err != nil {
panic(err)
}
type jobT struct {
Status string `json:"status"`
Output *struct {
Output string `json:"output"`
} `json:"output"`
Truncated bool `json:"truncated"`
ChargedCredits any `json:"charged_credits"`
Error any `json:"error"`
}
var job jobT
deadline := time.Now().Add(180 * time.Second) // 1 s interval, 180 s client-side limit
for {
job = jobT{}
if err := api("GET", "/jobs/"+url.PathEscape(started.JobID), nil, nil, &job); err != nil {
panic(err)
}
if job.Status == "succeeded" || job.Status == "failed" {
break
}
if time.Now().After(deadline) {
panic("job timed out")
}
time.Sleep(time.Second)
}
if job.Status == "failed" {
panic(fmt.Sprintf("run failed: %v", job.Error))
}
fmt.Println("truncated:", job.Truncated, "charged:", job.ChargedCredits)
text := ""
if job.Output != nil {
text = job.Output.Output
}
var reply map[string]any
if a, b := strings.Index(text, "{"), strings.LastIndex(text, "}"); a >= 0 && b > a {
if err := json.Unmarshal([]byte(text[a:b+1]), &reply); err != nil {
panic(err)
}
}
fmt.Println(reply["verdict"], "-", reply["headline"])
areas, _ := reply["areas"].([]any)
for _, e := range areas {
s, _ := e.(map[string]any)
fmt.Println("area", s["area"], s["status"])
}
findings, _ := reply["findings"].([]any)
for _, e := range findings {
f, _ := e.(map[string]any)
edits, _ := f["edits"].([]any)
fmt.Println(f["id"], f["file"], f["line"], f["severity"], len(edits), "edit(s)")
}
answers, _ := reply["flag_answers"].([]any)
for _, e := range answers {
a, _ := e.(map[string]any)
fmt.Println("answer", a["flag"], a["status"])
}
byte[] digest = MessageDigest.getInstance("SHA-256").digest(JSON.writeValueAsBytes(input));
String key = "dots-desk:audit:" + HexFormat.of().formatHex(digest, 0, 8) + ":a1";
String jobId = api("POST", "/run", input, Map.of("Idempotency-Key", key)).path("job_id").asText();
JsonNode job;
long deadline = System.currentTimeMillis() + 180_000; // 1 s interval, 180 s client-side limit
while (true) {
job = api("GET", "/jobs/" + URLEncoder.encode(jobId, StandardCharsets.UTF_8), null, null);
String s = job.path("status").asText();
if (s.equals("succeeded") || s.equals("failed")) break;
if (System.currentTimeMillis() > deadline) throw new RuntimeException("job timed out");
Thread.sleep(1000);
}
if (job.path("status").asText().equals("failed")) throw new RuntimeException("run failed: " + job.path("error"));
System.out.println("truncated: " + job.path("truncated").asBoolean(false) + ", charged: " + job.path("charged_credits"));
String text = job.path("output").path("output").asText("");
JsonNode reply = JSON.readTree(text.substring(text.indexOf('{'), text.lastIndexOf('}') + 1));
System.out.println(reply.path("verdict").asText() + " - " + reply.path("headline").asText());
for (JsonNode s : reply.path("areas")) {
System.out.println("area " + s.path("area").asText() + " " + s.path("status").asText());
}
for (JsonNode f : reply.path("findings")) {
System.out.println(f.path("id").asText() + " " + f.path("file").asText() + " " + f.path("line") + " "
+ f.path("severity").asText() + " " + f.path("edits").size() + " edit(s)");
}
for (JsonNode a : reply.path("flag_answers")) {
System.out.println("answer " + a.path("flag").asText() + " " + a.path("status").asText());
}
key = "dots-desk:audit:#{Digest::SHA256.hexdigest(JSON.generate(input))[0, 16]}:a1"
job_id = api("POST", "/run", input, { "Idempotency-Key" => key })["job_id"]
deadline = Time.now + 180 # 1 s interval, 180 s client-side limit
job = nil
loop do
job = api("GET", "/jobs/#{URI.encode_www_form_component(job_id)}")
break if %w[succeeded failed].include?(job["status"])
raise "job timed out" if Time.now > deadline
sleep 1
end
raise "run failed: #{job["error"].inspect}" if job["status"] == "failed"
puts "truncated: #{job["truncated"] == true}, charged: #{job["charged_credits"]}"
text = (job["output"] || {})["output"].to_s
reply = JSON.parse(text[text.index("{")..text.rindex("}")])
puts "#{reply["verdict"]} - #{reply["headline"]}"
(reply["areas"] || []).each { |s| puts "area #{s["area"]} #{s["status"]}" }
(reply["findings"] || []).each { |f| puts "#{f["id"]} #{f["file"]} #{f["line"].inspect} #{f["severity"]} #{(f["edits"] || []).size} edit(s)" }
(reply["flag_answers"] || []).each { |a| puts "answer #{a["flag"]} #{a["status"]}" }
$key = "dots-desk:audit:" . substr(hash("sha256", json_encode($input)), 0, 16) . ":a1";
$jobId = api("POST", "/run", $input, ["Idempotency-Key" => $key])->job_id;
$deadline = time() + 180; // 1 s interval, 180 s client-side limit
while (true) {
$job = api("GET", "/jobs/" . rawurlencode($jobId));
if (in_array($job->status, ["succeeded", "failed"], true)) break;
if (time() > $deadline) throw new RuntimeException("job timed out");
sleep(1);
}
if ($job->status === "failed") throw new RuntimeException("run failed: " . json_encode($job->error ?? null));
echo "truncated: ", json_encode(($job->truncated ?? false) === true), ", charged: ", $job->charged_credits ?? "-", "\n";
$text = $job->output->output ?? "";
$reply = json_decode(substr($text, strpos($text, "{"), strrpos($text, "}") - strpos($text, "{") + 1));
echo $reply->verdict, " - ", $reply->headline, "\n";
foreach ($reply->areas ?? [] as $s) echo "area ", $s->area, " ", $s->status, "\n";
foreach ($reply->findings ?? [] as $f) echo $f->id, " ", $f->file, " ", json_encode($f->line ?? null), " ", $f->severity, " ", count($f->edits ?? []), " edit(s)\n";
foreach ($reply->flag_answers ?? [] as $a) echo "answer ", $a->flag, " ", $a->status, "\n";
var digest = System.Security.Cryptography.SHA256.HashData(Encoding.UTF8.GetBytes(JsonSerializer.Serialize(input)));
var key = "dots-desk:audit:" + Convert.ToHexString(digest, 0, 8).ToLowerInvariant() + ":a1";
var started = await Api.Call("POST", "/run", input, new Dictionary<string, string> { ["Idempotency-Key"] = key });
var jobId = started!["job_id"]!.GetValue<string>();
JsonNode job;
var deadline = DateTime.UtcNow.AddSeconds(180); // 1 s interval, 180 s client-side limit
while (true)
{
job = (await Api.Call("GET", "/jobs/" + Uri.EscapeDataString(jobId)))!;
var s = job["status"]?.GetValue<string>();
if (s == "succeeded" || s == "failed") break;
if (DateTime.UtcNow > deadline) throw new TimeoutException("job timed out");
await Task.Delay(1000);
}
if (job["status"]?.GetValue<string>() == "failed") throw new Exception($"run failed: {job["error"]?.ToJsonString()}");
var truncated = job["truncated"] is JsonValue t && t.TryGetValue(out bool tb) && tb;
Console.WriteLine($"truncated: {truncated}, charged: {job["charged_credits"]}");
var text = job["output"]?["output"]?.GetValue<string>() ?? "";
var reply = JsonNode.Parse(text[text.IndexOf('{')..(text.LastIndexOf('}') + 1)])!;
Console.WriteLine($"{reply["verdict"]} - {reply["headline"]}");
foreach (var s in reply["areas"]?.AsArray() ?? new JsonArray())
Console.WriteLine($"area {s?["area"]} {s?["status"]}");
foreach (var f in reply["findings"]?.AsArray() ?? new JsonArray())
Console.WriteLine($"{f?["id"]} {f?["file"]} {f?["line"]?.ToJsonString() ?? "null"} {f?["severity"]} {f?["edits"]?.AsArray().Count ?? 0} edit(s)");
foreach (var a in reply["flag_answers"]?.AsArray() ?? new JsonArray())
Console.WriteLine($"answer {a?["flag"]} {a?["status"]}");
Step 6 — POST /run-stream (Server-Sent Events, fix)
The alternative to step 5, and what the page uses: same kind of body, same
Idempotency-Key header, one request. Run one or the other for a given input, not
both. To show the second lane, the samples build the fix input of the
bullets example (with its own key) and stream it; to stream the audit input instead, pass the
step 4 input and key. The response is text/event-stream. sdk.js splits
it into frames on a blank line, takes the event name from an event: line (default
message) and concatenates the data: lines, skips frames with no data or
with data that is not JSON, and handles these events:
| Event | Data | What the SDK does |
|---|---|---|
delta | {text} | Passes text to onDelta. |
job | job info | Passes it to onJob (the page uses it to advance its progress display). |
done | the final payload: {job_id, status, charged_credits, output} | Keeps it as the result. |
pending | a payload | Treated exactly like done. If it carries a job_id and no output, poll that job as in step 5. |
error | {message, code, job_id} | After the stream ends, raises an error with those fields. |
If the response is not text/event-stream, it is an ordinary JSON envelope:
the SDK returns its data (an idempotent replay returns this way) or raises the
error on a non-2xx status. Handle both shapes.
From the final payload the page reads output.output (falling back to the
concatenated delta text), truncated and charged_credits.
Browsers receive progress ticks rather than deltas from this endpoint, so the page relies on the
final payload; if the stream fails part-way, it tries to recover a partial reply from whatever
delta text arrived. The samples print the verdict and headline, each returned file’s path and
size, each change (function, flags and change), each
verification step, each open item and each question. To put the files into the paste and re-check
them the way the page’s “Put every file into the paste” does, keep the reply text
and run recheck.js with the lane fix. To fix code you audited, read handoff.js’s output instead of
bullets-check.json (for the swarm, swarm-fix-check.json): makeInput then carries its audit_handoff.
# the fix worked example: bullets-check.json from build-check.js
# (for audited code, read handoff.js's output instead; the + (...) adds its audit_handoff)
FBODY=$(jq -c --arg note "Bullets throw a safety exception every frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still prototyping." \
'{task: "fix", code, facts: (.facts | tojson), note: $note} + (if .audit_handoff then {audit_handoff} else {} end)' \
bullets-check.json)
FKEY="dots-desk:fix:$(printf '%s' "$FBODY" | shasum -a 256 | cut -c1-16):a1"
# -N turns off buffering; the whole stream lands in $STREAM
STREAM=$(api POST /run-stream -N -H "Idempotency-Key: $FKEY" -d "$FBODY")
# frames look like:
# event: job
# data: {...}
#
# event: done
# data: {"job_id":"...","status":"...","charged_credits":...,"output":{"output":"{\"task\":\"fix\",...}"}}
# the final reply text, from the done (or pending) frame:
REPLY=$(printf '%s\n' "$STREAM" \
| awk '/^event:/{ev=$2} /^data:/ && (ev=="done" || ev=="pending"){sub(/^data: */,""); print}' \
| jq -r '.output.output')
# an idempotent replay answers with a plain JSON envelope instead: REPLY=$(printf '%s' "$STREAM" | jq -r '.data.output.output')
printf '%s' "$REPLY" | jq '{verdict, headline,
files: [(.files // [])[] | {path, characters: (.content | length)}],
changes: [(.changes // [])[] | {function, flags, change}], verify, open, questions}'
# the fix worked example: bullets-check.json from build-check.js
# (for audited code, pass handoff.js's output instead: make_input adds its audit_handoff)
fix_inp = make_input("fix", "bullets-check.json",
"Bullets throw a safety exception every frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still prototyping.")
fix_key = "dots-desk:fix:" + hashlib.sha256(json.dumps(fix_inp).encode()).hexdigest()[:16] + ":a1"
h = {"Content-Type": "application/json", "Authorization": "Bearer " + TOKEN, "Idempotency-Key": fix_key}
done, failure, streamed = None, None, ""
with requests.post(BASE + "/run-stream", headers=h, data=json.dumps(fix_inp), stream=True) as r:
if "text/event-stream" not in r.headers.get("content-type", ""):
try:
env = r.json()
except ValueError:
env = {}
if not r.ok:
err = env.get("error") or {}
raise ApiError(r.status_code, err.get("code"), err.get("message") or r.reason)
done = env.get("data")
else:
event, data = "message", ""
for line in r.iter_lines(decode_unicode=True):
if line == "": # a blank line ends a frame
if data:
try:
payload = json.loads(data)
except ValueError:
payload = None
if event == "delta" and payload is not None:
streamed += payload.get("text") or ""
elif event == "job":
print("job", payload)
elif event in ("done", "pending"):
done = payload
elif event == "error":
failure = payload
event, data = "message", ""
elif line.startswith("event:"):
event = line[6:].strip()
elif line.startswith("data:"):
data += line[5:].strip()
if failure:
raise SystemExit(f"{failure.get('code')}: {failure.get('message')} (job {failure.get('job_id')})")
done = done or {}
full = (done.get("output") or {}).get("output") or streamed
print("truncated:", done.get("truncated") is True, "charged:", done.get("charged_credits"))
result = json.loads(full[full.index("{"): full.rindex("}") + 1])
print(result["verdict"], "-", result["headline"])
for f in result.get("files", []):
print("file", f["path"], len(f.get("content") or ""), "characters")
for c in result.get("changes", []):
print("change", c.get("function"), ",".join(c.get("flags") or []) or "-", "-", c.get("change"))
for step in result.get("verify", []):
print("verify", step)
for o in result.get("open", []):
print("open", o["item"], "-", o.get("reason"))
for q in result.get("questions", []):
print("question", q)
// the fix worked example: bullets-check.json from build-check.js
// (for audited code, pass handoff.js's output instead: makeInput adds its audit_handoff)
const fixInput = makeInput("fix", "bullets-check.json",
"Bullets throw a safety exception every frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still prototyping.");
const fixKey = "dots-desk:fix:" +
createHash("sha256").update(JSON.stringify(fixInput)).digest("hex").slice(0, 16) + ":a1";
const res = await fetch(BASE + "/run-stream", {
method: "POST",
headers: { "Content-Type": "application/json", Authorization: "Bearer " + TOKEN, "Idempotency-Key": fixKey },
body: JSON.stringify(fixInput),
});
let done = null, failure = null, streamed = "";
if (!(res.headers.get("content-type") || "").includes("text/event-stream")) {
const json = await res.json().catch(() => ({}));
if (!res.ok) throw new Error((json.error && json.error.message) || res.statusText);
done = json.data;
} else {
const reader = res.body.getReader();
const decoder = new TextDecoder();
let buffer = "";
for (;;) {
const chunk = await reader.read();
if (chunk.done) break;
buffer += decoder.decode(chunk.value, { stream: true });
let idx;
while ((idx = buffer.indexOf("\n\n")) >= 0) {
const frame = buffer.slice(0, idx);
buffer = buffer.slice(idx + 2);
let event = "message", dataStr = "";
for (const line of frame.split("\n")) {
if (line.startsWith("event:")) event = line.slice(6).trim();
else if (line.startsWith("data:")) dataStr += line.slice(5).trim();
}
if (!dataStr) continue;
let data;
try { data = JSON.parse(dataStr); } catch { continue; }
if (event === "delta") streamed += data.text || "";
else if (event === "job") console.log("job", data);
else if (event === "done" || event === "pending") done = data;
else if (event === "error") failure = data;
}
}
}
if (failure) throw new Error(`${failure.code}: ${failure.message} (job ${failure.job_id})`);
const full = (done && done.output && done.output.output) || streamed;
console.log("truncated:", !!(done && done.truncated), "charged:", done && done.charged_credits);
const result = JSON.parse(full.slice(full.indexOf("{"), full.lastIndexOf("}") + 1));
console.log(result.verdict, "-", result.headline);
for (const f of result.files || []) console.log("file", f.path, (f.content || "").length, "characters");
for (const c of result.changes || []) console.log("change", c.function, (c.flags || []).join(",") || "-", "-", c.change);
for (const step of result.verify || []) console.log("verify", step);
for (const o of result.open || []) console.log("open", o.item, "-", o.reason);
for (const q of result.questions || []) console.log("question", q);
// the fix worked example: bullets-check.json from build-check.js
// (for audited code, pass handoff.js's output instead: makeInput adds its audit_handoff)
fixInput := makeInput("fix", "bullets-check.json",
"Bullets throw a safety exception every frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still prototyping.")
fixJSON, _ := json.Marshal(fixInput)
fixSum := sha256.Sum256(fixJSON)
fixKey := "dots-desk:fix:" + hex.EncodeToString(fixSum[:8]) + ":a1"
sreq, err := newRequest("POST", "/run-stream", fixInput, map[string]string{"Idempotency-Key": fixKey})
if err != nil {
panic(err)
}
sres, err := http.DefaultClient.Do(sreq)
if err != nil {
panic(err)
}
defer sres.Body.Close()
var done, failure map[string]any
var streamed strings.Builder
if !strings.Contains(sres.Header.Get("Content-Type"), "text/event-stream") {
var env envelope
_ = json.NewDecoder(sres.Body).Decode(&env)
if sres.StatusCode < 200 || sres.StatusCode > 299 {
panic(errorFrom(sres, env))
}
_ = json.Unmarshal(env.Data, &done)
} else {
sc := bufio.NewScanner(sres.Body)
sc.Buffer(make([]byte, 64*1024), 16*1024*1024) // the done frame can be long
event, data := "message", ""
for sc.Scan() {
line := sc.Text()
switch {
case line == "": // a blank line ends a frame
if data != "" {
var p map[string]any
if json.Unmarshal([]byte(data), &p) == nil {
switch event {
case "delta":
if t, ok := p["text"].(string); ok {
streamed.WriteString(t)
}
case "job":
fmt.Println("job", p)
case "done", "pending":
done = p
case "error":
failure = p
}
}
}
event, data = "message", ""
case strings.HasPrefix(line, "event:"):
event = strings.TrimSpace(line[6:])
case strings.HasPrefix(line, "data:"):
data += strings.TrimSpace(line[5:])
}
}
}
if failure != nil {
panic(fmt.Sprintf("%v: %v (job %v)", failure["code"], failure["message"], failure["job_id"]))
}
full := streamed.String()
if out, ok := done["output"].(map[string]any); ok {
if s, ok := out["output"].(string); ok && s != "" {
full = s
}
}
fmt.Println("truncated:", done["truncated"] == true, "charged:", done["charged_credits"])
var result map[string]any
if a, b := strings.Index(full, "{"), strings.LastIndex(full, "}"); a >= 0 && b > a {
if err := json.Unmarshal([]byte(full[a:b+1]), &result); err != nil {
panic(err)
}
}
fmt.Println(result["verdict"], "-", result["headline"])
files, _ := result["files"].([]any)
for _, e := range files {
f, _ := e.(map[string]any)
c, _ := f["content"].(string)
fmt.Println("file", f["path"], len([]rune(c)), "characters")
}
changes, _ := result["changes"].([]any)
for _, e := range changes {
c, _ := e.(map[string]any)
var flags []string
if fs, ok := c["flags"].([]any); ok {
for _, fl := range fs {
flags = append(flags, fmt.Sprint(fl))
}
}
fl := strings.Join(flags, ",")
if fl == "" {
fl = "-"
}
fmt.Println("change", c["function"], fl, "-", c["change"])
}
verify, _ := result["verify"].([]any)
for _, st := range verify {
fmt.Println("verify", st)
}
open, _ := result["open"].([]any)
for _, e := range open {
o, _ := e.(map[string]any)
fmt.Println("open", o["item"], "-", o["reason"])
}
questions, _ := result["questions"].([]any)
for _, q := range questions {
fmt.Println("question", q)
}
// the fix worked example: bullets-check.json from build-check.js
// (for audited code, pass handoff.js's output instead: makeInput adds its audit_handoff)
Map<String, Object> fixInput = makeInput("fix", "bullets-check.json",
"Bullets throw a safety exception every frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still prototyping.");
byte[] fixDigest = MessageDigest.getInstance("SHA-256").digest(JSON.writeValueAsBytes(fixInput));
String fixKey = "dots-desk:fix:" + HexFormat.of().formatHex(fixDigest, 0, 8) + ":a1";
HttpRequest sreq = request("POST", "/run-stream", fixInput, Map.of("Idempotency-Key", fixKey)).build();
HttpResponse<Stream<String>> sres = HTTP.send(sreq, HttpResponse.BodyHandlers.ofLines());
JsonNode done = null, failure = null;
StringBuilder streamed = new StringBuilder();
if (!sres.headers().firstValue("content-type").orElse("").contains("text/event-stream")) {
JsonNode env = JSON.readTree(sres.body().collect(Collectors.joining("\n")));
if (env == null) env = JSON.createObjectNode();
if (sres.statusCode() / 100 != 2) throw errorFrom(sres.statusCode(), env);
done = env.path("data");
} else {
String event = "message";
StringBuilder data = new StringBuilder();
Iterator<String> it = sres.body().iterator();
while (it.hasNext()) {
String line = it.next();
if (line.isEmpty()) { // a blank line ends a frame
if (data.length() > 0) {
JsonNode p = null;
try { p = JSON.readTree(data.toString()); } catch (Exception ignored) { }
if (p != null) {
switch (event) {
case "delta": streamed.append(p.path("text").asText("")); break;
case "job": System.out.println("job " + p); break;
case "done": case "pending": done = p; break;
case "error": failure = p; break;
default: break;
}
}
}
event = "message";
data.setLength(0);
} else if (line.startsWith("event:")) event = line.substring(6).trim();
else if (line.startsWith("data:")) data.append(line.substring(5).trim());
}
}
if (failure != null) {
throw new RuntimeException(failure.path("code").asText() + ": " + failure.path("message").asText()
+ " (job " + failure.path("job_id").asText() + ")");
}
String full = done == null ? "" : done.path("output").path("output").asText("");
if (full.isEmpty()) full = streamed.toString();
System.out.println("truncated: " + (done != null && done.path("truncated").asBoolean(false))
+ ", charged: " + (done == null ? "-" : done.path("charged_credits").toString()));
JsonNode result = JSON.readTree(full.substring(full.indexOf('{'), full.lastIndexOf('}') + 1));
System.out.println(result.path("verdict").asText() + " - " + result.path("headline").asText());
for (JsonNode f : result.path("files")) {
System.out.println("file " + f.path("path").asText() + " " + f.path("content").asText("").codePointCount(0, f.path("content").asText("").length()) + " characters");
}
for (JsonNode c : result.path("changes")) {
List<String> flags = new ArrayList<>();
c.path("flags").forEach(fl -> flags.add(fl.asText()));
System.out.println("change " + c.path("function").asText() + " " + (flags.isEmpty() ? "-" : String.join(",", flags))
+ " - " + c.path("change").asText());
}
for (JsonNode step : result.path("verify")) System.out.println("verify " + step.asText());
for (JsonNode o : result.path("open")) System.out.println("open " + o.path("item").asText() + " - " + o.path("reason").asText());
for (JsonNode q : result.path("questions")) System.out.println("question " + q.asText());
# the fix worked example: bullets-check.json from build-check.js
# (for audited code, pass handoff.js's output instead: make_input adds its audit_handoff)
fix_input = make_input("fix", "bullets-check.json",
"Bullets throw a safety exception every frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still prototyping.")
fix_key = "dots-desk:fix:#{Digest::SHA256.hexdigest(JSON.generate(fix_input))[0, 16]}:a1"
uri, req = build_request("POST", "/run-stream", fix_input, { "Idempotency-Key" => fix_key })
done = failure = nil
streamed = +""
Net::HTTP.start(uri.host, uri.port, use_ssl: true, read_timeout: 300) do |http|
http.request(req) do |res|
unless res["content-type"].to_s.include?("text/event-stream")
env = (JSON.parse(res.body) rescue {})
unless res.is_a?(Net::HTTPSuccess)
raise ApiError.new(res.code.to_i, env.dig("error", "code"), env.dig("error", "message") || res.message)
end
done = env["data"]
next
end
buf = +""
res.read_body do |chunk|
buf << chunk
while (i = buf.index("\n\n"))
frame = buf.slice!(0, i + 2)
event = "message"
data = +""
frame.split("\n").each do |line|
if line.start_with?("event:") then event = line[6..].strip
elsif line.start_with?("data:") then data << line[5..].strip
end
end
next if data.empty?
payload = (JSON.parse(data) rescue nil)
next if payload.nil?
case event
when "delta" then streamed << payload["text"].to_s
when "job" then puts "job #{payload.inspect}"
when "done", "pending" then done = payload
when "error" then failure = payload
end
end
end
end
end
raise "#{failure["code"]}: #{failure["message"]} (job #{failure["job_id"]})" if failure
done ||= {}
full = (done["output"] || {})["output"].to_s
full = streamed if full.empty?
puts "truncated: #{done["truncated"] == true}, charged: #{done["charged_credits"]}"
result = JSON.parse(full[full.index("{")..full.rindex("}")])
puts "#{result["verdict"]} - #{result["headline"]}"
(result["files"] || []).each { |f| puts "file #{f["path"]} #{f["content"].to_s.length} characters" }
(result["changes"] || []).each do |c|
flags = (c["flags"] || []).join(",")
puts "change #{c["function"]} #{flags.empty? ? "-" : flags} - #{c["change"]}"
end
(result["verify"] || []).each { |step| puts "verify #{step}" }
(result["open"] || []).each { |o| puts "open #{o["item"]} - #{o["reason"]}" }
(result["questions"] || []).each { |q| puts "question #{q}" }
// the fix worked example: bullets-check.json from build-check.js
// (for audited code, pass handoff.js's output instead: make_input adds its audit_handoff)
$fixInput = make_input("fix", "bullets-check.json",
"Bullets throw a safety exception every frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still prototyping.");
$fixKey = "dots-desk:fix:" . substr(hash("sha256", json_encode($fixInput)), 0, 16) . ":a1";
$done = null; $failure = null; $streamed = ""; $buf = ""; $ctype = "";
$handle = function (string $event, string $data) use (&$done, &$failure, &$streamed) {
$p = json_decode($data);
if ($p === null) return; // not JSON: skipped, as sdk.js does
switch ($event) {
case "delta": $streamed .= $p->text ?? ""; break;
case "job": echo "job ", json_encode($p), "\n"; break;
case "done": case "pending": $done = $p; break;
case "error": $failure = $p; break;
}
};
$ch = curl_init(BASE . "/run-stream");
curl_setopt_array($ch, [
CURLOPT_POST => true,
CURLOPT_HTTPHEADER => headers_for(["Idempotency-Key" => $fixKey]),
CURLOPT_POSTFIELDS => json_encode($fixInput, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE),
CURLOPT_HEADERFUNCTION => function ($ch, $line) use (&$ctype) {
if (stripos($line, "content-type:") === 0) $ctype = strtolower(trim(substr($line, 13)));
return strlen($line);
},
CURLOPT_WRITEFUNCTION => function ($ch, $chunk) use (&$buf, &$ctype, $handle) {
$buf .= $chunk; // collects the response in memory
if (strpos($ctype, "text/event-stream") === false) return strlen($chunk); // plain JSON: parse at the end
while (($i = strpos($buf, "\n\n")) !== false) {
$frame = substr($buf, 0, $i);
$buf = substr($buf, $i + 2);
$event = "message"; $data = "";
foreach (explode("\n", $frame) as $line) {
if (strpos($line, "event:") === 0) $event = trim(substr($line, 6));
elseif (strpos($line, "data:") === 0) $data .= trim(substr($line, 5));
}
if ($data !== "") $handle($event, $data);
}
return strlen($chunk);
},
]);
if (curl_exec($ch) === false) throw new RuntimeException(curl_error($ch));
$status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
curl_close($ch);
if (strpos($ctype, "text/event-stream") === false) {
$env = json_decode($buf) ?? new stdClass();
if ($status < 200 || $status > 299) {
throw new ApiError($status, $env->error->code ?? null, $env->error->message ?? "HTTP $status");
}
$done = $env->data ?? null;
}
if ($failure) throw new RuntimeException(($failure->code ?? "") . ": " . ($failure->message ?? "") . " (job " . ($failure->job_id ?? "") . ")");
$full = $done->output->output ?? "";
if ($full === "") $full = $streamed;
echo "truncated: ", json_encode(($done->truncated ?? false) === true), ", charged: ", $done->charged_credits ?? "-", "\n";
$result = json_decode(substr($full, strpos($full, "{"), strrpos($full, "}") - strpos($full, "{") + 1));
echo $result->verdict, " - ", $result->headline, "\n";
foreach ($result->files ?? [] as $f) echo "file ", $f->path, " ", mb_strlen($f->content ?? ""), " characters\n";
foreach ($result->changes ?? [] as $c) {
$flags = implode(",", $c->flags ?? []);
echo "change ", $c->function ?? "", " ", $flags === "" ? "-" : $flags, " - ", $c->change ?? "", "\n";
}
foreach ($result->verify ?? [] as $step) echo "verify ", $step, "\n";
foreach ($result->open ?? [] as $o) echo "open ", $o->item, " - ", $o->reason ?? "", "\n";
foreach ($result->questions ?? [] as $q) echo "question ", $q, "\n";
// the fix worked example: bullets-check.json from build-check.js
// (for audited code, pass handoff.js's output instead: MakeInput adds its audit_handoff)
var fixInput = MakeInput("fix", "bullets-check.json",
"Bullets throw a safety exception every frame and the Console says the array was deallocated. Fix it - nothing to keep, we are still prototyping.");
var fixDigest = System.Security.Cryptography.SHA256.HashData(Encoding.UTF8.GetBytes(JsonSerializer.Serialize(fixInput)));
var fixKey = "dots-desk:fix:" + Convert.ToHexString(fixDigest, 0, 8).ToLowerInvariant() + ":a1";
using var sreq = Api.Request("POST", "/run-stream", fixInput, new Dictionary<string, string> { ["Idempotency-Key"] = fixKey });
using var sres = await Api.Http.SendAsync(sreq, HttpCompletionOption.ResponseHeadersRead);
JsonNode? done = null, failure = null;
var streamed = new StringBuilder();
if (sres.Content.Headers.ContentType?.MediaType != "text/event-stream")
{
JsonNode? env = null;
try { env = JsonNode.Parse(await sres.Content.ReadAsStringAsync()); } catch (JsonException) { }
if (!sres.IsSuccessStatusCode) throw Api.ErrorFrom(sres, env);
done = env?["data"];
}
else
{
using var reader = new StreamReader(await sres.Content.ReadAsStreamAsync());
var ev = "message";
var data = new StringBuilder();
string? line;
while ((line = await reader.ReadLineAsync()) != null)
{
if (line.Length == 0) // a blank line ends a frame
{
if (data.Length > 0)
{
JsonNode? p = null;
try { p = JsonNode.Parse(data.ToString()); } catch (JsonException) { }
if (p != null)
{
switch (ev)
{
case "delta": streamed.Append(p["text"]?.GetValue<string>() ?? ""); break;
case "job": Console.WriteLine($"job {p.ToJsonString()}"); break;
case "done": case "pending": done = p; break;
case "error": failure = p; break;
}
}
}
ev = "message";
data.Clear();
}
else if (line.StartsWith("event:")) ev = line[6..].Trim();
else if (line.StartsWith("data:")) data.Append(line[5..].Trim());
}
}
if (failure != null) throw new Exception($"{failure["code"]}: {failure["message"]} (job {failure["job_id"]})");
var full = done?["output"]?["output"]?.GetValue<string>();
if (string.IsNullOrEmpty(full)) full = streamed.ToString();
var cut = done?["truncated"] is JsonValue tv && tv.TryGetValue(out bool cutShort) && cutShort;
Console.WriteLine($"truncated: {cut}, charged: {done?["charged_credits"]}");
var result = JsonNode.Parse(full[full.IndexOf('{')..(full.LastIndexOf('}') + 1)])!;
Console.WriteLine($"{result["verdict"]} - {result["headline"]}");
foreach (var f in result["files"]?.AsArray() ?? new JsonArray())
Console.WriteLine($"file {f?["path"]} {(f?["content"]?.GetValue<string>() ?? "").Length} characters");
foreach (var c in result["changes"]?.AsArray() ?? new JsonArray())
{
var flags = string.Join(",", (c?["flags"]?.AsArray() ?? new JsonArray()).Select(fl => fl?.GetValue<string>()));
Console.WriteLine($"change {c?["function"]} {(flags == "" ? "-" : flags)} - {c?["change"]}");
}
foreach (var step in result["verify"]?.AsArray() ?? new JsonArray()) Console.WriteLine($"verify {step}");
foreach (var o in result["open"]?.AsArray() ?? new JsonArray()) Console.WriteLine($"open {o?["item"]} - {o?["reason"]}");
foreach (var q in result["questions"]?.AsArray() ?? new JsonArray()) Console.WriteLine($"question {q}");
What the page does that you now do
- Reads the paste in the browser and builds
codeandfactsfrom it (dotskit.js), joining dropped files under// file:lines and cutting a large paste on whole files with a// [dots-desk: not sent: ...]line; you send the same two strings. - Prices every input with
/estimateand refuses to run belowmin_credits, or on a paste with no C# type it can read. - Sends each attempt with an input- and lane-derived
Idempotency-Key, and retries once withretry_notewhen a reply does not parse. - Closes a cut-off JSON reply and shows what arrived when
truncatedis true or the stream ends early. - Hands an audit to the fix lane as
audit_handoff, with every edit applied to the paste first, and only while that edited paste is unchanged. - Checks the reply against the code (
recon.js), in the browser: files, lines, evidence, every edit applied in order and the free check re-run after each finding, flag answers and verdict; the fixed files put back, re-checked and matched against the changes list and the open items.recheck.jsabove runs the same checks for you.
Or skip all of this and use DOTS Desk in the browser: the check, the flags, the systems, jobs, allocations, command buffers and structural changes it inventories, putting an edit or the fixed files back into the paste, and the Markdown and CSV exports are free.