nexacon_messaging 1.0.0

Real-time messaging SDK for Nexacon — instant messaging with presence, typing indicators, delivery receipts, and message history.

nexacon_messaging

Real-time messaging SDK for Nexacon — instant messaging with presence, typing indicators, delivery receipts, and message history.

Features

• Real-time messaging — Send and receive messages instantly over WebSocket
• Presence tracking — Online/offline/away/busy status for users
• Typing indicators — Composing/paused chat state notifications (XEP-0085)
• Delivery receipts — Automatic delivery confirmation (XEP-0184)
• Read receipts — Manual read receipt sending
• Message history — Fetch paginated message history via REST API
• Auto-reconnect — Built-in reconnection with exponential backoff
• Heartbeat/ping — Keeps connection alive with periodic pings

Installation

Add to your pubspec.yaml:

dependencies:
  nexacon_messaging: ^1.0.0

Quick Start

import 'package:nexacon_messaging/nexacon_messaging.dart';

// Create the messaging instance
final messaging = NexaconMessaging(
  apiKey: 'your-api-key',
  secretKey: 'your-secret-key',
);

// Connect
final connected = await messaging.connect(
  nxid: '[e-mail]',
  password: 'nx-token',
  wsUrl: 'wss://nxservice.quantumvision-tech.com/xmpp-websocket',
);

if (connected) {
  // Listen for incoming messages
  messaging.messageStream.listen((msg) {
    print('Message from ${msg.from}: ${msg.body}');
  });

  // Listen for presence changes
  messaging.presenceStream.listen((presence) {
    print('${presence.from} is ${presence.status}');
  });

  // Listen for typing indicators
  messaging.typingStream.listen((event) {
    print('${event.from} is ${event.isTyping ? "typing..." : "stopped typing"}');
  });

  // Listen for delivery receipts
  messaging.deliveryReceiptStream.listen((receipt) {
    print('Message ${receipt.messageId} delivered to ${receipt.from}');
  });

  // Send a message
  await messaging.sendMessage(
    to: '[e-mail]',
    message: 'Hello!',
  );

  // Send typing indicator
  messaging.sendTypingIndicator('[e-mail]');

  // Update your presence
  messaging.setOnline();    // Available
  messaging.setAway();      // Away
  messaging.setBusy();      // Do not disturb
  messaging.setOffline();   // Offline

  // Fetch message history
  final history = await messaging.getMessageHistory(
    peer: '[e-mail]',
    page: 1,
    pageSize: 20,
  );
  print('Loaded ${history.messages.length} messages');
}

Connect with NX Token

If you have an NX token endpoint, you can connect in one step:

final connected = await messaging.connectWithToken(
  username: '[phone]',
  apiKey: 'your-api-key',
  secretKey: 'your-secret-key',
);

Presence Management

// Subscribe to a user's presence updates
messaging.subscribeToPresence('[e-mail]');

// Check cached presence
final status = messaging.getPresenceStatus('[e-mail]');
print('Status: $status'); // NxPresenceStatus.online, .offline, .away, .busy

// Query presence via REST API
final presence = await messaging.getPresence('[e-mail]');

Typing Indicators

// User started typing
messaging.sendTypingIndicator('[e-mail]', isTyping: true);

// User stopped typing
messaging.sendTypingIndicator('[e-mail]', isTyping: false);

// User is active in the chat
messaging.sendActiveState('[e-mail]');

// User left the chat
messaging.sendInactiveState('[e-mail]');

Cleanup

await messaging.disconnect();
messaging.dispose();

License

MIT