///
import { ForgeClient, IAuthOptions, Region } from './common';
export interface IBucket {
bucketKey: string;
createdDate: number;
policyKey: string;
}
export interface IBucketPermission {
authId: string;
access: string;
}
export interface IBucketDetail extends IBucket {
bucketOwner: string;
permissions: IBucketPermission[];
}
export declare enum DataRetentionPolicy {
Transient = "transient",
Temporary = "temporary",
Persistent = "persistent"
}
export interface IUploadParams {
urls: string[];
uploadKey: string;
}
export interface IDownloadParams {
/** Indicates status of the object */
status: 'complete' | 'chunked' | 'fallback';
/** The S3 signed URL to download from. This attribute is returned when the value
* of the status attribute is complete or fallback (in which case the URL will be
* an OSS Signed URL instead of an S3 signed URL).
*/
url?: string;
/** A map of S3 signed URLs where each key correspond to a specific byte range chunk.
* This attribute is returned when the value of the status attribute is chunked.
*/
urls?: {
[range: string]: string;
};
/** The values for the updatable params that were used in the creation of the returned
* S3 signed URL (`Content-Type`, `Content-Disposition` & `Cache-Control`).
*/
params?: object;
/** The object size in bytes. */
size?: number;
/** The calculated SHA-1 hash of the object, if available. */
sha1?: string;
}
export interface IObject {
objectKey: string;
bucketKey: string;
objectId: string;
sha1: string;
size: number;
location: string;
}
export interface IResumableUploadRange {
start: number;
end: number;
}
export interface ISignedUrl {
signedUrl: string;
expiration: number;
singleUse: boolean;
}
export interface IUploadOptions {
contentType?: string;
progress?: (bytesUploaded: number, totalBytes?: number) => void;
}
export interface IDownloadOptions {
contentType?: string;
progress?: (bytesDownloaded: number, totalBytes?: number) => void;
}
/**
* Client providing access to Autodesk Forge {@link https://forge.autodesk.com/en/docs/data/v2|data management APIs}.
* @tutorial data-management
*/
export declare class DataManagementClient extends ForgeClient {
/**
* Initializes new client with specific authentication method.
* @param {IAuthOptions} auth Authentication object,
* containing either `client_id` and `client_secret` properties (for 2-legged authentication),
* or a single `token` property (for 2-legged or 3-legged authentication with pre-generated access token).
* @param {string} [host="https://developer.api.autodesk.com"] Forge API host.
* @param {Region} [region="US"] Forge availability region ("US" or "EMEA").
*/
constructor(auth: IAuthOptions, host?: string, region?: Region);
private _pager;
private _collect;
/**
* Iterates over all buckets in pages of predefined size
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-GET|docs}).
* @async
* @generator
* @param {number} [limit=16] Max number of buckets to receive in one batch (allowed values: 1-100).
* @yields {AsyncIterable} List of bucket object containing 'bucketKey', 'createdDate', and 'policyKey'.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
iterateBuckets(limit?: number): AsyncIterable;
/**
* Lists all buckets
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-GET|docs}).
* @async
* @returns {Promise} List of bucket objects.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
listBuckets(): Promise;
/**
* Gets details of a specific bucket
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-details-GET|docs}).
* @async
* @param {string} bucket Bucket key.
* @returns {Promise} Bucket details, with properties "bucketKey", "bucketOwner", "createdDate",
* "permissions", and "policyKey".
* @throws Error when the request fails, for example, due to insufficient rights, or when a bucket
* with this name does not exist.
*/
getBucketDetails(bucket: string): Promise;
/**
* Creates a new bucket
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-POST|docs}).
* @async
* @param {string} bucket Bucket key.
* @param {DataRetentionPolicy} dataRetention Data retention policy for objects uploaded to this bucket.
* @returns {Promise} Bucket details, with properties "bucketKey", "bucketOwner", "createdDate",
* "permissions", and "policyKey".
* @throws Error when the request fails, for example, due to insufficient rights, incorrect scopes,
* or when a bucket with this name already exists.
*/
createBucket(bucket: string, dataRetention: DataRetentionPolicy): Promise;
/**
* Iterates over all objects in a bucket in pages of predefined size
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-objects-GET|docs}).
* @async
* @generator
* @param {string} bucket Bucket key.
* @param {number} [limit=16] Max number of objects to receive in one batch (allowed values: 1-100).
* @param {string} [beginsWith] Optional filter to only return objects whose keys are prefixed with this value.
* @yields {AsyncIterable} List of object containing 'bucketKey', 'objectKey', 'objectId', 'sha1', 'size', and 'location'.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
iterateObjects(bucket: string, limit?: number, beginsWith?: string): AsyncIterable;
/**
* Lists all objects in a bucket
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-objects-GET|docs}).
* @async
* @param {string} bucket Bucket key.
* @param {string} [beginsWith] Optional filter to only return objects whose keys are prefixed with this value.
* @returns {Promise} List of object containing 'bucketKey', 'objectKey', 'objectId', 'sha1', 'size', and 'location'.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
listObjects(bucket: string, beginsWith?: string): Promise;
/**
* Generates one or more signed URLs that can be used to upload a file (or its parts) to OSS,
* and an upload key that is used to generate additional URLs or in {@see completeUpload}
* after all the parts have been uploaded successfully.
*
* The URLs are valid for 60min.
*
* Note that if you are uploading in multiple parts, each part except for the final one
* must be of size at least 5MB, otherwise the call to {@see completeUpload} will fail.
*
* @param {string} bucketKey Bucket key.
* @param {string} objectKey Object key.
* @param {number} [parts=1] How many URLs to generate in case of multi-part upload.
* @param {number} [firstPart=1] Index of the part the first returned URL should point to.
* For example, to upload parts 10 through 15 of a file, use `firstPart` = 10 and `parts` = 6.
* @param {string} [uploadKey] Optional upload key if this is a continuation of a previously
* initiated upload.
* @returns {IUploadParams} Signed URLs for uploading chunks of the file to AWS S3 (valid for 60min),
* and a unique upload key used to generate additional URLs or to complete the upload.
*/
getUploadUrls(bucketKey: string, objectKey: string, parts?: number, firstPart?: number, uploadKey?: string): Promise;
/**
* Finalizes the upload of a file to OSS.
* @param {string} bucketKey Bucket key.
* @param {string} objectKey Object key.
* @param {string} uploadKey Upload key returned by {@see getUploadUrls}.
* @param {string} [contentType] Optinal content type that should be recorded for the uploaded file.
* @returns {IObject} Details of the uploaded object in OSS.
*/
completeUpload(bucketKey: string, objectKey: string, uploadKey: string, contentType?: string): Promise;
/**
* Uploads content to a specific bucket object.
* @async
* @param {string} bucketKey Bucket key.
* @param {string} objectKey Name of uploaded object.
* @param {Buffer} data Object content.
* @param {IUploadOptions} [options] Additional upload options.
* @returns {Promise} Object description containing 'bucketKey', 'objectKey', 'objectId',
* 'sha1', 'size', 'location', and 'contentType'.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
uploadObject(bucketKey: string, objectKey: string, data: Buffer, options?: IUploadOptions): Promise;
/**
* Uploads content stream to a specific bucket object.
* @async
* @param {string} bucketKey Bucket key.
* @param {string} objectKey Name of uploaded object.
* @param {AsyncIterable} stream Input stream.
* @param {IUploadOptions} [options] Additional upload options.
* @returns {Promise} Object description containing 'bucketKey', 'objectKey', 'objectId',
* 'sha1', 'size', 'location', and 'contentType'.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
uploadObjectStream(bucketKey: string, objectKey: string, input: AsyncIterable, options?: IUploadOptions): Promise;
/**
* Generates a signed URL that can be used to download a file from OSS.
* @param bucketKey Bucket key.
* @param objectKey Object key.
* @returns {IDownloadParams} Download URLs and potentially other helpful information.
*/
getDownloadUrl(bucketKey: string, objectKey: string, useCdn?: boolean): Promise;
/**
* Downloads a specific OSS object.
* @async
* @param {string} bucketKey Bucket key.
* @param {string} objectKey Object key.
* @param {IDownloadOptions} [options] Additional download options.
* @returns {Promise} Object content.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
downloadObject(bucketKey: string, objectKey: string, options?: IDownloadOptions): Promise;
/**
* Downloads content stream of a specific bucket object.
* @async
* @param {string} bucketKey Bucket key.
* @param {string} objectKey Object name.
* @param {IDownloadOptions} [options] Additional download options.
* @returns {Promise} Object content stream.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
downloadObjectStream(bucketKey: string, objectKey: string, options?: IDownloadOptions): Promise;
/**
* @deprecated This method of resumable upload is now deprecated and will be removed in future versions.
* Use {@see getUploadUrls} and {@see completeUpload} instead.
*
* Uploads content to a specific bucket object using the resumable capabilities
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-objects-:objectName-resumable-PUT|docs}).
* @async
* @param {string} bucketKey Bucket key.
* @param {string} objectName Name of uploaded object.
* @param {Buffer} data Object content.
* @param {number} byteOffset Byte offset of the uploaded blob in the target object.
* @param {number} totalBytes Total byte size of the target object.
* @param {string} sessionId Resumable session ID.
* @param {string} [contentType='application/stream'] Type of content to be used in HTTP headers, for example, "application/json".
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
uploadObjectResumable(bucketKey: string, objectName: string, data: Buffer, byteOffset: number, totalBytes: number, sessionId: string, contentType?: string): Promise;
/**
* @deprecated This method of resumable upload is now deprecated and will be removed in future versions.
* Use {@see getUploadUrls} and {@see completeUpload} instead.
*
* Uploads content stream to a specific bucket object using the resumable capabilities
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-objects-:objectName-resumable-PUT|docs}).
* @async
* @param {string} bucketKey Bucket key.
* @param {string} objectName Name of uploaded object.
* @param {ReadableStream} stream Object content stream.
* @param {number} chunkBytes Byte size of the stream to be uploaded.
* @param {number} byteOffset Byte offset of the uploaded blob in the target object.
* @param {number} totalBytes Total byte size of the target object.
* @param {string} sessionId Resumable session ID.
* @param {string} [contentType='application/stream'] Type of content to be used in HTTP headers, for example, "application/json".
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
uploadObjectStreamResumable(bucketKey: string, objectName: string, stream: ReadableStream, chunkBytes: number, byteOffset: number, totalBytes: number, sessionId: string, contentType?: string): Promise;
/**
* @deprecated This method of resumable upload is now deprecated and will be removed in future versions.
* Use {@see getUploadUrls} and {@see completeUpload} instead.
*
* Gets status of a resumable upload session
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-objects-:objectName-status-:sessionId-GET|docs}).
* @async
* @param {string} bucketKey Bucket key.
* @param {string} objectName Name of uploaded object.
* @param {string} sessionId Resumable session ID.
* @returns {Promise} List of range objects, with each object specifying 'start' and 'end' byte offsets
* of data that has already been uploaded.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
getResumableUploadStatus(bucketKey: string, objectName: string, sessionId: string): Promise;
/**
* Makes a copy of object under another name within the same bucket
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-objects-:objectName-copyto-:newObjectName-PUT|docs}).
* @async
* @param {string} bucket Bucket key.
* @param {string} oldObjectKey Original object key.
* @param {string} newObjectKey New object key.
* @returns {Promise} Details of the new object copy.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
copyObject(bucket: string, oldObjectKey: string, newObjectKey: string): Promise;
/**
* Gets details of a specific bucket object
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-objects-:objectName-details-GET|docs}).
* @async
* @param {string} bucket Bucket key.
* @param {string} object Object name.
* @returns {Promise} Object description containing 'bucketKey', 'objectKey', 'objectId',
* 'sha1', 'size', 'location', and 'contentType'.
* @throws Error when the request fails, for example, due to insufficient rights, or when an object
* with this name does not exist.
*/
getObjectDetails(bucket: string, object: string): Promise;
/**
* Creates signed URL for specific object
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-objects-:objectName-signed-POST|docs}).
* @async
* @param {string} bucketId Bucket key.
* @param {string} objectId Object key.
* @param {string} [access="readwrite"] Signed URL access authorization.
* @param {boolean} [useCdn=true] If true, this will generate a CloudFront URL for the S3 object.
* @returns {Promise} Description of the new signed URL resource.
* @throws Error when the request fails, for example, due to insufficient rights.
*/
createSignedUrl(bucketId: string, objectId: string, access?: string, useCdn?: boolean): Promise;
/**
* Deletes object
* ({@link https://forge.autodesk.com/en/docs/data/v2/reference/http/buckets-:bucketKey-objects-:objectName-DELETE|docs}).
* @async
* @param {string} bucketKey Bucket key.
* @param {string} objectName Name of object to delete.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
deleteObject(bucketKey: string, objectName: string): Promise;
/**
* Deletes bucket (this endpoint is not documented on the Forge portal).
* @async
* @param {string} bucketKey Bucket key.
* @throws Error when the request fails, for example, due to insufficient rights, or incorrect scopes.
*/
deleteBucket(bucketKey: string): Promise;
}
//# sourceMappingURL=data-management.d.ts.map