OddSockets Flutter SDK

import 'package:oddsockets_flutter/oddsockets_flutter.dart';

final client = OddSocketsClient(
  OddSocketsConfig.defaultConfig('ak_live_1234567890abcdef'),
);

final channel = client.channel('my-channel');

// Subscribe to messages
await channel.subscribe((message) {
  print('Received: ${message.data}');
});

// Publish a message
await channel.publish('Hello, Flutter!');

class ChatWidget extends StatefulWidget {
  @override
  _ChatWidgetState createState() => _ChatWidgetState();
}

class _ChatWidgetState extends State<ChatWidget> {
  late OddSocketsClient client;
  late OddSocketsChannel channel;

  @override
  void initState() {
    super.initState();
    client = OddSocketsClient(
      OddSocketsConfig.defaultConfig('ak_live_1234567890abcdef'),
    );
    channel = client.channel('chat-room');
  }

  @override
  Widget build(BuildContext context) {
    return StreamBuilder<Message>(
      stream: channel.messageStream,
      builder: (context, snapshot) {
        if (snapshot.hasData) {
          return Text('Latest: ${snapshot.data!.data}');
        }
        return Text('Waiting for messages...');
      },
    );
  }
}

final config = OddSocketsConfig.builder('ak_live_1234567890abcdef')
    .mobile() // Mobile-optimized settings
    .heartbeatInterval(Duration(seconds: 45))
    .reconnectAttempts(10)
    .build();

final client = OddSocketsClient(config);

final client = OddSocketsClient(
  OddSocketsConfig(
    apiKey: 'your-api-key',           // Required: Your OddSockets API key
    userId: 'user-id',                // Optional: User identifier
    autoConnect: true,                // Optional: Auto-connect on creation
    reconnectAttempts: 5,             // Optional: Max reconnection attempts
    heartbeatInterval: Duration(seconds: 30), // Optional: Heartbeat interval
  ),
);

await channel.subscribe(callback, SubscribeOptions(
  enablePresence: true,             // Enable presence tracking
  retainHistory: true,              // Retain message history
  filterExpression: 'user.premium == true', // Message filter expression
));

await channel.publish(message, PublishOptions(
  ttl: Duration(hours: 1),          // Time to live
  metadata: {'priority': 'high'},   // Additional metadata
  storeInHistory: true,             // Store in message history
));

// Receive-path: broadcasts from other users on the channel
client.on('user_typing',    (data) => print('${data['userId']} is typing'));
client.on('reaction_added', (data) => print('${data['userId']} reacted ${data['emoji']}'));

// Send-path: enhanced actions over the live socket
client.enhanced.startTyping('alice', 'room-42');

client.enhanced.addReaction(
  messageId: 'msg-1',
  channel: 'room-42',
  emoji: ':thumbsup:',
  userId: 'alice',
  userName: 'Alice',
);

client.on('thread_reply', (data) => print('new thread reply'));

final reply = await client.enhanced.threadReply(
  channel: 'room-42',
  parentMessageId: 'msg-1',
  message: 'Replying in the thread',
  userId: 'alice',
  userName: 'Alice',
);
print('thread reply: $reply');

// Receive-path: live challenge broadcasts
client.on('leaderboard_rank_change', (data) => print('rank now ${data['rank']}'));

// Send-path: create, report progress, read standings, finalize
await client.enhanced.createChallenge({'challengeId': 'daily-500', 'metric': 'score', 'ranked': true});
client.enhanced.reportProgress({'challengeId': 'daily-500', 'value': 120});
final board = await client.enhanced.getStandings({'challengeId': 'daily-500', 'limit': 10});
print('top: ${board['standings']}, you: ${board['yourRank']}');
await client.enhanced.completeChallenge({'challengeId': 'daily-500', 'outcome': 'completed'});

class MobileChatApp extends StatefulWidget {
  @override
  _MobileChatAppState createState() => _MobileChatAppState();
}

class _MobileChatAppState extends State<MobileChatApp> with WidgetsBindingObserver {
  late OddSocketsClient client;
  late OddSocketsChannel channel;

  @override
  void initState() {
    super.initState();
    WidgetsBinding.instance.addObserver(this);
    
    // Mobile-optimized configuration
    final config = OddSocketsConfig.builder('ak_live_1234567890abcdef')
        .mobile() // Optimizes for battery life and mobile networks
        .build();
    
    client = OddSocketsClient(config);
    channel = client.channel('mobile-chat');
  }

