Socket Server for link between multiple XBee Wifi modules and offsite server
eagletalontim
Posts: 1,399
Well, I just powered up my first Spinneret for the first time and have it connected to my router.... I have downloaded the SPIN socket server (Familiar language) I found from other posts and have my router configured to forward all requests from port 236 to port 8080. So far, this works great. I can open the PST and see the request come through. Now...
How do I do something with the request? If I plan on having this server communicate with the web, how to I send data to an off site server via the GET (Query string) or POST?
Can I also run a separate program along with the Spinneret Server? I am hoping to be able to run my Power Logger in the Spinneret and have it communicate with my off site server to store data for viewing via the Web.
How do I do something with the request? If I plan on having this server communicate with the web, how to I send data to an off site server via the GET (Query string) or POST?
Can I also run a separate program along with the Spinneret Server? I am hoping to be able to run my Power Logger in the Spinneret and have it communicate with my off site server to store data for viewing via the Web.
Comments
EDIT ***
I think I figured out the issue with it dying. Seems the browser I was using would send multiple header requests to the spinneret and the last request would open the connection but no bytes would be sent causing it to hang here :
repeat until NULL < bytesToRead := sock.AvailableI have stopped accessing it directly and wrote a PHP socket client script on my offsite server to send and receive messages from the Spinneret. http://www.techboneyard.com/home-stuff/ is the URL. It seems to work quite nicely. I can send text and the Spinneret will send it back which is what will display on the page
I still don't know how to Send data to a URL without a socket. Any help on this please?
CON _clkmode = xtal1 + pll16x _xinfreq = 5_000_000 BUFFER_2K = $800 CR = $0D LF = $0A NULL = $00 #0, CLOSED, TCP, UDP, IPRAW, MACRAW, PPPOE 'W5100 I/O SPI_MISO = 0 ' SPI master in serial out from slave SPI_MOSI = 1 ' SPI master out serial in to slave SPI_CS = 2 ' SPI chip select (active low) SPI_SCK = 3 ' SPI clock from master to all slaves WIZ_INT = 13 WIZ_RESET = 14 SPI_MODE = 15 delay = 500 timeout = 1 VAR DAT header byte "HTTP/1.1 200 OK", CR, LF, { } "Content-Type: text/html", CR, LF, CR, LF, $0 body byte "Hello World!", CR, LF, $0 SendURL BYTE "POST /spinneret/getpost.aspx?id=1&test=2 HTTP/1.1", CR, LF, { } "Host: agaverobotics.com", CR, LF, { } "Connection: keep-alive", CR, LF, { } "Content-Type: application/x-www-form-urlencoded", CR, LF, { } "Content-length: 23", CR, LF, CR, LF, { } "name=test&submit=Submit", $0 buff byte $0[BUFFER_2K] fileErrorHandle long $0 approot byte "\", 0 OBJ pst : "Parallax Serial Terminal" wiz : "W5100" sock : "Socket" SDCard : "S35390A_SD-MMC_FATEngineWrapper" 'http : "HttpHeader" PUB Main | bytesToRead, offset, tail, i bytesToRead := 0 pst.Start(115_200) pause(5000) SDCard.Start pause(500) 'Mount the SD card pst.str(string("Mount SD Card - ")) SDCard.mount(fileErrorHandle) pst.str(string("OK",13)) wiz.HardReset(WIZ_RESET) 'Set network parameters wiz.Start(SPI_CS, SPI_SCK, SPI_MOSI, SPI_MISO) wiz.SetCommonnMode(0) wiz.SetGateway(192, 168, 1, 1) wiz.SetSubnetMask(255, 255, 255, 0) wiz.SetIp(192, 168, 1, 110) wiz.SetMac($00, $08, $DC, $16, $F8, $01) pst.str(string("Initialize Socket",CR)) sock.Init(0, TCP, 8080) pst.str(string("Start Socket server",CR)) repeat sock.Open sock.Listen pst.str(string("Listening",CR)) 'Connection? repeat until sock.Connected pst.str(string("Someone Connected!",CR)) 'Data in the buffer? repeat until i == timeout OR NULL < bytesToRead := sock.Available i++ i := 0 pst.str(string("Time to Read...",CR)) 'Check for a timeout if(bytesToRead < 0) sock.Disconnect bytesToRead~ next 'Get the Rx buffer sock.Receive(@buff, bytesToRead) pst.str(string("Reading...",CR)) {{ Process the Rx data}} pst.str(@buff) pst.str(string("End of Read.",CR)) sock.Send(@SendURL, strsize(@SendURL)) ********* This does not work ********** 'sock.Send(@buff, strsize(@buff)) 'sock.Send(@header, strsize(@header)) ********* This sets the header just fine *********** pst.str(string("Send Recieved Data.",CR)) sock.Disconnect pst.str(string("Disconnect Client",CR)) bytesToRead~ { } PUB BufferHeader(buffer, source) result := strsize(source) bytemove(buffer, source, result) PUB BufferIndex(buffer, offset) | fileSize pst.str(string("Open", CR)) sdcard.listEntry(string("index.htm")) pst.str(SDCard.openFile(string("index.htm"), "r")) fileSize := SDCard.getFileSize pst.str(string(" (")) pst.dec(fileSize) pst.str(string(")", CR)) result := buffer+offset SDCard.readFromFile(result, fileSize) result += fileSize byte[result] := 0 'NOTE: add a pause if pst.str is removed 'else we'll have a problem closing the file pst.str(buffer) 'pause(500) pst.str(string(CR, "closeFile", CR)) SDCard.closeFile 'pst.str(string("done", CR)) PUB PrintIp(addr) | i repeat i from 0 to 3 pst.dec(byte[addr][i]) if(i < 3) pst.char($2E) else pst.char($0D) PRI pause(Duration) waitcnt(((clkfreq / 1_000 * Duration - 3932) #> 381) + cnt) returnCON _clkmode = xtal1 + pll16x _xinfreq = 5_000_000 TCP_MTU = 1460 BUFFER_2K = $800 BUFFER_LOG = $80 BUFFER_WS = $20 BUFFER_SNTP = 48+8 CR = $0D LF = $0A { Web Server Configuration } SOCKETS = 3 DHCP_SOCK = 3 SNTP_SOCK = 2 ATTEMPTS = 5 { Port Configuration } HTTP_PORT = 8080 '80 SNTP_PORT = 123 { SD IO } DISK_PARTION = 0 SUCCESS = -1 IO_OK = 0 IO_READ = "r" IO_WRITE = "w" { Serial IO PINs } USB_Rx = 31 USB_Tx = 30 {{ Content Types }} #0, CSS, GIF, HTML, ICO, JPG, JS, PDF, PNG, TXT, XML, ZIP {{ USA Standard Time Zone Abbreviations }} #-10, HST,AtST,_PST,MST,CST,EST,AlST GMT = 0 AZ_TIME = 1 {{ USA Daylight Time Zone Abbreviations }} #-9, HDT,AtDT,PDT,MDT,CDT,EDT,AlDT Zone = EST '<- Insert your timezone RTC_CHECK_DELAY = 4_000_000 '1_000_000 = ~4 minutes VAR long buttonStack[10] long longHIGH, longLOW, MM_DD_YYYY, DW_HH_MM_SS 'Expected 4-contigous variables for SNTP DAT '64, 147, 116, 229 '<- This SNTP server is on the west coast '207.223.123.18 ' <- CST sntpIp byte 128,252,19,1 '139,78,135,14 '129, 6, 15, 30 '<- NIST, Gaithersburg, Maryland version byte "1.2", $0 hasSd byte $00 approot byte "\", $0 indexPage byte "index.htm", $0 hello byte "HTTP/1.1 200 OK", CR, LF, { } "Content-Type: text/html", CR, LF, CR, LF, { } "<html>", { } "<head>", { } "<title>Hello World</title><head>", { } "<body>", { } "Hello World!<br />No SD Card Found", { } "</body>", { } "</html>", CR, LF, $0 _404 byte "HTTP/1.1 404 OK", CR, LF, { } "Content-Type: text/html", CR, LF, CR, LF, { } "<html>", { } "<head>", { } "<title>Not Found</title><head>", { } "<body>", { } "Page not found!", { } "</body>", { } "</html>", CR, LF, $0 POSTURL BYTE "POST /spinneret/getpost.aspx?id=1&test=2 HTTP/1.1", CR, LF, { } "Host: agaverobotics.com", CR, LF, { } "Connection: keep-alive", CR, LF, { } "Content-Type: application/x-www-form-urlencoded", CR, LF, { } "Content-length: 23", CR, LF, CR, LF, { } "name=test&submit=Submit", $0 xmlPinState byte "<root>", CR, LF, " <pin>" pinNum byte $30, $30, "</pin>", CR, LF, " <value>" pinState byte $30, $30, "</value>", CR, LF, " <dir>" pinDir byte $30, $30, "</dir>", CR, LF, { } "</root>", 0 xmlTime byte "<root>", CR, LF, " <time>" xtime byte "00/00/0000 00:00:00</time>", CR, LF, " <day>" xday byte "---","</day>", CR, LF, "</root>", $0 _h200 byte "HTTP/1.1 200 OK", CR, LF, $0 _h404 byte "HTTP/1.1 404 Not Found", CR, LF, $0 _css byte "Content-Type: text/css",CR, LF, $0 _gif byte "Content-Type: image/gif",CR, LF, $0 _html byte "Content-Type: text/html", CR, LF, $0 _ico byte "Content-Type: image/x-icon",CR, LF, $0 _jpg byte "Content-Type: image/jpeg",CR, LF, $0 _js byte "Content-Type: application/javascript",CR, LF, $0 _pdf byte "Content-Type: application/pdf",CR, LF, $0 _png byte "Content-Type: image/png",CR, LF, $0 _txt byte "Content-Type: text/plain; charset=utf-8",CR, LF, $0 _xml byte "Content-Type: text/xml",CR, LF, $0 _zip byte "Content-Type: application/zip",CR, LF, $0 _contLen byte "Content-Length: ", $0 _newline byte CR, LF, $0 time byte "00/00/0000 00:00:00", 0 sntpBuff byte $0[BUFFER_SNTP] workSpace byte $0[BUFFER_WS] logBuf byte $0[BUFFER_LOG] wizver byte $00 buff byte $0[BUFFER_2K] null long $00 dhcpRenew byte $00 contentType long @_css, @_gif, @_html, @_ico, @_jpg, @_js, @_pdf, @_png, @_txt, @_xml, @_zip, $0 mtuBuff long TCP_MTU OBJ pst : "Parallax Serial Terminal" wiz : "W5100" dhcp : "Dhcp" sock[SOCKETS] : "Socket" req : "HttpHeader2" sd : "S35390A_SD-MMC_FATEngineWrapper" sntp : "SNTP Simple Network Time Protocol" rtc : "S35390A_RTCEngine" PUB Init | i, t1 'A hardware reset can take 1.5 seconds 'before the Sockets are ready to Send/Receive wiz.HardReset(WIZ#WIZ_RESET) pst.Start(115_200) pause(500) '--------------------------------------------------- 'Main COG '--------------------------------------------------- pst.str(string("COG[0]: Spinneret Web Server v")) pst.str(@version) '--------------------------------------------------- 'Start the Parallax Serial Terminal '--------------------------------------------------- { pst.str(string(CR, "COG[")) i := pst.GetCogId pst.dec(i) pst.str(string("]: Parallax Serial Terminal")) } pst.str(string(CR, "COG[1]: Parallax Serial Terminal")) '--------------------------------------------------- 'Start the SD Driver and Mount the SD card '--------------------------------------------------- ifnot(sd.Start) pst.str(string(CR, " Failed to start SD driver!")) else pst.str(string(CR, "COG[")) i := sd.GetCogId pst.dec(i) pst.str(string("]: Started SD Driver")) pause(500) pst.str(string(CR," Mount SD Card - ")) t1 := sd.mount(DISK_PARTION) pst.str(t1) if(strcomp(t1, string("OK"))) hasSd := true else hasSd := false '--------------------------------------------------- 'Initialize the Realtime clock library '--------------------------------------------------- pst.str(string(CR," Init RTC: ")) rtc.RTCEngineStart(29, 28, -1) pst.str(FillTime(@time)) '--------------------------------------------------- 'Start the WizNet SPI driver '--------------------------------------------------- wiz.Start(WIZ#SPI_CS, WIZ#SPI_SCK, WIZ#SPI_MOSI, WIZ#SPI_MISO) pst.str(string(CR, "COG[")) i := wiz.GetCogId pst.dec(i) pst.str(string("]: Started W5100 SPI Driver")) 'Verify SPI connectivity by reading the WizNet 5100 version register wizver := GetVersion if(wizver == 0) pst.str(string(CR, CR, "SPI communication failed!", CR, "Check connections", CR)) return else pst.str(string(CR, " WizNet 5100 Connected; Reg(0x19) = ") ) pst.dec(wizver) pst.str(string(CR, "COG[n]: ")) pst.dec(i~ +1) pst.str(string(" COGs in Use")) pst.str(@divider) 'MAC (Source Hardware Address) must be unique 'on the local network 'wiz.SetMac($00, $08, $DC, $16, $F1, $32) '<- My second Spinneret wiz.SetMac($00, $08, $DC, $16, $EF, $22) '<- Tutorial Spinneret 'Invoke DHCP to retrived network parameters 'This assumes the WizNet 5100 is connected 'to a router with DHCP support pst.str(string(CR,"Retrieving Network Parameters...Please Wait")) pst.str(@divider) if(InitNetworkParameters) PrintNetworkParams else PrintDhcpError return '--------------------------------------------------- 'Snyc the RTC using SNTP '--------------------------------------------------- pst.str(string(CR, "Sync RTC with Time Server")) pst.str(@divider) if(SyncSntpTime(SNTP_SOCK)) PrintRemoteIp(SNTP_SOCK) pst.str(string("Web time..........")) DisplayHumanTime else pst.str(string(CR, "Sync failed")) '--------------------------------------------------- ' Set DHCP renew -> (Current hour + 12) // 24 '--------------------------------------------------- dhcpRenew := (rtc.clockHour + 12) // 24 pst.str(string("DHCP Renew........")) if(dhcpRenew < 10) pst.char("0") pst.dec(dhcpRenew) pst.str(string(":00:00",CR)) '--------------------------------------------------- 'Start up the web server '--------------------------------------------------- pst.str(string(CR, "Initialize Sockets")) pst.str(@divider) repeat i from 0 to SOCKETS-1 sock[i].Init(i, WIZ#TCP, HTTP_PORT) OpenListeners StartListners ResetSntpSock(SNTP_SOCK) pst.str(string(CR, "Start Socket Services", CR)) MultiSocketService pst.str(string("Fatal Error!!!")) CloseAll pst.str(string(CR, "Rebooting...")) pause(1000) reboot PRI MultiSocketService | bytesToRead, sockId, fn, i, path bytesToRead := sockId := i := 0 repeat bytesToRead~ CloseWait sock[sockId].send(@POSTURL, strsize(@POSTURL)) ' <************************************************************** NOT WORKING :( sock[sockId].Receive(@buff, bytesToRead) pst.str(@buff) pst.char(CR) 'Cycle through the sockets one at a time 'looking for a connections pst.str(string(CR, "Waiting for a connection", CR)) 'PrintAllStatuses repeat until sock[sockId].Connected sockId := ++sockId // SOCKETS if(++i//RTC_CHECK_DELAY == 0) rtc.readTime pst.str(string("DHCP Time check: ")) pst.dec(rtc.clockHour) pst.char(":") pst.dec(rtc.clockMinute) pst.char(CR) if(rtc.clockHour == dhcpRenew) RenewDhcpLease SyncSntpTime(SNTP_SOCK) i~ 'Repeat until we have data in the buffer repeat until bytesToRead := sock[sockId].Available 'PrintAllStatuses 'Check for a timeout error if(bytesToRead =< 0) pst.str(string(CR, "Timeout: ")) pst.dec(bytesToRead) PrintAllStatuses sock[sockId].Disconnect next 'Move the Rx buffer into HUB memory sock[sockId].Receive(@buff, bytesToRead) 'Display the request header 'pst.str(@buff) 'Tokenize and index the header req.TokenizeHeader(@buff, bytesToRead) path := req.GetPath 'WriteDebugLine(string("Path"), path, false) if(FileExists(path)) RenderFile(sockId, path) else ifnot(RenderDynamic(sockId)) if(hasSd) sock[sockId].Send(@_404, strsize(@_404)) else if(strcomp(req.GetFileName, string("index.htm" ))) sock[sockId].send(@POSTURL, strsize(@POSTURL)) 'Close the socket and reset the 'interupt register sock[sockId].Disconnect sock[sockId].SetSocketIR($FF) sockId := ++sockId // SOCKETS PRI RenewDhcpLease | requestIp pst.str(string(CR,"Retrieving Network Parameters...Please Wait")) pst.str(@divider) requestIp := dhcp.GetIp dhcp.SetRequestIp(byte[requestIp][0],byte[requestIp][1],byte[requestIp][2],byte[requestIp][3]) if(InitNetworkParameters) PrintNetworkParams else PrintDhcpError rtc.readTime dhcpRenew := (rtc.clockHour + 12) // 24 pst.str(string("DHCP Renew........")) if(dhcpRenew < 10) pst.char("0") pst.dec(dhcpRenew) pst.str(string(":00:00",CR)) PRI BuildAndSendHeader(id, contentLength, ext) | dest, src dest := @buff bytemove(dest, @_h200, strsize(@_h200)) dest += strsize(@_h200) src := GetContentType(GetExtension) bytemove(dest, src, strsize(src)) dest += strsize(src) 'Add content-length : value CR, LF if(contentLength > 0) bytemove(dest, @_contLen, strsize(@_contLen)) dest += strsize(@_contLen) src := Dec(contentLength) bytemove(dest, src, strsize(src)) dest += strsize(src) bytemove(dest, @_newline, strsize(@_newline)) dest += strsize(@_newline) 'End the header with a new line bytemove(dest, @_newline, strsize(@_newline)) dest += strsize(@_newline) byte[dest] := 0 sock[id].send(@buff, strsize(@buff)) PRI GetExtension if strsize(req.GetFileNameExtension) == 0 return string("htm") else return req.GetFileNameExtension PRI RenderDynamic(id) 'Process pinstate if(strcomp(req.GetFileName, string("pinstate.xml"))) BuildPinStateXml( req.Get(string("led")), req.Get(string("value")) ) BuildAndSendHeader(id, -1, string("xml")) sock[id].Send(@xmlPinState, strsize(@xmlPinState)) return true if(strcomp(req.GetFileName, string("p_encode.xml"))) BuildPinEndcodeStateXml( req.Get(string("value")) ) BuildAndSendHeader(id, -1, string("xml")) sock[id].Send(@xmlPinState, strsize(@xmlPinState)) return true if(strcomp(req.GetFileName, string("time.xml"))) FillTime(@xTime) FillDay(@xday) BuildAndSendHeader(id, -1, string("xml")) sock[id].Send(@xmlTime, strsize(@xmlTime)) return true if(strcomp(req.GetFileName, string("sntptime.xml"))) SyncSntpTime(SNTP_SOCK) FillTime(@xTime) FillDay(@xday) BuildAndSendHeader(id, -1, string("xml")) sock[id].Send(@xmlTime, strsize(@xmlTime)) ResetSntpSock(SNTP_SOCK) return true return false PRI BuildPinStateXml(strpin, strvalue) | pin, value, state, dir pin := StrToBase(strpin, 10) value := StrToBase(strvalue, 10) SetPinState(pin, value) state := ReadPinState(pin) 'Write the pin number to the XML doc if(strsize(strpin) > 1) bytemove(@pinNum,strpin, 2) else byte[@pinNum] := $30 byte[@pinNum][1] := byte[strpin] 'Write the pin value value := Dec(ReadPinState(pin)) if(strsize(value) > 1) bytemove(@pinState, value, 2) else byte[@pinState] := $30 byte[@pinState][1] := byte[value] 'Write Pin direction dir := Dec(ReadDirState(pin)) if(strsize(dir) > 1) bytemove(@pinDir, value, 2) else byte[@pinDir] := $30 byte[@pinDir][1] := byte[dir] PRI ReadDirState(pin) return dira[pin] PRI ReadPinState(pin) return outa[pin] | ina[pin] PRI SetPinState(pin, value) if(value == -1) return if(pin < 23 or pin > 27) return dira[pin]~~ outa[pin] := value PRI BuildPinEndcodeStateXml(strvalue) | value, state, dir value := StrToBase(strvalue, 10) 'pst.dec(value) if(value > -1) SetEncodedPinstate(value) state := ReadEncodedPinState 'Write the pin number to the XML doc bytemove(@pinNum,string("$F"), 2) 'Write the pin value value := Dec(ReadEncodedPinState) if(strsize(value) > 1) bytemove(@pinState, value, 2) else byte[@pinState] := $30 byte[@pinState][1] := byte[value] 'Write Pin direction dir := Dec(ReadEncodedDirState) if(strsize(dir) > 1) bytemove(@pinDir, value, 2) else byte[@pinDir] := $30 byte[@pinDir][1] := byte[dir] PRI ReadEncodedDirState return dira[27..24] PRI ReadEncodedPinState return outa[27..24] | ina[27..24] PRI SetEncodedPinState(value) dira[27..24]~~ outa[27..24] := value PRI ValidateParameters(pin, value) if(pin < 23 or pin > 27) return false if(value > 1 or value < -1) return false return true PRI RenderFile(id, fn) | fs, bytes {{ Render a static file from the SD Card }} mtuBuff := sock[id].GetMtu OpenFile(fn, IO_READ) fs := sd.getFileSize BuildAndSendHeader(id, fs, fn) repeat until fs =< 0 if(fs < mtuBuff) bytes := fs else bytes := mtuBuff sd.readFromFile(@buff, bytes) fs -= sock[id].Send(@buff, bytes) 'Pause after issuing the send command 'pause(10) sd.closeFile return PRI SyncSntpTime(sockId) | ptr 'Initialize the socket sock[sockId].Init(SNTP_SOCK, WIZ#UDP, SNTP_PORT) 'Initialize the destination paramaters 'sock[sockId].RemoteIp(64, 147, 116, 229) sock[sockId].RemoteIp(sntpIp[0], sntpIp[1], sntpIp[2], sntpIp[3]) sock[sockId].RemotePort(SNTP_PORT) 'Setup the buffer sntp.CreateUDPtimeheader(@sntpBuff) ptr := SntpSendReceive(SNTP_SOCK, @sntpBuff, 48) if(ptr == @null) return false else 'Set the time SNTP.GetTransmitTimestamp(Zone,@sntpBuff,@LongHIGH,@LongLOW) 'PUB writeTime(second, minute, hour, day, date, month, year) rtc.writeTime(byte[@DW_HH_MM_SS][0], { Seconds } byte[@DW_HH_MM_SS][1], { Minutes } byte[@DW_HH_MM_SS][2], { Hour } byte[@DW_HH_MM_SS][3], { Day of week } byte[@MM_DD_YYYY][2], { Day } byte[@MM_DD_YYYY][3], { Month } word[@MM_DD_YYYY][0]) { Year} return true PRI WriteDebugLine(label, value, isNum) pst.str(label) repeat 25 - strsize(label) pst.char(".") if(isNum) pst.dec(value) else pst.str(value) pst.char(CR) PRI ResetSntpSock(sockId) sock[sockId].Init(sockId, WIZ#TCP, HTTP_PORT) sock[sockId].Open sock[sockId].Listen PUB SntpSendReceive(sockId, buffer, len) | bytesToRead, ptr bytesToRead := 0 'Open socket and Send Message sock[sockId].Open sock[sockId].Send(buffer, len) pause(500) bytesToRead := sock[sockId].Available 'Check for a timeout if(bytesToRead =< 0 ) bytesToRead~ return @null if(bytesToRead > 0) 'Get the Rx buffer ptr := sock[sockId].Receive(buffer, bytesToRead) sock[sockId].Disconnect return ptr PRI Writeline(label, value) pst.str(label) repeat 25 - strsize(label) pst.char(".") pst.dec(value) pst.char(CR) PRI OpenFile(path, ioType) | rc {{ Open a file }} if(FileExists(path)) if req.IsFileRequest sd.listEntry(path) rc := sd.openFile(path, ioType) else sd.changeDirectory(path) sd.listEntry(@indexPage) rc := sd.openFile(@indexPage, ioType) if(rc == SUCCESS) return true return false PRI FileExists(path) | rc {{ Verify if the file exists }} ifnot(hasSd) return false if req.IsFileRequest rc := sd.listEntry(path) else rc := sd.changeDirectory(path) if strcomp(rc, path) rc := sd.listEntry(@indexPage) if rc == 0 return true else return false PRI GetContentType(ext) {{ Determine the content-type }} if(strcomp(ext, string("css")) OR strcomp(ext, string("CSS"))) return @@contentType[CSS] if(strcomp(ext, string("gif")) OR strcomp(ext, string("GIF"))) return @@contentType[GIF] if(strcomp(ext, string("htm")) OR strcomp(ext, string("HTM"))) return @@contentType[HTML] if(strcomp(ext, string("ico")) OR strcomp(ext, string("ICO"))) return @@contentType[ICO] if(strcomp(ext, string("jpg")) OR strcomp(ext, string("JPG"))) return @@contentType[JPG] if(strcomp(ext, string("js")) OR strcomp(ext, string("JS"))) return @@contentType[JS] if(strcomp(ext, string("pdf")) OR strcomp(ext, string("PDF"))) return @@contentType[PDF] if(strcomp(ext, string("png")) OR strcomp(ext, string("PNG"))) return @@contentType[PNG] if(strcomp(ext, string("txt")) OR strcomp(ext, string("TXT"))) return @@contentType[TXT] if(strcomp(ext, string("xml")) OR strcomp(ext, string("XML"))) return @@contentType[XML] if(strcomp(ext, string("zip")) OR strcomp(ext, string("ZIP"))) return @@contentType[ZIP] return @@contentType[HTML] PRI GetVersion | i i := 0 result := 0 repeat until result > 0 result := wiz.GetVersion if(i++ > ATTEMPTS*5) return 0 pause(250) PRI InitNetworkParameters | i i := 0 'Initialize the DHCP object dhcp.Init(@buff, DHCP_SOCK) 'Request an IP. The requested IP 'might not be assigned by DHCP dhcp.SetRequestIp(192, 168, 1, 110) 'Invoke the SHCP process repeat until dhcp.DoDhcp(true) if(++i > ATTEMPTS) return false return true PRI PrintDhcpError if(dhcp.GetErrorCode > 0) pst.char(CR) pst.str(string(CR, "Error Code: ")) pst.dec(dhcp.GetErrorCode) pst.char(CR) pst.str(dhcp.GetErrorMessage) pst.char(CR) PRI PrintNetworkParams pst.str(string("Assigned IP.......")) PrintIp(dhcp.GetIp) pst.str(string("Lease Time........")) pst.dec(dhcp.GetLeaseTime) pst.str(string(" (seconds)")) pst.char(CR) pst.str(string("DNS Server........")) PrintIp(wiz.GetDns) pst.str(string("DHCP Server.......")) printIp(dhcp.GetDhcpServer) pst.str(string("Router............")) printIp(dhcp.GetRouter) pst.str(string("Gateway...........")) printIp(wiz.GetGatewayIp) PRI PrintRemoteIp(id) pst.str(string("Remote IP.........")) printIp(wiz.GetRemoteIp(id)) PRI OpenListeners | i 'pst.str(string("Open",CR)) repeat i from 0 to SOCKETS-1 sock[i].Open PRI StartListners | i repeat i from 0 to SOCKETS-1 if(sock[i].Listen) pst.str(string("Socket ")) pst.dec(i) pst.str(string(" Port.....")) pst.dec(sock[i].GetPort) pst.str(string("; MTU=")) pst.dec(sock[i].GetMtu) pst.str(string("; TTL=")) pst.dec(sock[i].GetTtl) pst.char(CR) else pst.str(string("Listener failed ",CR)) PRI SetTranactionTimeout(timeout) | i repeat i from 0 to SOCKETS-1 sock[i].SetTransactionTimeout(timeout) PRI CloseWait | i repeat i from 0 to SOCKETS-1 if(sock[i].IsCloseWait) sock[i].Disconnect sock[i].Close if(sock[i].IsClosed) sock[i].Open sock[i].Listen PRI CloseAll | i repeat i from 0 to SOCKETS-1 sock[i].Disconnect sock[i].Close PRI PrintStatus(id) pst.str(string("Status (")) pst.dec(id) pst.str(string(").......")) pst.hex(wiz.GetSocketStatus(id), 2) pst.char(13) PRI PrintAllStatuses | i pst.str(string(CR, "Socket Status", CR)) repeat i from 0 to SOCKETS-1 pst.dec(i) pst.str(string(" ")) pst.char(CR) repeat i from 0 to SOCKETS-1 pst.hex(wiz.GetSocketStatus(i), 2) pst.char($20) pst.char(CR) PRI PrintIp(addr) | i repeat i from 0 to 3 pst.dec(byte[addr][i]) if(i < 3) pst.char($2E) else pst.char($0D) PRI PrintExtension pst.str(req.GetFileNameExtension) pst.char(CR) PRI PrintRequestedFileName pst.str(req.GetFileName) pst.char(CR) PRI PrintTokens | i, tcnt 't1 := req.GetTokens tcnt := req.GetStatusLineTokenCount repeat i from 0 to tcnt-1 pst.str(req.EnumerateHeader(i)) pst.char(CR) PUB DisplayUdpHeader(buffer) pst.char(CR) pst.str(string(CR, "Message from.......")) PrintIp(buffer) pst.char(":") pst.dec(DeserializeWord(buffer + 4)) pst.str(string(" (")) pst.dec(DeserializeWord(buffer + 6)) pst.str(string(")", CR)) PUB DisplayHumanTime if byte[@MM_DD_YYYY][3]<10 pst.Char("0") pst.dec(byte[@MM_DD_YYYY][3]) pst.Char("/") if byte[@MM_DD_YYYY][2]<10 pst.Char("0") pst.dec(byte[@MM_DD_YYYY][2]) pst.Char("/") pst.dec(word[@MM_DD_YYYY][0]) pst.Char($20) if byte[@DW_HH_MM_SS][2]<10 pst.Char("0") pst.dec(byte[@DW_HH_MM_SS][2]) pst.Char(":") if byte[@DW_HH_MM_SS][1]<10 pst.Char("0") pst.dec(byte[@DW_HH_MM_SS][1]) pst.Char(":") if byte[@DW_HH_MM_SS][0]<10 pst.Char("0") pst.dec(byte[@DW_HH_MM_SS][0]) pst.str(string("(GMT ")) if Zone<0 pst.Char("-") else pst.Char("+") pst.str(string(" ",||Zone+48,":00) ")) pst.Char(13) PRI FillTime(ptr) '00/00/0000 00:00:00 rtc.readTime FillTimeHelper(rtc.clockMonth, ptr) ptr += 3 FillTimeHelper(rtc.clockDate, ptr) ptr += 3 FillTimeHelper(rtc.clockYear, ptr) ptr += 5 FillTimeHelper(rtc.clockHour , ptr) ptr += 3 FillTimeHelper(rtc.clockMinute , ptr) ptr += 3 FillTimeHelper(rtc.clockSecond, ptr) return ptr-17 PRI FillDay(ptr) rtc.readTime bytemove(ptr, rtc.getDayString, 3) return ptr PRI FillTimeHelper(value, ptr) | t1 if(value < 10) byte[ptr++] := "0" t1 := Dec(value) bytemove(ptr, t1, strsize(t1)) PUB Dec(value) | i, x, j {{Send value as decimal characters. Parameter: value - byte, word, or long value to send as decimal characters. Note: This source came from the Parallax Serial Termianl library }} j := 0 x := value == NEGX 'Check for max negative if value < 0 value := ||(value+x) 'If negative, make positive; adjust for max negative 'and output sign i := 1_000_000_000 'Initialize divisor repeat 10 'Loop for 10 digits if value => i workspace[j++] := value / i + "0" + x*(i == 1) 'If non-zero digit, output digit; adjust for max negative value //= i 'and digit from value result~~ 'flag non-zero found elseif result or i == 1 workspace[j++] := "0" 'If zero digit (or only digit) output it i /= 10 workspace[j] := 0 return @workspace PRI DeserializeWord(buffer) | value value := byte[buffer++] << 8 value += byte[buffer] return value PRI StrToBase(stringptr, base) : value | chr, index {Converts a zero terminated string representation of a number to a value in the designated base. Ignores all non-digit characters (except negative (-) when base is decimal (10)).} value := index := 0 repeat until ((chr := byte[stringptr][index++]) == 0) chr := -15 + --chr & %11011111 + 39*(chr > 56) 'Make "0"-"9","A"-"F","a"-"f" be 0 - 15, others out of range if (chr > -1) and (chr < base) 'Accumulate valid values into result; ignore others value := value * base + chr if (base == 10) and (byte[stringptr] == "-") 'If decimal, address negative sign; ignore otherwise value := - value PRI pause(Duration) waitcnt(((clkfreq / 1_000 * Duration - 3932) #> 381) + cnt) return DAT divider byte CR, "-----------------------------------------------", CR, $0I would really like to stick with SPIN so I don't have to worry about trying to learn a language and learn how to get this working all at the same time. So far, I have seen 0 results and it almost appears no one is using the Spinneret anymore
I have the server working here : http://75.64.192.5/
You can see what happens when the output should be headers, but it just prints it to the screen : http://75.64.192.5/index.htm
Then, I have a PHP script that talks to the socket here : http://www.techboneyard.com/home-stuff/
That script just sends text to the socket and the socket returns what it was sent. That works great. Problem is, I want to initiate data to my server without having to open a browser and create a socket connection. If there were some way I could simply call an off site URL maybe with a simple Function :
ReturnedData := CallWebURL("http://www.techboneyard.com/home-stuff/actions.php?do=updateWatts&hour=5&watts=12345") if(ReturnedData == "Success"){ ' Do something }So basically, my goal is to have a socket server connection available for projects to communicate to it via Xbee Wifi modules. (This seems to be working by using the PHP script to talk to the server)
Next step is to have the spinneret call my off site server every X minutes via a specified URL with a dynamic query string and return some data to acknowledge it received it. (Lost here....)
If I can get that far, I am sure I can progress much more on my own.
Can a Spinneret call a URL like this http://www.example.com/example.php without the request being initiating through a browser?
For example, the spinneret is connected to my home network, 1 minute has passed and the spinneret needs to dump the calculated data to my off site web server but there is no computer communicating with the spinneret and the off site server does NOT have a socket server running. Can the Spinneret send the data or am I wasting my time?
EDIT * My IP has changed.
It is now http://69.247.180.219/
OR http://69.247.180.219/index.htm
And the PHP script can still be accessed here : http://www.techboneyard.com/home-stuff/
If you can open a socket to a server
then you can open one to an HTTP server
and send a GET url
the HTTP server is a socket server + handler for the HTTP protocol.
In Tachyon for example you can just take the EASYMAIL code and change it to connect to a Webserver.
Then send the request.
The SPIN / SPINNERET code should be able to do this as well.
At least the W5100 provides all that is needed.
CON '...... { Web Server Configuration } SOCKETS = 4 SERVER_SOCK = 4 DHCP_SOCK = 3 SNTP_SOCK = 2 ATTEMPTS = 5 { Port Configuration } HTTP_PORT = 8080 '80 SERVER_PORT = 80 SNTP_PORT = 123 '...... DAT '......... POSTURL BYTE "GET /spinneret/getpost.aspx?id=1&test=2 HTTP/1.1", CR, LF, { } "Host: agaverobotics.com", CR, LF, { } "Connection: keep-alive", CR, LF, { } "Content-Type: application/x-www-form-urlencoded", CR, LF, { } "Content-length: 23", CR, LF, CR, LF, { } "name=test&submit=Submit", $0 PUB Init | i, t1 '........ pst.str(string(CR, "Initialize Sockets")) pst.str(@divider) repeat i from 0 to SOCKETS - 1 sock[i].Init(i, WIZ#TCP, HTTP_PORT) pst.str(string(CR, "Started Socket : ")) pst.dec(i) pst.char(CR) pst.str(string(CR, "Starting Outbound Socket...", CR)) 'sock[SERVER_PORT].Init(SERVER_SOCK, WIZ#TCP, SERVER_PORT) ******* Open a new socket #4. Had to null it out since it would hang or reboot the program if I use port 80 for SERVER_PORT. pst.str(string(CR, "Opening Listeners", CR)) OpenListeners pst.str(string(CR, "Starting Listeners", CR)) StartListners pst.str(string(CR, "Resetting SNTP Socket...", CR)) ResetSntpSock(SNTP_SOCK) pst.str(string(CR, "Start Socket Services", CR)) MultiSocketService pst.str(string("Fatal Error!!!")) CloseAll pst.str(string(CR, "Rebooting...")) pause(1000) rebootThen for the Sending to the server :
PUB SendData | sockId, bytesToRead, i, fail sockId := SERVER_SOCK fail := 0 bytesToRead~ pst.str(string(CR, "Attempting to connect to Server.", CR)) repeat until sock[sockId].Connected ' ******************************************** If I use a port like 30030, it will at least Init the socket, but it will hang here. if(++i//Send_Time_Out == 0) pst.str(string(CR, "Timed Out.", CR)) i~ pause(5000) fail := 1 next if(fail == 0) pst.str(string(CR, "Sending data to Server.", CR)) sock[sockId].send(@POSTURL, strsize(@POSTURL)) repeat until bytesToRead := sock[sockId].Available if(bytesToRead =< 0) pst.str(string(CR, "Timeout: ")) pst.dec(bytesToRead) sock[sockId].Disconnect else pst.str(string(CR, "Reading Data from Server", CR)) sock[sockId].Receive(@buff, bytesToRead) 'pst.str(@buff) 'pst.char(CR) pst.str(string(CR, "Disconnecting from Server", CR)) sock[sockId].Disconnect sock[sockId].SetSocketIR($FF) pause(5000) ' Pause for 5 seconds before continuing.I have tried to copy the SNTP send and recieve code and modify it to work with my server. Still not working. This thread has over 800 views and no one seems to be able to help
Will someone PLEASE help me get this one thing accomplished..... Send data to a specified offsite URL without using the help of a browser?
CON _clkmode = xtal1 + pll16x _xinfreq = 5_000_000 BUFFER_2K = $800 CR = $0D LF = $0A #0, CLOSED, TCP, UDP, IPRAW, MACRAW, PPPOE ATTEMPTS = 5 USB_Rx = 31 USB_Tx = 30 { Spinneret PIN IO } SPI_MISO = 0 ' SPI master in serial out from slave SPI_MOSI = 1 ' SPI master out serial in to slave SPI_CS = 2 ' SPI chip select (active low) SPI_SCK = 3 ' SPI clock from master to all slaves WIZ_INT = 13 WIZ_RESET = 14 WIZ_SPI_MODE = 15 DHCP_SOCKET = 3 DNS_SOCKET = 2 VAR DAT request byte "GET /index.htm HTTP/1.1", CR, LF, { } byte "User-Agent: Wiz5200", CR, LF, CR, LF, $0 request2 byte "GET /default.aspx HTTP/1.1", CR, LF, { } byte "Host: agaverobotics.com", CR, LF, { } byte "User-Agent: Wiz5200", CR, LF, CR, LF, $0 google byte "GET /finance/historical?q=FB&output=csv HTTP/1.1", CR, LF, { } byte "Host: finance.google.com", CR, LF, { } byte "User-Agent: Wiz5200", CR, LF, CR, LF, $0 weather byte "GET / HTTP/1.1", CR, LF, { } byte "Host: www.weather.gov", CR, LF, { } byte "User-Agent: Wiz5200", CR, LF, CR, LF, $0 basicAuthReq byte "GET /spinneret/formtest.php HTTP/1.1", CR, LF, { } byte "Host: rcc.cfbtechnologies.com", CR, LF, { } byte "User-Agent: Wiz5200", CR, LF, { } byte "Authorization: Basic dGVzdDojYnhGeFgheWxTR3A=", CR, LF, CR, LF, $0 request3 byte "GET /tims/post.php?data=testing HTTP/1.1", CR, LF, { } byte "Host: www.roadsurge.com", CR, LF, { } byte "User-Agent: Wiz5200", CR, LF, CR, LF, $0 buff byte $0[BUFFER_2K] t1 long $0 null long $00 site byte "finance.google.com", $0 OBJ pst : "Parallax Serial Terminal" wiz : "W5100" sock : "Socket" dhcp : "Dhcp" dns : "Dns" PUB Main | bytesToRead, buffer, bytesSent, receiving, remoteIP, dnsServer, totalBytes, i, dnsInit wiz.HardReset(WIZ_RESET) receiving := true bytesToRead := 0 dnsInit := 0 pst.Start(115_200) pause(500) pst.str(string("Initialize W5100", CR)) wiz.Start(SPI_CS, SPI_SCK, SPI_MOSI, SPI_MISO) wiz.SetMac($00, $08, $DC, $16, $F1, $32) pause(500) pst.str(string("Getting network paramters", CR)) dhcp.Init(@buff, DHCP_SOCKET) pst.str(string("--------------------------------------------------", CR)) pst.str(string("Requesting IP.....")) repeat until dhcp.DoDhcp(true) if(++t1 > ATTEMPTS) quit if(t1 > ATTEMPTS) pst.char(CR) pst.str(string(CR, "DHCP Attempts: ")) pst.dec(t1) pst.str(string(CR, "Error Code: ")) pst.dec(dhcp.GetErrorCode) pst.char(CR) pst.str(dhcp.GetErrorMessage) pst.char(CR) return else PrintIp(dhcp.GetIp) { Stress test repeat pst.str(string("Requesting IP.....")) t1 := 0 'wiz.SetIp(0,0,0,0) repeat until dhcp.RenewDhcp if(++t1 > ATTEMPTS) quit if(t1 > ATTEMPTS) pst.char(CR) pst.str(string(CR, "DHCP Attempts: ")) pst.dec(t1) pst.str(string(CR, "Error Code: ")) pst.dec(dhcp.GetErrorCode) pst.char(CR) pst.str(dhcp.GetErrorMessage) pst.char(CR) return else PrintIp(dhcp.GetIp) 'pause(2000) } pst.str(string("Lease Time........")) pst.dec(dhcp.GetLeaseTime) pst.char(CR) pst.str(string("DNS...............")) dnsServer := wiz.GetDns PrintIp(wiz.GetDns) pst.str(string("DHCP Server.......")) printIp(dhcp.GetDhcpServer) pst.str(string("Router............")) printIp(dhcp.GetRouter) pst.str(string("Gateway...........")) printIp(wiz.GetGatewayIp) pst.char(CR) pst.str(string("DNS Init (bool)...")) if(dns.Init(@buff, DNS_SOCKET)) pst.str(string("True")) else pst.str(string("False")) pst.char(CR) pst.str(string("Resolved IP(0)....")) 'remoteIP := dns.ResolveDomain(string("www.agaverobotics.com")) remoteIP := dns.ResolveDomain(string("www.roadsurge.com")) 'remoteIP := dns.ResolveDomain(string("google.com")) 'remoteIP := dns.ResolveDomain(string("www.weather.gov")) 'remoteIP := dns.ResolveDomain(string("rcc.cfbtechnologies.com")) PrintIp(remoteIP) pst.str(string("Resolved IPs......")) pst.dec(dns.GetIpCount) pst.char(13) pst.char(13) 'remoteIP := dns.GetResolvedIp(1) pst.str(string("Initialize Socket")) buffer := sock.Init(0, TCP, 8080) sock.RemoteIp(byte[remoteIP][0], byte[remoteIP][1], byte[remoteIP][2], byte[remoteIP][3]) sock.RemotePort(80) repeat bytesToRead~ pause(3000) pst.str(string(CR, "Begin Client Web Request", CR)) 'Client 'pst.str(string("Open Socket", CR)) sock.Open pst.str(string("Status(open)......")) pst.hex(sock.GetStatus, 2) pst.char(CR) sock.Connect 'repeat until sock.Connect > 1 'pause(500) 'sock.Open 'pst.str(string("Status(open)......")) 'pst.hex(sock.GetStatus, 2) 'pst.char(CR) 'pause(500) pst.str(string("Status(conn)......")) pst.hex(sock.GetStatus, 2) pst.char(CR) pst.str(string("Connecting to.....")) PrintIp(wiz.GetRemoteIP(0)) pst.char(CR) 'Connection? repeat until sock.Connected pause(100) pst.str(string("Sending HTTP Request", CR)) 'bytesSent := sock.Send(@request2, strsize(@request2)) bytesSent := sock.Send(@request3, strsize(@request3)) 'bytesSent := sock.Send(@s_google, strsize(@s_google)) 'bytesSent := sock.Send(@weather, strsize(@weather)) 'bytesSent := sock.Send(@basicAuthReq, strsize(@basicAuthReq)) pst.str(string("Bytes Sent........")) pst.dec(bytesSent) pst.char(13) totalBytes := 0 repeat while receiving 'Data in the buffer? bytesToRead := sock.Available totalBytes += bytesToRead 'Check for a timeout if(bytesToRead < 0) receiving := false pst.str(string("Timeout", CR)) return if(bytesToRead == 0) receiving := false 'pst.str(string(CR, "Done Receiving Response", CR)) next if(bytesToRead > 0) 'Get the Rx buffer buffer := sock.Receive(@buff, bytesToRead) pst.str(buffer) bytesToRead~ pst.str(string("Bytes received....")) pst.dec(totalBytes) pst.char(13) pst.str(string(CR, "Disconnect", CR, CR)) sock.Disconnect PUB DisplayMemory(addr, len, isHex) | j pst.str(string(13,"-----------------------------------------------------",13)) pst.str(string(13, " ")) repeat j from 0 to $F pst.hex(j, 2) pst.char($20) pst.str(string(13, " ")) repeat j from 0 to $F pst.str(string("-- ")) pst.char(13) repeat j from 0 to len if(j == 0) pst.hex(0, 4) pst.char($20) pst.char($20) if(isHex) pst.hex(byte[addr + j], 2) else if(byte[addr+j] < $20 OR byte[addr+j] > $7E) if(byte[addr+j] == 0) pst.char($20) else pst.hex(byte[addr+j], 2) else pst.char($20) pst.char(byte[addr+j]) pst.char($20) if((j+1) // $10 == 0) pst.char($0D) pst.hex(j+1, 4) pst.char($20) pst.char($20) pst.char(13) pst.char(13) pst.str(string("Start: ")) pst.dec(addr) pst.str(string(" Len: ")) pst.dec(len) pst.str(string(13,"-----------------------------------------------------",13,13)) PUB PrintIp(addr) | i i := 0 repeat i from 0 to 3 pst.dec(byte[addr][i] & $FF) if(i < 3) pst.char($2E) else pst.char($0D) PRI pause(Duration) waitcnt(((clkfreq / 1_000 * Duration - 3932) #> 381) + cnt) returnNow.... How to strip the headers sent back?
repeat while receiving 'Data in the buffer? bytesToRead := sock.Available totalBytes += bytesToRead 'Check for a timeout if(bytesToRead < 0) receiving := false pst.str(string("Timeout", CR)) return if(bytesToRead == 0) receiving := false 'pst.str(string(CR, "Done Receiving Response", CR)) next if(bytesToRead > 0) 'Get the Rx buffer buffer := sock.Receive(@buff, bytesToRead) idx := 20 'if(str.MatchPattern(buffer, string(13,10,13,10), 0, FALSE)) ' **************** HANGS IF NOT NULLED OUT ************* ' pst.str(buffer+idx+4) 'else ' pst.str(buffer) bytesToRead~ pst.str(string("Bytes received....")) pst.dec(totalBytes) pst.char(13) pst.str(buffer)Returns........
Sending HTTP Request Bytes Sent........90 Bytes received....177 HTTP/1.1 200 OK Date: Fri, 28 Nov 2014 21:57:55 GMT Server: Apache Vary: Accept-Encoding Transfer-Encoding: chunked Content-Type: text/html 12 Received : testing 0How can I pull only the "Received : testing" from the output? I have tried using the StringMethod function and it just hangs the entire program. Have to reboot it each time or null out that line.