| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091 |
- using MQTTnet.Exceptions;
- namespace MQTTnet.Protocol
- {
- public class MqttConnectReasonCodeConverter
- {
- public MqttConnectReturnCode ToConnectReturnCode(MqttConnectReasonCode reasonCode)
- {
- switch (reasonCode)
- {
- case MqttConnectReasonCode.Success:
- {
- return MqttConnectReturnCode.ConnectionAccepted;
- }
- case MqttConnectReasonCode.NotAuthorized:
- {
- return MqttConnectReturnCode.ConnectionRefusedNotAuthorized;
- }
- case MqttConnectReasonCode.BadUserNameOrPassword:
- {
- return MqttConnectReturnCode.ConnectionRefusedBadUsernameOrPassword;
- }
- case MqttConnectReasonCode.ClientIdentifierNotValid:
- {
- return MqttConnectReturnCode.ConnectionRefusedIdentifierRejected;
- }
- case MqttConnectReasonCode.UnsupportedProtocolVersion:
- {
- return MqttConnectReturnCode.ConnectionRefusedUnacceptableProtocolVersion;
- }
- case MqttConnectReasonCode.ServerUnavailable:
- case MqttConnectReasonCode.ServerBusy:
- case MqttConnectReasonCode.ServerMoved:
- {
- return MqttConnectReturnCode.ConnectionRefusedServerUnavailable;
- }
- default:
- {
- throw new MqttProtocolViolationException("Unable to convert connect reason code (MQTTv5) to return code (MQTTv3).");
- }
- }
- }
- public MqttConnectReasonCode ToConnectReasonCode(MqttConnectReturnCode returnCode)
- {
- switch (returnCode)
- {
- case MqttConnectReturnCode.ConnectionAccepted:
- {
- return MqttConnectReasonCode.Success;
- }
- case MqttConnectReturnCode.ConnectionRefusedUnacceptableProtocolVersion:
- {
- return MqttConnectReasonCode.UnsupportedProtocolVersion;
- }
- case MqttConnectReturnCode.ConnectionRefusedBadUsernameOrPassword:
- {
- return MqttConnectReasonCode.BadUserNameOrPassword;
- }
- case MqttConnectReturnCode.ConnectionRefusedIdentifierRejected:
- {
- return MqttConnectReasonCode.ClientIdentifierNotValid;
- }
- case MqttConnectReturnCode.ConnectionRefusedServerUnavailable:
- {
- return MqttConnectReasonCode.ServerUnavailable;
- }
- case MqttConnectReturnCode.ConnectionRefusedNotAuthorized:
- {
- return MqttConnectReasonCode.NotAuthorized;
- }
- default:
- {
- throw new MqttProtocolViolationException("Unable to convert connect reason code (MQTTv5) to return code (MQTTv3).");
- }
- }
- }
- }
- }
|