Feat/142 collection stats

.gitignore

@@ -10,3 +10,5 @@
 
 .DS_Store
 dump_*.sql
+
+.env

db/migrations/1681318561000-Data.js

@@ -0,0 +1,13 @@
+module.exports = class Data1681318561000 {
+    name = 'Data1681318561000'
+
+    async up(db) {
+        await db.query(`ALTER TABLE "collection_entity" ADD "volume" numeric`)
+        await db.query(`ALTER TABLE "collection_entity" ADD "highest_sale_price" numeric`)
+    }
+
+    async down(db) {
+        await db.query(`ALTER TABLE "collection_entity" DROP COLUMN "volume"`)
+        await db.query(`ALTER TABLE "collection_entity" DROP COLUMN "highest_sale_price"`)
+    }
+}

schema.graphql

@@ -16,6 +16,8 @@ type CollectionEntity @entity {
   nftCount: Int!
   supply: Int!
   type: CollectionType!
+  volume: BigInt!
+  highestSalePrice: BigInt!
 }
 
 type NFTEntity @entity {

src/mappings/index.ts

@@ -94,6 +94,8 @@ export async function handleCollectionCreate(context: Context): Promise<void> {
   final.nftCount = 0;
   final.supply = 0;
   final.type = type;
+  final.volume = BigInt(0);
+  final.highestSalePrice = BigInt(0);
 
   logger.debug(`metadata: ${final.metadata}`);
 
@@ -248,6 +250,10 @@ export async function handleTokenBuy(context: Context): Promise<void> {
 
   const collection = ensure<CE>(await get<CE>(context.store, CE, event.collectionId));
   plsBe(real, collection);
+  collection.volume++;
+  if (event.price && collection.highestSalePrice < event.price) {
+    collection.highestSalePrice = event.price;
+  }
   collection.updatedAt = event.timestamp;
 
   logger.success(`[BUY] ${id} by ${event.caller}`);

src/model/generated/collectionEntity.model.ts

@@ -63,4 +63,10 @@ export class CollectionEntity {
 
     @Column_("varchar", {length: 15, nullable: false})
     type!: CollectionType
+
+    @Column_("numeric", {transformer: marshal.bigintTransformer, nullable: false})
+    volume!: bigint
+
+    @Column_("numeric", {transformer: marshal.bigintTransformer, nullable: false})
+    highestSalePrice!: bigint
 }