__init__.py

import argparse
import asyncio
import websockets
import pyperclip


async def send_clipboard_data(websocket, poll_interval):
    last_clipboard_contents = ""
    last_error = ""
    # last_send_status = True
    print(f"Connected...")
    while True:
        clipboard_contents = pyperclip.paste()
        if clipboard_contents != last_clipboard_contents:
            print(clipboard_contents)
            try:
                await websocket.send(clipboard_contents)
            except Exception as exception:
                if str(exception) != last_error:
                    print(exception)
                last_error = str(exception)
            last_clipboard_contents = clipboard_contents

        await asyncio.sleep(poll_interval)


async def ws_handler(websocket, path):
    await send_clipboard_data(websocket, args.poll_interval)


if __name__ == "__main__":
    parser = argparse.ArgumentParser(
        description="Expose clipboard data to a WebSocket server."
    )
    parser.add_argument(
        "--host",
        type=str,
        default="localhost",
        help="WebSocket server host (default: localhost)",
    )
    parser.add_argument(
        "--port", type=int, default=6678, help="WebSocket server port (default: 6678)"
    )
    parser.add_argument(
        "--poll-interval",
        type=float,
        default=0.1,
        help="Poll interval for clipboard data (default: 0.1)",
    )
    args = parser.parse_args()

    websocket_path = f"{args.host}:{args.port}"
    start_server = websockets.serve(ws_handler, args.host, args.port)
    print(f"Starting {'ws://' + websocket_path}")
    asyncio.get_event_loop().run_until_complete(start_server)
    try:
        asyncio.get_event_loop().run_forever()
    except KeyboardInterrupt:
        print('Closed Manually')