-rw-r--r-- | lib/Makefile.am | 2 | ||||
-rw-r--r-- | lib/message.cc (renamed from lib/openid_message.cc) | 94 |
2 files changed, 45 insertions, 51 deletions
diff --git a/lib/Makefile.am b/lib/Makefile.am index e8bfbf5..9b25b42 100644 --- a/lib/Makefile.am +++ b/lib/Makefile.am | |||
@@ -29,5 +29,5 @@ libopkele_la_SOURCES = \ | |||
29 | discovery.cc \ | 29 | discovery.cc \ |
30 | basic_rp.cc prequeue_rp.cc \ | 30 | basic_rp.cc prequeue_rp.cc \ |
31 | openid_message.cc \ | 31 | message.cc \ |
32 | basic_op.cc verify_op.cc | 32 | basic_op.cc verify_op.cc |
33 | libopkele_la_LDFLAGS = \ | 33 | libopkele_la_LDFLAGS = \ |
diff --git a/lib/openid_message.cc b/lib/message.cc index e244f43..78f20f4 100644 --- a/lib/openid_message.cc +++ b/lib/message.cc | |||
@@ -13,8 +13,8 @@ namespace opkele { | |||
13 | struct __om_copier : public unary_function<const string&,void> { | 13 | struct __om_copier : public unary_function<const string&,void> { |
14 | public: | 14 | public: |
15 | const basic_openid_message& from; | 15 | const basic_message& from; |
16 | basic_openid_message& to; | 16 | basic_message& to; |
17 | 17 | ||
18 | __om_copier(basic_openid_message& t,const basic_openid_message& f) | 18 | __om_copier(basic_message& t,const basic_message& f) |
19 | : from(f), to(t) { } | 19 | : from(f), to(t) { } |
20 | 20 | ||
@@ -23,59 +23,29 @@ namespace opkele { | |||
23 | }; | 23 | }; |
24 | 24 | ||
25 | basic_openid_message::basic_openid_message(const basic_openid_message& x) { | 25 | basic_message::basic_message(const basic_message& x) { |
26 | x.copy_to(*this); | 26 | x.copy_to(*this); |
27 | } | 27 | } |
28 | void basic_openid_message::copy_to(basic_openid_message& x) const { | 28 | void basic_message::copy_to(basic_message& x) const { |
29 | x.reset_fields(); | 29 | x.reset_fields(); |
30 | for_each(fields_begin(),fields_end(), | 30 | for_each(fields_begin(),fields_end(), |
31 | __om_copier(x,*this) ); | 31 | __om_copier(x,*this) ); |
32 | } | 32 | } |
33 | void basic_openid_message::append_to(basic_openid_message& x) const { | 33 | void basic_message::append_to(basic_message& x) const { |
34 | for_each(fields_begin(),fields_end(), | 34 | for_each(fields_begin(),fields_end(), |
35 | __om_copier(x,*this) ); | 35 | __om_copier(x,*this) ); |
36 | } | 36 | } |
37 | 37 | ||
38 | struct __om_ns_finder : public unary_function<const string&,bool> { | ||
39 | public: | ||
40 | const basic_openid_message& om; | ||
41 | const string& uri; | ||
42 | |||
43 | __om_ns_finder(const basic_openid_message& m, | ||
44 | const string& u) : om(m), uri(u) { } | ||
45 | |||
46 | result_type operator()(argument_type f) { | ||
47 | return | ||
48 | (!strncmp(f.c_str(),"ns.",sizeof("ns.")-1)) | ||
49 | && om.get_field(f)==uri ; | ||
50 | } | ||
51 | }; | ||
52 | |||
53 | bool basic_openid_message::has_ns(const string& uri) const { | ||
54 | fields_iterator ei = fields_end(); | ||
55 | fields_iterator i = find_if(fields_begin(),fields_end(), | ||
56 | __om_ns_finder(*this,uri)); | ||
57 | return !(i==ei); | ||
58 | } | ||
59 | string basic_openid_message::get_ns(const string& uri) const { | ||
60 | fields_iterator ei = fields_end(); | ||
61 | fields_iterator i = find_if(fields_begin(),fields_end(), | ||
62 | __om_ns_finder(*this,uri)); | ||
63 | if(i==ei) | ||
64 | throw failed_lookup(OPKELE_CP_ string("failed to find namespace ")+uri); | ||
65 | return i->substr(3); | ||
66 | } | ||
67 | |||
68 | struct __om_query_builder : public unary_function<const string&,void> { | 38 | struct __om_query_builder : public unary_function<const string&,void> { |
69 | public: | 39 | public: |
70 | const basic_openid_message& om; | 40 | const basic_message& om; |
71 | bool first; | 41 | bool first; |
72 | string& rv; | 42 | string& rv; |
73 | const char *pfx; | 43 | const char *pfx; |
74 | 44 | ||
75 | __om_query_builder(const char *p,string& r,const basic_openid_message& m) | 45 | __om_query_builder(const char *p,string& r,const basic_message& m) |
76 | : om(m), first(true), rv(r), pfx(p) { | 46 | : om(m), first(true), rv(r), pfx(p) { |
77 | for_each(om.fields_begin(),om.fields_end(),*this); | 47 | for_each(om.fields_begin(),om.fields_end(),*this); |
78 | } | 48 | } |
79 | __om_query_builder(const char *p,string& r,const basic_openid_message& m,const string& u) | 49 | __om_query_builder(const char *p,string& r,const basic_message& m,const string& u) |
80 | : om(m), first(true), rv(r), pfx(p) { | 50 | : om(m), first(true), rv(r), pfx(p) { |
81 | rv = u; | 51 | rv = u; |
@@ -99,23 +69,53 @@ namespace opkele { | |||
99 | }; | 69 | }; |
100 | 70 | ||
101 | string basic_openid_message::append_query(const string& url,const char *pfx) const { | 71 | string basic_message::append_query(const string& url,const char *pfx) const { |
102 | string rv; | 72 | string rv; |
103 | return __om_query_builder(pfx,rv,*this,url).rv; | 73 | return __om_query_builder(pfx,rv,*this,url).rv; |
104 | } | 74 | } |
105 | string basic_openid_message::query_string(const char *pfx) const { | 75 | string basic_message::query_string(const char *pfx) const { |
106 | string rv; | 76 | string rv; |
107 | return __om_query_builder(pfx,rv,*this).rv; | 77 | return __om_query_builder(pfx,rv,*this).rv; |
108 | } | 78 | } |
109 | 79 | ||
110 | void basic_openid_message::reset_fields() { | 80 | void basic_message::reset_fields() { |
111 | throw not_implemented(OPKELE_CP_ "reset_fields() not implemented"); | 81 | throw not_implemented(OPKELE_CP_ "reset_fields() not implemented"); |
112 | } | 82 | } |
113 | void basic_openid_message::set_field(const string&,const string&) { | 83 | void basic_message::set_field(const string&,const string&) { |
114 | throw not_implemented(OPKELE_CP_ "set_field() not implemented"); | 84 | throw not_implemented(OPKELE_CP_ "set_field() not implemented"); |
115 | } | 85 | } |
116 | void basic_openid_message::reset_field(const string&) { | 86 | void basic_message::reset_field(const string&) { |
117 | throw not_implemented(OPKELE_CP_ "reset_field() not implemented"); | 87 | throw not_implemented(OPKELE_CP_ "reset_field() not implemented"); |
118 | } | 88 | } |
119 | 89 | ||
90 | struct __om_ns_finder : public unary_function<const string&,bool> { | ||
91 | public: | ||
92 | const basic_openid_message& om; | ||
93 | const string& uri; | ||
94 | |||
95 | __om_ns_finder(const basic_openid_message& m, | ||
96 | const string& u) : om(m), uri(u) { } | ||
97 | |||
98 | result_type operator()(argument_type f) { | ||
99 | return | ||
100 | (!strncmp(f.c_str(),"ns.",sizeof("ns.")-1)) | ||
101 | && om.get_field(f)==uri ; | ||
102 | } | ||
103 | }; | ||
104 | |||
105 | bool basic_openid_message::has_ns(const string& uri) const { | ||
106 | fields_iterator ei = fields_end(); | ||
107 | fields_iterator i = find_if(fields_begin(),fields_end(), | ||
108 | __om_ns_finder(*this,uri)); | ||
109 | return !(i==ei); | ||
110 | } | ||
111 | string basic_openid_message::get_ns(const string& uri) const { | ||
112 | fields_iterator ei = fields_end(); | ||
113 | fields_iterator i = find_if(fields_begin(),fields_end(), | ||
114 | __om_ns_finder(*this,uri)); | ||
115 | if(i==ei) | ||
116 | throw failed_lookup(OPKELE_CP_ string("failed to find namespace ")+uri); | ||
117 | return i->substr(3); | ||
118 | } | ||
119 | |||
120 | void basic_openid_message::from_keyvalues(const string& kv) { | 120 | void basic_openid_message::from_keyvalues(const string& kv) { |
121 | reset_fields(); | 121 | reset_fields(); |
@@ -241,10 +241,4 @@ namespace opkele { | |||
241 | } | 241 | } |
242 | 242 | ||
243 | void openid_message_t::copy_to(basic_openid_message& x) const { | ||
244 | x.reset_fields(); | ||
245 | for(const_iterator i=begin();i!=end();++i) | ||
246 | x.set_field(i->first,i->second); | ||
247 | } | ||
248 | |||
249 | bool openid_message_t::has_field(const string& n) const { | 243 | bool openid_message_t::has_field(const string& n) const { |
250 | return find(n)!=end(); | 244 | return find(n)!=end(); |