Presentando Harbour websocket server

[Otto]

Dear Antonio,

It seems to me that the WSS is not forwarding the messages to the connected clients.
The server only responds to received messages and sends back to the original sender.

I wanted to make changes, but I'm missing files: hbmk2: Error: Referenced, missing, but unknown function(s): HB_SOCKETISOPEN(),
AP_FILENAME()

Code: Select all | Expand

   For Each hClient in aClients
                  if hb_socketIsOpen( hClient )
                     hb_socketSend( hClient, Mask( cRequest ) )
                  endif
               Next

Best regards,
Otto

[Antonio Linares]

Dear Otto,

That functions belongs to Harbour, it may not be linked into mod_harbour

[Otto]

Dear Antonio,

I think hb_socketSend() to all connected clients is missing in the websocketserver.
But I can't build myself a new exe.
Maybe you can provide a new exe.
Best regards,
Otto

[Otto]

Dear Antonio,

> That functions belongs to Harbour, it may not be linked into mod_harbour
It seems to me that this is missing in wsserver.prg.

Thank you in advance and best regards,
Otto

[Antonio Linares]

Dear Otto,

I have searched for hb_socketIsOpen() in all Harbour sources and it is not found. Maybe it was proposed by the AI ?

Harbour's hb_socketSend() is defined in src/rtl/hbsocket.c and hbsockhb.c ( high level HB_FUNC( HB_SOCKETSEND ) )

Code: Select all | Expand

long hb_socketSend( HB_SOCKET sd, const void * data, long len, int flags, HB_MAXINT timeout )
{
   long lSent = 0;

   hb_vmUnlock();

   if( timeout >= 0 )
   {
      lSent = hb_socketSelectWR( sd, timeout );
      if( lSent == 0 )
      {
         hb_socketSetError( HB_SOCKET_ERR_TIMEOUT );
         lSent = -1;
      }
   }
   if( lSent >= 0 )
   {
      int iError;

      flags = hb_socketTransFlags( flags );
      /* in POSIX systems writing data to broken connection stream causes
       * that system generates SIGPIPE which has to be caught by application
       * otherwise the default action for SIGPIPE is application termination.
       * we do not want to generate it so we are setting MSG_NOSIGNAL flag.
       */
#if defined( MSG_NOSIGNAL )
      flags |= MSG_NOSIGNAL;
#endif
      do
      {
         lSent = send( sd, ( const char * ) data, len, flags );
         iError = lSent > 0 ? 0 : HB_SOCK_GETERROR();
         hb_socketSetOsError( iError );
      }
      while( lSent == -1 && HB_SOCK_IS_EINTR( iError ) &&
             hb_vmRequestQuery() == 0 );
   }
   hb_vmLock();

   return lSent;
}
 

If you try to build wsserver.prg using hb_socketSend() it should be found, but hb_socketIsOpen() will be missing.

I am not sure if you meant that or I may have not properly understood you

[Otto]

Dear Antonio,
thank you.

Now with this changes all the clients get the same info.
Best regards,
Otto

Code: Select all | Expand

function ServeClient( hSocket )

   local cRequest, cBuffer := Space( 4096 ), nLen, nOpcode
   local I := 0
   AAdd( aClients, hSocket )
   
   hb_socketRecv( hSocket, @cBuffer,,, 1024 )
  
   HandShaking( hSocket, RTrim( cBuffer ) )
 
   ? "new client connected"

   USE log SHARED

   while .T.
      cRequest = ""
      nLen = 1

      while nLen > 0
         cBuffer := Space( 4096 )
         if ( nLen := hb_socketRecv( hSocket, @cBuffer,,, TIMEOUT ) ) > 0  
            cRequest += Left( cBuffer, nLen )
         else
            if nLen == -1 .and. hb_socketGetError() == HB_SOCKET_ERR_TIMEOUT
               nLen = 0
            endif
         endif
      end
      
      if ! Empty( cRequest )
         cRequest:= UnMask( cRequest, @nOpcode )
         
         do case
            case cRequest == "exit"          // 1000 value in hex and bytes swapped 
               hb_socketSend( hSocket, Mask( I2Bin( 0xE803 ) + "exiting", OPC_CLOSE ) )   // close handShake
               
            case cRequest == I2Bin( 0xE803 ) + "exiting"                                  // client answered to close handShake
               exit
               
            otherwise
               ? " Antwort: "  +cRequest
         //      hb_socketSend( hSocket, Mask( "*" + cRequest ) )
 
          FOR I := 1 to len( aClients )
                   
                  hb_socketSend( aClients[I], Mask( cRequest ) )
              Next
         endcase
      endif
   end

   ? "close socket"

   hb_socketShutdown( hSocket )
   hb_socketClose( hSocket )

   USE

return nil