/* * Juick * Copyright (C) 2008-2011, Ugnich Anton * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . */ package com.juick.www.controllers; import com.juick.Message; import com.juick.server.helpers.TagStats; import com.juick.server.util.HttpNotFoundException; import com.juick.service.MessagesService; import com.juick.service.TagService; import com.juick.service.UserService; import com.juick.util.MessageUtils; import com.juick.util.UserUtils; import com.juick.www.WebApp; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.ExceptionHandler; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import javax.inject.Inject; import javax.servlet.ServletException; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.PrintWriter; import java.util.ArrayList; import java.util.List; /** * * @author Ugnich Anton */ @Controller public class UserThread { @Inject WebApp webApp; @Inject MessagesService messagesService; @Inject UserService userService; @Inject TagService tagService; @Inject PageTemplates templates; @GetMapping("/{uname}/{mid}") protected void doGetThread(HttpServletRequest request, HttpServletResponse response, @PathVariable String uname, @PathVariable int mid) throws ServletException, IOException { com.juick.User visitor = UserUtils.getCurrentUser(); if (!messagesService.canViewThread(mid, visitor.getUid())) { response.sendError(HttpServletResponse.SC_FORBIDDEN); return; } com.juick.Message msg = messagesService.getMessage(mid); if (msg == null || msg.getUser().isBanned()) { throw new HttpNotFoundException(); } com.juick.User user = userService.getUserByName(uname); if (user.getUid() == 0 || !msg.getUser().equals(user)) { response.sendRedirect(String.format("/%s/%d", msg.getUser().getName(), mid)); return; } boolean listview = false; String paramView = request.getParameter("view"); if (paramView != null) { if (paramView.equals("list")) { listview = true; if (visitor.getUid() > 0) { userService.setUserOptionInt(visitor.getUid(), "repliesview", 1); } } else if (paramView.equals("tree") && visitor.getUid() > 0) { userService.setUserOptionInt(visitor.getUid(), "repliesview", 0); } } else if (visitor.getUid() > 0 && userService.getUserOptionInt(visitor.getUid(), "repliesview", 0) == 1) { listview = true; } String title = msg.getUser().getName() + ": " + msg.getTagsString(); response.setContentType("text/html; charset=UTF-8"); try (PrintWriter out = response.getWriter()) { String headers = ""; if (paramView != null) { headers += ""; } if (msg.Hidden) { headers += ""; } templates.pageHead(out, visitor, title, headers); templates.pageNavigation(out, visitor, null); out.println("
"); printMessage(out, msg, visitor); printReplies(out, msg, visitor, listview); out.println("
"); templates.pageFooter(request, out, visitor, false); templates.pageEnd(out); } } // when message id is not fit to int @ExceptionHandler(NumberFormatException.class) public ResponseEntity notfound() { return new ResponseEntity<>(HttpStatus.NOT_FOUND); } public com.juick.Message printMessage(PrintWriter out, com.juick.Message msg, com.juick.User visitor) { msg.VisitorCanComment = visitor.getUid() > 0; List tags = tagService.getMessageTags(msg.getMid()); String tagsStr = templates.formatTags(tags); if (msg.ReadOnly) { tagsStr += "readonly"; msg.VisitorCanComment = false; } if (msg.getPrivacy() < 0) { tagsStr += "friends"; } String txt; if (msg.getTags().stream().anyMatch(t -> t.getName().equals("code"))) { txt = MessageUtils.formatMessageCode(msg.getText()); } else { txt = MessageUtils.formatMessage(msg.getText()); } if (!tags.isEmpty()) { tagsStr = "
" + tagsStr + "
"; } out.println("
    "); out.println("
  • "); out.println("
    "); out.println("
    "); out.println("
    " + templates.formatJSLocalTime(msg.getDate()) + "
    "); out.println("
    \""
    "); out.println(" "); out.println("
    " + txt + "
    "); if (msg.getAttachmentType() != null) { out.println("
    \"\"/
    "); } boolean visitorInBL = false; if (visitor.getUid() > 0) { if (visitor.getUid() == msg.getUser().getUid()) { msg.VisitorCanComment = true; } else { visitorInBL = userService.isInBL(msg.getUser().getUid(), visitor.getUid()); if (visitorInBL) { msg.VisitorCanComment = false; } } } if (msg.VisitorCanComment && !messagesService.isReadonly()) { out.println("
    "); out.println("
    "); out.println("
    "); } List recomm = messagesService.getMessageRecommendations(msg.getMid()); if (!recomm.isEmpty()) { out.print("
    Рекомендовали (" + recomm.size() + "): "); for (int i = 0; i < recomm.size(); i++) { if (i > 0) { out.print(", "); } out.print("@" + recomm.get(i) + ""); } out.println("
    "); } out.println("
    "); out.println("
  • "); out.println("
  • "); out.println("
"); return msg; } public void printReplies(PrintWriter out, com.juick.Message msg, com.juick.User visitor, boolean listview) { List replies = messagesService.getReplies(msg.getMid()); List blUIDs = new ArrayList(); for (int i = 0; i < replies.size(); i++) { com.juick.Message reply = replies.get(i); if (reply.getUser().getUid() != msg.getUser().getUid() && !blUIDs.contains(reply.getUser().getUid())) { blUIDs.add(reply.getUser().getUid()); } if (reply.getReplyto() > 0) { boolean added = false; for (int n = 0; n < replies.size(); n++) { if (replies.get(n).getRid() == reply.getReplyto()) { replies.get(n).childs.add(reply); added = true; break; } } if (!added) { reply.setReplyto(0); } } } if (!replies.isEmpty()) { if (visitor.getUid() > 0 && msg.getUser().getUid() == visitor.getUid()) { for (Message reply : replies) { reply.VisitorCanComment = true; } } else if (visitor.getUid() > 0 && msg.VisitorCanComment) { blUIDs = userService.checkBL(visitor.getUid(), blUIDs); for (Message reply : replies) { reply.VisitorCanComment = reply.getUser().getUid() == visitor.getUid() || !blUIDs.contains(reply.getUser().getUid()); } } else { for (Message reply : replies) { reply.VisitorCanComment = false; } } boolean foldable = false; if (replies.size() > 10) { for (int i = 0; i < replies.size() - 1; i++) { if (replies.get(i).getChildsCount() > 1) { foldable = true; break; } } } out.println("
"); out.print("
"); if (listview) { out.print("Показать деревом"); } else { if (foldable) { out.print("Раскрыть все · "); } out.print("Показать списком"); } out.print("
"); out.println("

Ответы (" + replies.size() + ")

"); out.println("
"); out.println("
    "); if (listview) { printList(out, replies, visitor); } else { printTree(out, replies, visitor, 0, 0, false); } out.println("
"); for (Message reply : replies) { reply.cleanupChilds(); } replies.clear(); } } public void printTree(PrintWriter out, List replies, com.juick.User visitor, int ReplyTo, int margin, boolean hidden) { if (margin > 240) { margin = 240; } for (int i = 0; i < replies.size(); i++) { com.juick.Message msg = replies.get(i); if (msg.getReplyto() == ReplyTo) { out.print("
  • 0) { out.print("margin-left: " + margin + "px;"); } if (hidden) { out.print("display:none;"); } out.println("\">"); out.println("
    "); out.println("
    "); if (!msg.getUser().isBanned()) { out.println(" @" + msg.getUser().getName() + ":"); out.println("
    \""
    "); } else { out.println(" [удалено]:"); out.println("
    "); } out.println("
    "); out.println(" "); out.println("
    "); out.println("
    " + MessageUtils.formatMessage(msg.getText()) + "
    "); if (msg.getAttachmentType() != null) { out.println("
    \"\"/
    "); } out.print("
    /" + msg.getRid()); if (msg.getReplyto() > 0) { out.print(" в ответ на /" + msg.getReplyto() + ""); } if (msg.VisitorCanComment && !messagesService.isReadonly()) { out.println(" · Ответить
    "); out.println("
    "); } else if (visitor.getUid() == 0) { out.println(" · Ответить
    "); } int childs = msg.getChildsCount(); if (ReplyTo == 0 && childs > 1 && replies.size() > 10) { out.println(" "); } out.println(" "); out.println("
  • "); if (ReplyTo == 0 && childs > 1 && replies.size() > 10) { printTree(out, msg.childs, visitor, msg.getRid(), margin + 20, true); } else if (childs > 0) { printTree(out, msg.childs, visitor, msg.getRid(), margin + 20, hidden); } } } } public void printList(PrintWriter out, List replies, com.juick.User visitor) { for (Message msg : replies) { out.print("
  • "); out.println("
    "); out.println("
    "); if (!msg.getUser().isBanned()) { out.println(" @" + msg.getUser().getName() + ":"); out.println("
    \""
    "); } else { out.println(" [удалено]:"); out.println("
    "); } out.println("
    "); out.println(" "); out.println("
    "); out.println("
    " + MessageUtils.formatMessage(msg.getText()) + "
    "); if (msg.getAttachmentType() != null) { out.println("
    \"\"/
    "); } out.print("
    /" + msg.getRid()); if (msg.getReplyto() > 0) { out.print(" в ответ на /" + msg.getReplyto() + ""); } if (msg.VisitorCanComment && !messagesService.isReadonly()) { out.println(" · Ответить
    "); out.println("
    "); } else if (visitor.getUid() == 0) { out.println(" "); } out.println("
    "); out.println("
  • "); } } }