irc.go

irc.go

package irc
 
import(
  "net/textproto"
  "regexp"
  "time"
)
 
var (
  privmsg = regexp.MustCompile("^:([a-zA-Z0-9`_\\-]+)![a-zA-Z0-9/\\\\\\.\\-]+@[a-zA-Z0-9/\\\\\\.\\-]+ PRIVMSG (#[a-zA-Z0-9]+) :(.*)$")
  ping    = regexp.MustCompile("^PING :([a-zA-Z0-9\\.]+)$")
)
 
type Client struct {
  conn *textproto.Conn
  User string
  Pass string
 
  onMessage func(string, string)
}
 
func (client *Client) ConnectTo(server string) error {
  c, err := textproto.Dial("tcp", server + ":6667")
  if err != nil {
    return err
  }
 
  c.Cmd("PASS %s\r\n", client.Pass)
  c.Cmd("NICK %s\r\n", client.User)
  c.Cmd("USER %s * * :...\r\n", client.User)
 
  client.conn = c
  return nil
}
 
func (client *Client) Join(channel string) {
  client.conn.Cmd("JOIN %s\r\n", channel)
}
 
func (client *Client) OnMessage(cb func(string, string)) {
  client.onMessage = cb
}
 
func (client *Client) Loop() {
  ch := make(chan string)

  go func() {
    for {
      d, _ := client.conn.ReadLine()
      ch <- d
    }
  }()

  go func(in <-chan string) {
    for {
      d := <-in
      if m := privmsg.FindStringSubmatch(d); m != nil {
        go client.onMessage(m[1], m[3])
      }

      if m := ping.FindStringSubmatch(d); m != nil {
        client.conn.Cmd("PONG :%s\r\n", m[1])
      }
    }
  }(ch)

  for {    
    time.Sleep(50 * time.Millisecond)
  }
}