So, as you can see, the task implementation doesn't look complex, and Firefly also provides ways to implement it quite quickly.
Full action code (don't forget to install npm install papaparse for CSV parsing).
In short, actions are:
- Downloading a CSV file from an external source
- Parsing the file and reading the contents
- Convert content into JSON compatible Magento Rest API/products request.
- Executing the Magento API call to the /products endpoint.
- Read response
const Papa = require('papaparse')
const fetch = require('node-fetch')
const { Core, Events } = require('@adobe/aio-sdk')
const uuid = require('uuid')
const cloudEventV1 = require('cloudevents-sdk/v1')
const { errorResponse, getBearerToken, stringParameters, checkMissingRequestInputs } = require('../utils')
function csvToJson(csv) {
const logger = Core.Logger('main', { level: 'debug' })
logger.debug(JSON.stringify(csv));
const header = csv[0];
const out = csv.map((el, i) => {
if (i === 0)
return {};
const obj = {};
el.forEach((item, index) => {
obj[header[index].trim()] = item.trim();
})
const newObj = {};
newObj.product = obj;
return newObj;
});
logger.debug(JSON.stringify(out));
return out;
}
// main function that will be executed by Adobe I/O Runtime
async function main (params) {
// create a Logger
const logger = Core.Logger('main', { level: params.LOG_LEVEL || 'info' })
try {
// 'info' is the default level if not set
logger.info('Calling the main action')
const csv = await fetch("https://URL/media/firefly.csv")
.then(resp => resp.text())
.then(result => {
const res = Papa.parse(result);
return csvToJson(res.data);
})
// replace this with tddhe api you want to access
const apiEndpoint = 'https://URL/rest/V1/products'
const content = [];
const out = Promise.all(csv.map(async (el, i) => {
if (i === 0)
return;
const res = await fetch(apiEndpoint, {
method: 'POST',
body: JSON.stringify(el),
headers: {
"Authorization": “Bearer 123123123",
"Content-Type": “application/json",
}
})
if (!res.ok) {
logger.info((res))
throw new Error('request to ' + apiEndpoint + ' failed with status code ' + res.status)
}
content.push(await res.json());
}));
const response = {
statusCode: 200,
body: content
}
logger.info(stringParameters(response))
return response
} catch (error) {
// log any server errors
logger.error(error)
// return with 500
return errorResponse(500, 'server error', logger)
}
}
exports.main = main
