Pass lastLogForTick through BuildEventMessage parameter

Move lastLogForTick into BuildEventMessage as a parameter instead of
setting it on the returned struct after the call, so the function fully
constructs the message.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: 0xluk

bob-events-bridge/internal/kafka/message.go

@@ -101,7 +101,7 @@ func TransformEventBody(eventType uint32, body interface{}) (map[string]any, err
 }
 
 // BuildEventMessage assembles a full Kafka EventMessage from bob log payload components.
-func BuildEventMessage(payload *bob.LogPayload, parsedBody interface{}, indexInTick uint32) (*EventMessage, error) {
+func BuildEventMessage(payload *bob.LogPayload, parsedBody interface{}, indexInTick uint32, lastLogForTick bool) (*EventMessage, error) {
 	body, err := TransformEventBody(payload.Type, parsedBody)
 	if err != nil {
 		return nil, fmt.Errorf("failed to transform event body: %w", err)
@@ -118,5 +118,6 @@ func BuildEventMessage(payload *bob.LogPayload, parsedBody interface{}, indexInT
 		Timestamp:       payload.Timestamp,
 		TransactionHash: payload.TxHash,
 		Body:            body,
+		LastLogForTick:  lastLogForTick,
 	}, nil
 }

bob-events-bridge/internal/kafka/message_test.go

@@ -243,7 +243,7 @@ func TestBuildEventMessage(t *testing.T) {
 		Amount: 1000,
 	}
 
-	msg, err := BuildEventMessage(payload, body, 3)
+	msg, err := BuildEventMessage(payload, body, 3, false)
 	require.NoError(t, err)
 
 	assert.Equal(t, uint64(3), msg.Index)
@@ -258,6 +258,7 @@ func TestBuildEventMessage(t *testing.T) {
 	assert.Equal(t, "AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA", msg.Body["source"])
 	assert.Equal(t, "BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB", msg.Body["destination"])
 	assert.Equal(t, int64(1000), msg.Body["amount"])
+	assert.False(t, msg.LastLogForTick)
 }
 
 func TestBuildEventMessage_NilBody(t *testing.T) {
@@ -272,8 +273,33 @@ func TestBuildEventMessage_NilBody(t *testing.T) {
 		TxHash:    "TXHASH",
 	}
 
-	msg, err := BuildEventMessage(payload, nil, 0)
+	msg, err := BuildEventMessage(payload, nil, 0, false)
 	require.NoError(t, err)
 	assert.Nil(t, msg.Body)
+	assert.False(t, msg.LastLogForTick)
+}
+
+func TestBuildEventMessage_LastLogForTick(t *testing.T) {
+	payload := &bob.LogPayload{
+		OK:        true,
+		Epoch:     145,
+		Tick:      22000001,
+		Type:      0,
+		LogID:     99,
+		LogDigest: "def456",
+		BodySize:  64,
+		Timestamp: uint64(1718461800),
+		TxHash:    "TXHASH",
+	}
+
+	body := &bob.QuTransferBody{
+		From:   "AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA",
+		To:     "BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB",
+		Amount: 500,
+	}
+
+	msg, err := BuildEventMessage(payload, body, 5, true)
+	require.NoError(t, err)
+	assert.True(t, msg.LastLogForTick)
 }
 

bob-events-bridge/internal/processor/processor.go

@@ -349,11 +349,10 @@ func (p *Processor) handleTickStreamResult(ctx context.Context, result *bob.Tick
 		// Build kafka message (if publisher configured)
 		var kafkaMsg *kafka.EventMessage
 		if p.publisher != nil {
-			kafkaMsg, err = kafka.BuildEventMessage(&payload, parsed, p.tickEventIndex)
+			kafkaMsg, err = kafka.BuildEventMessage(&payload, parsed, p.tickEventIndex, isLastLog)
 			if err != nil {
 				return fmt.Errorf("failed to build kafka message: %w", err)
 			}
-			kafkaMsg.LastLogForTick = isLastLog
 		}
 
 		// Create event proto