  @override
  void didChangeAppLifecycleState(AppLifecycleState state) {
    super.didChangeAppLifecycleState(state);
    
    // Handle app lifecycle for better battery management
    switch (state) {
      case AppLifecycleState.paused:
        // Reduce heartbeat frequency when app is backgrounded
        break;
      case AppLifecycleState.resumed:
        // Restore normal operation when app is foregrounded
        break;
      default:
        break;
    }
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: Text('Mobile Chat')),
      body: StreamBuilder<Message>(
        stream: channel.messageStream,
        builder: (context, snapshot) {
          // Your chat UI here
          return Container();
        },
      ),
    );
  }
}

import 'dart:html' as html;

class WebChatApp extends StatefulWidget {
  @override
  _WebChatAppState createState() => _WebChatAppState();
}

class _WebChatAppState extends State<WebChatApp> {
  late OddSocketsClient client;
  late OddSocketsChannel channel;

  @override
  void initState() {
    super.initState();
    
    // Web-optimized configuration
    final config = OddSocketsConfig.builder('ak_live_1234567890abcdef')
        .web() // Optimizes for web browsers
        .build();
    
    client = OddSocketsClient(config);
    channel = client.channel('web-chat');
    
    // Handle browser tab visibility for better performance
    html.document.addEventListener('visibilitychange', (event) {
      if (html.document.hidden ?? false) {
        // Reduce activity when tab is not visible
      } else {
        // Resume normal activity when tab becomes visible
      }
    });
  }

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(title: Text('Web Chat')),
        body: StreamBuilder<Message>(
          stream: channel.messageStream,
          builder: (context, snapshot) {
            // Your web chat UI here
            return Container();
          },
        ),
      ),
    );
  }
}

class DesktopChatApp extends StatefulWidget {
  @override
  _DesktopChatAppState createState() => _DesktopChatAppState();
}

class _DesktopChatAppState extends State<DesktopChatApp> {
  late OddSocketsClient client;
  late OddSocketsChannel channel;

  @override
  void initState() {
    super.initState();
    
    // Desktop-optimized configuration
    final config = OddSocketsConfig.builder('ak_live_1234567890abcdef')
        .desktop() // Optimizes for desktop environments
        .build();
    
    client = OddSocketsClient(config);
    channel = client.channel('desktop-chat');
  }

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(title: Text('Desktop Chat')),
        body: Row(
          children: [
            // Sidebar for desktop layout
            Container(
              width: 250,
              child: StreamBuilder<PresenceInfo?>(
                stream: channel.presenceStream,
                builder: (context, snapshot) {
                  // User list sidebar
                  return Container();
                },
              ),
            ),
            // Main chat area
            Expanded(
              child: StreamBuilder<Message>(
                stream: channel.messageStream,
                builder: (context, snapshot) {
                  // Your desktop chat UI here
                  return Container();
                },
              ),
            ),
          ],
        ),
      ),
    );
  }
}

// Events
abstract class ChatEvent {}
class ChatStarted extends ChatEvent {}
class MessageReceived extends ChatEvent {
  final Message message;
  MessageReceived(this.message);
}
class MessageSent extends ChatEvent {
  final String content;
  MessageSent(this.content);
}

// States
abstract class ChatState {}
class ChatInitial extends ChatState {}
class ChatConnected extends ChatState {
  final List<Message> messages;
  ChatConnected(this.messages);
}

// BLoC
class ChatBloc extends Bloc<ChatEvent, ChatState> {
  final OddSocketsClient _client;
  late final OddSocketsChannel _channel;
  late StreamSubscription _messageSubscription;

  ChatBloc(this._client) : super(ChatInitial()) {
    _channel = _client.channel('chat-room');
    
    on<ChatStarted>(_onChatStarted);
    on<MessageReceived>(_onMessageReceived);
    on<MessageSent>(_onMessageSent);
  }

  Future<void> _onChatStarted(ChatStarted event, Emitter<ChatState> emit) async {
    await _channel.subscribe((message) {
      add(MessageReceived(message));
    });
    
    emit(ChatConnected([]));
  }

  void _onMessageReceived(MessageReceived event, Emitter<ChatState> emit) {
    if (state is ChatConnected) {
      final currentState = state as ChatConnected;
      emit(ChatConnected([...currentState.messages, event.message]));
    }
  }

  Future<void> _onMessageSent(MessageSent event, Emitter<ChatState> emit) async {
    await _channel.publish(event.content);
  }

  @override
  Future<void> close() {
    _messageSubscription.cancel();
    _client.dispose();
    return super.close();
  }
}