{{
ybox2 - Info Widget
http://www.deepdarc.com/ybox2
ABOUT
This simple (!?) program will poll a webpage for information
and display it on your TV screen, updating in 30 second
intervals. You can configure where it gets the data
by connecting to the device with a web browser and
changing the settings. By default it will grab weather
data from the 95008 zip code, which you can change
using any web browser.
If a password was set in the bootloader, it will be
required to change the settings.
}}
CON
_clkmode = xtal1 + pll16x
_xinfreq = 5_000_000
OBJ
websocket : "api_telnet_serial"
term : "TV_Text"
subsys : "subsys"
settings : "settings"
http : "http"
auth : "auth_digest"
tel : "api_telnet_serial"
random : "RealRandom"
VAR
byte path_holder[128]
byte tv_mode
' Statistics
long stat_refreshes
long stat_errors
long weatherstack[200]
DAT
productName BYTE "ybox2 info widget",0
productURL BYTE "http://www.deepdarc.com/ybox2/",0
info_refresh_period long 30 ' in seconds
PUB init | i
dira[0]~~ ' Set direction on reset pin
outa[0]~ ' Set state on reset pin to LOW
dira[subsys#SPKRPin]~~
stat_refreshes:=0
stat_errors:=0
' Default to NTSC
tv_mode:=term#MODE_NTSC
settings.start
subsys.init
' If there is a TV mode preference in the EEPROM, load it up.
if settings.findKey(settings#MISC_TV_MODE)
tv_mode := settings.getByte(settings#MISC_TV_MODE)
' Start the TV Terminal
term.startWithMode(12,tv_mode)
term.str(string($0C,7))
term.str(@productName)
term.out(13)
term.str(@productURL)
term.out(13)
term.out($0c)
term.out(2)
repeat term#cols
term.out($90)
term.out($0c)
term.out(0)
subsys.StatusLoading
' Init the auth object with some randomness
random.start
auth.init(random.random)
random.stop
if settings.findKey(settings#MISC_STAGE2)
settings.removeKey(settings#MISC_STAGE2)
'ir.init(15, 0, 300, 1)
dira[subsys#SPKRPin]:=!settings.findKey(settings#MISC_SOUND_DISABLE)
if NOT settings.findKey(settings#SERVER_PATH)
if NOT \initial_configuration
showMessage(string("Server configuration failed!"))
subsys.StatusFatalError
SadChirp
waitcnt(clkfreq*100000 + cnt)
reboot
outa[0]~~ ' Pull ethernet reset pin high, ending the reset condition.
if not \tel.start(1,2,3,4,6,7)
showMessage(string("Unable to start networking!"))
subsys.StatusFatalError
SadChirp
waitcnt(clkfreq*10000 + cnt)
reboot
if settings.getData(settings#NET_MAC_ADDR,@weatherstack,6)
term.str(string("MAC: "))
repeat i from 0 to 5
if i
term.out("-")
term.hex(byte[@weatherstack][i],2)
term.out(13)
if NOT settings.getData(settings#NET_IPv4_ADDR,@weatherstack,4)
term.str(string("IPv4 ADDR: DHCP..."))
repeat while NOT settings.getData(settings#NET_IPv4_ADDR,@weatherstack,4)
if ina[subsys#BTTNPin]
reboot
delay_ms(500)
term.out($0A)
term.out($00)
term.str(string("IPv4 ADDR: "))
repeat i from 0 to 3
if i
term.out(".")
term.dec(byte[@weatherstack][i])
term.out(13)
if settings.getData(settings#NET_IPv4_DNS,@weatherstack,4)
term.str(string("DNS ADDR: "))
repeat i from 0 to 3
if i
term.out(".")
term.dec(byte[@weatherstack][i])
term.out(13)
if settings.getData(settings#SERVER_IPv4_ADDR,@weatherstack,4)
term.str(string("SERVER ADDR:"))
repeat i from 0 to 3
if i
term.out(".")
term.dec(byte[@weatherstack][i])
term.out(":")
term.dec(settings.getWord(settings#SERVER_IPv4_PORT))
term.out(13)
if settings.getString(settings#SERVER_PATH,@weatherstack,40)
term.str(string("SERVER PATH:'"))
term.str(@weatherstack)
term.str(string("'",13))
if settings.getString(settings#SERVER_HOST,@weatherstack,40)
term.str(string("SERVER HOST:'"))
term.str(@weatherstack)
term.str(string("'",13))
cognew(WeatherCog, @weatherstack)
repeat
HappyChirp
i:=\httpServer
term.out("[")
term.dec(i)
term.out("]")
subsys.StatusFatalError
SadChirp
delay_ms(500)
websocket.closeAll
reboot
PRI initial_configuration
settings.setString(settings#SERVER_HOST,string("propserve.fwdweb.com"))
settings.setData(settings#SERVER_IPv4_ADDR,string(72,14,176,143),4)
settings.setWord(settings#SERVER_IPv4_PORT,80)
settings.setString(settings#SERVER_PATH,string("/?zipcode=95008"))
{
settings.setString(settings#SERVER_HOST,string("www.deepdarc.com"))
settings.setData(settings#SERVER_IPv4_ADDR,string(69,73,181,158),4)
settings.setWord(settings#SERVER_IPv4_PORT,80)
settings.setString(settings#SERVER_PATH,string("/weather.php?zip=95008"))
}
return TRUE
CON
WEATHER_SUCCESS = 860276
pub WeatherCog | retrydelay,port,err
port := 20000
retrydelay := 1 ' Reset the retry delay
repeat
subsys.StatusLoading
if (err:=\WeatherUpdate(port)) == WEATHER_SUCCESS
retrydelay := 1 ' Reset the retry delay
subsys.StatusIdle
term.str(string($B,12))
term.dec(subsys.RTC) ' Print out the RTC value
term.out(" ")
tel.close
delay_s(info_refresh_period) ' 30 sec delay
else
if err>0
subsys.StatusErrorCode(err)
stat_errors++
showMessage(string("Error!"))
tel.close
if retrydelay < 60
retrydelay+=retrydelay
else
tel.closeall
websocket.closeall
delay_s(retrydelay) ' failed to connect
if ++port > 30000
port := 20000
pub WeatherUpdate(port) | timeout, addr, gotstart,in,i,header[4],value[4]
if settings.getString(settings#SERVER_PATH,@path_holder,64)=<0
abort 5
addr := settings.getLong(settings#SERVER_IPv4_ADDR)
if tel.connect(@addr,settings.getWord(settings#SERVER_IPv4_PORT),port) == -1
abort 6
term.str(string($1,$A,39,$C,1," ",$C,$8,$1,$B))
term.out(0)
tel.waitConnectTimeout(2000)
ifnot tel.isEOF
term.str(string($1,$B,12," "))
term.str(string($1,$A,39,$C,$8," ",$1))
tel.str(string("GET "))
tel.str(@path_holder)
tel.str(string(" HTTP/1.0",13,10)) ' use HTTP/1.0, since we don't support chunked encoding
if settings.getString(settings#SERVER_HOST,@path_holder,64)
tel.txmimeheader(string("Host"),@path_holder)
tel.txmimeheader(string("User-Agent"),string("PropTCP"))
tel.txmimeheader(string("Connection"),string("close"))
tel.str(@CR_LF)
repeat while \http.getNextHeader(tel.handle,@header,16,@value,16)>0
if strcomp(string("Refresh"),@header)
info_refresh_period:=atoi(@value)
if info_refresh_period < 4
info_refresh_period:=4 ' Four second minimum refresh
timeout := cnt
i:=0
repeat
if (in := \tel.rxcheck) => 0
if in <> 10
\term.out(in)
i++
else
ifnot tel.isConnected
if i > 1
stat_refreshes++
return WEATHER_SUCCESS
abort 4
if cnt-timeout>10*clkfreq ' 10 second timeout
abort(subsys#ERR_DISCONNECTED)
else
abort(subsys#ERR_NO_CONNECT)
return 5
PUB showMessage(str)
term.str(string($1,$B,12,$C,$1))
term.str(str)
term.str(string($C,$8))
pub HappyChirp
subsys.chirpHappy
pub SadChirp
subsys.chirpSad
PRI delay_ms(Duration)
waitcnt(((clkfreq / 1_000 * Duration - 3932)) + cnt)
PRI delay_s(Duration)
repeat Duration
delay_ms(1000)
VAR
byte httpMethod[8]
byte httpPath[128]
byte httpHeader[32]
byte buffer[128]
byte buffer2[128]
DAT
HTTP_200 BYTE "HTTP/1.1 200 OK"
CR_LF BYTE 13,10,0
HTTP_303 BYTE "HTTP/1.1 303 See Other",13,10,0
HTTP_404 BYTE "HTTP/1.1 404 Not Found",13,10,0
HTTP_403 BYTE "HTTP/1.1 403 Forbidden",13,10,0
HTTP_401 BYTE "HTTP/1.1 401 Authorization Required",13,10,0
HTTP_411 BYTE "HTTP/1.1 411 Length Required",13,10,0
HTTP_501 BYTE "HTTP/1.1 501 Not Implemented",13,10,0
HTTP_HEADER_SEP BYTE ": ",0
HTTP_HEADER_CONTENT_TYPE BYTE "Content-Type",0
HTTP_HEADER_LOCATION BYTE "Location",0
HTTP_HEADER_CONTENT_DISPOS BYTE "Content-disposition",0
HTTP_HEADER_CONTENT_LENGTH BYTE "Content-Length",0
HTTP_CONTENT_TYPE_HTML BYTE "text/html; charset=utf-8",0
HTTP_CONNECTION_CLOSE BYTE "Connection: close",13,10,0
pri httpUnauthorized(authorized)
websocket.str(@HTTP_401)
websocket.str(@HTTP_CONNECTION_CLOSE)
auth.generateChallenge(@buffer,127,authorized)
websocket.txMimeHeader(string("WWW-Authenticate"),@buffer)
websocket.str(@CR_LF)
websocket.str(@HTTP_401)
pri httpNotFound
websocket.str(@HTTP_404)
websocket.str(@HTTP_CONNECTION_CLOSE)
websocket.str(@CR_LF)
websocket.str(@HTTP_404)
pri parseIPStr(instr,outaddr) | char, i,j
repeat j from 0 to 3
BYTE[outaddr][j]:=0
j:=0
repeat while j < 4
case BYTE[instr]
"0".."9":
BYTE[outaddr][j]:=BYTE[outaddr][j]*10+BYTE[instr]-"0"
".":
j++
other:
quit
instr++
if j==3
return TRUE
abort FALSE
PUB atoi(inptr):retVal | i,char
retVal~
' Skip leading whitespace
repeat while BYTE[inptr] AND BYTE[inptr]==" "
inptr++
repeat 10
case (char := BYTE[inptr++])
"0".."9":
retVal:=retVal*10+char-"0"
OTHER:
quit
pub addTextField(id,label,value,length)
websocket.str(string("
"))
pub httpServer | i, contentLength,authorized,queryPtr
repeat
repeat while websocket.listen(80) < 0
if ina[subsys#BTTNPin]
reboot
delay_ms(1000)
websocket.closeall
next
repeat while NOT websocket.waitConnectTimeout(100)
if ina[subsys#BTTNPin]
reboot
' If there isn't a password set, then we are by default "authorized"
authorized:=NOT settings.findKey(settings#MISC_PASSWORD)
contentLength:=0
if \http.parseRequest(websocket.handle,@httpMethod,@httpPath)<0
websocket.close
next
repeat while \http.getNextHeader(websocket.handle,@httpHeader,32,@buffer,128)>0
if strcomp(@httpHeader,@HTTP_HEADER_CONTENT_LENGTH)
contentLength:=atoi(@buffer)
elseif NOT authorized AND strcomp(@httpHeader,string("Authorization"))
authorized:=auth.authenticateResponse(@buffer,@httpMethod,@httpPath)
' Authorization check
' You can comment this out if you want to
' be able to let unauthorized people see the
' front page. Even if you uncomment this,
' unauthorized users won't be able to
' change the settings or reboot, due to
' redundant checks below.
if authorized<>auth#STAT_AUTH
httpUnauthorized(authorized)
websocket.close
next
queryPtr:=http.splitPathAndQuery(@httpPath)
if strcomp(@httpMethod,string("GET")) or strcomp(@httpMethod,string("POST"))
if strcomp(@httpPath,string("/"))
websocket.str(@HTTP_200)
websocket.txmimeheader(@HTTP_HEADER_CONTENT_TYPE,@HTTP_CONTENT_TYPE_HTML)
websocket.str(@HTTP_CONNECTION_CLOSE)
websocket.str(@CR_LF)
websocket.str(string("ybox2"))
websocket.str(string(""))
websocket.str(string("
INA: "))
repeat i from 0 to 7
websocket.dec(ina[i])
websocket.tx(" ")
repeat i from 8 to 15
websocket.dec(ina[i])
websocket.tx(" ")
repeat i from 16 to 23
websocket.dec(ina[i])
websocket.tx(" ")
repeat i from 23 to 31
websocket.dec(ina[i])
websocket.str(string("