Merge branch 'main' into feat/ingestion-push-endpoint

Author: shortcuts

clients/algoliasearch-client-go/algolia/search/api_search.go

@@ -33,8 +33,8 @@ func testIngestion(appID, apiKey string) int {
 
 	printResponse(createAuthenticationResponse)
 
-	listAuthenticationsResponse, err := ingestionClient.GetAuthentications(
-		ingestionClient.NewApiGetAuthenticationsRequest().WithItemsPerPage(2),
+	listAuthenticationsResponse, err := ingestionClient.ListAuthentications(
+		ingestionClient.NewApiListAuthenticationsRequest().WithItemsPerPage(2),
 	)
 	if err != nil {
 		fmt.Printf("request error with GetAuthentications: %v\n", err)

playground/go/ingestion.go

@@ -1,7 +1,7 @@
 package main
 
 import (
-	"context"
+	"fmt"
 
 	"github.com/algolia/algoliasearch-client-go/v4/algolia/search"
 )
@@ -13,9 +13,15 @@ func testSearch(appID, apiKey string) int {
 		panic(err)
 	}
 
-	res, err := searchClient.WaitForApiKey("test", search.API_KEY_OPERATION_ADD, search.WithContext(context.Background()), search.WithMaxRetries(4))
-	print(res)
-	print(err.Error())
+	err = searchClient.BrowseObjects("test-flag", *search.NewEmptyBrowseParamsObject(), search.WithAggregator(func(res any, err error) {
+		if err != nil {
+			panic(err)
+		}
+		fmt.Println(len(res.(*search.BrowseResponse).Hits))
+	}))
+	if err != nil {
+		panic(err)
+	}
 
 	/*
 		response, err := searchClient.AddOrUpdateObject(

playground/go/search.go

@@ -33,6 +33,11 @@ function addRoutes(app: Express): void {
     if (!chunkWrapperState[lang]) {
       chunkWrapperState[lang] = {};
     }
+
+    if (req.headers['x-algolia-api-key'] === 'wrong-api-key') {
+      res.status(403).json({ message: 'Invalid Application-ID or API key', status: 403 });
+      return;
+    }
     chunkWrapperState[lang][helper] = (chunkWrapperState[lang][helper] ?? 0) + 1;
     switch (helper) {
       case 'saveObjects':

scripts/cts/testServer/chunkWrapper.ts

@@ -43,7 +43,6 @@ type config struct {
 	maxRetries    int
 	timeout       func(int) time.Duration
 	aggregator    func(any, error)
-	iterableError *IterableError
 
   // -- WaitForApiKey options
   apiKey *ApiKey
@@ -187,12 +186,6 @@ func WithAggregator(aggregator func(any, error)) iterableOption {
 	})
 }
 
-func WithIterableError(iterableError *IterableError) iterableOption {
-	return iterableOption(func(c *config) {
-		c.iterableError = iterableError
-	})
-}
-
 // --------- WaitForKey options ---------.
 
 type WaitForApiKeyOption interface {