def publish_to_websocket()

in functions/source/publish-call-metadata/lambda_function.py [0:0]

• 16 lines of code
• 3 McCabe index (conditional complexity)

def publish_to_websocket(transactionId,fromNumber,toNumber,streamingStatus,date_,entities):
    ''' 
        Publish transaction details and extraction results to websocket
    '''
    try:
        print("payload", json.dumps({"transactionId": transactionId, "fromNumber": fromNumber, "toNumber": toNumber, "streamingStatus": streamingStatus,"date_": date_,"customEntities": entities}))
        response = connections_table.scan()
        data_ = response['Items']
        for item in data_:
            wsclient = boto3.client('apigatewaymanagementapi',endpoint_url = os.environ['WEBSOCKET_URL'])
            response = wsclient.post_to_connection(
                Data=json.dumps({"transactionId": transactionId, "fromNumber": fromNumber, "toNumber": toNumber, "streamingStatus": streamingStatus,"date_": date_,"customEntities": entities}),
                ConnectionId=item['ConnectionId']
            )
            
    except Exception as e:
        print("Exception while sending to websocket",str(e))