Skip to content

DataForSEO new components #18095

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 9 commits into from
Aug 22, 2025
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -0,0 +1,69 @@
import dataforseo from "../../dataforseo.app.mjs";
import { ConfigurationError } from "@pipedream/platform";
import { parseArray } from "../../common/utils.mjs";

export default {
key: "dataforseo-get-app-intersection",
name: "Get App Intersection",
description: "Compare keyword overlap between mobile apps to find shared ranking opportunities. [See the documentation](https://docs.dataforseo.com/v3/dataforseo_labs/google/app_intersection/live/?bash)",
version: "0.0.1",
type: "action",
props: {
dataforseo,
appIds: {
type: "string[]",
label: "App IDs",
description: "Package names (IDs) of target Android apps on Google Play; you can find the package name in the app page URL (e.g., com.example.app)",
},
locationCode: {
propDefinition: [
dataforseo,
"locationCode",
],
},
languageCode: {
propDefinition: [
dataforseo,
"languageCode",
],
},
limit: {
propDefinition: [
dataforseo,
"limit",
],
},
},
async run({ $ }) {
const appIds = {};
const parsedAppIds = parseArray(this.appIds);

for (let i = 0; i < parsedAppIds.length; i++) {
appIds[`${i + 1}`] = parsedAppIds[i];
}

const response = await this.dataforseo.getAppIntersection({
$,
debug: true,
data: [
{
app_ids: appIds,
location_code: this.locationCode,
language_code: this.languageCode,
limit: this.limit,
},
],
});

if (response.status_code !== 20000) {
throw new ConfigurationError(`Error: ${response.status_message}`);
}

if (response.tasks[0].status_code !== 20000) {
throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
}

$.export("$summary", "Successfully retrieved app intersection.");
return response;
},
};
Original file line number Diff line number Diff line change
@@ -0,0 +1,64 @@
import dataforseo from "../../dataforseo.app.mjs";
import { ConfigurationError } from "@pipedream/platform";

export default {
key: "dataforseo-get-app-reviews-summary",
name: "Get App Reviews Summary",
description: "Get app reviews and ratings summary for mobile app reputation analysis. [See the documentation](https://docs.dataforseo.com/v3/app_data/apple/app_reviews/task_post/?bash)",
version: "0.0.1",
type: "action",
props: {
dataforseo,
appId: {
type: "string",
label: "App ID",
description: "The ID of the mobile application on App Store. Yyou can find the ID in the URL of every app listed on App Store. Example: in the URL https://apps.apple.com/us/app/id835599320, the id is `835599320`",
},
locationCode: {
propDefinition: [
dataforseo,
"locationCode",
],
},
languageCode: {
propDefinition: [
dataforseo,
"languageCode",
],
},
sortBy: {
type: "string",
label: "Sort By",
description: "Sort reviews by specific criteria",
options: [
"most_recent",
"most_helpful",
],
optional: true,
},
},
async run({ $ }) {
const response = await this.dataforseo.getAppReviewsSummary({
$,
data: [
{
app_id: this.appId,
location_code: this.locationCode,
language_code: this.languageCode,
sort_by: this.sortBy,
},
],
});

if (response.status_code !== 20000) {
throw new ConfigurationError(`Error: ${response.status_message}`);
}

if (response.tasks[0].status_code !== 20000 && response.tasks[0].status_code !== 20100) {
throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
}

$.export("$summary", `Successfully retrieved app reviews summary for "${this.appId}".`);
return response;
},
};
Original file line number Diff line number Diff line change
@@ -0,0 +1,85 @@
import dataforseo from "../../dataforseo.app.mjs";
import { ConfigurationError } from "@pipedream/platform";

