crewai - 💡(How to fix) Fix [FEATURE] End to end server and client example code for a2a protocall. [3 comments, 2 participants]

import socket

def start_host_agent():
    host = '127.0.0.1'
    port = 12345

    # Create a socket object
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

    # Bind the socket to the host and port
    server_socket.bind((host, port))

    # Listen for incoming connections
    server_socket.listen(5)
    print(f"Host agent listening on {host}:{port}")

    while True:
        # Accept incoming connections
        client_socket, address = server_socket.accept()
        print(f"Connection from {address} established")

        # Handle incoming requests
        request = client_socket.recv(1024)
        print(f"Received request: {request}")

        # Send response back to the client
        response = b"Request received"
        client_socket.send(response)
        client_socket.close()

start_host_agent()

import socket

def start_agent_card():
    host = '127.0.0.1'
    port = 12345

    # Create a socket object
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

    # Connect to the host agent
    client_socket.connect((host, port))

    # Send a request to the host agent
    request = b"Hello from agent card"
    client_socket.send(request)

    # Receive response from the host agent
    response = client_socket.recv(1024)
    print(f"Received response: {response}")

    client_socket.close()

start_agent_card()

import socket

def update_status(client_socket, status):
    # Send the updated status to the client
    client_socket.send(f"Status updated: {status}".encode())

# Example usage:
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect((host, port))
update_status(client_socket, "online")