#!/usr/bin/env python

# Trigger a webhook event for Schutzbot using AWS SQS.

import json

import os

import boto3

from botocore import UNSIGNED

from botocore.client import Config

WEBHOOK_PAYLOAD = os.environ.get("WEBHOOK_PAYLOAD")

EVENT_NAME = os.environ.get("EVENT_NAME")

SQS_QUEUE_URL = os.environ.get("SQS_QUEUE_URL")

SQS_REGION = os.environ.get("SQS_REGION")

sqs = boto3.client(

    'sqs',

    region_name=SQS_REGION,

    config=Config(

        signature_version=UNSIGNED

    )

)

payload = json.loads(WEBHOOK_PAYLOAD)

message = {

    'headers': {'X-Github-Event': EVENT_NAME},

    'payload': payload

}

response = sqs.send_message(

    QueueUrl=SQS_QUEUE_URL,

    MessageBody=json.dumps(message)

)