Spaces:
Runtime error
Runtime error
| import { logger } from "@trigger.dev/sdk/v3"; | |
| import axios from "axios"; | |
| // Memory API functions using axios interceptor | |
| export interface SearchMemoryParams { | |
| query: string; | |
| validAt?: string; | |
| startTime?: string; | |
| endTime?: string; | |
| } | |
| export interface AddMemoryParams { | |
| message: string; | |
| referenceTime?: string; | |
| spaceId?: string; | |
| sessionId?: string; | |
| metadata?: any; | |
| } | |
| export const searchMemory = async (params: SearchMemoryParams) => { | |
| try { | |
| const response = await axios.post( | |
| "https://core::memory/api/v1/search", | |
| params, | |
| ); | |
| return response.data; | |
| } catch (error) { | |
| logger.error("Memory search failed", { error, params }); | |
| return { error: "Memory search failed" }; | |
| } | |
| }; | |
| export const addMemory = async (params: AddMemoryParams) => { | |
| try { | |
| // Set defaults for required fields | |
| const memoryInput = { | |
| ...params, | |
| episodeBody: params.message, | |
| referenceTime: params.referenceTime || new Date().toISOString(), | |
| source: "CORE", | |
| }; | |
| const response = await axios.post( | |
| "https://core::memory/api/v1/add", | |
| memoryInput, | |
| ); | |
| return response.data; | |
| } catch (error) { | |
| logger.error("Memory storage failed", { error, params }); | |
| return { error: "Memory storage failed" }; | |
| } | |
| }; | |