-rw-r--r-- | configure.ac | 1 | ||||
-rw-r--r-- | test/OP.cc | 6 |
2 files changed, 6 insertions, 1 deletions
diff --git a/configure.ac b/configure.ac index e636253..606e644 100644 --- a/configure.ac +++ b/configure.ac | |||
@@ -1,143 +1,144 @@ | |||
1 | AC_INIT([libopkele], [2.0.4], [libopkele-bugs@klever.net]) | 1 | AC_INIT([libopkele], [2.0.4], [libopkele-bugs@klever.net]) |
2 | AC_CONFIG_SRCDIR([include/opkele/opkele-config.h]) | 2 | AC_CONFIG_SRCDIR([include/opkele/opkele-config.h]) |
3 | AC_CONFIG_HEADERS([config.h include/opkele/acconfig.h]) | 3 | AC_CONFIG_HEADERS([config.h include/opkele/acconfig.h]) |
4 | AC_CONFIG_MACRO_DIR([aclocal.d]) | 4 | AC_CONFIG_MACRO_DIR([aclocal.d]) |
5 | AC_CONFIG_AUX_DIR([aux.d]) | 5 | AC_CONFIG_AUX_DIR([aux.d]) |
6 | AM_INIT_AUTOMAKE([dist-bzip2]) | 6 | AM_INIT_AUTOMAKE([dist-bzip2]) |
7 | 7 | ||
8 | AC_PROG_INSTALL | 8 | AC_PROG_INSTALL |
9 | AC_PROG_CXX | 9 | AC_PROG_CXX |
10 | AC_PROG_CC | 10 | AC_PROG_CC |
11 | AC_PROG_LIBTOOL | 11 | AC_PROG_LIBTOOL |
12 | PKG_PROG_PKG_CONFIG | 12 | PKG_PROG_PKG_CONFIG |
13 | 13 | ||
14 | AC_HEADER_STDC | 14 | AC_HEADER_STDC |
15 | AC_CHECK_FUNCS([timegm]) | 15 | AC_CHECK_FUNCS([timegm]) |
16 | AC_CHECK_HEADERS([ext/algorithm.h]) | ||
16 | 17 | ||
17 | AC_PATH_PROG([XSLTPROC],[xsltproc],[true]) | 18 | AC_PATH_PROG([XSLTPROC],[xsltproc],[true]) |
18 | 19 | ||
19 | AC_MSG_CHECKING([for source tree version]) | 20 | AC_MSG_CHECKING([for source tree version]) |
20 | if headrev=$(cd $srcdir && git rev-parse --verify HEAD 2>/dev/null) ; then | 21 | if headrev=$(cd $srcdir && git rev-parse --verify HEAD 2>/dev/null) ; then |
21 | PACKAGE_SRC_VERSION="$(cd $srcdir && git describe --tags $headrev)" | 22 | PACKAGE_SRC_VERSION="$(cd $srcdir && git describe --tags $headrev)" |
22 | test "$PACKAGE_SRC_VERSION" = "$PACKAGE_VERSION" \ | 23 | test "$PACKAGE_SRC_VERSION" = "$PACKAGE_VERSION" \ |
23 | -o "${PACKAGE_SRC_VERSION#${PACKAGE_VERSION}-}" != "$PACKAGE_SRC_VERSION" || PACKAGE_SRC_VERSION="${PACKAGE_VERSION}:${PACKAGE_SRC_VERSION}" | 24 | -o "${PACKAGE_SRC_VERSION#${PACKAGE_VERSION}-}" != "$PACKAGE_SRC_VERSION" || PACKAGE_SRC_VERSION="${PACKAGE_VERSION}:${PACKAGE_SRC_VERSION}" |
24 | ( cd $srcdir && git diff-index $headrev | read dirt ) && PACKAGE_SRC_VERSION="${PACKAGE_SRC_VERSION}-dirty" | 25 | ( cd $srcdir && git diff-index $headrev | read dirt ) && PACKAGE_SRC_VERSION="${PACKAGE_SRC_VERSION}-dirty" |
25 | else | 26 | else |
26 | PACKAGE_SRC_VERSION="$PACKAGE_VERSION" | 27 | PACKAGE_SRC_VERSION="$PACKAGE_VERSION" |
27 | fi | 28 | fi |
28 | AC_MSG_RESULT([$PACKAGE_SRC_VERSION]) | 29 | AC_MSG_RESULT([$PACKAGE_SRC_VERSION]) |
29 | AC_SUBST([PACKAGE_SRC_VERSION]) | 30 | AC_SUBST([PACKAGE_SRC_VERSION]) |
30 | AC_DEFINE_UNQUOTED([PACKAGE_SRC_VERSION],["$PACKAGE_SRC_VERSION"],[more or less precise source tree version]) | 31 | AC_DEFINE_UNQUOTED([PACKAGE_SRC_VERSION],["$PACKAGE_SRC_VERSION"],[more or less precise source tree version]) |
31 | 32 | ||
32 | tr1_mem_std="false" | 33 | tr1_mem_std="false" |
33 | tr1_mem_boost="false" | 34 | tr1_mem_boost="false" |
34 | AC_CHECK_SHAREDPTR(std::tr1,tr1/memory,[ tr1_mem_std=true ]) | 35 | AC_CHECK_SHAREDPTR(std::tr1,tr1/memory,[ tr1_mem_std=true ]) |
35 | AC_CHECK_SHAREDPTR(boost,boost/shared_ptr.hpp,[ tr1_mem_boost=true ]) | 36 | AC_CHECK_SHAREDPTR(boost,boost/shared_ptr.hpp,[ tr1_mem_boost=true ]) |
36 | tr1_mem="" | 37 | tr1_mem="" |
37 | AC_ARG_WITH([tr1-memory], | 38 | AC_ARG_WITH([tr1-memory], |
38 | AC_HELP_STRING([--with-tr1-memory=<boost|std>],[select tr1/memory (shared_ptr<>) implementation to use]), | 39 | AC_HELP_STRING([--with-tr1-memory=<boost|std>],[select tr1/memory (shared_ptr<>) implementation to use]), |
39 | [ tr1_mem="$withval" ] | 40 | [ tr1_mem="$withval" ] |
40 | ) | 41 | ) |
41 | AC_MSG_CHECKING([for tr1/memory implementation to use]) | 42 | AC_MSG_CHECKING([for tr1/memory implementation to use]) |
42 | test -z "$tr1_mem" && $tr1_mem_std && tr1_mem=std | 43 | test -z "$tr1_mem" && $tr1_mem_std && tr1_mem=std |
43 | test -z "$tr1_mem" && $tr1_mem_boost && tr1_mem=boost | 44 | test -z "$tr1_mem" && $tr1_mem_boost && tr1_mem=boost |
44 | if test -z "$tr1_mem" ; then | 45 | if test -z "$tr1_mem" ; then |
45 | AC_MSG_RESULT([none found]) | 46 | AC_MSG_RESULT([none found]) |
46 | else | 47 | else |
47 | AC_MSG_RESULT([$tr1_mem]) | 48 | AC_MSG_RESULT([$tr1_mem]) |
48 | fi | 49 | fi |
49 | case "$tr1_mem" in | 50 | case "$tr1_mem" in |
50 | std) | 51 | std) |
51 | $tr1_mem_std || AC_MSG_ERROR([std implementation requested, but not found]) | 52 | $tr1_mem_std || AC_MSG_ERROR([std implementation requested, but not found]) |
52 | OPKELE_TR1_MEM_NS=std::tr1 | 53 | OPKELE_TR1_MEM_NS=std::tr1 |
53 | OPKELE_TR1_MEM_HEADER=tr1/memory | 54 | OPKELE_TR1_MEM_HEADER=tr1/memory |
54 | ;; | 55 | ;; |
55 | boost) | 56 | boost) |
56 | $tr1_mem_boost || AC_MSG_ERROR([boost implementation requested, but not found]) | 57 | $tr1_mem_boost || AC_MSG_ERROR([boost implementation requested, but not found]) |
57 | OPKELE_TR1_MEM_NS=boost | 58 | OPKELE_TR1_MEM_NS=boost |
58 | OPKELE_TR1_MEM_HEADER=boost/shared_ptr.hpp | 59 | OPKELE_TR1_MEM_HEADER=boost/shared_ptr.hpp |
59 | ;; | 60 | ;; |
60 | *) | 61 | *) |
61 | AC_MSG_ERROR([no shared_ptr<> implementation found]) | 62 | AC_MSG_ERROR([no shared_ptr<> implementation found]) |
62 | ;; | 63 | ;; |
63 | esac | 64 | esac |
64 | AC_SUBST([OPKELE_TR1_MEM_NS]) | 65 | AC_SUBST([OPKELE_TR1_MEM_NS]) |
65 | AC_SUBST([OPKELE_TR1_MEM_HEADER]) | 66 | AC_SUBST([OPKELE_TR1_MEM_HEADER]) |
66 | 67 | ||
67 | AC_MSG_CHECKING([for deprecated attribute support]) | 68 | AC_MSG_CHECKING([for deprecated attribute support]) |
68 | AC_COMPILE_IFELSE([ | 69 | AC_COMPILE_IFELSE([ |
69 | int __attribute__((deprecated)) deprecated_function(); | 70 | int __attribute__((deprecated)) deprecated_function(); |
70 | ],[ | 71 | ],[ |
71 | AC_MSG_RESULT([yes]) | 72 | AC_MSG_RESULT([yes]) |
72 | AC_DEFINE([OPKELE_DEPRECATE],[__attribute__((deprecated))],[deprecated function attribute]) | 73 | AC_DEFINE([OPKELE_DEPRECATE],[__attribute__((deprecated))],[deprecated function attribute]) |
73 | ],[ | 74 | ],[ |
74 | AC_MSG_RESULT([no]) | 75 | AC_MSG_RESULT([no]) |
75 | AC_DEFINE([OPKELE_DEPRECATE],,[deprecated function attribute]) | 76 | AC_DEFINE([OPKELE_DEPRECATE],,[deprecated function attribute]) |
76 | ] | 77 | ] |
77 | ) | 78 | ) |
78 | 79 | ||
79 | AC_LANG_PUSH([C++]) | 80 | AC_LANG_PUSH([C++]) |
80 | AC_MSG_CHECKING([for abi::__cxa_demangle]) | 81 | AC_MSG_CHECKING([for abi::__cxa_demangle]) |
81 | AC_COMPILE_IFELSE([ | 82 | AC_COMPILE_IFELSE([ |
82 | #include <typeinfo> | 83 | #include <typeinfo> |
83 | using namespace std; | 84 | using namespace std; |
84 | #include <cxxabi.h> | 85 | #include <cxxabi.h> |
85 | int main(int c,char **v) { | 86 | int main(int c,char **v) { |
86 | int dstat; | 87 | int dstat; |
87 | char *demangled = abi::__cxa_demangle(typeid(dstat).name(),0,0,&dstat); | 88 | char *demangled = abi::__cxa_demangle(typeid(dstat).name(),0,0,&dstat); |
88 | return 0; | 89 | return 0; |
89 | } | 90 | } |
90 | ],[ | 91 | ],[ |
91 | AC_MSG_RESULT([yes]) | 92 | AC_MSG_RESULT([yes]) |
92 | AC_DEFINE([HAVE_DEMANGLE],,[defined if abi::__cxa_demangle is available]) | 93 | AC_DEFINE([HAVE_DEMANGLE],,[defined if abi::__cxa_demangle is available]) |
93 | ],[ | 94 | ],[ |
94 | AC_MSG_RESULT([no]) | 95 | AC_MSG_RESULT([no]) |
95 | ] | 96 | ] |
96 | ) | 97 | ) |
97 | AC_LANG_POP([C++]) | 98 | AC_LANG_POP([C++]) |
98 | 99 | ||
99 | 100 | ||
100 | 101 | ||
101 | 102 | ||
102 | PKG_CHECK_MODULES([OPENSSL],[openssl],,[ | 103 | PKG_CHECK_MODULES([OPENSSL],[openssl],,[ |
103 | AC_MSG_ERROR([no openssl library found. get one from http://www.openssl.org/]) | 104 | AC_MSG_ERROR([no openssl library found. get one from http://www.openssl.org/]) |
104 | ]) | 105 | ]) |
105 | 106 | ||
106 | WANT_KONFORKA="yes" | 107 | WANT_KONFORKA="yes" |
107 | AC_ARG_ENABLE([konforka], | 108 | AC_ARG_ENABLE([konforka], |
108 | AC_HELP_STRING([--disable-konforka],[do not use konforka library (default: use if found)]), | 109 | AC_HELP_STRING([--disable-konforka],[do not use konforka library (default: use if found)]), |
109 | [ | 110 | [ |
110 | test "${enableval}" = "no" && WANT_KONFORKA="no" | 111 | test "${enableval}" = "no" && WANT_KONFORKA="no" |
111 | ] | 112 | ] |
112 | ) | 113 | ) |
113 | if test "${WANT_KONFORKA}" = "yes" ; then | 114 | if test "${WANT_KONFORKA}" = "yes" ; then |
114 | PKG_CHECK_MODULES([KONFORKA],[konforka],[ | 115 | PKG_CHECK_MODULES([KONFORKA],[konforka],[ |
115 | AC_SUBST([KONFORKA_CFLAGS]) | 116 | AC_SUBST([KONFORKA_CFLAGS]) |
116 | AC_SUBST([KONFORKA_LIBS]) | 117 | AC_SUBST([KONFORKA_LIBS]) |
117 | AC_DEFINE([HAVE_KONFORKA],,[defined in presence of konforka library]) | 118 | AC_DEFINE([HAVE_KONFORKA],,[defined in presence of konforka library]) |
118 | AC_DEFINE([OPKELE_HAVE_KONFORKA],,[defined in presence of konforka library]) | 119 | AC_DEFINE([OPKELE_HAVE_KONFORKA],,[defined in presence of konforka library]) |
119 | AC_SUBST([KONFORKA_KONFORKA],[konforka]) | 120 | AC_SUBST([KONFORKA_KONFORKA],[konforka]) |
120 | ],[true]) | 121 | ],[true]) |
121 | fi | 122 | fi |
122 | 123 | ||
123 | WANT_DOXYGEN="yes" | 124 | WANT_DOXYGEN="yes" |
124 | AC_ARG_ENABLE([doxygen], | 125 | AC_ARG_ENABLE([doxygen], |
125 | AC_HELP_STRING([--disable-doxygen],[do not generate documentation]), | 126 | AC_HELP_STRING([--disable-doxygen],[do not generate documentation]), |
126 | [ | 127 | [ |
127 | test "${enableval}" = "no" && WANT_DOXYGEN="no" | 128 | test "${enableval}" = "no" && WANT_DOXYGEN="no" |
128 | ] | 129 | ] |
129 | ) | 130 | ) |
130 | if test "${WANT_DOXYGEN}" = "yes" ; then | 131 | if test "${WANT_DOXYGEN}" = "yes" ; then |
131 | AC_WITH_DOXYGEN | 132 | AC_WITH_DOXYGEN |
132 | AC_WITH_DOT | 133 | AC_WITH_DOT |
133 | else | 134 | else |
134 | AM_CONDITIONAL([HAVE_DOXYGEN],[false]) | 135 | AM_CONDITIONAL([HAVE_DOXYGEN],[false]) |
135 | AM_CONDITIONAL([HAVE_DOT],[false]) | 136 | AM_CONDITIONAL([HAVE_DOT],[false]) |
136 | fi | 137 | fi |
137 | 138 | ||
138 | LIBCURL_CHECK_CONFIG(,,,[ | 139 | LIBCURL_CHECK_CONFIG(,,,[ |
139 | AC_MSG_ERROR([no required libcurl library. get one from http://curl.haxx.se/]) | 140 | AC_MSG_ERROR([no required libcurl library. get one from http://curl.haxx.se/]) |
140 | ]) | 141 | ]) |
141 | 142 | ||
142 | AC_CHECK_HEADER([expat.h],[ | 143 | AC_CHECK_HEADER([expat.h],[ |
143 | AC_CHECK_LIB([expat],[XML_ParserCreate],[ | 144 | AC_CHECK_LIB([expat],[XML_ParserCreate],[ |
@@ -1,146 +1,150 @@ | |||
1 | #include <uuid/uuid.h> | 1 | #include <uuid/uuid.h> |
2 | #include <iostream> | 2 | #include <iostream> |
3 | #include <cassert> | 3 | #include <cassert> |
4 | #include <string> | 4 | #include <string> |
5 | #include <ext/algorithm> | ||
6 | using namespace std; | 5 | using namespace std; |
7 | #include <kingate/exception.h> | 6 | #include <kingate/exception.h> |
8 | #include <kingate/plaincgi.h> | 7 | #include <kingate/plaincgi.h> |
9 | #include <kingate/cgi_gateway.h> | 8 | #include <kingate/cgi_gateway.h> |
10 | #include <opkele/exception.h> | 9 | #include <opkele/exception.h> |
11 | #include <opkele/util.h> | 10 | #include <opkele/util.h> |
12 | #include <opkele/uris.h> | 11 | #include <opkele/uris.h> |
13 | #include <opkele/extension.h> | 12 | #include <opkele/extension.h> |
14 | #include <opkele/association.h> | 13 | #include <opkele/association.h> |
15 | #include <opkele/debug.h> | 14 | #include <opkele/debug.h> |
16 | #include <opkele/verify_op.h> | 15 | #include <opkele/verify_op.h> |
17 | #include <opkele/sreg.h> | 16 | #include <opkele/sreg.h> |
18 | 17 | ||
18 | #include "config.h" | ||
19 | #ifdef HAVE_EXT_ALGORITHM_H | ||
20 | # include <ext/algorithm> | ||
21 | #endif | ||
22 | |||
19 | #include "sqlite.h" | 23 | #include "sqlite.h" |
20 | #include "kingate_openid_message.h" | 24 | #include "kingate_openid_message.h" |
21 | 25 | ||
22 | static const string get_self_url(const kingate::cgi_gateway& gw) { | 26 | static const string get_self_url(const kingate::cgi_gateway& gw) { |
23 | bool s = gw.has_meta("SSL_PROTOCOL_VERSION"); | 27 | bool s = gw.has_meta("SSL_PROTOCOL_VERSION"); |
24 | string rv = s?"https://":"http://"; | 28 | string rv = s?"https://":"http://"; |
25 | rv += gw.http_request_header("Host"); | 29 | rv += gw.http_request_header("Host"); |
26 | const string& port = gw.get_meta("SERVER_PORT"); | 30 | const string& port = gw.get_meta("SERVER_PORT"); |
27 | if( port!=(s?"443":"80") ) { | 31 | if( port!=(s?"443":"80") ) { |
28 | rv += ':'; rv += port; | 32 | rv += ':'; rv += port; |
29 | } | 33 | } |
30 | rv += gw.get_meta("REQUEST_URI"); | 34 | rv += gw.get_meta("REQUEST_URI"); |
31 | string::size_type q = rv.find('?'); | 35 | string::size_type q = rv.find('?'); |
32 | if(q!=string::npos) | 36 | if(q!=string::npos) |
33 | rv.erase(q); | 37 | rv.erase(q); |
34 | return rv; | 38 | return rv; |
35 | } | 39 | } |
36 | 40 | ||
37 | class opdb_t : public sqlite3_t { | 41 | class opdb_t : public sqlite3_t { |
38 | public: | 42 | public: |
39 | opdb_t() | 43 | opdb_t() |
40 | : sqlite3_t("/tmp/OP.db") { | 44 | : sqlite3_t("/tmp/OP.db") { |
41 | assert(_D); | 45 | assert(_D); |
42 | char **resp; int nr,nc; char *errm; | 46 | char **resp; int nr,nc; char *errm; |
43 | if(sqlite3_get_table( | 47 | if(sqlite3_get_table( |
44 | _D, "SELECT a_op FROM assoc LIMIT 0", | 48 | _D, "SELECT a_op FROM assoc LIMIT 0", |
45 | &resp,&nr,&nc,&errm)!=SQLITE_OK) { | 49 | &resp,&nr,&nc,&errm)!=SQLITE_OK) { |
46 | extern const char *__OP_db_bootstrap; | 50 | extern const char *__OP_db_bootstrap; |
47 | DOUT_("Bootstrapping DB"); | 51 | DOUT_("Bootstrapping DB"); |
48 | if(sqlite3_exec(_D,__OP_db_bootstrap,NULL,NULL,&errm)!=SQLITE_OK) | 52 | if(sqlite3_exec(_D,__OP_db_bootstrap,NULL,NULL,&errm)!=SQLITE_OK) |
49 | throw opkele::exception(OPKELE_CP_ string("Failed to boostrap SQLite database: ")+errm); | 53 | throw opkele::exception(OPKELE_CP_ string("Failed to boostrap SQLite database: ")+errm); |
50 | }else | 54 | }else |
51 | sqlite3_free_table(resp); | 55 | sqlite3_free_table(resp); |
52 | } | 56 | } |
53 | }; | 57 | }; |
54 | 58 | ||
55 | class example_op_t : public opkele::verify_OP { | 59 | class example_op_t : public opkele::verify_OP { |
56 | public: | 60 | public: |
57 | kingate::cgi_gateway& gw; | 61 | kingate::cgi_gateway& gw; |
58 | opdb_t db; | 62 | opdb_t db; |
59 | kingate::cookie htc; | 63 | kingate::cookie htc; |
60 | 64 | ||
61 | 65 | ||
62 | example_op_t(kingate::cgi_gateway& g) | 66 | example_op_t(kingate::cgi_gateway& g) |
63 | : gw(g) { | 67 | : gw(g) { |
64 | try { | 68 | try { |
65 | htc = gw.cookies.get_cookie("htop_session"); | 69 | htc = gw.cookies.get_cookie("htop_session"); |
66 | sqlite3_mem_t<char*> S = sqlite3_mprintf( | 70 | sqlite3_mem_t<char*> S = sqlite3_mprintf( |
67 | "SELECT 1 FROM ht_sessions WHERE hts_id=%Q", | 71 | "SELECT 1 FROM ht_sessions WHERE hts_id=%Q", |
68 | htc.get_value().c_str()); | 72 | htc.get_value().c_str()); |
69 | sqlite3_table_t T; int nr,nc; | 73 | sqlite3_table_t T; int nr,nc; |
70 | db.get_table(S,T,&nr,&nc); | 74 | db.get_table(S,T,&nr,&nc); |
71 | if(nr<1) | 75 | if(nr<1) |
72 | throw kingate::exception_notfound(CODEPOINT,"forcing cookie generation"); | 76 | throw kingate::exception_notfound(CODEPOINT,"forcing cookie generation"); |
73 | }catch(kingate::exception_notfound& kenf) { | 77 | }catch(kingate::exception_notfound& kenf) { |
74 | uuid_t uuid; uuid_generate(uuid); | 78 | uuid_t uuid; uuid_generate(uuid); |
75 | htc = kingate::cookie("htop_session",opkele::util::encode_base64(uuid,sizeof(uuid))); | 79 | htc = kingate::cookie("htop_session",opkele::util::encode_base64(uuid,sizeof(uuid))); |
76 | sqlite3_mem_t<char*> S = sqlite3_mprintf( | 80 | sqlite3_mem_t<char*> S = sqlite3_mprintf( |
77 | "INSERT INTO ht_sessions (hts_id) VALUES (%Q)", | 81 | "INSERT INTO ht_sessions (hts_id) VALUES (%Q)", |
78 | htc.get_value().c_str()); | 82 | htc.get_value().c_str()); |
79 | db.exec(S); | 83 | db.exec(S); |
80 | } | 84 | } |
81 | } | 85 | } |
82 | 86 | ||
83 | void set_authorized(bool a) { | 87 | void set_authorized(bool a) { |
84 | sqlite3_mem_t<char*> | 88 | sqlite3_mem_t<char*> |
85 | S = sqlite3_mprintf( | 89 | S = sqlite3_mprintf( |
86 | "UPDATE ht_sessions" | 90 | "UPDATE ht_sessions" |
87 | " SET authorized=%d" | 91 | " SET authorized=%d" |
88 | " WHERE hts_id=%Q", | 92 | " WHERE hts_id=%Q", |
89 | (int)a,htc.get_value().c_str()); | 93 | (int)a,htc.get_value().c_str()); |
90 | db.exec(S); | 94 | db.exec(S); |
91 | } | 95 | } |
92 | bool get_authorized() { | 96 | bool get_authorized() { |
93 | sqlite3_mem_t<char*> | 97 | sqlite3_mem_t<char*> |
94 | S = sqlite3_mprintf( | 98 | S = sqlite3_mprintf( |
95 | "SELECT authorized" | 99 | "SELECT authorized" |
96 | " FROM ht_sessions" | 100 | " FROM ht_sessions" |
97 | " WHERE hts_id=%Q", | 101 | " WHERE hts_id=%Q", |
98 | htc.get_value().c_str()); | 102 | htc.get_value().c_str()); |
99 | sqlite3_table_t T; int nr,nc; | 103 | sqlite3_table_t T; int nr,nc; |
100 | db.get_table(S,T,&nr,&nc); | 104 | db.get_table(S,T,&nr,&nc); |
101 | assert(nr==1); assert(nc=1); | 105 | assert(nr==1); assert(nc=1); |
102 | return opkele::util::string_to_long(T.get(1,0,nc)); | 106 | return opkele::util::string_to_long(T.get(1,0,nc)); |
103 | } | 107 | } |
104 | 108 | ||
105 | ostream& cookie_header(ostream& o) const { | 109 | ostream& cookie_header(ostream& o) const { |
106 | o << "Set-Cookie: " << htc.set_cookie_header() << "\n"; | 110 | o << "Set-Cookie: " << htc.set_cookie_header() << "\n"; |
107 | return o; | 111 | return o; |
108 | } | 112 | } |
109 | 113 | ||
110 | opkele::assoc_t alloc_assoc(const string& type,size_t klength,bool sl) { | 114 | opkele::assoc_t alloc_assoc(const string& type,size_t klength,bool sl) { |
111 | uuid_t uuid; uuid_generate(uuid); | 115 | uuid_t uuid; uuid_generate(uuid); |
112 | string a_handle = opkele::util::encode_base64(uuid,sizeof(uuid)); | 116 | string a_handle = opkele::util::encode_base64(uuid,sizeof(uuid)); |
113 | opkele::secret_t a_secret; | 117 | opkele::secret_t a_secret; |
114 | generate_n( | 118 | generate_n( |
115 | back_insert_iterator<opkele::secret_t>(a_secret),klength, | 119 | back_insert_iterator<opkele::secret_t>(a_secret),klength, |
116 | rand ); | 120 | rand ); |
117 | string ssecret; a_secret.to_base64(ssecret); | 121 | string ssecret; a_secret.to_base64(ssecret); |
118 | time_t now = time(0); | 122 | time_t now = time(0); |
119 | int expires_in = sl?3600*2:3600*24*7*2; | 123 | int expires_in = sl?3600*2:3600*24*7*2; |
120 | sqlite3_mem_t<char*> | 124 | sqlite3_mem_t<char*> |
121 | S = sqlite3_mprintf( | 125 | S = sqlite3_mprintf( |
122 | "INSERT INTO assoc" | 126 | "INSERT INTO assoc" |
123 | " (a_handle,a_type,a_ctime,a_etime,a_secret,a_stateless)" | 127 | " (a_handle,a_type,a_ctime,a_etime,a_secret,a_stateless)" |
124 | " VALUES (" | 128 | " VALUES (" |
125 | " %Q,%Q,datetime('now')," | 129 | " %Q,%Q,datetime('now')," |
126 | " datetime('now','+%d seconds')," | 130 | " datetime('now','+%d seconds')," |
127 | " %Q,%d );", | 131 | " %Q,%d );", |
128 | a_handle.c_str(), type.c_str(), | 132 | a_handle.c_str(), type.c_str(), |
129 | expires_in, | 133 | expires_in, |
130 | ssecret.c_str(), sl ); | 134 | ssecret.c_str(), sl ); |
131 | db.exec(S); | 135 | db.exec(S); |
132 | return opkele::assoc_t(new opkele::association( | 136 | return opkele::assoc_t(new opkele::association( |
133 | "", | 137 | "", |
134 | a_handle, type, a_secret, | 138 | a_handle, type, a_secret, |
135 | now+expires_in, sl )); | 139 | now+expires_in, sl )); |
136 | } | 140 | } |
137 | 141 | ||
138 | opkele::assoc_t retrieve_assoc(const string& h) { | 142 | opkele::assoc_t retrieve_assoc(const string& h) { |
139 | sqlite3_mem_t<char*> | 143 | sqlite3_mem_t<char*> |
140 | S = sqlite3_mprintf( | 144 | S = sqlite3_mprintf( |
141 | "SELECT" | 145 | "SELECT" |
142 | " a_handle,a_type,a_secret,a_stateless," | 146 | " a_handle,a_type,a_secret,a_stateless," |
143 | " strftime('%%s',a_etime) AS a_etime," | 147 | " strftime('%%s',a_etime) AS a_etime," |
144 | " a_itime" | 148 | " a_itime" |
145 | " FROM assoc" | 149 | " FROM assoc" |
146 | " WHERE a_handle=%Q AND a_itime IS NULL" | 150 | " WHERE a_handle=%Q AND a_itime IS NULL" |