def greengrass_socket_server_run()

in functions/SocketServerPython/SocketServerPython.py [0:0]

• 17 lines of code
• 4 McCabe index (conditional complexity)

def greengrass_socket_server_run():
    global PORT

    logger.info('Starting socket server')

    HOST = ''

    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind((HOST, PORT))
    s.listen(1)

    while True:
        conn, addr = s.accept()
        logger.info('Connected by ' + str(addr))
        data = b''

        while 1:
            temp = conn.recv(1024)
            if not temp: break
            data += temp

        conn.close()

        client.publish(topic=output_topic, payload=data)