package Ġcom . rar ible . protocol . nft . migration . mong ock . mongo Ċ Ċ import Ġcom . github . cloud y rock . mong ock . Change Log Ċ import Ġcom . github . cloud y rock . mong ock . Change Set Ċ import Ġcom . rar ible . protocol . nft . core . model . Item Ċ import Ġcom . rar ible . protocol . nft . core . repository . item . Item Repository Ċ import Ġcom . rar ible . protocol . nft . core . service . item . Reduce EventListener Listener Ċ import Ġio . ch ang ock . migration . api . annotations . Non Lock Gu arded Ċ import Ġkotlinx . coroutines . run Blocking Ċ import Ġorg . slf 4 j . Logger Ċ import Ġorg . slf 4 j . LoggerFactory Ċ import Ġorg . springframework . data . mongodb . core . query . Query Ċ import Ġorg . springframework . data . mongodb . core . query . isEqualTo Ċ import Ġscale ther . domain . Address Ċ Ċ @ Change Log ( order Ġ= Ġ" 0 0 0 1 5 ") Ċ class ĠChange Log 0 0 0 1 5 Update Crypto Bot s Ġ{ ĊĠĠĠ Ġprivate Ġval Ġlogger : ĠLogger Ġ= ĠLoggerFactory . getLogger ( java Class ) ĊĊĠĠĠ Ġ@ Change Set ( id Ġ= Ġ" Change Log 0 0 0 1 5 Update Crypto Bot s . send Item Updates ", Ġorder Ġ= Ġ" 1 ", Ġauthor Ġ= Ġ" protocol ") ĊĠĠĠ Ġfun Ġsend Item Updates ( ĊĠĠĠĠĠĠĠ Ġ@ Non Lock Gu arded Ġitem Repository : ĠItem Repository , ĊĠĠĠĠĠĠĠ Ġ@ Non Lock Gu arded Ġreduce EventListener Listener : ĠReduce EventListener Listener ĊĠĠĠ Ġ) Ġ= Ġrun Blocking < Unit > Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġquery Ġ= ĠQuery . query ( Item :: token Ġis EqualTo ĠAddress . apply (" 0 xf 7 a 6 e 1 5 dfd 5 cdd 9 ef 1 2 7 1 1 bd 7 5 7 a 9 b 6 0 2 1 abf 6 4 3 ")) ĊĠĠĠĠĠĠĠ Ġitem Repository . search ( query ). forEach Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlogger . info (" Send Ġnotification Ġfor Ġ${ it . id }") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreduce EventListener Listener . on Item Changed ( it ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