insert optimizations

This commit is contained in:
Ben Wilson 2023-08-03 23:01:15 -04:00
parent 726b906071
commit 3debb2e3c9
3 changed files with 15 additions and 2 deletions

View File

@ -21,6 +21,17 @@ export class ClientService {
return await this.clientRepository.save(client);
}
public async insert(partialClient: Partial<ClientEntity>): Promise<ClientEntity> {
const insertResult = await this.clientRepository.insert(partialClient);
const client = {
...partialClient,
...insertResult.generatedMaps[0]
};
return client as ClientEntity;
}
public async delete(sessionId: string) {
return await this.clientRepository.softDelete({ sessionId });
}
@ -87,4 +98,5 @@ export class ClientService {
.getRawMany();
return result;
}
}

View File

@ -40,7 +40,7 @@ const ORMModules = [
cache: true,
logging: false,
enableWAL: true,
busyTimeout: 60 * 1000
busyErrorRetry: 60 * 1000
}),
CacheModule.register(),
ScheduleModule.forRoot(),

View File

@ -280,12 +280,13 @@ export class StratumV1Client extends EasyUnsubscribe {
this.entity = await this.clientService.save({
this.entity = await this.clientService.insert({
sessionId: this.extraNonceAndSessionId,
address: this.clientAuthorization.address,
clientName: this.clientAuthorization.worker,
userAgent: this.clientSubscription.userAgent,
startTime: new Date(),
bestDifficulty: 0
});
this.stratumV1JobsService.newMiningJob$.pipe(