Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 1 | /** |
| 2 | * \file session_server.h |
| 3 | * \author Michal Vasko <mvasko@cesnet.cz> |
| 4 | * \brief libnetconf2 session server manipulation |
| 5 | * |
| 6 | * Copyright (c) 2015 CESNET, z.s.p.o. |
| 7 | * |
Radek Krejci | 9b81f5b | 2016-02-24 13:14:49 +0100 | [diff] [blame] | 8 | * This source code is licensed under BSD 3-Clause License (the "License"). |
| 9 | * You may not use this file except in compliance with the License. |
| 10 | * You may obtain a copy of the License at |
Michal Vasko | afd416b | 2016-02-25 14:51:46 +0100 | [diff] [blame] | 11 | * |
Radek Krejci | 9b81f5b | 2016-02-24 13:14:49 +0100 | [diff] [blame] | 12 | * https://opensource.org/licenses/BSD-3-Clause |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 13 | */ |
| 14 | |
| 15 | #ifndef NC_SESSION_SERVER_H_ |
| 16 | #define NC_SESSION_SERVER_H_ |
| 17 | |
| 18 | #include <stdint.h> |
Michal Vasko | 05ba9df | 2016-01-13 14:40:27 +0100 | [diff] [blame] | 19 | #include <libyang/libyang.h> |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 20 | |
Michal Vasko | 709598e | 2016-11-28 14:48:32 +0100 | [diff] [blame] | 21 | #ifdef NC_ENABLED_TLS |
| 22 | # include <openssl/x509.h> |
| 23 | #endif |
| 24 | |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 25 | #include "session.h" |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 26 | #include "netconf.h" |
| 27 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 28 | /** |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 29 | * @defgroup server_session Server Session |
| 30 | * @ingroup server |
| 31 | * |
| 32 | * @brief Server-side NETCONF session manipulation. |
| 33 | * @{ |
| 34 | */ |
| 35 | |
| 36 | /** |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 37 | * @brief Prototype of callbacks that are called if some RPCs are received. |
| 38 | * |
| 39 | * If \p session termination reason is changed in the callback, one last reply |
| 40 | * is sent and then the session is considered invalid. |
| 41 | * |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 42 | * The callback is set via nc_set_global_rpc_clb(). |
| 43 | * |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 44 | * @param[in] rpc Parsed client RPC request. |
| 45 | * @param[in] session Session the RPC arrived on. |
| 46 | * @return Server reply. If NULL, an operation-failed error will be sent to the client. |
| 47 | */ |
Michal Vasko | 05ba9df | 2016-01-13 14:40:27 +0100 | [diff] [blame] | 48 | typedef struct nc_server_reply *(*nc_rpc_clb)(struct lyd_node *rpc, struct nc_session *session); |
| 49 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 50 | /** |
Michal Vasko | 7b09624 | 2016-01-29 15:55:10 +0100 | [diff] [blame] | 51 | * @brief Set the termination reason for a session. Use only in #nc_rpc_clb callbacks. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 52 | * |
| 53 | * @param[in] session Session to modify. |
| 54 | * @param[in] reason Reason of termination. |
| 55 | */ |
| 56 | void nc_session_set_term_reason(struct nc_session *session, NC_SESSION_TERM_REASON reason); |
| 57 | |
| 58 | /** |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 59 | * @brief Set a global nc_rpc_clb that is called if the particular RPC request is |
| 60 | * received and the private field in the corresponding RPC schema node is NULL. |
| 61 | * |
| 62 | * @param[in] clb An user-defined nc_rpc_clb function callback, NULL to default. |
| 63 | */ |
| 64 | void nc_set_global_rpc_clb(nc_rpc_clb clb); |
| 65 | |
| 66 | /**@} Server Session */ |
| 67 | |
| 68 | /** |
| 69 | * @addtogroup server |
| 70 | * @{ |
| 71 | */ |
| 72 | |
| 73 | /** |
Michal Vasko | a7b8ca5 | 2016-03-01 12:09:29 +0100 | [diff] [blame] | 74 | * @brief Initialize libssh and/or libssl/libcrypto and the server using a libyang context. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 75 | * |
| 76 | * The context is not modified internally, only its dictionary is used for holding |
Michal Vasko | a43589b | 2016-02-17 13:24:59 +0100 | [diff] [blame] | 77 | * all the strings, which is thread-safe. Reading models is considered thread-safe |
| 78 | * as models cannot be removed and are rarely modified (augments or deviations). |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 79 | * |
Michal Vasko | 3a889fd | 2016-09-30 12:16:37 +0200 | [diff] [blame] | 80 | * If the RPC callbacks on schema nodes (mentioned in @ref howtoserver) are modified after |
Michal Vasko | 5494f51 | 2016-03-01 12:13:44 +0100 | [diff] [blame] | 81 | * server initialization with that particular context, they will be called (changes |
| 82 | * will take effect). However, there could be race conditions as the access to |
| 83 | * these callbacks is not thread-safe. |
| 84 | * |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 85 | * Server capabilities are generated based on its content. Changing the context |
| 86 | * in ways that result in changed capabilities (adding models, changing features) |
| 87 | * is discouraged after sessions are established as it is not possible to change |
| 88 | * capabilities of a session. |
| 89 | * |
| 90 | * This context can safely be destroyed only after calling the last libnetconf2 |
| 91 | * function in an application. |
| 92 | * |
Michal Vasko | 3a889fd | 2016-09-30 12:16:37 +0200 | [diff] [blame] | 93 | * Supported RPCs of models in the context are expected to have their callback |
| 94 | * in the corresponding RPC schema node set to a nc_rpc_clb function callback using nc_set_rpc_callback(). |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 95 | * This callback is called by nc_ps_poll() if the particular RPC request is |
| 96 | * received. Callbacks for ietf-netconf:get-schema (supporting YANG and YIN format |
| 97 | * only) and ietf-netconf:close-session are set internally if left unset. |
| 98 | * |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 99 | * @param[in] ctx Core NETCONF server context. |
| 100 | * @return 0 on success, -1 on error. |
| 101 | */ |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 102 | int nc_server_init(struct ly_ctx *ctx); |
| 103 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 104 | /** |
Michal Vasko | a7b8ca5 | 2016-03-01 12:09:29 +0100 | [diff] [blame] | 105 | * @brief Destroy any dynamically allocated libssh and/or libssl/libcrypto and |
| 106 | * server resources. |
Michal Vasko | b48aa81 | 2016-01-18 14:13:09 +0100 | [diff] [blame] | 107 | */ |
| 108 | void nc_server_destroy(void); |
| 109 | |
| 110 | /** |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 111 | * @brief Set the with-defaults capability extra parameters. |
| 112 | * |
| 113 | * For the capability to be actually advertised, the server context must also |
| 114 | * include the ietf-netconf-with-defaults model. |
| 115 | * |
| 116 | * Changing this option has the same ill effects as changing capabilities while |
| 117 | * sessions are already established. |
| 118 | * |
| 119 | * @param[in] basic_mode basic-mode with-defaults parameter. |
| 120 | * @param[in] also_supported NC_WD_MODE bit array, also-supported with-defaults |
| 121 | * parameter. |
| 122 | * @return 0 on success, -1 on error. |
| 123 | */ |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 124 | int nc_server_set_capab_withdefaults(NC_WD_MODE basic_mode, int also_supported); |
| 125 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 126 | /** |
Michal Vasko | 55f0397 | 2016-04-13 08:56:01 +0200 | [diff] [blame] | 127 | * @brief Get with-defaults capability extra parameters. |
| 128 | * |
| 129 | * At least one argument must be non-NULL. |
| 130 | * |
| 131 | * @param[in,out] basic_mode basic-mode parameter. |
| 132 | * @param[in,out] also_supported also-supported parameter. |
| 133 | */ |
| 134 | void nc_server_get_capab_withdefaults(NC_WD_MODE *basic_mode, int *also_supported); |
| 135 | |
| 136 | /** |
Radek Krejci | 658782b | 2016-12-04 22:04:55 +0100 | [diff] [blame] | 137 | * @brief Set capability of the server. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 138 | * |
Radek Krejci | 658782b | 2016-12-04 22:04:55 +0100 | [diff] [blame] | 139 | * Capability can be used when some behavior or extension of the server is not defined |
| 140 | * as a YANG module. The provided value will be advertised in the server's \<hello\> |
| 141 | * messages. Note, that libnetconf only checks that the provided value is non-empty |
| 142 | * string. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 143 | * |
Michal Vasko | 50d2a5c | 2017-02-14 10:29:49 +0100 | [diff] [blame] | 144 | * @param[in] value Capability string to be advertised in server's \<hello\> messages. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 145 | */ |
Radek Krejci | 658782b | 2016-12-04 22:04:55 +0100 | [diff] [blame] | 146 | int nc_server_set_capability(const char *value); |
Michal Vasko | 55f0397 | 2016-04-13 08:56:01 +0200 | [diff] [blame] | 147 | |
| 148 | /** |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 149 | * @brief Set server timeout for receiving a hello message. |
| 150 | * |
| 151 | * @param[in] hello_timeout Hello message timeout. 0 for infinite waiting. |
| 152 | */ |
| 153 | void nc_server_set_hello_timeout(uint16_t hello_timeout); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 154 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 155 | /** |
Michal Vasko | 55f0397 | 2016-04-13 08:56:01 +0200 | [diff] [blame] | 156 | * @brief get server timeout for receiving a hello message. |
| 157 | * |
| 158 | * @return Hello message timeout, 0 is infinite. |
| 159 | */ |
| 160 | uint16_t nc_server_get_hello_timeout(void); |
| 161 | |
| 162 | /** |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 163 | * @brief Set server timeout for dropping an idle session. |
| 164 | * |
| 165 | * @param[in] idle_timeout Idle session timeout. 0 to never drop a session |
Michal Vasko | f0537d8 | 2016-01-29 14:42:38 +0100 | [diff] [blame] | 166 | * because of inactivity. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 167 | */ |
| 168 | void nc_server_set_idle_timeout(uint16_t idle_timeout); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 169 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 170 | /** |
Michal Vasko | 55f0397 | 2016-04-13 08:56:01 +0200 | [diff] [blame] | 171 | * @brief Get server timeout for dropping an idle session. |
| 172 | * |
| 173 | * @return Idle session timeout, 0 for for never dropping |
| 174 | * a session because of inactivity. |
| 175 | */ |
| 176 | uint16_t nc_server_get_idle_timeout(void); |
| 177 | |
| 178 | /** |
Michal Vasko | 4ffa3b2 | 2016-05-24 16:36:25 +0200 | [diff] [blame] | 179 | * @brief Get all the server capabilities as will be sent to every client. |
| 180 | * |
| 181 | * A few capabilities (with-defaults, interleave) depend on the current |
| 182 | * server options. |
| 183 | * |
| 184 | * @param[in] ctx Context to read most capabilities from. |
| 185 | * @return Array of capabilities stored in the \p ctx dictionary, NULL on error. |
| 186 | */ |
| 187 | const char **nc_server_get_cpblts(struct ly_ctx *ctx); |
| 188 | |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 189 | /**@} Server */ |
| 190 | |
| 191 | /** |
| 192 | * @addtogroup server_session |
| 193 | * @{ |
| 194 | */ |
| 195 | |
Michal Vasko | 4ffa3b2 | 2016-05-24 16:36:25 +0200 | [diff] [blame] | 196 | /** |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 197 | * @brief Accept a new session on a pre-established transport session. |
| 198 | * |
| 199 | * @param[in] fdin File descriptor to read (unencrypted) XML data from. |
| 200 | * @param[in] fdout File descriptor to write (unencrypted) XML data to. |
| 201 | * @param[in] username NETCONF username as provided by the transport protocol. |
| 202 | * @param[out] session New session on success. |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 203 | * @return NC_MSG_HELLO on success, NC_MSG_BAD_HELLO on client \<hello\> message |
| 204 | * parsing fail, NC_MSG_WOULDBLOCK on timeout, NC_MSG_ERROR on other errors. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 205 | */ |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 206 | NC_MSG_TYPE nc_accept_inout(int fdin, int fdout, const char *username, struct nc_session **session); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 207 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 208 | /** |
| 209 | * @brief Create an empty structure for polling sessions. |
| 210 | * |
| 211 | * @return Empty pollsession structure, NULL on error. |
| 212 | */ |
Michal Vasko | 05ba9df | 2016-01-13 14:40:27 +0100 | [diff] [blame] | 213 | struct nc_pollsession *nc_ps_new(void); |
Michal Vasko | fb89d77 | 2016-01-08 12:25:35 +0100 | [diff] [blame] | 214 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 215 | /** |
| 216 | * @brief Free a pollsession structure. |
| 217 | * |
Michal Vasko | 01082bf | 2016-04-07 10:44:21 +0200 | [diff] [blame] | 218 | * !IMPORTANT! Make sure that \p ps is not accessible (is not used) |
| 219 | * by any thread before and after this call! |
| 220 | * |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 221 | * @param[in] ps Pollsession structure to free. |
| 222 | */ |
Michal Vasko | 05ba9df | 2016-01-13 14:40:27 +0100 | [diff] [blame] | 223 | void nc_ps_free(struct nc_pollsession *ps); |
Michal Vasko | fb89d77 | 2016-01-08 12:25:35 +0100 | [diff] [blame] | 224 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 225 | /** |
| 226 | * @brief Add a session to a pollsession structure. |
| 227 | * |
| 228 | * @param[in] ps Pollsession structure to modify. |
| 229 | * @param[in] session Session to add to \p ps. |
| 230 | * @return 0 on success, -1 on error. |
| 231 | */ |
Michal Vasko | 05ba9df | 2016-01-13 14:40:27 +0100 | [diff] [blame] | 232 | int nc_ps_add_session(struct nc_pollsession *ps, struct nc_session *session); |
Michal Vasko | fb89d77 | 2016-01-08 12:25:35 +0100 | [diff] [blame] | 233 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 234 | /** |
| 235 | * @brief Remove a session from a pollsession structure. |
| 236 | * |
| 237 | * @param[in] ps Pollsession structure to modify. |
| 238 | * @param[in] session Session to remove from \p ps. |
Michal Vasko | f0537d8 | 2016-01-29 14:42:38 +0100 | [diff] [blame] | 239 | * @return 0 on success, -1 on not found. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 240 | */ |
Michal Vasko | 05ba9df | 2016-01-13 14:40:27 +0100 | [diff] [blame] | 241 | int nc_ps_del_session(struct nc_pollsession *ps, struct nc_session *session); |
| 242 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 243 | /** |
Michal Vasko | e1ee05b | 2017-03-21 10:10:18 +0100 | [diff] [blame] | 244 | * @brief Get a session from a pollsession structure matching the session ID. |
| 245 | * |
| 246 | * @param[in] ps Pollsession structure to read from. |
| 247 | * @param[in] sid Session ID of the session. |
| 248 | * @return Matching session or NULL on not found. |
| 249 | */ |
| 250 | struct nc_session *nc_ps_get_session_by_sid(const struct nc_pollsession *ps, uint32_t sid); |
| 251 | |
| 252 | /** |
Michal Vasko | 0fdb7ac | 2016-03-01 09:03:12 +0100 | [diff] [blame] | 253 | * @brief Learn the number of sessions in a pollsession structure. |
| 254 | * |
Michal Vasko | f4462fd | 2017-02-15 14:29:05 +0100 | [diff] [blame] | 255 | * Does not lock \p ps structure for efficiency. |
| 256 | * |
Michal Vasko | 0fdb7ac | 2016-03-01 09:03:12 +0100 | [diff] [blame] | 257 | * @param[in] ps Pollsession structure to check. |
Michal Vasko | c72d0e6 | 2016-07-26 11:36:11 +0200 | [diff] [blame] | 258 | * @return Number of sessions (even invalid ones) in \p ps, -1 on error. |
Michal Vasko | 0fdb7ac | 2016-03-01 09:03:12 +0100 | [diff] [blame] | 259 | */ |
| 260 | uint16_t nc_ps_session_count(struct nc_pollsession *ps); |
| 261 | |
Michal Vasko | 30a5d6b | 2017-02-15 14:29:39 +0100 | [diff] [blame] | 262 | #define NC_PSPOLL_NOSESSIONS 0x0001 /**< No sessions to poll. */ |
| 263 | #define NC_PSPOLL_TIMEOUT 0x0002 /**< Timeout elapsed. */ |
| 264 | #define NC_PSPOLL_RPC 0x0004 /**< RPC was correctly parsed and processed. */ |
| 265 | #define NC_PSPOLL_BAD_RPC 0x0008 /**< RPC was received, but failed to be parsed. */ |
| 266 | #define NC_PSPOLL_REPLY_ERROR 0x0010 /**< Response to the RPC was a \<rpc-reply\> of type error. */ |
| 267 | #define NC_PSPOLL_SESSION_TERM 0x0020 /**< Some session was terminated. */ |
| 268 | #define NC_PSPOLL_SESSION_ERROR 0x0040 /**< Some session was terminated incorrectly (not by a \<close-session\> or \<kill-session\> RPC). */ |
| 269 | #define NC_PSPOLL_ERROR 0x0080 /**< Other fatal errors (they are printed). */ |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 270 | |
| 271 | #ifdef NC_ENABLED_SSH |
Michal Vasko | 9a32736 | 2017-01-11 11:31:46 +0100 | [diff] [blame] | 272 | # define NC_PSPOLL_SSH_MSG 0x0080 /**< SSH message received (and processed, if relevant, only with SSH support). */ |
| 273 | # define NC_PSPOLL_SSH_CHANNEL 0x0100 /**< New SSH channel opened on an existing session (only with SSH support). */ |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 274 | #endif |
| 275 | |
Michal Vasko | 0fdb7ac | 2016-03-01 09:03:12 +0100 | [diff] [blame] | 276 | /** |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 277 | * @brief Poll sessions and process any received RPCs. |
| 278 | * |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 279 | * All the sessions must be running. Only one event on one session |
Michal Vasko | 96164bf | 2016-01-21 15:41:58 +0100 | [diff] [blame] | 280 | * is handled in one function call. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 281 | * |
| 282 | * @param[in] ps Pollsession structure to use. |
Michal Vasko | 11d142a | 2016-01-19 15:58:24 +0100 | [diff] [blame] | 283 | * @param[in] timeout Poll timeout in milliseconds. 0 for non-blocking call, -1 for |
Michal Vasko | 96830e3 | 2016-02-01 10:54:18 +0100 | [diff] [blame] | 284 | * infinite waiting. |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 285 | * @param[in] session Session that was processed and that specific return bits concern. |
| 286 | * Can be NULL. |
Michal Vasko | ade892d | 2017-02-22 13:40:35 +0100 | [diff] [blame] | 287 | * @return Bitfield of NC_PSPOLL_* macros. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 288 | */ |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 289 | int nc_ps_poll(struct nc_pollsession *ps, int timeout, struct nc_session **session); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 290 | |
Michal Vasko | 11d142a | 2016-01-19 15:58:24 +0100 | [diff] [blame] | 291 | /** |
Michal Vasko | cad3ac4 | 2016-03-01 09:06:01 +0100 | [diff] [blame] | 292 | * @brief Remove sessions from a pollsession structure and |
| 293 | * call nc_session_free() on them. |
Michal Vasko | d09eae6 | 2016-02-01 10:32:52 +0100 | [diff] [blame] | 294 | * |
Michal Vasko | ade892d | 2017-02-22 13:40:35 +0100 | [diff] [blame] | 295 | * Calling this function with \p all false makes sense if nc_ps_poll() returned #NC_PSPOLL_SESSION_TERM. |
Michal Vasko | d09eae6 | 2016-02-01 10:32:52 +0100 | [diff] [blame] | 296 | * |
| 297 | * @param[in] ps Pollsession structure to clear. |
Michal Vasko | cad3ac4 | 2016-03-01 09:06:01 +0100 | [diff] [blame] | 298 | * @param[in] all Whether to free all sessions, or only the invalid ones. |
Michal Vasko | e1a64ec | 2016-03-01 12:21:58 +0100 | [diff] [blame] | 299 | * @param[in] data_free Session user data destructor. |
Michal Vasko | d09eae6 | 2016-02-01 10:32:52 +0100 | [diff] [blame] | 300 | */ |
Michal Vasko | e1a64ec | 2016-03-01 12:21:58 +0100 | [diff] [blame] | 301 | void nc_ps_clear(struct nc_pollsession *ps, int all, void (*data_free)(void *)); |
Michal Vasko | d09eae6 | 2016-02-01 10:32:52 +0100 | [diff] [blame] | 302 | |
Radek Krejci | 53691be | 2016-02-22 13:58:37 +0100 | [diff] [blame] | 303 | #if defined(NC_ENABLED_SSH) || defined(NC_ENABLED_TLS) |
Michal Vasko | 9e036d5 | 2016-01-08 10:49:26 +0100 | [diff] [blame] | 304 | |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 305 | /**@} Server Session */ |
| 306 | |
| 307 | /** |
| 308 | * @addtogroup server |
| 309 | * @{ |
| 310 | */ |
| 311 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 312 | /** |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 313 | * @brief Add a new endpoint. |
| 314 | * |
| 315 | * Before the endpoint can accept any connections, its address and port must |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 316 | * be set via nc_server_endpt_set_address() and nc_server_endpt_set_port(). |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 317 | * |
| 318 | * @param[in] name Arbitrary unique endpoint name. |
Michal Vasko | 2e6defd | 2016-10-07 15:48:15 +0200 | [diff] [blame] | 319 | * @param[in] ti Transport protocol to use. |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 320 | * @return 0 on success, -1 on error. |
| 321 | */ |
Michal Vasko | 2e6defd | 2016-10-07 15:48:15 +0200 | [diff] [blame] | 322 | int nc_server_add_endpt(const char *name, NC_TRANSPORT_IMPL ti); |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 323 | |
| 324 | /** |
| 325 | * @brief Stop listening on and remove an endpoint. |
| 326 | * |
| 327 | * @param[in] name Endpoint name. NULL matches all endpoints. |
Michal Vasko | 5905037 | 2016-11-22 14:33:55 +0100 | [diff] [blame] | 328 | * @param[in] ti Endpoint transport protocol. NULL matches any protocol. |
| 329 | * Redundant to set if \p name is set, endpoint names are |
| 330 | * unique disregarding their protocol. |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 331 | * @return 0 on success, -1 on not finding any match. |
| 332 | */ |
Michal Vasko | 5905037 | 2016-11-22 14:33:55 +0100 | [diff] [blame] | 333 | int nc_server_del_endpt(const char *name, NC_TRANSPORT_IMPL ti); |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 334 | |
| 335 | /** |
Michal Vasko | e8e0770 | 2017-03-15 10:19:30 +0100 | [diff] [blame] | 336 | * @brief Get the number of currently configured listening endpoints. |
| 337 | * Note that an ednpoint without address and/or port will be included |
| 338 | * even though it is not, in fact, listening. |
| 339 | * |
| 340 | * @return Number of added listening endpoints. |
| 341 | */ |
| 342 | int nc_server_endpt_count(void); |
| 343 | |
| 344 | /** |
Michal Vasko | 2e6defd | 2016-10-07 15:48:15 +0200 | [diff] [blame] | 345 | * @brief Change endpoint listening address. |
| 346 | * |
| 347 | * On error the previous listening socket (if any) is left untouched. |
| 348 | * |
| 349 | * @param[in] endpt_name Existing endpoint name. |
| 350 | * @param[in] address New listening address. |
| 351 | * @return 0 on success, -1 on error. |
| 352 | */ |
| 353 | int nc_server_endpt_set_address(const char *endpt_name, const char *address); |
| 354 | |
| 355 | /** |
| 356 | * @brief Change endpoint listening port. |
| 357 | * |
| 358 | * On error the previous listening socket (if any) is left untouched. |
| 359 | * |
| 360 | * @param[in] endpt_name Existing endpoint name. |
| 361 | * @param[in] port New listening port. |
| 362 | * @return 0 on success, -1 on error. |
| 363 | */ |
| 364 | int nc_server_endpt_set_port(const char *endpt_name, uint16_t port); |
Michal Vasko | 9e036d5 | 2016-01-08 10:49:26 +0100 | [diff] [blame] | 365 | |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 366 | /**@} Server */ |
| 367 | |
| 368 | /** |
| 369 | * @addtogroup server_session |
| 370 | */ |
| 371 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 372 | /** |
Michal Vasko | 3031aae | 2016-01-27 16:07:18 +0100 | [diff] [blame] | 373 | * @brief Accept new sessions on all the listening endpoints. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 374 | * |
Michal Vasko | b70c8b8 | 2017-03-17 09:09:29 +0100 | [diff] [blame] | 375 | * Once a new (TCP/IP) conection is established a different (quite long) timeout |
| 376 | * is used for waiting for transport-related data, which means this call can block |
| 377 | * for much longer that \p timeout, but only with slow/faulty/malicious clients. |
| 378 | * |
Michal Vasko | 11d142a | 2016-01-19 15:58:24 +0100 | [diff] [blame] | 379 | * @param[in] timeout Timeout for receiving a new connection in milliseconds, 0 for |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 380 | * non-blocking call, -1 for infinite waiting. |
Michal Vasko | 96164bf | 2016-01-21 15:41:58 +0100 | [diff] [blame] | 381 | * @param[out] session New session. |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 382 | * @return NC_MSG_HELLO on success, NC_MSG_BAD_HELLO on client \<hello\> message |
| 383 | * parsing fail, NC_MSG_WOULDBLOCK on timeout, NC_MSG_ERROR on other errors. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 384 | */ |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 385 | NC_MSG_TYPE nc_accept(int timeout, struct nc_session **session); |
Michal Vasko | 9e036d5 | 2016-01-08 10:49:26 +0100 | [diff] [blame] | 386 | |
Radek Krejci | 53691be | 2016-02-22 13:58:37 +0100 | [diff] [blame] | 387 | #endif /* NC_ENABLED_SSH || NC_ENABLED_TLS */ |
Michal Vasko | 9e036d5 | 2016-01-08 10:49:26 +0100 | [diff] [blame] | 388 | |
Radek Krejci | 53691be | 2016-02-22 13:58:37 +0100 | [diff] [blame] | 389 | #ifdef NC_ENABLED_SSH |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 390 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 391 | /** |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 392 | * @brief Accept a new NETCONF session on an SSH session of a running NETCONF \p orig_session. |
Michal Vasko | ade892d | 2017-02-22 13:40:35 +0100 | [diff] [blame] | 393 | * Call this function only when nc_ps_poll() returns #NC_PSPOLL_SSH_CHANNEL on \p orig_session. |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 394 | * |
| 395 | * @param[in] orig_session Session that has a new SSH channel ready. |
| 396 | * @param[out] session New session. |
| 397 | * @return NC_MSG_HELLO on success, NC_MSG_BAD_HELLO on client \<hello\> message |
| 398 | * parsing fail, NC_MSG_WOULDBLOCK on timeout, NC_MSG_ERROR on other errors. |
| 399 | */ |
| 400 | NC_MSG_TYPE nc_session_accept_ssh_channel(struct nc_session *orig_session, struct nc_session **session); |
| 401 | |
| 402 | /** |
Michal Vasko | 96164bf | 2016-01-21 15:41:58 +0100 | [diff] [blame] | 403 | * @brief Accept a new NETCONF session on an SSH session of a running NETCONF session |
Michal Vasko | ade892d | 2017-02-22 13:40:35 +0100 | [diff] [blame] | 404 | * that was polled in \p ps. Call this function only when nc_ps_poll() on \p ps returns #NC_PSPOLL_SSH_CHANNEL. |
Michal Vasko | c0fde01 | 2016-03-01 09:07:23 +0100 | [diff] [blame] | 405 | * The new session is only returned in \p session, it is not added to \p ps. |
Michal Vasko | 96164bf | 2016-01-21 15:41:58 +0100 | [diff] [blame] | 406 | * |
| 407 | * @param[in] ps Unmodified pollsession structure from the previous nc_ps_poll() call. |
| 408 | * @param[out] session New session. |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 409 | * @return NC_MSG_HELLO on success, NC_MSG_BAD_HELLO on client \<hello\> message |
| 410 | * parsing fail, NC_MSG_WOULDBLOCK on timeout, NC_MSG_ERROR on other errors. |
Michal Vasko | 96164bf | 2016-01-21 15:41:58 +0100 | [diff] [blame] | 411 | */ |
Michal Vasko | 71090fc | 2016-05-24 16:37:28 +0200 | [diff] [blame] | 412 | NC_MSG_TYPE nc_ps_accept_ssh_channel(struct nc_pollsession *ps, struct nc_session **session); |
Michal Vasko | 96164bf | 2016-01-21 15:41:58 +0100 | [diff] [blame] | 413 | |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 414 | /**@} Server Session */ |
| 415 | |
| 416 | /** |
| 417 | * @defgroup server_ssh Server SSH |
| 418 | * @ingroup server |
| 419 | * |
| 420 | * @brief Server-side settings for SSH connections. |
| 421 | * @{ |
| 422 | */ |
| 423 | |
Michal Vasko | 96164bf | 2016-01-21 15:41:58 +0100 | [diff] [blame] | 424 | /** |
Michal Vasko | 17dfda9 | 2016-12-01 14:06:16 +0100 | [diff] [blame] | 425 | * @brief Add an authorized client SSH public key. This public key can be used for |
| 426 | * publickey authentication (for any SSH connection, even Call Home) afterwards. |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 427 | * |
Michal Vasko | 17dfda9 | 2016-12-01 14:06:16 +0100 | [diff] [blame] | 428 | * @param[in] pubkey_base64 Authorized public key binary content encoded in base64. |
| 429 | * @param[in] type Authorized public key SSH type. |
| 430 | * @param[in] username Username that the client with the public key must use. |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 431 | * @return 0 on success, -1 on error. |
| 432 | */ |
Michal Vasko | 17dfda9 | 2016-12-01 14:06:16 +0100 | [diff] [blame] | 433 | int nc_server_ssh_add_authkey(const char *pubkey_base64, NC_SSH_KEY_TYPE type, const char *username); |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 434 | |
| 435 | /** |
Michal Vasko | 17dfda9 | 2016-12-01 14:06:16 +0100 | [diff] [blame] | 436 | * @brief Add an authorized client SSH public key. This public key can be used for |
| 437 | * publickey authentication (for any SSH connection, even Call Home) afterwards. |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 438 | * |
Michal Vasko | 17dfda9 | 2016-12-01 14:06:16 +0100 | [diff] [blame] | 439 | * @param[in] pubkey_path Path to the public key. |
| 440 | * @param[in] username Username that the client with the public key must use. |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 441 | * @return 0 on success, -1 on error. |
| 442 | */ |
Michal Vasko | 17dfda9 | 2016-12-01 14:06:16 +0100 | [diff] [blame] | 443 | int nc_server_ssh_add_authkey_path(const char *pubkey_path, const char *username); |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 444 | |
| 445 | /** |
Michal Vasko | 17dfda9 | 2016-12-01 14:06:16 +0100 | [diff] [blame] | 446 | * @brief Remove an authorized client SSH public key. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 447 | * |
Michal Vasko | 17dfda9 | 2016-12-01 14:06:16 +0100 | [diff] [blame] | 448 | * @param[in] pubkey_path Path to an authorized public key. NULL matches all the keys. |
| 449 | * @param[in] pubkey_base64 Authorized public key content. NULL matches any key. |
| 450 | * @param[in] type Authorized public key type. 0 matches all types. |
| 451 | * @param[in] username Username for an authorized public key. NULL matches all the usernames. |
| 452 | * @return 0 on success, -1 on not finding any match. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 453 | */ |
Michal Vasko | 17dfda9 | 2016-12-01 14:06:16 +0100 | [diff] [blame] | 454 | int nc_server_ssh_del_authkey(const char *pubkey_path, const char *pubkey_base64, NC_SSH_KEY_TYPE type, |
| 455 | const char *username); |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 456 | |
| 457 | /** |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 458 | * @brief Add endpoint SSH host keys the server will identify itself with. Only the name is set, the key itself |
| 459 | * wil be retrieved using a callback. |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 460 | * |
| 461 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 462 | * @param[in] name Arbitrary name of the host key. |
Michal Vasko | 7d25588 | 2017-02-09 13:35:08 +0100 | [diff] [blame] | 463 | * @param[in] idx Optional index where to add the key. -1 adds at the end. |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 464 | * @return 0 on success, -1 on error. |
| 465 | */ |
Michal Vasko | 7d25588 | 2017-02-09 13:35:08 +0100 | [diff] [blame] | 466 | int nc_server_ssh_endpt_add_hostkey(const char *endpt_name, const char *name, int16_t idx); |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 467 | |
| 468 | /** |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 469 | * @brief Set the callback for retrieving host keys. Any RSA, DSA, and ECDSA keys can be added. However, |
| 470 | * a maximum of one key of each type will be used during SSH authentication, later keys replacing |
| 471 | * the earlier ones. |
| 472 | * |
| 473 | * @param[in] hostkey_clb Callback that should return the key itself. Zero return indicates success, non-zero |
| 474 | * an error. On success exactly ONE of \p privkey_path or \p privkey_data is expected |
| 475 | * to be set. The one set will be freed. |
| 476 | * - \p privkey_path expects a PEM file, |
| 477 | * - \p privkey_data expects a base-64 encoded ANS.1 DER data, |
| 478 | * - \p privkey_data_rsa flag whether \p privkey_data are the data of an RSA (1) or a DSA (0) key. |
| 479 | * @param[in] user_data Optional arbitrary user data that will be passed to \p hostkey_clb. |
| 480 | * @param[in] free_user_data Optional callback that will be called during cleanup to free any \p user_data. |
| 481 | */ |
| 482 | void nc_server_ssh_set_hostkey_clb(int (*hostkey_clb)(const char *name, void *user_data, char **privkey_path, |
| 483 | char **privkey_data, int *privkey_data_rsa), |
| 484 | void *user_data, void (*free_user_data)(void *user_data)); |
| 485 | |
| 486 | /** |
| 487 | * @brief Delete endpoint SSH host key. Their order is preserved. |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 488 | * |
| 489 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 7d25588 | 2017-02-09 13:35:08 +0100 | [diff] [blame] | 490 | * @param[in] name Name of the host key. NULL matches all the keys, but if \p idx != -1 then this must be NULL. |
| 491 | * @param[in] idx Index of the hostkey. -1 matches all indices, but if \p name != NULL then this must be -1. |
Michal Vasko | e2713da | 2016-08-22 16:06:40 +0200 | [diff] [blame] | 492 | * @return 0 on success, -1 on error. |
| 493 | */ |
Michal Vasko | 7d25588 | 2017-02-09 13:35:08 +0100 | [diff] [blame] | 494 | int nc_server_ssh_endpt_del_hostkey(const char *endpt_name, const char *name, int16_t idx); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 495 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 496 | /** |
Michal Vasko | fbfe8b6 | 2017-02-14 10:22:30 +0100 | [diff] [blame] | 497 | * @brief Move endpoint SSH host key. |
| 498 | * |
| 499 | * @param[in] endpt_name Exisitng endpoint name. |
| 500 | * @param[in] key_mov Name of the host key that will be moved. |
| 501 | * @param[in] key_after Name of the key that will preceed \p key_mov. NULL if \p key_mov is to be moved at the beginning. |
| 502 | * @return 0 in success, -1 on error. |
| 503 | */ |
| 504 | int nc_server_ssh_endpt_mov_hostkey(const char *endpt_name, const char *key_mov, const char *key_after); |
| 505 | |
| 506 | /** |
| 507 | * @brief Modify endpoint SSH host key. |
| 508 | * |
| 509 | * @param[in] endpt_name Exisitng endpoint name. |
| 510 | * @param[in] name Name of an existing host key. |
| 511 | * @param[in] new_name New name of the host key \p name. |
| 512 | * @return 0 in success, -1 on error. |
| 513 | */ |
| 514 | int nc_server_ssh_endpt_mod_hostkey(const char *endpt_name, const char *name, const char *new_name); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 515 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 516 | /** |
Michal Vasko | 3031aae | 2016-01-27 16:07:18 +0100 | [diff] [blame] | 517 | * @brief Set endpoint SSH banner the server will send to every client. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 518 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 519 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 520 | * @param[in] banner SSH banner. |
| 521 | * @return 0 on success, -1 on error. |
| 522 | */ |
Michal Vasko | 3031aae | 2016-01-27 16:07:18 +0100 | [diff] [blame] | 523 | int nc_server_ssh_endpt_set_banner(const char *endpt_name, const char *banner); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 524 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 525 | /** |
Michal Vasko | 3031aae | 2016-01-27 16:07:18 +0100 | [diff] [blame] | 526 | * @brief Set endpoint accepted SSH authentication methods. All (publickey, password, interactive) |
Michal Vasko | f0537d8 | 2016-01-29 14:42:38 +0100 | [diff] [blame] | 527 | * are supported by default. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 528 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 529 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 530 | * @param[in] auth_methods Accepted authentication methods bit field of NC_SSH_AUTH_TYPE. |
| 531 | * @return 0 on success, -1 on error. |
| 532 | */ |
Michal Vasko | 3031aae | 2016-01-27 16:07:18 +0100 | [diff] [blame] | 533 | int nc_server_ssh_endpt_set_auth_methods(const char *endpt_name, int auth_methods); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 534 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 535 | /** |
Michal Vasko | 3031aae | 2016-01-27 16:07:18 +0100 | [diff] [blame] | 536 | * @brief Set endpoint SSH authentication attempts of every client. 3 by default. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 537 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 538 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 5e6f4cc | 2016-01-20 13:27:44 +0100 | [diff] [blame] | 539 | * @param[in] auth_attempts Failed authentication attempts before a client is dropped. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 540 | * @return 0 on success, -1 on error. |
| 541 | */ |
Michal Vasko | 3031aae | 2016-01-27 16:07:18 +0100 | [diff] [blame] | 542 | int nc_server_ssh_endpt_set_auth_attempts(const char *endpt_name, uint16_t auth_attempts); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 543 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 544 | /** |
Michal Vasko | 3031aae | 2016-01-27 16:07:18 +0100 | [diff] [blame] | 545 | * @brief Set endpoint SSH authentication timeout. 10 seconds by default. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 546 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 547 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 548 | * @param[in] auth_timeout Number of seconds before an unauthenticated client is dropped. |
| 549 | * @return 0 on success, -1 on error. |
| 550 | */ |
Michal Vasko | 3031aae | 2016-01-27 16:07:18 +0100 | [diff] [blame] | 551 | int nc_server_ssh_endpt_set_auth_timeout(const char *endpt_name, uint16_t auth_timeout); |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 552 | |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 553 | /**@} Server SSH */ |
| 554 | |
Radek Krejci | 53691be | 2016-02-22 13:58:37 +0100 | [diff] [blame] | 555 | #endif /* NC_ENABLED_SSH */ |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 556 | |
Radek Krejci | 53691be | 2016-02-22 13:58:37 +0100 | [diff] [blame] | 557 | #ifdef NC_ENABLED_TLS |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 558 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 559 | /** |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 560 | * @defgroup server_tls Server TLS |
| 561 | * @ingroup server |
| 562 | * |
| 563 | * @brief Server-side settings for TLS connections. |
| 564 | * @{ |
| 565 | */ |
| 566 | |
| 567 | /** |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 568 | * @brief Set the server TLS certificate. Only the name is set, the certificate itself |
| 569 | * wil be retrieved using a callback. |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 570 | * |
| 571 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 572 | * @param[in] name Arbitrary certificate name. |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 573 | * @return 0 on success, -1 on error. |
| 574 | */ |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 575 | int nc_server_tls_endpt_set_server_cert(const char *endpt_name, const char *name); |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 576 | |
| 577 | /** |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 578 | * @brief Set the callback for retrieving server certificate and matching private key. |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 579 | * |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 580 | * @param[in] cert_clb Callback that should return the certificate and the key itself. Zero return indicates success, |
| 581 | * non-zero an error. On success exactly ONE of \p cert_path or \p cert_data and ONE of |
| 582 | * \p privkey_path and \p privkey_data is expected to be set. Those set will be freed. |
| 583 | * - \p cert_path expects a PEM file, |
| 584 | * - \p cert_data expects a base-64 encoded ASN.1 DER data, |
| 585 | * - \p privkey_path expects a PEM file, |
| 586 | * - \p privkey_data expects a base-64 encoded ANS.1 DER data, |
| 587 | * - \p privkey_data_rsa flag whether \p privkey_data are the data of an RSA (1) or a DSA (0) key. |
| 588 | * @param[in] user_data Optional arbitrary user data that will be passed to \p cert_clb. |
| 589 | * @param[in] free_user_data Optional callback that will be called during cleanup to free any \p user_data. |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 590 | */ |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 591 | void nc_server_tls_set_server_cert_clb(int (*cert_clb)(const char *name, void *user_data, char **cert_path, char **cert_data, |
| 592 | char **privkey_path, char **privkey_data, int *privkey_data_rsa), |
| 593 | void *user_data, void (*free_user_data)(void *user_data)); |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 594 | |
| 595 | /** |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 596 | * @brief Add a trusted certificate list. Can be both a CA or a client one. Can be |
Michal Vasko | fdfd9dd | 2016-02-29 10:18:46 +0100 | [diff] [blame] | 597 | * safely used together with nc_server_tls_endpt_set_trusted_ca_paths(). |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 598 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 599 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 600 | * @param[in] name Arbitary name identifying this certificate list. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 601 | * @return 0 on success, -1 on error. |
| 602 | */ |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 603 | int nc_server_tls_endpt_add_trusted_cert_list(const char *endpt_name, const char *name); |
Michal Vasko | 0457bb4 | 2016-01-08 15:49:13 +0100 | [diff] [blame] | 604 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 605 | /** |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 606 | * @brief Set the callback for retrieving trusted certificates. |
| 607 | * |
| 608 | * @param[in] cert_list_clb Callback that should return all the certificates of a list. Zero return indicates success, |
| 609 | * non-zero an error. On success, \p cert_paths and \p cert_data are expected to be set or left |
| 610 | * NULL. Both will be (deeply) freed. |
| 611 | * - \p cert_paths expect an array of PEM files, |
| 612 | * - \p cert_path_count number of \p cert_paths array members, |
| 613 | * - \p cert_data expect an array of base-64 encoded ASN.1 DER cert data, |
| 614 | * - \p cert_data_count number of \p cert_data array members. |
| 615 | * @param[in] user_data Optional arbitrary user data that will be passed to \p cert_clb. |
| 616 | * @param[in] free_user_data Optional callback that will be called during cleanup to free any \p user_data. |
| 617 | */ |
| 618 | void nc_server_tls_set_trusted_cert_list_clb(int (*cert_list_clb)(const char *name, void *user_data, char ***cert_paths, |
| 619 | int *cert_path_count, char ***cert_data, int *cert_data_count), |
| 620 | void *user_data, void (*free_user_data)(void *user_data)); |
| 621 | |
| 622 | /** |
| 623 | * @brief Remove a trusted certificate. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 624 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 625 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 626 | * @param[in] name Name of the certificate list to delete. NULL deletes all the lists. |
| 627 | * @return 0 on success, -1 on not found. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 628 | */ |
Michal Vasko | 4c1fb49 | 2017-01-30 14:31:07 +0100 | [diff] [blame] | 629 | int nc_server_tls_endpt_del_trusted_cert_list(const char *endpt_name, const char *name); |
Michal Vasko | 0457bb4 | 2016-01-08 15:49:13 +0100 | [diff] [blame] | 630 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 631 | /** |
| 632 | * @brief Set trusted Certificate Authority certificate locations. There can only be |
Michal Vasko | 5d2ad08 | 2016-02-09 11:47:59 +0100 | [diff] [blame] | 633 | * one file and one directory, they are replaced if already set. Can be safely |
Michal Vasko | fdfd9dd | 2016-02-29 10:18:46 +0100 | [diff] [blame] | 634 | * used with nc_server_tls_endpt_add_trusted_cert() or its _path variant. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 635 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 636 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 96830e3 | 2016-02-01 10:54:18 +0100 | [diff] [blame] | 637 | * @param[in] ca_file Path to a trusted CA cert store file in PEM format. Can be NULL. |
| 638 | * @param[in] ca_dir Path to a trusted CA cert store hashed directory (c_rehash utility |
| 639 | * can be used to create hashes) with PEM files. Can be NULL. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 640 | * @return 0 on success, -1 on error. |
| 641 | */ |
Michal Vasko | 96830e3 | 2016-02-01 10:54:18 +0100 | [diff] [blame] | 642 | int nc_server_tls_endpt_set_trusted_ca_paths(const char *endpt_name, const char *ca_file, const char *ca_dir); |
Michal Vasko | 0457bb4 | 2016-01-08 15:49:13 +0100 | [diff] [blame] | 643 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 644 | /** |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 645 | * @brief Set Certificate Revocation List locations. There can only be one file |
Michal Vasko | f0537d8 | 2016-01-29 14:42:38 +0100 | [diff] [blame] | 646 | * and one directory, they are replaced if already set. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 647 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 648 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 96830e3 | 2016-02-01 10:54:18 +0100 | [diff] [blame] | 649 | * @param[in] crl_file Path to a CRL store file in PEM format. Can be NULL. |
| 650 | * @param[in] crl_dir Path to a CRL store hashed directory (c_rehash utility |
| 651 | * can be used to create hashes) with PEM files. Can be NULL. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 652 | * @return 0 on success, -1 on error. |
| 653 | */ |
Michal Vasko | 96830e3 | 2016-02-01 10:54:18 +0100 | [diff] [blame] | 654 | int nc_server_tls_endpt_set_crl_paths(const char *endpt_name, const char *crl_file, const char *crl_dir); |
Michal Vasko | 0457bb4 | 2016-01-08 15:49:13 +0100 | [diff] [blame] | 655 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 656 | /** |
Michal Vasko | 96830e3 | 2016-02-01 10:54:18 +0100 | [diff] [blame] | 657 | * @brief Destroy and clean CRLs. Certificates, private keys, and CTN entries are |
Michal Vasko | f0537d8 | 2016-01-29 14:42:38 +0100 | [diff] [blame] | 658 | * not affected. |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 659 | * |
| 660 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 661 | */ |
Michal Vasko | c6b9c7b | 2016-01-28 11:10:08 +0100 | [diff] [blame] | 662 | void nc_server_tls_endpt_clear_crls(const char *endpt_name); |
Michal Vasko | 0457bb4 | 2016-01-08 15:49:13 +0100 | [diff] [blame] | 663 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 664 | /** |
Michal Vasko | 58c22a2 | 2016-11-23 13:49:53 +0100 | [diff] [blame] | 665 | * @brief Add a cert-to-name entry. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 666 | * |
Michal Vasko | 3cf4aaa | 2017-02-01 15:03:36 +0100 | [diff] [blame] | 667 | * It is possible to add an entry step-by-step, specifying first only \p ip and in later calls |
| 668 | * \p fingerprint, \p map_type, and optionally \p name spearately. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 669 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 670 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 3cf4aaa | 2017-02-01 15:03:36 +0100 | [diff] [blame] | 671 | * @param[in] id Priority of the entry. It must be unique. If already exists, the entry with this id |
| 672 | * is modified. |
| 673 | * @param[in] fingerprint Matching certificate fingerprint. If NULL, kept temporarily unset. |
| 674 | * @param[in] map_type Type of username-certificate mapping. If 0, kept temporarily unset. |
| 675 | * @param[in] name Specific username used only if \p map_type == NC_TLS_CTN_SPECIFED. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 676 | * @return 0 on success, -1 on error. |
| 677 | */ |
Michal Vasko | 3a889fd | 2016-09-30 12:16:37 +0200 | [diff] [blame] | 678 | int nc_server_tls_endpt_add_ctn(const char *endpt_name, uint32_t id, const char *fingerprint, |
| 679 | NC_TLS_CTN_MAPTYPE map_type, const char *name); |
Michal Vasko | c14e3c8 | 2016-01-11 16:14:30 +0100 | [diff] [blame] | 680 | |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 681 | /** |
Michal Vasko | 58c22a2 | 2016-11-23 13:49:53 +0100 | [diff] [blame] | 682 | * @brief Remove a cert-to-name entry. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 683 | * |
Michal Vasko | da51477 | 2016-02-01 11:32:01 +0100 | [diff] [blame] | 684 | * @param[in] endpt_name Existing endpoint name. |
Michal Vasko | 1a38c86 | 2016-01-15 15:50:07 +0100 | [diff] [blame] | 685 | * @param[in] id Priority of the entry. -1 matches all the priorities. |
| 686 | * @param[in] fingerprint Fingerprint fo the entry. NULL matches all the fingerprints. |
| 687 | * @param[in] map_type Mapping type of the entry. 0 matches all the mapping types. |
| 688 | * @param[in] name Specific username for the entry. NULL matches all the usernames. |
| 689 | * @return 0 on success, -1 on not finding any match. |
| 690 | */ |
Michal Vasko | 3a889fd | 2016-09-30 12:16:37 +0200 | [diff] [blame] | 691 | int nc_server_tls_endpt_del_ctn(const char *endpt_name, int64_t id, const char *fingerprint, |
| 692 | NC_TLS_CTN_MAPTYPE map_type, const char *name); |
Michal Vasko | 0457bb4 | 2016-01-08 15:49:13 +0100 | [diff] [blame] | 693 | |
Michal Vasko | df5e6af | 2016-11-23 13:50:56 +0100 | [diff] [blame] | 694 | /** |
| 695 | * @brief Get a cert-to-name entry. |
| 696 | * |
| 697 | * If a parameter is NULL, it is ignored. If its dereferenced value is NULL, |
| 698 | * it is filled and returned. If the value is set, it is used as a filter. |
| 699 | * Returns first matching entry. |
| 700 | * |
| 701 | * @param[in] endpt_name Existing endpoint name. |
| 702 | * @param[in,out] id Priority of the entry. |
| 703 | * @param[in,out] fingerprint Fingerprint fo the entry. |
| 704 | * @param[in,out] map_type Mapping type of the entry. |
| 705 | * @param[in,out] name Specific username for the entry. |
| 706 | * @return 0 on success, -1 on not finding any match. |
| 707 | */ |
Michal Vasko | f585ac7 | 2016-11-25 15:16:38 +0100 | [diff] [blame] | 708 | int nc_server_tls_endpt_get_ctn(const char *endpt_name, uint32_t *id, char **fingerprint, NC_TLS_CTN_MAPTYPE *map_type, |
| 709 | char **name); |
Michal Vasko | df5e6af | 2016-11-23 13:50:56 +0100 | [diff] [blame] | 710 | |
Michal Vasko | 7060bcf | 2016-11-28 14:48:11 +0100 | [diff] [blame] | 711 | /** |
Michal Vasko | 709598e | 2016-11-28 14:48:32 +0100 | [diff] [blame] | 712 | * @brief Get client certificate. |
| 713 | * |
| 714 | * @param[in] session Session to get the information from. |
| 715 | * @return Const session client certificate. |
| 716 | */ |
| 717 | const X509 *nc_session_get_client_cert(const struct nc_session *session); |
| 718 | |
| 719 | /** |
Michal Vasko | 7060bcf | 2016-11-28 14:48:11 +0100 | [diff] [blame] | 720 | * @brief Set TLS authentication additional verify callback. |
| 721 | * |
| 722 | * Server will always perform cert-to-name based on its configuration. Only after it passes |
| 723 | * and this callback is set, it is also called. It should return exactly what OpenSSL |
| 724 | * verify callback meaning 1 for success, 0 to deny the user. |
| 725 | * |
| 726 | * @param[in] verify_clb Additional user verify callback. |
| 727 | */ |
| 728 | void nc_server_tls_set_verify_clb(int (*verify_clb)(const struct nc_session *session)); |
| 729 | |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 730 | /**@} Server TLS */ |
| 731 | |
Radek Krejci | 53691be | 2016-02-22 13:58:37 +0100 | [diff] [blame] | 732 | #endif /* NC_ENABLED_TLS */ |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 733 | |
Michal Vasko | f835235 | 2016-05-24 09:11:36 +0200 | [diff] [blame] | 734 | /** |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 735 | * @addtogroup server_session |
| 736 | * @{ |
| 737 | */ |
| 738 | |
| 739 | /** |
Michal Vasko | c45ebd3 | 2016-05-25 11:17:36 +0200 | [diff] [blame] | 740 | * @brief Get session start time. |
Michal Vasko | f835235 | 2016-05-24 09:11:36 +0200 | [diff] [blame] | 741 | * |
| 742 | * @param[in] session Session to get the information from. |
Michal Vasko | c45ebd3 | 2016-05-25 11:17:36 +0200 | [diff] [blame] | 743 | * @return Session start time. |
Michal Vasko | f835235 | 2016-05-24 09:11:36 +0200 | [diff] [blame] | 744 | */ |
Michal Vasko | c45ebd3 | 2016-05-25 11:17:36 +0200 | [diff] [blame] | 745 | time_t nc_session_get_start_time(const struct nc_session *session); |
Michal Vasko | f835235 | 2016-05-24 09:11:36 +0200 | [diff] [blame] | 746 | |
Michal Vasko | 3486a7c | 2017-03-03 13:28:07 +0100 | [diff] [blame] | 747 | /** |
| 748 | * @brief Set session notification subscription flag. |
| 749 | * |
| 750 | * It is used only to ignore timeouts, because they are |
| 751 | * ignored for sessions with active subscriptions. |
| 752 | * |
| 753 | * @param[in] session Session to modify. |
| 754 | * @param[in] notif_status 0 for no active subscriptions, non-zero for an active subscription. |
| 755 | */ |
| 756 | void nc_session_set_notif_status(struct nc_session *session, int notif_status); |
| 757 | |
| 758 | /** |
| 759 | * @brief Get session notification subscription flag. |
| 760 | * |
| 761 | * @param[in] session Session to get the information from. |
| 762 | * @return 0 for no active subscription, non-zero for an active subscription. |
| 763 | */ |
| 764 | int nc_session_get_notif_status(const struct nc_session *session); |
| 765 | |
Radek Krejci | 6799a05 | 2017-05-19 14:23:23 +0200 | [diff] [blame^] | 766 | /**@} Server Session */ |
| 767 | |
Michal Vasko | 086311b | 2016-01-08 09:53:11 +0100 | [diff] [blame] | 768 | #endif /* NC_SESSION_SERVER_H_ */ |