feat: add Yutori integration (browsing agent, research, scouts)

components/yutori/README.md

@@ -0,0 +1,34 @@
+# Yutori
+
+## Overview
+
+[Yutori](https://yutori.com) is reimagining how people interact with the web. The [Yutori API](https://yutori.com/api) is an AI web agent platform. Give it a task and it navigates websites, fills forms, extracts data, and completes multi-step workflows using a real cloud browser — or runs deep research across 100+ sources. You can also set up Scouts: recurring monitors that watch any part of the web on a schedule and notify you when something relevant happens.
+
+All components authenticate with a Yutori API key. Get yours at [platform.yutori.com](https://platform.yutori.com). You'll enter it once in Pipedream Connect and it applies to all Yutori actions in your workflows.
+
+## Example Use Cases
+
+- **Competitive monitoring** *(Scout)*: Add the **New Scout Update** trigger, set the query to "alert me when [competitor]'s pricing page changes", and add a Slack step — deploy once and get notified automatically whenever prices change.
+- **Job alert** *(Scout)*: Add the **New Scout Update** trigger, set the query to "notify me when new Python engineer roles appear on Stripe's careers page", and add a Send Email step — you'll get an email for every new matching role.
+- **Sales research** *(Research)*: Trigger a workflow on a schedule or webhook, add a **Run Research Task** step with a company name as the query, wait for the result, and push the findings summary into Notion or HubSpot before a sales call.
+- **Web automation** *(Browsing)*: Trigger a workflow however you like, add a **Run Browsing Task** step with a URL and plain-English instructions (e.g. "fill out this form" or "extract the pricing table"), and pipe the result into a Google Sheet.
+
+## Getting Started
+
+1. Sign up and get an API key at [platform.yutori.com](https://platform.yutori.com)
+2. In Pipedream, add a new Yutori connection and enter your API key
+3. Add any Yutori action or trigger to your workflow
+
+**Getting browsing and research results (two options):**
+- **Webhook (recommended)**: Create a second Pipedream workflow with an HTTP trigger, copy its URL, and paste it into the **Webhook URL** field on Run Browsing Task or Run Research Task. Yutori pushes the result instantly when the task completes.
+- **Poll**: Add a Delay step (~15 min) after starting the task, then use **Get Browsing Task Result** or **Get Research Task Result** to fetch the outcome.
+
+**Getting scout findings:** The **New Scout Update** trigger polls automatically (default every 15 minutes) — no extra setup needed.
+
+## Troubleshooting
+
+- **Tasks take 5–15 minutes** — don't poll for results immediately; use the webhook pattern or add a Delay step
+- **Webhook not firing** — make sure the webhook URL is publicly accessible (a Pipedream HTTP trigger URL works out of the box)
+- **401 Unauthorized** — verify your API key is active at [platform.yutori.com](https://platform.yutori.com)
+- **Scout not producing updates** — check that the workflow is still deployed and enabled in Pipedream
+- **Need help?** — email [support@yutori.com](mailto:support@yutori.com) or check the [documentation](https://docs.yutori.com)

components/yutori/actions/get-browsing-task-result/get-browsing-task-result.mjs

@@ -0,0 +1,27 @@
+import yutori from "../../yutori.app.mjs";
+
+export default {
+  key: "yutori-get-browsing-task-result",
+  name: "Get Browsing Task Result",
+  description: "Fetch the current status and result of a browsing task started with **Run Browsing Task**. Place a **Delay** step (15 minutes recommended) before this action to give the task time to complete. If the task is still running, the step returns the current status — re-run or increase the delay if needed. [See the documentation](https://docs.yutori.com/reference/browsing-get)",
+  version: "0.0.1",
+  type: "action",
+  annotations: {
+    openWorldHint: true,
+    destructiveHint: false,
+    readOnlyHint: true,
+  },
+  props: {
+    yutori,
+    taskId: {
+      type: "string",
+      label: "Task ID",
+      description: "The task ID returned by the **Run Browsing Task** step, e.g. `{{steps.run_browsing_task.$return_value.task_id}}`",
+    },
+  },
+  async run({ $ }) {
+    const result = await this.yutori.getBrowsingTask($, this.taskId);
+    $.export("$summary", `Browsing task ${result.status}: ${this.taskId}`);
+    return result;
+  },
+};

components/yutori/actions/get-research-task-result/get-research-task-result.mjs

@@ -0,0 +1,27 @@
+import yutori from "../../yutori.app.mjs";
+
+export default {
+  key: "yutori-get-research-task-result",
+  name: "Get Research Task Result",
+  description: "Fetch the current status and result of a research task started with **Run Research Task**. Place a **Delay** step (15 minutes recommended) before this action to give the task time to complete. Research tasks typically take 5–15 minutes. If the task is still running, the step returns the current status — re-run or increase the delay if needed. [See the documentation](https://docs.yutori.com/reference/research-get)",
+  version: "0.0.1",
+  type: "action",
+  annotations: {
+    openWorldHint: true,
+    destructiveHint: false,
+    readOnlyHint: true,
+  },
+  props: {
+    yutori,
+    taskId: {
+      type: "string",
+      label: "Task ID",
+      description: "The task ID returned by the **Run Research Task** step, e.g. `{{steps.run_research_task.$return_value.task_id}}`",
+    },
+  },
+  async run({ $ }) {
+    const result = await this.yutori.getResearchTask($, this.taskId);
+    $.export("$summary", `Research task ${result.status}: ${this.taskId}`);
+    return result;
+  },
+};

components/yutori/actions/get-scout-updates/get-scout-updates.mjs

@@ -0,0 +1,46 @@
+import yutori from "../../yutori.app.mjs";
+
+export default {
+  key: "yutori-get-scout-updates",
+  name: "Get Scout Updates",
+  description: "Fetch the latest findings from a specific Yutori Scout. Returns updates in reverse chronological order. Use the **New Scout Update** trigger for event-driven workflows; use this action when you need to pull findings on demand. [See the documentation](https://docs.yutori.com/reference/scouting-updates-get)",
+  version: "0.0.1",
+  type: "action",
+  annotations: {
+    openWorldHint: true,
+    destructiveHint: false,
+    readOnlyHint: true,
+  },
+  props: {
+    yutori,
+    scoutId: {
+      type: "string",
+      label: "Scout ID",
+      description: "The ID of the scout whose updates to fetch, e.g. from the Yutori dashboard or a previous **Get Scout** step",
+    },
+    pageSize: {
+      type: "integer",
+      label: "Limit",
+      description: "Maximum number of updates to return (1–100)",
+      optional: true,
+      default: 10,
+      min: 1,
+      max: 100,
+    },
+  },
+  async run({ $ }) {
+    const params = {};
+    if (this.pageSize) params.page_size = this.pageSize;
+
+    const result = await this.yutori.getScoutUpdates($, this.scoutId, params);
+    const updates = result?.updates ?? result?.items ?? [];
+    const count = Array.isArray(updates)
+      ? updates.length
+      : "?";
+
+    $.export("$summary", `Retrieved ${count} update${count === 1
+      ? ""
+      : "s"} for scout ${this.scoutId}`);
+    return result;
+  },
+};

components/yutori/actions/get-scout/get-scout.mjs

@@ -0,0 +1,29 @@
+import yutori from "../../yutori.app.mjs";
+
+export default {
+  key: "yutori-get-scout",
+  name: "Get Scout",
+  description: "Fetch the details and current status of a specific Yutori Scout by its ID. Returns the scout's configuration, status (active, paused, completed), and metadata. [See the documentation](https://docs.yutori.com/reference/scouting-get)",
+  version: "0.0.1",
+  type: "action",
+  annotations: {
+    openWorldHint: true,
+    destructiveHint: false,
+    readOnlyHint: true,
+  },
+  props: {
+    yutori,
+    scoutId: {
+      type: "string",
+      label: "Scout ID",
+      description: "The ID of the scout to retrieve, e.g. from the Yutori dashboard or a previous **Get Scout** / **Get Scout Updates** step",
+    },
+  },
+  async run({ $ }) {
+    const scout = await this.yutori.getScout($, this.scoutId);
+    const name = scout?.display_name ?? scout?.query?.slice(0, 60) ?? this.scoutId;
+
+    $.export("$summary", `Scout: ${name}`);
+    return scout;
+  },
+};

components/yutori/actions/run-browsing-task/run-browsing-task.mjs

@@ -0,0 +1,59 @@
+import yutori from "../../yutori.app.mjs";
+
+export default {
+  key: "yutori-run-browsing-task",
+  name: "Run Browsing Task",
+  description: "Use Yutori's cloud browser agent to navigate a website, fill forms, extract data, or complete any multi-step task — just describe it in plain English. Returns a task ID immediately; provide a **Webhook URL** to receive the full result the moment the task finishes. [See the documentation](https://docs.yutori.com/reference/browsing-create)",
+  version: "0.0.1",
+  type: "action",
+  annotations: {
+    openWorldHint: true,
+    destructiveHint: false,
+    readOnlyHint: false,
+  },
+  props: {
+    yutori,
+    task: {
+      type: "string",
+      label: "Task",
+      description: "Natural language description of what to do on the website, e.g. `Find the cheapest flight from NYC to LA next Friday`",
+    },
+    startUrl: {
+      type: "string",
+      label: "Start URL",
+      description: "The URL to start browsing from, e.g. `https://google.com/flights`",
+    },
+    maxSteps: {
+      type: "integer",
+      label: "Max Steps",
+      description: "Maximum number of browser actions the agent can take (1–100)",
+      optional: true,
+      min: 1,
+      max: 100,
+      default: 50,
+    },
+    webhookUrl: {
+      propDefinition: [
+        yutori,
+        "webhookUrl",
+      ],
+      description: "URL to receive the result when the task completes. Recommended for reliable delivery — Yutori will POST the result to this URL.",
+    },
+  },
+  async run({ $ }) {
+    const payload = {
+      task: this.task,
+      start_url: this.startUrl,
+      max_steps: this.maxSteps,
+    };
+    if (this.webhookUrl) {
+      payload.webhook_url = this.webhookUrl;
+      payload.webhook_format = "scout";
+    }
+
+    const created = await this.yutori.createBrowsingTask($, payload);
+
+    $.export("$summary", `Browsing task started: ${this.task.slice(0, 60)}`);
+    return created;
+  },
+};

components/yutori/actions/run-research-task/run-research-task.mjs

@@ -0,0 +1,60 @@
+import yutori from "../../yutori.app.mjs";
+
+export default {
+  key: "yutori-run-research-task",
+  name: "Run Research Task",
+  description: "Use Yutori to run deep web research across 100+ sources and get a comprehensive findings report — competitive analysis, market research, pricing comparisons, and more. Returns a task ID immediately; provide a **Webhook URL** to receive the full findings the moment research completes. [See the documentation](https://docs.yutori.com/reference/research-create)",
+  version: "0.0.1",
+  type: "action",
+  annotations: {
+    openWorldHint: true,
+    destructiveHint: false,
+    readOnlyHint: false,
+  },
+  props: {
+    yutori,
+    query: {
+      propDefinition: [
+        yutori,
+        "query",
+      ],
+      label: "Research Query",
+      description: "What to research, e.g. `What are the top 5 CRM tools for startups in 2025, with pricing?`",
+    },
+    userTimezone: {
+      propDefinition: [
+        yutori,
+        "userTimezone",
+      ],
+    },
+    userLocation: {
+      propDefinition: [
+        yutori,
+        "userLocation",
+      ],
+    },
+    webhookUrl: {
+      propDefinition: [
+        yutori,
+        "webhookUrl",
+      ],
+      description: "URL to receive the result when research completes. Recommended for reliable delivery — Yutori will POST the findings to this URL.",
+    },
+  },
+  async run({ $ }) {
+    const payload = {
+      query: this.query,
+    };
+    if (this.userTimezone) payload.user_timezone = this.userTimezone;
+    if (this.userLocation) payload.user_location = this.userLocation;
+    if (this.webhookUrl) {
+      payload.webhook_url = this.webhookUrl;
+      payload.webhook_format = "scout";
+    }
+
+    const created = await this.yutori.createResearchTask($, payload);
+
+    $.export("$summary", `Research task started: ${this.query.slice(0, 60)}`);
+    return created;
+  },
+};

components/yutori/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/yutori",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Yutori Components",
   "main": "yutori.app.mjs",
   "keywords": [
@@ -11,5 +11,8 @@
   "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.1.1"
   }
-}
+}