ansxor.ca
this repo has no description
refactor: move factories into shared package
+2
-1
apps/api/package.json
+2
-1
apps/api/package.json
+1
-21
apps/api/tests/server.test.ts
+1
-21
apps/api/tests/server.test.ts
···
4
4
import type { BlobRef } from "db/schema";
5
5
import { createRouter } from "../index";
6
6
import { faker } from "@faker-js/faker";
7
+
import { fakeDid, fakeCid, fakeTid, fakeBlobRef } from "shared/factories";
7
8
import type { XRPCRouter } from "@atcute/xrpc-server";
8
9
9
10
let db: Awaited<ReturnType<typeof setupTestDb>>;
···
35
36
afterEach(() => {
36
37
rollback();
37
38
});
38
-
39
-
function fakeDid(): `did:${string}:${string}` {
40
-
return `did:plc:${faker.string.alphanumeric({ length: 24, casing: "lower" })}`;
41
-
}
42
-
43
-
function fakeCid(): string {
44
-
return `bafyrei${faker.string.alphanumeric({ length: 52, casing: "lower" })}`;
45
-
}
46
-
47
-
function fakeTid(): string {
48
-
return faker.string.alphanumeric(13);
49
-
}
50
-
51
-
function fakeBlobRef(mimeType = "audio/ogg"): BlobRef {
52
-
return {
53
-
$type: "blob",
54
-
ref: { $link: fakeCid() },
55
-
mimeType,
56
-
size: faker.number.int({ min: 100_000, max: 50_000_000 }),
57
-
};
58
-
}
59
39
60
40
const COLLECTION = "ca.ansxor.catnip.track";
61
41
+2
-1
apps/firehose/package.json
+2
-1
apps/firehose/package.json
+17
-19
apps/firehose/tests/firehose.test.ts
+17
-19
apps/firehose/tests/firehose.test.ts
···
1
1
import { test, expect, beforeAll, afterAll, beforeEach, afterEach } from "bun:test";
2
2
import { setupTestDb, teardownTestDb } from "db/test-utils";
3
-
import type { InferOutput } from "@atcute/lexicons/validations";
3
+
import { is, safeParse, type InferInput, type InferOutput } from "@atcute/lexicons/validations";
4
4
import { loop } from "../index";
5
5
import type { JetstreamEvent } from "@atcute/jetstream";
6
-
import type { CaAnsxorCatnipTrack } from "lexicon/atcute-lexicon";
6
+
import { CaAnsxorCatnipTrack } from "lexicon/atcute-lexicon";
7
7
import { faker } from "@faker-js/faker";
8
+
import { fakeDid, fakeCid, fakeTid } from "shared/factories";
8
9
9
10
let db: Awaited<ReturnType<typeof setupTestDb>>;
10
11
let txDb: typeof db;
···
48
49
};
49
50
}
50
51
51
-
function fakeDid(): `did:${string}:${string}` {
52
-
return `did:plc:${faker.string.alphanumeric({ length: 24, casing: "lower" })}`;
53
-
}
54
-
55
-
function fakeCid(): string {
56
-
return `bafyrei${faker.string.alphanumeric({ length: 52, casing: "lower" })}`;
57
-
}
58
-
59
-
function fakeTid(): string {
60
-
return faker.string.alphanumeric(13);
61
-
}
62
-
63
52
function fakeTrackRecord(
64
-
overrides?: Partial<InferOutput<typeof CaAnsxorCatnipTrack.mainSchema>>,
65
-
): InferOutput<typeof CaAnsxorCatnipTrack.mainSchema> {
66
-
return {
53
+
overrides?: Partial<InferInput<typeof CaAnsxorCatnipTrack.mainSchema>>,
54
+
): InferInput<typeof CaAnsxorCatnipTrack.mainSchema> {
55
+
const record = {
67
56
$type: "ca.ansxor.catnip.track",
68
57
title: faker.music.songName(),
69
58
createdAt: faker.date.recent().toISOString(),
···
74
63
size: faker.number.int({ min: 100_000, max: 50_000_000 }),
75
64
},
76
65
...overrides,
77
-
};
66
+
};
67
+
const result = safeParse(CaAnsxorCatnipTrack.mainSchema, record)
68
+
69
+
if (!result.ok) {
70
+
console.warn(result.issues)
71
+
console.warn(result.message)
72
+
throw new Error("record doesn't match expected schema")
73
+
}
74
+
return result.value
78
75
}
79
76
80
77
function fakeJetstreamCreateEvent(
···
82
79
did?: `did:${string}:${string}`;
83
80
rkey?: string;
84
81
cid?: string;
85
-
record?: InferOutput<typeof CaAnsxorCatnipTrack.mainSchema>;
82
+
record?: InferInput<typeof CaAnsxorCatnipTrack.mainSchema>;
86
83
},
87
84
): JetstreamEvent {
85
+
88
86
return {
89
87
did: overrides?.did ?? fakeDid(),
90
88
time_us: Date.now() * 1000,
+14
bun.lock
+14
bun.lock
···
25
25
"drizzle-orm": "^0.45.1",
26
26
"lexicon": "workspace:*",
27
27
"postgres": "^3.4.8",
28
+
"shared": "workspace:*",
28
29
},
29
30
"devDependencies": {
30
31
"@types/bun": "latest",
···
44
45
"db": "workspace:*",
45
46
"drizzle-orm": "^0.45.1",
46
47
"lexicon": "workspace:*",
48
+
"shared": "workspace:*",
47
49
},
48
50
"devDependencies": {
49
51
"@faker-js/faker": "^10.3.0",
···
100
102
"@atcute/lex-cli": "^2.5.3",
101
103
"@atcute/lexicon-doc": "^2.1.1",
102
104
"@atcute/lexicons": "^1.2.9",
105
+
},
106
+
},
107
+
"packages/shared": {
108
+
"name": "shared",
109
+
"version": "1.0.0",
110
+
"dependencies": {
111
+
"@faker-js/faker": "^10.3.0",
112
+
},
113
+
"devDependencies": {
114
+
"@types/bun": "latest",
103
115
},
104
116
},
105
117
},
···
793
805
"seroval": ["seroval@1.5.0", "", {}, "sha512-OE4cvmJ1uSPrKorFIH9/w/Qwuvi/IMcGbv5RKgcJ/zjA/IohDLU6SVaxFN9FwajbP7nsX0dQqMDes1whk3y+yw=="],
794
806
795
807
"seroval-plugins": ["seroval-plugins@1.5.0", "", { "peerDependencies": { "seroval": "^1.0" } }, "sha512-EAHqADIQondwRZIdeW2I636zgsODzoBDwb3PT/+7TLDWyw1Dy/Xv7iGUIEXXav7usHDE9HVhOU61irI3EnyyHA=="],
808
+
809
+
"shared": ["shared@workspace:packages/shared"],
796
810
797
811
"shebang-command": ["shebang-command@2.0.0", "", { "dependencies": { "shebang-regex": "^3.0.0" } }, "sha512-kHxr2zZpYtdmrN1qDjrrX/Z1rR1kG8Dx+gkpK1G4eXmvXswmcE1hTWBWYUzlraYw1/yZp6YuDY77YtvbN0dmDA=="],
798
812