gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 03:24:40 -07:00
Code Issues Packages Projects Releases Wiki Activity

send audit advisories for all api errors

Browse Source
This commit is contained in:
R.I.Pienaar
2020-04-23 12:23:07 +02:00
committed by Derek Collison
parent fb37c121d1
commit c64e39ea61
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
server/jetstream_api.go
View File

@@ -258,7 +258,7 @@ func (s *Server) jsCreateTemplateRequest(sub *subscription, c *client, subject,
}
templateName := subjectToken(subject, 2)
if templateName != cfg.Name {
s.sendInternalAccountMsg(c.acc, reply, protoErr("template name in subject does not match request"))
s.sendAPIResponse(c, subject, reply, string(msg), protoErr("template name in subject does not match request"))
return
}
@@ -361,12 +361,12 @@ func (s *Server) jsCreateStreamRequest(sub *subscription, c *client, subject, re
}
var cfg StreamConfig
if err := json.Unmarshal(msg, &cfg); err != nil {
s.sendInternalAccountMsg(c.acc, reply, JetStreamBadRequest)
s.sendAPIResponse(c, subject, reply, string(msg), JetStreamBadRequest)
return
}
streamName := subjectToken(subject, 2)
if streamName != cfg.Name {
s.sendInternalAccountMsg(c.acc, reply, protoErr("stream name in subject does not match request"))
s.sendAPIResponse(c, subject, reply, string(msg), protoErr("stream name in subject does not match request"))
return
}
@@ -388,12 +388,12 @@ func (s *Server) jsStreamUpdateRequest(sub *subscription, c *client, subject, re
}
var cfg StreamConfig
if err := json.Unmarshal(msg, &cfg); err != nil {
s.sendInternalAccountMsg(c.acc, reply, JetStreamBadRequest)
s.sendAPIResponse(c, subject, reply, string(msg), JetStreamBadRequest)
return
}
streamName := subjectToken(subject, 2)
if streamName != cfg.Name {
s.sendInternalAccountMsg(c.acc, reply, protoErr("stream name in subject does not match request"))
s.sendAPIResponse(c, subject, reply, string(msg), protoErr("stream name in subject does not match request"))
return
}
mset, err := c.acc.LookupStream(streamName)