adding ability to query the purse api for a users open orders

Author: dylanbathurst

README.md

@@ -61,3 +61,21 @@ example:
 duffle --auth-token eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyasdllkflkasdflaslljfjlJ1c2VyX2lkIjo2NzYsInVzZXJuYW1lIjoiZHlsYW5iYXRodXJzdCIsImV4cCI6MTU1MzE5MzUwMiwiZW1haWwiOiJkeWxhbmJhdGh1cnN0QGdtYWlsLmNvbSIsInNkIjoiZ2Z4M081T0kiLCJyIjo.iNkd4cmFoRWYiLCJkcyI6ImZVM orders-info examples/files/orders.csv
 ```
 Your console output will show the number of successful and unsuccessful order info requests, as well as the order info for each order.
+
+
+## Open Orders
+To get a bulk set of open orders on Purse, run:
+
+```
+duffle --auth-token YOUR_PURSE_TOKEN open-orders
+```
+example:
+```
+duffle --auth-token eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyasdllkflkasdflaslljfjlJ1c2VyX2lkIjo2NzYsInVzZXJuYW1lIjoiZHlsYW5iYXRodXJzdCIsImV4cCI6MTU1MzE5MzUwMiwiZW1haWwiOiJkeWxhbmJhdGh1cnN0QGdtYWlsLmNvbSIsInNkIjoiZ2Z4M081T0kiLCJyIjo.iNkd4cmFoRWYiLCJkcyI6ImZVM orders-info examples/files/orders.csv
+```
+with options:
+```
+duffle --auth-token YOUR_PURSE_TOKEN --limit 100 --offset 0 open-orders
+```
+run `duffle open-orders -h` for more options
+Your console output will show the number of successful open orders, as well as the order info for each order.

bin/duffle

@@ -125,4 +125,31 @@ program
     console.log(`${JSON.stringify(bulkInfo.failedOrders)}`);
   });
 
+program
+  .command('open-orders')
+  .description('Gets a bulk list of open orders')
+  .option('-l, --limit [limit]', 'The number of orders to request', 100)
+  .option('-o, --offset [offset]', 'The number of orders to offset by', 0)
+  .option('-i, --inactive [inactive]', 'The active or inactive state', false)
+  .option('-s, --sort [sort]', 'The field to sort the list by', 'created')
+  .option('-S, --search [search]', 'Search applied to order query', false)
+  .action(async (options) => {
+    let Api;
+    try {
+      Api = new apiRequest(options.parent.authToken);
+    } catch (e) {
+      console.log('*********************');
+      console.log(e.message);
+      console.log('*********************');
+      return;
+    }
+    const { limit, offset, inactive, sort, search } = options;
+    Api.openOrderQS = { limit, offset, inactive, sort, search };
+    const openOrders = await Api.getBulkOpenOrders();
+    console.log(`${openOrders.successfulOrders.length} successful orders:`);
+    console.log(`${JSON.stringify(openOrders.successfulOrders)}`);
+    console.log(`${openOrders.failedOrders.length} failed orders:`);
+    console.log(`${JSON.stringify(openOrders.failedOrders)}`);
+  });
+
 program.parse(process.argv);

lib/api.js

@@ -16,8 +16,9 @@ class apiRequest {
     this.modifyOrder = this.modifyOrder.bind(this);
     this.cancelOrder = this.cancelOrder.bind(this);
     this.getOrderInfo = this.getOrderInfo.bind(this);
+    this.getOpenOrders = this.getOpenOrders.bind(this);
   }
-  async bulkChange(bulkMethod, orders) {
+  async bulkChange(bulkMethod, orders = []) {
     const successfulOrders = [];
     const failedOrders = [];
 
@@ -45,6 +46,9 @@ class apiRequest {
   async getBulkInfo(orders) {
     return this.bulkChange(this.getOrderInfo, orders);
   }
+  async getBulkOpenOrders(params) {
+    return this.bulkChange(this.getOpenOrders, [{}]);
+  }
 
   async createOrder(order) {
     const validOrder = this.buildCreateOrder(order);
@@ -142,10 +146,8 @@ class apiRequest {
 
       let cancelRequest;
       try {
-        console.log(opts)
         cancelRequest = await request(opts);
       } catch (e) {
-        console.log(e)
         order.success = false;
         order.errorMessage = e.message;
         return order;
@@ -181,10 +183,8 @@ class apiRequest {
 
       let infoRequest;
       try {
-        console.log(opts)
         infoRequest = await request(opts);
       } catch (e) {
-        console.log(e)
         order.success = false;
         order.errorMessage = e.message;
         return order;
@@ -201,6 +201,37 @@ class apiRequest {
       }
     }
   }
+  async getOpenOrders(order) {
+    const opts = {
+      method: 'GET',
+      uri: `${this.apiUrl}/orders/me/active`,
+      qs: this.openOrderQS,
+      resolveWithFullResponse: true,
+      headers: { 
+        Authorization: `JWT ${this.jwt}`,
+        Origin: 'duffle://'
+      },
+    };
+
+    let infoRequest;
+    try {
+      infoRequest = await request(opts);
+    } catch (e) {
+      order.success = false;
+      order.errorMessage = e.message;
+      return order;
+    }
+    
+    if (infoRequest.statusCode !== 200) {
+      order.success = false;
+      order.errorMessage = infoRequest.body;
+      return order;
+    } else {
+      order.success = true;
+      order.body = JSON.parse(infoRequest.body);
+      return order;
+    }
+  }
 
   buildCreateOrder(order) {
     const { asin, quantity, discount, full_name, street1,