artin/osapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added catchup for transactions

Browse Source
This commit is contained in:
artin 2023-07-17 16:36:55 +00:00
parent 605f998815
commit 35837d8f03
1 changed files with 49 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
index.js
View File

@ -45,6 +45,39 @@ const accounts = {
}
}
async function getTransactionsAll(account,acct_id, api_key) {
for (const rg of [...Array(32).keys()]) {
try {
f = rg * 1000 + 1;
to = f + 1000;
const response = await axios.request({
url: `${APIURL}/accounts/${acct_id}/transactions/idrange?from=${f}&to=${to}`,
method: 'get',
headers: {
'Authorization': `Bearer ${api_key}`
}
});
for (const t of response.data.transactions){
qty = 0;
tp = "";
if(typeof(t['instrument']) !== undefined){
tp = t['instrument']
}
if(typeof(t['units']) !== undefined){
qty = t['units']
}
await client.query(`insert into orders (order_id, account_id, tpair, order_type, order_ref, order_reason, order_date, order_data, quantity) values ($1,$2,$3,$4,$5,$6,$7,$8,$9)`, [t.id, account, tp, t.type, t.batchID, t.reason, t.time, t, qty]);
}
} catch (error) {
console.error(error);
}
}
}
async function getTransactions(account,acct_id, api_key) {
// for (const rg of [...Array(32).keys()]) {
try {
@ -337,6 +370,18 @@ console.log(error)
})
app.get('/transactionsAll/:account', async (req, res) => {
let r = {}
let response = await getTransactions(account,accounts[account]['ACCT'], accounts[account]['APIKEY'])
try {
r = {};
} catch(error) {
console.log(error)
}
res.header('Access-Control-Allow-Origin', '*')
res.json("ok")
})
app.get('/transactions', async (req, res) => {
let r = {}
@ -351,6 +396,7 @@ console.log(error)
res.header('Access-Control-Allow-Origin', '*')
res.json("ok")
})
app.get('/trades', async (req, res) => {
let r = {}
@ -365,6 +411,7 @@ console.log(error)
res.header('Access-Control-Allow-Origin', '*')
res.json(r)
})
app.get('/accounts/del/:user_id/:account_id', async(req,res) => {
await client.query(`delete from accounts where user_id = ${req.params.user_id} and id = ${req.params.account_id}`);
res.header('Access-Control-Allow-Origin', '*');
@ -424,7 +471,9 @@ app.get('/order/:instrument/:quantity', async (req, res) => {
} */
for (account of Object.keys(accounts)) {
td = await getTradesByInstrument(accounts[account]['ACCT'], accounts[account]['APIKEY'], req.params.instrument);
if (td['state'] != "OPEN" || td['state'] != "PENDING") {
response = await order(accounts[account]['ACCT'], accounts[account]['APIKEY'], req.params.instrument, req.params.quantity);
}
}