Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@azure/storage-file-datalake

Package Overview
Dependencies
Maintainers
2
Versions
374
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@azure/storage-file-datalake - npm Package Compare versions

Comparing version 12.22.0-beta.1 to 12.22.0

dist-esm/storage-file-datalake/src/Pipeline.js

4

dist-esm/storage-common/src/PooledBuffer.js

@@ -7,4 +7,4 @@ // Copyright (c) Microsoft Corporation.

*/
// Can't use import as Typescript doesn't recognize "buffer".
const maxBufferLength = require("buffer").constants.MAX_LENGTH;
import buffer from "buffer";
const maxBufferLength = buffer.constants.MAX_LENGTH;
/**

@@ -11,0 +11,0 @@ * This class provides a buffer container which conceptually has no hard size limit.

@@ -5,3 +5,5 @@ // Copyright (c) Microsoft Corporation.

import { isNode } from "@azure/core-util";
import { AnonymousCredential, BlobClient, BlockBlobClient, newPipeline, Pipeline, } from "@azure/storage-blob";
import { isPipelineLike, newPipeline } from "./Pipeline";
import { BlobClient, BlockBlobClient } from "@azure/storage-blob";
import { AnonymousCredential } from "@azure/storage-blob";
import { StorageSharedKeyCredential } from "./credentials/StorageSharedKeyCredential";

@@ -92,3 +94,3 @@ import { BufferScheduler } from "../../storage-common/src";

options) {
if (credentialOrPipeline instanceof Pipeline) {
if (isPipelineLike(credentialOrPipeline)) {
super(url, credentialOrPipeline);

@@ -237,2 +239,5 @@ }

});
if (isTokenCredential(this.pipeline._credential)) {
this.isTokenCredential = true;
}
}

@@ -531,3 +536,3 @@ const paginated = recursive === true && this.isTokenCredential === true;

options) {
if (credentialOrPipeline instanceof Pipeline) {
if (isPipelineLike(credentialOrPipeline)) {
super(url, credentialOrPipeline);

@@ -956,3 +961,5 @@ }

return tracingClient.withSpan("DataLakeFileClient-readToFile", options, async (updatedOptions) => {
return this.blockBlobClientInternal.downloadToFile(filePath, offset, count, Object.assign(Object.assign({}, updatedOptions), { customerProvidedKey: toBlobCpkInfo(options.customerProvidedKey) }));
const rawResposne = await this.blockBlobClientInternal.downloadToFile(filePath, offset, count, Object.assign(Object.assign({}, updatedOptions), { customerProvidedKey: toBlobCpkInfo(options.customerProvidedKey) }));
const response = ParsePathGetPropertiesExtraHeaderValues(rawResposne);
return response;
});

@@ -959,0 +966,0 @@ }

import { __asyncDelegator, __asyncGenerator, __asyncValues, __await } from "tslib";
import { ContainerClient, AnonymousCredential, newPipeline, Pipeline, } from "@azure/storage-blob";
import { ContainerClient } from "@azure/storage-blob";
import { isPipelineLike, newPipeline } from "./Pipeline";
import { StorageSharedKeyCredential } from "./credentials/StorageSharedKeyCredential";
import { AnonymousCredential } from "@azure/storage-blob";
import { DataLakeLeaseClient } from "./DataLakeLeaseClient";

@@ -23,3 +25,3 @@ import { FileSystemOperationsImpl as FileSystem } from "./generated/src/operations";

options) {
if (credentialOrPipeline instanceof Pipeline) {
if (isPipelineLike(credentialOrPipeline)) {
super(url, credentialOrPipeline);

@@ -312,4 +314,4 @@ }

}
listItems(options = {}) {
return __asyncGenerator(this, arguments, function* listItems_1() {
listItems() {
return __asyncGenerator(this, arguments, function* listItems_1(options = {}) {
var _a, e_1, _b, _c;

@@ -333,4 +335,4 @@ try {

}
listSegments(continuation, options = {}) {
return __asyncGenerator(this, arguments, function* listSegments_1() {
listSegments(continuation_1) {
return __asyncGenerator(this, arguments, function* listSegments_1(continuation, options = {}) {
let response;

@@ -443,4 +445,4 @@ if (!!continuation || continuation === undefined) {

}
listDeletedItems(options = {}) {
return __asyncGenerator(this, arguments, function* listDeletedItems_1() {
listDeletedItems() {
return __asyncGenerator(this, arguments, function* listDeletedItems_1(options = {}) {
var _a, e_2, _b, _c;

@@ -464,4 +466,4 @@ try {

}
listDeletedSegments(continuation, options = {}) {
return __asyncGenerator(this, arguments, function* listDeletedSegments_1() {
listDeletedSegments(continuation_1) {
return __asyncGenerator(this, arguments, function* listDeletedSegments_1(continuation, options = {}) {
let response;

@@ -468,0 +470,0 @@ if (!!continuation || continuation === undefined) {

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
import "@azure/core-paging";
import { getDefaultProxySettings } from "@azure/core-rest-pipeline";
import { isNode } from "@azure/core-util";
import { AnonymousCredential, BlobServiceClient, Pipeline, newPipeline, } from "@azure/storage-blob";
import { BlobServiceClient, } from "@azure/storage-blob";
import { isPipelineLike, newPipeline } from "./Pipeline";
import { AnonymousCredential } from "@azure/storage-blob";
import { StorageSharedKeyCredential } from "./credentials/StorageSharedKeyCredential";

@@ -67,3 +68,3 @@ import { DataLakeFileSystemClient } from "./DataLakeFileSystemClient";

options) {
if (credentialOrPipeline instanceof Pipeline) {
if (isPipelineLike(credentialOrPipeline)) {
super(url, credentialOrPipeline);

@@ -70,0 +71,0 @@ }

@@ -101,3 +101,3 @@ /*

mapper: {
defaultValue: "2023-08-03",
defaultValue: "2024-05-04",
isConstant: true,

@@ -104,0 +104,0 @@ serializedName: "x-ms-version",

@@ -29,3 +29,3 @@ /*

};
const packageDetails = `azsdk-js-azure-storage-datalake/12.22.0-beta.1`;
const packageDetails = `azsdk-js-azure-storage-datalake/12.22.0`;
const userAgentPrefix = options.userAgentOptions && options.userAgentOptions.userAgentPrefix

@@ -32,0 +32,0 @@ ? `${options.userAgentOptions.userAgentPrefix} ${packageDetails}`

@@ -9,3 +9,4 @@ // Copyright (c) Microsoft Corporation.

export * from "./utils/DataLakeAclChangeFailedError";
export { Pipeline, newPipeline, AnonymousCredential, Credential, AnonymousCredentialPolicy, CredentialPolicy, StorageBrowserPolicy, StorageBrowserPolicyFactory, StorageRetryPolicy, StorageRetryPolicyFactory, } from "@azure/storage-blob";
export { Pipeline, isPipelineLike, newPipeline, StorageOAuthScopes, } from "./Pipeline";
export { AnonymousCredential, AnonymousCredentialPolicy, Credential, CredentialPolicy, StorageBrowserPolicy, StorageBrowserPolicyFactory, StorageRetryPolicy, StorageRetryPolicyType, StorageRetryPolicyFactory, } from "@azure/storage-blob";
export { ToBlobEndpointHostMappings, ToDfsEndpointHostMappings } from "./utils/constants";

@@ -12,0 +13,0 @@ export { RestError } from "@azure/core-rest-pipeline";

@@ -17,3 +17,4 @@ // Copyright (c) Microsoft Corporation.

export * from "./utils/DataLakeAclChangeFailedError";
export { Pipeline, newPipeline, BaseRequestPolicy, StorageOAuthScopes, AnonymousCredential, Credential, StorageSharedKeyCredential, AnonymousCredentialPolicy, CredentialPolicy, StorageBrowserPolicy, StorageBrowserPolicyFactory, StorageRetryPolicy, StorageRetryPolicyFactory, StorageSharedKeyCredentialPolicy, } from "@azure/storage-blob";
export { Pipeline, isPipelineLike, newPipeline, StorageOAuthScopes, } from "./Pipeline";
export { AnonymousCredential, AnonymousCredentialPolicy, BaseRequestPolicy, CredentialPolicy, Credential, StorageRetryPolicy, StorageRetryPolicyType, StorageRetryPolicyFactory, StorageBrowserPolicy, StorageBrowserPolicyFactory, StorageSharedKeyCredential, StorageSharedKeyCredentialPolicy, } from "@azure/storage-blob";
export { ToBlobEndpointHostMappings, ToDfsEndpointHostMappings } from "./utils/constants";

@@ -20,0 +21,0 @@ export { RestError } from "@azure/core-rest-pipeline";

@@ -32,2 +32,18 @@ // Keeping these for backward compatibility when we changed to use string unions.

})(PathResourceType || (PathResourceType = {}));
/**
* Defines the known cloud audiences for Storage.
*/
export var StorageDataLakeAudience;
(function (StorageDataLakeAudience) {
/**
* The OAuth scope to use to retrieve an AAD token for Azure Storage.
*/
StorageDataLakeAudience["StorageOAuthScopes"] = "https://storage.azure.com/.default";
})(StorageDataLakeAudience || (StorageDataLakeAudience = {}));
/**
* To get OAuth audience for a storage account for datalake service.
*/
export function getDataLakeServiceAccountAudience(storageAccountName) {
return `https://${storageAccountName}.dfs.core.windows.net/.default`;
}
/** *********************************************************/

