Minor fixes

db/changelog.go

@@ -126,8 +126,8 @@ func (conn *SqliteStreamDB) consumeReplicationEvent(event *ChangeLogEvent) error
 		log.Debug().
 			Str("table", event.TableName).
 			Str("type", event.Type).
-			Int64("id", event.Id).
-			Msg(fmt.Sprintf("Consuming replication event with PK %v", primaryKeyMap))
+			Int64("event_id", event.Id).
+			Msg(fmt.Sprintf("Replicating %v", primaryKeyMap))
 		return replicateRow(tnx, event, primaryKeyMap)
 	})
 }
@@ -217,7 +217,7 @@ func (conn *SqliteStreamDB) publishChangeLog() {
 				log.Debug().
 					Int64("cleaned", cnt).
 					Uint64("published", processed).
-					Msg("Rows published")
+					Msg("Cleaned up change log")
 			}
 		}
 

lib/sqlite_log_db.go

@@ -2,6 +2,7 @@ package lib
 
 import (
 	"database/sql"
+	"errors"
 	"fmt"
 	"math"
 	"time"
@@ -50,6 +51,7 @@ const (
 
 //go:embed log_db_script.sql
 var logDBScript string
+var errIndexNotApplicable = errors.New("index can not be applied for this save type")
 
 func NewSQLiteLogDBFactory(metaPath string, nodeID uint64) *SQLiteLogDBFactory {
 	path := fmt.Sprintf("%s/logdb-%d.sqlite?_journal=wal", metaPath, nodeID)
@@ -615,6 +617,13 @@ func saveInfoTuple(
 	entryType raftInfoEntryType,
 	f func() ([]byte, error),
 ) error {
+	// Assert that BootStrap and State has no index
+	if entryType == Bootstrap || entryType == State {
+		if index != nil {
+			return errIndexNotApplicable
+		}
+	}
+
 	data, err := f()
 	if err != nil {
 		return err