Added item draft api (#130)

* v2.7.7

* 2.8.7

* added deprecation message and update readme

* fix item filter for diff sites

* revert commit

* fix lint

* added item draftapi

Author: pajaydev

src/constants.js

@@ -1,5 +1,10 @@
 'use strict';
 
+const body = {
+    grant_type: 'client_credentials',
+    scope: 'https://api.ebay.com/oauth/api_scope'
+};
+
 module.exports = {
     PROD_OAUTHENVIRONMENT_WEBENDPOINT: 'https://auth.ebay.com/oauth2/authorize',
     SANDBOX_OAUTHENVIRONMENT_WEBENDPOINT: 'https://auth.sandbox.ebay.com/oauth2/authorize',
@@ -8,5 +13,6 @@ module.exports = {
     SANDBOX_BASE_URL: 'api.sandbox.ebay.com',
     BASE_SVC_URL: 'svcs.ebay.com',
     BASE_SANDBX_SVC_URL: 'svcs.sandbox.ebay.com',
-    MERCH_SRVC_NAME: 'MerchandisingService'
+    MERCH_SRVC_NAME: 'MerchandisingService',
+    DEFAULT_BODY: body
 };

src/credentials.js

@@ -2,6 +2,7 @@
 const qs = require('querystring');
 const { base64Encode } = require('./common-utils');
 const { makeRequest } = require('./request');
+const { DEFAULT_BODY } = require('./constants');
 const DEFAULT_API_SCOPE = 'https://api.ebay.com/oauth/api_scope';
 
 /**
@@ -12,16 +13,20 @@ const DEFAULT_API_SCOPE = 'https://api.ebay.com/oauth/api_scope';
 const getAccessToken = function () {
     if (!this.options.clientID) throw new Error('Missing Client ID');
     if (!this.options.clientSecret) throw new Error('Missing Client Secret or Cert Id');
-    if (!this.options.body) throw new Error('Missing Body, required Grant type');
-    const scopesParam = this.options.body.scopes
-        ? Array.isArray(this.options.body.scopes)
-            ? this.options.body.scopes.join('%20')
-            : this.options.body.scopes
-        : DEFAULT_API_SCOPE;
-    this.options.data = qs.stringify({
-        grant_type: 'client_credentials',
-        scope: scopesParam
-    });
+    if (!this.options.body) {
+        this.options.body = qs.stringify(DEFAULT_BODY);
+    }
+    else {
+        const scopesParam = this.options.body.scopes
+            ? Array.isArray(this.options.body.scopes)
+                ? this.options.body.scopes.join('%20')
+                : this.options.body.scopes
+            : DEFAULT_API_SCOPE;
+        this.options.body = qs.stringify({
+            grant_type: 'client_credentials',
+            scope: scopesParam
+        });
+    }
     this.options.contentType = 'application/x-www-form-urlencoded';
     const self = this;
     const encodedStr = base64Encode(this.options.clientID + ':' + this.options.clientSecret);

src/index.js

@@ -1,11 +1,13 @@
 'use strict';
+const qs = require('querystring');
 const ebayBuyApi = require('./buy-api');
 const shoppingApi = require('./shopping');
 const taxonomyApi = require('./taxonomy-api');
 const ebayFindingApi = require('./finding');
 const dealsApi = require('./deals');
 const commonUtils = require('./common-utils');
 const merchandisingApi = require('./merchandising');
+const itemApi = require('./item');
 const {
     getAccessToken,
     getUserAuthorizationUrl,
@@ -70,7 +72,8 @@ Ebay.prototype = {
     ...ebayBuyApi,
     ...taxonomyApi,
     ...ebayFindingApi,
-    ...dealsApi
+    ...dealsApi,
+    ...itemApi
 };
 
 module.exports = Ebay;

src/item.js

@@ -0,0 +1,21 @@
+'use strict';
+
+const { makeRequest } = require('./request');
+
+const createItemDraft = function (itemData) {
+    if (!itemData) return new Error('INVALID_REQUEST_PARMS -> Required item data to create item draft');
+    if (!this.options.userAccessToken) return new Error('INVALID_REQUEST_PARMS -> Authorization user token is required');
+    const auth = 'Bearer ' + this.options.userAccessToken;
+    this.options.contentType = 'application/json';
+    this.options.body = JSON.stringify(itemData);
+    return makeRequest(this.options, '/sell/listing/v1_beta/item_draft/', 'POST', auth).then((result) => {
+        const resultJSON = JSON.parse(result);
+        return resultJSON;
+    }).catch((error) => {
+        return new Error(error);
+    });
+};
+
+module.exports = {
+    createItemDraft
+};

src/request.js

@@ -1,6 +1,5 @@
 'use strict';
 let httpRequest = require('https');
-const qs = require('querystring');
 
 const getRequest = (url) => {
     if (url.includes('http://')) httpRequest = require('http');
@@ -25,22 +24,17 @@ const getRequest = (url) => {
     }));
 };
 
-const makeRequest = function postRequest(self, endpoint, methodName, token) {
-    let dataString = '';
-    if (self.data) {
-        dataString = self.data;
-    }
-    else {
-        methodName === 'POST' ? dataString = qs.stringify(self.body) : '';
-    }
+function makeRequest(self, endpoint, methodName, token) {
+    const dataString = self.body ||  '';
     const options = {
         'hostname': self.baseUrl,
         'path': endpoint,
         'method': methodName || 'GET',
         'headers': {
             'content-type': self.contentType ? self.contentType : 'application/json',
-            'authorization': token,
+            'Authorization': token,
             'cache-control': 'no-cache',
+            'X-EBAY-C-MARKETPLACE-ID': 'EBAY_US',
             ...self.headers
         }
     };
@@ -50,23 +44,19 @@ const makeRequest = function postRequest(self, endpoint, methodName, token) {
             let body = '';
             res.on('data', (data) => {
                 body += data;
-                //console.log(body);
             });
             res.on('end', () => {
                 resolve(body);
-
             });
             res.on('error', (error) => {
                 reject(error);
-
             });
         });
         //console.log('request ' + dataString);
         if (methodName === 'POST') req.write(dataString);
         req.end();
     }));
-};
-
+}
 
 const base64Encode = (encodeData) => {
     const buff = Buffer.from(encodeData);