001         package com.croftsoft.core.net.news;
002    
003         import java.io.*;
004         import java.net.*;
005         import java.util.*;
006    
007         import com.croftsoft.core.lang.Pair;
008         import com.croftsoft.core.lang.StringLib;
009         import com.croftsoft.core.security.Authentication;
010         import com.croftsoft.core.security.Identifier;
011         import com.croftsoft.core.security.PreIdentifier;
012         import com.croftsoft.core.util.log.Log;
013         import com.croftsoft.core.util.log.PrintStreamLog;
014    
015         /*********************************************************************
016         * Static library methods for NNTP (RFC 977).
017         *
018         * @author
019         *   <a href="http://croftsoft.com/">David Wallace Croft</A>
020         * @version
021         *   2001-08-03
022         * @since
023         *   2001-07-23
024         *********************************************************************/
025    
026         public final class  NntpLib
027           implements NntpConstants
028         //////////////////////////////////////////////////////////////////////
029         //////////////////////////////////////////////////////////////////////
030         {
031    
032         /*********************************************************************
033         * Posts a test message to a test newsgroup.
034         *********************************************************************/
035         public static void  main ( String [ ]  args )
036           throws IOException
037         //////////////////////////////////////////////////////////////////////
038         {
039           String  nntpServer = args [ 0 ];
040    
041           String  username   = args [ 1 ];
042    
043           String  password   = args [ 2 ];
044    
045           UsenetMessage  usenetMessage = new UsenetMessage (
046             args [ 3 ],          // from
047             "alt.test",          // newsgroup
048             "test",              // subject
049             "This is a test." ); // body
050    
051           post (
052             nntpServer,
053             new PreIdentifier ( username, password ),
054             usenetMessage,
055             new PrintStreamLog ( System.out ) );
056         }
057    
058         //////////////////////////////////////////////////////////////////////
059         //////////////////////////////////////////////////////////////////////
060    
061         /*********************************************************************
062         * Sends username and password.
063         *
064         * Synchronizes on the NntpSocket.
065         *********************************************************************/
066         public static String  authenticate (
067           NntpSocket  nntpSocket,
068           String      username,
069           String      password )
070           throws IOException, SecurityException
071         //////////////////////////////////////////////////////////////////////
072         {
073           synchronized ( nntpSocket )
074           {
075    
076           String  responseCode
077             = nntpSocket.command ( COMMAND_AUTHINFO + " USER " + username );
078    
079           if ( responseCode.startsWith ( "502" ) )
080           {
081             // 502 Authentication Failed
082    
083             throw new SecurityException ( responseCode );
084           }
085    
086           // 381 More Authentication Required
087    
088           Log  log = nntpSocket.getLog ( );
089    
090           nntpSocket.setLog ( null );
091    
092           responseCode
093             = nntpSocket.command ( COMMAND_AUTHINFO + " PASS " + password );
094    
095           nntpSocket.setLog ( log );
096    
097           if ( responseCode.startsWith ( "502" ) )
098           {
099             // 502 Authentication Failed
100    
101             throw new SecurityException ( responseCode );
102           }
103    
104           // 281 Authentication Accepted
105    
106           return responseCode;
107    
108           }
109         }
110    
111         /*********************************************************************
112         * Replaces lines that start with "." with "..",
113         * appends CR_LF to each line, then
114         * adds a final line of "." + CR_LF.
115         *********************************************************************/
116         public static StringBuffer  encodeLines ( String [ ]  lines )
117         //////////////////////////////////////////////////////////////////////
118         {
119           StringBuffer  stringBuffer = new StringBuffer ( );
120    
121           for ( int  i = 0; i < lines.length; i++ )
122           {
123             String  line = lines [ i ];
124    
125             if ( line.startsWith ( "." ) )
126             {
127               stringBuffer.append ( "." );
128             }
129    
130             stringBuffer.append ( line );
131    
132             stringBuffer.append ( CR_LF );
133           }
134    
135           stringBuffer.append ( "." + CR_LF );
136    
137           return stringBuffer;
138         }
139    
140         /*********************************************************************
141         * Encodes a message body in preparation for an NNTP POST transmission.
142         *
143         * <pre>
144         * return encodeLines (
145         *   StringLib.toStringArray ( messageBody ) ).toString ( );
146         * </pre>
147         *********************************************************************/
148         public static String  encode ( String  messageBody )
149         //////////////////////////////////////////////////////////////////////
150         {
151           return encodeLines (
152             StringLib.toStringArray ( messageBody ) ).toString ( );
153         }
154    
155         /*********************************************************************
156         * Replaces lines that start with ".." with ".".
157         *********************************************************************/
158         public static void  decodeLines ( String [ ]  lines )
159         //////////////////////////////////////////////////////////////////////
160         {
161           for ( int  i = 0; i < lines.length; i++ )
162           {
163             lines [ i ] = decodeLine ( lines [ i ] );
164           }
165         }
166    
167         /*********************************************************************
168         * Replaces starting ".." with ".".
169         *********************************************************************/
170         public static String  decodeLine ( String  line )
171         //////////////////////////////////////////////////////////////////////
172         {
173           if ( line.startsWith ( ".." ) )
174           {
175             return line.substring ( 1 );
176           }
177    
178           return new String ( line );
179         }
180    
181         public static String  post (
182           String         nntpServer,
183           Identifier     identifier,
184           UsenetMessage  usenetMessage,
185           Log            log )
186           throws IOException
187         //////////////////////////////////////////////////////////////////////
188         {
189           String  responseCode = null;
190    
191           NntpSocket  nntpSocket = null;
192    
193           try
194           {
195             nntpSocket = new NntpSocket ( nntpServer, log );
196    
197             nntpSocket.setSoLinger ( true, 30 ); // timeout after 30 seconds
198    
199             responseCode = nntpSocket.getResponseCode ( );
200    
201             if ( !nntpSocket.getPostingAllowed ( ) )
202             {
203               throw new IOException ( responseCode );
204             }
205    
206             responseCode = nntpSocket.command ( NntpConstants.COMMAND_POST );
207    
208             if ( responseCode.startsWith ( "480" )
209               && ( identifier != null ) )
210             {
211               // 480 Authentication Required
212    
213               Authentication  authentication
214                 = identifier.getAuthentication ( );
215    
216               if ( authentication != null )
217               {
218                 responseCode = authenticate (
219                   nntpSocket,
220                   authentication.getUsername ( ),
221                   authentication.getPassword ( ) );
222    
223                 responseCode
224                   = nntpSocket.command ( NntpConstants.COMMAND_POST );
225               }
226             }
227    
228             if ( !responseCode.startsWith ( "340" ) )
229             {
230               throw new IOException ( responseCode );
231             }
232    
233             responseCode = nntpSocket.command ( usenetMessage.toString ( ) );
234    
235             if ( !responseCode.startsWith ( "240" ) )
236             {
237               throw new IOException ( responseCode );
238             }
239    
240             responseCode = nntpSocket.command_QUIT ( );
241           }
242           finally
243           {
244             if ( nntpSocket != null )
245             {
246               nntpSocket.close ( );
247             }
248           }
249    
250           return responseCode;
251         }
252    
253    /*
254         public static String  post (
255           String      nntpServer,
256           Identifier  identifier,
257           Pair [ ]    messageHeaderPairs,
258           String      messageBody,
259           Log         log ) 
260           throws IOException
261         //////////////////////////////////////////////////////////////////////
262         {
263           UsenetMessage  usenetMessage = new UsenetMessage ( );
264    
265           for ( int  i = 0; i < messageHeaderPairs.length; i++ )
266           {
267             Pair  headerPair = messageHeaderPairs [ i ];
268    
269             usenetMessage.setHeader ( headerPair.name, headerPair.value );
270           }
271    
272           usenetMessage.setBody ( messageBody );
273    
274           return NntpLib.post (
275             nntpServer, username, password, usenetMessage, log );
276         }
277    */
278    
279         //////////////////////////////////////////////////////////////////////
280         //////////////////////////////////////////////////////////////////////
281    
282         private  NntpLib ( ) { }
283    
284         //////////////////////////////////////////////////////////////////////
285         //////////////////////////////////////////////////////////////////////
286         }