package com.battery.device.bts;

import java.nio.file.Path;
import java.time.Duration;
import java.time.ZoneId;
import java.util.Map;
import com.battery.device.api.DeviceAdapter;
import com.battery.device.api.DeviceAdapterException;
import com.battery.device.api.credentials.LocalCredentials;
import com.battery.device.api.registry.AdapterInstanceConfig;
import com.battery.device.api.registry.DeviceAdapterFactory;

/**
 * 按存储形态 {@code NEWARE_BTS} 构造**直连新威对外接口**的只读适配器实例（ADR-0068）。
 *
 * <p>与 {@code NEWARE_MYSQL}（直连厂商库）并列：这台机器能不能远程取数，取决于它的上位机形态，
 * 而不是厂商。8.0 形态的库内没有逐点数据，所以它的逐点只能从接口的 {@code download} 取。
 *
 * <p><b>为什么口令不进数据库</b>：这里要的是那台机器的**本地管理员口令**——它和厂商库口令一样是来源凭据，
 * 因此共用同一套取值顺序（本地凭据文件 → 同名环境变量 → 同名 JVM 启动参数，见
 * {@link LocalCredentials}），{@code source_config} 里只放变量名。三者都没有时装配失败，
 * 错误信息同时点名文件路径与变量名，使"忘了放口令"是可见的失败而不是沉默的缺失。
 *
 * <p>本类不缓存实例：实例由 {@code DeviceAdapterRegistry} 持有并按实例串行执行。
 */
public final class NewareBtsAdapterFactory implements DeviceAdapterFactory
{
    /** 实例配置里承载"本机管理员账号变量名"的键。 */
    public static final String USER_ENV_OPTION = "userEnv";
    /** 实例配置里承载"本机管理员口令变量名"的键。 */
    public static final String PASSWORD_ENV_OPTION = "passwordEnv";
    public static final String DEFAULT_USER_ENV = "NEWARE_WIN_USER";
    /** 建 SMB 会话是本地进程操作，超时给短一些：卡住也没有数据可取。 */
    private static final Duration SESSION_TIMEOUT = Duration.ofSeconds(10);
    /** 读应答超时；{@code download} 一页上千行在 SMB 上会慢一些，但远不到这个量级。 */
    private static final Duration RESPONSE_TIMEOUT = Duration.ofSeconds(60);
    /** 凭据文件相对进程工作目录定位，使开发（仓库根）与交付（应用目录）用同一个位置。 */
    static final Path CREDENTIALS_FILE = LocalCredentials.DEFAULT_FILE;

    /** 返回本形态的适配器类型标识 {@code NEWARE_BTS}。 */
    @Override
    public String adapterType()
    {
        return NewareBtsAdapter.ADAPTER_TYPE;
    }

    /** 从实例配置取账号与口令来源，装配远程命名管道传输与报文编解码器。 */
    @Override
    public DeviceAdapter create(AdapterInstanceConfig config)
    {
        Map<String, String> sourceConfig = config.sourceConfig();
        String user = LocalCredentials.resolve(option(sourceConfig, USER_ENV_OPTION, DEFAULT_USER_ENV),
                CREDENTIALS_FILE.toAbsolutePath(), System.getenv(), System::getProperty);
        String password = LocalCredentials.resolve(required(sourceConfig, PASSWORD_ENV_OPTION),
                CREDENTIALS_FILE.toAbsolutePath(), System.getenv(), System::getProperty);
        NewareBtsPipeTransport transport = new NewareBtsPipeTransport(config.host(), user, password,
                SESSION_TIMEOUT, RESPONSE_TIMEOUT);
        return new NewareBtsAdapter(config.adapterCode(), transport,
                new BtsXmlCodec(config.adapterCode(), ZoneId.of(config.timezoneId())), config.capabilities());
    }

    private static String option(Map<String, String> sourceConfig, String key, String fallback)
    {
        String value = sourceConfig.get(key);
        return value == null || value.isBlank() ? fallback : value.trim();
    }

    /** 口令变量名没有缺省值：五台机器的口令实测有两种，猜一个就会连错机器。 */
    private static String required(Map<String, String> sourceConfig, String key)
    {
        String value = option(sourceConfig, key, null);
        if (value == null) throw new DeviceAdapterException("新威 BTS 实例缺少配置项 " + key
                + "（本机管理员口令的变量名）：口令有两种取值，不能有缺省");
        return value;
    }
}