feat(recommend): Add trending types and methods

Author: SophieManley03

packages/recommend/src/__tests__/getTrendingFacets.test.ts

@@ -0,0 +1,46 @@
+import { TestSuite } from '../../../client-common/src/__tests__/TestSuite';
+
+const recommend = new TestSuite('recommend').recommend;
+
+function createMockedClient() {
+  const client = recommend('appId', 'apiKey');
+  jest.spyOn(client.transporter, 'read').mockImplementation(() => Promise.resolve());
+
+  return client;
+}
+
+describe('getTrendingFacets', () => {
+  test('builds the request', async () => {
+    const client = createMockedClient();
+
+    await client.getTrendingFacets(
+      [
+        {
+          indexName: 'products',
+          facetName: 'company',
+        },
+      ],
+      {}
+    );
+
+    expect(client.transporter.read).toHaveBeenCalledTimes(1);
+    expect(client.transporter.read).toHaveBeenCalledWith(
+      {
+        cacheable: true,
+        data: {
+          requests: [
+            {
+              indexName: 'products',
+              model: 'trending-facets',
+              facetName: 'company',
+              threshold: 0,
+            },
+          ],
+        },
+        method: 'POST',
+        path: '1/indexes/*/recommendations',
+      },
+      {}
+    );
+  });
+});

packages/recommend/src/__tests__/getTrendingGlobalItems.test.ts

@@ -0,0 +1,44 @@
+import { TestSuite } from '../../../client-common/src/__tests__/TestSuite';
+
+const recommend = new TestSuite('recommend').recommend;
+
+function createMockedClient() {
+  const client = recommend('appId', 'apiKey');
+  jest.spyOn(client.transporter, 'read').mockImplementation(() => Promise.resolve());
+
+  return client;
+}
+
+describe('getTrendingGlobalItems', () => {
+  test('builds the request', async () => {
+    const client = createMockedClient();
+
+    await client.getTrendingGlobalItems(
+      [
+        {
+          indexName: 'products',
+        },
+      ],
+      {}
+    );
+
+    expect(client.transporter.read).toHaveBeenCalledTimes(1);
+    expect(client.transporter.read).toHaveBeenCalledWith(
+      {
+        cacheable: true,
+        data: {
+          requests: [
+            {
+              indexName: 'products',
+              model: 'trending-items',
+              threshold: 0,
+            },
+          ],
+        },
+        method: 'POST',
+        path: '1/indexes/*/recommendations',
+      },
+      {}
+    );
+  });
+});

packages/recommend/src/__tests__/getTrendingItemsForFacet.test.ts

@@ -0,0 +1,48 @@
+import { TestSuite } from '../../../client-common/src/__tests__/TestSuite';
+
+const recommend = new TestSuite('recommend').recommend;
+
+function createMockedClient() {
+  const client = recommend('appId', 'apiKey');
+  jest.spyOn(client.transporter, 'read').mockImplementation(() => Promise.resolve());
+
+  return client;
+}
+
+describe('getTrendingItemsForFacet', () => {
+  test('builds the request', async () => {
+    const client = createMockedClient();
+
+    await client.getTrendingItemsForFacet(
+      [
+        {
+          indexName: 'products',
+          facetName: 'company',
+          facetValue: 'tesla',
+        },
+      ],
+      {}
+    );
+
+    expect(client.transporter.read).toHaveBeenCalledTimes(1);
+    expect(client.transporter.read).toHaveBeenCalledWith(
+      {
+        cacheable: true,
+        data: {
+          requests: [
+            {
+              indexName: 'products',
+              model: 'trending-items',
+              facetName: 'company',
+              facetValue: 'tesla',
+              threshold: 0,
+            },
+          ],
+        },
+        method: 'POST',
+        path: '1/indexes/*/recommendations',
+      },
+      {}
+    );
+  });
+});

packages/recommend/src/builds/browser.ts

@@ -8,7 +8,14 @@ import { createBrowserXhrRequester } from '@algolia/requester-browser-xhr';
 import { createUserAgent } from '@algolia/transporter';
 
 import { createRecommendClient } from '../createRecommendClient';
-import { getFrequentlyBoughtTogether, getRecommendations, getRelatedProducts } from '../methods';
+import {
+  getFrequentlyBoughtTogether,
+  getRecommendations,
+  getRelatedProducts,
+  getTrendingFacets,
+  getTrendingGlobalItems,
+  getTrendingItemsForFacet,
+} from '../methods';
 import { BaseRecommendClient, RecommendOptions, WithRecommendMethods } from '../types';
 
 export default function recommend(
@@ -47,6 +54,9 @@ export default function recommend(
       getFrequentlyBoughtTogether,
       getRecommendations,
       getRelatedProducts,
+      getTrendingFacets,
+      getTrendingGlobalItems,
+      getTrendingItemsForFacet,
     },
   });
 }

