81 lines
1.8 KiB
TypeScript
81 lines
1.8 KiB
TypeScript
|
import { parseResolution, getNextBarTime } from './helpers'
|
||
|
|
|
||
|
|
let subscriptionItem: any = {}
|
||
|
|
|
||
|
|
// Create WebSocket connection.
|
||
|
|
const socket = new WebSocket(`wss://api.mngo.cloud/fills/v1/`)
|
||
|
|
|
||
|
|
// Connection opened
|
||
|
|
socket.addEventListener('open', (_event) => {
|
||
|
|
console.log('[socket] Connected')
|
||
|
|
})
|
||
|
|
|
||
|
|
// Listen for messages
|
||
|
|
socket.addEventListener('message', (msg) => {
|
||
|
|
const data = JSON.parse(msg.data)
|
||
|
|
|
||
|
|
if (!data.event) return console.warn(data)
|
||
|
|
if (data.event.maker) return
|
||
|
|
|
||
|
|
const currTime = new Date(data.event.timestamp).getTime()
|
||
|
|
const lastBar = subscriptionItem.lastBar
|
||
|
|
const resolution = subscriptionItem.resolution
|
||
|
|
const nextBarTime = getNextBarTime(lastBar, resolution)
|
||
|
|
const price = data.event.price
|
||
|
|
const size = data.event.quantity
|
||
|
|
let bar
|
||
|
|
|
||
|
|
if (currTime >= nextBarTime) {
|
||
|
|
bar = {
|
||
|
|
time: nextBarTime,
|
||
|
|
open: price,
|
||
|
|
high: price,
|
||
|
|
low: price,
|
||
|
|
close: price,
|
||
|
|
volume: size,
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
bar = {
|
||
|
|
...lastBar,
|
||
|
|
high: Math.max(lastBar.high, price),
|
||
|
|
low: Math.min(lastBar.low, price),
|
||
|
|
close: price,
|
||
|
|
volume: lastBar.volume + size,
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
subscriptionItem.lastBar = bar
|
||
|
|
subscriptionItem.callback(bar)
|
||
|
|
})
|
||
|
|
|
||
|
|
export function subscribeOnStream(
|
||
|
|
symbolInfo: any,
|
||
|
|
resolution: any,
|
||
|
|
onRealtimeCallback: any,
|
||
|
|
subscriberUID: any,
|
||
|
|
onResetCacheNeededCallback: any,
|
||
|
|
lastBar: any
|
||
|
|
) {
|
||
|
|
subscriptionItem = {
|
||
|
|
resolution,
|
||
|
|
lastBar,
|
||
|
|
callback: onRealtimeCallback,
|
||
|
|
}
|
||
|
|
|
||
|
|
const msg = {
|
||
|
|
command: 'subscribe',
|
||
|
|
marketId: 'HwhVGkfsSQ9JSQeQYu2CbkRCLvsh3qRZxG6m4oMVwZpN',
|
||
|
|
}
|
||
|
|
|
||
|
|
socket.send(JSON.stringify(msg))
|
||
|
|
}
|
||
|
|
|
||
|
|
export function unsubscribeFromStream() {
|
||
|
|
const msg = {
|
||
|
|
command: 'unsubscribe',
|
||
|
|
marketId: 'HwhVGkfsSQ9JSQeQYu2CbkRCLvsh3qRZxG6m4oMVwZpN',
|
||
|
|
}
|
||
|
|
|
||
|
|
socket.send(JSON.stringify(msg))
|
||
|
|
}
|