From 91d220ff154fb7e18d04e97f6c68c291afb98766 Mon Sep 17 00:00:00 2001
From: michelle0927 <michellelbergero@hotmail.com>
Date: Wed, 2 Apr 2025 16:59:46 -0400
Subject: [PATCH 1/6] new components

---
 .../create-batch-job/create-batch-job.mjs     |  61 +++++++++
 .../create-embeddings/create-embeddings.mjs   |  32 +++++
 .../actions/generate-text/generate-text.mjs   |  76 +++++++++++
 .../actions/list-models/list-models.mjs       |  23 ++++
 components/mistral_ai/common/constants.mjs    |  26 ++++
 components/mistral_ai/common/utils.mjs        |  36 +++++
 components/mistral_ai/mistral_ai.app.mjs      | 124 +++++++++++++++++-
 components/mistral_ai/package.json            |   7 +-
 components/mistral_ai/sources/common/base.mjs |  86 ++++++++++++
 .../new-batch-job-completed.mjs               |  41 ++++++
 .../new-batch-job-failure.mjs                 |  30 +++++
 .../new-model-added/new-model-added.mjs       |  29 ++++
 .../sources/new-model-added/test-event.mjs    |  23 ++++
 13 files changed, 587 insertions(+), 7 deletions(-)
 create mode 100644 components/mistral_ai/actions/create-batch-job/create-batch-job.mjs
 create mode 100644 components/mistral_ai/actions/create-embeddings/create-embeddings.mjs
 create mode 100644 components/mistral_ai/actions/generate-text/generate-text.mjs
 create mode 100644 components/mistral_ai/actions/list-models/list-models.mjs
 create mode 100644 components/mistral_ai/common/constants.mjs
 create mode 100644 components/mistral_ai/common/utils.mjs
 create mode 100644 components/mistral_ai/sources/common/base.mjs
 create mode 100644 components/mistral_ai/sources/new-batch-job-completed/new-batch-job-completed.mjs
 create mode 100644 components/mistral_ai/sources/new-batch-job-failure/new-batch-job-failure.mjs
 create mode 100644 components/mistral_ai/sources/new-model-added/new-model-added.mjs
 create mode 100644 components/mistral_ai/sources/new-model-added/test-event.mjs

