feat: stream data from request

* Fix: add super agent stream
* Fix: add units api
* Fix: move stream to options
* Fix: move stream to options
* Fix: change response and deadline

Author: jasondu168

lib/Auth/index.js

@@ -168,7 +168,8 @@ class Auth {
         cache: false,
         response: 60000,
         deadline: 90000,
-        error: {}
+        error: {},
+        stream: false
       },
       opts
     );
@@ -204,15 +205,20 @@ class Auth {
           opts.headers.authorization = `Bearer ${clientToken}`;
         }
 
-        begin = new Date().getTime();
-        ({ status, body } = await superagent(method, url)
+        const req = superagent(method, url)
           .set(opts.headers)
           .timeout({
             response: opts.response,
             deadline: opts.deadline
           })
-          .query(opts.query)
-          .send(opts.payload));
+          .query(opts.query);
+
+        if (opts.stream) {
+          return req.send(opts.payload).pipe(opts.stream);
+        }
+
+        begin = new Date().getTime();
+        ({ status, body } = await req.send(opts.payload));
 
         if (
           this.isCacheEnabled &&

lib/Services/delorean-es.js

@@ -106,6 +106,35 @@ class DeloreanES {
     return this.auth.send(this.service, 'GET', url, { query });
   }
 
+  /**
+   * @param {String}  userId
+   * @param {String}  deviceId
+   * @param {Object}  query
+   */
+  getUnits(userId, deviceId, query) {
+    const url = `${this.url}/devices/${deviceId}/readings/units`;
+    query = { ...query, user_id: userId };
+    return this.auth.send(this.service, 'GET', url, { query });
+  }
+
+  /**
+   * @param {String}  userId
+   * @param {String}  deviceId
+   * @param {Object}  query
+   * @param {Object}  stream
+   */
+  getDeviceReportStream(userId, deviceId, query, stream) {
+    const url = `${this.url}/devices/${deviceId}/stream/report`;
+    query = { ...query, user_id: userId };
+
+    return this.auth.send(this.service, 'GET', url, {
+      query,
+      stream,
+      response: 90000 * 3,
+      timeout: 90000 * 3
+    });
+  }
+
   /**
    * @param {String}  userId
    * @param {String}  deviceId