|
[ |
|
{ |
|
"id": "f013e682.3118f8", |
|
"type": "tab", |
|
"label": "Marketing Cloud", |
|
"disabled": false, |
|
"info": "" |
|
}, |
|
{ |
|
"id": "a3b117e3.89e008", |
|
"type": "http response", |
|
"z": "f013e682.3118f8", |
|
"name": "", |
|
"statusCode": "", |
|
"headers": {}, |
|
"x": 670, |
|
"y": 360, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "f5dffd18.e3d34", |
|
"type": "http in", |
|
"z": "f013e682.3118f8", |
|
"name": "Configuration node", |
|
"url": "/marketing-cloud/config.json", |
|
"method": "get", |
|
"upload": false, |
|
"swaggerDoc": "", |
|
"x": 130, |
|
"y": 360, |
|
"wires": [ |
|
[ |
|
"6b8f953b.a15e5c" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "c75cc7a8.cfdec8", |
|
"type": "comment", |
|
"z": "f013e682.3118f8", |
|
"name": "Config File", |
|
"info": "The JSON file that explains to Marketing Cloud what\nthe activity does", |
|
"x": 100, |
|
"y": 320, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "6b8f953b.a15e5c", |
|
"type": "function", |
|
"z": "f013e682.3118f8", |
|
"name": "config.json", |
|
"func": "let activity = \"demo\";\nlet detailpayload = {\n params : msg.req.params,\n headers : msg.req.headers\n};\nlet host = msg.req.headers.host;\nlet hostURL = (host.substring(0,9)==='localhost') ? 'http://'+host : 'https://'+host;\n\nmsg.payload = {\n \"workflowApiVersion\": \"1.1\",\n \"metaData\": {\n \"icon\": \"/red/images/node-red.png\",\n \"category\": \"customer\",\n \"configOnDrop\": true\n },\n \"type\": \"REST\",\n \"lang\": {\n \"en-US\": {\n \"name\": activity,\n \"description\":activity,\n \"step1Label\": \"Configure Activity\"\n }\n },\n \"arguments\": {\n \"execute\": {\n \"inArguments\": [\n {\n \"CampaignID\": \"\",\n \"ContactKey\": \"{{Contact.Key}}\"\n }\n ],\n \"outArguments\": [\n {\n \"status\": \"\"\n }\n ],\n \"url\": hostURL+\"/endpoints/\"+activity+\"/execute\",\n \"verb\": \"POST\",\n \"body\": \"\",\n \"header\": \"\",\n \"format\": \"json\",\n \"useJwt\": true,\n \"timeout\": 10000\n }\n },\n \"configurationArguments\": {\n \"applicationExtensionKey\": \"mc_uniquekey\",\n \"save\": {\n \"url\": hostURL+\"/endpoints/\"+activity+\"/save\",\n \"verb\": \"POST\",\n \"useJwt\": true\n },\n \"publish\": {\n \"url\": hostURL+\"/endpoints/\"+activity+\"/publish\",\n \"verb\": \"POST\",\n \"useJwt\": true\n },\n \"stop\": {\n \"url\": hostURL+\"/endpoints/\"+activity+\"/stop\",\n \"verb\": \"POST\",\n \"useJwt\": true\n },\n \"validate\": {\n \"url\": hostURL+\"/endpoints/\"+activity+\"/validate\",\n \"verb\": \"POST\",\n \"useJwt\": true\n }\n },\n \"wizardSteps\": [\n {\n \"label\": \"Configure Activity\",\n \"key\": \"step1\"\n }\n ],\n \"userInterfaces\": {\n \"configModal\": {\n \"height\": 500,\n \"width\": 520,\n \"fullscreen\": false\n }\n },\n \"schema\": {\n \"arguments\": {\n \"execute\": {\n \"inArguments\": [],\n \"outArguments\": [\n {\n \"status\": {\n \"dataType\": \"Text\",\n \"direction\": \"out\",\n \"access\": \"visible\"\n }\n }\n ]\n }\n }\n },\n}\n\nreturn msg;", |
|
"outputs": 1, |
|
"noerr": 0, |
|
"x": 410, |
|
"y": 360, |
|
"wires": [ |
|
[ |
|
"a3b117e3.89e008" |
|
] |
|
], |
|
"info": "# Configuration\n\nYou need to adjust the `activity` variable to the \nsame value you specify in the \"Action Node\".\nDefault is \"demo\"" |
|
}, |
|
{ |
|
"id": "c5c130fa.e4b04", |
|
"type": "http response", |
|
"z": "f013e682.3118f8", |
|
"name": "", |
|
"statusCode": "", |
|
"headers": {}, |
|
"x": 770, |
|
"y": 660, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "44a433d4.4ff93c", |
|
"type": "http in", |
|
"z": "f013e682.3118f8", |
|
"name": "Action Node", |
|
"url": "/endpoints/demo/:action", |
|
"method": "post", |
|
"upload": false, |
|
"swaggerDoc": "", |
|
"x": 110, |
|
"y": 680, |
|
"wires": [ |
|
[ |
|
"32b72ce.89070d4" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "979d4b98.cd9b28", |
|
"type": "comment", |
|
"z": "f013e682.3118f8", |
|
"name": "Incoming from Marketing Cloud", |
|
"info": "", |
|
"x": 170, |
|
"y": 640, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "449433f6.0f9d3c", |
|
"type": "switch", |
|
"z": "f013e682.3118f8", |
|
"name": "Determine action", |
|
"property": "req.params.action", |
|
"propertyType": "msg", |
|
"rules": [ |
|
{ |
|
"t": "eq", |
|
"v": "save", |
|
"vt": "str" |
|
}, |
|
{ |
|
"t": "eq", |
|
"v": "publish", |
|
"vt": "str" |
|
}, |
|
{ |
|
"t": "eq", |
|
"v": "stop", |
|
"vt": "str" |
|
}, |
|
{ |
|
"t": "eq", |
|
"v": "validate", |
|
"vt": "str" |
|
}, |
|
{ |
|
"t": "else" |
|
}, |
|
{ |
|
"t": "eq", |
|
"v": "execute", |
|
"vt": "str" |
|
} |
|
], |
|
"checkall": "false", |
|
"repair": false, |
|
"outputs": 6, |
|
"x": 330, |
|
"y": 740, |
|
"wires": [ |
|
[ |
|
"739eaf33.de7e2" |
|
], |
|
[ |
|
"739eaf33.de7e2" |
|
], |
|
[ |
|
"739eaf33.de7e2" |
|
], |
|
[ |
|
"739eaf33.de7e2" |
|
], |
|
[ |
|
"de462a32.264b48" |
|
], |
|
[ |
|
"4d7d3ac9.4f4da4", |
|
"6fddb92b.d54758" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "de462a32.264b48", |
|
"type": "template", |
|
"z": "f013e682.3118f8", |
|
"name": "Error Message", |
|
"field": "payload", |
|
"fieldType": "msg", |
|
"format": "json", |
|
"syntax": "mustache", |
|
"template": "\"{ status : 'Error' }\"", |
|
"output": "str", |
|
"x": 580, |
|
"y": 720, |
|
"wires": [ |
|
[ |
|
"2ff490b7.e7f19" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "2ff490b7.e7f19", |
|
"type": "http response", |
|
"z": "f013e682.3118f8", |
|
"name": "Not Found", |
|
"statusCode": "404", |
|
"headers": {}, |
|
"x": 790, |
|
"y": 720, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "4d7d3ac9.4f4da4", |
|
"type": "template", |
|
"z": "f013e682.3118f8", |
|
"name": "Execute status", |
|
"field": "payload", |
|
"fieldType": "msg", |
|
"format": "text", |
|
"syntax": "mustache", |
|
"template": "'{\"status\" : \"OK\"}'", |
|
"output": "str", |
|
"x": 580, |
|
"y": 780, |
|
"wires": [ |
|
[ |
|
"157cb491.436b7b" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "32b72ce.89070d4", |
|
"type": "jwt verify", |
|
"z": "f013e682.3118f8", |
|
"name": "Test JWT", |
|
"alg": [ |
|
"HS256" |
|
], |
|
"jwkurl": "", |
|
"secret": "Barbequeue", |
|
"key": "", |
|
"signvar": "payload", |
|
"storetoken": "token", |
|
"x": 140, |
|
"y": 740, |
|
"wires": [ |
|
[ |
|
"449433f6.0f9d3c" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "beca8ce7.95c0a", |
|
"type": "debug", |
|
"z": "f013e682.3118f8", |
|
"name": "", |
|
"active": false, |
|
"tosidebar": true, |
|
"console": false, |
|
"tostatus": false, |
|
"complete": "true", |
|
"targetType": "full", |
|
"x": 470, |
|
"y": 1000, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "120fbb23.92a515", |
|
"type": "inject", |
|
"z": "f013e682.3118f8", |
|
"name": "", |
|
"topic": "", |
|
"payload": "eyJhbGciOiJIUzI1NiJ9.ewogICAiaW5Bcmd1bWVudHMiIDogW3sKICAgICJDYW1wYWlnbklEIjogIjcwMTdGMDAwMDAwTUo0T1FBVyIsCgkiQ29udGFjdEtleSI6ICIwMDM3RjAwMDAwejhWYnpRQUUiCiAgIH1dCn0.gnjf3FN7HMydDWUm-NMn3gaKpvuuXpEMrunR1A2PAgA", |
|
"payloadType": "str", |
|
"repeat": "", |
|
"crontab": "", |
|
"once": false, |
|
"onceDelay": 0.1, |
|
"x": 110, |
|
"y": 1000, |
|
"wires": [ |
|
[ |
|
"30901b69.d485a4" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "30901b69.d485a4", |
|
"type": "http request", |
|
"z": "f013e682.3118f8", |
|
"name": "", |
|
"method": "POST", |
|
"ret": "txt", |
|
"paytoqs": false, |
|
"url": "http://localhost:1880/endpoints/demo/execute", |
|
"tls": "", |
|
"proxy": "", |
|
"authType": "basic", |
|
"x": 290, |
|
"y": 1000, |
|
"wires": [ |
|
[ |
|
"beca8ce7.95c0a" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "739eaf33.de7e2", |
|
"type": "template", |
|
"z": "f013e682.3118f8", |
|
"name": "Simple return", |
|
"field": "payload", |
|
"fieldType": "msg", |
|
"format": "handlebars", |
|
"syntax": "mustache", |
|
"template": "{ \"action\" : \"{{req.params.action}}\",\n \"status\" : \"OK\" \n}", |
|
"output": "json", |
|
"x": 580, |
|
"y": 660, |
|
"wires": [ |
|
[ |
|
"c5c130fa.e4b04" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "954c450b.17ecc8", |
|
"type": "comment", |
|
"z": "f013e682.3118f8", |
|
"name": "This can be used for testing", |
|
"info": "", |
|
"x": 160, |
|
"y": 960, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "8ab679d8.15e868", |
|
"type": "comment", |
|
"z": "f013e682.3118f8", |
|
"name": "Static files (html, css, json)", |
|
"info": "", |
|
"x": 150, |
|
"y": 420, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "157cb491.436b7b", |
|
"type": "http response", |
|
"z": "f013e682.3118f8", |
|
"name": "", |
|
"statusCode": "", |
|
"headers": {}, |
|
"x": 770, |
|
"y": 780, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "6fddb92b.d54758", |
|
"type": "debug", |
|
"z": "f013e682.3118f8", |
|
"name": "", |
|
"active": true, |
|
"tosidebar": true, |
|
"console": false, |
|
"tostatus": false, |
|
"complete": "false", |
|
"x": 490, |
|
"y": 900, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "8bb75e68.fec1a", |
|
"type": "comment", |
|
"z": "f013e682.3118f8", |
|
"name": "Actual action goes here - whatever it might be", |
|
"info": "", |
|
"x": 210, |
|
"y": 880, |
|
"wires": [], |
|
"icon": "node-red/arrow-in.png" |
|
}, |
|
{ |
|
"id": "b8f1eb7f.067bf8", |
|
"type": "http response", |
|
"z": "f013e682.3118f8", |
|
"name": "html", |
|
"statusCode": "", |
|
"headers": { |
|
"content-type": "text/html" |
|
}, |
|
"x": 690, |
|
"y": 500, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "a0460c24.e8f65", |
|
"type": "http in", |
|
"z": "f013e682.3118f8", |
|
"name": "/marketing-cloud/index.html", |
|
"url": "/marketing-cloud/index.html", |
|
"method": "get", |
|
"upload": false, |
|
"swaggerDoc": "", |
|
"x": 160, |
|
"y": 500, |
|
"wires": [ |
|
[ |
|
"e6a1e098.42916" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "e6a1e098.42916", |
|
"type": "template", |
|
"z": "f013e682.3118f8", |
|
"name": "static HTML", |
|
"field": "payload", |
|
"fieldType": "msg", |
|
"format": "html", |
|
"syntax": "plain", |
|
"template": "<!DOCTYPE html>\n<html>\n <head>\n <title></title>\n <meta charset=\"utf-8\" />\n <meta http-equiv=\"x-ua-compatible\" content=\"ie=edge\" />\n <meta name=\"viewport\" content=\"width=device-width, initial-scale=1\" />\n <meta http-equiv=\"Content-Security-Policy\" content=\"upgrade-insecure-requests\" />\n <script type=\"text/javascript\" src=\"http://ajax.googleapis.com/ajax/libs/jquery/1.9.1/jquery.min.js\"></script>\n <script type=\"text/javascript\" src=\"js/postmonger.js\"></script>\n <script type=\"text/javascript\">\n var mc_fuel_token = '';\n var connection = new Postmonger.Session();\n var payload = {};\n var steps = [{ label: 'Configure Postcard', key: 'step1' }];\n\n $(window).ready(onRender);\n\n connection.on('initActivity', initialize);\n connection.on('requestedTokens', onGetTokens);\n connection.on('requestedEndpoints', onGetEndpoints);\n connection.on('clickedNext', save);\n\n function onRender() {\n connection.trigger('ready');\n connection.trigger('requestTokens');\n connection.trigger('requestEndpoints');\n }\n\n function jsonCallback(data) {}\n\n function initialize(data) {\n if (data) {\n payload = data;\n }\n\n var hasInArguments = Boolean(\n payload['arguments'] &&\n payload['arguments'].execute &&\n payload['arguments'].execute.inArguments &&\n payload['arguments'].execute.inArguments.length > 0\n );\n\n if (hasInArguments && payload['arguments'].execute.inArguments[0].CampaignID) {\n $('#CampaignID').val(payload['arguments'].execute.inArguments[0].CampaignID);\n }\n\n connection.trigger('updateButton', {\n button: 'next',\n text: 'done',\n visible: true\n });\n }\n\n function onGetTokens(tokens) {\n if (tokens != null && tokens.fuel2token != null) {\n mc_fuel_token = tokens.fuel2token;\n }\n }\n\n function onGetEndpoints(endpoints) {}\n\n function save() {\n $('#errorMsgPreview').text('');\n\n var CampaignID = $('#CampaignID').val();\n var errMsg;\n\n var hasInArguments = Boolean(\n payload['arguments'] &&\n payload['arguments'].execute &&\n payload['arguments'].execute.inArguments &&\n payload['arguments'].execute.inArguments.length > 0\n );\n if (hasInArguments) {\n payload['arguments'].execute.inArguments[0].CampaignID = CampaignID;\n }\n\n if (CampaignID.length == 0) {\n errMsg = 'Error: Campaign ID cannot be blank.';\n console.error(errMsg);\n $('#errorMsgConfig').text(errMsg);\n connection.trigger('ready');\n } else {\n payload['metaData'].isConfigured = true;\n connection.trigger('updateActivity', payload);\n }\n }\n </script>\n <link rel=\"stylesheet\" type=\"text/css\" href=\"css/styles.css\" />\n </head>\n <body>\n <div id=\"step1\" class=\"step\">\n <div class=\"col-xs-9\">\n <h3>Campaign Association</h3>\n <div class=\"well\">\n <fieldset>\n <div>\n <font color=\"red\"><div id=\"errorMsgConfig\"></div></font>\n </div>\n <!-- TODO: Call back to Salesforce ?-->\n <div class=\"form-group\">\n <label for=\"cid\" class=\"label\">Campaign ID</label>\n <div class=\"col-lg-8\">\n <input type=\"text\" id=\"CampaignID\" />\n </div>\n </div>\n </fieldset>\n </div>\n </div>\n </div>\n </body>\n</html>\n", |
|
"output": "str", |
|
"x": 470, |
|
"y": 500, |
|
"wires": [ |
|
[ |
|
"b8f1eb7f.067bf8" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "23a152b9.437fee", |
|
"type": "http response", |
|
"z": "f013e682.3118f8", |
|
"name": "css", |
|
"statusCode": "", |
|
"headers": { |
|
"content-type": "text/css" |
|
}, |
|
"x": 690, |
|
"y": 540, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "b758f1b7.53d34", |
|
"type": "http in", |
|
"z": "f013e682.3118f8", |
|
"name": "/marketing-cloud/css/style.css", |
|
"url": "/marketing-cloud/css/style.css", |
|
"method": "get", |
|
"upload": false, |
|
"swaggerDoc": "", |
|
"x": 170, |
|
"y": 540, |
|
"wires": [ |
|
[ |
|
"b4196642.0d04c8" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "b4196642.0d04c8", |
|
"type": "template", |
|
"z": "f013e682.3118f8", |
|
"name": "static CSS", |
|
"field": "payload", |
|
"fieldType": "msg", |
|
"format": "css", |
|
"syntax": "plain", |
|
"template": "body {\n margin: 20px;\n padding: 0px;\n\tfont-family: Arial, 'Helvetica Neue', Helvetica, sans-serif;\n\tfont-size:12px;\n}\n\nform {\n\twidth:400px;\n}\n\nselect\n{\n\tpadding: 5px;\n}\n\ntextarea, select, input{\n\twidth:400px;\n}\n\ndiv.isPush\n{\n\tpadding-bottom:10px;\n}\n\ninput[type='radio']\n{\n\twidth:20px;\n}\n\ninput[type='checkbox']\n{\n\twidth: 20px;\n\tborder:solid 1px red;\n}\n\ntd{\n\tvertical-align:top;\t\n}\n\ntd.label\n{\n\tpadding-top:2px;\n\twidth:120px;\n}\n\n#container {\n margin: 30px;\n}\n", |
|
"output": "str", |
|
"x": 470, |
|
"y": 540, |
|
"wires": [ |
|
[ |
|
"23a152b9.437fee" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "268afbe1.895354", |
|
"type": "http response", |
|
"z": "f013e682.3118f8", |
|
"name": "", |
|
"statusCode": "", |
|
"headers": { |
|
"content-type": "text/javascript" |
|
}, |
|
"x": 690, |
|
"y": 580, |
|
"wires": [] |
|
}, |
|
{ |
|
"id": "80b620de.65089", |
|
"type": "http in", |
|
"z": "f013e682.3118f8", |
|
"name": "/marketing-cloud/js/postmonger.js", |
|
"url": "/marketing-cloud/js/postmonger.js", |
|
"method": "get", |
|
"upload": false, |
|
"swaggerDoc": "", |
|
"x": 180, |
|
"y": 580, |
|
"wires": [ |
|
[ |
|
"64b99f72.1a599" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "64b99f72.1a599", |
|
"type": "template", |
|
"z": "f013e682.3118f8", |
|
"name": "postmonger.js", |
|
"field": "payload", |
|
"fieldType": "msg", |
|
"format": "javascript", |
|
"syntax": "plain", |
|
"template": "/*\n * Postmonger.js version 0.0.14\n * https://github.com/kevinparkerson/postmonger\n *\n * Copyright (c) 2012-2014 Kevin Parkerson\n * Available via the MIT or new BSD license.\n * Further details and documentation:\n * http://kevinparkerson.github.com/postmonger/\n *\n *///\n\n(function (root, factory) {\n\tif (typeof define === 'function' && define.amd) {\n\t\tdefine('postmonger', [], function () { return factory(root); });\n\t} else if (typeof exports === 'object') {\n\t\tmodule.exports = factory(root);\n\t} else {\n\t\t// OR use browser globals if AMD is not present\n\t\troot.Postmonger = factory(root);\n\t}\n}(this, function (root) {\n\troot = root || window;\n\n\tvar exports = exports || undefined;\n\tvar Postmonger;\n\tvar previous = root.Postmonger;\n\tvar _window = (root.addEventListener || root.attachEvent) ? root : window;\n\tvar Connection, Events, Session;\n\n\t//Set up Postmonger namespace, provide noConflict support, and version\n\tif (typeof(exports) !== 'undefined') {\n\t\tPostmonger = exports;\n\t} else {\n\t\tPostmonger = {};\n\t}\n\tPostmonger.noConflict = function () {\n\t\troot.Postmonger = previous;\n\t\treturn this;\n\t};\n\tPostmonger.version = '0.0.14';\n\n\t//Create a new Postmonger Connection\n\tConnection = Postmonger.Connection = function (options) {\n\t\toptions = (typeof(options) === 'object') ? options : {};\n\n\t\tvar connect = options.connect || _window.parent;\n\t\tvar from = options.from || '*';\n\t\tvar to = options.to || '*';\n\t\tvar self = this;\n\n\t\t//If string, grab based on id\n\t\tif (typeof(connect) === 'string') {\n\t\t\tconnect = document.getElementById(connect);\n\t\t}\n\n\t\t//If no connection, check for jquery object\n\t\tif (connect && !connect.postMessage && connect.jquery) {\n\t\t\tconnect = connect.get(0);\n\t\t}\n\n\t\t//If still no connection, check for iframe\n\t\tif (connect && !connect.postMessage && (connect.contentWindow || connect.contentDocument)) {\n\t\t\tconnect = connect.contentWindow || connect.contentDocument;\n\t\t}\n\n\t\t//Throw warning if connection could not be made\n\t\tif (!(connect && connect.postMessage)) {\n\t\t\tif (_window.console && _window.console.warn) {\n\t\t\t\t_window.console.warn(' Warning: Postmonger could not establish connection with ', options.connect);\n\t\t\t}\n\t\t\treturn false;\n\t\t}\n\n\t\tself.connect = connect;\n\t\tself.to = to;\n\t\tself.from = from;\n\n\t\treturn self;\n\t};\n\n\t//Postmonger.Events - Hacked together from Backbone.Events and two Underscore functions.\n\tEvents = Postmonger.Events = function () {\n\t\tvar eventSplitter = /\\s+/;\n\t\tvar self = this;\n\n\t\tself._callbacks = {};\n\n\t\tself._has = function (obj, key) {\n\t\t\treturn Object.prototype.hasOwnProperty.call(obj, key);\n\t\t};\n\n\t\tself._keys = function (obj) {\n\t\t\tif (Object.keys) {\n\t\t\t\treturn Object.keys(obj);\n\t\t\t}\n\n\t\t\tif (typeof(obj)!=='object') {\n\t\t\t\tthrow new TypeError('Invalid object');\n\t\t\t}\n\n\t\t\tvar keys = [];\n\n\t\t\tfor (var key in obj) {\n\t\t\t\tif (self._has(obj, key)) {\n\t\t\t\t\tkeys[keys.length] = key;\n\t\t\t\t}\n\t\t\t}\n\n\t\t\treturn keys;\n\t\t};\n\n\t\tself.on = function (events, callback, context) {\n\t\t\tvar calls, event, node, tail, list;\n\n\t\t\tif (!callback) {\n\t\t\t\treturn self;\n\t\t\t}\n\n\t\t\tevents = events.split(eventSplitter);\n\n\t\t\tself._callbacks = self._callbacks || {};\n\t\t\tcalls = self._callbacks;\n\n\t\t\twhile (event = events.shift()) {\n\t\t\t\tlist = calls[event];\n\n\t\t\t\tnode = (list) ? list.tail : {};\n\t\t\t\ttail = {};\n\n\t\t\t\tnode.next = tail;\n\t\t\t\tnode.context = context;\n\t\t\t\tnode.callback = callback;\n\n\t\t\t\tcalls[event] = {\n\t\t\t\t\ttail: tail,\n\t\t\t\t\tnext: (list) ? list.next : node\n\t\t\t\t};\n\t\t\t}\n\n\t\t\treturn self;\n\t\t};\n\n\t\tself.off = function (events, callback, context) {\n\t\t\tvar calls = self._callbacks;\n\t\t\tvar event, node, tail, cb, ctx;\n\n\t\t\tif (!calls) {\n\t\t\t\treturn;\n\t\t\t}\n\n\t\t\tif (!(events || callback || context)) {\n\t\t\t\tdelete self._callbacks;\n\t\t\t\treturn self;\n\t\t\t}\n\n\t\t\tevents = (events) ? events.split(eventSplitter) : self._keys(calls);\n\n\t\t\twhile (event = events.shift()) {\n\t\t\t\tnode = calls[event];\n\t\t\t\tdelete calls[event];\n\t\t\t\tif (!node || !(callback || context)) {\n\t\t\t\t\tcontinue;\n\t\t\t\t}\n\n\t\t\t\ttail = node.tail;\n\t\t\t\twhile ((node = node.next) !== tail) {\n\t\t\t\t\tcb = node.callback;\n\t\t\t\t\tctx = node.context;\n\t\t\t\t\tif (((callback && cb) !== callback) || ((context && ctx) !== context)) {\n\t\t\t\t\t\tself.on(event, cb, ctx);\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t}\n\n\t\t\treturn self;\n\t\t};\n\n\t\tself.trigger = function (events) {\n\t\t\tvar event, node, calls, tail, args, all, rest;\n\n\t\t\tif (!(calls = self._callbacks)) {\n\t\t\t\treturn self;\n\t\t\t}\n\n\t\t\tall = calls.all;\n\t\t\tevents = events.split(eventSplitter);\n\t\t\trest = Array.prototype.slice.call(arguments, 1);\n\n\t\t\twhile (event = events.shift()) {\n\t\t\t\tif (node = calls[event]) {\n\t\t\t\t\ttail = node.tail;\n\t\t\t\t\twhile ((node = node.next) !== tail) {\n\t\t\t\t\t\tnode.callback.apply(node.context || self, rest);\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t\tif (node = all) {\n\t\t\t\t\ttail = node.tail;\n\t\t\t\t\targs = [event].concat(rest);\n\t\t\t\t\twhile ((node = node.next) !== tail) {\n\t\t\t\t\t\tnode.callback.apply(node.context || self, args);\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t}\n\n\t\t\treturn self;\n\t\t};\n\n\t\treturn self;\n\t};\n\n\t//Create a new Postmonger Session\n\tSession = Postmonger.Session = function () {\n\t\tvar args = (arguments.length>0) ? Array.prototype.slice.call(arguments, 0) : [{}];\n\t\tvar connections = [];\n\t\tvar incoming = new Events();\n\t\tvar outgoing = new Events();\n\t\tvar self = this;\n\t\tvar connection, i, j, l, ln, postMessageListener;\n\n\t\t//Session API hooks\n\t\tself.on = incoming.on;\n\t\tself.off = incoming.off;\n\t\tself.trigger = outgoing.trigger;\n\t\tself.end = function () {\n\t\t\tincoming.off();\n\t\t\toutgoing.off();\n\t\t\tif (_window.removeEventListener) {\n\t\t\t\t_window.removeEventListener('message', postMessageListener, false);\n\t\t\t} else if (_window.detachEvent) {\n\t\t\t\t_window.detachEvent('onmessage', postMessageListener);\n\t\t\t}\n\t\t\treturn self;\n\t\t};\n\n\t\t//Establishing connections\n\t\tfor (i=0, l=args.length; i<l; i++) {\n\t\t\tconnection = new Connection(args[i]);\n\t\t\tif (connection) {\n\t\t\t\tfor (j=0, ln=connections.length; j<ln; j++) {\n\t\t\t\t\tif (\n\t\t\t\t\t\tconnections[j].connect === connection.connect &&\n\t\t\t\t\t\tconnections[j].from === connection.from &&\n\t\t\t\t\t\tconnections[j].to === connection.to\n\t\t\t\t\t) {\n\t\t\t\t\t\tconnection = null;\n\t\t\t\t\t\tbreak;\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t\tif (connection) {\n\t\t\t\t\tconnections.push(connection);\n\t\t\t\t}\n\t\t\t}\n\t\t}\n\n\t\t//Listener for incoming messages\n\t\tpostMessageListener = function(event){\n\t\t\tvar conn = null;\n\t\t\tvar message = [];\n\t\t\tvar data;\n\t\t\tvar k, len;\n\n\t\t\t//Attempt to find the connection we're dealing with\n\t\t\tfor (k=0, len=connections.length; k<len; k++) {\n\t\t\t\tif (connections[k].connect === event.source) {\n\t\t\t\t\tconn = connections[k];\n\t\t\t\t\tbreak;\n\t\t\t\t}\n\t\t\t}\n\n\t\t\t//Check if we've found the connection\n\t\t\tif (!conn) {\n\t\t\t\treturn false;\n\t\t\t}\n\n\t\t\t//Check if the message is from the expected origin\n\t\t\tif (conn.from !== '*' && conn.from !== event.origin) {\n\t\t\t\treturn false;\n\t\t\t}\n\n\t\t\t//Check the data that's been passed\n\t\t\ttry{\n\t\t\t\tdata = JSON.parse(event.data);\n\t\t\t\tif(!data.e){\n\t\t\t\t\treturn false;\n\t\t\t\t}\n\t\t\t}catch(e){\n\t\t\t\treturn false;\n\t\t\t}\n\n\t\t\t//Format the passed in data\n\t\t\tmessage.push(data.e);\n\t\t\tdelete data.e;\n\t\t\tfor (k in data) {\n\t\t\t\tmessage.push(data[k]);\n\t\t\t}\n\n\t\t\t//Send the message\n\t\t\tincoming['trigger'].apply(root, message);\n\t\t};\n\n\t\t//Add the listener\n\t\tif (_window.addEventListener) {\n\t\t\t_window.addEventListener('message', postMessageListener, false);\n\t\t} else if(_window.attachEvent) {\n\t\t\t_window.attachEvent('onmessage', postMessageListener);\n\t\t} else{\n\t\t\tif (_window.console && _window.console.warn) {\n\t\t\t\t_window.console.warn('WARNING: Postmonger could not listen for messages on window %o', _window);\n\t\t\t}\n\t\t\treturn false;\n\t\t}\n\n\t\t//Sending outgoing messages\n\t\toutgoing.on('all', function () {\n\t\t\tvar args = Array.prototype.slice.call(arguments, 0);\n\t\t\tvar message = {};\n\t\t\tvar k, len;\n\n\t\t\tmessage.e = args[0];\n\n\t\t\tfor (k=1, len=args.length; k<len; k++) {\n\t\t\t\tmessage['a' + k] = args[k];\n\t\t\t}\n\n\t\t\tfor (k=0, len=connections.length; k<len; k++) {\n\t\t\t\tconnections[k].connect.postMessage(JSON.stringify(message), connections[k].to);\n\t\t\t}\n\t\t});\n\n\t\treturn self;\n\t};\n\n\treturn Postmonger;\n}));", |
|
"output": "str", |
|
"x": 480, |
|
"y": 580, |
|
"wires": [ |
|
[ |
|
"268afbe1.895354" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "3eb29099.23cbb", |
|
"type": "http in", |
|
"z": "f013e682.3118f8", |
|
"name": "/marketing-cloud", |
|
"url": "/marketing-cloud", |
|
"method": "get", |
|
"upload": false, |
|
"swaggerDoc": "", |
|
"x": 120, |
|
"y": 460, |
|
"wires": [ |
|
[ |
|
"e6a1e098.42916" |
|
] |
|
] |
|
}, |
|
{ |
|
"id": "e62252d8.6eaae", |
|
"type": "catch", |
|
"z": "f013e682.3118f8", |
|
"name": "Catch JWT Error", |
|
"scope": [ |
|
"32b72ce.89070d4" |
|
], |
|
"uncaught": false, |
|
"x": 320, |
|
"y": 820, |
|
"wires": [ |
|
[ |
|
"de462a32.264b48" |
|
] |
|
] |
|
} |
|
] |
