this repo has no description
feat: make first derived table
+473
-334
+1
-1
api/package.json
+1
-1
api/package.json
···
10
10
"db:generate": "node ../scripts/db-generate.ts",
11
11
"db:migrate": "drizzle-kit migrate",
12
12
"db:studio": "drizzle-kit studio",
13
-
"build:lexicons": "rm -rf ./src/lexicons && lex build --lexicons ./lexicons --out ./src/lexicons"
13
+
"build:lexicons": "rm -rf ./src/lexicons && lex build --lexicons ./lexicons --import-ext \".ts\" --out ./src/lexicons"
14
14
},
15
15
"keywords": [],
16
16
"author": "",
+15
api/src/db/drizzle/0001_tangled_profile.sql
+15
api/src/db/drizzle/0001_tangled_profile.sql
···
1
+
CREATE TABLE "tangled_profile" (
2
+
"did" text PRIMARY KEY NOT NULL,
3
+
"rev" text NOT NULL,
4
+
"cid" text NOT NULL,
5
+
"deleted" boolean NOT NULL,
6
+
"avatar" text,
7
+
"description" text,
8
+
"links" text[],
9
+
"stats" text[],
10
+
"bluesky" boolean NOT NULL,
11
+
"location" text,
12
+
"pinned_repositories" text[],
13
+
"pronouns" text,
14
+
"preferred_handle" text
15
+
);
+1
api/src/db/drizzle/meta/0001_snapshot.json
+1
api/src/db/drizzle/meta/0001_snapshot.json
···
1
+
{"id":"9f626a39-ec46-47c9-acba-9f815b1066cb","prevId":"b6f04a1d-2900-4afb-9cb8-f555e332159b","version":"7","dialect":"postgresql","tables":{"public.raw_records":{"name":"raw_records","schema":"","columns":{"id":{"name":"id","type":"uuidv7","primaryKey":true,"notNull":true},"tap_id":{"name":"tap_id","type":"bigint","primaryKey":false,"notNull":true},"received_at":{"name":"received_at","type":"timestamp with time zone","primaryKey":false,"notNull":true,"default":"now()"},"did":{"name":"did","type":"text","primaryKey":false,"notNull":true},"rev":{"name":"rev","type":"text","primaryKey":false,"notNull":true},"collection":{"name":"collection","type":"text","primaryKey":false,"notNull":true},"rkey":{"name":"rkey","type":"text","primaryKey":false,"notNull":true},"action":{"name":"action","type":"raw_action","typeSchema":"public","primaryKey":false,"notNull":true},"cid":{"name":"cid","type":"text","primaryKey":false,"notNull":false},"record":{"name":"record","type":"jsonb","primaryKey":false,"notNull":false}},"indexes":{"raw_records_collection_index":{"name":"raw_records_collection_index","columns":[{"expression":"collection","isExpression":false,"asc":true,"nulls":"last"}],"isUnique":false,"concurrently":false,"method":"btree","with":{}},"raw_records_did_collection_rkey_index":{"name":"raw_records_did_collection_rkey_index","columns":[{"expression":"did","isExpression":false,"asc":true,"nulls":"last"},{"expression":"collection","isExpression":false,"asc":true,"nulls":"last"},{"expression":"rkey","isExpression":false,"asc":true,"nulls":"last"}],"isUnique":false,"concurrently":false,"method":"btree","with":{}}},"foreignKeys":{},"compositePrimaryKeys":{},"uniqueConstraints":{"raw_records_tap_id_unique":{"name":"raw_records_tap_id_unique","nullsNotDistinct":false,"columns":["tap_id"]}},"policies":{},"checkConstraints":{"raw_records_not_null_unless_delete":{"name":"raw_records_not_null_unless_delete","value":"(\"raw_records\".\"action\" = 'delete' or (\"raw_records\".\"cid\" is not null and \"raw_records\".\"record\" is not null))"}},"isRLSEnabled":false},"public.tangled_profile":{"name":"tangled_profile","schema":"","columns":{"did":{"name":"did","type":"text","primaryKey":true,"notNull":true},"rev":{"name":"rev","type":"text","primaryKey":false,"notNull":true},"cid":{"name":"cid","type":"text","primaryKey":false,"notNull":true},"deleted":{"name":"deleted","type":"boolean","primaryKey":false,"notNull":true},"avatar":{"name":"avatar","type":"text","primaryKey":false,"notNull":false},"description":{"name":"description","type":"text","primaryKey":false,"notNull":false},"links":{"name":"links","type":"text[]","primaryKey":false,"notNull":false},"stats":{"name":"stats","type":"text[]","primaryKey":false,"notNull":false},"bluesky":{"name":"bluesky","type":"boolean","primaryKey":false,"notNull":true},"location":{"name":"location","type":"text","primaryKey":false,"notNull":false},"pinned_repositories":{"name":"pinned_repositories","type":"text[]","primaryKey":false,"notNull":false},"pronouns":{"name":"pronouns","type":"text","primaryKey":false,"notNull":false},"preferred_handle":{"name":"preferred_handle","type":"text","primaryKey":false,"notNull":false}},"indexes":{},"foreignKeys":{},"compositePrimaryKeys":{},"uniqueConstraints":{},"policies":{},"checkConstraints":{},"isRLSEnabled":false}},"enums":{"public.raw_action":{"name":"raw_action","schema":"public","values":["create","update","delete"]}},"schemas":{},"sequences":{},"roles":{},"policies":{},"views":{},"_meta":{"columns":{},"schemas":{},"tables":{}}}
+7
api/src/db/drizzle/meta/_journal.json
+7
api/src/db/drizzle/meta/_journal.json
+17
-13
api/src/db/tables/tangled.ts
+17
-13
api/src/db/tables/tangled.ts
···
1
-
// import { bigint, check, index, jsonb, pgEnum, pgTable, text, timestamp } from "drizzle-orm/pg-core";
2
-
// import { uuidv7WithDefault } from "../helpers.ts";
3
-
// import { and, isNotNull, or, sql } from "drizzle-orm";
1
+
import { boolean, pgTable, text } from "drizzle-orm/pg-core";
4
2
5
-
// export const rawRecords = pgTable("tangled_profile", {
6
-
// did: text().primaryKey(),
7
-
// // no rkey, because always self
8
-
// cid: text().notNull(),
9
-
// rev: text().notNull(),
3
+
export const tangledProfile = pgTable("tangled_profile", {
4
+
did: text().primaryKey(),
5
+
rev: text().notNull(),
6
+
// no rkey here, because always self
7
+
cid: text().notNull(),
8
+
deleted: boolean().notNull(),
10
9
11
-
// }, (table) => [
12
-
// check("raw_records_not_null_unless_delete", or(sql`${table.action} = 'delete'`, and(isNotNull(table.cid), isNotNull(table.record)))!),
13
-
// index().on(table.collection),
14
-
// index().on(table.did, table.collection, table.rkey),
15
-
// ]);
10
+
avatar: text(),
11
+
description: text(),
12
+
links: text().array(),
13
+
stats: text().array(),
14
+
bluesky: boolean().notNull(),
15
+
location: text(),
16
+
pinnedRepositories: text().array(),
17
+
pronouns: text(),
18
+
preferredHandle: text(),
19
+
});
-81
api/src/importer.ts
-81
api/src/importer.ts
···
1
-
import { Tap, type RecordEvent, type TapHandler } from '@atproto/tap'
2
-
import { db } from './db/index.ts';
3
-
import { rawRecords } from './db/tables/raw_records.ts';
4
-
import { lexToJson } from '@atproto/lex';
5
-
import { TAP_URL } from './lib/constants.ts';
6
-
7
-
const tap = new Tap(TAP_URL);
8
-
9
-
const BATCH_SIZE = 500;
10
-
const FLUSH_MS = 1000;
11
-
12
-
// event, ack
13
-
let rowBuffer: [RecordEvent, () => Promise<void>][] = [];
14
-
let flushTimer: ReturnType<typeof setTimeout> | null = null;
15
-
16
-
async function flushRows(batch: [RecordEvent, () => Promise<void>][]) {
17
-
if (batch.length === 0) return;
18
-
try {
19
-
await db.insert(rawRecords).values(
20
-
batch.map(([evt]) => ({
21
-
tap_id: BigInt(evt.id),
22
-
did: evt.did,
23
-
rev: evt.rev,
24
-
collection: evt.collection,
25
-
rkey: evt.rkey,
26
-
action: evt.action,
27
-
cid: evt.cid,
28
-
record: evt.record ? lexToJson(evt.record) : null
29
-
})
30
-
)).onConflictDoNothing({ target: rawRecords.tap_id });
31
-
console.log(`Inserted ${batch.length} rows.`);
32
-
await Promise.all(batch.map(([_, ack]) => ack()))
33
-
} catch (err) {
34
-
if (batch.length === 1) {
35
-
console.error("Mb chat, it's over", err);
36
-
} else {
37
-
console.error("Mb chat, splitting in 2", err);
38
-
const pivot = Math.floor(batch.length / 2);
39
-
await flushRows(batch.slice(0, pivot));
40
-
await flushRows(batch.slice(pivot));
41
-
}
42
-
}
43
-
}
44
-
45
-
async function flush() {
46
-
if (flushTimer) { clearTimeout(flushTimer); flushTimer = null; }
47
-
if (rowBuffer.length === 0) return;
48
-
const batch = rowBuffer;
49
-
rowBuffer = [];
50
-
await flushRows(batch);
51
-
}
52
-
53
-
const indexer: TapHandler = {
54
-
onEvent: async (evt, opts) => {
55
-
// we don't care about identity events, yet
56
-
if (evt.type !== "record") {
57
-
await opts.ack();
58
-
return;
59
-
}
60
-
if (
61
-
(evt.action === "create" || evt.action === "update") &&
62
-
(evt.cid == null || evt.record == null)
63
-
) {
64
-
console.log("slop spotted, acking and dropping")
65
-
await opts.ack();
66
-
return;
67
-
}
68
-
rowBuffer.push([evt, opts.ack]);
69
-
if (rowBuffer.length >= BATCH_SIZE) {
70
-
await flush();
71
-
} else if (!flushTimer) {
72
-
flushTimer = setTimeout(flush, FLUSH_MS);
73
-
}
74
-
},
75
-
76
-
onError: (err) => console.error("Tap Error:", err),
77
-
}
78
-
79
-
const channel = tap.channel(indexer)
80
-
channel.start()
81
-
console.log("Started Tap Importer...")
+1
-1
api/src/index.ts
+1
-1
api/src/index.ts
+57
api/src/ingest/profile.ts
+57
api/src/ingest/profile.ts
···
1
+
import { and, eq, lt } from "drizzle-orm";
2
+
import { getBlobCidString } from "@atproto/lex";
3
+
import type { CollectionHandler } from "./tap";
4
+
import * as lexiconProfile from "../lexicons/sh/tangled/actor/profile.ts";
5
+
import { db } from "../db/index.ts";
6
+
import { tangledProfile } from "../db/tables/tangled.ts";
7
+
8
+
export const ingestProfile: CollectionHandler = async (profiles) => {
9
+
for (const profile of profiles) {
10
+
const validatedRecord = lexiconProfile.$safeParse(profile.record);
11
+
if (!validatedRecord.success) continue;
12
+
const { value: profileRecord } = validatedRecord;
13
+
14
+
if (profile.action === "delete") {
15
+
await db.update(tangledProfile).set({
16
+
deleted: true
17
+
}).where(and(eq(tangledProfile.did, profile.did), lt(tangledProfile.rev, profile.rev)));
18
+
continue;
19
+
}
20
+
21
+
const avatar = profileRecord.avatar ? getBlobCidString(profileRecord.avatar) : null;
22
+
23
+
await db.insert(tangledProfile).values({
24
+
did: profile.did,
25
+
rev: profile.rev,
26
+
cid: profile.cid,
27
+
deleted: false,
28
+
29
+
avatar,
30
+
description: profileRecord.description,
31
+
links: profileRecord.links,
32
+
stats: profileRecord.stats,
33
+
bluesky: profileRecord.bluesky,
34
+
location: profileRecord.location,
35
+
pinnedRepositories: profileRecord.pinnedRepositories,
36
+
pronouns: profileRecord.pronouns,
37
+
preferredHandle: profileRecord.preferredHandle,
38
+
}).onConflictDoUpdate({
39
+
target: tangledProfile.did,
40
+
set: {
41
+
rev: profile.rev,
42
+
cid: profile.cid,
43
+
deleted: false,
44
+
45
+
avatar,
46
+
description: profileRecord.description,
47
+
links: profileRecord.links,
48
+
stats: profileRecord.stats,
49
+
bluesky: profileRecord.bluesky,
50
+
location: profileRecord.location,
51
+
pinnedRepositories: profileRecord.pinnedRepositories,
52
+
pronouns: profileRecord.pronouns,
53
+
preferredHandle: profileRecord.preferredHandle,
54
+
}
55
+
})
56
+
}
57
+
}
+136
api/src/ingest/tap.ts
+136
api/src/ingest/tap.ts
···
1
+
import { Tap, type RecordEvent, type TapHandler } from '@atproto/tap'
2
+
import { jsonToLex, type JsonValue, lexToJson } from '@atproto/lex';
3
+
import { db } from '../db/index.ts';
4
+
import { rawRecords } from '../db/tables/raw_records.ts';
5
+
import { TAP_URL } from '../lib/constants.ts';
6
+
import { ingestProfile } from './profile.ts';
7
+
8
+
const tap = new Tap(TAP_URL);
9
+
10
+
const BATCH_SIZE = 500;
11
+
const FLUSH_MS = 1000;
12
+
13
+
// event, ack
14
+
let rowBuffer: [RecordEvent, () => Promise<void>][] = [];
15
+
let flushTimer: ReturnType<typeof setTimeout> | null = null;
16
+
17
+
type CollectionHandlerArg = {
18
+
did: `did:${string}:${string}`;
19
+
rev: string;
20
+
collection: `${string}.${string}.${string}`;
21
+
rkey: string;
22
+
action: "create" | "update";
23
+
cid: string;
24
+
record: JsonValue;
25
+
} | {
26
+
did: `did:${string}:${string}`;
27
+
rev: string;
28
+
collection: `${string}.${string}.${string}`;
29
+
rkey: string;
30
+
action: "delete";
31
+
cid: undefined;
32
+
record: JsonValue;
33
+
};
34
+
35
+
export type CollectionHandler = (updates: CollectionHandlerArg[]) => Promise<void>;
36
+
37
+
const COLLECTION_HANDLERS: Record<string, CollectionHandler> = {
38
+
"sh.tangled.actor.profile": ingestProfile
39
+
};
40
+
41
+
async function syncLevelTwoTables(insertedRecords: CollectionHandlerArg[], log = false) {
42
+
const splitByCollection = Object.groupBy(insertedRecords, ({ collection }) => collection);
43
+
44
+
for (const [collection, records] of Object.entries(splitByCollection)) {
45
+
if (!COLLECTION_HANDLERS[collection] || !records) continue;
46
+
if (log) console.log("Starting syncing", collection);
47
+
await COLLECTION_HANDLERS[collection](records).catch(console.error)
48
+
if (log) console.log("Finished syncing", collection);
49
+
}
50
+
}
51
+
52
+
async function flushRows(batch: [RecordEvent, () => Promise<void>][]) {
53
+
if (batch.length === 0) return;
54
+
try {
55
+
const mappedBatch = batch.map(([evt]) => ({
56
+
tap_id: BigInt(evt.id),
57
+
did: evt.did,
58
+
rev: evt.rev,
59
+
collection: evt.collection,
60
+
rkey: evt.rkey,
61
+
action: evt.action,
62
+
cid: evt.cid,
63
+
record: evt.record ? lexToJson(evt.record) : null
64
+
}));
65
+
66
+
const insertedRows = await db.insert(rawRecords).values(mappedBatch).onConflictDoNothing({ target: rawRecords.tap_id }).returning();
67
+
const insertedTapIds = new Set(insertedRows.map(row => row.tap_id));
68
+
console.log(`Inserted ${insertedTapIds.size} rows.`);
69
+
70
+
const insertedRecords = mappedBatch.filter(({ tap_id }) => insertedTapIds.has(tap_id));
71
+
72
+
// kinda sus, but trust bro
73
+
syncLevelTwoTables(insertedRecords as CollectionHandlerArg[]);
74
+
75
+
await Promise.all(batch.map(([_, ack]) => ack()))
76
+
} catch (err) {
77
+
if (batch.length === 1) {
78
+
console.error("Mb chat, it's over", err);
79
+
} else {
80
+
console.error("Mb chat, splitting in 2", err);
81
+
const pivot = Math.floor(batch.length / 2);
82
+
await flushRows(batch.slice(0, pivot));
83
+
await flushRows(batch.slice(pivot));
84
+
}
85
+
}
86
+
}
87
+
88
+
async function flush() {
89
+
if (flushTimer) { clearTimeout(flushTimer); flushTimer = null; }
90
+
if (rowBuffer.length === 0) return;
91
+
const batch = rowBuffer;
92
+
rowBuffer = [];
93
+
await flushRows(batch);
94
+
}
95
+
96
+
const indexer: TapHandler = {
97
+
onEvent: async (evt, opts) => {
98
+
// we don't care about identity events, yet
99
+
if (evt.type !== "record") {
100
+
await opts.ack();
101
+
return;
102
+
}
103
+
if (
104
+
(evt.action === "create" || evt.action === "update") &&
105
+
(evt.cid == null || evt.record == null)
106
+
) {
107
+
console.log("slop spotted, acking and dropping")
108
+
await opts.ack();
109
+
return;
110
+
}
111
+
rowBuffer.push([evt, opts.ack]);
112
+
if (rowBuffer.length >= BATCH_SIZE) {
113
+
await flush();
114
+
} else if (!flushTimer) {
115
+
flushTimer = setTimeout(flush, FLUSH_MS);
116
+
}
117
+
},
118
+
119
+
onError: (err) => console.error("Tap Error:", err),
120
+
}
121
+
122
+
const channel = tap.channel(indexer)
123
+
channel.start()
124
+
console.log("Started Tap Importer...");
125
+
126
+
(async () => {
127
+
const fullIngest = await db.select().from(rawRecords);
128
+
129
+
const relexed = fullIngest.map(({ record, ...fields }) => ({
130
+
...fields,
131
+
record: jsonToLex(record as JsonValue)
132
+
}))
133
+
134
+
// kinda sus, but trust bro
135
+
await syncLevelTwoTables(relexed as CollectionHandlerArg[], true);
136
+
})();
+1
-1
api/src/lexicons/sh.ts
+1
-1
api/src/lexicons/sh.ts
+13
-13
api/src/lexicons/sh/tangled.ts
+13
-13
api/src/lexicons/sh/tangled.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * as actor from './tangled/actor.js'
6
-
export * as feed from './tangled/feed.js'
7
-
export * as git from './tangled/git.js'
8
-
export * as graph from './tangled/graph.js'
9
-
export * as repo from './tangled/repo.js'
10
-
export * as knot from './tangled/knot.js'
11
-
export * as label from './tangled/label.js'
12
-
export * as owner from './tangled/owner.js'
13
-
export * as pipeline from './tangled/pipeline.js'
14
-
export * as publicKey from './tangled/publicKey.js'
15
-
export * as spindle from './tangled/spindle.js'
16
-
export * as string from './tangled/string.js'
17
-
export * as sync from './tangled/sync.js'
5
+
export * as actor from './tangled/actor.ts'
6
+
export * as feed from './tangled/feed.ts'
7
+
export * as git from './tangled/git.ts'
8
+
export * as graph from './tangled/graph.ts'
9
+
export * as repo from './tangled/repo.ts'
10
+
export * as knot from './tangled/knot.ts'
11
+
export * as label from './tangled/label.ts'
12
+
export * as owner from './tangled/owner.ts'
13
+
export * as pipeline from './tangled/pipeline.ts'
14
+
export * as publicKey from './tangled/publicKey.ts'
15
+
export * as spindle from './tangled/spindle.ts'
16
+
export * as string from './tangled/string.ts'
17
+
export * as sync from './tangled/sync.ts'
+1
-1
api/src/lexicons/sh/tangled/actor.ts
+1
-1
api/src/lexicons/sh/tangled/actor.ts
+2
-2
api/src/lexicons/sh/tangled/actor/profile.ts
+2
-2
api/src/lexicons/sh/tangled/actor/profile.ts
+2
-2
api/src/lexicons/sh/tangled/feed.ts
+2
-2
api/src/lexicons/sh/tangled/feed.ts
+2
-2
api/src/lexicons/sh/tangled/feed/reaction.ts
+2
-2
api/src/lexicons/sh/tangled/feed/reaction.ts
+2
-2
api/src/lexicons/sh/tangled/feed/star.ts
+2
-2
api/src/lexicons/sh/tangled/feed/star.ts
+2
-2
api/src/lexicons/sh/tangled/git.ts
+2
-2
api/src/lexicons/sh/tangled/git.ts
+2
-2
api/src/lexicons/sh/tangled/git/refUpdate.ts
+2
-2
api/src/lexicons/sh/tangled/git/refUpdate.ts
+15
-15
api/src/lexicons/sh/tangled/git/temp.ts
+15
-15
api/src/lexicons/sh/tangled/git/temp.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * as analyzeMerge from './temp/analyzeMerge.js'
6
-
export * as defs from './temp/defs.js'
7
-
export * as getArchive from './temp/getArchive.js'
8
-
export * as getBlob from './temp/getBlob.js'
9
-
export * as getBranch from './temp/getBranch.js'
10
-
export * as getCommit from './temp/getCommit.js'
11
-
export * as getDiff from './temp/getDiff.js'
12
-
export * as getEntity from './temp/getEntity.js'
13
-
export * as getHead from './temp/getHead.js'
14
-
export * as getTag from './temp/getTag.js'
15
-
export * as getTree from './temp/getTree.js'
16
-
export * as listBranches from './temp/listBranches.js'
17
-
export * as listCommits from './temp/listCommits.js'
18
-
export * as listLanguages from './temp/listLanguages.js'
19
-
export * as listTags from './temp/listTags.js'
5
+
export * as analyzeMerge from './temp/analyzeMerge.ts'
6
+
export * as defs from './temp/defs.ts'
7
+
export * as getArchive from './temp/getArchive.ts'
8
+
export * as getBlob from './temp/getBlob.ts'
9
+
export * as getBranch from './temp/getBranch.ts'
10
+
export * as getCommit from './temp/getCommit.ts'
11
+
export * as getDiff from './temp/getDiff.ts'
12
+
export * as getEntity from './temp/getEntity.ts'
13
+
export * as getHead from './temp/getHead.ts'
14
+
export * as getTag from './temp/getTag.ts'
15
+
export * as getTree from './temp/getTree.ts'
16
+
export * as listBranches from './temp/listBranches.ts'
17
+
export * as listCommits from './temp/listCommits.ts'
18
+
export * as listLanguages from './temp/listLanguages.ts'
19
+
export * as listTags from './temp/listTags.ts'
+2
-2
api/src/lexicons/sh/tangled/git/temp/analyzeMerge.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/analyzeMerge.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/defs.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/defs.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getArchive.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getArchive.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getBlob.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getBlob.ts
+1
-1
api/src/lexicons/sh/tangled/git/temp/getBranch.defs.ts
+1
-1
api/src/lexicons/sh/tangled/git/temp/getBranch.defs.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getBranch.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getBranch.ts
+1
-1
api/src/lexicons/sh/tangled/git/temp/getCommit.defs.ts
+1
-1
api/src/lexicons/sh/tangled/git/temp/getCommit.defs.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getCommit.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getCommit.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getDiff.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getDiff.ts
+1
-1
api/src/lexicons/sh/tangled/git/temp/getEntity.defs.ts
+1
-1
api/src/lexicons/sh/tangled/git/temp/getEntity.defs.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getEntity.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getEntity.ts
+1
-1
api/src/lexicons/sh/tangled/git/temp/getHead.defs.ts
+1
-1
api/src/lexicons/sh/tangled/git/temp/getHead.defs.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getHead.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getHead.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getTag.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getTag.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getTree.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/getTree.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/listBranches.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/listBranches.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/listCommits.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/listCommits.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/listLanguages.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/listLanguages.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/listTags.ts
+2
-2
api/src/lexicons/sh/tangled/git/temp/listTags.ts
+2
-2
api/src/lexicons/sh/tangled/graph.ts
+2
-2
api/src/lexicons/sh/tangled/graph.ts
+2
-2
api/src/lexicons/sh/tangled/graph/follow.ts
+2
-2
api/src/lexicons/sh/tangled/graph/follow.ts
+2
-2
api/src/lexicons/sh/tangled/graph/vouch.ts
+2
-2
api/src/lexicons/sh/tangled/graph/vouch.ts
+6
-6
api/src/lexicons/sh/tangled/knot.ts
+6
-6
api/src/lexicons/sh/tangled/knot.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * from './knot.defs.js'
6
-
export * as $defs from './knot.defs.js'
7
-
export * as listKeys from './knot/listKeys.js'
8
-
export * as member from './knot/member.js'
9
-
export * as subscribeRepos from './knot/subscribeRepos.js'
10
-
export * as version from './knot/version.js'
5
+
export * from './knot.defs.ts'
6
+
export * as $defs from './knot.defs.ts'
7
+
export * as listKeys from './knot/listKeys.ts'
8
+
export * as member from './knot/member.ts'
9
+
export * as subscribeRepos from './knot/subscribeRepos.ts'
10
+
export * as version from './knot/version.ts'
+2
-2
api/src/lexicons/sh/tangled/knot/listKeys.ts
+2
-2
api/src/lexicons/sh/tangled/knot/listKeys.ts
+2
-2
api/src/lexicons/sh/tangled/knot/member.ts
+2
-2
api/src/lexicons/sh/tangled/knot/member.ts
+1
-1
api/src/lexicons/sh/tangled/knot/subscribeRepos.defs.ts
+1
-1
api/src/lexicons/sh/tangled/knot/subscribeRepos.defs.ts
+2
-2
api/src/lexicons/sh/tangled/knot/subscribeRepos.ts
+2
-2
api/src/lexicons/sh/tangled/knot/subscribeRepos.ts
+2
-2
api/src/lexicons/sh/tangled/knot/version.ts
+2
-2
api/src/lexicons/sh/tangled/knot/version.ts
+2
-2
api/src/lexicons/sh/tangled/label.ts
+2
-2
api/src/lexicons/sh/tangled/label.ts
+2
-2
api/src/lexicons/sh/tangled/label/definition.ts
+2
-2
api/src/lexicons/sh/tangled/label/definition.ts
+2
-2
api/src/lexicons/sh/tangled/label/op.ts
+2
-2
api/src/lexicons/sh/tangled/label/op.ts
+2
-2
api/src/lexicons/sh/tangled/owner.ts
+2
-2
api/src/lexicons/sh/tangled/owner.ts
+4
-4
api/src/lexicons/sh/tangled/pipeline.ts
+4
-4
api/src/lexicons/sh/tangled/pipeline.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * as cancelPipeline from './pipeline/cancelPipeline.js'
6
-
export * from './pipeline.defs.js'
7
-
export * as $defs from './pipeline.defs.js'
8
-
export * as status from './pipeline/status.js'
5
+
export * as cancelPipeline from './pipeline/cancelPipeline.ts'
6
+
export * from './pipeline.defs.ts'
7
+
export * as $defs from './pipeline.defs.ts'
8
+
export * as status from './pipeline/status.ts'
+2
-2
api/src/lexicons/sh/tangled/pipeline/cancelPipeline.ts
+2
-2
api/src/lexicons/sh/tangled/pipeline/cancelPipeline.ts
+2
-2
api/src/lexicons/sh/tangled/pipeline/status.ts
+2
-2
api/src/lexicons/sh/tangled/pipeline/status.ts
+2
-2
api/src/lexicons/sh/tangled/publicKey.ts
+2
-2
api/src/lexicons/sh/tangled/publicKey.ts
+30
-30
api/src/lexicons/sh/tangled/repo.ts
+30
-30
api/src/lexicons/sh/tangled/repo.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * as issue from './repo/issue.js'
6
-
export * as pull from './repo/pull.js'
7
-
export * as addSecret from './repo/addSecret.js'
8
-
export * as archive from './repo/archive.js'
9
-
export * as artifact from './repo/artifact.js'
10
-
export * as blob from './repo/blob.js'
11
-
export * as branch from './repo/branch.js'
12
-
export * as branches from './repo/branches.js'
13
-
export * as collaborator from './repo/collaborator.js'
14
-
export * as compare from './repo/compare.js'
15
-
export * as create from './repo/create.js'
16
-
export * as setDefaultBranch from './repo/setDefaultBranch.js'
17
-
export * as 'delete' from './repo/delete.js'
18
-
export * as deleteBranch from './repo/deleteBranch.js'
19
-
export * as diff from './repo/diff.js'
20
-
export * as forkStatus from './repo/forkStatus.js'
21
-
export * as forkSync from './repo/forkSync.js'
22
-
export * as getDefaultBranch from './repo/getDefaultBranch.js'
23
-
export * as hiddenRef from './repo/hiddenRef.js'
24
-
export * as languages from './repo/languages.js'
25
-
export * as listSecrets from './repo/listSecrets.js'
26
-
export * as log from './repo/log.js'
27
-
export * as merge from './repo/merge.js'
28
-
export * as mergeCheck from './repo/mergeCheck.js'
29
-
export * as removeSecret from './repo/removeSecret.js'
30
-
export * from './repo.defs.js'
31
-
export * as $defs from './repo.defs.js'
32
-
export * as tag from './repo/tag.js'
33
-
export * as tags from './repo/tags.js'
34
-
export * as tree from './repo/tree.js'
5
+
export * as issue from './repo/issue.ts'
6
+
export * as pull from './repo/pull.ts'
7
+
export * as addSecret from './repo/addSecret.ts'
8
+
export * as archive from './repo/archive.ts'
9
+
export * as artifact from './repo/artifact.ts'
10
+
export * as blob from './repo/blob.ts'
11
+
export * as branch from './repo/branch.ts'
12
+
export * as branches from './repo/branches.ts'
13
+
export * as collaborator from './repo/collaborator.ts'
14
+
export * as compare from './repo/compare.ts'
15
+
export * as create from './repo/create.ts'
16
+
export * as setDefaultBranch from './repo/setDefaultBranch.ts'
17
+
export * as 'delete' from './repo/delete.ts'
18
+
export * as deleteBranch from './repo/deleteBranch.ts'
19
+
export * as diff from './repo/diff.ts'
20
+
export * as forkStatus from './repo/forkStatus.ts'
21
+
export * as forkSync from './repo/forkSync.ts'
22
+
export * as getDefaultBranch from './repo/getDefaultBranch.ts'
23
+
export * as hiddenRef from './repo/hiddenRef.ts'
24
+
export * as languages from './repo/languages.ts'
25
+
export * as listSecrets from './repo/listSecrets.ts'
26
+
export * as log from './repo/log.ts'
27
+
export * as merge from './repo/merge.ts'
28
+
export * as mergeCheck from './repo/mergeCheck.ts'
29
+
export * as removeSecret from './repo/removeSecret.ts'
30
+
export * from './repo.defs.ts'
31
+
export * as $defs from './repo.defs.ts'
32
+
export * as tag from './repo/tag.ts'
33
+
export * as tags from './repo/tags.ts'
34
+
export * as tree from './repo/tree.ts'
+2
-2
api/src/lexicons/sh/tangled/repo/addSecret.ts
+2
-2
api/src/lexicons/sh/tangled/repo/addSecret.ts
+2
-2
api/src/lexicons/sh/tangled/repo/archive.ts
+2
-2
api/src/lexicons/sh/tangled/repo/archive.ts
+2
-2
api/src/lexicons/sh/tangled/repo/artifact.ts
+2
-2
api/src/lexicons/sh/tangled/repo/artifact.ts
+2
-2
api/src/lexicons/sh/tangled/repo/blob.ts
+2
-2
api/src/lexicons/sh/tangled/repo/blob.ts
+2
-2
api/src/lexicons/sh/tangled/repo/branch.ts
+2
-2
api/src/lexicons/sh/tangled/repo/branch.ts
+2
-2
api/src/lexicons/sh/tangled/repo/branches.ts
+2
-2
api/src/lexicons/sh/tangled/repo/branches.ts
+2
-2
api/src/lexicons/sh/tangled/repo/collaborator.ts
+2
-2
api/src/lexicons/sh/tangled/repo/collaborator.ts
+2
-2
api/src/lexicons/sh/tangled/repo/compare.ts
+2
-2
api/src/lexicons/sh/tangled/repo/compare.ts
+2
-2
api/src/lexicons/sh/tangled/repo/create.ts
+2
-2
api/src/lexicons/sh/tangled/repo/create.ts
+2
-2
api/src/lexicons/sh/tangled/repo/delete.ts
+2
-2
api/src/lexicons/sh/tangled/repo/delete.ts
+2
-2
api/src/lexicons/sh/tangled/repo/deleteBranch.ts
+2
-2
api/src/lexicons/sh/tangled/repo/deleteBranch.ts
+2
-2
api/src/lexicons/sh/tangled/repo/diff.ts
+2
-2
api/src/lexicons/sh/tangled/repo/diff.ts
+2
-2
api/src/lexicons/sh/tangled/repo/forkStatus.ts
+2
-2
api/src/lexicons/sh/tangled/repo/forkStatus.ts
+2
-2
api/src/lexicons/sh/tangled/repo/forkSync.ts
+2
-2
api/src/lexicons/sh/tangled/repo/forkSync.ts
+2
-2
api/src/lexicons/sh/tangled/repo/getDefaultBranch.ts
+2
-2
api/src/lexicons/sh/tangled/repo/getDefaultBranch.ts
+4
-4
api/src/lexicons/sh/tangled/repo/issue.ts
+4
-4
api/src/lexicons/sh/tangled/repo/issue.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * as state from './issue/state.js'
6
-
export * as comment from './issue/comment.js'
7
-
export * from './issue.defs.js'
8
-
export * as $defs from './issue.defs.js'
5
+
export * as state from './issue/state.ts'
6
+
export * as comment from './issue/comment.ts'
7
+
export * from './issue.defs.ts'
8
+
export * as $defs from './issue.defs.ts'
+2
-2
api/src/lexicons/sh/tangled/repo/issue/comment.ts
+2
-2
api/src/lexicons/sh/tangled/repo/issue/comment.ts
+4
-4
api/src/lexicons/sh/tangled/repo/issue/state.ts
+4
-4
api/src/lexicons/sh/tangled/repo/issue/state.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * as closed from './state/closed.js'
6
-
export * as open from './state/open.js'
7
-
export * from './state.defs.js'
8
-
export * as $defs from './state.defs.js'
5
+
export * as closed from './state/closed.ts'
6
+
export * as open from './state/open.ts'
7
+
export * from './state.defs.ts'
8
+
export * as $defs from './state.defs.ts'
+2
-2
api/src/lexicons/sh/tangled/repo/issue/state/closed.ts
+2
-2
api/src/lexicons/sh/tangled/repo/issue/state/closed.ts
+2
-2
api/src/lexicons/sh/tangled/repo/issue/state/open.ts
+2
-2
api/src/lexicons/sh/tangled/repo/issue/state/open.ts
+2
-2
api/src/lexicons/sh/tangled/repo/languages.ts
+2
-2
api/src/lexicons/sh/tangled/repo/languages.ts
+2
-2
api/src/lexicons/sh/tangled/repo/listSecrets.ts
+2
-2
api/src/lexicons/sh/tangled/repo/listSecrets.ts
+2
-2
api/src/lexicons/sh/tangled/repo/log.ts
+2
-2
api/src/lexicons/sh/tangled/repo/log.ts
+2
-2
api/src/lexicons/sh/tangled/repo/merge.ts
+2
-2
api/src/lexicons/sh/tangled/repo/merge.ts
+2
-2
api/src/lexicons/sh/tangled/repo/mergeCheck.ts
+2
-2
api/src/lexicons/sh/tangled/repo/mergeCheck.ts
+4
-4
api/src/lexicons/sh/tangled/repo/pull.ts
+4
-4
api/src/lexicons/sh/tangled/repo/pull.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * as status from './pull/status.js'
6
-
export * as comment from './pull/comment.js'
7
-
export * from './pull.defs.js'
8
-
export * as $defs from './pull.defs.js'
5
+
export * as status from './pull/status.ts'
6
+
export * as comment from './pull/comment.ts'
7
+
export * from './pull.defs.ts'
8
+
export * as $defs from './pull.defs.ts'
+2
-2
api/src/lexicons/sh/tangled/repo/pull/comment.ts
+2
-2
api/src/lexicons/sh/tangled/repo/pull/comment.ts
+5
-5
api/src/lexicons/sh/tangled/repo/pull/status.ts
+5
-5
api/src/lexicons/sh/tangled/repo/pull/status.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * as closed from './status/closed.js'
6
-
export * as merged from './status/merged.js'
7
-
export * as open from './status/open.js'
8
-
export * from './status.defs.js'
9
-
export * as $defs from './status.defs.js'
5
+
export * as closed from './status/closed.ts'
6
+
export * as merged from './status/merged.ts'
7
+
export * as open from './status/open.ts'
8
+
export * from './status.defs.ts'
9
+
export * as $defs from './status.defs.ts'
+2
-2
api/src/lexicons/sh/tangled/repo/pull/status/closed.ts
+2
-2
api/src/lexicons/sh/tangled/repo/pull/status/closed.ts
+2
-2
api/src/lexicons/sh/tangled/repo/pull/status/merged.ts
+2
-2
api/src/lexicons/sh/tangled/repo/pull/status/merged.ts
+2
-2
api/src/lexicons/sh/tangled/repo/pull/status/open.ts
+2
-2
api/src/lexicons/sh/tangled/repo/pull/status/open.ts
+2
-2
api/src/lexicons/sh/tangled/repo/removeSecret.ts
+2
-2
api/src/lexicons/sh/tangled/repo/removeSecret.ts
+2
-2
api/src/lexicons/sh/tangled/repo/setDefaultBranch.ts
+2
-2
api/src/lexicons/sh/tangled/repo/setDefaultBranch.ts
+2
-2
api/src/lexicons/sh/tangled/repo/tag.ts
+2
-2
api/src/lexicons/sh/tangled/repo/tag.ts
+2
-2
api/src/lexicons/sh/tangled/repo/tree.ts
+2
-2
api/src/lexicons/sh/tangled/repo/tree.ts
+3
-3
api/src/lexicons/sh/tangled/spindle.ts
+3
-3
api/src/lexicons/sh/tangled/spindle.ts
···
2
2
* THIS FILE WAS GENERATED BY "@atproto/lex". DO NOT EDIT.
3
3
*/
4
4
5
-
export * as member from './spindle/member.js'
6
-
export * from './spindle.defs.js'
7
-
export * as $defs from './spindle.defs.js'
5
+
export * as member from './spindle/member.ts'
6
+
export * from './spindle.defs.ts'
7
+
export * as $defs from './spindle.defs.ts'
+2
-2
api/src/lexicons/sh/tangled/spindle/member.ts
+2
-2
api/src/lexicons/sh/tangled/spindle/member.ts
+2
-2
api/src/lexicons/sh/tangled/string.ts
+2
-2
api/src/lexicons/sh/tangled/string.ts
+1
-1
api/src/lexicons/sh/tangled/sync.ts
+1
-1
api/src/lexicons/sh/tangled/sync.ts
+2
-2
api/src/lexicons/sh/tangled/sync/requestCrawl.ts
+2
-2
api/src/lexicons/sh/tangled/sync/requestCrawl.ts