diff options
Diffstat (limited to 'res/ari')
-rw-r--r-- | res/ari/ari_model_validators.c | 359 | ||||
-rw-r--r-- | res/ari/ari_model_validators.h | 95 |
2 files changed, 452 insertions, 2 deletions
diff --git a/res/ari/ari_model_validators.c b/res/ari/ari_model_validators.c index 74611750e..389f83b09 100644 --- a/res/ari/ari_model_validators.c +++ b/res/ari/ari_model_validators.c @@ -4180,6 +4180,180 @@ ari_validator ast_ari_validate_channel_varset_fn(void) return ast_ari_validate_channel_varset; } +int ast_ari_validate_contact_info(struct ast_json *json) +{ + int res = 1; + struct ast_json_iter *iter; + int has_aor = 0; + int has_contact_status = 0; + int has_uri = 0; + + for (iter = ast_json_object_iter(json); iter; iter = ast_json_object_iter_next(json, iter)) { + if (strcmp("aor", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_aor = 1; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI ContactInfo field aor failed validation\n"); + res = 0; + } + } else + if (strcmp("contact_status", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_contact_status = 1; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI ContactInfo field contact_status failed validation\n"); + res = 0; + } + } else + if (strcmp("roundtrip_usec", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI ContactInfo field roundtrip_usec failed validation\n"); + res = 0; + } + } else + if (strcmp("uri", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_uri = 1; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI ContactInfo field uri failed validation\n"); + res = 0; + } + } else + { + ast_log(LOG_ERROR, + "ARI ContactInfo has undocumented field %s\n", + ast_json_object_iter_key(iter)); + res = 0; + } + } + + if (!has_aor) { + ast_log(LOG_ERROR, "ARI ContactInfo missing required field aor\n"); + res = 0; + } + + if (!has_contact_status) { + ast_log(LOG_ERROR, "ARI ContactInfo missing required field contact_status\n"); + res = 0; + } + + if (!has_uri) { + ast_log(LOG_ERROR, "ARI ContactInfo missing required field uri\n"); + res = 0; + } + + return res; +} + +ari_validator ast_ari_validate_contact_info_fn(void) +{ + return ast_ari_validate_contact_info; +} + +int ast_ari_validate_contact_status_change(struct ast_json *json) +{ + int res = 1; + struct ast_json_iter *iter; + int has_type = 0; + int has_application = 0; + int has_contact_info = 0; + int has_endpoint = 0; + + for (iter = ast_json_object_iter(json); iter; iter = ast_json_object_iter_next(json, iter)) { + if (strcmp("type", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_type = 1; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI ContactStatusChange field type failed validation\n"); + res = 0; + } + } else + if (strcmp("application", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_application = 1; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI ContactStatusChange field application failed validation\n"); + res = 0; + } + } else + if (strcmp("timestamp", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + prop_is_valid = ast_ari_validate_date( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI ContactStatusChange field timestamp failed validation\n"); + res = 0; + } + } else + if (strcmp("contact_info", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_contact_info = 1; + prop_is_valid = ast_ari_validate_contact_info( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI ContactStatusChange field contact_info failed validation\n"); + res = 0; + } + } else + if (strcmp("endpoint", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_endpoint = 1; + prop_is_valid = ast_ari_validate_endpoint( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI ContactStatusChange field endpoint failed validation\n"); + res = 0; + } + } else + { + ast_log(LOG_ERROR, + "ARI ContactStatusChange has undocumented field %s\n", + ast_json_object_iter_key(iter)); + res = 0; + } + } + + if (!has_type) { + ast_log(LOG_ERROR, "ARI ContactStatusChange missing required field type\n"); + res = 0; + } + + if (!has_application) { + ast_log(LOG_ERROR, "ARI ContactStatusChange missing required field application\n"); + res = 0; + } + + if (!has_contact_info) { + ast_log(LOG_ERROR, "ARI ContactStatusChange missing required field contact_info\n"); + res = 0; + } + + if (!has_endpoint) { + ast_log(LOG_ERROR, "ARI ContactStatusChange missing required field endpoint\n"); + res = 0; + } + + return res; +} + +ari_validator ast_ari_validate_contact_status_change_fn(void) +{ + return ast_ari_validate_contact_status_change; +} + int ast_ari_validate_device_state_changed(struct ast_json *json) { int res = 1; @@ -4479,7 +4653,7 @@ int ast_ari_validate_event(struct ast_json *json) discriminator = ast_json_string_get(ast_json_object_get(json, "type")); if (!discriminator) { - ast_log(LOG_ERROR, "ARI Event missing required field type"); + ast_log(LOG_ERROR, "ARI Event missing required field type\n"); return 0; } @@ -4552,6 +4726,9 @@ int ast_ari_validate_event(struct ast_json *json) if (strcmp("ChannelVarset", discriminator) == 0) { return ast_ari_validate_channel_varset(json); } else + if (strcmp("ContactStatusChange", discriminator) == 0) { + return ast_ari_validate_contact_status_change(json); + } else if (strcmp("DeviceStateChanged", discriminator) == 0) { return ast_ari_validate_device_state_changed(json); } else @@ -4561,6 +4738,9 @@ int ast_ari_validate_event(struct ast_json *json) if (strcmp("EndpointStateChange", discriminator) == 0) { return ast_ari_validate_endpoint_state_change(json); } else + if (strcmp("PeerStatusChange", discriminator) == 0) { + return ast_ari_validate_peer_status_change(json); + } else if (strcmp("PlaybackFinished", discriminator) == 0) { return ast_ari_validate_playback_finished(json); } else @@ -4656,7 +4836,7 @@ int ast_ari_validate_message(struct ast_json *json) discriminator = ast_json_string_get(ast_json_object_get(json, "type")); if (!discriminator) { - ast_log(LOG_ERROR, "ARI Message missing required field type"); + ast_log(LOG_ERROR, "ARI Message missing required field type\n"); return 0; } @@ -4729,6 +4909,9 @@ int ast_ari_validate_message(struct ast_json *json) if (strcmp("ChannelVarset", discriminator) == 0) { return ast_ari_validate_channel_varset(json); } else + if (strcmp("ContactStatusChange", discriminator) == 0) { + return ast_ari_validate_contact_status_change(json); + } else if (strcmp("DeviceStateChanged", discriminator) == 0) { return ast_ari_validate_device_state_changed(json); } else @@ -4744,6 +4927,9 @@ int ast_ari_validate_message(struct ast_json *json) if (strcmp("MissingParams", discriminator) == 0) { return ast_ari_validate_missing_params(json); } else + if (strcmp("PeerStatusChange", discriminator) == 0) { + return ast_ari_validate_peer_status_change(json); + } else if (strcmp("PlaybackFinished", discriminator) == 0) { return ast_ari_validate_playback_finished(json); } else @@ -4861,6 +5047,175 @@ ari_validator ast_ari_validate_missing_params_fn(void) return ast_ari_validate_missing_params; } +int ast_ari_validate_peer(struct ast_json *json) +{ + int res = 1; + struct ast_json_iter *iter; + int has_peer_status = 0; + + for (iter = ast_json_object_iter(json); iter; iter = ast_json_object_iter_next(json, iter)) { + if (strcmp("address", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI Peer field address failed validation\n"); + res = 0; + } + } else + if (strcmp("cause", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI Peer field cause failed validation\n"); + res = 0; + } + } else + if (strcmp("peer_status", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_peer_status = 1; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI Peer field peer_status failed validation\n"); + res = 0; + } + } else + if (strcmp("port", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI Peer field port failed validation\n"); + res = 0; + } + } else + if (strcmp("time", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI Peer field time failed validation\n"); + res = 0; + } + } else + { + ast_log(LOG_ERROR, + "ARI Peer has undocumented field %s\n", + ast_json_object_iter_key(iter)); + res = 0; + } + } + + if (!has_peer_status) { + ast_log(LOG_ERROR, "ARI Peer missing required field peer_status\n"); + res = 0; + } + + return res; +} + +ari_validator ast_ari_validate_peer_fn(void) +{ + return ast_ari_validate_peer; +} + +int ast_ari_validate_peer_status_change(struct ast_json *json) +{ + int res = 1; + struct ast_json_iter *iter; + int has_type = 0; + int has_application = 0; + int has_endpoint = 0; + int has_peer = 0; + + for (iter = ast_json_object_iter(json); iter; iter = ast_json_object_iter_next(json, iter)) { + if (strcmp("type", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_type = 1; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI PeerStatusChange field type failed validation\n"); + res = 0; + } + } else + if (strcmp("application", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_application = 1; + prop_is_valid = ast_ari_validate_string( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI PeerStatusChange field application failed validation\n"); + res = 0; + } + } else + if (strcmp("timestamp", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + prop_is_valid = ast_ari_validate_date( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI PeerStatusChange field timestamp failed validation\n"); + res = 0; + } + } else + if (strcmp("endpoint", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_endpoint = 1; + prop_is_valid = ast_ari_validate_endpoint( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI PeerStatusChange field endpoint failed validation\n"); + res = 0; + } + } else + if (strcmp("peer", ast_json_object_iter_key(iter)) == 0) { + int prop_is_valid; + has_peer = 1; + prop_is_valid = ast_ari_validate_peer( + ast_json_object_iter_value(iter)); + if (!prop_is_valid) { + ast_log(LOG_ERROR, "ARI PeerStatusChange field peer failed validation\n"); + res = 0; + } + } else + { + ast_log(LOG_ERROR, + "ARI PeerStatusChange has undocumented field %s\n", + ast_json_object_iter_key(iter)); + res = 0; + } + } + + if (!has_type) { + ast_log(LOG_ERROR, "ARI PeerStatusChange missing required field type\n"); + res = 0; + } + + if (!has_application) { + ast_log(LOG_ERROR, "ARI PeerStatusChange missing required field application\n"); + res = 0; + } + + if (!has_endpoint) { + ast_log(LOG_ERROR, "ARI PeerStatusChange missing required field endpoint\n"); + res = 0; + } + + if (!has_peer) { + ast_log(LOG_ERROR, "ARI PeerStatusChange missing required field peer\n"); + res = 0; + } + + return res; +} + +ari_validator ast_ari_validate_peer_status_change_fn(void) +{ + return ast_ari_validate_peer_status_change; +} + int ast_ari_validate_playback_finished(struct ast_json *json) { int res = 1; diff --git a/res/ari/ari_model_validators.h b/res/ari/ari_model_validators.h index 1803f57c9..0bcdb0fa2 100644 --- a/res/ari/ari_model_validators.h +++ b/res/ari/ari_model_validators.h @@ -1007,6 +1007,42 @@ int ast_ari_validate_channel_varset(struct ast_json *json); ari_validator ast_ari_validate_channel_varset_fn(void); /*! + * \brief Validator for ContactInfo. + * + * Detailed information about a contact on an endpoint. + * + * \param json JSON object to validate. + * \returns True (non-zero) if valid. + * \returns False (zero) if invalid. + */ +int ast_ari_validate_contact_info(struct ast_json *json); + +/*! + * \brief Function pointer to ast_ari_validate_contact_info(). + * + * See \ref ast_ari_model_validators.h for more details. + */ +ari_validator ast_ari_validate_contact_info_fn(void); + +/*! + * \brief Validator for ContactStatusChange. + * + * The state of a contact on an endpoint has changed. + * + * \param json JSON object to validate. + * \returns True (non-zero) if valid. + * \returns False (zero) if invalid. + */ +int ast_ari_validate_contact_status_change(struct ast_json *json); + +/*! + * \brief Function pointer to ast_ari_validate_contact_status_change(). + * + * See \ref ast_ari_model_validators.h for more details. + */ +ari_validator ast_ari_validate_contact_status_change_fn(void); + +/*! * \brief Validator for DeviceStateChanged. * * Notification that a device state has changed. @@ -1115,6 +1151,42 @@ int ast_ari_validate_missing_params(struct ast_json *json); ari_validator ast_ari_validate_missing_params_fn(void); /*! + * \brief Validator for Peer. + * + * Detailed information about a remote peer that communicates with Asterisk. + * + * \param json JSON object to validate. + * \returns True (non-zero) if valid. + * \returns False (zero) if invalid. + */ +int ast_ari_validate_peer(struct ast_json *json); + +/*! + * \brief Function pointer to ast_ari_validate_peer(). + * + * See \ref ast_ari_model_validators.h for more details. + */ +ari_validator ast_ari_validate_peer_fn(void); + +/*! + * \brief Validator for PeerStatusChange. + * + * The state of a peer associated with an endpoint has changed. + * + * \param json JSON object to validate. + * \returns True (non-zero) if valid. + * \returns False (zero) if invalid. + */ +int ast_ari_validate_peer_status_change(struct ast_json *json); + +/*! + * \brief Function pointer to ast_ari_validate_peer_status_change(). + * + * See \ref ast_ari_model_validators.h for more details. + */ +ari_validator ast_ari_validate_peer_status_change_fn(void); + +/*! * \brief Validator for PlaybackFinished. * * Event showing the completion of a media playback operation. @@ -1546,6 +1618,17 @@ ari_validator ast_ari_validate_application_fn(void); * - channel: Channel * - value: string (required) * - variable: string (required) + * ContactInfo + * - aor: string (required) + * - contact_status: string (required) + * - roundtrip_usec: string + * - uri: string (required) + * ContactStatusChange + * - type: string (required) + * - application: string (required) + * - timestamp: Date + * - contact_info: ContactInfo (required) + * - endpoint: Endpoint (required) * DeviceStateChanged * - type: string (required) * - application: string (required) @@ -1575,6 +1658,18 @@ ari_validator ast_ari_validate_application_fn(void); * MissingParams * - type: string (required) * - params: List[string] (required) + * Peer + * - address: string + * - cause: string + * - peer_status: string (required) + * - port: string + * - time: string + * PeerStatusChange + * - type: string (required) + * - application: string (required) + * - timestamp: Date + * - endpoint: Endpoint (required) + * - peer: Peer (required) * PlaybackFinished * - type: string (required) * - application: string (required) |