/*

 *   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.concurrent.ConcurrentLinkedQueue;

import org.sonews.storage.Article;

import org.sonews.storage.Headers;

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 AbstractFeeder

{

  private ConcurrentLinkedQueue<Article> articleQueue = 

    new ConcurrentLinkedQueue<Article>();

  @Override

  public void run()

  {

    while(isRunning())

    {

      try

      {

        synchronized(this)

        {

          this.wait();

        }

        Article  article = this.articleQueue.poll();

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

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

        for(Subscription sub : this.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(InterruptedException ex)

      {

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

      }

    }

  }

  public void queueForPush(Article article)

  {

    this.articleQueue.add(article);

    synchronized(this)

    {

      this.notifyAll();

    }

  }

}