receiveMessages method

Future<DynamiteResponse<ChatReceiveMessagesResponseApplicationJson, ChatChatReceiveMessagesHeaders>> receiveMessages({
  1. required String token,
  2. required ChatReceiveMessagesLookIntoFuture lookIntoFuture,
  3. ChatReceiveMessagesApiVersion? apiVersion,
  4. int? limit,
  5. int? lastKnownMessageId,
  6. int? lastCommonReadId,
  7. int? timeout,
  8. ChatReceiveMessagesSetReadMarker? setReadMarker,
  9. ChatReceiveMessagesIncludeLastKnown? includeLastKnown,
  10. ChatReceiveMessagesNoStatusUpdate? noStatusUpdate,
  11. ChatReceiveMessagesMarkNotificationsAsRead? markNotificationsAsRead,
  12. bool? oCSAPIRequest,
})

Receives chat messages from the given room.

  • Receiving the history ($lookIntoFuture=0): The next $limit messages after $lastKnownMessageId will be returned. The new $lastKnownMessageId for the follow up query is available as X-Chat-Last-Given header.
  • Looking into the future ($lookIntoFuture=1): If there are currently no messages the response will not be sent immediately. Instead, HTTP connection will be kept open waiting for new messages to arrive and, when they do, then the response will be sent. The connection will not be kept open indefinitely, though; the number of seconds to wait for new messages to arrive can be set using the timeout parameter; the default timeout is 30 seconds, maximum timeout is 60 seconds. If the timeout ends a successful but empty response will be sent. If messages have been returned (status=200) the new $lastKnownMessageId for the follow up query is available as X-Chat-Last-Given header. The limit specifies the maximum number of messages that will be returned, although the actual number of returned messages could be lower if some messages are not visible to the participant. Note that if none of the messages are visible to the participant the returned number of messages will be 0, yet the status will still be 200. Also note that X-Chat-Last-Given may reference a message not visible and thus not returned, but it should be used nevertheless as the $lastKnownMessageId for the follow-up query.

Returns a Future containing a DynamiteResponse with the status code, deserialized body and headers. Throws a DynamiteApiException if the API call does not return an expected status code.

Parameters:

  • apiVersion Defaults to "v1".
  • token
  • lookIntoFuture Polling for new messages (1) or getting the history of the chat (0).
  • limit Number of chat messages to receive (100 by default, 200 at most). Defaults to 100.
  • lastKnownMessageId The last known message (serves as offset). Defaults to 0.
  • lastCommonReadId The last known common read message (so the response is 200 instead of 304 when it changes even when there are no messages). Defaults to 0.
  • timeout Number of seconds to wait for new messages (30 by default, 30 at most). Defaults to 30.
  • setReadMarker Automatically set the last read marker when 1, if your client does this itself via chat/{token}/read set to 0. Defaults to 1.
  • includeLastKnown Include the $lastKnownMessageId in the messages when 1 (default 0). Defaults to 0.
  • noStatusUpdate When the user status should not be automatically set to online set to 1 (default 0). Defaults to 0.
  • markNotificationsAsRead Set to 0 when notifications should not be marked as read (default 1). Defaults to 1.
  • oCSAPIRequest Required to be true for the API request to pass. Defaults to true.

Status codes:

  • 200: Messages returned
  • 304: No messages

See:

Implementation

Future<_i1.DynamiteResponse<ChatReceiveMessagesResponseApplicationJson, ChatChatReceiveMessagesHeaders>>
    receiveMessages({
  required String token,
  required ChatReceiveMessagesLookIntoFuture lookIntoFuture,
  ChatReceiveMessagesApiVersion? apiVersion,
  int? limit,
  int? lastKnownMessageId,
  int? lastCommonReadId,
  int? timeout,
  ChatReceiveMessagesSetReadMarker? setReadMarker,
  ChatReceiveMessagesIncludeLastKnown? includeLastKnown,
  ChatReceiveMessagesNoStatusUpdate? noStatusUpdate,
  ChatReceiveMessagesMarkNotificationsAsRead? markNotificationsAsRead,
  bool? oCSAPIRequest,
}) async {
  final _request = $receiveMessages_Request(
    token: token,
    lookIntoFuture: lookIntoFuture,
    apiVersion: apiVersion,
    limit: limit,
    lastKnownMessageId: lastKnownMessageId,
    lastCommonReadId: lastCommonReadId,
    timeout: timeout,
    setReadMarker: setReadMarker,
    includeLastKnown: includeLastKnown,
    noStatusUpdate: noStatusUpdate,
    markNotificationsAsRead: markNotificationsAsRead,
    oCSAPIRequest: oCSAPIRequest,
  );
  final _streamedResponse = await _rootClient.httpClient.send(_request);
  final _response = await _i3.Response.fromStream(_streamedResponse);

  final _serializer = $receiveMessages_Serializer();
  return _i1.ResponseConverter<ChatReceiveMessagesResponseApplicationJson, ChatChatReceiveMessagesHeaders>(
    _serializer,
  ).convert(_response);
}