@cognite/sdk-beta
Advanced tools
Comparing version 5.11.6 to 5.12.0
@@ -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 |
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
83109
14
950
Updated@cognite/sdk@^9.16.0