log err

cmd/pinger/index.html.tmpl

@@ -9,11 +9,14 @@
             SELECT
               start AS start
               , CASE
-                WHEN ms < 750 OR ok THEN 
+                WHEN ms < 50 AND ok THEN
                   'okay'
+                WHEN ms < 750 AND ok THEN
+                  'slow'
                 ELSE
-                  'errored' 
+                  'bad'
                 END AS ok
+              , ms AS ms
             FROM
               "pinger_pings"
             ORDER BY start DESC
@@ -23,9 +26,12 @@
           [
             {{.ok}}==="okay"
             ? "🟢"
+            : {{.ok}}==="slow"
+              ? "🟠"
               : "🔴",
             `${Math.round((new Date() - 1000*{{.start}})/1000.0)}s ago`,
             new Date(1000*{{.start}}),
+            "{{.ms}}ms",
           ],
         {{ end }}
         ]

cmd/pinger/main.go

@@ -42,6 +42,7 @@ func run(ctx context.Context) error {
 		defer wg.Wait()
 		for _, foo := range []func(context.Context) error{
 			s.pingAndRecord,
+			s.collectGarbage,
 			s.listen,
 		} {
 			foo := foo
@@ -141,6 +142,32 @@ func (s S) listen(ctx context.Context) error {
 	return nil
 }
 
+func (s S) collectGarbage(ctx context.Context) error {
+	c := time.NewTicker(time.Hour)
+	defer c.Stop()
+
+	for {
+		select {
+		case <-c.C:
+		case <-ctx.Done():
+			return nil
+		}
+		if _, err := s.ExecContext(ctx, `
+			DELETE FROM "pinger_pings"
+			WHERE
+				start < $1
+				AND (
+					ms < 100
+					OR ok
+				)
+		`, time.Now().Add(-1*2*24*time.Hour).Unix()); err != nil {
+			log.Println("!", err)
+		}
+	}
+
+	return nil
+}
+
 func (s S) pingAndRecord(ctx context.Context) error {
 	ctx, can := context.WithCancel(ctx)
 	defer can()
@@ -224,6 +251,8 @@ func (s S) pingAndRecord(ctx context.Context) error {
 			}
 			if err == nil {
 				conn.Close()
+			} else {
+				log.Println("!", err)
 			}
 		}()
 	}