[8.9] Bump Elasticsearch apis (#693)

* Typedapi: Add changelog for future release

* bump 8.9.0

* API: Update typed API for Elasticsearch v8.9.0 (26d0e20)

* Tests: reflect typedapi changes

* API: Update API for Elasticsearch v8.9.0 (26ca704)

* fixup! API: Update typed API for Elasticsearch v8.9.0 (26d0e20)

.buildkite/pipeline.yml

@@ -4,7 +4,7 @@ steps:
       provider: "gcp"
     env:
       TEST_SUITE: "{{ matrix.suite }}"
-      STACK_VERSION: 8.8.0-SNAPSHOT
+      STACK_VERSION: 8.9.0-SNAPSHOT
       WORKSPACE: /tmp/go-elasticsearch
     matrix:
       setup:

.ci/test-matrix.yml

@@ -1,7 +1,7 @@
 ---
 
 STACK_VERSION:
-  - 8.8.0-SNAPSHOT
+  - 8.9.0-SNAPSHOT
 
 GO_VERSION:
   - 1-alpine

.github/workflows/build.yml

@@ -7,12 +7,12 @@ on:
     branches:
       - github-actions
       - main
-      - 8.5
+      - 8.9
       - 7.17
   pull_request:
     branches:
       - main
-      - 8.5
+      - 8.9
       - 7.17
 
 env:

.github/workflows/test-integration.yml

@@ -17,7 +17,7 @@ on:
 
 env:
   GITHUB_ACTIONS: true
-  ELASTICSEARCH_VERSION: elasticsearch:8.3.0-SNAPSHOT
+  ELASTICSEARCH_VERSION: elasticsearch:8.9.0-SNAPSHOT
 
 jobs:
   test:

CHANGELOG.md

@@ -1,3 +1,20 @@
+# 8.9.0
+
+## Typed API
+
+* Propagated request fields towards the endpoint for ease of access, taking priority over same-name query string fields.
+* Added a stub for Do methods on endpoints that only support a boolean response such as `core.exists`. 
+* NDJSON endpoints support with custom serialization and helpers for specific like `core.bulk`.
+* Link to endpoints documentation in API index to better display and easy of use.
+
+# 8.8.2
+
+## Typed API
+
+* Fixed deserialization for `Suggest` in search responses.
+* Fixed double-quoted strings in deserialization for unions normalized as string. #684
+* Fixed handling of `core.Get` response when the index did not exist. #678
+
 # 8.7.0
 
 ## API

Makefile

@@ -1,6 +1,6 @@
 SHELL := /bin/bash
 
-ELASTICSEARCH_DEFAULT_BUILD_VERSION = "8.8.0-SNAPSHOT"
+ELASTICSEARCH_DEFAULT_BUILD_VERSION = "8.9.0-SNAPSHOT"
 
 ##@ Test
 test-unit:  ## Run unit tests

elasticsearch_integration_test.go

@@ -28,7 +28,6 @@ import (
 	"errors"
 	"fmt"
 	"github.com/elastic/go-elasticsearch/v8/typedapi/core/search"
-	"github.com/elastic/go-elasticsearch/v8/typedapi/indices/create"
 	"github.com/elastic/go-elasticsearch/v8/typedapi/some"
 	"github.com/elastic/go-elasticsearch/v8/typedapi/types"
 	"github.com/elastic/go-elasticsearch/v8/typedapi/types/enums/refresh"
@@ -327,12 +326,10 @@ func TestTypedClient(t *testing.T) {
 		indexName := "test-index"
 		if exists, err := es.Indices.Exists(indexName).IsSuccess(context.Background()); !exists && err == nil {
 			res, err := es.Indices.Create(indexName).
-				Request(&create.Request{
-					Mappings: &types.TypeMapping{
-						Properties: map[string]types.Property{
-							"price": types.NewIntegerNumberProperty(),
-							"name":  types.NewKeywordProperty(),
-						},
+				Mappings(&types.TypeMapping{
+					Properties: map[string]types.Property{
+						"price": types.IntegerNumberProperty{},
+						"name":  types.KeywordProperty{},
 					},
 				}).
 				Do(context.Background())
@@ -360,6 +357,7 @@ func TestTypedClient(t *testing.T) {
 			Id    int    `json:"id"`
 			Name  string `json:"name"`
 			Price int    `json:"price"`
+			Alt   string `json:"alt"`
 		}
 
 		// Indexing synchronously with refresh.Waitfor, one document at a time
@@ -381,7 +379,7 @@ func TestTypedClient(t *testing.T) {
 			},
 		} {
 			indexed, err := es.Index(indexName).
-				Request(document).
+				Document(document).
 				Id(strconv.Itoa(document.Id)).
 				Refresh(refresh.Waitfor).
 				Do(context.Background())
@@ -391,6 +389,9 @@ func TestTypedClient(t *testing.T) {
 			if indexed.Result != result.Created {
 				t.Fatalf("unexpected result during indexation of document: %v, response: %v", document, indexed)
 			}
+
+			document.Alt = fmt.Sprintf("alt_%d", document.Id)
+			es.Update(indexName, strconv.Itoa(document.Id)).Doc(document).Do(context.Background())
 		}
 
 		// Check for document existence in index
@@ -412,13 +413,12 @@ func TestTypedClient(t *testing.T) {
 		// Simple search matching name
 		res, err := es.Search().
 			Index(indexName).
-			Request(&search.Request{
-				Query: &types.Query{
-					Match: map[string]types.MatchQuery{
-						"name": {Query: "Foo"},
-					},
+			Query(&types.Query{
+				Match: map[string]types.MatchQuery{
+					"name": {Query: "Foo"},
 				},
-			}).Do(context.Background())
+			}).
+			Do(context.Background())
 
 		if err != nil {
 			t.Fatalf("error runnning search query: %s", err)
@@ -440,17 +440,15 @@ func TestTypedClient(t *testing.T) {
 		// Aggregate prices with a SumAggregation
 		searchResponse, err := es.Search().
 			Index(indexName).
-			Request(
-				&search.Request{
-					Size: some.Int(0),
-					Aggregations: map[string]types.Aggregations{
-						"total_prices": {
-							Sum: &types.SumAggregation{
-								Field: some.String("price"),
-							},
-						},
+			Size(0).
+			Aggregations(map[string]types.Aggregations{
+				"total_prices": {
+					Sum: &types.SumAggregation{
+						Field: some.String("price"),
 					},
-				}).Do(context.Background())
+				},
+			}).
+			Do(context.Background())
 
 		if err != nil {
 			t.Fatal(err)