Merge branch 'main' into feature/servicebus-from-bytes-43979

Author: EldertGrootenboer

.github/CODEOWNERS

@@ -10,7 +10,7 @@
 
 # Core
 # PRLabel: %Core.Http
-/sdk/core/corehttp/                                                  @lmazuel @annatisch @johanste @iscai-msft @kashifkhan
+/sdk/core/corehttp/                                                  @lmazuel @johanste @iscai-msft @kashifkhan
 
 # AzureSdkOwners: @kashifkhan
 # ServiceLabel: %Core.Http
@@ -19,12 +19,12 @@
 # ServiceLabel: %Azure.Core
 
 # PRLabel: %Azure.Core
-/sdk/core/                                                           @lmazuel @annatisch @johanste
-/sdk/core/azure-core/                                                @lmazuel @annatisch @johanste @iscai-msft @kashifkhan
+/sdk/core/                                                           @lmazuel @johanste
+/sdk/core/azure-core/                                                @lmazuel @johanste @iscai-msft @kashifkhan
 /sdk/core/azure-mgmt-core/                                           @msyyc
 
 # Smoke Tests
-/common/smoketest/                                                   @lmazuel @chlowell @annatisch @mccoyp @shurd @southpolesteve
+/common/smoketest/                                                   @lmazuel @chlowell @mccoyp @shurd @southpolesteve
 
 ####################
 # Client Libraries
@@ -70,7 +70,7 @@
 
 # ServiceLabel: %Batch
 # PRLabel: %Batch
-/sdk/batch/    @cRui861 @dpwatrous @jingjlii @JJJessieWang @wanghoppe @wiboris
+/sdk/batch/    @cRui861 @dpwatrous @jingjlii @JJJessieWang @wanghoppe @wiboris @lilinvictorms @iwang2 @xingwu1
 
 # ServiceLabel: %Cognitive - Anomaly Detector
 # PRLabel: %Cognitive - Anomaly Detector
@@ -112,10 +112,10 @@
 /sdk/textanalytics/    @quentinRobinson @wangyuantao
 
 # PRLabel: %Cognitive - Translator
-/sdk/translation/    @jrjrguo @SG-MS
+/sdk/translation/    @jrjrguo @zhangeugenia
 
 # ServiceLabel: %Cognitive - Translator
-# ServiceOwners: @jrjrguo @SG-MS
+# ServiceOwners: @jrjrguo @zhangeugenia
 
 # ServiceLabel: %Communication
 # PRLabel: %Communication
@@ -235,7 +235,7 @@
 /sdk/durabletask/    @berndverst @cgillum @kaibocai @philliphoff @RyanLettieri @torosent
 
 # PRLabel: %EngSys
-/sdk/template/    @benbp @scbedd @danieljurek @weshaggard
+/sdk/template/    @benbp @mikeharder @danieljurek 
 
 # PRLabel: %Evaluation
 /sdk/evaluation/    @Azure/azure-sdk-write-evaluation
@@ -249,10 +249,10 @@
 /sdk/eventgrid/    @rajeshka @shankarsama
 
 # PRLabel: %Event Hubs
-/sdk/eventhub/    @axisc @hmlam @sjkwak
+/sdk/eventhub/    @axisc @hmlam @j7nw4r @SwayGom @sagar0207 @sjkwak
 
 # ServiceLabel: %Event Hubs
-# ServiceOwners: @axisc @hmlam @sjkwak
+# ServiceOwners: @axisc @hmlam @j7nw4r @SwayGom @sagar0207 @sjkwak
 
 # PRLabel: %Graph
 /sdk/graphrbac/    @lmazuel
@@ -753,7 +753,7 @@
 # ServiceOwners: @amber-yujueWang @rhurey @xitzhang @pankopon @emilyjiji
 
 # PRLabel: %Storage
-/sdk/storage/    @annatisch @jalauzon-msft @vincenttran-msft @weirongw23-msft
+/sdk/storage/    @jalauzon-msft @vincenttran-msft @weirongw23-msft
 
 # ServiceLabel: %Storage
 # ServiceOwners: @jalauzon-msft @vincenttran-msft
@@ -810,33 +810,33 @@
 ###########
 # Eng Sys and other
 ###########
