フェデレーションインスタンスキャッシュ無効化機能#

if (ps.isSuspended == null && ps.moderationNote == null) {
    await this.federatedInstanceService.invalidate(normalizedHost);
    return;
}

public async invalidate(host: string): Promise<void> {
    const normalizedHost = this.utilityService.normalizeHost(host);
    await this.federatedInstanceCache.delete(normalizedHost);
}

public normalizeHost(host: string): string {
    return punycode.toASCII(host.toLowerCase());
}

public async fetchOrRegister(host: string): Promise<MiInstance> {
    host = this.utilityService.normalizeHost(host);

    const cached = await this.federatedInstanceCache.get(host);
    if (cached) return cached;

    const index = await this.instancesRepository.findOneBy({ host });
    // ... インスタンスの作成または更新
}

public async update(id: MiInstance['id'], data: Partial<MiInstance>): Promise<void> {
    const result = await this.instancesRepository.createQueryBuilder().update()
        .set(data)
        .where('id = :id', { id })
        .returning('*')
        .execute()
        .then((response) => response.raw[0]);

    this.federatedInstanceCache.set(result.host, result);
}

public async fetch(host: string): Promise<MiInstance | null> {
    host = this.utilityService.normalizeHost(host);

    const cached = await this.federatedInstanceCache.get(host);
    if (cached !== undefined) return cached;

    // キャッシュにない場合のみデータベースをクエリ
    const index = await this.instancesRepository.findOneBy({ host });
    // ...
}

const isSuspendedBefore = instance.suspensionState !== 'none';
const suspensionState = (ps.isSuspended != null && isSuspendedBefore !== ps.isSuspended)
    ? (ps.isSuspended ? 'manuallySuspended' : 'none')
    : undefined;

// 値が実際に変更された場合のみログを記録
if (ps.isSuspended != null && isSuspendedBefore !== ps.isSuspended) {
    // ... モデレーションログエントリを作成
}

if (!force) {
    const _instance = await this.federatedInstanceService.fetchOrRegister(host);
    const now = Date.now();
    if (_instance && _instance.infoUpdatedAt && (now - _instance.infoUpdatedAt.getTime() < 1000 * 60 * 60 * 24)) {
        return; // 冗長な取得をスキップ
    }
}

public collapseUpdateInstanceJobs(oldJob: UpdateInstanceJob, newJob: UpdateInstanceJob) {
    const latestRequestReceivedAt = oldJob.latestRequestReceivedAt < newJob.latestRequestReceivedAt
        ? newJob.latestRequestReceivedAt
        : oldJob.latestRequestReceivedAt;
    const shouldUnsuspend = oldJob.shouldUnsuspend || newJob.shouldUnsuspend;
    return {
        latestRequestReceivedAt,
        shouldUnsuspend,
    };
}

if (i.isNotResponding) {
    this.federatedInstanceService.update(i.id, {
        isNotResponding: false,
        notRespondingSince: null,
    });
}