[Components] rumi_ai - new components

.gitignore

@@ -20,3 +20,5 @@ components/**/package-lock.json
 /packages/sdk/examples/.next/
 
 **/.claude/settings.local.json
+
+.cursor

components/rumi_ai/actions/add-session-access/add-session-access.mjs

@@ -0,0 +1,66 @@
+import app from "../../rumi_ai.app.mjs";
+
+export default {
+  key: "rumi_ai-add-session-access",
+  name: "Add Session Access",
+  description: "Add access to a session for specific email addresses or domains. [See the documentation](https://rumiai.notion.site/Rumi-Public-API-Authentication-02055b7286874bd7b355862f1abe48d9)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    sessionId: {
+      propDefinition: [
+        app,
+        "sessionId",
+      ],
+    },
+    sessionRecurrenceId: {
+      propDefinition: [
+        app,
+        "sessionRecurrenceId",
+      ],
+    },
+    emails: {
+      propDefinition: [
+        app,
+        "emails",
+      ],
+    },
+    domains: {
+      propDefinition: [
+        app,
+        "domains",
+      ],
+    },
+    message: {
+      propDefinition: [
+        app,
+        "message",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      sessionId,
+      sessionRecurrenceId,
+      emails,
+      domains,
+      message,
+    } = this;
+
+    const response = await app.addSessionAccess({
+      $,
+      data: {
+        sessionID: sessionId,
+        sessionRecurrenceID: sessionRecurrenceId,
+        emails,
+        domains,
+        message,
+      },
+    });
+
+    $.export("$summary", `Successfully added access to session \`${sessionId}\``);
+    return response;
+  },
+};

components/rumi_ai/actions/ai-stream-query/ai-stream-query.mjs

@@ -0,0 +1,50 @@
+import app from "../../rumi_ai.app.mjs";
+
+export default {
+  key: "rumi_ai-ai-stream-query",
+  name: "AI Stream Query",
+  description: "Stream an AI query against session memories. [See the documentation](https://rumiai.notion.site/Rumi-Public-API-Authentication-02055b7286874bd7b355862f1abe48d9)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    query: {
+      propDefinition: [
+        app,
+        "query",
+      ],
+    },
+    requestId: {
+      propDefinition: [
+        app,
+        "requestId",
+      ],
+    },
+    tz: {
+      propDefinition: [
+        app,
+        "tz",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      query,
+      requestId,
+      tz,
+    } = this;
+
+    const response = await app.streamAiQuery({
+      $,
+      data: {
+        query,
+        requestId,
+        tz,
+      },
+    });
+
+    $.export("$summary", "Successfully executed AI stream query");
+    return response;
+  },
+};

components/rumi_ai/actions/create-session/create-session.mjs

@@ -0,0 +1,105 @@
+import { ConfigurationError } from "@pipedream/platform";
+import app from "../../rumi_ai.app.mjs";
+
+export default {
+  key: "rumi_ai-create-session",
+  name: "Create Session",
+  description: "Create a new session/meeting. [See the documentation](https://rumiai.notion.site/Rumi-Public-API-Authentication-02055b7286874bd7b355862f1abe48d9)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    sessionTitle: {
+      propDefinition: [
+        app,
+        "sessionTitle",
+      ],
+    },
+    about: {
+      description: "A brief description of the session.",
+      propDefinition: [
+        app,
+        "about",
+      ],
+    },
+    startDateTime: {
+      propDefinition: [
+        app,
+        "startDateTime",
+      ],
+    },
+    endDateTime: {
+      propDefinition: [
+        app,
+        "endDateTime",
+      ],
+    },
+    enableRecording: {
+      propDefinition: [
+        app,
+        "enableRecording",
+      ],
+    },
+    summaAI: {
+      propDefinition: [
+        app,
+        "summaAI",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      sessionTitle,
+      about,
+      startDateTime,
+      endDateTime,
+      enableRecording,
+      summaAI,
+    } = this;
+
+    const startDateTimeObj = new Date(startDateTime);
+    const endDateTimeObj = new Date(endDateTime);
+
+    if (isNaN(startDateTimeObj.getTime())) {
+      throw new ConfigurationError("Invalid **Start Date Time** provided");
+    }
+    if (isNaN(endDateTimeObj.getTime())) {
+      throw new ConfigurationError("Invalid **End Date Time** provided");
+    }
+    if (endDateTimeObj <= startDateTimeObj) {
+      throw new ConfigurationError("**End Date Time** must be after **Start Date Time**");
+    }
+
+    const startTimestamp = Math.floor(startDateTimeObj.getTime() / 1000);
+    const endTimestamp = Math.floor(endDateTimeObj.getTime() / 1000);
+
+    const response = await app.createSession({
+      $,
+      data: {
+        sessionTitle,
+        about,
+        dataVisibility: "team-visible",
+        accessStatus: "unlocked",
+        startTimestamp,
+        endTimestamp,
+        sessionSettings: {
+          enableRecording,
+          summaAI,
+          preferredLanguages: [
+            "en-US",
+          ],
+          recurring: 0,
+          postSessionSummaries: {
+            recipients: {
+              email: "everyone",
+            },
+          },
+        },
+      },
+    });
+
+    $.export("$summary", `Successfully created session: ${sessionTitle}`);
+    return response;
+  },
+};

