TCP клиент asycnio

import asyncio
import socket
import json
 
host = '192.168.1.2'
port = 6666
loop = asyncio.get_event_loop()
connection = socket.create_connection((host, port))
 
async def handler(conn):
    while True:
        msg = await loop.sock_recv(conn, 1024)
        print(msg)
        if "command_1" in msg.decode():
            command_1(msg)
        elif "command_2" in msg.decode():
            command_1(msg)
        if not msg:
            break
        
 
def command_1(self, message):
        response = json.loads(message)
        test = {"status":"ok"}
        data_for_send = json.dumps(test, ensure_asii=False).encode()
        #здесь был кусок который ставил в начало размер послыки  
        #отправляю в сокет
        connection.sendall(data_for_send)
    
def command_2(self, message):
        response = json.loads(message)
        test = {"status":"bad"}
        data_for_send = json.dumps(test, ensure_asii=False).encode()
        #здесь был кусок который ставил в начало размер послыки  
        #отправляю в сокет
        connection.sendall(data_for_send)
 
 
loop.create_task(handler(connection))
loop.run_forever()
loop.close()

import asyncio
import json
 
class ClientProtocol(asyncio.Protocol):
    def __init__(self, loop):
        self.loop = loop
 
    def connection_made(self, transport):
        self.transport = transport
 
    def data_received(self, data):
        len_message = int.from_bytes(data[0:3], byteorder="little")
        message = data[4:len_message]
        decoded_msg = message.decode()
        print(decoded_msg)
        if "command_1" in decoded_msg:
            self.command_1(decoded_msg)
        elif "command_2" in decoded_msg:
            self.command_2()
 
    def connection_lost(self, exc):
        print('The server closed the connection')
        print('Stop the event loop')
        self.loop.stop()
 
    def command_1(self, message):
        response = json.loads(message)
        test = {"status":"ok"}
        data_for_send = json.dumps(test, ensure_asii=False).encode()
        #здесь был кусок который ставил в начало размер послыки  
        #отправляю в сокет
        self.transport.write(data_for_send)
 
    def command_2(self, message):
        response = json.loads(message)
        test = {"status":"bad"}
        data_for_send = json.dumps(test, ensure_asii=False).encode()
        #здесь был кусок который ставил в начало размер послыки  
        #отправляю в сокет
        self.transport.write(data_for_send)
 
 
 
loop = asyncio.get_event_loop()
 
coro = loop.create_connection(lambda: ClientProtocol(loop),
                            '192.168.1.2', 6666)
loop.run_until_complete(coro)
loop.run_forever()
loop.close()

    def data_received(self, data):
        self.buffer += data
        len_msg = self._byte_to_len(self.buffer[:4])
        try:
            json_msg = json.loads(self.buffer[4:len_msg+4])
            self._process_command(json_msg)
            self.buffer = self.buffer[len_msg+4:]
        except:
            pass