ref(twitter): compose setup from web domains

- use fixed OAuth capabilities and ordinary Source, Cron, and Job models
- separate Bookmark Source selection, creation, and scheduling in the wizard
- publish the immutable Web Distribution as 0.2.1

Author: xiaoland

apps/client-web/src/twitter-setup-api.spec.ts

@@ -1,16 +1,25 @@
 import { afterEach, describe, expect, it, vi } from 'vitest'
-import { Peer, PeerManager, type ExtensionStatePort, type InstalledExtension } from '@inkcre/core'
+import {
+  Cron,
+  Peer,
+  PeerManager,
+  Source,
+  SourceForm,
+  type ExtensionStatePort,
+  type InstalledExtension,
+} from '@inkcre/core'
 import {
   discoverCoreCandidates,
   OAuthTransactionSchema,
+  TwitterBookmarkSetup,
   TwitterSetupAPI,
   TwitterSetupStatusSchema,
 } from '../../../extensions/twitter/src/setup-api'
 
 const corePeerId = '00000000-0000-4000-8000-000000000002'
 const installed: InstalledExtension = {
   name: 'inkcre/twitter',
-  version: '0.2.0',
+  version: '0.2.1',
   enabled: [corePeerId],
   nickname: 'Twitter',
   config: {},
@@ -28,7 +37,7 @@ const corePeer = Peer.parse({
       inbound: { protocol: 'core.peer.protocol.http.v1', parameters: {} },
     },
     {
-      id: 'inkcre.twitter.setup.v1',
+      id: 'inkcre.twitter.setup.status.v1',
       inbound: { protocol: 'core.peer.protocol.http.v1', parameters: {} },
     },
   ],
@@ -70,20 +79,14 @@ describe('Twitter Peer setup API', () => {
         handle: null,
         scopes: [],
         reconnect_required: false,
-        bookmark_source_id: null,
-        bookmark_cron_id: null,
-        bookmark_sources: [],
-        collect_at: { day_of_week: null, hour: 0, minute: 0 },
-        bookmark_source_ready: false,
-        ready: false,
       },
     })
 
     await new TwitterSetupAPI(corePeer).status()
 
     expect(delegate).toHaveBeenCalledWith(
-      'inkcre.twitter.setup.v1',
-      { body: { action: 'get_status' } },
+      'inkcre.twitter.setup.status.v1',
+      { body: {} },
       corePeerId
     )
   })
@@ -100,12 +103,6 @@ describe('Twitter Peer setup API', () => {
         handle: null,
         scopes: [],
         reconnect_required: false,
-        bookmark_source_id: null,
-        bookmark_cron_id: null,
-        bookmark_sources: [],
-        collect_at: { day_of_week: null, hour: 0, minute: 0 },
-        bookmark_source_ready: false,
-        ready: false,
       })
     ).toThrow('HTTP or HTTPS')
     expect(() =>
@@ -127,4 +124,49 @@ describe('Twitter Peer setup API', () => {
       })
     ).toThrow('embedded credentials')
   })
+
+  it('composes bookmark Source, Cron, and initial Job through ordinary database models', async () => {
+    const source = Source.parse({
+      id: 25,
+      type: 'extensions.twitter.bookmark.Source',
+      nickname: 'Bookmarks',
+      config: {},
+      state: {},
+      storage: null,
+      block: null,
+      created_at: '2026-01-01T00:00:00Z',
+      updated_at: '2026-01-01T00:00:00Z',
+    })
+    const cron = Cron.parse({
+      id: 9,
+      schedule: '30 6 * * *',
+      enabled: false,
+      job_type: 'core.source.collect.v1',
+      job_parameters: { source: 25, config: { full: false, result_limit: 40 } },
+      job_timeout_seconds: null,
+      last_job: null,
+      last_scheduled_for: null,
+      created_at: '2026-01-01T00:00:00Z',
+      updated_at: '2026-01-01T00:00:00Z',
+    })
+    vi.spyOn(Source, 'getAll').mockResolvedValue([source])
+    vi.spyOn(Cron, 'getBySource').mockResolvedValue([cron])
+    vi.spyOn(SourceForm.prototype, 'create').mockResolvedValue(source)
+    const update = vi
+      .spyOn(Cron.prototype, 'update')
+      .mockImplementation(async (form) =>
+        Cron.parse({ ...cron, ...form, id: cron.id, enabled: form.enabled })
+      )
+    const runNow = vi.spyOn(Cron.prototype, 'runNow').mockResolvedValue({} as never)
+
+    await expect(TwitterBookmarkSetup.read()).resolves.toMatchObject({ source, cron })
+    await expect(TwitterBookmarkSetup.createSource('Bookmarks')).resolves.toBe(source)
+    const scheduled = await TwitterBookmarkSetup.saveSchedule(source, 7, 15)
+    expect(update).toHaveBeenLastCalledWith(
+      expect.objectContaining({ schedule: '15 7 * * *', enabled: false })
+    )
+    await TwitterBookmarkSetup.finish(source, scheduled)
+    expect(update).toHaveBeenLastCalledWith(expect.objectContaining({ enabled: true }))
+    expect(runNow).toHaveBeenCalledOnce()
+  })
 })

extensions/twitter/package.json

@@ -36,7 +36,7 @@
     "nickname": "Twitter",
     "module_federation": {
       "host_sdk": "@inkcre/core",
-      "host_sdk_version": ">=0.1.0 <0.2.0"
+      "host_sdk_version": ">=0.1.2 <0.2.0"
     }
   }
 }

extensions/twitter/src/components/twitterSetupWizard/twitterSetupWizard.scss

@@ -20,7 +20,7 @@
       display: flex;
       align-items: center;
       gap: 0.4rem;
-      color: #6b7280;
+      color: sys-var(color, text, muted);
       font-size: 0.8rem;
     }
 
@@ -35,7 +35,7 @@
 
     .is-current,
     .is-complete {
-      color: #2563eb;
+      color: sys-var(color, info, base);
       font-weight: 600;
     }
   }
@@ -58,20 +58,36 @@
     }
   }
 
+  &__section,
+  &__empty {
+    display: grid;
+    gap: sys-var(space, sm);
+    padding: sys-var(space, md);
+    border: 1px solid sys-var(color, border, base);
+    background: sys-var(color, surface, subtle);
+
+    h4,
+    p {
+      margin: 0;
+    }
+  }
+
+  &__hint {
+    color: sys-var(color, text, subtle);
+  }
+
   &__field,
   &__schedule label {
     display: grid;
     gap: 0.35rem;
   }
 
-  select,
-  input {
+  &__field input {
     min-height: 2.5rem;
-    padding: 0.5rem;
-    border: 1px solid #d1d5db;
-    border-radius: 0.35rem;
-    background: transparent;
-    color: inherit;
+    padding: sys-var(space, sm);
+    border: 1px solid sys-var(color, border, base);
+    background: sys-var(color, surface, base);
+    color: sys-var(color, text, base);
   }
 
   &__schedule,
@@ -94,7 +110,7 @@
 
   &__error {
     margin: 0;
-    color: #b91c1c;
+    color: sys-var(color, danger, base);
   }
 
   dl {