class Cinch::DCC::Outgoing::Send
DCC
SEND is a protocol for transferring files, usually found in IRC
. While the handshake, i.e. the details of the file transfer, are transferred over IRC
, the actual file transfer happens directly between two clients. As such it doesn't put stress on the IRC
server.
Cinch
allows sending files by either using {Cinch::User#dcc_send}, which takes care of all parameters as well as setting up resume support, or by creating instances of this class directly. The latter will only be useful to people working on the Cinch
code itself.
{Cinch::User#dcc_send} expects an object to send as well as optionaly a file name, which is sent to the receiver as a suggestion where to save the file. If no file name is provided, the method will use the object's `#path` method to determine it.
Any object that implements {DCC::DCCableObject} can be sent, but sending files will probably be the most common case.
If you're behind a NAT it is necessary to explicitly set the external IP using the {file:docs/bot_options.md#dccownip dcc.own_ip option}.
@example Sending a file to a user
match "send me something" def execute(m) m.user.dcc_send(open("/tmp/cookies")) end
Public Class Methods
@param [Hash] opts @option opts [User] receiver @option opts [String] filename @option opts [File] io @option opts [String] own_ip
# File lib/cinch/dcc/outgoing/send.rb, line 46 def initialize(opts = {}) @receiver, @filename, @io, @own_ip = opts.values_at(:receiver, :filename, :io, :own_ip) end
Public Instance Methods
Listen for an incoming connection.
This starts listening for an incoming connection to the server started by {#start_server}. After a client successfully connected, the server socket will be closed and the file transferred to the client.
@raise [Timeout::Error] Raised if the receiver did not connect
within 30 seconds
@return [void] @note This method blocks.
# File lib/cinch/dcc/outgoing/send.rb, line 77 def listen fd = nil Timeout.timeout(30) do fd, _ = @socket.accept end send_data(fd) fd.close ensure @socket.close end
@return [Fixnum] The port used for the socket
# File lib/cinch/dcc/outgoing/send.rb, line 98 def port @port ||= @socket.addr[1] end
Seek to `pos` in the data.
@param [Integer] pos @return [void] @api private
# File lib/cinch/dcc/outgoing/send.rb, line 93 def seek(pos) @io.seek(pos) end
Send
the handshake to the user.
@return [void]
# File lib/cinch/dcc/outgoing/send.rb, line 61 def send_handshake handshake = "\001DCC SEND %s %d %d %d\001" % [@filename, IPAddr.new(@own_ip).to_i, port, @io.size] @receiver.send(handshake) end
Start the server
@return [void]
# File lib/cinch/dcc/outgoing/send.rb, line 53 def start_server @socket = TCPServer.new(0) @socket.listen(1) end
Private Instance Methods
# File lib/cinch/dcc/outgoing/send.rb, line 104 def send_data(fd) @io.advise(:sequential) while chunk = @io.read(8096) loop do rs, ws = IO.select([fd], [fd]) rs.first.recv(8096) unless rs.empty? unless ws.empty? ws.first.write(chunk) break end end end end