forked from community/product-iots
Merge pull request #38 from Shabirmean/master
Adding separate jaggery module "apimstore"application-manager-new
Shabir Mohamed
9 years ago
commit
d08b13d514
@ -0,0 +1,883 @@
|
|||||||
|
<%
|
||||||
|
var site = require("/site/conf/site.json");
|
||||||
|
//TODO : remove this when log configs are implemented
|
||||||
|
//Log.prototype.isDebugEnabled = function () {
|
||||||
|
// return false;
|
||||||
|
//};
|
||||||
|
|
||||||
|
//TODO : remove this when Context HO is implemented.
|
||||||
|
var context = context || {
|
||||||
|
put:function (key, value) {
|
||||||
|
session.put(key, value);
|
||||||
|
},
|
||||||
|
get:function (key) {
|
||||||
|
return session.get(key);
|
||||||
|
},
|
||||||
|
remove:function (key) {
|
||||||
|
session.remove(key);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
var jagg = jagg || (function () {
|
||||||
|
var ctx = context;
|
||||||
|
|
||||||
|
var modules = {};
|
||||||
|
|
||||||
|
var requirs = {};
|
||||||
|
|
||||||
|
var templates = {};
|
||||||
|
|
||||||
|
var initializers = {};
|
||||||
|
|
||||||
|
var bloks = {};
|
||||||
|
|
||||||
|
var data;
|
||||||
|
|
||||||
|
var reverse_proxy;
|
||||||
|
|
||||||
|
var setData = function (d) {
|
||||||
|
data = d;
|
||||||
|
};
|
||||||
|
|
||||||
|
var getData = function () {
|
||||||
|
return data;
|
||||||
|
};
|
||||||
|
|
||||||
|
var getUser = function () {
|
||||||
|
var user = session.get("logged.user");
|
||||||
|
|
||||||
|
// If user is null then check for mutual auth
|
||||||
|
if (!user) {
|
||||||
|
user = mutualAuthVerifier(user);
|
||||||
|
}
|
||||||
|
|
||||||
|
return user;
|
||||||
|
};
|
||||||
|
|
||||||
|
var setUser = function (user) {
|
||||||
|
//if jaggery allow session reset
|
||||||
|
if (typeof request.getSession == "function") {
|
||||||
|
if (session && !session.isNew()) {
|
||||||
|
session.invalidate();
|
||||||
|
}
|
||||||
|
session = request.getSession(true);
|
||||||
|
}
|
||||||
|
session.put("logged.user", user);
|
||||||
|
};
|
||||||
|
|
||||||
|
var mutualAuthVerifier = function(user){
|
||||||
|
|
||||||
|
var log = new Log();
|
||||||
|
var site = require("/site/conf/site.json");
|
||||||
|
|
||||||
|
if(site.mutualAuthConfiguration){
|
||||||
|
if (site.mutualAuthConfiguration.enabled == "true") {
|
||||||
|
|
||||||
|
// cert will be available only if trust store holds client certificate. Otherwise it is null
|
||||||
|
var cert = request.getAttribute("javax.servlet.request.X509Certificate");
|
||||||
|
var userName = request.getHeader("MutualAuthUserName");
|
||||||
|
|
||||||
|
// proceed mutul ssl validation if cert and user name set properly
|
||||||
|
|
||||||
|
if (cert != null) {
|
||||||
|
if (userName) {
|
||||||
|
var security = require("apimstore");
|
||||||
|
var mutualAuthHostObject = new security.MutualAuthHostObject();
|
||||||
|
var isValidUser = mutualAuthHostObject.validateUserNameHeader(userName);
|
||||||
|
// Group ID feature not supported here
|
||||||
|
var groupId="";
|
||||||
|
session.put("groupId", groupId);
|
||||||
|
if (isValidUser) {
|
||||||
|
log.info("Mutual Auth authentication success for user : " + userName);
|
||||||
|
user = {username: userName, cookie: null, hasPublisherAccess: false};
|
||||||
|
return user;
|
||||||
|
} else {
|
||||||
|
log.debug("Mutual authentication failed for invalid user : " + userName);
|
||||||
|
}
|
||||||
|
|
||||||
|
} else {
|
||||||
|
log.debug("Mutual authentication failed for invalid user : MutualAuthUserName header is empty");
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
log.debug("Mutual Authentication failed due to no trusted certificate");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
var getThemeFile = function (path) {
|
||||||
|
var p, index, theme = getUserTheme();
|
||||||
|
if(theme.tenant_theme) {
|
||||||
|
p = getTenantThemePath() + path;
|
||||||
|
index = p.indexOf("?");
|
||||||
|
if(new File(p.substring(0, index == -1 ? p.length : index)).isExists()) {
|
||||||
|
return p;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(theme.subtheme) {
|
||||||
|
p = getThemePath() + "subthemes/" + theme.subtheme + "/" + path;
|
||||||
|
index = p.indexOf("?");
|
||||||
|
if(new File(p.substring(0, index == -1 ? p.length : index)).isExists()) {
|
||||||
|
return p;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return getThemePath() + path;
|
||||||
|
};
|
||||||
|
|
||||||
|
var getThemesPath = function () {
|
||||||
|
return "/site/themes/";
|
||||||
|
};
|
||||||
|
|
||||||
|
var getTenantThemesPath = function(){
|
||||||
|
return "/site/tenant_themes/";
|
||||||
|
};
|
||||||
|
|
||||||
|
var getThemePath = function () {
|
||||||
|
return getThemesPath() + getUserTheme().base + "/";
|
||||||
|
};
|
||||||
|
|
||||||
|
var getTenantThemePath = function (){
|
||||||
|
return getTenantThemesPath() + getTheme().tenant_theme + "/";
|
||||||
|
}
|
||||||
|
|
||||||
|
var getBlockFile = function (name) {
|
||||||
|
return getBlocksDir() + name + "/block.jag";
|
||||||
|
};
|
||||||
|
|
||||||
|
var getInitializerFile = function (name) {
|
||||||
|
return getThemeFile("templates/" + name + "/initializer.jag");
|
||||||
|
};
|
||||||
|
|
||||||
|
var getTemplateFile = function (name) {
|
||||||
|
return getThemeFile("templates/" + name + "/template.jag");
|
||||||
|
};
|
||||||
|
|
||||||
|
var getTemplatePath = function(themeDir, name) {
|
||||||
|
return themeDir + "templates/" + name + "/template.jag";
|
||||||
|
};
|
||||||
|
|
||||||
|
var getModuleFile = function (name) {
|
||||||
|
return getModulesDir() + name + "/module.jag";
|
||||||
|
};
|
||||||
|
|
||||||
|
var getBlocksDir = function () {
|
||||||
|
return "/site/blocks/";
|
||||||
|
};
|
||||||
|
|
||||||
|
var getThemesDir = function () {
|
||||||
|
return "/site/themes/";
|
||||||
|
};
|
||||||
|
|
||||||
|
var getModulesDir = function () {
|
||||||
|
return "/modules/";
|
||||||
|
};
|
||||||
|
|
||||||
|
var getTheme = function () {
|
||||||
|
//TODO : remove following lines if theme switching need to be avoided
|
||||||
|
var site = require("/site/conf/site.json"),
|
||||||
|
theme = request.getParameter("theme"),
|
||||||
|
subtheme = request.getParameter("subtheme");
|
||||||
|
var r = {
|
||||||
|
base : theme ? theme : site.theme.base,
|
||||||
|
subtheme : subtheme ? subtheme : site.theme.subtheme,
|
||||||
|
};
|
||||||
|
//load the tenant theme if exists
|
||||||
|
var tenant = getTenantDomain();
|
||||||
|
if(tenant){
|
||||||
|
tenant = tenant.replace("/",".");
|
||||||
|
r.tenant_theme = getTenantDomain();
|
||||||
|
}
|
||||||
|
return r;
|
||||||
|
};
|
||||||
|
|
||||||
|
var getUserTheme = function () {
|
||||||
|
return session.get("theme") ? session.get("theme") : getTheme();
|
||||||
|
};
|
||||||
|
|
||||||
|
var mergeParams = function (extInputs, defInputs) {
|
||||||
|
var key, obj;
|
||||||
|
extInputs = extInputs || {};
|
||||||
|
for (key in defInputs) {
|
||||||
|
if (defInputs.hasOwnProperty(key)) {
|
||||||
|
obj = extInputs[key];
|
||||||
|
if (!obj) {
|
||||||
|
extInputs[key] = defInputs[key];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return extInputs;
|
||||||
|
};
|
||||||
|
|
||||||
|
var renderBlock = function (name, inputs, outputs, populate) {
|
||||||
|
//initializeTemplate({name:name, params:null}, jagg);
|
||||||
|
|
||||||
|
var init, fn, blok, log = new Log();
|
||||||
|
|
||||||
|
fn = template(name);
|
||||||
|
if (!fn) {
|
||||||
|
log.error("Template header and footer includes are missing for : " + name);
|
||||||
|
}
|
||||||
|
if (populate) {
|
||||||
|
blok = block(name);
|
||||||
|
|
||||||
|
if (!inputs) {
|
||||||
|
inputs = blok.getInputs ? blok.getInputs() : {};
|
||||||
|
} else {
|
||||||
|
mergeParams(inputs, blok.getInputs ? blok.getInputs() : null);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (blok.getOutputs) {
|
||||||
|
outputs = blok.getOutputs(inputs);
|
||||||
|
} else if (blok.getInputs) {
|
||||||
|
outputs = inputs;
|
||||||
|
} else {
|
||||||
|
outputs = {};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
init = initializer(name);
|
||||||
|
if (init.postInitialize) {
|
||||||
|
init.postInitialize(inputs, outputs);
|
||||||
|
}
|
||||||
|
fn(inputs, outputs, jagg);
|
||||||
|
};
|
||||||
|
|
||||||
|
var inheritParent = function (blok, name) {
|
||||||
|
var parent = require(getBlockFile(name));
|
||||||
|
for (var prop in parent) {
|
||||||
|
if (parent.hasOwnProperty(prop)) {
|
||||||
|
if (!blok[prop]) {
|
||||||
|
blok[prop] = parent[prop];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
var initializeBlock = function (obj) {
|
||||||
|
if (!obj) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
var extInputs, defInputs, parent, tmpl, inputBlocks, outputBlocks, outputs, tmplInitializer, bloks, i, length,
|
||||||
|
name = obj.name, blok = block(name), log = new Log();
|
||||||
|
|
||||||
|
template(name);
|
||||||
|
extInputs = obj.inputs || (obj.inputs = {});
|
||||||
|
defInputs = blok.getInputs ? blok.getInputs() : {};
|
||||||
|
mergeParams(extInputs, defInputs);
|
||||||
|
|
||||||
|
if (blok.getInputBlocks) {
|
||||||
|
inputBlocks = blok.getInputBlocks();
|
||||||
|
length = inputBlocks.length;
|
||||||
|
for (i = 0; i < length; i++) {
|
||||||
|
initializeBlocks(inputBlocks[i], extInputs);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (blok.getOutputs) {
|
||||||
|
outputs = blok.getOutputs(extInputs);
|
||||||
|
} else if (blok.getInputs) {
|
||||||
|
outputs = extInputs;
|
||||||
|
} else {
|
||||||
|
outputs = {};
|
||||||
|
}
|
||||||
|
|
||||||
|
obj.outputs = outputs;
|
||||||
|
if (blok.getOutputBlocks) {
|
||||||
|
outputBlocks = blok.getOutputBlocks();
|
||||||
|
length = outputBlocks.length;
|
||||||
|
for (i = 0; i < length; i++) {
|
||||||
|
initializeBlocks(outputBlocks[i], outputs);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (blok.getStaticBlocks) {
|
||||||
|
bloks = blok.getStaticBlocks();
|
||||||
|
length = bloks.length;
|
||||||
|
for (i = 0; i < length; i++) {
|
||||||
|
initializeBlock({name:bloks[i], inputs:null});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// [ "foo", "bar", "mar"]
|
||||||
|
// [{ "name" : "foo/bar", params : {}}]
|
||||||
|
var initializeBlocks = function (keys, inputs) {
|
||||||
|
if (!inputs) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
var i, length, values, last;
|
||||||
|
if (typeof keys !== "string") {
|
||||||
|
length = keys.length;
|
||||||
|
values = inputs[keys[0]];
|
||||||
|
last = (length == 1);
|
||||||
|
if (values instanceof Array) {
|
||||||
|
length = values.length;
|
||||||
|
for (i = 0; i < length; i++) {
|
||||||
|
if (last) {
|
||||||
|
initializeBlock(values[i]);
|
||||||
|
} else {
|
||||||
|
initializeBlocks(keys.slice(1), values[i]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
if (last) {
|
||||||
|
initializeBlock(values);
|
||||||
|
} else {
|
||||||
|
initializeBlocks(keys.slice(1), values);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return;
|
||||||
|
} else {
|
||||||
|
values = inputs[keys];
|
||||||
|
}
|
||||||
|
|
||||||
|
if (values instanceof Array) {
|
||||||
|
length = values.length;
|
||||||
|
for (i = 0; i < length; i++) {
|
||||||
|
initializeBlock(values[i]);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
initializeBlock(values);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
var insertData = function (jagg, template, parent, name, key, value) {
|
||||||
|
var keys, values, data = getData();
|
||||||
|
data = data[parent] || (data[parent] = {});
|
||||||
|
data = data[name] || (data[name] = {});
|
||||||
|
data = data[template] || (data[template] = {});
|
||||||
|
|
||||||
|
keys = data.keys || (data.keys = []);
|
||||||
|
values = data.values || (data.values = {});
|
||||||
|
|
||||||
|
keys.push(key);
|
||||||
|
values[key] = value;
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
var printData = function (tmpls) {
|
||||||
|
var key, tmpl, keys, values, i, length;
|
||||||
|
for (key in tmpls) {
|
||||||
|
if (tmpls.hasOwnProperty(key)) {
|
||||||
|
tmpl = tmpls[key];
|
||||||
|
keys = tmpl.keys;
|
||||||
|
values = tmpl.values;
|
||||||
|
length = keys.length;
|
||||||
|
for (i = 0; i < length; i++) {
|
||||||
|
print(values[keys[i]]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
var getUrlMapping = function (path) {
|
||||||
|
var urlMap = ctx.get("url.map"), url, configs, i, length, mapping, mappings, file;
|
||||||
|
if (urlMap) {
|
||||||
|
url = urlMap[path];
|
||||||
|
return url ? url : path;
|
||||||
|
}
|
||||||
|
file = new File("/jaggery.conf");
|
||||||
|
file.open("r");
|
||||||
|
configs = parse(file.readAll());
|
||||||
|
file.close();
|
||||||
|
|
||||||
|
urlMap = {};
|
||||||
|
mappings = configs.urlMappings;
|
||||||
|
length = mappings.length;
|
||||||
|
for (i = 0; i < length; i++) {
|
||||||
|
mapping = mappings[i];
|
||||||
|
urlMap[mapping.path] = mapping.url;
|
||||||
|
}
|
||||||
|
ctx.put("url.map", urlMap);
|
||||||
|
url = urlMap[path];
|
||||||
|
return url ? url : path;
|
||||||
|
};
|
||||||
|
|
||||||
|
var getRequestSegments = function(){
|
||||||
|
var href = request.getRequestURL()
|
||||||
|
var match = href.match(/^(https?\:)\/\/(([^:\/?#]*)(?:\:([0-9]+))?)(\/[^?#]*)(\?[^#]*|)(#.*|)$/);
|
||||||
|
return match && {
|
||||||
|
protocol: match[1],
|
||||||
|
host: match[2],
|
||||||
|
hostname: match[3],
|
||||||
|
port: match[4],
|
||||||
|
pathname: match[5],
|
||||||
|
search: match[6],
|
||||||
|
hash: match[7]
|
||||||
|
}
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
var getMappedUrl = function (path) {
|
||||||
|
return getAbsoluteUrl(getUrlMapping(path));
|
||||||
|
};
|
||||||
|
|
||||||
|
var getAbsoluteUrl = function (path) {
|
||||||
|
var host = ""
|
||||||
|
if(isReverseProxyEnabled()){
|
||||||
|
host = "https://" + site.reverseProxy.host ;
|
||||||
|
}else{
|
||||||
|
var match = getRequestSegments();
|
||||||
|
var host = match.protocol + "//" + match.host;
|
||||||
|
}
|
||||||
|
return host + url(path);
|
||||||
|
};
|
||||||
|
|
||||||
|
var getSiteDomainFromRequest = function(){
|
||||||
|
var match = href.match(/^(https?\:)\/\/(([^:\/?#]*)(?:\:([0-9]+))?)(\/[^?#]*)(\?[^#]*|)(#.*|)$/);
|
||||||
|
}
|
||||||
|
|
||||||
|
var getHttpsUrl = function(path, parameters){
|
||||||
|
var hostname = "";
|
||||||
|
var requestSegments = getRequestSegments();
|
||||||
|
mod = jagg.module("manager");
|
||||||
|
hostname = mod.getHTTPsURL();
|
||||||
|
hostname = hostname.replace("https://","");
|
||||||
|
|
||||||
|
// if the site is fronted by a proxy server
|
||||||
|
if(isReverseProxyEnabled()){
|
||||||
|
hostname = site.reverseProxy.host ;
|
||||||
|
//if a custom https port is used
|
||||||
|
if(site.reverseProxy.hosts_port){
|
||||||
|
hostname = hostname + ":" + site.reverseProxy.hosts_port;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return "https://" + hostname + url(path, parameters);
|
||||||
|
}
|
||||||
|
|
||||||
|
var url = function(path,parameters){
|
||||||
|
var tail = "";
|
||||||
|
if(parameters){
|
||||||
|
var params = [];
|
||||||
|
for (var key in parameters) {
|
||||||
|
params.push(key+"="+parameters[key]) ;
|
||||||
|
}
|
||||||
|
if(/\?/.test(path)){
|
||||||
|
tail = "&";
|
||||||
|
}
|
||||||
|
else{
|
||||||
|
tail = "?";
|
||||||
|
}
|
||||||
|
tail = tail + params.join("&");
|
||||||
|
}
|
||||||
|
return getSiteContext()+ path + tail;
|
||||||
|
};
|
||||||
|
|
||||||
|
// following function will generate a url with the currently activated tenant
|
||||||
|
var urlTenanted = function(path, parameters){
|
||||||
|
//if tenented add tenant url
|
||||||
|
if(getTenantDomain() != null && !(/(\?tenant\=|\&tenant\=)/i.test(path))){
|
||||||
|
if(!parameters){
|
||||||
|
parameters = {};
|
||||||
|
}
|
||||||
|
parameters.tenant = getTenantDomain();
|
||||||
|
}
|
||||||
|
if(isReverseProxyEnabled()){
|
||||||
|
return getHttpsUrl(path, parameters)
|
||||||
|
}
|
||||||
|
return url(path,parameters)
|
||||||
|
};
|
||||||
|
|
||||||
|
var getCarbonProxyContextPath = function(){
|
||||||
|
var CarbonUtils = Packages.org.wso2.carbon.utils.CarbonUtils;
|
||||||
|
var carbonUtils = new CarbonUtils();
|
||||||
|
var context = carbonUtils.getServerConfiguration().getFirstProperty("ProxyContextPath");
|
||||||
|
if(context != null)
|
||||||
|
return context;
|
||||||
|
else
|
||||||
|
return '';
|
||||||
|
};
|
||||||
|
|
||||||
|
var isReverseProxyEnabled = function(){
|
||||||
|
if(reverse_proxy != undefined){
|
||||||
|
return reverse_proxy;
|
||||||
|
}
|
||||||
|
if(site.reverseProxy.enabled){
|
||||||
|
if(site.reverseProxy.enabled == "auto"){
|
||||||
|
var xfwd = request.getHeader("X-Forwarded-Host");
|
||||||
|
if(xfwd != null){
|
||||||
|
var xfwd = xfwd.split(",")[0];
|
||||||
|
//if(xfwd.trim() == site.reverseProxy.host){
|
||||||
|
reverse_proxy = true;
|
||||||
|
site.reverseProxy.host = xfwd.trim();
|
||||||
|
//}
|
||||||
|
}else{
|
||||||
|
reverse_proxy = false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else{
|
||||||
|
reverse_proxy = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else{
|
||||||
|
reverse_proxy = false;
|
||||||
|
}
|
||||||
|
return reverse_proxy;
|
||||||
|
};
|
||||||
|
|
||||||
|
var getSiteContext = function(){
|
||||||
|
if(isReverseProxyEnabled()){
|
||||||
|
//If we use a custom domain mapping we will not use the context.
|
||||||
|
if( site.reverseProxy.tenantHeader != null &&
|
||||||
|
request.getHeader(site.reverseProxy.tenantHeader) != null){
|
||||||
|
return "";
|
||||||
|
}
|
||||||
|
else{
|
||||||
|
return site.reverseProxy.context
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
var proxyContext = getCarbonProxyContextPath();
|
||||||
|
return proxyContext + site.context;
|
||||||
|
};
|
||||||
|
|
||||||
|
var getRegistryPath = function(path){
|
||||||
|
if(isReverseProxyEnabled()){
|
||||||
|
if(site.reverseProxy.regContext != undefined){
|
||||||
|
return site.reverseProxy.regContext + path;
|
||||||
|
}
|
||||||
|
return site.reverseProxy.context + path;
|
||||||
|
}
|
||||||
|
|
||||||
|
var ProxyContextPath = getCarbonProxyContextPath();
|
||||||
|
return ProxyContextPath + path;
|
||||||
|
}
|
||||||
|
|
||||||
|
var module = function (name, module) {
|
||||||
|
if (module) {
|
||||||
|
return modules[name] = module;
|
||||||
|
}
|
||||||
|
module = modules[name];
|
||||||
|
if (module) {
|
||||||
|
return module;
|
||||||
|
}
|
||||||
|
include(getModuleFile(name));
|
||||||
|
return modules[name];
|
||||||
|
};
|
||||||
|
|
||||||
|
var requir = function (path) {
|
||||||
|
var obj = requirs[path];
|
||||||
|
return obj ? obj : requirs[path] = require(path);
|
||||||
|
};
|
||||||
|
|
||||||
|
var block = function (name, blok) {
|
||||||
|
var parent;
|
||||||
|
if (blok) {
|
||||||
|
return bloks[name] = blok;
|
||||||
|
}
|
||||||
|
blok = bloks[name];
|
||||||
|
if (blok) {
|
||||||
|
return blok;
|
||||||
|
}
|
||||||
|
//we need to include and initialize
|
||||||
|
include(getBlockFile(name));
|
||||||
|
blok = bloks[name];
|
||||||
|
parent = blok.getParent;
|
||||||
|
if (parent) {
|
||||||
|
parent = parent();
|
||||||
|
inheritParent(blok, parent);
|
||||||
|
}
|
||||||
|
if (blok.initialize) {
|
||||||
|
//TODO which to pass into initialize method
|
||||||
|
blok.initialize(getData());
|
||||||
|
}
|
||||||
|
return bloks[name];
|
||||||
|
};
|
||||||
|
|
||||||
|
var template = function (name, tmpl) {
|
||||||
|
var blok, parent, init;
|
||||||
|
if (tmpl) {
|
||||||
|
return templates[name] = tmpl;
|
||||||
|
}
|
||||||
|
tmpl = templates[name];
|
||||||
|
if (tmpl) {
|
||||||
|
return tmpl;
|
||||||
|
}
|
||||||
|
|
||||||
|
blok = block(name);
|
||||||
|
parent = blok.getParent;
|
||||||
|
if (parent) {
|
||||||
|
name = parent();
|
||||||
|
}
|
||||||
|
|
||||||
|
tmpl = templates[name];
|
||||||
|
if (tmpl) {
|
||||||
|
return tmpl;
|
||||||
|
}
|
||||||
|
|
||||||
|
include(getTemplateFile(name));
|
||||||
|
init = initializer(name);
|
||||||
|
if (init.preInitialize) {
|
||||||
|
init.preInitialize();
|
||||||
|
}
|
||||||
|
return templates[name];
|
||||||
|
};
|
||||||
|
|
||||||
|
var initializer = function (name, init) {
|
||||||
|
var blok, parent;
|
||||||
|
if (init) {
|
||||||
|
return initializers[name] = init;
|
||||||
|
}
|
||||||
|
init = initializers[name];
|
||||||
|
if (init) {
|
||||||
|
return init;
|
||||||
|
}
|
||||||
|
|
||||||
|
blok = block(name);
|
||||||
|
parent = blok.getParent;
|
||||||
|
if (parent) {
|
||||||
|
name = parent();
|
||||||
|
}
|
||||||
|
|
||||||
|
init = initializers[name];
|
||||||
|
if (init) {
|
||||||
|
return init;
|
||||||
|
}
|
||||||
|
|
||||||
|
include(getInitializerFile(name));
|
||||||
|
return initializers[name];
|
||||||
|
};
|
||||||
|
|
||||||
|
var render = function (obj) {
|
||||||
|
var init, fn, inputs, outputs, name = obj.name, log = new Log(), blok;
|
||||||
|
setData(obj);
|
||||||
|
initializeBlock(obj);
|
||||||
|
include(getTemplateFile(name));
|
||||||
|
fn = template(name);
|
||||||
|
if (!fn) {
|
||||||
|
log.error("Template header and footer includes are missing for : " + name);
|
||||||
|
}
|
||||||
|
inputs = obj.inputs;
|
||||||
|
blok = block(name);
|
||||||
|
if (blok.getOutputs) {
|
||||||
|
outputs = blok.getOutputs(inputs);
|
||||||
|
} else if (blok.getInputs) {
|
||||||
|
outputs = inputs;
|
||||||
|
} else {
|
||||||
|
outputs = {};
|
||||||
|
}
|
||||||
|
init = initializer(name);
|
||||||
|
if (init.postInitialize) {
|
||||||
|
init.postInitialize(inputs, outputs);
|
||||||
|
}
|
||||||
|
fn(inputs, outputs, jagg);
|
||||||
|
};
|
||||||
|
|
||||||
|
var includeBlock = function (name, inputs) {
|
||||||
|
renderBlock(name, inputs, null, true);
|
||||||
|
};
|
||||||
|
|
||||||
|
var includeBlocks = function (bloks) {
|
||||||
|
if (!bloks) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
var i, d, length;
|
||||||
|
if (bloks instanceof Array) {
|
||||||
|
length = bloks.length;
|
||||||
|
for (i = 0; i < length; i++) {
|
||||||
|
d = bloks[i];
|
||||||
|
renderBlock(d.name, d.inputs, d.outputs, false);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
renderBlock(bloks.name, bloks.inputs, bloks.outputs, false);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
var addHeaderCSS = function (template, key, css) {
|
||||||
|
css = '<link type="text/css" rel="stylesheet" href="' + url(getThemeFile(css)) + '"/>';
|
||||||
|
insertData(this, template, "header", "css", key, css);
|
||||||
|
};
|
||||||
|
|
||||||
|
var addHeaderCSSCode = function (template, key, css) {
|
||||||
|
css = '<style type="text/css">' + css + '</style>';
|
||||||
|
insertData(this, template, "header", "css", key, css);
|
||||||
|
};
|
||||||
|
|
||||||
|
var addHeaderJS = function (template, key, js) {
|
||||||
|
js = '<script type="text/javascript" src="' + url(getThemeFile(js)) + '"></script>\n';
|
||||||
|
insertData(this, template, "header", "js", key, js);
|
||||||
|
};
|
||||||
|
|
||||||
|
var addHeaderJSCode = function (template, key, js) {
|
||||||
|
js = '<script type="text/javascript">' + js + '</script>';
|
||||||
|
insertData(this, template, "header", "js", key, js);
|
||||||
|
};
|
||||||
|
|
||||||
|
var addHeaderCode = function (template, key, code) {
|
||||||
|
insertData(this, template, "header", "code", key, code);
|
||||||
|
};
|
||||||
|
|
||||||
|
var addFooterCSS = function (template, key, css) {
|
||||||
|
css = '<link type="text/css" rel="stylesheet" href="' + url(getThemeFile(css)) + '"/>';
|
||||||
|
insertData(this, template, "footer", "css", key, css);
|
||||||
|
};
|
||||||
|
|
||||||
|
var addFooterCSSCode = function (template, key, css) {
|
||||||
|
css = '<style type="text/css">' + css + '</style>';
|
||||||
|
insertData(this, template, "footer", "css", key, css);
|
||||||
|
};
|
||||||
|
|
||||||
|
var addFooterJS = function (template, key, js) {
|
||||||
|
js = '\t<script type="text/javascript" src="' + url(getThemeFile(js)) + '"></script>\n';
|
||||||
|
insertData(this, template, "footer", "js", key, js);
|
||||||
|
};
|
||||||
|
|
||||||
|
var addFooterJSCode = function (template, key, js) {
|
||||||
|
js = '<script type="text/javascript">' + js + '</script>';
|
||||||
|
insertData(this, template, "footer", "js", key, js);
|
||||||
|
};
|
||||||
|
|
||||||
|
var addFooterCode = function (template, key, code) {
|
||||||
|
insertData(this, template, "footer", "code", key, code);
|
||||||
|
};
|
||||||
|
|
||||||
|
var includeJag = function (path) {
|
||||||
|
include(getThemeFile(path));
|
||||||
|
};
|
||||||
|
|
||||||
|
var getTenantDomain = function(){
|
||||||
|
if(isReverseProxyEnabled()){
|
||||||
|
// check if tenant header exists
|
||||||
|
if(site.reverseProxy.tenantHeader != undefined && site.reverseProxy.tenantHeader != null
|
||||||
|
&& request.getHeader(site.reverseProxy.tenantHeader) != null){
|
||||||
|
return request.getHeader(site.reverseProxy.tenantHeader);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return request.getParameter("tenant");
|
||||||
|
}
|
||||||
|
|
||||||
|
var setCSRFToken = function(){
|
||||||
|
var cookie = request.getCookie("csrftoken");
|
||||||
|
var user = jagg.getUser();
|
||||||
|
var csrfuser = session.get('csrfuser');
|
||||||
|
//set CSRF if it is not set + you need to refresh the token if the user has changed.
|
||||||
|
if( !cookie || user != csrfuser){
|
||||||
|
//Use a secure random as the CSRF token.
|
||||||
|
var SecureRandom = Packages.java.security.SecureRandom;
|
||||||
|
var random = new SecureRandom();
|
||||||
|
var BigInteger = Packages.java.math.BigInteger;
|
||||||
|
var token = new BigInteger(130, random).toString(32);
|
||||||
|
|
||||||
|
var cookie= {'name':'csrftoken','value': token , 'maxAge': 86400, 'path':"/"};
|
||||||
|
session.put('csrfuser',user);
|
||||||
|
response.addCookie(cookie);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
var isCSRFTokenValid = function(){
|
||||||
|
var log = new Log();
|
||||||
|
var cookie = request.getCookie("csrftoken");
|
||||||
|
var token = request.getHeader("X-CSRFToken");
|
||||||
|
var user = jagg.getUser();
|
||||||
|
if(cookie == null || cookie.value == token){
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
else{
|
||||||
|
log.info("CSRF Token error at "+request.getRequestURI());
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
var validateInputs = function(config){
|
||||||
|
var errors = [];
|
||||||
|
//set most used parapeters
|
||||||
|
config.name = { type:"name"};
|
||||||
|
config.provider = { type:"provider"};
|
||||||
|
config.version = { type:"name"};
|
||||||
|
|
||||||
|
for(var key in config){
|
||||||
|
var value = request.getParameter(key);
|
||||||
|
if(value == null){
|
||||||
|
if(config[key].required)
|
||||||
|
errors.push(key);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
switch (config[key].type) {
|
||||||
|
case "url":
|
||||||
|
break;
|
||||||
|
case "input":
|
||||||
|
var regex = /([<>\"\'])/;
|
||||||
|
if(regex.test(value)) errors.push(key);
|
||||||
|
break;
|
||||||
|
case "number":
|
||||||
|
var regex = /^[0-9]*$/;
|
||||||
|
if(!regex.test(value)) errors.push(key);
|
||||||
|
break;
|
||||||
|
case "safetext":
|
||||||
|
var regex = /^[a-zA-Z0-9]*$/;
|
||||||
|
if(!regex.test(value)) errors.push(key);
|
||||||
|
break;
|
||||||
|
case "uuid":
|
||||||
|
var regex = /^[a-zA-Z0-9\-]*$/;
|
||||||
|
if(!regex.test(value)) errors.push(key);
|
||||||
|
break;
|
||||||
|
case "name":
|
||||||
|
var regex = /([~!#$;%^*+={}\|\\<>\"\'\/,])/;
|
||||||
|
if(regex.test(value)) errors.push(key);
|
||||||
|
break;
|
||||||
|
case "password":
|
||||||
|
var regex = /^[\S]{5,30}$/;
|
||||||
|
if(!regex.test(value)) errors.push(key);
|
||||||
|
break;
|
||||||
|
case "email":
|
||||||
|
var regex = /^([A-Za-z0-9_\-\.])+\@([A-Za-z0-9_\-\.])+\.([A-Za-z]{2,4})$/;
|
||||||
|
if(!regex.test(value)) errors.push(key);
|
||||||
|
break;
|
||||||
|
case "provider":
|
||||||
|
var regex = /([~!#$;%^*+={}\|\\<>\"\'\,])/;
|
||||||
|
if(regex.test(value)) errors.push(key);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(errors.length > 0){
|
||||||
|
return errors;
|
||||||
|
}
|
||||||
|
else{
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return {
|
||||||
|
setUser:setUser,
|
||||||
|
getUser:getUser,
|
||||||
|
block:block,
|
||||||
|
module:module,
|
||||||
|
initializer:initializer,
|
||||||
|
includeBlock:includeBlock,
|
||||||
|
includeBlocks:includeBlocks,
|
||||||
|
render:render,
|
||||||
|
template:template,
|
||||||
|
require:requir,
|
||||||
|
getAbsoluteUrl:getAbsoluteUrl,
|
||||||
|
getMappedUrl:getMappedUrl,
|
||||||
|
printData:printData,
|
||||||
|
getUserTheme:getUserTheme,
|
||||||
|
getThemeFile:getThemeFile,
|
||||||
|
getModulesDir:getModulesDir,
|
||||||
|
data:getData,
|
||||||
|
addHeaderCSS:addHeaderCSS,
|
||||||
|
addHeaderCSSCode:addHeaderCSSCode,
|
||||||
|
addHeaderJS:addHeaderJS,
|
||||||
|
addHeaderJSCode:addHeaderJSCode,
|
||||||
|
addHeaderCode:addHeaderCode,
|
||||||
|
addFooterCSS:addFooterCSS,
|
||||||
|
addFooterCSSCode:addFooterCSSCode,
|
||||||
|
addFooterJS:addFooterJS,
|
||||||
|
addFooterJSCode:addFooterJSCode,
|
||||||
|
addFooterCode:addFooterCode,
|
||||||
|
includeJag:includeJag,
|
||||||
|
url:url,
|
||||||
|
urlTenanted:urlTenanted,
|
||||||
|
getRegistryPath:getRegistryPath,
|
||||||
|
getSiteContext:getSiteContext,
|
||||||
|
getHttpsUrl:getHttpsUrl,
|
||||||
|
getTenantDomain:getTenantDomain,
|
||||||
|
setCSRFToken:setCSRFToken,
|
||||||
|
isCSRFTokenValid:isCSRFTokenValid,
|
||||||
|
validateInputs:validateInputs,
|
||||||
|
};
|
||||||
|
|
||||||
|
}());
|
||||||
|
%>
|
||||||
@ -0,0 +1,168 @@
|
|||||||
|
<%
|
||||||
|
var getAuthServerURL = function() {
|
||||||
|
return getAPIStoreObj().getAuthServerURL();
|
||||||
|
};
|
||||||
|
|
||||||
|
var getHTTPsURL = function() {
|
||||||
|
return getAPIStoreObj().getHTTPsURL(request.getRequestURL());
|
||||||
|
};
|
||||||
|
|
||||||
|
var getHTTPURL = function() {
|
||||||
|
return getAPIStoreObj().getHTTPURL();
|
||||||
|
};
|
||||||
|
|
||||||
|
var getHostname = function() {
|
||||||
|
return getAPIStoreObj().getHostName();
|
||||||
|
};
|
||||||
|
|
||||||
|
var getAPIPublisherURL = function() {
|
||||||
|
var result,log=new Log();
|
||||||
|
var store = getAPIStoreObj();
|
||||||
|
try {
|
||||||
|
result = store.getAPIPublisherURL();
|
||||||
|
if (log.isDebugEnabled()) {
|
||||||
|
log.debug("getAPIPublisherURL : ");
|
||||||
|
}
|
||||||
|
return {
|
||||||
|
error:false,
|
||||||
|
url:result
|
||||||
|
};
|
||||||
|
} catch (e) {
|
||||||
|
return {
|
||||||
|
error:true,
|
||||||
|
message:e.message.split(":")[1]
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
var getServer = function() {
|
||||||
|
return {
|
||||||
|
server : "localhost",
|
||||||
|
port : "9443"
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
|
var isSelfSignupEnabled = function(){
|
||||||
|
return getAPIStoreObj().isSelfSignupEnabled();
|
||||||
|
};
|
||||||
|
|
||||||
|
var isSelfSignupEnabledForTenantUser = function(tenantDomain){
|
||||||
|
var log = new Log();
|
||||||
|
try {
|
||||||
|
|
||||||
|
if (tenantDomain == null) {
|
||||||
|
return getAPIStoreObj().isSelfSignupEnabledForTenant("carbon.super");
|
||||||
|
} else {
|
||||||
|
return getAPIStoreObj().isSelfSignupEnabledForTenant(tenantDomain);
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
log.error(e.message);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
var getAdminCookie = function() {
|
||||||
|
//TODO : this should be set in the Context during the deployment
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
var getAPIStoreObj = function() {
|
||||||
|
|
||||||
|
var tenantDomain = jagg.getTenantDomain();
|
||||||
|
var user = jagg.getUser();
|
||||||
|
var store;
|
||||||
|
if (user == null) {
|
||||||
|
store = require('apimstore');
|
||||||
|
var storeHostObj = new store.APIStore();
|
||||||
|
if(tenantDomain != null && tenantDomain != ""){
|
||||||
|
storeHostObj.loadRegistryOfTenant(tenantDomain);
|
||||||
|
}
|
||||||
|
return storeHostObj;
|
||||||
|
} else {
|
||||||
|
store = require('apimstore');
|
||||||
|
return new store.APIStore(user.username);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
var getAPIConsumerObj = function() {
|
||||||
|
var user = jagg.getUser();
|
||||||
|
|
||||||
|
var APIManagerFactory = Packages.org.wso2.carbon.apimgt.impl.APIManagerFactory;
|
||||||
|
|
||||||
|
return APIManagerFactory.getInstance().getAPIConsumer(user);
|
||||||
|
};
|
||||||
|
|
||||||
|
var loadTenantRegistry = function (tenantDomain) {
|
||||||
|
try {
|
||||||
|
if (tenantDomain != null && tenantDomain != "") {
|
||||||
|
getAPIStoreObj().loadRegistryOfTenant(tenantDomain);
|
||||||
|
return
|
||||||
|
{
|
||||||
|
error:false
|
||||||
|
}
|
||||||
|
;
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
return {
|
||||||
|
error:true,
|
||||||
|
message:e.message
|
||||||
|
};
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
var loadTenantAxisConfiguration = function (tenantDomain) {
|
||||||
|
|
||||||
|
try {
|
||||||
|
if (tenantDomain != null && tenantDomain != "") {
|
||||||
|
|
||||||
|
getAPIStoreObj().loadAxisConfigOfTenant(String(tenantDomain));
|
||||||
|
return
|
||||||
|
{
|
||||||
|
error:false
|
||||||
|
}
|
||||||
|
;
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
return {
|
||||||
|
error:true,
|
||||||
|
message:e.message
|
||||||
|
};
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
var getActiveTenantDomains=function(){
|
||||||
|
var tenantDomains,
|
||||||
|
log = new Log(),
|
||||||
|
store = jagg.module("manager").getAPIStoreObj();
|
||||||
|
|
||||||
|
try {
|
||||||
|
tenantDomains = store.getActiveTenantDomains();
|
||||||
|
tenantDomains = parse(stringify(tenantDomains));
|
||||||
|
if (log.isDebugEnabled()) {
|
||||||
|
log.debug("isTenantMode : " + stringify(api));
|
||||||
|
}
|
||||||
|
|
||||||
|
return {
|
||||||
|
error:false,
|
||||||
|
tenantDomains:tenantDomains
|
||||||
|
};
|
||||||
|
} catch (e) {
|
||||||
|
//log.error(e.message);
|
||||||
|
return {
|
||||||
|
error:true,
|
||||||
|
tenantDomains:null,
|
||||||
|
message:e.message
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
var getUsageClient = function(){
|
||||||
|
var user = jagg.getUser();
|
||||||
|
return org.wso2.carbon.apimgt.usage.client.UsageClient.getClient(user);
|
||||||
|
}
|
||||||
|
|
||||||
|
%>
|
||||||
@ -0,0 +1,10 @@
|
|||||||
|
<module name="apimstore" namespace="ns" expose="true" xmlns="http://wso2.org/projects/jaggery/module.xml">
|
||||||
|
<hostObject>
|
||||||
|
<className>org.wso2.carbon.apimgt.hostobjects.APIStoreHostObject</className>
|
||||||
|
<name>APIStore</name>
|
||||||
|
</hostObject>
|
||||||
|
<hostObject>
|
||||||
|
<className>org.wso2.carbon.apimgt.hostobjects.MutualAuthHostObject</className>
|
||||||
|
<name>MutualAuthHostObject</name>
|
||||||
|
</hostObject>
|
||||||
|
</module>
|
||||||
Loading…
Reference in new issue