1import { Actor, Dataset } from "apify";
2import { CheerioCrawler } from "crawlee";
3import fs from "fs";
4
5try {
6 await Actor.init();
7
8 const input = await Actor.getInput();
9 let { queries, maxRequestsPerCrawl } = input;
10 if (typeof queries === "string") {
11 queries = queries.replace(/^\[|\]$/g, "");
12 queries = `[${queries}]`;
13 }
14 const searchQueries = Array.isArray(queries) ? queries : [queries];
15 const searchQuery = searchQueries.join(" ");
16 const searchUrl = `https://www.google.com/search?q=${encodeURIComponent(
17 searchQuery
18 )}`;
19 console.log("URL ", searchUrl);
20
21 const phoneNumberRegex =
22 /(\d{3}[-.\s]??\d{3}[-.\s]??\d{4}|\(\d{3}\)\s*\d{3}[-.\s]??\d{4}|\d{3}[-.\s]??\d{4})/;
23
24 const resultsData = {
25 searchQuery: {
26 term: queries,
27 url: searchUrl,
28 device: "MOBILE",
29 page: 1,
30 type: "SEARCH",
31 domain: "google.com",
32 countryCode: "US",
33 languageCode: "en",
34 locationUule: null,
35 resultsPerPage: 10,
36 },
37 resultsTotal: "N/A",
38 relatedQueries: [],
39 paidResults: [],
40 paidProducts: [],
41 organicResults: [],
42 peopleAlsoAsk: [],
43 };
44
45 const crawler = new CheerioCrawler({
46 maxRequestsPerCrawl,
47 handlePageFunction: async ({ request, response, $, log }) => {
48 const searchResults = $("div.g, div.uEierd");
49 console.log("search results:", searchResults.length);
50
51 if (searchResults.length === 0) {
52 console.log("No search results were found.");
53 }
54
55 searchResults.each((index, element) => {
56 const $result = $(element);
57 let title =
58 $result.find("h3").text().trim() ||
59 $result.find(".xA33Gc").text().trim();
60 const url = $result.find("a").attr("href") || "";
61
62 const textContent = $result.text();
63 const description = extractDescription(textContent);
64 let phoneNumber = null;
65
66
67 const callElements = $result.find('*:contains("Call us")');
68 callElements.each((i, callElement) => {
69 const callText = $(callElement).text();
70 const phoneMatch = callText.match(phoneNumberRegex);
71 if (phoneMatch) {
72 phoneNumber = phoneMatch[0];
73 }
74 });
75
76
77 const isSponsored =
78 $result.hasClass("uEierd") ||
79 $result.find("span").text().toLowerCase().includes("ad");
80 let advertiserName = $result
81 .find("div.specific-class-for-advertiser-name")
82 .text()
83 .trim();
84
85 const [advertiserNameTrim, phoneNumberTrim] = title
86 .split("|~|")
87 .map((str) => str.trim());
88
89 if ((title || url || description) && phoneNumber) {
90 if (!title && advertiserName) {
91
92 title = `${advertiserName} |~| ${phoneNumber}`;
93 } else if (advertiserName) {
94 title = `${advertiserName} |~| ${phoneNumber}`;
95 } else {
96 title = `${phoneNumber}`;
97 }
98
99 console.log("title:", title);
100
101 if (isSponsored) {
102 resultsData.paidResults.push({
103 title,
104 url,
105 phoneNumber,
106 displayedUrl: url,
107 description,
108 emphasizedKeywords: [],
109 siteLinks: [],
110 type: "paid",
111 adPosition: index + 1,
112 advertiserName: advertiserNameTrim,
113 });
114 } else {
115 resultsData.organicResults.push({
116 title,
117 url,
118 phoneNumber,
119 displayedUrl: url,
120 description,
121 emphasizedKeywords: [],
122 siteLinks: [],
123 productInfo: {},
124 type: "organic",
125 position: index + 1,
126 advertiserName: advertiserNameTrim,
127 });
128 }
129 } else {
130 console.log(`Resultado ${index + 1} está vacío o incompleto.`);
131 }
132 });
133
134
135 const peopleAlsoAskElements = $("div.related-question-pair");
136 if (peopleAlsoAskElements.length === 0) {
137 console.log("No se encontraron 'People Also Ask'.");
138 }
139
140 peopleAlsoAskElements.each((index, element) => {
141 const $question = $(element).find(".yuRUbf").text().trim();
142 const $answer = $(element).find(".VwiC3b").text().trim();
143 const $url = $(element).find("a").attr("href") || "";
144
145 if ($question || $answer || $url) {
146 resultsData.peopleAlsoAsk.push({
147 question: $question,
148 answer: $answer,
149 url: $url,
150 title: $question,
151 date: "",
152 });
153 } else {
154 console.log(
155 `'People Also Ask' ${index + 1} está vacío o incompleto.`
156 );
157 }
158 });
159
160
161 const relatedQueriesElements = $('a[data-hveid="CAEQAw"]');
162 if (relatedQueriesElements.length === 0) {
163 console.log("No se encontraron 'Related Queries'.");
164 }
165
166 relatedQueriesElements.each((index, element) => {
167 const $relatedQuery = $(element).text().trim();
168 const $relatedUrl = $(element).attr("href") || "";
169
170 if ($relatedQuery || $relatedUrl) {
171 resultsData.relatedQueries.push({
172 title: $relatedQuery,
173 url: `https://www.google.com${$relatedUrl}`,
174 });
175 } else {
176 console.log(`'Related Query' ${index + 1} está vacío o incompleto.`);
177 }
178 });
179
180
181 const nextPageLink = $("a#pnnext").attr("href");
182 if (nextPageLink && request.userData.page < 25) {
183
184 await crawler.addRequests([
185 {
186 url: `https://www.google.com${nextPageLink}`,
187 userData: { page: request.userData.page + 1 },
188 },
189 ]);
190 }
191 },
192 });
193
194 const extractDescription = (textContent) => {
195
196 const cleanedText = textContent
197 .replace(/https?:\/\/[^\s]+|\/\/[^\s]+/g, "")
198 .trim();
199
200
201 const description = cleanedText
202 .replace(/(?: ›| · | - |:| · )[^›]*$/, "")
203 .trim();
204
205 return description;
206 };
207
208 await crawler.run([
209 {
210 url: searchUrl,
211 userData: { page: 1 },
212 },
213 ]);
214
215 if (!resultsData.paidResults.length && !resultsData.organicResults.length) {
216 console.log("No se encontraron resultados de búsqueda.");
217 }
218
219
220 await Actor.setValue("OUTPUT", resultsData);
221 await Dataset.pushData(resultsData);
222
223
224 fs.writeFileSync("./output.json", JSON.stringify(resultsData, null, 2));
225 console.log("Datos guardados en output.json");
226
227 await Actor.exit();
228} catch (error) {
229 console.error("Se produjo un error durante la ejecución del actor:", error);
230 process.exit(1);
231}