package Ġpt . ise l . vs dd ashboard application Ċ Ċ import Ġkotlinx . coroutines . run Blocking Ċ import Ġorg . junit . Assert Ċ import Ġorg . junit . Test Ċ import Ġpt . ise l . vs dd ashboard application . repository . services . Elastic Search Ret rofit Singleton Ċ Ċ class ĠQuery Dsl Test Ġ{ ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* ĠTest Ġfor ĠES , Ġget Ġall Ġthe Ġhits Ġfor ĠN uage Ġflow ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġget Pro best at With Query Test () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġuri Ġ= ĠTest Object . es Api ĊĠĠĠĠĠĠĠ ĠElastic Search Ret rofit Singleton . set ( uri ) ĊĠĠĠĠĠĠĠ Ġval Ġservice Ġ= ĠElastic Search Ret rofit Singleton . dpi Pro best ats () ĊĊĠĠĠĠĠĠĠ ĠAssert . assertNotNull ( service ) ĊĠĠĠĠĠĠĠ Ġval Ġmax Ġ= ĠSystem . currentTimeMillis () Ġ- Ġ 3 6 0 0 Ġ* Ġ 1 0 0 0 ĊĠĠĠĠĠĠĠ Ġval Ġmin Ġ= ĠSystem . currentTimeMillis () Ġ- Ġ 2 Ġ* Ġ( 3 6 0 0 Ġ* Ġ 1 0 0 0 ) ĊĊĠĠĠĠĠĠĠ Ġrun Blocking Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġprobe Job Ġ= Ġservice ?. get D pi Pro best ats With Query ( sort Ġ= Ġ" timestamp : desc ", Ġquery Ġ= ĠarrayOf (" timestamp : [$ min ĠTO Ġ$ max ] ")) ĊĠĠĠĠĠĠĠĠĠĠĠ ĠAssert . assertNotNull ( probe Job ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġprobe Ġ= Ġprobe Job !!. await () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġfor ( current Ġin Ġprobe . hits . hits ){ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġtime Ġ= Ġcurrent . source ?. timestamp ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠAssert . assertNotNull ( time ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠAssert . assertTrue ( time !! Ġ> Ġmin Ġ&& Ġtime Ġ< Ġmax ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ Ċ }