718af22dbb
- code.tvl.fyi/tvix/castore/protos -> code.tvl.fyi/tvix/castore-go - code.tvl.fyi/tvix/store/protos -> code.tvl.fyi/tvix/store-go See cl/9791, cl/9792 for context. Change-Id: I44614c6ed40b9f52d9dcdea8e61fe2c3c830ce78 Reviewed-on: https://cl.tvl.fyi/c/depot/+/9793 Reviewed-by: Connor Brewster <cbrewster@hey.com> Tested-by: BuildkiteCI Autosubmit: flokli <flokli@flokli.de>
101 lines
2.5 KiB
Go
101 lines
2.5 KiB
Go
package http
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
"sync"
|
|
"time"
|
|
|
|
castorev1pb "code.tvl.fyi/tvix/castore-go"
|
|
storev1pb "code.tvl.fyi/tvix/store-go"
|
|
"github.com/go-chi/chi/middleware"
|
|
"github.com/go-chi/chi/v5"
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
type Server struct {
|
|
srv *http.Server
|
|
handler chi.Router
|
|
|
|
directoryServiceClient castorev1pb.DirectoryServiceClient
|
|
blobServiceClient castorev1pb.BlobServiceClient
|
|
pathInfoServiceClient storev1pb.PathInfoServiceClient
|
|
|
|
// When uploading NAR files to a HTTP binary cache, the .nar
|
|
// files are uploaded before the .narinfo files.
|
|
// We need *both* to be able to fully construct a PathInfo object.
|
|
// Keep a in-memory map of narhash(es) (in SRI) to (unnamed) root node and nar
|
|
// size.
|
|
// This is necessary until we can ask a PathInfoService for a node with a given
|
|
// narSha256.
|
|
narDbMu sync.Mutex
|
|
narDb map[string]*narData
|
|
}
|
|
|
|
type narData struct {
|
|
rootNode *castorev1pb.Node
|
|
narSize uint64
|
|
}
|
|
|
|
func New(
|
|
directoryServiceClient castorev1pb.DirectoryServiceClient,
|
|
blobServiceClient castorev1pb.BlobServiceClient,
|
|
pathInfoServiceClient storev1pb.PathInfoServiceClient,
|
|
enableAccessLog bool,
|
|
priority int,
|
|
) *Server {
|
|
r := chi.NewRouter()
|
|
|
|
if enableAccessLog {
|
|
r.Use(middleware.Logger)
|
|
}
|
|
|
|
r.Get("/", func(w http.ResponseWriter, r *http.Request) {
|
|
_, err := w.Write([]byte("nar-bridge"))
|
|
if err != nil {
|
|
log.Errorf("Unable to write response: %v", err)
|
|
}
|
|
})
|
|
|
|
r.Get("/nix-cache-info", func(w http.ResponseWriter, r *http.Request) {
|
|
_, err := w.Write([]byte(fmt.Sprintf("StoreDir: /nix/store\nWantMassQuery: 1\nPriority: %d\n", priority)))
|
|
if err != nil {
|
|
log.Errorf("Unable to write response: %v", err)
|
|
}
|
|
})
|
|
|
|
s := &Server{
|
|
handler: r,
|
|
directoryServiceClient: directoryServiceClient,
|
|
blobServiceClient: blobServiceClient,
|
|
pathInfoServiceClient: pathInfoServiceClient,
|
|
narDb: make(map[string]*narData),
|
|
}
|
|
|
|
registerNarPut(s)
|
|
registerNarinfoPut(s)
|
|
|
|
registerNarinfoGet(s)
|
|
registerNarGet(s)
|
|
|
|
return s
|
|
}
|
|
|
|
func (s *Server) Shutdown(ctx context.Context) error {
|
|
return s.srv.Shutdown(ctx)
|
|
}
|
|
|
|
// ListenAndServer starts the webserver, and waits for it being closed or
|
|
// shutdown, after which it'll return ErrServerClosed.
|
|
func (s *Server) ListenAndServe(addr string) error {
|
|
s.srv = &http.Server{
|
|
Addr: addr,
|
|
Handler: s.handler,
|
|
ReadTimeout: 500 * time.Second,
|
|
WriteTimeout: 500 * time.Second,
|
|
IdleTimeout: 500 * time.Second,
|
|
}
|
|
|
|
return s.srv.ListenAndServe()
|
|
}
|