In order to learn some basics about sockets I'm trying to program a simple IRC client. In order to receive server messages I have a thread that is receiving from the socket. When sending commands to the server a new thread is created, with the same socket. This doesn't seem to work. The commands are executed, but do not seem to be sent through the socket (nothing happens).
So, my question is this. Is this approach, with threads and a socket, impossible to realise? An IRC client needs to have only one persistent connection, right? Can I get any feedback from the socket.send, when sending commands, to get a clue of whats happening? I'm attaching the present code if anyone wants to see it.

# Echo client program
import socket, threading
from time import gmtime, strftime

HOST = ''  # The remote host
PORT = 6667              # The same port as used by the server
NICK = "hadoque"         # Irc nickname
IDENT = "hadoque"        # Irc Ident
REALNAME = "Johan"       # Irc real name

lock = threading.Lock()

#***class Parser ***
#Takes a socket and a command, sends a formatted command to server
class Parser(threading.Thread): 
    def run(self):

    def __init__(self, socket, command):
        self.socket = socket
        self.command = command.split()
        global HOST
        global PORT
        global NICK
        global IDENT
        global REALNAME

    #function sendToServer
    #Takes a string to be sent, sends it and prints the sent command with a time stamp
    def sendToServer(self, snd):
        print ">>", strftime("%H:%M:%S", gmtime()), snd
    #function serverParser
    #handles server pings by sending back a PONG
    def serverParser(self, buf):
        buf = buf.split()
        if buf[0].lower() == "ping":
            self.sendToServer("PONG %s" % buf[1])

    #Checks for commands and sends the formatted version of the command to the server
    def run(self):
#        print "\033[95m", strftime("%H:%M:%S", gmtime()), threading.currentThread(), "\033[0m"
        #QUIT command
        if self.command[0].lower() == "quit":

        #JOIN #channel command
        if self.command[0].lower() == "join":
            self.sendToServer("JOIN %s" % self.command[1])

        #connects to server by socket and sends login commands to server
        #after this it listens for server messages and pings
        if self.command[0].lower() == "connect":
            self.socket.connect((HOST, PORT))
            print "Connected to", HOST, "port", PORT
            self.sendToServer("NICK %s\r\n" % NICK)
            self.sendToServer("USER %s %s bla :%s \r\n" % (IDENT, HOST, REALNAME))
            dataBuffer = ""

            #This loop receives data from socket and looks for "\r\n", since every server message
            #is ended with this. When finding a "\r\n" it cuts the received data at that point
            #and prints to screen with a time stamp.
            while True:
                data = self.socket.recv(512)
                dataBuffer += data

                while "\r\n" in dataBuffer:
                    part_data = dataBuffer.partition("\r\n")
                    dataBuffer = part_data[0]
                    print strftime("%H:%M:%S", gmtime()), dataBuffer
                    dataBuffer = part_data[2]


s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

#Waits for user input. Starts a new thread for every command passed
while True:
    cmd = raw_input(">>")
    Parser(s, cmd).start()
7 Years
Discussion Span
Last Post by hadoque

Ok, sorry about that. I discovered that I had missed a trailing "\r\n" when sending to the server...

This question has already been answered. Start a new discussion instead.
Have something to contribute to this discussion? Please be thoughtful, detailed and courteous, and be sure to adhere to our posting rules.