fix graph error inspection

This commit is contained in:
ryanfkeepers 2023-01-31 17:58:07 -07:00
parent b63f45acb4
commit 9059ad758b

View File

@ -538,21 +538,21 @@ func (suite *CollectionUnitTestSuite) TestStreamItem() {
}, },
}, },
{ {
name: "service unavailable errors", name: "internal server errors",
expectData: "", expectData: "",
coll: &Collection{ coll: &Collection{
data: mockDataChan(), data: mockDataChan(),
itemReader: mockReader("foo", graph.Err503ServiceUnavailable), itemReader: mockReader("foo", graph.Err500InternalServerError),
itemGetter: mockGetter(nil), itemGetter: mockGetter(nil),
}, },
errsIs: func(t *testing.T, e error, count int) { errsIs: func(t *testing.T, e error, count int) {
assert.True(t, graph.IsSericeUnavailable(e), "is unavailable error") assert.True(t, graph.IsInternalServerError(e), "is internal server error")
assert.ErrorIs(t, e, graph.Err503ServiceUnavailable) assert.ErrorIs(t, e, graph.Err500InternalServerError)
assert.Equal(t, 1, count, "one errors") assert.Equal(t, 1, count, "one errors")
}, },
readErrIs: func(t *testing.T, e error) { readErrIs: func(t *testing.T, e error) {
assert.True(t, graph.IsSericeUnavailable(e), "is unavailable error") assert.True(t, graph.IsInternalServerError(e), "is internal server error")
assert.ErrorIs(t, e, graph.Err503ServiceUnavailable) assert.ErrorIs(t, e, graph.Err500InternalServerError)
}, },
}, },
} }