{"id":326468,"date":"2021-07-15T09:00:15","date_gmt":"2021-07-15T09:00:15","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=326468"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=326468","title":{"rendered":"\u041a\u0430\u043a \u043d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043f\u0430\u0441\u0441\u0438\u0432\u043d\u044b\u0439 \u0434\u043e\u0445\u043e\u0434: \u041f\u0438\u0448\u0435\u043c \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u0433\u043e \u0442\u0440\u0435\u0439\u0434 \u0431\u043e\u0442\u0430 \u043d\u0430 JS (\u0447\u0430\u0441\u0442\u044c 2)"},"content":{"rendered":"\n
\n

\u042d\u0442\u0430 \u0441\u0442\u0430\u0442\u044c\u044f \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u0438\u043c \u043f\u0440\u043e\u0434\u043e\u043b\u0436\u0435\u043d\u0438\u0435\u043c \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u0439. \u041a\u0442\u043e \u043d\u0435 \u0447\u0438\u0442\u0430\u043b — \u043f\u0440\u043e\u0448\u0443 \u043e\u0437\u043d\u0430\u043a\u043e\u043c\u0438\u0442\u044c\u0441\u044f \u0442\u0443\u0442<\/a>.<\/p>\n

\u0418\u0442\u0430\u043a \u043f\u0440\u043e\u0434\u043e\u043b\u0436\u0438\u043c. \u0411\u044b\u0441\u0442\u0440\u0435\u043d\u044c\u043a\u043e \u0434\u043e\u043f\u0438\u0448\u0435\u043c \u0435\u0449\u0435 \u043f\u0430\u0440\u0443 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0445 \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u0432 \u0438 \u043f\u0435\u0440\u0435\u0439\u0434\u0435\u043c \u043a \u0431\u0430\u0437\u043e\u0432\u043e\u0439 \u0441\u0442\u0440\u0430\u0442\u0435\u0433\u0438\u0438.<\/p>\n

\u0427\u0442\u043e\u0431\u044b \u0437\u0430\u043f\u0440\u043e\u0441\u044b \u043a \u0431\u0438\u0440\u0436\u0435 \u043d\u0435 \u043f\u0440\u0435\u0432\u044b\u0448\u0430\u043b\u0438 \u0434\u043e\u043f\u0443\u0441\u0442\u0438\u043c\u044b\u0445 \u043b\u0438\u043c\u0438\u0442\u043e\u0432 \u0432 \u0441\u0435\u043a\u0443\u043d\u0434\u0443 — \u0434\u043e\u0431\u0430\u0432\u0438\u043c \u0441\u0435\u0440\u0432\u0438\u0441 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0439 \u043e\u0447\u0435\u0440\u0435\u0434\u0438. <\/p>\n

const MAX_QUERY_PER_SECOND = 4;  class ApiQueueService {   constructor() {     this.queue = [];     this.executeHistory = [];     this.isRun = false;   }    executeInQueue(method, ...data) {     return new Promise((resolve, reject) => {       this.addToQueue(method, data, ({ err, data }) => {         if (err) {           return reject(err);         }         return resolve(data);       });     });   }    addToQueue(method, data, cb) {     this.queue.push({ method, data, cb });     this.run();   }    run(force = false) {     if (this.isRun && !force) {       return;     }     this.isRun = true;     if (this.isBusy()) {       const timer = setTimeout(() => {         clearTimeout(timer);         this.run(true);       }, 100);       return;     }     const q = this.getFirst();     if (!q) {       this.isRun = false;       return;     }     this.execute(q).finally(() => {       this.removeFirst();       if (this.queue.length === 0) {         this.isRun = false;         return;       }       this.run(true);     });   }    getFirst() {     return this.queue && this.queue[0];   }    removeFirst() {     this.queue.splice(0, 1);   }    isBusy() {     return this.getCountQueryInLastSecond() >= MAX_QUERY_PER_SECOND;   }    getCountQueryInLastSecond() {     const currentTime = +new Date();     this.executeHistory = this.executeHistory.filter((d) => d.time > (currentTime - 1000));     return this.executeHistory.length;   }    execute(q) {     this.executeHistory.push({ time: +new Date() });     return q.method(...(q.data || [])).then((data) => {       q.cb({ data });     }).catch((err) => {       q.cb({ err });     });    } } module.exports = new ApiQueueService();<\/code><\/pre>\n
\u0414\u0435\u043b\u0430\u0435\u043c \u0438\u0437 \u043d\u0435\u0433\u043e \u0441\u0438\u043d\u0433\u043b\u0442\u043e\u043d \u043f\u0440\u0438 \u043f\u043e\u043c\u043e\u0449\u0438 module.exports = new ApiQueueService();<\/code> \u0438 \u0437\u0430\u043f\u0443\u0441\u0442\u0438\u043c \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u0439 \u0442\u0435\u0441\u0442 \u043e\u0447\u0435\u0440\u0435\u0434\u0438:<\/p>\n
const apiQueue = require('.\/services\/copy\/ApiQueueService'); const apiQueue2 = require('.\/services\/copy\/ApiQueueService'); const apiQueue3 = require('.\/services\/copy\/ApiQueueService');  const wait = (t) => new Promise((resolve) => setTimeout(() => resolve(), t));  const testAsync = async (d) => {   const { t, ...other } = d;   await wait(t);   return other; };  (async () => {   for (let i = 0; i < 100; i++) {     apiQueue.executeInQueue(testAsync, { t: 100, index: i, fromFile: 1 }).then((d) => console.log(d));     apiQueue2.executeInQueue(testAsync, { t: 100, index: i, fromFile: 2 }).then((d) => console.log(d));     apiQueue3.executeInQueue(testAsync, { t: 100, index: i, fromFile: 3 }).then((d) => console.log(d));   }  })();<\/code><\/pre>\n
<\/figcaption><\/figure>\n
\u041e\u0442\u043b\u0438\u0447\u043d\u043e. \u0420\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u043a\u0430\u043a \u043d\u0430\u0434\u043e. \u0422\u0430\u043a\u0436\u0435 \u043d\u0430\u043c \u043d\u0430\u0434\u043e \u0441\u043b\u0435\u0434\u0438\u0442\u044c \u0437\u0430 \u0441\u0442\u0430\u0442\u0443\u0441\u043e\u043c \u043d\u0430\u0448\u0438\u0445 \u043e\u0440\u0434\u0435\u0440\u043e\u0432. \u0414\u043b\u044f \u044d\u0442\u043e\u0433\u043e \u0443\u0441\u0442\u0430\u043d\u043e\u0432\u0438\u043c \u0441\u043e\u043a\u0435\u0442 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u0441 \u0431\u0438\u0440\u0436\u0435\u0439 \u043f\u043e API \u043a\u043b\u044e\u0447\u0430\u043c \u0438 \u0431\u0443\u0434\u0435\u043c \u043b\u043e\u0432\u0438\u0442\u044c \u0438\u0432\u0435\u043d\u0442\u044b \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u044f \u043e\u0440\u0434\u0435\u0440\u043e\u0432. \u0411\u0438\u043d\u0430\u043d\u0441 \u0434\u0430\u0435\u0442 \u043d\u0430\u043c \u0441\u043b\u0443\u0448\u0430\u0442\u044c \u0442\u0430\u043a\u0438\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0447\u0435\u0440\u0435\u0437 \u0441\u043e\u043a\u0435\u0442:<\/p>\n
this.api.websockets.userFutureData(       this.marginCallCallback,       this.accountUpdateCallback,       this.orderUpdateCallback,       this.subscribedCallback,       this.accountConfigUpdateCallback, )<\/code><\/pre>\n
\u0418\u0441\u043f\u043e\u043b\u044c\u0443\u0435\u043c \u0442\u043e\u043b\u044c\u043a\u043e \u043e\u0434\u043d\u043e \u0441\u043e\u0431\u044b\u0442\u0438\u0435  orderUpdateCallback<\/code> . \u041a\u0430\u043a \u0442\u043e\u043b\u044c\u043a\u043e \u0431\u0443\u0434\u0435\u0442 \u043f\u0440\u0438\u0445\u043e\u0434\u0438\u0442\u044c \u0441\u043e\u0431\u044b\u0442\u0438\u0435 — \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c \u043e\u0440\u0434\u0435\u0440. \u0415\u0441\u043b\u0438 \u0435\u0433\u043e \u0441\u0442\u0430\u0442\u0443\u0441 \u0432 \u0431\u0430\u0437\u0435 \u043e\u0442\u043b\u0438\u0447\u0430\u0435\u0442\u0441\u044f \u043e\u0442 \u0442\u043e\u0433\u043e, \u0447\u0442\u043e \u043f\u0440\u0438\u0448\u0435\u043b \u0432 \u0441\u043e\u0431\u044b\u0442\u0438\u0438 — \u043e\u0431\u043d\u043e\u0432\u043b\u044f\u0435\u043c \u0441\u0442\u0430\u0442\u0443\u0441 \u0438 \u0441\u043e\u0445\u0440\u0430\u043d\u044f\u0435\u043c \u043a\u043e\u043c\u0438\u0441\u0441\u0438\u044e.<\/p>\n
checkOrder = async (data)=>{     if (data && data.order) {       try {         const { order } = data         if (order && order.orderId && order.orderStatus && order.executionType === 'TRADE') {           const o = await orderProvider.getOrder(order)           if (o && o.status !== order.orderStatus) {             o.status = order.orderStatus             await orderProvider.updateOrderCommission(o, order)           }         }       } catch (e) {         this.error('executionTRADE error', e)       }     }   }<\/code><\/pre>\n
\u0422\u0435\u043f\u0435\u0440\u044c \u043d\u0430\u043f\u0438\u0448\u0435\u043c \u0431\u0430\u0437\u043e\u0432\u044b\u0439 \u0441\u0435\u0440\u0432\u0438\u0441, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0431\u0443\u0434\u0435\u0442 \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c  \u0441\u0442\u0440\u0430\u0442\u0435\u0433\u0438\u0435\u0439 \u0442\u043e\u0440\u0433\u043e\u0432\u043b\u0438. \u0421\u0442\u0440\u0430\u0442\u0435\u0433\u0438\u044f \u0434\u043e\u043b\u0436\u043d\u0430 \u0438\u043c\u0435\u0442\u044c \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0439 WAIT_ENTRY_POINT<\/code> ,IN_PROGRESS<\/code> , COMPLETED<\/code> . \u0418 \u0432 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u0438 \u043e\u0442 \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0439 \u0434\u043e\u043b\u0436\u043d\u0430 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u0442\u044c \u0440\u0430\u0437\u043d\u044b\u0435 \u0434\u0435\u0439\u0441\u0442\u0432\u0438\u044f:<\/p>\n