Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| dddac76955 |
@@ -1,12 +0,0 @@
|
|||||||
export async function retryInvalidToken<
|
|
||||||
T extends { status: { success: boolean }; error: string },
|
|
||||||
>(attempt: () => Promise<T>, relogin: () => Promise<void>): Promise<T> {
|
|
||||||
let result = await attempt();
|
|
||||||
if (
|
|
||||||
!result.status.success && result.error.includes("invalid_refresh_token")
|
|
||||||
) {
|
|
||||||
await relogin();
|
|
||||||
result = await attempt();
|
|
||||||
}
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
@@ -1,44 +0,0 @@
|
|||||||
import { assertEquals } from "jsr:@std/assert@1";
|
|
||||||
import { retryInvalidToken } from "./auth.ts";
|
|
||||||
|
|
||||||
Deno.test("retries once after an invalid refresh token", async () => {
|
|
||||||
let attempts = 0;
|
|
||||||
let relogins = 0;
|
|
||||||
const result = await retryInvalidToken(
|
|
||||||
() =>
|
|
||||||
Promise.resolve({
|
|
||||||
status: { success: false },
|
|
||||||
error: attempts++ === 0 ? "invalid_refresh_token" : "still failed",
|
|
||||||
}),
|
|
||||||
() => {
|
|
||||||
relogins++;
|
|
||||||
return Promise.resolve();
|
|
||||||
},
|
|
||||||
);
|
|
||||||
|
|
||||||
assertEquals({ attempts, relogins, error: result.error }, {
|
|
||||||
attempts: 2,
|
|
||||||
relogins: 1,
|
|
||||||
error: "still failed",
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
Deno.test("does not retry an unrelated failure", async () => {
|
|
||||||
let attempts = 0;
|
|
||||||
let relogins = 0;
|
|
||||||
await retryInvalidToken(
|
|
||||||
() => {
|
|
||||||
attempts++;
|
|
||||||
return Promise.resolve({
|
|
||||||
status: { success: false },
|
|
||||||
error: "rate limited",
|
|
||||||
});
|
|
||||||
},
|
|
||||||
() => {
|
|
||||||
relogins++;
|
|
||||||
return Promise.resolve();
|
|
||||||
},
|
|
||||||
);
|
|
||||||
|
|
||||||
assertEquals({ attempts, relogins }, { attempts: 1, relogins: 0 });
|
|
||||||
});
|
|
||||||
@@ -19,24 +19,25 @@ author's push credentials. Read the code there, run its checks and tests when
|
|||||||
they bear on the task, and push from there.
|
they bear on the task, and push from there.
|
||||||
|
|
||||||
For a `pull_request` event, and for a comment on a pull request that asks you to
|
For a `pull_request` event, and for a comment on a pull request that asks you to
|
||||||
review it, review the PR without changing code against its base and head. Run
|
review it, review the PR without changing code, using the
|
||||||
the project's checks on the head and treat a failure as at least Important.
|
`requesting-code-review` skill from superpowers: run its code reviewer template
|
||||||
Check the whole repository against the code rules at the end of this prompt, not
|
against the PR's base and head. Run the project's checks on the head and treat a
|
||||||
only the diff; a violation is at least Important even when the diff did not
|
failure as at least Important. Check the whole repository against the code rules
|
||||||
cause it. Write the complete review, and nothing else, to the file
|
at the end of this prompt, not only the diff; a violation is at least Important
|
||||||
`${REVIEW_PATH}`: it is posted verbatim as a pull request review from the bot
|
even when the diff did not cause it. Write the complete review, and nothing
|
||||||
account, and your final response is not posted at all. The file's first line
|
else, to the file `${REVIEW_PATH}`: it is posted verbatim as a pull request
|
||||||
must be exactly the verdict and nothing else: `Approved` when the head is ready
|
review from the bot account, and your final response is not posted at all. The
|
||||||
to merge, `Changes requested` otherwise. The mark in front of it is added when
|
file's first line must be exactly the verdict and nothing else: `Approved` when
|
||||||
posting, so write the words alone; any other first line is posted as a plain
|
the template's answer is yes, `Changes requested` otherwise. The mark in front
|
||||||
comment, which wastes the run. Minor issues alone never block, and neither does
|
of it is added when posting, so write the words alone; any other first line is
|
||||||
a finding the author has answered in the comment history below as intended or a
|
posted as a plain comment, which wastes the run. Minor issues alone never block,
|
||||||
false alarm, once the code or docs make that clear. When the verdict is
|
and neither does a finding the author has answered in the comment history below
|
||||||
`Changes requested`, the second line names what must change in one line,
|
as intended or a false alarm, once the code or docs make that clear. When the
|
||||||
addressed to the author; the author's own agent picks the fixes up, so never ask
|
verdict is `Changes requested`, the second line names what must change in one
|
||||||
`@bot` to make them. For UI changes, check that the result is aligned, clean,
|
line, addressed to the author; the author's own agent picks the fixes up, so
|
||||||
and pixel-perfect, and that included screenshots prove the intended result was
|
never ask `@bot` to make them. For UI changes, check that the result is aligned,
|
||||||
achieved.
|
clean, and pixel-perfect, and that included screenshots prove the intended
|
||||||
|
result was achieved.
|
||||||
|
|
||||||
Every finding that belongs to one line of the diff goes on that line instead of
|
Every finding that belongs to one line of the diff goes on that line instead of
|
||||||
into the body. Write those to `${ANCHORS_PATH}` as a JSON array, each entry
|
into the body. Write those to `${ANCHORS_PATH}` as a JSON array, each entry
|
||||||
|
|||||||
@@ -3,7 +3,6 @@
|
|||||||
// GITEA_TOKEN; everything this script posts goes through the reviewer token,
|
// GITEA_TOKEN; everything this script posts goes through the reviewer token,
|
||||||
// so it appears as the bot account.
|
// so it appears as the bot account.
|
||||||
import { TextLineStream } from "jsr:@std/streams@1/text-line-stream";
|
import { TextLineStream } from "jsr:@std/streams@1/text-line-stream";
|
||||||
import { retryInvalidToken } from "./auth.ts";
|
|
||||||
|
|
||||||
type GiteaUser = { login: string; email: string };
|
type GiteaUser = { login: string; email: string };
|
||||||
type GiteaComment = { user: GiteaUser; created_at: string; body: string };
|
type GiteaComment = { user: GiteaUser; created_at: string; body: string };
|
||||||
@@ -154,6 +153,19 @@ async function configureGitAuthor(): Promise<void> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// The superpowers plugin gives the agent its skills, including the code review
|
||||||
|
// one that the prompt asks for. Both installs are idempotent on the persisted
|
||||||
|
// home.
|
||||||
|
async function installSuperpowers(bot: string): Promise<void> {
|
||||||
|
const commands = bot === "claude"
|
||||||
|
? [
|
||||||
|
["plugin", "marketplace", "add", "obra/superpowers-marketplace"],
|
||||||
|
["plugin", "install", "-y", "superpowers@superpowers-marketplace"],
|
||||||
|
]
|
||||||
|
: [["plugin", "add", "superpowers@openai-curated-remote"]];
|
||||||
|
for (const args of commands) await run(bot, args);
|
||||||
|
}
|
||||||
|
|
||||||
async function renderPrompt(): Promise<string> {
|
async function renderPrompt(): Promise<string> {
|
||||||
const comments: GiteaComment[] = await (await gitea(
|
const comments: GiteaComment[] = await (await gitea(
|
||||||
REVIEWER_TOKEN,
|
REVIEWER_TOKEN,
|
||||||
@@ -188,6 +200,7 @@ async function runClaude(prompt: string): Promise<string> {
|
|||||||
"Run `claude setup-token` locally and set the `bot-token` action input.",
|
"Run `claude setup-token` locally and set the `bot-token` action input.",
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
await installSuperpowers("claude");
|
||||||
const claude = new Deno.Command("claude", {
|
const claude = new Deno.Command("claude", {
|
||||||
args: [
|
args: [
|
||||||
"--print",
|
"--print",
|
||||||
@@ -238,17 +251,12 @@ async function codexDeviceLogin(): Promise<void> {
|
|||||||
new WritableStream({ write: (chunk) => void (shown += chunk) }),
|
new WritableStream({ write: (chunk) => void (shown += chunk) }),
|
||||||
);
|
);
|
||||||
const drained = Promise.all([collect(login.stdout), collect(login.stderr)]);
|
const drained = Promise.all([collect(login.stdout), collect(login.stderr)]);
|
||||||
const status = login.status;
|
|
||||||
await new Promise((resolve) => setTimeout(resolve, 3000));
|
await new Promise((resolve) => setTimeout(resolve, 3000));
|
||||||
while (shown.trim() === "") {
|
|
||||||
const exited = await Promise.race([
|
|
||||||
status.then(() => true),
|
|
||||||
new Promise<boolean>((resolve) => setTimeout(() => resolve(false), 100)),
|
|
||||||
]);
|
|
||||||
if (exited) throw new Error("AI bot login produced no instructions");
|
|
||||||
}
|
|
||||||
await postComment(shown);
|
await postComment(shown);
|
||||||
await Promise.all([status, drained]);
|
await Promise.all([login.status, drained]);
|
||||||
|
const status = await new Deno.Command("codex", { args: ["login", "status"] })
|
||||||
|
.output();
|
||||||
|
await postComment(new TextDecoder().decode(status.stdout));
|
||||||
}
|
}
|
||||||
|
|
||||||
async function runCodex(prompt: string): Promise<string> {
|
async function runCodex(prompt: string): Promise<string> {
|
||||||
@@ -257,9 +265,9 @@ async function runCodex(prompt: string): Promise<string> {
|
|||||||
})
|
})
|
||||||
.output();
|
.output();
|
||||||
if (!loggedIn.success) await codexDeviceLogin();
|
if (!loggedIn.success) await codexDeviceLogin();
|
||||||
|
await installSuperpowers("codex");
|
||||||
const file = await Deno.makeTempFile();
|
const file = await Deno.makeTempFile();
|
||||||
const attempt = async () => {
|
const status = await new Deno.Command("codex", {
|
||||||
const codex = new Deno.Command("codex", {
|
|
||||||
args: [
|
args: [
|
||||||
"exec",
|
"exec",
|
||||||
"--model",
|
"--model",
|
||||||
@@ -272,21 +280,8 @@ async function runCodex(prompt: string): Promise<string> {
|
|||||||
env: agentEnv,
|
env: agentEnv,
|
||||||
clearEnv: true,
|
clearEnv: true,
|
||||||
stdout: "inherit",
|
stdout: "inherit",
|
||||||
stderr: "piped",
|
stderr: "inherit",
|
||||||
}).spawn();
|
}).spawn().status;
|
||||||
const decoder = new TextDecoder();
|
|
||||||
let error = "";
|
|
||||||
for await (const chunk of codex.stderr) {
|
|
||||||
await Deno.stderr.write(chunk);
|
|
||||||
error += decoder.decode(chunk, { stream: true });
|
|
||||||
}
|
|
||||||
error += decoder.decode();
|
|
||||||
return { status: await codex.status, error };
|
|
||||||
};
|
|
||||||
const { status } = await retryInvalidToken(attempt, async () => {
|
|
||||||
await run("codex", ["logout"]);
|
|
||||||
await codexDeviceLogin();
|
|
||||||
});
|
|
||||||
if (!status.success) throw new Error(`codex exited with ${status.code}`);
|
if (!status.success) throw new Error(`codex exited with ${status.code}`);
|
||||||
return await Deno.readTextFile(file);
|
return await Deno.readTextFile(file);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user