/********************************************* * vim:sw=8:ts=8:si:et * To use the above modeline in vim you must have "set modeline" in your .vimrc * Author: Guido Socher * Copyright: GPL V2 * See http://www.gnu.org/licenses/gpl.html * * Ethernet remote switch and 1wire sensor with * HTTP interface and measurement graphs * See http://tuxgraphics.org/electronics/ * * Chip type : Atmega168 or Atmega328 with ENC28J60 *********************************************/ #include #include #include #include #include #include #include #include "ip_arp_udp_tcp.h" #include "enc28j60.h" #include "timeout.h" #include "net.h" #include "websrv_help_functions.h" #include "onewire.h" #include "ds18x20.h" // set output to VCC, red LED off #define LEDOFF PORTB|=(1<\n")); return(plen); } uint16_t fill_tcp_data_uint(uint8_t *buf,uint16_t plen,uint8_t i) { itoa(i,gStrbuf,10); // convert integer to string return(fill_tcp_data(buf,plen,gStrbuf)); } uint16_t fill_tcp_data_int(uint8_t *buf,uint16_t plen,int8_t i) { itoa(i,gStrbuf,10); // convert integer to string return(fill_tcp_data(buf,plen,gStrbuf)); } // prepare the webpage by writing the data to the tcp send buffer uint16_t print_webpage_relay_ok() { uint16_t pl; pl=http200ok(0); pl=print_line_mobile_webpage(pl); pl=fill_tcp_data_p(buf,pl,PSTR("\n")); pl=fill_tcp_data_p(buf,pl,PSTR("

Rendben

\n")); return(pl); } uint16_t print_webpage_relay(uint8_t on) { uint16_t pl; pl=http200ok(1); pl=print_line_mobile_webpage(pl); pl=fill_tcp_data_p(buf,pl,PSTR(" \n")); pl=fill_tcp_data_p(buf,pl,PSTR("

Fűtés vezérlés

