quietlight/skraak_mcp - Change ZQTNKT6T6UBCFEQJY3XX26U7KZGAMHLPNX5HK3VAUXS6RYK53LKAC

more tidy up

Created by quietlight on March 28, 2026

ZQTNKT6T6UBCFEQJY3XX26U7KZGAMHLPNX5HK3VAUXS6RYK53LKAC

Dependencies

In channels

main

Change contents

Replacement in tools/export.go at line 245 [3.1]

B:BD[3.8966] → [3.8966:9024]

// copyTableAsIs copies an entire table without filtering

[3.8519]

[3.9024]

// copyTableAsIs copies an entire table without filtering.
// Table names are interpolated via Sprintf because SQL parameterization doesn't support
// identifiers (table/column names) — only values. This is safe because all table names
// come from the hardcoded datasetTables manifest, never from user input.

Deletion in tools/bulk_file_import.go at line 76 [4.1]

B:BD[4.2266] → [5.23689:23777]

// BulkFileImport imports WAV files across multiple locations/clusters using a CSV file

Replacement in tools/bulk_file_import.go at line 169 [4.1]

B:BD[4.4750] → [4.4750:4862]

			clusterID, err = bulkCreateCluster(database, input.DatasetID, loc.LocationID, loc.DateRange, loc.SampleRate)

[4.4750]

[4.4862]

			clusterID, err = bulkCreateCluster(ctx, database, input.DatasetID, loc.LocationID, loc.DateRange, loc.SampleRate)

Replacement in tools/bulk_file_import.go at line 400 [4.1]

B:BD[4.10175] → [4.10175:10286]

func bulkCreateCluster(database *sql.DB, datasetID, locationID, name string, sampleRate int) (string, error) {

[4.10175]

[4.10286]

func bulkCreateCluster(ctx context.Context, database *sql.DB, datasetID, locationID, name string, sampleRate int) (string, error) {

Replacement in tools/bulk_file_import.go at line 419 [4.1]

B:BD[4.10867] → [4.10867:10893]

	_, err = database.Exec(`

[4.10867]

[4.10893]

	tx, err := db.BeginLoggedTx(ctx, database, "bulk_file_import")
	if err != nil {
		return "", fmt.Errorf("failed to begin transaction: %w", err)
	}
	defer tx.Rollback()
	_, err = tx.ExecContext(ctx, `

Deletion in tools/bulk_file_import.go at line 429 [4.1]
B:BD[4.11117] → [4.11117:11118]

Replacement in tools/bulk_file_import.go at line 430 [4.1]

B:BD[4.11135] → [4.11135:11196]

		return "", fmt.Errorf("failed to insert cluster: %v", err)

[4.11135]

[4.11196]

		return "", fmt.Errorf("failed to insert cluster: %w", err)

Insertion in tools/bulk_file_import.go at line 433 [4.1]

[4.11200]

	if err = tx.Commit(); err != nil {
		return "", fmt.Errorf("failed to commit cluster creation: %w", err)
	}

Deletion in cmd/pattern.go at line 10 [6.897]
B:BD[6.964] → [7.22203:22216]
```
	"skraak/db"
```

Replacement in cmd/pattern.go at line 81 [6.897]

B:BD[6.3142] → [7.22217:22398]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.3142]

[7.22398]

	defer initEventLog(*dbPath)()

Replacement in cmd/pattern.go at line 152 [6.897]

B:BD[6.4966] → [7.22400:22581]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.4966]

[7.22581]

	defer initEventLog(*dbPath)()

Deletion in cmd/mcp.go at line 11 [5.1647]
B:BD[5.1719] → [7.22585:22598]
```
	"skraak/db"
```

Replacement in cmd/mcp.go at line 45 [5.1647]

B:BD[8.37556] → [7.22599:22801]

	// Initialize event log for mutation logging
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[8.37556]

[7.22801]

	defer initEventLog(*dbPath)()

Deletion in cmd/location.go at line 10 [6.5378]
B:BD[6.5445] → [7.22804:22817]
```
	"skraak/db"
```

Replacement in cmd/location.go at line 105 [6.5378]

B:BD[6.8421] → [7.22818:22999]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.8421]

[7.22999]

	defer initEventLog(*dbPath)()

Replacement in cmd/location.go at line 183 [6.5378]

B:BD[6.10548] → [7.23001:23182]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.10548]

[7.23182]

	defer initEventLog(*dbPath)()

Deletion in cmd/import.go at line 10 [5.9244]
B:BD[5.9317] → [7.23185:23198]
```
	"skraak/db"
```

Replacement in cmd/import.go at line 97 [5.9244]

B:BD[5.11380] → [7.23199:23380]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[5.11380]

[7.23380]

	defer initEventLog(*dbPath)()

Replacement in cmd/import.go at line 171 [5.9244]

B:BD[6.23909] → [7.23382:23563]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.23909]

[7.23563]

	defer initEventLog(*dbPath)()

Replacement in cmd/import.go at line 238 [5.9244]

B:BD[6.25836] → [7.23565:23746]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.25836]

[7.23746]

	defer initEventLog(*dbPath)()

Replacement in cmd/import.go at line 327 [5.9244]

B:BD[2.47038] → [2.47038:47219]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[2.47038]

[2.47219]

	defer initEventLog(*dbPath)()

Replacement in cmd/import.go at line 410 [5.9244]

B:BD[7.23932] → [7.23932:24113]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[7.23932]

[9.10976]

	defer initEventLog(*dbPath)()

Deletion in cmd/dataset.go at line 9 [6.10933]
B:BD[6.10989] → [7.24115:24128]
```
	"skraak/db"
```

Replacement in cmd/dataset.go at line 79 [6.10933]

B:BD[6.13299] → [7.24129:24310]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.13299]

[7.24310]

	defer initEventLog(*dbPath)()

Replacement in cmd/dataset.go at line 134 [6.10933]

B:BD[6.14929] → [7.24312:24493]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.14929]

[7.24493]

	defer initEventLog(*dbPath)()

File addition: common.go (----------)

[5.1]

package cmd
import "skraak/db"
// initEventLog configures transaction event logging for the given database path.
// Returns a cleanup function that should be deferred by the caller.
func initEventLog(dbPath string) func() {
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    dbPath + ".events.jsonl",
	})
	return func() { db.CloseEventLog() }
}

Deletion in cmd/cluster.go at line 10 [6.15264]
B:BD[6.15331] → [7.24496:24509]
```
	"skraak/db"
```

Replacement in cmd/cluster.go at line 96 [6.15264]

B:BD[6.17978] → [7.24510:24691]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.17978]

[7.24691]

	defer initEventLog(*dbPath)()

Replacement in cmd/cluster.go at line 163 [6.15264]

B:BD[6.20206] → [7.24693:24874]

	// Initialize event log
	eventLogPath := *dbPath + ".events.jsonl"
	db.SetEventLogConfig(db.EventLogConfig{
		Enabled: true,
		Path:    eventLogPath,
	})
	defer db.CloseEventLog()

[6.20206]

[7.24874]

	defer initEventLog(*dbPath)()