// go get github.com/gorilla/websocket
// Connect
c, _, err := websocket.DefaultDialer.Dial("wss://api.solanastreaming.com/", http.Header{"X-Api-Key": []string{"923aeea0ac3549a80dcd9f881986eaf7"}})
if err != nil {
    log.Fatal("dial:", err)
}
defer c.Close()

// Start the pair / price stream
err = c.WriteMessage(websocket.TextMessage, []byte(`{"id":1,"method":"newPairSubscribe"}`))
if err != nil {
    log.Fatal("write:", err)
}

for {
    // Continuously read pairs / prices
    _, message, err := c.ReadMessage()
    if err != nil {
        log.Fatal("read:", err)
    }
    log.Printf("recv: %s\n", message)
}

// npm install ws
const WebSocket = require('ws');

(async function () {
    // Connect
    const ws = new WebSocket('wss://api.solanastreaming.com/', undefined,
        {
            headers: {
                'X-API-KEY': '923aeea0ac3549a80dcd9f881986eaf7'
            }
        }
    );
    ws.on('error', console.error);
    ws.on('open', () => {
        // Start the pair / price stream
        ws.send('{"id":1,"method":"newPairSubscribe"}');
    });
    ws.on('message', (data) => {
        // Continuously read pairs / prices
        console.log('received: %s', data);
    });
})();

// composer require textalk/websocket
$client = new \WebSocket\Client("wss://api.solanastreaming.com/", ['headers' => ['X-Api-Key'=>'923aeea0ac3549a80dcd9f881986eaf7'], 'timeout' => -1]);
$client->text('{"id":1,"method":"newPairSubscribe"}');

while(true){
    $message =  $client->receive();
    echo "Received: ", $message, "\n";
}