Merge remote-tracking branch 'origin/master' into issue-16062

Author: michelle0927

components/adyntel/actions/google-ads-by-company/google-ads-by-company.mjs

@@ -0,0 +1,39 @@
+import adyntel from "../../adyntel.app.mjs";
+
+export default {
+  key: "adyntel-google-ads-by-company",
+  name: "Get Google Ads by Company",
+  description: "Retrieve all Google ads for a given company domain. [See the documentation](https://docs.adyntel.com/ad-libraries/google)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    adyntel,
+    companyDomain: {
+      type: "string",
+      label: "Company Domain",
+      description: "The company domain. Company domain has to be passed in the 'company.com' format, meaning all prefixes like 'https://' or 'www.' need to be removed.",
+    },
+    mediaType: {
+      type: "string",
+      label: "Media Type",
+      description: "Filter results based on media type",
+      options: [
+        "text",
+        "image",
+        "video",
+      ],
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const response = await this.adyntel.getGoogleAds({
+      $,
+      data: {
+        company_domain: this.companyDomain,
+        media_type: this.mediaType,
+      },
+    });
+    $.export("$summary", `Fetched Google Ads for domain ${this.companyDomain}`);
+    return response;
+  },
+};

components/adyntel/actions/meta-ad-search/meta-ad-search.mjs

@@ -0,0 +1,37 @@
+import adyntel from "../../adyntel.app.mjs";
+
+export default {
+  key: "adyntel-meta-ad-search",
+  name: "Meta Ad Search",
+  description: "Searches the Meta ad library. [See the documentation](https://docs.adyntel.com/ad-libraries/meta-ad-search)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    adyntel,
+    keyword: {
+      propDefinition: [
+        adyntel,
+        "keyword",
+      ],
+    },
+    countryCode: {
+      propDefinition: [
+        adyntel,
+        "countryCode",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.adyntel.metaAdSearch({
+      $,
+      data: {
+        keyword: this.keyword,
+        country_code: this.countryCode,
+      },
+    });
+    $.export("$summary", `Successfully performed Meta ad search with keyword: \`${this.keyword}\`${this.countryCode
+      ? ` and country code: \`${this.countryCode}\``
+      : ""}`);
+    return response;
+  },
+};

components/adyntel/actions/tiktok-search/tiktok-search.mjs

@@ -0,0 +1,28 @@
+import adyntel from "../../adyntel.app.mjs";
+
+export default {
+  key: "adyntel-tiktok-search",
+  name: "Search TikTok Ads",
+  description: "Search TikTok ads using a keyword. [See the documentation](https://docs.adyntel.com/ad-libraries/tiktok-search)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    adyntel,
+    keyword: {
+      propDefinition: [
+        adyntel,
+        "keyword",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.adyntel.getTiktokAds({
+      $,
+      data: {
+        keyword: this.keyword,
+      },
+    });
+    $.export("$summary", `Successfully retrieved TikTok ads for keyword: \`${this.keyword}\``);
+    return response;
+  },
+};

components/adyntel/adyntel.app.mjs

@@ -0,0 +1,60 @@
+import { axios } from "@pipedream/platform";
+
+export default {
+  type: "app",
+  app: "adyntel",
+  propDefinitions: {
+    keyword: {
+      type: "string",
+      label: "Keyword",
+      description: "The keyword to search by",
+    },
+    countryCode: {
+      type: "string",
+      label: "Country Code",
+      description: "Use if you want to limit the search to only one country. E.g. `US`",
+      optional: true,
+    },
+  },
+  methods: {
+    _baseUrl() {
+      return "https://api.adyntel.com";
+    },
+    _makeRequest({
+      $ = this,
+      method = "POST",
+      path = "/",
+      data = {},
+      ...otherOpts
+    }) {
+      return axios($, {
+        ...otherOpts,
+        method,
+        url: `${this._baseUrl()}${path}`,
+        data: {
+          ...data,
+          api_key: this.$auth.api_key,
+          email: this.$auth.username,
+        },
+      });
+    },
+    metaAdSearch(opts = {}) {
+      return this._makeRequest({
+        path: "/facebook_ad_search",
+        ...opts,
+      });
+    },
+    getGoogleAds(opts = {}) {
+      return this._makeRequest({
+        path: "/google",
+        ...opts,
+      });
+    },
+    getTiktokAds(opts = {}) {
+      return this._makeRequest({
+        path: "/tiktok_search",
+        ...opts,
+      });
+    },
+  },
+};

