How to use createCiProject method in Cypress

...822      .withArgs({ foo: 'bar' }, 'remoteOrigin', 'auth-token-123')823      .resolves(this.newProject)824    })825    it('calls api.createProject with user session', function () {826      return createCiProject({ foo: 'bar', projectRoot }).then(() => {827        expect(api.createProject).to.be.calledWith({ foo: 'bar' }, 'remoteOrigin', 'auth-token-123')828      })829    })830    it('calls writeProjectId with id', function () {831      return createCiProject({ foo: 'bar', projectRoot, configFile }).then(() => {832        expect(settings.write).to.be.calledWith(projectRoot, { projectId: 'project-id-123' }, { configFile })833      })834    })835    it('returns project id', function () {836      return createCiProject({ foo: 'bar', projectRoot }).then((projectId) => {837        expect(projectId).to.eql(this.newProject)838      })839    })840  })841  context('#getRecordKeys', () => {842    beforeEach(function () {843      this.recordKeys = []844      this.project = new ProjectBase({ projectRoot: this.pristinePath, testingType: 'e2e' })845      sinon.stub(settings, 'read').resolves({ projectId: 'id-123' })846      sinon.stub(user, 'ensureAuthToken').resolves('auth-token-123')847      sinon.stub(api, 'getProjectRecordKeys').resolves(this.recordKeys)848    })849    it('calls api.getProjectRecordKeys with project id + session', function () {850      return this.project.getRecordKeys().then(() => {...

1var meta = {2    use: 'action',3    purpose: 'save',4    type: 'form',5    source: 'default',6    applyTo: '*',7    required: ['model', 'template'],8    name: 'asset.action.save'9};10/*11Description:Saves the contents of the model to an artifact instance and then retrieves the12            id13Filename: asset.action.save.js14Created Date: 8/8/201315 */16var module = function () {17    var configs = require('/config/publisher.json');18    var log = new Log();19    /*20    adding asset details to Social Cache DB.21     */22    function addToSocialCache(id, type) {23        if (id) {24            var logged = require('store').server.current(session);25            var domain = (logged && logged.tenantDomain) ? logged.tenantDomain : "carbon.super";26            var CREATE_QUERY = "CREATE TABLE IF NOT EXISTS SOCIAL_CACHE (id VARCHAR(255) NOT NULL,tenant VARCHAR(255),type VARCHAR(255), " +27                "body VARCHAR(5000), rating DOUBLE,  PRIMARY KEY ( id ))";28            var server = require('store').server;29            server.privileged(function () {30                var db = new Database("SOCIAL_CACHE");31                db.query(CREATE_QUERY);32                var combinedId = type + ':' + id;33                db.query("MERGE INTO SOCIAL_CACHE (id,tenant,type,body,rating) VALUES('" + combinedId + "','" + domain + "','" + type + "','',0)");34                db.close();35            });36        }37    }38    function createVCSRepo(context) {39        var model = context.model;40        var rxtManager = context.rxtManager;41        var artifactManager = rxtManager.getArtifactManager("vcs");42        var resourceId = model.getField('Other.VCSResourceID').value;43        var repoLocation = model.getField('Other.VersionControl').value;44        repoLocation = repoLocation.substring((repoLocation.lastIndexOf("/") + 1), (repoLocation.length + 1));45        var artifactManager = rxtManager.getArtifactManager('vcs');46        if (resourceId !== null) {47            var artifact = artifactManager.get(resourceId);48            var osgiService;49            var repositoryAdminService = carbon.server.osgiServices('org.wso2.carbon.utility.versioncontrol.IRepository');50            for (var i = 0; i < repositoryAdminService.size(); i++) {51                var id = repositoryAdminService.get(i).getRepositoryType();52                if (id.toLocaleLowerCase() == artifact.attributes.overview_serverType.toLocaleLowerCase()) {53                    osgiService = repositoryAdminService.get(i);54                }55            }56            var status = osgiService.createRepository(artifact.attributes.interface_username, artifact.attributes.interface_password, repoLocation);57            var result = {58                success: Boolean(status),59                status: status60            };61        }62    }63    function createPMSProject(context) {64        var model = context.model;65        var rxtManager = context.rxtManager;66        var pMSResourceId = model.getField('Other.PMSResourceID').value;67        var pMSEndPoint = model.getField('Other.ProjectManagementTool').value;68        pMSEndPoint = pMSEndPoint.substring((pMSEndPoint.lastIndexOf("/") + 1), (pMSEndPoint.length + 1));69        var artifactManager = rxtManager.getArtifactManager('pms');70        if (pMSResourceId !== null) {71            var artifact = artifactManager.get(pMSResourceId);72            var osgiService;73            var pMAdminService = carbon.server.osgiServices('org.wso2.carbon.utility.projectmanagement.IProjectManagement');74            for (var i = 0; i < pMAdminService.size(); i++) {75                var id = pMAdminService.get(i).getPMSType();76                if (id.toLocaleLowerCase() == artifact.attributes.overview_serverType.toLocaleLowerCase()) {77                    osgiService = pMAdminService.get(i);78                }79            }80            var status = osgiService.createPMSProject(artifact.attributes.interface_username, artifact.attributes.interface_password, pMSEndPoint);81            var result = {82                success: Boolean(status),83                status: status84            };85        }86    }87    function createIssueTrackerProject(context) {88        var model = context.model;89        var rxtManager = context.rxtManager;90        var issueTrackerResourceId = model.getField('Other.ISSResourceID').value;91        var issueTrackerEndPoint = model.getField('Other.IssueTracker').value;92        var projectName = issueTrackerEndPoint.substring((issueTrackerEndPoint.lastIndexOf("/") + 1), (issueTrackerEndPoint.length + 1));93        var artifactManager = rxtManager.getArtifactManager('iss');94        if (issueTrackerResourceId !== null) {95            var artifact = artifactManager.get(issueTrackerResourceId);96            var osgiService;97            var issueTrackerAdminService = carbon.server.osgiServices('org.wso2.carbon.utility.issuetracker.IIssueTracker');98            for (var i = 0; i < issueTrackerAdminService.size(); i++) {99                var id = issueTrackerAdminService.get(i).getIssueTrackerType();100                log.info(id.toLocaleLowerCase() + "  " + artifact.attributes.overview_serverType.toLocaleLowerCase())101                if (id.toLocaleLowerCase() == artifact.attributes.overview_serverType.toLocaleLowerCase()) {102                    osgiService = issueTrackerAdminService.get(i);103                    log.info(osgiService);104                }105            }106            //String projectKey,String name,String description,String url,String lead107            log.info(artifact.attributes.interface_username + " " + artifact.attributes.interface_password + " " + issueTrackerEndPoint + " " + issueTrackerResourceId);108            var status = osgiService.createIssueTrackerProject(artifact.attributes.interface_username, artifact.attributes.interface_password, projectName, projectName, " <Add Description Here> ", issueTrackerEndPoint, artifact.attributes.interface_username);109            var result = {110                success: Boolean(status),111                status: status112            };113        }114    }115    function createCIProject(context) {116        var model = context.model;117        var rxtManager = context.rxtManager;118        var cIResourceId = model.getField('Other.CISResourceID').value;119        var cIJobName = model.getField('Other.ContinuousIntegration').value;120        cIJobName = cIJobName.substring((cIJobName.lastIndexOf("/") + 1), (cIJobName.length + 1));121        var artifactManager = rxtManager.getArtifactManager('cis');122        if (cIResourceId !== null) {123            var artifact = artifactManager.get(cIResourceId);124            var osgiService;125            var cIAdminService = carbon.server.osgiServices('org.wso2.carbon.utility.continuousintegration.IContinuousIntegration');126            for (var i = 0; i < cIAdminService.size(); i++) {127                var id = cIAdminService.get(i).getCISType();128                log.info(id.toLocaleLowerCase() + "  " + artifact.attributes.overview_serverType.toLocaleLowerCase())129                if (id.toLocaleLowerCase() == artifact.attributes.overview_serverType.toLocaleLowerCase()) {130                    osgiService = cIAdminService.get(i);131                    log.info(osgiService);132                }133            }134            var status = osgiService.createCISProject(artifact.attributes.interface_username, artifact.attributes.interface_password, artifact.attributes.interface_serverURL, cIJobName);135            var result = {136                success: Boolean(status),137                status: status138            };139        }140    }141    return {142        execute: function (context) {143            var utility = require('/modules/utility.js').rxt_utility();144            log.debug('Entered : ' + meta.name);145            log.debug(stringify(context.actionMap));146            var model = context.model;147            var template = context.template;148            var now = new String(new Date().valueOf());149            var length = now.length;150            var prefix = configs.constants.assetCreatedDateLength;151            var onsetVal = '';152            if (length != prefix) {153                var onset = prefix - length;154                for (var i = 0; i < onset; i++) {155                    onsetVal += '0';156                }157            }158            model.setField('overview.createdtime', onsetVal + now);159            var name = model.getField('overview.name').value;160            var version = model.getField('overview.version').value;161            var shortName = template.shortName;162            log.debug('Artifact name: ' + name);163            log.debug('Converting model to an artifact for use with an artifact manager');164            //Export the model to an asset165            var asset = context.parent.export('asset.exporter');166            log.debug('Finished exporting model to an artifact');167            //Save the artifact168            log.debug('Saving artifact with name :' + name);169            //Get the artifact using the name170            var rxtManager = context.rxtManager;171            var artifactManager = rxtManager.getArtifactManager(shortName);172            artifactManager.add(asset);173            //name='test-gadget-7';174            log.debug('Finished saving asset : ' + name);175            //The predicate object used to compare the assets176            var predicate = {177                attributes: {178                    overview_name: name,179                    overview_version: version180                }181            };182            var artifact = artifactManager.find(function (adapter) {183                //Check if the name and version are the same184                //return ((adapter.attributes.overview_name==name)&&(adapter.attributes.overview_version==version))?true:false;185                return utility.assertEqual(adapter, predicate);186            }, null);187            log.debug('Locating saved asset: ' + stringify(artifact) + ' to get the asset id.');188            var id = artifact[0].id || ' ';189            log.debug('Setting id of model to ' + id);190            //adding asset to social191            addToSocialCache(id, template.shortName);192            //Save the id data to the model193            model.setField('*.id', id);194            if (shortName === "project") {195                if (model.getField('Other.VCSResourceID').value != null && model.getField('Other.VCSResourceID').value.trim().length >0) {196                    createVCSRepo(context);197                }198                if (model.getField('Other.CISResourceID').value != null && model.getField('Other.CISResourceID').value.trim().length >0 ) {199                    createCIProject(context);200                }201                if (model.getField('Other.PMSResourceID').value != null && model.getField('Other.PMSResourceID').value.trim().length >0) {202                    createPMSProject(context);203                }204                if (model.getField('Other.ISSResourceID').value != null && model.getField('Other.ISSResourceID').value.trim().length >0) {205                    createIssueTrackerProject(context);206                }207            }208            log.debug('Finished saving asset with id: ' + id);209        }210    }...

...163        return id;164    });165}166exports.writeProjectId = writeProjectId;167function createCiProject(_a) {168    var { projectRoot, configFile } = _a, projectDetails = (0, tslib_1.__rest)(_a, ["projectRoot", "configFile"]);169    return (0, tslib_1.__awaiter)(this, void 0, void 0, function* () {170        debug('create CI project with projectDetails %o projectRoot %s', projectDetails);171        const authToken = yield user_1.default.ensureAuthToken();172        const remoteOrigin = yield commit_info_1.default.getRemoteOrigin(projectRoot);173        debug('found remote origin at projectRoot %o', {174            remoteOrigin,175            projectRoot,176        });177        const newProject = yield api_1.default.createProject(projectDetails, remoteOrigin, authToken);178        yield writeProjectId({179            configFile,180            projectRoot,181            id: newProject.id,...

...175        }).call("getConfig").then(send)["catch"](sendErr);176      case "close:project":177        return openProject.close().then(send)["catch"](sendErr);178      case "setup:dashboard:project":179        return openProject.createCiProject(arg).then(send)["catch"](sendErr);180      case "get:record:keys":181        return openProject.getRecordKeys().then(send)["catch"](sendErr);182      case "get:specs":183        return openProject.getSpecChanges({184          onChange: send,185          onError: sendErr186        });187      case "get:runs":188        return openProject.getRuns().then(send)["catch"](function(err) {189          err.type = _.get(err, "statusCode") === 401 ? "UNAUTHENTICATED" : _.get(err, "cause.code") === "ESOCKETTIMEDOUT" ? "TIMED_OUT" : _.get(err, "code") === "ENOTFOUND" ? "NO_CONNECTION" : err.type || "UNKNOWN";190          return sendErr(err);191        });192      case "request:access":193        return openProject.requestAccess(arg).then(send)["catch"](function(err) {...

1/**2 * Created by pkutxq on 15-4-24.3 */4angular.module('data')5    .service('ciService', ['url', '$http',6        function (url, $http) {7            var _buildDTOs = [],8             _ciProjectList = [],9                _ciProject,10                _repository;11            var findCIProjectDTOIdx = function (ciProjectDTO) {12                for (var i = 0; i < _ciProjectList.length; i++) {13                    if (ciProjectDTO.id === _ciProjectList[i].id) {14                        return i;15                    }16                }17                return -1;18            };19            var findCIBuildDTOIdx = function (ciBuildDTO) {20                for (var i = 0; i < _buildDTOs.length; i++) {21                    if (ciBuildDTO.id === _buildDTOs[i].id) {22                        return i;23                    }24                }25                return -1;26            };27            // 从后台获取数据28            this.getCiProjects = function () {29                return $http.get([url.projectApiUrl(url.projectId(), url.companyId()), '/ciProject'].join(""))30                    .then(function (result) {31                        _repository = result.data.repository === null ? "" : result.data.repository;32                        _ciProjectList = result.data.ciProjectList === null ? "" : result.data.ciProjectList;33                        return {34                            repository: _repository,35                            ciProjectList: _ciProjectList36                        };37                    });38            };39            this.getCiBuilds = function (ciProjectId) {40                return $http.get([url.projectApiUrl(url.projectId(), url.companyId()), '/ciProject/',ciProjectId].join(""))41                    .then(function (result) {42                        _ciProject = result.data === null ? "" : result.data;43                        _buildDTOs = _ciProject.ciBuildDTOs;44                        return {45                            ciProject: _ciProject46                        };                    47                    });48            };49            this.createCiProject = function (ciProject) {50                var project = angular.copy(ciProject);51                for (var key in ciProject.dockerConfigs) {52                    project.dockerConfigs[key] = ciProject.dockerConfigs[key].value;53                }54                return $http.post([url.projectApiUrl(url.projectId(), url.companyId()), '/ciProject/create'].join(""), project).then(function (result) {55                    _ciProject = result.data;56                    return _ciProject;57                });58            };59            this.updateCIProject = function (ciProject, ciProjectId) {60                var project = angular.copy(ciProject);61                for (var key in ciProject.dockerConfigs) {62                    project.dockerConfigs[key] = ciProject.dockerConfigs[key].value;63                }64                return $http.post([url.projectApiUrl(url.projectId(), url.companyId()), '/ciProject/', ciProjectId, '/update'].join(""), project).then(function (result) {65                    _ciProject = result.data;66                    return _ciProject;67                });68            };69            this.deleteCIProject = function (ciProjectId) {70                var _delUrl = [url.projectApiUrl(url.projectId(), url.companyId()), '/ciProject/', ciProjectId, '/delete'].join("");71                $http.delete(_delUrl).then(function (result) {72                    return result.data;73                });74            };75            this.createBuild = function (ciProjectId) {76                var _createCiBuildUrl = [url.projectApiUrl(url.projectId(), url.companyId()), '/ciProject/', ciProjectId, '/builds/new'].join("");77                return $http.post(_createCiBuildUrl).then(function (response) {78                    return response.data;79                });80            };81            this.deleteBuild = function(ciProjectId,ciBuildId){82                var _deleteCiBuildUrl = [url.projectApiUrl(url.projectId(), url.companyId()), '/ciProject/', ciProjectId, '/builds/',ciBuildId,'/delete'].join("");83                return $http.delete(_deleteCiBuildUrl).then(function(response){84                   return response.data;85                });86            };87            this.getCiBuildDetail = function (ciProjectId, buildId) {88                var _getCiBuildResultUrl = [url.projectApiUrl(url.projectId(), url.companyId()), '/ciProject/', ciProjectId, '/builds/', buildId].join("");89                return $http.get(_getCiBuildResultUrl).then(function (response) {90                    return response.data;91                });92            };93            this.getCiBuildTestReport = function (ciProjectId, buildId) {94                var _getCiBuildResultUrl = [url.projectApiUrl(url.projectId(), url.companyId()), '/ciProject/', ciProjectId, '/builds/', buildId,'/testresult'].join("");95                return $http.get(_getCiBuildResultUrl).then(function (response) {96                    return response.data;97                });98            };99            this.getCIProjectById = function (companyId, projectId, ciProjectId) {100                var _getCIProjectByIdUrl = [url.projectApiUrl(projectId, companyId), '/ciProject/', ciProjectId].join("");101                return $http.get(_getCIProjectByIdUrl).then(function (response) {102                    return response.data;103                });104            };105            this.webSocketCreateCIProject = function (ciProjectDTO) {106                // _ciProjectList.slice(0,0,data);107                _ciProject = ciProjectDTO;108            };109            this.webSocketUpdateCIProject = function (ciProjectDTO) {110                _ciProject = ciProjectDTO;111            };112            this.webSocketCreateCIBuild = function (ciBuildDTO) {113                _buildDTOs.slice(0, 0, ciBuildDTO);114            };115            this.webSocketUpdateCIBuild = function (ciBuildDTO) {116                var idx = findCIBuildDTOIdx(ciBuildDTO);117                if (idx > -1) {118                    _buildDTOs.splice(idx, 1);119                    _buildDTOs.splice(0, 0, ciBuildDTO);120                }121            };122            this.webSocketDeleteCIBuild = function (ciBuildDTO) {123                var idx = findCIBuildDTOIdx(ciBuildDTO);124                if (idx > -1) {125                    _buildDTOs.slice(idx, 1);126                }127            };...

1(function() {2  var Project, Promise, _, browsers, config, create, files, log,3    slice = [].slice;4  _ = require("lodash");5  Promise = require("bluebird");6  files = require("./controllers/files");7  config = require("./config");8  Project = require("./project");9  browsers = require("./browsers");10  log = require('./log');11  create = function() {12    var openProject, relaunchBrowser, reset, specIntervalId, tryToCall;13    openProject = null;14    specIntervalId = null;15    relaunchBrowser = null;16    reset = function() {17      openProject = null;18      return relaunchBrowser = null;19    };20    tryToCall = function(method) {21      return function() {22        var args;23        args = 1 <= arguments.length ? slice.call(arguments, 0) : [];24        if (openProject) {25          return openProject[method].apply(openProject, args);26        } else {27          return Promise.resolve(null);28        }29      };30    };31    return {32      reset: tryToCall("reset"),33      getConfig: tryToCall("getConfig"),34      createCiProject: tryToCall("createCiProject"),35      getRecordKeys: tryToCall("getRecordKeys"),36      getRuns: tryToCall("getRuns"),37      requestAccess: tryToCall("requestAccess"),38      emit: tryToCall("emit"),39      getProject: function() {40        return openProject;41      },42      launch: function(browserName, spec, options) {43        if (options == null) {44          options = {};45        }46        log("launching browser %s spec %s", browserName, spec);47        return this.reset().then(function() {48          return openProject.ensureSpecUrl(spec);49        }).then(function(url) {50          return openProject.getConfig().then(function(cfg) {51            var am, automation;52            options.browsers = cfg.browsers;53            options.proxyUrl = cfg.proxyUrl;54            options.userAgent = cfg.userAgent;55            options.proxyServer = cfg.proxyUrl;56            options.socketIoRoute = cfg.socketIoRoute;57            options.chromeWebSecurity = cfg.chromeWebSecurity;58            options.url = url;59            automation = openProject.getAutomation();60            if (am = options.automationMiddleware) {61              automation.use(am);62            }63            return (relaunchBrowser = function() {64              log("launching project in browser " + browserName);65              return browsers.open(browserName, options, automation);66            })();67          });68        });69      },70      getSpecChanges: function(options) {71        var checkForSpecUpdates, currentSpecs, get, sendIfChanged;72        if (options == null) {73          options = {};74        }75        currentSpecs = null;76        _.defaults(options, {77          onChange: function() {},78          onError: function() {}79        });80        sendIfChanged = function(specs) {81          if (specs == null) {82            specs = [];83          }84          if (_.isEqual(specs, currentSpecs)) {85            return;86          }87          currentSpecs = specs;88          return options.onChange(specs);89        };90        checkForSpecUpdates = (function(_this) {91          return function() {92            if (!openProject) {93              return _this.clearSpecInterval();94            }95            return get().then(sendIfChanged)["catch"](options.onError);96          };97        })(this);98        get = function() {99          return openProject.getConfig().then(function(cfg) {100            return files.getTestFiles(cfg);101          });102        };103        specIntervalId = setInterval(checkForSpecUpdates, 2500);104        return checkForSpecUpdates();105      },106      clearSpecInterval: function() {107        if (specIntervalId) {108          clearInterval(specIntervalId);109          return specIntervalId = null;110        }111      },112      closeBrowser: function() {113        return browsers.close();114      },115      closeOpenProjectAndBrowsers: function() {116        return Promise.all([this.closeBrowser(), openProject ? openProject.close() : void 0]).then(function() {117          reset();118          return null;119        });120      },121      close: function() {122        log("closing opened project");123        this.clearSpecInterval();124        return this.closeOpenProjectAndBrowsers();125      },126      create: function(path, args, options) {127        if (args == null) {128          args = {};129        }130        if (options == null) {131          options = {};132        }133        openProject = Project(path);134        _.defaults(options, {135          onReloadBrowser: (function(_this) {136            return function(url, browser) {137              if (relaunchBrowser) {138                return relaunchBrowser();139              }140            };141          })(this)142        });143        options = _.extend({}, args.config, options);144        return browsers.get().then(function(b) {145          if (b == null) {146            b = [];147          }148          options.browsers = b;149          log("opening project %s", path);150          return openProject.open(options);151        })["return"](this);152      }153    };154  };155  module.exports = create();156  module.exports.Factory = create;...