Silverfish/proton-bridge
1
0
Fork 1
mirror of https://github.com/ProtonMail/proton-bridge.git synced 2025-12-16 15:16:44 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Other(test): Increase timeouts because race check is slow

Browse Source
This commit is contained in:
James Houlahan
2022-10-25 12:03:06 +02:00
parent 5adbf74cbe
commit dabc9717d1
2 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
tests/bridge_test.go
View File

@ -124,7 +124,7 @@ func (s *scenario) theUserReportsABug() error {
} }
func (s *scenario) bridgeSendsAConnectionUpEvent() error { func (s *scenario) bridgeSendsAConnectionUpEvent() error {
if event := s.t.events.await(events.ConnStatusUp{}, 5*time.Second); event == nil { if event := s.t.events.await(events.ConnStatusUp{}, 30*time.Second); event == nil {
return errors.New("expected connection up event, got none") return errors.New("expected connection up event, got none")
} }
@ -132,7 +132,7 @@ func (s *scenario) bridgeSendsAConnectionUpEvent() error {
} }
func (s *scenario) bridgeSendsAConnectionDownEvent() error { func (s *scenario) bridgeSendsAConnectionDownEvent() error {
if event := s.t.events.await(events.ConnStatusDown{}, 5*time.Second); event == nil { if event := s.t.events.await(events.ConnStatusDown{}, 30*time.Second); event == nil {
return errors.New("expected connection down event, got none") return errors.New("expected connection down event, got none")
} }
@ -140,7 +140,7 @@ func (s *scenario) bridgeSendsAConnectionDownEvent() error {
} }
func (s *scenario) bridgeSendsADeauthEventForUser(username string) error { func (s *scenario) bridgeSendsADeauthEventForUser(username string) error {
event, ok := awaitType(s.t.events, events.UserDeauth{}, 5*time.Second) event, ok := awaitType(s.t.events, events.UserDeauth{}, 30*time.Second)
if !ok { if !ok {
return errors.New("expected deauth event, got none") return errors.New("expected deauth event, got none")
} }
@ -153,7 +153,7 @@ func (s *scenario) bridgeSendsADeauthEventForUser(username string) error {
} }
func (s *scenario) bridgeSendsAnAddressCreatedEventForUser(username string) error { func (s *scenario) bridgeSendsAnAddressCreatedEventForUser(username string) error {
event, ok := awaitType(s.t.events, events.UserAddressCreated{}, 5*time.Second) event, ok := awaitType(s.t.events, events.UserAddressCreated{}, 30*time.Second)
if !ok { if !ok {
return errors.New("expected address created event, got none") return errors.New("expected address created event, got none")
} }
@ -166,7 +166,7 @@ func (s *scenario) bridgeSendsAnAddressCreatedEventForUser(username string) erro
} }
func (s *scenario) bridgeSendsAnAddressDeletedEventForUser(username string) error { func (s *scenario) bridgeSendsAnAddressDeletedEventForUser(username string) error {
event, ok := awaitType(s.t.events, events.UserAddressDeleted{}, 5*time.Second) event, ok := awaitType(s.t.events, events.UserAddressDeleted{}, 30*time.Second)
if !ok { if !ok {
return errors.New("expected address deleted event, got none") return errors.New("expected address deleted event, got none")
} }
@ -179,7 +179,7 @@ func (s *scenario) bridgeSendsAnAddressDeletedEventForUser(username string) erro
} }
func (s *scenario) bridgeSendsSyncStartedAndFinishedEventsForUser(username string) error { func (s *scenario) bridgeSendsSyncStartedAndFinishedEventsForUser(username string) error {
startEvent, ok := awaitType(s.t.events, events.SyncStarted{}, 5*time.Second) startEvent, ok := awaitType(s.t.events, events.SyncStarted{}, 30*time.Second)
if !ok { if !ok {
return errors.New("expected sync started event, got none") return errors.New("expected sync started event, got none")
} }
@ -188,7 +188,7 @@ func (s *scenario) bridgeSendsSyncStartedAndFinishedEventsForUser(username strin
return fmt.Errorf("expected sync started event for user %s, got %s", wantUserID, startEvent.UserID) return fmt.Errorf("expected sync started event for user %s, got %s", wantUserID, startEvent.UserID)
} }
finishEvent, ok := awaitType(s.t.events, events.SyncFinished{}, 5*time.Second) finishEvent, ok := awaitType(s.t.events, events.SyncFinished{}, 30*time.Second)
if !ok { if !ok {
return errors.New("expected sync finished event, got none") return errors.New("expected sync finished event, got none")
} }
@ -201,7 +201,7 @@ func (s *scenario) bridgeSendsSyncStartedAndFinishedEventsForUser(username strin
} }
func (s *scenario) bridgeSendsAnUpdateNotAvailableEvent() error { func (s *scenario) bridgeSendsAnUpdateNotAvailableEvent() error {
if event := s.t.events.await(events.UpdateNotAvailable{}, 5*time.Second); event == nil { if event := s.t.events.await(events.UpdateNotAvailable{}, 30*time.Second); event == nil {
return errors.New("expected update not available event, got none") return errors.New("expected update not available event, got none")
} }
@ -209,7 +209,7 @@ func (s *scenario) bridgeSendsAnUpdateNotAvailableEvent() error {
} }
func (s *scenario) bridgeSendsAnUpdateAvailableEventForVersion(version string) error { func (s *scenario) bridgeSendsAnUpdateAvailableEventForVersion(version string) error {
event, ok := awaitType(s.t.events, events.UpdateAvailable{}, 5*time.Second) event, ok := awaitType(s.t.events, events.UpdateAvailable{}, 30*time.Second)
if !ok { if !ok {
return errors.New("expected update available event, got none") return errors.New("expected update available event, got none")
} }
@ -226,7 +226,7 @@ func (s *scenario) bridgeSendsAnUpdateAvailableEventForVersion(version string) e
} }
func (s *scenario) bridgeSendsAManualUpdateEventForVersion(version string) error { func (s *scenario) bridgeSendsAManualUpdateEventForVersion(version string) error {
event, ok := awaitType(s.t.events, events.UpdateAvailable{}, 5*time.Second) event, ok := awaitType(s.t.events, events.UpdateAvailable{}, 30*time.Second)
if !ok { if !ok {
return errors.New("expected update available event, got none") return errors.New("expected update available event, got none")
} }
@ -243,7 +243,7 @@ func (s *scenario) bridgeSendsAManualUpdateEventForVersion(version string) error
} }
func (s *scenario) bridgeSendsAnUpdateInstalledEventForVersion(version string) error { func (s *scenario) bridgeSendsAnUpdateInstalledEventForVersion(version string) error {
event, ok := awaitType(s.t.events, events.UpdateInstalled{}, 5*time.Second) event, ok := awaitType(s.t.events, events.UpdateInstalled{}, 30*time.Second)
if !ok { if !ok {
return errors.New("expected update installed event, got none") return errors.New("expected update installed event, got none")
} }
@ -256,7 +256,7 @@ func (s *scenario) bridgeSendsAnUpdateInstalledEventForVersion(version string) e
} }
func (s *scenario) bridgeSendsAForcedUpdateEvent() error { func (s *scenario) bridgeSendsAForcedUpdateEvent() error {
if event := s.t.events.await(events.UpdateForced{}, 5*time.Second); event == nil { if event := s.t.events.await(events.UpdateForced{}, 30*time.Second); event == nil {
return errors.New("expected update forced event, got none") return errors.New("expected update forced event, got none")
} }

2
tests/ctx_bridge_test.go
View File

@ -97,7 +97,7 @@ func (t *testCtx) startBridge() error {
t.events.collectFrom(eventCh) t.events.collectFrom(eventCh)
// Wait for the users to be loaded. // Wait for the users to be loaded.
t.events.await(events.AllUsersLoaded{}, 10*time.Second) t.events.await(events.AllUsersLoaded{}, 30*time.Second)
// Save the bridge to the context. // Save the bridge to the context.
t.bridge = bridge t.bridge = bridge