Update prettier dev-dependency to v2.5.1 in Event Hub

sdk/eventhub/event-hubs/karma.conf.js

@@ -2,7 +2,7 @@
 process.env.CHROME_BIN = require("puppeteer").executablePath();
 require("dotenv").config();
 
-module.exports = function(config) {
+module.exports = function (config) {
   config.set({
     // base path that will be used to resolve all patterns (eg. files, exclude)
     basePath: "./",
@@ -21,13 +21,13 @@ module.exports = function(config) {
       "karma-env-preprocessor",
       "karma-coverage",
       "karma-sourcemap-loader",
-      "karma-junit-reporter"
+      "karma-junit-reporter",
     ],
 
     // list of files / patterns to load in the browser
     files: [
       "dist-test/index.browser.js",
-      { pattern: "dist-test/index.browser.js.map", type: "html", included: false, served: true }
+      { pattern: "dist-test/index.browser.js.map", type: "html", included: false, served: true },
     ],
 
     // list of files / patterns to exclude
@@ -36,7 +36,7 @@ module.exports = function(config) {
     // preprocess matching files before serving them to the browser
     // available preprocessors: https://npmjs.org/browse/keyword/karma-preprocessor
     preprocessors: {
-      "**/*.js": ["env"]
+      "**/*.js": ["env"],
       // IMPORTANT: COMMENT following line if you want to debug in your browsers!!
       // Preprocess source file to calculate code coverage, however this will make source file unreadable
       // "dist-test/index.browser.js": ["coverage"]
@@ -49,7 +49,7 @@ module.exports = function(config) {
       "EVENTHUB_CONNECTION_STRING",
       "EVENTHUB_NAME",
       "IOTHUB_EH_COMPATIBLE_CONNECTION_STRING",
-      "TEST_TARGET"
+      "TEST_TARGET",
     ],
 
     // test results reporter to use
@@ -64,8 +64,8 @@ module.exports = function(config) {
         { type: "json", subdir: ".", file: "coverage.json" },
         { type: "lcovonly", subdir: ".", file: "lcov.info" },
         { type: "html", subdir: "html" },
-        { type: "cobertura", subdir: ".", file: "cobertura-coverage.xml" }
-      ]
+        { type: "cobertura", subdir: ".", file: "cobertura-coverage.xml" },
+      ],
     },
 
     junitReporter: {
@@ -75,7 +75,7 @@ module.exports = function(config) {
       useBrowserName: false, // add browser name to report and classes names
       nameFormatter: undefined, // function (browser, result) to customize the name attribute in xml testcase element
       classNameFormatter: undefined, // function (browser, result) to customize the classname attribute in xml testcase element
-      properties: {} // key value pair of properties to add to the <properties> section of the report
+      properties: {}, // key value pair of properties to add to the <properties> section of the report
     },
 
     // web server port
@@ -112,8 +112,8 @@ module.exports = function(config) {
       mocha: {
         // change Karma's debug.html to the mocha web reporter
         reporter: "html",
-        timeout: "600000"
-      }
-    }
+        timeout: "600000",
+      },
+    },
   });
 };

sdk/eventhub/event-hubs/package.json

@@ -171,7 +171,7 @@
     "mocha-junit-reporter": "^2.0.0",
     "moment": "^2.24.0",
     "nyc": "^15.0.0",
-    "prettier": "^1.16.4",
+    "prettier": "^2.5.1",
     "puppeteer": "^10.2.0",
     "rimraf": "^3.0.0",
     "rollup": "^1.16.3",

sdk/eventhub/event-hubs/rollup.test.config.js

@@ -28,32 +28,32 @@ function makeBrowserTestConfigPatch() {
       // browser only. Rollup's dead code elimination will remove
       // any code guarded by if (isNode) { ... }
       "if (isNode)": "if (false)",
-      "if (!isNode)": "if (true)"
+      "if (!isNode)": "if (true)",
     }),
     // fs, net, and tls are used by rhea and need to be shimmed
     // dotenv doesn't work in the browser, so replace it with a no-op function
     shim({
-      dotenv: `export function config() { }`
+      dotenv: `export function config() { }`,
     }),
     nodeResolve({
       mainFields: ["module", "browser"],
-      preferBuiltins: false
+      preferBuiltins: false,
     }),
     cjs({
       namedExports: {
-        chai: ["should", "assert"]
-      }
+        chai: ["should", "assert"],
+      },
     }),
     // rhea and rhea-promise use the Buffer global which requires
     // injection to shim properly
     inject({
       modules: {
         Buffer: ["buffer", "Buffer"],
-        process: "process"
+        process: "process",
       },
-      exclude: ["./**/package.json"]
+      exclude: ["./**/package.json"],
     }),
-    json()
+    json(),
   ];
 
   return config;

sdk/eventhub/event-hubs/samples-dev/iothubConnectionString.ts

