You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by is...@apache.org on 2014/04/04 08:19:59 UTC
[21/33] Removed autoscaler,
cloud-controller and stratos-manager products
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/artifacts.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/artifacts.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/artifacts.js
deleted file mode 100644
index a05e567..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/artifacts.js
+++ /dev/null
@@ -1,595 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-(function (server, registry) {
-
- var log = new Log();
-
- var GenericArtifactManager = Packages.org.wso2.carbon.governance.api.generic.GenericArtifactManager;
- var GenericArtifactFilter = Packages.org.wso2.carbon.governance.api.generic.GenericArtifactFilter;
- var ByteArrayInputStream = Packages.java.io.ByteArrayInputStream;
- var QName = Packages.javax.xml.namespace.QName;
- var IOUtils = Packages.org.apache.commons.io.IOUtils;
- var PrivilegedCarbonContext = Packages.org.wso2.carbon.context.PrivilegedCarbonContext; //Used regard tenant details
- var CarbonContext = Packages.org.wso2.carbon.context.CarbonContext;
- var MultitenantConstants = Packages.org.wso2.carbon.utils.multitenancy.MultitenantConstants;
- var List = java.util.List;
- var Map = java.util.Map;
- var ArrayList = java.util.ArrayList;
- var HashMap = java.util.HashMap;
-
- var GovernanceUtils = Packages.org.wso2.carbon.governance.api.util.GovernanceUtils;//Used to obtain Asset Types
- var DEFAULT_MEDIA_TYPE = 'application/vnd.wso2.registry-ext-type+xml';//Used to obtain Asset types
- var PaginationContext = Packages.org.wso2.carbon.registry.core.pagination.PaginationContext;//Used for pagination on register
-
- var REGISTRY_ABSOLUTE_PATH = "/_system/governance";
-
- var HISTORY_PATH_SEPERATOR = '_';
- var ASSET_PATH_SEPERATOR = '/';
- var lcHistoryRegExpression = new RegExp(ASSET_PATH_SEPERATOR, 'g');
- var HISTORY_PATH = '/_system/governance/_system/governance/repository/components/org.wso2.carbon.governance/lifecycles/history/';
-
-
- var buildArtifact = function (manager, artifact) {
- return {
- id: String(artifact.id),
- type: String(manager.type),
- path: "/_system/governance" + String(artifact.getPath()),
- lifecycle: artifact.getLifecycleName(),
- lifecycleState: artifact.getLifecycleState(),
- mediaType: String(artifact.getMediaType()),
- attributes: (function () {
- var i, name,
- names = artifact.getAttributeKeys(),
- length = names.length,
- attributes = {};
- for (i = 0; i < length; i++) {
- name = names[i];
-
- var data = artifact.getAttributes(name);
-
- //Check if there is only one element
- if (data.length == 1) {
- attributes[name] = String(artifact.getAttribute(name));
- }
- else {
- attributes[name] = data;
- }
- }
- return attributes;
- }()),
- content: function () {
- return new Stream(new ByteArrayInputStream(artifact.getContent()));
- }
- };
- };
-
- var createArtifact = function (manager, options) {
- var name, attribute, i, length, lc,
- artifact = manager.newGovernanceArtifact(new QName(options.name)),
- attributes = options.attributes;
- for (name in attributes) {
- if (attributes.hasOwnProperty(name)) {
- attribute = attributes[name];
- if (attribute instanceof Array) {
- /*length = attribute.length;
- for (i = 0; i < length; i++) {
- artifact.addAttribute(name, attribute[i]);
- }*/
- artifact.setAttributes(name, attribute);
- } else {
- artifact.setAttribute(name, attribute);
- }
- }
- }
- if (options.id) {
- artifact.id = options.id;
- }
- if (options.content) {
- if (options.content instanceof Stream) {
- artifact.setContent(IOUtils.toByteArray(options.content.getStream()));
- } else {
- artifact.setContent(new java.lang.String(options.content).getBytes());
- }
- }
- lc = options.lifecycles;
- if (lc) {
- length = lc.length;
- for (i = 0; i < length; i++) {
- artifact.attachLifeCycle(lc[i]);
- }
- }
- return artifact;
- };
-
- var ArtifactManager = function (registry, type) {
- this.registry = registry;
- this.manager = new GenericArtifactManager(registry.registry.getChrootedRegistry("/_system/governance"), type);
- this.type = type;
- };
- registry.ArtifactManager = ArtifactManager;
-
- ArtifactManager.prototype.find = function (fn, paging) {
- var i, length, artifacts,
- artifactz = [];
- artifacts = this.manager.findGenericArtifacts(new GenericArtifactFilter({
- matches: function (artifact) {
- return fn(buildArtifact(this, artifact));
- }
- }));
- length = artifacts.length;
- for (i = 0; i < length; i++) {
- artifactz.push(buildArtifact(this, artifacts[i]));
- }
- return artifactz;
- };
-
-
- /*
- * this funtion is used ArtifactManager find with map for query for solr basicly
- * query - for maping attribute of resource
- * pagin - pagination details
- * return - list of artifacts under the seach request
- *
- */
- ArtifactManager.prototype.search = function (query, paging) {
-
- var list, map, key, artifacts, pagination, value, that,
- artifactz = [];
- pagination = generatePaginationForm(paging);
- try {
- PaginationContext.init(pagination.start, pagination.count, pagination.sortOrder,
- pagination.sortBy, pagination.paginationLimit);
- map = HashMap();
- //case senstive search as it using greg with solr 1.4.1
- if (!query) {
- //listing for sorting
- map = java.util.Collections.emptyMap();
- } else if (query instanceof String || typeof query === 'string') {
- list = new ArrayList();
- list.add('*' + query + '*');
- map.put('overview_name', list);
- } else {
- //support for only on name of attribut -
- for (key in query) {
- // if attribute is string values
- if (query.hasOwnProperty(key)) {
- value = query[key];
- list = new ArrayList();
- if (value instanceof Array) {
- value.forEach(function (val) {
- //solr config update need have '*' as first char in below line
- //check life_cycle state
- list.add(key == 'lcState' ? val : '*' + val + '*');
- });
- } else {
- //solr config update need have '*' as first char in below line
- list.add(key == 'lcState' ? value : '*' + value + '*');
- }
- map.put(key, list);
- }
- }//end of attribut looping (all attributes)
- }
- artifacts = this.manager.findGenericArtifacts(map);
- that = this;
- artifacts.forEach(function (artifact) {
- artifactz.push(buildArtifact(that, artifact));
- });
- } finally {
- PaginationContext.destroy();
- }
- return artifactz;
- };
-
- ArtifactManager.prototype.get = function (id) {
- return buildArtifact(this, this.manager.getGenericArtifact(id))
- };
-
- ArtifactManager.prototype.count = function () {
- return this.manager.getAllGenericArtifactIds().length;
- };
-
- /**
- * @deprecated Please use search method instead
- * @param paging
- * @return {*}
- */
- ArtifactManager.prototype.list = function (paging) {
- return this.search(null, paging);
- };
-
- /*
- The function returns an array of asset types
- @mediaType - The media type of the assets
- @return An array of strings containing the asset paths
- */
- ArtifactManager.prototype.getAssetTypePaths = function (mediaType) {
-
- //Use the default media type if one is not provided
- if (!mediaType) {
- mediaType = DEFAULT_MEDIA_TYPE;
- }
-
- //var assetArray=GovernanceUtils.findGovernanceArtifacts(mediaType,this.registry);
- var result = Packages.org.wso2.carbon.governance.api.util.GovernanceUtils.findGovernanceArtifacts(mediaType, registry.registry);
-
- return result;
- //Create an empty array if no asset types are found
- //return (!assetArray)?[]:assetArray;
- };
-
- /*
- {
- name: 'AndroidApp1',
- attributes: {
- overview_status: "CREATED",
- overview_name: 'AndroidApp1',
- overview_version: '1.0.0',
- overview_url: 'http://overview.com',
- overview_provider: 'admin',
- images_thumbnail: 'http://localhost:9763/portal/gadgets/co2-emission/thumbnail.jpg',
- images_banner: 'http://localhost:9763/portal/gadgets/electric-power/banner.jpg'
- },
- lifecycles : ['lc1', 'lc2'],
- content : '<?xml ....>'
- }
- */
- ArtifactManager.prototype.add = function (options) {
- this.manager.addGenericArtifact(createArtifact(this.manager, options));
- };
-
- ArtifactManager.prototype.update = function (options) {
- this.manager.updateGenericArtifact(createArtifact(this.manager, options));
- };
-
- ArtifactManager.prototype.remove = function (id) {
- this.manager.removeGenericArtifact(id);
- };
-
- /*
- Attaches the provided lifecycle name to the artifact
- @lifecycleName: The name of a valid lifecycle.The lifecycle should be visible to the
- registry.
- @options: The artifact to which the life cycle must be attached.
- */
- ArtifactManager.prototype.attachLifecycle = function (lifecycleName, options) {
- var artifact = getArtifactFromImage(this.manager, options);
- if (!artifact) {
- throw new Error('Specified artifact cannot be found : ' + JSON.stringify(options));
- }
- artifact.attachLifecycle(lifecycleName);
- };
-
- /*
- Removes the attached lifecycle from the artifact
- @options: The artifact from which the life cycle must be removed
- */
- ArtifactManager.prototype.detachLifecycle = function (options) {
- var artifact = getArtifactFromImage(this.manager, options);
- if (!artifact) {
- throw new Error('Specified artifact cannot be found : ' + JSON.stringify(options));
- }
- artifact.detachLifecycle();
- };
-
- /*
- Promotes the artifact to the next stage in its life cycle
- @options: An artifact image (Not a real artifact)
- */
- ArtifactManager.prototype.promoteLifecycleState = function (state, options) {
- var checkListItems,
- artifact = getArtifactFromImage(this.manager, options);
- if (!artifact) {
- throw new Error('Specified artifact cannot be found : ' + JSON.stringify(options));
- }
- //checkListItems = artifact.getAllCheckListItemNames();
- artifact.invokeAction(state);
- };
-
- /*
- Gets the current lifecycle state
- @options: An artifact object
- @returns: The life cycle state
- */
- ArtifactManager.prototype.getLifecycleState = function (options) {
- var artifact = getArtifactFromImage(this.manager, options);
- if (!artifact) {
- throw new Error('Specified artifact cannot be found : ' + JSON.stringify(options));
- }
- return artifact.getLifecycleState();
- };
-
- /*
- The function returns the list of check list items for a given state
- @options: The artifact
- @returns: A String array containing the check list items.(Can be empty if no check list items are present)
- */
- ArtifactManager.prototype.getCheckListItemNames = function (options) {
- var artifact = getArtifactFromImage(this.manager, options);
-
- var checkListItems = artifact.getAllCheckListItemNames() || [];
-
- var checkListItemArray = [];
-
- //Go through each check list item
- for (var index in checkListItems) {
- //Get whether the check list item is checked
- var state = artifact.isLCItemChecked(index);
- checkListItemArray.push({ 'name': checkListItems[index], 'checked': state });
- }
-
- return checkListItemArray;
- };
-
- /*
- The function checks whether a given check list item at the provided index is checked for the current state
- @index: The index of the check list item.This must be a value between 0 and the maximum check list item
- that appears in the lifecycle definition
- @options: An artifact object
- @throws Exception: If the index is not within 0 and the max check list item or if there is an issue ticking the item
- */
- ArtifactManager.prototype.isItemChecked = function (index, options) {
-
- var artifact = getArtifactFromImage(this.manager, options);
-
- var checkListItems = artifact.getAllCheckListItemNames();
-
- var checkListLength = checkListItems.length;
-
- if ((index < 0) || (index > checkListLength)) {
- throw "The index value: " + index + " must be between 0 and " + checkListLength + ".Please refer to the lifecycle definition in the registry.xml for the number of check list items.";
- }
-
- var result = artifact.isLCItemChecked(index);
-
- return result;
- };
-
- /*
- The method enables the check list item and the given index
- @index: The index of the check list item.This must be a value between 0 and the maximum check list item
- that appears in the lifecycle definition.
- @options: An artifact object
- @throws Exception: If the index is not within 0 and max check list item or if there is an issue ticking the item.
- */
- ArtifactManager.prototype.checkItem = function (index, options) {
-
- var artifact = getArtifactFromImage(this.manager, options);
-
- var checkListItems = artifact.getAllCheckListItemNames();
-
- var checkListLength = checkListItems.length;
-
- if ((index < 0) || (index > checkListLength)) {
- throw "The index value: " + index + " must be between 0 and " + checkListLength + ".Please refer to the lifecycle definition in the registry.xml for the number of check list items.";
- }
-
- artifact.checkLCItem(index);
- };
-
- /*
- The method disables the check list item at the given index
- @index: The index of the check list item.This must be a value between 0 and the maximum check list item
- that appears in the lifecycle definition
- @options: An artifact object
- @throws Exception: If the index is not within 0 and max check list item or if there is an issue ticking the item
- */
- ArtifactManager.prototype.uncheckItem = function (index, options) {
-
- var artifact = getArtifactFromImage(this.manager, options);
-
- var checkListItems = artifact.getAllCheckListItemNames();
-
- var checkListLength = checkListItems.length;
-
- if ((index < 0) || (index > checkListLength)) {
- throw "The index value: " + index + " must be between 0 and " + checkListLength + ".Please refer to the lifecycle definition in the registry.xml for the number of check list items.";
- }
-
- artifact.uncheckLCItem(index);
- };
-
- /*
- The method obtains the list of all available actions for the current state of the asset
- @options: An artifact object
- @returns: The list of available actions for the current state,else false
- */
- ArtifactManager.prototype.availableActions = function (options) {
- var artifact = getArtifactFromImage(this.manager, options);
- if (!artifact) {
- throw new Error('Specified artifact cannot be found : ' + JSON.stringify(options));
- }
- return artifact.getAllLifecycleActions() || [];
- };
-
- /*
- The function returns the life-cycle history path using
- the provided asset.
- @options: An asset.
- @return: A string path of the life-cycle history.
- */
- ArtifactManager.prototype.getLifecycleHistoryPath = function (options) {
-
- return getHistoryPath(options.path);
- };
-
- /*
- The function obtains the lifecycle history for the provided asset
- @options: An asset with a valid path.(A path which exists in the registry
- @return: A resource object containing the history as an xml
- */
- ArtifactManager.prototype.getLifecycleHistory=function(options){
- var historyPath=getHistoryPath(options.path);
- return this.registry.get(historyPath);
- };
-
- /*
- The function returns the life-cycle attached to the provided artifact
- @options: An asset as returned by the ArtifactManager get method
- @return: A string indicating the lifecycle name.If the artifact does not
- have a life-cycle then an empty string is returned.
- */
- ArtifactManager.prototype.getLifeCycleName = function (options) {
-
- var artifact = getArtifactFromImage(this.manager, options);
-
- var lifecycleName = '';
-
- if (artifact != null) {
- lifecycleName = artifact.getLifecycleName();
- }
-
- return lifecycleName;
- };
-
- /*
- The function returns all versions of the provided artifact
- @options: The artifact to be checked
- @return: A list of all the different versions of the provided asset
- */
- ArtifactManager.prototype.getAllAssetVersions = function (assetName) {
-
- var matchingArtifacts = [];
-
- var pred = {
- overview_name: assetName || ''
- };
-
- this.find(function (artifact) {
-
- //Add to the matches if the artifact exists
- if (assert(artifact.attributes, pred)) {
-
- //We only need the id and version
- matchingArtifacts.push({id: artifact.id, version: artifact.attributes.overview_version});
- }
- });
-
- return matchingArtifacts;
- };
-
- /*
- The function checks if the two objects a and b are equal.If a property in b is not
- in a, then both objects are assumed to be different.
- @a: The object to be compared
- @b: The object containing properties that must match in a
- @return: True if the objects are equal,else false.
- */
- var assert = function (a, b) {
-
- //Assume the objects will be same
- var equal = true;
-
- for (var key in b) {
-
-
- if (a.hasOwnProperty(key)) {
-
- //If the two keys are not equal
- if (a[key] != b[key]) {
- return false;
- }
- }
- else {
- return false;
- }
- }
-
- return equal;
- };
-
- /*
- The function generates the history path of a given asset
- using its path
- @assetPath:The path of the asset to be retrieved.
- @return: The path of lifecycle history information
- */
- var getHistoryPath = function (assetPath) {
-
- //Replace the / in the assetPath
- var partialHistoryPath = assetPath.replace(lcHistoryRegExpression, HISTORY_PATH_SEPERATOR);
-
- var fullPath = HISTORY_PATH + partialHistoryPath;
-
- return fullPath;
- };
-
- /*
- generatePaginationForm will genrate json for registry pagination context, (pagination consistent handling)
- @pagin:The pagination details from UI
- @
- */
- var generatePaginationForm = function (pagin) {
-
- //pagination context for default
- var paginationLimit = 300;
- var paginationForm = {
- 'start': 0,
- 'count': 12,
- 'sortOrder': 'ASC',
- 'sortBy': 'overview_name',
- 'paginationLimit': 2147483647
- };
-
- if (!pagin) {
- return paginationForm;
- }
-
- if (pagin.count != null) {
- paginationForm.count = pagin.count;
- }
- if (pagin.start != null) {
- paginationForm.start = pagin.start;
- }
- if (pagin.paginationLimit != null) {
- paginationForm.paginationLimit = pagin.paginationLimit;
- }
- if (pagin.sortBy != null) {
- paginationForm.sortBy = pagin.sortBy;
- }
- if (paginationForm.sortOrder != null) {
- paginationForm.sortOrder = pagin.sortOrder;
- }
- return paginationForm;
-
- };
-
- /*
- Helper function to create an artifact instance from a set of options (an image).
- */
- var getArtifactFromImage = function (manager, options) {
-
- var path = options.path || '';
- var lcName = options.lifecycle || '';
- var artifact = createArtifact(manager, {
- id: options.id,
- attributes: options.attributes
- });
-
- path = path.replace(REGISTRY_ABSOLUTE_PATH, '');
-
- artifact.setArtifactPath(path);
- artifact.setLcName(lcName);
-
- return artifact;
- };
-
-}(server, registry));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-osgi.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-osgi.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-osgi.js
deleted file mode 100644
index eefbaad..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-osgi.js
+++ /dev/null
@@ -1,466 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-var registry = registry || {};
-
-(function (server, registry) {
- var log = new Log();
-
- var Resource = Packages.org.wso2.carbon.registry.core.Resource;
-
- var Collection = Packages.org.wso2.carbon.registry.core.Collection;
-
- var Comment = Packages.org.wso2.carbon.registry.core.Comment;
-
- var StaticConfiguration = Packages.org.wso2.carbon.registry.core.config.StaticConfiguration;
-
- var queryPath = '/_system/config/repository/components/org.wso2.carbon.registry/queries/';
-
- var content = function (registry, resource, paging) {
- if (resource instanceof Collection) {
- // #1 : this always sort children by name, so sorting cannot be done for the chunk
- return children(registry, resource, paging);
- }
- if (resource instanceof Comment) {
- return String(resource.getText());
- }
- var stream = resource.getContentStream();
- if (stream) {
- return new Stream(stream);
- }
- return String(resource.content);
- };
-
- var resourceSorter = function (key) {
- var nameAsc = function (l, r) {
- var lname, rname;
- if (l instanceof Collection) {
- lname = l.getName();
- lname = lname.substring(lname.lastIndexOf('/') + 1);
- } else {
- lname = l.name;
- }
- if (r instanceof Collection) {
- rname = r.getName();
- rname = rname.substring(rname.lastIndexOf('/') + 1);
- } else {
- rname = r.name;
- }
- return lname === rname ? 0 : (lname > rname ? 1 : -1);
- };
- switch (key) {
- case 'time-created-asc' :
- return function (l, r) {
- return l.getCreatedTime().getTime() - r.getCreatedTime().getTime();
- };
- case 'time-created-des' :
- return function (l, r) {
- return r.getCreatedTime().getTime() - l.getCreatedTime().getTime();
- };
- case 'name-asc' :
- return nameAsc;
- case 'name-des' :
- return function (l, r) {
- return -nameAsc(l, r);
- };
- default:
- return resourceSorter('time-created-des');
- }
- };
-
- var children = function (registry, resource, paging) {
- var resources = resource.getChildren();
- //we have to manually sort this due to the bug in registry.getChildren() (#1 above)
- //resources.sort(resourceSorter(paging.sort));
- return resources.slice(paging.start, paging.start + paging.count);
- };
-
- var resource = function (registry, resource) {
- var path = String(resource.path),
- o = {
- created: {
- author: String(resource.authorUserName),
- time: resource.createdTime.time
- },
- content: content(registry, resource, {
- start: 0,
- count: 10
- }),
- id: String(resource.id),
- version: resource.versionNumber
- };
- if (resource instanceof Comment) {
- return o;
- }
- if (resource instanceof Collection) {
- o.collection = (resource instanceof Collection);
- }
- o.uuid = String(resource.UUID);
- o.path = String(path);
- o.name = String(resource.name) || resolveName(path);
- o.description = String(resource.description);
- o.updated = {
- author: String(resource.lastUpdaterUserName),
- time: resource.lastModified.time
- };
- o.mediaType = String(resource.mediaType);
- o.properties = function () {
- return properties(resource);
- };
- o.aspects = function () {
- return aspects(resource);
- };
- return o;
- };
-
- var properties = function (resource) {
- var prop,
- properties = resource.properties,
- props = properties.keySet().toArray(),
- length = props.length,
- o = {};
- for (var i = 0; i < length; i++) {
- prop = props[i];
- o[prop] = resource.getPropertyValues(prop).toArray();
- }
- return o;
- };
-
- var aspects = function (resource) {
- var aspects = resource.getAspects();
- return aspects ? aspects.toArray() : [];
- };
-
- var resolveName = function (path) {
- path = path.charAt(path.length - 1) === '/' ? path.substring(0, path.length - 1) : path;
- return path.substring(path.lastIndexOf('/') + 1);
- };
-
- var merge = function (def, options) {
- if (options) {
- for (var op in def) {
- if (def.hasOwnProperty(op)) {
- def[op] = options[op] || def[op];
- }
- }
- }
- return def;
- };
-
- var Registry = function (serv, options) {
- var registryService = server.osgiService('org.wso2.carbon.registry.core.service.RegistryService'),
- carbon = require('carbon');
- if (options) {
- this.server = serv;
- } else {
- this.server = new server.Server();
- options = serv || {};
- }
-
- if (options.tenantId) {
- this.tenantId = options.tenantId;
- } else if (options.username || options.domain) {
- this.tenantId = server.tenantId({
- domain: options.domain,
- username: options.username
- });
- } else {
- this.tenantId = server.tenantId();
- }
-
- if (options.username) {
- this.username = options.username;
- } else if (options.system) {
- this.username = carbon.user.systemUser;
- } else {
- this.username = carbon.user.anonUser;
- }
-
- this.registry = registryService.getRegistry(this.username, this.tenantId);
- this.versioning = {
- comments: StaticConfiguration.isVersioningComments()
- };
- };
-
- registry.Registry = Registry;
-
- Registry.prototype.put = function (path, resource) {
- var res;
- if (resource.collection) {
- res = this.registry.newCollection();
- } else {
- res = this.registry.newResource();
- if (resource.content instanceof Stream) {
- res.contentStream = resource.content.getStream();
- } else {
- res.content = resource.content || null;
- }
- res.mediaType = resource.mediaType || null;
- }
- res.name = resource.name;
- res.description = resource.description || null;
- res.UUID = resource.uuid || null;
-
- var values, length, i, ArrayList,
- properties = resource.properties;
- if (properties) {
- ArrayList = java.util.ArrayList;
- for (var name in properties) {
- var list = new ArrayList();
- if (properties.hasOwnProperty(name)) {
- values = properties[name];
- values = values instanceof Array ? values : [values];
- length = values.length;
- for (i = 0; i < length; i++) {
- list.add(values[i]);
- }
- res.setProperty(name, list);
- }
- }
- }
-
- var aspects = resource.aspects;
- if (aspects) {
- length = aspects.length;
- for (i = 0; i < length; i++) {
- res.addAspect(aspects[i]);
- }
- }
-
- this.registry.put(path, res);
- };
-
- Registry.prototype.remove = function (path) {
- this.registry.delete(path);
- };
-
- Registry.prototype.move = function (src, dest) {
- this.registry.move(src, dest);
- };
-
- Registry.prototype.rename = function (current, newer) {
- this.registry.rename(current, newer);
- };
-
- Registry.prototype.copy = function (src, dest) {
- this.registry.copy(src, dest);
- };
-
- Registry.prototype.restore = function (path) {
- this.registry.restoreVersion(path);
- };
-
- Registry.prototype.get = function (path) {
- if (!this.exists(path)) {
- return null;
- }
- var res = this.registry.get(path);
- return resource(this, res);
- };
-
- Registry.prototype.exists = function (path) {
- return this.registry.resourceExists(path);
- };
-
- Registry.prototype.content = function (path, paging) {
- if (!this.exists(path)) {
- return null;
- }
- var resource = this.registry.get(path);
- paging = merge({
- start: 0,
- count: 10,
- sort: 'recent'
- }, paging);
- return content(this, resource, paging);
- };
-
- Registry.prototype.tags = function (path) {
- var tags, i, length,
- tagz = [];
- tags = this.registry.getTags(path);
- length = tags.length;
- for (i = 0; i < length; i++) {
- tagz.push(String(tags[i].tagName));
- }
- return tagz;
- };
-
- Registry.prototype.tag = function (path, tags) {
- var i, length;
- tags = tags instanceof Array ? tags : [tags];
- length = tags.length;
- for (i = 0; i < length; i++) {
- this.registry.applyTag(path, tags[i]);
- }
- };
-
- Registry.prototype.untag = function (path, tags) {
- var i, length;
- tags = tags instanceof Array ? tags : [tags];
- length = tags.length;
- for (i = 0; i < length; i++) {
- this.registry.removeTag(path, tags[i]);
- }
- };
-
- Registry.prototype.associate = function (src, dest, type) {
- this.registry.addAssociation(src, dest, type);
- };
-
- Registry.prototype.dissociate = function (src, dest, type) {
- this.registry.removeAssociation(src, dest, type);
- };
-
- Registry.prototype.associations = function (path, type) {
- var i, asso,
- assos = type ? this.registry.getAssociations(path, type) : this.registry.getAllAssociations(path),
- length = assos.length,
- associations = [];
- for (i = 0; i < length; i++) {
- asso = assos[i];
- associations.push({
- type: String(asso.associationType),
- src: String(asso.sourcePath),
- dest: String(asso.destinationPath)
- });
- }
- return associations;
- };
-
- Registry.prototype.addProperty = function (path, name, value) {
- var resource = this.registry.get(path);
- resource.addProperty(name, value);
- };
-
- Registry.prototype.removeProperty = function (path, name, value) {
- var resource = this.registry.get(path);
- (value ? resource.removePropertyValue(name, value) : resource.removeProperty(name));
- };
-
- Registry.prototype.properties = function (path) {
- var resource = this.registry.get(path);
- return properties(resource);
- };
-
- Registry.prototype.version = function (path) {
- this.registry.createVersion(path);
- };
-
- Registry.prototype.versions = function (path) {
- return this.registry.getVersions(path);
- };
-
- Registry.prototype.unversion = function (path, snapshot) {
- this.registry.removeVersionHistory(path, snapshot);
- };
-
- Registry.prototype.comment = function (path, comment) {
- this.registry.addComment(path, new Comment(comment));
- };
-
- Registry.prototype.comments = function (path, paging) {
- var i, length, comments, comment, key,
- commentz = [];
- paging = merge({
- start: 0,
- count: 25,
- sort: 'recent'
- }, paging);
-
- comments = this.registry.getComments(path);
- //we have to manually sort this due to the bug in registry.getChildren() (#1 above)
- key = paging.sort;
- key = (key === 'time-created-des' || key === 'time-created-asc') ? key : 'time-created-des';
- comments = comments.sort(resourceSorter(key));
- comments = comments.slice(paging.start, paging.start + paging.count);
- length = comments.length;
- for (i = 0; i < length; i++) {
- comment = comments[i];
- commentz.push({
- content: comment.getText(),
- created: {
- author: comment.getUser(),
- time: comment.getCreatedTime().getTime()
- },
- path: comment.getCommentPath()
- });
- }
- return commentz;
- };
-
- Registry.prototype.commentCount = function (path) {
- return this.registry.getComments(path).length;
- };
-
- Registry.prototype.uncomment = function (path) {
- this.registry.removeComment(path);
- };
-
- Registry.prototype.rate = function (path, rating) {
- this.registry.rateResource(path, rating);
- };
-
- Registry.prototype.unrate = function (path) {
- this.registry.rateResource(path, 0);
- };
-
- Registry.prototype.rating = function (path, username) {
- var rating = {
- average: this.registry.getAverageRating(path)
- };
- if (username) {
- rating.user = this.registry.getRating(path, username);
- }
- return rating;
- };
-
- Registry.prototype.link = function (path, target) {
- return this.registry.createLink(path, target);
- };
-
- Registry.prototype.unlink = function (path) {
- return this.registry.removeLink(path);
- };
-
- Registry.prototype.search = function (query, paging) {
- var res = this.registry.searchContent(query);
- paging = merge({
- start: 0,
- count: 10,
- sort: 'recent'
- }, paging);
- return res ? content(this, res, paging) : [];
- };
-
- Registry.prototype.query = function (path, params) {
- var res, name,
- map = new java.util.HashMap();
- for (name in params) {
- if (params.hasOwnProperty(name)) {
- map.put(name, params[name]);
- }
- }
- res = this.registry.executeQuery(path, map);
- return res.getChildren();
- };
-
-}(server, registry));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-ws.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-ws.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-ws.js
deleted file mode 100644
index 014a75c..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-ws.js
+++ /dev/null
@@ -1,77 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-var log = new Log();
-
-var Registry = function (server) {
- this.server = server;
-};
-
-var Resource = function (name) {
-
-};
-
-var Collection = function (name) {
-
-};
-
-Registry.prototype.invoke = function (action, payload) {
- var options,
- ws = require('ws'),
- client = new ws.WSRequest(),
- server = this.server;
-
- options = {
- useSOAP: 1.2,
- useWSA: 1.0,
- action: action,
- HTTPHeaders: [
- { name: 'Cookie', value: server.cookie }
- ]
- };
-
- try {
- client.open(options, server.url + '/services/WSRegistryService', false);
- client.send(payload);
- return client.responseXML;
- } catch (e) {
- log.error(e.toString());
- throw new Error('Error while invoking action in WSRegistryService : ' +
- action + ', user : ' + server.user.username);
- }
-};
-
-Registry.prototype.putResource = function (path, resource) {
-
-};
-
-Registry.prototype.getResource = function (path) {
- var res, payload,
- base64 = require('/modules/base64.js');
-
- payload =
- <api:getContent xmlns:api="http://api.ws.registry.carbon.wso2.org">
- <api:path>{path}</api:path>
- </api:getContent>;
-
- res = this.invoke('urn:getContent', payload);
- return base64.decode(String(res.*::['return'].text()));
-};
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry.js
deleted file mode 100644
index 43467bc..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry.js
+++ /dev/null
@@ -1,45 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-var registry = {};
-
-(function (registry) {
- var ActionConstants = Packages.org.wso2.carbon.registry.core.ActionConstants,
- AccessControlConstants = Packages.org.wso2.carbon.registry.core.utils.AccessControlConstants;
-
- registry.Registry = function (server, auth) {
- var osgi = require('registry-osgi.js').registry,
- o = new osgi.Registry(server, auth);
- o.prototype = this;
- return o;
- };
-
- registry.actions = {};
-
- registry.actions.GET = ActionConstants.GET;
-
- registry.actions.PUT = ActionConstants.PUT;
-
- registry.actions.DELETE = ActionConstants.DELETE;
-
- registry.actions.AUTHORIZE = AccessControlConstants.AUTHORIZE;
-
-}(registry));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/config.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/config.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/config.js
deleted file mode 100644
index fe5078f..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/config.js
+++ /dev/null
@@ -1,53 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-(function (server) {
- var process = require('process'),
- configDir = 'file:///' + process.getProperty('carbon.config.dir.path').replace(/[\\]/g, '/').replace(/^[\/]/g, '') + '/';
- server.loadConfig = function (path) {
- var content,
- index = path.lastIndexOf('.'),
- ext = (index !== -1 && index < path.length) ? path.substring(index + 1) : '',
- file = new File(configDir + path);
- if (!file.isExists()) {
- throw new Error('Specified config file does not exists : ' + path);
- }
- if (file.isDirectory()) {
- throw new Error('Specified config file is a directory : ' + path);
- }
- file.open('r');
- content = file.readAll();
- file.close();
- switch (ext) {
- case 'xml' :
- return new XML(content);
- case 'json' :
- return parse(content);
- case 'properties' :
- default :
- return content;
-
- }
- };
-
- server.home = 'file:///' + require('process').getProperty('carbon.home').replace(/[\\]/g, '/').replace(/^[\/]/g, '');
-
-}(server));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/osgi.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/osgi.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/osgi.js
deleted file mode 100644
index 2175c23..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/osgi.js
+++ /dev/null
@@ -1,31 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-var server = {};
-
-(function (server) {
- var PrivilegedCarbonContext = Packages.org.wso2.carbon.context.PrivilegedCarbonContext,
- Class = java.lang.Class;
-
- server.osgiService = function (clazz) {
- return PrivilegedCarbonContext.getThreadLocalCarbonContext().getOSGiService(Class.forName(clazz));
- };
-}(server));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/server.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/server.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/server.js
deleted file mode 100644
index 4a8a69b..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/server.js
+++ /dev/null
@@ -1,111 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-(function (server) {
- var log = new Log();
-
- var login = function (url, username, password) {
- var res, options, payload,
- ws = require('ws'),
- client = new ws.WSRequest(),
- host = url.match(/.*:\/\/([^:\/]*)/)[1];
-
- options = {
- useSOAP: 1.2,
- useWSA: 1.0,
- action: 'urn:login'
- };
-
- payload =
- <aut:login xmlns:aut="http://authentication.services.core.carbon.wso2.org">
- <aut:username>{username}</aut:username>
- <aut:password>{password}</aut:password>
- <aut:remoteAddress>{host}</aut:remoteAddress>
- </aut:login>;
-
- try {
- client.open(options, url + '/services/AuthenticationAdmin', false);
- client.send(payload);
- res = client.responseXML;
- if (res.*::["return"].text() != 'true') {
- return false;
- }
- return client.getResponseHeader('Set-Cookie');
- } catch (e) {
- log.error(e.toString());
- throw new Error('Error while login to the server : ' + url + ', user : ' + username);
- }
- };
-
- var logout = function (url, cookie) {
- var options,
- ws = require('ws'),
- client = new ws.WSRequest();
-
- options = {
- useSOAP: 1.2,
- useWSA: 1.0,
- action: 'urn:logout',
- mep: 'in-only',
- HTTPHeaders: [
- { name: 'Cookie', value: cookie }
- ]
- };
-
- try {
- client.open(options, url + '/services/AuthenticationAdmin', false);
- client.send(null);
- return true;
- } catch (e) {
- log.error(e.toString());
- throw new Error('Error while logging out in server : ' + url + ', cookie : ' + cookie);
- }
- };
-
- var Cookie = function (cookie) {
- this.cookie = cookie;
- };
-
- server.Cookie = Cookie;
-
- var Server = function (options) {
- this.url = (options && options.url) ? options.url : 'local:/';
- };
- server.Server = Server;
-
- Server.prototype.authenticate = function (username, password) {
- var realm, user,
- carbon = require('carbon'),
- realmService = server.osgiService('org.wso2.carbon.user.core.service.RealmService');
- user = carbon.server.tenantUser(username);
- realm = realmService.getTenantUserRealm(user.tenantId);
- return realm.getUserStoreManager().authenticate(user.username, password);
- };
-
- Server.prototype.login = function (username, password) {
- var cookie = login(this.url, username, password);
- return new Cookie(cookie);
- };
-
- Server.prototype.logout = function (cookie) {
- return logout(this.url, cookie.cookie);
- };
-}(server));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/tenant.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/tenant.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/tenant.js
deleted file mode 100644
index 255e7d7..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/tenant.js
+++ /dev/null
@@ -1,70 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-(function (server) {
- var PrivilegedCarbonContext = Packages.org.wso2.carbon.context.PrivilegedCarbonContext,
- MultitenantConstants = Packages.org.wso2.carbon.utils.multitenancy.MultitenantConstants,
- MultitenantUtils = Packages.org.wso2.carbon.utils.multitenancy.MultitenantUtils,
- realmService = server.osgiService('org.wso2.carbon.user.core.service.RealmService'),
- tenantManager = realmService.getTenantManager();
-
- server.tenantDomain = function (options) {
- if (!options) {
- return PrivilegedCarbonContext.getThreadLocalCarbonContext().getTenantDomain();
- }
- if(options.tenantId) {
- return tenantManager.getDomain(options.tenantId);
- }
- if (options.username) {
- return MultitenantUtils.getTenantDomain(options.username);
- }
- if (options.url) {
- return MultitenantUtils.getTenantDomainFromRequestURL(options.url);
- }
- return null;
- };
-
- server.tenantId = function (options) {
- var domain = options ? (options.domain || server.tenantDomain(options)) : server.tenantDomain();
- return domain ? tenantManager.getTenantId(domain) : null;
- };
-
- server.tenantUser = function (username) {
- var domain = server.tenantDomain({
- username: username
- }),
- id = server.tenantId({
- domain: domain
- });
- username = MultitenantUtils.getTenantAwareUsername(username);
- return {
- domain: domain,
- username: username,
- tenantId: id
- };
- };
-
- server.superTenant = {
- tenantId: MultitenantConstants.SUPER_TENANT_ID,
- domain: MultitenantConstants.SUPER_TENANT_DOMAIN_NAME
- };
-
-}(server));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/registry-space.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/registry-space.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/registry-space.js
deleted file mode 100644
index 9536fb4..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/registry-space.js
+++ /dev/null
@@ -1,60 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-(function (server, registry, user) {
-
- var Space = function (user, space, options) {
- var serv = new server.Server(options.serverUrl);
- this.registry = new registry.Registry(serv, {
- username: options.username || user,
- domain: options.domain || server.tenantDomain()
- });
- this.prefix = options.path + '/' + user + '/' + space;
- if (!this.registry.exists(this.prefix)) {
- this.registry.put(this.prefix, {
- collection: true
- });
- }
- };
- user.Space = Space;
-
- Space.prototype.put = function (key, value) {
- value = (!(value instanceof String) && typeof value !== "string") ? stringify(value) : value;
- this.registry.put(this.prefix + '/' + key, {
- content: value
- });
- };
-
- Space.prototype.get = function (key) {
- var o = this.registry.content(this.prefix + '/' + key);
- return o ? o.toString() : null;
- };
-
- Space.prototype.remove = function (key) {
- this.registry.remove(this.prefix + '/' + key);
- };
-
- Space.prototype.find = function (filter) {
-
- };
-
-
-}(server, registry, user));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/space.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/space.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/space.js
deleted file mode 100644
index c895cc1..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/space.js
+++ /dev/null
@@ -1,31 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-(function (server, user) {
-
- user.Space = function (user, space, options) {
- var reg = require('registry-space.js').user,
- o = new reg.Space(user, space, options);
- o.prototype = this;
- return o;
- };
-
-}(server, user));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user-manager.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user-manager.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user-manager.js
deleted file mode 100644
index 56833b9..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user-manager.js
+++ /dev/null
@@ -1,179 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-(function (server, user) {
-
- var log = new Log();
-
- var processPerms = function (perms, fn) {
- var perm, actions, i, length;
- for (perm in perms) {
- if (perms.hasOwnProperty(perm)) {
- actions = perms[perm];
- length = actions.length;
- for (i = 0; i < length; i++) {
- fn(perm, actions[i]);
- }
- }
- }
- };
-
- var UserManager = function (serv, tenantId) {
- this.server = serv;
- this.tenantId = tenantId || server.superTenant.tenantId;
- var realmService = server.osgiService('org.wso2.carbon.user.core.service.RealmService'),
- realm = realmService.getTenantUserRealm(this.tenantId);
- this.manager = realm.getUserStoreManager();
- this.authorizer = realm.getAuthorizationManager();
- };
- user.UserManager = UserManager;
-
- UserManager.prototype.getUser = function (username) {
- if (!this.manager.isExistingUser(username)) {
- return null;
- }
- return new user.User(this, username);
- };
- UserManager.prototype.getRoleListOfUser = function (username) {
- return this.manager.getRoleListOfUser(username);
- };
- UserManager.prototype.addUser = function (username, password, roles, claims, profile) {
- this.manager.addUser(username, password, roles || [], claims || null, profile);
- };
-
- UserManager.prototype.removeUser = function (username) {
- this.manager.deleteUser(username);
- };
-
- UserManager.prototype.userExists = function (username) {
- return this.manager.isExistingUser(username);
- };
-
- UserManager.prototype.roleExists = function (role) {
- return this.manager.isExistingRole(role);
- };
- UserManager.prototype.updateRole = function (previousRoleName, newRoleName) {
- return this.manager.updateRoleName(previousRoleName, newRoleName);
- };
- UserManager.prototype.getClaims = function (username, profile) {
- return this.manager.getUserClaimValues(username, profile);
- };
- UserManager.prototype.getClaimsForSet = function (username,claims, profile) {
- return this.manager.getUserClaimValues(username,claims, profile);
- };
- UserManager.prototype.getClaim = function (username, claim, profile) {
- return this.manager.getUserClaimValue(username, claim, profile);
- };
-
- UserManager.prototype.setClaims = function (username, claims, profile) {
- return this.manager.setUserClaimValues(username, claims, profile);
- };
-
- UserManager.prototype.setClaim = function (username, claim, value, profile) {
- return this.manager.setUserClaimValue(username, claim, value, profile);
- };
-
- UserManager.prototype.isAuthorized = function (role, permission, action) {
- return this.authorizer.isRoleAuthorized(role, permission, action);
- };
- UserManager.prototype.updateRoleListOfUser = function(name, deletedRoles, newRoles){
- return this.manager.updateRoleListOfUser(name, deletedRoles, newRoles);
- };
- UserManager.prototype.updateUserListOfRole = function(name, deletedUsers, newUsers){
- return this.manager.updateUserListOfRole(name, deletedUsers, newUsers);
- };
- UserManager.prototype.listUsers = function () {
- return this.manager.listUsers("*", -1);
- };
- UserManager.prototype.addRole = function (role, users, permissions) {
- var perms = [],
- Permission = Packages.org.wso2.carbon.user.api.Permission;
- processPerms(permissions, function (id, action) {
- perms.push(new Permission(id, action));
- });
- this.manager['addRole(java.lang.String,java.lang.String[],org.wso2.carbon.user.api.Permission[])']
- (role, users, perms);
- };
-
- UserManager.prototype.removeRole = function (role) {
- this.manager.deleteRole(role);
- };
-
- UserManager.prototype.allRoles = function () {
- return this.manager.getRoleNames();
- };
- UserManager.prototype.getUserListOfRole = function (role) {
- return this.manager.getUserListOfRole(role);
- };
- /**
- * um.authorizeRole('store-admin', '/permissions/mypermission', 'ui-execute');
- *
- * um.authorizeRole('store-admin', {
- * '/permissions/myperm1' : ['read', 'write'],
- * '/permissions/myperm2' : ['read', 'write']
- * });
- *
- * @param role
- * @param permission
- * @param action
- */
- UserManager.prototype.authorizeRole = function (role, permission, action) {
- var that = this;
- if (permission instanceof String || typeof permission === 'string') {
- if (!that.isAuthorized(role, permission, action)) {
- that.authorizer.authorizeRole(role, permission, action);
- }
- } else {
- processPerms(permission, function (id, action) {
- if (!that.isAuthorized(role, id, action)) {
- that.authorizer.authorizeRole(role, id, action);
- if (log.isDebugEnabled()) {
- log.debug('permission added(role:permission:action) - ' + role + ':' + id + ':' + action);
- }
- }
- });
- }
- };
-
- /**
- * um.denyRole('store-admin', '/permissions/mypermission', 'ui-execute');
- *
- * um.denyRole('store-admin', {
- * '/permissions/myperm1' : ['read', 'write'],
- * '/permissions/myperm2' : ['read', 'write']
- * });
- *
- * @param role
- * @param permission
- * @param action
- */
- UserManager.prototype.denyRole = function (role, permission, action) {
- var deny = this.authorizer.denyRole;
- if (permission instanceof String || typeof permission === 'string') {
- deny(role, permission, action);
- } else {
- processPerms(permission, function (id, action) {
- deny(role, id, action);
- });
- }
- };
-
-}(server, user));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user.js b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user.js
deleted file mode 100644
index 66b253d..0000000
--- a/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user.js
+++ /dev/null
@@ -1,99 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-var user = {};
-
-(function (user) {
-
- var CarbonConstants = Packages.org.wso2.carbon.CarbonConstants;
-
- user.systemUser = CarbonConstants.REGISTRY_SYSTEM_USERNAME;
-
- user.anonUser = CarbonConstants.REGISTRY_ANONNYMOUS_USERNAME;
-
- user.anonRole = CarbonConstants.REGISTRY_ANONNYMOUS_ROLE_NAME;
-
- var User = function (manager, username) {
- this.um = manager;
- this.tenantId = manager.tenantId;
- this.username = username;
- };
- user.User = User;
-
- User.prototype.getClaims = function (profile) {
- return this.um.getClaims(this.username, profile);
- };
- User.prototype.getClaimsForSet = function (claims,profile) {
- return this.um.getClaimsForSet(this.username, claims, profile);
- };
-
- User.prototype.setClaims = function (claims, profile) {
- this.um.setClaims(this.username, claims, profile);
- };
-
- User.prototype.getRoles = function () {
- return this.um.manager.getRoleListOfUser(this.username);
- };
-
- User.prototype.hasRoles = function (roles) {
- var i, j, role,
- rs = this.getRoles(),
- length1 = roles.length,
- length2 = rs.length;
- L1:
- for (i = 0; i < length1; i++) {
- //Array.indexOf() fails due to Java String vs JS String difference
- role = roles[i];
- for (j = 0; j < length2; j++) {
- if (role == rs[j]) {
- continue L1;
- }
- }
- return false;
- }
- return true;
- };
-
- User.prototype.addRoles = function (roles) {
- return this.um.manager.updateRoleListOfUser(this.username, [], roles);
- };
-
- User.prototype.removeRoles = function (roles) {
- return this.um.manager.updateRoleListOfUser(this.username, roles, []);
- };
-
- User.prototype.updateRoles = function (remove, add) {
- return this.um.manager.updateRoleListOfUser(this.username, remove, add);
- };
-
- User.prototype.isAuthorized = function (permission, action) {
- var i,
- roles = this.getRoles(),
- length = roles.length;
- for (i = 0; i < length; i++) {
- if (this.um.authorizer.isRoleAuthorized(roles[i], permission, action)) {
- return true;
- }
- }
- return false;
- };
-
-}(user));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/org.jaggeryjs.hostobjects.xhr_0.9.0.ALPHA4_wso2v1.jar
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/org.jaggeryjs.hostobjects.xhr_0.9.0.ALPHA4_wso2v1.jar b/products/stratos-manager/conf/temp-artifacts/org.jaggeryjs.hostobjects.xhr_0.9.0.ALPHA4_wso2v1.jar
deleted file mode 100644
index 60f6f07..0000000
Binary files a/products/stratos-manager/conf/temp-artifacts/org.jaggeryjs.hostobjects.xhr_0.9.0.ALPHA4_wso2v1.jar and /dev/null differ
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/org.wso2.store.sso.common_1.0.0.jar
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/org.wso2.store.sso.common_1.0.0.jar b/products/stratos-manager/conf/temp-artifacts/org.wso2.store.sso.common_1.0.0.jar
deleted file mode 100644
index 4a74e5b..0000000
Binary files a/products/stratos-manager/conf/temp-artifacts/org.wso2.store.sso.common_1.0.0.jar and /dev/null differ
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/org.wso2.stratos.identity.saml2.sso.mgt_2.2.0.jar
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/org.wso2.stratos.identity.saml2.sso.mgt_2.2.0.jar b/products/stratos-manager/conf/temp-artifacts/org.wso2.stratos.identity.saml2.sso.mgt_2.2.0.jar
deleted file mode 100644
index 29a9fb7..0000000
Binary files a/products/stratos-manager/conf/temp-artifacts/org.wso2.stratos.identity.saml2.sso.mgt_2.2.0.jar and /dev/null differ
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/sso/module.xml
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/sso/module.xml b/products/stratos-manager/conf/temp-artifacts/sso/module.xml
deleted file mode 100644
index 159203b..0000000
--- a/products/stratos-manager/conf/temp-artifacts/sso/module.xml
+++ /dev/null
@@ -1,28 +0,0 @@
-<?xml version='1.0'?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one
- or more contributor license agreements. See the NOTICE file
- distributed with this work for additional information
- regarding copyright ownership. The ASF licenses this file
- to you under the Apache License, Version 2.0 (the
- "License"); you may not use this file except in compliance
- with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing,
- software distributed under the License is distributed on an
- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- KIND, either express or implied. See the License for the
- specific language governing permissions and limitations
- under the License.
-
--->
-
-<module name="sso" xmlns="http://wso2.org/projects/jaggery/module.xml">
- <script>
- <name>client</name>
- <path>scripts/sso.client.js</path>
- </script>
-</module>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/temp-artifacts/sso/scripts/sso.client.js
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/sso/scripts/sso.client.js b/products/stratos-manager/conf/temp-artifacts/sso/scripts/sso.client.js
deleted file mode 100644
index 9553220..0000000
--- a/products/stratos-manager/conf/temp-artifacts/sso/scripts/sso.client.js
+++ /dev/null
@@ -1,193 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-/**
- * Following module act as a client to create a saml request and also to
- * unwrap and return attributes of a returning saml response
- * @type {{}}
- */
-
-var client = {};
-
-(function (client) {
-
- var Util = Packages.org.wso2.store.sso.common.util.Util,
- carbon = require('carbon'),
- log = new Log();
-
- /**
- * obtains an encoded saml response and return a decoded/unmarshalled saml obj
- * @param samlResp
- * @return {*}
- */
- client.getSamlObject = function (samlResp) {
- var decodedResp = Util.decode(samlResp);
- return Util.unmarshall(decodedResp);
- };
-
- /**
- * validating the signature of the response saml object
- */
- client.validateSignature = function (samlObj, config) {
- var tDomain = Util.getDomainName(samlObj);
- var tId = carbon.server.tenantId({domain: tDomain});
-
- return Util.validateSignature(samlObj,
- config.KEY_STORE_NAME, config.KEY_STORE_PASSWORD, config.IDP_ALIAS, tId, tDomain);
- };
-
- /**
- * Checking if the request is a logout call
- */
- client.isLogoutRequest = function (samlObj) {
- return samlObj instanceof Packages.org.opensaml.saml2.core.LogoutRequest;
- };
-
- /**
- * Checking if the request is a logout call
- */
- client.isLogoutResponse = function (samlObj) {
- return samlObj instanceof Packages.org.opensaml.saml2.core.LogoutResponse;
- };
-
- /**
- * getting url encoded saml authentication request
- * @param issuerId
- */
- client.getEncodedSAMLAuthRequest = function (issuerId) {
- return Util.encode(
- Util.marshall(
- new Packages.org.wso2.store.sso.common.builders.AuthReqBuilder().buildAuthenticationRequest(issuerId)
- ));
- };
-
- /**
- * get url encoded saml logout request
- */
- client.getEncodedSAMLLogoutRequest = function (user, sessionIndex, issuerId) {
- return Util.encode(
- Util.marshall(
- new Packages.org.wso2.store.sso.common.builders.LogoutRequestBuilder().buildLogoutRequest(user, sessionIndex,
- Packages.org.wso2.store.sso.common.constants.SSOConstants.LOGOUT_USER,
- issuerId)));
- };
-
- /**
- * Reads the returning SAML login response and populates a session info object
- */
- client.decodeSAMLLoginResponse = function (samlObj, samlResp, sessionId) {
- var samlSessionObj = {
- // sessionId, loggedInUser, sessionIndex, samlToken
- };
-
- if (samlObj instanceof Packages.org.opensaml.saml2.core.Response) {
-
- var assertions = samlObj.getAssertions();
-
- // extract the session index
- if (assertions != null && assertions.size() > 0) {
- var authenticationStatements = assertions.get(0).getAuthnStatements();
- var authnStatement = authenticationStatements.get(0);
- if (authnStatement != null) {
- if (authnStatement.getSessionIndex() != null) {
- samlSessionObj.sessionIndex = authnStatement.getSessionIndex();
- }
- }
- }
-
- // extract the username
- if (assertions != null && assertions.size() > 0) {
- var subject = assertions.get(0).getSubject();
- var samlAssertion = assertions.get(0);
- if (subject != null) {
- if (subject.getNameID() != null) {
- samlSessionObj.loggedInUser = subject.getNameID().getValue();
- }
- }
- }
- samlSessionObj.sessionId = sessionId;
- samlSessionObj.samlToken = samlResp;
- }
-
- return samlSessionObj;
- };
-
- client.getURLencodedB64EncodedSAML2Token = function(samlObj){
- var saml2Token = {
- // URLEncodedB64
- };
- if (samlObj instanceof Packages.org.opensaml.saml2.core.Response) {
- saml2Token.URLEncodedB64 = Util.getURLEncodedB64SAML2Token(samlObj);
- }
- return saml2Token;
- };
-
- client.getB64EncodedtSAMLAssertion = function(samlObj){
- var saml2Token = {
- // URLEncodedB64
- };
- if (samlObj instanceof Packages.org.opensaml.saml2.core.Response) {
- saml2Token.b64Encoded = Util.getB64EncodedtSAMLAssertion(samlObj);
- }
- return saml2Token;
- };
-
-
- client.b64encode = function(str){
- return Util.encode(str);
- };
-
- /**
- * This method is to get the session index when a single logout happens
- * The IDP sends a logout request to the ACS with the session index, so that
- * the app can invalidate the associated HTTP Session
- */
- client.decodeSAMLLogoutRequest = function (samlObj) {
- var sessionIndex = null;
-
- if (samlObj instanceof org.opensaml.saml2.core.LogoutRequest) {
- var sessionIndexes = samlObj.getSessionIndexes();
- if (sessionIndexes != null && sessionIndexes.size() > 0) {
- sessionIndex = sessionIndexes.get(0).getSessionIndex();
- }
- }
-
- return sessionIndex;
-
- };
-
- client.getTenantDomain = function (samlObj) {
- var tDomain = Util.getDomainName(samlObj);
- return tDomain;
- };
-
- client.getRoleList = function(samlObj) {
- var roleObj = [];
- var roleString = Util.getRoles(samlObj);
- log.info("role string : " + roleString);
- var roleSplit = roleString.split(",");
- for(var i=0; i < roleSplit.length;i++){
- roleObj.push(roleSplit[i].trim());
- }
- return roleObj;
- };
-
-}(client));
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/eae721e7/products/stratos-manager/conf/tenant-reg-agent.xml
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/tenant-reg-agent.xml b/products/stratos-manager/conf/tenant-reg-agent.xml
deleted file mode 100755
index c39e189..0000000
--- a/products/stratos-manager/conf/tenant-reg-agent.xml
+++ /dev/null
@@ -1,25 +0,0 @@
-<!--
- ~ Licensed to the Apache Software Foundation (ASF) under one
- ~ or more contributor license agreements. See the NOTICE file
- ~ distributed with this work for additional information
- ~ regarding copyright ownership. The ASF licenses this file
- ~ to you under the Apache License, Version 2.0 (the
- ~ "License"); you may not use this file except in compliance
- ~ with the License. You may obtain a copy of the License at
- ~
- ~ http://www.apache.org/licenses/LICENSE-2.0
- ~
- ~ Unless required by applicable law or agreed to in writing,
- ~ software distributed under the License is distributed on an
- ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- ~ KIND, either express or implied. See the License for the
- ~ specific language governing permissions and limitations
- ~ under the License.
- -->
-<tenantRegListenerServers>
- <!--<server>
- <serverUrl>https://10.100.1.206:9443/services/</serverUrl>
- <userName>admin</userName>
- <password>admin</password>
- </server>-->
-</tenantRegListenerServers>