stratos-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pradee...@apache.org
Subject [1/2] git commit: latest jaggery module
Date Wed, 05 Feb 2014 07:25:37 GMT
Updated Branches:
  refs/heads/master 1db00e3d4 -> 989be9cb7


latest jaggery module


Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/a1fc1caa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/a1fc1caa
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/a1fc1caa

Branch: refs/heads/master
Commit: a1fc1caab0f167e15bd5a8ef8f9530f2ce1eb73d
Parents: fb72772
Author: Pradeep Fernando <pradeepfn@gmail.com>
Authored: Wed Feb 5 12:54:50 2014 +0530
Committer: Pradeep Fernando <pradeepfn@gmail.com>
Committed: Wed Feb 5 12:54:50 2014 +0530

----------------------------------------------------------------------
 .../conf/temp-artifacts/carbon/module.xml       |  47 ++
 .../carbon/scripts/registry/artifacts.js        | 574 +++++++++++++++++++
 .../carbon/scripts/registry/registry-osgi.js    | 445 ++++++++++++++
 .../carbon/scripts/registry/registry-ws.js      |  56 ++
 .../carbon/scripts/registry/registry.js         |  24 +
 .../carbon/scripts/server/config.js             |  32 ++
 .../carbon/scripts/server/osgi.js               |  10 +
 .../carbon/scripts/server/server.js             |  90 +++
 .../carbon/scripts/server/tenant.js             |  49 ++
 .../carbon/scripts/user/registry-space.js       |  39 ++
 .../temp-artifacts/carbon/scripts/user/space.js |  10 +
 .../carbon/scripts/user/user-manager.js         | 158 +++++
 .../temp-artifacts/carbon/scripts/user/user.js  |  78 +++
 .../modules/distribution/src/assembly/bin.xml   |  77 +--
 14 files changed, 1621 insertions(+), 68 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/products/stratos-manager/conf/temp-artifacts/carbon/module.xml
