Format runtime cleanup follow-up
This commit is contained in:
@@ -24,9 +24,9 @@ function makeChannel(overrides: Partial<Channel> = {}): Channel {
|
|||||||
describe('index scheduler messaging helpers', () => {
|
describe('index scheduler messaging helpers', () => {
|
||||||
it('uses the paired verdict parser to detect terminal status messages', () => {
|
it('uses the paired verdict parser to detect terminal status messages', () => {
|
||||||
expect(isTerminalStatusMessage('DONE\nfinished')).toBe(true);
|
expect(isTerminalStatusMessage('DONE\nfinished')).toBe(true);
|
||||||
expect(isTerminalStatusMessage('**DONE_WITH_CONCERNS**\nneed follow-up')).toBe(
|
expect(
|
||||||
true,
|
isTerminalStatusMessage('**DONE_WITH_CONCERNS**\nneed follow-up'),
|
||||||
);
|
).toBe(true);
|
||||||
expect(isTerminalStatusMessage('Approved.\nlooks good')).toBe(true);
|
expect(isTerminalStatusMessage('Approved.\nlooks good')).toBe(true);
|
||||||
expect(isTerminalStatusMessage('LGTM\nship it')).toBe(true);
|
expect(isTerminalStatusMessage('LGTM\nship it')).toBe(true);
|
||||||
expect(isTerminalStatusMessage('random prose only')).toBe(false);
|
expect(isTerminalStatusMessage('random prose only')).toBe(false);
|
||||||
|
|||||||
@@ -1,15 +1,12 @@
|
|||||||
import { beforeEach, describe, expect, it, vi } from 'vitest';
|
import { beforeEach, describe, expect, it, vi } from 'vitest';
|
||||||
import type { RegisteredGroup } from './types.js';
|
import type { RegisteredGroup } from './types.js';
|
||||||
|
|
||||||
const {
|
const { handleSessionCommandMock, hasAllowedTriggerMock, loggerInfoMock } =
|
||||||
handleSessionCommandMock,
|
vi.hoisted(() => ({
|
||||||
hasAllowedTriggerMock,
|
handleSessionCommandMock: vi.fn(),
|
||||||
loggerInfoMock,
|
hasAllowedTriggerMock: vi.fn(),
|
||||||
} = vi.hoisted(() => ({
|
loggerInfoMock: vi.fn(),
|
||||||
handleSessionCommandMock: vi.fn(),
|
}));
|
||||||
hasAllowedTriggerMock: vi.fn(),
|
|
||||||
loggerInfoMock: vi.fn(),
|
|
||||||
}));
|
|
||||||
|
|
||||||
vi.mock('./session-commands.js', () => ({
|
vi.mock('./session-commands.js', () => ({
|
||||||
handleSessionCommand: handleSessionCommandMock,
|
handleSessionCommand: handleSessionCommandMock,
|
||||||
|
|||||||
@@ -15,10 +15,7 @@ import {
|
|||||||
resolveHandoffRoleOverride,
|
resolveHandoffRoleOverride,
|
||||||
} from './message-runtime-shared.js';
|
} from './message-runtime-shared.js';
|
||||||
import type { ExecuteTurnFn } from './message-runtime-types.js';
|
import type { ExecuteTurnFn } from './message-runtime-types.js';
|
||||||
import type {
|
import type { Channel, RegisteredGroup } from './types.js';
|
||||||
Channel,
|
|
||||||
RegisteredGroup,
|
|
||||||
} from './types.js';
|
|
||||||
|
|
||||||
export function enqueuePendingHandoffs(args: {
|
export function enqueuePendingHandoffs(args: {
|
||||||
enqueueTask: (
|
enqueueTask: (
|
||||||
|
|||||||
@@ -57,7 +57,11 @@ export async function runGithubCiTask(
|
|||||||
if (check.terminal) {
|
if (check.terminal) {
|
||||||
await statusTracker.update('completed');
|
await statusTracker.update('completed');
|
||||||
if (check.completionMessage) {
|
if (check.completionMessage) {
|
||||||
await sendScheduledMessage(deps, task.chat_jid, check.completionMessage);
|
await sendScheduledMessage(
|
||||||
|
deps,
|
||||||
|
task.chat_jid,
|
||||||
|
check.completionMessage,
|
||||||
|
);
|
||||||
}
|
}
|
||||||
deleteTask(task.id);
|
deleteTask(task.id);
|
||||||
completedAndDeleted = true;
|
completedAndDeleted = true;
|
||||||
|
|||||||
@@ -9,10 +9,7 @@ import {
|
|||||||
import { getErrorMessage } from './utils.js';
|
import { getErrorMessage } from './utils.js';
|
||||||
|
|
||||||
import { ASSISTANT_NAME, SCHEDULER_POLL_INTERVAL, TIMEZONE } from './config.js';
|
import { ASSISTANT_NAME, SCHEDULER_POLL_INTERVAL, TIMEZONE } from './config.js';
|
||||||
import {
|
import { AgentOutput, runAgentProcess } from './agent-runner.js';
|
||||||
AgentOutput,
|
|
||||||
runAgentProcess,
|
|
||||||
} from './agent-runner.js';
|
|
||||||
import {
|
import {
|
||||||
getAllTasks,
|
getAllTasks,
|
||||||
deleteTask,
|
deleteTask,
|
||||||
|
|||||||
Reference in New Issue
Block a user