1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
|
/* Copyright 2017 greenbytes GmbH (https://www.greenbytes.de)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef mod_md_md_acme_h
#define mod_md_md_acme_h
struct apr_array_header_t;
struct apr_bucket_brigade;
struct md_http_response_t;
struct apr_hash_t;
struct md_http_t;
struct md_json_t;
struct md_pkey_t;
struct md_t;
struct md_acme_acct_t;
struct md_proto_t;
struct md_store_t;
#define MD_PROTO_ACME "ACME"
#define MD_AUTHZ_CHA_HTTP_01 "http-01"
#define MD_AUTHZ_CHA_SNI_01 "tls-sni-01"
typedef enum {
MD_ACME_S_UNKNOWN, /* MD has not been analysed yet */
MD_ACME_S_REGISTERED, /* MD is registered at CA, but not more */
MD_ACME_S_TOS_ACCEPTED, /* Terms of Service were accepted by account holder */
MD_ACME_S_CHALLENGED, /* MD challenge information for all domains is known */
MD_ACME_S_VALIDATED, /* MD domains have been validated */
MD_ACME_S_CERTIFIED, /* MD has valid certificate */
MD_ACME_S_DENIED, /* MD domains (at least one) have been denied by CA */
} md_acme_state_t;
typedef struct md_acme_t md_acme_t;
struct md_acme_t {
const char *url; /* directory url of the ACME service */
const char *sname; /* short name for the service, not necessarily unique */
apr_pool_t *p;
const char *user_agent;
struct md_acme_acct_t *acct;
struct md_pkey_t *acct_key;
const char *new_authz;
const char *new_cert;
const char *new_reg;
const char *revoke_cert;
struct md_http_t *http;
const char *nonce;
int max_retries;
};
/**
* Global init, call once at start up.
*/
apr_status_t md_acme_init(apr_pool_t *pool, const char *base_version);
/**
* Create a new ACME server instance. If path is not NULL, will use that directory
* for persisting information. Will load any inforation persisted in earlier session.
* url needs only be specified for instances where this has never been persisted before.
*
* @param pacme will hold the ACME server instance on success
* @param p pool to used
* @param url url of the server, optional if known at path
*/
apr_status_t md_acme_create(md_acme_t **pacme, apr_pool_t *p, const char *url);
/**
* Contact the ACME server and retrieve its directory information.
*
* @param acme the ACME server to contact
*/
apr_status_t md_acme_setup(md_acme_t *acme);
/**************************************************************************************************/
/* account handling */
#define MD_ACME_ACCT_STAGED "staged"
apr_status_t md_acme_acct_load(struct md_acme_acct_t **pacct, struct md_pkey_t **ppkey,
struct md_store_t *store, md_store_group_t group,
const char *name, apr_pool_t *p);
/**
* Specify the account to use by name in local store. On success, the account
* the "current" one used by the acme instance.
*/
apr_status_t md_acme_use_acct(md_acme_t *acme, struct md_store_t *store,
apr_pool_t *p, const char *acct_id);
apr_status_t md_acme_use_acct_staged(md_acme_t *acme, struct md_store_t *store,
md_t *md, apr_pool_t *p);
/**
* Get the local name of the account currently used by the acme instance.
* Will be NULL if no account has been setup successfully.
*/
const char *md_acme_get_acct(md_acme_t *acme, apr_pool_t *p);
/**
* Agree to the given Terms-of-Service url for the current account.
*/
apr_status_t md_acme_agree(md_acme_t *acme, apr_pool_t *p, const char *tos);
/**
* Confirm with the server that the current account agrees to the Terms-of-Service
* given in the agreement url.
* If the known agreement is equal to this, nothing is done.
* If it differs, the account is re-validated in the hope that the server
* accounces the Tos URL it wants. If this is equal to the agreement specified,
* the server is notified of this. If the server requires a ToS that the account
* thinks it has already given, it is resend.
*
* If an agreement is required, different from the current one, APR_INCOMPLETE is
* returned and the agreement url is returned in the parameter.
*/
apr_status_t md_acme_check_agreement(md_acme_t *acme, apr_pool_t *p,
const char *agreement, const char **prequired);
/**
* Get the ToS agreement for current account.
*/
const char *md_acme_get_agreement(md_acme_t *acme);
/**
* Find an existing account in the local store. On APR_SUCCESS, the acme
* instance will have a current, validated account to use.
*/
apr_status_t md_acme_find_acct(md_acme_t *acme, struct md_store_t *store, apr_pool_t *p);
/**
* Create a new account at the ACME server. The
* new account is the one used by the acme instance afterwards, on success.
*/
apr_status_t md_acme_create_acct(md_acme_t *acme, apr_pool_t *p, apr_array_header_t *contacts,
const char *agreement);
apr_status_t md_acme_acct_save(struct md_store_t *store, apr_pool_t *p, md_acme_t *acme,
struct md_acme_acct_t *acct, struct md_pkey_t *acct_key);
apr_status_t md_acme_save(md_acme_t *acme, struct md_store_t *store, apr_pool_t *p);
apr_status_t md_acme_acct_save_staged(md_acme_t *acme, struct md_store_t *store,
md_t *md, apr_pool_t *p);
/**
* Delete the current account at the ACME server and remove it from store.
*/
apr_status_t md_acme_delete_acct(md_acme_t *acme, struct md_store_t *store, apr_pool_t *p);
/**
* Delete the account from the local store without contacting the ACME server.
*/
apr_status_t md_acme_unstore_acct(struct md_store_t *store, apr_pool_t *p, const char *acct_id);
/**************************************************************************************************/
/* request handling */
/**
* Request callback on a successfull HTTP response (status 2xx).
*/
typedef apr_status_t md_acme_req_res_cb(md_acme_t *acme,
const struct md_http_response_t *res, void *baton);
/**
* A request against an ACME server
*/
typedef struct md_acme_req_t md_acme_req_t;
/**
* Request callback to initialize before sending. May be invoked more than once in
* case of retries.
*/
typedef apr_status_t md_acme_req_init_cb(md_acme_req_t *req, void *baton);
/**
* Request callback on a successfull response (HTTP response code 2xx) and content
* type matching application/.*json.
*/
typedef apr_status_t md_acme_req_json_cb(md_acme_t *acme, apr_pool_t *p,
const apr_table_t *headers,
struct md_json_t *jbody, void *baton);
struct md_acme_req_t {
md_acme_t *acme; /* the ACME server to talk to */
apr_pool_t *p; /* pool for the request duration */
const char *url; /* url to POST the request to */
const char *method; /* HTTP method to use */
apr_table_t *prot_hdrs; /* JWS headers needing protection (nonce) */
struct md_json_t *req_json; /* JSON to be POSTed in request body */
apr_table_t *resp_hdrs; /* HTTP response headers */
struct md_json_t *resp_json; /* JSON response body recevied */
apr_status_t rv; /* status of request */
md_acme_req_init_cb *on_init; /* callback to initialize the request before submit */
md_acme_req_json_cb *on_json; /* callback on successful JSON response */
md_acme_req_res_cb *on_res; /* callback on generic HTTP response */
int max_retries; /* how often this might be retried */
void *baton; /* userdata for callbacks */
};
apr_status_t md_acme_GET(md_acme_t *acme, const char *url,
md_acme_req_init_cb *on_init,
md_acme_req_json_cb *on_json,
md_acme_req_res_cb *on_res,
void *baton);
/**
* Perform a POST against the ACME url. If a on_json callback is given and
* the HTTP response is JSON, only this callback is invoked. Otherwise, on HTTP status
* 2xx, the on_res callback is invoked. If no on_res is given, it is considered a
* response error, since only JSON was expected.
* At least one callback needs to be non-NULL.
*
* @param acme the ACME server to talk to
* @param url the url to send the request to
* @param on_init callback to initialize the request data
* @param on_json callback on successful JSON response
* @param on_res callback on successful HTTP response
* @param baton userdata for callbacks
*/
apr_status_t md_acme_POST(md_acme_t *acme, const char *url,
md_acme_req_init_cb *on_init,
md_acme_req_json_cb *on_json,
md_acme_req_res_cb *on_res,
void *baton);
apr_status_t md_acme_GET(md_acme_t *acme, const char *url,
md_acme_req_init_cb *on_init,
md_acme_req_json_cb *on_json,
md_acme_req_res_cb *on_res,
void *baton);
/**
* Retrieve a JSON resource from the ACME server
*/
apr_status_t md_acme_get_json(struct md_json_t **pjson, md_acme_t *acme,
const char *url, apr_pool_t *p);
apr_status_t md_acme_req_body_init(md_acme_req_t *req, struct md_json_t *jpayload);
apr_status_t md_acme_protos_add(struct apr_hash_t *protos, apr_pool_t *p);
#endif /* md_acme_h */
|