Adding more error logging for failed replication

maxpert · Sep 12, 2022 · c59893f · c59893f
1 parent f2b264a
commit c59893f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/db/changelog.go b/db/changelog.go
@@ -297,7 +297,7 @@ func (conn *SqliteStreamDB) consumeChangeLogs(tableName string, changes []*chang
 			})
 
 			if err != nil {
-				logger.Error().Err(err).Msg("Change failed to notify on change")
+				logger.Error().Err(err).Msg("Failed to acquire consensus")
 				return err
 			}
 		}

diff --git a/lib/replica_machine.go b/lib/replica_machine.go
@@ -71,6 +71,7 @@ func (ssm *SQLiteStateMachine) Update(entries []sm.Entry) ([]sm.Entry, error) {
 	for _, entry := range entries {
 		event := &ReplicationEvent[db.ChangeLogEvent]{}
 		if err := event.Unmarshal(entry.Cmd); err != nil {
+			log.Error().Err(err).Msg("Unable to unmarshal command")
 			return nil, err
 		}