def lambdaHandler()

in backend/lambda/websocket-service/lambda.py [0:0]


def lambdaHandler(event, context):
    print("Received event: " + json.dumps(event, indent=2))
    try:
        response = {}
        if event['requestContext']['eventType'] == 'CONNECT':
            connectionId = event['requestContext']['connectionId']
            channelArn = event['queryStringParameters']['channelarn']
            response=connectionTable.put_item(
                Item={
                    'Id': connectionId,
                    'ChannelArn': channelArn,
                }
            )
        elif event['requestContext']['eventType'] == 'DISCONNECT': 
            response = connectionTable.delete_item(
                Key={'Id': event['requestContext']['connectionId']}
            )
        print(response)
    except Exception as e:
        print(e)
        return { 'statusCode': '500' }
        
    return { 'statusCode': '200' }