Skip to content

Commit 882623b

Browse files
committed
remove fakeAcker in favour of generated Acker mock
1 parent f1e7591 commit 882623b

File tree

1 file changed

+13
-35
lines changed

1 file changed

+13
-35
lines changed

internal/pkg/agent/application/upgrade/upgrade_test.go

Lines changed: 13 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -29,14 +29,14 @@ import (
2929
"github.com/elastic/elastic-agent/internal/pkg/agent/errors"
3030
"github.com/elastic/elastic-agent/internal/pkg/config"
3131
"github.com/elastic/elastic-agent/internal/pkg/fleetapi"
32-
"github.com/elastic/elastic-agent/internal/pkg/fleetapi/acker"
3332
"github.com/elastic/elastic-agent/internal/pkg/release"
3433
v1 "github.com/elastic/elastic-agent/pkg/api/v1"
3534
"github.com/elastic/elastic-agent/pkg/control/v2/client"
3635
"github.com/elastic/elastic-agent/pkg/control/v2/cproto"
3736
"github.com/elastic/elastic-agent/pkg/core/logger"
3837
"github.com/elastic/elastic-agent/pkg/core/logger/loggertest"
3938
agtversion "github.com/elastic/elastic-agent/pkg/version"
39+
mockack "github.com/elastic/elastic-agent/testing/mocks/internal_/pkg/fleetapi/acker"
4040
mocks "github.com/elastic/elastic-agent/testing/mocks/pkg/control/v2/client"
4141
)
4242

@@ -293,37 +293,31 @@ func TestUpgraderAckAction(t *testing.T) {
293293
require.Nil(t, u.AckAction(t.Context(), nil, action))
294294
})
295295
t.Run("AckAction with acker", func(t *testing.T) {
296-
acker := &fakeAcker{}
297-
acker.On("Ack", mock.Anything, action).Return(nil)
298-
acker.On("Commit", mock.Anything).Return(nil)
296+
mockAcker := &mockack.Acker{}
297+
mockAcker.EXPECT().Ack(mock.Anything, action).Return(nil)
298+
mockAcker.EXPECT().Commit(mock.Anything).Return(nil)
299299

300-
require.Nil(t, u.AckAction(t.Context(), acker, action))
301-
acker.AssertCalled(t, "Ack", mock.Anything, action)
302-
acker.AssertCalled(t, "Commit", mock.Anything)
300+
require.Nil(t, u.AckAction(t.Context(), mockAcker, action))
303301
})
304302

305303
t.Run("AckAction with acker - failing commit", func(t *testing.T) {
306-
acker := &fakeAcker{}
304+
mockAcker := &mockack.Acker{}
307305

308306
errCommit := errors.New("failed commit")
309-
acker.On("Ack", mock.Anything, action).Return(nil)
310-
acker.On("Commit", mock.Anything).Return(errCommit)
307+
mockAcker.EXPECT().Ack(mock.Anything, action).Return(nil)
308+
mockAcker.EXPECT().Commit(mock.Anything).Return(errCommit)
311309

312-
require.ErrorIs(t, u.AckAction(t.Context(), acker, action), errCommit)
313-
acker.AssertCalled(t, "Ack", mock.Anything, action)
314-
acker.AssertCalled(t, "Commit", mock.Anything)
310+
require.ErrorIs(t, u.AckAction(t.Context(), mockAcker, action), errCommit)
315311
})
316312

317313
t.Run("AckAction with acker - failed ack", func(t *testing.T) {
318-
acker := &fakeAcker{}
314+
mockAcker := &mockack.Acker{}
319315

320316
errAck := errors.New("ack error")
321-
acker.On("Ack", mock.Anything, action).Return(errAck)
322-
acker.On("Commit", mock.Anything).Return(nil)
317+
mockAcker.EXPECT().Ack(mock.Anything, action).Return(errAck)
318+
mockAcker.EXPECT().Commit(mock.Anything).Return(nil)
323319

324-
require.ErrorIs(t, u.AckAction(t.Context(), acker, action), errAck)
325-
acker.AssertCalled(t, "Ack", mock.Anything, action)
326-
acker.AssertNotCalled(t, "Commit", mock.Anything)
320+
require.ErrorIs(t, u.AckAction(t.Context(), mockAcker, action), errAck)
327321
})
328322
}
329323

@@ -1276,19 +1270,3 @@ func TestIsSameReleaseVersion(t *testing.T) {
12761270
})
12771271
}
12781272
}
1279-
1280-
var _ acker.Acker = &fakeAcker{}
1281-
1282-
type fakeAcker struct {
1283-
mock.Mock
1284-
}
1285-
1286-
func (f *fakeAcker) Ack(ctx context.Context, action fleetapi.Action) error {
1287-
args := f.Called(ctx, action)
1288-
return args.Error(0)
1289-
}
1290-
1291-
func (f *fakeAcker) Commit(ctx context.Context) error {
1292-
args := f.Called(ctx)
1293-
return args.Error(0)
1294-
}

0 commit comments

Comments
 (0)