-/eng/                                                                @scbedd @danieljurek @weshaggard @benbp
+/eng/                                                                @danieljurek @mikeharder @benbp
 /eng/common/                                                         @Azure/azure-sdk-eng
-/eng/tools/                                                          @scbedd @danieljurek @mccoyp
+/eng/tools/                                                          @danieljurek @mccoyp
 /.github/workflows/                                                  @Azure/azure-sdk-eng
 /.github/workflows/typespec-python-regenerate.yml                    @Azure/azure-sdk-eng @tadelesh @msyyc @iscai-msft @ChenxiJiang333
 /.github/CODEOWNERS                                                  @lmazuel @kashifkhan @Azure/azure-sdk-eng
 /.github/copilot-instructions.md                                     @l0lawrence @praveenkuttappan @maririos
 /.github/prompts/                                                    @mccoyp @l0lawrence @benbp
-/.github/skills/                                                     @mccoyp @l0lawrence @benbp
-/sdk/pullrequest.yml                                                 @scbedd @danieljurek @weshaggard @benbp
+/.github/skills/                                                     @mccoyp @l0lawrence @benbp @Azure/azsdk-cli
+/sdk/pullrequest.yml                                                 @danieljurek @mikeharder @benbp
 
-/.config/1espt/                                                      @benbp @weshaggard
-/.devcontainer/                                                      @scbedd @danieljurek @mccoyp @benbp @weshaggard
-/.vscode/                                                            @scbedd @danieljurek @mccoyp @benbp @weshaggard
+/.config/1espt/                                                      @benbp @mikeharder
+/.devcontainer/                                                      @danieljurek @mccoyp @benbp @mikeharder
+/.vscode/                                                            @danieljurek @mccoyp @benbp @mikeharder
 
-/scripts/                                                            @scbedd @danieljurek @mccoyp
+/scripts/                                                            @danieljurek @mccoyp
 /scripts/breaking_changes_checker/                                   @catalinaperalta
-/doc/                                                                @scbedd @danieljurek @Azure/azure-python-sdk
-/conda/                                                              @scbedd @danieljurek @lmazuel
+/doc/                                                                @danieljurek @Azure/azure-python-sdk
+/conda/                                                              @danieljurek @xiangyan99 @lmazuel
 
 /shared_requirements.txt                                             @azure/azure-sdk-eng @kashifkhan @xirzec
 
 # Add owners for notifications for specific pipelines
 /eng/pipelines/templates/jobs/tests-nightly-python.yml               @lmazuel @mccoyp
 /eng/pipelines/aggregate-reports.yml                                 @lmazuel @mccoyp
 /eng/common/pipelines/codeowners-linter.yml                          @lmazuel @mccoyp
-/eng/pipelines/docindex.yml                                          @danieljurek @scbedd @weshaggard @benbp
+/eng/pipelines/docindex.yml                                          @danieljurek @benbp
 
 # Add approvers for typespec-python emitter version updates
 /eng/emitter-package.json                                            @mccoyp @catalinaperalta @iscai-msft @msyyc @ChenxiJiang333
@@ -845,11 +845,11 @@
 # TypeSpec Python generated tests and regeneration workflow
 /eng/tools/emitter/                                                  @tadelesh @msyyc @iscai-msft @lmazuel @lirenhe @ChenxiJiang333
 
-/pylintrc                                                            @l0lawrence @scbedd @danieljurek @mccoyp
-/sdk/**/ci.yml                                                       @msyyc @lmazuel @scbedd @danieljurek
+/pylintrc                                                            @l0lawrence @danieljurek @mccoyp
+/sdk/**/ci.yml                                                       @msyyc @lmazuel @danieljurek
 
 # Add Johnathan Walker as code owner for Event Hubs SDK
