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 engagement time middleware

Browse Source
This commit is contained in:
Kevin Franklin Kim 2025-02-12 09:29:27 +01:00
parent 8c170e83ad
commit 12c8d87600
No known key found for this signature in database
1 changed files with 25 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
pkg/http/mpv2/middleware.go
View File

@ -151,14 +151,34 @@ func MiddlewareIPOverride(next MiddlewareHandler) MiddlewareHandler {
}
}
func MiddlewareEngagementTime(next MiddlewareHandler) MiddlewareHandler {
return func(l *zap.Logger, w http.ResponseWriter, r *http.Request, payload *mpv2.Payload[any]) error {
for i, event := range payload.Events {
if value, ok := event.Params.(map[string]any); ok {
value["engagement_time_msec"] = 100
payload.Events[i] = event
}
}
return next(l, w, r, payload)
}
}
func MiddlewarePageLocation(next MiddlewareHandler) MiddlewareHandler {
return func(l *zap.Logger, w http.ResponseWriter, r *http.Request, payload *mpv2.Payload[any]) error {
if referrer := r.Header.Get("Referer"); referrer != "" {
for i, event := range payload.Events {
if value, ok := event.Params.(map[string]any); ok {
value["page_location"] = referrer
payload.Events[i] = event
pageTitle := r.Header.Get("X-Page-Title")
pageLocation := r.Header.Get("Referer")
pageReferrer := r.Header.Get("X-Page-Referrer")
for i, event := range payload.Events {
if value, ok := event.Params.(map[string]any); ok {
if value["page_title"] == "" && pageTitle != "" {
value["page_title"] = pageTitle
}
if value["page_referrer"] == "" && pageReferrer != "" {
value["page_referrer"] = pageReferrer
}
if value["page_location"] == "" && pageLocation != "" {
value["page_location"] = pageLocation
}
payload.Events[i] = event
}
}
return next(l, w, r, payload)