+
+ if (isset($this->s2u[$id])) {
+ $user = $this->s2u[$id];
+
+ // fprintf(STDERR, 'POST USER');
+ if ($user && $user->rd_transp && strpos($user->rd_transp->type, "websocket") !== FALSE) {
+ $clie_cmd = $user->rd_transp->unchunk($buf);
+ $clie_cmd = json_decode($clie_cmd, TRUE);
+ // fprintf(STDERR, "HERE WE ARE INCOMING DATA [%s]\n", print_r($clie_cmd, TRUE));
+
+ ob_start();
+ // complete: index_wr_main($this->app, $addr, $get, $post, $cookie);
+ index_wr_main($this->app, $addr, $clie_cmd, NULL, NULL);
+ $content = ob_get_contents();
+ ob_end_clean();
+
+ // $this->pendpage_try_addflush($new_socket, 20, $enc, $header_out, $content);
+ // FIXME ^
+ // fprintf(STDERR, "RETURNED CONTENT [%s]\n", $content);
+ }
+ }
+ else {
+ fprintf(STDERR, "User associated with ID: %s not found\n", $id);
+ }
+
+ if (isset($this->s2u[$id])) {
+ $user = $this->s2u[$id];
+
+ fprintf(STDERR, 'POST USER');
+ if ($user && $user->rd_transp && strpos($user->rd_transp->type, "websocket") !== FALSE) {
+ fprintf(STDERR, "HERE WE ARE INCOMING DATA [%s]\n", $user->rd_transp->deframe($buf));
+
+ }
+ }
+ else {
+ fprintf(STDERR, "REC ID: %s\n", $id);
+ }