feat: sales feed

src/server-extension/model/sales.model.ts

@@ -0,0 +1,38 @@
+import { Field, ObjectType } from 'type-graphql';
+
+@ObjectType()
+export class SaleNftEntity {
+    @Field(() => String, { nullable: false })
+    id!: string
+
+    @Field(() => String)
+    name!: string
+
+    @Field(() => String, { nullable: false })
+    issuer!: string
+
+    @Field(() => String, { nullable: false })
+    buyer!: string
+
+    @Field(() => String, { nullable: false, name: 'collectionId'})
+    collection_id!: string
+
+    @Field(() => String, { nullable: false, name: 'collectionName'})
+    collection_name!: string
+
+    @Field(() => BigInt, { nullable: false, name: 'salePrice' })
+    sale_price!: bigint
+
+    @Field(() => String, { nullable: false, name: 'blockNumber' })
+    block_number!: string
+
+    @Field(() => String, { nullable: false })
+    timestamp!: string
+
+    @Field(() => String, { nullable: true })
+    image!: string
+
+    constructor(props: Partial<SaleNftEntity>) {
+        Object.assign(this, props);
+    }
+}

src/server-extension/query/nft.ts

@@ -1,4 +1,24 @@
 export const passionQuery = `SELECT DISTINCT ne.issuer as id
 FROM nft_entity ne
 WHERE ne.current_owner = $1
-AND ne.current_owner != ne.issuer`
+AND ne.current_owner != ne.issuer`
+
+export const salesQuery = `SELECT
+    ne.id,
+    ne.name,
+    ce.name as collection_name,
+    ne.issuer,
+    collection_id,
+    e.caller as buyer,
+    (e.meta::bigint) as sale_price,
+    e.timestamp,
+    e.block_number,
+    me.image
+FROM nft_entity ne
+    JOIN collection_entity ce on ce.id = collection_id
+    LEFT join event as e on e.nft_id = ne.id
+    LEFT join metadata_entity me on me.id = ne.metadata
+where
+    e.interaction = 'BUY'
+    and e.timestamp >= NOW() - INTERVAL '7 DAY'
+ORDER BY e.timestamp desc`

src/server-extension/resolvers/index.ts

@@ -6,6 +6,7 @@ import { SpotlightResolver } from './spotlight'
 import { CollectionChartResolver } from './collectionChart'
 import { CollectionEventResolver } from './collectionEvent'
 import { PassionFeedResolver } from "./passionFeed";
+import { SalesFeedResolver } from "./salesFeed";
 
 @ObjectType()
 export class Hello {
@@ -37,4 +38,5 @@ export {
   SpotlightResolver,
   CollectionEventResolver,
   PassionFeedResolver,
+  SalesFeedResolver,
 }

src/server-extension/resolvers/salesFeed.ts

@@ -0,0 +1,17 @@
+import { Query, Resolver } from 'type-graphql'
+import type { EntityManager } from 'typeorm'
+import { NFTEntity } from '../../model/generated'
+import { SaleNftEntity } from '../model/sales.model'
+import { salesQuery } from "../query/nft";
+import { makeQuery } from "../utils";
+
+@Resolver()
+export class SalesFeedResolver {
+    constructor(private tx: () => Promise<EntityManager>) { }
+
+    @Query(() => [SaleNftEntity])
+    async salesFeed(): Promise<[SaleNftEntity]> {
+        const result: [SaleNftEntity] = await makeQuery(this.tx, NFTEntity, salesQuery)
+        return result
+    }
+}