Connecting to the Live Updates Gateway

import socketio
 
sio = socketio.Client()
sio.connect(
    "https://api.botsubscription.com",
    namespaces=["/v2/live-updates"],
    transports=["websocket", "polling"],
    auth={
        "token": "YOUR_USER_JWT",
        "project_id": "YOUR_PROJECT_UUID",
    },
)

<?php
require __DIR__ . '/vendor/autoload.php';
 
use ElephantIO\Client;
use ElephantIO\Engine\SocketIO\Version4X;
 
$client = new Client(new Version4X('https://api.botsubscription.com/v2/live-updates', [
    'transport' => 'websocket',
    'auth' => [
        'token'      => 'YOUR_USER_JWT',
        'project_id' => 'YOUR_PROJECT_UUID',
    ],
]));
 
$client->initialize();

package main
 
import "github.com/zishang520/socket.io-client-go/socket"
 
func main() {
    opts := socket.DefaultOptions()
    opts.SetTransports([]string{"websocket", "polling"})
    opts.SetAuth(map[string]any{
        "token":      "YOUR_USER_JWT",
        "project_id": "YOUR_PROJECT_UUID",
    })
 
    s := socket.NewManager("https://api.botsubscription.com", nil).
        Socket("/v2/live-updates", opts)
    s.Connect()
}

require "socketio-client-simple"
 
socket = SocketIO::Client::Simple.connect(
  "https://api.botsubscription.com/v2/live-updates",
  transport: %w[websocket polling],
  auth: {
    token: "YOUR_USER_JWT",
    project_id: "YOUR_PROJECT_UUID",
  }
)

import os
import socketio
 
NAMESPACE = "/v2/live-updates"
sio = socketio.Client()
 
 
@sio.on("message", namespace=NAMESPACE)
def on_message(data):
    if data.get("event") == "ready":
        print("connected", data.get("connection_id"), data.get("channels"))
        sio.send(
            {"action": "subscribe", "channel": "payment-methods"},
            namespace=NAMESPACE,
        )
 
 
@sio.on("session.revoked", namespace=NAMESPACE)
def on_session_revoked(_data=None):
    # clear stored token; do not auto-reconnect
    pass
 
 
@sio.on("payment-method.added", namespace=NAMESPACE)
def on_payment_method_added(frame):
    print("payment method added", frame["payment_method"])
 
 
sio.connect(
    "https://api.botsubscription.com",
    namespaces=[NAMESPACE],
    transports=["websocket", "polling"],
    auth={
        "token": os.environ["USER_JWT"],
        "project_id": os.environ["PROJECT_ID"],
    },
)
sio.wait()

<?php
require __DIR__ . '/vendor/autoload.php';
 
use ElephantIO\Client;
use ElephantIO\Engine\SocketIO\Version4X;
 
$client = new Client(new Version4X('https://api.botsubscription.com/v2/live-updates', [
    'transport' => 'websocket',
    'auth' => [
        'token'      => getenv('USER_JWT'),
        'project_id' => getenv('PROJECT_ID'),
    ],
]));
 
$client->initialize();
 
$client->emit('message', [
    'action' => 'subscribe',
    'channel' => 'payment-methods',
]);
 
while ($frame = $client->wait('payment-method.added')) {
    print_r($frame['payment_method']);
}
 
$client->close();

package main
 
import (
    "log"
    "os"
 
    "github.com/zishang520/socket.io-client-go/socket"
)
 
func main() {
    manager := socket.NewManager("https://api.botsubscription.com", nil)
    opts := socket.DefaultOptions()
    opts.SetTransports([]string{"websocket", "polling"})
    opts.SetAuth(map[string]any{
        "token":      os.Getenv("USER_JWT"),
        "project_id": os.Getenv("PROJECT_ID"),
    })
 
    s := manager.Socket("/v2/live-updates", opts)
 
    s.On("message", func(args ...any) {
        data := args[0].(map[string]any)
        if data["event"] == "ready" {
            log.Println("connected", data["connection_id"])
            s.Emit("message", map[string]any{
                "action":  "subscribe",
                "channel": "payment-methods",
            })
        }
    })
 
    s.On("payment-method.added", func(args ...any) {
        log.Printf("payment method added: %v\n", args[0])
    })
 
    s.Connect()
    select {} // keep the process alive
}

require "socketio-client-simple"
 
NAMESPACE = "/v2/live-updates"
 
socket = SocketIO::Client::Simple.connect(
  "https://api.botsubscription.com#{NAMESPACE}",
  transport: %w[websocket polling],
  auth: {
    token: ENV.fetch("USER_JWT"),
    project_id: ENV.fetch("PROJECT_ID"),
  }
)
 
socket.on :message do |data|
  if data["event"] == "ready"
    puts "connected #{data["connection_id"]}"
    socket.emit :message, { action: "subscribe", channel: "payment-methods" }
  end
end
 
socket.on :"payment-method.added" do |frame|
  puts "payment method added: #{frame["payment_method"].inspect}"
end
 
loop { sleep 1 }