feat: implemented property format

controllers/apiUsagePricing.js

@@ -1,10 +1,12 @@
 const { StatusCodes } = require("http-status-codes")
 const API_Pricing = require("../models/API_Pricing.js")
+const mongoose = require('mongoose');
 const {
     mustContainProperties,
     calculateApiUsage,
 } = require('../utils')
 const API_Usage = require("../models/API_Usage.js")
+const API_Products = require("../models/API_Products.js")
 const billingSumUsage = require("../utils/billingSumUsage.js")
 const moment = require('moment')
 const API_Call = require("../models/API_Call.js")
@@ -13,7 +15,7 @@ const API_Usage_Whatsapp = require("../models/API_Usage_Whatsapp.js")
 
 const setApiPricing = async (req, res) => {
 
-    const { provider, product, currency, price, billingBy, billingUnit, type } = req.body
+    const { provider, product, currency, price, billingBy, billingUnit, type, clientPrice, format } = req.body
 
     mustContainProperties(req, ['provider',
         'product',
@@ -37,7 +39,9 @@ const setApiPricing = async (req, res) => {
         price,
         billingBy,
         billingUnit,
-        type
+        type,
+        clientPrice,
+        format
     }
     const options = { new: true, upsert: true }
 
@@ -46,6 +50,145 @@ const setApiPricing = async (req, res) => {
     res.status(StatusCodes.OK).json({ apiPricing })
 }
 
+const updateProductPricing = async (req, res) => {
+    const { price, name, description } = req.body;
+    const { id } = req.params;
+
+    if (!mongoose.Types.ObjectId.isValid(id)) {
+        return res.status(StatusCodes.BAD_REQUEST).json({
+            error: 'ID do produto inválido.'
+        });
+    }
+
+    let existingProduct = await API_Products.findById(id);
+
+    if (!existingProduct) {
+        return res.status(StatusCodes.NOT_FOUND).json({
+            error: 'Produto não encontrado.'
+        });
+    }
+
+    if (price) {
+        const activePriceIndex = existingProduct.priceHistory.findIndex(priceEntry => !priceEntry.endDate);
+
+        if (activePriceIndex !== -1 && existingProduct.priceHistory[activePriceIndex].price != price) {
+            existingProduct.priceHistory[activePriceIndex].endDate = new Date();
+        }
+        else {
+            return res.status(StatusCodes.BAD_REQUEST).json({
+                msg: `Product with the same price ${price}`
+            });
+        }
+    }
+
+    const newPriceEntry = {
+        startDate: new Date(),
+        endDate: null, // Novo preço ativo
+        price
+    };
+
+    if (description) existingProduct.description = description.trim();
+    if (name) existingProduct.name = name.trim();
+    if (price) existingProduct.priceHistory.push(newPriceEntry);
+
+    await existingProduct.save();
+
+    res.status(StatusCodes.OK).json({
+        msg: 'Preço do produto atualizado com sucesso!',
+        product: existingProduct
+    });
+
+};
+
+const setProductPricing = async (req, res) => {
+    const { name, description, price } = req.body;
+
+    console.log("price: ", price)
+
+    mustContainProperties(req, ['name']);
+
+    const normalizedName = name.trim();
+
+    let existingProduct = await API_Products.findOne({ name: normalizedName });
+
+    if (existingProduct) {
+        if (price) {
+
+            const activePriceIndex = existingProduct.priceHistory.findIndex(priceEntry => !priceEntry.endDate);
+
+            if (activePriceIndex !== -1 && existingProduct.priceHistory[activePriceIndex].price != price) {
+                existingProduct.priceHistory[activePriceIndex].endDate = new Date();
+            }
+            else {
+                return res.status(StatusCodes.BAD_REQUEST).json({
+                    msg: `Product with the same price ${price}`
+                });
+            }
+
+            const newPriceEntry = {
+                startDate: new Date(),
+                endDate: null, // Novo preço ativo
+                price
+            };
+
+            existingProduct.priceHistory.push(newPriceEntry);
+
+            if (description) existingProduct.description = description.trim();
+
+            await existingProduct.save();
+
+            return res.status(StatusCodes.OK).json({
+                msg: 'Preço do produto atualizado com sucesso!',
+                product: existingProduct
+            });
+        } else {
+            return res.status(StatusCodes.CONFLICT).json({
+                error: 'Produto já existe. Para atualizar o preço, forneça o campo "price".',
+                product: existingProduct
+            });
+        }
+    }
+
+    // Se o produto não existe, criar um novo
+    const productData = {
+        name: normalizedName,
+        description: description?.trim() || '',
+        priceHistory: []
+    };
+
+    if (price) {
+        const priceEntry = {
+            startDate: new Date(), // Data atual automática
+            endDate: null, // Preço ativo (sem data de fim)
+            price,
+        };
+
+        productData.priceHistory.push(priceEntry);
+    }
+
+    console.log('---------> Dados do produto a ser criado:', productData);
+
+    // Criar o produto
+    const newProduct = new API_Products(productData);
+    await newProduct.save();
+
+    res.status(StatusCodes.CREATED).json({
+        msg: 'Produto criado com sucesso!',
+        product: newProduct
+    });
+};
+
+const listProductPricing = async (req, res) => {
+     
+    const products = await API_Products.find();
+
+    res.status(StatusCodes.OK).json({
+        msg: 'ok', 
+        products
+    })
+
+}
+
 const registerUsage = async (req, res) => {
     const {
         provider,
@@ -54,6 +197,7 @@ const registerUsage = async (req, res) => {
         callerId,
         sessionId,
         companyId,
+        format
 
     } = req.body
 
@@ -85,7 +229,8 @@ const registerUsage = async (req, res) => {
             billingBy,
             billingUnit,
             companyId,
-            total_cost: calculateApiUsage(price, billingUnit, usage)
+            total_cost: calculateApiUsage(price, billingUnit, usage),
+            format
         })
 
         return res.status(StatusCodes.OK).json({ apiUsage })
@@ -121,7 +266,7 @@ const registerWhatsappUsage = async (req, res) => {
         'billable',
         'pricing_model',
         'companyPhone',
-        'clientPhone', 
+        'clientPhone',
     ])
 
     const apiPricing = await API_Pricing.findOne({
@@ -319,6 +464,9 @@ const getUsage = async (req, res) => {
 
 module.exports = {
     setApiPricing,
+    setProductPricing,
+    updateProductPricing,
+    listProductPricing,
     registerUsage,
     registerAPICall,
     registerOperation,

models/API_Pricing.js

@@ -1,40 +1,49 @@
-const mongoose = require('../db/connect')
+const mongoose = require("../db/connect");
 
-const { Schema } = mongoose
+const { Schema } = mongoose;
 
-const apiPricing = new Schema({    
+const apiPricing = new Schema(
+  {
     provider: {
-        type: String,
+      type: String,
-        required: true,
+      required: true,
     },
     product: {
-        type: String,
+      type: String,
-        required: true,
+      required: true,
     },
     currency: {
-        type: String,
+      type: String,
-        enum: ['dollar', 'real',],
+      enum: ["dollar", "real"],
-        default: 'dollar'
+      default: "dollar",
     },
     price: {
-        type: String,
+      type: String,
-        required: true
+      required: true,
-    }, 
-    billingBy:{
-        type: String,
-        enum: ['minute', 'character', 'token', 'second', 'hour'],
-        required: true,
     },
-    billingUnit:{
+    clientPrice: {
-        type: Number,
+      type: String,
-        required: true
+    },
+    billingBy: {
+      type: String,
+      enum: ["minute", "character", "token", "second", "hour"],
+      required: true,
+    },
+    billingUnit: {
+      type: Number,
+      required: true,
     },
     type: {
-        type: String, 
+      type: String,
-    }
+    },
+    format: {
+      type: String,
+      enum: ["text", "audio", "image", "video"],
+    },
+  },
+  { timestamps: true }
+);
 
-}, { timestamps: true })
+const API_Pricing = mongoose.model("API_Pricing", apiPricing);
- 
-const API_Pricing = mongoose.model('API_Pricing', apiPricing)
 
-module.exports = API_Pricing
+module.exports = API_Pricing;

models/API_Products.js

@@ -0,0 +1,55 @@
+const mongoose = require('../db/connect');
+
+const { Schema } = mongoose;
+
+/**
+ * @description Sub-schema para o histórico de preços.
+ * A opção `strict: false` permite adicionar campos de preço dinâmicos (ex: tokenPrice, sttSecondPrice)
+ * que podem variar conforme o `pricingModel` do produto principal.
+ * A opção `_id: false` evita que o Mongoose crie um ObjectId para cada entrada no histórico.
+ */
+const priceHistorySchema = new Schema({
+    startDate: {
+        type: Date,
+        required: [true, 'A data de início da vigência é obrigatória.'],
+    },
+    endDate: {
+        type: Date,
+        default: null, // Um valor nulo significa que o preço está atualmente vigente.
+    },
+    // price: {
+    //     type: String,
+    //     required: [true, 'O preço é obrigatório'],
+    // }
+}, { _id: false, strict: false });
+
+/**
+ * @description Schema principal para os produtos da API.
+ */
+const apiProductSchema = new Schema({
+    name: {
+        type: String,
+        required: [true, 'O nome do produto é obrigatório.'],
+        trim: true,
+        unique: true, // Garante que não hajam produtos com o mesmo nome.
+    },
+    description: {
+        type: String,
+        trim: true,
+    },
+    // pricingModel: {
+    //     type: String,
+    //     required: [true, 'O modelo de precificação é obrigatório.'],
+    //     trim: true,
+    // },
+    priceHistory: {
+        type: [priceHistorySchema],
+        default: [], // O produto pode ser criado sem um histórico de preços inicial.
+    },
+}, {
+    timestamps: true, // Adiciona os campos `createdAt` e `updatedAt` automaticamente.
+});
+ 
+const API_Products = mongoose.model('API_Products', apiProductSchema);
+
+module.exports = API_Products;

package-lock.json

@@ -7443,7 +7443,8 @@
       "version": "4.4.0",
       "resolved": "https://registry.npmjs.org/cosmiconfig-typescript-loader/-/cosmiconfig-typescript-loader-4.4.0.tgz",
       "integrity": "sha512-BabizFdC3wBHhbI4kJh0VkQP9GkBfoHPydD0COMce1nJ1kJAB3F2TmJ/I7diULBKtmEWSwEbuN/KDtgnmUUVmw==",
-      "dev": true
+      "dev": true,
+      "requires": {}
     },
     "create-require": {
       "version": "1.1.1",
@@ -7748,7 +7749,8 @@
     "express-async-errors": {
       "version": "3.1.1",
       "resolved": "https://registry.npmjs.org/express-async-errors/-/express-async-errors-3.1.1.tgz",
-      "integrity": "sha512-h6aK1da4tpqWSbyCa3FxB/V6Ehd4EEB15zyQq9qe75OZBp0krinNKuH4rAY+S/U/2I36vdLAUFSjQJ+TFmODng=="
+      "integrity": "sha512-h6aK1da4tpqWSbyCa3FxB/V6Ehd4EEB15zyQq9qe75OZBp0krinNKuH4rAY+S/U/2I36vdLAUFSjQJ+TFmODng==",
+      "requires": {}
     },
     "express-fileupload": {
       "version": "1.2.1",

routes/apiPriceRoute.js

@@ -2,6 +2,9 @@ const express = require('express')
 const router = express.Router()
 const { authorization, } = require('../middleware/authentication') 
 const { setApiPricing, 
+    setProductPricing,
+    updateProductPricing,
+    listProductPricing,
     registerUsage, 
     getUsage, 
     registerAPICall, 
@@ -10,6 +13,9 @@ const { setApiPricing,
 registerWhatsappUsage} = require('../controllers/apiUsagePricing')
 
 router.route('/create').post(authorization, setApiPricing)  
+router.route('/product').post(authorization, setProductPricing)
+router.route('/products').get(authorization, listProductPricing)
+router.route('/product/:id').patch(authorization, updateProductPricing)
 router.route('/usage').post(authorization, registerUsage)
 router.route('/usage-whatsapp').post(authorization, registerWhatsappUsage)  
 router.route('/report').post(authorization, getUsage)  
@@ -17,6 +23,4 @@ router.route('/api-call').post(authorization, registerAPICall)
 router.route('/api-operation').post(authorization, registerOperation)  
 router.route('/api-register-all').post(authorization, registerAll)  
 
-
-
 module.exports = router