tabbit

Tue Apr 17 2018
Copied to clipboard! Copy reply
import Airtable from 'airtable';
import createPromosFile from '../createPromosFile';
import createPagesFile from '../createPagesFile';
import getSKUFile from '../getSKUFile';
import createCrescendoFile from '../createCrescendoFile';
import { replaceTimeFormatArray } from '../replaceTimeFormat';
import replacePromoCodeIdWithPromoCode from '../replacePromoCodeIdWithPromoCode';
import ProductArray from '../Util/ProductArray';
import { HomschoolProductArray } from '../Util/ProductArray';
import { createImages, createSitewidePromoImages } from '../FileHandler';

const configObject = { view: 'Grid view' };

const getRSI = dataSourceStrategy =>
  new Promise((resolve, reject) => {
    console.log('getRSI key', dataSourceStrategy.key);
    console.log('getRSI base', dataSourceStrategy.base);

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

    base('RSI')
      .select(configObject)
      .eachPage(
        function page(records, fetchNextPage) {
          records.forEach(function(record) {
            RSIArray.push({
              RSI: 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'),
              ProductFilter: record.get('ProductFilter')
            });
          });

          fetchNextPage();
        },
        function done(err) {
          if (err) {
            console.error(err);
            reject(err);
          }
          resolve(RSIArray);
        }
      );
  });

const getPromo = dataSourceStrategy =>
  new Promise((resolve, reject) => {
    const PromoArray = [];
    const base = new Airtable({ apiKey: dataSourceStrategy.key }).base(
      dataSourceStrategy.base
    );

    base('PROMO')
      .select(configObject)
      .eachPage(
        function page(records, fetchNextPage) {
          records.forEach(record => {
            var tempObject = {};
            let processProductArray;

            if (dataSourceStrategy.filepath.match(/homeschool/))
              processProductArray = HomschoolProductArray;
            else processProductArray = ProductArray;

            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);
        }
      );
  });

const getPromoCodes = dataSourceStrategy =>
  new Promise((resolve, reject) => {
    const PromoCodeObject = {};
    const base = new Airtable({ apiKey: dataSourceStrategy.key }).base(
      dataSourceStrategy.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);
        }
      );
  });

const getCrescendo = dataSourceStrategy =>
  new Promise((resolve, reject) => {
    const base = new Airtable({ apiKey: dataSourceStrategy.key }).base(
      dataSourceStrategy.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);
        }
      );
  });

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;
};

const getAllImages = (rsiArray, dataSourceStrategy) => {
  for (let i = 0; i < rsiArray.length; i++) {
    createImages(rsiArray[i], dataSourceStrategy);
  }
};

/**
 * These are the images & criteo feed that get
 * changed with each campaign. If a new assets is introduced
 * to a page, just create it in the `Name` column. Us devs
 * won't have to do anything to accomodate.
 */

const getAssets = dataSourceStrategy => {
  new Promise((resolve, reject) => {
    
    const base = await new Airtable({ apiKey: dataSourceStrategy.key }).base(
      dataSourceStrategy.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 = async dataSourceStrategy => {
  // If it's the 'assets' market, we dont pull RSI models, etc.
  if (dataSourceStrategy.market == 'assets') {
    // Put sitewide assets in sitewide-promos directory
    const assets = await getAssets(dataSourceStrategy);
    createSitewidePromoImages(assets, dataSourceStrategy);
    return;
  }

  Promise.all([
    getRSI(dataSourceStrategy),
    getPromo(dataSourceStrategy),
    getPromoCodes(dataSourceStrategy),
    getCrescendo(dataSourceStrategy),
    getAssets(dataSourceStrategy)
  ])
    .then(async ([rsiArray, promoArray, PromoCodeObject, crescendosObject, getAssets]) => {
      rsiArray = replacePromoIdWithPromoName(rsiArray, promoArray);
      rsiArray = replaceTimeFormatArray(rsiArray);

      let processProductArray;
      
      

      if (dataSourceStrategy.filepath.match(/homeschool/)) {
        processProductArray = HomschoolProductArray;
      } else {
        processProductArray = ProductArray;
      }

      promoArray = replacePromoCodeIdWithPromoCode(
        promoArray,
        PromoCodeObject,
        processProductArray
      );

      createPagesFile(rsiArray, dataSourceStrategy);
      createPromosFile(promoArray, dataSourceStrategy);
      getSKUFile(dataSourceStrategy);

      Object.keys(crescendosObject).forEach(k => {
        createCrescendoFile(k, crescendosObject[k], dataSourceStrategy);
      });

      if (
        typeof dataSourceStrategy.getImages != 'undefined' &&
        dataSourceStrategy.getImages == 'yes'
      ) {
        getAllImages(rsiArray, dataSourceStrategy);
      }
    })
    .catch(e => {
      console.log(e);
    });
};

export default AirtableHandler;