feat(recommend): Add trending types and methods

package.json

@@ -105,7 +105,7 @@
     },
     {
       "path": "packages/recommend/dist/recommend.umd.js",
-      "maxSize": "4.1KB"
+      "maxSize": "4.2KB"
     }
   ]
 }

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__/getTrendingItems.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('getTrendingItems', () => {
+  test('builds the request', async () => {
+    const client = createMockedClient();
+
+    await client.getTrendingItems(
+      [
+        {
+          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/builds/browser.ts

@@ -8,7 +8,13 @@ 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,
+  getTrendingItems,
+} from '../methods';
 import { BaseRecommendClient, RecommendOptions, WithRecommendMethods } from '../types';
 
 export default function recommend(
@@ -47,6 +53,8 @@ export default function recommend(
       getFrequentlyBoughtTogether,
       getRecommendations,
       getRelatedProducts,
+      getTrendingFacets,
+      getTrendingItems,
     },
   });
 }

packages/recommend/src/builds/node.ts

@@ -7,7 +7,13 @@ 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,
+  getTrendingItems,
+} from '../methods';
 import { BaseRecommendClient, RecommendOptions, WithRecommendMethods } from '../types';
 
 export default function recommend(
@@ -41,6 +47,8 @@ export default function recommend(
       getFrequentlyBoughtTogether,
       getRecommendations,
       getRelatedProducts,
+      getTrendingFacets,
+      getTrendingItems,
     },
   });
 }

packages/recommend/src/methods/getTrendingFacets.ts

@@ -0,0 +1,32 @@
+import { MethodEnum } from '@algolia/requester-common';
+
+import { BaseRecommendClient, TrendingFacetsQuery, WithRecommendMethods } from '../types';
+
+type GetTrendingFacets = (
+  base: BaseRecommendClient
+) => WithRecommendMethods<BaseRecommendClient>['getTrendingFacets'];
+
+export const getTrendingFacets: GetTrendingFacets = base => {
+  return (queries: readonly TrendingFacetsQuery[], requestOptions) => {
+    const requests: readonly TrendingFacetsQuery[] = queries.map(query => ({
+      ...query,
+      model: 'trending-facets',
+      // The `threshold` param is required by the endpoint to make it easier
+      // to provide a default value later, so we default it in the client
+      // so that users don't have to provide a value.
+      threshold: query.threshold || 0,
+    }));
+
+    return base.transporter.read(
+      {
+        method: MethodEnum.Post,
+        path: '1/indexes/*/recommendations',
+        data: {
+          requests,
+        },
+        cacheable: true,
+      },
+      requestOptions
+    );
+  };
+};

packages/recommend/src/methods/getTrendingItems.ts

@@ -0,0 +1,32 @@
+import { MethodEnum } from '@algolia/requester-common';
+
+import { BaseRecommendClient, TrendingItemsQuery, WithRecommendMethods } from '../types';
+
+type GetTrendingItems = (
+  base: BaseRecommendClient
+) => WithRecommendMethods<BaseRecommendClient>['getTrendingItems'];
+
+export const getTrendingItems: GetTrendingItems = base => {
+  return (queries: readonly TrendingItemsQuery[], requestOptions) => {
+    const requests: readonly TrendingItemsQuery[] = queries.map(query => ({
+      ...query,
+      model: 'trending-items',
+      // The `threshold` param is required by the endpoint to make it easier
+      // to provide a default value later, so we default it in the client
+      // so that users don't have to provide a value.
+      threshold: query.threshold || 0,
+    }));
+
+    return base.transporter.read(
+      {
+        method: MethodEnum.Post,
+        path: '1/indexes/*/recommendations',
+        data: {
+          requests,
+        },
+        cacheable: true,
+      },
+      requestOptions
+    );
+  };
+};

packages/recommend/src/methods/index.ts

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

packages/recommend/src/types/FrequentlyBoughtTogetherQuery.ts

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

packages/recommend/src/types/RecommendModel.ts

@@ -1 +1,2 @@
-export type RecommendModel = 'related-products' | 'bought-together';
+export type RecommendModel = 'related-products' | 'bought-together' | TrendingModel;
+export type TrendingModel = '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,7 @@
 import { RecommendationsQuery } from './RecommendationsQuery';
 
-export type RelatedProductsQuery = Omit<RecommendationsQuery, 'model'>;
+export type RelatedProductsQuery = Omit<
+  RecommendationsQuery,
+  'model' | 'facetName' | 'facetValue'
+> &
+  Required<Pick<RecommendationsQuery, 'objectID'>>;

packages/recommend/src/types/TrendingFacetsQuery.ts

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

packages/recommend/src/types/TrendingItemsQuery.ts

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

packages/recommend/src/types/WithRecommendMethods.ts

@@ -4,6 +4,8 @@ import { RequestOptions } from '@algolia/transporter';
 import { FrequentlyBoughtTogetherQuery } from './FrequentlyBoughtTogetherQuery';
 import { RecommendationsQuery } from './RecommendationsQuery';
 import { RelatedProductsQuery } from './RelatedProductsQuery';
+import { TrendingFacetsQuery } from './TrendingFacetsQuery';
+import { TrendingItemsQuery } from './TrendingItemsQuery';
 
 export type WithRecommendMethods<TType> = TType & {
   /**
@@ -29,4 +31,20 @@ export type WithRecommendMethods<TType> = TType & {
     queries: readonly FrequentlyBoughtTogetherQuery[],
     requestOptions?: RequestOptions & SearchOptions
   ) => Readonly<Promise<MultipleQueriesResponse<TObject>>>;
+
+  /**
+   * Returns trending items
+   */
+  readonly getTrendingItems: <TObject>(
+    queries: readonly TrendingItemsQuery[],
+    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,6 @@ export * from './RecommendOptions';
 export * from './RecommendSearchOptions';
 export * from './RecommendationsQuery';
 export * from './RelatedProductsQuery';
+export * from './TrendingFacetsQuery';
+export * from './TrendingItemsQuery';
 export * from './WithRecommendMethods';