ASSETS-88896 : (Backend) Campaign Details: Collections

blocks/adp-infinite-results-campaign-collections/CollectionsDatasource.js

@@ -0,0 +1,90 @@
+import { createLinkHref, navigateTo } from '../../scripts/shared.js';
+import {
+  getCollectionID,
+  getCollectionTitle,
+  listCampaignCollections,
+} from '../../scripts/collections.js';
+
+import { createCollectionCardElement } from '../../scripts/card-html-builder.js';
+
+export default class CollectionsDatasource {
+  infiniteResultsContainer = null;
+
+  container = null;
+
+  pageNumber = 0;
+
+  lastPage = false;
+
+  async showMore() {
+
+    this.pageNumber += 1;
+
+    //Todo Pass in the campaignName
+    const list = await listCampaignCollections('gmo-campaignName:Everyone Can',pageNumber);
+
+    if (this.pageNumber >= list.nbPages){
+      this.lastPage = true;
+    }
+
+    this.infiniteResultsContainer.resultsCallback(
+      this.container,
+      list.items,
+      () => this.showMore(),
+      this.pageNumber,
+      false,
+      false,
+      () => this.isLastPage(),
+    );
+  }
+
+  isLastPage() {
+    return this.lastPage;
+  }
+
+  async registerResultsCallback(container, infiniteResultsContainer) {
+    this.infiniteResultsContainer = infiniteResultsContainer;
+    this.container = container;
+
+    //Todo Pass in the campaignName
+    const list = await listCampaignCollections('gmo-campaignName:Everyone Can',this.pageNumber);
+
+    infiniteResultsContainer.resultsCallback(
+      container,
+      list.items,
+      () => this.showMore(),
+      0,
+      true,
+      true,
+      () => this.isLastPage(),
+    );
+  }
+
+  getItemId(resultItem) {
+    return getCollectionID(resultItem);
+  }
+
+  getItemName(resultItem) {
+    return getCollectionTitle(resultItem);
+  }
+
+  createItemElement(item, infiniteResultsContainer) {
+    const id = getCollectionID(item);
+    const card = createCollectionCardElement(
+      item,
+      {
+        selectItemHandler: () => {
+          infiniteResultsContainer.toggleSelection(id);
+        },
+        deselectItemHandler: () => {
+          infiniteResultsContainer.deselectItem(id);
+        },
+      },
+    );
+    return card;
+  }
+
+  onItemSelected(itemElement, itemId) {
+    navigateTo(createLinkHref(`collection/${itemId}`));
+  }
+}

blocks/adp-infinite-results-campaign-collections/adp-infinite-results-campaign-collections.css

@@ -0,0 +1,9 @@
+.adp-infinite-results-collections .metadata-fields .metadata-row {
+  grid-column: span 2;
+}
+
+.adp-infinite-results-collections .metadata-fields .label {
+    color: var(--metadata-label-color);
+    font: var(--metadata-label-font);
+    margin-bottom: 4px;
+}

blocks/adp-infinite-results-campaign-collections/adp-infinite-results-campaign-collections.js

@@ -0,0 +1,9 @@
+import InfiniteResultsContainer from '../../scripts/infinite-results/InfiniteResultsContainer.js';
+// eslint-disable-next-line import/no-unresolved
+import CollectionsDatasource from './CollectionsDatasource.js';
+
+export default async function decorate(block) {
+  const instantSearchDatasource = new CollectionsDatasource();
+  const infiniteResultsContainer = new InfiniteResultsContainer(block, instantSearchDatasource);
+  infiniteResultsContainer.render();
+}

contenthub/hydration/hydration-utils.js

