aboutsummaryrefslogtreecommitdiff
path: root/subsonic-backend/src/main/java/net
diff options
context:
space:
mode:
authorScott Jackson <daneren2005@gmail.com>2013-07-27 14:33:25 -0700
committerScott Jackson <daneren2005@gmail.com>2013-07-27 14:33:38 -0700
commit4738428c2c205f42200386ae09b44b9ec07b9144 (patch)
treea6402978fe1b4655f90c3c8a181f4d246fbc5e89 /subsonic-backend/src/main/java/net
parent82ec8315f777c319f2372540098e21111019d629 (diff)
downloaddsub-4738428c2c205f42200386ae09b44b9ec07b9144.tar.gz
dsub-4738428c2c205f42200386ae09b44b9ec07b9144.tar.bz2
dsub-4738428c2c205f42200386ae09b44b9ec07b9144.zip
Move subsonic-android to root
Diffstat (limited to 'subsonic-backend/src/main/java/net')
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/Util.java62
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/IPNController.java152
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/MultiController.java256
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/RedirectionController.java155
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/controller/RedirectionManagementController.java273
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/AbstractDao.java57
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/DaoHelper.java84
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/PaymentDao.java125
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/RedirectionDao.java96
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema.java66
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema10.java100
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/dao/schema/Schema20.java90
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/domain/Payment.java200
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/domain/Redirection.java155
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/EmailSession.java108
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/LicenseGenerator.java170
-rw-r--r--subsonic-backend/src/main/java/net/sourceforge/subsonic/backend/service/WhitelistGenerator.java53
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;
- }
-}