package com.juick.components.service;

import com.juick.service.component.DisconnectedEvent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.client.WebSocketConnectionManager;

import javax.annotation.Nonnull;
import javax.inject.Inject;

@Component
public class JuickServerReconnectManager implements ApplicationListener<DisconnectedEvent> {
    private static Logger logger = LoggerFactory.getLogger(JuickServerReconnectManager.class);
    @Inject
    private WebSocketConnectionManager webSocketConnectionManager;
    @Override
    public void onApplicationEvent(@Nonnull DisconnectedEvent event) {
        logger.info("retrying...");
        webSocketConnectionManager.stop();
        webSocketConnectionManager.start();
    }
}