package Ġco . nil in . op ex . bc gateway . ports . postgres . dao Ċ Ċ import Ġco . nil in . op ex . bc gateway . ports . postgres . model . Chain Sync Record Model Ċ import Ġorg . springframework . data . r 2 dbc . repository . Query Ċ import Ġorg . springframework . data . repository . reactive . Reactive Crud Repository Ċ import Ġorg . springframework . stereotype . Repository Ċ import Ġreactor . core . publisher . Mono Ċ import Ġjava . time . LocalDateTime Ċ Ċ @ Repository Ċ interface ĠChain Sync Record Repository Ġ: ĠReactive Crud Repository < Chain Sync Record Model , ĠString > Ġ{ ĊĊĠĠĠ Ġ@ Query (" insert Ġinto Ġchain _ sync _ records Ġvalues (: chain , Ġ: time , Ġ: endpoint Url , Ġ: latest Block , Ġ: success , Ġ: error )") ĊĠĠĠ Ġfun Ġinsert ( ĊĠĠĠĠĠĠĠ Ġchain : ĠString , ĊĠĠĠĠĠĠĠ Ġtime : ĠLocalDateTime , ĊĠĠĠĠĠĠĠ Ġendpoint Url : ĠString , ĊĠĠĠĠĠĠĠ Ġlatest Block : ĠLong ?, ĊĠĠĠĠĠĠĠ Ġsuccess : ĠBoolean , ĊĠĠĠĠĠĠĠ Ġerror : ĠString ? ĊĠĠĠ Ġ): Mono < Chain Sync Record Model > ĊĊĠĠĠ Ġfun ĠfindBy Chain ( chain : ĠString ): ĠMono < Chain Sync Record Model > Ċ } Ċ