/* * 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.http.www; import org.springframework.jdbc.core.JdbcTemplate; import java.io.BufferedReader; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.URL; import java.net.URLConnection; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.UUID; import javax.servlet.http.Cookie; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.servlet.http.Part; /** * * @author Ugnich Anton */ public class Utils { public static String getCookie(HttpServletRequest request, String name) { Cookie cookies[] = request.getCookies(); if (cookies != null) { for (int i = 0; i < cookies.length; i++) { if (cookies[i].getName().equals(name)) { return cookies[i].getValue(); } } } return null; } public static String receiveMultiPartFile(HttpServletRequest request, String name) throws Exception { String attachmentFName = null; Part filePart = request.getPart("attach"); if (filePart != null) { String partname = Utils.getPartFilename(filePart); if (partname != null && partname.length() > 0) { String attachmentType = partname.substring(partname.length() - 3).toLowerCase(); if (attachmentType.equals("jpg") || attachmentType.equals("peg") || attachmentType.equals("png")) { if (attachmentType.equals("peg")) { attachmentType = "jpg"; } attachmentFName = UUID.randomUUID().toString() + "." + attachmentType; filePart.write("/var/www/juick.com/i/tmp/" + attachmentFName); } else { throw new Exception("Wrong file type"); } } } return attachmentFName; } public static com.juick.User getVisitorUser(JdbcTemplate sql, HttpServletRequest request, HttpServletResponse response) { String hash = getCookie(request, "hash"); if (hash != null) { com.juick.User visitor = com.juick.server.UserQueries.getUserByHash(sql, hash); if (response != null && visitor != null) { response.setHeader("X-Username", visitor.getUName()); } return visitor; } else { return null; } } public static void sendTemporaryRedirect(HttpServletResponse response, String location) { response.setStatus(HttpServletResponse.SC_MOVED_TEMPORARILY); response.setHeader("Location", location); } public static void sendPermanentRedirect(HttpServletResponse response, String location) { response.setStatus(HttpServletResponse.SC_MOVED_PERMANENTLY); response.setHeader("Location", location); } public static String getPartFilename(Part part) { for (String cd : part.getHeader("content-disposition").split(";")) { if (cd.trim().startsWith("filename")) { String filename = cd.substring(cd.indexOf('=') + 1).trim().replace("\"", ""); return filename.substring(filename.lastIndexOf('/') + 1).substring(filename.lastIndexOf('\\') + 1); // MSIE fix. } } return null; } public static void finishSQL(ResultSet rs, Statement stmt) { if (rs != null) { try { rs.close(); } catch (SQLException e) { } } if (stmt != null) { try { stmt.close(); } catch (SQLException e) { } } } public static void replyJSON(HttpServletRequest request, HttpServletResponse response, String json) throws IOException { response.setContentType("application/json; charset=UTF-8"); response.setHeader("Access-Control-Allow-Origin", "*"); String callback = request.getParameter("callback"); if (callback != null && (callback.length() > 64 || !callback.matches("[a-zA-Z0-9\\-\\_]+"))) { callback = null; } PrintWriter out = response.getWriter(); try { if (callback != null) { out.print(callback + "("); out.print(json); out.print(")"); } else { out.print(json); } } finally { out.close(); } } public static String convertArray2String(ArrayList mids) { String q = ""; for (int i = 0; i < mids.size(); i++) { if (i > 0) { q += ","; } q += mids.get(i); } return q; } public static String encodeHTML(String str) { if (str == null) return null; return str.replaceAll("&", "&").replaceAll("<", "<").replaceAll(">", ">").replaceAll("'", "'").replaceAll("\"", """).replaceAll("\n", " "); } public static String encodeSphinx(String str) { return str.replaceAll("@", "\\\\@"); } public static int parseInt(String str, int def) { int ret = def; if (str != null) { try { ret = Integer.parseInt(str); } catch (Exception e) { } } return ret; } public static String fetchURL(String url) { try { URLConnection c = new URL(url).openConnection(); BufferedReader in = new BufferedReader(new InputStreamReader(c.getInputStream())); String inputLine; StringBuilder b = new StringBuilder(); while ((inputLine = in.readLine()) != null) { b.append(inputLine).append("\n"); } in.close(); return b.toString(); } catch (Exception e) { System.err.println("fetchURL: "+e.toString()); return null; } } public static String downloadImage(URL url) throws Exception { String attachmentFName = null; Exception ex = null; InputStream is = null; FileOutputStream fos = null; try { URLConnection urlConn = url.openConnection(); is = urlConn.getInputStream(); String mime = urlConn.getContentType(); String attachmentType; if (mime != null && mime.equals("image/jpeg")) { attachmentType = "jpg"; } else if (mime != null && mime.equals("image/png")) { attachmentType = "png"; } else { throw new Exception("Wrong file type"); } attachmentFName = UUID.randomUUID().toString() + "." + attachmentType; fos = new FileOutputStream("/var/www/juick.com/i/tmp/" + attachmentFName); byte[] buffer = new byte[10240]; int len; while ((len = is.read(buffer)) > 0) { fos.write(buffer, 0, len); } } catch (Exception e) { ex = e; attachmentFName = null; } finally { try { if (is != null) { is.close(); } } finally { if (fos != null) { fos.close(); } } } if (ex != null) { throw ex; } else { return attachmentFName; } } }