Populate offers table

packages/backend/src/Application.ts

@@ -447,6 +447,7 @@ export class Application {
       userService,
       assetRepository,
       userTransactionRepository,
+      forcedTradeOfferRepository,
       preprocessedStateDetailsRepository,
       config.starkex.tradingMode,
       collateralAsset
@@ -456,6 +457,7 @@ export class Application {
       preprocessedAssetHistoryRepository,
       sentTransactionRepository,
       userTransactionRepository,
+      forcedTradeOfferRepository,
       userRegistrationEventRepository,
       assetRepository,
       config.starkex.tradingMode,

packages/backend/src/api/controllers/HomeController.ts

@@ -9,10 +9,12 @@ import { CollateralAsset } from '../../config/starkex/StarkexConfig'
 import { UserService } from '../../core/UserService'
 import { PaginationOptions } from '../../model/PaginationOptions'
 import { AssetRepository } from '../../peripherals/database/AssetRepository'
+import { ForcedTradeOfferRepository } from '../../peripherals/database/ForcedTradeOfferRepository'
 import { PreprocessedStateDetailsRepository } from '../../peripherals/database/PreprocessedStateDetailsRepository'
 import { UserTransactionData } from '../../peripherals/database/transactions/UserTransaction'
 import { UserTransactionRepository } from '../../peripherals/database/transactions/UserTransactionRepository'
 import { ControllerResult } from './ControllerResult'
+import { forcedTradeOfferToEntry } from './forcedTradeOfferToEntry'
 import { getAssetHashToAssetDetailsMap } from './getAssetDetailsMap'
 import { userTransactionToEntry } from './userTransactionToEntry'
 
@@ -27,6 +29,7 @@ export class HomeController {
     private readonly userService: UserService,
     private readonly assetRepository: AssetRepository,
     private readonly userTransactionRepository: UserTransactionRepository,
+    private readonly forcedTradeOfferRepository: ForcedTradeOfferRepository,
     private readonly preprocessedStateDetailsRepository: PreprocessedStateDetailsRepository,
     private readonly tradingMode: TradingMode,
     private readonly collateralAsset?: CollateralAsset
@@ -36,25 +39,24 @@ export class HomeController {
     givenUser: Partial<UserDetails>
   ): Promise<ControllerResult> {
     const user = await this.userService.getUserDetails(givenUser)
-
+    const paginationOpts = { offset: 0, limit: 6 }
     const [
       stateUpdates,
       totalStateUpdates,
       forcedUserTransactions,
       forcedUserTransactionsCount,
+      availableOffers,
+      availableOffersCount,
     ] = await Promise.all([
-      this.preprocessedStateDetailsRepository.getPaginated({
-        offset: 0,
-        limit: 6,
-      }),
+      this.preprocessedStateDetailsRepository.getPaginated(paginationOpts),
       this.preprocessedStateDetailsRepository.countAll(),
-
       this.userTransactionRepository.getPaginated({
-        offset: 0,
-        limit: 6,
+        ...paginationOpts,
         types: FORCED_TRANSACTION_TYPES,
       }),
       this.userTransactionRepository.countAll(FORCED_TRANSACTION_TYPES),
+      this.forcedTradeOfferRepository.getAvailablePaginated(paginationOpts),
+      this.forcedTradeOfferRepository.countAvailable(),
     ])
 
     const assetDetailsMap = await getAssetHashToAssetDetailsMap(
@@ -82,8 +84,8 @@ export class HomeController {
       totalStateUpdates,
       transactions,
       totalForcedTransactions: forcedUserTransactionsCount,
-      offers: [],
-      totalOffers: 0,
+      offers: availableOffers.map((offer) => forcedTradeOfferToEntry(offer)),
+      totalOffers: availableOffersCount,
       tradingMode: this.tradingMode,
     })
     return { type: 'success', content }

packages/backend/src/api/controllers/UserController.ts

@@ -8,12 +8,13 @@ import {
 } from '@explorer/frontend'
 import { UserBalanceChangeEntry } from '@explorer/frontend/src/view/pages/user/components/UserBalanceChangesTable'
 import { AssetDetails, TradingMode, UserDetails } from '@explorer/shared'
-import { AssetHash, AssetId, EthereumAddress, StarkKey } from '@explorer/types'
+import { AssetHash, AssetId, StarkKey } from '@explorer/types'
 
 import { CollateralAsset } from '../../config/starkex/StarkexConfig'
 import { UserService } from '../../core/UserService'
 import { PaginationOptions } from '../../model/PaginationOptions'
 import { AssetRepository } from '../../peripherals/database/AssetRepository'
+import { ForcedTradeOfferRepository } from '../../peripherals/database/ForcedTradeOfferRepository'
 import {
   PreprocessedAssetHistoryRecord,
   PreprocessedAssetHistoryRepository,
@@ -28,6 +29,7 @@ import {
 } from '../../peripherals/database/transactions/UserTransactionRepository'
 import { UserRegistrationEventRepository } from '../../peripherals/database/UserRegistrationEventRepository'
 import { ControllerResult } from './ControllerResult'
+import { forcedTradeOfferToEntry } from './forcedTradeOfferToEntry'
 import { getAssetHashToAssetDetailsMap } from './getAssetDetailsMap'
 import { sentTransactionToEntry } from './sentTransactionToEntry'
 import { userTransactionToEntry } from './userTransactionToEntry'
@@ -41,6 +43,7 @@ export class UserController {
     >,
     private readonly sentTransactionRepository: SentTransactionRepository,
     private readonly userTransactionRepository: UserTransactionRepository,
+    private readonly forcedTradeOfferRepository: ForcedTradeOfferRepository,
     private readonly userRegistrationEventRepository: UserRegistrationEventRepository,
     private readonly assetRepository: AssetRepository,
     private readonly tradingMode: TradingMode,
@@ -51,6 +54,10 @@ export class UserController {
     givenUser: Partial<UserDetails>,
     starkKey: StarkKey
   ): Promise<ControllerResult> {
+    const paginationOpts = {
+      offset: 0,
+      limit: 10,
+    }
     const [
       user,
       registeredUser,
@@ -61,30 +68,42 @@ export class UserController {
       sentTransactions,
       userTransactions,
       userTransactionsCount,
+      forcedTradeOffers,
+      forcedTradeOffersCount,
     ] = await Promise.all([
       this.userService.getUserDetails(givenUser),
       this.userRegistrationEventRepository.findByStarkKey(starkKey),
       this.preprocessedAssetHistoryRepository.getCurrentByStarkKeyPaginated(
         starkKey,
-        { offset: 0, limit: 10 },
+        paginationOpts,
         this.collateralAsset?.assetId
       ),
       this.preprocessedAssetHistoryRepository.getCountOfCurrentByStarkKey(
         starkKey
       ),
-      this.preprocessedAssetHistoryRepository.getByStarkKeyPaginated(starkKey, {
-        offset: 0,
-        limit: 10,
-      }),
+      this.preprocessedAssetHistoryRepository.getByStarkKeyPaginated(
+        starkKey,
+        paginationOpts
+      ),
       this.preprocessedAssetHistoryRepository.getCountByStarkKey(starkKey),
       this.sentTransactionRepository.getByStarkKey(starkKey),
-      this.userTransactionRepository.getByStarkKey(starkKey, undefined, {
-        offset: 0,
-        limit: 10,
-      }),
+      this.userTransactionRepository.getByStarkKey(
+        starkKey,
+        undefined,
+        paginationOpts
+      ),
       this.userTransactionRepository.getCountByStarkKey(starkKey),
+      this.forcedTradeOfferRepository.getUserOffersByStarkKey(
+        starkKey,
+        paginationOpts
+      ),
+      this.forcedTradeOfferRepository.countByStarkKey(starkKey),
     ])
 
+    if (!registeredUser) {
+      return { type: 'not found', content: 'User not found' }
+    }
+
     const assetDetailsMap = await getAssetHashToAssetDetailsMap(
       this.tradingMode,
       this.assetRepository,
@@ -122,7 +141,7 @@ export class UserController {
       user,
       tradingMode: this.tradingMode,
       starkKey,
-      ethereumAddress: registeredUser?.ethAddress ?? EthereumAddress.ZERO,
+      ethereumAddress: registeredUser.ethAddress,
       withdrawableAssets: [],
       offersToAccept: [],
       assets: assetEntries,
@@ -131,8 +150,10 @@ export class UserController {
       totalBalanceChanges: historyCount,
       transactions,
       totalTransactions,
-      offers: [],
-      totalOffers: 0,
+      offers: forcedTradeOffers.map((offer) =>
+        forcedTradeOfferToEntry(offer, registeredUser.starkKey)
+      ),
+      totalOffers: forcedTradeOffersCount,
     })
 
     return { type: 'success', content }

packages/backend/src/api/controllers/forcedTradeOfferToEntry.ts

@@ -0,0 +1,59 @@
+import { OfferEntry } from '@explorer/frontend'
+import { StarkKey, Timestamp } from '@explorer/types'
+
+import { ForcedTradeOfferRecord } from '../../peripherals/database/ForcedTradeOfferRepository'
+
+function buildTradeOfferHistory(
+  forcedTradeOffer: ForcedTradeOfferRecord
+): OfferEntry['status'][] {
+  const history: OfferEntry['status'][] = []
+  if (forcedTradeOffer.accepted) {
+    if (forcedTradeOffer.accepted.transactionHash) {
+      history.push('SENT')
+    } else if (
+      Timestamp.fromHours(forcedTradeOffer.accepted.submissionExpirationTime) <
+      Timestamp.now()
+    ) {
+      history.push('EXPIRED')
+    }
+  }
+
+  if (forcedTradeOffer.cancelledAt) {
+    history.push('CANCELLED')
+  }
+
+  if (forcedTradeOffer.accepted) {
+    history.push('ACCEPTED')
+  }
+
+  history.push('CREATED')
+
+  return history
+}
+
+export function forcedTradeOfferToEntry(
+  forcedTradeOffer: ForcedTradeOfferRecord,
+  userStarkKey?: StarkKey
+): OfferEntry {
+  // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
+  const status = buildTradeOfferHistory(forcedTradeOffer)[0]!
+  const role =
+    forcedTradeOffer.starkKeyA === userStarkKey
+      ? 'MAKER'
+      : forcedTradeOffer.accepted?.starkKeyB === userStarkKey
+      ? 'TAKER'
+      : undefined
+  return {
+    id: forcedTradeOffer.id.toString(),
+    timestamp: forcedTradeOffer.createdAt,
+    asset: {
+      hashOrId: forcedTradeOffer.syntheticAssetId,
+    },
+    amount: forcedTradeOffer.syntheticAmount,
+    price: 0n, //TODO: calculate price
+    totalPrice: 0n * forcedTradeOffer.syntheticAmount,
+    status,
+    type: forcedTradeOffer.isABuyingSynthetic ? 'BUY' : 'SELL',
+    role,
+  }
+}