package org.robsite.extension.rss;
   
   import java.awt.event.ActionEvent;
   import java.awt.event.ActionListener;
   import java.awt.event.MouseAdapter;
   import java.awt.event.MouseEvent;
   import java.awt.event.MouseListener;
   
   import java.io.InputStream;
  
  import java.net.URL;
  
  import javax.swing.ImageIcon;
  import javax.swing.JLabel;
  import javax.swing.SwingUtilities;
  import javax.swing.Timer;
  
  import oracle.ide.Ide;
  import oracle.ide.controls.StatusBarControl;
  import oracle.ide.net.URLFactory;
  import oracle.ide.util.Assert;
  
  import org.robsite.extension.rss.model.Channel;
  import org.robsite.extension.rss.model.Channels;
  import org.robsite.extension.rss.model.DirectoryParser;
  
  /***
   * The runnable that periodically checks for new news.
   * 
   * @author brian_duff@sourceforge.net
   * @version $Revision: 1.1.1.1 $
   */
  final class NewsCheckRunnable implements Runnable, ActionListener
  {
    private boolean _isRunning;
  
    private final NewsFeedExtension _extension;
    
    private final ResHelper _res = new ResHelper( "NewsChecker." );
  
    NewsCheckRunnable( NewsFeedExtension extension )
    {
      _extension = extension;
      _isRunning = true;
    }
    
    public synchronized void stop()
    {
      _isRunning = false;
      notify();
    }
    
    /***
     * Force an immediate update of all channels.
     */
    public synchronized void forceUpdate()
    {
      notify();
    }
    
    /***
     * Called on a timer tick.
     * 
     * @param ae the timer action
     */
    public synchronized void actionPerformed( ActionEvent ae )
    {
      forceUpdate();
    }
    
    private synchronized boolean isRunning()
    {
      return _isRunning;
    }
  
    public void run()
    {
      while ( isRunning() )
      {
        // Go to sleep until the timer notifies us to wake up or forceUpdate()
        // is called.
        synchronized( this )
        {
          try
          {
            wait();
          }
          catch ( InterruptedException ie )
          {
            stop();
            return;
          }
        }
        
        // Check that we're still actually running, i.e. that stop() was not
        // called.
        if ( !isRunning() )
        {
          return;
       }
       
       boolean newItems = checkForNews();
       
       // If the news dockable window is not visible, show the status bar
       // notification message.
       if ( _extension.getNewsDockable() == null && newItems )
       {
         showStatusBarMessage();
       }
     }
   }
   
   static void checkDirectory( NewsFeedPreferences prefs )
     throws Exception
   {
     URL url = URLFactory.newURL( prefs.getDirectoryURL() );
     InputStream is = url.openStream();
     DirectoryParser dirParser = new DirectoryParser();
     dirParser.parse( is, prefs.getChannels() );
   }
   
   private boolean checkForNews()
   {
     boolean newUnreadItems = false;
     boolean hadFailures = false;
     try
     {
       setWindowBusy( true );
       
       SwingUtilities.invokeLater( new Runnable() 
       {
         public void run()
         {
           Ide.getStatusBar().setText( _res.getRes( "CheckingNews" ) );
         }
       } );
       
       HTTPUtil.setHTTPTimeout( 
         NewsFeedExtension.get().getPreferences().getHTTPTimeout() );
       Channels channels = NewsFeedExtension.get().getChannels();
       
       // First, check for channels.
       setWindowStatus( _res.getRes( "CheckingForChannels" ) );
       try
       {
         checkDirectory( NewsFeedExtension.get().getPreferences() );
         setWindowStatus( "" );        
       }
       catch ( Exception e )
       {
         hadFailures = true;
         setWindowStatus( _res.getRes( "FailedToGetChannels" ) );
         e.printStackTrace();
         sleep( 2000 );
       }
 
           
       for ( int i=0; i < channels.getSubscribedChannels().size(); i++ )
       {
         // If we're stopped part-way through the loop, bail out early.
         if ( !isRunning() ) return false;
         final Channel c = (Channel) channels.getSubscribedChannels().get( i );
         try
         {
           setWindowStatus( _res.getRes( "CheckingChannel", String.valueOf( c ) ) );
           if ( channels.checkChannel( i ) > 0 )
           {
             newUnreadItems = true;
           }
           setWindowStatus( "" );
         }
         catch ( Exception e )
         {
           hadFailures = true;
           setWindowStatus( _res.getRes( "FailedToCheck", c.getURL() ) );
           
           e.printStackTrace();
           
           // Back off for a small delay so the user has time to see the 
           // status message.
           sleep( 2000 );          
         }
         
 
       }
             
     }
     catch ( RuntimeException re )
     {
       Assert.println( "Runtime Exception during news check" );
       re.printStackTrace();
     }
     finally
     {
       setWindowBusy( false );
       
       SwingUtilities.invokeLater( new Runnable() 
       {
         public void run()
         {
           Ide.getStatusBar().setText( "" );
         }
       } );      
       HTTPUtil.resetHTTPTimeout();
       if ( hadFailures )
       {
         setWindowStatus( _res.getRes( "FailedToConnect" ) );
       }
     }
     return newUnreadItems;
   }
   
   private void showStatusBarMessage()
   {
     SwingUtilities.invokeLater( new Runnable() 
     {
       public void run()
       {
         Ide.getStatusBar().setText( _res.getRes( "GotNewNews" )  );
         final JLabel l = new JLabel();
         l.setIcon( new ImageIcon( NewsCheckRunnable.class.getResource( "xml.gif" )) );
         l.setText( _res.getRes( "ClickToRead" ) );
         
         final MouseListener labelListener = new MouseAdapter() {
           public void mouseClicked( MouseEvent me )
           {
             if ( me.getButton() == MouseEvent.BUTTON1 )
             {
               try
               {
                 Commands.getAction( Commands.VIEW_NEWS_DOCKABLE ).performAction();
                 ((StatusBarControl)Ide.getStatusBar()).remove( l );
                 l.removeMouseListener( this );
               }
               catch ( Exception e ) {}
             }
           }
         };
         l.addMouseListener( labelListener );
         
         ((StatusBarControl)Ide.getStatusBar()).add( l );
         Timer t = new Timer( 
           1000 * _extension.getPreferences().getStatusMessageDuration(), 
         new ActionListener() 
         {
           public void actionPerformed( ActionEvent ae )
           {
             ((StatusBarControl)Ide.getStatusBar()).remove( l );
             l.removeMouseListener( labelListener );
           }
         });
         t.setRepeats( false );
         t.start();
       }
     } );
   }
   
   private void sleep( int ms )
   {
     try
     {
       Thread.sleep( ms );
     }
     catch ( InterruptedException ie )
     {
       
     }
   }
   
   private void setWindowBusy( final boolean isBusy )
   {
     if ( _extension.getNewsDockable() != null )
     {
       SwingUtilities.invokeLater( new Runnable() 
       {
         public void run()
         {
           _extension.getNewsDockable().getPanel().setBusy( isBusy );
         }
       } );
     }
   }
   
   private void setWindowStatus( final String text )
   {
     if ( _extension.getNewsDockable() != null )
     {
       SwingUtilities.invokeLater( new Runnable() 
       {
         public void run()
         {
           _extension.getNewsDockable().getPanel().setStatusText( text );
         }
       } );
     }
   }
 }