Merge pull request #6 from CrystallizeAPI/new-schema

Updated schema
CrystallizeAPI · Sep 10, 2020 · d7564fe · d7564fe
2 parents 960064d + 51af922
commit d7564fe
Show file tree

Hide file tree

Showing 6 changed files with 149 additions and 107 deletions.
diff --git a/products-import-from-csv/graph.js b/products-import-from-csv/graph.js
diff --git a/products-import-from-csv/index.js b/products-import-from-csv/index.js
@@ -2,21 +2,22 @@ const parseCSV = require('./parse-csv');
 const utils = require('./utils');
 
 async function importProducts({
+  language,
   products,
   tenantId,
   shapeId,
   vatTypeId,
   treeParentId,
 }) {
-  const chunks = utils.chunkArray(products, 10);
-
   const productImportResult = [];
 
-  for (let i = 0; i < chunks.length; i++) {
-    const data = await utils.graphQLFetcher({
-      query: `mutation importProducts($products: [CreateProductInput!]!) {
+  // Import one product at a time
+  for (let i = 0; i < products.length; i++) {
+    const product = products[i];
+    const response = await utils.graphQLFetcher({
+      query: `mutation importProduct($language: String!, $product: CreateProductInput!) {
         product {
-          createMany(input: $products) {
+          create(input: $product, language: $language) {
             id
             tree {
               parentId
@@ -26,25 +27,20 @@ async function importProducts({
         }
       }`,
       variables: {
-        products: products.map(product => ({
+        language,
+        product: {
           ...product,
           tenantId,
           shapeId,
           vatTypeId,
           tree: {
             parentId: treeParentId,
           },
-          name: [
-            {
-              language: 'en',
-              translation: product.name,
-            },
-          ],
-        })),
+        },
       },
     });
 
-    productImportResult.push(data);
+    productImportResult.push(response);
   }
 
   return productImportResult;
@@ -62,7 +58,7 @@ async function importProducts({
   } else {
     console.log(`Found ${products.length} product(s) for import`);
 
-    const tenantId = await utils.getTenantId();
+    const { tenantId, language } = await utils.getTenantBaseInfo();
 
     const {
       shapeId,
@@ -71,6 +67,7 @@ async function importProducts({
     } = await utils.getExtraProductProperties(tenantId);
 
     const importResult = await importProducts({
+      language,
       products,
       tenantId,
       shapeId,

diff --git a/products-import-from-csv/package-lock.json b/products-import-from-csv/package-lock.json
diff --git a/products-import-from-csv/package.json b/products-import-from-csv/package.json
@@ -8,6 +8,7 @@
   },
   "dependencies": {
     "csv-parse": "^4.4.7",
+    "dotenv": "^8.2.0",
     "inquirer": "^6.5.1",
     "node-fetch": "2.6.0",
     "ora": "^3.4.0",

diff --git a/products-import-from-csv/parse-csv.js b/products-import-from-csv/parse-csv.js
@@ -20,7 +20,7 @@ function getRows(csv) {
       }
     });
 
-    parser.on('error', error => {
+    parser.on('error', (error) => {
       reject({
         message: 'Could not parse CSV',
         error,
@@ -38,7 +38,7 @@ function getRows(csv) {
 
 function parseAttributes(attributesString) {
   const parts = attributesString.split(';');
-  return parts.map(part => {
+  return parts.map((part) => {
     const [attribute, value] = part.split('=');
     return { attribute, value };
   });
@@ -59,7 +59,7 @@ function getProductsFromRows(rows) {
 
   const products = [];
 
-  rest.forEach(row => {
+  rest.forEach((row) => {
     if (row[keys.type] === 'product') {
       handleProduct(row);
     } else {
@@ -78,12 +78,7 @@ function getProductsFromRows(rows) {
     const product = products[products.length - 1];
 
     product.variants.push({
-      name: [
-        {
-          language: 'en',
-          translation: row[keys.name],
-        },
-      ],
+      name: row[keys.name],
       sku: row[keys.sku],
       price: parseFloat(row[keys.price], 10),
       stock: parseInt(row[keys.stock], 10),