mirror of https://github.com/curusarn/resh
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
69 lines
2.6 KiB
69 lines
2.6 KiB
package main
|
|
|
|
import (
|
|
"net/http"
|
|
"os"
|
|
"strconv"
|
|
|
|
"github.com/curusarn/resh/pkg/cfg"
|
|
"github.com/curusarn/resh/pkg/histfile"
|
|
"github.com/curusarn/resh/pkg/records"
|
|
"github.com/curusarn/resh/pkg/sesshist"
|
|
"github.com/curusarn/resh/pkg/sesswatch"
|
|
"github.com/curusarn/resh/pkg/signalhandler"
|
|
)
|
|
|
|
func runServer(config cfg.Config, reshHistoryPath, bashHistoryPath, zshHistoryPath string) {
|
|
var recordSubscribers []chan records.Record
|
|
var sessionInitSubscribers []chan records.Record
|
|
var sessionDropSubscribers []chan string
|
|
var signalSubscribers []chan os.Signal
|
|
|
|
shutdown := make(chan string)
|
|
|
|
// sessshist
|
|
sesshistSessionsToInit := make(chan records.Record)
|
|
sessionInitSubscribers = append(sessionInitSubscribers, sesshistSessionsToInit)
|
|
sesshistSessionsToDrop := make(chan string)
|
|
sessionDropSubscribers = append(sessionDropSubscribers, sesshistSessionsToDrop)
|
|
sesshistRecords := make(chan records.Record)
|
|
recordSubscribers = append(recordSubscribers, sesshistRecords)
|
|
|
|
// histfile
|
|
histfileRecords := make(chan records.Record)
|
|
recordSubscribers = append(recordSubscribers, histfileRecords)
|
|
histfileSessionsToDrop := make(chan string)
|
|
sessionDropSubscribers = append(sessionDropSubscribers, histfileSessionsToDrop)
|
|
histfileSignals := make(chan os.Signal)
|
|
signalSubscribers = append(signalSubscribers, histfileSignals)
|
|
maxHistSize := 10000 // lines
|
|
minHistSizeKB := 2000 // roughly lines
|
|
histfileBox := histfile.New(histfileRecords, histfileSessionsToDrop,
|
|
reshHistoryPath, bashHistoryPath, zshHistoryPath,
|
|
maxHistSize, minHistSizeKB,
|
|
histfileSignals, shutdown)
|
|
|
|
// sesshist New
|
|
sesshistDispatch := sesshist.NewDispatch(sesshistSessionsToInit, sesshistSessionsToDrop,
|
|
sesshistRecords, histfileBox,
|
|
config.SesshistInitHistorySize)
|
|
|
|
// sesswatch
|
|
sesswatchSessionsToWatch := make(chan records.Record)
|
|
sessionInitSubscribers = append(sessionInitSubscribers, sesswatchSessionsToWatch)
|
|
sesswatch.Go(sesswatchSessionsToWatch, sessionDropSubscribers, config.SesswatchPeriodSeconds)
|
|
|
|
// handlers
|
|
mux := http.NewServeMux()
|
|
mux.HandleFunc("/status", statusHandler)
|
|
mux.Handle("/record", &recordHandler{subscribers: recordSubscribers})
|
|
mux.Handle("/session_init", &sessionInitHandler{subscribers: sessionInitSubscribers})
|
|
mux.Handle("/recall", &recallHandler{sesshistDispatch: sesshistDispatch})
|
|
mux.Handle("/inspect", &inspectHandler{sesshistDispatch: sesshistDispatch})
|
|
|
|
server := &http.Server{Addr: ":" + strconv.Itoa(config.Port), Handler: mux}
|
|
go server.ListenAndServe()
|
|
|
|
// signalhandler - takes over the main goroutine so when signal handler exists the whole program exits
|
|
signalhandler.Run(signalSubscribers, shutdown, server)
|
|
}
|
|
|