/* Ċ Ġ* ĠCopyright ĠOpen Search ĠContributors Ċ Ġ* ĠSPDX - License - Identifier : ĠApache - 2 . 0 Ċ Ġ*/ Ċ Ċ package Ġorg . opense arch . index management . index state management . action Ċ Ċ import Ġorg . opense arch . index management . index state management . Index State Management Rest TestCase Ċ import Ġorg . opense arch . index management . index state management . model . Policy Ċ import Ġorg . opense arch . index management . index state management . model . State Ċ import Ġorg . opense arch . index management . index state management . random Error Notification Ċ import Ġorg . opense arch . index management . waitFor Ċ import Ġjava . time . Instant Ċ import Ġjava . time . temporal . Ch rono Unit Ċ import Ġjava . util . Locale Ċ Ċ class ĠOpen Action IT Ġ: ĠIndex State Management Rest TestCase () Ġ{ ĊĠĠĠ Ġprivate Ġval Ġtest Index Name Ġ= Ġjava Class . simple Name . toLowerCase ( Locale . ROOT ) ĊĊĠĠĠ Ġfun Ġ` test Ġbasic `() Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġindex Name Ġ= Ġ"${ test Index Name }_ index _ 1 " ĊĠĠĠĠĠĠĠ Ġval Ġpolicy ID Ġ= Ġ"${ test Index Name }_ test Policy Name _ 1 " ĊĠĠĠĠĠĠĠ Ġval Ġaction Config Ġ= ĠOpen Action ( 0 ) ĊĠĠĠĠĠĠĠ Ġval Ġstates Ġ= ĠlistOf ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠState (" Open State ", ĠlistOf ( action Config ), ĠlistOf ()) ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ Ġval Ġpolicy Ġ= ĠPolicy ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġid Ġ= Ġpolicy ID , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġdescription Ġ= Ġ"$ test Index Name Ġdescription ", ĊĠĠĠĠĠĠĠĠĠĠĠ Ġschema Version Ġ= Ġ 1 L , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlast Updated Time Ġ= ĠInstant . now (). tr uncated To ( Ch rono Unit . M ILL IS ), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġerror Notification Ġ= Ġrandom Error Notification (), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġdefault State Ġ= Ġstates [ 0 ]. name , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġstates Ġ= Ġstates ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġcreate Policy ( policy , Ġpolicy ID ) ĊĠĠĠĠĠĠĠ Ġcreate Index ( index Name , Ġpolicy ID ) ĊĠĠĠĠĠĠĠ Ġclose Index ( index Name ) ĊĊĠĠĠĠĠĠĠ ĠassertEquals (" close ", Ġget Index State ( index Name )) ĊĊĠĠĠĠĠĠĠ Ġval Ġmanaged Index Config Ġ= Ġget Existing Managed Index Config ( index Name ) ĊĊĠĠĠĠĠĠĠ Ġ// ĠChange Ġthe Ġstart Ġtime Ġso Ġthe Ġjob Ġwill Ġtrigger Ġin Ġ 2 Ġseconds . ĊĠĠĠĠĠĠĠ Ġupdate Managed Index Config StartTime ( managed Index Config ) ĊĊĠĠĠĠĠĠĠ ĠwaitFor Ġ{ ĠassertEquals ( policy ID , Ġget Explain Managed Index MetaData ( index Name ). policy ID ) Ġ} ĊĊĠĠĠĠĠĠĠ Ġ// ĠNeed Ġto Ġwait Ġtwo Ġcycles . ĊĠĠĠĠĠĠĠ Ġ// ĠChange Ġthe Ġstart Ġtime Ġso Ġthe Ġjob Ġwill Ġtrigger Ġin Ġ 2 Ġseconds . ĊĠĠĠĠĠĠĠ Ġupdate Managed Index Config StartTime ( managed Index Config ) ĊĊĠĠĠĠĠĠĠ ĠwaitFor Ġ{ ĠassertEquals (" open ", Ġget Index State ( index Name )) Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ` test Ġalready Ġopen Ġindex `() Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġindex Name Ġ= Ġ"${ test Index Name }_ index _ 2 " ĊĠĠĠĠĠĠĠ Ġval Ġpolicy ID Ġ= Ġ"${ test Index Name }_ test Policy Name _ 2 " ĊĠĠĠĠĠĠĠ Ġval Ġaction Config Ġ= ĠOpen Action ( 0 ) ĊĠĠĠĠĠĠĠ Ġval Ġstates Ġ= ĠlistOf ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠState (" Open State ", ĠlistOf ( action Config ), ĠlistOf ()) ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ Ġval Ġpolicy Ġ= ĠPolicy ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġid Ġ= Ġpolicy ID , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġdescription Ġ= Ġ"$ test Index Name Ġdescription ", ĊĠĠĠĠĠĠĠĠĠĠĠ Ġschema Version Ġ= Ġ 1 L , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlast Updated Time Ġ= ĠInstant . now (). tr uncated To ( Ch rono Unit . M ILL IS ), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġerror Notification Ġ= Ġrandom Error Notification (), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġdefault State Ġ= Ġstates [ 0 ]. name , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġstates Ġ= Ġstates ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġcreate Policy ( policy , Ġpolicy ID ) ĊĠĠĠĠĠĠĠ Ġcreate Index ( index Name , Ġpolicy ID ) ĊĊĠĠĠĠĠĠĠ ĠassertEquals (" open ", Ġget Index State ( index Name )) ĊĊĠĠĠĠĠĠĠ Ġval Ġmanaged Index Config Ġ= Ġget Existing Managed Index Config ( index Name ) ĊĊĠĠĠĠĠĠĠ Ġ// ĠChange Ġthe Ġstart Ġtime Ġso Ġthe Ġjob Ġwill Ġtrigger Ġin Ġ 2 Ġseconds . ĊĠĠĠĠĠĠĠ Ġupdate Managed Index Config StartTime ( managed Index Config ) ĊĊĠĠĠĠĠĠĠ ĠwaitFor Ġ{ ĠassertEquals ( policy ID , Ġget Explain Managed Index MetaData ( index Name ). policy ID ) Ġ} ĊĊĠĠĠĠĠĠĠ Ġ// ĠNeed Ġto Ġwait Ġtwo Ġcycles . ĊĠĠĠĠĠĠĠ Ġ// ĠChange Ġthe Ġstart Ġtime Ġso Ġthe Ġjob Ġwill Ġtrigger Ġin Ġ 2 Ġseconds . ĊĠĠĠĠĠĠĠ Ġupdate Managed Index Config StartTime ( managed Index Config ) ĊĊĠĠĠĠĠĠĠ ĠwaitFor Ġ{ ĠassertEquals (" open ", Ġget Index State ( index Name )) Ġ} ĊĠĠĠ Ġ} Ċ } Ċ