"use strict";
var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
    return c > 3 && r && Object.defineProperty(target, key, r), r;
};
var __metadata = (this && this.__metadata) || function (k, v) {
    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
};
var __param = (this && this.__param) || function (paramIndex, decorator) {
    return function (target, key) { decorator(target, key, paramIndex); }
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.SystemConfigService = void 0;
const common_1 = require("@nestjs/common");
const typeorm_1 = require("@nestjs/typeorm");
const system_config_model_1 = require("../../../model/system_config.model");
const typeorm_2 = require("typeorm");
const cache_manager_1 = require("@nestjs/cache-manager");
const common_2 = require("@nestjs/common");
const lock_service_1 = require("./lock.service");
const SYSTEM_CONFIG_KEY = 'system:config';
const LOAD_LOCK_KEY = 'system:config:load_lock';
let SystemConfigService = class SystemConfigService {
    systemConfigRepos;
    cacheManager;
    distributedLockService;
    loadPromises = new Map();
    constructor(systemConfigRepos, cacheManager, distributedLockService) {
        this.systemConfigRepos = systemConfigRepos;
        this.cacheManager = cacheManager;
        this.distributedLockService = distributedLockService;
    }
    async readConfig() {
        const cached = await this.cacheManager.get(SYSTEM_CONFIG_KEY);
        if (cached) {
            return cached;
        }
        if (this.loadPromises.has(LOAD_LOCK_KEY)) {
            return this.loadPromises.get(LOAD_LOCK_KEY);
        }
        const promise = this.distributedLockService.withLock(LOAD_LOCK_KEY, async () => {
            const retry = await this.cacheManager.get(SYSTEM_CONFIG_KEY);
            if (retry) {
                return retry;
            }
            const config = await this.systemConfigRepos
                .createQueryBuilder('c')
                .where({ id: (0, typeorm_2.MoreThan)(0) })
                .getOneOrFail();
            await this.cacheManager.set(SYSTEM_CONFIG_KEY, config);
            return config;
        }, {
            ttl: 3000,
            maxRetries: 3,
            retryDelay: 200,
            fallback: async () => {
                for (let i = 0; i < 10; i++) {
                    const cached = await this.cacheManager.get(SYSTEM_CONFIG_KEY);
                    if (cached) {
                        return cached;
                    }
                    await new Promise((resolve) => setTimeout(resolve, 200));
                }
                const config = await this.systemConfigRepos
                    .createQueryBuilder('c')
                    .where({ id: (0, typeorm_2.MoreThan)(0) })
                    .getOneOrFail();
                await this.cacheManager.set(SYSTEM_CONFIG_KEY, config);
                return config;
            },
        });
        this.loadPromises.set(LOAD_LOCK_KEY, promise);
        return promise;
    }
    async updateConfig(partial) {
        const config = await this.systemConfigRepos
            .createQueryBuilder('c')
            .where({ id: (0, typeorm_2.MoreThan)(0) })
            .getOne();
        if (!config) {
            throw new Error('系统配置不存在');
        }
        Object.assign(config, partial);
        await this.systemConfigRepos.save(config);
        await this.cacheManager.set(SYSTEM_CONFIG_KEY, config);
        return config;
    }
};
exports.SystemConfigService = SystemConfigService;
exports.SystemConfigService = SystemConfigService = __decorate([
    (0, common_1.Injectable)(),
    __param(0, (0, typeorm_1.InjectRepository)(system_config_model_1.SystemConfigModel)),
    __param(1, (0, common_2.Inject)(cache_manager_1.CACHE_MANAGER)),
    __metadata("design:paramtypes", [typeorm_2.Repository, Object, lock_service_1.DistributedLockService])
], SystemConfigService);
//# sourceMappingURL=system_config.service.js.map