| 1 | "use strict";var e=require("bluebird"),r=e.promisify,t=require("path"),o=require("./files"),n=require("./progress"),s=require("adm-zip"),i=r(require("request")),a=require("lodash"),d=require("fs"),u=config.API_BASEPATH;const c=require("./../utils/messagehandler").messagesHandler;var p={Accept:"application/json","Content-Type":"application/json"},l=module.exports={};function y(r,t){return new e((e,o)=>{try{var n=d.readFileSync(t)}catch(e){o(e)}i({url:r,method:"PUT",body:n},function(r,t,n){if(r)return process.stdout.write("[?25h"),o("Ugh!! We couldn't upload connector due to slow internet connection :(");t&&200==t.statusCode?e(!0):o(!1)})})}l.makeApiCall=function(r,t){if(r){var o={url:t.url||u+r,method:t.method||"GET",json:!0,body:t.body?t.body:{},headers:t.headers?a.extend(p,t.headers):p};return i(o).then(r=>r.statusCode>=200&&r.statusCode<=399?e.resolve(r):r.body.error?e.reject(r.body.error):r.body.statusText?e.reject(r.body.statusText):e.reject(r.body)).catch(r=>r.error?e.reject(r.error):r.statusText?e.reject(r.statusText+" "+r.errors.map(e=>e.messages.join(" ")).join(" ")):e.reject(r))}Console.error("Endpoint path cannot be empty")},l.delete=function(r,t,n,s){return e.coroutine(function*(){var e=yield o.getIndex(),r=Zip.readAsText("index.json"),t=JSON.parse(r).version,i={method:"POST",headers:{accesstoken:s}};yield l.makeApiCall("/app/"+e.appId+"/"+t+"/"+n+"/deletezip",i)})},l.upload=function(r,i,a,d){r=r||config.BUILD_PATH;var u=t.resolve(r);return e.coroutine(function*(){var e=new s(u),r=yield o.getIndex(),t=e.readAsText("index.json"),i=JSON.parse(t).version,p=yield o.readFile(u);new Buffer(p);n.printMessage(c("UPLOADING_CONNECTOR",{version:i}));var h={method:"POST",headers:{accesstoken:d}};yield y((yield l.makeApiCall("/app/"+r.appId+"/"+i+"/"+a+"/uploadzip",h)).body.url,u),n.printDone()})().catch(r=>(n.printDone(),e.reject(r)))}; |