summaryrefslogtreecommitdiffabout
Unidiff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--lib/hypnodata.cc2
-rw-r--r--lib/st-decode.cc2
-rw-r--r--src/db.cc2
3 files changed, 6 insertions, 0 deletions
diff --git a/lib/hypnodata.cc b/lib/hypnodata.cc
index 977fb76..a64b7d7 100644
--- a/lib/hypnodata.cc
+++ b/lib/hypnodata.cc
@@ -1,92 +1,94 @@
1#include <stdlib.h>
2#include <string.h>
1#include <napkin/exception.h> 3#include <napkin/exception.h>
2#include <napkin/util.h> 4#include <napkin/util.h>
3#include <napkin/types.h> 5#include <napkin/types.h>
4 6
5namespace napkin { 7namespace napkin {
6 8
7 void hypnodata_t::clear() { 9 void hypnodata_t::clear() {
8 to_bed = alarm = 0; 10 to_bed = alarm = 0;
9 data_a = window = 0; 11 data_a = window = 0;
10 almost_awakes.clear(); 12 almost_awakes.clear();
11 } 13 }
12 14
13 static time_t from_minute_w3c(const string& w3c) { 15 static time_t from_minute_w3c(const string& w3c) {
14 struct tm t; memset(&t,0,sizeof(t)); t.tm_isdst=-1; 16 struct tm t; memset(&t,0,sizeof(t)); t.tm_isdst=-1;
15 if(sscanf(w3c.c_str(),"%04d-%02d-%02dT%02d:%02d", 17 if(sscanf(w3c.c_str(),"%04d-%02d-%02dT%02d:%02d",
16 &t.tm_year,&t.tm_mon,&t.tm_mday,&t.tm_hour,&t.tm_min)!=5) 18 &t.tm_year,&t.tm_mon,&t.tm_mday,&t.tm_hour,&t.tm_min)!=5)
17 throw exception("failed to parse w3c time"); 19 throw exception("failed to parse w3c time");
18 --t.tm_mon;t.tm_year-=1900; 20 --t.tm_mon;t.tm_year-=1900;
19 time_t rv = mktime(&t); 21 time_t rv = mktime(&t);
20 if(rv==(time_t)-1) 22 if(rv==(time_t)-1)
21 throw exception("failed to mktime()"); 23 throw exception("failed to mktime()");
22 return rv; 24 return rv;
23 } 25 }
24 26
25 void hypnodata_t::set_to_bed(const string& w3c) { 27 void hypnodata_t::set_to_bed(const string& w3c) {
26 to_bed = from_minute_w3c(w3c); } 28 to_bed = from_minute_w3c(w3c); }
27 void hypnodata_t::set_alarm(const string& w3c) { 29 void hypnodata_t::set_alarm(const string& w3c) {
28 alarm = from_minute_w3c(w3c); } 30 alarm = from_minute_w3c(w3c); }
29 void hypnodata_t::set_window(const string& str) { 31 void hypnodata_t::set_window(const string& str) {
30 window = strtol(str.c_str(),0,10); /* TODO: check for error */ 32 window = strtol(str.c_str(),0,10); /* TODO: check for error */
31 } 33 }
32 void hypnodata_t::set_data_a(const string& str) { 34 void hypnodata_t::set_data_a(const string& str) {
33 data_a = strtol(str.c_str(),0,10); /* TODO: check for error */ 35 data_a = strtol(str.c_str(),0,10); /* TODO: check for error */
34 } 36 }
35 void hypnodata_t::set_almost_awakes(const string& str) { 37 void hypnodata_t::set_almost_awakes(const string& str) {
36 almost_awakes.clear(); 38 almost_awakes.clear();
37 static const char *significants = "0123456789-T:Z"; 39 static const char *significants = "0123456789-T:Z";
38 string::size_type p = str.find_first_of(significants); 40 string::size_type p = str.find_first_of(significants);
39 struct tm t; memset(&t,0,sizeof(t)); t.tm_isdst=-1; 41 struct tm t; memset(&t,0,sizeof(t)); t.tm_isdst=-1;
40 while(p!=string::npos) { 42 while(p!=string::npos) {
41 string::size_type ns = str.find_first_not_of(significants,p); 43 string::size_type ns = str.find_first_not_of(significants,p);
42 string w3c; 44 string w3c;
43 if(ns==string::npos) { 45 if(ns==string::npos) {
44 w3c = str.substr(p); 46 w3c = str.substr(p);
45 p = string::npos; 47 p = string::npos;
46 }else{ 48 }else{
47 w3c = str.substr(p,ns-p); 49 w3c = str.substr(p,ns-p);
48 p = str.find_first_of(significants,ns); 50 p = str.find_first_of(significants,ns);
49 } 51 }
50 if(w3c.empty()) continue; 52 if(w3c.empty()) continue;
51 if(sscanf(w3c.c_str(),"%04d-%02d-%02dT%02d:%02d:%02d", 53 if(sscanf(w3c.c_str(),"%04d-%02d-%02dT%02d:%02d:%02d",
52 &t.tm_year,&t.tm_mon,&t.tm_mday,&t.tm_hour,&t.tm_min,&t.tm_sec)!=6) 54 &t.tm_year,&t.tm_mon,&t.tm_mday,&t.tm_hour,&t.tm_min,&t.tm_sec)!=6)
53 throw exception("failed to parse w3c time"); 55 throw exception("failed to parse w3c time");
54 --t.tm_mon;t.tm_year-=1900; 56 --t.tm_mon;t.tm_year-=1900;
55 time_t aa = mktime(&t); 57 time_t aa = mktime(&t);
56 if(aa==(time_t)-1) 58 if(aa==(time_t)-1)
57 throw exception("failed to mktime()"); 59 throw exception("failed to mktime()");
58 almost_awakes.push_back(aa); 60 almost_awakes.push_back(aa);
59 } 61 }
60 } 62 }
61 63
62 const string hypnodata_t::w3c_to_bed() const { 64 const string hypnodata_t::w3c_to_bed() const {
63 return strftime("%Y-%m-%dT%H:%M",to_bed); } 65 return strftime("%Y-%m-%dT%H:%M",to_bed); }
64 const string hypnodata_t::w3c_alarm() const { 66 const string hypnodata_t::w3c_alarm() const {
65 return strftime("%Y-%m-%dT%H:%M",alarm); } 67 return strftime("%Y-%m-%dT%H:%M",alarm); }
66 const string hypnodata_t::w3c_almostawakes() const { 68 const string hypnodata_t::w3c_almostawakes() const {
67 string rv; 69 string rv;
68 for(vector<time_t>::const_iterator i=almost_awakes.begin();i!=almost_awakes.end();++i) { 70 for(vector<time_t>::const_iterator i=almost_awakes.begin();i!=almost_awakes.end();++i) {
69 if(!rv.empty()) 71 if(!rv.empty())
70 rv += ','; 72 rv += ',';
71 rv += strftime("%Y-%m-%dT%H:%M:%S",*i); 73 rv += strftime("%Y-%m-%dT%H:%M:%S",*i);
72 } 74 }
73 return rv; 75 return rv;
74 } 76 }
75 77
76 const string hypnodata_t::str_to_bed() const { 78 const string hypnodata_t::str_to_bed() const {
77 return strftime("%H:%M",to_bed); } 79 return strftime("%H:%M",to_bed); }
78 const string hypnodata_t::str_alarm() const { 80 const string hypnodata_t::str_alarm() const {
79 return strftime("%H:%M",alarm); } 81 return strftime("%H:%M",alarm); }
80 const string hypnodata_t::str_date() const { 82 const string hypnodata_t::str_date() const {
81 return strftime("%Y-%m-%d, %a",alarm); } 83 return strftime("%Y-%m-%d, %a",alarm); }
82 const string hypnodata_t::str_data_a() const { 84 const string hypnodata_t::str_data_a() const {
83 char tmp[16]; 85 char tmp[16];
84 snprintf(tmp,sizeof(tmp),"%d:%02d:%02d", 86 snprintf(tmp,sizeof(tmp),"%d:%02d:%02d",
85 data_a/3600, (data_a%3600)/60, 87 data_a/3600, (data_a%3600)/60,
86 data_a % 60 ); 88 data_a % 60 );
87 return tmp; } 89 return tmp; }
88 90
89 time_t hypnodata_t::aligned_start() const { 91 time_t hypnodata_t::aligned_start() const {
90 return alarm - (alarm % (24*60*60)) - 24*60*60; } 92 return alarm - (alarm % (24*60*60)) - 24*60*60; }
91 93
92} 94}
diff --git a/lib/st-decode.cc b/lib/st-decode.cc
index 0fb41de..b354250 100644
--- a/lib/st-decode.cc
+++ b/lib/st-decode.cc
@@ -1,96 +1,98 @@
1#include <stdlib.h>
2#include <string.h>
1#include <stdexcept> 3#include <stdexcept>
2#include <numeric> 4#include <numeric>
3#include <napkin/exception.h> 5#include <napkin/exception.h>
4#include <napkin/st/decode.h> 6#include <napkin/st/decode.h>
5 7
6namespace napkin { 8namespace napkin {
7 namespace sleeptracker { 9 namespace sleeptracker {
8 using std::invalid_argument; 10 using std::invalid_argument;
9 using std::runtime_error; 11 using std::runtime_error;
10 12
11 struct st_time_t { 13 struct st_time_t {
12 uint8_t hour; 14 uint8_t hour;
13 uint8_t min; 15 uint8_t min;
14 }; 16 };
15 struct st_date_t { 17 struct st_date_t {
16 uint8_t month; 18 uint8_t month;
17 uint8_t day; 19 uint8_t day;
18 uint8_t dow; 20 uint8_t dow;
19 }; 21 };
20 struct st_fulltime_t { 22 struct st_fulltime_t {
21 uint8_t hour; 23 uint8_t hour;
22 uint8_t min; 24 uint8_t min;
23 uint8_t sec; 25 uint8_t sec;
24 }; 26 };
25 struct st_data_header_t { 27 struct st_data_header_t {
26 char magic; 28 char magic;
27 st_date_t today; 29 st_date_t today;
28 uint8_t window; 30 uint8_t window;
29 st_time_t to_bed; 31 st_time_t to_bed;
30 st_time_t alarm; 32 st_time_t alarm;
31 uint8_t nawakes; 33 uint8_t nawakes;
32 }; 34 };
33 struct st_data_footer_t { 35 struct st_data_footer_t {
34 uint16_t data_a; 36 uint16_t data_a;
35 uint8_t checksum; 37 uint8_t checksum;
36 uint8_t eof_mark; 38 uint8_t eof_mark;
37 }; 39 };
38 40
39 static void back_a_day(struct tm& t) { 41 static void back_a_day(struct tm& t) {
40 time_t ts = mktime(&t); 42 time_t ts = mktime(&t);
41 if(ts==(time_t)-1) 43 if(ts==(time_t)-1)
42 throw exception_st_data("failed to make up time to step back a day"); 44 throw exception_st_data("failed to make up time to step back a day");
43 ts -= 60*60*24; 45 ts -= 60*60*24;
44 if(!localtime_r(&ts,&t)) 46 if(!localtime_r(&ts,&t))
45 throw exception_st_data("failed to localtime_r() while stepping back a day"); 47 throw exception_st_data("failed to localtime_r() while stepping back a day");
46 } 48 }
47 49
48 hypnodata_t& decode(hypnodata_t& rv,const void *data,size_t data_length) { 50 hypnodata_t& decode(hypnodata_t& rv,const void *data,size_t data_length) {
49 if(data_length < (sizeof(st_data_header_t)+sizeof(st_data_footer_t))) 51 if(data_length < (sizeof(st_data_header_t)+sizeof(st_data_footer_t)))
50 throw exception_st_data_envelope("not enough sleeptracker data to decode"); 52 throw exception_st_data_envelope("not enough sleeptracker data to decode");
51 st_data_header_t *h = (st_data_header_t*)data; 53 st_data_header_t *h = (st_data_header_t*)data;
52 if(h->magic != 'V') 54 if(h->magic != 'V')
53 throw exception_st_data_envelope("invalid magic in the data"); 55 throw exception_st_data_envelope("invalid magic in the data");
54 st_data_footer_t *f = (st_data_footer_t*)(static_cast<const char *>(data)+data_length-sizeof(st_data_footer_t)); 56 st_data_footer_t *f = (st_data_footer_t*)(static_cast<const char *>(data)+data_length-sizeof(st_data_footer_t));
55 if( (std::accumulate((uint8_t*)&h->today,(uint8_t*)&f->checksum,0)&0xFF) != f->checksum ) 57 if( (std::accumulate((uint8_t*)&h->today,(uint8_t*)&f->checksum,0)&0xFF) != f->checksum )
56 throw exception_st_data_integrity("checksum mismatch"); 58 throw exception_st_data_integrity("checksum mismatch");
57 st_fulltime_t *aawake = (st_fulltime_t*)&h[1]; 59 st_fulltime_t *aawake = (st_fulltime_t*)&h[1];
58 if((void*)&aawake[h->nawakes] != (void*)f) 60 if((void*)&aawake[h->nawakes] != (void*)f)
59 throw exception_st_data_envelope("unbelievably screwed up data"); 61 throw exception_st_data_envelope("unbelievably screwed up data");
60 rv.clear(); 62 rv.clear();
61 time_t now = time(0); 63 time_t now = time(0);
62 struct tm t; 64 struct tm t;
63 if(!localtime_r(&now,&t)) 65 if(!localtime_r(&now,&t))
64 throw exception_st_data("failed to localtime_r()"); 66 throw exception_st_data("failed to localtime_r()");
65 t.tm_mon = h->today.month-1; 67 t.tm_mon = h->today.month-1;
66 t.tm_mday = h->today.day; 68 t.tm_mday = h->today.day;
67 time_t mkt = mktime(&t); 69 time_t mkt = mktime(&t);
68 if(mkt == (time_t)-1) 70 if(mkt == (time_t)-1)
69 throw exception_st_data("failed to mktime() for a timestamp"); 71 throw exception_st_data("failed to mktime() for a timestamp");
70 if(mkt > now) { 72 if(mkt > now) {
71 --t.tm_year; 73 --t.tm_year;
72 } 74 }
73 struct tm ta; 75 struct tm ta;
74 memmove(&ta,&t,sizeof(ta)); 76 memmove(&ta,&t,sizeof(ta));
75 ta.tm_sec = 0; 77 ta.tm_sec = 0;
76 ta.tm_hour = h->alarm.hour; ta.tm_min = h->alarm.min; 78 ta.tm_hour = h->alarm.hour; ta.tm_min = h->alarm.min;
77 rv.alarm = mktime(&ta); 79 rv.alarm = mktime(&ta);
78 if(rv.alarm == (time_t)-1) 80 if(rv.alarm == (time_t)-1)
79 throw exception_st_data("failed to mktime() for alarm"); 81 throw exception_st_data("failed to mktime() for alarm");
80 struct tm tb; 82 struct tm tb;
81 memmove(&tb,&ta,sizeof(tb)); 83 memmove(&tb,&ta,sizeof(tb));
82 tb.tm_hour = h->to_bed.hour; tb.tm_min = h->to_bed.min; 84 tb.tm_hour = h->to_bed.hour; tb.tm_min = h->to_bed.min;
83 rv.to_bed = mktime(&tb); 85 rv.to_bed = mktime(&tb);
84 if(rv.to_bed == (time_t)-1) 86 if(rv.to_bed == (time_t)-1)
85 throw exception_st_data("failed to mktime() for 'to bed'"); 87 throw exception_st_data("failed to mktime() for 'to bed'");
86 if(rv.to_bed > rv.alarm) { 88 if(rv.to_bed > rv.alarm) {
87 back_a_day(tb); 89 back_a_day(tb);
88 rv.to_bed -= 24*60*60; 90 rv.to_bed -= 24*60*60;
89 } 91 }
90 struct tm taaw; 92 struct tm taaw;
91 memmove(&taaw,&tb,sizeof(taaw)); 93 memmove(&taaw,&tb,sizeof(taaw));
92 for(int rest=h->nawakes;rest;--rest,++aawake) { 94 for(int rest=h->nawakes;rest;--rest,++aawake) {
93 if( 95 if(
94 taaw.tm_mday!=ta.tm_mday 96 taaw.tm_mday!=ta.tm_mday
95 && ( 97 && (
96 aawake->hour < tb.tm_hour 98 aawake->hour < tb.tm_hour
diff --git a/src/db.cc b/src/db.cc
index c350e68..2b4a7eb 100644
--- a/src/db.cc
+++ b/src/db.cc
@@ -1,99 +1,101 @@
1#include <unistd.h> 1#include <unistd.h>
2#include <sys/stat.h> 2#include <sys/stat.h>
3#include <sys/types.h> 3#include <sys/types.h>
4#include <stdlib.h>
5#include <string.h>
4#include <cassert> 6#include <cassert>
5#include <napkin/exception.h> 7#include <napkin/exception.h>
6#include "db.h" 8#include "db.h"
7 9
8#include "config.h" 10#include "config.h"
9 11
10namespace napkin { 12namespace napkin {
11 13
12 extern const char *sql_bootstrap; 14 extern const char *sql_bootstrap;
13 15
14 db_t::db_t() { 16 db_t::db_t() {
15 const char *h = getenv("HOME"); 17 const char *h = getenv("HOME");
16 if(h) { 18 if(h) {
17 datadir = h; 19 datadir = h;
18 datadir += "/."PACKAGE_NAME"/"; 20 datadir += "/."PACKAGE_NAME"/";
19 }else{ 21 }else{
20#if defined(HAVE_GET_CURRENT_DIR_NAME) 22#if defined(HAVE_GET_CURRENT_DIR_NAME)
21 char *cwd = get_current_dir_name(); 23 char *cwd = get_current_dir_name();
22 if(!cwd) 24 if(!cwd)
23 throw napkin::exception("failed to get_current_dir_name()"); 25 throw napkin::exception("failed to get_current_dir_name()");
24 datadir = cwd; 26 datadir = cwd;
25 free(cwd); 27 free(cwd);
26#elif defined(HAVE_GETCWD) 28#elif defined(HAVE_GETCWD)
27 { 29 {
28 char cwd[ 30 char cwd[
29# if defined(MAXPATH) 31# if defined(MAXPATH)
30 MAXPATH 32 MAXPATH
31# elif defined(MAXPATHLEN) 33# elif defined(MAXPATHLEN)
32 MAXPATHLEN 34 MAXPATHLEN
33# else /* maxpath */ 35# else /* maxpath */
34 512 36 512
35# endif /* maxpath */ 37# endif /* maxpath */
36 ]; 38 ];
37 if(!getcwd(cwd,sizeof(cwd))) 39 if(!getcwd(cwd,sizeof(cwd)))
38 throw napkin::exception("failed to getcwd()"); 40 throw napkin::exception("failed to getcwd()");
39 datadir = cwd; 41 datadir = cwd;
40 } 42 }
41#else /* get cwd */ 43#else /* get cwd */
42# error dunno how to get current workdir 44# error dunno how to get current workdir
43#endif /* get cwd */ 45#endif /* get cwd */
44 datadir += "/."PACKAGE_NAME"/"; 46 datadir += "/."PACKAGE_NAME"/";
45 } 47 }
46 if(access(datadir.c_str(),R_OK|W_OK) 48 if(access(datadir.c_str(),R_OK|W_OK)
47 && mkdir(datadir.c_str(),0700)) 49 && mkdir(datadir.c_str(),0700))
48 throw napkin::exception("no access to '"+datadir+"' directory"); 50 throw napkin::exception("no access to '"+datadir+"' directory");
49 open((datadir+PACKAGE_NAME".db").c_str()); 51 open((datadir+PACKAGE_NAME".db").c_str());
50 assert(_D); 52 assert(_D);
51 char **resp; int nr,nc; char *errm; 53 char **resp; int nr,nc; char *errm;
52 if(sqlite3_get_table( 54 if(sqlite3_get_table(
53 _D, 55 _D,
54 "SELECT s_tobed FROM sleeps LIMIT 0", 56 "SELECT s_tobed FROM sleeps LIMIT 0",
55 &resp,&nr,&nc,&errm)!=SQLITE_OK) { 57 &resp,&nr,&nc,&errm)!=SQLITE_OK) {
56 if(sqlite3_exec(_D,sql_bootstrap,NULL,NULL,&errm)!=SQLITE_OK) 58 if(sqlite3_exec(_D,sql_bootstrap,NULL,NULL,&errm)!=SQLITE_OK)
57 throw napkin::exception(string("failed to bootstrap sqlite database: ")+errm); 59 throw napkin::exception(string("failed to bootstrap sqlite database: ")+errm);
58 }else 60 }else
59 sqlite3_free_table(resp); 61 sqlite3_free_table(resp);
60 } 62 }
61 63
62 void db_t::store(const hypnodata_t& hd) { 64 void db_t::store(const hypnodata_t& hd) {
63 sqlite::mem_t<char*> S = sqlite3_mprintf( 65 sqlite::mem_t<char*> S = sqlite3_mprintf(
64 "INSERT INTO sleeps (" 66 "INSERT INTO sleeps ("
65 "s_tobed,s_alarm," 67 "s_tobed,s_alarm,"
66 "s_window,s_data_a," 68 "s_window,s_data_a,"
67 "s_almost_awakes," 69 "s_almost_awakes,"
68 "s_timezone" 70 "s_timezone"
69 ") VALUES (" 71 ") VALUES ("
70 "%Q,%Q,%d,%d,%Q,%ld" 72 "%Q,%Q,%d,%d,%Q,%ld"
71 ")", 73 ")",
72 hd.w3c_to_bed().c_str(), 74 hd.w3c_to_bed().c_str(),
73 hd.w3c_alarm().c_str(), 75 hd.w3c_alarm().c_str(),
74 hd.window,hd.data_a, 76 hd.window,hd.data_a,
75 hd.w3c_almostawakes().c_str(), 77 hd.w3c_almostawakes().c_str(),
76 timezone ); 78 timezone );
77 try { 79 try {
78 exec(S); 80 exec(S);
79 }catch(sqlite::exception& se) { 81 }catch(sqlite::exception& se) {
80 if(se.rcode==SQLITE_CONSTRAINT) 82 if(se.rcode==SQLITE_CONSTRAINT)
81 throw exception_db_already("The record seems to be already in the database"); 83 throw exception_db_already("The record seems to be already in the database");
82 throw exception_db("Well, some error occured"); 84 throw exception_db("Well, some error occured");
83 } 85 }
84 } 86 }
85 87
86 void db_t::remove(const hypnodata_t& hd) { 88 void db_t::remove(const hypnodata_t& hd) {
87 sqlite::mem_t<char*> S = sqlite3_mprintf( 89 sqlite::mem_t<char*> S = sqlite3_mprintf(
88 "DELETE FROM sleeps" 90 "DELETE FROM sleeps"
89 " WHERE s_tobed=%Q AND s_alarm=%Q", 91 " WHERE s_tobed=%Q AND s_alarm=%Q",
90 hd.w3c_to_bed().c_str(), 92 hd.w3c_to_bed().c_str(),
91 hd.w3c_alarm().c_str() ); 93 hd.w3c_alarm().c_str() );
92 exec(S); 94 exec(S);
93 } 95 }
94 96
95 void db_t::load(list<hypnodata_ptr_t>& rv, 97 void db_t::load(list<hypnodata_ptr_t>& rv,
96 const string& sql) { 98 const string& sql) {
97 sqlite::table_t T; 99 sqlite::table_t T;
98 int nr,nc; 100 int nr,nc;
99 get_table( string( 101 get_table( string(