tabbit

Fri Dec 21 2018
Copied to clipboard! Copy reply
import fs from 'fs-extra'
import Airtable from 'airtable';
import createPromosFile from '../createPromosFile';
import createPagesFile from '../createPagesFile';
import createCrescendoFile from '../createCrescendoFile';
import { replaceTimeFormatArray } from '../replaceTimeFormat';
import replacePromoCodeIdWithPromoCode from '../replacePromoCodeIdWithPromoCode';
import ProductArray from '../Util/ProductArray';
import { createMastheadImages, createSitewidePromoImages } from '../FileHandler';
import _ from 'lodash'
const configObject = { view: 'Grid view' };


/****************************************
 * Download Airtable's RSI tab
 ****************************************/
const getRSI = config =>
  new Promise((resolve, reject) => {

    console.log(`[${config.market}] Downloading RSIs from Airtable..`)

    const RSIArray = [];
    const base = new Airtable({ apiKey: config.key }).base(config.base)

    base('RSI')
      .select(configObject)
      .eachPage(
        function page(records, fetchNextPage) {
          records.forEach(function(record) {
            RSIArray.push({
              Id: record.get('RSI'),
              PromoNode: record.get('PromoNode'),
              MastheadImage: record.get('MastheadImage'),
              MobileMastheadImage: record.get('MobileMastheadImage'),
              ExpirationDate: record.get('ExpirationDate'),
              Campaign: record.get('Campaign'),
              BonusMonths: record.get('BonusMonths'),
              Bogo: record.get('Bogo'),
              ProductFilter: record.get('ProductFilter'),
              Js: record.get('Js'),
              Css: record.get('Css')
            });            
          });
          fetchNextPage();
        },
        function done(err) {
          if (err) {
            console.error(err);
            reject(err);
          }
          resolve(RSIArray);
        }
      );
  });


/****************************************
 * Download Airtable's PROMO tab
 ****************************************/
const getPromo = config =>
  new Promise((resolve, reject) => {
    
    console.log(`[${config.market}] Downloading PROMO from Airtable..`)

    const PromoArray = [];
    const base = new Airtable({ apiKey: config.key }).base(config.base);

    base('PROMO')
      .select(configObject)
      .eachPage((records, fetchNextPage) => {
          records.forEach(record => {
            let tempObject = {};
            let processProductArray;            
            
            processProductArray = ProductArray[config.market]; 

            for (let i = 0; i < processProductArray.length; i++)
            {
              Object.assign(tempObject, {
                [processProductArray[i]]:
                  typeof record.get(processProductArray[i]) !== 'undefined'
                    ? record.get(processProductArray[i])[0]
                    : 'undefined'
              });
            }

            Object.assign(tempObject, {
              id: record.id,
              PromoNodeName: record.get('PromoNodeName')
            });

            PromoArray.push(tempObject);
          });

          fetchNextPage();
        },
        function done(err)
        {
          if (err)
          {
            reject(err);
          }

          resolve(PromoArray);
        }
      );
  });


/****************************************
 * Download Airtable's PROMO _CODES tab
 ****************************************/
const getPromoCodes = config =>
  new Promise((resolve, reject) => {

    console.log(`[${config.market}] Downloading PROMO_CODES from Airtable..`)

    const PromoCodeObject = {};
    const base = new Airtable({ apiKey: config.key }).base(config.base);

    base('PROMO_CODES')
      .select(configObject)
      .eachPage(
        function page(records, fetchNextPage) {
          records.forEach(function(record) {
            Object.assign(PromoCodeObject, {
              [record.id]: {
                code: record.get('PROMOCODE'),
                price: record.get('PRICE')
              }
            });
          });
          fetchNextPage();
        },
        function done(err) {
          if (err) {
            reject(err);
          }
          resolve(PromoCodeObject);
        }
      );
  });


/****************************************
 * Download Airtable's CRESCENDO tab
 ****************************************/
