feat(go): guides

Author: Fluf22

templates/go/guides/search/deleteMultipleIndices.mustache

@@ -0,0 +1,70 @@
+package main
+
+import (
+  "encoding/json"
+  "fmt"
+  "net/http"
+)
+
+{{> snippets/import}}
+
+func deleteMultipleIndices() {
+  // You need an API key with `deleteIndex`
+  {{> snippets/init}}
+
+  // List all indices
+  indices, err := {{#dynamicSnippet}}listIndicesSimple{{/dynamicSnippet}}
+  if err != nil {
+    panic(err)
+  }
+
+  // Primary indices don't have a `primary` key
+  primaryIndices := make([]search.FetchedIndex, len(indices.Items))
+	replicaIndices := make([]search.FetchedIndex, len(indices.Items))
+
+	for _, index := range indices.Items {
+		if index.Primary == nil {
+			primaryIndices = append(primaryIndices, index)
+		} else {
+			replicaIndices = append(replicaIndices, index)
+		}
+	}
+
+  // Delete primary indices first
+  if len(primaryIndices) > 0 {
+		requests := make([]search.MultipleBatchRequest, len(primaryIndices))
+
+		for _, index := range primaryIndices {
+			requests = append(requests, search.MultipleBatchRequest{
+				Action:    "delete",
+				IndexName: index.Name,
+			})
+    }
+
+    _, err = {{#dynamicSnippet}}deleteMultipleIndicesPrimary{{/dynamicSnippet}}
+    if err != nil {
+      panic(err)
+    }
+
+    fmt.Println("Deleted primary indices.")
+  }
+
+  // Now, delete replica indices
+  if len(replicaIndices) > 0 {
+		requests := make([]search.MultipleBatchRequest, len(primaryIndices))
+
+		for _, index := range primaryIndices {
+			requests = append(requests, search.MultipleBatchRequest{
+				Action:    "delete",
+				IndexName: index.Name,
+			})
+		}
+
+    _, err = {{#dynamicSnippet}}deleteMultipleIndicesReplica{{/dynamicSnippet}}
+    if err != nil {
+      panic(err)
+    }
+
+    fmt.Println("Deleted replica indices.")
+  }
+}

templates/go/guides/search/saveObjectsChunks.mustache

@@ -0,0 +1,37 @@
+package main
+
+import (
+  "os"
+  "encoding/json"
+  "fmt"
+  "net/http"
+)
+
+{{> snippets/import}}
+
+func saveObjectsChunks() {
+  {{> snippets/init}}
+
+  content, err := os.ReadFile("actors.json")
+  if err != nil {
+    panic(err)
+  }
+
+  var records []map[string]any
+
+  err = json.Unmarshal(content, &records)
+  if err != nil {
+    panic(err)
+  }
+
+  chunkSize := 10000
+
+	for beginIndex := 0; beginIndex < len(records); beginIndex += chunkSize {
+		chunk := records[beginIndex:min(beginIndex+chunkSize, len(records))]
+
+    _, err = {{#dynamicSnippet}}saveObjectsChunks{{/dynamicSnippet}}
+    if err != nil {
+      panic(err)
+    }
+  }
+}

templates/go/guides/search/saveObjectsMCM.mustache

@@ -0,0 +1,39 @@
+package main
+
+import (
+  "encoding/json"
+  "fmt"
+  "net/http"
+)
+
+{{> snippets/import}}
+
+func getAllAppIDConfigurations() ([]struct{ appID, apiKey string }, error) {
+	return []struct{ appID, apiKey string }{ /* A list of your MCM AppID/ApiKey pairs */ }, nil
+}
+
+func saveObjectsMCM() {
+  playlists := []map[string]any{ { /* Your records */ } }
+
+  // Fetch from your own data storage and with your own code
+  // the list of application IDs and API keys to target each cluster
+  configurations, err := getAllAppIDConfigurations()
+  if err != nil {
+    fmt.Println(err)
+    return
+  }
+
+  // Send the records to each cluster
+  for _, configuration := range configurations {
+    client, err := search.NewClient(configuration.appID, configuration.apiKey)
+    if err != nil {
+      fmt.Println(err)
+      return
+    }
+
+    _, err = {{#dynamicSnippet}}saveObjectsPlaylists{{/dynamicSnippet}}
+    if err != nil {
+      panic(err)
+    }
+  }
+}

templates/go/guides/search/saveObjectsModified.mustache

@@ -0,0 +1,47 @@
+package main
+
+import (
+  "os"
+  "encoding/json"
+  "fmt"
+  "net/http"
+)
+
+{{> snippets/import}}
+
+func saveObjectsModified() {
+  {{> snippets/init}}
+
+  content, err := os.ReadFile("products.json")
+  if err != nil {
+    panic(err)
+  }
+
+  var products []map[string]any
+
+  err = json.Unmarshal(content, &products)
+  if err != nil {
+    panic(err)
+  }
+
+  records := make([]map[string]any, len(products))
+
+  for _, product := range products {
+    reference := product["product_reference"].(string)
+    suffixes := make([]string, len(reference)-1)
+
+    for i := len(reference); i > 1; i-- {
+      suffixes = append(suffixes, reference[i:])
+    }
+
+    record := product
+    record["product_reference_suffixes"] = suffixes
+
+    records = append(records, record)
+  }
+
+  _, err = {{#dynamicSnippet}}saveObjectsRecords{{/dynamicSnippet}}
+  if err != nil {
+    panic(err)
+  }
+}

templates/go/guides/search/saveObjectsMovies.mustache

@@ -35,9 +35,8 @@ func saveObjectsMovies() {
 	// push data to algolia
 	result, err := {{#dynamicSnippet}}saveObjectsMovies{{/dynamicSnippet}}
 	if err != nil {
-		fmt.Println(err)
-		return
+		panic(err)
 	}
 
-fmt.Printf("Done! Uploaded records in %d batches.", len(result))
+  fmt.Printf("Done! Uploaded records in %d batches.", len(result))
 }

templates/go/guides/search/saveObjectsPublicUser.mustache

@@ -0,0 +1,20 @@
+package main
+
+import (
+  "encoding/json"
+  "fmt"
+  "net/http"
+)
+
+{{> snippets/import}}
+
+func saveObjectsPublicUser() {
+    playlists := []map[string]any{ { /* Your records */ } }
+
+    {{> snippets/init}}
+
+    _, err = {{#dynamicSnippet}}saveObjectsPlaylistsWithUserIDPublic{{/dynamicSnippet}}
+    if err != nil {
+      panic(err)
+    }
+}

templates/go/guides/search/savePopularRecords.mustache

@@ -0,0 +1,41 @@
+package main
+
+import (
+  "encoding/json"
+  "fmt"
+  "net/http"
+)
+
+{{> snippets/import}}
+
+func savePopularRecords() {
+  {{> snippets/init}}
+
+  records := []map[string]any{ { /* Your records */ } }
+
+  err = client.BrowseObjects("<YOUR_INDEX_NAME>", search.BrowseParamsObject{}, search.WithAggregator(func(res any, err error) {
+		if err != nil {
+			panic(err)
+		}
+
+		browseRes, ok := res.(search.BrowseResponse)
+    if !ok {
+      panic("Invalid response")
+    }
+
+		for _, hit := range browseRes.Hits {
+			record := hit.AdditionalProperties
+      record["isPopular"] = record["nbFollowers"].(int) >= 1_000_000
+
+			records = append(records, record)
+		}
+	}))
+  if err != nil {
+    panic(err)
+  }
+
+  _, err = {{#dynamicSnippet}}saveObjectsRecords{{/dynamicSnippet}}
+  if err != nil {
+    panic(err)
+  }
+}

templates/go/guides/search/searchRecentlyPublishedBooks.mustache

@@ -0,0 +1,26 @@
+package main
+
+import (
+  "encoding/json"
+  "fmt"
+  "net/http"
+  "time"
+)
+
+{{> snippets/import}}
+
+func searchRecentlyPublishedBooks() {
+  {{> snippets/init}}
+
+  dateTimestamp := time.Now().UnixMilli()
+  searchParams := search.SearchParamsObjectAsSearchParams(
+    search.NewSearchParamsObject().
+      SetQuery("<YOUR_SEARCH_QUERY>").
+      SetFilters(fmt.Sprintf("date_timestamp > %d", dateTimestamp)),
+  )
+
+  _, err = {{#dynamicSnippet}}searchWithSearchParams{{/dynamicSnippet}}
+  if err != nil {
+    panic(err)
+  }
+}

templates/go/guides/search/searchWithGAToken.mustache

@@ -0,0 +1,44 @@
+package main
+
+import (
+  "encoding/json"
+  "fmt"
+  "net/http"
+)
+
+{{> snippets/import}}
+
+func getGoogleAnalyticsUserIdFromBrowserCookie(_ string) (string, error) {
+  return "", nil // Implement your logic here
+}
+
+func searchWithGAToken() {
+  {{> snippets/init}}
+
+  userToken, err := getGoogleAnalyticsUserIdFromBrowserCookie("_ga")
+	if err != nil {
+		panic(err)
+	}
+
+	searchParams := search.SearchParamsObjectAsSearchParams(
+		search.NewSearchParamsObject().
+			SetQuery("<YOUR_SEARCH_QUERY>").
+			SetUserToken(userToken),
+	)
+
+  _, err = {{#dynamicSnippet}}searchWithSearchParams{{/dynamicSnippet}}
+  if err != nil {
+    panic(err)
+  }
+
+  var loggedInUser *string
+
+	if loggedInUser != nil {
+		searchParams = search.SearchParamsObjectAsSearchParams(searchParams.SearchParamsObject.SetUserToken(*loggedInUser))
+	}
+
+  _, err = {{#dynamicSnippet}}searchWithSearchParams{{/dynamicSnippet}}
+  if err != nil {
+    panic(err)
+  }
+}

templates/go/guides/search/searchWithOptionalFilters.mustache

@@ -0,0 +1,35 @@
+package main
+
+import (
+  "encoding/json"
+  "fmt"
+  "net/http"
+)
+
+{{> snippets/import}}
+
+func reduceLabelsToFilters(_ []string) (search.OptionalFilters, error) {
+	return search.OptionalFilters{}, nil // Implement your logic here
+}
+
+func searchWithOptionalFilters() {
+  labels := []string{ /* A list of labels */ }
+
+  {{> snippets/init}}
+
+  optionalFilters, err := reduceLabelsToFilters(labels)
+  if err != nil {
+    panic(err)
+  }
+
+  searchParams := search.SearchParamsObjectAsSearchParams(
+    search.NewSearchParamsObject().
+      SetQuery("<YOUR_SEARCH_QUERY>").
+      SetOptionalFilters(&optionalFilters),
+  )
+
+  _, err = {{#dynamicSnippet}}searchWithSearchParams{{/dynamicSnippet}}
+  if err != nil {
+    panic(err)
+  }
+}