> uploadtext_

// client.js
const socketUrl = 'ws://localhost:8080/realtime-feed'; // Replace with your WebSocket API URL
let socket;
let reconnectInterval;

function connectWebSocket() {
    console.log('Attempting to connect to WebSocket...');
    socket = new WebSocket(socketUrl);

    socket.onopen = (event) => {
        console.log('WebSocket connection opened:', event);
        // Clear any existing reconnect interval
        if (reconnectInterval) {
            clearInterval(reconnectInterval);
            reconnectInterval = null;
        }
        // Send a message to the server, e.g., to subscribe to a topic
        socket.send(JSON.stringify({ type: 'subscribe', topic: 'news_feed' }));
    };

    socket.onmessage = (event) => {
        console.log('Message from server:', event.data);
        try {
            const data = JSON.parse(event.data);
            // Handle different types of messages
            if (data.type === 'news_update') {
                console.log('New news update:', data.payload.title);
                // Update UI with new data
            } else if (data.type === 'chat_message') {
                console.log('New chat message:', data.payload.message);
            }
        } catch (e) {
            console.error('Failed to parse WebSocket message:', e, event.data);
        }
    };

    socket.onclose = (event) => {
        console.log('WebSocket connection closed:', event);
        // Attempt to reconnect after a delay if the close was not clean (e.g., error or unexpected)
        if (!event.wasClean) {
            console.log('WebSocket connection was not clean. Reconnecting in 5 seconds...');
            if (!reconnectInterval) { // Prevent multiple reconnect intervals
                reconnectInterval = setInterval(connectWebSocket, 5000); // Reconnect every 5 seconds
            }
        }
    };

    socket.onerror = (error) => {
        console.error('WebSocket error:', error);
        // The onerror event is often followed by onclose
        socket.close(); // Ensure socket is closed
    };
}

// Initialize connection
connectWebSocket();

// Example of sending data from client to server
function sendChatMessage(message) {
    if (socket && socket.readyState === WebSocket.OPEN) {
        socket.send(JSON.stringify({ type: 'chat', message: message }));
    } else {
        console.warn('WebSocket is not open. Cannot send message.');
    }
}

// You can call sendChatMessage() later, e.g., on a button click
// setTimeout(() => sendChatMessage('Hello from client!'), 3000);

// To close the connection explicitly
// function disconnectWebSocket() {
//     if (socket && socket.readyState === WebSocket.OPEN) {
//         socket.close(1000, 'Client initiated disconnect');
//     }
//     if (reconnectInterval) {
//         clearInterval(reconnectInterval);
//         reconnectInterval = null;
//     }
// }