/*

 *   SONEWS News Server

 *   see AUTHORS for the list of contributors

 *

 *   This program 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.

 *

 *   This program is distributed in the hope that it will be useful,

 *   but WITHOUT ANY WARRANTY; without even the implied warranty of

 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 *   GNU General Public License for more details.

 *

 *   You should have received a copy of the GNU General Public License

 *   along with this program.  If not, see <http://www.gnu.org/licenses/>.

 */

package org.sonews.daemon.command;

import java.io.IOException;

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.sql.SQLException;

import java.util.Arrays;

import javax.mail.MessagingException;

import javax.mail.internet.AddressException;

import javax.mail.internet.InternetHeaders;

import org.sonews.config.Config;

import org.sonews.util.Log;

import org.sonews.mlgw.Dispatcher;

import org.sonews.storage.Article;

import org.sonews.storage.Group;

import org.sonews.daemon.NNTPConnection;

import org.sonews.storage.Headers;

import org.sonews.storage.StorageBackendException;

import org.sonews.storage.StorageManager;

import org.sonews.feed.FeedManager;

import org.sonews.util.Stats;

/**

 * Implementation of the POST command. This command requires multiple lines

 * from the client, so the handling of asynchronous reading is a little tricky

 * to handle.

 * @author Christian Lins

 * @since sonews/0.5.0

 */

public class PostCommand implements Command {

	private final Article article = new Article();

	private int lineCount = 0;

	private long bodySize = 0;

	private InternetHeaders headers = null;

	private long maxBodySize =

			Config.inst().get(Config.ARTICLE_MAXSIZE, 128) * 1024L; // Size in bytes

	private PostState state = PostState.WaitForLineOne;

	private final ByteArrayOutputStream bufBody = new ByteArrayOutputStream();

	private final StringBuilder strHead = new StringBuilder();

	@Override

	public String[] getSupportedCommandStrings() {

		return new String[]{"POST"};

	}

	@Override

	public boolean hasFinished() {

		return this.state == PostState.Finished;

	}

	@Override

	public String impliedCapability() {

		return null;

	}

	@Override

	public boolean isStateful() {

		return true;

	}

	/**

	 * Process the given line String. line.trim() was called by NNTPConnection.

	 * @param line

	 * @throws java.io.IOException

	 * @throws java.sql.SQLException

	 */

	@Override // TODO: Refactor this method to reduce complexity!

	public void processLine(NNTPConnection conn, String line, byte[] raw)

			throws IOException, StorageBackendException {

		switch (state) {

			case WaitForLineOne: {

				if (line.equalsIgnoreCase("POST")) {

					conn.println("340 send article to be posted. End with <CR-LF>.<CR-LF>");

					state = PostState.ReadingHeaders;

				} else {

					conn.println("500 invalid command usage");

				}

				break;

			}

			case ReadingHeaders: {

				strHead.append(line);

				strHead.append(NNTPConnection.NEWLINE);

				if ("".equals(line) || ".".equals(line)) {

					// we finally met the blank line

					// separating headers from body

					try {

						// Parse the header using the InternetHeader class from JavaMail API

						headers = new InternetHeaders(

								new ByteArrayInputStream(strHead.toString().trim().getBytes(conn.getCurrentCharset())));

						// add the header entries for the article

						article.setHeaders(headers);

					} catch (MessagingException e) {

						e.printStackTrace();

						conn.println("500 posting failed - invalid header");

						state = PostState.Finished;

						break;

					}

					// Change charset for reading body;

					// for multipart messages UTF-8 is returned

					//conn.setCurrentCharset(article.getBodyCharset());

					state = PostState.ReadingBody;

					if (".".equals(line)) {

						// Post an article without body

						postArticle(conn, article);

						state = PostState.Finished;

					}

				}

				break;

			}

			case ReadingBody: {

				if (".".equals(line)) {

					// Set some headers needed for Over command

					headers.setHeader(Headers.LINES, Integer.toString(lineCount));

					headers.setHeader(Headers.BYTES, Long.toString(bodySize));

					byte[] body = bufBody.toByteArray();

					if (body.length >= 2) {

						// Remove trailing CRLF

						body = Arrays.copyOf(body, body.length - 2);

					}

					article.setBody(body); // set the article body

					postArticle(conn, article);

					state = PostState.Finished;

				} else {

					bodySize += line.length() + 1;

					lineCount++;

					// Add line to body buffer

					bufBody.write(raw, 0, raw.length);

					bufBody.write(NNTPConnection.NEWLINE.getBytes());

					if (bodySize > maxBodySize) {

						conn.println("500 article is too long");

						state = PostState.Finished;

						break;

					}

				}

				break;

			}

			default: {

				// Should never happen

				Log.get().severe("PostCommand::processLine(): already finished...");

			}

		}

	}

