import ICAL from './lib/ical.timezones.js'; import fs from 'fs'; import path from 'path'; import axios from 'axios'; export const MERGED_CALENDARS_DIR = path.join(process.cwd(), 'calendar'); // Ensure the merged calendars directory exists fs.mkdirSync(MERGED_CALENDARS_DIR, { recursive: true }); // Utility to sanitize filenames export const sanitizeFilename = (filename) => filename.replace(/[<>:"/\\|?* ]/g, '_'); // Fetch calendar data from URL or file export async function fetchCalendarData(calendar) { const isFilePath = !calendar.url.startsWith('http'); try { if (isFilePath) { return { data: fs.readFileSync(path.resolve(calendar.url), 'utf-8'), ...calendar }; } else { const response = await axios.get(calendar.url); return { data: response.data, ...calendar }; } } catch (error) { throw new Error(`Error retrieving calendar from ${calendar.url}: ${error.message}`); } } // Helper function to check if TZID exists in the raw property string function hasTZID(rawProperty) { return rawProperty.includes('TZID='); } // Function to process DTSTART/DTEND function processDateTimeProperty(event, propertyName, newEvent) { const rawProperty = event.getFirstProperty(propertyName)?.toICALString(); if (!rawProperty) return; const dateTime = event.getFirstPropertyValue(propertyName); const dateTimeString = dateTime.toString(); const property = new ICAL.Property(propertyName, newEvent); property.setValue(dateTimeString); if (hasTZID(rawProperty)) { // If raw property includes TZID, add it property.setParameter('TZID', dateTime.zone.tzid); } newEvent.addProperty(property); } // Create a top-level VCALENDAR component export function createCalendarComponent(name) { const calendarComponent = new ICAL.Component(['vcalendar', [], []]); calendarComponent.updatePropertyWithValue('name', name); calendarComponent.updatePropertyWithValue('prodid', '-//CalMerge//Calendar Merger 1.0//EN'); calendarComponent.updatePropertyWithValue('version', '2.0'); calendarComponent.updatePropertyWithValue('calscale', 'GREGORIAN'); return calendarComponent; } // Add events to the calendar component export function addEventsToCalendar(calendarComponent, results, overrideFlag = false) { let defaultTimeZone = null; // To store the first found X-WR-TIMEZONE results.forEach((result) => { try { const parsed = ICAL.parse(result.data); const component = new ICAL.Component(parsed); // Extract METHOD from the parsed data (if available) const method = component.getFirstPropertyValue('method'); if (method) { console.log(`Extracted METHOD: ${method}`); // Only add the METHOD property once if (!calendarComponent.getFirstPropertyValue('method')) { calendarComponent.updatePropertyWithValue('method', method.toUpperCase()); } } // Extract X-WR-TIMEZONE if available const wrTimeZone = component.getFirstPropertyValue('x-wr-timezone'); if (wrTimeZone) { console.log(`Extracted X-WR-TIMEZONE: ${wrTimeZone}`); // Set it as the default if not already set if (!defaultTimeZone) { defaultTimeZone = wrTimeZone; if (!calendarComponent.getFirstPropertyValue('x-wr-timezone')) { calendarComponent.updatePropertyWithValue('x-wr-timezone', defaultTimeZone); } } } // Extract and add VTIMEZONE components const timezones = component.getAllSubcomponents('vtimezone'); timezones.forEach((timezone) => { const tzid = timezone.getFirstPropertyValue('tzid'); if (!calendarComponent.getFirstSubcomponent((comp) => comp.name === 'vtimezone' && comp.getFirstPropertyValue('tzid') === tzid)) { calendarComponent.addSubcomponent(timezone); } }); // Process VEVENT components component.getAllSubcomponents('vevent').forEach((event) => { const vevent = new ICAL.Event(event); const newEvent = new ICAL.Component('vevent'); // 1. Add DTSTART processDateTimeProperty(event, 'dtstart', newEvent); // 2. Add DTEND processDateTimeProperty(event, 'dtend', newEvent); // 3. Copy DTSTAMP const dtstamp = event.getFirstPropertyValue('dtstamp'); if (dtstamp) newEvent.updatePropertyWithValue('dtstamp', dtstamp); // 4. Copy UID newEvent.updatePropertyWithValue('uid', vevent.uid); // 5. Add LOCATION (conditionally included) if (!overrideFlag && vevent.location) { newEvent.updatePropertyWithValue('location', vevent.location); } else if (overrideFlag && vevent.location) { // Modify SUMMARY if override is set const modifiedSummary = `${vevent.summary.trim()} (Location omitted)`; newEvent.updatePropertyWithValue('summary', modifiedSummary); } else { newEvent.updatePropertyWithValue('summary', vevent.summary.trim()); } // 6. Copy Recurrence Rules (RRULE) and Recurrence ID const rrule = event.getFirstPropertyValue('rrule'); if (rrule) newEvent.updatePropertyWithValue('rrule', rrule); const recurrenceId = event.getFirstPropertyValue('recurrence-id'); if (recurrenceId) newEvent.updatePropertyWithValue('recurrence-id', recurrenceId); // 7. Copy SUMMARY newEvent.updatePropertyWithValue('summary', vevent.summary.trim()); // 8. Add SEQUENCE (if available or default to 0) const sequence = event.getFirstPropertyValue('sequence') || 0; newEvent.updatePropertyWithValue('sequence', sequence); // Add the VEVENT to the calendar calendarComponent.addSubcomponent(newEvent); }); console.log(`Processed VEVENT components for calendar: ${result.name}`); } catch (error) { console.error('Error processing calendar data:', error.message); } }); } // Save calendar data to file export function saveCalendarFile(filename, content) { const normalizedContent = content.replace(/\r?\n/g, '\r\n').trimEnd(); // Normalize to CRLF const filePath = path.join(MERGED_CALENDARS_DIR, filename); // console.log(`Saving calendar data to file: ${filePath}`); fs.writeFileSync(filePath, normalizedContent); return filePath; }