source: code/trunk/upstream.go@ 16

package jounce

import (
        "crypto/tls"
        "fmt"
        "io"
        "net"

        "gopkg.in/irc.v3"
)

const (
        rpl_localusers  = "265"
        rpl_globalusers = "266"
)

type upstreamConn struct {
        upstream   *Upstream
        net        net.Conn
        irc        *irc.Conn
        srv        *Server
        registered bool

        serverName            string
        availableUserModes    string
        availableChannelModes string
        channelModesWithParam string
}

func (c *upstreamConn) handleMessage(msg *irc.Message) error {
        switch msg.Command {
        case "PING":
                // TODO: handle params
                return c.irc.WriteMessage(&irc.Message{
                        Command: "PONG",
                        Params:  []string{c.srv.Hostname},
                })
        case irc.RPL_WELCOME:
                c.registered = true
                c.srv.Logger.Printf("Connection to %q registered", c.upstream.Addr)
        case irc.RPL_MYINFO:
                if len(msg.Params) < 5 {
                        return newNeedMoreParamsError(msg.Command)
                }
                c.serverName = msg.Params[1]
                c.availableUserModes = msg.Params[3]
                c.availableChannelModes = msg.Params[4]
                if len(msg.Params) > 5 {
                        c.channelModesWithParam = msg.Params[5]
                }
        case irc.RPL_YOURHOST, irc.RPL_CREATED:
                // Ignore
        case irc.RPL_LUSERCLIENT, irc.RPL_LUSEROP, irc.RPL_LUSERUNKNOWN, irc.RPL_LUSERCHANNELS, irc.RPL_LUSERME:
                // Ignore
        case irc.RPL_MOTDSTART, irc.RPL_MOTD, irc.RPL_ENDOFMOTD:
                // Ignore
        case rpl_localusers, rpl_globalusers:
                // Ignore
        case irc.RPL_STATSVLINE, irc.RPL_STATSPING, irc.RPL_STATSBLINE, irc.RPL_STATSDLINE:
                // Ignore
        default:
                c.srv.Logger.Printf("Unhandled upstream message: %v", msg)
        }
        return nil
}

func connect(s *Server, upstream *Upstream) error {
        s.Logger.Printf("Connecting to %v", upstream.Addr)

        netConn, err := tls.Dial("tcp", upstream.Addr, nil)
        if err != nil {
                return fmt.Errorf("failed to dial %q: %v", upstream.Addr, err)
        }

        c := upstreamConn{
                upstream: upstream,
                net:      netConn,
                irc:      irc.NewConn(netConn),
                srv:      s,
        }
        defer netConn.Close()

        err = c.irc.WriteMessage(&irc.Message{
                Command: "NICK",
                Params:  []string{upstream.Nick},
        })
        if err != nil {
                return err
        }

        err = c.irc.WriteMessage(&irc.Message{
                Command: "USER",
                Params:  []string{upstream.Username, "0", "*", upstream.Realname},
        })
        if err != nil {
                return err
        }

        for {
                msg, err := c.irc.ReadMessage()
                if err == io.EOF {
                        break
                } else if err != nil {
                        return fmt.Errorf("failed to read IRC command: %v", err)
                }

                if err := c.handleMessage(msg); err != nil {
                        c.srv.Logger.Printf("Failed to handle message %q from %q: %v", msg, upstream.Addr, err)
                }
        }

        return netConn.Close()
}