fix: restore backups + fork lineage (#1) (thanks @joshp123)

Author: steipete

CHANGELOG.md

@@ -12,6 +12,8 @@
 - Web: stabilize skill OG image generation on server runtimes.
 - Web: prevent skill OG text overflow outside the card.
 - Registry: make SoulHub auto-seed idempotent and non-user-owned.
+- Registry: keep GitHub backup state + publish backups intact (thanks @joshp123, #1).
+- CLI/Registry: restore fork lineage on sync + clamp bulk list queries (thanks @joshp123, #1).
 
 ## 0.0.6 - 2026-01-07
 

convex/schema.ts

@@ -268,6 +268,12 @@ const rateLimits = defineTable({
   .index('by_key_window', ['key', 'windowStart'])
   .index('by_key', ['key'])
 
+const githubBackupSyncState = defineTable({
+  key: v.string(),
+  cursor: v.optional(v.string()),
+  updatedAt: v.number(),
+}).index('by_key', ['key'])
+
 const userSyncRoots = defineTable({
   userId: v.id('users'),
   rootId: v.string(),
@@ -324,6 +330,7 @@ export default defineSchema({
   auditLogs,
   apiTokens,
   rateLimits,
+  githubBackupSyncState,
   userSyncRoots,
   userSkillInstalls,
   userSkillRootInstalls,

convex/skills.ts

@@ -20,6 +20,8 @@ type FileTextResult = { path: string; text: string; size: number; sha256: string
 
 const MAX_DIFF_FILE_BYTES = 200 * 1024
 const MAX_LIST_LIMIT = 50
+const MAX_LIST_BULK_LIMIT = 200
+const MAX_LIST_TAKE = 1000
 
 export const getBySlug = query({
   args: { slug: v.string() },
@@ -87,13 +89,14 @@ export const list = query({
     limit: v.optional(v.number()),
   },
   handler: async (ctx, args) => {
-    const limit = args.limit ?? 24
+    const limit = clampInt(args.limit ?? 24, 1, MAX_LIST_BULK_LIMIT)
+    const takeLimit = Math.min(limit * 5, MAX_LIST_TAKE)
     if (args.batch) {
       const entries = await ctx.db
         .query('skills')
         .withIndex('by_batch', (q) => q.eq('batch', args.batch))
         .order('desc')
-        .take(limit * 5)
+        .take(takeLimit)
       return entries.filter((skill) => !skill.softDeletedAt).slice(0, limit)
     }
     const ownerUserId = args.ownerUserId
@@ -102,13 +105,10 @@ export const list = query({
         .query('skills')
         .withIndex('by_owner', (q) => q.eq('ownerUserId', ownerUserId))
         .order('desc')
-        .take(limit * 5)
+        .take(takeLimit)
       return entries.filter((skill) => !skill.softDeletedAt).slice(0, limit)
     }
-    const entries = await ctx.db
-      .query('skills')
-      .order('desc')
-      .take(limit * 5)
+    const entries = await ctx.db.query('skills').order('desc').take(takeLimit)
     return entries.filter((skill) => !skill.softDeletedAt).slice(0, limit)
   },
 })
@@ -120,25 +120,23 @@ export const listWithLatest = query({
     limit: v.optional(v.number()),
   },
   handler: async (ctx, args) => {
-    const limit = args.limit ?? 24
+    const limit = clampInt(args.limit ?? 24, 1, MAX_LIST_BULK_LIMIT)
+    const takeLimit = Math.min(limit * 5, MAX_LIST_TAKE)
     let entries: Doc<'skills'>[] = []
     if (args.batch) {
       entries = await ctx.db
         .query('skills')
         .withIndex('by_batch', (q) => q.eq('batch', args.batch))
         .order('desc')
-        .take(limit * 5)
+        .take(takeLimit)
     } else if (args.ownerUserId) {
       entries = await ctx.db
         .query('skills')
         .withIndex('by_owner', (q) => q.eq('ownerUserId', args.ownerUserId))
         .order('desc')
-        .take(limit * 5)
+        .take(takeLimit)
     } else {
-      entries = await ctx.db
-        .query('skills')
-        .order('desc')
-        .take(limit * 5)
+      entries = await ctx.db.query('skills').order('desc').take(takeLimit)
     }
 
     const filtered = entries.filter((skill) => !skill.softDeletedAt).slice(0, limit)

packages/clawdhub/src/cli/commands/sync.ts

@@ -1,6 +1,6 @@
 import { intro, outro } from '@clack/prompts'
 import { readGlobalConfig } from '../../config.js'
-import { hashSkillFiles, listTextFiles } from '../../skills.js'
+import { hashSkillFiles, listTextFiles, readSkillOrigin } from '../../skills.js'
 import { resolveClawdbotSkillRoots } from '../clawdbotConfig.js'
 import { getFallbackSkillRoots } from '../scanSkills.js'
 import type { GlobalOpts } from '../types.js'
@@ -84,12 +84,14 @@ export async function cmdSync(opts: GlobalOpts, options: SyncOptions, inputAllow
     const parsed = await mapWithConcurrency(skills, Math.min(concurrency, 12), async (skill) => {
       const filesOnDisk = await listTextFiles(skill.folder)
       const hashed = hashSkillFiles(filesOnDisk)
+      const origin = await readSkillOrigin(skill.folder)
       done += 1
       parsingSpinner.text = `Parsing local skills ${done}/${skills.length}`
       return {
         ...skill,
         fingerprint: hashed.fingerprint,
         fileCount: filesOnDisk.length,
+        origin,
       }
     })
     locals.push(...parsed)
@@ -174,14 +176,25 @@ export async function cmdSync(opts: GlobalOpts, options: SyncOptions, inputAllow
       allowPrompt,
       changelogFlag: options.changelog,
     })
+    const forkOf =
+      skill.origin && normalizeRegistry(skill.origin.registry) === normalizeRegistry(registry)
+        ? skill.origin.slug !== skill.slug
+          ? `${skill.origin.slug}@${skill.origin.installedVersion}`
+          : undefined
+        : undefined
     await cmdPublish(opts, skill.folder, {
       slug: skill.slug,
       name: skill.displayName,
       version: publishVersion,
       changelog,
       tags,
+      forkOf,
     })
   }
 
   outro(`Uploaded ${selected.length} skill(s).`)
 }
+
+function normalizeRegistry(value: string) {
+  return value.trim().replace(/\/+$/, '').toLowerCase()
+}

packages/clawdhub/src/cli/commands/syncTypes.ts

@@ -1,3 +1,4 @@
+import type { SkillOrigin } from '../../skills.js'
 import type { SkillFolder } from '../scanSkills.js'
 
 export type SyncOptions = {
@@ -13,6 +14,7 @@ export type SyncOptions = {
 export type Candidate = SkillFolder & {
   fingerprint: string
   fileCount: number
+  origin: SkillOrigin | null
   status: 'synced' | 'new' | 'update'
   matchVersion: string | null
   latestVersion: string | null
@@ -21,4 +23,5 @@ export type Candidate = SkillFolder & {
 export type LocalSkill = SkillFolder & {
   fingerprint: string
   fileCount: number
+  origin: SkillOrigin | null
 }

src/routeTree.gen.ts

@@ -357,11 +357,10 @@ export const routeTree = rootRouteImport
   ._addFileTypes<FileRouteTypes>()
 
 import type { getRouter } from './router.tsx'
-import type { startInstance } from './start.ts'
+import type { createStart } from '@tanstack/react-start'
 declare module '@tanstack/react-start' {
   interface Register {
     ssr: true
     router: Awaited<ReturnType<typeof getRouter>>
-    config: Awaited<ReturnType<typeof startInstance.getOptions>>
   }
 }

src/routes/skills/index.tsx

@@ -83,9 +83,9 @@ function SkillsIndex() {
           return (a.skill.updatedAt - b.skill.updatedAt) * multiplier
         case 'name':
           return (
-            a.skill.displayName.localeCompare(b.skill.displayName) ||
-            a.skill.slug.localeCompare(b.skill.slug)
-          ) * multiplier
+            (a.skill.displayName.localeCompare(b.skill.displayName) ||
+              a.skill.slug.localeCompare(b.skill.slug)) * multiplier
+          )
         default:
           return (a.skill.createdAt - b.skill.createdAt) * multiplier
       }