Aliyun OSS Node.js Client

import OSS from 'ali-oss';
import { readFileSync, unlinkSync, existsSync, writeFileSync } from 'fs';
import { join } from 'path';

async function runOssOperations() {
  const client = new OSS({
    region: process.env.ALI_OSS_REGION ?? 'oss-cn-hangzhou', // e.g., 'oss-cn-hangzhou'
    accessKeyId: process.env.ALI_OSS_AKID ?? 'YOUR_ACCESS_KEY_ID',
    accessKeySecret: process.env.ALI_OSS_AKSECRET ?? 'YOUR_ACCESS_KEY_SECRET',
    bucket: process.env.ALI_OSS_BUCKET ?? 'your-test-bucket', // Ensure this bucket exists
    secure: true, // Always use HTTPS for production
  });

  const objectName = `my-test-file-${Date.now()}.txt`;
  const localFilePath = join(process.cwd(), 'temp_test_file.txt');
  const fileContent = 'Hello, Alibaba Cloud OSS! This is a test file.\nAnother line of content.';

  // Create a dummy local file for upload
  writeFileSync(localFilePath, fileContent);
  console.log(`Created local file: ${localFilePath}`);

  try {
    // 1. Upload a file
    console.log(`Uploading ${objectName}...`);
    const putResult = await client.put(objectName, localFilePath);
    console.log('Upload successful. ETag:', putResult.etag, 'Status:', putResult.res.status);

    // 2. Download the file and verify content
    console.log(`Downloading ${objectName}...`);
    const getResult = await client.get(objectName);
    console.log('Download successful. Content:', getResult.content.toString());
    if (getResult.content.toString() === fileContent) {
      console.log('Content verification successful.');
    } else {
      console.warn('Downloaded content differs from original.');
    }

    // 3. List objects in the bucket
    console.log('Listing objects in bucket...');
    const listResult = await client.list({
      prefix: 'my-test-file-', // Filter for our test files
      'max-keys': 5,
    });
    console.log('Found objects:', listResult.objects.map(obj => obj.name));

    // 4. Get object metadata (head request)
    console.log(`Getting metadata for ${objectName}...`);
    const headResult = await client.head(objectName);
    console.log('Object metadata status:', headResult.res.status, 'Content-Length:', headResult.res.headers['content-length']);

    // 5. Delete the file
    console.log(`Deleting ${objectName}...`);
    const deleteResult = await client.delete(objectName);
    console.log('Delete successful. Status:', deleteResult.res.status);

  } catch (error: any) {
    console.error('OSS operation failed:', error.message);
    if (error.code === 'NoSuchBucket') {
      console.error('ERROR: Please ensure the bucket exists and you have correct region and permissions.');
    } else if (error.code === 'AccessDenied') {
      console.error('ERROR: Check your AccessKeyId, AccessKeySecret, and IAM permissions.');
    }
  } finally {
    // Clean up local file
    if (existsSync(localFilePath)) {
      unlinkSync(localFilePath);
      console.log(`Cleaned up local file: ${localFilePath}`);
    }
  }
}

runOssOperations();