WebSocket client library
Websocket.cpp
- Committer:
- samux
- Date:
- 2011-08-15
- Revision:
- 3:9b00db719afa
- Parent:
- 2:4a841609a3a3
- Child:
- 4:1d3e630b8f9c
File content as of revision 3:9b00db719afa:
#include "Websocket.h" Websocket::Websocket(char * url, int port, Wifly * wifi) { char *res = NULL; char buf[30]; strcpy(buf, url); res = strtok(buf, ":"); if (strcmp(res, "ws")) { this->ip_domain = NULL; this->path = NULL; printf("\r\nFormat error: please use: \"ws://ip-or-domain/path\"\r\n\r\n"); } else { res = strtok(NULL, ":"); res = strtok(res, "/"); if(res != NULL) { ip_domain = (char *) malloc (sizeof(char) * strlen(res)); strcpy(this->ip_domain, res); } res = strtok(NULL, " "); if(res != NULL) { path = (char *) malloc (sizeof(char) * strlen(res)); strcpy(this->path, res); } this->port = port; this->wifi = wifi; } } bool Websocket::connect() { char cmd[50]; wifi->Send("exit\r", "NO"); //enter in cmd mode while(!wifi->Send("$$$", "CMD")) { printf("cannot enter in CMD mode\r\n"); wifi->exit(); } //open the connection sprintf(cmd, "open %s %d\r\n", ip_domain, port); if(!wifi->Send(cmd, "OPEN")) { printf("Websocket::connect cannot open\r\n"); return false; } //send websocket HTTP header sprintf(cmd, "GET /%s HTTP/1.1\r\n", path); wifi->Send(cmd, "NO"); sprintf(cmd, "Host: %s:%d\r\n", ip_domain, port); wifi->Send(cmd, "NO"); wifi->Send("Upgrade: WebSocket\r\n", "NO"); sprintf(cmd, "Origin: http:%s:%d\r\n", ip_domain, port); wifi->Send(cmd, "NO"); wifi->Send("Connection: Upgrade\r\n", "NO"); wifi->Send("Sec-WebSocket-Key1: 4 @1 46546xW%0l 1 5\r\n", "NO"); wifi->Send("Sec-WebSocket-key2: 12998 5 Y3 1 .P00\r\n\r\n", "NO"); if(!wifi->Send("^n:ds[4U", "8jKS'y:G*Co,Wxa-")) return false; printf("\r\nip_domain: %s\r\npath: /%s\r\nport: %d\r\n\r\n",this->ip_domain, this->path, this->port); return true; } void Websocket::Send(char * str) { char cmd[100]; wifi->putc('\x00'); sprintf(cmd, "%s%c", str, '\xff'); wifi->Send(cmd, "NO"); } bool Websocket::read(char * message) { int i = 0; char char_read; if (!wifi->readable()) { message = NULL; return false; } if (wifi->getc() != 0x00) { message = NULL; return false; } while ( (char_read = wifi->getc()) != 0xff) message[i++] = char_read; return true; } bool Websocket::close() { if(!wifi->CmdMode()) { printf("Websocket::close: cannot enter in cmd mode\r\n"); return false; } wifi->Send("close\r", "NO"); if(!wifi->exit()) return false; return true; } bool Websocket::connected() { char str[10]; wait(0.25); if(!wifi->CmdMode()) { printf("Websocket::connected: cannot enter in cmd mode\r\n"); return false; } wait(0.25); wifi->Send("show c\r\n", "NO"); wifi->read(str); if(str[3] == '1') { if(!wifi->exit()) { printf("Websocket::connected: cannot exit\r\n"); return false; } return true; } return false; }