Porting code to vNext - Forum

humba

2020-02-03, 14:33 #1

Member since Feb 2020 · 23 posts
Group memberships: Members

Show profile ·

Link to this post

Subject: Porting code to vNext

I have a working solution using the old matrix lib that I need to bring into the .NET core world. So I swapped out the matrix libs and now I'm flailing trying to migrate my code.

For instance, I'm using xmppClient.StreamActive to determine if an XmppClient has a connection or now. How does that translate to Matrix vNext?

Similarly, I subscribed to a variety of OnXXXX events. Going by the sample for message subscription I managed to port OnMessage and OnPresence, but there's a bunch of other events I'm still struggling with: OnClose, OnError, OnStreamError, OnXmlError, OnAuthError. How do these translate?

I'm also using the PubSubManager in the old lib and I haven't found a replacement there, either.

Alex

2020-02-03, 17:03 #2

Member since Feb 2003 · 4449 posts · Location: Germany
Group memberships: Administrators, Members

Show profile ·

Link to this post

Hello humba,

Quote by humba:
I have a working solution using the old matrix lib that I need to bring into the .NET core world. So I swapped out the matrix libs and now I'm flailing trying to migrate my code.

Similarly, I subscribed to a variety of OnXXXX events. Going by the sample for message subscription I managed to port OnMessage and OnPresence, but there's a bunch of other events I'm still struggling with: OnClose, OnError, OnStreamError, OnXmlError, OnAuthError. How do these translate?

MatriX vNext is very different from MatriX. You cannot just change the libraries with some minor changes and recompile. You have to rewrite and redesign lots of your code.

MatriX vNext is reactive, there are no classical events. You have to filter on the packet stream and subscribe to it with actions instead.
See also:
https://matrix-xmpp.io/docs/receiving-messages

Quote by humba:
For instance, I'm using xmppClient.StreamActive to determine if an XmppClient has a connection or now. How does that translate to Matrix vNext?

In MatriX vNext I guess the closest is the XmppSessionState which you can get from the XmppSessionStateObserver.

xmppClient.XmppSessionStateObserver.Subscribe(v => {
   Debug.WriteLine($"State changed: {v}");
});

Quote by humba:
I'm also using the PubSubManager in the old lib and I haven't found a replacement there, either.

this does not exist yet. If it helps I can send you the codes of the previous MatriX version for that which can be easily ported.
This is on the ToDo list for vNext and will come to the Matrix.Extensions package soon.

You can also look at this sample client on GitHub here which shows you many of the concepts in MatriX vNext.

Best,
Alex

humba

2020-02-03, 18:29 #3

Member since Feb 2020 · 23 posts
Group memberships: Members

Show profile ·

Link to this post

I've already downloaded the source code and I'm going through various classes that appear interesting.

