New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@cognite/sdk-beta

Package Overview
Dependencies
Maintainers
0
Versions
160
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@cognite/sdk-beta - npm Package Compare versions

Comparing version 5.11.6 to 5.12.0

222

dist/index.js

@@ -124,126 +124,4 @@ 'use strict';

var UploadAlreadyFinishedError = /** @class */ (function (_super) {
__extends(UploadAlreadyFinishedError, _super);
function UploadAlreadyFinishedError() {
return _super.call(this, 'Upload has already finished') || this;
}
return UploadAlreadyFinishedError;
}(Error));
var version="5.12.0";
var FilesMultipartUploadSessionAPI = /** @class */ (function (_super) {
__extends(FilesMultipartUploadSessionAPI, _super);
function FilesMultipartUploadSessionAPI() {
var _a;
var args = [];
for (var _i = 0; _i < arguments.length; _i++) {
args[_i] = arguments[_i];
}
var _this = _super.call(this, args[0], args[1], args[2]) || this;
_a = __read(args, 4), _this.multiPartFileUploadResponse = _a[3];
_this.uploadedUrls = _this.multiPartFileUploadResponse.uploadUrls.map(function () { return false; });
_this.finished = false;
return _this;
}
FilesMultipartUploadSessionAPI.prototype.uploadPart = function (partNumber, fileContent) {
return __awaiter(this, void 0, void 0, function () {
var hasFileContent, response;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
hasFileContent = fileContent != null;
if (!hasFileContent) {
throw Error('you are uploading an empty content');
}
if (partNumber < 0 ||
partNumber >= this.multiPartFileUploadResponse.uploadUrls.length) {
throw Error('part number is greater than the number of parts');
}
if (!this.canCompleteUpload()) return [3 /*break*/, 2];
return [4 /*yield*/, this.completeMultiPartUpload()];
case 1:
_a.sent();
return [2 /*return*/];
case 2:
if (this.alreadyUploadedPart(partNumber)) {
return [2 /*return*/];
}
if (this.multiPartFileUploadResponse.uploadUrls[partNumber] === null) {
throw Error('part number is not valid');
}
if (!(fileContent != null)) return [3 /*break*/, 7];
return [4 /*yield*/, this.put(this.multiPartFileUploadResponse.uploadUrls[partNumber], {
data: fileContent,
})];
case 3:
response = _a.sent();
if (!(response.status === 200 || response.status === 201)) return [3 /*break*/, 6];
this.uploadedUrls[partNumber] = true;
if (!this.canCompleteUpload()) return [3 /*break*/, 5];
return [4 /*yield*/, this.completeMultiPartUpload()];
case 4:
_a.sent();
_a.label = 5;
case 5: return [2 /*return*/, { partNumber: partNumber, status: response.status }];
case 6: return [2 /*return*/, { partNumber: partNumber, status: response.status }];
case 7: return [2 /*return*/];
}
});
});
};
FilesMultipartUploadSessionAPI.prototype.alreadyUploadedPart = function (partNumber) {
return this.uploadedUrls[partNumber];
};
FilesMultipartUploadSessionAPI.prototype.canCompleteUpload = function () {
return (this.uploadedUrls.length !== 0 && this.getNotCompletedParts().length === 0);
};
FilesMultipartUploadSessionAPI.prototype.completeMultiPartUpload = function () {
return __awaiter(this, void 0, void 0, function () {
var path, requestBody, response;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
if (this.finished) {
throw new UploadAlreadyFinishedError();
}
if (!this.canCompleteUpload()) {
return [2 /*return*/];
}
path = this.url('completemultipartupload');
requestBody = {
id: this.multiPartFileUploadResponse.id,
uploadId: this.multiPartFileUploadResponse.uploadId,
};
return [4 /*yield*/, this.post(path, {
data: requestBody,
})];
case 1:
response = _a.sent();
if (response.status !== 200) {
throw Error('upload cannot be completed');
}
this.finished = true;
return [2 /*return*/];
}
});
});
};
FilesMultipartUploadSessionAPI.prototype.getNotCompletedParts = function () {
return this.uploadedUrls.reduce(function (acc, curr, index) {
if (curr === false) {
acc.push(index);
}
return acc;
}, []);
};
FilesMultipartUploadSessionAPI.prototype.getMultiPartFileUploadId = function () {
return this.multiPartFileUploadResponse.uploadId;
};
FilesMultipartUploadSessionAPI.prototype.getFinished = function () {
return this.finished;
};
return FilesMultipartUploadSessionAPI;
}(sdkCore.BaseResourceAPI));
var version="5.11.6";
// Copyright 2022 Cognite AS

