feat(V2-3차): pull 확장 + invite flow + Realtime + 테스트 + mobile UI 교체
묶음 E — V2-4b pull 확장:
- CloudSyncService.pullAll()에 meetings/meeting_memos/meeting_documents 추가
- meetings: LWW, 모든 컬럼 매핑 (minutes_json JSON 직렬화)
- meeting_memos: immutable INSERT-only 전략
- meeting_documents: LWW UPDATE
묶음 F — api-client types:
- interface -> type alias 전환 (11개)
- Database 타입에 TypedTable<Row, Insert, Update> 유틸 도입
(Row & Record<string, unknown> 교차로 GenericTable 제약 만족)
- @supabase/ssr 2.102는 supabase-js 버전 불일치로 제네릭 주입 불가 -
다음 사이클로 이월, api-client index.ts는 types만 재수출
묶음 G — apps/mobile UI 교체:
- login.tsx: MetalCard + PhosphorText(hero/label) + PhysicalButton
- meetings.tsx: MetalCard + Led(status) + PhosphorText(body/meta)
- record.tsx: Led + PhosphorText + PhysicalButton
- profile.tsx: MetalCard + PhysicalButton(danger) + d3roNativePalette
묶음 H — V2-7b 이메일 invite flow:
- migrations/20260410000001_team_invites.sql
- team_invites 테이블 (token, email, role, expires_at 7일)
- RLS: 같은 팀 멤버 + 초대 이메일 소유자 SELECT,
owner/admin만 INSERT/DELETE
- generate_invite_token() SECURITY DEFINER RPC (service_role)
- functions/team-invite: 권한 체크 -> 토큰 생성 -> 초대 URL 반환
- functions/team-accept: 토큰 검증 -> expires_at/accepted_at/이메일 일치 ->
team_members upsert -> 초대 accepted 표시
- config.toml에 team-invite/team-accept 함수 등록
- InviteMemberForm 재작성: 이메일 입력 + 역할 선택 -> URL 복사 UI
- /accept-invite 페이지 신규 (Suspense 내 useSearchParams + token 수락)
묶음 I — Realtime transcripts:
- apps/web/components/meetings/live-transcript-list.tsx (client)
- supabase.channel('transcripts:meeting:${id}').on('postgres_changes')
- INSERT -> 세그먼트 추가, UPDATE -> row 교체
- 중복 방지 segment_index 기준
- edited 배지 표시
- meetings/[id]/page.tsx의 transcript 섹션을 LiveTranscriptList로 교체
묶음 J — 테스트:
- packages/api-client/__tests__/client.test.ts (9 tests)
- createD3roSupabaseClient, isClientConfigured 팩토리 검증
- packages/api-client/__tests__/types.test.ts (10 tests)
- 모든 Row 타입 + 리터럴 union + Database keyof
- vitest.config.ts 신규
- apps/web/playwright.config.ts 신규 (baseURL, webServer dev 서버)
- apps/web/e2e/smoke.spec.ts 신규 (6 스모크 테스트)
- apps/web tsconfig exclude에 e2e/playwright.config.ts 추가
- package.json scripts: test, test:e2e, test:e2e:ui
검증:
- desktop typecheck OK
- web typecheck OK
- web next build OK (12 라우트, /accept-invite Suspense 적용)
- desktop build OK
- api-client test 19 passed
This commit is contained in:
yunchan8804
parent
37f3f4d5bd
commit
c167737198
26 changed files with 1530 additions and 374 deletions
|
|
@ -532,6 +532,175 @@ class CloudSyncService extends EventEmitter {
|
|||
return applied
|
||||
}, result)
|
||||
|
||||
// 3) meetings (V1 meeting_sessions)
|
||||
result.pushed += await this._pullTable('meetings', async () => {
|
||||
const { data: remoteRows, error } = await this._client!.from('meetings')
|
||||
.select('*')
|
||||
.gt('updated_at', sinceIso)
|
||||
|
||||
if (error) throw new Error(error.message)
|
||||
if (!remoteRows || remoteRows.length === 0) return 0
|
||||
|
||||
let applied = 0
|
||||
for (const remote of remoteRows as Array<Record<string, unknown>>) {
|
||||
const remoteUpdated = remote.updated_at
|
||||
? new Date(remote.updated_at as string).getTime()
|
||||
: 0
|
||||
const remoteStarted = remote.started_at
|
||||
? new Date(remote.started_at as string).getTime()
|
||||
: remoteUpdated
|
||||
const remoteEnded = remote.ended_at
|
||||
? new Date(remote.ended_at as string).getTime()
|
||||
: null
|
||||
const remoteCreated = remote.created_at
|
||||
? new Date(remote.created_at as string).getTime()
|
||||
: remoteUpdated
|
||||
|
||||
const existing = await db
|
||||
.select()
|
||||
.from(meetingSessions)
|
||||
.where(eq(meetingSessions.id, remote.id as string))
|
||||
.limit(1)
|
||||
|
||||
// V1 스키마는 minutesJson이 text (JSON 직렬화)
|
||||
const minutesJsonStr = remote.minutes_json
|
||||
? JSON.stringify(remote.minutes_json)
|
||||
: null
|
||||
|
||||
const row = {
|
||||
title: (remote.title as string | null) ?? null,
|
||||
status: (remote.status as 'recording' | 'processing' | 'completed' | 'error'),
|
||||
startedAt: remoteStarted,
|
||||
endedAt: remoteEnded,
|
||||
durationMs: (remote.duration_ms as number | null) ?? null,
|
||||
rawTranscript: (remote.raw_transcript as string | null) ?? null,
|
||||
editedTranscript: (remote.edited_transcript as string | null) ?? null,
|
||||
minutesMarkdown: (remote.minutes_markdown as string | null) ?? null,
|
||||
minutesJson: minutesJsonStr,
|
||||
sttModel: (remote.stt_model as string | null) ?? null,
|
||||
llmModel: (remote.llm_model as string | null) ?? null,
|
||||
sttLatencyMs: (remote.stt_latency_ms as number | null) ?? null,
|
||||
llmLatencyMs: (remote.llm_latency_ms as number | null) ?? null,
|
||||
errorMessage: (remote.error_message as string | null) ?? null,
|
||||
updatedAt: remoteUpdated
|
||||
}
|
||||
|
||||
if (existing.length > 0) {
|
||||
if (existing[0].updatedAt >= remoteUpdated) continue
|
||||
await db
|
||||
.update(meetingSessions)
|
||||
.set(row)
|
||||
.where(eq(meetingSessions.id, remote.id as string))
|
||||
applied++
|
||||
} else {
|
||||
await db.insert(meetingSessions).values({
|
||||
id: remote.id as string,
|
||||
...row,
|
||||
createdAt: remoteCreated
|
||||
})
|
||||
applied++
|
||||
}
|
||||
this.emit('sync-progress', { current: applied, total: remoteRows.length, table: 'meetings' })
|
||||
}
|
||||
return applied
|
||||
}, result)
|
||||
|
||||
// 4) meeting_memos
|
||||
result.pushed += await this._pullTable('meeting_memos', async () => {
|
||||
const { data: remoteRows, error } = await this._client!.from('meeting_memos')
|
||||
.select('*')
|
||||
.gt('created_at', sinceIso)
|
||||
|
||||
if (error) throw new Error(error.message)
|
||||
if (!remoteRows || remoteRows.length === 0) return 0
|
||||
|
||||
let applied = 0
|
||||
for (const remote of remoteRows as Array<Record<string, unknown>>) {
|
||||
const remoteCreated = remote.created_at
|
||||
? new Date(remote.created_at as string).getTime()
|
||||
: Date.now()
|
||||
|
||||
const existing = await db
|
||||
.select()
|
||||
.from(meetingMemos)
|
||||
.where(eq(meetingMemos.id, remote.id as string))
|
||||
.limit(1)
|
||||
|
||||
if (existing.length === 0) {
|
||||
await db.insert(meetingMemos).values({
|
||||
id: remote.id as string,
|
||||
sessionId: remote.meeting_id as string,
|
||||
content: remote.content as string,
|
||||
timestampMs: remote.timestamp_ms as number,
|
||||
createdAt: remoteCreated
|
||||
})
|
||||
applied++
|
||||
}
|
||||
// memo는 immutable 전제 (수정 없음), INSERT-only
|
||||
this.emit('sync-progress', { current: applied, total: remoteRows.length, table: 'meeting_memos' })
|
||||
}
|
||||
return applied
|
||||
}, result)
|
||||
|
||||
// 5) meeting_documents
|
||||
result.pushed += await this._pullTable('meeting_documents', async () => {
|
||||
const { data: remoteRows, error } = await this._client!.from('meeting_documents')
|
||||
.select('*')
|
||||
.gt('updated_at', sinceIso)
|
||||
|
||||
if (error) throw new Error(error.message)
|
||||
if (!remoteRows || remoteRows.length === 0) return 0
|
||||
|
||||
let applied = 0
|
||||
for (const remote of remoteRows as Array<Record<string, unknown>>) {
|
||||
const remoteUpdated = remote.updated_at
|
||||
? new Date(remote.updated_at as string).getTime()
|
||||
: 0
|
||||
const remoteCreated = remote.created_at
|
||||
? new Date(remote.created_at as string).getTime()
|
||||
: remoteUpdated
|
||||
|
||||
const existing = await db
|
||||
.select()
|
||||
.from(meetingDocuments)
|
||||
.where(eq(meetingDocuments.id, remote.id as string))
|
||||
.limit(1)
|
||||
|
||||
const row = {
|
||||
sessionId: remote.meeting_id as string,
|
||||
templateType: (remote.template_type as 'minutes' | 'report' | 'idea-note' | 'custom' | 'mindmap'),
|
||||
title: remote.title as string,
|
||||
content: (remote.content as string) ?? '',
|
||||
promptUsed: (remote.prompt_used as string | null) ?? null,
|
||||
llmModel: (remote.llm_model as string | null) ?? null,
|
||||
llmLatencyMs: (remote.llm_latency_ms as number | null) ?? null,
|
||||
updatedAt: remoteUpdated
|
||||
}
|
||||
|
||||
if (existing.length > 0) {
|
||||
if (existing[0].updatedAt >= remoteUpdated) continue
|
||||
await db
|
||||
.update(meetingDocuments)
|
||||
.set(row)
|
||||
.where(eq(meetingDocuments.id, remote.id as string))
|
||||
applied++
|
||||
} else {
|
||||
await db.insert(meetingDocuments).values({
|
||||
id: remote.id as string,
|
||||
...row,
|
||||
createdAt: remoteCreated
|
||||
})
|
||||
applied++
|
||||
}
|
||||
this.emit('sync-progress', {
|
||||
current: applied,
|
||||
total: remoteRows.length,
|
||||
table: 'meeting_documents'
|
||||
})
|
||||
}
|
||||
return applied
|
||||
}, result)
|
||||
|
||||
this._lastSyncAt = Date.now()
|
||||
logger.info(`Pull complete: applied=${result.pushed} errors=${result.errors.length}`)
|
||||
this.emit('sync-complete', result)
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue