Как отправить сочинение / ввод текста (состояния чата) в многопользовательском чате / групповом чате и в чате "один на один" в xmpp android?

Question

Я хочу отправить событие создания в групповом (многопользовательском) чате в xmpp, я использую библиотеку asmack, я выполнил ту же функцию в чате One-to-One.

Я использую ниже код:

mMessageEventManager = new MessageEventManager(XMPPConnectApplication.getInstance().getXmppConnection());

                mMessageEventManager.addMessageEventNotificationListener(new MessageEventNotificationListener() {

                    @Override
                    public void offlineNotification(String arg0, String arg1) {

                    }

                    @Override
                    public void displayedNotification(String arg0, String arg1) {

                    }

                    @Override
                    public void deliveredNotification(String arg0, String arg1) {

                    }

                    @Override
                    public void composingNotification(String from, String to) {
                        Log.e("Receiver-composingNotification",from + " is started typing......"+to);

                    }

                    @Override
                    public void cancelledNotification(String from, String to) {
                        Log.e("Receiver-cancelledNotification",from + " is stopped typing......"+to);

                    }
                }); 

Пожалуйста, дайте мне знать, если у вас есть идея для того же.

Любая помощь будет оценена.

Answer 1

Да, у меня есть идея об этом, и я сделал это до 1 недели.

Я использовал MessageEventManager для управления состояниями чата.

private MessageEventManager mMessageEventManager;

Добавьте этот метод для слушателя состояния чата:

private void chatStateRecognizer(){

        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                mMessageEventManager = new MessageEventManager(mXmppConnection);

                mMessageEventManager.addMessageEventNotificationListener(new MessageEventNotificationListener() {

                    @Override
                    public void offlineNotification(String arg0, String arg1) {

                    }

                    @Override
                    public void displayedNotification(String arg0, String arg1) {

                    }

                    @Override
                    public void deliveredNotification(String from, String arg1) {
                    }

                    @Override
                    public void composingNotification(String from, String to) {
                      Log.i("Receiver:Compose state",from + " is started typing......"+to);
                    }

                    @Override
                    public void cancelledNotification(String from, String to) {
                      Log.i("Receiver:Stop state",from + " is stopped typing......"+to);

                    }
                });
            }
        });

        thread.start();
    }

Создайте одно имя класса Model с GroupInfoModel.java:

public class GroupInfoModel implements Comparable<GroupInfoModel>, Serializable{

    private static final long serialVersionUID = 1L;
    private String memberId = "", memberName = "";
    private boolean isAdmin;
    public String getMemberId() {
        return memberId;
    }
    public void setMemberId(String memberId) {
        this.memberId = memberId;
    }
    public String getMemberName() {
        return memberName;
    }
    public void setMemberName(String memberName) {
        this.memberName = memberName;
    }
    public boolean isAdmin() {
        return isAdmin;
    }
    public void setAdmin(boolean isAdmin) {
        this.isAdmin = isAdmin;
    }
    @Override
    public int compareTo(GroupInfoModel another) {
        return getMemberName().compareTo(another.getMemberName());
    }
}

Теперь возьмите ArrayList класса GroupInfoModel.java:

private ArrayList<GroupInfoModel> groupDetailsList = new ArrayList<GroupInfoModel>();

private boolean isComposingStarted;

onCreate() действия / фрагмент:

groupDetailsList.clear();
ServiceDiscoveryManager discoManager = ServiceDiscoveryManager.getInstanceFor(mXmppConnection);
DiscoverItems items = discoManager.discoverItems(mRoomId);
    for (Iterator<Item> it = items.getItems(); it.hasNext();) {
        DiscoverItems.Item item = (DiscoverItems.Item) it.next();
        String occupant = item.getEntityID();
        occupant = occupant.split("/")[1];
        GroupInfoModel groupInfoModel = new GroupInfoModel();
        groupInfoModel.setAdmin(false);
        groupInfoModel.setMemberId(occupant+"@"+mServiceNameHere);
        groupInfoModel.setMemberName(occupant);
        groupDetailsList.add(groupInfoModel);
    }

Теперь добавьте TextWatcher на ваш экран EditText of Compose Message (просмотр чата):

@Override
public void onTextChanged(CharSequence s, int start, int before, int count) {
    if(s.toString().length()==1&&!isComposingStarted){
        isComposingStarted = true;
        if(chatType.equals("OneToOneChat")){
           mMessageEventManager.sendComposingNotification(myJabberId, friendJabberId);
        }else if(chatType.equals("GroupChat")){
           for (int i = 0; i < groupDetailsList.size(); i++) {
            if(!groupDetailsList.get(i).getMemberId().contains(myJabberId)){
              mMessageEventManager.sendComposingNotification(groupDetailsList.get(i).getMemberId(), roomId);    
            }
           }
        }
    }else if(s.toString().length()==0){
        isComposingStarted = false;
        if(chatType.equals("OneToOneChat")){
            mMessageEventManager.sendCancelledNotification(myJabberId, friendJabberId);
        }else if(chatType.equals("GroupChat")){
            for (int i = 0; i < groupDetailsList.size(); i++) {
               if(!groupDetailsList.get(i).getMemberId().contains(myJabberId)){
                 mMessageEventManager.sendCancelledNotification(groupDetailsList.get(i).getMemberId(), roomId); 
               }
            }
        }
    }
}

Я настоятельно рекомендую использовать приведенный выше код в классе Application, вы можете изменять методы в соответствии со своими требованиями.

Готово

Answer 2

// send multi user chat typing status
public static void sendMUCTypingStatus(ChatState state)
{
// check if you are connected to group
if(multiUserChat != null)
{
    try{
        // create packet
        Message statusPacket = new Message();
        // set body to null
        statusPacket.setBody(null);
        // set packet type to group chat
        statusPacket.setType(Message.Type.groupchat);
        // set subject to null
        statusPacket.setSubject(null);
        // set to the group name
        statusPacket.setTo(multiUserChat.getRoom());
        // set from my current jis example : [e-mail]
        statusPacket.setFrom(new MyPrefrence(XmppBase.context).getUsername());
        // get the chat state extension and pass our state
        ChatStateExtension extension = new ChatStateExtension(state);
        // add the extention to our packet
        statusPacket.addExtension(extension);
        // get the connection and send the packet
        Utils.getConnection().sendStanza(statusPacket);
    } catch (SmackException.NotConnectedException e) {
        e.printStackTrace();
    }
}
}

Использование:

sendMucTypingStatus(ChatState.composing);

смотреть это: краткий обзор использования

Answer 3

С RxJava и RxBinding Джейка Уортона это сделать довольно просто:

RxTextView.afterTextChangeEvents(editText)
    .observeOn(Schedulers.io())
    .skip(1)
    .map({ input ->
        // FIRE ChatState.composing EVENT HERE
        input  // just returning the argument here
    })
    .debounce(2, TimeUnit.SECONDS)
    .observeOn(Schedulers.io())
    .subscribe {
        // FIRE ChatState.active EVENT HERE
    }

Помните, что нам нужно будет написать код для перехвата этих событий через smack stanzaListener и соответственно отобразить его в пользовательском интерфейсе!

Код написан на Kotlin, но это довольно просто.