foomo/sesamy-go
1
0
Fork 0
mirror of https://github.com/foomo/sesamy-go.git synced 2025-10-16 12:35:43 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: add cookies

Browse Source
This commit is contained in:
Kevin Franklin Kim 2024-03-08 13:31:42 +01:00
parent 19b1b587af
commit a527a59197
No known key found for this signature in database
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
integration/watermill/keel/subscriber.go
View File

@ -175,6 +175,14 @@ func (s *Subscriber) handle(l *zap.Logger, r *http.Request, event *mpv2.Event) e
msg.Metadata.Set(name, strings.Join(headers, ",")) msg.Metadata.Set(name, strings.Join(headers, ","))
} }
if cookies := r.Cookies(); len(cookies) > 0 {
values := make([]string, len(cookies))
for i, cookie := range r.Cookies() {
values[i] = cookie.String()
}
msg.Metadata.Set("Cookies", strings.Join(values, "; "))
}
for k, v := range msg.Metadata { for k, v := range msg.Metadata {
l = l.With(zap.String(k, v)) l = l.With(zap.String(k, v))
} }
@ -190,13 +198,13 @@ func (s *Subscriber) handle(l *zap.Logger, r *http.Request, event *mpv2.Event) e
// wait for ACK // wait for ACK
select { select {
case <-msg.Acked(): case <-msg.Acked():
l.Debug("message acked") l.Info("message acked")
return nil return nil
case <-msg.Nacked(): case <-msg.Nacked():
l.Debug("message nacked") l.Info("message nacked")
return ErrMessageNacked return ErrMessageNacked
case <-r.Context().Done(): case <-r.Context().Done():
l.Debug("message cancled") l.Info("message cancled")
return ErrContextCanceled return ErrContextCanceled
} }
} }