packages/recommend/src/builds/node.ts

@@ -7,7 +7,14 @@ import { createNodeHttpRequester } from '@algolia/requester-node-http';
 import { createUserAgent } from '@algolia/transporter';
 
 import { createRecommendClient } from '../createRecommendClient';
-import { getFrequentlyBoughtTogether, getRecommendations, getRelatedProducts } from '../methods';
+import {
+  getFrequentlyBoughtTogether,
+  getRecommendations,
+  getRelatedProducts,
+  getTrendingFacets,
+  getTrendingGlobalItems,
+  getTrendingItemsForFacet,
+} from '../methods';
 import { BaseRecommendClient, RecommendOptions, WithRecommendMethods } from '../types';
 
 export default function recommend(
@@ -41,6 +48,9 @@ export default function recommend(
       getFrequentlyBoughtTogether,
       getRecommendations,
       getRelatedProducts,
+      getTrendingFacets,
+      getTrendingGlobalItems,
+      getTrendingItemsForFacet,
     },
   });
 }

packages/recommend/src/methods/getTrendingFacets.ts

@@ -0,0 +1,18 @@
+import { BaseRecommendClient, TrendingFacetsQuery, WithRecommendMethods } from '../types';
+import { getRecommendations } from './getRecommendations';
+
+type GetTrendingFacets = (
+  base: BaseRecommendClient
+) => WithRecommendMethods<BaseRecommendClient>['getTrendingFacets'];
+
+export const getTrendingFacets: GetTrendingFacets = base => {
+  return (queries: readonly TrendingFacetsQuery[], requestOptions) => {
+    return getRecommendations(base)(
+      queries.map(query => ({
+        ...query,
+        model: 'trending-facets',
+      })),
+      requestOptions
+    );
+  };
+};

packages/recommend/src/methods/getTrendingGlobalItems.ts

@@ -0,0 +1,18 @@
+import { BaseRecommendClient, TrendingGlobalItemsQuery, WithRecommendMethods } from '../types';
+import { getRecommendations } from './getRecommendations';
+
+type GetTrendingGlobalItems = (
+  base: BaseRecommendClient
+) => WithRecommendMethods<BaseRecommendClient>['getTrendingGlobalItems'];
+
+export const getTrendingGlobalItems: GetTrendingGlobalItems = base => {
+  return (queries: readonly TrendingGlobalItemsQuery[], requestOptions) => {
+    return getRecommendations(base)(
+      queries.map(query => ({
+        ...query,
+        model: 'trending-items',
+      })),
+      requestOptions
+    );
+  };
+};

packages/recommend/src/methods/getTrendingItemsForFacet.ts

@@ -0,0 +1,18 @@
+import { BaseRecommendClient, TrendingItemsForFacetQuery, WithRecommendMethods } from '../types';
+import { getRecommendations } from './getRecommendations';
+
+type GetTrendingItemsForFacet = (
+  base: BaseRecommendClient
+) => WithRecommendMethods<BaseRecommendClient>['getTrendingItemsForFacet'];
+
+export const getTrendingItemsForFacet: GetTrendingItemsForFacet = base => {
+  return (queries: readonly TrendingItemsForFacetQuery[], requestOptions) => {
+    return getRecommendations(base)(
+      queries.map(query => ({
+        ...query,
+        model: 'trending-items',
+      })),
+      requestOptions
+    );
+  };
+};

packages/recommend/src/methods/index.ts

@@ -5,3 +5,6 @@
 export * from './getFrequentlyBoughtTogether';
 export * from './getRecommendations';
 export * from './getRelatedProducts';
+export * from './getTrendingFacets';
+export * from './getTrendingGlobalItems';
+export * from './getTrendingItemsForFacet';

packages/recommend/src/types/FrequentlyBoughtTogetherQuery.ts

@@ -2,5 +2,5 @@ import { RecommendationsQuery } from './RecommendationsQuery';
 
 export type FrequentlyBoughtTogetherQuery = Omit<
   RecommendationsQuery,
-  'model' | 'fallbackParameters'
+  'model' | 'fallbackParameters' | 'facetName' | 'facetValue'
 >;

packages/recommend/src/types/RecommendModel.ts

@@ -1 +1,5 @@
-export type RecommendModel = 'related-products' | 'bought-together';
+export type RecommendModel =
+  | 'related-products'
+  | 'bought-together'
+  | 'trending-items'
+  | 'trending-facets';

