Class OpenAIAdapter

back/src/main/java/com/smarthr/service/ai/OpenAIAdapter.java:23–117

import java.util.Map;

@Slf4j
public class OpenAIAdapter implements AIModelAdapter {

    private static final String MODEL_ID = "openai";
    private static final String MODEL_NAME = "OpenAI";

    private final OpenAIConfig config;
    private final ChatClient chatClient;
    private final EmbeddingModel embeddingModel;

    public OpenAIAdapter(OpenAIConfig config, ChatClient chatClient, EmbeddingModel embeddingModel) {
        this.config = config;
        this.chatClient = chatClient;
        this.embeddingModel = embeddingModel;
        log.info("OpenAIAdapter initialized (enabled: {})", config.isEnabled());
    }

    @Override
    public String getModelId() {
        return MODEL_ID;
    }

    @Override
    public String getModelName() {
        return MODEL_NAME;
    }

    @Override
    public boolean isEnabled() {
        return config.isEnabled();
    }

    @Override
    public String chat(List<Map<String, String>> messages) {
        if (!isEnabled()) {
            throw new IllegalStateException("OpenAI model is not enabled");
        }
        List<Message> aiMessages = convertMessages(messages);
        Prompt prompt = new Prompt(aiMessages);
        String response = chatClient.prompt(prompt).call().content();
        log.debug("OpenAI chat completed, response length: {}", response != null ? response.length() : 0);
        return response;
    }

    @Override
    public Flux<String> stream(List<Map<String, String>> messages) {
        if (!isEnabled()) {
            return Flux.error(new IllegalStateException("OpenAI model is not enabled"));
        }
        List<Message> aiMessages = convertMessages(messages);
        Prompt prompt = new Prompt(aiMessages);
        return chatClient.prompt(prompt).stream().content();
    }

    @Override
    public float[] embed(String text) {
        if (!isEnabled()) {
            throw new IllegalStateException("OpenAI model is not enabled");