[101] | 1 | package soju
|
---|
| 2 |
|
---|
| 3 | import (
|
---|
| 4 | "sync"
|
---|
| 5 | "time"
|
---|
| 6 | )
|
---|
| 7 |
|
---|
| 8 | type network struct {
|
---|
| 9 | Network
|
---|
| 10 | user *user
|
---|
| 11 | conn *upstreamConn
|
---|
| 12 | }
|
---|
| 13 |
|
---|
| 14 | func newNetwork(user *user, record *Network) *network {
|
---|
| 15 | return &network{
|
---|
| 16 | Network: *record,
|
---|
| 17 | user: user,
|
---|
| 18 | }
|
---|
| 19 | }
|
---|
| 20 |
|
---|
| 21 | func (net *network) run() {
|
---|
| 22 | var lastTry time.Time
|
---|
| 23 | for {
|
---|
| 24 | if dur := time.Now().Sub(lastTry); dur < retryConnectMinDelay {
|
---|
| 25 | delay := retryConnectMinDelay - dur
|
---|
| 26 | net.user.srv.Logger.Printf("waiting %v before trying to reconnect to %q", delay.Truncate(time.Second), net.Addr)
|
---|
| 27 | time.Sleep(delay)
|
---|
| 28 | }
|
---|
| 29 | lastTry = time.Now()
|
---|
| 30 |
|
---|
| 31 | uc, err := connectToUpstream(net)
|
---|
| 32 | if err != nil {
|
---|
| 33 | net.user.srv.Logger.Printf("failed to connect to upstream server %q: %v", net.Addr, err)
|
---|
| 34 | continue
|
---|
| 35 | }
|
---|
| 36 |
|
---|
| 37 | uc.register()
|
---|
| 38 |
|
---|
| 39 | net.user.lock.Lock()
|
---|
| 40 | net.conn = uc
|
---|
| 41 | net.user.lock.Unlock()
|
---|
| 42 |
|
---|
| 43 | if err := uc.readMessages(); err != nil {
|
---|
| 44 | uc.logger.Printf("failed to handle messages: %v", err)
|
---|
| 45 | }
|
---|
| 46 | uc.Close()
|
---|
| 47 |
|
---|
| 48 | net.user.lock.Lock()
|
---|
| 49 | net.conn = nil
|
---|
| 50 | net.user.lock.Unlock()
|
---|
| 51 | }
|
---|
| 52 | }
|
---|
| 53 |
|
---|
| 54 | type user struct {
|
---|
| 55 | User
|
---|
| 56 | srv *Server
|
---|
| 57 |
|
---|
| 58 | lock sync.Mutex
|
---|
| 59 | networks []*network
|
---|
| 60 | downstreamConns []*downstreamConn
|
---|
| 61 | }
|
---|
| 62 |
|
---|
| 63 | func newUser(srv *Server, record *User) *user {
|
---|
| 64 | return &user{
|
---|
| 65 | User: *record,
|
---|
| 66 | srv: srv,
|
---|
| 67 | }
|
---|
| 68 | }
|
---|
| 69 |
|
---|
| 70 | func (u *user) forEachNetwork(f func(*network)) {
|
---|
| 71 | u.lock.Lock()
|
---|
| 72 | for _, network := range u.networks {
|
---|
| 73 | f(network)
|
---|
| 74 | }
|
---|
| 75 | u.lock.Unlock()
|
---|
| 76 | }
|
---|
| 77 |
|
---|
| 78 | func (u *user) forEachUpstream(f func(uc *upstreamConn)) {
|
---|
| 79 | u.lock.Lock()
|
---|
| 80 | for _, network := range u.networks {
|
---|
| 81 | uc := network.conn
|
---|
| 82 | if uc == nil || !uc.registered || uc.closed {
|
---|
| 83 | continue
|
---|
| 84 | }
|
---|
| 85 | f(uc)
|
---|
| 86 | }
|
---|
| 87 | u.lock.Unlock()
|
---|
| 88 | }
|
---|
| 89 |
|
---|
| 90 | func (u *user) forEachDownstream(f func(dc *downstreamConn)) {
|
---|
| 91 | u.lock.Lock()
|
---|
| 92 | for _, dc := range u.downstreamConns {
|
---|
| 93 | f(dc)
|
---|
| 94 | }
|
---|
| 95 | u.lock.Unlock()
|
---|
| 96 | }
|
---|
| 97 |
|
---|
| 98 | func (u *user) getNetwork(name string) *network {
|
---|
| 99 | for _, network := range u.networks {
|
---|
| 100 | if network.Addr == name {
|
---|
| 101 | return network
|
---|
| 102 | }
|
---|
| 103 | }
|
---|
| 104 | return nil
|
---|
| 105 | }
|
---|
| 106 |
|
---|
| 107 | func (u *user) run() {
|
---|
| 108 | networks, err := u.srv.db.ListNetworks(u.Username)
|
---|
| 109 | if err != nil {
|
---|
| 110 | u.srv.Logger.Printf("failed to list networks for user %q: %v", u.Username, err)
|
---|
| 111 | return
|
---|
| 112 | }
|
---|
| 113 |
|
---|
| 114 | u.lock.Lock()
|
---|
| 115 | for _, record := range networks {
|
---|
| 116 | network := newNetwork(u, &record)
|
---|
| 117 | u.networks = append(u.networks, network)
|
---|
| 118 |
|
---|
| 119 | go network.run()
|
---|
| 120 | }
|
---|
| 121 | u.lock.Unlock()
|
---|
| 122 | }
|
---|
| 123 |
|
---|
| 124 | func (u *user) createNetwork(addr, nick string) (*network, error) {
|
---|
| 125 | network := newNetwork(u, &Network{
|
---|
| 126 | Addr: addr,
|
---|
| 127 | Nick: nick,
|
---|
| 128 | })
|
---|
| 129 | err := u.srv.db.StoreNetwork(u.Username, &network.Network)
|
---|
| 130 | if err != nil {
|
---|
| 131 | return nil, err
|
---|
| 132 | }
|
---|
| 133 | u.lock.Lock()
|
---|
| 134 | u.networks = append(u.networks, network)
|
---|
| 135 | u.lock.Unlock()
|
---|
| 136 | go network.run()
|
---|
| 137 | return network, nil
|
---|
| 138 | }
|
---|