An experimental pub/sub client and server project.
removed all that commented out cod
+2
-15
+2
-15
server/server.go
+2
-15
server/server.go
···
85
85
default:
86
86
slog.Error("unknown action", "action", action, "peer", peer.addr())
87
87
peer.writeStatus(Error, "unknown action")
88
-
//_, _ = peer.Write([]byte("unknown action"))
89
88
}
90
89
}
91
90
···
113
112
s.handleUnsubscribe(peer)
114
113
default:
115
114
slog.Error("unknown action for subscriber", "action", action, "peer", peer.addr())
115
+
peer.writeStatus(Error, "unknown action")
116
116
continue
117
117
}
118
118
}
···
124
124
if err != nil {
125
125
slog.Error(err.Error(), "peer", peer.addr())
126
126
peer.writeStatus(Error, "invalid data length of topics provided")
127
-
// _, _ = peer.Write([]byte("invalid data length of topics provided"))
128
127
return
129
128
}
130
129
if dataLen == 0 {
131
130
peer.writeStatus(Error, "data length of topics is 0")
132
-
// _, _ = peer.Write([]byte("data length of topics is 0"))
133
131
return
134
132
}
135
133
···
138
136
if err != nil {
139
137
slog.Error("failed to read subscibers topic data", "error", err, "peer", peer.addr())
140
138
peer.writeStatus(Error, "failed to read topic data")
141
-
//_, _ = peer.Write([]byte("failed to read topic data"))
142
139
return
143
140
}
144
141
···
147
144
if err != nil {
148
145
slog.Error("failed to unmarshal subscibers topic data", "error", err, "peer", peer.addr())
149
146
peer.writeStatus(Error, "invalid topic data provided")
150
-
//_, _ = peer.Write([]byte("invalid topic data provided"))
151
147
return
152
148
}
153
149
154
150
s.subscribeToTopics(peer, topics)
155
-
//_, _ = peer.Write([]byte("subscribed"))
156
151
peer.writeStatus(Subscribed, "")
157
152
}
158
153
···
162
157
if err != nil {
163
158
slog.Error(err.Error(), "peer", peer.addr())
164
159
peer.writeStatus(Error, "invalid data length of topics provided")
165
-
//_, _ = peer.Write([]byte("invalid data length of topics provided"))
166
160
return
167
161
}
168
162
if dataLen == 0 {
169
163
peer.writeStatus(Error, "data length of topics is 0")
170
-
//_, _ = peer.Write([]byte("data length of topics is 0"))
171
164
return
172
165
}
173
166
···
176
169
if err != nil {
177
170
slog.Error("failed to read subscibers topic data", "error", err, "peer", peer.addr())
178
171
peer.writeStatus(Error, "failed to read topic data")
179
-
//_, _ = peer.Write([]byte("failed to read topic data"))
180
172
return
181
173
}
182
174
···
185
177
if err != nil {
186
178
slog.Error("failed to unmarshal subscibers topic data", "error", err, "peer", peer.addr())
187
179
peer.writeStatus(Error, "invalid topic data provided")
188
-
//_, _ = peer.Write([]byte("invalid topic data provided"))
189
180
return
190
181
}
191
182
192
183
s.unsubscribeToTopics(peer, topics)
193
184
peer.writeStatus(Unsubscribed, "")
194
-
//_, _ = peer.Write([]byte("unsubscribed"))
195
185
}
196
186
197
187
func (s *Server) handlePublish(peer peer) {
···
200
190
if err != nil {
201
191
slog.Error(err.Error(), "peer", peer.addr())
202
192
peer.writeStatus(Error, "invalid data length of data provided")
203
-
//_, _ = peer.Write([]byte("invalid data length of data provided"))
204
193
return
205
194
}
206
195
if dataLen == 0 {
···
212
201
if err != nil {
213
202
slog.Error("failed to read data from peer", "error", err, "peer", peer.addr())
214
203
peer.writeStatus(Error, "failed to read data")
215
-
//_, _ = peer.Write([]byte("failed to read data"))
216
204
return
217
205
}
218
206
219
207
var msg messagebroker.Message
220
208
err = json.Unmarshal(buf, &msg)
221
209
if err != nil {
210
+
slog.Error("failed to unmarshal data to message", "error", err, "peer", peer.addr())
222
211
peer.writeStatus(Error, "invalid message")
223
-
//_, _ = peer.Write([]byte("invalid message"))
224
-
slog.Error("failed to unmarshal data to message", "error", err, "peer", peer.addr())
225
212
continue
226
213
}
227
214