import json
import requests


# Slack webhook URL
webhook_url = (
    "https://hooks.slack.com/services/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"
)


def handler(event, context):
    for record in event["Records"]:
        sns_message = json.loads(record["Sns"]["Message"])
        jobName = sns_message["detail"]["jobName"]
        severity = sns_message["detail"]["severity"]
        # Message payload
        payload = {"text": jobName + " failed."}

        # Send the POST request
        response = requests.post(webhook_url, json=payload)

        # Check the response
        if response.status_code == 200:
            print("Message sent successfully!")
        else:
            print(f"Failed to send message: {response.status_code}, {response.text}")

    return {
        "statusCode": 200,
        "body": json.dumps("SNS message processed successfully!"),
    }