fix unit tests

This commit is contained in:
ryanfkeepers 2023-02-20 15:28:23 -07:00
parent f88cf05117
commit 5593352226
4 changed files with 17 additions and 25 deletions

View File

@ -69,7 +69,7 @@ func New(
DetailsID: detailsID, DetailsID: detailsID,
Status: status, Status: status,
Selector: selector, Selector: selector,
Errors: errs.Data(), Errors: errs.Errors(),
ReadWrites: rw, ReadWrites: rw,
StartAndEndTime: se, StartAndEndTime: se,
Version: Version, Version: Version,
@ -156,12 +156,12 @@ func (b Backup) errorCount() int {
} }
// future tracking // future tracking
if b.Errors.Err != nil || len(b.Errors.Errs) > 0 { if b.Errors.Failure != nil || len(b.Errors.Recovered) > 0 {
if b.Errors.Err != nil { if b.Errors.Failure != nil {
errCount++ errCount++
} }
errCount += len(b.Errors.Errs) errCount += len(b.Errors.Recovered)
} }
return errCount return errCount

View File

@ -42,7 +42,7 @@ func stubBackup(t time.Time) backup.Backup {
Status: "status", Status: "status",
Selector: sel.Selector, Selector: sel.Selector,
Errors: fault.Errors{ Errors: fault.Errors{
Errs: []error{errors.New("read"), errors.New("write")}, Recovered: []error{errors.New("read"), errors.New("write")},
}, },
Errs: stats.Errs{ Errs: stats.Errs{
ReadErrors: errors.New("1"), ReadErrors: errors.New("1"),

View File

@ -32,12 +32,8 @@ type Bus struct {
// controls, allowing the data to be persisted. // controls, allowing the data to be persisted.
type Errors struct { type Errors struct {
Failure error `json:"failure"` Failure error `json:"failure"`
Recovered []error `json:"recovered"` Recovered []error `json:"-"`
FailFast bool `json:"failFast"` FailFast bool `json:"failFast"`
// legacy support
Err error `json:"err"`
Errs []error `json:"errs"`
} }
// New constructs a new error with default values in place. // New constructs a new error with default values in place.
@ -63,9 +59,9 @@ func (e *Bus) Recovered() []error {
return e.recoverable return e.recoverable
} }
// Data returns the plain record of errors that were aggregated // Errors returns the plain record of errors that were aggregated
// within a fult Bus. // within a fult Bus.
func (e *Bus) Data() Errors { func (e *Bus) Errors() Errors {
return Errors{ return Errors{
Failure: e.failure, Failure: e.failure,
Recovered: slices.Clone(e.recoverable), Recovered: slices.Clone(e.recoverable),

View File

@ -177,7 +177,7 @@ func (suite *FaultErrorsUnitSuite) TestAdd() {
assert.Len(t, n.Recovered(), 2) assert.Len(t, n.Recovered(), 2)
} }
func (suite *FaultErrorsUnitSuite) TestData() { func (suite *FaultErrorsUnitSuite) TestErrors() {
t := suite.T() t := suite.T()
// not fail-fast // not fail-fast
@ -188,9 +188,9 @@ func (suite *FaultErrorsUnitSuite) TestData() {
n.AddRecoverable(errors.New("1")) n.AddRecoverable(errors.New("1"))
n.AddRecoverable(errors.New("2")) n.AddRecoverable(errors.New("2"))
d := n.Data() d := n.Errors()
assert.Equal(t, n.Failure(), d.Err) assert.Equal(t, n.Failure(), d.Failure)
assert.ElementsMatch(t, n.Recovered(), d.Errs) assert.ElementsMatch(t, n.Recovered(), d.Recovered)
assert.False(t, d.FailFast) assert.False(t, d.FailFast)
// fail-fast // fail-fast
@ -201,9 +201,9 @@ func (suite *FaultErrorsUnitSuite) TestData() {
n.AddRecoverable(errors.New("1")) n.AddRecoverable(errors.New("1"))
n.AddRecoverable(errors.New("2")) n.AddRecoverable(errors.New("2"))
d = n.Data() d = n.Errors()
assert.Equal(t, n.Failure(), d.Err) assert.Equal(t, n.Failure(), d.Failure)
assert.ElementsMatch(t, n.Recovered(), d.Errs) assert.ElementsMatch(t, n.Recovered(), d.Recovered)
assert.True(t, d.FailFast) assert.True(t, d.FailFast)
} }
@ -217,14 +217,10 @@ func (suite *FaultErrorsUnitSuite) TestMarshalUnmarshal() {
n.AddRecoverable(errors.New("1")) n.AddRecoverable(errors.New("1"))
n.AddRecoverable(errors.New("2")) n.AddRecoverable(errors.New("2"))
data := n.Data() bs, err := json.Marshal(n.Errors())
jsonStr, err := json.Marshal(data)
require.NoError(t, err) require.NoError(t, err)
um := fault.Errors{} err = json.Unmarshal(bs, &fault.Errors{})
err = json.Unmarshal(jsonStr, &um)
require.NoError(t, err) require.NoError(t, err)
} }