# # import datetime
# #
# #
# # print(datetime.datetime.now())
# import json
#
# import yaml
#
# from utils import ConfigUtils
#
# with open('config/application.yaml', 'r') as f:
#     yaml_data = yaml.safe_load(f)
#     data = json.dumps(yaml_data)
#     print(data)
#     print(yaml_data['redis']) # {'username': None, 'password': None, 'port': 6379, 'host': 'localhost'}
# r = ConfigUtils.get_redis_config()
# print(r)

import socket
from threading import Thread
from time import sleep

import socket
#
#
# from utils import ScanPortsUtils
# ScanPortsUtils.start("192.168.188.149")


import asyncio
import websockets


async def echo(websocket, path):
    async for message in websocket:
        await websocket.send(message)
        print(message)


start_server = websockets.serve(echo, "localhost", 8765)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()