Test

package.json

@@ -20,10 +20,10 @@
     "vscode": "^1.39.0"
   },
   "dependencies": {
-    "@azure/ms-rest-js": "^1.5.0",
+    "@azure/ms-rest-js": "^2.7.0",
     "applicationinsights": "^2.9.6",
     "args": "^5.0.1",
-    "axios": "^0.27.0",
+    "axios": "^0.30.0",
     "etag": "^1.8.1",
     "express": "^4.16.4",
     "fs-extra": "^11.1.1",
@@ -36,7 +36,7 @@
     "rimraf": "^3.0.2",
     "sequelize": "^6.31.0",
     "stoppable": "^1.1.0",
-    "tedious": "^16.7.0",
+    "tedious": "^18.6.1",
     "to-readable-stream": "^2.1.0",
     "tslib": "^2.3.0",
     "uri-templates": "^0.2.0",
@@ -48,8 +48,8 @@
     "@azure/core-auth": "^1.3.2",
     "@azure/core-rest-pipeline": "^1.2.0",
     "@azure/data-tables": "^13.0.1",
-    "@azure/storage-blob": "^12.9.0",
-    "@azure/storage-queue": "^12.8.0",
+    "@azure/storage-blob": "^12.28.0",
+    "@azure/storage-queue": "^12.27.0",
     "@types/args": "^5.0.0",
     "@types/async": "^3.0.1",
     "@types/bluebird": "^3.5.27",
@@ -73,7 +73,6 @@
     "@typescript-eslint/eslint-plugin": "^5.54.1",
     "@typescript-eslint/parser": "^5.54.1",
     "autorest": "^3.6.0",
-    "azure-storage": "^2.10.3",
     "cross-env": "^7.0.3",
     "cross-var": "^1.1.0",
     "eslint": "^8.35.0",
@@ -87,7 +86,8 @@
     "ts-mockito": "^2.6.1",
     "ts-node": "^10.0.0",
     "typescript": "^5.0.3",
-    "vsce": "^2.7.0"
+    "vsce": "^2.7.0",
+    "@azure/identity": "^4.2.1"
   },
   "activationEvents": [
     "onStartupFinished"

scripts/buildExe.js

@@ -47,7 +47,12 @@ async function downloadCache(pkgTarget) {
   const [nodeRange, platform, arch] = pkgTarget.split('-');
 
   await pkgFetch.need({ nodeRange, platform, arch });
-  const cacheExe = glob.sync(process.env.PKG_CACHE_PATH + "\\**\\fetched*");
+  const fetchedPattern = path.join(process.env.PKG_CACHE_PATH, '*', 'fetched*').replace(/\\/g, '/');
+  let cacheExe = glob.sync(fetchedPattern);
+  if (cacheExe.length < 1) {
+    const builtPattern = path.join(process.env.PKG_CACHE_PATH, '*', 'built*').replace(/\\/g, '/');
+    cacheExe = glob.sync(builtPattern);
+  }
   if (cacheExe.length < 1) {
     console.log('Error downloading PKG cache');
     process.exit(1);

src/blob/authentication/BlobSharedKeyAuthenticator.ts

@@ -13,7 +13,7 @@ export default class BlobSharedKeyAuthenticator implements IAuthenticator {
   public constructor(
     private readonly dataStore: IAccountDataStore,
     private readonly logger: ILogger
-  ) {}
+  ) { }
 
   public async validate(
     req: IRequest,
@@ -77,8 +77,8 @@ export default class BlobSharedKeyAuthenticator implements IAuthenticator {
     const stringToSign: string =
       [
         req.getMethod().toUpperCase(),
-        this.getHeaderValueToSign(req, HeaderConstants.CONTENT_ENCODING),
         this.getHeaderValueToSign(req, HeaderConstants.CONTENT_LANGUAGE),
+        this.getHeaderValueToSign(req, HeaderConstants.CONTENT_ENCODING),
         this.getHeaderValueToSign(req, HeaderConstants.CONTENT_LENGTH),
         this.getHeaderValueToSign(req, HeaderConstants.CONTENT_MD5),
         this.getHeaderValueToSign(req, HeaderConstants.CONTENT_TYPE),
@@ -137,10 +137,9 @@ export default class BlobSharedKeyAuthenticator implements IAuthenticator {
       }
     }
 
-    if (context.context.isSecondary && blobContext.authenticationPath?.indexOf(account) === 1)
-    {
-        // JS/.net Track2 SDK will generate stringToSign from IP style URI with "-secondary" in authenticationPath, so will also compare signature with this kind stringToSign
-        const stringToSign_secondary: string =
+    if (context.context.isSecondary && blobContext.authenticationPath?.indexOf(account) === 1) {
+      // JS/.net Track2 SDK will generate stringToSign from IP style URI with "-secondary" in authenticationPath, so will also compare signature with this kind stringToSign
+      const stringToSign_secondary: string =
         [
           req.getMethod().toUpperCase(),
           this.getHeaderValueToSign(req, HeaderConstants.CONTENT_ENCODING),
@@ -171,7 +170,7 @@ export default class BlobSharedKeyAuthenticator implements IAuthenticator {
         blobContext.contextId
       );
 
-      const signature1_secondary= computeHMACSHA256(stringToSign_secondary, accountProperties.key1);
+      const signature1_secondary = computeHMACSHA256(stringToSign_secondary, accountProperties.key1);
       const authValue1_secondary = `SharedKey ${account}:${signature1_secondary}`;
       this.logger.info(
         `BlobSharedKeyAuthenticator:validate() Calculated authentication header based on key1 and stringToSign with "-secondary": ${authValue1_secondary}`,

src/blob/generated/ExpressRequestAdapter.ts

@@ -3,7 +3,7 @@ import { Request } from 'express';
 import IRequest, { HttpMethod } from './IRequest';
 
 export default class ExpressRequestAdapter implements IRequest {
-  public constructor(private readonly req: Request) {}
+  public constructor(private readonly req: Request) { }
 
   public getMethod(): HttpMethod {
     return this.req.method.toUpperCase() as HttpMethod;
@@ -48,7 +48,13 @@ export default class ExpressRequestAdapter implements IRequest {
   }
 
   public getQuery(key: string): string | undefined {
-    return this.req.query[key];
+    const queryValue = this.req.query[key];
+    if ((typeof queryValue) === "string") {
+      return queryValue;
+    }
+    else {
+      return undefined;
+    }
   }
 
   public getProtocol(): string {

src/blob/generated/artifacts/parameters.ts

@@ -223,7 +223,6 @@ export const blobSequenceNumber: msRest.OperationParameter = {
   ],
   mapper: {
     serializedName: "x-ms-blob-sequence-number",
-    defaultValue: 0,
     type: {
       name: "Number"
     }

src/blob/generated/utils/xml.ts

@@ -2,8 +2,6 @@ import * as xml2js from 'xml2js';
 
 export function stringifyXML(obj: any, opts?: { rootName?: string }) {
   const builder = new xml2js.Builder({
-    explicitArray: false,
-    explicitCharkey: false,
     renderOpts: {
       pretty: false
     },
@@ -25,7 +23,7 @@ export function parseXML(
     emptyTag: undefined
   });
   return new Promise((resolve, reject) => {
-    xmlParser.parseString(str, (err?: Error, res?: any) => {
+    xmlParser.parseString(str, (err?: Error | null, res?: any) => {
       if (err) {
         reject(err);
       } else {

src/blob/handlers/AppendBlobHandler.ts

@@ -205,7 +205,7 @@ export default class AppendBlobHandler extends BaseHandler
       requestId: context.contextId,
       eTag: properties.etag,
       lastModified: properties.lastModified,
-      contentMD5: contentMD5Buffer,
+      contentMD5: contentMD5Buffer ? new Uint8Array(contentMD5Buffer) : undefined,
       xMsContentCrc64: undefined,
       clientRequestId: options.requestId,
       version: BLOB_API_VERSION,

src/blob/handlers/BlobBatchHandler.ts

@@ -266,7 +266,7 @@ export class BlobBatchHandler {
           return;
         }
 
-        buffer.fill(chunk, pos, pos + chunk.length);
+        buffer.fill(new Uint8Array(chunk), pos, pos + chunk.length);
         pos += chunk.length;
       });
 

src/blob/handlers/BlobBatchSubResponse.ts

@@ -74,11 +74,11 @@ export class BlobBatchSubResponse implements IResponse {
     return this.bodyStream;
   }
 
-  public getBodyContent(): string{
+  public getBodyContent(): string {
     return this.bodyStream.getBodyContent();
   }
 
-  public end(): void{
+  public end(): void {
     this.setStatusMessage(STATUS_CODES[this.statusCode!] || 'unknown');
   }
 }

src/blob/handlers/SubResponseTextBodyStream.ts

@@ -1,8 +1,7 @@
 import { Writable } from "stream";
 import { BlobBatchSubResponse } from "./BlobBatchSubResponse";
 
-export class SubResponseTextBodyStream extends Writable
-{
+export class SubResponseTextBodyStream extends Writable {
   private bodyText: string;
   public constructor(
     private readonly subResponse: BlobBatchSubResponse) {
@@ -15,12 +14,13 @@ export class SubResponseTextBodyStream extends Writable
     callback();
   }
 
-  public end(cb?: (() => void) | undefined): void;
-  public end(chunk: any, cb?: (() => void) | undefined): void;
-  public end(chunk: any, encoding: BufferEncoding, cb?: (() => void) | undefined): void;
-  public end(chunk?: unknown, encoding?: unknown, cb?: unknown): void {
+  public end(cb?: (() => void) | undefined): this;
+  public end(chunk: any, cb?: (() => void) | undefined): this;
+  public end(chunk: any, encoding: BufferEncoding, cb?: (() => void) | undefined): this;
+  public end(chunk?: unknown, encoding?: unknown, cb?: unknown): this {
     if (chunk) this.bodyText += (chunk! as any).toString();
     this.subResponse.end();
+    return this;
   }
 
   public getBodyContent(): string {

src/blob/main.ts

@@ -20,6 +20,7 @@ function shutdown(server: BlobServer | SqlBlobServer) {
   });
 }
 
+
 /**
  * Entry for Azurite blob service.
  */
@@ -45,9 +46,9 @@ async function main() {
   console.log(
     `Azurite Blob service successfully listens on ${server.getHttpServerAddress()}`
   );
-  
+
   const location = await env.location();
-  AzuriteTelemetryClient.init(location, !env.disableTelemetry(), env);  
+  AzuriteTelemetryClient.init(location, !env.disableTelemetry(), env);
   await AzuriteTelemetryClient.TraceStartEvent("Blob");
 
   // Handle close event

src/blob/persistence/LokiBlobMetadataStore.ts

@@ -1739,15 +1739,14 @@ export default class LokiBlobMetadataStore
     breakPeriod: number | undefined,
     options: Models.BlobBreakLeaseOptionalParams = {}
   ): Promise<BreakBlobLeaseResponse> {
+    await this.checkContainerExist(context, account, container);
     const coll = this.db.getCollection(this.BLOBS_COLLECTION);
-    const doc = await this.getBlobWithLeaseUpdated(
-      account,
-      container,
-      blob,
-      undefined,
-      context,
-      false
-    ); // This may return an uncommitted blob, or undefined for an nonexistent blob
+    const doc = coll.findOne({
+      name: blob,
+      accountName: account,
+      containerName: container,
+      snapshot: ""
+    });
 
     validateWriteConditions(context, options.modifiedAccessConditions, doc);
 
@@ -3113,12 +3112,8 @@ export default class LokiBlobMetadataStore
       return undefined;
     }
 
-    if (obj instanceof Uint8Array) {
-      return obj;
-    }
-
-    if (obj.type === "Buffer") {
-      obj = obj.data;
+    if (obj instanceof Buffer) {
+      return new Uint8Array(obj);
     }
 
     const length = Object.keys(obj).length;
@@ -3134,7 +3129,7 @@ export default class LokiBlobMetadataStore
       arr[i] = obj[i];
     }
 
-    return arr;
+    return new Uint8Array(arr);
   }
 
   /**