initial commit

Author: dylanbathurst

.gitignore

@@ -0,0 +1 @@
+node_modules/

README.md

@@ -0,0 +1,40 @@
+# Duffle 
+Bulk order management for Purse.io
+
+## Requirements
+- nodejs
+- npm
+- git
+
+## Getting Started
+- `git clone [email protected]:dylanbathurst/duffle.git`
+- `cd duffle`
+- `npm install`
+- `npm link`
+- `duffle -h`
+
+## Authentication
+1. Log in to your account on [Purse.io](https://purse.io/)
+1. In your browser's web inspector, look for the `purse_token` cookie and copy the contents. ![purse token in web inspector](./examples/images/purse_token.png)
+1. This token will used on the command line when using duffle. 
+
+## Creating Orders
+To create a bulk set of orders on Purse, create a `.csv` file and format it exactly like <a href="./examples/files/create.csv">this file</a> in the examples directory. Then run:
+```
+duffle --auth-token YOUR_PURSE_TOKEN create-orders /PATH/TO/YOUR/CSV/FILE.csv
+```
+example:
+```
+duffle --auth-token eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyasdllkflkasdflaslljfjlJ1c2VyX2lkIjo2NzYsInVzZXJuYW1lIjoiZHlsYW5iYXRodXJzdCIsImV4cCI6MTU1MzE5MzUwMiwiZW1haWwiOiJkeWxhbmJhdGh1cnN0QGdtYWlsLmNvbSIsInNkIjoiZ2Z4M081T0kiLCJyIjo.iNkd4cmFoRWYiLCJkcyI6ImZVM create-orders examples/files/create.csv
+```
+
+## Modify Orders
+To modify a bulk set of orders on Purse, create a `.csv` file and format it exactly like <a href="./examples/files/modify.csv">this file</a> in the examples directory. Then run:
+```
+duffle --auth-token YOUR_PURSE_TOKEN modify-orders /PATH/TO/YOUR/CSV/FILE.csv
+```
+example:
+```
+duffle --auth-token eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyasdllkflkasdflaslljfjlJ1c2VyX2lkIjo2NzYsInVzZXJuYW1lIjoiZHlsYW5iYXRodXJzdCIsImV4cCI6MTU1MzE5MzUwMiwiZW1haWwiOiJkeWxhbmJhdGh1cnN0QGdtYWlsLmNvbSIsInNkIjoiZ2Z4M081T0kiLCJyIjo.iNkd4cmFoRWYiLCJkcyI6ImZVM modify-orders examples/files/modify.csv
+```
+Your console output will show the number of successful and unsuccessfully created orders, as well as the response text for each order.

bin/duffle

@@ -0,0 +1,75 @@
+#!/usr/bin/env node
+
+'use strict';
+
+const program = require('commander');
+const parseCSV = require('../lib/parseCSV');
+const apiRequest = require('../lib/api');
+
+const initApi = (jwt) => {
+  
+};
+
+program
+  .version('0.0.1')
+  .option('-a, --auth-token <jwt>', 'Your Purse JWT Auth Token');
+  
+program
+  .command('create-orders <path>')
+  .description('Creates a bulk list of orders from a CSV file')
+  .action(async (path, options) => {
+    let Api;
+    try {
+      Api = new apiRequest(options.parent.authToken);
+    } catch (e) {
+      console.log('*********************');
+      console.log(e.message);
+      console.log('*********************');
+      return;
+    }
+    let parsedFile;
+    try {
+      parsedFile = await parseCSV(path);
+    } catch (e) {
+      console.log(e);
+      return;
+    }
+    const bulkOrders = await Api.createBulkOrders(parsedFile);
+    console.log(`${bulkOrders.successfulOrders.length} successful orders:`);
+    console.log(`${JSON.stringify(bulkOrders.successfulOrders)}`);
+    console.log(`${bulkOrders.failedOrders.length} failed orders:`);
+    console.log(`${JSON.stringify(bulkOrders.failedOrders)}`);
+  });
+  
+program
+  .command('modify-orders <path>')
+  .description('Modifies a bulk list of orders from a CSV file')
+  .action(async (path, options) => {
+    let Api;
+    try {
+      Api = new apiRequest(options.parent.authToken);
+    } catch (e) {
+      console.log('*********************');
+      console.log(e.message);
+      console.log('*********************');
+      return;
+    }
+    let parsedFile;
+    try {
+      parsedFile = await parseCSV(path);
+    } catch (e) {
+      console.log(e);
+      return;
+    }
+    const bulkModify = await Api.modifyBulkOrders(parsedFile);
+    console.log(`${bulkModify.successfulOrders.length} successful orders:`);
+    console.log(`${JSON.stringify(bulkModify.successfulOrders)}`);
+    console.log(`${bulkModify.failedOrders.length} failed orders:`);
+    console.log(`${JSON.stringify(bulkModify.failedOrders)}`);
+  });
+  
+program
+  .command('cancel-orders <path>')
+  .description('Cancels a bulk list of orders from a CSV file');
+  
+program.parse(process.argv);

examples/files/create.csv

@@ -0,0 +1,2 @@
+asin,quantity,discount,full_name,street1,street2,city,state,zip,country,phone
+B016QO5YNG,1,0.15,Bob Smith,Some St,,San Francisco,CA,94000,US,1234567890

examples/files/modify.csv

@@ -0,0 +1,2 @@
+id,discount,shipping_cost
+SP-PFTU2FQK,0.10,0

examples/images/purse_token.png

@@ -0,0 +1,147 @@
+const request = require('request-promise-native');
+const NODE_ENV = process.env.NODE_ENV || 'production';
+
+class apiRequest {
+  constructor(jwt) {
+    if (!jwt) {
+      throw new Error('You must provide a valid Purse Auth Token.');
+    }
+    this.jwt = jwt;
+    if (NODE_ENV === 'production') {
+      this.apiUrl = 'https://api.purse.io/api/v1'
+    } else {
+      this.apiUrl = 'https://master.api.dev.purse.io/api/v1'
+    }
+    this.createOrder = this.createOrder.bind(this);
+    this.modifyOrder = this.modifyOrder.bind(this);
+  }
+  async bulkChange(bulkMethod, orders) {
+    const successfulOrders = [];
+    const failedOrders = [];
+    
+    for (let order of orders) {
+      const orderReq = await bulkMethod(order);
+      if (orderReq.success) {
+        successfulOrders.push(orderReq);
+      } else {
+        failedOrders.push(orderReq);
+      }
+    }
+    
+    return { successfulOrders, failedOrders };
+  }
+  
+  async createBulkOrders(orders) {
+    return this.bulkChange(this.createOrder, orders);
+  }
+  async modifyBulkOrders(orders) {
+    return this.bulkChange(this.modifyOrder, orders);
+  }
+  async createOrder(order) {
+    const validOrder = this.buildNYDOrder(order);
+    
+    if (!validOrder) {
+      order.success = false;
+      order.errorMessage = 'This was not a valid order';
+      return order;
+    } else {
+      const opts = {
+        method: 'POST',
+        uri: `${this.apiUrl}/orders/instant`,
+        resolveWithFullResponse: true,
+        headers: { Authorization: `JWT ${this.jwt}` },
+        json: validOrder
+      };
+
+      let orderRequest;
+      try {
+        orderRequest = await request(opts);
+      } catch (e) {
+        order.success = false;
+        order.errorMessage = e.message;
+        return order;
+      }
+
+      if (orderRequest.statusCode !== 200) {
+        order.success = false;
+        order.errorMessage = orderRequest.body;
+        return order;
+      } else {
+        order.success = true;
+        order.body = orderRequest.body;
+        return order;
+      }
+    }
+  }
+  async modifyOrder(order) {
+    const validModifiedOrder = this.buildModifiedOrder(order);
+    
+    if (!validModifiedOrder) {
+      order.success = false;
+      order.errorMessage = 'This was not a valid modified order';
+    } else {
+      const opts = {
+        method: 'PATCH',
+        uri: `${this.apiUrl}/orders/${order.id}`,
+        resolveWithFullResponse: true,
+        headers: { Authorization: `JWT ${this.jwt}` },
+        json: validModifiedOrder
+      };
+
+      let modifyRequest;
+      try {
+        modifyRequest = await request(opts);
+      } catch (e) {
+        order.success = false;
+        order.errorMessage = e.message;
+        return order;
+      }
+
+      if (modifyRequest.statusCode !== 200) {
+        order.success = false;
+        order.errorMessage = modifyRequest.body;
+        return order;
+      } else {
+        order.success = true;
+        order.body = modifyRequest.body;
+        return order;
+      }
+    }
+  }
+  buildNYDOrder(order) {
+    const { asin, quantity, discount, full_name, street1,
+            street2, city, state, zip, country, phone } = order;
+    if (!asin || !quantity || !discount || !full_name || 
+        !street1 || !city || !state || !zip || !country || !phone ) {
+      return false;
+    }
+    
+    const orderModel = {
+      coin: 'BTC',
+      discount: parseFloat(discount),
+      country,
+      shipping_cost: 0,
+      service: {
+        type: 'instant',
+        items: [{
+          asin, quantity
+        }],
+        shipping_address: {
+          full_name, street1, street2, city, state, zip, country, phone
+        } 
+      }
+    };
+    return orderModel;
+  }
+  buildModifiedOrder(order) {
+    let { discount, shipping_cost } = order;
+    
+    const modifyModel = {
+      discount,
+      shipping_cost
+    };
+    return modifyModel;
+  }
+}
+
+module.exports = apiRequest;

lib/api.js

@@ -0,0 +1,26 @@
+const csvParse = require('csv-parse');
+const fs = require('fs');
+
+const parser = (filePath) => {
+  const parsedFile = [];
+  return new Promise((resolve, reject) => {
+    const parser = csvParse({
+      skip_empty_lines: true,
+      columns: true
+    });
+
+    fs.createReadStream(filePath)
+      .pipe(parser)
+      .on('data', (row) => {
+          parsedFile.push(row);
+      })
+      .on('end', () => {
+        resolve(parsedFile);
+      })
+      .on('error', (err) => {
+        reject(err);
+      })
+  });
+};
+
+module.exports = parser;

lib/parseCSV.js

@@ -0,0 +1,5 @@
+const createBulk = require('./createBulk');
+const modifyBulk = require('./modifyBulk');
+const cancelBulk = require('./cancelBulk');
+
+module.exports = { createBulk, modifyBulk, cancelBulk };