I understand the notification subscription (and I've already ported session state, Message, Iq and Presence handling, as well as unsubscription), yet, as with the OnXXX events I listed, there's a bunch of error events and there's no documentation on error handling. I don't know when I should be expecting which exception (in case something goes wrong which I'm sure it will in the beginning - it was the same when I first started (my server is Cisco Finesse)). Say, I'm connecting with incorrect credentials.. what would be the response to ConnectAsync? And how can my application get informed about a connection closing? (there's no Closing in SessionState - would receiving a SessionState.Disconnected be )

I also found a ReconnectHandliner in the source code which I suspect would do automatic reconnect.. yet, it's unused in the entire repo (reconnect is something I do need.. I was using OnClose event to inform my application that the connection broken, and triggering a reconnect).

PubSubManager code would sure help.. either I stop this thing now and delay the entire port or I have to port it now. PubSub is essential to what I'm going. I found a bunch of classes in the source, but again, no live usage so no change for me to figure out what goes where. I only need to List active subscriptions, and add/remove subscriptions (methods

Iq data = await mgr.RequestSubscriptionsAsync(pubSubAddress, null, pubSubManagerTimeout).ConfigureAwait(false);
Iq data = await mgr.SubscribeAsync(pubSubAddress, node, user, pubSubManagerTimeout).ConfigureAwait(false);
Iq data = await mgr.UnsubscribeAsync(pubSubAddress, node, user, pubSubManagerTimeout).ConfigureAwait(false);

Alex

2020-02-03, 19:29 #4

Member since Feb 2003 · 4449 posts · Location: Germany
Group memberships: Administrators, Members

Show profile ·

Link to this post

Hello humba,

those are many questions at the same time. Let me try to answer them. And let me know if some answers are missing ;-)

When you loose you connection the state changes to disconnected.

As you have seen there is reconnect logic build in. This is best used together with stream management.
Here is a sample how to enable it:

var xmppClient = new XmppClient(
conf =>
{
    conf.UseAutoReconnect();
    conf.UseStreamManagement();
},
pipelineInitializerAction)
{
    Username = "user",
    Password = "secret",
    XmppDomain = "server.com",
    HostnameResolver = new SrvNameResolver(),
};

ConnectAsync throws exceptions, they are all defined in the Xml docs. Please see here:

/// <summary>
/// Connect to the XMPP server.
/// This establishes the connection to the server, including TLS, authentication, resource binding and
/// compression.
/// </summary>
/// <param name="cancellationToken"></param>
/// <returns></returns>
/// <exception cref="AuthenticationException">Thrown when the authentication fails.</exception>
/// <exception cref="BindException">Thrown when resource binding fails.</exception>
/// <exception cref="StreamErrorException">Throws a StreamErrorException when the server returns a stream error.</exception>
/// <exception cref="CompressionException">Throws a CompressionException when establishing stream compression fails.</exception>
/// <exception cref="RegisterException">Throws aRegisterException when new account registration fails.</exception>

I have attached the code of the PubSubManager. This should help you to port the PubSubManager functions over to MatriX vnext.
You only need to get the code which is building the packets, and then use SendIqAsync as described here:
https://matrix-xmpp.io/docs/info-query

Alex

The author has attached one file to this post:

PubSubManager.cs 74.5 kBytes
You have no permission to open this file.

Alex

2020-02-04, 11:30 #5

Member since Feb 2003 · 4449 posts · Location: Germany
Group memberships: Administrators, Members

Show profile ·

Link to this post

PubSub extensions are in MatriX vNext now.
See:
https://github.com/matrix-xmpp/matrix-vnext/tree/master/sr…

New NuGet packages are available as well.

humba

2020-02-05, 11:00 #6

Member since Feb 2020 · 23 posts
Group memberships: Members

Show profile ·

Link to this post

In reply to post #4

Hehe.. and I was just done porting what I needed from the PubSubManager. It was pretty easy though.

For the ONXXX events.. here's what I came up with

OnPresence:

presenceHandler = xmppClient
                .XmppXElementStreamObserver
                .Where(el => el is Presence)
                .Subscribe(el =>
                {
                    // handle the message here
                    XmppClient_OnPresence(xmppClient, el as Presence);
                });

OnIq

            iqHandler = xmppClient
                .XmppXElementStreamObserver
                .Where(el => el is Iq)
                .Subscribe(el =>
                {
                    // handle the message here
                    XmppClient_OnIq(xmppClient, el as Iq);
                });

OnMessage

messageHandler = xmppClient
                .XmppXElementStreamObserver
                .Where(el => el is Message)
                .Subscribe(el =>
                {
                    // handle the message here
                    XmppClient_OnMessage(xmppClient, el as Message);
                });

OnClose

sessionStateHandler = xmppClient.XmppSessionStateObserver.Subscribe(v => 
            {
                OnSessionState(v);
            });
 
private void OnSessionState(SessionState state)
        {
            Log($"session state has changed, new state: {state}", 4);
            switch (state)
            {
                case SessionState.Disconnected:
                    XmppClient_OnClose();
                    break;
            }
        }

OnStreamError: catch StreamErrorException thrown from ConnectAsync

OnAuthError: catch AuthenticationException from ConnectAsync

OnBindError: catch BindException from ConnectAsync

OnBind:

extend the above OnSessionState to handle SessionState.Binding.

OnError: I have no clue at present.. any idea? My code just sets the internal connection state to error, but does otherwise not react to it.

Alex

2020-02-05, 12:09 #7

Member since Feb 2003 · 4449 posts · Location: Germany
Group memberships: Administrators, Members

Show profile ·

Link to this post

Quote by humba:
OnError: I have no clue at present.. any idea? My code just sets the internal connection state to error, but does otherwise not react to it.

This was required in the previous version of MatriX because its using the older callback based asynchronous pattern with BeginXXX and EndXXX. So some kind of callback is required to raise back errors and exception to the application code for asynchronous operations.

MatriX vNext is all based on tasks/async/await pattern (TAP). So you can catch all you exceptions on the awaitable operations, eg. using try/catch pattern.

The stream errors you can catch over the XmppXElementStreamObserver.

Alex

humba

2020-02-05, 13:42 #8

Member since Feb 2020 · 23 posts
Group memberships: Members

Show profile ·

Link to this post

I'm running my code now. And I'm not getting MESSAGE and PRESENCE events, only Iqs. I sniffed traffic from the old and the new solution. One thing I noted is that the old matrix client would query the roster implicitly.. I added that manually to my vnext code after ConnectAsync.. now as far as I can tell, things are pretty much the same. But I must be missing something still.

This is what I get if I do follow TCP stream in Wireshark using the old matrix lib

<stream:stream xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client" to="chdevuccx105.nxodev.intra" version="1.0" >
    <?xml version='1.0' encoding='UTF-8'?>
    <stream:stream xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client" from="chdevuccx105.nxodev.intra" id="13bc6ee6" xml:lang="en" version="1.0">
        <stream:features>
            <mechanisms xmlns="urn:ietf:params:xml:ns:xmpp-sasl">
                <mechanism>PLAIN</mechanism>
            </mechanisms>
            <auth xmlns="http://jabber.org/features/iq-auth"/>
            <register xmlns="http://jabber.org/features/iq-register"/>
        </stream:features>
        <auth mechanism="PLAIN" xmlns="urn:ietf:params:xml:ns:xmpp-sasl">my secret goes here</auth>
        <success xmlns="urn:ietf:params:xml:ns:xmpp-sasl"/>
        <stream:stream xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client" to="chdevuccx105.nxodev.intra" version="1.0" >
            <?xml version='1.0' encoding='UTF-8'?>
            <stream:stream xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client" from="chdevuccx105.nxodev.intra" id="13bc6ee6" xml:lang="en" version="1.0">
                <stream:features>
                    <bind xmlns="urn:ietf:params:xml:ns:xmpp-bind"/>
                    <session xmlns="urn:ietf:params:xml:ns:xmpp-session"/>
                </stream:features>
                <iq id="MX_1" type="set">
                    <bind xmlns="urn:ietf:params:xml:ns:xmpp-bind">
                        <resource>MatriX</resource>
                    </bind>
                </iq>
                <iq type="result" id="MX_1" to="chdevuccx105.nxodev.intra/13bc6ee6">
                    <bind xmlns="urn:ietf:params:xml:ns:xmpp-bind">
                        <jid>pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX</jid>
                    </bind>
                </iq>
                <iq id="MX_2" type="set">
                    <session xmlns="urn:ietf:params:xml:ns:xmpp-session" />
                </iq>
                <iq type="result" id="MX_2" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX"/>
                <iq id="MX_3" type="get">
                    <query xmlns="jabber:iq:roster" />
                </iq>
                <iq type="result" id="MX_3" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX">
                    <query xmlns="jabber:iq:roster">
                        <item jid="finesse@chdevuccx105.nxodev.intra" subscription="both"/>
                        <item jid="admin@chdevuccx105.nxodev.intra" subscription="both"/>
                        <item jid="presencelistener@chdevuccx105.nxodev.intra" subscription="both"/>
                    </query>
                </iq>
                <presence>
                    <status/>
                    <priority>0</priority>
                </presence>
                <presence id="rV85B-7" from="finesse@chdevuccx105.nxodev.intra/web_framework" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX"/>
                <presence id="JC3X6-3" from="admin@chdevuccx105.nxodev.intra/desktop" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX"/>
                <iq id="MX_4" type="get" to="pubsub.chdevuccx105.nxodev.intra">
                    <pubsub xmlns="http://jabber.org/protocol/pubsub">
                        <subscriptions />
                    </pubsub>
                </iq>
                <iq type="result" id="MX_4" from="pubsub.chdevuccx105.nxodev.intra" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX">
                    <pubsub xmlns="http://jabber.org/protocol/pubsub">
                        <subscriptions>
                            <subscription node="/finesse/api/User/pmgr_agentmonitoring/Dialogs" jid="pmgr_agentmonitoring@chdevuccx105.nxodev.intra" subscription="subscribed"/>
                            <subscription node="/finesse/api/User/pmgr_agentmonitoring" jid="pmgr_agentmonitoring@chdevuccx105.nxodev.intra" subscription="subscribed"/>
                            <subscription node="/finesse/api/SystemInfo" jid="pmgr_agentmonitoring@chdevuccx105.nxodev.intra" subscription="subscribed"/>
                        </subscriptions>
                    </pubsub>
                </iq>
                <iq id="MX_5" to="pubsub.chdevuccx105.nxodev.intra" type="set">
                    <pubsub xmlns="http://jabber.org/protocol/pubsub">
                        <subscribe node="/finesse/api/User/mtra" jid="pmgr_agentmonitoring@chdevuccx105.nxodev.intra" />
                    </pubsub>
                </iq>
                <iq type="result" id="MX_5" from="pubsub.chdevuccx105.nxodev.intra" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX">
                    <pubsub xmlns="http://jabber.org/protocol/pubsub">
                        <subscription node="/finesse/api/User/mtra" jid="pmgr_agentmonitoring@chdevuccx105.nxodev.intra" subscription="subscribed">
                            <subscribe-options/>
                        </subscription>
                    </pubsub>
                </iq>
                <message from="pubsub.chdevuccx105.nxodev.intra" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra" id="/finesse/api/User/mtra__pmgr_agentmonitoring@chdevuccx105.nxodev.intra__qwEqo">
                    <event xmlns="http://jabber.org/protocol/pubsub#event">
                        <items node="/finesse/api/User/mtra">
                            <item id="f5e95957-d6bd-47ea-9e62-ff2bb80be86336">
                                <notification xmlns="http://jabber.org/protocol/pubsub">&lt;Update&gt;
  &lt;data&gt;
    &lt;user&gt;
      &lt;dialogs&gt;/finesse/api/User/mtra/Dialogs&lt;/dialogs&gt;
      &lt;extension&gt;5006&lt;/extension&gt;
      &lt;firstName&gt;Admin&lt;/firstName&gt;
      &lt;lastName&gt;Minh&lt;/lastName&gt;
      &lt;loginId&gt;mtra&lt;/loginId&gt;
      &lt;loginName&gt;mtra&lt;/loginName&gt;
      &lt;mediaType&gt;1&lt;/mediaType&gt;
      &lt;pendingState&gt;&lt;/pendingState&gt;
      &lt;reasonCodeId&gt;-1&lt;/reasonCodeId&gt;
      &lt;roles&gt;
        &lt;role&gt;Agent&lt;/role&gt;
      &lt;/roles&gt;
      &lt;settings&gt;
        &lt;wrapUpOnIncoming&gt;&lt;/wrapUpOnIncoming&gt;
      &lt;/settings&gt;
      &lt;state&gt;NOT_READY&lt;/state&gt;
      &lt;stateChangeTime&gt;2020-02-05T12:02:57.095Z&lt;/stateChangeTime&gt;
      &lt;teamId&gt;1&lt;/teamId&gt;
      &lt;teamName&gt;Default&lt;/teamName&gt;
      &lt;uri&gt;/finesse/api/User/mtra&lt;/uri&gt;
    &lt;/user&gt;
  &lt;/data&gt;
  &lt;event&gt;PUT&lt;/event&gt;
  &lt;requestId&gt;01746877-93c7-479d-8075-64b5522a83d8&lt;/requestId&gt;
  &lt;source&gt;/finesse/api/User/mtra&lt;/source&gt;
&lt;/Update&gt;</notification>
                            </item>
                        </items>
                    </event>
                </message>
                <message from="pubsub.chdevuccx105.nxodev.intra" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra" id="/finesse/api/User/mtra__pmgr_agentmonitoring@chdevuccx105.nxodev.intra__65IQy">
                    <event xmlns="http://jabber.org/protocol/pubsub#event">
                        <items node="/finesse/api/User/mtra">
                            <item id="f5e95957-d6bd-47ea-9e62-ff2bb80be86338">
                                <notification xmlns="http://jabber.org/protocol/pubsub">&lt;Update&gt;
  &lt;data&gt;
    &lt;user&gt;
      &lt;dialogs&gt;/finesse/api/User/mtra/Dialogs&lt;/dialogs&gt;
      &lt;extension&gt;5006&lt;/extension&gt;
      &lt;firstName&gt;Admin&lt;/firstName&gt;
      &lt;lastName&gt;Minh&lt;/lastName&gt;
      &lt;loginId&gt;mtra&lt;/loginId&gt;
      &lt;loginName&gt;mtra&lt;/loginName&gt;
      &lt;mediaType&gt;1&lt;/mediaType&gt;
      &lt;pendingState&gt;&lt;/pendingState&gt;
      &lt;roles&gt;
        &lt;role&gt;Agent&lt;/role&gt;
      &lt;/roles&gt;
      &lt;settings&gt;
        &lt;wrapUpOnIncoming&gt;&lt;/wrapUpOnIncoming&gt;
      &lt;/settings&gt;
      &lt;state&gt;READY&lt;/state&gt;
      &lt;stateChangeTime&gt;2020-02-05T12:03:00.370Z&lt;/stateChangeTime&gt;
      &lt;teamId&gt;1&lt;/teamId&gt;
      &lt;teamName&gt;Default&lt;/teamName&gt;
      &lt;uri&gt;/finesse/api/User/mtra&lt;/uri&gt;
    &lt;/user&gt;
  &lt;/data&gt;
  &lt;event&gt;PUT&lt;/event&gt;
  &lt;requestId&gt;5f6b2359-4f15-4371-8596-78a0e160b170&lt;/requestId&gt;
  &lt;source&gt;/finesse/api/User/mtra&lt;/source&gt;
&lt;/Update&gt;</notification>
                            </item>
                        </items>
                    </event>
                </message>

The pubsub stuff can be ignored.. that works on both clients

humba

2020-02-05, 13:43 #9

Member since Feb 2020 · 23 posts
Group memberships: Members

Show profile ·

Link to this post

and from the vnext

<stream:stream xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client" to="chdevuccx105.nxodev.intra" version="1.0" >
    <?xml version='1.0' encoding='UTF-8'?>
    <stream:stream xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client" from="chdevuccx105.nxodev.intra" id="e2a418e4" xml:lang="en" version="1.0">
        <stream:features>
            <mechanisms xmlns="urn:ietf:params:xml:ns:xmpp-sasl">
                <mechanism>PLAIN</mechanism>
            </mechanisms>
            <auth xmlns="http://jabber.org/features/iq-auth"/>
            <register xmlns="http://jabber.org/features/iq-register"/>
        </stream:features>
        <auth mechanism="PLAIN" xmlns="urn:ietf:params:xml:ns:xmpp-sasl">secret secret</auth>
        <success xmlns="urn:ietf:params:xml:ns:xmpp-sasl"/>
        <stream:stream xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client" to="chdevuccx105.nxodev.intra" version="1.0" >
            <?xml version='1.0' encoding='UTF-8'?>
            <stream:stream xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client" from="chdevuccx105.nxodev.intra" id="e2a418e4" xml:lang="en" version="1.0">
                <stream:features>
                    <bind xmlns="urn:ietf:params:xml:ns:xmpp-bind"/>
                    <session xmlns="urn:ietf:params:xml:ns:xmpp-session"/>
                </stream:features>
                <iq id="Lo1O3xkhCE2O5tvvSvH6hA" type="set" xmlns="jabber:client">
                    <bind xmlns="urn:ietf:params:xml:ns:xmpp-bind">
                        <resource>MatriX</resource>
                    </bind>
                </iq>
                <iq type="result" id="Lo1O3xkhCE2O5tvvSvH6hA" to="chdevuccx105.nxodev.intra/e2a418e4">
                    <bind xmlns="urn:ietf:params:xml:ns:xmpp-bind">
                        <jid>pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX</jid>
                    </bind>
                </iq>
                <iq id="WMjerjLKG0WYaGRv4uesLw" type="set" xmlns="jabber:client">
                    <session xmlns="urn:ietf:params:xml:ns:xmpp-session" />
                </iq>
                <iq type="result" id="WMjerjLKG0WYaGRv4uesLw" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX"/>
                <iq id="588Sz5dxaESvS3s+tkMNzw" type="get" xmlns="jabber:client">
                    <query xmlns="jabber:iq:roster" />
                </iq>
                <iq type="result" id="588Sz5dxaESvS3s+tkMNzw" to="pmgr_agentmonitoring@chdevuccx105.nxodev.intra/MatriX">
                    <query xmlns="jabber:iq:roster">
                        <item jid="finesse@chdevuccx105.nxodev.intra" subscription="both"/>
                        <item jid="admin@chdevuccx105.nxodev.intra" subscription="both"/>
                        <item jid="presencelistener@chdevuccx105.nxodev.intra" subscription="both"/>
                    </query>
                </iq>
            </stream:stream>
        </stream:stream>

Any idea what could be going wrong?

And do you have an example of getting errors from XmppXElementStreamObserver?

This post was edited on 2020-02-05, 13:46 by Alex.

Alex

2020-02-05, 13:51 #10

Member since Feb 2003 · 4449 posts · Location: Germany
Group memberships: Administrators, Members

Show profile ·

Link to this post

The ConnectAsync sets up the connection until resource binding.
It does not set your own presence which is required for getting other presences and messages.
It also does not fetch the roster automatically.

The reason for this is that is that presence and roster are not required in all applications.

When you need roster and presence then just do it like described here in the Console client sample:
https://github.com/matrix-xmpp/matrix-vnext/blob/a99f7d7e2…

// Connect the XMPP connection
await xmppClient.ConnectAsync();
 
// request the roster (aka contact list)
var roster = await xmppClient.RequestRosterAsync();
 
// Send our presence to the server
await xmppClient.SendPresenceAsync(Show.Chat, "free for chat");

humba

2020-02-05, 14:30 #11

Member since Feb 2020 · 23 posts
Group memberships: Members

Show profile ·

Link to this post

Setting the presence after querying the roster did the trick, thanks.

So the only thing remaining is catching errors from XmppXElementStreamObserver. Do you have an example on how to do that?

Alex

2020-02-05, 15:46 #12

Member since Feb 2003 · 4449 posts · Location: Germany
Group memberships: Administrators, Members

Show profile ·

Link to this post

Quote by humba:
Setting the presence after querying the roster did the trick, thanks.

So the only thing remaining is catching errors from XmppXElementStreamObserver. Do you have an example on how to do that?

for <stream:error/> you just subscribe to the Error element in the Matrix.Xmpp.Stream namespace

xmppClient
    .XmppXElementStreamObserver
    .Where(el => el is Matrix.Xmpp.Stream.Error)
    .Subscribe(el =>
    {
        // handle the stream errors here        
    });