order status subscriptions

This commit is contained in:
Tim Olson
2023-11-06 23:49:08 -04:00
parent bec1b33d22
commit 754fd38301
6 changed files with 73 additions and 6 deletions

View File

@@ -24,8 +24,10 @@ socket.on('welcome', async (data) => {
onChainChanged(network.chainId)
})
socket.on('p', async (pool, price) => {
socket.on('p', async (chainId, pool, price) => {
const s = useStore()
if( s.chainId !== chainId )
return
const prices = {}
prices[pool] = price
console.log('pool price', pool, price)
@@ -34,8 +36,10 @@ socket.on('p', async (pool, price) => {
s.poolPrices = poolPrices
})
socket.on('vb', async (vault, balances) => {
socket.on('vb', async (chainId, vault, balances) => {
const s = useStore()
if( s.chainId !== chainId )
return
console.log('vb', vault, balances)
const vb = {}
vb[vault] = JSON.parse(balances)
@@ -43,8 +47,10 @@ socket.on('vb', async (vault, balances) => {
console.log('vault balances', vault, vb)
})
socket.on('vaults', (vaults)=>{
socket.on('vaults', (chainId, owner, vaults)=>{
const s = useStore()
if( s.chainId !== chainId || s.account !== owner )
return
console.log('vaults', vaults)
s.vaults = vaults
if( vaults.length ) {
@@ -52,3 +58,17 @@ socket.on('vaults', (vaults)=>{
flushOrders(vault)
}
})
socket.on( 'o', (chainId, vault, orderIndex, status)=>{
const s = useStore()
if( s.chainId !== chainId )
return
console.log('o', chainId, vault, orderIndex, status)
})
socket.on( 'of', (chainId, vault, orderIndex, fills)=>{
const s = useStore()
if( s.chainId !== chainId )
return
console.log('of', chainId, vault, orderIndex, fills)
})