اتصال به فضای ذخیره‌سازی ابری در برنامه‌های NodeJS

npm install @aws-sdk/client-s3

LIARA_ENDPOINT=https://<Liara Bucket Endpoint>
LIARA_BUCKET_NAME=<Bucket Name>
LIARA_ACCESS_KEY=<Access Key>
LIARA_SECRET_KEY=<Secret Key>

const { S3Client, PutObjectCommand } = require("@aws-sdk/client-s3");
require("dotenv").config();

const client = new S3Client({
  region: "default",
endpoint: process.env.LIARA_ENDPOINT,
credentials: {
	accessKeyId: process.env.LIARA_ACCESS_KEY,
	secretAccessKey: process.env.LIARA_SECRET_KEY
},
});

const params = {
Body: "<Binary String>",
Bucket: process.env.LIARA_BUCKET_NAME,
Key: "objectkey",
};

// async/await
try {
await client.send(new PutObjectCommand(params));
} catch (error) {
console.log(error);
}

// callback
client.send(new PutObjectCommand(params), (error, data) => {
if (error) {
  console.log(error);
} else {
  console.log(data);
}
});

const { S3Client, GetObjectCommand } = require("@aws-sdk/client-s3");
require("dotenv").config();

const client = new S3Client({
  region: "default",
endpoint: process.env.LIARA_ENDPOINT,
credentials: {
	accessKeyId: process.env.LIARA_ACCESS_KEY,
	secretAccessKey: process.env.LIARA_SECRET_KEY
},
});
const params = {
Bucket: process.env(LIARA_BUCKET_NAME),
Key: "objectkey"
};

// async/await
try {
const data = await client.send(new GetObjectCommand(params));
console.log(data.Body.toString());
} catch (error) {
console.log(error);
}

// callback
client.send(new GetObjectCommand(params), (error, data) => {
if (error) {
  console.log(error);
} else {
  console.log(data.Body.toString());
}
});

const { S3Client, GetObjectCommand } = require("@aws-sdk/client-s3");
const { getSignedUrl } = require("@aws-sdk/s3-request-presigner");
require("dotenv").config();

const filename = "example_filename.png"; // change this to your filename

const client = new S3Client({
region: "default",
endpoint: process.env.LIARA_ENDPOINT,
credentials: {
  accessKeyId: process.env.LIARA_ACCESS_KEY,
  secretAccessKey: process.env.LIARA_SECRET_KEY,
},
});
const params = {
Bucket: process.env.LIARA_BUCKET_NAME,
Key: filename,
};

const command = new GetObjectCommand(params);
getSignedUrl(client, command).then((url) => console.log(url));

const { S3Client, GetObjectCommand } = require("@aws-sdk/client-s3");
const { getSignedUrl } = require("@aws-sdk/s3-request-presigner");
require("dotenv").config();

const client = new S3Client({
region: "default",
endpoint: process.env.LIARA_ENDPOINT,
requestChecksumCalculation: "WHEN_REQUIRED",
responseChecksumValidation: "WHEN_REQUIRED",
credentials: {
  accessKeyId: process.env.LIARA_ACCESS_KEY,
  secretAccessKey: process.env.LIARA_SECRET_KEY,
},
});

async function main() {
const signed = await getSignedUrl(
  client,
  new GetObjectCommand({
    Bucket: process.env.LIARA_BUCKET_NAME,
    Key: "example_filename.png", // change this to your filename
  }),
  { expiresIn: 3600 }
);

const url = new URL(signed);
url.host = "example.com"; // change this to your custom domain

console.log(url.toString());
}

main();

const { S3Client, ListObjectsV2Command } = require("@aws-sdk/client-s3");
require("dotenv").config();

const client = new S3Client({
  region: "default",
endpoint: process.env.LIARA_ENDPOINT,
credentials: {
	accessKeyId: process.env.LIARA_ACCESS_KEY,
	secretAccessKey: process.env.LIARA_SECRET_KEY
},
});

const params = {
Bucket: process.env.LIARA_BUCKET_NAME
};

// async/await
try {
const data = await client.send(new ListObjectsV2Command(params));
const files = data.Contents.map((file) => file.Key);
console.log(files);
} catch (error) {
console.log(error);
}

// callback
client.send(new ListObjectsV2Command(params), (error, data) => {
if (error) {
  console.log(error);
} else {
  const files = data.Contents.map((file) => file.Key);
  console.log(files);
}
});

const { S3Client, DeleteObjectCommand } = require("@aws-sdk/client-s3");
require("dotenv").config();

const client = new S3Client({
  region: "default",
endpoint: process.env.LIARA_ENDPOINT,
credentials: {
	accessKeyId: process.env.LIARA_ACCESS_KEY,
	secretAccessKey: process.env.LIARA_SECRET_KEY
},
});

const params = {
Bucket: process.env.LIARA_BUCKET_NAME,
Key: "objectkey"
};

// async/await
try {
await client.send(new DeleteObjectCommand(params));
console.log("File deleted successfully");
} catch (error) {
console.log(error);
}

// callback
client.send(new DeleteObjectCommand(params), (error, data) => {
if (error) {
  console.log(error);
} else {
  console.log("File deleted successfully");
}
});

const { S3Client, ListBucketsCommand } = require("@aws-sdk/client-s3");
require("dotenv").config();

const client = new S3Client({
region: "default",
endpoint: process.env.LIARA_ENDPOINT,
credentials: {
	accessKeyId: process.env.LIARA_ACCESS_KEY,
	secretAccessKey: process.env.LIARA_SECRET_KEY,
},
});


client.send(new ListBucketsCommand({}), (error, data) => {
if (error) {
  console.log(error);
} else {
  const buckets = data.Buckets.map((bucket) => bucket.Name);
  console.log(buckets); // List of bucket names
}
});

import AWS from 'aws-sdk';
import multer from 'multer';
import express from 'express';
import multerS3 from 'multer-s3';

const config = {
endpoint: process.env(LIARA_ENDPOINT),
accessKeyId: process.env(LIARA_ACCESS_KEY),
secretAccessKey: process.env(LIARA_SECRET_KEY),
region: "default",
};

const app = express();
const s3 = new AWS.S3(config);

const upload = multer({
storage: multerS3({
  s3,
  bucket: process.env(LIARA_BUCKET_NAME),
  key: function (req, file, cb) {
    console.log(file);
    cb(null, file.originalname);
  },
}),
});


// route
app.post('/upload', upload.single('objectKey'), function (req, res) {
console.log(req.file);

return res.send({
  status: 'success',
  message: 'file uploaded!',
  url: {
    size: req.file.size,
    url: req.file.location,
    name: req.file.key,
    type: req.file.mimetype,
  },
});
});


app.listen(3000, function () {
console.log('Example app listening on port 3000!');
});