@@ -530,84 +408,2 @@ var ChannelsAPI = /** @class */ (function (_super) {

// Copyright 2020 Cognite AS
var MonitoringTaskModelExternalId = {
THRESHOLD: 'threshold',
DOUBLE_THRESHOLD: 'double_threshold',
};
var AlertStatus = {
FIRING: 'FIRING',
PENDING: 'PENDING',
};
var AlertSortProperty = {
CREATED_TIME: 'createdTime',
LAST_TRIGGERED_TIME: 'lastTriggeredTime',
};
// Copyright 2020 Cognite AS
var FilesAPI = /** @class */ (function (_super) {
__extends(FilesAPI, _super);
function FilesAPI() {
var _a;
var args = [];
for (var _i = 0; _i < arguments.length; _i++) {
args[_i] = arguments[_i];
}
var _this = _super.apply(this, __spread(args)) || this;
_this.limits = {
minimumNumberOfParts: 1,
maxNumberOfParts: 250,
};
_a = __read(args, 3), _this._baseUrl = _a[0], _this._client = _a[1], _this._map = _a[2];
return _this;
}
/**
* [Init a multipart file upload](https://api-docs.cognite.com/20230101/tag/Files/operation/initMultiPartUpload)
*
* ```js
* const numberOfParts = 5;
* // automatic upload:
* const multiPartUploadApi = await client.files.upload({name: 'examplefile.jpg', mimeType: 'image/jpeg'}, numberOfParts);
* ```
*/
FilesAPI.prototype.multipartUploadSession = function (fileInfo, parts, overwrite) {
if (overwrite === void 0) { overwrite = false; }
return __awaiter(this, void 0, void 0, function () {
var response, multipartUploadSession;
return __generator(this, function (_a) {
switch (_a.label) {
case 0: return [4 /*yield*/, this.getMultipartUploadSession(fileInfo, parts, overwrite)];
case 1:
response = _a.sent();
multipartUploadSession = new FilesMultipartUploadSessionAPI(this._baseUrl, this._client, this._map, response.data);
return [2 /*return*/, this.addToMapAndReturn(multipartUploadSession, response)];
}
});
});
};
FilesAPI.prototype.getMultipartUploadSession = function (fileInfo, parts, overwrite) {
if (overwrite === void 0) { overwrite = false; }
return __awaiter(this, void 0, void 0, function () {
var path, params, response;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
if (parts < this.limits.minimumNumberOfParts ||
parts > this.limits.maxNumberOfParts) {
throw Error('parts must be greater than 0 and less than 250');
}
path = this.url('initmultipartupload');
params = { overwrite: overwrite, parts: parts };
return [4 /*yield*/, this.post(path, {
params: params,
data: fileInfo,
})];
case 1:
response = _a.sent();
return [2 /*return*/, response];
}
});
});
};
return FilesAPI;
}(sdk.FilesAPI));
// Copyright 2023 Cognite AS

