|
|
|
@ -54,16 +54,18 @@ func NewServer(clock *derby.DerbyClock, events <-chan derby.Event, dbPath string
|
|
|
|
|
|
|
|
|
|
|
|
// Create server
|
|
|
|
// Create server
|
|
|
|
s := &Server{
|
|
|
|
s := &Server{
|
|
|
|
router: chi.NewRouter(),
|
|
|
|
router: chi.NewRouter(),
|
|
|
|
clock: clock,
|
|
|
|
clock: clock,
|
|
|
|
events: events,
|
|
|
|
events: events,
|
|
|
|
clients: make(map[chan string]bool),
|
|
|
|
clients: make(map[chan string]bool),
|
|
|
|
clientsMux: sync.Mutex{},
|
|
|
|
clientsMux: sync.Mutex{},
|
|
|
|
port: port,
|
|
|
|
adminclients: make(map[chan string]bool),
|
|
|
|
shutdown: make(chan struct{}),
|
|
|
|
adminclientsMux: sync.Mutex{},
|
|
|
|
logger: logger,
|
|
|
|
port: port,
|
|
|
|
db: database,
|
|
|
|
shutdown: make(chan struct{}),
|
|
|
|
adminEvents: make(chan string, 10),
|
|
|
|
logger: logger,
|
|
|
|
|
|
|
|
db: database,
|
|
|
|
|
|
|
|
adminEvents: make(chan string, 10),
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// Set up routes
|
|
|
|
// Set up routes
|
|
|
|
|