/* Ċ Ġ* ĠCopyright ĠOpen Search ĠContributors Ċ Ġ* ĠSPDX - License - Identifier : ĠApache - 2 . 0 Ċ Ġ*/ Ċ Ċ package Ġorg . opense arch . alert ing . action Ċ Ċ import Ġorg . opense arch . action . support . Write Request Ċ import Ġorg . opense arch . alert ing . model . destination . Ch ime Ċ import Ġorg . opense arch . alert ing . model . destination . Destination Ċ import Ġorg . opense arch . alert ing . random User Ċ import Ġorg . opense arch . alert ing . util . Destination Type Ċ import Ġorg . opense arch . common . io . stream . Bytes Stream Output Ċ import Ġorg . opense arch . common . io . stream . Stream Input Ċ import Ġorg . opense arch . rest . Rest Request Ċ import Ġorg . opense arch . test . Open Search TestCase Ċ import Ġjava . time . Instant Ċ Ċ class ĠIndex Destination Request Tests Ġ: ĠOpen Search TestCase () Ġ{ ĊĊĠĠĠ Ġfun Ġ` test Ġindex Ġdestination Ġpost Ġrequest `() Ġ{ ĊĊĠĠĠĠĠĠĠ Ġval Ġreq Ġ= ĠIndex Destination Request ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" 1 2 3 4 ", ĊĠĠĠĠĠĠĠĠĠĠĠĠ 0 L , ĊĠĠĠĠĠĠĠĠĠĠĠĠ 1 L , ĊĠĠĠĠĠĠĠĠĠĠĠ ĠWrite Request . Refresh Policy . IM MEDI ATE , ĊĠĠĠĠĠĠĠĠĠĠĠ ĠRest Request . Method . POST , ĊĠĠĠĠĠĠĠĠĠĠĠ ĠDestination ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" 1 2 3 4 ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 0 L , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠDestination Type . CH IME , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" Test Ch ime Dest ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġrandom User (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠInstant . now (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠCh ime (" test . com "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġnull , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġnull , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġnull ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ ĠassertNotNull ( req ) ĊĊĠĠĠĠĠĠĠ Ġval Ġout Ġ= ĠBytes Stream Output () ĊĠĠĠĠĠĠĠ Ġreq . writeTo ( out ) ĊĠĠĠĠĠĠĠ Ġval Ġsin Ġ= ĠStream Input . wrap ( out . bytes (). to Bytes Ref (). bytes ) ĊĠĠĠĠĠĠĠ Ġval Ġnew Req Ġ= ĠIndex Destination Request ( sin ) ĊĠĠĠĠĠĠĠ ĠassertEquals (" 1 2 3 4 ", Ġnew Req . destination Id ) ĊĠĠĠĠĠĠĠ ĠassertEquals ( 0 , Ġnew Req . seq No ) ĊĠĠĠĠĠĠĠ ĠassertEquals ( 1 , Ġnew Req . primary Term ) ĊĠĠĠĠĠĠĠ ĠassertEquals (" true ", Ġnew Req . refresh Policy . value ) ĊĠĠĠĠĠĠĠ ĠassertEquals ( Rest Request . Method . POST , Ġnew Req . method ) ĊĠĠĠĠĠĠĠ ĠassertNotNull ( new Req . destination ) ĊĠĠĠĠĠĠĠ ĠassertEquals (" 1 2 3 4 ", Ġnew Req . destination . id ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ` test Ġindex Ġdestination Ġput Ġrequest `() Ġ{ ĊĊĠĠĠĠĠĠĠ Ġval Ġreq Ġ= ĠIndex Destination Request ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" 1 2 3 4 ", ĊĠĠĠĠĠĠĠĠĠĠĠĠ 0 L , ĊĠĠĠĠĠĠĠĠĠĠĠĠ 1 L , ĊĠĠĠĠĠĠĠĠĠĠĠ ĠWrite Request . Refresh Policy . IM MEDI ATE , ĊĠĠĠĠĠĠĠĠĠĠĠ ĠRest Request . Method . PUT , ĊĠĠĠĠĠĠĠĠĠĠĠ ĠDestination ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" 1 2 3 4 ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 0 L , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠDestination Type . CH IME , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" Test Ch ime Dest ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġrandom User (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠInstant . now (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠCh ime (" test . com "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġnull , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġnull , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġnull ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ ĠassertNotNull ( req ) ĊĊĠĠĠĠĠĠĠ Ġval Ġout Ġ= ĠBytes Stream Output () ĊĠĠĠĠĠĠĠ Ġreq . writeTo ( out ) ĊĠĠĠĠĠĠĠ Ġval Ġsin Ġ= ĠStream Input . wrap ( out . bytes (). to Bytes Ref (). bytes ) ĊĠĠĠĠĠĠĠ Ġval Ġnew Req Ġ= ĠIndex Destination Request ( sin ) ĊĠĠĠĠĠĠĠ ĠassertEquals (" 1 2 3 4 ", Ġnew Req . destination Id ) ĊĠĠĠĠĠĠĠ ĠassertEquals ( 0 , Ġnew Req . seq No ) ĊĠĠĠĠĠĠĠ ĠassertEquals ( 1 , Ġnew Req . primary Term ) ĊĠĠĠĠĠĠĠ ĠassertEquals (" true ", Ġnew Req . refresh Policy . value ) ĊĠĠĠĠĠĠĠ ĠassertEquals ( Rest Request . Method . PUT , Ġnew Req . method ) ĊĠĠĠĠĠĠĠ ĠassertNotNull ( new Req . destination ) ĊĠĠĠĠĠĠĠ ĠassertEquals (" 1 2 3 4 ", Ġnew Req . destination . id ) ĊĠĠĠ Ġ} Ċ } Ċ