From ec8a9bba354e3bcdb7b7b004d3ce3d148bd9fc7f Mon Sep 17 00:00:00 2001 From: matz Date: Wed, 13 Oct 1999 07:29:15 +0000 Subject: maillib-1.0.2 git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@541 b2dd03c8-39d4-4d8f-98ff-823fe69b080e --- lib/net/pop.rb | 207 +++++++++++++++++++++++++++++++++++++++-- lib/net/session.rb | 267 ++++++++++++++++++++++++++++++++++++++++++++++------- lib/net/smtp.rb | 103 +++++++++++++++++++-- 3 files changed, 528 insertions(+), 49 deletions(-) diff --git a/lib/net/pop.rb b/lib/net/pop.rb index bd4551571d..c492a4cd20 100644 --- a/lib/net/pop.rb +++ b/lib/net/pop.rb @@ -1,8 +1,14 @@ -# -# pop.rb version 1.0.1 -# -# author: Minero Aoki -# +=begin + += Net module version 1.0.2 reference manual + +pop.rb written by Minero Aoki + +This library is distributed under the terms of Ruby style license. +You can freely distribute/modify/copy this file. + +=end + require 'net/session' require 'md5' @@ -10,8 +16,44 @@ require 'md5' module Net +=begin + +== Net::POP3Session + +=== Super Class + +Net::Session + +=== Class Methods + +: new( address = 'localhost', port = 110 ) + + This method create a new POP3Session object but this will not open connection. + +=end + class POP3Session < Session + +=begin + +=== Methods + +: start( account, password ) + + This method start POP session. + +: each{|popmail| ...} + + This method is equals to "POP3Session.mails.each" + +: mails + + This method returns an array of POP3Session::POPMail. + This array is renewed when login. + +=end + attr :mails def each() @mails.each{|m| yield m} end @@ -44,6 +86,17 @@ module Net end +=begin + +== Net::POP3Session::POPMail + +A class of mail which exists on POP server. + +=== Super Class + +Object + +=end class POPMail @@ -55,6 +108,39 @@ module Net @deleted = false end +=begin + +=== Method + +: all +: pop +: mail + + This method fetches a mail and return it. + +: header + + This method fetches only mail header. + +: top( lines ) + + This method fetches mail header and 'lines' lines body. + +: delete +: delete! + + This method deletes mail. + +: size + + size of mail(bytes) + +: deleted? + + true if mail was deleted + +=end + attr :size def all( dest = '' ) @@ -83,8 +169,23 @@ module Net end - end + end # POP3Session + + POPSession = POP3Session + POP3 = POP3Session + +=begin + +== Net::APOP3Session + +This class has no new methods. Only way of authetication is changed. + +=== Super Class + +Net::POP3Session + +=end class APOPSession < POP3Session @@ -95,14 +196,85 @@ module Net end + APOP = APOPSession - POPSession = POP3Session - POP3 = POP3Session +=begin + +== Net::POP3Command + +POP3 protocol class. + +=== Super Class + +Net::Command + +=== Class Methods +: new( socket ) + + This method creates new POP3Command object. 'socket' must be ProtocolSocket. + +=end class POP3Command < Command + +=begin + +=== Methods + +: auth( account, password ) + + This method do POP authorization (no RPOP) + In case of failed authorization, raises Protocol::ProtocolError exception. + +: list + + a list of mails which existing on server. + The list is an array like "array[ number ] = size". + + ex: + + The list from server is + + 1 2452 + 2 3355 + 4 9842 + : + + then, an array is + + [ nil, 2452, 3355, nil, 9842, ... ] + +: quit + + This method finishes POP3 session. + +: rset + + This method reset all changes done in current session, + by sending 'RSET' command. + +: top( num, lines = 0 ) + + This method gets all mail header and 'lines' lines body + by sending 'TOP' command. 'num' is mail number. + + WARNING: the TOP command is 'Optional' in RFC1939 (POP3) + + +: retr( num : Integer ) + + This method gets a mail by 'RETR' command. 'num' is mail number. + + +: dele( num : Integer ) + + This method deletes a mail on server by 'DELE'. + +=end + def auth( acnt, pass ) @socket.writeline( 'USER ' + acnt ) check_reply_auth @@ -190,6 +362,23 @@ module Net end +=begin + +== APOPCommand + +=== Super Class + +POP3 + +=== Methods + +: auth( account, password ) + + This method do authorization by sending 'APOP' command. + If server is not APOP server, this raises Net::ProtoAuthError exception. + On other errors, raises Net::ProtocolError. + +=end class APOPCommand < POP3Command @@ -223,7 +412,7 @@ module Net end - unless Session::Version == '1.0.1' then + unless Session::Version == '1.0.2' then $stderr.puts "WARNING: wrong version of session.rb & pop.rb" end diff --git a/lib/net/session.rb b/lib/net/session.rb index b0977e7e14..3f7ef7f51f 100644 --- a/lib/net/session.rb +++ b/lib/net/session.rb @@ -1,8 +1,14 @@ -# -# session.rb version 1.0.1 -# -# author: Minero Aoki -# +=begin + += Net module version 1.0.2 reference manual + +session.rb written by Minero Aoki + +This library is distributed under the terms of Ruby style license. +You can freely distribute/modify/copy this file. + +=end + require 'socket' @@ -19,16 +25,47 @@ class String end +=begin -module Net +== Net::Session + +the abstruct class for Internet session + +=== Super Class + +Object + +=== Constants + +: Version + + The version of Session class. It is a string like "1.0.2". + +=end - DEBUG = $DEBUG - # DEBUG = false +module Net class Session - Version = '1.0.1' + Version = '1.0.2' + +=begin + +=== Class Methods + +: new( address = 'localhost', port = nil ) + + This method Create a new Session object. + +: start( address = 'localhost', port = nil, *args ) +: start( address = 'localhost', port = nil, *args ){|session| .... } + + This method create a new Session object and start session. + If you call this method with block, Session object give itself + to block and finish session when block returns. + +=end def initialize( addr = 'localhost', port = nil ) proto_initialize @@ -50,6 +87,19 @@ module Net end end +=begin + +=== Methods + +: address + + the address of connecting server (FQDN). + +: port + + connecting port number + +=end attr :address attr :port @@ -59,21 +109,45 @@ module Net attr :proto_type attr :proto, true +=begin + +: start( *args ) + + This method start session. If you call this method when the session + is already started, this only returns false without doing anything. + + '*args' are specified in subclasses. + +: finish + + This method finish session. If you call this method before session starts, + it only return false without doing anything. + +: active? + + true if session have been started + +=end + def start( *args ) return false if active? + @active = true if ProtocolSocket === args[0] then @socket = args.shift + @socket.pipe = @pipe else - @socket = ProtocolSocket.open( @address, @port ) + @socket = ProtocolSocket.open( @address, @port, @pipe ) end + @pipe = nil + @proto = @proto_type.new( @socket ) do_start( *args ) - - @active = true end def finish + @active = false + if @proto then do_finish @proto = nil @@ -86,9 +160,36 @@ module Net def active?() @active end + def set_pipe( arg ) + @pipe = arg + end + end +=begin + +== Net::Command + +=== Super Class + +Object + +=== Class Methods + +: new( socket ) + + This method create new Command object. 'socket' must be ProtocolSocket. + This method is abstract class. + + +=== Methods + +: quit + + This method finishes protocol. + +=end class Command @@ -181,12 +282,28 @@ MES end +=begin + +== Net::ProtocolSocket + +=== Super Class + +Object + +=== Class Methods + +: new( address = 'localhost', port = nil ) + + This create new ProtocolSocket object, and connect to server. + +=end class ProtocolSocket - def initialize( addr, port ) + def initialize( addr, port, pipe = nil ) @address = addr @port = port + @pipe = pipe @ipaddr = '' @closed = false @@ -195,14 +312,39 @@ MES @socket = TCPsocket.new( addr, port ) @ipaddr = @socket.addr[3] - - @dout = Net::DEBUG end + attr :pipe, true + class << self alias open new end +=begin + +=== Methods + +: close + + This method closes socket. + +: addr + + a FQDN address of server + +: ipaddr + + an IP address of server + +: port + + connecting port number. + +: closed? + + true if ProtocolSokcet have been closed already + +=end attr :socket, true @@ -225,6 +367,36 @@ MES TERMEXP = /\n|\r\n|\r/o +=begin + +: read( length ) + + This method read 'length' bytes and return the string. + +: readuntil( target ) + + This method read until find 'target'. Returns read string. + +: readline + + read until "\r\n" and returns it without "\r\n". + +: read_pendstr + + This method read until "\r\n.\r\n". + At the same time, delete period at line head and final line ("\r\n.\r\n"). + +: read_pendlist +: read_pendlist{|line| .... } + + This method read until "\r\n.\r\n". This method resembles to 'read_pendstr', + but 'read_pendlist' don't check period at line head, and returns array which + each element is one line. + + When this method was called with block, evaluate it for each reading a line. + +=end + def read( len, ret = '' ) rsize = 0 @@ -256,7 +428,7 @@ MES def read_pendstr( dest = '' ) - $stderr.puts "reading pendstr" if pre = @dout ; @dout = false + @pipe << "reading text...\n" if pre = @pipe ; @pipe = nil rsize = 0 @@ -266,12 +438,14 @@ MES dest << str end - $stderr.puts "read pendstr #{rsize} bytes" if @dout = pre + @pipe << "read #{rsize} bytes\n" if @pipe = pre return dest end def read_pendlist + @pipe << "reading list...\n" if pre = @pipe ; @pipe = nil + arr = [] str = nil call = iterator? @@ -282,6 +456,7 @@ MES yield str if iterator? end + @pipe << "read #{arr.size} lines\n" if @pipe = pre return arr end @@ -300,16 +475,34 @@ MES ret = @buffer[ 0, len ] @buffer = @buffer[ len, bsi - len ] - if @dout then - $stderr.print 'read "' - debugout ret - $stderr.print "\"\n" - end + @pipe << %{read "#{debugstr ret}"\n} if @pipe return ret end - ### write +=begin + +: write( src ) + + This method send 'src'. ProtocolSocket read strings from 'src' by 'each' + iterator. This method returns written bytes. + +: writebin( src ) + + This method send 'src'. ProtocolSokcet read string from 'src' by 'each' + iterator. This method returns written bytes. + +: writeline( str ) + + This method writes 'str'. There has not to be bare "\r" or "\n" in 'str'. + +: write_pendstr( src ) + + This method writes 'src' as a mail. + ProtocolSocket reads strings from 'src' by 'each' iterator. + This returns written bytes. + +=end public @@ -341,8 +534,7 @@ MES def write_pendstr( src ) - $stderr.puts "writing pendstr from #{src.type}" if pre = @dout - @dout = false + @pipe << "writing text from #{src.type}" if pre = @pipe ; @pipe = nil do_write_beg each_crlf_line( src ) do |line| @@ -352,7 +544,7 @@ MES do_write_do D_CRLF wsize = do_write_fin - $stderr.puts "wrote pendstr #{wsize} bytes" if @dout = pre + @pipe << "wrote #{wsize} bytes text" if @pipe = pre return wsize end @@ -382,7 +574,7 @@ MES buf << "\n" unless /\n|\r/o === buf[-1,1] beg = 0 - while pos = buf.index(TERMEXP, beg) do + while pos = buf.index( TERMEXP, beg ) do pos += $&.size tmp = buf[ beg, pos - beg ] tmp.chop! @@ -393,39 +585,46 @@ MES def do_write_beg - $stderr.print 'write "' if @dout + @wtmp = 'write "' if @pipe @writtensize = 0 @sending = '' end def do_write_do( arg ) - debugout arg if @dout + @wtmp << debugstr( arg ) if @pipe if @sending.size < 128 then @sending << arg else @sending << '...' unless @sending[-1] == ?. end + s = @socket.write( arg ) @writtensize += s return s end def do_write_fin - $stderr.puts if @dout + if @pipe then + @wtmp << "\n" + @pipe << @wtmp + @wtmp = nil + end @socket.flush return @writtensize end - def debugout( ret ) - while ret and tmp = ret[ 0, 50 ] do - ret = ret[ 50, ret.size - 50 ] + def debugstr( str ) + ret = '' + while str and tmp = str[ 0, 50 ] do + str = str[ 50, str.size - 50 ] tmp = tmp.inspect - $stderr.print tmp[ 1, tmp.size - 2 ] + ret << tmp[ 1, tmp.size - 2 ] end + ret end end diff --git a/lib/net/smtp.rb b/lib/net/smtp.rb index 9f534c20c0..de97feaa23 100644 --- a/lib/net/smtp.rb +++ b/lib/net/smtp.rb @@ -1,12 +1,34 @@ -# -# smtp.rb version 1.0.1 -# -# author Minero Aoki -# +=begin + += Net module version 1.0.2 reference manual + +smtp.rb written by Minero Aoki + +This library is distributed under the terms of Ruby style license. +You can freely redistribute/modify/copy this file. + +=end + require 'net/session' +=begin + +== Net::SMTPSession + +=== Super Class + +Net::Session + +=== Class Methods + +: new( address = 'localhost', port = 25 ) + + This method create new SMTPSession object. + +=end + module Net class SMTPSession < Session @@ -16,6 +38,33 @@ module Net @port = 25 end +=begin + +=== Methods + +: start( helo_domain = ENV['HOSTNAME'] ) + + This method opens TCP connection and start SMTP session. + If session had been started, do nothing and return false. + +: sendmail( mailsrc, from_domain, to_addrs ) + + This method sends 'mailsrc' as mail. SMTPSession read strings from 'mailsrc' + by calling 'each' iterator, and convert them into "\r\n" terminated string when write. + + SMTPSession's Exceptions are: + * Protocol::ProtoSyntaxError: syntax error (errno.500) + * Protocol::ProtoFatalError: fatal error (errno.550) + * Protocol::ProtoUnknownError: unknown error + * Protocol::ProtoServerBusy: temporary error (errno.420/450) + +: finish + + This method closes SMTP session. + If session had not started, do nothind and return false. + +=end + def sendmail( mailsrc, fromaddr, toaddrs ) @proto.mailfrom( fromaddr ) @proto.rcpt( toaddrs ) @@ -43,6 +92,48 @@ module Net SMTP = SMTPSession +=begin + +== Net::SMTPCommand + +=== Super Class + +Net::Command + +=== Class Methods + +: new( socket ) + + This method creates new SMTPCommand object, and open SMTP session. + + +=== Methods + +: helo( helo_domain ) + + This method send "HELO" command and start SMTP session.
+ helo_domain is localhost's FQDN. + +: mailfrom( from_addr ) + + This method sends "MAIL FROM" command.
+ from_addr is your mail address(????@????). + +: rcpt( to_addrs ) + + This method sends "RCPT TO" command.
+ to_addrs is array of mail address(???@???) of destination. + +: data( mailsrc ) + + This method send 'mailsrc' as mail. SMTP reads strings from 'mailsrc' + by calling 'each' iterator. + +: quit + + This method sends "QUIT" command and ends SMTP session. + +=end class SMTPCommand < Command @@ -121,7 +212,7 @@ module Net end - unless Session::Version == '1.0.1' then + unless Session::Version == '1.0.2' then $stderr.puts "WARNING: wrong version of session.rb & smtp.rb" end -- cgit v1.2.3