Skip to content

10.12 additional apis #5

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
sagpembo merged 2 commits into from
Jul 18, 2022
Merged

10.12 additional apis #5

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
3056148
added themes, recipes, project parameters, webhooks, extended debug
sagpembo Jul 18, 2022
718a1a4
updated version to 2022.07.2
sagpembo Jul 18, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
22 changes: 17 additions & 5 deletions flowservice.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,27 +8,39 @@ const rest = require('./rest.js');
const dbg = require('./debug.js');


var domainName, username,password,timeout;
var domainName, username,password,timeout,prettyprint;
var url;

function debug(message){
dbg.message("<FLOWSERVICE> " + message);
}

function init(inDomainName, inUsername, inPassword,inTimeout,projectId){
function init(inDomainName, inUsername, inPassword,inTimeout,inPrettyPrint,projectId){
domainName = inDomainName;
username = inUsername;
password = inPassword;
timeout = inTimeout;
prettyprint = inPrettyPrint;

url = "https://" + domainName + "/enterprise/v1/rest/projects/" + projectId ;
debug("Username [" + username + "]");
debug("URL [" + url + "]");
debug("Timeout [" + timeout + "]");
}

function processResponse(data,status,filename){
debug("Processing response message");
console.log(JSON.stringify(data));
/**
* Call back function to process REST response
* @param {return data from REST request} data
* @param {status} status
*/
function processResponse(data,status){
if(prettyprint==true){
console.log(JSON.stringify(data,null,4));
}
else{
console.log(JSON.stringify(data));
}

if(status!=0){
process.exit(status);
}
Expand Down
94 changes: 81 additions & 13 deletions projects.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,18 +5,17 @@
*/

const request = require('./rest.js');
const dbg = require('./debug.js');

var domainName, username,password,timeout;
var prettyprint = false;
var url;

function checkForErrors(inBody)
{
//Error Codes
//Any error response

function debug(message){
dbg.message("<PROJECTS> " + message);
}


function init(inDomainName, inUsername, inPassword,inTimeout,inPrettyprint){
domainName = inDomainName;
username = inUsername;
Expand All @@ -25,6 +24,9 @@ function init(inDomainName, inUsername, inPassword,inTimeout,inPrettyprint){
prettyprint = inPrettyprint;

url = "https://" + domainName + "/apis/v1/rest/projects";
debug("Username [" + username + "]");
debug("URL [" + url + "]");
debug("Timeout [" + timeout + "]");
}

/**
Expand All @@ -45,37 +47,97 @@ function processResponse(data,status){
}
}

/* Projects */
function list(projectId){

debug("List Projects ID[" + projectId + "]");
if(projectId)url+="/" + projectId;
request.get(url,username,password,timeout,processResponse);
}

function listAssets(projectId){
if(projectId)url+="/" + projectId + "/assets";
request.get(url,username,password,timeout,processResponse);
}

function create(projectName){
debug("Create Project ID[" + projectName + "]");
var data={"name":projectName};
request.post(url,username,password,timeout,data,processResponse);
}

function update(projectId, projectName){

debug("Update Project ID[" + projectId + "] Name[" + projectName + "]");
url += "/" + projectId;
var data={"name":projectName};
request.put(url,username,password,timeout,data,processResponse);
}

function del(projectId){

debug("Create Project ID[" + projectId + "]");
url += "/" + projectId;
var data={};
request.httpDelete(url,username,password,timeout,data,processResponse);
}

/* Project Assets */
function listAssets(projectId){
debug("List Assets [" + projectId + "]");
if(projectId)url+="/" + projectId + "/assets";
request.get(url,username,password,timeout,processResponse);
}

/* Project Params */
function listParam(projectId,paramId){
debug("List Params [" + projectId + "] Param ID [" + paramId + "]");
if(projectId)url+="/" + projectId + "/params";
if(paramId)url +="/" + paramId;
request.get(url,username,password,timeout,processResponse);
}

function createParam(projectId,paramName,paramValue,required,isPassword){
debug("Create Param Project ID[" + projectId + "] Name [" + paramName + "] value ["+paramValue + "] required [" + required + "] isPassword [" + isPassword + "]" );
if(projectId)url+="/" + projectId + "/params";
var data={"key":paramName,"value":paramValue,"required":required,"isPassword":isPassword};
request.post(url,username,password,timeout,data,processResponse);
}

function updateParam(projectId,paramId,paramName,paramValue,required,isPassword){
debug("Update Param ProjectId [" + projectId + "] Param ID[" + paramId + "] Name [" + paramName + "] value ["+paramValue + "] required [" + required + "] isPassword [" + isPassword + "]" );
if(projectId)url+="/" + projectId + "/params";
if(paramId)url +="/" + paramId;
var data={"key":paramName,"value":paramValue,"required":required,"isPassword":isPassword};
request.put(url,username,password,timeout,data,processResponse);
}

function deleteParam(projectId,paramId){
debug("Delete Param ProjectId [" + projectId + "] Param ID[" + paramId + "]");
if(projectId)url+="/" + projectId + "/params";
if(paramId)url +="/" + paramId;
var data={};
request.httpDelete(url,username,password,timeout,data,processResponse);
}


/* Webhook APIs */
function listWebhooks(projectId){
debug("List webhooks ProjectId [" + projectId + "]");
if(projectId)url+="/" + projectId + "/webhook-flows";
request.get(url,username,password,timeout,processResponse);
}

function regenWebhook(projectId,workflowUid){
debug("List webhooks ProjectId [" + projectId + "] workflowUid [" + workflowUid + "]");
if(projectId)url+="/" + projectId + "/webhook-flows";
if(workflowUid)url +="/" + workflowUid + "/reset";
request.put(url,username,password,timeout,{},processResponse);
}

function setWebhookAuth(projectId,workflowUid,authType){
debug("List webhooks ProjectId [" + projectId + "] workflowUid [" + workflowUid + "] auth type [" + authType + "]");
if(projectId)url+="/" + projectId + "/webhook-flows";
if(workflowUid)url +="/" + workflowUid + "/auth";
var data={"auth": authType};
request.post(url,username,password,timeout,data,processResponse);
}


/* Deployment */

/**
* Pushes a deployment to a destination tenant
Expand All @@ -86,6 +148,7 @@ function del(projectId){
* @param {assets to publish} assets
*/
function pub(projectId,publishName,targetTenantDomainName,targetUserId,targetUserPassword,assetsJson){
debug("Project Pub ProjectId [" + projectId + "] publishName [" + publishName + "] target Tenant [" + targetTenantDomainName + "]");
//{"output":{"workflows":["fla73a20e13dd6736cf9c355","fl3cfd145262bbc5d44acff3"],"flows":["mapLeads"],"rest_api":[],"soap_api":[],"listener":[],"messaging":[]}}
url += "/" + projectId + "/push";

Expand All @@ -111,9 +174,14 @@ function pub(projectId,publishName,targetTenantDomainName,targetUserId,targetUse
*/
function deploy(projectName, version)
{
debug("Project Deploy ProjectName [" + projectName + "] Version [" + version + "]");
url += "/" + projectName + "/deploy";
data={"version":parseInt(version)};
request.post(url,username,password,timeout,data,processResponse);
}

module.exports = { init, list, listAssets, create, update, del, pub, deploy};
module.exports = { init, list, create, update, del,
listAssets, pub, deploy,
createParam,updateParam,listParam,deleteParam,
listWebhooks, regenWebhook, setWebhookAuth
};
66 changes: 66 additions & 0 deletions recipe.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,66 @@
/*
* webMethods.io CLI
* Copyright 2022 Software AG
* Apache-2.0
*/

const rest = require('./rest.js');
const dbg = require('./debug.js');


var domainName, username,password,timeout,prettyprint;
var url;

function debug(message){
dbg.message("<RECIPE> " + message);
}

function init(inDomainName, inUsername, inPassword,inTimeout,inPrettyPrint){
domainName = inDomainName;
username = inUsername;
password = inPassword;
timeout = inTimeout;
prettyprint = inPrettyPrint;
url = "https://" + domainName + "/apis/v1/rest/recipes" ;
debug("Username [" + username + "]");
debug("URL [" + url + "]");
debug("Timeout [" + timeout + "]");
}

/**
* Call back function to process REST response
* @param {return data from REST request} data
* @param {status} status
*/
function processResponse(data,status){
if(prettyprint==true){
console.log(JSON.stringify(data,null,4));
}
else{
console.log(JSON.stringify(data));
}

if(status!=0){
process.exit(status);
}
}

function create(filename){
debug("Creating Recipe from file [" + filename + "]");
rest.postUploadFile(url,username,password,timeout,undefined,filename,processResponse);
}

function list(recipeUid){
if(recipeUid)url+="/" + recipeUid;
debug("List Recipes [" + recipeUid + "]");
rest.get(url,username,password,timeout,processResponse);
}


function del(recipeUid){
debug("Deleting Recipe with ID [" + recipeUid + "]");
url += "/" + recipeUid;
rest.del(url,username,password,timeout,{},processResponse);
}

module.exports = { init, list, del, create };
Loading