@@ -138,29 +138,25 @@ mod tests {
138
138
#[ tokio:: test]
139
139
async fn sync_from_same_chain ( ) {
140
140
let mut chain = Blockchain :: default ( ) . with_height ( 4 ) ;
141
- let new_tip = chain. tip ( ) ;
142
- let old_tip_1 = chain. at_height ( 1 ) ;
143
- let old_tip_2 = chain. at_height ( 2 ) ;
144
- let old_tip_3 = chain. at_height ( 3 ) ;
145
141
146
142
let mut listener_1 = MockChainListener :: new ( )
147
- . expect_block_connected ( * old_tip_2 )
148
- . expect_block_connected ( * old_tip_3 )
149
- . expect_block_connected ( * new_tip ) ;
143
+ . expect_block_connected ( * chain . at_height ( 2 ) )
144
+ . expect_block_connected ( * chain . at_height ( 3 ) )
145
+ . expect_block_connected ( * chain . at_height ( 4 ) ) ;
150
146
let mut listener_2 = MockChainListener :: new ( )
151
- . expect_block_connected ( * old_tip_3 )
152
- . expect_block_connected ( * new_tip ) ;
147
+ . expect_block_connected ( * chain . at_height ( 3 ) )
148
+ . expect_block_connected ( * chain . at_height ( 4 ) ) ;
153
149
let mut listener_3 = MockChainListener :: new ( )
154
- . expect_block_connected ( * new_tip ) ;
150
+ . expect_block_connected ( * chain . at_height ( 4 ) ) ;
155
151
156
152
let listeners = vec ! [
157
- ( old_tip_1 . block_hash, & mut listener_1 as & mut dyn ChainListener ) ,
158
- ( old_tip_2 . block_hash, & mut listener_2 as & mut dyn ChainListener ) ,
159
- ( old_tip_3 . block_hash, & mut listener_3 as & mut dyn ChainListener ) ,
153
+ ( chain . at_height ( 1 ) . block_hash, & mut listener_1 as & mut dyn ChainListener ) ,
154
+ ( chain . at_height ( 2 ) . block_hash, & mut listener_2 as & mut dyn ChainListener ) ,
155
+ ( chain . at_height ( 3 ) . block_hash, & mut listener_3 as & mut dyn ChainListener ) ,
160
156
] ;
161
157
let mut cache = chain. header_cache ( 0 ..=4 ) ;
162
158
match sync_listeners ( & mut chain, Network :: Bitcoin , & mut cache, listeners) . await {
163
- Ok ( header) => assert_eq ! ( header, new_tip ) ,
159
+ Ok ( header) => assert_eq ! ( header, chain . tip ( ) ) ,
164
160
Err ( e) => panic ! ( "Unexpected error: {:?}" , e) ,
165
161
}
166
162
}
@@ -172,11 +168,6 @@ mod tests {
172
168
let fork_chain_2 = main_chain. fork_at_height ( 2 ) ;
173
169
let fork_chain_3 = main_chain. fork_at_height ( 3 ) ;
174
170
175
- let new_tip = main_chain. tip ( ) ;
176
- let old_tip_1 = fork_chain_1. tip ( ) ;
177
- let old_tip_2 = fork_chain_2. tip ( ) ;
178
- let old_tip_3 = fork_chain_3. tip ( ) ;
179
-
180
171
let mut listener_1 = MockChainListener :: new ( )
181
172
. expect_block_disconnected ( * fork_chain_1. at_height ( 4 ) )
182
173
. expect_block_disconnected ( * fork_chain_1. at_height ( 3 ) )
@@ -194,15 +185,15 @@ mod tests {
194
185
. expect_block_connected ( * main_chain. at_height ( 4 ) ) ;
195
186
196
187
let listeners = vec ! [
197
- ( old_tip_1 . block_hash, & mut listener_1 as & mut dyn ChainListener ) ,
198
- ( old_tip_2 . block_hash, & mut listener_2 as & mut dyn ChainListener ) ,
199
- ( old_tip_3 . block_hash, & mut listener_3 as & mut dyn ChainListener ) ,
188
+ ( fork_chain_1 . tip ( ) . block_hash, & mut listener_1 as & mut dyn ChainListener ) ,
189
+ ( fork_chain_2 . tip ( ) . block_hash, & mut listener_2 as & mut dyn ChainListener ) ,
190
+ ( fork_chain_3 . tip ( ) . block_hash, & mut listener_3 as & mut dyn ChainListener ) ,
200
191
] ;
201
192
let mut cache = fork_chain_1. header_cache ( 2 ..=4 ) ;
202
193
cache. extend ( fork_chain_2. header_cache ( 3 ..=4 ) ) ;
203
194
cache. extend ( fork_chain_3. header_cache ( 4 ..=4 ) ) ;
204
195
match sync_listeners ( & mut main_chain, Network :: Bitcoin , & mut cache, listeners) . await {
205
- Ok ( header) => assert_eq ! ( header, new_tip ) ,
196
+ Ok ( header) => assert_eq ! ( header, main_chain . tip ( ) ) ,
206
197
Err ( e) => panic ! ( "Unexpected error: {:?}" , e) ,
207
198
}
208
199
}
@@ -214,11 +205,6 @@ mod tests {
214
205
let fork_chain_2 = fork_chain_1. fork_at_height ( 2 ) ;
215
206
let fork_chain_3 = fork_chain_2. fork_at_height ( 3 ) ;
216
207
217
- let new_tip = main_chain. tip ( ) ;
218
- let old_tip_1 = fork_chain_1. tip ( ) ;
219
- let old_tip_2 = fork_chain_2. tip ( ) ;
220
- let old_tip_3 = fork_chain_3. tip ( ) ;
221
-
222
208
let mut listener_1 = MockChainListener :: new ( )
223
209
. expect_block_disconnected ( * fork_chain_1. at_height ( 4 ) )
224
210
. expect_block_disconnected ( * fork_chain_1. at_height ( 3 ) )
@@ -242,15 +228,15 @@ mod tests {
242
228
. expect_block_connected ( * main_chain. at_height ( 4 ) ) ;
243
229
244
230
let listeners = vec ! [
245
- ( old_tip_1 . block_hash, & mut listener_1 as & mut dyn ChainListener ) ,
246
- ( old_tip_2 . block_hash, & mut listener_2 as & mut dyn ChainListener ) ,
247
- ( old_tip_3 . block_hash, & mut listener_3 as & mut dyn ChainListener ) ,
231
+ ( fork_chain_1 . tip ( ) . block_hash, & mut listener_1 as & mut dyn ChainListener ) ,
232
+ ( fork_chain_2 . tip ( ) . block_hash, & mut listener_2 as & mut dyn ChainListener ) ,
233
+ ( fork_chain_3 . tip ( ) . block_hash, & mut listener_3 as & mut dyn ChainListener ) ,
248
234
] ;
249
235
let mut cache = fork_chain_1. header_cache ( 2 ..=4 ) ;
250
236
cache. extend ( fork_chain_2. header_cache ( 3 ..=4 ) ) ;
251
237
cache. extend ( fork_chain_3. header_cache ( 4 ..=4 ) ) ;
252
238
match sync_listeners ( & mut main_chain, Network :: Bitcoin , & mut cache, listeners) . await {
253
- Ok ( header) => assert_eq ! ( header, new_tip ) ,
239
+ Ok ( header) => assert_eq ! ( header, main_chain . tip ( ) ) ,
254
240
Err ( e) => panic ! ( "Unexpected error: {:?}" , e) ,
255
241
}
256
242
}
@@ -259,13 +245,12 @@ mod tests {
259
245
async fn cache_connected_and_keep_disconnected_blocks ( ) {
260
246
let mut main_chain = Blockchain :: default ( ) . with_height ( 2 ) ;
261
247
let fork_chain = main_chain. fork_at_height ( 1 ) ;
262
-
263
248
let new_tip = main_chain. tip ( ) ;
264
249
let old_tip = fork_chain. tip ( ) ;
265
250
266
251
let mut listener = MockChainListener :: new ( )
267
- . expect_block_disconnected ( * fork_chain . at_height ( 2 ) )
268
- . expect_block_connected ( * main_chain . at_height ( 2 ) ) ;
252
+ . expect_block_disconnected ( * old_tip )
253
+ . expect_block_connected ( * new_tip ) ;
269
254
270
255
let listeners = vec ! [ ( old_tip. block_hash, & mut listener as & mut dyn ChainListener ) ] ;
271
256
let mut cache = fork_chain. header_cache ( 2 ..=2 ) ;
0 commit comments