importRegistrationsJob.ts

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

/**
 * This sample demonstrates how the createNotificationJob() method can be used to import registrations
 * descriptions from an existing set of exports.
 *
 * See https://learn.microsoft.com/azure/notification-hubs/export-modify-registrations-bulk
 * to learn about Export and Import Registrations in Azure Notification Hubs.
 *
 *
 * @summary Demonstrates how to import registrations into a Notification Hub.
 * @azsdk-weight 100
 */

import "dotenv/config";
import {
  createClientContext,
  getNotificationHubJob,
  submitNotificationHubJob,
} from "@azure/notification-hubs/api";
import type { NotificationHubJob } from "@azure/notification-hubs/models";
import { delay } from "@azure/core-util";

// Define connection string and hub name
const connectionString = process.env.NOTIFICATIONHUBS_CONNECTION_STRING || "<connection string>";
const hubName = process.env.NOTIFICATION_HUB_NAME || "<hub name>";

// Define export job parameters
const outputContainerUrl = process.env.OUTPUT_CONTAINER_URL || "<output container URL>";
const importFileUrl = process.env.IMPORT_FILE_URL || "<import file URL>";

async function main(): Promise<void> {
  const context = createClientContext(connectionString, hubName);

  let importJob: NotificationHubJob = {
    outputContainerUrl,
    importFileUrl,
    type: "ImportCreateRegistrations",
  };

  importJob = await submitNotificationHubJob(context, importJob);

  let count = 0;
  while (importJob.status !== "Completed" && importJob.status !== "Failed" && count++ < 10) {
    importJob = await getNotificationHubJob(context, importJob.jobId!);
    await delay(1000);
  }

  console.log(`Notification Hub Job status: ${importJob.status}`);
}

main().catch((err) => {
  console.log("exportRegistrationJob Sample: Error occurred: ", err);
  process.exit(1);
});