This commit is contained in:
Ben Wilson
2023-06-23 16:03:24 -04:00
parent a1d8590055
commit 1e51792b67
3 changed files with 15 additions and 9 deletions
+9 -5
View File
@@ -18,12 +18,13 @@ export class AppController {
getClientInfo(@Param('clientId') clientId: string) {
const workers = this.stratumV1Service.clients.filter(client => client.clientAuthorization.address === clientId);
return {
workers: workers.length,
workerIds: workers.map(worker => {
workersCount: workers.length,
workers: workers.map(worker => {
return {
id: worker.id,
bestDifficulty: worker.statistics.bestDifficulty,
hashrate: worker.statistics.getHashrate()
name: worker.clientAuthorization.worker,
bestDifficulty: Math.floor(worker.statistics.bestDifficulty),
hashRate: Math.floor(worker.statistics.getHashRate()),
}
})
}
@@ -33,7 +34,10 @@ export class AppController {
getWorkerInfo(@Param('clientId') clientId: string, @Param('workerId') workerId: string) {
const worker = this.stratumV1Service.clients.find(client => client.clientAuthorization.address === clientId && client.id === workerId);
return {
id: worker.id
id: worker.id,
name: worker.clientAuthorization.worker,
bestDifficulty: Math.floor(worker.statistics.bestDifficulty),
hashData: worker.statistics.historicSubmissions
}
}
}
+5 -3
View File
@@ -4,8 +4,8 @@ import { FastifyAdapter, NestFastifyApplication } from '@nestjs/platform-fastify
import { AppModule } from './app.module';
async function bootstrap() {
const app = await NestFactory.create<NestFastifyApplication>(AppModule, new FastifyAdapter());
app.setGlobalPrefix('api')
app.useGlobalPipes(
@@ -18,7 +18,9 @@ async function bootstrap() {
);
app.enableCors();
await app.listen(process.env.PORT, '0.0.0.0');
console.log(`http listening on port ${process.env.PORT}`)
await app.listen(process.env.PORT, '0.0.0.0', () => {
console.log(`https listening on port ${process.env.PORT}`);
});
}
bootstrap();
+1 -1
View File
@@ -24,7 +24,7 @@ export class StratumV1ClientStatistics {
}
}
public getHashrate() {
public getHashRate() {
return this.historicSubmissions.reduce((pre, cur, idx, arr) => {
if (idx === 0) {
pre.time = cur.time;