/*

 *   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.feed;

import java.io.IOException;

import java.util.List;

import java.util.concurrent.ConcurrentLinkedQueue;

import org.sonews.daemon.AbstractDaemon;

import org.sonews.storage.Article;

import org.sonews.storage.Headers;

import org.sonews.storage.StorageBackendException;

import org.sonews.storage.StorageManager;

import org.sonews.util.Log;

import org.sonews.util.io.ArticleWriter;

/**

 * Pushes new articles to remote newsservers. This feeder sleeps until a new

 * message is posted to the sonews instance.

 * @author Christian Lins

 * @since sonews/0.5.0

 */

class PushFeeder extends AbstractDaemon

{

	private ConcurrentLinkedQueue<Article> articleQueue =

		new ConcurrentLinkedQueue<Article>();

	@Override

	public void run()

	{

		while (isRunning()) {

			try {

				synchronized (this) {

					this.wait();

				}

				List<Subscription> subscriptions = StorageManager.current().getSubscriptions(FeedManager.TYPE_PUSH);

				Article article = this.articleQueue.poll();

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

				Log.get().info("PushFeed: " + article.getMessageID());

				for (Subscription sub : subscriptions) {

					// Circle check

					if (article.getHeader(Headers.PATH)[0].contains(sub.getHost())) {

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

							+ sub.getHost());

						continue;

					}

					try {

						for (String group : groups) {

							if (sub.getGroup().equals(group)) {

								// Delete headers that may cause problems

								article.removeHeader(Headers.NNTP_POSTING_DATE);

								article.removeHeader(Headers.NNTP_POSTING_HOST);

								article.removeHeader(Headers.X_COMPLAINTS_TO);

								article.removeHeader(Headers.X_TRACE);

								article.removeHeader(Headers.XREF);

								// POST the message to remote server

								ArticleWriter awriter = new ArticleWriter(sub.getHost(), sub.getPort());

								awriter.writeArticle(article);

								break;

							}

						}

					} catch (IOException ex) {

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

					}

				}

			} catch (StorageBackendException ex) {

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

			} catch (InterruptedException ex) {

				Log.get().warning("PushFeeder interrupted: " + ex);

			}

		}

	}

	public void queueForPush(Article article)

	{

		this.articleQueue.add(article);

		synchronized (this) {

			this.notifyAll();

		}

	}

}