Merge pull request #42 from microsoftgraph/feature/js-sdk

- fixess #41: replaces http calls by js sdk

Author: baywet

.eslintrc.js

@@ -15,6 +15,7 @@ module.exports = {
     "no-param-reassign": 0,
     "no-use-before-define": 0,
     "linebreak-style": 0,
-    "no-plusplus": 0
+    "no-plusplus": 0,
+    "max-len": 0
   }
 };

helpers/requestHelper.js

@@ -1,100 +1,39 @@
-import https from 'https';
-
-const host = 'graph.microsoft.com';
-
-/**
- * Generates a POST request (of Content-type ```application/json```)
- * @param {string} path the path, relative to the host, to which this request will be sent
- * @param {string} token the access token with which the request should be authenticated
- * @param {string} data the data which will be 'POST'ed
- * @param {callback} callback
- */
-export function postData(path, token, data, callback) {
-  const options = {
-    host: host,
-    path: path,
-    method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: 'Bearer ' + token,
-      'Content-Length': data.length
-    }
-  };
-
-  const req = https.request(options, res => {
-    let subscriptionData = '';
-
-    res.on('data', chunk => { subscriptionData += chunk; });
-    res.on('end', () => {
-      if (res.statusCode === 201) callback(null, JSON.parse(subscriptionData));
-      else callback(JSON.parse(subscriptionData), null);
+import 'isomorphic-fetch';
+import * as MicrosoftGraph from '@microsoft/microsoft-graph-client';
+
+export class SubscriptionManagementService {
+  constructor(accessToken) {
+    this.accessToken = accessToken;
+    this.subscriptionPath = '/subscriptions';
+  }
+
+  getGraphClient() {
+    const client = MicrosoftGraph.Client.init({
+      authProvider: (done) => {
+        done(null, this.accessToken);
+      }
     });
-  });
-
-  req.write(data);
-  req.end();
-
-  req.on('error', error => callback(error, null));
-}
-
-/**
- * Generates a GET request (of Content-type ```application/json```)
- * @param {string} path the path, relative to the host, to which this request will be sent
- * @param {string} token the acess token with which the request should be authenticated
- * @param {callback} callback
- */
-export function getData(path, token, callback) {
-  const options = {
-    host: host,
-    path: path,
-    method: 'GET',
-    headers: {
+    return client;
+  }
+
+  async deleteSubscription(subscriptionId) {
+    const client = this.getGraphClient();
+    await client.api(`${this.subscriptionPath}/${subscriptionId}`).delete();
+  }
+
+  async createSubscription(subscriptionCreationInformation) {
+    const client = this.getGraphClient();
+    const subscription = await client.api(this.subscriptionPath).create(subscriptionCreationInformation);
+    return subscription;
+  }
+
+  async getData(path) {
+    const client = this.getGraphClient();
+    const result = await client.api(path).headers({
       'Content-Type': 'application/json',
       Accept: 'application/json;odata.metadata=minimal;'
-              + 'odata.streaming=true;IEEE754Compatible=false',
-      Authorization: 'Bearer ' + token
-    }
-  };
-
-  const req = https.request(options, res => {
-    let endpointData = '';
-
-    res.on('data', chunk => { endpointData += chunk; });
-    res.on('end', () => {
-      if (res.statusCode === 200) callback(null, JSON.parse(endpointData));
-      else callback(JSON.parse(endpointData), null);
-    });
-  });
-
-  req.write('');
-  req.end();
-
-  req.on('error', error => callback(error, null));
-}
-
-/**
- * Generates a DELETE request
- * @param {string} path the path, relative to the host, to which this request will be sent
- * @param {string} token the acess token with which the request should be authenticated
- * @param {callback} callback
- */
-export function deleteData(path, token, callback) {
-  const options = {
-    host: host,
-    path: path,
-    method: 'POST',
-    headers: {
-      'Content-Type': 'text/plain',
-      'X-HTTP-Method': 'DELETE',
-      Authorization: 'Bearer ' + token
-    }
-  };
-
-  const req = https.request(options, res => {
-    res.on('end', () => callback(null));
-  });
-
-  req.end();
-
-  req.on('error', error => callback(error));
+                + 'odata.streaming=true;IEEE754Compatible=false'
+    }).get();
+    return result;
+  }
 }