package Ġcom . gr in is rit . crypto . der ib it Ċ Ċ import Ġcom . gr in is rit . crypto . common .* Ċ import Ġcom . gr in is rit . crypto . common . mongo . MongoDB Server Ċ import Ġkotlinx . coroutines . flow .* Ċ import Ġorg . lit ote . km ongo .* Ċ Ċ class ĠDer ib it Mongo Client ( server : ĠMongoDB Server ) Ġ{ ĊĠĠĠ Ġprivate Ġval Ġdatabase Ġ= Ġserver . client . get Database ( Platform Name . der ib it . toString ()) ĊĊĠĠĠ Ġfun Ġload Order Books ( symbol : ĠString ): Ġun ref ined Data Flow Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġcollection Ġ= Ġdatabase . get Collection < Timestamp ed Order Book >( Der ib it DataType . book . toString ()) ĊĠĠĠĠĠĠĠ Ġreturn Ġcollection . find ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠTimestamp ed Order Book :: platform _ data Ġ/ ĠDer ib it Book :: params ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ/ ĠBook Parameters :: data Ġ/ ĠBook Data :: instrument _ name Ġeq Ġsymbol ĊĠĠĠĠĠĠĠ Ġ). to Flow (). map Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġit . to Timestamp ed Data () ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġload Trades ( symbol : ĠString ): Ġun ref ined Data Flow Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġcollection Ġ= Ġdatabase . get Collection < Timestamp ed Trade >( Der ib it DataType . tr ades . toString ()) ĊĠĠĠĠĠĠĠ Ġval Ġchannel Ġ= Ġ" tr ades .$ symbol . raw " ĊĠĠĠĠĠĠĠ Ġreturn Ġcollection . find ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠTimestamp ed Trade :: platform _ data Ġ/ ĠDer ib it Trades :: params Ġ/ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠTr ades Parameters :: channel Ġeq Ġchannel ĊĠĠĠĠĠĠĠ Ġ). to Flow (). map Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġit . to Timestamp ed Data () ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ Ċ }