feat: 메인 시계를 턴 엔진 상태로 표시한다
This commit is contained in:
@@ -0,0 +1,63 @@
|
||||
import { gatewayProfileCapabilities } from '@sammo-ts/common';
|
||||
|
||||
import type { ProfileStatusSource } from '../auth/profileStatusSource.js';
|
||||
|
||||
interface TurnDaemonLeaseSource {
|
||||
turnDaemonLease: {
|
||||
findUnique(input: {
|
||||
where: { profile: string };
|
||||
select: { leaseUntil: true };
|
||||
}): Promise<{ leaseUntil: Date } | null>;
|
||||
};
|
||||
}
|
||||
|
||||
export const loadTurnEngineRunning = async (
|
||||
source: ProfileStatusSource | undefined,
|
||||
db: TurnDaemonLeaseSource,
|
||||
profileName: string,
|
||||
now = new Date()
|
||||
): Promise<boolean | null> => {
|
||||
if (!source) return null;
|
||||
try {
|
||||
const status = await source.get(profileName);
|
||||
if (status === null) return null;
|
||||
if (!gatewayProfileCapabilities(status).turnsRunning) return false;
|
||||
const lease = await db.turnDaemonLease.findUnique({
|
||||
where: { profile: profileName },
|
||||
select: { leaseUntil: true },
|
||||
});
|
||||
return lease !== null && lease.leaseUntil.getTime() > now.getTime();
|
||||
} catch {
|
||||
return null;
|
||||
}
|
||||
};
|
||||
|
||||
export class CachedTurnEngineStatus {
|
||||
private cachedAt = Number.NEGATIVE_INFINITY;
|
||||
private cachedValue: boolean | null = null;
|
||||
private pending: Promise<boolean | null> | null = null;
|
||||
|
||||
constructor(
|
||||
private readonly source: ProfileStatusSource,
|
||||
private readonly db: TurnDaemonLeaseSource,
|
||||
private readonly profileName: string,
|
||||
private readonly cacheMs = 2_000,
|
||||
private readonly now = () => Date.now()
|
||||
) {}
|
||||
|
||||
get(): Promise<boolean | null> {
|
||||
if (this.now() - this.cachedAt < this.cacheMs) {
|
||||
return Promise.resolve(this.cachedValue);
|
||||
}
|
||||
if (this.pending) return this.pending;
|
||||
|
||||
this.pending = loadTurnEngineRunning(this.source, this.db, this.profileName).then((value) => {
|
||||
this.cachedValue = value;
|
||||
this.cachedAt = this.now();
|
||||
return value;
|
||||
});
|
||||
return this.pending.finally(() => {
|
||||
this.pending = null;
|
||||
});
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user