src/shared/services/buildings.service.ts

import { fetchBuildings } from './propertyware.service';
import PwBuildings from '../../models/pwBuildings';
import { logger } from '../../utils/logger';

export const syncBuildingsDataService = async (): Promise<string> => {
    try {
        const buildingsData = await fetchBuildings();
        const buildingsResponseData = buildingsData.map((building: Record<string, string>) => ({
            pw_id: building.id,
            name: building.name,
            pw_portfolio_id: building.portfolioID
        }));

        await PwBuildings.bulkCreate(buildingsResponseData, {
            updateOnDuplicate: ['name', 'pw_portfolio_id'],
        });

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