Added actions

Author: lcaresia

components/zep/actions/get-session-memory/get-session-memory.mjs

@@ -0,0 +1,51 @@
+import zep from "../../zep.app.mjs";
+
+export default {
+  key: "zep-get-thread-messages",
+  name: "Get Thread Messages",
+  description: "Returns messages for the thread with the specified ID. [See the documentation](https://help.getzep.com/sdk-reference/thread/get)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    zep,
+    threadId: {
+      propDefinition: [
+        zep,
+        "threadId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const allMessages = [];
+    let cursor = 0;
+    const limit = 100; // Tamanho da página
+
+    while (true) {
+      const response = await this.zep.getThreadMessages({
+        $,
+        threadId: this.threadId,
+        params: {
+          limit,
+          cursor,
+        },
+      });
+
+      if (!response.messages || response.messages.length === 0) {
+        break;
+      }
+
+      allMessages.push(...response.messages);
+
+      // Se recebemos menos mensagens que o limite, chegamos ao fim
+      if (response.messages.length < limit) {
+        break;
+      }
+
+      cursor += limit;
+    }
+
+    $.export("$summary", `Successfully retrieved ${allMessages.length} messages for the thread with ID: ${this.threadId}`);
+
+    return allMessages;
+  },
+};

components/zep/actions/get-session-messages/get-session-messages.mjs

@@ -0,0 +1,76 @@
+import zep from "../../zep.app.mjs";
+import constants from "../../common/constants.mjs";
+
+export default {
+  key: "zep-get-threads",
+  name: "Get Threads",
+  description: "Returns a paginated list of threads. [See the documentation](https://help.getzep.com/sdk-reference/thread/list-all)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    zep,
+    order_by: {
+      type: "string",
+      label: "Order By",
+      description: "Field to order by (e.g., updated_at).",
+      optional: true,
+      options: constants.SORT_OPTIONS,
+    },
+    asc: {
+      type: "boolean",
+      label: "Ascending",
+      description: "If true, results are returned in ascending order.",
+      optional: true,
+    },
+    maxResults: {
+      type: "integer",
+      label: "Max Results",
+      description: "Maximum number of threads to return across pages.",
+      optional: true,
+      default: 50,
+    },
+  },
+  async run({ $ }) {
+    const max = this.maxResults ?? 50;
+    const threads = [];
+
+    let page = 1;
+    while (threads.length < max) {
+      const pageSize = Math.min(1000, max - threads.length);
+      const params = {
+        page_number: page,
+        page_size: pageSize,
+      };
+
+      if (this.order_by) {
+        params.order_by = this.order_by;
+      }
+      if (typeof this.asc === "boolean") {
+        params.asc = this.asc;
+      }
+
+      const response = await this.zep.getThreads({
+        $,
+        params,
+      });
+
+      const pageThreads = response?.threads || [];
+      if (!Array.isArray(pageThreads) || pageThreads.length === 0) {
+        break;
+      }
+
+      threads.push(...pageThreads);
+      if (pageThreads.length < pageSize) {
+        break;
+      }
+
+      page += 1;
+    }
+
+    const plural = threads.length === 1
+      ? ""
+      : "s";
+    $.export("$summary", `Successfully retrieved ${threads.length} thread${plural}`);
+    return threads;
+  },
+};

components/zep/actions/get-session/get-session.mjs

@@ -0,0 +1,8 @@
+export default {
+  SORT_OPTIONS: [
+    "created_at",
+    "updated_at",
+    "user_id",
+    "thread_id",
+  ],
+};

components/zep/actions/get-sessions/get-sessions.mjs

@@ -5,7 +5,7 @@ export default {
   key: "zep-new-message",
   name: "New Message in Session",
   description: "Emit new event when a message is added to a session. [See the documentation](https://help.getzep.com/api-reference/memory/get-session-messages)",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "source",
   dedupe: "unique",
   methods: {

components/zep/actions/get-thread-messages/get-thread-messages.mjs

@@ -5,7 +5,7 @@ export default {
   key: "zep-new-session",
   name: "New Session Created",
   description: "Emit new event when a new session is created in Zep. [See the documentation](https://help.getzep.com/api-reference/memory/list-sessions)",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "source",
   dedupe: "unique",
   methods: {

components/zep/actions/get-threads/get-threads.mjs

@@ -3,9 +3,9 @@ import common from "../common/base.mjs";
 export default {
   ...common,
   key: "zep-session-updated",
-  name: "Session Updated",
+  name: "New Session Updated",
   description: "Emit new event when an existing session is updated. [See the documentation](https://help.getzep.com/api-reference/memory/list-sessions)",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "source",
   dedupe: "unique",
   methods: {