add support for elastic v7

Author: fupelaqu

build.sbt

@@ -96,6 +96,59 @@ lazy val persistence = project.in(file("persistence"))
     core % "compile->compile;test->test;it->it"
   )
 
+lazy val es7rest = project.in(file("es7/rest"))
+  .configs(IntegrationTest)
+  .settings(
+    Defaults.itSettings,
+    moduleSettings,
+    elasticSearchVersion := Versions.es7,
+  )
+  .dependsOn(
+    core % "compile->compile;test->test;it->it"
+  )
+
+lazy val es7restp = project.in(file("es7/rest/persistence"))
+  .configs(IntegrationTest)
+  .settings(
+    Defaults.itSettings,
+    moduleSettings,
+    elasticSearchVersion := Versions.es7,
+  )
+  .dependsOn(
+    persistence % "compile->compile;test->test;it->it"
+  )
+  .dependsOn(
+    es7rest % "compile->compile;test->test;it->it"
+  )
+
+lazy val es7testkit = project.in(file("es7/testkit"))
+  .configs(IntegrationTest)
+  .settings(
+    Defaults.itSettings,
+    app.softnetwork.Info.infoSettings,
+    moduleSettings,
+    elasticSearchVersion := Versions.es7,
+    buildInfoKeys += BuildInfoKey("elasticVersion" -> elasticSearchVersion.value)
+  )
+  .enablePlugins(BuildInfoPlugin)
+  .dependsOn(
+    es7restp % "compile->compile;test->test;it->it"
+  )
+
+lazy val es7 = project.in(file("es7"))
+  .configs(IntegrationTest)
+  .settings(
+    Defaults.itSettings,
+    Publish.noPublishSettings,
+    crossScalaVersions := Nil,
+    elasticSearchVersion := Versions.es7
+  )
+  .aggregate(
+    es7rest,
+    es7restp,
+    es7testkit
+  )
+
 lazy val es8java = project.in(file("es8/java"))
   .configs(IntegrationTest)
   .settings(

es7/build.sbt

@@ -0,0 +1,7 @@
+import SoftClient4es.*
+organization := "app.softnetwork.elastic"
+name := s"softclient4es${elasticSearchMajorVersion(elasticSearchVersion.value)}"
+publish / skip := true
+Compile / sources := Nil
+Test / sources := Nil
+

es7/rest/build.sbt

@@ -0,0 +1,8 @@
+import SoftClient4es.*
+
+organization := "app.softnetwork.elastic"
+
+name := s"softclient4es${elasticSearchMajorVersion(elasticSearchVersion.value)}-rest-client"
+
+libraryDependencies ++= restClientDependencies(elasticSearchVersion.value) ++
+  elastic4sDependencies(elasticSearchVersion.value)

es7/rest/persistence/build.sbt

@@ -0,0 +1,6 @@
+import SoftClient4es.{elasticSearchMajorVersion, elasticSearchVersion}
+
+organization := "app.softnetwork.elastic"
+
+name := s"softclient4es${elasticSearchMajorVersion(elasticSearchVersion.value)}-rest-persistence"
+

es7/rest/persistence/src/main/scala/app/softnetwork/elastic/persistence/query/RestHighLevelClientProvider.scala

@@ -0,0 +1,12 @@
+package app.softnetwork.elastic.persistence.query
+
+import app.softnetwork.elastic.client.rest.RestHighLevelClientApi
+import app.softnetwork.persistence.ManifestWrapper
+import app.softnetwork.persistence.model.Timestamped
+
+trait RestHighLevelClientProvider[T <: Timestamped]
+    extends ElasticProvider[T]
+    with RestHighLevelClientApi {
+  _: ManifestWrapper[T] =>
+
+}

es7/rest/persistence/src/main/scala/app/softnetwork/elastic/persistence/query/State2ElasticProcessorStreamWithRestProvider.scala

@@ -0,0 +1,9 @@
+package app.softnetwork.elastic.persistence.query
+
+import app.softnetwork.persistence.message.CrudEvent
+import app.softnetwork.persistence.model.Timestamped
+import app.softnetwork.persistence.query.{JournalProvider, OffsetProvider}
+
+trait State2ElasticProcessorStreamWithRestProvider[T <: Timestamped, E <: CrudEvent]
+    extends State2ElasticProcessorStream[T, E]
+    with RestHighLevelClientProvider[T] { _: JournalProvider with OffsetProvider => }