@@ -34,0 +50,0 @@ /** DataLakeLeaseClient option and response related models */

@@ -42,3 +42,3 @@ // Copyright (c) Microsoft Corporation.

version,
accountSASSignatureValues.encryptionScope ? accountSASSignatureValues.encryptionScope : "",
accountSASSignatureValues.encryptionScope ? accountSASSignatureValues.encryptionScope : "", // Reserve for encryption scope
"", // Account SAS requires an additional newline character

@@ -45,0 +45,0 @@ ].join("\n");

@@ -121,8 +121,8 @@ import { ipRangeToString } from "./SasIPRange";

"ses",
"skoid",
"sktid",
"skt",
"ske",
"sks",
"skv",
"skoid", // Signed object ID
"sktid", // Signed tenant ID
"skt", // Signed key start time
"ske", // Signed key expiry time
"sks", // Signed key service
"skv", // Signed key version
"sr",

@@ -129,0 +129,0 @@ "sp",

import { __rest } from "tslib";
import { StorageContextClient } from "./StorageContextClient";
import { BlobServiceClient, } from "@azure/storage-blob";
import { BlobServiceClient } from "@azure/storage-blob";
import { toBlobEndpointUrl, toDfsEndpointUrl } from "./transforms";

@@ -17,3 +17,3 @@ import { escapeURLPath, getAccountNameFromUrl, getURLScheme, iEqual } from "./utils/utils.common";

}
return Object.assign(Object.assign({}, restOptions), { httpClient, pipeline: corePipeline });
return Object.assign(Object.assign({}, restOptions), { allowInsecureConnection: true, httpClient, pipeline: corePipeline });
}

