CI/CD Pipeline Pattern for ServiceNow

// CI/CD Pipeline Orchestrator Script Include
var CICDPipelineOrchestrator = Class.create();
CICDPipelineOrchestrator.prototype = {
    initialize: function() {
        this.restClient = new sn_ws.RESTMessageV2();
    },

    // Main pipeline execution method
    executePipeline: function(updateSetSysId, targetInstance) {
        try {
            var pipeline = {
                updateSetId: updateSetSysId,
                target: targetInstance,
                status: 'running',
                startTime: new GlideDateTime()
            };
            
            // Step 1: Validate update set completeness
            if (!this._validateUpdateSet(updateSetSysId)) {
                throw new Error('Update set validation failed');
            }
            
            // Step 2: Run ATF test suite
            var testResults = this._executeATFTests(updateSetSysId);
            if (!testResults.success) {
                throw new Error('ATF tests failed: ' + testResults.failureDetails);
            }
            
            // Step 3: Create change request for deployment approval
            var changeRequest = this._createChangeRequest(updateSetSysId, targetInstance);
            
            // Step 4: Wait for change approval (will be handled by workflow)
            this._scheduleDeploymentOnApproval(changeRequest, updateSetSysId, targetInstance);
            
            return { success: true, changeRequest: changeRequest, pipeline: pipeline };
            
        } catch (error) {
            gs.error('Pipeline execution failed: ' + error.message);
            this._notifyFailure(updateSetSysId, error.message);
            return { success: false, error: error.message };
        }
    },

    _validateUpdateSet: function(updateSetSysId) {
        var updateSet = new GlideRecord('sys_update_set');
        if (!updateSet.get(updateSetSysId)) return false;
        
        // Check if update set is complete and has updates
        if (updateSet.state != 'complete') {
            gs.warn('Update set is not in complete state: ' + updateSet.name);
            return false;
        }
        
        // Verify there are actual updates in the set
        var updateCount = new GlideAggregate('sys_update_xml');
        updateCount.addQuery('update_set', updateSetSysId);
        updateCount.addAggregate('COUNT');
        updateCount.query();
        
        return updateCount.next() && updateCount.getAggregate('COUNT') > 0;
    },

    _executeATFTests: function(updateSetSysId) {
        // Get test suite associated with update set or use default
        var testSuite = this._getTestSuiteForUpdateSet(updateSetSysId);
        
        var testRunner = new sn_atf.AutomatedTestingFramework();
        var executionId = testRunner.executeTestSuite(testSuite);
        
        // Poll for completion (in real implementation, use scheduled jobs)
        var maxWaitTime = 30 * 60 * 1000; // 30 minutes
        var startTime = Date.now();
        var testResult;
        
        do {
            gs.sleep(5000); // Wait 5 seconds
            testResult = testRunner.getExecutionResult(executionId);
        } while (testResult.status === 'running' && (Date.now() - startTime) < maxWaitTime);
        
        if (testResult.status === 'timeout') {
            return { success: false, failureDetails: 'Test execution timed out' };
        }
        
        return {
            success: testResult.status === 'success' && testResult.failureCount === 0,
            failureDetails: testResult.failureDetails || '',
            executionId: executionId
        };
    },

    _createChangeRequest: function(updateSetSysId, targetInstance) {
        var updateSet = new GlideRecord('sys_update_set');
        updateSet.get(updateSetSysId);
        
        var change = new GlideRecord('change_request');
        change.initialize();
        change.short_description = 'Automated deployment: ' + updateSet.name;
        change.description = 'Automated CI/CD pipeline deployment for update set: ' + updateSet.name + ' to ' + targetInstance;
        change.category = 'Software';
        change.type = 'Normal';
        change.risk = 'Low';
        change.impact = '3';
        change.priority = '3';
        change.assignment_group = gs.getProperty('cicd.deployment.approval.group', 'CAB');
        change.u_update_set = updateSetSysId;
        change.u_target_instance = targetInstance;
        
        var changeSysId = change.insert();
        gs.info('Created change request ' + change.number + ' for update set deployment');
        
        return changeSysId;
    },

    _scheduleDeploymentOnApproval: function(changeRequestSysId, updateSetSysId, targetInstance) {
        // This would typically trigger a workflow or scheduled job
        // that monitors the change request approval status
        var scheduledJob = new GlideRecord('sysauto_script');
        scheduledJob.initialize();
        scheduledJob.name = 'Deploy on Change Approval - ' + new GlideDateTime();
        scheduledJob.condition_script = this._generateApprovalCheckScript(changeRequestSysId);
        scheduledJob.script = this._generateDeploymentScript(updateSetSysId, targetInstance, changeRequestSysId);
        scheduledJob.active = true;
        scheduledJob.run_period = '0 */5 * * * ?'; // Every 5 minutes
        scheduledJob.insert();
    },

    _generateDeploymentScript: function(updateSetSysId, targetInstance, changeRequestSysId) {
        return "var deployer = new CICDDeploymentExecutor(); deployer.executeDeployment('" + 
               updateSetSysId + "', '" + targetInstance + "', '" + changeRequestSysId + "');"
    },

    _getTestSuiteForUpdateSet: function(updateSetSysId) {
        // Logic to determine appropriate test suite
        return gs.getProperty('cicd.default.test.suite', 'default_regression_suite');
    },

    type: 'CICDPipelineOrchestrator'
};