[Components] openrouter #15025

Actions
 - Send Completion Request
 - Send Chat Completion Request
 - Retrieve Available Models

Author: luancazarine

components/openrouter/actions/retrieve-available-models/retrieve-available-models.mjs

@@ -0,0 +1,20 @@
+import openrouter from "../../openrouter.app.mjs";
+
+export default {
+  key: "openrouter-retrieve-available-models",
+  name: "Retrieve Available Models",
+  version: "0.0.1",
+  description: "Returns a list of models available through the API. [See the documentation](https://openrouter.ai/docs/api-reference/list-available-models)",
+  type: "action",
+  props: {
+    openrouter,
+  },
+  async run({ $ }) {
+    const response = await this.openrouter.listModels({
+      $,
+    });
+
+    $.export("$summary", `Successfully retrieved ${response.data.length} available model(s)!`);
+    return response;
+  },
+};

components/openrouter/actions/send-chat-completion-request/send-chat-completion-request.mjs

@@ -0,0 +1,190 @@
+import { ConfigurationError } from "@pipedream/platform";
+import { parseObject } from "../../common/utils.mjs";
+import openrouter from "../../openrouter.app.mjs";
+
+export default {
+  key: "openrouter-send-chat-completion-request",
+  name: "Send Chat Completion Request",
+  version: "0.0.1",
+  description: "Send a chat completion request to a selected model. [See the documentation](https://openrouter.ai/docs/api-reference/chat-completion)",
+  type: "action",
+  props: {
+    openrouter,
+    model: {
+      propDefinition: [
+        openrouter,
+        "model",
+      ],
+    },
+    messages: {
+      type: "string[]",
+      label: "Messages",
+      description: "A list of objects containing role and content. E.g. **{\"role\":\"user\", \"content\":\"text\"}**. [See the documentation](https://openrouter.ai/docs/api-reference/chat-completion#request.body.messages) for further details.",
+    },
+    maxTokens: {
+      propDefinition: [
+        openrouter,
+        "maxTokens",
+      ],
+    },
+    temperature: {
+      propDefinition: [
+        openrouter,
+        "temperature",
+      ],
+    },
+    seed: {
+      propDefinition: [
+        openrouter,
+        "seed",
+      ],
+    },
+    topP: {
+      propDefinition: [
+        openrouter,
+        "topP",
+      ],
+    },
+    topK: {
+      propDefinition: [
+        openrouter,
+        "topK",
+      ],
+    },
+    frequencyPenalty: {
+      propDefinition: [
+        openrouter,
+        "frequencyPenalty",
+      ],
+    },
+    presencePenalty: {
+      propDefinition: [
+        openrouter,
+        "presencePenalty",
+      ],
+    },
+    repetitionPenalty: {
+      propDefinition: [
+        openrouter,
+        "repetitionPenalty",
+      ],
+    },
+    logitBias: {
+      propDefinition: [
+        openrouter,
+        "logitBias",
+      ],
+    },
+    togLogprobs: {
+      propDefinition: [
+        openrouter,
+        "togLogprobs",
+      ],
+    },
+    minP: {
+      propDefinition: [
+        openrouter,
+        "minP",
+      ],
+    },
+    topA: {
+      propDefinition: [
+        openrouter,
+        "topA",
+      ],
+    },
+    transforms: {
+      propDefinition: [
+        openrouter,
+        "transforms",
+      ],
+    },
+    models: {
+      propDefinition: [
+        openrouter,
+        "model",
+      ],
+      type: "string[]",
+      label: "Models",
+      description: "Alternate list of models for routing overrides.",
+    },
+    sort: {
+      propDefinition: [
+        openrouter,
+        "sort",
+      ],
+    },
+    effort: {
+      propDefinition: [
+        openrouter,
+        "effort",
+      ],
+    },
+    reasoningMaxTokens: {
+      propDefinition: [
+        openrouter,
+        "reasoningMaxTokens",
+      ],
+    },
+    exclude: {
+      propDefinition: [
+        openrouter,
+        "exclude",
+      ],
+    },
+  },
+  async run({ $ }) {
+    if (this.effort && this.reasoningMaxTokens) {
+      throw new ConfigurationError("**Reasoning Effort** and **Reasoning Max Tokens** cannot be used simultaneously.");
+    }
+    const data = {
+      model: this.model,
+      messages: parseObject(this.prompt),
+      stream: false,
+      maxTokens: this.maxTokens,
+      temperature: this.temperature && parseFloat(this.temperature),
+      seed: this.seed,
+      topP: this.topP && parseFloat(this.topP),
+      topK: this.topK,
+      frequencyPenalty: this.frequencyPenalty && parseFloat(this.frequencyPenalty),
+      presencePenalty: this.presencePenalty && parseFloat(this.presencePenalty),
+      repetitionPenalty: this.repetitionPenalty && parseFloat(this.repetitionPenalty),
+      logitBias: this.logitBias,
+      togLogprobs: this.togLogprobs,
+      minP: this.minP && parseFloat(this.minP),
+      topA: this.topA && parseFloat(this.topA),
+      transforms: this.transforms,
+      models: this.models,
+      provider: this.provider,
+      reasoning: this.reasoning,
+    };
+    if (this.sort) {
+      data.provider = {
+        sort: this.sort,
+      };
+    }
+    const reasoning = {};
+    if (this.effort) {
+      reasoning.effort =  this.effort;
+    }
+    if (this.reasoningMaxTokens) {
+      reasoning.max_tokens = parseFloat(this.reasoningMaxTokens);
+    }
+    if (this.exclude) {
+      reasoning.exclude =  this.exclude;
+    }
+    if (Object.entries(reasoning).length) {
+      data.reasoning = reasoning;
+    }
+    const response = await this.openrouter.sendChatCompetionRequest({
+      $,
+      data,
+      timeout: 1000 * 60 * 5,
+    });
+    if (response.error) {
+      throw new ConfigurationError(response.error.message);
+    }
+    $.export("$summary", `A new chat completion request with Id: ${response.id} was successfully created!`);
+    return response;
+  },
+};