forked from diffusiondata/wireshark-dissector
-
Notifications
You must be signed in to change notification settings - Fork 0
/
dpt.proto.lua
170 lines (149 loc) · 7.87 KB
/
dpt.proto.lua
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
-- Proto package
-- This package sets up the protocol description, fields and value mappings used by Wireshark.
-- Package header
local master = diffusion or {}
if master.proto ~= nil then
return master.proto
end
local v5 = diffusion.v5
local dptProto = Proto( "DPT", "Diffusion Protocol over TCP")
local responseCodes = {
[100] = "OK - Connection Successful",
[101] = "Invalid Connection Protocol",
[103] = "One or more of the specified topics are invalid",
[105] = "Reconnection Successful",
[110] = "Topic already exists",
[111] = "Connection Rejected",
[127] = "Undefined error"
}
local capabilities = {
[0x00] = "None",
[0x01] = "Supports encrypted data messages",
[0x02] = "Supports compressed data messages",
[0x03] = "Supports encrypted and compressed data messages",
[0x04] = "Supports base 64 encoded data messages",
[0x05] = "Supports encrypted and base 64 encoded data messages",
[0x06] = "Supports compressed and base 64 encoded data messages",
[0x07] = "Supports encrypted, compressed and base 64 encoded data messages",
[0x0f] = "Supports encrypted, compressed, base 64 encoded data messages and is a feature based client"
}
local encodingTypesByValue = {
[0] = "None",
[1] = "Encryption requested",
[2] = "Compression requested",
[3] = "Base64 encoding requested",
[0x11] = "Encrypted",
[0x12] = "Compressed",
[0x13] = "Base64 encoded"
}
local clientTypesByValue = {
[0x01] = "Event Publisher",
[0x02] = "UDP Event Publisher",
[0x10] = "Publisher Client",
[0x14] = "Unspecified Client",
[0x15] = "Java Client",
[0x16] = ".Net Client",
[0x17] = "Flash Bridge Client",
[0x18] = "Silverlight Bridge Client",
[0x19] = "iPhone Client",
[0x1a] = "J2ME Client",
[0x1b] = "Android Client",
[0x1c] = "Blackberry Client",
[0x1d] = "C Client",
[0x1e] = "Perl Client",
[0x1f] = "Introspector Client",
[0x20] = "Windows Phone Client",
[0x21] = "iPad Client",
[0x22] = "Flash Client",
[0x23] = "Silverlight Client",
[0x28] = "UDP Java Client",
[0x29] = "UDP .Net Client",
[0x2a] = "UDP Silverlight Client",
[0x2b] = "UDP Publisher Client"
}
local topicTypesByByte = {
[0x00] = "NONE",
[0x01] = "STATELESS",
[0x02] = "DELEGATED",
[0x03] = "SINGLE_VALUE",
[0x04] = "RECORD",
[0x05] = "PROTOCOL_BUFFER",
[0x06] = "CUSTOM",
[0x07] = "SLAVE",
[0x08] = "SERVICE",
[0x09] = "PAGED_STRING",
[0x0a] = "PAGED_RECORD",
[0x0b] = "TOPIC_NOTIFY",
[0x0c] = "ROUTING",
[0x0d] = "CHILD_LIST"
}
local statusResponseBytes = {
[0x00] = "OK",
[0x01] = "UNMATCHED_SELECTOR"
}
local topicRemovalReasonByBytes = {
[0x00] = "Unsubscription requested",
[0x01] = "Control client or server unsubscription",
[0x02] = "Topic Removal",
}
-- Connection negotiation fields
dptProto.fields.connectionMagicNumber = ProtoField.uint8( "dpt.connection.magicNumber", "Magic number" , base.HEX )
dptProto.fields.connectionProtoNumber = ProtoField.uint8( "dpt.connection.protocolVersion", "Protocol number" )
dptProto.fields.connectionType = ProtoField.uint8( "dpt.connection.connectionType", "Connection Type", base.HEX, clientTypesByValue )
dptProto.fields.capabilities = ProtoField.uint8( "dpt.connection.capabilities", "Client Capabilities", base.HEX, capabilities )
dptProto.fields.connectionResponse = ProtoField.uint8( "dpt.connection.responseCode", "Connection Response", base.DEC, responseCodes )
dptProto.fields.clientID = ProtoField.string( "dpt.clientID", "Client ID" )
dptProto.fields.direction = ProtoField.string( "dpt.direction", "Direction" )
-- Message fields
dptProto.fields.typeHdr = ProtoField.uint8( "dpt.message.type", "Type", base.HEX ) -- no lookup table possible here, it's a bitfield
dptProto.fields.encodingHdr = ProtoField.uint8( "dpt.message.encoding", "Encoding", base.HEX, encodingTypesByValue )
dptProto.fields.topic = ProtoField.string( "dpt.header.topic", "Topic" )
dptProto.fields.alias = ProtoField.string( "dpt.header.alias", "Alias" )
dptProto.fields.headers = ProtoField.string( "dptProto.headers", "Headers" )
dptProto.fields.userHeaders = ProtoField.string( "dptProto.userHeaders", "User headers" )
dptProto.fields.fixedHeaders = ProtoField.string( "dptProto.fixedHeaders", "Fixed headers" )
dptProto.fields.content = ProtoField.string( "dptProto.content", "Content" )
dptProto.fields.connection = ProtoField.string( "dptProto.connection", "Connection" )
dptProto.fields.sizeHdr = ProtoField.uint32( "dptProto.size", "Size" )
dptProto.fields.messageLengthSize = ProtoField.uint8( "dptProto.messageLengthSize", "Size Length", base.DEC )
dptProto.fields.record = ProtoField.string( "dpt.records" )
dptProto.fields.field = ProtoField.string( "dpt.fields" )
-- Command message fields
dptProto.fields.command = ProtoField.string( "dpt.header.command", "Command" )
dptProto.fields.commandTopicType = ProtoField.string( "dpt.header.command.topicType", "Topic Type" )
dptProto.fields.commandTopicCategory = ProtoField.string( "dpt.header.command.topicCategory", "Topic Category" )
dptProto.fields.notificationType = ProtoField.string( "dpt.header.command.notificationType", "Notification Type" )
dptProto.fields.parameters = ProtoField.string( "dptProto.field.parameters", "Parameters" )
dptProto.fields.loginCreds = ProtoField.string( "dptProto.field.loginCreds", "Login Credentials" )
dptProto.fields.loginTopics = ProtoField.string( "dptProto.field.loginTopics", "Subscriptions" )
-- Ping message fields
dptProto.fields.timestamp = ProtoField.string( "dpt.header.timestamp", "Timestamp" )
dptProto.fields.queueSize = ProtoField.string( "dpt.header.queueSize", "Message Queue size" )
-- Ack message field
dptProto.fields.ackId = ProtoField.string( "dpt.header.ackId", "Acknowledgement ID" )
-- Service fields
dptProto.fields.service = ProtoField.string( "dpt.service", "Service" )
dptProto.fields.serviceIdentity = ProtoField.uint8( "dpt.service.identity", "Service Identity", base.HEX, v5.serviceIdentity )
dptProto.fields.serviceMode = ProtoField.uint8( "dpt.service.mode", "Mode", base.HEX, v5.modeValues )
dptProto.fields.conversation = ProtoField.uint32( "dpt.conversation.id", "Conversation ID" )
dptProto.fields.topicInfo = ProtoField.string( "dpt.service.topicInfo", "Topic Info" )
dptProto.fields.topicId = ProtoField.uint32( "dpt.service.topicInfo.topicId", "Topic ID" )
dptProto.fields.topicPath = ProtoField.string( "dpt.service.topicInfo.topicPath", "Topic Path" )
dptProto.fields.topicType = ProtoField.uint8( "dpt.service.topicInfo.topicType", "Topic Type", base.HEX, topicTypesByByte )
dptProto.fields.selector = ProtoField.string( "dpt.service.selector", "Topic selector" )
dptProto.fields.status = ProtoField.uint8( "dpt.service.status", "Status", base.HEX, statusResponseBytes )
dptProto.fields.topicName = ProtoField.string( "dpt.service.topicName", "Topic Name" )
dptProto.fields.topicUnSubReason = ProtoField.uint8( "dpt.service.topicUnsubscribeReason", "Reason", base.HEX, topicRemovalReasonByBytes )
dptProto.fields.responseTime = ProtoField.string( "dpt.service.responseTime", "Response time" )
dptProto.fields.handlerName = ProtoField.string( "dpt.service.handlerName", "Handler name" )
dptProto.fields.controlGroup = ProtoField.string( "dpt.service.controlGroup", "Control group" )
dptProto.fields.regServiceId = ProtoField.uint8( "dpt.service.regServiceId", "Registration Service Identity", base.HEX, v5.serviceIdentity )
dptProto.fields.handlerTopicPath = ProtoField.string( "dpt.service.handlerTopicPath", "Handler topic path" )
dptProto.fields.topicSourceTopicPath = ProtoField.string( "dpt.service.topicSourceTopicPath", "Topic source topic path" )
-- Package footer
master.proto = {
dptProto = dptProto,
statusResponseBytes = statusResponseBytes
}
diffusion = master
return master.proto