Websocket

New Listings Feed WebSocket

A membership key is required to access the endpoints. Get one at t.me/NLF_websocket_bot

Streaming endpoints

Some announcements will come faster through different endpoints. We recommend you to connect to both locations and parse whatever comes first, or review the timings and choose what to execute on.

Listings

Tokyo

wss://tokyo.newlistings.pro/v1/new-listings
wss://tokyo.newlistings.pro/v1/delistings

New York

wss://ny.newlistings.pro/v1/new-listings
wss://ny.newlistings.pro/v1/delistings

Frankfurt

wss://newlistings.pro/v1/new-listings
wss://newlistings.pro/v1/delistings

Announcements feed

wss://newlistings.pro/v1/announcements

Setting up a WebSocket connection

const WebSocket = require('ws');
let pingInterval;

const connectWebSocket = () => {
  const ws = new WebSocket('wss://newlistings.pro/v1/new-listings', {
    headers: { 'authorization': 'Bearer your-api-key' } // ← put your key here
  });

  ws.on('open', () => {
    console.log('WebSocket Open');
    clearInterval(pingInterval);
    pingInterval = setInterval(() => { if (ws.readyState === WebSocket.OPEN) ws.ping() }, 30000);
  });

  ws.on('message', (data) => {
    try { console.log(JSON.parse(data)); } catch(e) { console.error('Parse Error:', e); }
  });

  ws.on('close', () => {
    console.log('WebSocket Closed, reconnecting in 1s...');
    clearInterval(pingInterval);
    setTimeout(connectWebSocket, 1000);
  });

  ws.on('error', (err) => {
    console.error('WebSocket Error:', err.message);
    clearInterval(pingInterval);
  });
};

connectWebSocket();

# pip install websocket-client
import json, time, websocket
from datetime import datetime

URL  = "wss://newlistings.pro/v1/new-listings"
HEAD = ["authorization: Bearer your-api-key"] # ← put your key here

def on_msg(ws, message):
    timestamp = datetime.now().strftime('%H:%M:%S.%f')[:-3]
    print(f"[{timestamp}] {message}")
    
    try:
        data = json.loads(message)
        print(f"[{timestamp}] {json.dumps(data, indent=2)}")
    except json.JSONDecodeError:
        print(f"[{timestamp}] {message}")
    
    print("-" * 80)

def on_err(ws, error):   
    print(f"\n[{datetime.now().strftime('%H:%M:%S')}] Error: {error}")

def on_close(ws, close_status_code, close_msg): 
    if close_status_code:
        print(f"  Status code: {close_status_code}")
    if close_msg:
        print(f"  Message: {close_msg}")
    print("Reconnecting in 1 second...")
    time.sleep(1)
    connect()

def connect():
    print(f"[{datetime.now().strftime('%H:%M:%S')}] Connecting to {URL}")
    websocket.WebSocketApp(
        URL, header=HEAD,
        on_message=on_msg,
        on_error=on_err, on_close=on_close
    ).run_forever(ping_interval=30, ping_timeout=10)

connect()

Historical data

Get historical data using an authenticated GET request to endpoint example:

curl -H "authorization: Bearer your-api-key" https://newlistings.pro/v1/new-listings

Frankfurt

https://newlistings.pro/v1/new-listings
https://newlistings.pro/v1/delistings

Tokyo

https://tokyo.newlistings.pro/v1/new-listings
https://tokyo.newlistings.pro/v1/delistings

New York

https://ny.newlistings.pro/v1/new-listings
https://ny.newlistings.pro/v1/delistings

Example outputs

{
  "id": 1739462417129,
  "time": 1761719456916,
  "time_iso": "2025-10-29T06:30:56.916Z"
  "announcement": "$TRUST listed on Upbit spot (KRW)",
  "original_title": "인튜이션(TRUST) 신규 거래지원 안내 (KRW, BTC, USDT 마켓)",
  "url": "https://upbit.com/service_center/notice?id=5727",
  "exchange": "upbit",
  "type": "spot",
  "detections": [
    {
      "ticker": "TRUST"
    }
  ],
  "delay":"0ms"
}

{
  "id": 1739462417129,
  "time": 1761719456916,
  "time_iso": "2025-10-29T06:30:56.916Z"
  "announcement": "$ASTER live on Binance alpha",
  "original_title": "",
  "url": "https://www.binance.com/en/binancewallet/0x000ae314e2a2172a039b26378814c252734f556a",
  "detections": [
    {
      "ticker": "ASTER",
      "projectName": "Aster",
      "onchain": {
        "contract": "0x000ae314e2a2172a039b26378814c252734f556a",
        "chain": "bsc"
      }
    }
  ],
  "exchange": "binance",
  "type": "alpha",
  "delay":"0ms"
}

{
  "id": 1765546215726,
  "exchange": "kucoin",
  "announcement": "Funding Rate Settlement Frequency of Multiple USDⓈ-M Perpetual Contracts Will Be Resumed (12-12)",
  "url": "https://www.kucoin.com/announcement/en-funding-rate-settlement-frequency-of-multiple-usd-m-perpetual-contracts-will-be-resumed-12-12?lang=en_US",
  "published_at": "2025-12-12T13:30:15.353Z",
  "delay": "0ms"
}

Listings fields

binance
okx
lighter
hyperliquid
bybit
coinbase
coinbaseinternational
robinhood
bithumb
upbit

Delistings fields

coinbase
okx
bybit
binance
bithumb

Announcements fields

binance
bybit
okx
upbit
bithumb
hyperliquid
coinbase
robinhood
bitget
bitmart
mexc
gate
htx
kucoin
kraken
gemini
coinlist
bullish
coinone
korbit
crypto.com
bingx
coinex
asterdex

Additional information

Unable to connect?

If you repeatedly attempt to connect with invalid credentials (e.g. wrong token, expired subscription, or exceeding the IP limit), your IP may be temporarily blocked.

This block is automatic and short-term. Simply wait about an hour before trying again with valid credentials.

Useful links

Bybit API docs: https://bybit-exchange.github.io/docs/
Binance API docs: https://www.binance.com/binance-api
Official Binance API Telegram support: https://t.me/binance_api_english

Last updated 2 days ago