diff --git a/components/mistral_ai/actions/create-batch-job/create-batch-job.mjs b/components/mistral_ai/actions/create-batch-job/create-batch-job.mjs
new file mode 100644
index 0000000000000..0c32b766ea2bf
--- /dev/null
+++ b/components/mistral_ai/actions/create-batch-job/create-batch-job.mjs
@@ -0,0 +1,61 @@
+import mistralAI from "../../mistral_ai.app.mjs";
+import constants from "../../common/constants.mjs";
+import { parseObj } from "../../common/utils.mjs";
+
+export default {
+  key: "mistral_ai-create-batch-job",
+  name: "Create Batch Job",
+  description: "Create a new batch job, it will be queued for processing. [See the Documentation](https://docs.mistral.ai/api/#tag/batch/operation/jobs_api_routes_batch_get_batch_jobs)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    mistralAI,
+    inputFiles: {
+      propDefinition: [
+        mistralAI,
+        "fileIds",
+      ],
+    },
+    modelId: {
+      propDefinition: [
+        mistralAI,
+        "modelId",
+      ],
+    },
+    endpoint: {
+      type: "string",
+      label: "Endpoint",
+      description: "The endpoint to use for the batch job",
+      options: constants.BATCH_JOB_ENDPOINT_OPTIONS,
+    },
+    metadata: {
+      type: "object",
+      label: "Metadata",
+      description: "Optional metadata for the batch job in JSON format.",
+      optional: true,
+    },
+    timeoutHours: {
+      type: "integer",
+      label: "Timeout Hours",
+      description: "Optional timeout duration for the batch job in hours.",
+      optional: true,
+      default: 24,
+    },
+  },
+  async run({ $ }) {
+    const response = await this.mistralAI.createBatchJob({
+      $,
+      data: {
+        input_files: this.inputFiles,
+        endpoint: this.endpoint,
+        model: this.modelId,
+        metadata: parseObj(this.metadata),
+        timeoutHours: this.timeoutHours,
+      },
+    });
+    if (response?.id) {
+      $.export("$summary", `Successfully created batch job with ID: ${response.id}`);
+    }
+    return response;
+  },
+};
diff --git a/components/mistral_ai/actions/create-embeddings/create-embeddings.mjs b/components/mistral_ai/actions/create-embeddings/create-embeddings.mjs
new file mode 100644
index 0000000000000..5b8af6258943a
--- /dev/null
+++ b/components/mistral_ai/actions/create-embeddings/create-embeddings.mjs
@@ -0,0 +1,32 @@
+import mistralAI from "../../mistral_ai.app.mjs";
+import { parseArray } from "../../common/utils.mjs";
+import constants from "../../common/constants.mjs";
+
+export default {
+  key: "mistral_ai-create-embeddings",
+  name: "Create Embeddings",
+  description: "Create new embedding in Mistral AI. [See the Documentation](https://docs.mistral.ai/api/#tag/embeddings)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    mistralAI,
+    input: {
+      type: "string",
+      label: "Input",
+      description: "The input text for which to create an embedding. May be a string or an array of strings.",
+    },
+  },
+  async run({ $ }) {
+    const response = await this.mistralAI.createEmbeddings({
+      $,
+      data: {
+        model: constants.EMBEDDINGS_MODEL,
+        input: parseArray(this.input),
+      },
+    });
+    if (response?.id) {
+      $.export("$summary", `Successfully created embedding with ID: ${response.id}`);
+    }
+    return response;
+  },
+};
diff --git a/components/mistral_ai/actions/generate-text/generate-text.mjs b/components/mistral_ai/actions/generate-text/generate-text.mjs
new file mode 100644
index 0000000000000..aa10b39d78005
--- /dev/null
+++ b/components/mistral_ai/actions/generate-text/generate-text.mjs
@@ -0,0 +1,76 @@
+import mistralAI from "../../mistral_ai.app.mjs";
+
+export default {
+  key: "mistral_ai-generate-text",
+  name: "Generate Text",
+  description: "Retrieve a list of available Mistral AI models that the user is authorized to access. [See the Documentation](https://docs.mistral.ai/api/#tag/fim/operation/fim_completion_v1_fim_completions_post)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    mistralAI,
+    message: {
+      type: "string",
+      label: "Message",
+      description: "The prompt message to send",
+    },
+    modelId: {
+      propDefinition: [
+        mistralAI,
+        "modelId",
+      ],
+    },
+    temperature: {
+      type: "string",
+      label: "Temperature",
+      description: "The sampling temperature to use, we recommend between 0.0 and 0.7. Higher values like 0.7 will make the output more random, while lower values like 0.2 will make it more focused and deterministic. We generally recommend altering this or top_p but not both. The default value varies depending on the model you are targeting.",
+      optional: true,
+    },
+    topP: {
+      type: "string",
+      label: "Top P",
+      description: "Nucleus sampling, where the model considers the results of the tokens with top_p probability mass. So 0.1 means only the tokens comprising the top 10% probability mass are considered. We generally recommend altering this or temperature but not both.",
+      optional: true,
+    },
+    maxTokens: {
+      type: "integer",
+      label: "Max Tokens",
+      description: "The maximum number of tokens to generate in the completion. The token count of your prompt plus max_tokens cannot exceed the model's context length.",
+      optional: true,
+    },
+    randomSeed: {
+      type: "integer",
+      label: "Random Seed",
+      description: "The seed to use for random sampling. If set, different calls will generate deterministic results.",
+      optional: true,
+    },
+    n: {
+      type: "integer",
+      label: "N",
+      description: "Number of completions to return for each request, input tokens are only billed once.",
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const response = await this.mistralAI.sendPrompt({
+      $,
+      data: {
+        model: this.modelId,
+        messages: [
+          {
+            content: this.message,
+            role: "user",
+          },
+        ],
+        temperature: this.temperature && +this.temperature,
+        top_p: this.topP && +this.topP,
+        max_tokens: this.maxTokens,
+        random_seed: this.randomSeed,
+        n: this.n,
+      },
+    });
+    if (response?.id) {
+      $.export("$summary", `Successfully retrieved response with ID: ${response.id}`);
+    }
+    return response;
+  },
+};
diff --git a/components/mistral_ai/actions/list-models/list-models.mjs b/components/mistral_ai/actions/list-models/list-models.mjs
new file mode 100644
index 0000000000000..2370d4ee9f98b
--- /dev/null
+++ b/components/mistral_ai/actions/list-models/list-models.mjs
@@ -0,0 +1,23 @@
+import mistralAI from "../../mistral_ai.app.mjs";
+
+export default {
+  key: "mistral_ai-list-models",
+  name: "List Models",
+  description: "Retrieve a list of available Mistral AI models that the user is authorized to access. [See the Documentation](https://docs.mistral.ai/api/#tag/models)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    mistralAI,
+  },
+  async run({ $ }) {
+    const { data } = await this.mistralAI.listModels({
+      $,
+    });
+    if (data?.length) {
+      $.export("$summary", `Successfully retrieved ${data.length} model${data.length === 1
+        ? ""
+        : "s"}`);
+    }
+    return data;
+  },
+};
diff --git a/components/mistral_ai/common/constants.mjs b/components/mistral_ai/common/constants.mjs
new file mode 100644
index 0000000000000..f0d5c96e9b0c0
--- /dev/null
+++ b/components/mistral_ai/common/constants.mjs
@@ -0,0 +1,26 @@
+const DEFAULT_PAGE_SIZE = 100;
+
+const EMBEDDINGS_MODEL = "mistral-embed";
+
+const BATCH_JOB_STATUS_OPTIONS = [
+  "SUCCESS",
+  "FAILED",
+  "TIMEOUT_EXCEEDED",
+  "CANCELLATION_REQUESTED",
+  "CANCELLED",
+];
+
+const BATCH_JOB_ENDPOINT_OPTIONS = [
+  "/v1/chat/completions",
+  "/v1/embeddings",
+  "/v1/fim/completions",
+  "/v1/moderations",
+  "/v1/chat/moderations",
+];
+
+export default {
+  DEFAULT_PAGE_SIZE,
+  EMBEDDINGS_MODEL,
+  BATCH_JOB_STATUS_OPTIONS,
+  BATCH_JOB_ENDPOINT_OPTIONS,
+};
diff --git a/components/mistral_ai/common/utils.mjs b/components/mistral_ai/common/utils.mjs
new file mode 100644
index 0000000000000..92f83d199aed5
--- /dev/null
+++ b/components/mistral_ai/common/utils.mjs
@@ -0,0 +1,36 @@
+function parseArray(arr) {
+  if (!arr) {
+    return undefined;
+  }
+
+  if (typeof arr === "string") {
+    try {
+      return JSON.parse(arr);
+    } catch {
+      return arr;
+    }
+  }
+
+  return arr;
+}
+
+function parseObj(obj) {
+  if (!obj) {
+    return undefined;
+  }
+
+  if (typeof obj === "string") {
+    try {
+      return JSON.parse(obj);
+    } catch {
+      return obj;
+    }
+  }
+
+  return obj;
+}
+
+export {
+  parseArray,
+  parseObj,
+};
diff --git a/components/mistral_ai/mistral_ai.app.mjs b/components/mistral_ai/mistral_ai.app.mjs
index ff6fa3a29205a..b70be5c8c98df 100644
--- a/components/mistral_ai/mistral_ai.app.mjs
+++ b/components/mistral_ai/mistral_ai.app.mjs
@@ -1,11 +1,125 @@
+import { axios } from "@pipedream/platform";
+import constants from "./common/constants.mjs";
+
 export default {
   type: "app",
   app: "mistral_ai",
-  propDefinitions: {},
+  propDefinitions: {
+    fileIds: {
+      type: "string[]",
+      label: "File IDs",
+      description: "Array of input file UUIDs for batch processing",
+      async options({ page }) {
+        const { data } = await this.listFiles({
+          params: {
+            page,
+            page_size: constants.DEFAULT_PAGE_SIZE,
+          },
+        });
+        return data?.map(({
+          id: value, filename: label,
+        }) => ({
+          value,
+          label,
+        })) || [];
+      },
+    },
+    modelId: {
+      type: "string",
+      label: "Model ID",
+      description: "The identifier of the model to use",
+      async options() {
+        const { data } = await this.listModels();
+        return data?.map(({
+          id: value, name: label,
+        }) => ({
+          value,
+          label,
+        })) || [];
+      },
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _baseUrl() {
+      return "https://api.mistral.ai/v1";
+    },
+    _makeRequest({
+      $ = this,
+      path,
+      ...otherOpts
+    }) {
+      return axios($, {
+        ...otherOpts,
+        url: `${this._baseUrl()}${path}`,
+        headers: {
+          "Authorization": `Bearer ${this.$auth.api_key}`,
+          "Content-Type": "application/json",
+        },
+      });
+    },
+    listModels(opts = {}) {
+      return this._makeRequest({
+        path: "/models",
+        ...opts,
+      });
+    },
+    listBatchJobs(opts = {}) {
+      return this._makeRequest({
+        path: "/batch/jobs",
+        ...opts,
+      });
+    },
+    listFiles(opts = {}) {
+      return this._makeRequest({
+        path: "/files",
+        ...opts,
+      });
+    },
+    createEmbeddings(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/embeddings",
+        ...opts,
+      });
+    },
+    sendPrompt(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/chat/completions",
+        ...opts,
+      });
+    },
+    createBatchJob(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/batch/jobs",
+        ...opts,
+      });
+    },
+    async *paginate({
+      fn,
+      params = {},
+      max,
+    }) {
+      params = {
+        ...params,
+        page: 0,
+        page_size: constants.DEFAULT_PAGE_SIZE,
+      };
+      let total, count = 0;
+      do {
+        const { data } = await fn({
+          params,
+        });
+        for (const item of data) {
+          yield item;
+          if (max && ++count >= max) {
+            return;
+          }
+        }
+        total = data?.length;
+        params.page++;
+      } while (total);
     },
   },
