Add product metadata and tags to S3 objects

- Add product ID as tag and product name as metadata when uploading images
- Update StorageService to support metadata and tagging
- Add helper functions for retrieving object metadata and tags
- Update integration tests to validate metadata and tags are applied correctly

Resolves #64

Author: mikesir87

src/services/ProductService.js

@@ -88,7 +88,15 @@ async function getProductImage(id) {
 async function uploadProductImage(id, buffer) {
   const client = await getClient();
 
-  await uploadFile(id, buffer);
+  // Get product name for metadata
+  const productResult = await client.query(
+    "SELECT name FROM products WHERE id = $1",
+    [id],
+  );
+  const productName =
+    productResult.rows.length > 0 ? productResult.rows[0].name : "";
+
+  await uploadFile(id, buffer, productName);
   await client.query("UPDATE products SET has_image=TRUE WHERE id=$1", [id]);
 }
 

src/services/StorageService.js

@@ -2,6 +2,8 @@ const {
   S3Client,
   PutObjectCommand,
   GetObjectCommand,
+  GetObjectTaggingCommand,
+  HeadObjectCommand,
 } = require("@aws-sdk/client-s3");
 const { publishEvent } = require("./PublisherService");
 
@@ -25,14 +27,18 @@ async function getFile(id) {
   return result.Body;
 }
 
-async function uploadFile(id, buffer) {
+async function uploadFile(id, buffer, productName) {
   const name = "product.png";
 
   await s3Client.send(
     new PutObjectCommand({
       Bucket: BUCKET_NAME,
       Key: `${id}/${name}`,
       Body: buffer,
+      Metadata: {
+        productName: productName || "",
+      },
+      Tagging: `productId=${id}`,
     }),
   );
 
@@ -47,7 +53,35 @@ async function uploadFile(id, buffer) {
   return details;
 }
 
+async function getObjectMetadata(id) {
+  const name = "product.png";
+
+  const result = await s3Client.send(
+    new HeadObjectCommand({
+      Bucket: BUCKET_NAME,
+      Key: `${id}/${name}`,
+    }),
+  );
+
+  return result.Metadata;
+}
+
+async function getObjectTags(id) {
+  const name = "product.png";
+
+  const result = await s3Client.send(
+    new GetObjectTaggingCommand({
+      Bucket: BUCKET_NAME,
+      Key: `${id}/${name}`,
+    }),
+  );
+
+  return result.TagSet;
+}
+
 module.exports = {
   uploadFile,
   getFile,
+  getObjectMetadata,
+  getObjectTags,
 };

test/integration/productCreation.integration.spec.js

@@ -9,7 +9,7 @@ const { KafkaConsumer } = require("./kafkaSupport");
 describe("Product creation", () => {
   let postgresContainer, kafkaContainer, localstackContainer;
   let kafkaConsumer;
-  let productService, publisherService;
+  let productService, publisherService, storageService;
 
   beforeAll(async () => {
     console.log("Starting containers");
@@ -30,6 +30,7 @@ describe("Product creation", () => {
   beforeAll(async () => {
     productService = require("../../src/services/ProductService");
     publisherService = require("../../src/services/PublisherService");
+    storageService = require("../../src/services/StorageService");
   });
 
   afterAll(async () => {
@@ -126,6 +127,16 @@ describe("Product creation", () => {
       }))();
 
     expect(retrievedImageBuffer).toEqual(imageBuffer);
+
+    // Validate metadata
+    const metadata = await storageService.getObjectMetadata(createdProduct.id);
+    expect(metadata.productname).toBe("Kafka publishing test");
+
+    // Validate tags
+    const tags = await storageService.getObjectTags(createdProduct.id);
+    expect(tags).toEqual([
+      { Key: "productId", Value: createdProduct.id.toString() },
+    ]);
   }, 15000);
 
   it("doesn't allow duplicate UPCs", async () => {