129 lines
2.6 KiB
Go
129 lines
2.6 KiB
Go
package main
|
|
|
|
import (
|
|
"net/http"
|
|
"strconv"
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
var captureID int
|
|
|
|
// CaptureList stores all captures
|
|
type CaptureList struct {
|
|
items []Capture
|
|
mu sync.RWMutex
|
|
maxItems int
|
|
updated chan struct{} // signals any change in "items"
|
|
}
|
|
|
|
// Capture saves our traffic data
|
|
type Capture struct {
|
|
ID int
|
|
Req *http.Request
|
|
Res *http.Response
|
|
|
|
// Elapsed time of the request, in milliseconds
|
|
Elapsed time.Duration
|
|
}
|
|
|
|
// CaptureMetadata is the data for each list item in the dashboard
|
|
type CaptureMetadata struct {
|
|
ID int `json:"id"`
|
|
Path string `json:"path"`
|
|
Method string `json:"method"`
|
|
Status int `json:"status"`
|
|
|
|
Elapsed time.Duration `json:"elapsed"`
|
|
}
|
|
|
|
// CaptureDump saves all the dumps shown in the dashboard
|
|
type CaptureDump struct {
|
|
Request string `json:"request"`
|
|
Response string `json:"response"`
|
|
Curl string `json:"curl"`
|
|
}
|
|
|
|
// Metadata returns the metadada of a capture
|
|
func (c *Capture) Metadata() CaptureMetadata {
|
|
return CaptureMetadata{
|
|
ID: c.ID,
|
|
Path: c.Req.URL.Path,
|
|
Method: c.Req.Method,
|
|
Status: c.Res.StatusCode,
|
|
Elapsed: c.Elapsed,
|
|
}
|
|
}
|
|
|
|
// NewCaptureList creates a new list of captures
|
|
func NewCaptureList(maxItems int) *CaptureList {
|
|
return &CaptureList{
|
|
maxItems: maxItems,
|
|
updated: make(chan struct{}),
|
|
}
|
|
}
|
|
|
|
// Insert adds a new capture
|
|
func (c *CaptureList) Insert(capture Capture) {
|
|
c.mu.Lock()
|
|
defer c.mu.Unlock()
|
|
captureID++
|
|
capture.ID = captureID
|
|
c.items = append(c.items, capture)
|
|
if len(c.items) > c.maxItems {
|
|
c.items = c.items[1:]
|
|
}
|
|
c.signalsChange()
|
|
}
|
|
|
|
// Find finds a capture by its id
|
|
func (c *CaptureList) Find(captureID string) *Capture {
|
|
c.mu.RLock()
|
|
defer c.mu.RUnlock()
|
|
idInt, _ := strconv.Atoi(captureID)
|
|
for _, c := range c.items {
|
|
if c.ID == idInt {
|
|
return &c
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// RemoveAll removes all the captures
|
|
func (c *CaptureList) RemoveAll() {
|
|
c.mu.Lock()
|
|
defer c.mu.Unlock()
|
|
c.items = nil
|
|
c.signalsChange()
|
|
}
|
|
|
|
// Items returns all the captures
|
|
func (c *CaptureList) Items() []Capture {
|
|
c.mu.RLock()
|
|
defer c.mu.RUnlock()
|
|
return c.items
|
|
}
|
|
|
|
// ItemsAsMetadata returns all the captures as metadata
|
|
func (c *CaptureList) ItemsAsMetadata() []CaptureMetadata {
|
|
c.mu.RLock()
|
|
defer c.mu.RUnlock()
|
|
metadatas := make([]CaptureMetadata, len(c.items))
|
|
for i, capture := range c.items {
|
|
metadatas[i] = capture.Metadata()
|
|
}
|
|
return metadatas
|
|
}
|
|
|
|
func (c *CaptureList) signalsChange() {
|
|
close(c.updated)
|
|
c.updated = make(chan struct{})
|
|
}
|
|
|
|
// Updated signals any change in the list
|
|
func (c *CaptureList) Updated() <-chan struct{} {
|
|
c.mu.RLock()
|
|
defer c.mu.RUnlock()
|
|
return c.updated
|
|
}
|