74 lines
2.3 KiB
TypeScript
74 lines
2.3 KiB
TypeScript
import { env } from "@code/env/convex";
|
|
import { convexTest } from "convex-test";
|
|
import { anyApi } from "convex/server";
|
|
import { describe, expect, test } from "vitest";
|
|
|
|
import schema from "./schema";
|
|
|
|
declare global {
|
|
interface ImportMeta {
|
|
readonly glob: (pattern: string) => Record<string, () => Promise<unknown>>;
|
|
}
|
|
}
|
|
|
|
const modules = import.meta.glob("./**/*.ts");
|
|
const api = anyApi;
|
|
|
|
describe("works", () => {
|
|
test("creates one proposed Work and one normalized attachment", async () => {
|
|
const t = convexTest({ modules, schema });
|
|
const fixture = await t.run(async (ctx) => {
|
|
const organizationId = await ctx.db.insert("organizations", {
|
|
createdAt: 1,
|
|
createdBy: "user",
|
|
kind: "personal",
|
|
name: "Personal",
|
|
});
|
|
const projectId = await ctx.db.insert("projects", {
|
|
createdAt: 1,
|
|
name: "Zopu",
|
|
normalizedSourceUrl: "https://example.com/zopu",
|
|
organizationId,
|
|
repositoryPath: "puter/zopu",
|
|
sourceHost: "example.com",
|
|
sourceUrl: "https://example.com/zopu",
|
|
updatedAt: 1,
|
|
});
|
|
const conversationId = await ctx.db.insert("conversations", {
|
|
createdAt: 1,
|
|
organizationId,
|
|
});
|
|
const signalId = await ctx.db.insert("signals", {
|
|
conversationId,
|
|
createdAt: 1,
|
|
desiredOutcome: "A working Slice 1",
|
|
organizationId,
|
|
processedByAgentInstanceId: String(organizationId),
|
|
processedByAgentName: "zopu",
|
|
projectId,
|
|
sourceKey: "source-1",
|
|
summary: "Slice 1 needs work",
|
|
title: "Finish Slice 1",
|
|
});
|
|
return { organizationId, signalId };
|
|
});
|
|
|
|
const first = await t.mutation(api.works.createFromSignal, {
|
|
organizationId: fixture.organizationId,
|
|
signalId: fixture.signalId,
|
|
token: env.FLUE_DB_TOKEN,
|
|
});
|
|
const second = await t.mutation(api.works.createFromSignal, {
|
|
organizationId: fixture.organizationId,
|
|
signalId: fixture.signalId,
|
|
token: env.FLUE_DB_TOKEN,
|
|
});
|
|
expect(first.created).toBe(true);
|
|
expect(second).toEqual({ created: false, workId: first.workId });
|
|
const attachments = await t.run(async (ctx) =>
|
|
ctx.db.query("signalWorkAttachments").collect()
|
|
);
|
|
expect(attachments).toHaveLength(1);
|
|
});
|
|
});
|