const getCrescendo = config =>
  new Promise((resolve, reject) => {
    
    console.log(`[${config.market}] Downloading CRESCENDO from Airtable..`)

    const base = new Airtable({ apiKey: config.key }).base( config.base )    
    const CrescendoArray = [];

    // crescendos = { valentine: [ {clockEnd:...}, {clockEnd:...} ] }
    const crescendos = {};

    base('CRESCENDO')
      .select(configObject)
      .eachPage(
        function page(records, fetchNextPage) {
          records.forEach(function(record) {
            CrescendoArray.push({
              name: record.get('name'),
              crescendoDate: record.get('crescendo-date'),
              expirationDate: record.get('expiration-date'),
              clockEnd: record.get('clock-end'),
              violatorText: record.get('violator-text')
            });
          });

          fetchNextPage();

          CrescendoArray.forEach(o => {            
            if (typeof crescendos[o.name] == 'undefined') {
              crescendos[o.name] = [];
            }

            crescendos[o.name].push(o);
          });
        },
        err => {
          if (err) {
            reject(err);
          }
          resolve(crescendos);
        }
      );   
  });


/****************************************
 * Download Airtable's Products tab
 ****************************************/
const getProducts = config =>
  new Promise((resolve, reject) => {
    console.log(`[${config.market}] Downloading PRODUCTS from Airtable..`)
    const base = new Airtable({ apiKey: config.key }).base( config.base )    
    const ProductsArray = [];

    base('PRODUCTS')
      .select(configObject)
      .eachPage(
        function page(records, fetchNextPage) {
          records.forEach(function(record) {
            ProductsArray.push({
              shortName: record.get('ShortName'),
              longName: record.get('LongName'),
              msrp: record.get('Msrp'),
              languages: record.get('Languages'),
              type: record.get('Type'),
              airtableId: record.id
            });
          });

          fetchNextPage();
         
        },
        err => {
          if (err) {
            reject(err);
          }
          resolve(ProductsArray);
        }
      );  
    });


 /****************************************
 * Download Airtable's Languages tab
 ****************************************/
const getLanguages = config =>
  new Promise((resolve, reject) => {

    console.log(`[${config.market}] Downloading LANGUAGES from Airtable..`)
    
    const base = new Airtable({ apiKey: config.key }).base(config.base);

    const LanguagesArray = [];

    base('LANGUAGES')
      .select(configObject)
      .eachPage((records, fetchNextPage) => {
          records.forEach(record => {
              return LanguagesArray.push({
                code: record.get('Code'),
                language: record.get('Language'),
                version: record.get('Version'),
                products: record.get('Products'),
                airtableId: record.id
              });
            });
          
          fetchNextPage();
        },
        function done(err) {
          if (err) {
            reject(err);
          }
          resolve(LanguagesArray);
        }
      );
  });


const replacePromoIdWithPromoName = (rsiArray, promoArray) => {
  const promosDict = {};
  for (let i = 0; i < promoArray.length; i++)
  {
    promosDict[promoArray[i].id] = promoArray[i].PromoNodeName;
  }
  
  rsiArray = rsiArray.map(rsi => {
    rsi.PromoNode = promosDict[rsi.PromoNode[0]];
    return rsi;
  });
  return rsiArray;
};



/**
 * These are the images  that get
 * changed with each campaign. If a new assets is introduced
 * to a page, just create it in the `Name` column in Airtable.
 * We devs won't have to do anything here to accomodate.
 * This has to be its own Airtable Base, not just a column
 * inside US base
 */

const getAssets = config => {
  return new Promise((resolve, reject) => {

    console.log('Getting SITEWIDE ASSETS from Airtable..')
    const base = new Airtable({ apiKey: config.key }).base(
      config.base
    );    

    const files = [];
    base('ASSETS')
      .select(configObject)
      .eachPage(
        (records, fetchNextPage) => {
          records.forEach(record => {
            files.push({
              name: record.get('Name'),
              file: record.get('File')
            });
          });
          fetchNextPage();
        },
        function done(err) {
          if (err) {
            console.error(err);
            reject(err);
          }
          resolve(files.filter(f => typeof f.file != 'undefined'));
        }
      );
  });
};

