scom

Perl Code

#!/usr/bin/perl
use LWP::UserAgent;,
use strict;
use Switch;
use warnings;
use Data::Dump qw(dump);
use Net::SSLeay;

$Net::SSLeay::trace = 2;
my $ua = LWP::UserAgent->new(ssl_opts => { verify_hostname => 0});



my $eventtype= $ARGV[0];
my $CONTACTPAGER = $ARGV[1];
my $HOSTNAME = $ARGV[3];
my $HOSTGROUPNAMES =  $ARGV[2];
my $NOTIFICATIONTYPE =  $ARGV[4];
my $NOTIFICATIONSCOM = "";
my $post_data = "";

switch ($NOTIFICATIONTYPE) {
        case  "RECOVERY" { $NOTIFICATIONSCOM = 3;}
        case  "CUSTOM" {  $NOTIFICATIONSCOM = 3;}
        case "WARNING" { $NOTIFICATIONSCOM = 2;}
        case "DOWN" { $NOTIFICATIONSCOM = 1;}
        case "CRITICAL" { $NOTIFICATIONSCOM = 1;}
        case "OK" { $NOTIFICATIONSCOM = 0;}
        case "UP" { $NOTIFICATIONSCOM = 0;}
        else { $NOTIFICATIONSCOM = 3;}
}
[11:07 pm]
my $scom_server = "https://pagerapi.com/rest/Event/AddEvent";

if ($eventtype eq "HOST") {
        my $HOSTSTATE =  $ARGV[4];
        my $HOSTOUTPUT =  $ARGV[5];
        $post_data = '{"RecipientList":"' . $CONTACTPAGER . '","AssignmentGroup":"' . $CONTACTPAGER . '","CI": "' . $HOSTNAME . '" , "Service": "IT Monitoring", "ObjectClass": "' . $HOSTGROUPNAMES . '", "Source":2, "Object": "' . $HOSTSTATE . '", "Severity": ' . $NOTIFICATIONSCOM . ' , "Message": "' . $HOSTOUTPUT . '"}';

        }

        else {
        my $SERVICESTATE =  $ARGV[4];
        my $SERVICEOUTPUT =  $ARGV[5];
        my $SERVICEDESC = $ARGV[6];
         $post_data = '{"RecipientList":"' . $CONTACTPAGER . '","AssignmentGroup":"' . $CONTACTPAGER . '","CI": "' . $HOSTNAME . '" , "Service": "IT Monitoring", "ObjectClass": "' . $HOSTGROUPNAMES . '", "Source":2, "Object": "' . $SERVICEDESC . " is " . $SERVICESTATE . '", "Severity": ' . $NOTIFICATIONSCOM . ' , "Message": "' . $SERVICEOUTPUT . '"}';
}
#print $post_data;
my $req = HTTP::Request->new(POST => $scom_server);

$req->header('content-type' => 'application/json');
$req->authorization_basic('user','pass');
$req->content($post_data);

print $req->as_string;

my $resp = $ua->request($req);
#print "HTTP POST error code: ", $resp->code, "\n";
#print "HTTP POST error message: ", $resp->message, "\n";
my $datestring = localtime();
my $fh;
open ($fh, '>>','/tmp/to_scom.log');
print $fh "" . $datestring . " - " . $resp->code . " - " . $post_data . "\n";
close $fh;

Python Code

#!/usr/bin/env python3

import sys
import json
import datetime
import requests

# Disable insecure‐SSL warnings
requests.packages.urllib3.disable_warnings(
    requests.packages.urllib3.exceptions.InsecureRequestWarning
)

# Map Nagios state strings to numeric severity codes
SEVERITY_MAP = {
    "RECOVERY": 3,
    "CUSTOM":   3,
    "WARNING":  2,
    "DOWN":     1,
    "CRITICAL": 1,
    "OK":       0,
    "UP":       0
}

def usage():
    print(f"Usage: {sys.argv[0]} EVENT_TYPE CONTACT_PAGER HOSTGROUPS HOSTNAME STATE OUTPUT [SERVICEDESC]")
    print("  EVENT_TYPE  = HOST or SERVICE")
    print("  STATE       = OK, WARNING, CRITICAL, DOWN, UP, RECOVERY, CUSTOM")
    sys.exit(1)

def build_payload(event_type, contact_pager, hostgroups, hostname, state, output, desc=None):
    severity = SEVERITY_MAP.get(state.upper(), 3)
    base = {
        "RecipientList":   contact_pager,
        "AssignmentGroup": contact_pager,
        "CI":              hostname,
        "Service":         "IT Monitoring",
        "ObjectClass":     hostgroups,
        "Source":          2,
        "Severity":        severity,
    }

    if event_type.upper() == "HOST":
        base["Object"]  = state
        base["Message"] = output
    else:
        # For SERVICE events, include the service description
        base["Object"]  = f"{desc} is {state}"
        base["Message"] = output

    return base

def main():
    # Minimal argument check
    if len(sys.argv) < 7:
        usage()

    event_type, contact_pager, hostgroups, hostname = sys.argv[1:5]
    state, output = sys.argv[5:7]
    desc = sys.argv[7] if len(sys.argv) >= 8 else None

    payload = build_payload(event_type,
                            contact_pager,
                            hostgroups,
                            hostname,
                            state,
                            output,
                            desc)

    url = "https://pagerapi.com/rest/Event/AddEvent"
    auth = ("user", "pass")
    headers = {"Content-Type": "application/json"}

    # Prepare and print the raw HTTP request (similar to $req->as_string in Perl)
    session = requests.Session()
    req = requests.Request("POST", url, headers=headers, auth=auth, json=payload)
    prepped = session.prepare_request(req)
    print(f"{prepped.method} {prepped.url}")
    for h, v in prepped.headers.items():
        print(f"{h}: {v}")
    print("\n" + (prepped.body.decode() if isinstance(prepped.body, bytes) else prepped.body))

    # Send the request, skipping certificate verification
    resp = session.send(prepped, verify=False)

    # Log the result
    timestamp = datetime.datetime.now().isoformat()
    log_line = f"{timestamp} - {resp.status_code} - {json.dumps(payload)}\n"
    with open("/tmp/to_scom.log", "a") as logf:
        logf.write(log_line)

    # Optionally print response status
    print(f"\nResponse Code: {resp.status_code}")

if __name__ == "__main__":
    main()