export default {
key: "dataforseo-get-app-store-search",
name: "Get App Store Search",
description: "Search iOS App Store apps by keywords for app store optimization (ASO) analysis. [See the documentation](https://docs.dataforseo.com/v3/app_data/apple/app_searches/task_post/?bash)",
version: "0.0.1",
type: "action",
props: {
dataforseo,
keyword: {
type: "string",
label: "Keyword",
description: "The keyword to search for",
},
locationCode: {
propDefinition: [
dataforseo,
"locationCode",
],
},
languageCode: {
propDefinition: [
dataforseo,
"languageCode",
],
},
waitForResults: {
type: "boolean",
label: "Wait for Results",
description: "Wait for the results to be available. Not for use with Pipedream Connect.",
default: true,
optional: true,
},
postbackUrl: {
type: "string",
label: "Postback URL",
description: "The URL to receive the search results. Only applicable when \"Wait for Results\" = `FALSE`",
optional: true,
},
},
async run({ $ }) {
let response;
const context = $.context;
const run = context
? context.run
: {
runs: 1,
};

if (run.runs === 1) {
let postbackUrl = this.postbackUrl;
if (context && this.waitForResults) {
({ resume_url: postbackUrl } = $.flow.rerun(600000, null, 1));
}
response = await this.dataforseo.getAppStoreSearch({
$,
data: [
{
keyword: this.keyword,
location_code: this.locationCode,
language_code: this.languageCode,
postback_url: postbackUrl,
},
],
});

if (response.status_code !== 20000) {
throw new ConfigurationError(`Error: ${response.status_message}`);
}

if (response.tasks[0].status_code !== 20000 && response.tasks[0].status_code !== 20100) {
throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
}
}

if (run.runs > 1) {
response = run.callback_request.body;
}

$.export("$summary", `Successfully searched App Store for "${this.keyword}".`);
return response;
},
};
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ export default {
name: "Get Backlinks History",
description:
"Get historical backlinks data back to the beginning of 2019. [See the documentation](https://docs.dataforseo.com/v3/backlinks/history/live/)",
version: "0.0.1",
version: "0.0.2",
type: "action",
methods: {
getBacklinksHistory(args = {}) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ export default {
name: "Get Backlinks Summary",
description:
"Get an overview of backlinks data available for a given domain, subdomain, or webpage. [See the documentation](https://docs.dataforseo.com/v3/backlinks/summary/live/)",
version: "0.0.1",
version: "0.0.2",
type: "action",
methods: {
getBacklinksSummary(args = {}) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ export default {
name: "Get Backlinks",
description:
"Get a list of backlinks and relevant data for a given domain, subdomain, or webpage. [See the documentation](https://docs.dataforseo.com/v3/backlinks/backlinks/live/)",
version: "0.0.1",
version: "0.0.2",
type: "action",
methods: {
getBacklinks(args = {}) {
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,69 @@
import dataforseo from "../../dataforseo.app.mjs";
import { ConfigurationError } from "@pipedream/platform";

export default {
key: "dataforseo-get-bing-organic-results",
name: "Get Bing Organic Results",
description: "Retrieve Bing organic search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/bing/organic/live/regular/?bash)",
version: "0.0.1",
type: "action",
props: {
dataforseo,
keyword: {
type: "string",
label: "Keyword",
description: "The keyword to search for",
},
locationCode: {
propDefinition: [
dataforseo,
"locationCode",
],
},
languageCode: {
propDefinition: [
dataforseo,
"languageCode",
],
},
depth: {
type: "integer",
label: "Depth",
description: "The parsing depth. Default: 100",
max: 700,
optional: true,
},
maxCrawlPages: {
type: "integer",
label: "Max Crawl Pages",
description: "The page crawl limit",
max: 100,
optional: true,
},
},
async run({ $ }) {
const response = await this.dataforseo.getBingOrganicResults({
$,
data: [
{
keyword: this.keyword,
location_code: this.locationCode,
language_code: this.languageCode,
depth: this.depth,
max_crawl_pages: this.maxCrawlPages,
},
],
});

if (response.status_code !== 20000) {
throw new ConfigurationError(`Error: ${response.status_message}`);
}

if (response.tasks[0].status_code !== 20000) {
throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
}

$.export("$summary", `Successfully retrieved Bing organic results for "${this.keyword}".`);
return response;
},
};
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ export default {
name: "Get Bulk Backlinks",
description:
"Get the number of backlinks pointing to specified domains, subdomains, and pages. [See the documentation](https://docs.dataforseo.com/v3/backlinks/bulk_backlinks/live/)",
version: "0.0.1",
version: "0.0.2",
type: "action",
methods: {
getBulkBacklinks(args = {}) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ export default {
name: "Get Bulk Ranks",
description:
"Get rank scores of specified domains, subdomains, and pages. [See the documentation](https://docs.dataforseo.com/v3/backlinks/bulk_ranks/live/)",
version: "0.0.1",
version: "0.0.2",
type: "action",
methods: {
getBacklinksBulkRanks(args = {}) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ export default {
name: "Get Bulk Referring Domains",
description:
"Get the number of referring domains pointing to the specified domains, subdomains, and pages. [See the documentation](https://docs.dataforseo.com/v3/backlinks/bulk_referring_domains/live/)",
version: "0.0.1",
version: "0.0.2",
type: "action",
methods: {
getBulkReferringDomains(args = {}) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ export default {
name: "Get Bulk Spam Score",
description:
"Get spam scores of the specified domains, subdomains, and pages. [See the documentation](https://docs.dataforseo.com/v3/backlinks/bulk_spam_score/live/)",
version: "0.0.1",
version: "0.0.2",
type: "action",
methods: {
getBulkSpamScore(args = {}) {
Expand Down
Loading
Loading