+
+ {mobileOpen ? (
+
+
setMobileOpen(false)} />
+
+
+ ) : null}
+
+
+ );
+}
diff --git a/frontend/modules/communication/components/createPortalLayout.tsx b/frontend/modules/communication/components/createPortalLayout.tsx
new file mode 100644
index 0000000..241af66
--- /dev/null
+++ b/frontend/modules/communication/components/createPortalLayout.tsx
@@ -0,0 +1,34 @@
+"use client";
+
+import { AuthGuard } from "@/components/AuthGuard";
+import { useMe } from "@/hooks/useMe";
+import { useRouter } from "next/navigation";
+import { useEffect } from "react";
+import { LoadingState, ErrorState } from "@/components/ds";
+import { CommunicationPortalShell } from "@/modules/communication/components/CommunicationPortalShell";
+
+function PortalGate({ children }: { children: React.ReactNode }) {
+ const { me, loading, error, reload } = useMe();
+ const router = useRouter();
+
+ useEffect(() => {
+ if (loading) return;
+ if (me?.onboarding_required) router.replace("/onboarding");
+ }, [me, loading, router]);
+
+ if (loading) return
;
+ if (error) return
;
+ if (!me?.current_tenant_id) {
+ return
;
+ }
+
+ return
{children};
+}
+
+export function CommunicationRootLayout({ children }: { children: React.ReactNode }) {
+ return (
+
+ {children}
+
+ );
+}
diff --git a/frontend/modules/communication/constants/featureRegistry.ts b/frontend/modules/communication/constants/featureRegistry.ts
new file mode 100644
index 0000000..f680552
--- /dev/null
+++ b/frontend/modules/communication/constants/featureRegistry.ts
@@ -0,0 +1,234 @@
+import type { FeatureLockConfig } from "@/modules/communication/types";
+
+/** Backend-active features (from /capabilities features[] + channel status). */
+export const SMS_FEATURES = [
+ "sms",
+ "provider_framework",
+ "communication_router",
+ "template_engine",
+ "dynamic_contact_sources",
+ "queue_engine",
+ "delivery_tracking",
+ "otp",
+ "webhooks",
+ "failover",
+ "circuit_breaker",
+ "rate_limiting",
+ "idempotency",
+ "metrics",
+] as const;
+
+/** Future modules — always locked until backend registers capability. */
+export const FUTURE_MODULE_REGISTRY: Record
= {
+ email: {
+ feature: "channel_email",
+ title: "پلتفرم ایمیل",
+ description: "ارسال ایمیل سازمانی با SMTP، قالبهای HTML، پیگیری تحویل و failover.",
+ phase: "Roadmap",
+ bundle: "Communication Pro",
+ capabilities: ["SMTP adapters", "HTML templates", "Bounce handling", "DKIM/SPF guides"],
+ integrations: ["CRM", "Marketing", "Accounting"],
+ },
+ whatsapp: {
+ feature: "channel_whatsapp",
+ title: "واتساپ بیزینس",
+ description: "پیامرسانی WhatsApp Cloud API با قالبهای تأییدشده و webhook تحویل.",
+ phase: "Roadmap",
+ bundle: "Omnichannel Pack",
+ capabilities: ["Template sync", "Read receipts", "Media messages", "Opt-in management"],
+ integrations: ["CRM", "Support", "Campaigns"],
+ },
+ telegram: {
+ feature: "channel_telegram",
+ title: "تلگرام",
+ description: "ربات تلگرام برای اعلانها، OTP و پشتیبانی.",
+ phase: "Roadmap",
+ bundle: "Omnichannel Pack",
+ capabilities: ["Bot API", "Inline keyboards", "Channel broadcasts"],
+ integrations: ["Support", "Notifications"],
+ },
+ rubika: {
+ feature: "channel_rubika",
+ title: "روبیکا",
+ description: "پیامرسانی اجتماعی بومی با adapter اختصاصی.",
+ phase: "Roadmap",
+ bundle: "Regional Pack",
+ capabilities: ["Bot messaging", "Rich cards", "Delivery callbacks"],
+ integrations: ["CRM", "Loyalty"],
+ },
+ push: {
+ feature: "channel_push",
+ title: "Push Notifications",
+ description: "اعلان push موبایل و وب via FCM با ثبت توکن دستگاه.",
+ phase: "Roadmap",
+ bundle: "Mobile Pack",
+ capabilities: ["FCM", "Device registry", "Silent push", "Topic subscriptions"],
+ integrations: ["Mobile apps", "PWA"],
+ },
+ voice: {
+ feature: "channel_voice",
+ title: "تماس صوتی",
+ description: "OTP و اعلان صوتی با gateway تلفنی.",
+ phase: "Roadmap",
+ bundle: "Voice Pack",
+ capabilities: ["TTS", "Call status webhooks", "OTP voice path"],
+ integrations: ["Identity", "Security"],
+ },
+ video: {
+ feature: "channel_video",
+ title: "تماس ویدیویی",
+ description: "جلسات ویدیویی و تماس تصویری برای پشتیبانی.",
+ phase: "Roadmap",
+ bundle: "Enterprise",
+ capabilities: ["WebRTC rooms", "Recording refs", "Scheduling"],
+ integrations: ["CRM", "Support"],
+ },
+ live_chat: {
+ feature: "live_chat",
+ title: "Live Chat",
+ description: "چت زنده وبسایت با routing به اپراتور.",
+ phase: "Roadmap",
+ bundle: "Support Pack",
+ capabilities: ["Widget embed", "Agent queue", "Canned responses"],
+ integrations: ["CRM", "Experience"],
+ },
+ omnichannel_inbox: {
+ feature: "omnichannel_inbox",
+ title: "صندوق ورودی Omnichannel",
+ description: "تجمیع SMS، ایمیل، چت و شبکههای اجتماعی در یک inbox.",
+ phase: "Roadmap",
+ bundle: "Omnichannel Pack",
+ capabilities: ["Unified threads", "Agent assignment", "SLA timers"],
+ integrations: ["All channels", "CRM"],
+ },
+ marketing_automation: {
+ feature: "marketing_automation",
+ title: "Marketing Automation",
+ description: "اتوماسیون کمپین چندمرحلهای با trigger و segment.",
+ phase: "Roadmap",
+ bundle: "Marketing Pro",
+ capabilities: ["Drip campaigns", "A/B tests", "Segment builder"],
+ integrations: ["CRM", "Loyalty", "Analytics"],
+ },
+ automation_triggers: {
+ feature: "automation_triggers",
+ title: "Automation Triggers",
+ description: "تریگرهای رویداد-محور برای ارسال خودکار پیام.",
+ phase: "Roadmap",
+ bundle: "Automation",
+ capabilities: ["Event hooks", "Conditions", "Delay steps"],
+ integrations: ["All business modules"],
+ },
+ journey_builder: {
+ feature: "journey_builder",
+ title: "Journey Builder",
+ description: "طراح بصری مسیر مشتری با شاخه و wait steps.",
+ phase: "Roadmap",
+ bundle: "Marketing Pro",
+ capabilities: ["Visual canvas", "Branch logic", "Goal tracking"],
+ integrations: ["CRM", "Loyalty"],
+ },
+ ai_campaigns: {
+ feature: "ai_campaigns",
+ title: "AI Campaigns",
+ description: "پیشنهاد محتوا و زمانبندی هوشمند کمپین.",
+ phase: "Roadmap",
+ bundle: "AI Pack",
+ capabilities: ["Content generation", "Send-time optimization", "Churn prediction"],
+ integrations: ["AI Platform", "Analytics"],
+ },
+ webhook_center: {
+ feature: "webhook_center",
+ title: "Webhook Center",
+ description: "مدیریت متمرکز webhookهای ورودی و خروجی.",
+ phase: "Roadmap",
+ bundle: "Developer",
+ capabilities: ["Inbound/outbound", "Retry logs", "Signature rotation"],
+ integrations: ["All providers"],
+ },
+ connectors: {
+ feature: "third_party_connectors",
+ title: "Third-party Connectors",
+ description: "اتصال به سرویسهای خارجی و marketplace adapters.",
+ phase: "Roadmap",
+ bundle: "Integrations",
+ capabilities: ["Plugin registry", "OAuth flows", "Credential vault refs"],
+ integrations: ["Zapier-style", "Custom REST"],
+ },
+ conversations: {
+ feature: "customer_conversation_timeline",
+ title: "Customer Conversation Timeline",
+ description: "خط زمانی یکپارچه مکالمات مشتری across channels.",
+ phase: "Roadmap",
+ bundle: "CRM Plus",
+ capabilities: ["360 timeline", "Agent notes", "Context handoff"],
+ integrations: ["CRM", "Customer360"],
+ },
+ campaign_orchestrator: {
+ feature: "campaign_orchestrator",
+ title: "Campaign Orchestrator",
+ description: "هماهنگی کمپینهای چندکاناله با بودجه و cap.",
+ phase: "Roadmap",
+ bundle: "Marketing Pro",
+ capabilities: ["Cross-channel caps", "Budget guard", "Orchestration rules"],
+ integrations: ["SMS", "Email", "Push"],
+ },
+ notification_center: {
+ feature: "notification_center",
+ title: "Notification Center",
+ description: "مرکز اعلان in-app و out-of-app برای tenant users.",
+ phase: "Roadmap",
+ bundle: "Platform",
+ capabilities: ["In-app feed", "Preference center", "Digest mode"],
+ integrations: ["All modules"],
+ },
+ template_categories: {
+ feature: "template_categories",
+ title: "دستهبندی قالبها",
+ description: "سازماندهی قالبها در دستههای قابل جستجو.",
+ phase: "Roadmap",
+ bundle: "SMS Pro",
+ capabilities: ["Category tree", "Bulk assign", "Permissions per category"],
+ integrations: ["Templates"],
+ },
+ roles: {
+ feature: "communication_roles",
+ title: "نقشهای ارتباطات",
+ description: "مدیریت نقش اختصاصی Communication Platform.",
+ phase: "Roadmap",
+ bundle: "Enterprise",
+ capabilities: ["Role templates", "Scoped permissions", "Audit"],
+ integrations: ["Identity"],
+ },
+ audit: {
+ feature: "communication_audit_ui",
+ title: "ممیزی ارتباطات",
+ description: "رابط کاربری جستجوی audit log (backend موجود — UI در roadmap).",
+ phase: "Roadmap",
+ bundle: "Enterprise",
+ capabilities: ["Entity filter", "Export", "Retention policy"],
+ integrations: ["Compliance"],
+ },
+ api_keys: {
+ feature: "communication_api_keys",
+ title: "کلیدهای API",
+ description: "صدور و چرخش کلید API برای یکپارچهسازی سرویس-به-سرویس.",
+ phase: "Roadmap",
+ bundle: "Developer",
+ capabilities: ["Scoped keys", "Rotation", "Usage metrics"],
+ integrations: ["Core Identity"],
+ },
+ integrations_hub: {
+ feature: "integrations_hub",
+ title: "Integrations",
+ description: "مرکز یکپارچهسازی با ماژولهای TorbatYar.",
+ phase: "Roadmap",
+ bundle: "Platform",
+ capabilities: ["Module connectors", "Event subscriptions", "Health checks"],
+ integrations: ["CRM", "Loyalty", "Delivery", "Experience"],
+ },
+};
+
+export function getFutureModule(key: string): FeatureLockConfig | undefined {
+ return FUTURE_MODULE_REGISTRY[key];
+}
diff --git a/frontend/modules/communication/constants/permissions.ts b/frontend/modules/communication/constants/permissions.ts
new file mode 100644
index 0000000..51d682a
--- /dev/null
+++ b/frontend/modules/communication/constants/permissions.ts
@@ -0,0 +1,27 @@
+/** Mirrors backend app/permissions/definitions.py */
+export const COMMUNICATION_PERMISSIONS = [
+ "communication.view",
+ "communication.manage",
+ "communication.providers.view",
+ "communication.providers.manage",
+ "communication.senders.view",
+ "communication.senders.manage",
+ "communication.templates.view",
+ "communication.templates.manage",
+ "communication.templates.approve",
+ "communication.contacts.view",
+ "communication.contacts.manage",
+ "communication.sources.view",
+ "communication.sources.manage",
+ "communication.messages.view",
+ "communication.messages.send",
+ "communication.messages.cancel",
+ "communication.queue.view",
+ "communication.queue.manage",
+ "communication.otp.request",
+ "communication.otp.verify",
+ "communication.webhooks.manage",
+ "communication.monitoring.view",
+] as const;
+
+export type CommunicationPermission = (typeof COMMUNICATION_PERMISSIONS)[number];
diff --git a/frontend/modules/communication/constants/portals.ts b/frontend/modules/communication/constants/portals.ts
new file mode 100644
index 0000000..4fae087
--- /dev/null
+++ b/frontend/modules/communication/constants/portals.ts
@@ -0,0 +1,190 @@
+import type { LucideIcon } from "lucide-react";
+import {
+ LayoutDashboard,
+ MessageSquare,
+ Server,
+ FileText,
+ Users,
+ Send,
+ ListOrdered,
+ BarChart3,
+ Activity,
+ Settings,
+ Shield,
+ Key,
+ Plug,
+ Mail,
+ Bell,
+ Phone,
+ Video,
+ MessagesSquare,
+ Workflow,
+ Brain,
+ Webhook,
+ Layers,
+ History,
+ BookOpen,
+ Target,
+ Radio,
+ Lock,
+} from "lucide-react";
+
+export type PortalNavItem = {
+ href: string;
+ label: string;
+ feature?: string | null;
+ locked?: boolean;
+ lockKey?: string;
+};
+
+export type PortalNavGroup = {
+ id: string;
+ label: string;
+ icon: LucideIcon;
+ href?: string;
+ feature?: string | null;
+ items?: PortalNavItem[];
+};
+
+export const COMMUNICATION_PORTAL = {
+ id: "communication" as const,
+ label: "تربت ارتباط",
+ description: "پلتفرم Enterprise Communication — SMS Production Ready",
+ basePath: "/communication",
+ icon: MessageSquare,
+};
+
+export const COMMUNICATION_NAV: PortalNavGroup[] = [
+ {
+ id: "dashboards",
+ label: "داشبوردها",
+ icon: LayoutDashboard,
+ items: [
+ { href: "/communication", label: "داشبورد اجرایی" },
+ { href: "/communication/dashboard", label: "داشبورد ارتباطات" },
+ { href: "/communication/providers/dashboard", label: "داشبورد ارائهدهندگان" },
+ { href: "/communication/sms", label: "داشبورد SMS", feature: "sms" },
+ ],
+ },
+ {
+ id: "sms",
+ label: "پلتفرم SMS",
+ icon: Send,
+ feature: "sms",
+ items: [
+ { href: "/communication/sms/providers", label: "ارائهدهندگان SMS", feature: "sms" },
+ { href: "/communication/sms/templates", label: "قالبها", feature: "sms" },
+ {
+ href: "/communication/sms/template-categories",
+ label: "دستهبندی قالبها",
+ locked: true,
+ lockKey: "template_categories",
+ },
+ { href: "/communication/sms/senders", label: "Sender ID", feature: "sms" },
+ { href: "/communication/sms/campaigns", label: "کمپینهای SMS", feature: "sms" },
+ { href: "/communication/sms/send", label: "ارسال پیام", feature: "sms" },
+ { href: "/communication/sms/queue", label: "صف SMS", feature: "queue_engine" },
+ { href: "/communication/sms/delivery-reports", label: "گزارش تحویل", feature: "delivery_tracking" },
+ { href: "/communication/sms/messages", label: "تاریخچه پیام", feature: "sms" },
+ ],
+ },
+ {
+ id: "contacts",
+ label: "مخاطبین",
+ icon: Users,
+ feature: "dynamic_contact_sources",
+ items: [
+ { href: "/communication/contacts/recipients", label: "گیرندگان", feature: "dynamic_contact_sources" },
+ { href: "/communication/contacts/sources", label: "منابع پویا", feature: "dynamic_contact_sources" },
+ { href: "/communication/contacts/address-books", label: "دفترچه آدرس", feature: "dynamic_contact_sources" },
+ ],
+ },
+ {
+ id: "channels",
+ label: "کانالهای آینده",
+ icon: Layers,
+ items: [
+ { href: "/communication/email", label: "ایمیل", locked: true, lockKey: "email" },
+ { href: "/communication/whatsapp", label: "واتساپ", locked: true, lockKey: "whatsapp" },
+ { href: "/communication/telegram", label: "تلگرام", locked: true, lockKey: "telegram" },
+ { href: "/communication/rubika", label: "روبیکا", locked: true, lockKey: "rubika" },
+ { href: "/communication/push", label: "Push", locked: true, lockKey: "push" },
+ { href: "/communication/voice", label: "تماس صوتی", locked: true, lockKey: "voice" },
+ { href: "/communication/video", label: "تماس ویدیویی", locked: true, lockKey: "video" },
+ { href: "/communication/live-chat", label: "Live Chat", locked: true, lockKey: "live_chat" },
+ { href: "/communication/inbox", label: "Omnichannel Inbox", locked: true, lockKey: "omnichannel_inbox" },
+ ],
+ },
+ {
+ id: "automation",
+ label: "اتوماسیون",
+ icon: Workflow,
+ items: [
+ { href: "/communication/automation", label: "Marketing Automation", locked: true, lockKey: "marketing_automation" },
+ { href: "/communication/automation/triggers", label: "Automation Triggers", locked: true, lockKey: "automation_triggers" },
+ { href: "/communication/journey-builder", label: "Journey Builder", locked: true, lockKey: "journey_builder" },
+ { href: "/communication/ai-campaigns", label: "AI Campaigns", locked: true, lockKey: "ai_campaigns" },
+ { href: "/communication/campaign-orchestrator", label: "Campaign Orchestrator", locked: true, lockKey: "campaign_orchestrator" },
+ ],
+ },
+ {
+ id: "insights",
+ label: "گزارش و تحلیل",
+ icon: BarChart3,
+ items: [
+ { href: "/communication/reports", label: "گزارشها", feature: "metrics" },
+ { href: "/communication/analytics", label: "آنالیتیکس", feature: "metrics" },
+ { href: "/communication/otp", label: "OTP", feature: "otp" },
+ { href: "/communication/conversations", label: "خط زمانی مکالمات", locked: true, lockKey: "conversations" },
+ ],
+ },
+ {
+ id: "platform",
+ label: "پلتفرم",
+ icon: Server,
+ items: [
+ { href: "/communication/monitoring", label: "مانیتoring", feature: "metrics" },
+ { href: "/communication/health", label: "سلامت سرویس" },
+ { href: "/communication/capabilities", label: "قابلیتها" },
+ { href: "/communication/webhooks", label: "Webhook Center", locked: true, lockKey: "webhook_center" },
+ { href: "/communication/connectors", label: "Connectors", locked: true, lockKey: "connectors" },
+ { href: "/communication/notifications", label: "Notification Center", locked: true, lockKey: "notification_center" },
+ ],
+ },
+ {
+ id: "admin",
+ label: "مدیریت",
+ icon: Settings,
+ items: [
+ { href: "/communication/settings", label: "تنظیمات", feature: "provider_framework" },
+ { href: "/communication/permissions", label: "مجوزها" },
+ { href: "/communication/roles", label: "نقشها", locked: true, lockKey: "roles" },
+ { href: "/communication/audit", label: "ممیزی", locked: true, lockKey: "audit" },
+ { href: "/communication/api-keys", label: "کلید API", locked: true, lockKey: "api_keys" },
+ { href: "/communication/integrations", label: "Integrations", locked: true, lockKey: "integrations_hub" },
+ ],
+ },
+];
+
+export function navForCommunication(): PortalNavGroup[] {
+ return COMMUNICATION_NAV;
+}
+
+/** Show all nav items; do not hide locked/future modules. */
+export function filterNavForDisplay(
+ nav: PortalNavGroup[],
+ features?: Record
+): PortalNavGroup[] {
+ return nav.map((group) => ({
+ ...group,
+ items: group.items?.map((item) => ({
+ ...item,
+ locked:
+ item.locked ||
+ (item.feature ? features?.[item.feature] !== true : false) ||
+ false,
+ })),
+ }));
+}
+
+export { Lock };
diff --git a/frontend/modules/communication/constants/resourceRegistry.ts b/frontend/modules/communication/constants/resourceRegistry.ts
new file mode 100644
index 0000000..b70bf15
--- /dev/null
+++ b/frontend/modules/communication/constants/resourceRegistry.ts
@@ -0,0 +1,151 @@
+import { communicationApi } from "@/modules/communication/services/communication-api";
+import type { CommunicationListConfig } from "@/modules/communication/components/CommunicationListCrudPage";
+
+export const communicationResources = {
+ providers: {
+ title: "ارائهدهندگان SMS",
+ description: "پیکربندی mock، Payamak و failover",
+ resourceKey: "providers",
+ permission: "communication.providers.view",
+ api: {
+ list: (tenantId: string) => communicationApi.providers.list(tenantId),
+ create: (tenantId: string, body: Record) =>
+ communicationApi.providers.create(tenantId, body),
+ update: (tenantId: string, id: string, body: Record) =>
+ communicationApi.providers.update(tenantId, id, body),
+ remove: (tenantId: string, id: string) => communicationApi.providers.remove(tenantId, id),
+ },
+ columns: [
+ { key: "name", header: "نام" },
+ { key: "provider_kind", header: "نوع" },
+ { key: "channel", header: "کانال" },
+ { key: "status", header: "وضعیت", type: "status" as const },
+ { key: "priority", header: "اولویت" },
+ { key: "circuit_state", header: "Circuit" },
+ ],
+ createFields: [
+ { name: "name", label: "نام", required: true },
+ {
+ name: "provider_kind",
+ label: "نوع",
+ type: "select" as const,
+ required: true,
+ options: [
+ { value: "mock", label: "Mock" },
+ { value: "payamak", label: "Payamak" },
+ ],
+ },
+ { name: "channel", label: "کانال", required: true, placeholder: "sms" },
+ { name: "priority", label: "اولویت", type: "number" as const },
+ { name: "rate_limit_per_minute", label: "Rate limit/min", type: "number" as const },
+ ],
+ } satisfies CommunicationListConfig,
+
+ senders: {
+ title: "Sender ID",
+ description: "شمارههای ارسال SMS",
+ resourceKey: "senders",
+ permission: "communication.senders.view",
+ api: {
+ list: (tenantId: string) => communicationApi.providers.senders.list(tenantId),
+ create: (tenantId: string, body: Record) =>
+ communicationApi.providers.senders.create(tenantId, body),
+ },
+ columns: [
+ { key: "value", header: "شماره / شناسه" },
+ { key: "label", header: "برچسب" },
+ { key: "channel", header: "کانال" },
+ { key: "is_default", header: "پیشفرض" },
+ { key: "is_active", header: "فعال" },
+ ],
+ createFields: [
+ { name: "channel", label: "کانال", required: true, placeholder: "sms" },
+ { name: "value", label: "مقدار", required: true },
+ { name: "label", label: "برچسب" },
+ ],
+ readOnly: false,
+ } satisfies CommunicationListConfig,
+
+ templates: {
+ title: "قالبهای پیام",
+ resourceKey: "templates",
+ permission: "communication.templates.view",
+ api: {
+ list: (tenantId: string) => communicationApi.templates.list(tenantId),
+ create: (tenantId: string, body: Record) =>
+ communicationApi.templates.create(tenantId, body),
+ },
+ columns: [
+ { key: "template_key", header: "کلید" },
+ { key: "name", header: "نام" },
+ { key: "channel", header: "کانال" },
+ { key: "locale", header: "زبان" },
+ { key: "status", header: "وضعیت", type: "status" as const },
+ { key: "version", header: "نسخه" },
+ ],
+ createFields: [
+ { name: "template_key", label: "کلید قالب", required: true },
+ { name: "name", label: "نام", required: true },
+ { name: "channel", label: "کانال", required: true, placeholder: "sms" },
+ { name: "locale", label: "زبان", placeholder: "fa" },
+ { name: "body", label: "متن", type: "textarea" as const, required: true },
+ ],
+ } satisfies CommunicationListConfig,
+
+ recipients: {
+ title: "گیرندگان",
+ resourceKey: "recipients",
+ permission: "communication.contacts.view",
+ api: {
+ list: (tenantId: string) => communicationApi.contacts.manual.list(tenantId),
+ create: (tenantId: string, body: Record) =>
+ communicationApi.contacts.manual.create(tenantId, body),
+ },
+ columns: [
+ { key: "display_name", header: "نام" },
+ { key: "phone", header: "موبایل" },
+ { key: "email", header: "ایمیل" },
+ { key: "created_at", header: "ایجاد", type: "datetime" as const },
+ ],
+ createFields: [
+ { name: "display_name", label: "نام نمایشی" },
+ { name: "phone", label: "موبایل", required: true },
+ { name: "email", label: "ایمیل", type: "email" as const },
+ ],
+ } satisfies CommunicationListConfig,
+
+ contactSources: {
+ title: "منابع پویای مخاطب",
+ resourceKey: "contactSources",
+ permission: "communication.sources.view",
+ api: {
+ list: (tenantId: string) => communicationApi.contacts.sources.list(tenantId),
+ create: (tenantId: string, body: Record) =>
+ communicationApi.contacts.sources.create(tenantId, body),
+ },
+ columns: [
+ { key: "name", header: "نام" },
+ { key: "source_type", header: "نوع" },
+ { key: "base_url", header: "URL پایه" },
+ { key: "is_active", header: "فعال" },
+ ],
+ createFields: [
+ { name: "name", label: "نام", required: true },
+ {
+ name: "source_type",
+ label: "نوع منبع",
+ type: "select" as const,
+ required: true,
+ options: [
+ { value: "crm", label: "CRM" },
+ { value: "loyalty", label: "Loyalty" },
+ { value: "sports", label: "Sports" },
+ { value: "restaurant", label: "Restaurant" },
+ { value: "external_rest", label: "REST خارجی" },
+ ],
+ },
+ { name: "base_url", label: "URL پایه" },
+ { name: "endpoint_path", label: "مسیر endpoint" },
+ ],
+ } satisfies CommunicationListConfig,
+};
diff --git a/frontend/modules/communication/design-system/CommunicationStatGrid.tsx b/frontend/modules/communication/design-system/CommunicationStatGrid.tsx
new file mode 100644
index 0000000..95b9cee
--- /dev/null
+++ b/frontend/modules/communication/design-system/CommunicationStatGrid.tsx
@@ -0,0 +1,17 @@
+"use client";
+
+import { StatCard } from "@/components/ds";
+
+export function CommunicationStatGrid({
+ stats,
+}: {
+ stats: { label: string; value: string; hint?: string }[];
+}) {
+ return (
+
+ {stats.map((s) => (
+
+ ))}
+
+ );
+}
diff --git a/frontend/modules/communication/design-system/CommunicationStatusChip.tsx b/frontend/modules/communication/design-system/CommunicationStatusChip.tsx
new file mode 100644
index 0000000..5e81238
--- /dev/null
+++ b/frontend/modules/communication/design-system/CommunicationStatusChip.tsx
@@ -0,0 +1,10 @@
+"use client";
+
+import { Badge } from "@/components/ds";
+import { messageStatusLabels, messageStatusTone } from "./tokens";
+
+export function CommunicationStatusChip({ status }: { status: string }) {
+ const label = messageStatusLabels[status] ?? status;
+ const tone = messageStatusTone[status] ?? "default";
+ return {label};
+}
diff --git a/frontend/modules/communication/design-system/CommunicationTablePage.tsx b/frontend/modules/communication/design-system/CommunicationTablePage.tsx
new file mode 100644
index 0000000..80432fa
--- /dev/null
+++ b/frontend/modules/communication/design-system/CommunicationTablePage.tsx
@@ -0,0 +1,152 @@
+"use client";
+
+import { useMemo, useState } from "react";
+import { PageHeader, DataTable, EmptyState, Input, Pagination, Skeleton } from "@/components/ds";
+import { Search } from "lucide-react";
+import { CommunicationBreadcrumbs } from "@/modules/communication/components/CommunicationBreadcrumbs";
+
+export type CommunicationTableColumn = {
+ key: string;
+ header: string;
+ className?: string;
+ render?: (row: Record) => React.ReactNode;
+ searchable?: boolean;
+ sortable?: boolean;
+ defaultVisible?: boolean;
+};
+
+export function CommunicationTablePage({
+ title,
+ description,
+ breadcrumb,
+ columns,
+ rows,
+ empty,
+ actions,
+ searchPlaceholder = "جستجو…",
+ filterFn,
+ toolbar,
+ page,
+ pageSize,
+ onPageChange,
+ selectedIds,
+ onSelectionChange,
+ bulkActions,
+ loading,
+}: {
+ title: string;
+ description?: string;
+ breadcrumb?: string;
+ columns: CommunicationTableColumn[];
+ rows: Record[];
+ empty?: React.ReactNode;
+ actions?: React.ReactNode;
+ searchPlaceholder?: string;
+ filterFn?: (row: Record, query: string) => boolean;
+ toolbar?: React.ReactNode;
+ page?: number;
+ pageSize?: number;
+ onPageChange?: (page: number) => void;
+ selectedIds?: Set;
+ onSelectionChange?: (ids: Set) => void;
+ bulkActions?: React.ReactNode;
+ loading?: boolean;
+}) {
+ const [query, setQuery] = useState("");
+ const [sortKey, setSortKey] = useState(null);
+ const [sortDir, setSortDir] = useState<"asc" | "desc">("asc");
+
+ const visibleColumns = columns;
+
+ const filtered = useMemo(() => {
+ let data = rows;
+ const q = query.trim().toLowerCase();
+ if (q) {
+ data = filterFn
+ ? data.filter((r) => filterFn(r, q))
+ : data.filter((r) =>
+ visibleColumns.some((c) => {
+ if (c.searchable === false) return false;
+ const val = r[c.key];
+ return val != null && String(val).toLowerCase().includes(q);
+ })
+ );
+ }
+ if (sortKey) {
+ data = [...data].sort((a, b) => {
+ const av = a[sortKey];
+ const bv = b[sortKey];
+ const cmp = String(av ?? "").localeCompare(String(bv ?? ""), "fa");
+ return sortDir === "asc" ? cmp : -cmp;
+ });
+ }
+ return data;
+ }, [rows, query, visibleColumns, filterFn, sortKey, sortDir]);
+
+ const paged = useMemo(() => {
+ if (!pageSize || !page) return filtered;
+ const start = (page - 1) * pageSize;
+ return filtered.slice(start, start + pageSize);
+ }, [filtered, page, pageSize]);
+
+ const totalPages = pageSize ? Math.max(1, Math.ceil(filtered.length / pageSize)) : 1;
+
+ if (loading) {
+ return (
+
+
+
+
+ );
+ }
+
+ return (
+
+ {breadcrumb ?
: null}
+
+
+
+
+ setQuery(e.target.value)}
+ />
+
+ {toolbar}
+
+ {selectedIds && selectedIds.size > 0 && bulkActions ? (
+
+ {selectedIds.size} مورد انتخاب شده
+ {bulkActions}
+
+ ) : null}
+ {paged.length === 0 ? (
+ empty ??
+ ) : (
+ <>
+
({
+ key: c.key,
+ header: c.header,
+ className: c.className,
+ render: c.render
+ ? (row: Record) => c.render!(row)
+ : undefined,
+ }))}
+ rows={paged}
+ />
+ {pageSize && page && onPageChange ? (
+
+ ) : null}
+
+ )}
+
+
+
+
+ {Object.entries(features).map(([k, v]) => (
+
+
+ {k}
+ {v ? "فعال" : "غیرفعال"}
+
+
+ ))}
+
+
+
+ کانالها
+
+ {channels.map((c) => (
+
+ {c.channel}: {c.status}
+
+ ))}
+
+
+
+
+
+
v{caps.data?.version} · SMS MVP
+ }
+ />
+
+
+
+
+
+
+ {stats ? (
+
+
+
+ صف پیام
+
+ {JSON.stringify(stats.queue_by_status, null, 2)}
+
+
+
+
+
+ وضعیت پیامها
+
+ {JSON.stringify(stats.messages_by_status, null, 2)}
+
+
+
+
+
+
+
+
+ {health.data?.status}
+ {health.data?.service} — v{health.data?.version}
+ {ready.data ? (
+ DB: {ready.data.database} — {ready.data.status}
+ ) : null}
+
+
+
+
+
+
+ }
+ />
+ setDetailId(null)} title="Timeline تحویل">
+ {timelineQ.isLoading ? : null}
+ {timelineQ.data ? (
+ ({
+ id: String(e.id),
+ title: String(e.status),
+ subtitle: e.detail ? String(e.detail) : undefined,
+ timestamp: String(e.created_at ?? new Date().toISOString()),
+ }))}
+ />
+ ) : null}
+
+
+ );
+}
+
+export default MessagesPage;
diff --git a/frontend/modules/communication/features/monitoring.tsx b/frontend/modules/communication/features/monitoring.tsx
new file mode 100644
index 0000000..4904b95
--- /dev/null
+++ b/frontend/modules/communication/features/monitoring.tsx
@@ -0,0 +1,48 @@
+"use client";
+
+import { useQuery } from "@tanstack/react-query";
+import { communicationApi } from "@/modules/communication/services/communication-api";
+import { useTenantId } from "@/hooks/useTenantId";
+import { CommunicationPageLoader, CommunicationPageError } from "@/modules/communication/pages/shared";
+import { PageHeader, Card, CardContent } from "@/components/ds";
+import { CommunicationBreadcrumbs } from "@/modules/communication/components/CommunicationBreadcrumbs";
+
+export function MonitoringPage() {
+ const { tenantId } = useTenantId();
+ const q = useQuery({
+ queryKey: ["communication", tenantId, "monitoring"],
+ queryFn: () => communicationApi.monitoring.stats(tenantId!),
+ enabled: !!tenantId,
+ });
+ if (!tenantId || q.isLoading) return ;
+ if (q.error) return q.refetch()} />;
+
+ return (
+
+
+
+
{JSON.stringify(q.data, null, 2)}
+
+
+
+
{JSON.stringify(q.data, null, 2)}
+
+
+
+
+ {COMMUNICATION_PERMISSIONS.map((p) => (
+
+
+ {p}
+ تعریفشده
+
+
+ ))}
+
+
+
+
+
+
+ r.healthy).length)} />
+
+
+
+
+ {rows.map((p) => (
+
+
+
{String(p.name)}
+
{String(p.provider_kind)} · {String(p.channel)}
+
+
+
ارائهدهندهای ثبت نشده
: null}
+
+
+
+
+
processM.mutate()} loading={processM.isPending}>پردازش صف}
+ />
+
+ {Object.entries((stats as { by_status?: Record }).by_status ?? stats).slice(0, 6).map(([k, v]) => (
+ typeof v === "number" ? : null
+ ))}
+
+ },
+ { key: "attempt", header: "تلاش" },
+ { key: "last_error", header: "خطا" },
+ ]}
+ rows={dlq}
+ />
+
+
+
+
+
+ {q.data?.length ?? 0} ارائهدهنده فعال
+
+
+
+
+
+
+
+ {Object.entries(msg).map(([k, v]) => (
+
+ ))}
+ {Object.entries(queue).map(([k, v]) => (
+
+ ))}
+
+
+
+
+
+
+
+
+