tencent cloud

import { CredentialCallBack, QCloudCredential } from '@tencentcloud/cos';

export class Credential {
  /**
   * Obtain STS temporary keys
   */
  public static sessionCredential: CredentialCallBack = (request)=>{
    return new Promise((resolve, reject) => {
      // First, obtain a response containing key information from your temporary key server
      let httpRequest = http.createHttp();
      httpRequest.request(
        // Please replace it with the specific sts temporary key acquisition service url
        "http://127.0.0.1/sts",
        { method: http.RequestMethod.GET },
        (err: BusinessError, data: http.HttpResponse) => {
          if (!err) {
            const stsSessionQCloudCredentials: StsSessionQCloudCredentials = JSON.parse(data.result.toString());
            let credential : QCloudCredential= new QCloudCredential();
            credential.secretID = stsSessionQCloudCredentials.credentials.tmpSecretId;
            credential.secretKey = stsSessionQCloudCredentials.credentials.tmpSecretKey;
            credential.token = stsSessionQCloudCredentials.credentials.sessionToken;
            // It is recommended to use the server time as the signature start time to avoid request expiration caused by significant deviations in the user's local device time.
            // Both startDate and expirationDate are of type Date, constructed here using a millisecond timestamp,
            // The timestamp in the sts response is usually in seconds, so it needs to be multiplied by 1000. If your temporary key service returns timestamps in milliseconds, no multiplication by 1000 is required
            credential.startDate = new Date(stsSessionQCloudCredentials.startTime * 1000);
            credential.expirationDate = new Date(stsSessionQCloudCredentials.expiredTime * 1000);
            httpRequest.destroy();
            // Finally, return the temporary key information object
            resolve(credential);
          } else {
            httpRequest.destroy();
            reject(err);
          }
        });
    })
  }
}

/**
 * Temporary Key Entity Definition
 */
export class StsSessionQCloudCredentials{
  credentials: StsCredentials;
  startTime: number;
  expiredTime: number;

  constructor(credentials: StsCredentials, startTime: number, expiredTime: number) {
    this.credentials = credentials;
    this.startTime = startTime;
    this.expiredTime = expiredTime;
  }
}
export class StsCredentials{
  tmpSecretId: string;
  tmpSecretKey: string;
  sessionToken: string;

  constructor(tmpSecretId: string, tmpSecretKey: string, sessionToken: string) {
    this.tmpSecretId = tmpSecretId;
    this.tmpSecretKey = tmpSecretKey;
    this.sessionToken = sessionToken;
  }
}

// Define the server-side signature callback
let selfSignCallBack = async (request)=>{
  // First, obtain a response containing signature information from your server
  let httpRequest = http.createHttp();
  httpRequest.request(
    // Please replace it with the specific signature acquisition service url
    "http://127.0.0.1/sign",
    { method: http.RequestMethod.GET },
    (err: BusinessError, data: http.HttpResponse) => {
      if (!err) {
        // Obtain the signature information
        let signData: object = JSON.parse(data.result.toString());
        // Set the signature header for the request
        request.addHeader(HttpHeader.AUTHORIZATION, signData['authorization'])
        if(signData['securityToken']){
          request.addHeader("x-cos-security-token", signData['securityToken'])
        }
        httpRequest.destroy();
      } else {
        httpRequest.destroy();
      }
  });
}

// Obtain signature data (controlled by the business layer)
let authorization: string = "authorization";
let token: string = "token";
let tokenName: string = "x-cos-security-token";

import { CredentialCallBack, QCloudCredential } from '@tencentcloud/cos';

export class Credential {
  /**
   * Obtain fixed keys. Only used during testing.
   */
  public static constCredential: CredentialCallBack = (request)=>{
    return new Promise((resolve, reject) => {
      let credential : QCloudCredential= new QCloudCredential();

      // User's SecretId. It is recommended to use a sub-account key, with authorization following the least privilege guidelines to reduce usage risks. Sub-account key obtainment can be referred to https://www.tencentcloud.com/document/product/598/37140?from_cn_redirect=1
      credential.secretID = "SECRETID";
      // User's SecretKey. It is recommended to use a sub-account key, with authorization following the least privilege guidelines to reduce usage risks. Sub-account key obtainment can be referred to https://www.tencentcloud.com/document/product/598/37140?from_cn_redirect=1
      credential.secretKey = "SECRETKEY";
      resolve(credential);
    })
  }
}

