OpChan/src/lib/identity/services/MessageService.ts

import { OpchanMessage } from '@/types';
import { AuthService } from './AuthService';
import messageManager from '@/lib/waku';

export interface MessageResult {
  success: boolean;
  message?: OpchanMessage;
  error?: string;
}

export class MessageService {
  private authService: AuthService;

  constructor(authService: AuthService) {
    this.authService = authService;
  }

  /**
   * Sign and send a message to the Waku network
   */
  async signAndSendMessage(message: OpchanMessage): Promise<MessageResult> {
    try {
      const signedMessage = await this.authService.signMessage(message);
      
      if (!signedMessage) {
        // Check if delegation exists but is expired
        const isDelegationExpired = this.authService.isDelegationValid() === false;
        
        return {
          success: false,
          error: isDelegationExpired 
            ? 'Key delegation expired. Please re-delegate your key through the profile menu.'
            : 'Key delegation required. Please delegate a signing key from your profile menu to post without wallet approval for each action.'
        };
      }
      
      await messageManager.sendMessage(signedMessage);
      
      return {
        success: true,
        message: signedMessage
      };
    } catch (error) {
      console.error("Error signing and sending message:", error);
      
      let errorMessage = "Failed to sign and send message. Please try again.";
      
      if (error instanceof Error) {
        if (error.message.includes("timeout") || error.message.includes("network")) {
          errorMessage = "Network issue detected. Please check your connection and try again.";
        } else if (error.message.includes("rejected") || error.message.includes("denied")) {
          errorMessage = "Wallet signature request was rejected. Please approve signing to continue.";
        } else {
          errorMessage = error.message;
        }
      }
      
      return {
        success: false,
        error: errorMessage
      };
    }
  }

  /**
   * Verify a message signature
   */
  verifyMessage(message: OpchanMessage): boolean {
    return this.authService.verifyMessage(message);
  }
}