SMSWise.AI: Compliant SMS Automation for Shopify

export async function syncSegment(shop: string, segmentId: string) {
  const rules = await SegmentRules.find(segmentId);
  const query = compileShopifyCustomerQuery(rules);
  const members = await shopify.customers.list({ shop, query });

  await SubscriberIndex.replaceAll(segmentId, members.map(toSubscriber));
  return { count: members.length };
}

export async function dispatchCampaign(campaign: Campaign) {
  if (!isWithinQuietHours(campaign.shop, new Date())) {
    await scheduleForNextWindow(campaign);
    return;
  }

  for (const batch of chunk(campaign.recipients, 100)) {
    await twilio.messages.create({
      messagingServiceSid: campaign.messagingServiceSid,
      to: batch.map((r) => r.phone),
      body: renderTemplate(campaign.body, batch),
    });
  }
}