package com.ard.vtdu.client;

import com.ard.vtdu.config.MediamtxConfig;
import com.dtflys.forest.http.ForestRequest;
import com.dtflys.forest.interceptor.ForestInterceptor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.util.Base64;

/**
 * 这个拦截器暂时先不使用，需要时在启用
 * 用于mediaMtx流媒体接口安全请求
 *
 * @author lsy
 * @date 2025/10/16
 */

@Component
@Slf4j
public class MediamtxAuthInterceptor implements ForestInterceptor {

    /**
     * 该方法在请求发送之前被调用, 若返回false则不会继续发送请求
     *
     * @Param request Forest请求对象
     */
    @Override
    public boolean beforeExecute(ForestRequest req) {
        try {

            String username = "admin";
            String password = "mypass";
            //对应mediamtx.yml
            //- user: argon2:$argon2id$v=19$m=4096,t=3,p=1$c2FsdEl0V2l0aFNhbHQ$Mi4H+feNHQk/E0sm46PEz3dnHPTzZMNWV5LVdDD/4SI
            //  pass: argon2:$argon2id$v=19$m=4096,t=3,p=1$c2FsdEl0V2l0aFNhbHQ$5VEdlOBG/er50vvc4GZO4uA3juhk/uvUzYOzTMv6RiQ

            // 拼接用户名和密码
            String authString = username + ":" + password;

            // Base64 编码
            String encodedAuth = Base64.getEncoder().encodeToString(authString.getBytes());

            // 最终的 Authorization 头
            String authorizationHeader = "Basic " + encodedAuth;

            log.debug("Authorization header: " + authorizationHeader);
            req.addHeader("Authorization", authorizationHeader);
        } catch (Exception e) {
            log.error("TokenInterceptor 处理异常:{}", e.getMessage());
            return false;
        }
        return true;
    }
}