Method appendMessage

apps/sim/executor/handlers/agent/memory.ts:248–270

(workspaceId: string, key: string, message: Message)

  }

  private async appendMessage(workspaceId: string, key: string, message: Message): Promise<void> {
    const now = new Date()

    const sanitizedMessage = this.sanitizeMessageForStorage(message)

    await db
      .insert(memory)
      .values({
        id: generateId(),
        workspaceId,
        key,
        data: [sanitizedMessage],
        createdAt: now,
        updatedAt: now,
      })
      .onConflictDoUpdate({
        target: [memory.workspaceId, memory.key],
        set: {
          data: sql`${memory.data} || ${JSON.stringify([sanitizedMessage])}::jsonb`,
          updatedAt: now,
        },
      })
  }

  private parsePositiveInt(value: string | undefined, defaultValue: number): number {
    if (!value) return defaultValue