adding restricted to standard ok error prefixes.

handler/req.go

@@ -28,7 +28,7 @@ type filterQuery struct {
 	Limit uint32
 }
 
-func (h *Handler) HandleReq(f filter.Filter) ([]event.Event, error) {
+func (h *Handler) HandleReq(f *filter.Filter) ([]event.Event, error) {
 	ctx, cancel := context.WithTimeout(context.Background(), h.db.QueryTimeout)
 	defer cancel()
 

server/websocket/event_handler.go

@@ -281,7 +281,7 @@ func (s *Server) handleEvent(conn *websocket.Conn, m message.Message) { //nolint
 			return
 		}
 	}
-	
+
 	_ = conn.WriteMessage(1, message.MakeOK(true, msg.Event.ID, ""))
 
 	_, err = s.redis.Client.BFAdd(qCtx, s.redis.BloomFilterName, eID[:]).Result()

server/websocket/req_handler.go

@@ -73,7 +73,7 @@ func (s *Server) handleReq(conn *websocket.Conn, m message.Message) {
 		return
 	}
 
-	res, err := s.handler.HandleReq(msg.Filter)
+	res, err := s.handler.HandleReq(&msg.Filter)
 	if err != nil {
 		_ = conn.WriteMessage(1, message.MakeNotice(fmt.Sprintf("error: can't process REQ message: %s", err.Error())))
 		status = databaseFail

types/message/message.go

@@ -140,7 +140,7 @@ func (rm *Req) DecodeFromJSON(data []byte) error {
 		}
 	}
 	rm.SubscriptionID = arr[1].Str
-	rm.Filter = *new(filter.Filter)
+	rm.Filter = filter.Filter{}
 	if err := easyjson.Unmarshal([]byte(arr[2].Raw), &rm.Filter); err != nil {
 		return types.DecodeError{
 			Reason: fmt.Sprintf("REQ message: %s", err.Error()),
@@ -150,7 +150,7 @@ func (rm *Req) DecodeFromJSON(data []byte) error {
 	return nil
 }
 
-func (rm Req) EncodeToJSON() ([]byte, error) {
+func (rm *Req) EncodeToJSON() ([]byte, error) {
 	return nil, nil
 }