delete unused: statistics and account

apollo/prisma/schema.prisma

@@ -46,17 +46,6 @@ model HistoryRecord {
   extData String?
 }
 
-model DailyStatistics {
-  fromChain String
-  toChain String
-  bridge String
-  timestamp Int
-  token String
-  dailyVolume BigInt?
-  dailyCount BigInt?
-  @@unique([fromChain, toChain, bridge, timestamp, token], name: "daily_statistics_id")
-}
-
 model LnBridgeRelayInfo {
   id String @id
   version String

apollo/src/aggregation/aggregation.history.graphql

@@ -35,16 +35,6 @@ type HistoryRecord {
   extData: String
 }
 
-type DailyStatistics {
-  fromChain: String!
-  toChain: String!
-  bridge: String!
-  timestamp: Int!
-  token: String!
-  dailyVolume: BigInt
-  dailyCount: BigInt
-}
-
 type HistoryRecords {
   total: Int!
   records: [HistoryRecord]
@@ -106,7 +96,6 @@ type Query {
   historyRecordById(id: String): HistoryRecord
   historyRecordByTxHash(txHash: String): HistoryRecord
   firstHistoryRecord(fromChain: String, toChain: String, bridge: String, results: [Int], relayer: String, token: String, order: String, notsubmited: Boolean): HistoryRecord
-  queryDailyStatistics(timepast: Int!, first: Int, from: String, to: String, bridge: String, token: String): [DailyStatistics]
   historyRecords(sender: String, recipient: String, relayer: String, needWithdrawLiquidity: Boolean, fromChains: [String], toChains: [String], bridges: [String], row: Int, page: Int, results: [Int], recvTokenAddress: String,  order: String): HistoryRecords
   checkLnBridgeExist(fromChainId: Int, toChainId: Int, fromToken: String, toToken: String, version: String): Boolean
   tasksHealthCheck(name: String): [HealthInfo]

apollo/src/aggregation/aggregation.resolver.ts

@@ -160,39 +160,6 @@ export class AggregationResolver {
     });
   }
 
-  // daily statistics
-  @Query()
-  async queryDailyStatistics(
-    @Args('timepast') timepast: number,
-    @Args('first') take: number,
-    @Args('from') fromChain: string,
-    @Args('to') toChain: string,
-    @Args('bridge') bridge: string,
-    @Args('token') token: string
-  ) {
-    const filter = [];
-    if (fromChain) {
-      filter.push({ fromChain });
-    }
-    if (toChain) {
-      filter.push({ toChain });
-    }
-    if (bridge) {
-      filter.push({ bridge });
-    }
-    if (token) {
-      filter.push({ token });
-    }
-
-    const now = Date.now() / 1000;
-    const timelimit = Math.floor(now - timepast);
-    const where = { AND: { timestamp: { gt: timelimit }, AND: filter } };
-    return this.aggregationService.queryDailyStatistics({
-      take,
-      where,
-    });
-  }
-
   /**
   * @deprecated instead, please use signConfirmedBlock
   **/

apollo/src/aggregation/aggregation.service.ts

@@ -1,5 +1,5 @@
 import { INestApplication, Injectable, Logger, OnModuleInit } from '@nestjs/common';
-import { DailyStatistics, HistoryRecord, Prisma, PrismaClient } from '@prisma/client';
+import { HistoryRecord, Prisma, PrismaClient } from '@prisma/client';
 import { HistoryRecords, LnBridgeRelayInfo, LnBridgeRelayInfos } from '../graphql';
 // export lnbridge service configure
 import { last } from 'lodash';
@@ -165,39 +165,6 @@ export class AggregationService extends PrismaClient implements OnModuleInit {
     return { total, records };
   }
 
-  // daily statistics
-  async createDailyStatistics(data: Prisma.DailyStatisticsCreateInput): Promise<DailyStatistics> {
-    return this.dailyStatistics.create({
-      data,
-    });
-  }
-
-  async updateDailyStatistics(params: {
-    where: Prisma.DailyStatisticsWhereUniqueInput;
-    data: Prisma.DailyStatisticsUpdateInput;
-  }): Promise<DailyStatistics> {
-    const { where, data } = params;
-    return this.dailyStatistics.update({
-      data,
-      where,
-    });
-  }
-
-  async queryDailyStatistics(params: {
-    skip?: number;
-    take?: number;
-    where?: Prisma.DailyStatisticsWhereInput;
-  }): Promise<DailyStatistics[]> {
-    const { skip, take, where } = params;
-
-    return this.dailyStatistics.findMany({
-      skip,
-      take,
-      where,
-      orderBy: { timestamp: 'desc' },
-    });
-  }
-
   tasksHealthCheck() {
       return this.tasksService.queryHealthChecks();
   }
@@ -300,15 +267,6 @@ export class AggregationService extends PrismaClient implements OnModuleInit {
     }
   }
 
-  async queryDailyStatisticsFirst(
-    dailyStatisticsWhereInput: Prisma.DailyStatisticsWhereInput
-  ): Promise<DailyStatistics | null> {
-    return this.dailyStatistics.findFirst({
-      where: dailyStatisticsWhereInput,
-      orderBy: { timestamp: 'desc' },
-    });
-  }
-
   async calculateLnBridgeRelayerPoint(
     token: string,
     amount: bigint,

apollo/src/app.module.ts

@@ -5,12 +5,10 @@ import { GraphQLModule, Scalar } from '@nestjs/graphql';
 import { ScheduleModule } from '@nestjs/schedule';
 import BigInt from 'apollo-type-bigint';
 import { join } from 'path';
-import { AccountModule } from './account/account.module';
 import { AggregationModule } from './aggregation/aggregation.module';
 import { AppController } from './app.controller';
 import { AppService } from './app.service';
 import { TasksModule } from './tasks/tasks.module';
-import { StatisticModule } from './statistic/statistic.module';
 import { Lnv2Module } from './lnv2/lnv2.module';
 import { Lnv3Module } from './lnv3/lnv3.module';
 
@@ -29,15 +27,13 @@ export class BigIntScalar extends BigInt {}
         outputAs: 'class',
       },
     }),
-    AccountModule,
     ConfigModule.forRoot({
       envFilePath: ['.env', chainEnvFilePath],
       isGlobal: true,
     }),
     ScheduleModule.forRoot(),
     TasksModule,
     AggregationModule,
-    StatisticModule,
     Lnv2Module,
     Lnv3Module,
   ],