-};
\ No newline at end of file
+};
diff --git a/components/mistral_ai/package.json b/components/mistral_ai/package.json
index 02d8030515df4..b000b8d89d774 100644
--- a/components/mistral_ai/package.json
+++ b/components/mistral_ai/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/mistral_ai",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Mistral AI Components",
   "main": "mistral_ai.app.mjs",
   "keywords": [
@@ -11,5 +11,8 @@
   "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3"
   }
-}
\ No newline at end of file
+}
diff --git a/components/mistral_ai/sources/common/base.mjs b/components/mistral_ai/sources/common/base.mjs
new file mode 100644
index 0000000000000..2f76cc3c2ff65
--- /dev/null
+++ b/components/mistral_ai/sources/common/base.mjs
@@ -0,0 +1,86 @@
+import mistralAI from "../../mistral_ai.app.mjs";
+import {
+  DEFAULT_POLLING_SOURCE_TIMER_INTERVAL, ConfigurationError,
+} from "@pipedream/platform";
+
+export default {
+  props: {
+    mistralAI,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+  },
+  methods: {
+    _getLastTs() {
+      return this.db.get("lastTs") || 0;
+    },
+    _setLastTs(lastTs) {
+      this.db.set("lastTs", lastTs);
+    },
+    async getPaginatedResults(fn, params, max) {
+      const items = this.mistralAI.paginate({
+        fn,
+        params,
+        max,
+      });
+
+      const results = [];
+      for await (const item of items) {
+        results.push(item);
+      }
+
+      return results;
+    },
+    async processEvent(max) {
+      const fn = this.getResourceFn();
+      const params = this.getParams();
+      const paginated = this.isPaginated();
+
+      let results;
+      if (paginated) {
+        results = await this.getPaginatedResults(fn, params, max);
+        this.findAndSetLastTs(results);
+      } else {
+        results = (await fn({
+          params,
+        })).data;
+      }
+
+      results.forEach((result) => {
+        const meta = this.generateMeta(result);
+        this.$emit(result, meta);
+      });
+    },
+    findAndSetLastTs(results) {
+      let maxTs = this._getLastTs();
+      for (const result of results) {
+        maxTs = Math.max(result.created_at, maxTs);
+      }
+      this._setLastTs(maxTs);
+    },
+    getParams() {
+      return {};
+    },
+    isPaginated() {
+      return true;
+    },
+    getResourceFn() {
+      throw new ConfigurationError("getResourceFn is not implemented");
+    },
+    generateMeta() {
+      throw new ConfigurationError("generateMeta is not implemented");
+    },
+  },
+  hooks: {
+    async deploy() {
+      await this.processEvent(25);
+    },
+  },
+  async run() {
+    await this.processEvent();
+  },
+};
diff --git a/components/mistral_ai/sources/new-batch-job-completed/new-batch-job-completed.mjs b/components/mistral_ai/sources/new-batch-job-completed/new-batch-job-completed.mjs
new file mode 100644
index 0000000000000..60740d3a698bf
--- /dev/null
+++ b/components/mistral_ai/sources/new-batch-job-completed/new-batch-job-completed.mjs
@@ -0,0 +1,41 @@
+import common from "../common/base.mjs";
+import constants from "../../common/constants.mjs";
+
+export default {
+  ...common,
+  key: "mistral_ai-new-batch-job-completed",
+  name: "New Batch Job Completed",
+  description: "Emit new event when a new batch job is completed. [See the Documentation](https://docs.mistral.ai/api/#tag/batch/operation/jobs_api_routes_batch_get_batch_jobs)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    ...common.props,
+    status: {
+      type: "string",
+      label: "Status",
+      description: "Filter the results by the batch job status",
+      options: constants.BATCH_JOB_STATUS_OPTIONS,
+      optional: true,
+    },
+  },
+  methods: {
+    ...common.methods,
+    getResourceFn() {
+      return this.mistralAI.listBatchJobs;
+    },
+    getParams() {
+      return {
+        status: this.status,
+        created_after: this._getLastTs(),
+      };
+    },
+    generateMeta(job) {
+      return {
+        id: job.id,
+        summary: `New Batch Job ${job.status} with ID: ${job.id}`,
+        ts: job.created_at,
+      };
+    },
+  },
+};
diff --git a/components/mistral_ai/sources/new-batch-job-failure/new-batch-job-failure.mjs b/components/mistral_ai/sources/new-batch-job-failure/new-batch-job-failure.mjs
new file mode 100644
index 0000000000000..cf46681b8b564
--- /dev/null
+++ b/components/mistral_ai/sources/new-batch-job-failure/new-batch-job-failure.mjs
@@ -0,0 +1,30 @@
+import common from "../common/base.mjs";
+
+export default {
+  ...common,
+  key: "mistral_ai-new-batch-job-failure",
+  name: "New Batch Job Failure",
+  description: "Emit new event when a new batch job fails. [See the Documentation](https://docs.mistral.ai/api/#tag/batch/operation/jobs_api_routes_batch_get_batch_jobs)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getResourceFn() {
+      return this.mistralAI.listBatchJobs;
+    },
+    getParams() {
+      return {
+        status: "FAILED",
+        created_after: this._getLastTs(),
+      };
+    },
+    generateMeta(job) {
+      return {
+        id: job.id,
+        summary: `New Batch Job Failed with ID: ${job.id}`,
+        ts: job.created_at,
+      };
+    },
+  },
+};
diff --git a/components/mistral_ai/sources/new-model-added/new-model-added.mjs b/components/mistral_ai/sources/new-model-added/new-model-added.mjs
new file mode 100644
index 0000000000000..a2faded0df7fe
--- /dev/null
+++ b/components/mistral_ai/sources/new-model-added/new-model-added.mjs
@@ -0,0 +1,29 @@
+import common from "../common/base.mjs";
+import sampleEmit from "./test-event.mjs";
+
+export default {
+  ...common,
+  key: "mistral_ai-new-model-added",
+  name: "New Model Added",
+  description: "Emit new event when a new AI model is registered or becomes available. [See the Documentation](https://docs.mistral.ai/api/#tag/models)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getResourceFn() {
+      return this.mistralAI.listModels;
+    },
+    isPaginated() {
+      return false;
+    },
+    generateMeta(model) {
+      return {
+        id: model.id,
+        summary: `New Model: ${model.name}`,
+        ts: model.created,
+      };
+    },
+  },
+  sampleEmit,
+};
diff --git a/components/mistral_ai/sources/new-model-added/test-event.mjs b/components/mistral_ai/sources/new-model-added/test-event.mjs
new file mode 100644
index 0000000000000..d18980647c472
--- /dev/null
+++ b/components/mistral_ai/sources/new-model-added/test-event.mjs
@@ -0,0 +1,23 @@
+export default {
+  "id": "mistral-ocr-latest",
+  "object": "model",
+  "created": 1743621323,
+  "owned_by": "mistralai",
+  "capabilities": {
+    "completion_chat": false,
+    "completion_fim": false,
+    "function_calling": false,
+    "fine_tuning": false,
+    "vision": false,
+    "classification": false
+  },
+  "name": "mistral-ocr-2503",
+  "description": "Official mistral-ocr-2503 Mistral AI model",
+  "max_context_length": 32768,
+  "aliases": [
+    "mistral-ocr-2503"
+  ],
+  "deprecation": null,
+  "default_model_temperature": null,
+  "type": "base"
+}
\ No newline at end of file

