DigitalOcean Spaces

# สร้างโปรเจคใหม่
mkdir digitalocean-spaces-demo
cd digitalocean-spaces-demo
npm init -y

# ติดตั้ง AWS SDK v3 (S3 client)
npm install @aws-sdk/client-s3

# ติดตั้ง dotenv สำหรับ environment variables
npm install dotenv

# ติดตั้ง multer สำหรับ file upload (optional)
npm install multer

import { S3Client } from '@aws-sdk/client-s3';
import dotenv from 'dotenv';

dotenv.config();

const s3Client = new S3Client({
    forcePathStyle: false, // ใช้ subdomain/virtual calling
    region: 'us-east-1', // AWS region (ต้องใช้ us-east-1)
    endpoint: process.env.DO_SPACES_ENDPOINT,
    credentials: {
        accessKeyId: process.env.DO_SPACES_KEY,
        secretAccessKey: process.env.DO_SPACES_SECRET
    }
});

export default s3Client;

import { PutObjectCommand } from '@aws-sdk/client-s3';
import fs from 'fs';
import s3Client from './spaces-client.js';

async function uploadFile(localPath, remoteKey) {
    const fileContent = fs.readFileSync(localPath);

    const params = {
        Bucket: process.env.DO_SPACES_BUCKET,
        Key: remoteKey, // เช่น 'images/profile.jpg'
        Body: fileContent,
        ACL: 'public-read', // หรือ 'private'
        ContentType: 'image/jpeg' // MIME type
    };

    try {
        const data = await s3Client.send(new PutObjectCommand(params));
        console.log('✅ Upload successful!');
        console.log('File URL:', `https://${process.env.DO_SPACES_BUCKET}.sgp1.digitaloceanspaces.com/${remoteKey}`);
        return data;
    } catch (err) {
        console.error('❌ Upload error:', err);
        throw err;
    }
}

// ตัวอย่างการใช้งาน
uploadFile('./local-image.jpg', 'uploads/profile-2024.jpg');

import { GetObjectCommand } from '@aws-sdk/client-s3';
import fs from 'fs';
import s3Client from './spaces-client.js';

async function downloadFile(remoteKey, localPath) {
    const params = {
        Bucket: process.env.DO_SPACES_BUCKET,
        Key: remoteKey
    };

    try {
        const data = await s3Client.send(new GetObjectCommand(params));

        // แปลง stream เป็น buffer
        const chunks = [];
        for await (const chunk of data.Body) {
            chunks.push(chunk);
        }
        const buffer = Buffer.concat(chunks);

        // บันทึกไฟล์
        fs.writeFileSync(localPath, buffer);
        console.log(`✅ Downloaded: ${remoteKey} → ${localPath}`);
    } catch (err) {
        console.error('❌ Download error:', err);
        throw err;
    }
}

// ตัวอย่างการใช้งาน
downloadFile('uploads/profile-2024.jpg', './downloaded-image.jpg');

import { ListObjectsV2Command } from '@aws-sdk/client-s3';
import s3Client from './spaces-client.js';

async function listFiles(prefix = '') {
    const params = {
        Bucket: process.env.DO_SPACES_BUCKET,
        Prefix: prefix, // เช่น 'images/' เพื่อกรองเฉพาะโฟลเดอร์
        MaxKeys: 100
    };

    try {
        const data = await s3Client.send(new ListObjectsV2Command(params));

        console.log(`📁 Files in bucket (${data.KeyCount} items):`);

        data.Contents?.forEach(item => {
            const size = (item.Size / 1024).toFixed(2);
            console.log(`  - ${item.Key} (${size} KB)`);
        });

        return data.Contents;
    } catch (err) {
        console.error('❌ List error:', err);
        throw err;
    }
}

// ตัวอย่างการใช้งาน
listFiles('uploads/'); // แสดงไฟล์ในโฟลเดอร์ uploads

# ติดตั้ง boto3 (AWS SDK for Python)
pip install boto3 python-dotenv

import os
import boto3
from botocore.client import Config
from dotenv import load_dotenv

load_dotenv()

# สร้าง S3 client สำหรับ DigitalOcean Spaces
session = boto3.session.Session()

s3_client = session.client(
    's3',
    region_name=os.getenv('DO_SPACES_REGION'),
    endpoint_url=os.getenv('DO_SPACES_ENDPOINT'),
    aws_access_key_id=os.getenv('DO_SPACES_KEY'),
    aws_secret_access_key=os.getenv('DO_SPACES_SECRET'),
    config=Config(s3={'addressing_style': 'virtual'})
)

BUCKET_NAME = os.getenv('DO_SPACES_BUCKET')

import os
from spaces_client import s3_client, BUCKET_NAME

def upload_file(local_path, remote_key, public=True):
    """
    อัปโหลดไฟล์ไปยัง DigitalOcean Spaces

    Args:
        local_path: พาธไฟล์ในเครื่อง
        remote_key: ชื่อไฟล์บน Spaces (เช่น 'images/profile.jpg')
        public: True สำหรับ public-read, False สำหรับ private
    """
    extra_args = {
        'ContentType': 'image/jpeg'  # ปรับตามประเภทไฟล์
    }

    if public:
        extra_args['ACL'] = 'public-read'

    try:
        s3_client.upload_file(
            local_path,
            BUCKET_NAME,
            remote_key,
            ExtraArgs=extra_args
        )

        url = f"https://{BUCKET_NAME}.sgp1.digitaloceanspaces.com/{remote_key}"
        print(f"✅ Upload successful! URL: {url}")
        return url

    except Exception as e:
        print(f"❌ Upload error: {e}")
        raise

# ตัวอย่างการใช้งาน
if __name__ == "__main__":
    upload_file("./local-image.jpg", "uploads/profile.jpg")

from spaces_client import s3_client, BUCKET_NAME

def download_file(remote_key, local_path):
    """ดาวน์โหลดไฟล์จาก DigitalOcean Spaces"""
    try:
        s3_client.download_file(
            BUCKET_NAME,
            remote_key,
            local_path
        )
        print(f"✅ Downloaded: {remote_key} → {local_path}")

    except Exception as e:
        print(f"❌ Download error: {e}")
        raise

# ตัวอย่างการใช้งาน
download_file("uploads/profile.jpg", "./downloaded.jpg")

from spaces_client import s3_client, BUCKET_NAME

def list_files(prefix=''):
    """แสดงรายการไฟล์ใน bucket"""
    try:
        response = s3_client.list_objects_v2(
            Bucket=BUCKET_NAME,
            Prefix=prefix
        )

        print(f"📁 Files in bucket ({response['KeyCount']} items):")

        for obj in response.get('Contents', []):
            size_kb = obj['Size'] / 1024
            print(f"  - {obj['Key']} ({size_kb:.2f} KB)")

        return response.get('Contents', [])

    except Exception as e:
        print(f"❌ List error: {e}")
        raise

# ตัวอย่างการใช้งาน
list_files("uploads/")