AllAccepted answers
Nezla · Jun 26

Hi Robert,

here is how my code looks like but when I comes to line code :  Set WebSoc=##class(%Net.WebSocket.Client).%New(WebSocURL,cre,evl)

it just hangs and doesn't go any further!?

ClassMethod GetAdvData() As %String
{
    S Token=##class(SX3.Task.TemperatureCollection).GetAuth()
        S BleMac="DC:0D:30:00:07:25",GatewayMac="CC:1B:E0:E2:52:D4"  // this for testing
set cre=##class(SX3.Production.HTTP.AdvCredenials).%New()
set evl=##class(SX3.Production.HTTP.AdvListener).%New()
Set WebSocURL="https://ac1.mqtt.sx3ac.com/api/gap/nodes?filter_mac="_BleMac_"&filter_rssi=-75&mac="_GatewayMac_"&active=1&event=1&chip=1&access_token="_Token
Set WebSoc=##class(%Net.WebSocket.Client).%New(WebSocURL,cre,evl)

S res=WebSoc.Next(30,1)

Quit WebSoc_"|"_WebSocURL
}

Class SX3.Production.HTTP.AdvCredenials Extends (%RegisteredObject, %Net.WebSocket.ICredentials)
{
Method GetUsername() As %String
{
quit "SuperUser"
}
/// Returns the password to use for authentication with the web socket
/// @API.Overrideable
Method GetPassword() As %String
{
quit "SYS"
}
Method GetSSLConfiguration() As %String
{
q "RTLS"
} }
 

Class SX3.Production.HTTP.AdvListener Extends (%RegisteredObject, %Net.WebSocket.IEventListener)
{ Method OnMessage(pContent As %Stream.Object)
{
S ^data("message")="1" //pContent.Read()

} 
}

Also changed the listener class to include you code and still the same, hangs

Class SX3.Production.HTTP.AdvListener Extends (%RegisteredObject, %Net.WebSocket.IEventListener)
{ Method OnOpen()
{
if $increment(%ct("O")) set io=$io use 0 write "OPEN",! break:$get(%b) use io
} /// Called when an error occurs in the web socket connection.<br />
/// @API.Overrideable
Method OnError(pError As %Exception.AbstractException)
{
if $increment(%ct("E")) set io=$io use 0 write !
do $system.OBJ.DisplayError()
if pError.Code=28000 kill ws   use io quit     ;connection lost
zwrite pError write ! break:$get(%b) use io
} /// Called when the web socket connection is closed by either the client (%OnClose) or the server (by sending a close frame).<br />
/// @API.Overrideable
Method OnClose()
{
 if $increment(%ct("C")) set io=$io use 0 write "CLOSE",! BREAK:$get(%b) use io
} /// Called when the client receives a message from the server. <br />
/// <var>pContent</var> may be a binary or UTF8-decoded character stream. <br />
/// @API.Overrideable
Method OnMessage(pContent As %Stream.Object)
{
if $increment(%ct("M")) set io=$io use 0 write "MESSAGE:",pContent,!
if $isobject(pContent) write pContent.Read(),!
if $get(%b) zwrite pContent BREAK  
use io
} }
 

any clues?

Thanks

Nezla · Jun 25

Thanks but it looks like you are not using Credential class (CRE.cls)? 
I think in my case it should be simpler, only need to create an instance of the WebsocketClient, set the URL and implement Credentials & the EventLister, and I can where you used EventLister but don't know where to use the Credentials  class?

But I also noticed that in your Try method you're actually sending message, in my case I'm looking to get messages, but if you can let me know where to use Credentials, that would be a good start for me to try and get data?  
Thanks  

Nezla · Jun 23

So basically I have a URL call that connect to server and continuously populate data so if I run that URL in a browser you will that data coming thought the browser and stopping till you close the browser, and they problem is if I use the same call using HTTP request I can't get any response because I guess didn't finish and will never finish collecting data to a response, so the solution is either to find a way to end the collection of HTTP request so can get a response, or use EventSource like in Javascript, below is a javascript code that can do it

var es = new EventSource('Myurl')
    checkTime();
    var startTime = new Date().getTime()
    es.onmessage = function(e) {
    var endTime=new Date().getTime();
    console.log(e.data);
    if ((endTime-startTime)>20000){es.close();return;}};
    es.onerror = function(e) {console.log('ERROR!'+e.status);es.close();return; };
    function checkTime() {
    setTimeout(function() {
    es.close();
    return;
    }, 60000);}

Thanks          

Nezla · Apr 29, 2024

I can always install the Gateway as I have already just installed it but the reason why I'm asking is that because after installing the gateway from CSPGateway installer my application didn't work and was wondering if not having the gateway initially installed with ensemble could be the reason why the Zen application is not working, I've raised a separate case in this link: 

Page not found in Zen application | InterSystems Developer Community |

Thanks

Nezla · Apr 3, 2024

Spot on Ben & Enrico, I've mapped the package in my namespace and now looks good, the only problem is that before doing that, I tried creating Security.Common in my namespace by copying the content of it from my old system then went to my new system right click in Security Package--> new class and pasted the content then save & compile, but before mapping the package as mentioned, I deleted the class from my namespace and after the  mapping I can all classes except  Security.Common, my namespace now compiles fine with no errors but I'm wondering if that means I lost the Common class from my %Sys namespace as I can't see it there anymore?

Thanks