@@ -20,0 +20,0 @@ /**

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
export const SDK_VERSION = "12.22.0-beta.1";
export const SERVICE_VERSION = "2023-08-03";
export const SDK_VERSION = "12.22.0";
export const SERVICE_VERSION = "2024-05-04";
export const KB = 1024;

@@ -15,2 +15,5 @@ export const MB = KB * 1024;

export const FILE_MAX_SIZE_BYTES = BLOCK_BLOB_MAX_BLOCKS * FILE_UPLOAD_MAX_CHUNK_SIZE;
/**
* The OAuth scope to use with Azure Storage.
*/
export const StorageOAuthScopes = "https://storage.azure.com/.default";

@@ -17,0 +20,0 @@ export const StorageDataLakeLoggingAllowedHeaderNames = [

@@ -6,3 +6,3 @@ // Copyright (c) Microsoft Corporation.

import { DevelopmentConnectionString, EncryptionAlgorithmAES25, HeaderConstants, PathStylePorts, UrlConstants, } from "./constants";
import { toPermissions } from "../transforms";
import { toAcl, toPermissions } from "../transforms";
/**

@@ -556,2 +556,3 @@ * Reserved URL characters must be properly escaped for Storage services like Blob or File.

response.permissions = toPermissions(ParseHeaderValue(rawResponse, "x-ms-permissions"));
response.acl = toAcl(ParseHeaderValue(rawResponse, "x-ms-acl"));
if ((_a = response._response) === null || _a === void 0 ? void 0 : _a.parsedHeaders) {

@@ -562,2 +563,3 @@ response._response.parsedHeaders.encryptionContext = response.encryptionContext;

response._response.parsedHeaders.permissions = response.permissions;
response._response.parsedHeaders.acl = response.acl;
}

@@ -564,0 +566,0 @@ return response;

{
"name": "@azure/storage-file-datalake",
"version": "12.22.0-beta.1",
"version": "12.22.0",
"description": "Microsoft Azure Storage SDK for JavaScript - DataLake",

@@ -9,11 +9,5 @@ "sdk-type": "client",

"types": "./types/latest/storage-file-datalake.d.ts",
"typesVersions": {
"<3.6": {
"*": [
"./types/3.1/storage-file-datalake.d.ts"
]
}
},
"browser": {
"./dist-esm/storage-file-datalake/src/index.js": "./dist-esm/storage-file-datalake/src/index.browser.js",
"./dist-esm/storage-blob/src/policies/StorageSharedKeyCredentialPolicyV2.js": "./dist-esm/storage-blob/src/policies/StorageSharedKeyCredentialPolicyV2.browser.js",
"./dist-esm/storage-file-datalake/src/credentials/StorageSharedKeyCredential.js": "./dist-esm/storage-file-datalake/src/credentials/StorageSharedKeyCredential.browser.js",

@@ -40,11 +34,10 @@ "./dist-esm/storage-file-datalake/src/credentials/UserDelegationKeyCredential.js": "./dist-esm/storage-file-datalake/src/credentials/UserDelegationKeyCredential.browser.js",

"build:test": "tsc -p . && dev-tool run bundle",
"build:types": "downlevel-dts types/latest types/3.1",
"build": "npm run clean && tsc -p . && dev-tool run bundle && api-extractor run --local && npm run build:types",
"build": "npm run clean && tsc -p . && dev-tool run bundle && dev-tool run extract-api",
"build:samples": "echo Obsolete.",
"check-format": "prettier --list-different --config ../../../.prettierrc.json --ignore-path ../../../.prettierignore \"src/**/*.ts\" \"test/**/*.ts\" \"samples-dev/**/*.ts\" \"*.{js,json}\"",
"clean": "rimraf dist dist-* types temp statistics.html coverage coverage-browser .nyc_output *.tgz *.log test*.xml TEST*.xml",
"check-format": "dev-tool run vendored prettier --list-different --config ../../../.prettierrc.json --ignore-path ../../../.prettierignore \"src/**/*.ts\" \"test/**/*.ts\" \"samples-dev/**/*.ts\" \"*.{js,json}\"",
"clean": "rimraf --glob dist dist-* types temp statistics.html coverage coverage-browser .nyc_output *.tgz *.log test*.xml TEST*.xml",
"clean:samples": "rimraf samples/v12/javascript/node_modules samples/v12/typescript/node_modules samples/v12/typescript/dist samples/v12/typescript/package-lock.json samples/v12/javascript/package-lock.json",
"extract-api": "tsc -p . && api-extractor run --local",
"extract-api": "tsc -p . && dev-tool run extract-api",
"execute:samples": "dev-tool samples run samples-dev",
"format": "prettier --write --config ../../../.prettierrc.json --ignore-path ../../../.prettierignore \"src/**/*.ts\" \"test/**/*.ts\" \"samples-dev/**/*.ts\" \"*.{js,json}\"",
"format": "dev-tool run vendored prettier --write --config ../../../.prettierrc.json --ignore-path ../../../.prettierignore \"src/**/*.ts\" \"test/**/*.ts\" \"samples-dev/**/*.ts\" \"*.{js,json}\"",
"generate:client": "autorest --typescript ./swagger/README.md",

@@ -70,3 +63,2 @@ "integration-test:browser": "dev-tool run test:browser",

"types/latest/storage-file-datalake.d.ts",
"types/3.1/storage-file-datalake.d.ts",
"README.md",

@@ -130,5 +122,6 @@ "LICENSE"

"@azure/core-tracing": "^1.0.0",
"@azure/core-xml": "^1.3.2",
"@azure/core-util": "^1.1.1",
"@azure/logger": "^1.0.0",
"@azure/storage-blob": "^12.23.0-beta.1",
"@azure/storage-blob": "^12.23.0",
"events": "^3.0.0",

@@ -140,7 +133,7 @@ "tslib": "^2.2.0"

"@azure/eslint-plugin-azure-sdk": "^3.0.0",
"@azure/identity": "^3.3.0",
"@azure/test-utils": "^1.0.0",
"@azure/identity": "^4.0.1",
"@azure-tools/test-utils": "^1.0.1",
"@azure-tools/test-credential": "^1.0.0",
"@azure-tools/test-recorder": "^3.0.0",
"@azure/test-utils-perf": "^1.0.0",
"@azure-tools/test-perf": "^1.0.0",
"@microsoft/api-extractor": "^7.31.1",

@@ -150,10 +143,8 @@ "@types/chai": "^4.1.6",

"@types/node": "^18.0.0",
"@types/sinon": "^10.0.0",
"@types/sinon": "^17.0.0",
"chai": "^4.2.0",
"cross-env": "^7.0.2",
"dotenv": "^16.0.0",
"downlevel-dts": "^0.10.0",
"es6-promise": "^4.2.5",
"eslint": "^8.0.0",
"esm": "^3.2.18",
"execa": "^6.0.0",

@@ -172,13 +163,11 @@ "inherits": "^2.0.3",

"mocha": "^10.0.0",
"mocha-junit-reporter": "^2.0.0",
"c8": "^8.0.0",
"prettier": "^2.5.1",
"puppeteer": "^19.2.2",
"rimraf": "^3.0.0",
"sinon": "^15.0.0",
"nyc": "^15.1.0",
"puppeteer": "^22.2.0",
"rimraf": "^5.0.5",
"sinon": "^17.0.0",
"source-map-support": "^0.5.9",
"ts-node": "^10.0.0",
"typescript": "~5.2.0",
"typescript": "~5.4.5",
"util": "^0.12.1"
}
}

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is too big to display

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc