Add Algolia sample extension to sync products

full-ingestion/package.json

@@ -27,10 +27,12 @@
   "dependencies": {
     "@commercetools-backend/loggers": "^21.19.0",
     "@commercetools/platform-sdk": "^4.1.0",
-    "@commercetools/sdk-client-v2": "^2.0.1",
+    "@commercetools/sdk-client-v2": "^2.2.0",
+    "algoliasearch": "^4.19.1",
     "body-parser": "^1.20.1",
     "dotenv": "^16.0.3",
     "express": "4.18.2",
+    "lodash": "^4.17.21",
     "validator": "^13.7.0"
   }
-}
+}

full-ingestion/src/clients/build.client.js

@@ -0,0 +1,15 @@
+import { ClientBuilder } from '@commercetools/sdk-client-v2';
+import { authMiddlewareOptions } from '../middlewares/auth.middleware.js';
+import { httpMiddlewareOptions } from '../middlewares/http.middleware.js';
+import { readConfiguration } from '../utils/config.utils.js';
+
+/**
+ * Create a new client builder.
+ * This code creates a new Client that can be used to make API calls
+ */
+export const createClient = () =>
+  new ClientBuilder()
+    .withProjectKey(readConfiguration().projectKey)
+    .withClientCredentialsFlow(authMiddlewareOptions)
+    .withHttpMiddleware(httpMiddlewareOptions)
+    .build();

full-ingestion/src/clients/create.client.js

@@ -0,0 +1,29 @@
+import { createApiBuilderFromCtpClient } from '@commercetools/platform-sdk';
+import { createClient } from './build.client.js';
+import { readConfiguration } from '../utils/config.utils.js';
+
+/**
+ * Create client with apiRoot
+ * apiRoot can now be used to build requests to de Composable Commerce API
+ */
+export const createApiRoot = ((root) => () => {
+  if (root) {
+    return root;
+  }
+
+  root = createApiBuilderFromCtpClient(createClient()).withProjectKey({
+    projectKey: readConfiguration().projectKey,
+  });
+
+  return root;
+})();
+
+/**
+ * Example code to get the Project details
+ * This code has the same effect as sending a GET
+ * request to the commercetools Composable Commerce API without any endpoints.
+ *
+ */
+export const getProject = async () => {
+  return await createApiRoot().get().execute();
+};