export async function onIndexCreatedHandler()

in storage-reverse-image-search/functions/src/functions/on_index_created.ts [40:107]
50 lines of code
11 McCabe index (conditional complexity)

export async function onIndexCreatedHandler(event: any) {
  try {
    const maxRetries = 5;
    const {operation} = event.data;
    functionsv2.logger.info('Event recieved 👇', event);
    if (!operation) return;

    // Check if the operation is the last one, which means the index is ready.
    if (operation && !operation.last) return;
    const _operation = await getOperationByName(operation.id);

    // Check if the operation failed.
    if (_operation.error) {
      functionsv2.logger.error(
        'Something wrong happened while creating the Index.',
        JSON.stringify(_operation)
      );
      throw new Error(_operation.error?.message ?? 'Unknown error.');
    }

    const indexResourceName = (operation.id as string).split('/operations/')[0];

    functionsv2.logger.info('Index created!', {
      indexResourceName,
    });

    const indexEndpointOp = await createIndexEndpoint();

    // Poll the operation until it's done.
    for (let i = 0; i < maxRetries; i++) {
      if (indexEndpointOp.done) {
        break;
      } else if (indexEndpointOp.error) {
        throw indexEndpointOp.error;
      }

      await new Promise(resolve => setTimeout(resolve, 2000));
    }

    const indexEndpoint = await indexEndpointOp.promise();
    functionsv2.logger.info(indexEndpoint);

    if (!indexEndpoint[0].name)
      throw new Error('Index endpoint name is undefined.');

    try {
      const indexEndpointResourceName = indexEndpoint[0].name;

      await deployIndex(indexEndpointResourceName, indexResourceName);

      functionsv2.logger.info('Index is being deployed.');

      // Add the index endpoint to the metadata document.
      await admin.firestore().doc(config.metadataDoc).update({
        index: indexResourceName,
        status: IndexStatus.DEPLOYING,
        indexEndpoint: indexEndpoint[0].name,
      });

      return;
    } catch (error) {
      functionsv2.logger.error(error);
      throw error;
    }
  } catch (error) {
    functionsv2.logger.error(error);
  }
}