@@ -66,6 +66,7 @@ func TestNetworkProvider_GetNodeStatusWithSuccess(t *testing.T) {
6666 Hash : "00000998" ,
6767 PrevBlockHash : "00000997" ,
6868 Timestamp : 998 ,
69+ TimestampMs : 998200 ,
6970 },
7071 },
7172 }, nil
@@ -80,6 +81,7 @@ func TestNetworkProvider_GetNodeStatusWithSuccess(t *testing.T) {
8081 Hash : "00000300" ,
8182 PrevBlockHash : "00000299" ,
8283 Timestamp : 300 ,
84+ TimestampMs : 3002000 ,
8385 },
8486 },
8587 }, nil
@@ -102,13 +104,15 @@ func TestNetworkProvider_GetNodeStatusWithSuccess(t *testing.T) {
102104 Hash : "00000998" ,
103105 PreviousBlockHash : "00000997" ,
104106 Timestamp : 998 ,
107+ TimestampMs : 998200 ,
105108 }
106109
107110 expectedSummaryOfOldest := resources.BlockSummary {
108111 Nonce : 300 ,
109112 Hash : "00000300" ,
110113 PreviousBlockHash : "00000299" ,
111114 Timestamp : 300 ,
115+ TimestampMs : 3002000 ,
112116 }
113117
114118 nodeStatus , err := provider .GetNodeStatus ()
@@ -164,8 +168,8 @@ func TestNetworkProvider_GetLatestBlockNonce(t *testing.T) {
164168 args .FirstHistoricalEpoch = 2
165169 args .NumHistoricalEpochs = 8
166170
167- provider , err := NewNetworkProvider (args )
168- require .Nil (t , err )
171+ provider , errC := NewNetworkProvider (args )
172+ require .Nil (t , errC )
169173 require .NotNil (t , provider )
170174
171175 t .Run ("when HighestFinalNonce <= 2 (node didn't start syncing)" , func (t * testing.T ) {
@@ -207,6 +211,51 @@ func TestNetworkProvider_GetLatestBlockNonce(t *testing.T) {
207211 return 0 , errors .New ("unexpected request" )
208212 }
209213
214+ nonce , err := provider .getLatestBlockNonce ()
215+ require .Nil (t , err )
216+ require .Equal (t , uint64 (40 ), nonce )
217+ })
218+ t .Run ("when HighestFinalNonce is greater than LastExecutedNonce" , func (t * testing.T ) {
219+ t .Parallel ()
220+
221+ observerFacade .CallGetRestEndPointCalled = func (baseUrl , path string , value interface {}) (int , error ) {
222+ if path == "/node/status" {
223+ value .(* resources.NodeStatusApiResponse ).Data = resources.NodeStatusApiResponsePayload {
224+ Status : resources.NodeStatus {
225+ HighestFinalNonce : 42 ,
226+ LastExecutedNonce : 39 ,
227+ },
228+ }
229+
230+ return 0 , nil
231+ }
232+
233+ return 0 , errors .New ("unexpected request" )
234+ }
235+
236+ nonce , err := provider .getLatestBlockNonce ()
237+ require .Nil (t , err )
238+ require .Equal (t , uint64 (39 ), nonce )
239+ })
240+
241+ t .Run ("when HighestFinalNonce is greater than LastExecutedNonce, but LastExecutedNonce is zero" , func (t * testing.T ) {
242+ t .Parallel ()
243+
244+ observerFacade .CallGetRestEndPointCalled = func (baseUrl , path string , value interface {}) (int , error ) {
245+ if path == "/node/status" {
246+ value .(* resources.NodeStatusApiResponse ).Data = resources.NodeStatusApiResponsePayload {
247+ Status : resources.NodeStatus {
248+ HighestFinalNonce : 42 ,
249+ LastExecutedNonce : 0 ,
250+ },
251+ }
252+
253+ return 0 , nil
254+ }
255+
256+ return 0 , errors .New ("unexpected request" )
257+ }
258+
210259 nonce , err := provider .getLatestBlockNonce ()
211260 require .Nil (t , err )
212261 require .Equal (t , uint64 (40 ), nonce )
0 commit comments