Server 500 response Timed out fetching a new connection from the connection pool.

Timed out fetching a new connection from the connection pool. More info: <http://pris.ly/d/connection-pool> (Current connection pool timeout: 10, connection limit: 3)

Timed out fetching a new connection from the connection pool. More info: <http://pris.ly/d/connection-pool> (Current connection pool timeout: 10, connection limit: 3)

   import { HttpError } from 'wasp/server'

   export const getTrackedProductStats = async (args, context) => {
     try {
       // Your database operation here
     } catch (error) {
       throw new HttpError(
         500,
         "Database connection error",
         { details: error.message }
       )
     }
   }
   

   import { HttpError } from 'wasp/server'

   export const getTrackedProductStats = async (args, context) => {
     try {
       // Your database operation here
     } catch (error) {
       throw new HttpError(
         500,
         "Database connection error",
         { details: error.message }
       )
     }
   }
   

export const getTrackedProducts: GetTrackedProducts<void, Products[]> = async (args, context) => {
        if (!context.user) {
            throw new HttpError(401,'User is not authenticated');
        }
        
        if (!context.user.isAdmin) {
          // Check for subscription status and plan restrictions for non-admin users
          if (context.user.subscriptionStatus === 'past_due') {
              throw new HttpError(403, 'Uw abonnement is verlopen. Werk uw betalingsgegevens bij.');
          }
          
          if (context.user.subscriptionPlan !== 'max' && context.user.subscriptionPlan !== 'boost') {
            throw new HttpError(403, 'Uw abbonoment laat deze functie niet toe.');
          }
      }
          
      

    const trackedProducts = await context.entities.UserTrackedProducts.findMany({
        where: { userId: context.user.id },
        select: { productId: true },
    });

    const productIds = trackedProducts.map((track) => track.productId);

    return context.entities.Products.findMany({
        where: { id: { in: productIds } },
        orderBy: { id: 'asc' },
    });
    };

export const getTrackedProducts: GetTrackedProducts<void, Products[]> = async (args, context) => {
        if (!context.user) {
            throw new HttpError(401,'User is not authenticated');
        }
        
        if (!context.user.isAdmin) {
          // Check for subscription status and plan restrictions for non-admin users
          if (context.user.subscriptionStatus === 'past_due') {
              throw new HttpError(403, 'Uw abonnement is verlopen. Werk uw betalingsgegevens bij.');
          }
          
          if (context.user.subscriptionPlan !== 'max' && context.user.subscriptionPlan !== 'boost') {
            throw new HttpError(403, 'Uw abbonoment laat deze functie niet toe.');
          }
      }
          
      

    const trackedProducts = await context.entities.UserTrackedProducts.findMany({
        where: { userId: context.user.id },
        select: { productId: true },
    });

    const productIds = trackedProducts.map((track) => track.productId);

    return context.entities.Products.findMany({
        where: { id: { in: productIds } },
        orderBy: { id: 'asc' },
    });
    };

export const getTrackedProductStats: GetTrackedProductStats<{ timeFrame: string }, { productId: number, avgPrice: number, totalSales: number, totalRevenue: number }[]> = async (args, context) => {
  const { timeFrame } = args;
  const days = timeFrame === '3m' ? 90 : 30;

  if (!context.user) {
    throw new Error('User is not authenticated');
  }
  if (!context.user.isAdmin) {
    // Check for subscription status and plan restrictions for non-admin users
    if (context.user.subscriptionStatus === 'past_due') {
        throw new HttpError(403, 'Uw abonnement is verlopen. Werk uw betalingsgegevens bij.');
    }
    
    if (context.user.subscriptionPlan !== 'max' && context.user.subscriptionPlan !== 'boost') {
      throw new HttpError(403, 'Uw abbonoment laat deze functie niet toe.');
    }
}

  // Get the IDs of products tracked by the user
  const trackedProducts = await context.entities.UserTrackedProducts.findMany({
    where: { userId: context.user.id },
    select: { productId: true },
  });

  const productIds = trackedProducts.map((track) => track.productId);

  // Get sales data only for tracked products
  const stats = await Promise.all(
    productIds.map(async (productId) => {
      const salesData = await context.entities.SalesData.findMany({
        where: { productId },
        orderBy: { id: 'desc' },
        take: days,
      });

      const avgPrice = salesData.length > 0 
      ? salesData.reduce((sum, data) => sum + (data.avgPrice || 0), 0) / salesData.length 
      : 0;     
      const totalSales = salesData.reduce((sum, data) => sum + (data.totalSales || 0), 0);
      const totalRevenue = salesData.reduce((sum, data) => sum + (data.totalRevenue || 0), 0);

      return {
        productId,
        avgPrice,
        totalSales,
        totalRevenue,
      };
    })
  );

  return stats;
};

export const getTrackedProductStats: GetTrackedProductStats<{ timeFrame: string }, { productId: number, avgPrice: number, totalSales: number, totalRevenue: number }[]> = async (args, context) => {
  const { timeFrame } = args;
  const days = timeFrame === '3m' ? 90 : 30;

  if (!context.user) {
    throw new Error('User is not authenticated');
  }
  if (!context.user.isAdmin) {
    // Check for subscription status and plan restrictions for non-admin users
    if (context.user.subscriptionStatus === 'past_due') {
        throw new HttpError(403, 'Uw abonnement is verlopen. Werk uw betalingsgegevens bij.');
    }
    
    if (context.user.subscriptionPlan !== 'max' && context.user.subscriptionPlan !== 'boost') {
      throw new HttpError(403, 'Uw abbonoment laat deze functie niet toe.');
    }
}

  // Get the IDs of products tracked by the user
  const trackedProducts = await context.entities.UserTrackedProducts.findMany({
    where: { userId: context.user.id },
    select: { productId: true },
  });

  const productIds = trackedProducts.map((track) => track.productId);

  // Get sales data only for tracked products
  const stats = await Promise.all(
    productIds.map(async (productId) => {
      const salesData = await context.entities.SalesData.findMany({
        where: { productId },
        orderBy: { id: 'desc' },
        take: days,
      });

      const avgPrice = salesData.length > 0 
      ? salesData.reduce((sum, data) => sum + (data.avgPrice || 0), 0) / salesData.length 
      : 0;     
      const totalSales = salesData.reduce((sum, data) => sum + (data.totalSales || 0), 0);
      const totalRevenue = salesData.reduce((sum, data) => sum + (data.totalRevenue || 0), 0);

      return {
        productId,
        avgPrice,
        totalSales,
        totalRevenue,
      };
    })
  );

  return stats;
};