From dd3a641bdaf2db0fc981b312e80663ce33bd0c19 Mon Sep 17 00:00:00 2001
From: michelle0927 <michellelbergero@hotmail.com>
Date: Wed, 2 Apr 2025 17:01:52 -0400
Subject: [PATCH 2/6] pnpm-lock.yaml

---
 pnpm-lock.yaml | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
index 4c0245be37368..30b1d22db64a3 100644
--- a/pnpm-lock.yaml
+++ b/pnpm-lock.yaml
@@ -1401,8 +1401,7 @@ importers:
 
   components/better_uptime: {}
 
-  components/bettercontact:
-    specifiers: {}
+  components/bettercontact: {}
 
   components/bettervoice:
     dependencies:
@@ -1930,8 +1929,7 @@ importers:
         specifier: ^4.2.0
         version: 4.2.0
 
-  components/bytebot:
-    specifiers: {}
+  components/bytebot: {}
 
   components/byteforms:
     dependencies:
@@ -8076,7 +8074,11 @@ importers:
         specifier: ^1.4.1
         version: 1.6.6
 
-  components/mistral_ai: {}
+  components/mistral_ai:
+    dependencies:
+      '@pipedream/platform':
+        specifier: ^3.0.3
+        version: 3.0.3
 
   components/mitra: {}
 