\n
Állapot: "));
        if (on){
                pl=fill_tcp_data_p(buf,pl,PSTR("Kikapcsolva"));
                if (gRelay_timeout_min>0){
                        pl=fill_tcp_data_p(buf,pl,PSTR(" [for "));
                        // gRelay_timeout_min is 16bit we do not use fill_tcp_data_int
                        itoa(gRelay_timeout_min,gStrbuf,10); // convert integer to string
                        pl=fill_tcp_data(buf,pl,gStrbuf);
                        pl=fill_tcp_data_p(buf,pl,PSTR(" more min]"));
                }
        }else{
                pl=fill_tcp_data_p(buf,pl,PSTR("Bekapcsolva"));
        }
        pl=fill_tcp_data_p(buf,pl,PSTR("\n
"));
        pl=fill_tcp_data_p(buf,pl,PSTR("\nJelszó: "));
                pl=fill_tcp_data_p(buf,pl,PSTR("
\n"));
        }else{
                pl=fill_tcp_data_p(buf,pl,PSTR("1>\n"));
		pl=fill_tcp_data_p(buf,pl,PSTR("Jelszó: "));
                pl=fill_tcp_data_p(buf,pl,PSTR("\n"));
        }
        pl=fill_tcp_data_p(buf,pl,PSTR("
")); return(pl); } // writes to global array gSensorIDs int8_t search_sensors(void) { uint8_t diff; uint8_t nSensors=0; for( diff = OW_SEARCH_FIRST; diff != OW_LAST_DEVICE && nSensors < MAXSENSORS ; ) { DS18X20_find_sensor( &diff, &(gSensorIDs[nSensors][0]) ); if( diff == OW_PRESENCE_ERR ) { return(-1); //No Sensor found } if( diff == OW_DATA_ERR ) { return(-2); //Bus Error } nSensors++; } return nSensors; } // start a measurement for all sensors on the bus: void start_temp_meas(void){ gTemp_measurementstatus=0; if ( DS18X20_start_meas(NULL) != DS18X20_OK) { gTemp_measurementstatus=1; } } // convert celsius times 10 values to Farenheit int8_t c2f(int16_t celsiustimes10){ return((int8_t)((int16_t)(celsiustimes10 * 18)/100) + 32); } // read the latest measurement off the scratchpad of the ds18x20 sensor // and store it in gTempdata void read_temp_meas(void){ uint8_t i; uint8_t subzero, cel, cel_frac_bits; for ( i=0; i#Copy/paste as txt file:\");\ ")); pl=fill_tcp_data_p(buf,pl,PSTR("dw(\"#date;")); pl=fill_tcp_data(buf,pl,label[0]); pl=fill_tcp_data(buf,pl,";"); pl=fill_tcp_data(buf,pl,label[1]); pl=fill_tcp_data(buf,pl,";"); pl=fill_tcp_data_p(buf,pl,PSTR("\");\n")); pl=fill_tcp_data_p(buf,pl,PSTR("\ var i,ms,pt;\ ms=t.getTime();\ var l=new Date();\ for(i=0;i\"+t+\"

\");\ }\n\ function bpt(gd,c,a,h){\ dw(\"

\"+h+\"

\");\ var i,n,ms,pt;\ ms=t.getTime();\ var l=new Date();\ for(i=0;iTZ diff GMT: \"+t.getTimezoneOffset()/60+\"h. Format: day-hh:mm=val
\");\ }\n\ ")); return(pl); } // sensor = 0 or 1 uint16_t print_webpage_graph_array(uint8_t *buf,uint8_t sensor) { int8_t i; uint8_t nptr; uint16_t pl; pl=http200okjs(1); nptr=gTemphistnextptr; // gTemphistnextptr may change so we make a snapshot here i=nptr; pl=fill_tcp_data_p(buf,pl,PSTR("gdat")); pl=fill_tcp_data_int(buf,pl,sensor); pl=fill_tcp_data_p(buf,pl,PSTR("=Array(")); if (!eeprom_is_ready()){ // don't sit and wait pl=fill_tcp_data_p(buf,pl,PSTR("0);\n")); return(pl); } while(1){ if (i!=nptr){ // not first time pl=fill_tcp_data_p(buf,pl,PSTR(",")); } i--; if (i<0){ i=TEMPHIST_BUFFER_SIZE-1; } #ifdef GRAPH_IN_F pl=fill_tcp_data_int(buf,pl,c2f(read_temphist(i,sensor)*10)); #else pl=fill_tcp_data_int(buf,pl,read_temphist(i,sensor)); #endif if (i==nptr){ break; // end loop } } pl=fill_tcp_data_p(buf,pl,PSTR(");\n")); return(pl); } uint16_t print_webpage_graph(void) { uint16_t pl; pl=http200ok(0); // global javascript variables: pl=fill_tcp_data_p(buf,pl,PSTR("\n")); pl=fill_tcp_data_p(buf,pl,PSTR("\n")); pl=fill_tcp_data_p(buf,pl,PSTR("")); pl=fill_tcp_data_p(buf,pl,PSTR("")); pl=fill_tcp_data_p(buf,pl,PSTR(" ")); pl=fill_tcp_data_p(buf,pl,PSTR("\n")); pl=fill_tcp_data_p(buf,pl,PSTR("\n
\n")); return(pl); } uint16_t print_webpage_sensoronly(uint8_t *buf,uint8_t num,uint8_t farenh) { uint16_t pl; pl=http200ok(1); pl=print_line_mobile_webpage(pl); if (num\n\n")); pl=fill_tcp_data_p(buf,pl,PSTR("\nTemp. sensors\n")); pl=fill_tcp_data_p(buf,pl,PSTR("")); pl=fill_tcp_data(buf,pl,RSSBASEURL); pl=fill_tcp_data_p(buf,pl,PSTR("\n")); pl=fill_tcp_data_p(buf,pl,PSTR("Temp. RSS feed\n")); // max 3 sensors otherwise this page might be bigger than the buf variable: while(i\ns")); pl=fill_tcp_data_int(buf,pl,i); // sensor number pl=fill_tcp_data_p(buf,pl,PSTR(": ")); pl=fill_tcp_data_int(buf,pl,gTempdata[i]/10); pl=fill_tcp_data_p(buf,pl,PSTR(".")); pl=fill_tcp_data_int(buf,pl,abs(gTempdata[i])%10); pl=fill_tcp_data_p(buf,pl,PSTR("'C [")); pl=fill_tcp_data_int(buf,pl,c2f(gTempdata[i])); pl=fill_tcp_data_p(buf,pl,PSTR("'F]\n")); pl=fill_tcp_data_p(buf,pl,PSTR("")); pl=fill_tcp_data(buf,pl,RSSBASEURL); pl=fill_tcp_data(buf,pl,"/?ts="); pl=fill_tcp_data_int(buf,pl,i); // sensor number pl=fill_tcp_data_p(buf,pl,PSTR("\n")); // readers use guid to determine if the artice // is new and needs to be refreshed. Therefore // we need to change guid in order to show current values // guid is just a string. We must however only change // it if the temperature really changed. We use // the units 'F to do that. pl=fill_tcp_data_p(buf,pl,PSTR("")); pl=fill_tcp_data_int(buf,pl,myip[2]); pl=fill_tcp_data(buf,pl,"-"); pl=fill_tcp_data_int(buf,pl,myip[3]); pl=fill_tcp_data(buf,pl,"-"); pl=fill_tcp_data_int(buf,pl,i); // sensor number pl=fill_tcp_data(buf,pl,"-"); pl=fill_tcp_data_int(buf,pl,rss_guid); // counter pl=fill_tcp_data_p(buf,pl,PSTR("\n")); pl=fill_tcp_data_p(buf,pl,PSTR("\n")); i++; } pl=fill_tcp_data_p(buf,pl,PSTR("\n\n")); return(pl); } #endif // RSS_FEATURE uint16_t print_webpage_main(uint8_t *buf) { int8_t i=0; uint16_t pl; pl=http200ok(1); pl=print_line_mobile_webpage(pl); #ifdef RSS_FEATURE pl=fill_tcp_data_p(buf,pl,PSTR("\n")); #endif // RSS_FEATURE pl=fill_tcp_data_p(buf,pl,PSTR(" ")); if (DEBUG_SENSORS==1){ pl=fill_tcp_data_p(buf,pl,PSTR(" [dbg sensor]")); } pl=fill_tcp_data_p(buf,pl,PSTR(" \n

