added code

.gitignore

@@ -0,0 +1 @@
+tracking.db

go.mod

@@ -0,0 +1,5 @@
+module tracking
+
+go 1.23.3
+
+require github.com/mattn/go-sqlite3 v1.14.24

go.sum

@@ -0,0 +1,2 @@
+github.com/mattn/go-sqlite3 v1.14.24 h1:tpSp2G2KyMnnQu99ngJ47EIkWVmliIizyZBfPrBWDRM=
+github.com/mattn/go-sqlite3 v1.14.24/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=

tracking.go

@@ -0,0 +1,167 @@
+package main
+
+import (
+	"database/sql"
+	"encoding/json"
+	"fmt"
+	"log"
+	"net/http"
+	"strings"
+	"time"
+
+	_ "github.com/mattn/go-sqlite3"
+)
+
+/*
+A few usage examples:
+
+post event:
+
+curl --header "Content-Type: application/json" \
+--request POST \
+--data "{\"property\":\"ne1net\",\"ip\":\"192.168.0.0\",\"user_agent\":\"secret agent\",\"description\":\"awesome thing\"}" \
+http://localhost:8091/events
+
+fetch quick stats:
+
+curl "http://localhost:8091/stats?property=ne1net"
+
+*/
+
+const file string = "tracking.db" // name of database (sqlite3)
+const listenAddr string = ":8091" // address/port to listen at
+const eventsTableCreate string = `
+  CREATE TABLE IF NOT EXISTS events (
+  id INTEGER NOT NULL PRIMARY KEY,
+  timestamp INTEGER, 
+  property TEXT,
+  ip TEXT,
+  user_agent TEXT,
+  description TEXT
+  );`
+const indexOnTimestamp string = `CREATE INDEX IF NOT EXISTS idx_property_timestamp ON events (property,timestamp)`
+const statsSql string = `select count(distinct(ip)),min(timestamp) from events where property = ? AND timestamp > ?`
+const insertSql string = `INSERT INTO events VALUES(NULL,?,?,?,?,?)`
+
+func main() {
+	db, err := sql.Open("sqlite3", file)
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer db.Close()
+
+	if _, err := db.Exec(eventsTableCreate); err != nil {
+		log.Fatal(err)
+	}
+
+	if _, err := db.Exec(indexOnTimestamp); err != nil {
+		log.Fatal(err)
+	}
+
+	http.HandleFunc("/events", postEventHandler)
+	http.HandleFunc("/stats", statsHandler)
+	http.ListenAndServe(listenAddr, nil)
+}
+
+type Event struct {
+	Property    string  `json:"property"`
+	Ip          *string `json:"ip"`
+	UserAgent   *string `json:"user_agent"`
+	Description *string `json:"description"`
+}
+
+func postEventHandler(w http.ResponseWriter, req *http.Request) {
+	if req.Method != "POST" {
+		return
+	}
+
+	decoder := json.NewDecoder(req.Body)
+	var event Event
+	err := decoder.Decode(&event)
+	if err != nil {
+		log.Println("unable to parse!")
+		return
+	}
+
+	// populate ip if not provided
+	if event.Ip == nil {
+		ip := req.RemoteAddr
+		// remove remote port from ip
+		lastColonIndex := strings.LastIndex(ip, ":")
+		if lastColonIndex > -1 {
+			ip = string(ip[:lastColonIndex])
+		}
+		event.Ip = &ip
+	}
+
+	// populate user agent if not provided
+	if event.UserAgent == nil {
+		ua := req.UserAgent()
+		event.UserAgent = &ua
+	}
+
+	// populate description if not provided
+	if event.Description == nil {
+		event.Description = &req.RequestURI
+	}
+
+	logEvent(event)
+}
+
+func statsHandler(w http.ResponseWriter, req *http.Request) {
+	if req.Method != "GET" {
+		return
+	}
+
+	if data, ok := req.URL.Query()["property"]; ok {
+		property := data[0]
+		if len(property) == 0 {
+			return
+		}
+
+		db, err := sql.Open("sqlite3", file)
+		if err != nil {
+			log.Println(err)
+			return
+		}
+		defer db.Close()
+
+		time := time.Now().Unix() - 86400*30
+		statsRow := db.QueryRow(statsSql, property, time)
+
+		stats := struct {
+			Version             string `json:"version"`
+			Unique_last_30_days int    `json:"unique_last_30_days"`
+			First_timestamp     int    `json:"first_timestamp"`
+		}{
+			Version: "0.0.1",
+		}
+		_ = statsRow.Scan(&stats.Unique_last_30_days, &stats.First_timestamp)
+
+		b, err := json.Marshal(stats)
+		if err != nil {
+			log.Println(err)
+			return
+		}
+		fmt.Fprint(w, string(b))
+
+	}
+}
+
+func logEvent(event Event) {
+	time := time.Now().Unix()
+
+	// insert db and autoclose!
+	db, err := sql.Open("sqlite3", file)
+	if err != nil {
+		log.Println(err)
+		return
+	}
+	defer db.Close()
+
+	_, err = db.Exec(insertSql, time, event.Property, *event.Ip, *event.UserAgent, *event.Description)
+	if err != nil {
+		log.Println(err)
+		return
+	}
+}