@@ -8611,8 +8613,7 @@ importers:
         specifier: ^1.3.0
         version: 1.6.6
 
-  components/notiff:
-    specifiers: {}
+  components/notiff: {}
 
   components/notion:
     dependencies:
@@ -12782,8 +12783,7 @@ importers:
         specifier: ^1.6.0
         version: 1.6.6
 
-  components/teltel:
-    specifiers: {}
+  components/teltel: {}
 
   components/temi:
     dependencies:

From afa869af34fa7cbcb2299bd9c6eb6133d30cb45c Mon Sep 17 00:00:00 2001
From: michelle0927 <michellelbergero@hotmail.com>
Date: Wed, 2 Apr 2025 17:21:09 -0400
Subject: [PATCH 3/6] fix description

---
 components/mistral_ai/actions/generate-text/generate-text.mjs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/mistral_ai/actions/generate-text/generate-text.mjs b/components/mistral_ai/actions/generate-text/generate-text.mjs
index aa10b39d78005..4de61ba1a40fc 100644
--- a/components/mistral_ai/actions/generate-text/generate-text.mjs
+++ b/components/mistral_ai/actions/generate-text/generate-text.mjs
@@ -3,7 +3,7 @@ import mistralAI from "../../mistral_ai.app.mjs";
 export default {
   key: "mistral_ai-generate-text",
   name: "Generate Text",
-  description: "Retrieve a list of available Mistral AI models that the user is authorized to access. [See the Documentation](https://docs.mistral.ai/api/#tag/fim/operation/fim_completion_v1_fim_completions_post)",
+  description: "Generate text using Mistral AI models. [See the Documentation](https://docs.mistral.ai/api/#tag/chat/operation/chat_completion_v1_chat_completions_post)",
   version: "0.0.1",
   type: "action",
   props: {

From aa6d496149a41b55e4c5ef050039c975ac22738f Mon Sep 17 00:00:00 2001
From: michelle0927 <michellelbergero@hotmail.com>
Date: Tue, 8 Apr 2025 12:26:51 -0400
Subject: [PATCH 4/6] new actions

---
 .../download-batch-job-results.mjs            | 50 ++++++++++++++++
 .../get-batch-job-details.mjs                 | 28 +++++++++
 .../actions/upload-file/upload-file.mjs       | 59 +++++++++++++++++++
 components/mistral_ai/mistral_ai.app.mjs      | 44 +++++++++++++-
 components/mistral_ai/package.json            |  3 +-
 5 files changed, 182 insertions(+), 2 deletions(-)
 create mode 100644 components/mistral_ai/actions/download-batch-job-results/download-batch-job-results.mjs
 create mode 100644 components/mistral_ai/actions/get-batch-job-details/get-batch-job-details.mjs
 create mode 100644 components/mistral_ai/actions/upload-file/upload-file.mjs

diff --git a/components/mistral_ai/actions/download-batch-job-results/download-batch-job-results.mjs b/components/mistral_ai/actions/download-batch-job-results/download-batch-job-results.mjs
new file mode 100644
index 0000000000000..b92b3cd10927c
--- /dev/null
+++ b/components/mistral_ai/actions/download-batch-job-results/download-batch-job-results.mjs
@@ -0,0 +1,50 @@
+import mistralAI from "../../mistral_ai.app.mjs";
+import fs from "fs";
+
+export default {
+  key: "mistral_ai-download-batch-job-results",
+  name: "Download Batch Job Results",
+  description: "Download a batch job results file to the /tmp direcory. [See the Documentation](https://docs.mistral.ai/api/#tag/files/operation/files_api_routes_download_file)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    mistralAI,
+    fileId: {
+      propDefinition: [
+        mistralAI,
+        "fileIds",
+        () => ({
+          sampleType: "batch_result",
+        }),
+      ],
+      type: "string",
+      label: "File ID",
+      description: "The identifier of a batch result file to download",
+    },
+    filename: {
+      type: "string",
+      label: "File Name",
+      description: "The filename to save the results file in the /tmp directory",
+    },
+  },
+  async run({ $ }) {
+    const response = await this.mistralAI.downloadFile({
+      $,
+      fileId: this.fileId,
+      responseType: "arraybuffer",
+    });
+
+    const rawcontent = response.toString("base64");
+    const buffer = Buffer.from(rawcontent, "base64");
+    const filename = this.filename;
+    const filePath = `/tmp/${filename}`;
+    fs.writeFileSync(filePath, buffer);
+
+    $.export("$summary", "Successfully downloaded batch results file");
+
+    return [
+      filename,
+      filePath,
+    ];
+  },
+};
diff --git a/components/mistral_ai/actions/get-batch-job-details/get-batch-job-details.mjs b/components/mistral_ai/actions/get-batch-job-details/get-batch-job-details.mjs
new file mode 100644
index 0000000000000..fb52ad5309efd
--- /dev/null
+++ b/components/mistral_ai/actions/get-batch-job-details/get-batch-job-details.mjs
@@ -0,0 +1,28 @@
+import mistralAI from "../../mistral_ai.app.mjs";
+
+export default {
+  key: "mistral_ai-get-batch-job-details",
+  name: "Get Batch Job Details",
+  description: "Get the details of a batch job by its ID. [See the Documentation](https://docs.mistral.ai/api/#tag/batch/operation/jobs_api_routes_batch_get_batch_job)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    mistralAI,
+    batchJobId: {
+      propDefinition: [
+        mistralAI,
+        "batchJobId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.mistralAI.getBatchJob({
+      $,
+      jobId: this.batchJobId,
+    });
+    if (response?.id) {
+      $.export("$summary", `Successfully retrieved details for batch job with ID: ${this.batchJobId}`);
+    }
+    return response;
+  },
+};
diff --git a/components/mistral_ai/actions/upload-file/upload-file.mjs b/components/mistral_ai/actions/upload-file/upload-file.mjs
new file mode 100644
index 0000000000000..6f6583088e4df
--- /dev/null
+++ b/components/mistral_ai/actions/upload-file/upload-file.mjs
@@ -0,0 +1,59 @@
+import mistralAI from "../../mistral_ai.app.mjs";
+import { ConfigurationError } from "@pipedream/platform";
+import fs from "fs";
+import FormData from "form-data";
+
+export default {
+  key: "mistral_ai-upload-file",
+  name: "Upload File",
+  description: "Upload a file that can be used across various endpoints. [See the Documentation](https://docs.mistral.ai/api/#tag/files/operation/files_api_routes_upload_file)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    mistralAI,
+    filePath: {
+      type: "string",
+      label: "File Path",
+      description: "The path to a file in the `/tmp` directory. The size of individual files can be a maximum of 512 MB. The Fine-tuning API only supports .jsonl files. [See the Pipedream documentation on working with files](https://pipedream.com/docs/code/nodejs/working-with-files/#writing-a-file-to-tmp)",
+    },
+    purpose: {
+      type: "string",
+      label: "Purpose",
+      description: "The purpose of the file",
+      options: [
+        "fine-tune",
+        "batch",
+        "ocr",
+      ],
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const filePath = this.filePath.startsWith("/tmp/")
+      ? this.filePath
+      : `/tmp/${this.filePath}`;
+
+    if (!fs.existsSync(filePath)) {
+      throw new ConfigurationError(`File \`${filePath}\` not found`);
+    }
+
+    const fileContent = fs.createReadStream(filePath);
+    const form = new FormData();
+    form.append("file", fileContent);
+    if (this.purpose) {
+      form.append("purpose", this.purpose);
+    }
+
+    const response = await this.mistralAI.uploadFile({
+      $,
+      data: form,
+      headers: form.getHeaders(),
+    });
+
+    if (response?.filename) {
+      $.export("$summary", `Successfully uploaded file: ${response.filename}`);
+    }
+
+    return response;
+  },
+};
diff --git a/components/mistral_ai/mistral_ai.app.mjs b/components/mistral_ai/mistral_ai.app.mjs
index b70be5c8c98df..5d957ab6fa074 100644
--- a/components/mistral_ai/mistral_ai.app.mjs
+++ b/components/mistral_ai/mistral_ai.app.mjs
@@ -9,11 +9,14 @@ export default {
       type: "string[]",
       label: "File IDs",
       description: "Array of input file UUIDs for batch processing",
-      async options({ page }) {
+      async options({
+        page, sampleType,
+      }) {
         const { data } = await this.listFiles({
           params: {
             page,
             page_size: constants.DEFAULT_PAGE_SIZE,
+            sample_type: sampleType,
           },
         });
         return data?.map(({
@@ -38,6 +41,20 @@ export default {
         })) || [];
       },
     },
+    batchJobId: {
+      type: "string",
+      label: "Batch Job ID",
+      description: "The identifier of the batch job to retrieve",
+      async options({ page }) {
+        const { data } = await this.listBatchJobs({
+          params: {
+            page,
+            page_size: constants.DEFAULT_PAGE_SIZE,
+          },
+        });
+        return data?.map(({ id }) => id) || [];
+      },
+    },
   },
   methods: {
     _baseUrl() {
@@ -46,6 +63,7 @@ export default {
     _makeRequest({
       $ = this,
       path,
+      headers,
       ...otherOpts
     }) {
       return axios($, {
@@ -54,6 +72,7 @@ export default {
         headers: {
           "Authorization": `Bearer ${this.$auth.api_key}`,
           "Content-Type": "application/json",
+          ...headers,
         },
       });
     },
@@ -75,6 +94,29 @@ export default {
         ...opts,
       });
     },
+    getBatchJobDetails({
+      jobId, ...opts
+    }) {
+      return this._makeRequest({
+        path: `/batch/jobs/${jobId}`,
+        ...opts,
+      });
+    },
+    downloadFile({
+      fileId, ...opts
+    }) {
+      return this._makeRequest({
+        path: `/files/${fileId}/content`,
+        ...opts,
+      });
+    },
+    uploadFile(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/files",
+        ...opts,
+      });
+    },
     createEmbeddings(opts = {}) {
       return this._makeRequest({
         method: "POST",
diff --git a/components/mistral_ai/package.json b/components/mistral_ai/package.json
index b000b8d89d774..091e79e2483ca 100644
--- a/components/mistral_ai/package.json
+++ b/components/mistral_ai/package.json
@@ -13,6 +13,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^3.0.3"
+    "@pipedream/platform": "^3.0.3",
+    "form-data": "^4.0.2"
   }
 }

From be67973fd119c05edd8ff05c22dddd3c3e375e0b Mon Sep 17 00:00:00 2001
From: michelle0927 <michellelbergero@hotmail.com>
Date: Tue, 8 Apr 2025 12:28:42 -0400
Subject: [PATCH 5/6] pnpm-lock.yaml

---
 pnpm-lock.yaml | 65 ++++++++++++++++++++++----------------------------
 1 file changed, 29 insertions(+), 36 deletions(-)

diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
index 30b1d22db64a3..2b8f373305357 100644
--- a/pnpm-lock.yaml
+++ b/pnpm-lock.yaml
@@ -8079,6 +8079,9 @@ importers:
       '@pipedream/platform':
         specifier: ^3.0.3
         version: 3.0.3
+      form-data:
+        specifier: ^4.0.2
+        version: 4.0.2
 
   components/mitra: {}
 
@@ -16455,8 +16458,8 @@ packages:
   '@dabh/diagnostics@2.0.3':
     resolution: {integrity: sha512-hrlQOIi7hAfzsMqlGSFyVucrx38O+j6wiGOf//H2ecvIEqYN4ADBSS2iLMh5UFyDunCNniUIPk/q3riFv45xRA==}
 
-  '@definitelytyped/header-parser@0.2.18':
-    resolution: {integrity: sha512-3JWGzhieGOx+zhy+qaPDoiby2TPA1PZGpEJHt0VwR1aK0R9dER5BoBvnT5zSafg9kHQTw4aBRFbt3o41FNkaLw==}
+  '@definitelytyped/header-parser@0.2.19':
+    resolution: {integrity: sha512-zu+RxQpUCgorYUQZoyyrRIn9CljL1CeM4qak3NDeMO1r7tjAkodfpAGnVzx/6JR2OUk0tAgwmZxNMSwd9LVgxw==}
     engines: {node: '>=18.18.0'}
 
   '@definitelytyped/typescript-versions@0.1.8':
@@ -22126,10 +22129,6 @@ packages:
     resolution: {integrity: sha512-FGgH2h8zKNim9ljj7dankFPcICIK9Cp5bm+c2gQSYePhpaG5+esrLODihIorn+Pe6FGJzWhXQotPv73jTaldXA==}
     engines: {node: '>= 0.4'}
 
-  es-set-tostringtag@2.0.3:
-    resolution: {integrity: sha512-3T8uNMC3OQTHkFUsFq8r/BwAXLHvU/9O9mE0fBc/MY5iq/8H7ncvO947LmYA6ldWw9Uh8Yhf25zu6n7nML5QWQ==}
-    engines: {node: '>= 0.4'}
-
   es-set-tostringtag@2.1.0:
     resolution: {integrity: sha512-j6vWzfrGVfyXxge+O0x5sh6cvxAog0a/4Rdd2K36zCMV5eJ+/+tOAngRO8cODMNWbVRdVlmGZQL2YS3yR8bIUA==}
     engines: {node: '>= 0.4'}
@@ -32198,7 +32197,7 @@ snapshots:
       enabled: 2.0.0
       kuler: 2.0.0
 
-  '@definitelytyped/header-parser@0.2.18':
+  '@definitelytyped/header-parser@0.2.19':
     dependencies:
       '@definitelytyped/typescript-versions': 0.1.8
       '@definitelytyped/utils': 0.1.8
@@ -33940,7 +33939,7 @@ snapshots:
   '@pipedream/monday@0.7.0':
     dependencies:
       '@pipedream/platform': 3.0.3
-      form-data: 4.0.1
+      form-data: 4.0.2
       lodash.flatmap: 4.5.0
       lodash.map: 4.6.0
       lodash.uniqby: 4.7.0
@@ -37039,7 +37038,7 @@ snapshots:
       define-properties: 1.2.1
       es-abstract: 1.23.5
       es-array-method-boxes-properly: 1.0.0
-      es-object-atoms: 1.0.0
+      es-object-atoms: 1.1.1
       is-string: 1.0.7
 
   array.prototype.tosorted@1.1.4:
@@ -37057,7 +37056,7 @@ snapshots:
       define-properties: 1.2.1
       es-abstract: 1.23.5
       es-errors: 1.3.0
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
       is-array-buffer: 3.0.4
       is-shared-array-buffer: 1.0.3
 
@@ -38838,7 +38837,7 @@ snapshots:
 
   dts-critic@3.3.11(typescript@5.7.2):
     dependencies:
-      '@definitelytyped/header-parser': 0.2.18
+      '@definitelytyped/header-parser': 0.2.19
       command-exists: 1.2.9
       rimraf: 3.0.2
       semver: 6.3.1
@@ -38848,7 +38847,7 @@ snapshots:
 
   dtslint@4.2.1(typescript@5.7.2):
     dependencies:
-      '@definitelytyped/header-parser': 0.2.18
+      '@definitelytyped/header-parser': 0.2.19
       '@definitelytyped/typescript-versions': 0.1.8
       '@definitelytyped/utils': 0.1.8
       dts-critic: 3.3.11(typescript@5.7.2)
@@ -38982,7 +38981,7 @@ snapshots:
       es-define-property: 1.0.0
       es-errors: 1.3.0
       es-object-atoms: 1.0.0
-      es-set-tostringtag: 2.0.3
+      es-set-tostringtag: 2.1.0
       es-to-primitive: 1.2.1
       function.prototype.name: 1.1.6
       get-intrinsic: 1.2.4
@@ -39036,7 +39035,7 @@ snapshots:
 
   es-define-property@1.0.0:
     dependencies:
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
 
   es-define-property@1.0.1: {}
 
@@ -39045,8 +39044,8 @@ snapshots:
   es-get-iterator@1.1.3:
     dependencies:
       call-bind: 1.0.7
-      get-intrinsic: 1.2.4
-      has-symbols: 1.0.3
+      get-intrinsic: 1.3.0
+      has-symbols: 1.1.0
       is-arguments: 1.1.1
       is-map: 2.0.3
       is-set: 2.0.3
@@ -39060,9 +39059,9 @@ snapshots:
       define-properties: 1.2.1
       es-abstract: 1.23.5
       es-errors: 1.3.0
-      es-set-tostringtag: 2.0.3
+      es-set-tostringtag: 2.1.0
       function-bind: 1.1.2
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
       globalthis: 1.0.4
       gopd: 1.0.1
       has-property-descriptors: 1.0.2
@@ -39080,12 +39079,6 @@ snapshots:
     dependencies:
       es-errors: 1.3.0
 
-  es-set-tostringtag@2.0.3:
-    dependencies:
-      get-intrinsic: 1.2.4
-      has-tostringtag: 1.0.2
-      hasown: 2.0.2
-
   es-set-tostringtag@2.1.0:
     dependencies:
       es-errors: 1.3.0
@@ -40307,7 +40300,7 @@ snapshots:
     dependencies:
       call-bind: 1.0.7
       es-errors: 1.3.0
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
 
   get-tsconfig@4.8.1:
     dependencies:
@@ -41320,7 +41313,7 @@ snapshots:
   is-array-buffer@3.0.4:
     dependencies:
       call-bind: 1.0.7
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
 
   is-arrayish@0.2.1: {}
 
@@ -41491,7 +41484,7 @@ snapshots:
 
   is-symbol@1.0.4:
     dependencies:
-      has-symbols: 1.0.3
+      has-symbols: 1.1.0
 
   is-typed-array@1.1.13:
     dependencies:
@@ -41518,7 +41511,7 @@ snapshots:
   is-weakset@2.0.3:
     dependencies:
       call-bind: 1.0.7
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
 
   is-wsl@2.2.0:
     dependencies:
@@ -41621,8 +41614,8 @@ snapshots:
   iterator.prototype@1.1.3:
     dependencies:
       define-properties: 1.2.1
-      get-intrinsic: 1.2.4
-      has-symbols: 1.0.3
+      get-intrinsic: 1.3.0
+      has-symbols: 1.1.0
       reflect.getprototypeof: 1.0.6
       set-function-name: 2.0.2
 
@@ -44710,7 +44703,7 @@ snapshots:
       axios: 0.28.1
       base-64: 0.1.0
       build-url: 1.3.3
-      form-data: 4.0.1
+      form-data: 4.0.2
       https-proxy-agent: 5.0.1
       joi: 17.13.3
       jsonwebtoken: 9.0.2
@@ -44884,7 +44877,7 @@ snapshots:
       define-properties: 1.2.1
       es-abstract: 1.23.5
       es-aggregate-error: 1.0.13
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
       iterate-value: 1.0.2
 
   prompts@2.4.2:
@@ -45536,7 +45529,7 @@ snapshots:
       define-properties: 1.2.1
       es-abstract: 1.23.5
       es-errors: 1.3.0
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
       globalthis: 1.0.4
       which-builtin-type: 1.1.4
 
@@ -46146,7 +46139,7 @@ snapshots:
   safe-array-concat@1.1.2:
     dependencies:
       call-bind: 1.0.7
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
       has-symbols: 1.0.3
       isarray: 2.0.5
 
@@ -46255,7 +46248,7 @@ snapshots:
       define-data-property: 1.1.4
       es-errors: 1.3.0
       function-bind: 1.1.2
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
       gopd: 1.0.1
       has-property-descriptors: 1.0.2
 
@@ -46713,7 +46706,7 @@ snapshots:
       es-abstract: 1.23.5
       es-errors: 1.3.0
       es-object-atoms: 1.0.0
-      get-intrinsic: 1.2.4
+      get-intrinsic: 1.3.0
       gopd: 1.0.1
       has-symbols: 1.0.3
       internal-slot: 1.0.7

From 20e50906dc32eab36904894781531555ce95c1b0 Mon Sep 17 00:00:00 2001
From: michelle0927 <michellelbergero@hotmail.com>
Date: Tue, 8 Apr 2025 12:55:54 -0400
Subject: [PATCH 6/6] updates

---
 .../download-batch-job-results.mjs                         | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/components/mistral_ai/actions/download-batch-job-results/download-batch-job-results.mjs b/components/mistral_ai/actions/download-batch-job-results/download-batch-job-results.mjs
index b92b3cd10927c..8a1b7141b5171 100644
--- a/components/mistral_ai/actions/download-batch-job-results/download-batch-job-results.mjs
+++ b/components/mistral_ai/actions/download-batch-job-results/download-batch-job-results.mjs
@@ -4,7 +4,7 @@ import fs from "fs";
 export default {
   key: "mistral_ai-download-batch-job-results",
   name: "Download Batch Job Results",
-  description: "Download a batch job results file to the /tmp direcory. [See the Documentation](https://docs.mistral.ai/api/#tag/files/operation/files_api_routes_download_file)",
+  description: "Download a batch job results file to the /tmp directory. [See the Documentation](https://docs.mistral.ai/api/#tag/files/operation/files_api_routes_download_file)",
   version: "0.0.1",
   type: "action",
   props: {
@@ -34,8 +34,9 @@ export default {
       responseType: "arraybuffer",
     });
 
-    const rawcontent = response.toString("base64");
-    const buffer = Buffer.from(rawcontent, "base64");
+    const buffer = Buffer.isBuffer(response)
+      ? response
+      : Buffer.from(response);
     const filename = this.filename;
     const filePath = `/tmp/${filename}`;
     fs.writeFileSync(filePath, buffer);