	/**

	 * Article is a control message and needs special handling.

	 * @param article

	 */

	private void controlMessage(NNTPConnection conn, Article article)

			throws IOException {

		String[] ctrl = article.getHeader(Headers.CONTROL)[0].split(" ");

		if (ctrl.length == 2) // "cancel <mid>"

		{

			try {

				StorageManager.current().delete(ctrl[1]);

				// Move cancel message to "control" group

				article.setHeader(Headers.NEWSGROUPS, "control");

				StorageManager.current().addArticle(article);

				conn.println("240 article cancelled");

			} catch (StorageBackendException ex) {

				Log.get().severe(ex.toString());

				conn.println("500 internal server error");

			}

		} else {

			conn.println("441 unknown control header");

		}

	}

	private void supersedeMessage(NNTPConnection conn, Article article)

			throws IOException {

		try {

			String oldMsg = article.getHeader(Headers.SUPERSEDES)[0];

			StorageManager.current().delete(oldMsg);

			StorageManager.current().addArticle(article);

			conn.println("240 article replaced");

		} catch (StorageBackendException ex) {

			Log.get().severe(ex.toString());

			conn.println("500 internal server error");

		}

	}

	private void postArticle(NNTPConnection conn, Article article)

			throws IOException {

		if (article.getHeader(Headers.CONTROL)[0].length() > 0) {

			controlMessage(conn, article);

		} else if (article.getHeader(Headers.SUPERSEDES)[0].length() > 0) {

			supersedeMessage(conn, article);

		} else // Post the article regularily

		{

			// Circle check; note that Path can already contain the hostname here

			String host = Config.inst().get(Config.HOSTNAME, "localhost");

			if (article.getHeader(Headers.PATH)[0].indexOf(host + "!", 1) > 0) {

				Log.get().info(article.getMessageID() + " skipped for host " + host);

				conn.println("441 I know this article already");

				return;

			}

			// Try to create the article in the database or post it to

			// appropriate mailing list

			try {

				boolean success = false;

				String[] groupnames = article.getHeader(Headers.NEWSGROUPS)[0].split(",");

				for (String groupname : groupnames) {

					Group group = StorageManager.current().getGroup(groupname);

					if (group != null && !group.isDeleted()) {

						if (group.isMailingList() && !conn.isLocalConnection()) {

							// Send to mailing list; the Dispatcher writes

							// statistics to database

							Dispatcher.toList(article, group.getName());

							success = true;

						} else {

							// Store in database

							if (!StorageManager.current().isArticleExisting(article.getMessageID())) {

								StorageManager.current().addArticle(article);

								// Log this posting to statistics

								Stats.getInstance().mailPosted(

										article.getHeader(Headers.NEWSGROUPS)[0]);

							}

							success = true;

						}

					}

				} // end for

				if (success) {

					conn.println("240 article posted ok");

					FeedManager.queueForPush(article);

				} else {

					conn.println("441 newsgroup not found");

				}

			} catch (AddressException ex) {

				Log.get().warning(ex.getMessage());

				conn.println("441 invalid sender address");

			} catch (MessagingException ex) {

				// A MessageException is thrown when the sender email address is

				// invalid or something is wrong with the SMTP server.

				System.err.println(ex.getLocalizedMessage());

				conn.println("441 " + ex.getClass().getCanonicalName() + ": " + ex.getLocalizedMessage());

			} catch (StorageBackendException ex) {

				ex.printStackTrace();

				conn.println("500 internal server error");

			}

		}

	}

}