@Channel

import { Channel, ChannelContext } from '@frontmcp/sdk';
import type { ChannelNotification } from '@frontmcp/sdk';

@Channel({
  name: 'deploy-alerts',
  description: 'CI/CD deployment notifications',
  source: { type: 'webhook', path: '/hooks/deploy' },
})
class DeployAlertChannel extends ChannelContext {
  async onEvent(payload: unknown): Promise<ChannelNotification> {
    const { body } = payload as { body: { status: string; version: string } };
    return {
      content: `Deploy ${body.status}: ${body.version}`,
      meta: { status: body.status },
    };
  }
}

function Channel(opts: ChannelMetadata): ClassDecorator

function channel(opts: ChannelMetadata): (handler: ChannelMessageHandler) => () => void

const ErrorChannel = channel({
  name: 'error-alerts',
  source: { type: 'app-event', event: 'app:error' },
})((payload) => ({
  content: `Error: ${(payload as { message: string }).message}`,
}));

source: { type: 'webhook', path: '/hooks/github' }

source: { type: 'app-event', event: 'app:error' }

source: { type: 'agent-completion', agentIds: ['code-reviewer'] }

source: { type: 'job-completion', jobNames: ['daily-report'] }

source: { type: 'service', service: 'whatsapp-business' }

source: { type: 'file-watcher', paths: ['./logs/*.log'], events: ['change'] }

source: { type: 'manual' }

interface ChannelNotification {
  /** Notification content (appears inside <channel> tags in Claude) */
  content: string;
  /** Key-value metadata (becomes XML attributes on the <channel> tag) */
  meta?: Record<string, string>;
}

@Channel({
  name: 'chat-bridge',
  source: { type: 'webhook', path: '/hooks/chat' },
  twoWay: true,
})
class ChatBridge extends ChannelContext {
  async onEvent(payload: unknown): Promise<ChannelNotification> {
    const { body } = payload as { body: { sender: string; text: string; chatId: string } };
    return {
      content: `${body.sender}: ${body.text}`,
      meta: { chat_id: body.chatId },
    };
  }

  async onReply(reply: string, meta?: Record<string, string>): Promise<void> {
    await sendToChatPlatform(meta?.chat_id, reply);
  }
}

@FrontMcp({
  channels: {
    enabled: true,
    defaultMeta: { server: 'my-app' },  // Optional
  },
})