@@ -179,7 +179,9 @@ mod tests {
179179 . into_iter ( )
180180 . collect ( ) ,
181181 } ;
182- let change = SourceChange :: new ( ChangeOp :: Create , node, 1234567890 , 1 , None ) ;
182+ let mut change = SourceChange :: new ( ChangeOp :: Create , node, 1234567890000000000 , 1234500000123456789 , 1 , None ) ;
183+ let current_time = 1234567890001234567 ;
184+ change. set_reactivator_end_ns ( current_time) ;
183185 let serialized = serde_json:: to_string ( & change) . unwrap ( ) ;
184186 let expected = json ! ( {
185187 "op" : "i" ,
@@ -197,11 +199,13 @@ mod tests {
197199 "db" : "drasi" ,
198200 "lsn" : 1 ,
199201 "table" : "node" ,
200- "ts_ms " : 1234567890 ,
202+ "ts_ns " : 1234500000123456789u128 ,
201203 } ,
202204 } ,
203- "ts_ms" : 1234567890 ,
205+ "reactivatorStart_ns" : 1234567890000000000u128 ,
206+ "reactivatorEnd_ns" : current_time,
204207 } ) ;
208+ println ! ( "Serialized: {}" , serialized) ;
205209 assert_eq ! (
206210 serde_json:: from_str:: <Value >( & serialized) . unwrap( ) ,
207211 expected
@@ -223,7 +227,9 @@ mod tests {
223227 start_id : "2" . to_string ( ) ,
224228 end_id : "3" . to_string ( ) ,
225229 } ;
226- let change = SourceChange :: new ( ChangeOp :: Create , relation, 1234567890 , 1 , None ) ;
230+ let mut change = SourceChange :: new ( ChangeOp :: Create , relation, 1234567890000000000 , 1234500000123456789 , 1 , None ) ;
231+ let current_time = 1234567890001234567 ;
232+ change. set_reactivator_end_ns ( current_time) ;
227233 let serialized = serde_json:: to_string ( & change) . unwrap ( ) ;
228234 let expected = json ! ( {
229235 "op" : "i" ,
@@ -243,10 +249,11 @@ mod tests {
243249 "db" : "drasi" ,
244250 "lsn" : 1 ,
245251 "table" : "rel" ,
246- "ts_ms " : 1234567890 ,
252+ "ts_ns " : 1234500000123456789u128 ,
247253 } ,
248254 } ,
249- "ts_ms" : 1234567890 ,
255+ "reactivatorStart_ns" : 1234567890000000000u128 ,
256+ "reactivatorEnd_ns" : current_time,
250257 } ) ;
251258 assert_eq ! (
252259 serde_json:: from_str:: <Value >( & serialized) . unwrap( ) ,
@@ -267,7 +274,9 @@ mod tests {
267274 . into_iter ( )
268275 . collect ( ) ,
269276 } ;
270- let change = SourceChange :: new ( ChangeOp :: Update , node, 1234567890 , 1 , None ) ;
277+ let mut change = SourceChange :: new ( ChangeOp :: Update , node, 1234567890000000000 , 1234500000123456789 , 1 , None ) ;
278+ let current_time = 1234567890001234567 ;
279+ change. set_reactivator_end_ns ( current_time) ;
271280 let serialized = serde_json:: to_string ( & change) . unwrap ( ) ;
272281 let expected = json ! ( {
273282 "op" : "u" ,
@@ -285,10 +294,11 @@ mod tests {
285294 "db" : "drasi" ,
286295 "lsn" : 1 ,
287296 "table" : "node" ,
288- "ts_ms " : 1234567890 ,
297+ "ts_ns " : 1234500000123456789u128 ,
289298 } ,
290299 } ,
291- "ts_ms" : 1234567890 ,
300+ "reactivatorEnd_ns" : current_time,
301+ "reactivatorStart_ns" : 1234567890000000000u128 ,
292302 } ) ;
293303 assert_eq ! (
294304 serde_json:: from_str:: <Value >( & serialized) . unwrap( ) ,
@@ -309,7 +319,9 @@ mod tests {
309319 . into_iter ( )
310320 . collect ( ) ,
311321 } ;
312- let change = SourceChange :: new ( ChangeOp :: Delete , node, 1234567890 , 1 , None ) ;
322+ let mut change = SourceChange :: new ( ChangeOp :: Delete , node, 1234567890000000000 , 1234500000123456789 , 1 , None ) ;
323+ let current_time = 1234567890001234567 ;
324+ change. set_reactivator_end_ns ( current_time) ;
313325 let serialized = serde_json:: to_string ( & change) . unwrap ( ) ;
314326 let expected = json ! ( {
315327 "op" : "d" ,
@@ -327,10 +339,11 @@ mod tests {
327339 "db" : "drasi" ,
328340 "lsn" : 1 ,
329341 "table" : "node" ,
330- "ts_ms " : 1234567890 ,
342+ "ts_ns " : 1234500000123456789u128 ,
331343 } ,
332344 } ,
333- "ts_ms" : 1234567890 ,
345+ "reactivatorEnd_ns" : current_time,
346+ "reactivatorStart_ns" : 1234567890000000000u128 ,
334347 } ) ;
335348 assert_eq ! (
336349 serde_json:: from_str:: <Value >( & serialized) . unwrap( ) ,
0 commit comments