Feat/update owner for each cw721 activity ( main) #349
Conversation
| await this.updateOwnerForMintActs( | ||
| unprocessedActivities.filter((e) => e.action === CW721_ACTION.MINT) | ||
| ); | ||
| const tokens = unprocessedActivities.reduce( |
phamphong9981
changed the title
|
|
||
| export async function up(knex: Knex): Promise<void> { | ||
| await knex.schema.alterTable('cw721_activity', (table) => { | ||
| table.string('owner'); |
There was a problem hiding this comment.
để nguyên định nghĩa from với to, em thêm sender thì nó hợp lý hơn
There was a problem hiding this comment.
from và to hiện tại đang có data, thực chất from đang là data của sender, nếu thêm cột sender thì phải chuyển data từ from qua ( hoặc rename cột ). Em thêm cột owner thì chỉ cần fill data vào mà em thấy cũng tạm chấp nhận được, cái tên cột mình hiểu là đc mà :))
| queueName: BULL_JOB_NAME.UPDATE_CW721_ACTIVITY_OWNER_BY_TOKEN, | ||
| jobName: BULL_JOB_NAME.UPDATE_CW721_ACTIVITY_OWNER_BY_TOKEN, | ||
| }) | ||
| async updateCw721ActOwnerByToken(_payload: { |
There was a problem hiding this comment.
hiện tại trên xstaxy cũng chỉ có 25k activity, load hết ra mà sửa trong 1 migration
sau đó thì gán luôn lúc có activity mới
There was a problem hiding this comment.
Trước kia em đã có nghĩ giải quyết theo hướng chạy migration update data cũ và sửa logic code. Nhưng việc sửa logic code sẽ gặp những vấn đề là:
- code phình to
- logic tương đối phức tạp
- khó debug/test
- có nhiều trường hợp khi một phần data nằm trong range [startBlock, endBlock] khi mình bắt được và một phần data nằm trong DB
Em muốn thống nhất là data khi trong DB rồi thì mình bốc ra xử lý những cái chưa update owner
|
@peara em sửa lại theo migration + update code r anh nhé |
No description provided.