gistfile1.txt

import WebSocket from 'ws'

const APIKEY = 'myapiKeyIsHere'

// Connection Type:
const ws = new WebSocket('wss://delayed.polygon.io/stocks') // stocks 15-min delay

// Connection Opened:
ws.on('open', () => {
  console.log('Connected!')
  ws.send(`{"action":"auth","params":"${APIKEY}"}`)

  ws.send(`{"action":"subscribe","params":"AM.*"}`) // min

})

// Per message packet:
ws.on('message', (data) => {
  data = JSON.parse(data)
  data.map((msg) => {
    if (msg.ev === 'status') {
      return console.log('Status Update:', msg.message)
    }
    console.log(msg)
  })
})

ws.on('error', console.log)