cosmos-explorer/src/Common/dataAccess/readOffers.ts

import { Offer } from "../../Contracts/DataModels";
import { ClientDefaults } from "../Constants";
import { MessageTypes } from "../../Contracts/ExplorerContracts";
import { Platform, configContext } from "../../ConfigContext";
import { client } from "../CosmosClient";
import { logConsoleProgress, logConsoleError } from "../../Utils/NotificationConsoleUtils";
import { logError } from "../Logger";
import { sendCachedDataMessage } from "../MessageHandler";
import { sendNotificationForError } from "./sendNotificationForError";
import { userContext } from "../../UserContext";

export const readOffers = async (): Promise<Offer[]> => {
  const clearMessage = logConsoleProgress(`Querying offers`);
  try {
    if (configContext.platform === Platform.Portal) {
      return sendCachedDataMessage<Offer[]>(MessageTypes.AllOffers, [
        userContext.databaseAccount.id,
        ClientDefaults.portalCacheTimeoutMs
      ]);
    }
  } catch (error) {
    // If error getting cached Offers, continue on and read via SDK
  }

  try {
    const response = await client()
      .offers.readAll()
      .fetchAll();
    return response?.resources;
  } catch (error) {
    // This should be removed when we can correctly identify if an account is serverless when connected using connection string too.
    if (error.message.includes("Reading or replacing offers is not supported for serverless accounts")) {
      return [];
    }

    logConsoleError(`Error while querying offers:\n ${JSON.stringify(error)}`);
    logError(JSON.stringify(error), "ReadOffers", error.code);
    sendNotificationForError(error);
    throw error;
  } finally {
    clearMessage();
  }
};