AWS Lambdaを使用してAsset Managerにアセットを自動追加する

import https from "https";
 
export async function handler(event) {
  try {
    // Extract bucket name and object key from the event
    const record = event.Records[0];
    const objectKey = decodeURIComponent(
 record.s3.object.key.replace(/\+/g, " ")
 );
 
    // Retrieve environment variables
    const imgixApiKey = process.env.IMGIX_API_KEY;
    const imgixSourceId = process.env.IMGIX_SOURCE_ID;
 
    if (!imgixApiKey || !imgixSourceId) {
 console.error(
        "IMGIX_API_KEY or IMGIX_SOURCE_ID is not set in environment variables."
 );
      throw new Error(
        "Server configuration error: Missing IMGIX_API_KEY or IMGIX_SOURCE_ID."
 );
    }
 
    // Prepare the Origin path for the imgix add endpoint
    const originPath = encodeURIComponent(objectKey);
 
    // Create the request body
    const requestBody = JSON.stringify({});
 
    // Options for the HTTPS request
    const options = {
 hostname: "api.imgix.com",
 path: `/api/v1/sources/${imgixSourceId}/assets/add/${originPath}`,
 method: "POST",
 headers: {
 Authorization: `Bearer ${imgixApiKey}`,
        "Content-Type": "application/json",
        "Content-Length": Buffer.byteLength(requestBody),
      },
    };
 
    // Make a request to the imgix add endpoint
    const response = await makeHttpsRequest(options, requestBody);
 
 console.log("Asset added successfully:", response);
    return {
 statusCode: 200,
 body: JSON.stringify({ message: "Asset added successfully" }),
    };
  } catch (error) {
 console.error("Error adding asset to imgix:", error);
    return {
 statusCode: 500,
 body: JSON.stringify({ error: "Failed to add asset to imgix" }),
    };
  }
}
 
// Helper function to make HTTPS requests
function makeHttpsRequest(options, body) {
  return new Promise((resolve, reject) => {
    const req = https.request(options, (res) => {
 
 res.on("end", () => {
        if (res.statusCode >= 200 && res.statusCode 300) {
          resolve();
        } else {
          reject(new Error(`HTTP ${res.statusCode}`));
        }
      });
    });
 
 req.on("error", (error) => {
      reject(error);
    });
 
    // Send the request body
 req.write(body);
 req.end();
  });
}