vg_msg api change

[carveJwlIkooP6JGAAIwe30JlM.git] / network.c

diff --git a/network.c b/network.c
index d60dc0cb38f429e32d102163e737649e2154e561..96832ae3166c253d15cc58994a442ff9ef740f7c 100644 (file)
--- a/network.c
+++ b/network.c
@@ -153,9 +153,9 @@ static void network_send_request( netmsg_request *req, vg_msg *body,
                                                     vg_msg *body )){
    u32 len = 0;
    if( body ){
-      len = body->len;
-      vg_info( "Request scoreboard. Info (%u):\n", body->len );
-      vg_msg_print( body );
+      len = body->cur.co;
+      vg_info( "Request scoreboard. Info (%u):\n", body->cur.co );
+      vg_msg_print( body, len );
 
       if( body->error != k_vg_msg_error_OK ){
          vg_error( "Body not OK\n" );
@@ -201,18 +201,12 @@ static void network_scoreboard_callback( netmsg_request *res, vg_msg *body ){
       return;
    }
 
-   /* TODO: frame pointers?? */
-
    u32 l = 0;
-   vg_msg rows = *body;
-   if( vg_msg_seekframe( &rows, "rows", k_vg_msg_first ) ){
-      vg_msg entry = rows;
-
-      while( vg_msg_seekframe( &entry, NULL, k_vg_msg_next ) ){
-         const char *username = vg_msg_seekkvstr( &entry, "username", 
-                                                  k_vg_msg_first );
+   if( vg_msg_seekframe( body, "rows" ) ){
+      while( vg_msg_seekframe( body, NULL ) ){
+         const char *username = vg_msg_getkvstr( body, "username" );
          sfd_encode( l ++, username );
-         vg_msg_skip_frame( &entry );
+         vg_msg_skip_frame( body );
       }
    }
 }
@@ -231,10 +225,8 @@ static void network_request_scoreboard( const char *mod_uid,
    req->inetmsg_id = k_inetmsg_request;
    req->id = 0; /* TODO: pool allocatable */
 
-   vg_msg data = {0};
-   data.buf = req->q;
-   data.max = 512;
-
+   vg_msg data;
+   vg_msg_init( &data, req->q, 512 );
    vg_msg_wkvstr( &data, "endpoint", "scoreboard" );
    vg_msg_wkvstr( &data, "mod", mod_uid );
    vg_msg_wkvstr( &data, "route", route_uid );
@@ -252,14 +244,12 @@ static void network_request_rx_300_400( SteamNetworkingMessage_t *msg ){
       netmsg_request *res = (netmsg_request *)msg->m_pData;
 
       vg_msg *body = NULL;
-      vg_msg data = {0};
 
+      vg_msg data;
       if( res->status == k_request_status_ok ){
-         data.buf = res->q;
-         data.len = msg->m_cbSize - sizeof(netmsg_request);
-         data.max = data.len;
+         vg_msg_init( &data, res->q, msg->m_cbSize - sizeof(netmsg_request) );
          vg_success( "Response to #%d:\n", (i32)res->id );
-         vg_msg_print( &data );
+         vg_msg_print( &data, data.max );
          body = &data;
       }
       else {