Merge pull request #99 from painless-security/jennifer/count_failed_reqs
[trust_router.git] / mon / monc.c
1 /*
2  * Copyright (c) 2012, 2014-2018, JANET(UK)
3  * All rights reserved.
4  *
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  *
9  * 1. Redistributions of source code must retain the above copyright
10  *    notice, this list of conditions and the following disclaimer.
11  *
12  * 2. Redistributions in binary form must reproduce the above copyright
13  *    notice, this list of conditions and the following disclaimer in the
14  *    documentation and/or other materials provided with the distribution.
15  *
16  * 3. Neither the name of JANET(UK) nor the names of its contributors
17  *    may be used to endorse or promote products derived from this software
18  *    without specific prior written permission.
19  *
20  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
21  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
22  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
23  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
24  * COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
25  * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
26  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
27  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
29  * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
30  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
31  * OF THE POSSIBILITY OF SUCH DAMAGE.
32  *
33  */
34
35 #include <stdio.h>
36 #include <jansson.h>
37 #include <talloc.h>
38
39 #include <trust_router/tr_dh.h>
40 #include <mon_internal.h>
41 #include <tr_msg.h>
42 #include <gsscon.h>
43 #include <tr_debug.h>
44
45
46 MONC_INSTANCE *monc_new(TALLOC_CTX *mem_ctx)
47 {
48   MONC_INSTANCE *monc=talloc(mem_ctx, MONC_INSTANCE);
49   if (monc!=NULL) {
50     monc->gssc = tr_gssc_instance_new(monc);
51     if (monc->gssc == NULL) {
52       talloc_free(monc);
53       return NULL;
54     }
55
56     monc->gssc->service_name = "trustmonitor";
57   }
58   return monc;
59 }
60
61 void monc_free(MONC_INSTANCE *monc)
62 {
63   talloc_free(monc);
64 }
65
66 int monc_open_connection(MONC_INSTANCE *monc,
67                          const char *server,
68                          int port)
69 {
70   return tr_gssc_open_connection(monc->gssc, server, port);
71 }
72
73 MON_RESP *monc_send_request(TALLOC_CTX *mem_ctx, MONC_INSTANCE *monc, MON_REQ *req)
74 {
75   TALLOC_CTX *tmp_ctx = talloc_new(NULL);
76   TR_MSG *msg = NULL;
77   TR_MSG *resp_msg = NULL;
78   MON_RESP *resp = NULL;
79
80   /* Create and populate a msg structure */
81   if (!(msg = talloc_zero(tmp_ctx, TR_MSG)))
82     goto cleanup;
83
84   msg->msg_type = MON_REQUEST;
85   tr_msg_set_mon_req(msg, req);
86
87   resp_msg = tr_gssc_exchange_msgs(tmp_ctx, monc->gssc, msg);
88   if (resp_msg == NULL)
89     goto cleanup;
90
91   resp = tr_msg_get_mon_resp(resp_msg);
92
93   /* if we got a response, steal it from resp_msg's context so we can return it */
94   if (resp)
95     talloc_steal(mem_ctx, resp);
96
97 cleanup:
98   talloc_free(tmp_ctx);
99   return resp;
100 }