feat: Memory Exports (#3117)

mem0-ts/src/client/mem0.ts

@@ -13,6 +13,8 @@ import {
   WebhookPayload,
   Message,
   FeedbackPayload,
+  CreateMemoryExportPayload,
+  GetMemoryExportPayload,
 } from "./mem0.types";
 import { captureClientEvent, generateHash } from "./telemetry";
 
@@ -705,6 +707,57 @@ export default class MemoryClient {
     );
     return response;
   }
+
+  async createMemoryExport(
+    data: CreateMemoryExportPayload,
+  ): Promise<{ message: string; id: string }> {
+    if (this.telemetryId === "") await this.ping();
+    this._captureEvent("create_memory_export", []);
+
+    // Return if missing filters or schema
+    if (!data.filters || !data.schema) {
+      throw new Error("Missing filters or schema");
+    }
+
+    // Add Org and Project ID
+    data.org_id = this.organizationId?.toString() || null;
+    data.project_id = this.projectId?.toString() || null;
+
+    const response = await this._fetchWithErrorHandling(
+      `${this.host}/v1/exports/`,
+      {
+        method: "POST",
+        headers: this.headers,
+        body: JSON.stringify(data),
+      },
+    );
+
+    return response;
+  }
+
+  async getMemoryExport(
+    data: GetMemoryExportPayload,
+  ): Promise<{ message: string; id: string }> {
+    if (this.telemetryId === "") await this.ping();
+    this._captureEvent("get_memory_export", []);
+
+    if (!data.memory_export_id && !data.filters) {
+      throw new Error("Missing memory_export_id or filters");
+    }
+
+    data.org_id = this.organizationId?.toString() || "";
+    data.project_id = this.projectId?.toString() || "";
+
+    const response = await this._fetchWithErrorHandling(
+      `${this.host}/v1/exports/get/`,
+      {
+        method: "POST",
+        headers: this.headers,
+        body: JSON.stringify(data),
+      },
+    );
+    return response;
+  }
 }
 
 export { MemoryClient };