diff options
Diffstat (limited to 'subsonic-backend/src/main/java/net')
17 files changed, 0 insertions, 2202 deletions
diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/Util.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/Util.java deleted file mode 100644 index 31a1be71..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/Util.java +++ /dev/null @@ -1,62 +0,0 @@ -package net.sourceforge.subsonic.backend; - -import org.apache.log4j.Logger; -import org.apache.commons.lang.StringUtils; -import org.apache.commons.io.IOUtils; - -import java.io.File; -import java.io.Reader; -import java.io.FileReader; -import java.io.FileNotFoundException; -import java.io.IOException;/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2010 (C) Sindre Mehus - */ - -/** - * @author Sindre Mehus - */ -public class Util { - - private static final File BACKEND_HOME = new File("/var/subsonic-backend"); - private static final Logger LOG = Logger.getLogger(Util.class); - - private Util() { - } - - public static synchronized File getBackendHome() { - if (!BACKEND_HOME.exists() || !BACKEND_HOME.isDirectory()) { - boolean success = BACKEND_HOME.mkdirs(); - if (!success) { - String message = "The directory " + BACKEND_HOME + " does not exist. Please create it and make it writable."; - LOG.error(message); - throw new RuntimeException(message); - } - } - return BACKEND_HOME; - } - - public static String getPassword(String filename) throws IOException { - File pwdFile = new File(getBackendHome(), filename); - Reader reader = new FileReader(pwdFile); - try { - return StringUtils.trimToNull(IOUtils.toString(reader)); - } finally { - IOUtils.closeQuietly(reader); - } - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/IPNController.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/IPNController.java deleted file mode 100644 index f6ced54f..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/IPNController.java +++ /dev/null @@ -1,152 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2009 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.controller; - -import org.apache.log4j.Logger; -import org.apache.http.client.HttpClient; -import org.apache.http.client.ResponseHandler; -import org.apache.http.client.methods.HttpGet; -import org.apache.http.impl.client.DefaultHttpClient; -import org.apache.http.impl.client.BasicResponseHandler; -import org.apache.http.params.HttpConnectionParams; -import org.springframework.web.servlet.ModelAndView; -import org.springframework.web.servlet.mvc.Controller; - -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; -import java.net.URLEncoder; -import java.util.Enumeration; -import java.util.Date; -import java.io.UnsupportedEncodingException; - -import net.sourceforge.subsonic.backend.domain.Payment; -import net.sourceforge.subsonic.backend.dao.PaymentDao; - -/** - * Processes IPNs (Instant Payment Notifications) from PayPal. - * - * @author Sindre Mehus - */ -public class IPNController implements Controller { - - private static final Logger LOG = Logger.getLogger(IPNController.class); - - private static final String PAYPAL_URL = "https://www.paypal.com/cgi-bin/webscr"; - - private PaymentDao paymentDao; - - public ModelAndView handleRequest(HttpServletRequest request, HttpServletResponse response) throws Exception { - try { - - LOG.info("Incoming IPN from " + request.getRemoteAddr()); - - String url = createValidationURL(request); - if (validate(url)) { - LOG.info("Verified payment. " + url); - } else { - LOG.warn("Failed to verify payment. " + url); - } - createOrUpdatePayment(request); - - return null; - } catch (Exception x) { - LOG.error("Failed to process IPN.", x); - throw x; - } - } - - private String createValidationURL(HttpServletRequest request) throws UnsupportedEncodingException { - Enumeration<?> en = request.getParameterNames(); - StringBuilder url = new StringBuilder(PAYPAL_URL).append("?cmd=_notify-validate"); - String encoding = request.getParameter("charset"); - if (encoding == null) { - encoding = "ISO-8859-1"; - } - - while (en.hasMoreElements()) { - String paramName = (String) en.nextElement(); - String paramValue = request.getParameter(paramName); - url.append("&").append(paramName).append("=").append(URLEncoder.encode(paramValue, encoding)); - } - - return url.toString(); - } - - private void createOrUpdatePayment(HttpServletRequest request) { - String item = request.getParameter("item_number"); - if (item == null) { - item = request.getParameter("item_number1"); - } - String paymentStatus = request.getParameter("payment_status"); - String paymentType = request.getParameter("payment_type"); - int paymentAmount = Math.round(new Float(request.getParameter("mc_gross"))); - String paymentCurrency = request.getParameter("mc_currency"); - String txnId = request.getParameter("txn_id"); - String txnType = request.getParameter("txn_type"); - String payerEmail = request.getParameter("payer_email"); - String payerFirstName = request.getParameter("first_name"); - String payerLastName = request.getParameter("last_name"); - String payerCountry = request.getParameter("address_country"); - - Payment payment = paymentDao.getPaymentByTransactionId(txnId); - if (payment == null) { - payment = new Payment(null, txnId, txnType, item, paymentType, paymentStatus, - paymentAmount, paymentCurrency, payerEmail, payerFirstName, payerLastName, - payerCountry, Payment.ProcessingStatus.NEW, new Date(), new Date()); - paymentDao.createPayment(payment); - } else { - payment.setTransactionType(txnType); - payment.setItem(item); - payment.setPaymentType(paymentType); - payment.setPaymentStatus(paymentStatus); - payment.setPaymentAmount(paymentAmount); - payment.setPaymentCurrency(paymentCurrency); - payment.setPayerEmail(payerEmail); - payment.setPayerFirstName(payerFirstName); - payment.setPayerLastName(payerLastName); - payment.setPayerCountry(payerCountry); - payment.setLastUpdated(new Date()); - paymentDao.updatePayment(payment); - } - - LOG.info("Received " + payment); - } - - private boolean validate(String url) throws Exception { - HttpClient client = new DefaultHttpClient(); - HttpConnectionParams.setConnectionTimeout(client.getParams(), 60000); - HttpConnectionParams.setSoTimeout(client.getParams(), 60000); - HttpGet method = new HttpGet(url); - String content; - try { - ResponseHandler<String> responseHandler = new BasicResponseHandler(); - content = client.execute(method, responseHandler); - - LOG.info("Validation result: " + content); - return "VERIFIED".equals(content); - } finally { - client.getConnectionManager().shutdown(); - } - } - - public void setPaymentDao(PaymentDao paymentDao) { - this.paymentDao = paymentDao; - } - -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/MultiController.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/MultiController.java deleted file mode 100644 index cdc1674a..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/MultiController.java +++ /dev/null @@ -1,256 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2009 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.controller; - -import java.io.IOException; -import java.io.PrintWriter; -import java.util.Calendar; -import java.util.Date; -import java.util.Map; -import java.util.HashMap; -import java.util.List; -import java.util.Arrays; - -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; - -import net.sourceforge.subsonic.backend.dao.PaymentDao; -import net.sourceforge.subsonic.backend.service.LicenseGenerator; -import net.sourceforge.subsonic.backend.service.WhitelistGenerator; -import org.apache.log4j.Logger; -import org.apache.commons.lang.exception.ExceptionUtils; -import org.springframework.web.bind.ServletRequestBindingException; -import org.springframework.web.servlet.ModelAndView; -import org.springframework.web.servlet.mvc.multiaction.MultiActionController; -import org.springframework.web.bind.ServletRequestUtils; -import org.springframework.jdbc.core.ColumnMapRowMapper; -import org.springframework.dao.DataAccessException; -import net.sourceforge.subsonic.backend.dao.DaoHelper; -import net.sourceforge.subsonic.backend.Util; -import net.sourceforge.subsonic.backend.service.EmailSession; - -/** - * Multi-controller used for simple pages. - * - * @author Sindre Mehus - */ -public class MultiController extends MultiActionController { - - private static final Logger LOG = Logger.getLogger(RedirectionController.class); - - private static final String SUBSONIC_VERSION = "4.6"; - private static final String SUBSONIC_BETA_VERSION = "4.7.beta2"; - - private static final Date LICENSE_DATE_THRESHOLD; - - private DaoHelper daoHelper; - - private PaymentDao paymentDao; - private WhitelistGenerator whitelistGenerator; - private LicenseGenerator licenseGenerator; - - static { - Calendar calendar = Calendar.getInstance(); - calendar.clear(); - calendar.set(Calendar.YEAR, 2010); - calendar.set(Calendar.MONTH, Calendar.JUNE); - calendar.set(Calendar.DAY_OF_MONTH, 19); - LICENSE_DATE_THRESHOLD = calendar.getTime(); - } - - public ModelAndView version(HttpServletRequest request, HttpServletResponse response) throws Exception { - - String localVersion = request.getParameter("v"); - LOG.info(request.getRemoteAddr() + " asked for latest version. Local version: " + localVersion); - - PrintWriter writer = response.getWriter(); - - writer.println("SUBSONIC_VERSION_BEGIN" + SUBSONIC_VERSION + "SUBSONIC_VERSION_END"); - writer.println("SUBSONIC_FULL_VERSION_BEGIN" + SUBSONIC_VERSION + "SUBSONIC_FULL_VERSION_END"); - writer.println("SUBSONIC_BETA_VERSION_BEGIN" + SUBSONIC_BETA_VERSION + "SUBSONIC_BETA_VERSION_END"); - - return null; - } - - public ModelAndView validateLicense(HttpServletRequest request, HttpServletResponse response) throws Exception { - - String email = request.getParameter("email"); - Long date = ServletRequestUtils.getLongParameter(request, "date"); - - boolean valid = isLicenseValid(email, date); - LOG.info(request.getRemoteAddr() + " asked to validate license for " + email + ". Result: " + valid); - - PrintWriter writer = response.getWriter(); - writer.println(valid); - - return null; - } - - public ModelAndView sendMail(HttpServletRequest request, HttpServletResponse response) throws Exception { - String from = request.getParameter("from"); - String to = request.getParameter("to"); - String subject = request.getParameter("subject"); - String text = request.getParameter("text"); - - EmailSession session = new EmailSession(); - session.sendMessage(from, Arrays.asList(to), null, null, null, subject, text); - - LOG.info("Sent email on behalf of " + request.getRemoteAddr() + " to " + to + " with subject '" + subject + "'"); - - return null; - } - - public ModelAndView db(HttpServletRequest request, HttpServletResponse response) throws Exception { - - if (!authenticate(request, response)) { - return null; - } - - Map<String, Object> map = new HashMap<String, Object>(); - - map.put("p", request.getParameter("p")); - String query = request.getParameter("query"); - if (query != null) { - map.put("query", query); - - try { - List<?> result = daoHelper.getJdbcTemplate().query(query, new ColumnMapRowMapper()); - map.put("result", result); - } catch (DataAccessException x) { - map.put("error", ExceptionUtils.getRootCause(x).getMessage()); - } - } - - return new ModelAndView("backend/db", "model", map); - } - - public ModelAndView payment(HttpServletRequest request, HttpServletResponse response) throws Exception { - - if (!authenticate(request, response)) { - return null; - } - - Map<String, Object> map = new HashMap<String, Object>(); - - Calendar startOfToday = Calendar.getInstance(); - startOfToday.set(Calendar.HOUR_OF_DAY, 0); - startOfToday.set(Calendar.MINUTE, 0); - startOfToday.set(Calendar.SECOND, 0); - startOfToday.set(Calendar.MILLISECOND, 0); - - Calendar endOfToday = Calendar.getInstance(); - endOfToday.setTime(startOfToday.getTime()); - endOfToday.add(Calendar.DATE, 1); - - Calendar startOfYesterday = Calendar.getInstance(); - startOfYesterday.setTime(startOfToday.getTime()); - startOfYesterday.add(Calendar.DATE, -1); - - Calendar startOfMonth = Calendar.getInstance(); - startOfMonth.setTime(startOfToday.getTime()); - startOfMonth.set(Calendar.DATE, 1); - - int sumToday = paymentDao.getPaymentAmount(startOfToday.getTime(), endOfToday.getTime()); - int sumYesterday = paymentDao.getPaymentAmount(startOfYesterday.getTime(), startOfToday.getTime()); - int sumMonth = paymentDao.getPaymentAmount(startOfMonth.getTime(), endOfToday.getTime()); - int dayAverageThisMonth = sumMonth / startOfToday.get(Calendar.DATE); - - map.put("sumToday", sumToday); - map.put("sumYesterday", sumYesterday); - map.put("sumMonth", sumMonth); - map.put("dayAverageThisMonth", dayAverageThisMonth); - - return new ModelAndView("backend/payment", "model", map); - } - - public ModelAndView requestLicense(HttpServletRequest request, HttpServletResponse response) throws Exception { - - String email = request.getParameter("email"); - boolean valid = email != null && isLicenseValid(email, System.currentTimeMillis()); - if (valid) { - EmailSession session = new EmailSession(); - licenseGenerator.sendLicenseTo(email, session); - } - - Map<String, Object> map = new HashMap<String, Object>(); - - map.put("email", email); - map.put("valid", valid); - - return new ModelAndView("backend/requestLicense", "model", map); - } - - public ModelAndView whitelist(HttpServletRequest request, HttpServletResponse response) throws Exception { - if (!authenticate(request, response)) { - return null; - } - - Date newerThan = MultiController.LICENSE_DATE_THRESHOLD; - Integer days = ServletRequestUtils.getIntParameter(request, "days"); - if (days != null) { - Calendar cal = Calendar.getInstance(); - cal.add(Calendar.DATE, -days); - newerThan = cal.getTime(); - } - whitelistGenerator.generate(newerThan); - return null; - } - - private boolean authenticate(HttpServletRequest request, HttpServletResponse response) throws ServletRequestBindingException, IOException { - String password = ServletRequestUtils.getRequiredStringParameter(request, "p"); - if (!password.equals(Util.getPassword("backendpwd.txt"))) { - response.sendError(HttpServletResponse.SC_FORBIDDEN); - return false; - } - return true; - } - - private boolean isLicenseValid(String email, Long date) { - if (email == null || date == null) { - return false; - } - - if (paymentDao.isBlacklisted(email)) { - return false; - } - - // Always accept licenses that are older than 2010-06-19. - if (date < LICENSE_DATE_THRESHOLD.getTime()) { - return true; - } - - return paymentDao.getPaymentByEmail(email) != null || paymentDao.isWhitelisted(email); - } - - public void setDaoHelper(DaoHelper daoHelper) { - this.daoHelper = daoHelper; - } - - public void setPaymentDao(PaymentDao paymentDao) { - this.paymentDao = paymentDao; - } - - public void setWhitelistGenerator(WhitelistGenerator whitelistGenerator) { - this.whitelistGenerator = whitelistGenerator; - } - - public void setLicenseGenerator(LicenseGenerator licenseGenerator) { - this.licenseGenerator = licenseGenerator; - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/RedirectionController.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/RedirectionController.java deleted file mode 100644 index 3f36ec6d..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/RedirectionController.java +++ /dev/null @@ -1,155 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2009 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.controller; - -import net.sourceforge.subsonic.backend.dao.RedirectionDao; -import net.sourceforge.subsonic.backend.domain.Redirection; -import static net.sourceforge.subsonic.backend.controller.RedirectionManagementController.RESERVED_REDIRECTS; -import org.apache.commons.lang.StringUtils; -import org.apache.log4j.Logger; -import org.springframework.web.servlet.ModelAndView; -import org.springframework.web.servlet.mvc.Controller; -import org.springframework.web.servlet.view.RedirectView; - -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; -import java.net.MalformedURLException; -import java.net.URL; -import java.net.URLEncoder; -import java.util.Date; -import java.util.Enumeration; -import java.io.UnsupportedEncodingException; - -/** - * Redirects vanity URLs (such as http://sindre.subsonic.org). - * - * @author Sindre Mehus - */ -public class RedirectionController implements Controller { - - private static final Logger LOG = Logger.getLogger(RedirectionController.class); - private RedirectionDao redirectionDao; - - public ModelAndView handleRequest(HttpServletRequest request, HttpServletResponse response) throws Exception { - - String redirectFrom = getRedirectFrom(request); - if (RESERVED_REDIRECTS.containsKey(redirectFrom)) { - LOG.info("Reserved redirection: " + redirectFrom); - return new ModelAndView(new RedirectView(RESERVED_REDIRECTS.get(redirectFrom))); - } - - Redirection redirection = redirectFrom == null ? null : redirectionDao.getRedirection(redirectFrom); - - if (redirection == null) { - LOG.info("No redirection found: " + redirectFrom); - return new ModelAndView(new RedirectView("http://subsonic.org/pages")); - } - - redirection.setLastRead(new Date()); - redirection.setReadCount(redirection.getReadCount() + 1); - redirectionDao.updateRedirection(redirection); - - // Check for trial expiration (unless called from REST client for which the Subsonic server manages trial expiry). - if (isTrialExpired(redirection) && !isREST(request)) { - LOG.info("Expired redirection: " + redirectFrom); - return new ModelAndView(new RedirectView("http://subsonic.org/pages/redirect-expired.jsp?redirectFrom=" + - redirectFrom + "&expired=" + redirection.getTrialExpires().getTime())); - } - - String requestUrl = getFullRequestURL(request); - String to = StringUtils.removeEnd(getRedirectTo(request, redirection), "/"); - String redirectTo = requestUrl.replaceFirst("http://" + redirectFrom + "\\.subsonic\\.org", to); - LOG.info("Redirecting from " + requestUrl + " to " + redirectTo); - - return new ModelAndView(new RedirectView(redirectTo)); - } - - private String getRedirectTo(HttpServletRequest request, Redirection redirection) { - - // If the request comes from within the same LAN as the destination Subsonic - // server, redirect using the local IP address of the server. - - String localRedirectTo = redirection.getLocalRedirectTo(); - if (localRedirectTo != null) { - try { - URL url = new URL(redirection.getRedirectTo()); - if (url.getHost().equals(request.getRemoteAddr())) { - return localRedirectTo; - } - } catch (Throwable x) { - LOG.error("Malformed local redirect URL.", x); - } - } - - return redirection.getRedirectTo(); - } - - private boolean isTrialExpired(Redirection redirection) { - return redirection.isTrial() && redirection.getTrialExpires() != null && redirection.getTrialExpires().before(new Date()); - } - - private boolean isREST(HttpServletRequest request) { - return request.getParameter("c") != null; - } - - private String getFullRequestURL(HttpServletRequest request) throws UnsupportedEncodingException { - StringBuilder builder = new StringBuilder(request.getRequestURL()); - - // For backwards compatibility; return query parameters in exact same sequence. - if ("GET".equalsIgnoreCase(request.getMethod())) { - if (request.getQueryString() != null) { - builder.append("?").append(request.getQueryString()); - } - return builder.toString(); - } - - builder.append("?"); - - Enumeration<?> paramNames = request.getParameterNames(); - while (paramNames.hasMoreElements()) { - String paramName = (String) paramNames.nextElement(); - String[] paramValues = request.getParameterValues(paramName); - for (String paramValue : paramValues) { - String p = URLEncoder.encode(paramValue, "UTF-8"); - builder.append(paramName).append("=").append(p).append("&"); - } - } - - return builder.toString(); - } - - private String getRedirectFrom(HttpServletRequest request) throws MalformedURLException { - URL url = new URL(request.getRequestURL().toString()); - String host = url.getHost(); - - String redirectFrom; - if (host.contains(".")) { - redirectFrom = StringUtils.substringBefore(host, "."); - } else { - // For testing. - redirectFrom = request.getParameter("redirectFrom"); - } - - return StringUtils.lowerCase(redirectFrom); - } - - public void setRedirectionDao(RedirectionDao redirectionDao) { - this.redirectionDao = redirectionDao; - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/RedirectionManagementController.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/RedirectionManagementController.java deleted file mode 100644 index 01ff90fa..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/RedirectionManagementController.java +++ /dev/null @@ -1,273 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2009 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.controller; - -import java.io.File; -import java.io.IOException; -import java.io.PrintWriter; -import java.net.URL; -import java.util.Date; -import java.util.List; -import java.util.Map; -import java.util.HashMap; - -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; -import javax.net.ssl.SSLPeerUnverifiedException; - -import org.apache.commons.io.IOUtils; -import org.apache.commons.lang.StringUtils; -import org.apache.log4j.Logger; -import org.apache.http.client.HttpClient; -import org.apache.http.client.methods.HttpGet; -import org.apache.http.impl.client.DefaultHttpClient; -import org.apache.http.HttpStatus; -import org.apache.http.HttpResponse; -import org.apache.http.StatusLine; -import org.apache.http.params.HttpConnectionParams; -import org.springframework.web.bind.ServletRequestUtils; -import org.springframework.web.servlet.mvc.multiaction.MultiActionController; - -import net.sourceforge.subsonic.backend.dao.RedirectionDao; -import net.sourceforge.subsonic.backend.domain.Redirection; - -/** - * @author Sindre Mehus - */ -public class RedirectionManagementController extends MultiActionController { - - private static final Logger LOG = Logger.getLogger(RedirectionManagementController.class); - - public static final Map<String,String> RESERVED_REDIRECTS = new HashMap<String, String>(); - - static { - RESERVED_REDIRECTS.put("forum", "http://www.activeobjects.no/subsonic/forum/index.php"); - RESERVED_REDIRECTS.put("www", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("web", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("ftp", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("mail", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("s", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("subsonic", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("gosubsonic", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("android", "http://www.subsonic.org/pages/android.jsp"); - RESERVED_REDIRECTS.put("iphone", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("subair", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("m", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("link", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("share", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("mobile", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("mobil", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("phone", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("wap", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("db", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("shop", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("wiki", "http://www.subsonic.org/pages/index.jsp"); - RESERVED_REDIRECTS.put("test", "http://www.subsonic.org/pages/index.jsp"); - } - - private RedirectionDao redirectionDao; - - public void register(HttpServletRequest request, HttpServletResponse response) throws Exception { - - String redirectFrom = StringUtils.lowerCase(ServletRequestUtils.getRequiredStringParameter(request, "redirectFrom")); - String licenseHolder = ServletRequestUtils.getStringParameter(request, "licenseHolder"); - String serverId = ServletRequestUtils.getRequiredStringParameter(request, "serverId"); - int port = ServletRequestUtils.getRequiredIntParameter(request, "port"); - Integer localPort = ServletRequestUtils.getIntParameter(request, "localPort"); - String localIp = ServletRequestUtils.getStringParameter(request, "localIp"); - String contextPath = ServletRequestUtils.getRequiredStringParameter(request, "contextPath"); - boolean trial = ServletRequestUtils.getBooleanParameter(request, "trial", false); - - Date now = new Date(); - Date trialExpires = null; - if (trial) { - trialExpires = new Date(ServletRequestUtils.getRequiredLongParameter(request, "trialExpires")); - } - - if (RESERVED_REDIRECTS.containsKey(redirectFrom)) { - sendError(response, "\"" + redirectFrom + "\" is a reserved address. Please select another."); - return; - } - - if (!redirectFrom.matches("(\\w|\\-)+")) { - sendError(response, "Illegal characters present in \"" + redirectFrom + "\". Please select another."); - return; - } - - String host = request.getRemoteAddr(); - URL url = new URL("http", host, port, "/" + contextPath); - String redirectTo = url.toExternalForm(); - - String localRedirectTo = null; - if (localIp != null && localPort != null) { - URL localUrl = new URL("http", localIp, localPort, "/" + contextPath); - localRedirectTo = localUrl.toExternalForm(); - } - - Redirection redirection = redirectionDao.getRedirection(redirectFrom); - if (redirection == null) { - - // Delete other redirects for same server ID. - redirectionDao.deleteRedirectionsByServerId(serverId); - - redirection = new Redirection(0, licenseHolder, serverId, redirectFrom, redirectTo, localRedirectTo, trial, trialExpires, now, null, 0); - redirectionDao.createRedirection(redirection); - LOG.info("Created " + redirection); - - } else { - - boolean sameServerId = serverId.equals(redirection.getServerId()); - boolean sameLicenseHolder = licenseHolder != null && licenseHolder.equals(redirection.getLicenseHolder()); - - // Note: A licensed user can take over any expired trial domain. - boolean existingTrialExpired = redirection.getTrialExpires() != null && redirection.getTrialExpires().before(now); - - if (sameServerId || sameLicenseHolder || (existingTrialExpired && !trial)) { - redirection.setLicenseHolder(licenseHolder); - redirection.setServerId(serverId); - redirection.setRedirectFrom(redirectFrom); - redirection.setRedirectTo(redirectTo); - redirection.setLocalRedirectTo(localRedirectTo); - redirection.setTrial(trial); - redirection.setTrialExpires(trialExpires); - redirection.setLastUpdated(now); - redirectionDao.updateRedirection(redirection); - LOG.info("Updated " + redirection); - } else { - sendError(response, "The web address \"" + redirectFrom + "\" is already in use. Please select another."); - } - } - } - - public void unregister(HttpServletRequest request, HttpServletResponse response) throws Exception { - String serverId = ServletRequestUtils.getStringParameter(request, "serverId"); - if (!StringUtils.isEmpty(serverId)) { - redirectionDao.deleteRedirectionsByServerId(serverId); - } - } - - public void get(HttpServletRequest request, HttpServletResponse response) throws Exception { - String redirectFrom = StringUtils.lowerCase(ServletRequestUtils.getRequiredStringParameter(request, "redirectFrom")); - - Redirection redirection = redirectionDao.getRedirection(redirectFrom); - if (redirection == null) { - response.sendError(HttpServletResponse.SC_BAD_REQUEST, "Web address " + redirectFrom + ".subsonic.org not registered."); - return; - } - - PrintWriter writer = response.getWriter(); - String url = redirection.getRedirectTo(); - if (!url.endsWith("/")) { - url += "/"; - } - writer.println(url); - - url = redirection.getLocalRedirectTo(); - if (!url.endsWith("/")) { - url += "/"; - } - writer.println(url); - } - - public void test(HttpServletRequest request, HttpServletResponse response) throws Exception { - String redirectFrom = StringUtils.lowerCase(ServletRequestUtils.getRequiredStringParameter(request, "redirectFrom")); - PrintWriter writer = response.getWriter(); - - Redirection redirection = redirectionDao.getRedirection(redirectFrom); - String webAddress = redirectFrom + ".subsonic.org"; - if (redirection == null) { - writer.print("Web address " + webAddress + " not registered."); - return; - } - - if (redirection.getTrialExpires() != null && redirection.getTrialExpires().before(new Date())) { - writer.print("Trial period expired. Please donate to activate web address."); - return; - } - - String url = redirection.getRedirectTo(); - if (!url.endsWith("/")) { - url += "/"; - } - url += "icons/favicon.ico"; - - HttpClient client = new DefaultHttpClient(); - HttpConnectionParams.setConnectionTimeout(client.getParams(), 15000); - HttpConnectionParams.setSoTimeout(client.getParams(), 15000); - HttpGet method = new HttpGet(url); - - try { - HttpResponse resp = client.execute(method); - StatusLine status = resp.getStatusLine(); - - if (status.getStatusCode() == HttpStatus.SC_OK) { - String msg = webAddress + " responded successfully."; - writer.print(msg); - LOG.info(msg); - } else { - String msg = webAddress + " returned HTTP error code " + status.getStatusCode() + " " + status.getReasonPhrase(); - writer.print(msg); - LOG.info(msg); - } - } catch (SSLPeerUnverifiedException x) { - String msg = webAddress + " responded successfully, but could not authenticate it."; - writer.print(msg); - LOG.info(msg); - - } catch (Throwable x) { - String msg = webAddress + " is registered, but could not connect to it. (" + x.getClass().getSimpleName() + ")"; - writer.print(msg); - LOG.info(msg); - } finally { - client.getConnectionManager().shutdown(); - } - } - - private void sendError(HttpServletResponse response, String message) throws IOException { - response.getWriter().print(message); - response.setStatus(HttpServletResponse.SC_BAD_REQUEST); - } - - public void dump(HttpServletRequest request, HttpServletResponse response) throws Exception { - - File file = File.createTempFile("redirections", ".txt"); - PrintWriter writer = new PrintWriter(file, "UTF-8"); - try { - int offset = 0; - int count = 100; - while (true) { - List<Redirection> redirections = redirectionDao.getAllRedirections(offset, count); - if (redirections.isEmpty()) { - break; - } - offset += redirections.size(); - for (Redirection redirection : redirections) { - writer.println(redirection); - } - } - LOG.info("Dumped redirections to " + file.getAbsolutePath()); - } finally { - IOUtils.closeQuietly(writer); - } - } - - public void setRedirectionDao(RedirectionDao redirectionDao) { - this.redirectionDao = redirectionDao; - } -}
\ No newline at end of file diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/AbstractDao.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/AbstractDao.java deleted file mode 100644 index 86830b7c..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/AbstractDao.java +++ /dev/null @@ -1,57 +0,0 @@ -package net.sourceforge.subsonic.backend.dao; - -import org.springframework.jdbc.core.JdbcTemplate; -import org.springframework.jdbc.core.RowMapper; - -import java.util.List; - -/** - * Abstract superclass for all DAO's. - * - * @author Sindre Mehus - */ -public class AbstractDao { - private DaoHelper daoHelper; - - /** - * Returns a JDBC template for performing database operations. - * @return A JDBC template. - */ - public JdbcTemplate getJdbcTemplate() { - return daoHelper.getJdbcTemplate(); - } - - protected String questionMarks(String columns) { - int count = columns.split(", ").length; - StringBuffer buf = new StringBuffer(); - for (int i = 0; i < count; i++) { - buf.append('?'); - if (i < count - 1) { - buf.append(", "); - } - } - return buf.toString(); - } - - protected int update(String sql, Object... args) { - return getJdbcTemplate().update(sql, args); - } - - protected <T> List<T> query(String sql, RowMapper rowMapper, Object... args) { - return getJdbcTemplate().query(sql, args, rowMapper); - } - - protected <T> T queryOne(String sql, RowMapper rowMapper, Object... args) { - List<T> result = query(sql, rowMapper, args); - return result.isEmpty() ? null : result.get(0); - } - - protected Integer queryForInt(String sql, Integer defaultValue, Object... args) { - List<Integer> result = getJdbcTemplate().queryForList(sql, args, Integer.class); - return result.isEmpty() ? defaultValue : result.get(0) == null ? defaultValue : result.get(0); - } - - public void setDaoHelper(DaoHelper daoHelper) { - this.daoHelper = daoHelper; - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/DaoHelper.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/DaoHelper.java deleted file mode 100644 index 2f5911f9..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/DaoHelper.java +++ /dev/null @@ -1,84 +0,0 @@ -package net.sourceforge.subsonic.backend.dao; - -import net.sourceforge.subsonic.backend.dao.schema.Schema; -import net.sourceforge.subsonic.backend.dao.schema.Schema10; -import net.sourceforge.subsonic.backend.dao.schema.Schema20; -import net.sourceforge.subsonic.backend.Util; -import org.apache.log4j.Logger; -import org.springframework.jdbc.core.JdbcTemplate; -import org.springframework.jdbc.datasource.DriverManagerDataSource; - -import javax.sql.DataSource; -import java.io.File; - -/** - * DAO helper class which creates the data source, and updates the database schema. - * - * @author Sindre Mehus - */ -public class DaoHelper { - - private static final Logger LOG = Logger.getLogger(DaoHelper.class); - - private Schema[] schemas = {new Schema10(), new Schema20()}; - private DataSource dataSource; - private static boolean shutdownHookAdded; - - public DaoHelper() { - dataSource = createDataSource(); - checkDatabase(); - addShutdownHook(); - } - - private void addShutdownHook() { - if (shutdownHookAdded) { - return; - } - shutdownHookAdded = true; - Runtime.getRuntime().addShutdownHook(new Thread() { - @Override - public void run() { - System.err.println("Shutting down database."); - try { - getJdbcTemplate().execute("shutdown"); - System.err.println("Done."); - } catch (Throwable x) { - System.err.println("Failed to shut down database."); - x.printStackTrace(); - } - } - }); - } - - /** - * Returns a JDBC template for performing database operations. - * - * @return A JDBC template. - */ - public JdbcTemplate getJdbcTemplate() { - return new JdbcTemplate(dataSource); - } - - private DataSource createDataSource() { - File home = Util.getBackendHome(); - DriverManagerDataSource ds = new DriverManagerDataSource(); - ds.setDriverClassName("org.hsqldb.jdbcDriver"); - ds.setUrl("jdbc:hsqldb:file:" + home.getPath() + "/db/subsonic-backend"); - ds.setUsername("sa"); - ds.setPassword(""); - - return ds; - } - - private void checkDatabase() { - LOG.info("Checking database schema."); - try { - for (Schema schema : schemas) { - schema.execute(getJdbcTemplate()); - } - LOG.info("Done checking database schema."); - } catch (Exception x) { - LOG.error("Failed to initialize database.", x); - } - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/PaymentDao.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/PaymentDao.java deleted file mode 100644 index e9f2eb21..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/PaymentDao.java +++ /dev/null @@ -1,125 +0,0 @@ -package net.sourceforge.subsonic.backend.dao; - -import net.sourceforge.subsonic.backend.domain.Payment; -import org.apache.commons.lang.StringUtils; -import org.apache.log4j.Logger; -import org.springframework.jdbc.core.RowMapper; -import org.springframework.jdbc.core.simple.ParameterizedRowMapper; -import org.springframework.jdbc.core.simple.ParameterizedSingleColumnRowMapper; - -import java.sql.ResultSet; -import java.sql.SQLException; -import java.util.Date; -import java.util.List; - -/** - * Provides database services for PayPal payments. - * - * @author Sindre Mehus - */ -public class PaymentDao extends AbstractDao { - - private static final Logger LOG = Logger.getLogger(PaymentDao.class); - private static final String COLUMNS = "id, transaction_id, transaction_type, item, " + - "payment_type, payment_status, payment_amount, payment_currency, " + - "payer_email, payer_email_lower, payer_first_name, payer_last_name, payer_country, " + - "processing_status, created, last_updated"; - - private RowMapper paymentRowMapper = new PaymentRowMapper(); - private RowMapper listRowMapper = new ParameterizedSingleColumnRowMapper<Integer>(); - - /** - * Returns the payment with the given transaction ID. - * - * @param transactionId The transaction ID. - * @return The payment or <code>null</code> if not found. - */ - public Payment getPaymentByTransactionId(String transactionId) { - String sql = "select " + COLUMNS + " from payment where transaction_id=?"; - return queryOne(sql, paymentRowMapper, transactionId); - } - - /** - * Returns the payment with the given payer email. - * - * @param email The payer email. - * @return The payment or <code>null</code> if not found. - */ - public Payment getPaymentByEmail(String email) { - if (email == null) { - return null; - } - String sql = "select " + COLUMNS + " from payment where payer_email_lower=?"; - return queryOne(sql, paymentRowMapper, email.toLowerCase()); - } - - /** - * Returns all payments with the given processing status. - * - * @param status The status. - * @return List of payments. - */ - public List<Payment> getPaymentsByProcessingStatus(Payment.ProcessingStatus status) { - return query("select " + COLUMNS + " from payment where processing_status=?", paymentRowMapper, status.name()); - } - - /** - * Creates a new payment. - * - * @param payment The payment to create. - */ - public void createPayment(Payment payment) { - String sql = "insert into payment (" + COLUMNS + ") values (" + questionMarks(COLUMNS) + ")"; - update(sql, null, payment.getTransactionId(), payment.getTransactionType(), payment.getItem(), - payment.getPaymentType(), payment.getPaymentStatus(), payment.getPaymentAmount(), - payment.getPaymentCurrency(), payment.getPayerEmail(), StringUtils.lowerCase(payment.getPayerEmail()), - payment.getPayerFirstName(), payment.getPayerLastName(), payment.getPayerCountry(), - payment.getProcessingStatus().name(), payment.getCreated(), payment.getLastUpdated()); - LOG.info("Created " + payment); - } - - /** - * Updates the given payment. - * - * @param payment The payment to update. - */ - public void updatePayment(Payment payment) { - String sql = "update payment set transaction_type=?, item=?, payment_type=?, payment_status=?, " + - "payment_amount=?, payment_currency=?, payer_email=?, payer_email_lower=?, payer_first_name=?, payer_last_name=?, " + - "payer_country=?, processing_status=?, created=?, last_updated=? where id=?"; - update(sql, payment.getTransactionType(), payment.getItem(), payment.getPaymentType(), payment.getPaymentStatus(), - payment.getPaymentAmount(), payment.getPaymentCurrency(), payment.getPayerEmail(), StringUtils.lowerCase(payment.getPayerEmail()), - payment.getPayerFirstName(), payment.getPayerLastName(), payment.getPayerCountry(), payment.getProcessingStatus().name(), - payment.getCreated(), payment.getLastUpdated(), payment.getId()); - LOG.info("Updated " + payment); - } - - public int getPaymentAmount(Date from, Date to) { - String sql = "select sum(payment_amount) from payment where created between ? and ?"; - return queryForInt(sql, 0, from, to); - } - - public boolean isBlacklisted(String email) { - String sql = "select 1 from blacklist where email=?"; - return queryOne(sql, listRowMapper, StringUtils.lowerCase(email)) != null; - } - - public boolean isWhitelisted(String email) { - String sql = "select 1 from whitelist where email=?"; - return queryOne(sql, listRowMapper, StringUtils.lowerCase(email)) != null; - } - - public void whitelist(String email) { - update("insert into whitelist(email) values (?)", StringUtils.lowerCase(email)); - } - - private static class PaymentRowMapper implements ParameterizedRowMapper<Payment> { - - public Payment mapRow(ResultSet rs, int rowNum) throws SQLException { - return new Payment(rs.getString(1), rs.getString(2), rs.getString(3), rs.getString(4), rs.getString(5), - rs.getString(6), rs.getInt(7), rs.getString(8), rs.getString(9), rs.getString(11), - rs.getString(12), rs.getString(13), Payment.ProcessingStatus.valueOf(rs.getString(14)), - rs.getTimestamp(15), rs.getTimestamp(16)); - } - } -}
\ No newline at end of file diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/RedirectionDao.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/RedirectionDao.java deleted file mode 100644 index edd73222..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/RedirectionDao.java +++ /dev/null @@ -1,96 +0,0 @@ -package net.sourceforge.subsonic.backend.dao; - -import net.sourceforge.subsonic.backend.domain.Redirection; -import org.apache.log4j.Logger; -import org.springframework.jdbc.core.simple.ParameterizedRowMapper; - -import java.sql.ResultSet; -import java.sql.SQLException; -import java.util.ArrayList; -import java.util.List; - -/** - * Provides database services for xxx.subsonic.org redirections. - * - * @author Sindre Mehus - */ -public class RedirectionDao extends AbstractDao { - - private static final Logger LOG = Logger.getLogger(RedirectionDao.class); - private static final String COLUMNS = "id, license_holder, server_id, redirect_from, redirect_to, local_redirect_to, trial, trial_expires, last_updated, last_read, read_count"; - - private RedirectionRowMapper rowMapper = new RedirectionRowMapper(); - - /** - * Returns the redirection with the given "redirect from". - * - * @param redirectFrom The "redirect from" string. - * @return The redirection or <code>null</code> if not found. - */ - public Redirection getRedirection(String redirectFrom) { - String sql = "select " + COLUMNS + " from redirection where redirect_from=?"; - return queryOne(sql, rowMapper, redirectFrom); - } - - /** - * Returns all redirections with respect to the given row offset and count. - * - * @param offset Number of rows to skip. - * @param count Maximum number of rows to return. - * @return Redirections with respect to the given row offset and count. - */ - public List<Redirection> getAllRedirections(int offset, int count) { - if (count < 1) { - return new ArrayList<Redirection>(); - } - String sql = "select " + COLUMNS + " from redirection " + - "order by id " + - "limit " + count + " offset " + offset; - return query(sql, rowMapper); - } - - /** - * Creates a new redirection. - * - * @param redirection The redirection to create. - */ - public void createRedirection(Redirection redirection) { - String sql = "insert into redirection (" + COLUMNS + ") values (null, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; - update(sql, redirection.getLicenseHolder(), redirection.getServerId(), redirection.getRedirectFrom(), - redirection.getRedirectTo(), redirection.getLocalRedirectTo(), redirection.isTrial(), - redirection.getTrialExpires(), redirection.getLastUpdated(), - redirection.getLastRead(), redirection.getReadCount()); - LOG.info("Created redirection " + redirection.getRedirectFrom() + " -> " + redirection.getRedirectTo()); - } - - /** - * Updates the given redirection. - * - * @param redirection The redirection to update. - */ - public void updateRedirection(Redirection redirection) { - String sql = "update redirection set license_holder=?, server_id=?, redirect_from=?, redirect_to=?, " + - "local_redirect_to=?, trial=?, trial_expires=?, last_updated=?, last_read=?, read_count=? where id=?"; - update(sql, redirection.getLicenseHolder(), redirection.getServerId(), redirection.getRedirectFrom(), - redirection.getRedirectTo(), redirection.getLocalRedirectTo(), redirection.isTrial(), redirection.getTrialExpires(), - redirection.getLastUpdated(), redirection.getLastRead(), redirection.getReadCount(), redirection.getId()); - } - - /** - * Deletes all redirections with the given server ID. - * - * @param serverId The server ID. - */ - public void deleteRedirectionsByServerId(String serverId) { - update("delete from redirection where server_id=?", serverId); - LOG.info("Deleted redirections for server ID " + serverId); - } - - private static class RedirectionRowMapper implements ParameterizedRowMapper<Redirection> { - public Redirection mapRow(ResultSet rs, int rowNum) throws SQLException { - return new Redirection(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getString(4), rs.getString(5), - rs.getString(6), rs.getBoolean(7), rs.getTimestamp(8), rs.getTimestamp(9), rs.getTimestamp(10), - rs.getInt(11)); - } - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema.java deleted file mode 100644 index 850b82da..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema.java +++ /dev/null @@ -1,66 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2009 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.dao.schema; - -import org.springframework.jdbc.core.JdbcTemplate; - -/** - * Used for creating and evolving the database schema. - * - * @author Sindre Mehus - */ -public abstract class Schema { - - /** - * Executes this schema. - * @param template The JDBC template to use. - */ - public abstract void execute(JdbcTemplate template); - - /** - * Returns whether the given table exists. - * @param template The JDBC template to use. - * @param table The table in question. - * @return Whether the table exists. - */ - protected boolean tableExists(JdbcTemplate template, String table) { - try { - template.execute("select 1 from " + table); - } catch (Exception x) { - return false; - } - return true; - } - - /** - * Returns whether the given column in the given table exists. - * @param template The JDBC template to use. - * @param column The column in question. - * @param table The table in question. - * @return Whether the column exists. - */ - protected boolean columnExists(JdbcTemplate template, String column, String table) { - try { - template.execute("select " + column + " from " + table + " where 1 = 0"); - } catch (Exception x) { - return false; - } - return true; - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema10.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema10.java deleted file mode 100644 index 29c4c492..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema10.java +++ /dev/null @@ -1,100 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2009 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.dao.schema; - -import org.apache.log4j.Logger; -import org.springframework.jdbc.core.JdbcTemplate; - -/** - * Used for creating and evolving the database schema. - * This class implementes the database schema for Subsonic Backend version 1.0. - * - * @author Sindre Mehus - */ -public class Schema10 extends Schema { - private static final Logger LOG = Logger.getLogger(Schema10.class); - - public void execute(JdbcTemplate template) { - - /* - Example row 1: - - id: 123 - license_holder: sindre@activeobjects.no - server_id: 972342834928656 - redirect_from: sindre - redirect_to: http://23.45.123.56:8080/subsonic - local_redirect_to: http://192.168.0.7:80/subsonic - trial: false - trial_expires: null - - Example row 2: - - id: 124 - license_holder: null - server_id: 72121983567129 - redirect_from: joe - redirect_to: http://232.21.18.14/subsonic - local_redirect_to: http://192.168.0.7:80/subsonic - trial: true - trial_expires: 2010-01-13 05:34:17 - */ - - if (!tableExists(template, "redirection")) { - LOG.info("Database table 'redirection' not found. Creating it."); - template.execute("create cached table redirection (" + - "id identity," + - "license_holder varchar," + - "server_id varchar not null," + - "redirect_from varchar not null," + - "redirect_to varchar not null," + - "trial boolean not null," + - "trial_expires datetime," + - "last_updated datetime," + - "last_read datetime," + - "unique(redirect_from))"); - template.execute("create index idx_redirection_redirect_from on redirection(redirect_from)"); - template.execute("create index idx_redirection_server_id on redirection(server_id)"); - - createRedirection(template, "demo", "http://subsonic.org/demo"); - - LOG.info("Database table 'redirection' was created successfully."); - } - - if (!columnExists(template, "local_redirect_to", "redirection")) { - LOG.info("Database column 'redirection.local_redirect_to' not found. Creating it."); - template.execute("alter table redirection " + - "add local_redirect_to varchar"); - LOG.info("Database column 'redirection.local_redirect_to' was added successfully."); - } - - if (!columnExists(template, "read_count", "redirection")) { - LOG.info("Database column 'redirection.read_count' not found. Creating it."); - template.execute("alter table redirection " + - "add read_count int default 0 not null"); - LOG.info("Database column 'redirection.read_count' was added successfully."); - } - } - - private void createRedirection(JdbcTemplate template, String redirectFrom, String redirectTo) { - template.update("insert into redirection values (null, 'sindre@activeobjects.no', '-1', ?, ?, false, null, null, null)", - new Object[] {redirectFrom, redirectTo}); - LOG.info("Creating redirection from " + redirectFrom + " to " + redirectTo); - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema20.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema20.java deleted file mode 100644 index 99ea679e..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema20.java +++ /dev/null @@ -1,90 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2009 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.dao.schema; - -import org.apache.log4j.Logger; -import org.springframework.jdbc.core.JdbcTemplate; - -/** - * Used for creating and evolving the database schema. - * This class implementes the database schema for Subsonic Backend version 2.0. - * - * @author Sindre Mehus - */ -public class Schema20 extends Schema { - private static final Logger LOG = Logger.getLogger(Schema20.class); - - public void execute(JdbcTemplate template) { - - if (!tableExists(template, "payment")) { - LOG.info("Database table 'payment' not found. Creating it."); - template.execute("create cached table payment (" + - "id identity," + - "transaction_id varchar not null," + - "transaction_type varchar," + // cart, web_accept - "item varchar," + - "payment_type varchar," + // echeck, instant - "payment_status varchar," + // Completed, Pending, Denied, Failed, ... - "payment_amount int," + - "payment_currency varchar," + - "payer_email varchar," + - "payer_first_name varchar," + - "payer_last_name varchar," + - "payer_country varchar," + - "processing_status varchar not null," + - "created datetime," + - "last_updated datetime," + - "unique(transaction_id))"); - template.execute("create index idx_payment_transaction_id on payment(transaction_id)"); - template.execute("create index idx_payment_created on payment(created)"); - template.execute("create index idx_payment_payer_email on payment(payer_email)"); - - LOG.info("Database table 'payment' was created successfully."); - } - - if (!columnExists(template, "payer_email_lower", "payment")) { - LOG.info("Database column 'payment.payer_email_lower' not found. Creating it."); - template.execute("alter table payment " + - "add payer_email_lower varchar"); - template.execute("update payment set payer_email_lower=lcase(payer_email)"); - template.execute("create index idx_payment_payer_email_lower on payment(payer_email_lower)"); - LOG.info("Database column 'payment.payer_email_lower' was added successfully."); - } - - if (!tableExists(template, "whitelist")) { - LOG.info("Database table 'whitelist' not found. Creating it."); - template.execute("create cached table whitelist (" + - "id identity," + - "email varchar not null)"); - template.execute("create index idx_whitelist_email on whitelist(email)"); - - LOG.info("Database table 'whitelist' was created successfully."); - } - - if (!tableExists(template, "blacklist")) { - LOG.info("Database table 'blacklist' not found. Creating it."); - template.execute("create cached table blacklist (" + - "id identity," + - "email varchar not null)"); - template.execute("create index idx_blacklist_email on blacklist(email)"); - - LOG.info("Database table 'blacklist' was created successfully."); - } - } -}
\ No newline at end of file diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/domain/Payment.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/domain/Payment.java deleted file mode 100644 index 9e32b2cd..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/domain/Payment.java +++ /dev/null @@ -1,200 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2010 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.domain; - -import java.util.Date; - -/** - * @author Sindre Mehus - */ -public class Payment { - - private String id; - private String transactionId; - private String transactionType; - private String item; - private String paymentType; - private String paymentStatus; - private int paymentAmount; - private String paymentCurrency; - private String payerEmail; - private String payerFirstName; - private String payerLastName; - private String payerCountry; - private ProcessingStatus processingStatus; - private Date created; - private Date lastUpdated; - - public Payment(String id, String transactionId, String transactionType, String item, String paymentType, - String paymentStatus, int paymentAmount, String paymentCurrency, String payerEmail, - String payerFirstName, String payerLastName, String payerCountry, ProcessingStatus processingStatus, - Date created, Date lastUpdated) { - this.id = id; - this.transactionId = transactionId; - this.transactionType = transactionType; - this.item = item; - this.paymentType = paymentType; - this.paymentStatus = paymentStatus; - this.paymentAmount = paymentAmount; - this.paymentCurrency = paymentCurrency; - this.payerEmail = payerEmail; - this.payerFirstName = payerFirstName; - this.payerLastName = payerLastName; - this.payerCountry = payerCountry; - this.processingStatus = processingStatus; - this.created = created; - this.lastUpdated = lastUpdated; - } - - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - public String getTransactionId() { - return transactionId; - } - - public void setTransactionId(String transactionId) { - this.transactionId = transactionId; - } - - public String getTransactionType() { - return transactionType; - } - - public void setTransactionType(String transactionType) { - this.transactionType = transactionType; - } - - public String getItem() { - return item; - } - - public void setItem(String item) { - this.item = item; - } - - public String getPaymentType() { - return paymentType; - } - - public void setPaymentType(String paymentType) { - this.paymentType = paymentType; - } - - public String getPaymentStatus() { - return paymentStatus; - } - - public void setPaymentStatus(String paymentStatus) { - this.paymentStatus = paymentStatus; - } - - public int getPaymentAmount() { - return paymentAmount; - } - - public void setPaymentAmount(int paymentAmount) { - this.paymentAmount = paymentAmount; - } - - public String getPaymentCurrency() { - return paymentCurrency; - } - - public void setPaymentCurrency(String paymentCurrency) { - this.paymentCurrency = paymentCurrency; - } - - public String getPayerEmail() { - return payerEmail; - } - - public void setPayerEmail(String payerEmail) { - this.payerEmail = payerEmail; - } - - public String getPayerFirstName() { - return payerFirstName; - } - - public void setPayerFirstName(String payerFirstName) { - this.payerFirstName = payerFirstName; - } - - public String getPayerLastName() { - return payerLastName; - } - - public void setPayerLastName(String payerLastName) { - this.payerLastName = payerLastName; - } - - public String getPayerCountry() { - return payerCountry; - } - - public void setPayerCountry(String payerCountry) { - this.payerCountry = payerCountry; - } - - public ProcessingStatus getProcessingStatus() { - return processingStatus; - } - - public void setProcessingStatus(ProcessingStatus processingStatus) { - this.processingStatus = processingStatus; - } - - public Date getCreated() { - return created; - } - - public void setCreated(Date created) { - this.created = created; - } - - public Date getLastUpdated() { - return lastUpdated; - } - - public void setLastUpdated(Date lastUpdated) { - this.lastUpdated = lastUpdated; - } - - @Override - public String toString() { - return "Payment{" + - "tx='" + transactionId + '\'' + - ", type='" + paymentType + '\'' + - ", status='" + paymentStatus + '\'' + - ", amount=" + paymentAmount + - ", email='" + payerEmail + '\'' + - '}'; - } - - public enum ProcessingStatus { - NEW, - COMPLETED - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/domain/Redirection.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/domain/Redirection.java deleted file mode 100644 index aa62bd75..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/domain/Redirection.java +++ /dev/null @@ -1,155 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2009 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.domain; - -import java.util.Date; - -/** - * @author Sindre Mehus - */ -public class Redirection { - - private int id; - private String licenseHolder; - private String serverId; - private String redirectFrom; - private String redirectTo; - private String localRedirectTo; - private boolean trial; - private Date trialExpires; - private Date lastUpdated; - private Date lastRead; - private int readCount; - - public Redirection(int id, String licenseHolder, String serverId, String redirectFrom, String redirectTo, - String localRedirectTo, boolean trial, Date trialExpires, Date lastUpdated, Date lastRead, int readCount) { - this.id = id; - this.licenseHolder = licenseHolder; - this.serverId = serverId; - this.redirectFrom = redirectFrom; - this.redirectTo = redirectTo; - this.localRedirectTo = localRedirectTo; - this.trial = trial; - this.trialExpires = trialExpires; - this.lastUpdated = lastUpdated; - this.lastRead = lastRead; - this.readCount = readCount; - } - - public int getId() { - return id; - } - - public String getLicenseHolder() { - return licenseHolder; - } - - public void setLicenseHolder(String licenseHolder) { - this.licenseHolder = licenseHolder; - } - - public String getServerId() { - return serverId; - } - - public void setServerId(String serverId) { - this.serverId = serverId; - } - - public String getRedirectFrom() { - return redirectFrom; - } - - public void setRedirectFrom(String redirectFrom) { - this.redirectFrom = redirectFrom; - } - - public String getRedirectTo() { - return redirectTo; - } - - public void setRedirectTo(String redirectTo) { - this.redirectTo = redirectTo; - } - - public String getLocalRedirectTo() { - return localRedirectTo; - } - - public void setLocalRedirectTo(String localRedirectTo) { - this.localRedirectTo = localRedirectTo; - } - - public boolean isTrial() { - return trial; - } - - public void setTrial(boolean trial) { - this.trial = trial; - } - - public Date getTrialExpires() { - return trialExpires; - } - - public void setTrialExpires(Date trialExpires) { - this.trialExpires = trialExpires; - } - - public Date getLastUpdated() { - return lastUpdated; - } - - public void setLastUpdated(Date lastUpdated) { - this.lastUpdated = lastUpdated; - } - - public Date getLastRead() { - return lastRead; - } - - public void setLastRead(Date lastRead) { - this.lastRead = lastRead; - } - - public int getReadCount() { - return readCount; - } - - public void setReadCount(int readCount) { - this.readCount = readCount; - } - - @Override - public String toString() { - return "Redirection{" + - "id=" + id + - ", licenseHolder='" + licenseHolder + '\'' + - ", serverId='" + serverId + '\'' + - ", redirectFrom='" + redirectFrom + '\'' + - ", redirectTo='" + redirectTo + '\'' + - ", localRedirectTo='" + localRedirectTo + '\'' + - ", trial=" + trial + - ", trialExpires=" + trialExpires + - ", lastUpdated=" + lastUpdated + - ", lastRead=" + lastRead + - ", readCount=" + readCount + - '}'; - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/EmailSession.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/EmailSession.java deleted file mode 100644 index cfd96651..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/EmailSession.java +++ /dev/null @@ -1,108 +0,0 @@ -/* - This file is part of Subsonic. - - Subsonic is free software: you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - Subsonic 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 General Public License for more details. - - You should have received a copy of the GNU General Public License - along with Subsonic. If not, see <http://www.gnu.org/licenses/>. - - Copyright 2010 (C) Sindre Mehus - */ -package net.sourceforge.subsonic.backend.service; - -import net.sourceforge.subsonic.backend.Util; - -import javax.mail.Folder; -import javax.mail.Session; -import javax.mail.Message; -import javax.mail.Address; -import javax.mail.MessagingException; -import javax.mail.Store; -import javax.mail.Transport; -import javax.mail.internet.InternetAddress; -import javax.mail.internet.MimeMessage; -import javax.mail.internet.AddressException; -import java.util.Properties; -import java.util.List; - -/** - * @author Sindre Mehus - */ -public class EmailSession { - - private static final String SMTP_MAIL_SERVER = "smtp.gmail.com"; - private static final String POP_MAIL_SERVER = "pop.gmail.com"; - private static final String IMAP_MAIL_SERVER = "imap.gmail.com"; - private static final String USER = "subsonic@activeobjects.no"; - - private Session session; - private String password; - - public EmailSession() throws Exception { - Properties props = new Properties(); -// props.setProperty("mail.debug", "true"); - props.setProperty("mail.store.protocol", "pop3s"); - props.setProperty("mail.smtps.host", SMTP_MAIL_SERVER); - props.setProperty("mail.smtps.auth", "true"); - props.setProperty("mail.smtps.timeout", "10000"); - props.setProperty("mail.smtps.connectiontimeout", "10000"); - props.setProperty("mail.pop3s.timeout", "10000"); - props.setProperty("mail.pop3s.connectiontimeout", "10000"); - - session = Session.getDefaultInstance(props, null); - password = Util.getPassword("gmailpwd.txt"); - } - - public void sendMessage(String from, List<String> to, List<String> cc, List<String> bcc, List<String> replyTo, - String subject, String text) throws MessagingException { - Message message = new MimeMessage(session); - - message.setFrom(new InternetAddress(from)); - message.setReplyTo(new Address[]{new InternetAddress(from)}); - message.setRecipients(Message.RecipientType.TO, convertAddress(to)); - message.setRecipients(Message.RecipientType.CC, convertAddress(cc)); - message.setRecipients(Message.RecipientType.BCC, convertAddress(bcc)); - message.setReplyTo(convertAddress(replyTo)); - message.setSubject(subject); - message.setText(text); - - // Send the message - Transport transport = null; - try { - transport = session.getTransport("smtps"); - transport.connect(USER, password); - transport.sendMessage(message, message.getAllRecipients()); - } finally { - if (transport != null) { - transport.close(); - } - } - } - - public Folder getFolder(String name) throws Exception { - Store store = session.getStore("imaps"); - store.connect(IMAP_MAIL_SERVER, USER, password); - Folder folder = store.getFolder(name); - folder.open(Folder.READ_ONLY); - return folder; - } - - private Address[] convertAddress(List<String> addresses) throws AddressException { - if (addresses == null) { - return null; - } - Address[] result = new Address[addresses.size()]; - for (int i = 0; i < addresses.size(); i++) { - result[i] = new InternetAddress(addresses.get(i)); - } - return result; - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/LicenseGenerator.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/LicenseGenerator.java deleted file mode 100644 index 77376a8e..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/LicenseGenerator.java +++ /dev/null @@ -1,170 +0,0 @@ -package net.sourceforge.subsonic.backend.service; - -import net.sourceforge.subsonic.backend.dao.PaymentDao; -import net.sourceforge.subsonic.backend.domain.Payment; -import org.apache.commons.codec.binary.Hex; -import org.apache.log4j.Logger; - -import javax.mail.MessagingException; -import java.security.MessageDigest; -import java.util.Arrays; -import java.util.Date; -import java.util.List; -import java.util.concurrent.Executors; -import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.TimeUnit; - -/** - * Runs a task at regular intervals, checking for incoming donations and sending - * out license keys by email. - * - * @author Sindre Mehus - * @version $Id$ - */ -public class LicenseGenerator { - - private static final Logger LOG = Logger.getLogger(LicenseGenerator.class); - private static final long DELAY = 60; // One minute. - - private PaymentDao paymentDao; - private final ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(); - - public void init() { - Runnable task = new Runnable() { - public void run() { - try { - LOG.info("Starting license generator."); - processPayments(); - LOG.info("Completed license generator."); - } catch (Throwable x) { - LOG.error("Failed to process license emails.", x); - } - } - }; - executor.scheduleWithFixedDelay(task, DELAY, DELAY, TimeUnit.SECONDS); - LOG.info("Scheduled license generator to run every " + DELAY + " seconds."); - } - - private void processPayments() throws Exception { - List<Payment> payments = paymentDao.getPaymentsByProcessingStatus(Payment.ProcessingStatus.NEW); - LOG.info(payments.size() + " new payment(s)."); - if (payments.isEmpty()) { - return; - } - - EmailSession emailSession = new EmailSession(); - for (Payment payment : payments) { - processPayment(payment, emailSession); - } - } - - private void processPayment(Payment payment, EmailSession emailSession) { - try { - LOG.info("Processing " + payment); - String email = payment.getPayerEmail(); - if (email == null) { - throw new Exception("Missing email address."); - } - - boolean eligible = isEligible(payment); - boolean ignorable = isIgnorable(payment); - if (eligible) { - sendLicenseTo(email, emailSession); - LOG.info("Sent license key for " + payment); - } else { - LOG.info("Payment not eligible for " + payment); - } - - if (eligible || ignorable) { - payment.setProcessingStatus(Payment.ProcessingStatus.COMPLETED); - payment.setLastUpdated(new Date()); - paymentDao.updatePayment(payment); - } - - } catch (Throwable x) { - LOG.error("Failed to process " + payment, x); - } - } - - private boolean isEligible(Payment payment) { - String status = payment.getPaymentStatus(); - if ("echeck".equalsIgnoreCase(payment.getPaymentType())) { - return "Pending".equalsIgnoreCase(status) || "Completed".equalsIgnoreCase(status); - } - return "Completed".equalsIgnoreCase(status); - } - - private boolean isIgnorable(Payment payment) { - String status = payment.getPaymentStatus(); - return "Denied".equalsIgnoreCase(status) || - "Reversed".equalsIgnoreCase(status) || - "Refunded".equalsIgnoreCase(status); - } - - public void sendLicenseTo(String to, EmailSession emailSession) throws MessagingException { - emailSession.sendMessage("subsonic_donation@activeobjects.no", - Arrays.asList(to), - null, - Arrays.asList("subsonic_donation@activeobjects.no", "sindre@activeobjects.no"), - Arrays.asList("subsonic_donation@activeobjects.no"), - "Subsonic License", - createLicenseContent(to)); - LOG.info("Sent license to " + to); - } - - private String createLicenseContent(String to) { - String license = md5Hex(to.toLowerCase()); - - return "Dear Subsonic donor,\n" + - "\n" + - "Many thanks for your kind donation to Subsonic!\n" + - "Please find your license key below.\n" + - "\n" + - "Email: " + to + "\n" + - "License: " + license + " \n" + - "\n" + - "To install the license key, click the \"Donate\" link in the top right corner of the Subsonic web interface.\n" + - "\n" + - "More info here: http://subsonic.org/pages/getting-started.jsp#3\n" + - "\n" + - "This license is valid for personal, non-commercial of Subsonic. For commercial use, please contact us for licensing options.\n" + - "\n" + - "Thanks again for supporting the project!\n" + - "\n" + - "Best regards,\n" + - "The Subsonic team"; - } - - /** - * Calculates the MD5 digest and returns the value as a 32 character hex string. - * - * @param s Data to digest. - * @return MD5 digest as a hex string. - */ - private String md5Hex(String s) { - if (s == null) { - return null; - } - - try { - MessageDigest md5 = MessageDigest.getInstance("MD5"); - return new String(Hex.encodeHex(md5.digest(s.getBytes("UTF-8")))); - } catch (Exception x) { - throw new RuntimeException(x.getMessage(), x); - } - } - - public void setPaymentDao(PaymentDao paymentDao) { - this.paymentDao = paymentDao; - } - - public static void main(String[] args) throws Exception { - String address = args[0]; -// String license = md5Hex(address.toLowerCase()); -// System.out.println("Email: " + address); -// System.out.println("License: " + license); - - LicenseGenerator generator = new LicenseGenerator(); - generator.sendLicenseTo(address, new EmailSession()); - } -} diff --git a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/WhitelistGenerator.java b/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/WhitelistGenerator.java deleted file mode 100644 index eef29611..00000000 --- a/subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/WhitelistGenerator.java +++ /dev/null @@ -1,53 +0,0 @@ -package net.sourceforge.subsonic.backend.service; - -import net.sourceforge.subsonic.backend.dao.PaymentDao; -import org.apache.log4j.Logger; - -import javax.mail.Address; -import javax.mail.Folder; -import javax.mail.Message; -import javax.mail.internet.InternetAddress; -import java.util.Date; - -/** - * Creates a license whitelist. - * - * @author Sindre Mehus - * @version $Id$ - */ -public class WhitelistGenerator { - - private static final Logger LOG = Logger.getLogger(WhitelistGenerator.class); - - private PaymentDao paymentDao; - - public void generate(Date newerThan) throws Exception { - LOG.info("Starting whitelist update for emails newer than " + newerThan); - - EmailSession session = new EmailSession(); - Folder folder = session.getFolder("[Gmail]/Sent Mail"); - int n = folder.getMessageCount(); - - for (int i = n; i >= 0; i--) { - Message message = folder.getMessage(i); - Date date = message.getSentDate(); - InternetAddress address = (InternetAddress) message.getRecipients(Message.RecipientType.TO)[0]; - String recipient = address.getAddress(); - if (date.before(newerThan)) { - break; - } - LOG.info(date + " " + recipient); - - if (paymentDao.getPaymentByEmail(recipient) == null && !paymentDao.isWhitelisted(recipient)) { - paymentDao.whitelist(recipient); - LOG.info("WHITELISTED " + recipient); - } - } - folder.close(false); - LOG.info("Completed whitelist update."); - } - - public void setPaymentDao(PaymentDao paymentDao) { - this.paymentDao = paymentDao; - } -} |