import json
import logging

from internal.helpers import rds_query

log = logging.getLogger()
log.setLevel(logging.INFO)


def lambda_handler(event, context):
    log.info(f"{event}")

    if 'httpMethod' in event and event['httpMethod'] == 'POST' and \
            'requestContext' in event and 'path' in event['requestContext'] and \
            event['requestContext']['path'] == '/pre-sign':
        try:
            body = json.loads(event['body'])
            if 'data' in body and 'referrer' in body['data'] and \
                    body['data']['referrer'].startswith('https://fansifter.com/signup'):
                rds_query("INSERT INTO commons.raw_pre_signup (data) VALUES (%(body_data)s)",
                          {'body_data': json.dumps(body['data'])})
        except Exception as e:
            log.exception("Weird parameters?!", exc_info=e)

    return {
        'statusCode': 200,
        'body': 'OK'
    }