feat(insights): introduce insights middleware (1/4)

src/middleware/insights.ts

@@ -0,0 +1,36 @@
+import { Middleware } from '.';
+import { InsightsClient } from '../types';
+
+export type InsightsProps = {
+  insightsClient: InsightsClient;
+};
+
+export type CreateInsightsMiddleware = (props: InsightsProps) => Middleware;
+
+export const createInsightsMiddleware: CreateInsightsMiddleware = props => {
+  const { insightsClient } = props;
+
+  return ({ instantSearchInstance }) => {
+    return {
+      onStateChange() {},
+      subscribe() {
+        instantSearchInstance.mainIndex
+          .getHelper()
+          .setQueryParameter('clickAnalytics', true);
+
+        insightsClient(
+          'onUserTokenChange',
+          userToken => {
+            instantSearchInstance.mainIndex
+              .getHelper()
+              .setQueryParameter('userToken', userToken);
+          },
+          { immediate: true }
+        );
+      },
+      unsubscribe() {
+        insightsClient('onUserTokenChange', () => {});
+      },
+    };
+  };
+};

src/types/insights.ts

@@ -10,11 +10,21 @@ export type InsightsClientPayload = {
   positions?: number[];
 };
 
-export type InsightsClient = (
+export type InsightsSendEvent = (
   method: InsightsClientMethod,
   payload: InsightsClientPayload
 ) => void;
 
+export type InsightsOnUserTokenChangeMethod = 'onUserTokenChange';
+
+export type InsightsOnUserTokenChange = (
+  method: InsightsOnUserTokenChangeMethod,
+  callback: (userToken: string) => void,
+  options?: { immediate?: boolean }
+) => void;
+
+export type InsightsClient = InsightsSendEvent & InsightsOnUserTokenChange;
+
 export type InsightsClientWrapper = (
   method: InsightsClientMethod,
   payload: Partial<InsightsClientPayload>