components/adyntel/package.json

@@ -0,0 +1,18 @@
+{
+  "name": "@pipedream/adyntel",
+  "version": "0.1.0",
+  "description": "Pipedream Adyntel Components",
+  "main": "adyntel.app.mjs",
+  "keywords": [
+    "pipedream",
+    "adyntel"
+  ],
+  "homepage": "https://pipedream.com/apps/adyntel",
+  "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
+  "publishConfig": {
+    "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3"
+  }
+}

components/agentset/actions/create-ingest-job/create-ingest-job.mjs

@@ -0,0 +1,100 @@
+import agentset from "../../agentset.app.mjs";
+import { PAYLOAD_TYPE_OPTIONS } from "../../common/constants.mjs";
+import { parseObject } from "../../common/utils.mjs";
+
+export default {
+  key: "agentset-create-ingest-job",
+  name: "Create Ingest Job",
+  description: "Create an ingest job for the authenticated organization. [See the documentation](https://docs.agentset.ai/api-reference/endpoint/ingest-jobs/create)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    agentset,
+    namespaceId: {
+      propDefinition: [
+        agentset,
+        "namespaceId",
+      ],
+    },
+    payloadType: {
+      type: "string",
+      label: "Payload Type",
+      description: "Type of payload for the ingest job",
+      options: PAYLOAD_TYPE_OPTIONS,
+      reloadProps: true,
+    },
+    text: {
+      type: "string",
+      label: "Text",
+      description: "The text to ingest",
+      hidden: true,
+    },
+    fileUrl: {
+      type: "string",
+      label: "File URL",
+      description: "The URL of the file to ingest",
+      hidden: true,
+    },
+    urls: {
+      type: "string[]",
+      label: "URLs",
+      description: "The URLs to ingest",
+      hidden: true,
+    },
+    name: {
+      type: "string",
+      label: "Name",
+      description: "The name of the ingest job",
+      optional: true,
+      hidden: true,
+    },
+  },
+  async additionalProps(props) {
+    props.text.hidden = true;
+    props.name.hidden = true;
+    props.fileUrl.hidden = true;
+    props.urls.hidden = true;
+
+    switch (this.payloadType) {
+    case "TEXT":
+      props.text.hidden = false;
+      props.name.hidden = false;
+      break;
+    case "FILE":
+      props.fileUrl.hidden = false;
+      props.name.hidden = false;
+      break;
+    case "URLS":
+      props.urls.hidden = false;
+      break;
+    }
+    return {};
+  },
+  async run({ $ }) {
+    const payload = {
+      type: this.payloadType,
+    };
+    switch (this.payloadType) {
+    case "TEXT":
+      payload.text = this.text;
+      payload.name = this.name;
+      break;
+    case "FILE":
+      payload.fileUrl = this.fileUrl;
+      payload.name = this.name;
+      break;
+    case "URLS":
+      payload.urls = parseObject(this.urls);
+      break;
+    }
+    const response = await this.agentset.createIngestJob({
+      $,
+      namespaceId: this.namespaceId,
+      data: {
+        payload,
+      },
+    });
+    $.export("$summary", `Ingest job created successfully: ID ${response.data.id}`);
+    return response;
+  },
+};

components/agentset/actions/create-namespace/create-namespace.mjs

@@ -0,0 +1,30 @@
+import agentset from "../../agentset.app.mjs";
+import { slugify } from "../../common/utils.mjs";
+
+export default {
+  key: "agentset-create-namespace",
+  name: "Create Namespace",
+  description: "Creates a namespace for the authenticated organization. [See the documentation](https://docs.agentset.ai/api-reference/endpoint/namespaces/create)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    agentset,
+    name: {
+      type: "string",
+      label: "Name",
+      description: "The name of the namespace to create",
+    },
+  },
+  async run({ $ }) {
+    const response = await this.agentset.createNamespace({
+      $,
+      data: {
+        name: this.name,
+        slug: slugify(this.name),
+      },
+    });
+
+    $.export("$summary", `Successfully created namespace with ID: ${response.data.id}`);
+    return response;
+  },
+};