Managing a Smart Product Catalog Metadata Architecture With MongoDB Atlas and Google Cloud

1
// Making a GET request to the microservice
2
exports = async function(payload, response) {
3
    const url = "http://127.0.0.1:3000/signURLs"; // This is an example URL
4
    try {
5
        const httpResult = await context.http.get({ url: url });
6
        if (httpResult.status == "200 OK") {
7
            return httpResult.body.text();
8
        } else {
9
            return { error: "Failed to fetch data", statusCode: httpResult.status };
10
        }
11
    } catch (error) {
12
        return { error: error.message };
13
    }
14
};

1
// Getting bucket resources      
2
const serviceAccountKey = await loadJson(jsonFilePath);
3
const storage = new Storage({
4
      credentials: serviceAccountKey,
5
    });
6
7
const bucketName = process.env.GC_STORAGE_BUCKET;
8
const folderName = process.env.GC_BUCKET_FOLDER;
9
10
const bucket = storage.bucket(process.env.GC_STORAGE_BUCKET);
11
const [files] = await bucket.getFiles({ prefix: folderName });

1
// Updating URL expiration time
2
const [signedUrl] = await file.getSignedUrl({
3
          action: "read",
4
          expires: Date.now() + 14 * 60 * 60 * 1000, // 14 hours
5
        });

1
// Updating MongoDB collection
2
const updateResult = await collection.updateOne(
3
          { id: id },
4
          { $set: { "image.url": signedUrl } }
5
        );

1
// Retrieving the products catalog from the API.
2
const response = await axios.post("/api/getProducts", filters);
3
const transformedProducts = response.data.products.map((product) => ({
4
id: product.id,
5
photo: product.image.url,
6
         name: product.name,
7
         brand: product.brand,
8
         price: `${product.price.amount.toFixed(2)}`,
9
         pred_price: `${product.pred_price.toFixed(2)}`,
10
         items: product.items,
11
}));
12
13
setProducts(transformedProducts);

1
// getProducts API
2
import { NextResponse } from "next/server";
3
import { connectToDatabase } from "../../_db/connect";
4
5
export async function POST(request) {
6
    const filters = await request.json();
7
    const db = await connectToDatabase();
8
    const collection = db.collection("products");
9
10
    let queryBrand = {};
11
    let queryCategory = {};
12
13
    if (filters.selectedBrands && filters.selectedBrands.length > 0) {
14
        queryBrand = { brand: { $in: filters.selectedBrands } };
15
    }
16
    if (filters.selectedCategories && filters.selectedCategories.length > 0) {
17
        queryCategory = { masterCategory: { $in: filters.selectedCategories } };
18
19
    }
20
21
     const products = await collection
22
    .find(
23
      { $and: [queryBrand, queryCategory] },
24
      {
25
        projection: {
26
          name: 1,
27
          price: 1,
28
          brand: 1,
29
          image: 1,
30
          id: 1,
31
          _id: 0,
32
          pred_price: 1,
33
          items: 1,
34
        },
35
      }
36
    )
37
    .toArray();
38
39
    return NextResponse.json({ products }, { status: 200 });
40
}

1
// Displaying products in the UI	
2
{products.map((product, index) => (
3
        <div key={index}>
4
          <ProductCard
5
            id={product.id}
6
            photo={product.photo}
7
            name={product.name}
8
            brand={product.brand}
9
            price={product.price}
10
            items={product.items}
11
          />
12
        </div>
13
))}