From de4e52d1004f3a68bd8a863d3a507dc252f20cea Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Thu, 7 Jul 2016 15:52:04 +0300
Subject: reorganize project, part 3

---
 src/main/java/com/juick/ws/WebsocketComponent.java | 140 ---------------------
 1 file changed, 140 deletions(-)
 delete mode 100644 src/main/java/com/juick/ws/WebsocketComponent.java

(limited to 'src/main/java/com/juick/ws/WebsocketComponent.java')

diff --git a/src/main/java/com/juick/ws/WebsocketComponent.java b/src/main/java/com/juick/ws/WebsocketComponent.java
deleted file mode 100644
index e87b96a5..00000000
--- a/src/main/java/com/juick/ws/WebsocketComponent.java
+++ /dev/null
@@ -1,140 +0,0 @@
-package com.juick.ws;
-
-import com.juick.User;
-import com.juick.server.MessagesQueries;
-import com.juick.server.UserQueries;
-import org.apache.http.NameValuePair;
-import org.apache.http.client.utils.URLEncodedUtils;
-import org.springframework.http.HttpHeaders;
-import org.springframework.jdbc.core.JdbcTemplate;
-import org.springframework.stereotype.Component;
-import org.springframework.web.socket.CloseStatus;
-import org.springframework.web.socket.WebSocketSession;
-import org.springframework.web.socket.handler.TextWebSocketHandler;
-
-import javax.inject.Inject;
-import java.io.IOException;
-import java.net.URI;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-/**
- * Created by vitalyster on 28.06.2016.
- */
-@Component
-public class WebsocketComponent extends TextWebSocketHandler {
-
-    @Inject
-    JdbcTemplate jdbc;
-
-    private static final Logger logger = Logger.getLogger(WebsocketComponent.class.getName());
-    final List<SocketSubscribed> clients = Collections.synchronizedList(new ArrayList<SocketSubscribed>());
-
-    @Override
-    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
-        URI hLocation;
-        String hXRealIP = "";
-
-        hLocation = session.getUri();
-        HttpHeaders headers = session.getHandshakeHeaders();
-        hXRealIP = headers.getOrDefault("X-Real-IP",
-                Collections.singletonList(session.getRemoteAddress().toString())).get(0);
-
-        // Auth
-        User visitor = new User();
-        List<NameValuePair> params = URLEncodedUtils.parse(hLocation, "UTF-8");
-        for (NameValuePair param : params) {
-            if (param.getName().equals("hash")) {
-                String hash = param.getValue();
-                if (hash.length() == 16) {
-                    visitor = UserQueries.getUserByHash(jdbc, hash);
-                } else {
-                    try {
-                        logger.info(String.format("wrong hash for %d from %s", visitor.getUID(), hXRealIP));
-                        session.close(new CloseStatus(403, "Forbidden"));
-                    } catch (IOException e) {
-                        logger.log(Level.WARNING, "ws error", e);
-                    }
-                }
-                break;
-            }
-        }
-        logger.info(String.format("user %d connected to %s from %s", visitor.getUID(), hLocation.getPath(), hXRealIP));
-
-        int MID = 0;
-        SocketSubscribed sockSubscr = null;
-        if (hLocation.getPath().equals("/")) {
-            logger.info(String.format("user %d connected", visitor.getUID()));
-            sockSubscr = new SocketSubscribed(session, hXRealIP, visitor, false);
-        } else if (hLocation.getPath().equals("/_all")) {
-            logger.info(String.format("user %d connected to legacy _all (%s)", visitor.getUID(), hLocation.getPath()));
-            sockSubscr = new SocketSubscribed(session, hXRealIP, visitor, true);
-            sockSubscr.allMessages = true;
-        } else if (hLocation.getPath().equals("/_replies")) {
-            logger.info(String.format("user %d connected to legacy _replies (%s)", visitor.getUID(), hLocation.getPath()));
-            sockSubscr = new SocketSubscribed(session, hXRealIP, visitor, true);
-            sockSubscr.allReplies = true;
-        } else if (hLocation.getPath().matches("/\\d+$")) {
-            try {
-                MID = Integer.parseInt(hLocation.getPath().substring(1));
-            } catch (Exception e) {
-            }
-            if (MID > 0) {
-                if (MessagesQueries.canViewThread(jdbc, MID, visitor.getUID())) {
-                    logger.info(String.format("user %d connected to legacy thread (%d) from %s", visitor.getUID(), MID, hXRealIP));
-                    sockSubscr = new SocketSubscribed(session, hXRealIP, visitor, true);
-                    sockSubscr.MID = MID;
-                } else {
-                    try {
-                        session.close(new CloseStatus(403, "Forbidden"));
-                    } catch (IOException e) {
-                        logger.log(Level.WARNING, "ws error", e);
-                    }
-                }
-            }
-        }
-        if (sockSubscr != null) {
-            synchronized (clients) {
-                clients.add(sockSubscr);
-                logger.info(clients.size() + " clients connected");
-            }
-        }
-    }
-    @Override
-    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
-        synchronized (clients) {
-            clients.removeIf(c -> {
-                if (c.session.getId().equals(session.getId())) {
-                    logger.info(String.format("session from %s closed with status %d", c.clientName, status.getCode()));
-                    return true;
-                }
-                return false;
-            });
-            logger.info(clients.size() + " clients connected");
-        }
-
-    }
-    class SocketSubscribed {
-
-        WebSocketSession session;
-        String clientName;
-        User visitor;
-        int MID;
-        boolean allMessages;
-        boolean allReplies;
-        long tsConnected;
-        long tsLastData;
-        boolean legacy;
-
-        public SocketSubscribed(WebSocketSession session, String clientName, User visitor, boolean legacy) {
-            this.session = session;
-            this.clientName = clientName;
-            this.visitor = visitor;
-            tsConnected = tsLastData = System.currentTimeMillis();
-            this.legacy = legacy;
-        }
-    }
-}
-- 
cgit v1.2.3