Skip to content

Commit bd224fb

Browse files
Studio Openclawneuroradgist
authored andcommitted
fix: satisfy lint after backpressure changes
1 parent 34f615f commit bd224fb

5 files changed

Lines changed: 11 additions & 7 deletions

File tree

extensions/discord/src/monitor/message-media.ts

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -330,14 +330,15 @@ async function mapWithConcurrency<T, R>(
330330
mapper: (item: T, index: number) => Promise<R>,
331331
): Promise<R[]> {
332332
const limit = Math.max(1, Math.floor(concurrency));
333-
const results = new Array<R>(items.length);
333+
const results: R[] = [];
334+
results.length = items.length;
334335
let nextIndex = 0;
335336

336337
const worker = async () => {
337338
while (nextIndex < items.length) {
338339
const index = nextIndex;
339340
nextIndex += 1;
340-
results[index] = await mapper(items[index]!, index);
341+
results[index] = await mapper(items[index], index);
341342
}
342343
};
343344

extensions/discord/src/monitor/message-run-queue.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ describe("createDiscordMessageRunQueue", () => {
126126
});
127127

128128
queue.enqueue(createJob({ messageId: "m-1" }));
129-
await vi.runAllTicks();
129+
vi.runAllTicks();
130130
await flushQueueWork();
131131
queue.enqueue(createJob({ messageId: "m-2" }));
132132

extensions/discord/src/monitor/message-utils.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -694,7 +694,7 @@ describe("resolveMediaList", () => {
694694
filename: `${index + 1}.png`,
695695
content_type: "image/png",
696696
}));
697-
const downloads = attachments.map((attachment) =>
697+
const downloads = attachments.map(() =>
698698
createDeferred<{ buffer: Buffer; contentType: string }>(),
699699
);
700700
const activeUrls = new Set<string>();

src/config/sessions/transcript.test.ts

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -185,9 +185,11 @@ describe("appendAssistantMessageToSessionTranscript", () => {
185185
if (secondResult.ok) {
186186
expect(secondResult.messageId).toBe(firstResult.messageId);
187187
}
188-
expect(readSpy.mock.calls.some(([file]) => String(file) === firstResult.sessionFile)).toBe(
189-
false,
190-
);
188+
expect(
189+
readSpy.mock.calls.some(
190+
([file]) => typeof file === "string" && file === firstResult.sessionFile,
191+
),
192+
).toBe(false);
191193
readSpy.mockRestore();
192194

193195
const lines = fs.readFileSync(firstResult.sessionFile, "utf-8").trim().split("\n");

src/config/sessions/transcript.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -487,6 +487,7 @@ async function findTranscriptIdempotencyKey(
487487
case "unavailable":
488488
return await scanTranscriptIdempotencyKey(transcriptPath, idempotencyKey);
489489
}
490+
return undefined;
490491
}
491492

492493
async function scanTranscriptIdempotencyKey(

0 commit comments

Comments
 (0)