from twisted.internet import reactor,protocol

class EchoServ(protocol.Protocol):
    def connectionMade(self):
        self.factory.clients.append(self)

    def dataReceived(self,data):
        print self.transport.client, "sent: ", data
        self.groupmessage(data)


    def connectionLost(self,reason):
        print self.transport.client, "lost connection"
        self.factory.clients.remove(self)

    def groupmessage(self,message):
        for clients in self.factory.clients:
           clients.transport.write(message)


factory = protocol.ServerFactory()
factory.protocol = EchoServ
#factory.blocking(0)
factory.clients = []
reactor.listenTCP(9998,factory)
reactor.run()
while 1:
    EchoServ.groupmessage(raw_input())