nodefetch.js

const fetch = require('node-fetch');
const utils = require('ethers').utils;

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

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

const IPFS = require('ipfs');
const fs = require('file-system');


/*fetch('https://00000000000000000000000000000000:11111111111111111111111111111111@luxarity-test.myshopify.com/admin/orders.json')
    .then(res => res.json())
    .then(json => {

        console.log(json.orders.length)
    	for(var i = 0; i < json.orders.length; i++){
            console.log("###LOOP NUMBER "+i+"###")
            //console.log("id: "+json.orders[i].id)
            //console.log("order_number: "+json.orders[i].order_number)
            //console.log("total price: "+json.orders[i].total_price)
            //console.log("email: "+json.orders[i].email)
            //console.log("fulfillment_status: "+json.orders[i].fulfillment_status)
    		//console.log("lineitems: "+json.orders[i].line_items[0].title)
            if(json.orders[i].customer){
            //console.log("cust: "+JSON.stringify(json.orders[i].customer.email))
            console.log("cust: "+json.orders[i].customer.email)
            }
        
   		   //console.log(json)
    	}
    	
    }
    );*/


//GET /admin/orders.json?since_id=667062206575
//'https://00000000000000000000000000000000:11111111111111111111111111111111@luxarity-test.myshopify.com/admin/orders.json'
//GET /admin/orders.json?ids=671314968687
//https://00000000000000000000000000000000:11111111111111111111111111111111@luxarity-test.myshopify.com/admin/orders.json?ids=667073937519

fetch('https://00000000000000000000000000000000:11111111111111111111111111111111@luxarity-test.myshopify.com/admin/orders.json?since_id=667062206575')
    .then(res => res.json())
    .then(json => {

        console.log("looping through orders")
    	for(var i = 0; i < json.orders.length; i++){
            
            //var order = [];
            //orderid
            //customer.email
            //total_price
            //order_number
            /*if(json.orders[i].customer){
            console.log(json.orders[i].customer.email)
            }else{
                 console.log(json.orders[i].id)
            }*/

            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)
                try{

                //console.log("orderId: "+json.orders[i].id);
                //console.log("orderNumber: "+json.orders[i].order_number);
                
                ////var redemptionPin = json.orders[i].id.toString()+json.orders[i].order_number.toString();
                
                //console.log("remptionPin: "+redemptionPin);
                
                ////var redemptionPin256 = utils.solidityKeccak256(['string'], [redemptionPin])
                ////var customerEmail256 = utils.solidityKeccak256(['string'], [json.orders[i].customer.email])
                
                //console.log("redemptionPin256: "+redemptionPin256)
                //console.log("customerEmail256: "+customerEmail256)
                //json.orders[i].customer.email

                //sendsqs(json.orders[i].id, json.orders[i].total_price, json.orders[i].order_number, customerEmail256, redemptionPin256)
                try{
                console.log("sendIpfs before");
                sendIpfs(json.orders[i].customer.email, json.orders[i].id, json.orders[i].total_price, json.orders[i].order_number);
                console.log("sendIpfs after");
                }catch(err){
                    throw new Error(err)
                }
                //console.log("ihash: "+ihash);

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

            }

    		
    	}
    	
    }
    );

//add regular customer_email
async function sendsqs(tokenUri, orderid, total_price, order_number, customer_email_sha256, 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+"\", \"orderId\" : "+orderid+", \"orderNumber\" : "+order_number+", \"redemptionPinSHA256\" : \""+redemption_pin_sha256+"\",  \"blockchain\" : \"Rinkeby\" }",
     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);
		  }
		});
}

async function sendIpfs(buyerId, orderId, totalPrice, orderNumber){
    //create IPFS file and link
    let orderMetaData = {
      "buyerId": buyerId,
      "orderId": orderId,
      "orderAmount": totalPrice,
      "vendor": 'Luxarity',
      "dateOfSale": new Date(),
    };
    let orderMdString = JSON.stringify(orderMetaData);
    //let mdHash = sha256(orderMdString);
    let mdHash = utils.solidityKeccak256(['string'], [orderMdString])
    fs.writeFile(mdHash + ".json", orderMdString);

    console.log("Waiting for IPFS URL to be generated.");
    //setting up IPFS node
    let ipfsHash;
    const node = new IPFS();
    await node.on('ready', async () => {
      const version = await node.version()

      console.log('Version:', version.version);

      const filesAdded = await node.files.add({
        path: mdHash + ".json",
        content: Buffer.from(orderMdString)
      });

      console.log('Added file:', filesAdded[0].path, filesAdded[0].hash);
      ipfsHash = filesAdded[0].hash;

      const fileBuffer = await node.files.cat(filesAdded[0].hash);

      console.log('Added file contents:', fileBuffer.toString());

      let ipfsURL = "https://ipfs.io/ipfs/" + ipfsHash;
      console.log("ipfsURL: "+ipfsURL)
      node.stop(() => {
            console.log("node is now offline")
        })
      //return ipfsURL;

      var redemptionPin = orderId.toString()+orderNumber.toString();
      //console.log("remptionPin: "+redemptionPin);
      var redemptionPin256 = utils.solidityKeccak256(['string'], [redemptionPin])
      var customerEmail256 = utils.solidityKeccak256(['string'], [buyerId])

      await sendsqs(ipfsURL, orderId, totalPrice, orderNumber, customerEmail256, redemptionPin256);
      console.log("done");

    });
}


//'{"name" : "Jane Smith", "email" : "jsmith@gmail.com", "password" : "anothergoodpw"}'



//https://www.npmjs.com/package/node-fetch

/*fetch('https://00000000000000000000000000000000:11111111111111111111111111111111@luxarity-test.myshopify.com/admin/orders.json')
    .then(res => res.text())
    .then(body => console.log(body));*/

/*fetch('https://00000000000000000000000000000000:11111111111111111111111111111111@luxarity-test.myshopify.com/admin/orders.json')
    .then(res => res.json())
    .then(json => console.log(json));*/


//id
//total_price
//order_number