import { WorkerHost } from "@nestjs/bullmq";
import { Job } from "bullmq";
import { ClsService } from "nestjs-cls";
import { ReferralCompletionHandler } from "../interfaces/referral-completion-handler.interface";
import { AppLoggingService } from "../../../core/logging";
import { WebSocketService } from "../../../core/websocket/services/websocket.service";
import { CompanyRepository } from "../../company/repositories/company.repository";
import { StripeCustomerRepository } from "../../stripe-customer/repositories/stripe-customer.repository";
import { StripeInvoiceRepository } from "../../stripe-invoice/repositories/stripe-invoice.repository";
import { StripeInvoiceAdminService } from "../../stripe-invoice/services/stripe-invoice-admin.service";
import { StripePriceRepository } from "../../stripe-price/repositories/stripe-price.repository";
import { StripeSubscriptionRepository } from "../../stripe-subscription/repositories/stripe-subscription.repository";
import { FeatureSyncService } from "../../stripe-subscription/services/feature-sync.service";
import { StripeSubscriptionAdminService } from "../../stripe-subscription/services/stripe-subscription-admin.service";
import { TokenAllocationService } from "../../stripe-subscription/services/token-allocation.service";
import { StripeService } from "../../stripe/services/stripe.service";
import { StripeWebhookEventRepository } from "../repositories/stripe-webhook-event.repository";
import { StripeWebhookNotificationService } from "../services/stripe-webhook-notification.service";
export interface StripeWebhookJobData {
    webhookEventId: string;
    stripeEventId: string;
    eventType: string;
    payload: Record<string, any>;
}
export declare class StripeWebhookProcessor extends WorkerHost {
    private readonly stripeWebhookEventRepository;
    private readonly subscriptionService;
    private readonly stripeCustomerRepository;
    private readonly subscriptionRepository;
    private readonly stripeInvoiceRepository;
    private readonly stripePriceRepository;
    private readonly notificationService;
    private readonly tokenAllocationService;
    private readonly featureSyncService;
    private readonly stripeService;
    private readonly companyRepository;
    private readonly stripeInvoiceAdminService;
    private readonly logger;
    private readonly cls;
    private readonly webSocketService;
    private readonly referralCompletionHandler?;
    constructor(stripeWebhookEventRepository: StripeWebhookEventRepository, subscriptionService: StripeSubscriptionAdminService, stripeCustomerRepository: StripeCustomerRepository, subscriptionRepository: StripeSubscriptionRepository, stripeInvoiceRepository: StripeInvoiceRepository, stripePriceRepository: StripePriceRepository, notificationService: StripeWebhookNotificationService, tokenAllocationService: TokenAllocationService, featureSyncService: FeatureSyncService, stripeService: StripeService, companyRepository: CompanyRepository, stripeInvoiceAdminService: StripeInvoiceAdminService, logger: AppLoggingService, cls: ClsService, webSocketService: WebSocketService, referralCompletionHandler?: ReferralCompletionHandler);
    onActive(job: Job<StripeWebhookJobData>): void;
    onError(job: Job<StripeWebhookJobData>): void;
    onCompleted(job: Job<StripeWebhookJobData>): void;
    process(job: Job<StripeWebhookJobData>): Promise<void>;
    private handleEvent;
    private handleSubscriptionEvent;
    private handleTrialWillEndEvent;
    private handleInvoiceEvent;
    private handleCustomerEvent;
    private handlePaymentIntentEvent;
}
//# sourceMappingURL=stripe-webhook.processor.d.ts.map