const AirtableHandler = config => {

  // If it's the 'assets' market, we dont pull RSI models, etc. Just
  // Get our sitewide assets (buynow.jpg, freedemo.jpg, etc)
  // and put sitewide assets in sitewide-promos directory
  if (config.market == 'assets')
  {
    getAssets(config).then(files => createSitewidePromoImages(files, config))
    return;
  }

  Promise.all([
    getRSI(config),
    getPromo(config),
    getPromoCodes(config),
    getCrescendo(config),
    getProducts(config),
    getLanguages(config)
  ])
  .then(([
    rsiArray,
    promoArray,
    PromoCodeObject,
    crescendosObject,
    productsArray,
    languagesArray
  ]) => {
      
    rsiArray = replacePromoIdWithPromoName(rsiArray, promoArray);
    rsiArray = replaceTimeFormatArray(rsiArray);

    let processProductArray = ProductArray[config.market];   
            
    promoArray = replacePromoCodeIdWithPromoCode(promoArray, PromoCodeObject, processProductArray);         
    
    
    
    

    console.log(productsArray[0])
    console.log('--- Languages Array:')
    console.log(languagesArray[0])

    // Each id in a product.languages array, is an airtableId in languagesArray[obj].airtableId
    for (let langObject of languagesArray)
    {
      var tmpLangObject = {
        code: null,
        language: null,
        version: null,
        products: {
          // subscription: []
          // dictionary: []
          //...
        }
      }

      // Puts product type into `tmpLangObject.products`
      for (let obj of productsArray)
      {
        if (!Object.keys(tmpLangObject.products).includes(obj.type))
        {
          tmpLangObject.products[obj.type] = []
        }
      }

      // it's a v3 lang
      if (typeof langObject.products == 'undefined')
      {
        break
      }
      
      for (let productId of langObject.products)
      {
        // find this productId in productsArray
        let productObj = productsArray.filter(o => o.airtableId == productId)[0]
        //console.log(productObj)
        //console.log(`type: ${productObj.code}`)
        tmpLangObject.products[productObj.type].push({
          name: productObj.shortName,
          msrp: productObj.msrp,
          type: productObj.type
          // longName: productObj.longName
        })
        tmpLangObject.code = langObject.code
        tmpLangObject.version = langObject.version
        // Each productId is an 'airtableId' in a langObject
      
      }
      langObject.products = tmpLangObject   
     
    }

    console.log(languagesArray)

    

    return


    
    
    /* languageaarray
     { code: 'vie',
    language: 'Vietnamese',
    version: '4',
    products:
     [ 'recHDYQV2kFZJ8PZK',
       'recJC4nv2LBursfKR',
       'recfhbC5sXBb7z9vv',
       'recL5I0DTM0XPvhH4',
       'rec0R5Rh1PVP48s2n',
       'recF5yqzajmzQMl97',
       'recxQHigXYhUAX16C',
       'recLxYYsOzTq3rH5k',
       'recpOfs418YONyqHD',
       'recqWBOp2iRCBwHSy' ],
    airtableId: 'reczrnLjfSZnBkwLi' }
    */
    //let langs = _.keyBy(languagesObject, 'type')
    // Language object holds lang info and products (product object)
    //console.log(langs)
    /*
    'chi': {
      language: 'Chinese',
      products: {
        subscription: {
          1: { sku: 123, msrp: 199},
          3: { sku: 123, msrp: 199}
        }
      }
        
      ]
    }
    */
    let prods = productsArray.map( prodObject => {

          
          for (let i = 0; i < prodObject.languages.length; i++)
          {
            let langId = prodObject.languages[i]
          
          
          //   console.log('----')
          // /prodNode[productName] = productsArray[ prodNode[productName] ]        
          }      
          return prodObject;      
      })        
    

    //console.log(prods)






    // Create our pages.json file
    createPagesFile(rsiArray, config);

    // Create our promos.json file
    createPromosFile(promoArray, config);

    // Create our products.json file
    //createProductsFile(productsObject, config)

      
    // We don't store SKUs and MSRPs in Airtable. We store in locally. 
    // In this repo's data/{market}/skus.json file.
    // Move it to  ../data-rsi/{market}/skus.json so the RSI parser can use it
    fs.copySync(`./data/${config.market}/skus.json`, `${config.dstpath}/models/json/skus.json`)

    // Create all our crescendo files
    Object.keys(crescendosObject)
      .forEach(k => createCrescendoFile(k, crescendosObject[k], config));

      // Get all masthead images
      if (typeof config.getImages != 'undefined' && config.getImages == 'yes')
      {
        console.log(`[${config.market}] Creating masthead images...`)
        for (let i = 0; i < rsiArray.length; i++)
        {
          createMastheadImages(rsiArray[i], config);
        }
      }
    })
    
    .catch(e => console.log(e) );
};

export default AirtableHandler;