🐛 delete: atomic counter

cmd/metrica/main.go

@@ -10,9 +10,8 @@ import (
 )
 
 func main() {
-	c := metrica.NewAtomicCounter()
 	fs := metrica.NewFileStorage(&sync.Mutex{}, "metrica.txt")
-	mux := metrica.Handler(c, fs)
+	mux := metrica.Handler(fs)
 
 	slog.Info("Starting server", "port", 8080)
 	err := http.ListenAndServe(":8080", mux)

handler.go

@@ -14,22 +14,14 @@ type countResponse struct {
 }
 
 // Handler returns a http.Handler for new endpoints.
-func Handler(c *AtomicCounter, fs *FileStorage) http.Handler {
+func Handler(fs *FileStorage) http.Handler {
 	mux := http.NewServeMux()
-	mux.HandleFunc("/count", func(w http.ResponseWriter, r *http.Request) {
-		counter(w, r, c)
-	})
 	mux.HandleFunc("/countfs", func(w http.ResponseWriter, r *http.Request) {
 		counterFs(w, r, fs)
 	})
 	return mux
 }
 
-func counter(w http.ResponseWriter, _ *http.Request, c *AtomicCounter) {
-	c.Inc(1)
-	send(w, http.StatusOK, countResponse{Count: c.Value()})
-}
-
 func counterFs(w http.ResponseWriter, _ *http.Request, fs *FileStorage) {
 	var wg sync.WaitGroup
 	var counter int64

handler_test.go

@@ -9,50 +9,6 @@ import (
 	"testing"
 )
 
-func TestHandlerCount_Sequential(t *testing.T) {
-	c := NewAtomicCounter()
-	mux := Handler(c, nil)
-
-	for i := 0; i < 100; i++ {
-		req := httptest.NewRequest("GET", "/count", nil)
-		w := httptest.NewRecorder()
-		mux.ServeHTTP(w, req)
-		if w.Code != http.StatusOK {
-			t.Errorf("expected status OK; got %v", w.Code)
-		}
-
-		var gotRes countResponse
-		if err := json.NewDecoder(w.Body).Decode(&gotRes); err != nil {
-			t.Errorf("unable to decode body: %v", err)
-		}
-
-		wantCount := int64(i + 1)
-		assert(t, wantCount, gotRes.Count)
-	}
-}
-
-func TestHandlerCount_Concurrent(t *testing.T) {
-	c := NewAtomicCounter()
-	mux := Handler(c, nil)
-	var wg sync.WaitGroup
-
-	for i := 0; i < 1000; i++ {
-		wg.Add(1)
-		go func() {
-			req := httptest.NewRequest("GET", "/count", nil)
-			w := httptest.NewRecorder()
-			mux.ServeHTTP(w, req)
-			if w.Code != http.StatusOK {
-				t.Errorf("expected status OK; got %v", w.Code)
-			}
-			defer wg.Done()
-		}()
-	}
-	wg.Wait()
-
-	assert(t, int64(1000), c.Value())
-}
-
 func TestHandlerCountFS_Sequential(t *testing.T) {
 	f, err := os.Create("test")
 	if err != nil {
@@ -63,7 +19,7 @@ func TestHandlerCountFS_Sequential(t *testing.T) {
 	}()
 
 	fs := NewFileStorage(&sync.Mutex{}, f.Name())
-	mux := Handler(nil, fs)
+	mux := Handler(fs)
 
 	for i := 0; i < 100; i++ {
 		req := httptest.NewRequest("GET", "/countfs", nil)
@@ -94,7 +50,7 @@ func TestHandlerCountFS_Concurrent(t *testing.T) {
 
 	fs := NewFileStorage(&sync.Mutex{}, f.Name())
 
-	mux := Handler(nil, fs)
+	mux := Handler(fs)
 	var wg sync.WaitGroup
 
 	for i := 0; i < 100; i++ {