dispatch/irc/conn.go

package irc

import (
	"bufio"
	"crypto/tls"
	"fmt"
	"log"
	"net"
	"strings"
	"time"
)

func (c *Client) Connect(address string) {
	c.ConnectionChanged <- false

	if idx := strings.Index(address, ":"); idx < 0 {
		c.Host = address

		if c.TLS {
			address += ":6697"
		} else {
			address += ":6667"
		}
	} else {
		c.Host = address[:idx]
	}
	c.Server = address
	c.dialer = &net.Dialer{Timeout: 10 * time.Second}

	go c.run()
}

func (c *Client) Write(data string) {
	c.out <- data + "\r\n"
}

func (c *Client) Writef(format string, a ...interface{}) {
	c.out <- fmt.Sprintf(format+"\r\n", a...)
}

func (c *Client) write(data string) {
	c.conn.Write([]byte(data + "\r\n"))
}

func (c *Client) writef(format string, a ...interface{}) {
	fmt.Fprintf(c.conn, format+"\r\n", a...)
}

func (c *Client) connect() error {
	c.lock.Lock()
	defer c.lock.Unlock()

	if c.TLS {
		if c.TLSConfig == nil {
			c.TLSConfig = &tls.Config{
				InsecureSkipVerify: true,
			}
		}

		conn, err := tls.DialWithDialer(c.dialer, "tcp", c.Server, c.TLSConfig)
		if err != nil {
			return err
		}

		c.conn = conn
	} else {
		conn, err := c.dialer.Dial("tcp", c.Server)
		if err != nil {
			return err
		}

		c.conn = conn
	}

	c.connected = true
	c.ConnectionChanged <- true
	c.reader = bufio.NewReader(c.conn)

	c.register()

	c.ready.Add(1)
	go c.send()
	go c.recv()

	return nil
}

func (c *Client) tryConnect() {
	for {
		select {
		case <-c.quit:
			return

		default:
		}

		err := c.connect()
		if err == nil {
			c.backoff.Reset()
			return
		}

		log.Println(err)
		time.Sleep(c.backoff.Duration())
	}
}

func (c *Client) run() {
	c.tryConnect()

	for {
		select {
		case <-c.quit:
			c.close()
			return

		case <-c.reconnect:
			c.sendRecv.Wait()
			c.reconnect = make(chan struct{})
			c.once.Reset()

			c.tryConnect()
		}
	}
}

func (c *Client) send() {
	c.sendRecv.Add(1)
	defer c.sendRecv.Done()

	c.ready.Wait()

	for {
		select {
		case <-c.quit:
			return

		case <-c.reconnect:
			return

		case msg := <-c.out:
			_, err := c.conn.Write([]byte(msg))
			if err != nil {
				return
			}
		}
	}
}

func (c *Client) recv() {
	defer func() {
		recover()
	}()

	c.sendRecv.Add(1)
	defer c.sendRecv.Done()

	for {
		line, err := c.reader.ReadString('\n')
		if err != nil {
			select {
			case <-c.quit:
				return

			default:
				c.ConnectionChanged <- false
				c.lock.Lock()
				c.connected = false
				c.lock.Unlock()

				c.once.Do(c.ready.Done)
				c.conn.Close()

				close(c.reconnect)
				return
			}
		}

		msg := parseMessage(line)
		c.Messages <- msg

		switch msg.Command {
		case Ping:
			go c.write("PONG :" + msg.Trailing)

		case ReplyWelcome:
			c.once.Do(c.ready.Done)
		}
	}
}

func (c *Client) close() {
	if c.Connected() {
		c.ConnectionChanged <- false
		c.lock.Lock()
		c.connected = false
		c.lock.Unlock()

		c.once.Do(c.ready.Done)
		c.conn.Close()
	}

	close(c.out)
	close(c.Messages)
}