Bump version to 1.0.59

Makefile

@@ -1,5 +1,5 @@
 BINARY=syncserver
-VERSION?=1.0.58
+VERSION?=1.0.59
 GO?=go
 LDFLAGS=-s -w -X main.version=$(VERSION) -X main.commit=$(shell git rev-parse --short HEAD 2>/dev/null || echo unknown)
 BUILD_FLAGS=CGO_ENABLED=0

cmd/server/main.go

@@ -20,7 +20,7 @@ import (
 	"github.com/syncserver/internal/syncengine"
 )
 
-var version = "1.0.58"
+var version = "1.0.59"
 
 func main() {
 	cfgPath := flag.String("config", "", "Path to config.yaml")

internal/db/db.go

@@ -86,11 +86,29 @@ func (db *DB) runMigrationsInternal(mfs embedFS, migrationsRoot string) error {
 
 	for _, name := range names {
 		if hasChecksumCol {
-			var storedChecksum string
+			var storedChecksum sql.NullString
 			row := db.QueryRow("SELECT checksum FROM schema_migrations WHERE version = ?", name)
-			if err := row.Scan(&storedChecksum); err == nil && storedChecksum != "" {
+			switch err := row.Scan(&storedChecksum); {
+			case err == nil:
+				if storedChecksum.Valid && storedChecksum.String != "" {
 					continue
 				}
+				data, err := mfs.ReadFile(filepath.Join(migrationsRoot, name))
+				if err != nil {
+					return fmt.Errorf("reading migration %s: %w", name, err)
+				}
+				checksum := sha256.Sum256(data)
+				if _, err := db.Exec(
+					"UPDATE schema_migrations SET checksum = ? WHERE version = ?",
+					hex.EncodeToString(checksum[:]), name,
+				); err != nil {
+					return fmt.Errorf("backfilling checksum for %s: %w", name, err)
+				}
+				continue
+			case err == sql.ErrNoRows:
+			default:
+				return fmt.Errorf("checking migration %s: %w", name, err)
+			}
 		} else {
 			var count int
 			row := db.QueryRow("SELECT COUNT(*) FROM schema_migrations WHERE version = ?", name)