ServiceNow Docker Integration Guide

var rm = new sn_ws.RESTMessageV2('Docker API Client', 'list_containers');
rm.setStringParameterNoEscape('docker_host', 'docker-prod-01.company.com');
rm.setStringParameterNoEscape('api_path', '/containers/json?all=true');
rm.setRequestHeader('Content-Type', 'application/json');
var response = rm.execute();
var httpStatus = response.getStatusCode();
var responseBody = response.getBody();
if (httpStatus == 200) {
    var containers = JSON.parse(responseBody);
    gs.info('Found ' + containers.length + ' containers');
    return containers;
} else {
    gs.error('Docker API call failed with status: ' + httpStatus);
    return null;
}

var DockerDiscovery = Class.create();
DockerDiscovery.prototype = {
    initialize: function() {
        this.containerTable = 'cmdb_ci_docker_container';
        this.imageTable = 'cmdb_ci_docker_image';
    },
    
    discoverContainers: function(dockerHost) {
        var rm = new sn_ws.RESTMessageV2('Docker API Client', 'list_containers');
        rm.setStringParameterNoEscape('docker_host', dockerHost);
        var response = rm.execute();
        
        if (response.getStatusCode() == 200) {
            var containers = JSON.parse(response.getBody());
            for (var i = 0; i < containers.length; i++) {
                this.processContainer(containers[i], dockerHost);
            }
        }
    },
    
    processContainer: function(containerData, dockerHost) {
        var gr = new GlideRecord(this.containerTable);
        gr.addQuery('container_id', containerData.Id);
        gr.query();
        
        if (!gr.next()) {
            gr.initialize();
            gr.container_id = containerData.Id;
        }
        
        gr.name = containerData.Names[0].substring(1);
        gr.image = containerData.Image;
        gr.status = containerData.Status;
        gr.docker_host = dockerHost;
        gr.ports = JSON.stringify(containerData.Ports);
        gr.update();
    },
    
    type: 'DockerDiscovery'
};

(function process(/*RESTAPIRequest*/ request, /*RESTAPIResponse*/ response) {
    var payload = request.body.data;
    var action = payload.action;
    var repository = payload.target.repository;
    var tag = payload.target.tag;
    
    gs.info('Docker registry webhook received: ' + action + ' for ' + repository + ':' + tag);
    
    // Create event management record
    var eventGr = new GlideRecord('em_event');
    eventGr.initialize();
    eventGr.source = 'Docker Registry';
    eventGr.type = 'docker.registry.' + action;
    eventGr.resource = repository;
    eventGr.node = payload.request.host;
    eventGr.description = 'Docker image ' + action + ': ' + repository + ':' + tag;
    eventGr.severity = (action == 'push') ? 1 : 2;
    eventGr.insert();
    
    // Trigger container discovery for push events
    if (action == 'push') {
        gs.eventQueue('docker.image.pushed', eventGr, repository, tag);
    }
    
    response.setStatus(200);
    response.setBody(JSON.stringify({status: 'processed', action: action}));
})(request, response);

// Event Rule Script for Docker Container Health Events
if (event.type == 'docker.container.unhealthy') {
    var containerName = event.resource;
    var dockerHost = event.node;
    
    // Check if container is critical (tagged with critical=true label)
    var containerGr = new GlideRecord('cmdb_ci_docker_container');
    containerGr.addQuery('name', containerName);
    containerGr.addQuery('docker_host', dockerHost);
    containerGr.query();
    
    if (containerGr.next()) {
        var labels = JSON.parse(containerGr.labels || '{}');
        if (labels.critical == 'true') {
            // Create high priority incident for critical containers
            var incGr = new GlideRecord('incident');
            incGr.initialize();
            incGr.short_description = 'Critical Docker container unhealthy: ' + containerName;
            incGr.description = 'Docker container ' + containerName + ' on host ' + dockerHost + ' is reporting unhealthy status';
            incGr.priority = 1;
            incGr.assignment_group = 'DevOps Team';
            incGr.cmdb_ci = containerGr.sys_id;
            incGr.insert();
            
            // Trigger automated restart workflow
            gs.eventQueue('docker.container.restart', incGr, containerName, dockerHost);
        }
    }
}