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