Aktuális hőmérséklet

")); pl=fill_tcp_data_p(buf,pl,PSTR("
"));
        // max 3 sensors otherwise this page might be bigger than the buf variable:
        while(i"));
                pl=fill_tcp_data_int(buf,pl,gTempdata[i]/10);
                pl=fill_tcp_data_p(buf,pl,PSTR("."));
                pl=fill_tcp_data_int(buf,pl,abs(gTempdata[i])%10);
                pl=fill_tcp_data_p(buf,pl,PSTR("°C ["));
                pl=fill_tcp_data_int(buf,pl,c2f(gTempdata[i]));
                pl=fill_tcp_data_p(buf,pl,PSTR("°F]\n"));
                i++;
        }
        if (gTemp_measurementstatus==1){
                pl=fill_tcp_data_p(buf,pl,PSTR("warning: sensor error\n"));
        }
/*
                pl=fill_tcp_data_p(buf,pl,PSTR("dbg time since startup: "));
                pl=fill_tcp_data_int(buf,pl,gRecMin-1);
                pl=fill_tcp_data_p(buf,pl,PSTR(":"));
                pl=fill_tcp_data_int(buf,pl,gSec);
*/
        pl=fill_tcp_data_p(buf,pl,PSTR("
")); #ifdef RSS_FEATURE pl=fill_tcp_data_p(buf,pl,PSTR("

[rss]

\n")); #endif // RSS_FEATURE pl=fill_tcp_data_p(buf,pl,PSTR("
Tux\n")); return(pl); } #if (DEBUG_SENSORS==1) uint16_t print_webpage_sensordetails_dbg_login(uint8_t *buf) { uint16_t plen; plen=http200ok(1); plen=fill_tcp_data_p(buf,plen,PSTR("[home]\n")); plen=fill_tcp_data_p(buf,plen,PSTR("

Sensor debug login

\n
"));
        plen=fill_tcp_data_p(buf,plen,PSTR("\n
"));
        plen=fill_tcp_data_p(buf,plen,PSTR("\n"));
        plen=fill_tcp_data_p(buf,plen,PSTR("Jelszó: "));
        plen=fill_tcp_data_p(buf,plen,PSTR("
\n"));
        plen=fill_tcp_data_p(buf,plen,PSTR("\n
Tux")); return(plen); } // debug information, read sensor data at the moment when // showing this page uint16_t print_webpage_sensordetails_dbg(uint8_t *buf) { uint16_t plen; uint8_t subzero, cel, cel_frac_bits; int8_t i,j; uint8_t sp[DS18X20_SP_SIZE]; plen=http200ok(1); plen=fill_tcp_data_p(buf,plen,PSTR(" \n")); plen=fill_tcp_data_p(buf,plen,PSTR("

1wire sensors

")); plen=fill_tcp_data_p(buf,plen,PSTR("
"));
        if (gNsensors==-1){
                plen=fill_tcp_data_p(buf,plen,PSTR("no sensor found"));
                goto EOSENSOR;
        }
        if (gNsensors==-2){
                plen=fill_tcp_data_p(buf,plen,PSTR("OW_DATA_ERR"));
                goto EOSENSOR;
        }
        if (gNsensors>0){
                plen=fill_tcp_data_p(buf,plen,PSTR("Num. of sens:"));
                plen=fill_tcp_data_int(buf,plen,gNsensors);
        }
        plen=fill_tcp_data_p(buf,plen,PSTR("\n"));

        for (i=0; i0)plen=fill_tcp_data_p(buf,plen,PSTR(":"));
                                plen=fill_tcp_data_uint(buf,plen,sp[j]);
                        }
                }
                plen=fill_tcp_data_p(buf,plen,PSTR(" "));
                if ( DS18X20_read_meas( &gSensorIDs[i][0], &subzero,
                                &cel, &cel_frac_bits) == DS18X20_OK ) {
                        // display temp
                        if (subzero){
                                plen=fill_tcp_data_p(buf,plen,PSTR("-"));
                        }else{
                                plen=fill_tcp_data_p(buf,plen,PSTR("+"));
                        }
                        plen=fill_tcp_data_int(buf,plen,cel);
                        plen=fill_tcp_data_p(buf,plen,PSTR("."));
                        plen=fill_tcp_data_int(buf,plen,DS18X20_frac_bits_decimal(cel_frac_bits));
                        plen=fill_tcp_data_p(buf,plen,PSTR("'C"));
                } else {
                        plen=fill_tcp_data_p(buf,plen,PSTR("ERR: CRC/connection"));
                }
                plen=fill_tcp_data_p(buf,plen,PSTR("\n"));
        }
EOSENSOR:

        plen=fill_tcp_data_p(buf,plen,PSTR("\nSensors are searched at power-on only.\n
Tux"));
        return(plen);
}
#endif

// takes a string of the form command/Number and analyse it (e.g "?sw=pd7&a=1 HTTP/1.1")
// The first char of the url ('/') is already removed.
int8_t analyse_get_url(char *str)
{
        int8_t i=0;
        int8_t temp;
        if (str[0]==' '){
                return(1); // end of url, main page
        }
        if (strncmp("favicon.ico",str,11)==0){
                gPlen=fill_tcp_data_p(buf,0,PSTR("HTTP/1.0 301 Moved Permanently\r\nLocation: "));
                gPlen=fill_tcp_data_p(buf,gPlen,PSTR("http://minijib.net/favico/therm.ico"));
                gPlen=fill_tcp_data_p(buf,gPlen,PSTR("\r\n\r\n"));
                return(10);
        }
        // --------
        if (find_key_val(str,gStrbuf,STR_BUFFER_SIZE,"sc")){
                if (gStrbuf[0]=='1'){
                        i=1;
                }
                if (find_key_val(str,gStrbuf,STR_BUFFER_SIZE,"pw")){
                        urldecode(gStrbuf);
                        if (verify_password(gStrbuf)){
                                if (i){
                                        PORTD|= (1<49){ 
                gSec++;
                gMeasurementTimer++;
                cnt2step=0;
        }
}

/* setup timer T2 as an interrupt generating time base.
* You must call once sei() in the main program */
void init_cnt2(void)
{
        cnt2step=0;
        PRR&=~(1<3){
                        j=3;
                }
                for ( i=0; i5){
                                store_temphist(1+gTempdata[i]/10,gTemphistnextptr,i);
                        }else{
                                store_temphist(gTempdata[i]/10,gTemphistnextptr,i);
                        }
                }
                gTemphistnextptr++;
                gTemphistnextptr=gTemphistnextptr%TEMPHIST_BUFFER_SIZE;
        }
        // compensate after 17 intervals of 5 min
        if (gCompSecCnt>16){ // executed 1min after gCompSecCnt==17
                gSec+=1;
                gCompSecCnt=0;
        }
        // We calibrate/compensate the clock here a bit.
        // Our clock is a bit behind by 50/49.82461=1.00352
        // We need to compenstate by 3600*1.00352-3600sec=12.672sec every
        // hour or 1sec every minute.
        // The gSec is zero or max one when this function is called.
        if (gRecMin%5==0){
                gSec+=1;
                gCompSecCnt++;
        }
        // we have a remaining compensation of 16.12800sec per day
        // after the above. There are 288 5min units in 24h: 288/16.128=17.85
        // In the next minute we will fix that (see code at "compensate after 17 intervals")
        // - - - -
        gRecMin++;
        if (gRecMin==((uint16_t)rec_interval*10)){
#ifdef RSS_FEATURE
                increment_rss_guid(); // update rss guid value to force a page refresh if there was a temperature change.
#endif // RSS_FEATURE
                gRecMin=0; 
        }
}

int main(void){

        uint16_t dat_p;
        int8_t i,j,firstsample=1;
        static int8_t state=0;
        // set the clock speed to "no pre-scaler" (8MHz with internal osc or 
        // full external speed)
        // set the clock prescaler. First write CLKPCE to enable setting of clock the
        // next four instructions.
        CLKPR=(1<0){
                start_temp_meas();
        }

        gMeasurementTimer=0; // set again to zero before starting while loop
        while(1){
                // handle ping and wait for a tcp packet:
                gPlen=enc28j60PacketReceive(BUFFER_SIZE, buf);
                dat_p=packetloop_icmp_tcp(buf,gPlen);

                // dat_p will ne unequal to zero if there is a valid http get 
                if(dat_p==0){
                        // we need at least 750ms time between 
                        // start of measurement and reading
                        if (gMeasurementTimer==2 && state==0 && eeprom_is_ready()){ 
                                LEDON;
                                read_temp_meas();
                                state=1;
                                if (firstsample==1){
                                        firstsample=0;
                                        store_graph_dat();
                                }
                        }
                        if (gMeasurementTimer==3 && state==1){ 
                                LEDOFF;
                                start_temp_meas();
                                state=2;
                        }
                        if (gMeasurementTimer==5){ // every 5 sec new measurement:
                                gMeasurementTimer=0;
                                state=0;
                        }
                        if (gSec>59){
                                gSec=0;
                                if (gRelay_timeout_min>0){
                                        gRelay_timeout_min--;
                                        if (gRelay_timeout_min==0){
                                                PORTD &= ~(1<200 OK"));
                        goto SENDTCP;
                }
                // Cut the size for security reasons. If we are almost at the
                // end of the buffer then there is a zero but normally there is
                // a lot of room and we can cut down the processing time as
                // correct URLs should be short in our case:
                if ((dat_p+5+55) < BUFFER_SIZE){
                        buf[dat_p+5+55]='\0';
                }
                // analyse the url and do possible port changes:
                // move one char ahead:
                i=analyse_get_url((char *)&(buf[dat_p+5]));
                // for possible status codes see:
                // http://www.w3.org/Protocols/rfc2616/rfc2616-sec10.html
                if (i==-1){
                        gPlen=fill_tcp_data_p(buf,0,PSTR("HTTP/1.0 401 Unauthorized\r\nContent-Type: text/html\r\n\r\n
401 Unauthorized
continue"));
                        goto SENDTCP;
                }
                if (i==0){
                        gPlen=fill_tcp_data_p(buf,0,PSTR("HTTP/1.0 404 Not Found\r\nContent-Type: text/html\r\n\r\n
404 Not Found
"));
                        goto SENDTCP;
                }
                if (i==2){
                        gPlen=print_webpage_relay_ok();
                        goto SENDTCP;
                }
                if (i==3){
                        j=0;
                        // state of the transistor/relay
                        if (PORTD&(1<