@@ -712,3 +508,2 @@ var MonitoringTasksAPI = /** @class */ (function (_super) {

this.alertsApi = this.apiFactory(AlertsAPI, 'alerts');
this.filesApi = this.apiFactory(FilesAPI, 'files');
this.monitoringTasksApi = this.apiFactory(MonitoringTasksAPI, 'monitoringtasks');

@@ -720,2 +515,16 @@ this.dataPointsApi = this.apiFactory(DataPointsAPI, 'timeseries/data');

// Copyright 2020 Cognite AS
var MonitoringTaskModelExternalId = {
THRESHOLD: 'threshold',
DOUBLE_THRESHOLD: 'double_threshold',
};
var AlertStatus = {
FIRING: 'FIRING',
PENDING: 'PENDING',
};
var AlertSortProperty = {
CREATED_TIME: 'createdTime',
LAST_TRIGGERED_TIME: 'lastTriggeredTime',
};
Object.keys(sdk).forEach(function (k) {

@@ -727,4 +536,3 @@ if (k !== 'default') exports[k] = sdk[k];

exports.CogniteClient = CogniteClient;
exports.FilesMultipartUploadSessionAPI = FilesMultipartUploadSessionAPI;
exports.MonitoringTaskModelExternalId = MonitoringTaskModelExternalId;
//# sourceMappingURL=index.js.map

4

dist/src/cogniteClient.d.ts
import { CogniteClient as CogniteClientStable } from '@cognite/sdk';
import { AlertsAPI } from './api/alerts/alertsApi';
import { DataPointsAPI } from './api/dataPoints/dataPointsApi';
import { FilesAPI } from './api/files/filesApi';
import { MonitoringTasksAPI } from './api/monitoringTasks/monitoringTasksApi';

@@ -27,6 +26,5 @@ declare class CogniteClientCleaned extends CogniteClientStable {

private alertsApi?;
protected filesApi?: FilesAPI;
private monitoringTasksApi?;
get alerts(): AlertsAPI;
get files(): FilesAPI;
get files(): import("@cognite/sdk/dist/src").FilesAPI;
get monitoringTasks(): MonitoringTasksAPI;

@@ -33,0 +31,0 @@ get datapoints(): DataPointsAPI;

export * from '@cognite/sdk';
export { FilesMultipartUploadSessionAPI } from './api/files/filesMultipartUploadSessionApi';
export { default as CogniteClient } from './cogniteClient';
export * from './types';
export { Aggregate, DatapointAggregate, DatapointAggregates, Datapoints, DatapointsMonthlyGranularityMultiQuery, DatapointsMultiQuery, DatapointsMultiQueryBase, DatapointsQuery, DatapointsQueryExternalId, DatapointsQueryId, DatapointsQueryProperties, DoubleDatapoint, DoubleDatapoints, StringDatapoint, StringDatapoints, } from './types';

@@ -1,2 +0,2 @@

import type { Aggregate as AggregateStable, DatapointsMultiQueryBase as DataPointsMultiQueryBaseStable, DatapointAggregate as DatapointAggregateStable, DatapointAggregates as DatapointAggregatesStable, DatapointsQueryProperties as DatapointsQueryPropertiesStable, DateRange, DoubleDatapoint as DoubleDatapointStable, DoubleDatapoints as DoubleDatapointsStable, FileInfo, Metadata, MetadataPatch, SinglePatchRequired, SinglePatchRequiredString, SinglePatchString, SortOrder, StringDatapoint as StringDatapointStable, StringDatapoints as StringDatapointsStable, Timestamp } from '@cognite/sdk';
import type { Aggregate as AggregateStable, DatapointsMultiQueryBase as DataPointsMultiQueryBaseStable, DatapointAggregate as DatapointAggregateStable, DatapointAggregates as DatapointAggregatesStable, DatapointsQueryProperties as DatapointsQueryPropertiesStable, DateRange, DoubleDatapoint as DoubleDatapointStable, DoubleDatapoints as DoubleDatapointsStable, Metadata, MetadataPatch, SinglePatchRequired, SinglePatchRequiredString, SinglePatchString, SortOrder, StringDatapoint as StringDatapointStable, StringDatapoints as StringDatapointsStable, Timestamp } from '@cognite/sdk';
import type { CogniteExternalId, CogniteInternalId, ExternalId, FilterQuery, InternalId } from '@cognite/sdk-core';

@@ -266,10 +266,2 @@ export * from '@cognite/sdk';

}
export interface MultiPartFileUploadResponse extends FileInfo {
uploadUrls: string[];
uploadId: string;
}
export interface MultiPartFileChunkResponse {
partNumber: number;
status: number;
}
export interface DatapointsMultiQuery extends DatapointsMultiQueryBase {

@@ -276,0 +268,0 @@ items: DatapointsQuery[];

@@ -8,3 +8,3 @@ {

"types": "dist/src/index.d.ts",
"version": "5.11.6",
"version": "5.12.0",
"scripts": {

@@ -25,3 +25,3 @@ "clean": "rm -rf dist/ docs/ codeSnippets/",

"dependencies": {
"@cognite/sdk": "^9.15.7",
"@cognite/sdk": "^9.16.0",
"@cognite/sdk-core": "^4.10.6"

@@ -35,3 +35,3 @@ },

},
"gitHead": "80869c9e704401fdd7aadbafc5426df1d8a45ca6"
"gitHead": "0b728eff9ec598a89037c91f4127f8180e945b51"
}

Sorry, the diff of this file is not supported yet

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