removed hash from client stats table, connection pool size

src/ORM/client-statistics/client-statistics.entity.ts

@@ -1,15 +1,14 @@
-import { Column, Entity, Index, PrimaryColumn } from 'typeorm';
+import { Column, Entity, Index, PrimaryGeneratedColumn } from 'typeorm';
 
 import { TrackedEntity } from '../utils/TrackedEntity.entity';
 
 @Entity()
-//Index for the heartbeat update
-@Index(["address", "clientName", "sessionId", "time"])
+//Index for getHashRateForSession
+@Index(["address", "clientName", "sessionId"])
 export class ClientStatisticsEntity extends TrackedEntity {
 
-    @PrimaryColumn({ length: 64, type: 'varchar' })
-    submissionHash: string;
-
+    @PrimaryGeneratedColumn()
+    id: number;
 
     @Column({ length: 62, type: 'varchar' })
     address: string;

src/app.module.ts

@@ -64,7 +64,7 @@ const ORMModules = [
                     ],
                     synchronize: configService.get('PRODUCTION') != 'true',
                     logging: false,
-
+                    poolSize: 30
                 }
             },
             imports: [ConfigModule],

src/models/StratumV1Client.ts

@@ -505,7 +505,7 @@ export class StratumV1Client {
                 }
             }
             try {
-                await this.statistics.addSubmission(this.entity, submissionHash, this.sessionDifficulty);
+                await this.statistics.addSubmission(this.entity, this.sessionDifficulty);
                 await this.clientService.heartbeat(this.entity.address, this.entity.clientName, this.entity.sessionId, this.hashRate);
             } catch (e) {
                 console.log(e);

src/models/StratumV1ClientStatistics.ts

@@ -17,7 +17,7 @@ export class StratumV1ClientStatistics {
         this.submissionCacheStart = new Date();
     }
 
-    public async addSubmission(client: ClientEntity, submissionHash: string, targetDifficulty: number) {
+    public async addSubmission(client: ClientEntity, targetDifficulty: number) {
 
         if (this.submissionCache.length > CACHE_SIZE) {
             this.submissionCache.shift();
@@ -31,15 +31,14 @@ export class StratumV1ClientStatistics {
         // 10 min
         var coeff = 1000 * 60 * 10;
         var date = new Date();
-        var rounded = new Date(Math.round(date.getTime() / coeff) * coeff);
+        var rounded = new Date(Math.floor(date.getTime() / coeff) * coeff);
 
         await this.clientStatisticsService.save({
             time: rounded.getTime(),
             shares: targetDifficulty,
             address: client.address,
             clientName: client.clientName,
-            sessionId: client.sessionId,
-            submissionHash
+            sessionId: client.sessionId
         });
 
     }