export async function datapointWriteTaskHandler()

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

export async function datapointWriteTaskHandler(data: any) {
  const {operation, imagePath} = data as {
    operation: 'update' | 'remove';
    imagePath: string;
  };

  const queue = getFunctions().taskQueue(
    'datapointWriteTask',
    config.instanceId
  );

  const {index, status} = await checkIndexStatus();

  // If the index exist but isn't deployed yet, or is still building retry in an hour.
  if (
    (index && status !== IndexStatus.DEPLOYED) ||
    status === IndexStatus.BUILDING
  ) {
    functions.logger.info('Index not deployed yet, skipping...');

    // Index isn't ready yet, retry in an hour.
    await queue.enqueue(data, {
      scheduleDelaySeconds: 60 * 60,
    });
    return;
  }

  try {
    // Get the index name from the metadata document.
    const metdata = await admin.firestore().doc(config.metadataDoc).get();
    const index = metdata.data()?.index;
    if (!index) {
      functions.logger.error('Index not found');
      return;
    }

    switch (operation) {
      case 'remove':
        // Upsert the datapoint to the index.
        await removeDatapoint(index, [imagePath]);
        break;
      case 'update':
        {
          const [object] = await admin
            .storage()
            .bucket(config.imgBucket)
            .file(imagePath)
            .getMetadata();

          if (!object.name) return;
          if (!utils.isImage(object.name)) {
            functions.logger.info(`Skipping ${object.name}, not an image...`);
            return;
          }

          const vector = await getFeatureVectors([imagePath]);
          if (!vector) {
            functions.logger.info('No feature vectors found, skipping...');
            return;
          }

          functions.logger.info('Datapoint generated 🎉');
          // Upsert the datapoint to the index.
          await upsertDatapoint(index, [
            {
              datapoint_id: object.name,
              feature_vector: vector[0],
            },
          ]);
        }
        break;
    }
  } catch (error) {
    functions.logger.error((error as AxiosError).response);
  }
}