Notes

import boto3
import time
import json
import os
from service_now import createServiceNowStandardChange, update_service_now_cr

# A dictionary to map the next state based on the current state
state_transition = {
-5: {"value": "New", "label": "New"},
-2: {"value": "Scheduled", "label": "Scheduled"},
-1: {"value": "Implement", "label": "Implement"},
0: {"value": "Review", "label": "Review"},
3: {"value": "Closed", "label": "Closed"},
4: {"value": "Canceled", "label": "Canceled"}
}

def get_default_assigned_to(region):
client = boto3.client('ssm', region_name=region)
response = client.get_parameter(Name='/onyx/servicenow/default_assigned_to', WithDecryption=True)
default_assigned_to = response['Parameter']['Value']
return default_assigned_to

def lambda_handler(event, context):
print("EVENT:", event)
region = 'us-east-1'
action = event.get('action', 'create')

if action == 'create':
harness_execution_id = event.get("HarnessExecutionId", "N/A")
harness_build_id = event.get("BuildId", "N/A")
harness_triggered_by = event.get("TriggeredBy", "N/A")

if harness_triggered_by != "N/A" and harness_triggered_by != "$TRIGGERED_BY":
assigned_to = harness_triggered_by.split('-')[0].strip()
else:
assigned_to = get_default_assigned_to(region)

try:
create_response = createServiceNowStandardChange(assigned_to)
except Exception as e:
print(f"Error calling createServiceNowStandardChange: {e}")
return None

if create_response is None:
print("createServiceNowStandardChange returned None")
return None

if 'result' in create_response and 'respBody' in create_response['result']:
change_request = create_response['result']['respBody'].get('number', 'N/A')
sys_id = create_response['result']['respBody'].get('sys_id', 'N/A')
else:
print("Error: 'result' or 'respBody' key not found in the response")
return None

output = {
'harnessExecutionId': harness_execution_id,
'buildId': harness_build_id,
'outputVariables': {
'CHG_REQUEST_ID': change_request,
'CHG_REQUEST_SYS_ID': sys_id
}
}
print("Output:", output)
return output

elif action == 'update':
sys_id = event.get('CHANGE_REQUEST_SYS_ID')

if not sys_id:
return {
"statusCode": 400,
"body": "Missing Change Request sys_id (CHANGE_REQUEST_SYS_ID)"
}

current_state = int(event.get('current_state', -5))
closure_notes = event.get('closure_notes', 'Automatically moved to the next state.')

next_state = state_transition.get(current_state)

if not next_state:
return {
"statusCode": 200,
"body": f"Change Request {sys_id} is already in the 'Closed' state."
}

next_state = next_state["value"]
next_label = next_state["label"]

result = update_service_now_cr(sys_id, next_state, closure_notes)

if result:
return {
"statusCode": 200,
"body": json.dumps({
"message": f"ServiceNow CR {sys_id} updated from {current_state} to {next_label}",
"next_state": next_state
})
}
else:
return {
"statusCode": 500,
"body": json.dumps(f"Failed to update ServiceNow CR {sys_id} to {next_label}")
}