import { CosXmlBaseService, CosXmlServiceConfig } from '@tencentcloud/cos';

// Service configuration
let cosXmlServiceConfig = new CosXmlServiceConfig("ap-guangzhou");
// Initialize the default Service
CosXmlBaseService.initDefaultService(
  this.context.getApplicationContext(),
  cosXmlServiceConfig,
  // The temporary key callback obtained in the first step "Initialize Key"
  Credential.sessionCredential
)

import { CosXmlBaseService, CosXmlServiceConfig } from '@tencentcloud/cos';

// Service configuration
let cosXmlServiceConfig = new CosXmlServiceConfig("ap-guangzhou");
// Initialize the default Service
CosXmlBaseService.initDefaultService(
  this.context.getApplicationContext(),
  cosXmlServiceConfig
)
// The server-side signature callback obtained in the first step "Initialize Key"
CosXmlBaseService.default().setSelfSignCallBack(selfSignCallBack);

import { CosXmlBaseService, PutObjectRequest, UploadTask } from '@tencentcloud/cos';

// Any CosXmlRequest supports this method, for example, upload PutObjectRequest, download GetObjectRequest, delete DeleteObjectRequest, etc.
// The following uses upload as an example
let putRequest = new PutObjectRequest("examplebucket-1250000000", "exampleobject.txt", "Local file path");
// authorization, token, and tokenName are the single-signature information obtained in the first step "Initialize Key"
putRequest.setSign(authorization, stoken, tokenName);
let task: UploadTask = CosXmlBaseService.default().upload(putRequest);
task.start();

// Service configuration
let cosXmlServiceConfig = new CosXmlServiceConfig("ap-guangzhou");
// Initialize the default Service
CosXmlBaseService.initDefaultService(
  this.context.getApplicationContext(),
  cosXmlServiceConfig,
  // The fixed key callback obtained in the first step "Initialize Key"
  Credential.constCredential
)

{
  "version": "2.0",
  "statement": [
    {
      "action": [
                //head operation 
                "name/cos:HeadObject",
                //Downloading operation
                "name/cos:GetObject",
      ],
      "effect": "allow",
      "resource": [
        "qcs::cos:ap-beijing:uid/1250000000:examplebucket-1250000000/doc/*"
      ]
    }
  ]
}

import { CosXmlBaseService, HttpProgress, GetObjectRequest, DownloadTask, CosError } from '@tencentcloud/cos';
import { CosXmlDownloadTaskResult } from '@tencentcloud/cos/src/main/ets/transfer/DownloadTask'

// Bucket name, which consists of bucketname-appid (appid must be included), can be viewed in the COS console. https://console.tencentcloud.com/cos5/bucket
let bucket = "examplebucket-1250000000";
//The location identifier of an object in a bucket, also known as the object key
let cosPath = "exampleobject.txt"; 
// Local file download path. If the file does not exist, the sdk will automatically create it.
let downliadPath = "Local file path"; 

let getRequest = new GetObjectRequest(bucket, cosPath, downliadPath);
let task: DownloadTask = CosXmlBaseService.default().download(getRequest);
// Download progress callback
task.onProgress = (progress: HttpProgress) => {
  // progress.complete indicates the currently downloaded size
  // progress.target is the total size
};
task.onResult = {
  // Download success callback
  onSuccess: (request, result: CosXmlDownloadTaskResult) => {
    // todo Logic after successful download
  },
  // Download failure callback
  onFail: (request, error: CosError) => {
    // todo Logic after download failure
  }
}
// Start download
task.start();
// Pause task
// task.pause();
// Resume task
// task.resume();
// Cancel task
// task.cancel();