Message Scheduling

timeZone: z.string().default('America/Chicago')

const timeRegex = new RegExp(/^(\d{1,2}):(\d{2})$/);
const timeMatch = timeRegex.exec(messageTime);

if (!timeMatch?.[1] || !timeMatch?.[2]) {
  throw new Error("Invalid time format");
}

const hours = parseInt(timeMatch[1], 10);
const minutes = parseInt(timeMatch[2], 10);

if (hours < 0 || hours > 23 || minutes < 0 || minutes > 59) {
  throw new Error("Invalid time values");
}

enum Recurrence {
  DAILY
  WEEKLY
  SEMI_MONTHLY
  SEMI_ANNUALLY
  ANNUALLY
}

const recurrenceDaysMap = {
  DAILY: 1,
  WEEKLY: 7,
  SEMI_MONTHLY: 15,
  MONTHLY: 30,
  SEMI_ANNUALLY: 182,
  ANNUALLY: 365,
}

const messages = [];
let days_width = 1;

if (isRecurring) {
  days_width = recurrenceDaysMap[recurrence];
}

let i = 0;
let sequenceIndex = 0;
const daysDiff = Math.ceil(endDt.diff(startDt, 'days').days) + 1;
const sendTimeUtc = startDt.toUTC().toJSDate();

while (i < daysDiff) {
  const messageDate = startDt.plus({ days: i });
  const scheduledDateUtc = messageDate.toUTC().toJSDate();
  const daysLeft = daysDiff - i - 1;
  
  // Build message content
  let messageContent = '';
  
  if (!input.isFreeForm) {
    if (title) {
      messageContent += `Campaign Title: ${title}\n`;
    }
    messageContent += `Campaign Start Date: ${startDt.toFormat('yyyy-LL-dd')}\n`;
    messageContent += `Campaign End Date: ${endDt.toFormat('yyyy-LL-dd')}\n`;
    if (targetAmount) {
      messageContent += `Contribution Target Amount: ${targetAmount}\n`;
    }
    messageContent += `Days Remaining: ${daysLeft}\n\n`;
  }

  // Select message from sequence
  const messageText = isRecurring && messageSequence.length > 0
    ? messageSequence[sequenceIndex % messageSequence.length]
    : messageTemplate;
  messageContent += messageText?.replace(/{days_left}/g, daysLeft.toString());

  messages.push({
    sessionId,
    content: messageContent,
    scheduledAt: scheduledDateUtc,
  });

  i = i + days_width;
  sequenceIndex++;
}

const hasMessageSequence = messageTemplate.includes('*');
const messageSequence = hasMessageSequence 
  ? messageTemplate.split('*').map(msg => msg.trim()).filter(msg => msg.length > 0)
  : [messageTemplate];

if (isRecurring && hasMessageSequence) {
  const daysDiff = Math.ceil(endDt.diff(startDt, 'days').days) + 1;
  const requiredMessageCount = Math.ceil(daysDiff / recurrenceDaysMap[recurrence]);
  
  if (messageSequence.length !== requiredMessageCount) {
    throw new Error(
      `For the selected date range and ${recurrence.toLowerCase()} recurrence, ` +
      `you need exactly ${requiredMessageCount} unique message${requiredMessageCount > 1 ? 's' : ''} ` +
      `separated by asterisks (*). Or remove the asterisks to use the same message for all occurrences.`
    );
  }
}

model Message {
  id                String    @id @default(cuid())
  sessionId         String
  content           String
  scheduledAt       DateTime
  sentAt            DateTime?
  isPicked          Boolean   @default(false)
  retryCount        Int       @default(0)
  maxRetries        Int       @default(3)
  MessageCampaignId String
  createdAt         DateTime  @default(now())
  updatedAt         DateTime  @updatedAt
  isDeleted         Boolean   @default(false)
  isEdited          Boolean   @default(false)
  isSent            Boolean   @default(false)
  isFailed          Boolean   @default(false)
  failedReason      String?

  MessageCampaign MessageCampaign @relation(fields: [MessageCampaignId], references: [id], onDelete: Cascade)
}

if (!startDt.isValid || !endDt.isValid) {
  throw new Error("Invalid date format");
}

if (endDt < startDt) {
  throw new Error("End date must be after start date");
}

messageContent += messageText?.replace(/{days_left}/g, daysLeft.toString());