export default async function main(args) {
const logs = [];
// Extract input variables from args
const { shopDomain, productTitle } = args.inputVars;
const query = productTitle;
logs.push(`Extracted inputs - query: ${query}, shopDomain: ${shopDomain}`);
// Validate that the required input variables are provided
if (!shopDomain || !query) {
logs.push("Error: Missing required input variables: shopDomain or query");
return {
next: { path: 'error' },
trace: [{ type: "debug", payload: { message: logs.join(", ") } }]
};
}
// Define the endpoint URL
const encodedQuery = encodeURIComponent(query);
const url = `https://${shopDomain}/search/suggest.json?q=${encodedQuery}&resources[type]=product`;
logs.push(`URL: ${url}`);
// Configure the fetch request
const config = {
method: 'GET',
headers: {
'Content-Type': 'application/json',
},
};
try {
// Make the API call
logs.push(`Making API call to URL: ${url}`);
const response = await fetch(url, config);
// Check if the response status is OK
if (!response.ok) {
const errorMsg = await response.text();
logs.push(`HTTP error! status: ${response.status}, message: ${errorMsg}`);
throw new Error(`HTTP error! status: ${response.status}, message: ${errorMsg}`);
}
// Extract the JSON body from the response
logs.push("Extracting JSON from the response");
const responseBody = await response.json;
// Validate the responseBody structure as expected
if (!responseBody || !responseBody.resources || !responseBody.resources.results || !Array.isArray(responseBody.resources.results.products)) {
throw new Error("Invalid or missing response body from the API");
}
// Fetch the first product from the search results
const products = responseBody.resources.results.products;
if (products.length === 0) {
throw new Error("No products found for the given query");
}
const firstProduct = products[0];
// Extract required product details
const productTitle = firstProduct.title;
const productImageUrl = firstProduct.image;
const productPrice = firstProduct.price; // Assuming 'price' is the correct field for product price
const productUrl = firstProduct.url;
logs.push(`Product found: Title - ${productTitle}, Image URL - ${productImageUrl}, Price - ${productPrice}, URL - ${productUrl}`);
// Create the success return object with extracted data
return {
outputVars: {
Productresponse: JSON.stringify(responseBody),
productTitle,
productImageUrl,
productPrice,
productUrl
},
next: { path: 'success' },
};
} catch (error) {
logs.push(`Error: ${error.message}`);
return {
next: { path: 'error' },
};
}
}
