[EPH] Format all the EPH files using prettier

sdk/eventhub/event-processor-host/samples/iothubEph.ts

@@ -33,7 +33,7 @@ async function main(): Promise<void> {
   await stopEph(eph);
 }
 
-main().catch(err => {
+main().catch((err) => {
   console.log("Exiting from main() due to an error: %O.", err);
 });
 
@@ -58,7 +58,9 @@ async function startEph(ephName: string): Promise<EventProcessorHost> {
   // Message handler
   const partionCount: { [x: string]: number } = {};
   const onMessage: OnReceivedMessage = async (context: PartitionContext, event: EventData) => {
-    !partionCount[context.partitionId] ? (partionCount[context.partitionId] = 1) : partionCount[context.partitionId]++;
+    !partionCount[context.partitionId]
+      ? (partionCount[context.partitionId] = 1)
+      : partionCount[context.partitionId]++;
     console.log(
       "[%s] %d - Received message from partition: '%s', offset: '%s'",
       ephName,
@@ -75,7 +77,11 @@ async function startEph(ephName: string): Promise<EventProcessorHost> {
           eph.receivingFromPartitions
         );
         await context.checkpointFromEventData(event);
-        console.log("[%s] Successfully checkpointed message number %d", ephName, partionCount[context.partitionId]);
+        console.log(
+          "[%s] Successfully checkpointed message number %d",
+          ephName,
+          partionCount[context.partitionId]
+        );
       } catch (err) {
         console.log(
           "[%s] An error occurred while checkpointing msg number %d: %O",

sdk/eventhub/event-processor-host/samples/multiEph.ts

@@ -46,7 +46,7 @@ async function main(): Promise<void> {
   await stopEph(eph2);
 }
 
-main().catch(err => {
+main().catch((err) => {
   console.log("Error occurred: ", err);
 });
 
@@ -75,7 +75,9 @@ async function startEph(ephName: string): Promise<EventProcessorHost> {
   // Message handler
   const partionCount: { [x: string]: number } = {};
   const onMessage: OnReceivedMessage = async (context: PartitionContext, event: EventData) => {
-    !partionCount[context.partitionId] ? (partionCount[context.partitionId] = 1) : partionCount[context.partitionId]++;
+    !partionCount[context.partitionId]
+      ? (partionCount[context.partitionId] = 1)
+      : partionCount[context.partitionId]++;
     console.log(
       "[%s] %d - Received message from partition: '%s', offset: '%s'",
       ephName,
@@ -92,7 +94,11 @@ async function startEph(ephName: string): Promise<EventProcessorHost> {
           eph.receivingFromPartitions
         );
         await context.checkpointFromEventData(event);
-        console.log("[%s] Successfully checkpointed message number %d", ephName, partionCount[context.partitionId]);
+        console.log(
+          "[%s] Successfully checkpointed message number %d",
+          ephName,
+          partionCount[context.partitionId]
+        );
       } catch (err) {
         console.log(
           "[%s] An error occurred while checkpointing msg number %d: %O",

sdk/eventhub/event-processor-host/samples/sendBatch.ts

@@ -31,12 +31,12 @@ async function main(): Promise<void> {
   console.log("Sending batch events...");
 
   // Will concurrently send batched events to all the partitions.
-  const sendPromises = partitionIds.map(id => client.sendBatch(events, id));
+  const sendPromises = partitionIds.map((id) => client.sendBatch(events, id));
 
   await Promise.all(sendPromises);
   await client.close();
 }
 
-main().catch(err => {
+main().catch((err) => {
   console.log("Error occurred: ", err);
 });

sdk/eventhub/event-processor-host/samples/singleEph.ts

@@ -42,7 +42,7 @@ async function main(): Promise<void> {
   await stopEph(eph);
 }
 
-main().catch(err => {
+main().catch((err) => {
   console.log("Error occurred: ", err);
 });
 
@@ -68,7 +68,9 @@ async function startEph(ephName: string): Promise<EventProcessorHost> {
   // Message handler
   const partionCount: { [x: string]: number } = {};
   const onMessage: OnReceivedMessage = async (context: PartitionContext, event: EventData) => {
-    !partionCount[context.partitionId] ? (partionCount[context.partitionId] = 1) : partionCount[context.partitionId]++;
+    !partionCount[context.partitionId]
+      ? (partionCount[context.partitionId] = 1)
+      : partionCount[context.partitionId]++;
     console.log(
       "[%s] %d - Received message from partition: '%s', offset: '%s'",
       ephName,
@@ -85,7 +87,11 @@ async function startEph(ephName: string): Promise<EventProcessorHost> {
           eph.receivingFromPartitions
         );
         await context.checkpointFromEventData(event);
-        console.log("[%s] Successfully checkpointed message number %d", ephName, partionCount[context.partitionId]);
+        console.log(
+          "[%s] Successfully checkpointed message number %d",
+          ephName,
+          partionCount[context.partitionId]
+        );
       } catch (err) {
         console.log(
           "[%s] An error occurred while checkpointing msg number %d: %O",

sdk/eventhub/event-processor-host/samples/tsconfig.json

@@ -3,11 +3,6 @@
   "compilerOptions": {
     "module": "commonjs"
   },
-  "include": [
-    "**/*.ts"
-  ],
-  "exclude": [
-    "../node_modules",
-    "../typings/**",
-  ]
+  "include": ["**/*.ts"],
+  "exclude": ["../node_modules", "../typings/**"]
 }

sdk/eventhub/event-processor-host/src/azureBlob.ts

@@ -81,8 +81,16 @@ export class AzureBlob {
     return this._blobService.getContent(this._containerName, this._blobPath, options);
   }
 
-  changeLease(currentLeaseId: string, proposedLeaseId: string): Promise<StorageBlobService.LeaseResult> {
-    return this._blobService.changeLease(this._containerName, this._blobPath, currentLeaseId, proposedLeaseId);
+  changeLease(
+    currentLeaseId: string,
+    proposedLeaseId: string
+  ): Promise<StorageBlobService.LeaseResult> {
+    return this._blobService.changeLease(
+      this._containerName,
+      this._blobPath,
+      currentLeaseId,
+      proposedLeaseId
+    );
   }
 
   getBlobProperties(): Promise<StorageBlobService.BlobResult> {
@@ -97,7 +105,12 @@ export class AzureBlob {
     metadata: Dictionary<string>,
     options?: StorageBlobService.BlobRequestOptions
   ): Promise<StorageBlobService.BlobResult> {
-    return this._blobService.setBlobMetadata(this._containerName, this._blobPath, metadata, options);
+    return this._blobService.setBlobMetadata(
+      this._containerName,
+      this._blobPath,
+      metadata,
+      options
+    );
   }
 
   listBlobsSegmented(
@@ -106,7 +119,9 @@ export class AzureBlob {
     return this._blobService.listBlobsSegmented(this._containerName, options);
   }
 
-  acquireLease(options: StorageBlobService.AcquireLeaseRequestOptions): Promise<StorageBlobService.LeaseResult> {
+  acquireLease(
+    options: StorageBlobService.AcquireLeaseRequestOptions
+  ): Promise<StorageBlobService.LeaseResult> {
     return this._blobService.acquireLease(this._containerName, this._blobPath, options);
   }
 

sdk/eventhub/event-processor-host/src/azureStorageCheckpointLeaseManager.ts

@@ -107,7 +107,9 @@ export class AzureStorageCheckpointLeaseManager implements CheckpointManager, Le
         await Promise.all(deleteBlobs);
         await blobService.deleteContainerIfExists(storageContainerName);
       } else {
-        throw new Error("'blobService' is not defined in the 'hostContext', hence cannot " + "list all the blobs.");
+        throw new Error(
+          "'blobService' is not defined in the 'hostContext', hence cannot " + "list all the blobs."
+        );
       }
     } catch (err) {
       const msg =
@@ -189,7 +191,9 @@ export class AzureStorageCheckpointLeaseManager implements CheckpointManager, Le
       const leaseBlobs = await this._listBlobs();
       if (leaseBlobs.length === partitionIds.length) {
         log.checkpointLeaseMgr(
-          withHost("Number of blobs %d === Number of partitionIds %d. " + "Hence no need to create leases."),
+          withHost(
+            "Number of blobs %d === Number of partitionIds %d. " + "Hence no need to create leases."
+          ),
           leaseBlobs.length,
           partitionIds.length
         );
@@ -235,7 +239,10 @@ export class AzureStorageCheckpointLeaseManager implements CheckpointManager, Le
         returnLease = <AzureBlobLease>await this.getLease(partitionId);
       } else {
         log.error(
-          withHostAndPartition(partitionId, "An error occurred while creating lease if " + "it does not exist: %O."),
+          withHostAndPartition(
+            partitionId,
+            "An error occurred while creating lease if " + "it does not exist: %O."
+          ),
           error
         );
         throw error;
@@ -277,7 +284,10 @@ export class AzureStorageCheckpointLeaseManager implements CheckpointManager, Le
           return false;
         }
         log.checkpointLeaseMgr(
-          withHostAndPartition(lease, "Need to change lease '%s' -> '%s' " + "for partitionId '%s'."),
+          withHostAndPartition(
+            lease,
+            "Need to change lease '%s' -> '%s' " + "for partitionId '%s'."
+          ),
           lease.token,
           newLeaseId,
           lease.partitionId
@@ -364,7 +374,8 @@ export class AzureStorageCheckpointLeaseManager implements CheckpointManager, Le
     log.checkpointLeaseMgr(
       withHostAndPartition(
         lease,
-        "Let us renew the lease to make sure the " + "update with offset '%s' and sequence number %d will go through."
+        "Let us renew the lease to make sure the " +
+          "update with offset '%s' and sequence number %d will go through."
       ),
       lease.offset,
       lease.sequenceNumber
@@ -463,7 +474,9 @@ export class AzureStorageCheckpointLeaseManager implements CheckpointManager, Le
       log.checkpointLeaseMgr(withHost("Number of blobs: %d"), listResult.entries.length);
       return listResult.entries;
     } else {
-      throw new Error("'blobService' is not defined in the 'hostContext', hence cannot " + "list all the blobs.");
+      throw new Error(
+        "'blobService' is not defined in the 'hostContext', hence cannot " + "list all the blobs."
+      );
     }
   }
 
@@ -521,7 +534,10 @@ export class AzureStorageCheckpointLeaseManager implements CheckpointManager, Le
       options.metadata[metadataOwnerName] = lease.owner || this._context.hostName;
     }
     log.checkpointLeaseMgr(
-      withHostAndPartition(lease, "Trying to upload raw JSON for activity " + "'%s': %s, with options: %o"),
+      withHostAndPartition(
+        lease,
+        "Trying to upload raw JSON for activity " + "'%s': %s, with options: %o"
+      ),
       activity,
       jsonToUpload,
       options
@@ -546,7 +562,11 @@ export class AzureStorageCheckpointLeaseManager implements CheckpointManager, Le
         result = true;
       }
     }
-    log.error(withHostAndPartition(partitionId, "Was lease lost -> %s, err: %O."), result, getStorageError(err));
+    log.error(
+      withHostAndPartition(partitionId, "Was lease lost -> %s, err: %O."),
+      result,
+      getStorageError(err)
+    );
     return result;
   }
 }