(
workspaceId: string,
key: string,
messages: Message[]
)
| 224 | } |
| 225 | |
| 226 | private async seedMemoryRecord( |
| 227 | workspaceId: string, |
| 228 | key: string, |
| 229 | messages: Message[] |
| 230 | ): Promise<void> { |
| 231 | const now = new Date() |
| 232 | |
| 233 | const sanitizedMessages = messages.map((message) => this.sanitizeMessageForStorage(message)) |
| 234 | |
| 235 | await db |
| 236 | .insert(memory) |
| 237 | .values({ |
| 238 | id: generateId(), |
| 239 | workspaceId, |
| 240 | key, |
| 241 | data: sanitizedMessages, |
| 242 | createdAt: now, |
| 243 | updatedAt: now, |
| 244 | }) |
| 245 | .onConflictDoNothing() |
| 246 | } |
| 247 | |
| 248 | private async appendMessage(workspaceId: string, key: string, message: Message): Promise<void> { |
| 249 | const now = new Date() |
no test coverage detected