-/sdk/eventhub/azure-eventhub/* @j7nw4r
+/sdk/eventhub/azure-eventhub/* @j7nw4r @SwayGom @sagar0207
 
 # Add Johnathan Walker as code owner for Service Bus SDK
-/sdk/servicebus/azure-servicebus/* @j7nw4r
+/sdk/servicebus/azure-servicebus/* @j7nw4r @SwayGom @sagar0207

.github/actionlint.yaml

@@ -0,0 +1,3 @@
+self-hosted-runner:
+  labels:
+    - 1ES.Pool=azsdk-pool-github-runners

.github/matchers/actionlint.json

@@ -0,0 +1,17 @@
+{
+  "problemMatcher": [
+    {
+      "owner": "actionlint",
+      "pattern": [
+        {
+          "regexp": "^(?:\\x1b\\[\\d+m)?(.+?)(?:\\x1b\\[\\d+m)*:(?:\\x1b\\[\\d+m)*(\\d+)(?:\\x1b\\[\\d+m)*:(?:\\x1b\\[\\d+m)*(\\d+)(?:\\x1b\\[\\d+m)*: (?:\\x1b\\[\\d+m)*(.+?)(?:\\x1b\\[\\d+m)* \\[(.+?)\\]$",
+          "file": 1,
+          "line": 2,
+          "column": 3,
+          "message": 4,
+          "code": 5
+        }
+      ]
+    }
+  ]
+}

.github/shared/README.md

@@ -0,0 +1,3 @@
+# `.github/shared`
+
+Copied from https://github.com/Azure/azure-rest-api-specs/tree/main/.github/shared

.github/shared/src/cache.js

@@ -0,0 +1,61 @@
+/**
+ * Caches values in memory with a single key of any type.
+ *
+ * @template K, V
+ */
+export class KeyedCache {
+  /** @type {Map<K, V>} */
+  #map = new Map();
+
+  /**
+   * Returns cached value, initializing if necessary
+   *
+   * @param {K} key
+   * @param {() => V} factory
+   * @returns {V} cached value
+   *
+   * @example
+   * const result = cache.getOrCreate(42, async () => await doWork(42));
+   */
+  getOrCreate(key, factory) {
+    let value = this.#map.get(key);
+
+    if (value === undefined) {
+      value = factory();
+      this.#map.set(key, value);
+    }
+
+    return value;
+  }
+}
+
+/**
+ * Caches values in memory with an ordered pair of keys of any types.
+ *
+ * @template K1, K2, V
+ */
+export class KeyedPairCache {
+  // Two-layer nested cache
+  /** @type {KeyedCache<K1, KeyedCache<K2, V>>} */
+  #cache1 = new KeyedCache();
+
+  /**
+   * Returns cached value, initializing if necessary.
+   * Keys are ordered, so (key1, key2) != (key2, key1).
+   *
+   * @param {K1} key1
+   * @param {K2} key2
+   * @param {() => V} factory
+   * @returns {V} cached value
+   *
+   * @example
+  * const result = cache.getOrCreate(42, 7, async () => await doWork(42, 7));
+   */
+  getOrCreate(key1, key2, factory) {
+    // key1 => cache for the next layer
+    const cache2 = this.#cache1.getOrCreate(key1, () => new KeyedCache());
+
+    // key2 => final value
+    return cache2.getOrCreate(key2, factory);
+  }
+}

.github/shared/src/exec.js

