feat: statistics #248
feat: statistics #248
Conversation
andqk00
commented
Jul 7, 2023
andqk00
commented
- Job to crawl daily onchain statistics (number of txs, number of active accounts, total accounts)
- Job to calculate top accounts
- Api to query top accounts since it is stored on redis
…reate statistics jobs with date
| Event.EVENT_TYPE.COIN_RECEIVED, | ||
| Event.EVENT_TYPE.USE_FEEGRANT, | ||
| ]) | ||
| .orWhereIn('events:attributes.key', [ |
| { | ||
| id: null, | ||
| date: ctx.params.date, | ||
| accountStats: [], |
There was a problem hiding this comment.
cho thành object key là address đi
| .orderBy('id') | ||
| )[0].id | ||
| : _payload.id; | ||
| const nextId = startTxId + 50; |
There was a problem hiding this comment.
sao phải chặn thế này? có nhiều lắm ko?
| const dailyEvents = await Transaction.query() | ||
| .joinRelated('events.[attributes]') | ||
| .select( | ||
| 'transaction.gas_used', |
There was a problem hiding this comment.
nếu tách cái gas_used này ra thì có cần join nữa ko?
| } | ||
|
|
||
| private calculateTop(dayStat: AccountStatistics[]) { | ||
| const newTopStat = { |
There was a problem hiding this comment.
const topAmountSent = [], topAmountReceived = [], topTxSent = [], topGasUsed = [];
| (_, index) => index < config.accountStatistics.numberOfTopRecords | ||
| ); | ||
|
|
||
| return newTopStat; |
There was a problem hiding this comment.
return {
top_tx_sent: topTxSent,
top_tx_received: topTxReceived,
..
}
| ), | ||
| }); | ||
| }); | ||
| newTopStat.top_amount_sent = newTopStat.top_amount_sent |
There was a problem hiding this comment.
topAmountSent = _.sortBy(topAmountSent, 'percentage').slice(0, config....);
| public async handleTopAccounts(_payload: object): Promise<void> { | ||
| try { | ||
| const syncDate = new Date(); | ||
| const now = syncDate.setUTCHours(0, 0, 0, 0); |
There was a problem hiding this comment.
dùng dayjs
dayjs().startOf('day')
| const syncDate = new Date(); | ||
| const now = syncDate.setUTCHours(0, 0, 0, 0); | ||
| syncDate.setDate(syncDate.getDate() - 3); | ||
| const threeDays = syncDate.setUTCHours(0, 0, 0, 0); |
There was a problem hiding this comment.
const threeDayAgo = syncDate.subtract(3, 'day')
| .groupBy('address'), | ||
| ]); | ||
|
|
||
| let topAccounts = await this.broker.cacher?.get(REDIS_KEY.TOP_ACCOUNTS); |
|
|
||
| @Action({ | ||
| name: 'getTopAccounts', | ||
| params: {}, |
| .subtract(1, 'day') | ||
| .startOf('day') | ||
| .toDate(); | ||
| const endTime = dayjs.utc(date).startOf('day').toDate(); |
There was a problem hiding this comment.
const startTime = endTime.subtract(1, 'day');
| _payload.addresses.concat( | ||
| dailyAddresses | ||
| .filter((event) => | ||
| Utils.isValidAccountAddress( |
There was a problem hiding this comment.
TODO cần tính xem chỉ count address thường hay cả contract address
| .insert(dailyStat) | ||
| .catch((error) => { | ||
| this.logger.error('Error insert new daily statistic record'); | ||
| this.logger.error(error); |
