-string RemotedCache::insert(\r
- time_t expires,\r
- const Application& application,\r
- const char* client_addr,\r
- const saml2md::EntityDescriptor* issuer,\r
- const saml2::NameID* nameid,\r
- const char* authn_instant,\r
- const char* session_index,\r
- const char* authncontext_class,\r
- const char* authncontext_decl,\r
- const vector<const Assertion*>* tokens,\r
- const multimap<string,Attribute*>* attributes\r
- )\r
-{\r
- DDF in("insert::"REMOTED_SESSION_CACHE"::SessionCache");\r
- DDFJanitor jin(in);\r
- in.structure();\r
- if (expires) {\r
-#ifndef HAVE_GMTIME_R\r
- struct tm* ptime=gmtime(&expires);\r
-#else\r
- struct tm res;\r
- struct tm* ptime=gmtime_r(&expires,&res);\r
-#endif\r
- char timebuf[32];\r
- strftime(timebuf,32,"%Y-%m-%dT%H:%M:%SZ",ptime);\r
- in.addmember("expires").string(timebuf);\r
- }\r
- in.addmember("application_id").string(application.getId());\r
- if (client_addr)\r
- in.addmember("client_addr").string(client_addr);\r
- if (issuer) {\r
- auto_ptr_char provid(issuer->getEntityID());\r
- in.addmember("entity_id").string(provid.get());\r
- }\r
- if (authn_instant)\r
- in.addmember("authn_instant").string(authn_instant);\r
- if (session_index)\r
- in.addmember("session_index").string(session_index);\r
- if (authncontext_class)\r
- in.addmember("authncontext_class").string(authncontext_class);\r
- if (authncontext_decl)\r
- in.addmember("authncontext_decl").string(authncontext_decl);\r
- \r
- if (nameid) {\r
- ostringstream namestr;\r
- namestr << *nameid;\r
- in.addmember("nameid").string(namestr.str().c_str());\r
- }\r
-\r
- if (tokens) {\r
- in.addmember("assertions").list();\r
- in.addmember("tokens").list();\r
- for (vector<const Assertion*>::const_iterator t = tokens->begin(); t!=tokens->end(); ++t) {\r
- ostringstream tokenstr;\r
- tokenstr << *(*t);\r
- auto_ptr_char tokenid((*t)->getID());\r
- DDF tokid = DDF(NULL).string(tokenid.get());\r
- in["assertions"].add(tokid);\r
- DDF tok = DDF(tokenid.get()).string(tokenstr.str().c_str());\r
- in["tokens"].add(tok);\r
- }\r
- }\r
- \r
- if (attributes) {\r
- DDF attr;\r
- DDF attrs = in.addmember("attributes").list();\r
- for (multimap<string,Attribute*>::const_iterator a=attributes->begin(); a!=attributes->end(); ++a) {\r
- attr = a->second->marshall();\r
- attrs.add(attr);\r
- }\r
- }\r
-\r
- DDF out=application.getServiceProvider().getListenerService()->send(in);\r
- DDFJanitor jout(out);\r
- if (out["key"].isstring()) {\r
- // Transaction Logging\r
- auto_ptr_char name(nameid ? nameid->getName() : NULL);\r
- const char* pid = in["entity_id"].string();\r
- TransactionLog* xlog = application.getServiceProvider().getTransactionLog();\r
- Locker locker(xlog);\r
- xlog->log.infoStream() <<\r
- "New session (ID: " <<\r
- out["key"].string() <<\r
- ") with (applicationId: " <<\r
- application.getId() <<\r
- ") for principal from (IdP: " <<\r
- (pid ? pid : "none") <<\r
- ") at (ClientAddress: " <<\r
- (client_addr ? client_addr : "none") <<\r
- ") with (NameIdentifier: " <<\r
- (name.get() ? name.get() : "none") <<\r
- ")";\r
-\r
- if (attributes) {\r
- xlog->log.infoStream() <<\r
- "Cached the following attributes with session (ID: " <<\r
- out["key"].string() <<\r
- ") for (applicationId: " <<\r
- application.getId() <<\r
- ") {";\r
- for (multimap<string,Attribute*>::const_iterator a=attributes->begin(); a!=attributes->end(); ++a)\r
- xlog->log.infoStream() << "\t" << a->second->getId() << " (" << a->second->valueCount() << " values)";\r
- xlog->log.info("}");\r
- for_each(attributes->begin(), attributes->end(), cleanup_pair<string,Attribute>());\r
- }\r
-\r
- return out["key"].string();\r
- }\r
- throw RetryableProfileException("A remoted cache insertion operation did not return a usable session key.");\r
-}\r
-\r