MCPcopy
hub / github.com/lobehub/lobehub / add

Method add

packages/database/src/models/taskTopic.ts:46–62  ·  view source on GitHub ↗
(
    taskId: string,
    topicId: string,
    params: { operationId?: string; seq: number },
  )

Source from the content-addressed store, hash-verified

44 }
45
46 async add(
47 taskId: string,
48 topicId: string,
49 params: { operationId?: string; seq: number },
50 ): Promise<void> {
51 await this.db
52 .insert(taskTopics)
53 .values({
54 operationId: params.operationId,
55 seq: params.seq,
56 taskId,
57 topicId,
58 userId: this.userId,
59 workspaceId: this.workspaceId ?? null,
60 })
61 .onConflictDoNothing();
62 }
63
64 async updateStatus(taskId: string, topicId: string, status: string): Promise<void> {
65 await this.db

Callers 15

createImplFunction · 0.80
processAssistantGroupMethod · 0.80
collectCouncilMembersMethod · 0.80
createTasksMessageMethod · 0.80
collectToolMessagesMethod · 0.80
collectAssistantChainMethod · 0.80
walkMethod · 0.80

Calls

no outgoing calls

Tested by 5

makeInMemoryReceiptStoreFunction · 0.64
createMockClientFunction · 0.64
traverseFunction · 0.64
createMockHandleFunction · 0.64