lib/request.c

   1 /* See the file COPYING for licensing information.  */
   2
   3 #if defined HAVE_CONFIG_H
   4 #include <config.h>
   5 #endif
   6
   7 #include <time.h>
   8 #include <assert.h>
   9 #include <event2/event.h>
  10 #include <radsec/radsec.h>
  11 #include <radsec/radsec-impl.h>
  12 #include <radsec/request.h>
  13 #include <radsec/request-impl.h>
  14
  15 int
  16 rs_request_create (struct rs_connection *conn, struct rs_request **req_out)
  17 {
  18   struct rs_request *req = rs_malloc (conn->ctx, sizeof(*req));
  19   assert (req_out);
  20   if (!req)
  21     return rs_err_conn_push_fl (conn, RSE_NOMEM, __FILE__, __LINE__, NULL);
  22   memset (req, 0, sizeof(*req));
  23   req->conn = conn;
  24   *req_out = req;
  25   return RSE_OK;
  26 }
  27
  28 void
  29 rs_request_add_reqpkt (struct rs_request *req, struct rs_packet *reqpkt)
  30 {
  31   assert (req);
  32   req->req_msg = reqpkt;
  33 }
  34
  35 int
  36 rs_request_create_authn (struct rs_connection *conn,
  37                          struct rs_request **req_out,
  38                          const char *user_name,
  39                          const char *user_pw)
  40 {
  41   struct rs_request *req;
  42   assert (req_out);
  43   if (rs_request_create (conn, &req))
  44     return -1;
  45
  46   if (rs_packet_create_authn_request (conn, &req->req_msg, user_name, user_pw))
  47     return -1;
  48
  49   *req_out = req;
  50   return RSE_OK;
  51 }
  52
  53 void
  54 rs_request_destroy (struct rs_request *request)
  55 {
  56   assert (request);
  57   rs_packet_destroy (request->req_msg);
  58   rs_packet_destroy (request->resp_msg);
  59   rs_free (request->conn->ctx, request);
  60 }
  61
  62 #if 0
  63 static void
  64 _timer_cb(evutil_socket_t fd, short what, void *arg)
  65
  66 {
  67 }
  68 #endif
  69
  70 static void
  71 _rs_req_connected(void *user_data)
  72 {
  73   //struct rs_request *request = (struct rs_request *)user_data;
  74 }
  75
  76 static void
  77 _rs_req_disconnected(void *user_data)
  78 {
  79   //struct rs_request *request = (struct rs_request *)user_data;
  80 }
  81
  82 static void
  83 _rs_req_packet_received(struct rs_packet *msg, void *user_data)
  84 {
  85   //struct rs_request *request = (struct rs_request *)user_data;
  86 }
  87
  88 static void
  89 _rs_req_packet_sent(void *user_data)
  90 {
  91   //struct rs_request *request = (struct rs_request *)user_data;
  92 }
  93
  94 int
  95 rs_request_send (struct rs_request *request, struct rs_packet **resp_msg)
  96 {
  97   int err;
  98   struct rs_connection *conn;
  99
 100   assert (request);
 101   assert (request->conn);
 102   assert (request->req_msg);
 103   conn = request->conn;
 104
 105   request->saved_cb = conn->callbacks;
 106
 107   conn->callbacks.connected_cb = _rs_req_connected;
 108   conn->callbacks.disconnected_cb = _rs_req_disconnected;
 109   conn->callbacks.received_cb = _rs_req_packet_received;
 110   conn->callbacks.sent_cb = _rs_req_packet_sent;
 111
 112   err = rs_packet_send(request->req_msg, request);
 113   if (err)
 114     goto cleanup;
 115
 116   err = rs_conn_receive_packet(request->conn, request->req_msg, resp_msg);
 117   if (err)
 118     goto cleanup;
 119
 120 cleanup:
 121   conn->callbacks = request->saved_cb;
 122   return err;
 123 }