ServiceNow Puppet Integration Guide

var rm = new sn_ws.RESTMessageV2('Puppet Enterprise API', 'get_nodes');
rm.setStringParameterNoEscape('query', 'query=["=", "certname", "web01.company.com"]');
rm.setMIDServer('YOUR_MID_SERVER_NAME');
var response = rm.execute();
var responseBody = response.getBody();
var httpStatus = response.getStatusCode();

// Transform script example for setting CI class based on OS
(function transformEntry(source, map, log, target) {
    var os = source.u_operating_system.toString().toLowerCase();
    if (os.indexOf('windows') >= 0) {
        target.sys_class_name = 'cmdb_ci_win_server';
    } else if (os.indexOf('linux') >= 0) {
        target.sys_class_name = 'cmdb_ci_linux_server';
    } else {
        target.sys_class_name = 'cmdb_ci_server';
    }
})(source, map, log, target);

var rm = new sn_ws.RESTMessageV2('Puppet Enterprise API', 'get_nodes');
rm.setMIDServer('YOUR_MID_SERVER_NAME');
var response = rm.execute();
if (response.getStatusCode() == 200) {
    var nodes = JSON.parse(response.getBody());
    var importGR = new GlideRecord('u_puppet_nodes_import');
    for (var i = 0; i < nodes.length; i++) {
        importGR.initialize();
        importGR.u_certname = nodes[i].certname;
        importGR.u_catalog_timestamp = nodes[i].catalog_timestamp;
        importGR.u_operating_system = nodes[i].facts ? nodes[i].facts.operatingsystem : '';
        importGR.insert();
    }
    var transform = new GlideTransformMap('Puppet Nodes to CMDB');
    transform.execute();
    gs.info('Puppet inventory sync completed: ' + nodes.length + ' nodes processed');
}

(function process(/*RESTAPIRequest*/ request, /*RESTAPIResponse*/ response) {
    var requestBody = request.body.data;
    var report = JSON.parse(requestBody);
    
    if (report.status === 'failed' || report.status === 'changed') {
        var incident = new GlideRecord('incident');
        incident.initialize();
        incident.short_description = 'Puppet run ' + report.status + ' on ' + report.certname;
        incident.description = 'Puppet report details: ' + JSON.stringify(report, null, 2);
        incident.caller_id.setDisplayValue('Puppet Automation');
        incident.category = 'Software';
        incident.subcategory = 'Configuration Management';
        incident.priority = report.status === 'failed' ? 2 : 4;
        var sysId = incident.insert();
        response.setStatus(201);
        response.setBody({status: 'success', incident: sysId});
    }
})(request, response);

(function executeRule(current, previous /*null when async*/) {
    var affectedCIs = current.cmdb_ci.getDisplayValue().split(',');
    
    for (var i = 0; i < affectedCIs.length; i++) {
        var rm = new sn_ws.RESTMessageV2('Puppet Enterprise API', 'run_task');
        var payload = {
            environment: 'production',
            task: 'service::restart',
            params: {service: 'apache2'},
            scope: {nodes: [affectedCIs[i].trim()]}
        };
        rm.setRequestBody(JSON.stringify(payload));
        rm.setMIDServer('YOUR_MID_SERVER_NAME');
        
        var response = rm.execute();
        var workNote = 'Puppet task execution on ' + affectedCIs[i] + ': ' + response.getStatusCode();
        if (response.getStatusCode() == 202) {
            var jobResult = JSON.parse(response.getBody());
            workNote += ' - Job ID: ' + jobResult.job.id;
        }
        current.work_notes = workNote;
        current.update();
    }
})(current, previous);

// Health check script for integration monitoring
var healthCheck = {
    puppet_api_status: 'unknown',
    last_sync_time: null,
    active_incidents: 0
};

var rm = new sn_ws.RESTMessageV2('Puppet Enterprise API', 'get_nodes');
rm.setStringParameterNoEscape('limit', '1');
var response = rm.execute();
healthCheck.puppet_api_status = response.getStatusCode() == 200 ? 'healthy' : 'error';

var syncGR = new GlideRecord('sys_execution_tracker');
syncGR.addQuery('name', 'Puppet Node Inventory Sync');
syncGR.orderByDesc('sys_created_on');
syncGR.setLimit(1);
if (syncGR.next()) {
    healthCheck.last_sync_time = syncGR.sys_created_on.toString();
}

gs.info('Puppet integration health: ' + JSON.stringify(healthCheck));