flutter_mqchat 0.1.2

MqChat client, this package enables you to use MQTT protocol as a chatting protocol, the broker should implement the HiveMq-Chat-Extension specifications.

Flutter client of MqChat, a protocol built over MQTT for chatting purposes.

Features

Use MQTT as a chat protocol, to create a modern chat application that supports all needed features. This is a flutter client of MqChat.

• ✅ Login
• ✅ Send/receive messages (text, image, vide, location, document, contact messages)
• ✅ Send Files
• ✅ Typing indicators
• ✅ Presence
• ✅ Group Chat
• ✅ Private Chat invitation

Getting started

Install the package flutter-mqchat:

flutter pub add flutter-mqchat

copied to clipboard

Usage

A full and rich example can be found in /example folder.

1. Login

User login using an existing account:

bool connected = await ChatApp.instance()!.clientHandler.connect(
        host: "broker.url.com",
        username: "[e-mail]",
        password: "user_pass");

copied to clipboard

After a successful login, the mqtt client will receive updates. The first updates to be received are profile details, rooms that users is member of, ongoing invitations and messages (if message archiving is supported by the broker).

2. Listen to my profile changes

ChatApp.instance()!.archiveHandler.getUser().listen((user) {
      //insert/update user to database
    });

copied to clipboard

3. Listen to rooms

Whenever the logged in user is added to a room (or room details changed), the room details will be added to the Conversations stream.

ChatApp.instance()!.archiveHandler.getAllConversations().listen((rooms) {
      //insert/update rooms on the Database
    });

copied to clipboard

4. Listen to new messages

ChatApp.instance()!.messageReader.getChatMessages().listen((message) {
      var dbMessage = message.toDbMessage();
      // insert the message to the database
      // send chatmarker if the message is not mine
    });

copied to clipboard

5. Listen to ChatMarkers

ChatApp.instance()!
        .messageReader
        .getChatMarkerMessages()
        .listen((markerMessage) {

      String messageId = markerMessage.referenceId;
      if (markerMessage.status == ChatMarker.displayed) {
          //update the database record
      } else if (markerMessage.status == ChatMarker.delivered) {
          //update the database record
      }
    });

copied to clipboard

6. Listen to new chat invitations

ChatApp.instance()!
        .invitationHandler
        .newInvitationsStream()
        .listen((invitation) {
          if(invitation.type == MessageType.EventInvitationRequest) {
            //new invitation request
            //insert invitation record to the database, notify the user
          }
          if(invitation.type == MessageType.EventInvitationResponseAccept || invitation.type == MessageType.EventInvitationResponseReject) {
            //responded to invitation, update the local record and wait the server to sync the new contact (if accepted).
            //Do not insert a room, the user will receive a new room details triggered by getAllConversations()
          }
    });

copied to clipboard

7. Listen to invitatioin updates

We use this to listen to the invitations that the user has sent. It could be:

• Info: When receive an affirmation that the invitation is sent
• Error: When there is an error (like the user is not found)

ChatApp.instance()!
        .invitationHandler
        .invitationUpdatesStream()
        .listen((invitation) {
      if (invitation.invitationMessageType == InvitationMessageType.INFO) {
       //update the invitation record to be confirmed
      }
      else if (invitation.invitationMessageType == InvitationMessageType.ERROR) {
        //notify the user, and delete the record in inserted
      }
    });

copied to clipboard

8. Send a text Message

ChatMessage newMessage = ChatMessage(
        id: "generated_random_id",
        type: MessageType.ChatText,
        text: "Hello there",
        roomId: "[room_id]",
        fromId: "[my_id]",//optional
        sendTime: DateTime.now().millisecondsSinceEpoch,
        fromName: "[my_name]");

copied to clipboard

8.1 Send the message as regular message

ChatApp.instance()!
          .messageSender
          .sendChatMessage(newMessage, "[room_id]");

copied to clipboard

8.2 Send the message as a reply to another message

ChatMessage replyToMessage = ...; //the message to reply to
ChatApp.instance()!
          .messageSender
          .replyToMessage(replyToMessage, newMessage, widget.contactChat.roomId);

copied to clipboard

9. Send File Message

 ChatApp.instance()!.messageSender.sendFileChatMessage(
          type: MessageType.ChatImage,//for example
          fileLocalPath: path,
          room: "[room_id]");

copied to clipboard

10. Send typing indicator

ChatApp.instance()!
          .eventsSender
          .sendIsTyping(true, "[room_id]");

copied to clipboard

11. Listen to typing indicator

ChatApp.instance()!.messageReader.getTypingMessages().listen((event) {
    //using event.roomId and event.isTyping and event.fromId, update the ui state
    
    });

copied to clipboard

12. Send new chat invitation

ChatApp.instance()!
        .eventsSender
        .sendInvitation("[invitee_username]", "[invitation_random_id]");

copied to clipboard

Additional information

TODO: Tell users more about the package: where to find more information, how to contribute to the package, how to file issues, what response they can expect from the package authors, and more.