-
Notifications
You must be signed in to change notification settings - Fork 0
/
connackcode.go
126 lines (104 loc) · 3.58 KB
/
connackcode.go
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
// Copyright (c) 2014 Dataence, LLC. All rights reserved.
//
// 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.
package mqtt
import "errors"
// ConnackCode is the type representing the return code in the CONNACK message,
// returned after the initial CONNECT message
type ConnackCode byte
const (
// Connection accepted
ConnectionAccepted ConnackCode = iota
// The Server does not support the level of the MQTT protocol requested by the Client
UnacceptableProtocolVersion
// The Client identifier is correct UTF-8 but not allowed by the server
IdentifierRejected
// The Network Connection has been made but the MQTT service is unavailable
ServerUnavailable
// The data in the user name or password is malformed
BadUsernameOrPassword
// The Client is not authorized to connect
NotAuthorized
)
var (
// Error represention of ConnectionAccepted
ErrUnacceptableProtocolVersion = errors.New("Connection Refused, unacceptable protocol version")
// Error represention of IdentifierRejected
ErrIdentifierRejected = errors.New("Connection Refused, identifier rejected")
// Error represention of ServerUnavailable
ErrServerUnavailable = errors.New("Connection Refused, Server unavailable")
// Error represention of BadUsernameOrPassword
ErrBadUsernameOrPassword = errors.New("Connection Refused, bad user name or password")
// Error represention of NotAuthorized
ErrNotAuthorized = errors.New("Connection Refused, not authorized")
)
// Value returns the value of the ConnackCode, which is just the byte representation
func (this ConnackCode) Value() byte {
return byte(this)
}
// Response returns a string representation of the ConnackCode
func (this ConnackCode) Response() string {
switch this {
case 0:
return "Connection Accepted"
case 1:
return "Connection Refused, unacceptable protocol version"
case 2:
return "Connection Refused, identifier rejected"
case 3:
return "Connection Refused, Server unavailable"
case 4:
return "Connection Refused, bad user name or password"
case 5:
return "Connection Refused, not authorized"
}
return ""
}
// Desc returns the description of the ConnackCode
func (this ConnackCode) Desc() string {
switch this {
case 0:
return "Connection accepted"
case 1:
return "The Server does not support the level of the MQTT protocol requested by the Client"
case 2:
return "The Client identifier is correct UTF-8 but not allowed by the server"
case 3:
return "The Network Connection has been made but the MQTT service is unavailable"
case 4:
return "The data in the user name or password is malformed"
case 5:
return "The Client is not authorized to connect"
}
return ""
}
// Valid checks to see if the ConnackCode is valid. Currently valid codes are <= 5
func (this ConnackCode) Valid() bool {
return this <= 5
}
// Error returns the corresonding error for the ConnackCode
func (this ConnackCode) Error() error {
switch this {
case 1:
return ErrUnacceptableProtocolVersion
case 2:
return ErrIdentifierRejected
case 3:
return ErrServerUnavailable
case 4:
return ErrBadUsernameOrPassword
case 5:
return ErrNotAuthorized
}
return nil
}