Oh, thanks. 
Didn't see that.
But, now, there are some problems. The program gets stuck in the loop
on line 12, which I want the program to do in the background. (and it
shouldn't get stuck)
require 'socket'
class Session < Thread
def initialize(session)
super
puts session
@session_id, @nick, @channels = session.split(";", 3)
@host = "wowow"
@channels = @channels.split(",")
@connected = 0
@connection = TCPSocket.new("127.0.0.1", 12122)
until @connection.closed?
print "a"
if @connected == 0
login
@connected = 1
end
raw = @connection.gets
parse( raw.strip ) unless raw.nil?
end
end
def session_id
@session_id
end
def send_message( message )
puts message
end
def irc_join( channel )
irc_raw( "JOIN #{ channel }" )
end
def irc_nick( nick )
irc_raw( "NICK #{ nick }" )
@nick = nick
end
private
def irc_raw( msg )
@connection.send( "#{ msg }\r\n", 0 )
end
def login
irc_raw( "NICK #{ @nick }" )
irc_raw( "USER #{ @nick } #{ @nick } #{ @host } : #{ @nick } " )
end
def parse( line )
input = line.split(" ")
if input[0][0].chr == ":"
case input[1]
when "001"
@channels.each {|c| irc_join(c) }
when "433"
irc_nick( "#{ @nick }_" )
end
end
end
end
threads =
server = TCPServer.new("0.0.0.0", 12121)
while (session = server.accept)
session_id, message = session.gets.split(";", 2)
t = threads.map {|t| t if t["session_id"] == session_id }.delete_if
{|s| s == nil}.first
puts t
if t
puts "Found thread with existing session_id: #{session_id}"
t.send :send_message, message
else
threads << Session.new("#{session_id};#{message}") do |t|
Thread.current["session_id"] = session_id
puts "Creating thread for #{ session_id }"
end
end
session.close
end
Francis Cianfrocca wrote:
···
On 8/19/06, andreas.alin@gmail.com <andreas.alin@gmail.com> wrote:
> Yow!
> I'm trying to make a script that will act as a server (server 1), and
> when a connection to the server server 1 is made, it will start a
> thread that will connect to another server (server 2), and it will keep
> the connection to server 2, even if the client disconnects.
>
> The thing is that, as I've tried, my client/server will not connect to
> another server, and if it does, the client can not disconnect.
>
> Any ideas?
>
> Thanks,
> Andreas
>
> ----------------------
>
> require 'socket'
>
> class Session < Thread
> def initalize(session_id)
> super
> @session_id = session_id
> end
>
> def session_id
> @session_id
> end
>
> def send_message( message
> # This method should send a message to
> # server 2
> puts message
> end
> end
>
> threads =
>
> server = TCPServer.new("0.0.0.0", 12121)
>
> while (session = server.accept)
> session_id, message = session.gets.split(";", 2)
>
> t = threads.map {|t| t if t["session_id"] == session_id }.delete_if
> {|s| s == nil}.first
> puts t
> if t
> puts "Found thread with existing session_id: #{ session_id }"
> t.send :send_message, message
> else
> threads << Session.new(session) do |t|
> Thread.current["session_id"] = session_id
> puts "Creating thread for #{ session_id }"
> end
> end
> session.close
> end
>
>
>
First, make sure your constructor is getting called. You spelled it
"initalize" instead of "initialize"