Account Active Status Check
Weekly automated purge check for inactive software accounts
Weekly automated purge check for inactive software accounts
Calculates churn risk based on subscription cancellation patterns
CSV-based bulk account creation with business contacts and field mapping
Account import, status monitoring, and Stripe domain verification
Field mapping and data transformation for contact and account CSV imports
Automatically adds followers to deals when they enter a stage
Automatically adds notes to deals when they enter a stage
Automatically adds CRM tags to deals when they enter a stage
Monthly affiliate commission calculation with software and managed subscription tracking
Affiliate commission calculations, leaderboard generation, and payout management
Daily cleanup job that retains the 10 most recent funnel step backups per step and deletes older versions
Stripe key initialization completion handler with socket notifications and queue cleanup
Imports Stripe customers as DashClicks contacts with field mapping, update/create logic, and import result tracking
Billing contact import and new authentication processing
Monitors Twilio A2P brand registration status and automatically creates messaging services and campaigns when brands are verified
Generates desktop and mobile preview thumbnails for funnel pages using Puppeteer with stale job recovery
Handles monthly A2P messaging campaign renewals by charging OneBalance fees and scheduling next renewal dates
Monitors Twilio A2P messaging campaign approval status and sets renewal dates when campaigns are verified
Delete custom domains from Cloudflare, remove from database, update associated funnels, and send cancellation notifications
Automatically reassigns deal ownership when deals enter a stage
MongoDB change stream wrapper for real-time document watching with error handling and fullDocument lookup
Remove orphaned and inactive domains that fail SSL validation or remain inactive for 14+ days after creation
Removes stale churn risk pulses when risk falls below threshold
Shared utilities and helpers used across Queue Manager modules
Communication violation detection and A2P campaign management
Environment variables and Queue Manager configuration
Automated cleanup of expired contact export CSV files from Wasabi S3 storage
CSV export generation for contacts and companies with authentication and currency support
Detailed CSV contact import processing with field mapping and three import types
Contact import, export, and cleanup background processing
Support ticket management, snoozing, message status, and notifications
Automatically creates InstaReports for deal contacts when deals enter a stage
Automatically creates InstaSites for deal contacts when deals enter a stage
Automatically creates reminders for deals when they enter a stage
CRM workflow automation engine with 11 action types and delay triggers
CSV deal import with field mapping and pipeline stage assignment
Deal import and automation workflow processing
Domain validation, renewal, cancellation, and cleanup
Result tracking and socket notifications for subscription downgrade operations
High-frequency job that monitors email and SMS error rates, opt-out rates, and automatically suspends accounts exceeding violation thresholds
Hourly cleanup job to reset stuck thumbnail generation processes
Complex two-tier funnel cloning system that duplicates funnels with all steps, components, images, forms, and chat plugins
Funnel cloning, backup cleanup, and thumbnail generation
Redis-backed Bull queue factory with connection pooling and retry strategies
Result tracking and error logging for contact and account CSV imports
Creates pulses for tasks with no communication in 7+ days
Automated report generation and building
InstaSite build queue processing with fair distribution across accounts
Automatic cleanup of unpublished and orphaned InstaSites
Site building, purging, and management
Dynamic MRR-based loyalty tier tracking with sliding window calculations
Projects, Intercom leads, and schedule utilization monitoring
Automatically moves deals to a different stage
Initializes Stripe integration by creating webhooks and fetching initial data for charges, customers, disputes, subscriptions, refunds, and products
Balance reload and charge processing for OneBalance system
Assigns Twilio phone numbers to verified A2P messaging campaigns based on campaign use case type
Customer engagement, churn prevention, and loyalty tracking automation
Creates quarterly engagement check-in pulses for active subscriptions
Background job processing service with environment-controlled module loading, Bull queues, and Express API
Complete system architecture and processing patterns
Bull queue factory with Redlock and standardized event handling
Automatically removes CRM tags from deals when they enter a stage
Automatically queue domains for renewal via OneBalance payment system every 30 days
Creates review request pulses for agencies with 1+ month active subscriptions
Automated review fetching from multiple platforms
Automatically sends emails to deal contacts when deals enter a stage
Automatically sends SMS messages to deal contacts when deals enter a stage
Automated screenshot generation for InstaSites and Agency Websites using Puppeteer
Site thumbnail generation and business information updates
Subscription lifecycle management, billing, and invoice processing
Automatic registration of custom account domains with Stripe for payment processing
Third-party subscription cancellation for Yext listings and Duda sites with retry scheduling and external API integration
Tier downgrade processing with data deletion, custom domain removal, and MongoDB transactions
Health check to create missing support messages from communication logs
Track SMS/Email message delivery status for support conversations
Send real-time notifications to support agents for incoming messages
Automatic unsnoozing of support conversation rooms at scheduled times
Synchronizes account has_orders flag based on active orders
Sync business contact information (phone, email, address, social accounts) from CRM to Duda website content library
Sync custom domain status from Cloudflare to Lightning Domains database and update funnel status for inactive domains
Webhook notification delivery and retry management
Ask me anything about the docs