Software/platform
1
1
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases Wiki Activity

Standards domain models shuffling and renaming

Browse Source
This commit is contained in:
Dominic Ferrando
2026-07-04 13:36:49 -04:00
parent 448cabcb31
commit 9e1025e119
7 changed files with 92 additions and 93 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/api/src/services/calculator.ts
+31 -32
View File
@@ -1,40 +1,39 @@
import { LevelCalculator, Standards, DEFAULT_STANDARDS_DATA, type StandardsConfig, StandardsConfigSchema } from "@blade-and-brawn/calculator";
import { LevelCalculator, Standards, DEFAULT_STANDARDS_DATA, type StandardsParameters, StandardsParametersSchema } from "@blade-and-brawn/calculator";
import type { ActivityPerformance, Player } from "@blade-and-brawn/domain";
import { db } from "../database/db";
import { Value } from "@sinclair/typebox/value";
import { log } from "../util";
export class CalculatorService {
private static readonly CONFIG_REFRESH_INTERVAL_MS = 30_000;
let calculator = new LevelCalculator(new Standards(DEFAULT_STANDARDS_DATA));
export class CalculatorService {
standards: StandardsSubService = new StandardsSubService();
calculate(player: Player, activityPerformances: ActivityPerformance[]) {
this.standards.refreshConfig({ onlyIfStale: true }).catch((err) => log.error({ err }, "failed to refresh standards config"));
return calculator.calculate(player, activityPerformances);
}
}
class StandardsSubService {
private static readonly CONFIG_REFRESH_INTERVAL_MS = 30_000;
private cachedStandardsConfigData: string | null = null;
private lastRefreshedAt = 0;
private calculator: LevelCalculator;
constructor() {
this.calculator = new LevelCalculator(new Standards(DEFAULT_STANDARDS_DATA));
}
calculate(player: Player, activityPerformances: ActivityPerformance[]) {
this.refreshConfig({ onlyIfStale: true }).catch((err) => log.error({ err }, "failed to refresh calculator config"));
return this.calculator.calculate(player, activityPerformances);
}
async getSelectedConfig(opt: { skipCache?: boolean } = {}): Promise<StandardsConfig> {
if (!opt.skipCache) return this.calculator.standards.cfg;
async getSelectedConfig(opt: { skipCache?: boolean } = {}): Promise<StandardsParameters> {
if (!opt.skipCache) return calculator.standards.params;
await this.refreshConfig();
return this.calculator.standards.cfg;
return calculator.standards.params;
}
async selectConfig(id: string) {
await db.transaction().execute(async (trx) => {
await trx.updateTable("calculator_configs")
await trx.updateTable("standards_configs")
.set({ is_selected: false })
.where("is_selected", "=", true)
.execute();
const result = await trx.updateTable("calculator_configs")
const result = await trx.updateTable("standards_configs")
.set({ is_selected: true })
.where("id", "=", id)
.execute();
@@ -42,37 +41,37 @@ export class CalculatorService {
});
}
async setConfig(id: string, standardsConfig: StandardsConfig) {
const result = await db.updateTable("calculator_configs")
.set({ standards_config: standardsConfig })
async setConfig(id: string, parameters: StandardsParameters) {
const result = await db.updateTable("standards_configs")
.set({ parameters })
.where("id", "=", id)
.execute();
if (result[0]?.numUpdatedRows === 0n) throw new Error(`No config with id "${id}"`);
}
async createConfig(standardsConfig: StandardsConfig) {
await db.insertInto("calculator_configs")
.values({ standards_config: standardsConfig })
async createConfig(parameters: StandardsParameters) {
await db.insertInto("standards_configs")
.values({ parameters })
.execute();
}
async refreshConfig(opt: { onlyIfStale?: boolean } = {}) {
if (opt.onlyIfStale)
if (Date.now() - this.lastRefreshedAt < CalculatorService.CONFIG_REFRESH_INTERVAL_MS) return;
if (Date.now() - this.lastRefreshedAt < StandardsSubService.CONFIG_REFRESH_INTERVAL_MS) return;
this.lastRefreshedAt = Date.now();
const result = await db.selectFrom("calculator_configs")
.select(["standards_config"])
const { parameters } = await db.selectFrom("standards_configs")
.select(["parameters"])
.where("is_selected", "=", true)
.limit(1)
.executeTakeFirstOrThrow({ errorConstructor: () => new Error("No calculator config selected") });
Value.Assert(StandardsConfigSchema, result.standards_config);
.executeTakeFirstOrThrow({ errorConstructor: () => new Error("No standards config selected") });
Value.Assert(StandardsParametersSchema, parameters);
const standardsConfigData = JSON.stringify(result.standards_config);
const standardsConfigData = JSON.stringify(parameters);
if (standardsConfigData === this.cachedStandardsConfigData) return;
this.calculator = new LevelCalculator(new Standards(DEFAULT_STANDARDS_DATA, result.standards_config));
calculator = new LevelCalculator(new Standards(DEFAULT_STANDARDS_DATA, parameters));
this.cachedStandardsConfigData = standardsConfigData;
}
}