@@ -145,6 +145,7 @@ export function getMetadataSchema(facetOptions){
             { name: 'Digital Editions', id: 'digital-editions' },
             { name: 'Dreamweaver', id: 'dreamweaver' },
             { name: 'Fill Sign', id: 'fill-sign' },
+            { name: 'Firefly', id: 'firefly' },
             { name: 'Frame.io', id: 'frame-io' },
             { name: 'Fresco', id: 'fresco' },
             { name: 'Http Dynamic Streaming', id: 'http-dynamic-streaming' },

scripts/collections.js

@@ -1,5 +1,6 @@
 import { getBearerToken } from './security.js';
 import {
+  getSearchIndex,
   getAssetHandlerApiKey,
   getDeliveryEnvironment,
   getBackendApiKey,
@@ -98,8 +99,6 @@ export function getSearchCollectionsUrl() {
   return `${getDeliveryEnvironment()}/adobe/assets/search`;
 }
 
-
-
 /**
  * Constructs and returns the base URL for assets collections. (New)
  *
@@ -284,6 +283,101 @@ export async function searchListCollection(limit = undefined, page = 0) {
   }
 }
 
+
+/**
+ * List Campaign Collections with required campaignName, indexName and page parameters.
+ *
+ * @param {String} - Campaign Name
+ * @param {String} - The Index Name
+ * @param {Number} - Page Number
+ * @returns {Promise<object>} A promise that resolves with a list of collections.
+ * @throws {Error} If an HTTP error or network error occurs.
+ */
+export async function listCampaignCollections(campaignName, page = 0) {
+
+  // Construct the query parameters
+  const queryParams = new URLSearchParams();
+
+  const indexName = getSearchIndex();
+
+  if (campaignName) {
+    queryParams.append('campaignName', campaignName);
+  }
+
+  if (indexName) {
+    queryParams.append('indexName', indexName);
+  }
+
+  if (page) {
+    queryParams.append('page', page);
+  }
+
+  const data = {
+    requests: [
+      {
+        indexName: indexName,
+        params: {
+          facetFilters: [
+            campaignName
+          ],
+          highlightPostTag: '__/ais-highlight__',
+          highlightPreTag: '__ais-highlight__',
+          hitsPerPage: 40,
+          maxValuesPerFacet: 20,
+          page: page,
+          query: '',
+          tagFilters: ''
+        }
+      }
+    ]
+  };
+
+  const options = {
+    method: 'POST',
+    headers: await getRequestHeadersSearchCollections(),
+    body: JSON.stringify(data),
+  };
+
+  // Include the query parameters in the URL
+  const queryString = queryParams.toString();
+  //Uses Search Collections URL
+  const url = `${getSearchCollectionsUrl()}${queryString ? `?${queryString}` : ''}`;
+
+  try {
+    const response = await fetch(url, options);
+    // Handle response codes
+    if (response.status === 200) {
+      // Collection retrieved successfully
+      const responseBody = await response.json();
+      const hits  = responseBody.results[0].hits;
+      const uniqueCollectionIds = Array.from(new Set(hits.reduce((acc, {collectionIds}) => [...acc, ...collectionIds], [])));
+
+      let collections = [];
+      for (const collectionId of uniqueCollectionIds) {
+          //collectionId is missing urn:cid:aem:
+          const  fixedCollectionId = `urn:cid:aem:${collectionId}`;
+          const collectionBody = await getCollection(fixedCollectionId);
+          collections.push({id:collectionBody.self[0].id, title:collectionBody.self[0].collectionMetadata.title, description:collectionBody.self[0].collectionMetadata.description});
+      }
+
+      const transformedData = {
+        page: responseBody.results[0].page,
+        nbHits: uniqueCollectionIds.length,
+        nbPages: 1,
+        items:  collections
+      };
+
+      return transformedData;
+    }
+    // Handle other response codes
+    throw new Error(`Failed to search campaign collection: ${response.status} ${response.statusText}`);
+  } catch (error) {
+    logError('listCampaignCollection', error);
+    throw error;
+  }
+}
+
+
 /**
  * Updates a collection using JSON patch operations.
  *