deleteMessages static method

Future<DeleteMessagesAck> deleteMessages(P2PStream stream, List<String> messageIds)

Delete messages immediately (client-side)

Implementation

static Future<DeleteMessagesAck> deleteMessages(
  P2PStream stream,
  List<String> messageIds,
) async {
  try {
    final request = DeleteMessagesRequest(messageIds: messageIds);

    // Encode and send request with length prefix
    final requestBytes = AccessFrame.encodeDeleteMessages(request);
    await _writeFrameStatic(stream, requestBytes);

    // Read acknowledgment
    final ackBytes = await _readFrameStatic(stream);
    return AccessFrame.decodeDeleteMessagesAck(ackBytes);
  } catch (e, stackTrace) {
    _logger.severe('Error deleting messages: $e', e, stackTrace);
    rethrow;
  }
}