void addCoHostListener(CoHostListener listener);

void removeCoHostListener(CoHostListener listener);

Future<CompletionHandler> requestHostConnection({
    required String targetHostLiveID,
    required CoHostLayoutTemplate layoutTemplate,
    required int timeout,
    String extraInfo = '',
});

Future<CompletionHandler> cancelHostConnection(String toHostLiveID);

Future<CompletionHandler> acceptHostConnection(String fromHostLiveID);

Future<CompletionHandler> rejectHostConnection(String fromHostLiveID);

Future<CompletionHandler> exitHostConnection();

Future<CompletionHandler> getCoHostCandidates(String cursor);

// Create store instance
final store = CoHostStore.create('live_room_123');

// Define listeners
late final VoidCallback statusListener = _onStatusChanged;
late final VoidCallback connectedListener = _onConnectedChanged;

void _onStatusChanged() {
    print('Connection status: ${store.coHostState.coHostStatus.value}');
}

void _onConnectedChanged() {
    print('Connected hosts: ${store.coHostState.connected.value.length}');
}

// Subscribe to state changes
store.coHostState.coHostStatus.addListener(statusListener);
store.coHostState.connected.addListener(connectedListener);

// Add connection event listener
final coHostListener = CoHostListener(
    onCoHostRequestReceived: (inviter, extensionInfo) {
        print('Received connection request from ${inviter.userName}');
        // Show accept/reject UI
    },
    onCoHostRequestAccepted: (invitee) {
        print('Connection request accepted by ${invitee.userName}');
    },
    onCoHostUserJoined: (userInfo) {
        print('Host ${userInfo.userName} joined connection');
    },
);
store.addCoHostListener(coHostListener);

// Initiate connection request
final result = await store.requestHostConnection(
    targetHostLiveID: 'target_live_id',
    layoutTemplate: CoHostLayoutTemplate.hostDynamicGrid,
    timeout: 30,
    extraInfo: '',
);
if (result.code == 0) {
    print('Connection request sent successfully');
}

// Unsubscribe when done
store.coHostState.coHostStatus.removeListener(statusListener);
store.coHostState.connected.removeListener(connectedListener);
store.removeCoHostListener(coHostListener);