WITHOUT ROWID

src/ORM/client/client.entity.ts

@@ -1,27 +1,32 @@
-import { Column, Entity, Index, PrimaryGeneratedColumn } from 'typeorm';
+import { Column, Entity, Index, PrimaryColumn } from 'typeorm';
 
 import { DateTimeTransformer } from '../utils/DateTimeTransformer';
 import { TrackedEntity } from '../utils/TrackedEntity.entity';
 
-@Entity()
+//https://www.sqlite.org/withoutrowid.html
+
+//The WITHOUT ROWID optimization is likely to be helpful for tables that have non-integer
+// or composite (multi-column) PRIMARY KEYs and that do not store large strings or BLOBs.
+//WITHOUT ROWID tables work best when individual rows are not too large.
+@Entity({ withoutRowid: true })
+@Index(['address', 'clientName', 'sessionId'], { unique: true })
 export class ClientEntity extends TrackedEntity {
 
-    @PrimaryGeneratedColumn()
-    id: number;
 
-
+    @PrimaryColumn({ length: 62, type: 'varchar' })
-    @Column({ length: 62, type: 'varchar' })
     address: string;
 
-    @Column({ length: 64, type: 'varchar' })
+    @PrimaryColumn({ length: 64, type: 'varchar' })
     clientName: string;
 
+    @PrimaryColumn({ length: 8, type: 'varchar' })
+    sessionId: string;
+
+
     @Column({ length: 128, type: 'varchar', nullable: true })
     userAgent: string;
 
-    @Index()
+
-    @Column({ length: 8, type: 'varchar', unique: true })
-    sessionId: string;
 
     @Column({ type: 'datetime', transformer: new DateTimeTransformer() })
     startTime: Date;

src/models/StratumV1Client.ts

@@ -41,7 +41,9 @@ export class StratumV1Client {
     private stratumInitialized = false;
     private usedSuggestedDifficulty = false;
     private sessionDifficulty: number = 16384;
+
     private entity: ClientEntity;
+    private creatingEntity: Promise<void>;
 
     public extraNonceAndSessionId: string;
     public sessionStart: Date;
@@ -416,6 +418,9 @@ export class StratumV1Client {
     private async handleMiningSubmission(submission: MiningSubmitMessage) {
 
         if (this.entity == null) {
+            if (this.creatingEntity == null) {
+                this.creatingEntity = new Promise(async (resolve, reject) => {
+                    try {
                         this.entity = await this.clientService.insert({
                             sessionId: this.extraNonceAndSessionId,
                             address: this.clientAuthorization.address,
@@ -424,6 +429,16 @@ export class StratumV1Client {
                             startTime: new Date(),
                             bestDifficulty: 0
                         });
+                    } catch (e) {
+                        reject(e);
+                    }
+                    resolve();
+                });
+                await this.creatingEntity;
+
+            } else {
+                await this.creatingEntity;
+            }
         }
 
 

src/services/stratum-v1.service.ts

@@ -42,11 +42,6 @@ export class StratumV1Service implements OnModuleInit {
   private startSocketServer() {
     const server = new Server(async (socket: Socket) => {
 
-      // socket.setTimeout(5000, () => {
-      //   console.log(`Client ${client.extraNonceAndSessionId} timeout`);
-      //   socket.destroy();
-      // });
-
       const client = new StratumV1Client(
         socket,
         this.stratumV1JobsService,