src/shared/services/portfolio.service.ts

import { fetchPortfolio } from './propertyware.service';
import PwPortfolio from '../../models/pwPortfolio';
import { logger } from '../../utils/logger';

export const syncPortfolioDataService = async (): Promise<string> => {
    try {
        const portfolioData = await fetchPortfolio();
        const portfolioResponseData = portfolioData.map((portfolio: { id: any; name: any; }) => ({
            pw_id: portfolio.id,
            name: portfolio.name,
        }));

        await PwPortfolio.bulkCreate(portfolioResponseData, {
            updateOnDuplicate: ['name'],
        });

        logger.info("Portfolio data synced successfully");
        return "Portfolio data synced successfully";
    } catch (error) {
        logger.error("Error syncing Portfolio");
        logger.error(error);
        throw new Error("Error syncing Portfolio");
    }
};