packages/recommend/src/types/RecommendationsQuery.ts

@@ -15,7 +15,7 @@ export type RecommendationsQuery = {
   /**
    * The `objectID` of the item to get recommendations for.
    */
-  readonly objectID: string;
+  readonly objectID?: string;
 
   /**
    * Threshold for the recommendations confidence score (between 0 and 100). Only recommendations with a greater score are returned.
@@ -38,4 +38,14 @@ export type RecommendationsQuery = {
    * Additional filters to use as fallback when there aren’t enough recommendations.
    */
   readonly fallbackParameters?: RecommendSearchOptions;
+
+  /**
+   * Used for trending model
+   */
+  readonly facetName?: string;
+
+  /**
+   * Used for trending model
+   */
+  readonly facetValue?: string;
 };

packages/recommend/src/types/RelatedProductsQuery.ts

@@ -1,3 +1,3 @@
 import { RecommendationsQuery } from './RecommendationsQuery';
 
-export type RelatedProductsQuery = Omit<RecommendationsQuery, 'model'>;
+export type RelatedProductsQuery = Omit<RecommendationsQuery, 'model' | 'facetName' | 'facetValue'>;

packages/recommend/src/types/TrendingFacetsQuery.ts

@@ -0,0 +1,3 @@
+import { RecommendationsQuery } from './RecommendationsQuery';
+
+export type TrendingFacetsQuery = Omit<RecommendationsQuery, 'model' | 'objectID' | 'facetValue'>;

packages/recommend/src/types/TrendingGlobalItemsQuery.ts

@@ -0,0 +1,6 @@
+import { RecommendationsQuery } from './RecommendationsQuery';
+
+export type TrendingGlobalItemsQuery = Omit<
+  RecommendationsQuery,
+  'model' | 'objectID' | 'facetName' | 'facetValue'
+>;

packages/recommend/src/types/TrendingItemsForFacetQuery.ts

@@ -0,0 +1,3 @@
+import { RecommendationsQuery } from './RecommendationsQuery';
+
+export type TrendingItemsForFacetQuery = Omit<RecommendationsQuery, 'model' | 'objectID'>;

packages/recommend/src/types/WithRecommendMethods.ts

@@ -4,6 +4,9 @@ import { RequestOptions } from '@algolia/transporter';
 import { FrequentlyBoughtTogetherQuery } from './FrequentlyBoughtTogetherQuery';
 import { RecommendationsQuery } from './RecommendationsQuery';
 import { RelatedProductsQuery } from './RelatedProductsQuery';
+import { TrendingFacetsQuery } from './TrendingFacetsQuery';
+import { TrendingGlobalItemsQuery } from './TrendingGlobalItemsQuery';
+import { TrendingItemsForFacetQuery } from './TrendingItemsForFacetQuery';
 
 export type WithRecommendMethods<TType> = TType & {
   /**
@@ -29,4 +32,28 @@ export type WithRecommendMethods<TType> = TType & {
     queries: readonly FrequentlyBoughtTogetherQuery[],
     requestOptions?: RequestOptions & SearchOptions
   ) => Readonly<Promise<MultipleQueriesResponse<TObject>>>;
+
+  /**
+   * Returns trending items
+   */
+  readonly getTrendingGlobalItems: <TObject>(
+    queries: readonly TrendingGlobalItemsQuery[],
+    requestOptions?: RequestOptions & SearchOptions
+  ) => Readonly<Promise<MultipleQueriesResponse<TObject>>>;
+
+  /**
+   * Returns trending items per facet
+   */
+  readonly getTrendingItemsForFacet: <TObject>(
+    queries: readonly TrendingItemsForFacetQuery[],
+    requestOptions?: RequestOptions & SearchOptions
+  ) => Readonly<Promise<MultipleQueriesResponse<TObject>>>;
+
+  /**
+   * Returns trending items per facet
+   */
+  readonly getTrendingFacets: <TObject>(
+    queries: readonly TrendingFacetsQuery[],
+    requestOptions?: RequestOptions & SearchOptions
+  ) => Readonly<Promise<MultipleQueriesResponse<TObject>>>;
 };

packages/recommend/src/types/index.ts

@@ -10,4 +10,7 @@ export * from './RecommendOptions';
 export * from './RecommendSearchOptions';
 export * from './RecommendationsQuery';
 export * from './RelatedProductsQuery';
+export * from './TrendingFacetsQuery';
+export * from './TrendingGlobalItemsQuery';
+export * from './TrendingItemsForFacetQuery';
 export * from './WithRecommendMethods';