@@ -0,0 +1,152 @@
+import child_process from "child_process";
+import { dirname, join } from "path";
+import { promisify } from "util";
+const execFileImpl = promisify(child_process.execFile);
+
+/**
+ * @typedef {Object} ExecOptions
+ * @property {string} [cwd] Current working directory.  Default: process.cwd().
+ * @property {import('./logger.js').ILogger} [logger]
+ * @property {boolean} [logOutput] Log captured stdout/stderr at info level. Default: false.
+ * @property {number} [maxBuffer] Max bytes allowed on stdout or stderr.  Default: 16 * 1024 * 1024.
+ */
+
+/**
+ * @typedef {Object} NpmPrefixOptions
+ * @property {string} [prefix] Prefix to pass to npm via "--prefix".
+ */
+
+/**
+ * @typedef {ExecOptions & NpmPrefixOptions} ExecNpmOptions
+ */
+
+/**
+ * @typedef {Object} ExecResult
+ * @property {string} stdout
+ * @property {string} stderr
+ */
+
+/**
+ * @typedef {Error & { stdout?: string, stderr?: string, code?: number }} ExecError
+ */
+
+/**
+ * Checks whether an unknown error object is an ExecError.
+ * @param {unknown} error
+ * @returns {error is ExecError}
+ */
+export function isExecError(error) {
+  if (!(error instanceof Error)) return false;
+
+  const e = /** @type {ExecError} */ (error);
+  return typeof e.stdout === "string" || typeof e.stderr === "string";
+}
+
+/**
+ * Wraps `child_process.execFile()`, adding logging and a larger default maxBuffer.
+ *
+ * @param {string} file
+ * @param {string[]} [args]
+ * @param {ExecOptions} [options]
+ * @returns {Promise<ExecResult>}
+ * @throws {ExecError}
+ */
+export async function execFile(file, args, options = {}) {
+  const {
+    cwd,
+    logger,
+    logOutput = false,
+    // Node default is 1024 * 1024, which is too small for some git commands returning many entities or large file content.
+    // To support "git show", should be larger than the largest swagger file in the repo (2.5 MB as of 2/28/2025).
+    maxBuffer = 16 * 1024 * 1024,
+  } = options;
+
+  logger?.info(`execFile("${file}", ${JSON.stringify(args)})`);
+
+  try {
+    // execFile(file, args) is more secure than exec(cmd), since the latter is vulnerable to shell injection
+    const result = await execFileImpl(file, args, {
+      cwd,
+      maxBuffer,
+    });
+
+    logger?.debug(`stdout: '${result.stdout}'`);
+    logger?.debug(`stderr: '${result.stderr}'`);
+    if (logOutput) {
+      if (result.stdout) {
+        logger?.info(result.stdout.trimEnd());
+      }
+      if (result.stderr) {
+        logger?.info(result.stderr.trimEnd());
+      }
+    }
+
+    return result;
+  } catch (error) {
+    /* v8 ignore next */
+    logger?.debug(`error: '${JSON.stringify(error)}'`);
+    if (logOutput && isExecError(error)) {
+      if (error.stdout) {
+        logger?.info(error.stdout.trimEnd());
+      }
+      if (error.stderr) {
+        logger?.info(error.stderr.trimEnd());
+      }
+    }
+
+    throw error;
+  }
+}
+
+/**
+ * Calls `execFile()` with appropriate arguments to run `npm` on all platforms
+ *
+ * @param {string[]} args
+ * @param {ExecNpmOptions} [options]
+ * @returns {Promise<ExecResult>}
+ * @throws {ExecError}
+ */
+export async function execNpm(args, options = {}) {
+  const { prefix } = options;
+
+  // Exclude platform-specific code from coverage
+  /* v8 ignore start */
+  const { file, defaultArgs } =
+    process.platform === "win32"
+      ? {
+          // Only way I could find to run "npm" on Windows, without using the shell (e.g. "cmd /c npm ...")
+          //
+          // "node.exe", ["--", "npm-cli.js", ...args]
+          //
+          // The "--" MUST come BEFORE "npm-cli.js", to ensure args are sent to the script unchanged.
+          // If the "--" comes after "npm-cli.js", the args sent to the script will be ["--", ...args],
+          // which is NOT equivalent, and can break if args itself contains another "--".
+
+          // example: "C:\Program Files\nodejs\node.exe"
+          file: process.execPath,
+
+          // example: "C:\Program Files\nodejs\node_modules\npm\bin\npm-cli.js"
+          defaultArgs: [
+            "--",
+            join(dirname(process.execPath), "node_modules", "npm", "bin", "npm-cli.js"),
+          ],
+        }
+      : { file: "npm", defaultArgs: [] };
+  /* v8 ignore stop */
+
+  const prefixArgs = prefix ? ["--prefix", prefix] : [];
+
+  return await execFile(file, [...defaultArgs, ...prefixArgs, ...args], options);
+}
+
+/**
+ * Calls `execNpm()` with arguments ["exec", "--no", "--"] prepended.
+ *
+ * @param {string[]} args
+ * @param {ExecNpmOptions} [options]
+ * @returns {Promise<ExecResult>}
+ * @throws {ExecError}
+ */
+export async function execNpmExec(args, options = {}) {
+  return await execNpm(["exec", "--no", "--", ...args], options);
+}