Mukan Erkin Törük
ef24c0b67e
Some checks are pending
docker-build-cometbft / vars (push) Waiting to run
docker-build-cometbft / build-images (amd64, ubuntu-24.04) (push) Blocked by required conditions
docker-build-cometbft / build-images (arm64, ubuntu-24.04-arm) (push) Blocked by required conditions
docker-build-cometbft / merge-images (push) Blocked by required conditions
docker-build-e2e-node / vars (push) Waiting to run
docker-build-e2e-node / build-images (amd64, ubuntu-24.04) (push) Blocked by required conditions
docker-build-e2e-node / build-images (arm64, ubuntu-24.04-arm) (push) Blocked by required conditions
docker-build-e2e-node / merge-images (push) Blocked by required conditions
57 lines
1 KiB
Go
57 lines
1 KiB
Go
package service
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
type testService struct {
|
|
BaseService
|
|
}
|
|
|
|
func (testService) OnReset() error {
|
|
return nil
|
|
}
|
|
|
|
func TestBaseServiceWait(t *testing.T) {
|
|
ts := &testService{}
|
|
ts.BaseService = *NewBaseService(nil, "TestService", ts)
|
|
err := ts.Start()
|
|
require.NoError(t, err)
|
|
|
|
waitFinished := make(chan struct{})
|
|
go func() {
|
|
ts.Wait()
|
|
waitFinished <- struct{}{}
|
|
}()
|
|
|
|
go ts.Stop() //nolint:errcheck // ignore for tests
|
|
|
|
select {
|
|
case <-waitFinished:
|
|
// all good
|
|
case <-time.After(100 * time.Millisecond):
|
|
t.Fatal("expected Wait() to finish within 100 ms.")
|
|
}
|
|
}
|
|
|
|
func TestBaseServiceReset(t *testing.T) {
|
|
ts := &testService{}
|
|
ts.BaseService = *NewBaseService(nil, "TestService", ts)
|
|
err := ts.Start()
|
|
require.NoError(t, err)
|
|
|
|
err = ts.Reset()
|
|
require.Error(t, err, "expected cant reset service error")
|
|
|
|
err = ts.Stop()
|
|
require.NoError(t, err)
|
|
|
|
err = ts.Reset()
|
|
require.NoError(t, err)
|
|
|
|
err = ts.Start()
|
|
require.NoError(t, err)
|
|
}
|