errors_test.go

package reflex

import (
	"context"
	"testing"

	"github.com/luno/jettison/errors"
	"github.com/stretchr/testify/require"
	"google.golang.org/grpc/status"
)

func TestIsExpected(t *testing.T) {
	tests := []struct {
		Name     string
		Err      error
		Expected bool
	}{
		{
			Name:     "nil",
			Err:      nil,
			Expected: false,
		},
		{
			Name:     "context.Canceled",
			Err:      context.Canceled,
			Expected: true,
		},
		{
			Name:     "context.DeadlineExceeded",
			Err:      context.DeadlineExceeded,
			Expected: true,
		},
		{
			Name:     "ErrStopped",
			Err:      ErrStopped,
			Expected: true,
		},
		{
			Name:     "Canceled status",
			Err:      status.FromContextError(context.Canceled).Err(),
			Expected: true,
		},
		{
			Name:     "DeadlineExceeded status",
			Err:      status.FromContextError(context.DeadlineExceeded).Err(),
			Expected: true,
		},
		{
			Name:     "not me",
			Err:      errors.New("not me"),
			Expected: false,
		},
	}

	for _, test := range tests {
		t.Run(test.Name, func(t *testing.T) {
			require.Equal(t, test.Expected, IsExpected(test.Err))
		})
	}
}

func TestIsFilterErr(t *testing.T) {
	tests := []struct {
		Name     string
		Err      error
		Expected bool
	}{
		{
			Name:     "nil",
			Err:      nil,
			Expected: false,
		},
		{
			Name:     "context.Canceled",
			Err:      context.Canceled,
			Expected: false,
		},
		{
			Name:     "context.DeadlineExceeded",
			Err:      context.DeadlineExceeded,
			Expected: false,
		},
		{
			Name:     "ErrStopped",
			Err:      ErrStopped,
			Expected: false,
		},
		{
			Name:     "Canceled status",
			Err:      status.FromContextError(context.Canceled).Err(),
			Expected: false,
		},
		{
			Name:     "DeadlineExceeded status",
			Err:      status.FromContextError(context.DeadlineExceeded).Err(),
			Expected: false,
		},
		{
			Name:     "not me",
			Err:      errors.New("not me"),
			Expected: false,
		},
		{
			Name:     "filter error",
			Err:      filterErr,
			Expected: true,
		},
		{
			Name:     "wrapped filter error",
			Err:      asFilterErr(errors.New("not me")),
			Expected: true,
		},
	}

	for _, test := range tests {
		t.Run(test.Name, func(t *testing.T) {
			require.Equal(t, test.Expected, IsFilterErr(test.Err))
		})
	}
}