components/rumi_ai/actions/get-current-user/get-current-user.mjs

@@ -0,0 +1,22 @@
+import app from "../../rumi_ai.app.mjs";
+
+export default {
+  key: "rumi_ai-get-current-user",
+  name: "Get Current User",
+  description: "Get information about the current authenticated user. [See the documentation](https://rumiai.notion.site/Rumi-Public-API-Authentication-02055b7286874bd7b355862f1abe48d9)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+  },
+  async run({ $ }) {
+    const { app } = this;
+
+    const response = await app.getCurrentUser({
+      $,
+    });
+
+    $.export("$summary", "Successfully retrieved current user information");
+    return response;
+  },
+};

components/rumi_ai/actions/get-future-sessions/get-future-sessions.mjs

@@ -0,0 +1,22 @@
+import app from "../../rumi_ai.app.mjs";
+
+export default {
+  key: "rumi_ai-get-future-sessions",
+  name: "Get Future Sessions",
+  description: "Retrieve upcoming/future sessions. [See the documentation](https://rumiai.notion.site/Rumi-Public-API-Authentication-02055b7286874bd7b355862f1abe48d9)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+  },
+  async run({ $ }) {
+    const { app } = this;
+
+    const response = await app.getFutureSessions({
+      $,
+    });
+
+    $.export("$summary", `Successfully retrieved \`${response?.data?.sessions?.length}\` future session(s)`);
+    return response;
+  },
+};

components/rumi_ai/actions/get-meeting-types/get-meeting-types.mjs

@@ -0,0 +1,22 @@
+import app from "../../rumi_ai.app.mjs";
+
+export default {
+  key: "rumi_ai-get-meeting-types",
+  name: "Get Meeting Types",
+  description: "Retrieve available meeting types. [See the documentation](https://rumiai.notion.site/Rumi-Public-API-Authentication-02055b7286874bd7b355862f1abe48d9)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+  },
+  async run({ $ }) {
+    const { app } = this;
+
+    const response = await app.getMeetingTypes({
+      $,
+    });
+
+    $.export("$summary", `Successfully retrieved \`${response?.data?.meetingTypes?.length}\` meeting type(s)`);
+    return response;
+  },
+};

components/rumi_ai/actions/get-memory-threads/get-memory-threads.mjs

@@ -0,0 +1,34 @@
+import app from "../../rumi_ai.app.mjs";
+
+export default {
+  key: "rumi_ai-get-memory-threads",
+  name: "Get Memory Threads",
+  description: "Retrieve memory threads. [See the documentation](https://rumiai.notion.site/Rumi-Public-API-Authentication-02055b7286874bd7b355862f1abe48d9)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    limit: {
+      propDefinition: [
+        app,
+        "limit",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      limit,
+    } = this;
+
+    const response = await app.getMemoryThreads({
+      $,
+      params: {
+        limit,
+      },
+    });
+
+    $.export("$summary", `Successfully retrieved \`${response?.data?.threads?.length}\` memory thread(s)`);
+    return response;
+  },
+};

components/rumi_ai/actions/get-past-sessions/get-past-sessions.mjs

@@ -0,0 +1,33 @@
+import app from "../../rumi_ai.app.mjs";
+
+export default {
+  key: "rumi_ai-get-past-sessions",
+  name: "Get Past Sessions",
+  description: "Retrieve past sessions/meetings. [See the documentation](https://rumiai.notion.site/Rumi-Public-API-Authentication-02055b7286874bd7b355862f1abe48d9)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    limit: {
+      propDefinition: [
+        app,
+        "limit",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app, limit,
+    } = this;
+
+    const response = await app.getPastSessions({
+      $,
+      params: {
+        limit,
+      },
+    });
+
+    $.export("$summary", `Successfully retrieved \`${response?.data?.sessions?.length}\` past session(s)`);
+    return response;
+  },
+};