Function TestWriteOutboxRow_NilsEmptyOptionals

internal/webhookpub/outbox_test.go:214–246

(t *testing.T)

}

func TestWriteOutboxRow_NilsEmptyOptionals(t *testing.T) {
	// AgentID/ConversationID/MessageID are passed as *string; empty
	// strings should become nil, not "".
	fe := &fakeExec{}
	e := Event{
		ID:     "evt_abc",
		Type:   EventEmailReceived,
		UserID: "u_42",
		// AgentID, ConversationID, MessageID all empty
	}
	if err := writeOutboxRow(context.Background(), fe, e); err != nil {
		t.Fatalf("writeOutboxRow err: %v", err)
	}
	if len(fe.args) < 1 || len(fe.args[0]) < 7 {
		t.Fatalf("not enough args captured: %v", fe.args)
	}
	// args order in writeOutboxRow: id, userID, type, envelopeJSON, agentID, conversationID, messageID
	// indices            0,    1,      2,     3,            4,        5,              6
	// args[4..6] are *string for agent_id, conversation_id, message_id.
	// Empty event fields should become typed-nil pointers so pgx
	// passes SQL NULL to the column. Use reflect to dereference the
	// interface and check the underlying pointer is nil.
	for i, name := range []string{"agent_id", "conversation_id", "message_id"} {
		v := reflect.ValueOf(fe.args[0][4+i])
		if v.Kind() != reflect.Ptr {
			t.Errorf("%s arg should be *string, got %s", name, v.Kind())
			continue
		}
		if !v.IsNil() {
			t.Errorf("expected %s = nil, got %v", name, fe.args[0][4+i])
		}
	}
}

func TestOutbox_PublishTx_FlagOffNoOp(t *testing.T) {
	// PublishTx must be a complete no-op when the flag is disabled.