addons/Socket/samples/ChatServer.io

   1 #!/usr/bin/env io
   2
   3 // A simple chat server
   4
   5 ChatClient := Object clone
   6 ChatClient handleSocketFromServer := method(aSocket, aServer,
   7   self server := aServer
   8   self socket := aSocket
   9   self name := "Unnamed"
  10   while(aSocket isOpen,
  11     if(aSocket read,
  12       text := aSocket readBuffer asString
  13       self handleCommand(text)
  14     )
  15     aSocket readBuffer empty
  16   )
  17   server removeClient(self)
  18   write("[Closed connection from ", socket host, "]\n")
  19 )
  20
  21 ChatClient handleCommand := method(text,
  22   if (text beginsWithSeq("name:"),
  23       self name := text substring(6, -1) replace("\n", "") replace("\r", "")
  24       return
  25   )
  26   server broadcastFrom(name .. ": " .. text, self)
  27 )
  28
  29 ChatClient send := method(text, socket write(text))
  30
  31
  32
  33 ChatServer := Server clone
  34 ChatServer clients := List clone
  35 ChatServer init := method(self clients := List clone)
  36
  37 ChatServer handleSocket := method(aSocket,
  38   write("[Accepted connection from ", aSocket host, "]\n")
  39   client := ChatClient clone
  40   clients append(client)
  41   client @handleSocketFromServer(aSocket, self)
  42 )
  43 ChatServer removeClient := method(client, clients remove(client))
  44
  45 ChatServer broadcastFrom := method(text, senderClient,
  46   write(text)
  47   clients foreach(client, if (client != senderClient, client send(text)))
  48 )
  49
  50
  51 server := ChatServer
  52 port := 8405
  53 write("Chat server starting on port ", port, "\n")
  54 server setPort(port) start
  55