nodefetch_tmporders.js

const fetch = require('node-fetch');
const utils = require('ethers').utils;
const sha256 = require('js-sha256');
//const sleep = require('sleep')

// Load the AWS SDK for Node.js
var AWS = require('aws-sdk');
// Set the region 
AWS.config.update({region: 'us-east-1'});

// Create an SQS service object
var sqs = new AWS.SQS({apiVersion: '2012-11-05'});

const { Client } = require('pg');

var sleep = require('sleep');

getorderid()

async function getorderid(){
  //var latestOrderId = await getLastOrderId();
  //latestOrderId = 
  //console.log("latestOrderId: "+JSON.stringify(latestOrderId));

  //var fetchUrl = 'https://00000000000000000000000000000000:11111111111111111111111111111111@luxarity-test.myshopify.com/admin/orders.json?since_id='+latestOrderId;
  var fetchUrl = 'https://00000000000000000000000000000000:11111111111111111111111111111111@luxarity-popup-2016.myshopify.com/admin/orders.json?since_ids=776273756203';
  
  console.log("fetchUrl : "+fetchUrl)
fetch(fetchUrl)
    .then(res => res.json())
    .then(json => {

        console.log("looping through orders")
      for(var i = 0; i < json.orders.length; i++){

            if(!(json.orders[i].id && json.orders[i].total_price && json.orders[i].order_number && json.orders[i].customer)){
                //place holder for std out - possibly dlq
                console.log("order missing attributes: "+json.orders[i].id+" loop number: "+i)
            }else{
                console.log("send this order id to sqs queue: "+json.orders[i].id + " "+json.orders[i].customer.email)


                var redemptionPin = json.orders[i].id.toString()+json.orders[i].order_number.toString();
                console.log("redemptionPin: "+redemptionPin)
                var redemptionPin256reg = sha256(redemptionPin)
                console.log("redemptionPin256reg: "+redemptionPin256reg)
                var redemptionPin256 = redemptionPin256reg.toUpperCase()

                
                var customerEmail256reg = sha256(json.orders[i].customer.email)
                var customerEmail256 = customerEmail256reg.toUpperCase()

                var ipfsURL = 'ipfs_not_generated';
                
                try{
                 //sendsqs(ipfsURL, json.orders[i].id, json.orders[i].total_price, json.orders[i].order_number, customerEmail256, json.orders[i].customer.email, redemptionPin256);
                  doinsertTmpOrder(ipfsURL, json.orders[i].id, json.orders[i].total_price, json.orders[i].order_number, customerEmail256, json.orders[i].customer.email, redemptionPin256)
                  console.log("sent insert to db: "+json.orders[i].id)
                  //console.log("sleep 1 second")
                  //sleep.sleep(1)

                }catch(err){
                    console.log("err for "+json.orders[i].id+" "+err)
                }

            }

        
      }
      
    })

    //sleep.sleep(15)
}

async function getLastOrderId() {

  console.log("inside getLastOrderId : ");



  const client = new Client({
      host     : "luxarity.cijmyc3a39cj.us-east-1.rds.amazonaws.com",
      database     : "lux",
      user : "b4siga",
      password : "Social1mp4ct",
      port     : "5432"
    })

  const query = {
    name: 'getLastOrderId',
    text: "select max(orderid) from orders",
    values: []
  }

    try {
      console.log("inside client.connect try");
        await client.connect();
        const res = await client.query(query);
        if(res.rows === undefined || res.rows.length == 0){
          throw new Error('no rows returned');
        }else{
          console.log("res.rows: "+res.rows)
          return res.rows[0].max;
        }
      } catch (e) {
        throw e;
      } finally {
        await client.end();
      }

  };

  async function doinsertTmpOrder(ipfsURL, orderid, total_price, order_number, customerEmail256, customeremail, redemptionPin256){
    await insertTmpOrder(ipfsURL, orderid, total_price, order_number, customerEmail256, customeremail, redemptionPin256)
    console.log("done insertTmpOrder: "+orderid)
  }

  async function insertTmpOrder(ipfsURL, orderid, total_price, order_number, customerEmail256, customeremail, redemptionPin256) {

  console.log("inside insertTmpOrder : ");



  const client = new Client({
      host     : "luxarity.cijmyc3a39cj.us-east-1.rds.amazonaws.com",
      database     : "lux",
      user : "b4siga",
      password : "Social1mp4ct",
      port     : "5432"
    })

  const query = {
    name: 'insertTmpOrder',
    text: "insert into tmp_orders_copy (tokenuri, orderid, totalcost, ordernumber, customeremail256, customeremail, redemptionhash ) VALUES ($1,$2,$3,$4,$5,$6,$7)",
    values: [ipfsURL, orderid, total_price, order_number, customerEmail256, customeremail, redemptionPin256]
  }

    try {
      console.log("inside client.connect try");
        await client.connect();
        const res = await client.query(query);
        if(res.rows === undefined || res.rows.length == 0){
          //throw new Error('no rows returned');
        }else{
          console.log("res.rows: "+res.rows)
          return res.rows[0].max;
        }
      } catch (e) {
        throw e;
      } finally {
        await client.end();
      }

  };




//add regular customer_email
async function sendsqs(tokenUri, orderid, total_price, order_number, customer_email_sha256, customerEmail, redemption_pin_sha256){
  var params = {
     DelaySeconds: 10,
     MessageAttributes: {
      "LuxarityOrder": {
        DataType: "String",
        StringValue: "Individual Lux Order for SoldOrderToMint endpoint"
       }
     },
     //MessageBody: "{ \"orderid\" : \""+orderid+"\" , \"total_price\" : \""+total_price+"\" , \"order_number\" : \""+order_number+"\" , \"customer_email\" : \""+customer_email+"\"}",
     MessageBody: "{ \"tokenURI\" : \""+tokenUri+"\", \"totalPrice\" : "+total_price+", \"customerEmailSHA256\" : \""+customer_email_sha256+"\", \"customerEmail\" : \""+customerEmail+"\" , \"orderId\" : "+orderid+", \"orderNumber\" : "+order_number+", \"redemptionPinSHA256\" : \""+redemption_pin_sha256+"\",  \"blockchain\" : \"Rinkeby\" }",
     //QueueUrl: "https://sqs.us-east-1.amazonaws.com/711302153787/luxarity-orders"
     //QueueUrl: "https://sqs.us-east-1.amazonaws.com/711302153787/lux-ebs-test"
     //QueueUrl: "https://sqs.us-east-1.amazonaws.com/711302153787/luxarity-orders"
     //QueueUrl: "https://sqs.us-west-1.amazonaws.com/711302153787/SQS_QUEUE_NAME"
    };

        console.log("message body: "+params.MessageBody)
    await sqs.sendMessage(params, function(err, data) {
      if (err) {
        console.log("Error", err);
      } else {
        console.log("Success", data.MessageId);
      }
    });
}