forked from quickfixgo/quickfix
-
Notifications
You must be signed in to change notification settings - Fork 0
/
resend_state_test.go
58 lines (44 loc) · 1.27 KB
/
resend_state_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
package quickfix
import (
"testing"
"github.com/quickfixgo/quickfix/internal"
"github.com/stretchr/testify/suite"
)
type resendStateTestSuite struct {
SessionSuiteRig
}
func TestResendStateTestSuite(t *testing.T) {
suite.Run(t, new(resendStateTestSuite))
}
func (s *resendStateTestSuite) SetupTest() {
s.Init()
s.session.State = resendState{}
}
func (s *resendStateTestSuite) TestIsLoggedOn() {
s.True(s.session.IsLoggedOn())
}
func (s *resendStateTestSuite) TestIsConnected() {
s.True(s.session.IsConnected())
}
func (s *resendStateTestSuite) TestIsSessionTime() {
s.True(s.session.IsSessionTime())
}
func (s *resendStateTestSuite) TestTimeoutPeerTimeout() {
s.MockApp.On("ToAdmin")
s.session.Timeout(s.session, internal.PeerTimeout)
s.MockApp.AssertExpectations(s.T())
s.State(pendingTimeout{resendState{}})
}
func (s *resendStateTestSuite) TestTimeoutUnchangedIgnoreLogonLogoutTimeout() {
tests := []internal.Event{internal.LogonTimeout, internal.LogoutTimeout}
for _, event := range tests {
s.session.Timeout(s.session, event)
s.State(resendState{})
}
}
func (s *resendStateTestSuite) TestTimeoutUnchangedNeedHeartbeat() {
s.MockApp.On("ToAdmin")
s.session.Timeout(s.session, internal.NeedHeartbeat)
s.MockApp.AssertExpectations(s.T())
s.State(resendState{})
}