blockworks-foundation
/
mango-feeds
mirror of https://github.com/blockworks-foundation/mango-feeds.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

v0.1.7

This commit is contained in:
Riordan Panayides 2023-06-23 15:30:59 +01:00
parent 13c2636e00
commit 61dfa18277
2 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

@ -1,6 +1,6 @@
{
"name": "@blockworks-foundation/mango-feeds",
"version": "0.1.6",
"version": "0.1.7",
"description": "Typescript Client for mango-feeds.",
"repository": "https://github.com/blockworks-foundation/mango-feeds",
"author": {

24
ts/client/src/orderbook.ts
View File

@ -61,15 +61,29 @@ interface OrderbookL3Checkpoint {
}
function isOrderbookL2Checkpoint(obj: any): obj is OrderbookL2Checkpoint {
return obj.bids !== undefined && obj.asks !== undefined && obj.bids.every((bid: any) => bid.length() == 2) && obj.asks.every((ask: any) => ask.length() == 2);
return (
obj.bids !== undefined &&
obj.asks !== undefined &&
obj.bids.every((bid: any) => bid.length() == 2) &&
obj.asks.every((ask: any) => ask.length() == 2)
);
}
function isOrderbookL3Checkpoint(obj: any): obj is OrderbookL3Checkpoint {
return obj.bids !== undefined && obj.asks !== undefined && obj.bids.every((order: any) => isOrder(order)) && obj.asks.every((order: any) => isOrder(order));
return (
obj.bids !== undefined &&
obj.asks !== undefined &&
obj.bids.every((order: any) => isOrder(order)) &&
obj.asks.every((order: any) => isOrder(order))
);
}
function isOrder(obj: any): obj is Order {
return obj.price !== undefined && obj.quantity !== undefined && obj.ownerPubkey !== undefined;
return (
obj.price !== undefined &&
obj.quantity !== undefined &&
obj.ownerPubkey !== undefined
);
}
export class OrderbookFeed extends ReconnectingWebsocketFeed {
@ -79,7 +93,7 @@ export class OrderbookFeed extends ReconnectingWebsocketFeed {
private _onL3Update: ((update: OrderbookL3Update) => void) | null = null;
private _onL2Checkpoint: ((update: OrderbookL2Checkpoint) => void) | null =
null;
private _onL3Checkpoint: ((update: OrderbookL3Checkpoint) => void) | null =
private _onL3Checkpoint: ((update: OrderbookL3Checkpoint) => void) | null =
null;
constructor(url: string, options?: OrderbookFeedOptions) {
@ -93,7 +107,7 @@ export class OrderbookFeed extends ReconnectingWebsocketFeed {
this.onMessage((data) => {
if (isOrderbookL2Update(data) && this._onL2Update) {
this._onL2Update(data);
} else if (isOrderbookL3Update(data) && this._onL3Update) {
} else if (isOrderbookL3Update(data) && this._onL3Update) {
this._onL3Update(data);
} else if (isOrderbookL2Checkpoint(data) && this._onL2Checkpoint) {
this._onL2Checkpoint(data);