dashboard / erock/tuns / chore(analytics): send content-type to `metric-drain` #38 rss

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

diff --git a/httpmuxer/httpmuxer.go b/httpmuxer/httpmuxer.go
index ef3ece3..37e20cf 100644
--- a/httpmuxer/httpmuxer.go
+++ b/httpmuxer/httpmuxer.go
@@ -129,14 +129,15 @@ func Start(state *utils.State) {
 					slog.Info(logLine, "user", user, "userId", userId)
 
 					visit := &utils.MetricDrainVisit{
-						Namespace: "tuns",
-						UserID:    userId,
-						Host:      param.Request.Host,
-						IpAddress: param.ClientIP,
-						Status:    param.StatusCode,
-						Path:      originalURI,
-						UserAgent: param.Request.UserAgent(),
-						Referer:   param.Request.Referer(),
+						Namespace:   "tuns",
+						UserID:      userId,
+						Host:        param.Request.Host,
+						IpAddress:   param.ClientIP,
+						Status:      param.StatusCode,
+						Path:        originalURI,
+						UserAgent:   param.Request.UserAgent(),
+						Referer:     param.Request.Referer(),
+						ContentType: param.Request.Response.Header.Get("Content-Type"),
 					}
 
 					select {

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

diff --git a/utils/state.go b/utils/state.go
index 44ca24f..ec99ef6 100644
--- a/utils/state.go
+++ b/utils/state.go
@@ -218,14 +218,15 @@ type Ports struct {
 
 // MetricDrainVisit represents a visit for the metric drain.
 type MetricDrainVisit struct {
-	Namespace string `json:"namespace"`
-	UserID    string `json:"user_id"`
-	Host      string `json:"host"`
-	Path      string `json:"path"`
-	IpAddress string `json:"ip_address"`
-	UserAgent string `json:"user_agent"`
-	Referer   string `json:"referer"`
-	Status    int    `json:"status"`
+	Namespace   string `json:"namespace"`
+	UserID      string `json:"user_id"`
+	Host        string `json:"host"`
+	Path        string `json:"path"`
+	IpAddress   string `json:"ip_address"`
+	UserAgent   string `json:"user_agent"`
+	Referer     string `json:"referer"`
+	Status      int    `json:"status"`
+	ContentType string `json:"content_type"`
 }
 
 // State handles overall state. It retains mutexed maps for various