AppView in a box as a Vite plugin thing
hatk.dev
fix: add commit and validationStatus to createRecord/putRecord lexicon output, format
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
+29
-13
-5
packages/hatk/src/backfill.ts
-5
packages/hatk/src/backfill.ts
···
29
29
config: BackfillConfig
30
30
}
31
31
32
-
33
32
interface PdsResolution {
34
33
/** The PDS service endpoint URL from the DID document. */
35
34
pds: string
···
82
81
return result
83
82
}
84
83
85
-
86
84
/**
87
85
* Paginates through all active repos on a relay/PDS using `com.atproto.sync.listRepos`.
88
86
* Yields `{ did, rev }` for each active repo. Skips deactivated repos.
···
128
126
cursor = data.cursor
129
127
}
130
128
}
131
-
132
129
133
130
/**
134
131
* Downloads and indexes a single user's repo via `com.atproto.sync.getRepo`.
···
307
304
}
308
305
}
309
306
310
-
311
307
/**
312
308
* Processes items concurrently with a fixed number of workers.
313
309
* Workers pull from a shared index so the pool stays saturated even when
···
335
331
const workers = Array.from({ length: Math.min(parallelism, items.length) }, () => worker())
336
332
await Promise.all(workers)
337
333
}
338
-
339
334
340
335
/**
341
336
* Orchestrates a full backfill run: enumerate repos, filter to pending, download, and index.
+1
-1
packages/hatk/src/car.ts
+1
-1
packages/hatk/src/car.ts
···
125
125
async function fill(need: number): Promise<boolean> {
126
126
while (len - pos < need) {
127
127
const { done, value } = await reader.read()
128
-
if (done) return (len - pos) >= need
128
+
if (done) return len - pos >= need
129
129
byteLength += value.length
130
130
131
131
// Compact: shift remaining data to front when read cursor passes midpoint
+16
packages/hatk/src/cli.ts
+16
packages/hatk/src/cli.ts
···
580
580
properties: {
581
581
uri: { type: 'string', format: 'at-uri' },
582
582
cid: { type: 'string', format: 'cid' },
583
+
commit: {
584
+
type: 'object',
585
+
properties: {
586
+
cid: { type: 'string', format: 'cid' },
587
+
rev: { type: 'string' },
588
+
},
589
+
},
590
+
validationStatus: { type: 'string' },
583
591
},
584
592
},
585
593
},
···
651
659
properties: {
652
660
uri: { type: 'string', format: 'at-uri' },
653
661
cid: { type: 'string', format: 'cid' },
662
+
commit: {
663
+
type: 'object',
664
+
properties: {
665
+
cid: { type: 'string', format: 'cid' },
666
+
rev: { type: 'string' },
667
+
},
668
+
},
669
+
validationStatus: { type: 'string' },
654
670
},
655
671
},
656
672
},
-1
packages/hatk/src/db.ts
-1
packages/hatk/src/db.ts
+3
-2
packages/hatk/src/main.ts
+3
-2
packages/hatk/src/main.ts
···
28
28
29
29
function logMemory(phase: string): void {
30
30
const mem = process.memoryUsage()
31
-
log(`[mem] ${phase}: heap=${Math.round(mem.heapUsed / 1024 / 1024)}MB rss=${Math.round(mem.rss / 1024 / 1024)}MB external=${Math.round(mem.external / 1024 / 1024)}MB arrayBuffers=${Math.round(mem.arrayBuffers / 1024 / 1024)}MB`)
31
+
log(
32
+
`[mem] ${phase}: heap=${Math.round(mem.heapUsed / 1024 / 1024)}MB rss=${Math.round(mem.rss / 1024 / 1024)}MB external=${Math.round(mem.external / 1024 / 1024)}MB arrayBuffers=${Math.round(mem.arrayBuffers / 1024 / 1024)}MB`,
33
+
)
32
34
}
33
35
34
36
const configPath = process.argv[2] || 'hatk.config.ts'
···
100
102
await initDatabase(config.database, schemas, ddlStatements)
101
103
logMemory('after-db-init')
102
104
log(`[main] DuckDB initialized (${config.database === ':memory:' ? 'in-memory' : config.database})`)
103
-
104
105
105
106
// 3b. Run setup hooks (after DB init, before server)
106
107
await initSetup(resolve(configDir, 'setup'))
+9
-4
packages/hatk/src/seed.ts
+9
-4
packages/hatk/src/seed.ts
···
89
89
collection: K,
90
90
record: R[K] extends Record<string, unknown> ? R[K] : Record<string, unknown>,
91
91
opts: { rkey: string },
92
-
): Promise<{ uri: string; cid: string }> {
92
+
): Promise<{ uri: string; cid: string; commit: { cid: string; rev: string }; validationStatus: string }> {
93
93
const error = validateRecord(lexiconArray, collection, record)
94
94
if (error) {
95
95
throw new Error(
···
112
112
if (!res.ok) {
113
113
throw new Error(`[seed] [${session.handle}] failed to create ${collection}: ${await res.text()}`)
114
114
}
115
-
const { uri, cid } = (await res.json()) as { uri: string; cid: string }
116
-
console.log(`[seed] [${session.handle}] ${collection} → ${uri}`)
117
-
return { uri, cid }
115
+
const result = (await res.json()) as {
116
+
uri: string
117
+
cid: string
118
+
commit: { cid: string; rev: string }
119
+
validationStatus: string
120
+
}
121
+
console.log(`[seed] [${session.handle}] ${collection} → ${result.uri}`)
122
+
return result
118
123
}
119
124
120
125
/** Upload a file to the PDS as a blob. MIME type is inferred from the file extension. */