Added CSV file support [API, ImportForm]

admin/src/containers/ImportPage/ImportForm.js

@@ -6,6 +6,7 @@ import {FieldRow, FileField, FormAction} from "./ui-components";
 import {readLocalFile} from "../../utils/file";
 import JsonDataDisplay from "../../components/JsonDataDisplay";
 import {importData} from "../../utils/api";
+import { csvParser } from '../../utils/csvParser';
 
 const ImportForm = ({models}) => {
   const options = map(models, convertModelToOption);
@@ -37,7 +38,11 @@ const ImportForm = ({models}) => {
       return;
     }
     setLoading(true);
-    readLocalFile(sourceFile, JSON.parse).then(setSource)
+
+    const filenameSplit = sourceFile.name.split('.');
+    const ext = filenameSplit[filenameSplit.length - 1];
+
+    readLocalFile(sourceFile, ext === 'csv' ? csvParser : JSON.parse).then(setSource)
     .catch((error) => {
       strapi.notification.error(
         "Something wrong when uploading the file, please check the file and try again.");
@@ -77,7 +82,7 @@ const ImportForm = ({models}) => {
       <FileField>
         <input id="source"
                name="source"
-               accept={".json"}
+               accept={".csv,.json"}
                type="file"
                onChange={onSourceFileChange}
         />

admin/src/utils/csvParser.js

@@ -0,0 +1,21 @@
+export const csvParser = (csv) => {
+	const csvLines = csv.split(/\r\n|\n/);
+	const headers = csvLines[0].split(',');
+	const lines = [];
+
+	for (let i = 1; i < csvLines.length; i++) {
+		const data = csvLines[i].split(',');
+
+		if (data.length == headers.length) {
+			const jsonObj = {};
+
+			for (let j = 0; j < headers.length; j++) {
+				jsonObj[headers[j]] = data[j];
+			}
+
+			lines.push(jsonObj);
+		}
+	}
+
+	return lines;
+};

controllers/ContentExportImport.js

@@ -3,10 +3,40 @@
 const PLUGIN_ID = 'content-export-import';
 
 const validator = require('./validations');
+const csvHelpers = require("./csvHelpers");
 
 module.exports = {
   importContent: async (ctx) => {
     const importService = strapi.plugins[PLUGIN_ID].services['contentexportimport'];
+
+    let body = ctx.request.body;
+
+    try {
+      // Check if request has files
+      if (ctx.request.files) {
+        // Get files['source']
+        const sourceFile = ctx.request.files["source"].path;
+        const type = ctx.request.files["source"].type;
+
+        // Read and parse file['source']
+        const source = csvHelpers.readFile(
+          sourceFile,
+          type === "text/csv" ? csvHelpers.csvParser : JSON.parse
+        );
+
+        body = {
+          ...body,
+          source,
+        };
+
+        ctx.request.body = body;
+
+        console.log(body);
+      }
+    } catch (err) {
+      console.error("err", err, ctx.request.files);
+    }
+
     const validationResult = validator.validateImportContentRequest(
       ctx.request.body);
     if (validationResult) {

controllers/csvHelpers.js

@@ -0,0 +1,38 @@
+const fs = require('fs');
+
+const readFile = (file, parser) => {
+	try {
+		const content = fs.readFileSync(file).toString('utf-8');
+		console.log('content', content);
+		return parser && typeof parser === 'function' ? parser(content) : content;
+	} catch (err) {
+		throw err;
+	}
+};
+
+const csvParser = (csv) => {
+	const csvLines = csv.split(/\r\n|\n/);
+	const headers = csvLines[0].split(',');
+	const lines = [];
+
+	for (let i = 1; i < csvLines.length; i++) {
+		const data = csvLines[i].split(',');
+
+		if (data.length == headers.length) {
+			const jsonObj = {};
+
+			for (let j = 0; j < headers.length; j++) {
+				jsonObj[headers[j]] = data[j];
+			}
+
+			lines.push(jsonObj);
+		}
+	}
+
+	return lines;
+};
+
+module.exports = {
+	readFile,
+	csvParser
+};