Skip to content
This repository has been archived by the owner on Sep 2, 2021. It is now read-only.

Order Book API update #1

Merged
merged 3 commits into from Jul 13, 2021
Merged

Order Book API update #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
ee0df9c
The postMarketOrder function have been update with postProMarketOrder…
jelilat Jul 5, 2021
e2acbb0
Order Book API Update
jelilat Jul 6, 2021
8ac3a9e
Orderbook API Update (recurring-buy)
jelilat Jul 6, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
116 changes: 63 additions & 53 deletions modules/api.js
View file
Open in desktop
Expand Up @@ -50,76 +50,86 @@ module.exports = {
});
},

getMarketOrders: () => {
getMarketOrders: (pair) => {

const query = `
query getMarketBook($cryptocurrency: Cryptocurrency) {
getMarketBook(cryptocurrency: $cryptocurrency) {
import {Orderbook} from 'public-protos-js/proto/orderbook_socket/v1/orderbook_pb';

orders(first: 10) {

nodes {
id
coinAmount
pricePerCoin
side

}
}


}
}
`;

const variables = {
cryptocurrency: "bitcoin",
}

return graphQLClient
.request(query, variables)
.then((res) => {
const orders = res.getMarketBook.orders.nodes;
const sellOrders = orders.filter((o) => o.side === 'sell');
sellOrders.sort((a, b) => {
return parseFloat(a.pricePerCoin) - parseFloat(b.pricePerCoin);
});
return sellOrders;
})
.catch((error) => {
const message = error.response && error.response.errors && error.response.errors[0] && error.response.errors[0].message;
console.error(message);
return [];
try {
const baseUrl = `wss://markets.buycoins.tech/ws?pair=${pair}`;

const orderbookSocket = new WebSocket(baseUrl);
orderbookSocket.binaryType = 'arraybuffer';

window.orderbookSocket.addEventListener('open', () => {
console.log('Disconnected from orderbook WebSocket API');
});

window.orderbookSocket.addEventListener('close', () => {
console.log('Disconnected from orderbook WebSocket API. Reconnect will be attempted in 1 second.');
setTimeout(function() {
getMarketOrders(pair);
}, 1000);
});

window.orderbookSocket.addEventListener('message', ({ data }) => {
console.log('Order Book update received');
const market = Orderbook.deserializeBinary(data).toObject();
console.log(market);
});

// const variables = {
// pair: "BTC/USDT",
// }

const orders = market;
const sellOrders = orders.filter((o) => o.side === 'sell');
sellOrders.sort((a, b) => {
return parseFloat(a.pricePerCoin) - parseFloat(b.pricePerCoin);
});
return sellOrders;
} catch (error) {
const message = error.response && error.response.errors && error.response.errors[0] && error.response.errors[0].message;
console.error(message);
return [];
};

},

postMarketOrder: (coinAmount) => {
postProMarketOrder: (quantity) => {

const query = `
mutation postMarketOrder($cryptocurrency: Cryptocurrency, $orderSide: OrderSide!, $coinAmount: BigDecimal!) {
postMarketOrder(cryptocurrency: $cryptocurrency, orderSide: $orderSide, coinAmount: $coinAmount) {
mutation postProMarketOrder($pair: CryptocurrencyPair, $quantity: BigDecimal!, $side: OrderSide!) {
postProMarketOrder(pair: $pair, quantity: $quantity, side: $side){
id
createdAt
cryptocurrency
coinAmount
pricePerCoin
priceType
staticPrice
dynamicExchangeRate
pair
price
side
status
timeInForce
orderType
fees
filled
total
initialBaseQuantity
initialQuoteQuantity
remainingBaseQuantity
remainingQuoteQuantity
meanExecutionPrice
engineMessage
}
}
`;
`;

const variables = {
cryptocurrency: "bitcoin",
orderSide: "sell",
coinAmount,
pair: "btc_usdt",
side: "sell",
quantity,
};

return graphQLClient
.request(query, variables)
.then((res) => {
if (res.postMarketOrder) return res.postMarketOrder;
if (res.postProMarketOrder) return res.postProMarketOrder;
return Promise.reject();
})
.catch((error) => {
Expand Down
10 changes: 8 additions & 2 deletions modules/recurring-buy.js
View file
Open in desktop
Expand Up @@ -56,7 +56,13 @@ const checkIfShouldBuyToday = async (allowMultipeBuyOnDay) => {

const buyViaMarket = async () => {

const marketOrders = await api.getMarketOrders();
let currencyPair;

if (currencyPair == "") {
currencyPair = "BTC/USDT"
}

const marketOrders = await api.getMarketOrders(currencyPair);

if (marketOrders.length === 0) return {
error: "no_market_orders"
Expand Down Expand Up @@ -86,7 +92,7 @@ const buyViaMarket = async () => {
}

try {
const marketOrder = await api.postMarketOrder(amountToBuy);
const marketOrder = await api.postProMarketOrder(amountToBuy);
return {
purchase_method: "market",
purchase_amount: marketOrder.coinAmount,
Expand Down