Function TestVoidProcessor

push/push_test.go:469–532

TestVoidProcessor tests the void processor implementation

(t *testing.T)

// TestVoidProcessor tests the void processor implementation
func TestVoidProcessor(t *testing.T) {
	t.Run("NewVoidProcessor", func(t *testing.T) {
		processor := NewVoidProcessor()
		if processor == nil {
			t.Error("NewVoidProcessor should not return nil")
		}
	})

	t.Run("GetHandler", func(t *testing.T) {
		processor := NewVoidProcessor()
		handler := processor.GetHandler("TEST")
		if handler != nil {
			t.Error("VoidProcessor GetHandler should always return nil")
		}
	})

	t.Run("RegisterHandler", func(t *testing.T) {
		processor := NewVoidProcessor()
		handler := NewTestHandler("test")

		err := processor.RegisterHandler("TEST", handler, false)
		if err == nil {
			t.Error("VoidProcessor RegisterHandler should return error")
		}

		if !strings.Contains(err.Error(), "register failed") {
			t.Errorf("Error message should mention registration failure, got: %v", err)
		}

		if !strings.Contains(err.Error(), "push notifications are disabled") {
			t.Errorf("Error message should mention disabled notifications, got: %v", err)
		}
	})

	t.Run("UnregisterHandler", func(t *testing.T) {
		processor := NewVoidProcessor()

		err := processor.UnregisterHandler("TEST")
		if err == nil {
			t.Error("VoidProcessor UnregisterHandler should return error")
		}

		if !strings.Contains(err.Error(), "unregister failed") {
			t.Errorf("Error message should mention unregistration failure, got: %v", err)
		}
	})

	t.Run("ProcessPendingNotifications_NilReader", func(t *testing.T) {
		processor := NewVoidProcessor()
		ctx := context.Background()
		handlerCtx := NotificationHandlerContext{
			Client:     nil,
			ConnPool:   nil,
			PubSub:     nil,
			Conn:       nil,
			IsBlocking: false,
		}