----------------------------------------------------------------------
diff --git a/products/stratos-manager/conf/temp-artifacts/carbon/module.xml b/products/stratos-manager/conf/temp-artifacts/carbon/module.xml
new file mode 100644
index 0000000..9eafb94
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/module.xml
@@ -0,0 +1,47 @@
+<module name="carbon" xmlns="http://wso2.org/projects/jaggery/module.xml">
+    <!-- scripts -->
+    <script>
+        <name>osgi</name>
+        <path>scripts/server/osgi.js</path>
+    </script>
+    <script>
+        <name>tenant</name>
+        <path>scripts/server/tenant.js</path>
+    </script>
+    <script>
+        <name>server</name>
+        <path>scripts/server/server.js</path>
+    </script>
+    <script>
+        <name>config</name>
+        <path>scripts/server/config.js</path>
+    </script>
+    <script>
+        <name>user</name>
+        <path>scripts/user/user.js</path>
+    </script>
+    <script>
+        <name>registry</name>
+        <path>scripts/registry/registry.js</path>
+    </script>
+    <script>
+        <name>registry-osgi</name>
+        <path>scripts/registry/registry-osgi.js</path>
+    </script>
+    <script>
+        <name>artifacts</name>
+        <path>scripts/registry/artifacts.js</path>
+    </script>
+    <script>
+        <name>space</name>
+        <path>scripts/user/space.js</path>
+    </script>
+    <script>
+        <name>registry-space</name>
+        <path>scripts/user/registry-space.js</path>
+    </script>
+    <script>
+        <name>user-manager</name>
+        <path>scripts/user/user-manager.js</path>
+    </script>
+</module>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/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
new file mode 100755
index 0000000..573d0fa
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/artifacts.js
@@ -0,0 +1,574 @@
+(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/a1fc1caa/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
new file mode 100644
index 0000000..a9ed825
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-osgi.js
@@ -0,0 +1,445 @@
+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/a1fc1caa/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
new file mode 100644
index 0000000..b79583f
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry-ws.js
@@ -0,0 +1,56 @@
+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()));
+};
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/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
new file mode 100644
index 0000000..9a76849
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/registry/registry.js
@@ -0,0 +1,24 @@
+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));
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/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
new file mode 100644
index 0000000..3dd4034
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/config.js
@@ -0,0 +1,32 @@
+(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));
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/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
new file mode 100644
index 0000000..caf5729
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/osgi.js
@@ -0,0 +1,10 @@
+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));
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/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
new file mode 100644
index 0000000..83f6ac7
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/server.js
@@ -0,0 +1,90 @@
+(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));
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/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
new file mode 100644
index 0000000..70466ad
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/server/tenant.js
@@ -0,0 +1,49 @@
+(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));
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/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
new file mode 100644
index 0000000..0fa8e56
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/registry-space.js
@@ -0,0 +1,39 @@
+(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));
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/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
new file mode 100644
index 0000000..1b7a996
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/space.js
@@ -0,0 +1,10 @@
+(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));
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fc1caa/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
new file mode 100644
index 0000000..cb511b9
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user-manager.js
@@ -0,0 +1,158 @@
+(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/a1fc1caa/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
new file mode 100644
index 0000000..cdfae1c
--- /dev/null
+++ b/products/stratos-manager/conf/temp-artifacts/carbon/scripts/user/user.js
@@ -0,0 +1,78 @@
+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/a1fc1caa/products/stratos-manager/modules/distribution/src/assembly/bin.xml
----------------------------------------------------------------------
diff --git a/products/stratos-manager/modules/distribution/src/assembly/bin.xml b/products/stratos-manager/modules/distribution/src/assembly/bin.xml
index b621eef..e74fe42 100755
--- a/products/stratos-manager/modules/distribution/src/assembly/bin.xml
+++ b/products/stratos-manager/modules/distribution/src/assembly/bin.xml
@@ -53,6 +53,7 @@
                 <exclude>**/repository/conf/security/cipher-tool.properties</exclude>
                 <exclude>**/repository/conf/security/cipher-text.properties</exclude>
 		<exclude>**/repository/conf/axis2/axis2.xml</exclude>
+		<exclude>**/repository/conf/log4j.properties</exclude>
             </excludes>
         </fileSet>
 	<!-- Copying p2 profile and osgi bundles-->
@@ -136,6 +137,7 @@
                 <exclude>**/user-mgt.xml</exclude>
                 <exclude>**/datasources.properties</exclude>
                 <exclude>.svn</exclude>
+                <exclude>**/temp-artifacts/**</exclude>
                 <exclude>email-bill-generated.xml</exclude>
                 <exclude>email-billing-notifications.xml</exclude>
                 <exclude>email-new-tenant-activation.xml</exclude>
@@ -351,6 +353,9 @@
         <fileSet>
             <directory>../p2-profile-gen/target/wso2carbon-core-${carbon.kernel.version}/modules</directory>
             <outputDirectory>${pom.artifactId}-${pom.version}/modules</outputDirectory>
+	    <excludes>
+                <exclude>**/carbon/**</exclude>
+	    </excludes>
             <includes>
                 <include>*/**</include>
             </includes>
@@ -411,6 +416,10 @@
             <outputDirectory>${pom.artifactId}-${pom.version}/modules/sso</outputDirectory>
         </fileSet>
 	<fileSet>
+            <directory>../../conf/temp-artifacts/carbon</directory>
+            <outputDirectory>${pom.artifactId}-${pom.version}/modules/carbon</outputDirectory>
+        </fileSet>
+	<fileSet>
             <directory>../../conf/temp-artifacts</directory>
             <outputDirectory>${pom.artifactId}-${pom.version}/repository/components/plugins</outputDirectory>
             <includes>
@@ -447,28 +456,6 @@
                 <include>org.wso2.carbon:org.wso2.carbon.mediator.bridge:jar</include>
             </includes>
         </dependencySet>
-        <!--dependencySet>
-            <outputDirectory>wso2elb-${pom.version}/samples/axis2Client/client_repo/modules
-            </outputDirectory>
-            <includes>
-                <include>org.apache.axis2:addressing:mar</include>
-                <include>org.apache.rampart:rampart:mar</include>
-                <include>org.apache.sandesha2:sandesha2:mar</include>
-            </includes>
-            <outputFileNameMapping>${artifact.artifactId}.${artifact.extension}
-            </outputFileNameMapping>
-        </dependencySet>
-        <dependencySet>
-            <outputDirectory>wso2elb-${pom.version}/samples/axis2Server/repository/modules
-            </outputDirectory>
-            <includes>
-                <include>org.apache.axis2:addressing:mar</include>
-                <include>org.apache.rampart:rampart:mar</include>
-                <include>org.apache.sandesha2:sandesha2:mar</include>
-            </includes>
-            <outputFileNameMapping>${artifact.artifactId}.${artifact.extension}
-            </outputFileNameMapping>
-        </dependencySet-->
         <dependencySet>
             <outputDirectory>${pom.artifactId}-${pom.version}/repository/axis2/client/lib</outputDirectory>
             <includes>
@@ -484,12 +471,6 @@
                 <include>org.apache.rampart:rampart:mar</include>
             </includes>
         </dependencySet>
-	<!--<dependencySet>
-		<outputDirectory>${pom.artifactId}-${pom.version}/repository/deployment/server/webapps</outputDirectory>
-		<includes>
-                    <include>org.wso2.carbon:features-dashboard:war</include>
-		</includes>
-	</dependencySet>-->
     </dependencySets>
 
     <files>
@@ -616,10 +597,6 @@
             <outputDirectory>${pom.artifactId}-${pom.version}/repository/conf/etc/</outputDirectory>
         </file>
 	<file>
-            <source>../../conf/log4j.properties</source>
-            <outputDirectory>${pom.artifactId}-${pom.version}/repository/conf/</outputDirectory>
-        </file>
-	<file>
             <source>src/bin/stratos.sh</source>
             <outputDirectory>apache-stratos-manager-${pom.version}/bin/</outputDirectory>
             <filtered>true</filtered>
@@ -667,32 +644,12 @@
             <filtered>true</filtered>
             <fileMode>755</fileMode>
         </file>
-         <!-- Including log4j.properties file -->
-        <!--file>
-            <source>
-                ../p2-profile-gen/target/wso2carbon-core-${carbon.kernel.version}/repository/conf/log4j.properties
-
-            </source>
-            <outputDirectory>${pom.artifactId}-${pom.version}/repository/conf</outputDirectory>
-        </file-->      
 	<file>
             <source>../p2-profile-gen/target/wso2carbon-core-${carbon.kernel.version}/repository/conf/claim-config.xml</source>
             <outputDirectory>${pom.artifactId}-${pom.version}/repository/conf</outputDirectory>
 	    <filtered>true</filtered>
 	    <fileMode>644</fileMode>	
         </file>
-
-        <!--file>
-            <source>../p2-profile-gen/target/wso2carbon-core-${carbon.kernel.version}/repository/conf/sso-idp-config.xml</source>
-            <outputDirectory>${pom.artifactId}-${pom.version}/repository/conf/</outputDirectory>
-        </file-->
-
-	<!-- Including coordination-client-config.xml file -->
-    <!--<file>
-            <source>../p2-profile-gen/target/wso2carbon-core-${carbon.kernel.version}/repository/conf/etc/coordination-client-config.xml</source>
-            <outputDirectory>${pom.artifactId}-${pom.version}/repository/conf/etc</outputDirectory>
-        </file> -->
-	<!-- Ntask config file -->
 	<file>
             <source>../p2-profile-gen/target/wso2carbon-core-${carbon.kernel.version}/repository/conf/etc/tasks-config.xml</source>
             <outputDirectory>${pom.artifactId}-${pom.version}/repository/conf/etc</outputDirectory>
@@ -727,22 +684,6 @@
             <outputDirectory>${pom.artifactId}-${pom.version}/dbscripts</outputDirectory>
             <filtered>true</filtered>
         </file>
-
-        <!-- <file>
-            <source>../p2-profile/target/WSO2-CARBON-PATCH-4.2.0-0002/repository/conf/axis2/axis2_client.xml</source>
-            <outputDirectory>apache-stratos-autoscaler-${pom.version}/repository/conf/axis2/</outputDirectory>
-            <filtered>true</filtered>
-        </file>
-        <file>
-            <source>../p2-profile/target/WSO2-CARBON-PATCH-4.2.0-0002/repository/conf/axis2/axis2.xml</source>
-            <outputDirectory>apache-stratos-autoscaler-${pom.version}/repository/conf/axis2/</outputDirectory>
-            <filtered>true</filtered>
-        </file>
-        <file>
-            <source>../p2-profile/target/WSO2-CARBON-PATCH-4.2.0-0002/repository/conf/axis2/tenant-axis2.xml</source>
-            <outputDirectory>apache-stratos-autoscaler-${pom.version}/repository/conf/axis2/</outputDirectory>
-            <filtered>true</filtered>
-        </file>-->
         <file>
             <source>../p2-profile-gen/target/WSO2-CARBON-PATCH-4.2.0-0002/repository/conf/security/cipher-text.properties</source>
             <outputDirectory>${pom.artifactId}-${pom.version}/repository/conf/security/</outputDirectory>


Mime
View raw message