@@ -95,13 +95,13 @@ async function convertIotHubToEventHubsConnectionString(connectionString: string
     username: `${SharedAccessKeyName}@sas.root.${iotHubName}`,
     port: 5671,
     reconnect: false,
-    password: token
+    password: token,
   });
   await connection.open();
 
   // Create the receiver that will trigger a redirect error.
   const receiver = await connection.createReceiver({
-    source: { address: `amqps://${HostName}/messages/events/$management` }
+    source: { address: `amqps://${HostName}/messages/events/$management` },
   });
 
   return new Promise((resolve, reject) => {
@@ -147,7 +147,7 @@ export async function main() {
       },
       processError: async (err, context) => {
         console.log(`Error on partition "${context.partitionId}" : ${err}`);
-      }
+      },
     },
     { startPosition: earliestEventPosition }
   );

sdk/eventhub/event-hubs/samples-dev/iothubConnectionStringWebsockets.ts

@@ -100,14 +100,14 @@ async function convertIotHubToEventHubsConnectionString(connectionString: string
     webSocketOptions: {
       webSocket: WebSocket,
       protocol: ["AMQPWSB10"],
-      url: `wss://${HostName}:${443}/$servicebus/websocket`
-    }
+      url: `wss://${HostName}:${443}/$servicebus/websocket`,
+    },
   });
   await connection.open();
 
   // Create the receiver that will trigger a redirect error.
   const receiver = await connection.createReceiver({
-    source: { address: `amqps://${HostName}/messages/events/$management` }
+    source: { address: `amqps://${HostName}/messages/events/$management` },
   });
 
   return new Promise((resolve, reject) => {
@@ -153,7 +153,7 @@ export async function main() {
       },
       processError: async (err, context) => {
         console.log(`Error on partition "${context.partitionId}" : ${err}`);
-      }
+      },
     },
     { startPosition: earliestEventPosition }
   );

sdk/eventhub/event-hubs/samples-dev/receiveEvents.ts

@@ -40,7 +40,7 @@ export async function main() {
       },
       processError: async (err, context) => {
         console.log(`Error on partition "${context.partitionId}": ${err}`);
-      }
+      },
     },
     { startPosition: earliestEventPosition }
   );

sdk/eventhub/event-hubs/samples-dev/websockets.ts

@@ -38,8 +38,8 @@ export async function main(): Promise<void> {
   const client = new EventHubConsumerClient(consumerGroup, connectionString, eventHubName, {
     webSocketOptions: {
       webSocket: WebSocket,
-      webSocketConstructorOptions: { agent: proxyAgent }
-    }
+      webSocketConstructorOptions: { agent: proxyAgent },
+    },
   });
   /*
    Refer to other samples, and place your code here to send/receive events

sdk/eventhub/event-hubs/src/batchingPartitionChannel.ts

@@ -7,7 +7,7 @@ import {
   EventDataBatch,
   EventHubBufferedProducerClientOptions,
   EventHubProducerClient,
-  OperationOptions
+  OperationOptions,
 } from "./index";
 import { isDefined, isObjectWithProperties } from "./util/typeGuards";
 import { AbortSignalLike } from "@azure/abort-controller";
@@ -47,7 +47,7 @@ export class BatchingPartitionChannel {
   private _flushState:
     | { isFlushing: false }
     | { isFlushing: true; currentPromise: Promise<void>; resolve: () => void } = {
-    isFlushing: false
+    isFlushing: false,
   };
   private _isRunning: boolean = false;
   private _lastBatchCreationTime: number = 0;
@@ -67,7 +67,7 @@ export class BatchingPartitionChannel {
     onSendEventsErrorHandler,
     onSendEventsSuccessHandler,
     partitionId,
-    producer
+    producer,
   }: BatchingPartitionChannelProps) {
     this._loopAbortSignal = loopAbortSignal;
     this._maxBufferSize = maxBufferSize;
@@ -242,7 +242,7 @@ export class BatchingPartitionChannel {
     this._lastBatchCreationTime = Date.now();
     this._batchedEvents = [];
     const batch = await this._producer.createBatch({
-      partitionId: this._partitionId
+      partitionId: this._partitionId,
     });
     this._incrementReadiness();
     return batch;
@@ -276,7 +276,7 @@ export class BatchingPartitionChannel {
     this._updateFlushState();
     this._onSendEventsSuccessHandler?.({
       events: this._batchedEvents,
-      partitionId: this._partitionId
+      partitionId: this._partitionId,
     }).catch((e) => {
       logger.error(
         `The following error occured in the onSendEventsSuccessHandler: ${JSON.stringify(
@@ -298,7 +298,7 @@ export class BatchingPartitionChannel {
     this._onSendEventsErrorHandler({
       error: err,
       events: event ? [event] : this._batchedEvents,
-      partitionId: this._partitionId
+      partitionId: this._partitionId,
     }).catch((e) => {
       logger.error(
         `The following error occured in the onSendEventsErrorHandler: ${JSON.stringify(