| 1 | const e=require("./files"),r=require("bluebird"),o=r.promisifyAll,n=o(require("fs-extra")),i=require("./api"),t=require("path"),a=require("./../utils/messagehandler").messagesHandler,c=require("./input"),s=(e,r,o)=>{var n={headers:{accesstoken:r},method:"POST",body:{title:e.name,description:e.description,version:e.version,cli_version:config.PACKAGE.version}};return o&&(n.body.name=o),i.makeApiCall("/app/register",n)},d=(e,o,i)=>r.coroutine(function*(){console.log(a("CONNECTOR_REGISTER"));var c=yield s(e,o,i);return e.appId=c.body.data.uid,yield u(c.body.data.name),yield n.writeFileAsync(t.join(process.cwd(),"index.json"),JSON.stringify(e,null,2),"utf8"),console.log(a("CONNECTOR_REGISTER_SUCCESS")),r.resolve(e.appId)})().catch(e=>(console.log(e),r.reject(e))),l=(e,r)=>{var o={headers:{accesstoken:r},method:"GET"};return i.makeApiCall("/app/"+e,o)};function u(e){var r={};r.service_name=e;var o=config.APP_DIR;return n.writeFileAsync(t.join(o,".flowapprc"),JSON.stringify(r))}module.exports.getAppId=(o=>r.coroutine(function*(){var n=yield e.getIndex();if(n.appId){console.log("Validating connector...");var i=null;try{i=JSON.parse(yield e.getLinkedApp()).service_name}catch(e){}var t=yield l(n.appId,o);console.log("Connector validated successfully");var s=t.body.data.version;return n.version==s?r.resolve(n.appId):n.version<s?r.reject(a("CONNECTOR_VERSION_ERROR")):(name=yield c.getInput(`Your current connector version is different then deployed connector version do you want to create new connector with ${n.version} version ? (y/n) `),"y"===name.toLowerCase()?d(n,o,i):r.reject(`Please update connector version in index.json file to ${s} and rerun deploy command`))}return d(n,o)})().catch(e=>r.reject(e))),module.exports.getBuildId=(e=>{var r={headers:{accesstoken:e},method:"GET"};return i.makeApiCall("/generatebuild",r)}),module.exports.updateApp=((r,o,n,t)=>e.getIndex().then(e=>{var a={headers:{accesstoken:r},method:"PUT",body:{build_id:n,title:e.name,description:e.description,auth_type:e.auth_type?e.auth_type:"noauth",actions:e.actions,lookup:e.lookups,triggers:e.triggers,version:e.version,icon:e.icon,oauth_provider:e.oauth_provider,validationCode:t}};return e.audience&&(a.body.audience=e.audience),i.makeApiCall("/app/"+o,a)})),module.exports.checkExistingLookup=function(){var e=config.APP_DIR;return n.readdirAsync(t.join(e,"lookup")).then(function(e){return e.length?r.reject(a("LOOKUP_EXIST_ERROR")):r.resolve(!0)}).catch(e=>r.resolve(!0))},module.exports.isAppDeployed=function(){var o=t.join(config.APP_DIR,".flowapprc");return e.readFile(o).then(e=>!0).catch(e=>r.reject(a("UNDEPLOYED_CONNECTOR")))}; |