package Ġcom . notice med an . fin ch . service Ċ Ċ import Ġcom . notice med an . fin ch . Test Config Ċ import Ġcom . notice med an . fin ch . dto . Flow Info Ċ import Ġcom . notice med an . fin ch . dto . Result Config Info Ċ import Ġcom . notice med an . fin ch . dto . Result Kind Ċ import Ġcom . notice med an . fin ch . dto . t tn .* Ċ import Ġcom . notice med an . fin ch . exception . Application Not Part Of Flow Ċ import Ġcom . vl ad mi hal cea . hibernate . type . json . internal . Jack son Util Ċ import Ġorg . junit . Test Ċ import Ġorg . junit . jupiter . api . assert DoesNot Throw Ċ import Ġorg . junit . jupiter . api . assert Throws Ċ import Ġorg . junit . runner . RunWith Ċ import Ġorg . springframework . beans . factory . annotation . Autowired Ċ import Ġorg . springframework . boot . test . context . SpringBootTest Ċ import Ġorg . springframework . test . context . junit 4 . Spring Runner Ċ import Ġjava . time . Instant Ċ Ċ @ RunWith ( Spring Runner :: class ) Ċ @ SpringBootTest ( classes Ġ= Ġ[ Test Config :: class ]) Ċ class ĠWeb hook Service Test Ġ{ ĊĠĠĠ Ġ@ Autowired ĊĠĠĠ Ġprivate Ġlateinit Ġvar Ġwebhook Service : ĠWeb hook Service ĊĊĠĠĠ Ġ@ Autowired ĊĠĠĠ Ġprivate Ġlateinit Ġvar Ġflow Service : ĠFlow Service ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġadd EventData () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġreceived At Ġ= ĠInstant . now () ĊĊĠĠĠĠĠĠĠ Ġval Ġevent Ġ= ĠEvent Data Info ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠEnd DeviceId Info ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" dev Id ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠApplication Id Info (" appId "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" dev Addr " ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠlistOf (" correlation "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġreceived At , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠU plink MessageInfo ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 L , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 L , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" payload ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠlistOf ( Rx Metadata Info ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠGateway Id Info (" gateway Id "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġreceived At , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 L , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" token " ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ)), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠSettings Info ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠData Rate Info ( L ora Info ( 1 L , Ġ 1 L )), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" coding rate ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" freq ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 L , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġreceived At ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġreceived At ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ ĠassertThrows < Application Not Part Of Flow > Ġ{ Ġwebhook Service . add EventData ( event ) Ġ} ĊĊĠĠĠĠĠĠĠ Ġval Ġconfig Ġ= Ġ"{\" url \": Ġ\" http :// google . com / \", Ġ\" size \": Ġ 2 }" ĊĠĠĠĠĠĠĠ Ġval Ġresult Config Ġ= ĠResult Config Info ( Result Kind . HTTP , ĠJack son Util . toJson Node ( config )) ĊĠĠĠĠĠĠĠ Ġflow Service . create Flow ( Flow Info (" My Ġflow ", Ġ" appId ", Ġ" 1 Ġ* Ġ* Ġ* Ġ* Ġ* ", Ġresult Config , Ġtrue )) ĊĊĠĠĠĠĠĠĠ Ġassert DoesNot Throw Ġ{ Ġwebhook Service . add EventData ( event ) Ġ} ĊĠĠĠ Ġ} Ċ } Ċ