fix: duplicate WriteHeader call

internal/cluster/http/service.go

@@ -498,6 +498,7 @@ func (s *Service) process(w http.ResponseWriter, r *http.Request, e *v1.Data) {
 	err := s.store.Data(ctx, e)
 	if err == nil {
 		w.WriteHeader(http.StatusAccepted)
+		return
 	}
 	if !errors.Is(err, store.ErrNotLeader) {
 		s.log.Error("failed to store event data", "err", err)

internal/cluster/store/store.go

@@ -236,6 +236,7 @@ var _ Storage = (*Store)(nil)
 
 func NewStore(base *v1.Config, transit raft.Transport, mgr *connections.Manager, tenants *tenant.Tenants) (*Store, error) {
 	dbPath := filepath.Join(base.Data, dbName)
+	os.RemoveAll(dbPath) // rely on raft to keep this up to date
 	store, err := db.NewKV(dbPath)
 	if err != nil {
 		return nil, err

internal/load/load.go

@@ -141,7 +141,7 @@ func (s *Session) send(name, path string, dump bool) error {
 		return err
 	}
 	defer res.Body.Close()
-	if res.StatusCode != http.StatusOK {
+	if res.StatusCode != http.StatusAccepted {
 		data, _ = io.ReadAll(res.Body)
 		return errors.New(string(data))
 	}

internal/load/testdata/page_view.js

@@ -1,5 +1,5 @@
 const site = "https://vinceanalytics.com"
 for (let index = 0; index < limit; index++) {
     const session = createSession(site);
-    session.SendDebug("pageview", "/");
+    session.Send("pageview", "/");
 }