package org.egl_cepgl.pm.config.websocket;

import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.egl_cepgl.pm.dto.ChatMessage;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
//import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.stereotype.Controller;
//import org.springframework.web.socket.config.annotation.*;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.logging.SocketHandler;

//@Slf4j
//@EnableWebFlux
//@Configuration
//public class WebSocketConfig
//{
//    @Bean
//    public SimpleUrlHandlerMapping simpleUrlHandlerMapping(WebSocketHandler wsh)
//    {
//        Map<String, WebSocketHandler> urlMap = new HashMap<>();
//        urlMap.put("/ws/chat", wsh);
//        SimpleUrlHandlerMapping handlerMapping = new SimpleUrlHandlerMapping();
//        handlerMapping.setUrlMap(urlMap);
//        handlerMapping.setOrder(1);
//        return handlerMapping;
//    }
//
//    @Bean
//    public WebSocketService webSocketService() {
//        return new HandshakeWebSocketService();
//    }
//
//    @Bean
//    public WebSocketHandlerAdapter webSocketHandlerAdapter(){
//        return new WebSocketHandlerAdapter(webSocketService());
//    }
//
//    @Bean
//    public Sinks.Many<ChatMessage> sink(){
//        return Sinks.many().replay().all();
//    }
//}