WebSocket to WebSocket Integration using Subprotocols

If you need to read and transform the content of WebSocket frames, the information in incoming WebSocket frames is not sufficient because the WebSocket protocol does not specify any information about the content-type of frames that flow through WebSocket channels. Hence, WSO2 Enterprise Integrator deﬁnes a WebSocket subprotocol extension to determine the content type of WebSocket frames.

WSO2 Enterprise Integrator's WebSocket inbound endpoint supports the following Synapse subprotocols by default:

synapse(contentType='application/json')
synapse(contentType='application/xml')
synapse(contentType='text/xml')

Now let's look at a sample scenario that demonstrates WebSocket to WebSocket integration using subprotocols to support content handling.

This scenario includes the following sections:

Introduction

Let's say you need to send messages between two WebSocket based systems using WSO2 Enterprise Integrator as a WebSocket gateway that facilitates the messaging, and you also need to read and transform the content of WebSocket frames that are sent and received.

The following should take place in this scenario:

The WebSocket Client sends WebSocket frames to WSO2 Enterprise Integrator.
When the initial handshake happens between the WebSocket client and WSO2 EI WebSocket inbound endpoint, the WebSocket client sends a Sec-WebSockets-Protocol header that specifies the content type of the WebSocket frame. In this sample it is synapse(contentType='application/json').
WSO2 Enterprise Integrator's WebSocket inbound endpoint determines the content-type of the incoming WebSocket frame using the subprotocol.
Once the handshake is complete, the WebSocket inbound endpoint builds all the subsequent WebSocket frames based on the content-type specified during the initial handshake.
WSO2 Enterprise Integrator sends the transformed message in the form of WebSocket frames.

If necessary, you can use the data mapper to perform data transformation inside WSO2 Enterprise Integrator message flow. For example, you can perform JSON to JSON transformation. To do this, you have to explicitly apply the required data mapping logic for all WebSocket frames.

Prerequisites

Start WSO2 Enterprise Integrator. For information on how to start WSO2 Enterprise Integrator,see Running the Product.
Download the netty artifacts.
Open a terminal, navigate to the location where you saved the netty artifacts, and execute the following command to start the WebSocket server on port 8082:
```
java -cp netty-example-4.0.30.Final.jar:lib/*:. io.netty.example.http.websocketx.server.WebSocketServer
```

Configuring the sample scenario

Create the sequence for client to back-end mediation as follows:

<sequence name="dispatchSeq" xmlns="http://ws.apache.org/ns/synapse">
    <property name="OUT_ONLY" value="true"/>
    <property name="websocket.accept.contenType" scope="axis2" value="application/json"/>
    <log level="full">
        <property name="LOGGED_MESSAGE" value="LOGGED"/>
    </log>
    <send>
        <endpoint>
            <address uri="ws://localhost:8082/websocket"/>
        </endpoint>
    </send>
</sequence>

Specify the websocket.accept.contenType property to inform the WebSocket sender to build the frames with the specified content type, and to include the same subprotocol header that was used to determine the content of the WebSocket frames. In this case it is JSON.

Create the sequence for back-end to client mediation as follows:

<sequence name="outDispatchSeq" trace="enable" xmlns="http://ws.apache.org/ns/synapse">
    <respond/>
    <log level="full"/>
</sequence>

Configure WSO2 Enterprise Integrator's WebSocket inbound endpoint as follows to use the created sequences and listen on port 9091:

<inboundEndpoint name="test" onError="fault" protocol="ws"
   	sequence="dispatchSeq" suspend="false">
   	<parameters>
       	<parameter name="inbound.ws.port">9091</parameter>
       	<parameter name="ws.outflow.dispatch.sequence">outDispatchSeq</parameter>
       	<parameter name="ws.client.side.broadcast.level">0</parameter>
       	<parameter name="ws.outflow.dispatch.fault.sequence">fault</parameter>
   	</parameters>
</inboundEndpoint>

Executing the sample scenario

Open a terminal, navigate to the location where you saved the netty artifacts, and execute the following command to start the WebSocket client:
```
java -DsubProtocol="synapse(contentType='application/json') -DclientPort=9091 -cp netty-example-4.0.30.Final.jar:lib/*:.io.netty.example.http.websocketx.client.WebSocketClient
```
You will see the message WebSocket Client connected ! on the client terminal.
Send the following sample JSON payload from the client terminal:
```
("sample message":"test"}
```

Analyzing the output

When you send a sample JSON payload from the client, you will see that a connection from the WebSocket client to WSO2 Enterprise Integrator is established, and that WSO2 Enterprise Integrator receives the message. Following is the WSO2 Enterprise Integrator log that you will see:

This shows that the sequences are executed by the WebSocket inbound endpoint.

You will also see that the message sent to the WebSocket server is transformed, and that the response injected to the out sequence is also transformed.

Following is the server log that you will see:

Following is the client log that you will see: