[98] | 1 | package soju
|
---|
[1] | 2 |
|
---|
| 3 | import (
|
---|
| 4 | "fmt"
|
---|
[37] | 5 | "log"
|
---|
[1] | 6 | "net"
|
---|
[24] | 7 | "sync"
|
---|
[67] | 8 | "time"
|
---|
[1] | 9 |
|
---|
| 10 | "gopkg.in/irc.v3"
|
---|
| 11 | )
|
---|
| 12 |
|
---|
[67] | 13 | // TODO: make configurable
|
---|
| 14 | var keepAlivePeriod = time.Minute
|
---|
[71] | 15 | var retryConnectMinDelay = time.Minute
|
---|
[206] | 16 | var connectTimeout = 15 * time.Second
|
---|
[205] | 17 | var writeTimeout = 10 * time.Second
|
---|
[67] | 18 |
|
---|
| 19 | func setKeepAlive(c net.Conn) error {
|
---|
| 20 | tcpConn, ok := c.(*net.TCPConn)
|
---|
| 21 | if !ok {
|
---|
| 22 | return fmt.Errorf("cannot enable keep-alive on a non-TCP connection")
|
---|
| 23 | }
|
---|
| 24 | if err := tcpConn.SetKeepAlive(true); err != nil {
|
---|
| 25 | return err
|
---|
| 26 | }
|
---|
| 27 | return tcpConn.SetKeepAlivePeriod(keepAlivePeriod)
|
---|
| 28 | }
|
---|
| 29 |
|
---|
[9] | 30 | type Logger interface {
|
---|
| 31 | Print(v ...interface{})
|
---|
| 32 | Printf(format string, v ...interface{})
|
---|
| 33 | }
|
---|
| 34 |
|
---|
[21] | 35 | type prefixLogger struct {
|
---|
| 36 | logger Logger
|
---|
| 37 | prefix string
|
---|
| 38 | }
|
---|
| 39 |
|
---|
| 40 | var _ Logger = (*prefixLogger)(nil)
|
---|
| 41 |
|
---|
| 42 | func (l *prefixLogger) Print(v ...interface{}) {
|
---|
| 43 | v = append([]interface{}{l.prefix}, v...)
|
---|
| 44 | l.logger.Print(v...)
|
---|
| 45 | }
|
---|
| 46 |
|
---|
| 47 | func (l *prefixLogger) Printf(format string, v ...interface{}) {
|
---|
| 48 | v = append([]interface{}{l.prefix}, v...)
|
---|
| 49 | l.logger.Printf("%v"+format, v...)
|
---|
| 50 | }
|
---|
| 51 |
|
---|
[10] | 52 | type Server struct {
|
---|
[79] | 53 | Hostname string
|
---|
| 54 | Logger Logger
|
---|
| 55 | RingCap int
|
---|
[178] | 56 | LogPath string
|
---|
[79] | 57 | Debug bool
|
---|
[22] | 58 |
|
---|
[77] | 59 | db *DB
|
---|
| 60 |
|
---|
[172] | 61 | lock sync.Mutex
|
---|
| 62 | users map[string]*user
|
---|
[10] | 63 | }
|
---|
| 64 |
|
---|
[77] | 65 | func NewServer(db *DB) *Server {
|
---|
[37] | 66 | return &Server{
|
---|
[50] | 67 | Logger: log.New(log.Writer(), "", log.LstdFlags),
|
---|
| 68 | RingCap: 4096,
|
---|
| 69 | users: make(map[string]*user),
|
---|
[77] | 70 | db: db,
|
---|
[37] | 71 | }
|
---|
| 72 | }
|
---|
| 73 |
|
---|
[5] | 74 | func (s *Server) prefix() *irc.Prefix {
|
---|
| 75 | return &irc.Prefix{Name: s.Hostname}
|
---|
| 76 | }
|
---|
| 77 |
|
---|
[77] | 78 | func (s *Server) Run() error {
|
---|
| 79 | users, err := s.db.ListUsers()
|
---|
| 80 | if err != nil {
|
---|
| 81 | return err
|
---|
| 82 | }
|
---|
[71] | 83 |
|
---|
[77] | 84 | s.lock.Lock()
|
---|
| 85 | for _, record := range users {
|
---|
| 86 | s.Logger.Printf("starting bouncer for user %q", record.Username)
|
---|
| 87 | u := newUser(s, &record)
|
---|
| 88 | s.users[u.Username] = u
|
---|
[71] | 89 |
|
---|
[77] | 90 | go u.run()
|
---|
[71] | 91 | }
|
---|
[37] | 92 | s.lock.Unlock()
|
---|
| 93 |
|
---|
[77] | 94 | select {}
|
---|
[10] | 95 | }
|
---|
| 96 |
|
---|
[38] | 97 | func (s *Server) getUser(name string) *user {
|
---|
| 98 | s.lock.Lock()
|
---|
| 99 | u := s.users[name]
|
---|
| 100 | s.lock.Unlock()
|
---|
| 101 | return u
|
---|
| 102 | }
|
---|
| 103 |
|
---|
[3] | 104 | func (s *Server) Serve(ln net.Listener) error {
|
---|
[154] | 105 | var nextDownstreamID uint64 = 1
|
---|
[1] | 106 | for {
|
---|
[22] | 107 | netConn, err := ln.Accept()
|
---|
[1] | 108 | if err != nil {
|
---|
| 109 | return fmt.Errorf("failed to accept connection: %v", err)
|
---|
| 110 | }
|
---|
| 111 |
|
---|
[67] | 112 | setKeepAlive(netConn)
|
---|
| 113 |
|
---|
[154] | 114 | dc := newDownstreamConn(s, netConn, nextDownstreamID)
|
---|
| 115 | nextDownstreamID++
|
---|
[1] | 116 | go func() {
|
---|
[103] | 117 | if err := dc.runUntilRegistered(); err != nil {
|
---|
| 118 | dc.logger.Print(err)
|
---|
| 119 | } else {
|
---|
[166] | 120 | dc.user.events <- eventDownstreamConnected{dc}
|
---|
[165] | 121 | if err := dc.readMessages(dc.user.events); err != nil {
|
---|
[103] | 122 | dc.logger.Print(err)
|
---|
| 123 | }
|
---|
[167] | 124 | dc.user.events <- eventDownstreamDisconnected{dc}
|
---|
[1] | 125 | }
|
---|
[65] | 126 | dc.Close()
|
---|
[1] | 127 | }()
|
---|
| 128 | }
|
---|
| 129 | }
|
---|