guides: add pushSetup for ingestion API

config/generation.config.mjs

@@ -24,6 +24,8 @@ export const patterns = [
   '!clients/algoliasearch-client-csharp/algoliasearch/Transport/**',
   '!clients/algoliasearch-client-csharp/algoliasearch/Models/Common/**',
 
+  '!docs/guides/csharp/src/program.cs',
+
   'tests/output/csharp/global.json',
 
   // Dart
@@ -49,6 +51,8 @@ export const patterns = [
   '!clients/algoliasearch-client-go/algolia/debug/*',
   '!clients/algoliasearch-client-go/algolia/utils/*',
 
+  '!docs/guides/go/src/main.go',
+
   '!tests/output/go/go.*',
 
   // Java

docs/guides/csharp/src/program.cs

@@ -0,0 +1,4 @@
+public class Program
+{
+  public static void Main() { }
+}

docs/guides/go/src/main.go

@@ -0,0 +1,7 @@
+package main
+
+import "fmt"
+
+func main() {
+	fmt.Println("wow nice")
+}

generators/src/main/java/com/algolia/codegen/cts/AlgoliaCTSGenerator.java

@@ -9,6 +9,7 @@
 import com.algolia.codegen.utils.*;
 import com.google.common.collect.ImmutableMap.Builder;
 import com.samskivert.mustache.Mustache.Lambda;
+import java.io.File;
 import java.util.*;
 import java.util.Map.Entry;
 import java.util.TreeMap;
@@ -159,7 +160,9 @@ public Map<String, Object> postProcessSupportingFileData(Map<String, Object> obj
       bundle.put("isSyncClient", false);
       // special lambda for dynamic templates
       bundle.put("dynamicTemplate", new DynamicTemplateLambda(this));
-      bundle.put("dynamicSnippet", new DynamicSnippetLambda(this, models, operations, language, client));
+      if (new File("tests/CTS/guides/" + client + ".json").exists()) {
+        bundle.put("dynamicSnippet", new DynamicSnippetLambda(this, models, operations, language, client));
+      }
       bundle.put("lambda", lambda);
 
       String languageVersion = ctsManager.getLanguageVersion((String) additionalProperties.getOrDefault("languageVersion", ""));

generators/src/main/java/com/algolia/codegen/cts/lambda/DynamicSnippetLambda.java

@@ -43,7 +43,7 @@ public DynamicSnippetLambda(
     this.operations = operations;
     this.paramsType = new ParametersWithDataType(models, language, client, true);
 
-    JsonNode snippetsFile = Helpers.readJsonFile("tests/CTS/guides/search.json");
+    JsonNode snippetsFile = Helpers.readJsonFile("tests/CTS/guides/" + client + ".json");
     this.snippets = Json.mapper().convertValue(snippetsFile, new TypeReference<Map<String, Snippet>>() {});
 
     // we can't access the default template manager, so we have to create our own

playground/csharp/Performances/Performances.csproj

@@ -2,7 +2,7 @@
 
     <PropertyGroup>
         <OutputType>Exe</OutputType>
-        <TargetFramework>net8.0</TargetFramework>
+        <TargetFramework>net9.0</TargetFramework>
         <ImplicitUsings>enable</ImplicitUsings>
         <Nullable>enable</Nullable>
         <RootNamespace>Performances</RootNamespace>

playground/csharp/Playground/Playground.csproj

@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net8.0</TargetFramework>
+    <TargetFramework>net9.0</TargetFramework>
     <LangVersion>12</LangVersion>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>

playground/go/ingestion.go

@@ -2,7 +2,6 @@ package main
 
 import (
 	"fmt"
-	"time"
 
 	"github.com/algolia/algoliasearch-client-go/v4/algolia/ingestion"
 )
@@ -14,34 +13,14 @@ func testIngestion(appID, apiKey string) int {
 	}
 
 	// another example to generate payload for a request.
-	createAuthenticationResponse, err := ingestionClient.CreateAuthentication(ingestionClient.NewApiCreateAuthenticationRequest(
-		&ingestion.AuthenticationCreate{
-			Type: ingestion.AUTHENTICATION_TYPE_BASIC,
-			Name: fmt.Sprintf("my-authentication-%d", time.Now().Unix()),
-			Input: ingestion.AuthInput{
-				AuthBasic: &ingestion.AuthBasic{
-					Username: "username",
-					Password: "password",
-				},
-			},
-		}))
-
+	_, payload, err := ingestionClient.ListTasksWithHTTPInfo(ingestionClient.NewApiListTasksRequest())
 	if err != nil {
-		fmt.Printf("request error with CreateAuthentication: %v\n", err)
-		return 1
-	}
+		fmt.Printf("request error: %v\n", err)
 
-	printResponse(createAuthenticationResponse)
-
-	listAuthenticationsResponse, err := ingestionClient.ListAuthentications(
-		ingestionClient.NewApiListAuthenticationsRequest().WithItemsPerPage(2),
-	)
-	if err != nil {
-		fmt.Printf("request error with GetAuthentications: %v\n", err)
 		return 1
 	}
 
-	printResponse(listAuthenticationsResponse)
+	fmt.Println(string(payload))
 
 	return 0
 }

playground/kotlin/build.gradle.kts

@@ -1,6 +1,7 @@
 plugins {
     kotlin("jvm") version "2.0.21"
     kotlin("plugin.serialization") version "2.0.21"
+    id("application")
 }
 
 repositories {
@@ -16,4 +17,8 @@ dependencies {
 
 tasks.test {
     useJUnitPlatform()
-}
+}
+
+application {
+  mainClass.set("com.algolia.playground.${property("client")}Kt")
+}

scripts/buildLanguages.ts

@@ -70,8 +70,9 @@ async function buildLanguage(language: Language, gens: Generator[], buildType: B
       break;
     case 'java':
     case 'kotlin':
+      // the playground specify search but it will still build everything
       await run(
-        `./gradle/gradlew -p ${cwd} ${buildType === 'client' || buildType === 'playground' ? 'assemble' : 'build'}`,
+        `./gradle/gradlew -p ${cwd} ${buildType === 'client' || buildType === 'playground' ? 'assemble -Pclient=Search' : 'build'}`,
         { language },
       );
       break;

scripts/formatter.ts

@@ -5,7 +5,7 @@ export async function formatter(language: string, cwd: string): Promise<void> {
   const spinner = createSpinner(`running formatter for '${language}' in '${cwd}'`);
   switch (language) {
     case 'csharp':
-      if (cwd.includes('tests') || cwd.includes('snippets')) {
+      if (cwd.includes('tests') || cwd.includes('snippets') || cwd.includes('guides')) {
         await run('dotnet format --no-restore && dotnet tool restore && dotnet dotnet-csharpier .', {
           cwd,
           language,

scripts/playground.ts

@@ -25,13 +25,9 @@ export async function playground({ language, client }: { language: AllLanguage;
       );
       break;
     case 'kotlin':
-      await run(
-        `./gradle/gradlew -p playground/kotlin -PmainClass=com.algolia.playground.${createClientName(
-          client,
-          'kotlin',
-        )}Kt run`,
-        { language },
-      );
+      await run(`./gradle/gradlew -p playground/kotlin run -Pclient=${createClientName(client, 'kotlin')}`, {
+        language,
+      });
       break;
     case 'php':
       await runComposerInstall();

templates/csharp/guides/ingestion/pushSetup.mustache

@@ -0,0 +1,30 @@
+using System;
+using System.Text.Json;
+using System.Collections.Generic;
+
+{{> snippets/import}}
+
+using Action = Algolia.Search.Models.Ingestion.Action;
+
+class PushSetup
+{
+    public static async Task Main(string[] args)
+    {
+        string jsonContent = File.ReadAllText("/my-raw-records.json");
+
+        var records = JsonSerializer.Deserialize<List<Algolia.Search.Models.Ingestion.PushTaskRecords>>(jsonContent);
+
+        // use the region matching your applicationID
+        {{> snippets/init}}
+
+        try
+        {
+            var run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}};
+            Console.WriteLine(run.RunID);
+        }
+        catch (Exception e)
+        {
+            Console.WriteLine(e.Message);
+        }
+    }
+}

templates/csharp/guides/search/saveObjectsMovies.mustache

@@ -5,7 +5,7 @@ using System.Collections.Generic;
 
 {{> snippets/import}}
 
-class Program
+class SaveObjectsMovies
 {
     public static async Task Main(string[] args)
     {

templates/csharp/snippets/dotnet-tools.mustache

@@ -3,10 +3,10 @@
   "isRoot": true,
   "tools": {
     "csharpier": {
-      "version": "0.29.2",
+      "version": "0.30.1",
       "commands": [
         "dotnet-csharpier"
       ]
     }
   }
-}
+}

templates/csharp/snippets/src.csproj.mustache

@@ -2,7 +2,7 @@
 
     <PropertyGroup>
         <OutputType>Exe</OutputType>
-        <TargetFramework>net8.0</TargetFramework>
+        <TargetFramework>net9.0</TargetFramework>
         <ImplicitUsings>enable</ImplicitUsings>
         <Nullable>enable</Nullable>
         <RootNamespace>Algolia</RootNamespace>

templates/go/guides/ingestion/pushSetup.mustache

@@ -0,0 +1,36 @@
+package main
+
+import (
+  "os"
+  "encoding/json"
+  "fmt"
+  "net/http"
+)
+
+
+{{> snippets/import}}
+
+func push() {
+  // use the region matching your applicationID
+  {{> snippets/init}}
+
+  content, err := os.ReadFile("/my-raw-records.json")
+  if err != nil {
+    panic(err)
+  }
+
+  var records []ingestion.PushTaskRecords
+
+  err = json.Unmarshal(content, &records)
+  if err != nil {
+    panic(err)
+  }
+
+  run, err := {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
+  if err != nil {
+    panic(err)
+  }
+
+  // use runID in the Observability debugger
+  fmt.Println("run", run.RunID)
+}

templates/go/guides/search/saveObjectsMovies.mustache

@@ -8,7 +8,7 @@ import (
 
 {{> snippets/import}}
 
-func main() {
+func saveObjectsMovies() {
   // read json file
   url := "https://dashboard.algolia.com/sample_datasets/movie.json"
   response, err := http.Get(url)

templates/go/snippets/.golangci.mustache

@@ -2,10 +2,11 @@ linters:
   disable:
     - ineffassign
     - staticcheck
+    - unused
 
 issues:
   exclude-generated: disable
 
 run:
   concurrency: 2
-  timeout: 10m
+  timeout: 10m

templates/java/guides/ingestion/pushSetup.mustache

@@ -0,0 +1,23 @@
+import com.fasterxml.jackson.databind.*;
+import java.io.File;
+import java.util.List;
+import java.util.Map;
+
+{{> snippets/import}}
+
+public class pushSetup {
+  public static void main(String[] args) throws Exception {
+    JsonNode content = new ObjectMapper().readTree(new File("/my-raw-records.json"));
+    List<PushTaskRecords> records = new ObjectMapper().readerForListOf(Map.class).readValue(content);
+
+    // use the region matching your applicationID
+    {{> snippets/init}}
+
+    RunResponse run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}};
+
+    // use runID in the Observability debugger
+    System.out.println(run);
+
+    client.close();
+  }
+}

templates/javascript/guides/ingestion/pushSetup.mustache

@@ -0,0 +1,20 @@
+import fs from 'node:fs';
+import type { PushTaskRecords } from 'algoliasearch';
+
+{{> snippets/import}}
+
+// use the region matching your applicationID
+{{> snippets/init}}
+
+try {
+  // read local JSON file containing array of records
+  const records = JSON.parse(fs.readFileSync('/my-raw-records.json', 'utf8')) as PushTaskRecords[];
+
+  // push records to the API
+  const run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
+
+  // use runID in the Observability debugger
+  console.log(run.runID);
+} catch (err) {
+  console.error(err);
+}

templates/javascript/snippets/package.mustache

@@ -1,6 +1,7 @@
 {
   "name": "javascript-{{mode}}",
   "version": "1.0.0",
+  "type": "module",
   "dependencies": {
     "typescript": "5.6.3",
     "@algolia/client-common": "link:../../../clients/algoliasearch-client-javascript/packages/client-common",

templates/kotlin/guides/ingestion/pushSetup.mustache

@@ -0,0 +1,28 @@
+package org.example
+{{> snippets/import}}
+{{#isSearchClient}}
+import com.algolia.client.extensions.*
+{{/isSearchClient}}
+import com.algolia.client.model.ingestion.*
+
+import kotlinx.serialization.builtins.ListSerializer
+import kotlinx.serialization.json.Json
+import kotlinx.serialization.json.JsonObject
+import java.io.File
+
+suspend fun main() {
+    val json = File("/my-raw-records.json").readText()
+    val records: List<PushTaskRecords> = Json.decodeFromString(ListSerializer(PushTaskRecords.serializer()), json)
+
+    // use the region matching your applicationID
+    {{> snippets/init}}
+
+    try {
+        val run = client.{{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
+
+        // use runID in the Observability debugger
+        println(run)
+    } catch(e: Exception) {
+        println(e.message)
+    }
+}