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
use paste::paste;
pub use super::super::{router, Error, Response};
use super::ServerFeatures;
pub type HandleReqReturn<T> = Result<
(
super::proto::EPPCommandType,
Option<Vec<super::proto::EPPCommandExtensionType>>,
),
Response<T>,
>;
macro_rules! router {
($($n:ident, $req_handle:path, $res_handle:path);*) => {
#[derive(Default, Debug)]
pub struct Router {}
impl router::InnerRouter<ServerFeatures> for Router {
type Request = (super::proto::EPPCommandType, Option<Vec<super::proto::EPPCommandExtensionType>>);
type Response = super::proto::EPPResponse;
paste! {
$(fn [<$n _request>](&mut self, client: &super::ServerFeatures, req: &router::[<$n Request>], _command_id: uuid::Uuid) -> HandleReqReturn<router::[<$n Response>]> {
$req_handle(client, &req)
})*
$(fn [<$n _response>](&mut self, return_path: router::Sender<router::[<$n Response>]>, response: Self::Response) {
let _ = if !response.is_success() {
if response.is_server_error() {
return_path.send(Err(Error::Err(format!("Server error: {}", response.response_msg()))))
} else {
return_path.send(Err(Error::Err(response.response_msg())))
}
} else {
let trans_id = router::CommandTransactionID {
client: response.transaction_id.client_transaction_id.as_deref().unwrap_or_default().to_owned(),
server: response.transaction_id.server_transaction_id.as_deref().unwrap_or_default().to_owned(),
};
match $res_handle(response) {
Ok(r) => return_path.send(Ok(router::CommandResponse {
response: r,
extra_values: vec![],
transaction_id: Some(trans_id)
})),
Err(e) => return_path.send(Err(e))
}
};
})*
}
}
}
}
fn request_nop<T, R>(_client: &super::ServerFeatures, _req: &T) -> HandleReqReturn<R> {
Err(Response::Err(Error::Unsupported))
}
fn response_nop<T, R>(_response: T) -> Result<R, Error> {
Err(Error::Unsupported)
}
router!(
Logout, super::handle_logout, super::handle_logout_response;
Poll, super::poll::handle_poll, super::poll::handle_poll_response;
PollAck, super::poll::handle_poll_ack, super::poll::handle_poll_ack_response;
DomainCheck, super::domain::handle_check, super::domain::handle_check_response;
DomainClaimsCheck, super::domain::handle_claims_check, super::domain::handle_claims_check_response;
DomainTrademarkCheck, super::domain::handle_trademark_check, super::domain::handle_claims_check_response;
DomainInfo, super::domain::handle_info, super::domain::handle_info_response;
DomainCreate, super::domain::handle_create, super::domain::handle_create_response;
DomainDelete, super::domain::handle_delete, super::domain::handle_delete_response;
DomainUpdate, super::domain::handle_update, super::domain::handle_update_response;
DomainRenew, super::domain::handle_renew, super::domain::handle_renew_response;
DomainTransferQuery, super::domain::handle_transfer_query, super::domain::handle_transfer_response;
DomainTransferRequest, super::domain::handle_transfer_request, super::domain::handle_transfer_response;
DomainTransferCancel, super::domain::handle_transfer_cancel, super::domain::handle_transfer_response;
DomainTransferAccept, super::domain::handle_transfer_accept, super::domain::handle_transfer_response;
DomainTransferReject, super::domain::handle_transfer_reject, super::domain::handle_transfer_response;
VerisignSync, super::domain::handle_verisign_sync, super::domain::handle_update_response;
EmailForwardCheck, super::email_forward::handle_check, super::email_forward::handle_check_response;
EmailForwardInfo, super::email_forward::handle_info, super::email_forward::handle_info_response;
EmailForwardCreate, super::email_forward::handle_create, super::email_forward::handle_create_response;
EmailForwardDelete, super::email_forward::handle_delete, super::email_forward::handle_delete_response;
EmailForwardUpdate, super::email_forward::handle_update, super::email_forward::handle_update_response;
EmailForwardRenew, super::email_forward::handle_renew, super::email_forward::handle_renew_response;
EmailForwardTransferQuery, super::email_forward::handle_transfer_query, super::email_forward::handle_transfer_response;
EmailForwardTransferRequest, super::email_forward::handle_transfer_request, super::email_forward::handle_transfer_response;
EmailForwardTransferCancel, super::email_forward::handle_transfer_cancel, super::email_forward::handle_transfer_response;
EmailForwardTransferAccept, super::email_forward::handle_transfer_accept, super::email_forward::handle_transfer_response;
EmailForwardTransferReject, super::email_forward::handle_transfer_reject, super::email_forward::handle_transfer_response;
RestoreRequest, super::rgp::handle_restore, super::rgp::handle_restore_response;
HostCheck, super::host::handle_check, super::host::handle_check_response;
HostInfo, super::host::handle_info, super::host::handle_info_response;
HostCreate, super::host::handle_create, super::host::handle_create_response;
HostDelete, super::host::handle_delete, super::host::handle_delete_response;
HostUpdate, super::host::handle_update, super::host::handle_update_response;
ContactCheck, super::contact::handle_check, super::contact::handle_check_response;
ContactInfo, super::contact::handle_info, super::contact::handle_info_response;
ContactCreate, super::contact::handle_create, super::contact::handle_create_response;
ContactDelete, super::contact::handle_delete, super::contact::handle_delete_response;
ContactUpdate, super::contact::handle_update, super::contact::handle_update_response;
ContactTransferQuery, super::contact::handle_transfer_query, super::contact::handle_transfer_response;
ContactTransferRequest, super::contact::handle_transfer_request, super::contact::handle_transfer_response;
ContactTransferAccept, super::contact::handle_transfer_accept, super::contact::handle_transfer_response;
ContactTransferReject, super::contact::handle_transfer_reject, super::contact::handle_transfer_response;
NominetTagList, super::nominet::handle_tag_list, super::nominet::handle_tag_list_response;
NominetAccept, super::nominet::handle_accept, super::nominet::handle_handshake_response;
NominetReject, super::nominet::handle_reject, super::nominet::handle_handshake_response;
NominetRelease, super::nominet::handle_release, super::nominet::handle_release_response;
NominetContactValidate, super::nominet::handle_contact_validate, super::nominet::handle_contact_validate_response;
NominetLock, super::nominet::handle_lock, super::nominet::handle_lock_response;
NominetUnlock, super::nominet::handle_unlock, super::nominet::handle_lock_response;
Balance, super::balance::handle_balance, super::balance::handle_balance_response;
MaintenanceList, super::maintenance::handle_list, super::maintenance::handle_list_response;
MaintenanceInfo, super::maintenance::handle_info, super::maintenance::handle_info_response;
EURIDHitPoints, super::eurid::handle_hit_points, super::eurid::handle_hit_points_response;
EURIDRegistrationLimit, super::eurid::handle_registration_limits, super::eurid::handle_registration_limits_response;
EURIDDNSSECEligibility, super::eurid::handle_dnssec_eligibility, super::eurid::handle_dnssec_eligibility_response;
EURIDDNSQuality, super::eurid::handle_dns_quality, super::eurid::handle_dns_quality_response;
TMCHCheck, request_nop, response_nop;
TMCHCreate, request_nop, response_nop;
TMCHMarkInfo, request_nop, response_nop;
TMCHMarkSMDInfo, request_nop, response_nop;
TMCHMarkEncodedSMDInfo, request_nop, response_nop;
TMCHMarkFileInfo, request_nop, response_nop;
TMCHUpdate, request_nop, response_nop;
TMCHRenew, request_nop, response_nop;
TMCHTransferInitiate, request_nop, response_nop;
TMCHTransfer, request_nop, response_nop;
TMCHTrexActivate, request_nop, response_nop;
TMCHTrexRenew, request_nop, response_nop;
DACDomain, request_nop, response_nop;
DACUsage, request_nop, response_nop;
DACLimits, request_nop, response_nop;
Hello, request_nop, response_nop
);
