Start shifting traffic from VTEX I/O to EKS

CHANGELOG.md

@@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## [Unreleased]
 
+### Changed
+- Switch autocomplete endpoints to use intsch as primary with intelligentSearchApi as fallback.
+- Start testing 10% of the fetchCorrection traffic to intsch and compare the result against the VTEX /IO version.
+
 ## [1.80.0] - 2025-09-25
 
 ### Changed

node/clients/intelligent-search-api.ts

@@ -80,7 +80,7 @@ export class IntelligentSearchApi
     })
   }
 
-  public async correction(params: CorrectionParams) {
+  public async fetchCorrection(params: CorrectionParams) {
     return this.http.get('/correction_search', {
       params: { ...params, locale: this.locale },
       metric: 'correction',

node/clients/intsch/index.ts

@@ -3,6 +3,8 @@ import { InstanceOptions, IOContext, JanusClient } from '@vtex/api'
 import {
   AutocompleteSuggestionsArgs,
   AutocompleteSuggestionsResponse,
+  CorrectionArgs,
+  CorrectionResponse,
   IIntelligentSearchClient,
   SearchSuggestionsArgs,
   SearchSuggestionsResponse,
@@ -49,4 +51,11 @@ export class Intsch extends JanusClient implements IIntelligentSearchClient {
       metric: 'searchSuggestions-new',
     })
   }
+
+  public fetchCorrection(args: CorrectionArgs): Promise<CorrectionResponse> {
+    return this.http.get('/api/intelligent-search/v0/correction-search', {
+      params: { query: args.query, locale: this.locale },
+      metric: 'correction-new',
+    })
+  }
 }

node/clients/intsch/types.ts

@@ -35,11 +35,25 @@ export type SearchSuggestionsResponse = {
   }[]
 }
 
+export type CorrectionArgs = {
+  query: string
+}
+
+export type CorrectionResponse = {
+  correction: {
+    text: string
+    highlighted: string
+    misspelled: boolean
+    correction: boolean
+  }
+}
+
 // eslint-disable-next-line @typescript-eslint/interface-name-prefix
 export interface IIntelligentSearchClient {
   fetchAutocompleteSuggestions(
     args: AutocompleteSuggestionsArgs
   ): Promise<AutocompleteSuggestionsResponse>
   fetchTopSearches(): Promise<TopSearchesResponse>
   fetchSearchSuggestions(args: SearchSuggestionsArgs): Promise<SearchSuggestionsResponse>
+  fetchCorrection(args: CorrectionArgs): Promise<CorrectionResponse>
 }

node/mocks/contextFactory.ts

@@ -1,6 +1,5 @@
 import parse from 'co-body'
 
-import { MockedIntelligentSearchApiClient } from './intelligent-search-api'
 import type { IntelligentSearchClientArgs } from './intsch'
 import { MockedIntschClient } from './intsch'
 
@@ -44,7 +43,7 @@ export function createContext<Ctx = Context>({
     },
     clients: {
       intsch: new MockedIntschClient(intschSettings),
-      intelligentSearchApi: new MockedIntelligentSearchApiClient(
+      intelligentSearchApi: new MockedIntschClient(
         intelligentSearchApiSettings
       ),
       apps: {

node/mocks/intsch.ts

@@ -3,6 +3,7 @@ import type {
   AutocompleteSuggestionsResponse,
   TopSearchesResponse,
   SearchSuggestionsResponse,
+  CorrectionResponse,
 } from '../clients/intsch/types'
 
 export class MockedIntschClient implements IIntelligentSearchClient {
@@ -30,15 +31,23 @@ export class MockedIntschClient implements IIntelligentSearchClient {
         args?.fetchSearchSuggestions ?? null
       )
     }
+
+    if (args?.fetchCorrection instanceof Error) {
+      this.fetchCorrection.mockRejectedValue(args.fetchCorrection)
+    } else {
+      this.fetchCorrection.mockResolvedValue(args?.fetchCorrection ?? null)
+    }
   }
 
   public fetchAutocompleteSuggestions = jest.fn()
   public fetchTopSearches = jest.fn()
   public fetchSearchSuggestions = jest.fn()
+  public fetchCorrection = jest.fn()
 }
 
 export type IntelligentSearchClientArgs = {
   fetchAutocompleteSuggestions?: AutocompleteSuggestionsResponse | Error
   fetchTopSearches?: TopSearchesResponse | Error
   fetchSearchSuggestions?: SearchSuggestionsResponse | Error
+  fetchCorrection?: CorrectionResponse | Error
 }

node/resolvers/search/index.ts

@@ -36,7 +36,8 @@ import {
 import { 
   fetchAutocompleteSuggestions,
   fetchTopSearches,
-  fetchSearchSuggestions 
+  fetchSearchSuggestions,
+  fetchCorrection,
 } from '../../services/autocomplete'
 interface ProductIndentifier {
   field: 'id' | 'slug' | 'ean' | 'reference' | 'sku'
@@ -800,12 +801,7 @@ export const queries = {
     )
   },
   correction: (_: any, args: { fullText: string }, ctx: Context) => {
-    const { intelligentSearchApi } = ctx.clients
-
-    return intelligentSearchApi.correction({
-      query: args.fullText,
-      ...args,
-    })
+    return fetchCorrection(ctx, args.fullText)
   },
   searchSuggestions: (_: any, args: { fullText: string }, ctx: Context) => {
     return fetchSearchSuggestions(ctx, args.fullText)