From 52c00adfe7cffff9a6081f5e754f6fba0c2ffc4f Mon Sep 17 00:00:00 2001
From: bel <bel>
Date: Sat, 27 Jun 2026 23:59:55 -0600
Subject: [PATCH] pings record to sqlite

---
 cmd/pinger/.main.go.swp | Bin 12288 -> 0 bytes
 cmd/pinger/main.go      | 145 ++++++++++++++++++++++++++++++++++++++--
 go.mod                  |   1 +
 go.sum                  |   2 +
 4 files changed, 143 insertions(+), 5 deletions(-)
 delete mode 100644 cmd/pinger/.main.go.swp

diff --git a/cmd/pinger/.main.go.swp b/cmd/pinger/.main.go.swp
deleted file mode 100644
index c6350c1e46d4399cd5c38ce6d2588aebe4e6db99..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 12288
zcmeI2J&O}T7{{LzEVeimwX&MbH5-VtiP{)BxFeXu!t*ekg%WVHnQT@!J7IR0JCMXe
zOGW$$3YIp03a#uc1xs7~0{$m276A!YSR6bXemu$U^D^^G6*9g0gFAP{P1PV=7l>Xw
z+<DT!eAat=K-ANzySw)4L^dp<;o7_@8U}kN$ZZtFNuk4FoMf@KK{V<w-;Tm0Q?Xgw
zixb!Y8#t+fO}c)qQFm2avLY^BJUnRw&SwK`fDNz#Hoykh02^QfY~U0dD8?J~9P2-`
z*h6IzH&)`}BL_CX2G{@_U;}J`4X^<=zy{a=8(;%$;1n7N`$R7{iNrZ99{>L@fB*kJ
zPxK4?1mD3o@D+RkpTS4)2D}EZz!Y>q8??YK*a26-5A^;7K7jY&9hia<cnrE=546Dz
zAc0#?1@OfN*Z><~18jf|umLu}2G{@_U<3cxz+^(+gxt%sx+rZXqT*QHw$`tbmzr3$
z!y-(5dH--<R*Ag69%w7(=eboYHMw?)s9u(9YspIn0#Q`9MV6%E8F}-9+U#y~dseUZ
z^^q@SO~__**7_e!kUq%OL1;0`<Z9Q(`J+a&TfMb1Vvq}$nuf9K+(zu^;%`O0Tbn;?
znXE{%Qs2w4Nn@)tD6>e|GV`%<5#gymE|kkcthyP-Vh2u;Ti`g%lE}wh?0T_FOg&19
z;j+d@uhqrPX1F8oe%19tt;E6jVcAoW83p|$PBLwR*j#m<<ou})70%JCURvtF9jJFR
kB)$P@a+iVc#s#-u7Z(ecl#Is47Q!bQhtbn8*22xDKQ6k(zyJUM

diff --git a/cmd/pinger/main.go b/cmd/pinger/main.go
index edd9735..0c44fd9 100644
--- a/cmd/pinger/main.go
+++ b/cmd/pinger/main.go
@@ -2,12 +2,17 @@ package main
 
 import (
 	"context"
+	"database/sql"
 	"flag"
+	"fmt"
 	"log"
+	"math/rand"
+	"net"
 	"os"
+	"sync"
+	"time"
 
 	"gitea.bel.blue/bel/with"
-	"github.com/digineo/go-ping"
 )
 
 func main() {
@@ -16,18 +21,148 @@ func main() {
 	}
 }
 
+type S struct {
+	*sql.DB
+}
+
 func run(ctx context.Context) error {
+	return with.Sqlite(ctx, "/tmp/pinger.db", func(db *sql.DB) error {
+		s := S{
+			DB: db,
+		}
+		if err := s.init(ctx); err != nil {
+			return err
+		}
+
+		wg := &sync.WaitGroup{}
+		defer wg.Wait()
+		for _, foo := range []func(context.Context) error{
+			s.pingAndRecord,
+			s.listen,
+		} {
+			foo := foo
+			wg.Go(func() {
+				if err := foo(ctx); err != nil {
+					panic(err)
+				}
+			})
+		}
+		return ctx.Err()
+	})
+}
+
+func (s S) init(ctx context.Context) error {
+	for _, q := range []string{
+		`CREATE TABLE IF NOT EXISTS "pinger_to" (
+			id NUMBER NOT NULL UNIQUE
+			, addr TEXT NOT NULL UNIQUE
+		)`,
+		`CREATE TABLE IF NOT EXISTS "pinger_pings" (
+			start TIMESTAMP NOT NULL 
+			, ms NUMBER NOT NULL
+			, ok BOOLEAN NOT NULL DEFAULT false
+			, to_id NUMBER 
+			, FOREIGN KEY (to_id) REFERENCES "pinger_to"(id)
+		)`,
+		//`ALTER TABLE "pinger_pings" SET UNLOGGED`,
+	} {
+		if _, err := s.ExecContext(ctx, q); err != nil {
+			return err
+		}
+	}
+	return ctx.Err()
+}
+
+func (S) listen(ctx context.Context) error {
+	return ctx.Err()
+}
+
+func (s S) pingAndRecord(ctx context.Context) error {
+	ctx, can := context.WithCancel(ctx)
+	defer can()
+
 	fs := flag.NewFlagSet(os.Args[0], flag.ContinueOnError)
+	target := fs.String("t", "google.com", "target")
+	port := fs.String("p", "80", "target port")
+	interval := fs.Duration("i", time.Second, "between conns")
 	if err := fs.Parse(os.Args[1:]); err != nil {
 		return err
 	}
 
-	pinger, err := ping.New("", "::")
-	if err != nil {
+	addr := fmt.Sprintf("%s:%s", *target, *port)
+	if _, err := s.ExecContext(ctx, `
+		INSERT INTO "pinger_to" (id, addr)
+		VALUES ($1, $2)
+		ON CONFLICT (addr) DO NOTHING
+	`, rand.Int(), addr); err != nil {
 		return err
 	}
-	defer pinger.Close()
 
-	log.Fatal("RUN")
+	var toId int
+	if row := s.QueryRowContext(ctx, `
+		SELECT id
+		FROM "pinger_to"
+		WHERE addr=$1
+	`, addr); row.Err() != nil {
+		return row.Err()
+	} else if err := row.Scan(&toId); err != nil {
+		return err
+	}
+
+	type record struct {
+		start time.Time
+		ms    time.Duration
+		ok    bool
+	}
+	records := make(chan record, 100)
+	defer close(records)
+	go func() {
+		for record := range records {
+			if _, err := s.ExecContext(ctx, `
+				INSERT INTO "pinger_pings" 
+				(start, ms, ok, to_id)
+				VALUES
+				($1, $2, $3, $4)
+			`, record.start, record.ms.Milliseconds(), record.ok, toId); err != nil {
+				log.Println("!", err)
+			}
+		}
+	}()
+
+	c := time.NewTicker(*interval)
+	go func() {
+		<-ctx.Done()
+		c.Stop()
+	}()
+
+	dialer := &net.Dialer{
+		Timeout: time.Second,
+	}
+
+	for {
+		select {
+		case <-c.C:
+		case <-ctx.Done():
+			return nil
+		}
+		func() {
+			ctx, can := context.WithTimeout(ctx, *interval)
+			defer can()
+			start := time.Now()
+			conn, err := dialer.DialContext(ctx, "tcp", addr)
+			select {
+			case records <- record{
+				start: start,
+				ms:    time.Since(start),
+				ok:    err == nil,
+			}:
+			default:
+			}
+			if err == nil {
+				conn.Close()
+			}
+		}()
+	}
+
 	return ctx.Err()
 }
diff --git a/go.mod b/go.mod
index 51384a3..3db96cd 100644
--- a/go.mod
+++ b/go.mod
@@ -13,6 +13,7 @@ require (
 	github.com/mattn/go-isatty v0.0.20 // indirect
 	github.com/ncruces/go-strftime v1.0.0 // indirect
 	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
+	github.com/tatsushid/go-fastping v0.0.0-20160109021039-d7bb493dee3e // indirect
 	golang.org/x/exp v0.0.0-20251023183803-a4bb9ffd2546 // indirect
 	golang.org/x/net v0.43.0 // indirect
 	golang.org/x/sys v0.43.0 // indirect
diff --git a/go.sum b/go.sum
index 5ef2be4..f98d4c2 100644
--- a/go.sum
+++ b/go.sum
@@ -18,6 +18,8 @@ github.com/ncruces/go-strftime v1.0.0 h1:HMFp8mLCTPp341M/ZnA4qaf7ZlsbTc+miZjCLOF
 github.com/ncruces/go-strftime v1.0.0/go.mod h1:Fwc5htZGVVkseilnfgOVb9mKy6w1naJmn9CehxcKcls=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
+github.com/tatsushid/go-fastping v0.0.0-20160109021039-d7bb493dee3e h1:nt2877sKfojlHCTOBXbpWjBkuWKritFaGIfgQwbQUls=
+github.com/tatsushid/go-fastping v0.0.0-20160109021039-d7bb493dee3e/go.mod h1:B4+Kq1u5FlULTjFSM707Q6e/cOHFv0z/6QRoxubDIQ8=
 golang.org/x/exp v0.0.0-20251023183803-a4bb9ffd2546 h1:mgKeJMpvi0yx/sU5GsxQ7p6s2wtOnGAHZWCHUM4KGzY=
 golang.org/x/exp v0.0.0-20251023183803-a4bb9ffd2546/go.mod h1:j/pmGrbnkbPtQfxEe5D0VQhZC6qKbfKifgD0oM7sR70=
 golang.org/x/mod v0.29.0 h1:HV8lRxZC4l2cr3Zq1LvtOsi/ThTgWnUk/y64QSs8GwA=