FilesExpand file tree

main

/

logging.go

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

69 lines (59 loc) · 1.64 KB

main

/

logging.go

Copy path

Top

File metadata and controls

• Code
• Blame

69 lines (59 loc) · 1.64 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

package httpstream

import (

"log/slog"

"net/http"

"time"

)

// LoggingMiddleware returns a Middleware that logs HTTP requests and responses

// using the provided *slog.Logger. It is compatible with the Middleware type

// expected by the package: func(http.RoundTripper) http.RoundTripper.

//

// The middleware logs an entry before the request is sent and after the

// response is received (or when an error occurs). It records method, url,

// duration, status (when available), headers and the error when present.

func LoggingMiddleware(logger *slog.Logger) func(http.RoundTripper) http.RoundTripper {

if logger == nil {

// Use the default logger if nil was provided to avoid panics.

logger = slog.Default()

}

return func(next http.RoundTripper) http.RoundTripper {

return &loggingRoundTripper{

next: next,

logger: logger,

}

}

}

type loggingRoundTripper struct {

next http.RoundTripper

logger *slog.Logger

}

func (l *loggingRoundTripper) RoundTrip(req *http.Request) (*http.Response, error) {

start := time.Now()

// Log request start

l.logger.Info("HTTP Request",

"method", req.Method,

"url", req.URL.String(),

"headers", req.Header,

)

// Delegate to the next RoundTripper

resp, err := l.next.RoundTrip(req)

duration := time.Since(start)

if err != nil {

l.logger.Error("HTTP Request failed",

"method", req.Method,

"url", req.URL.String(),

"duration", duration,

"error", err,

)

return resp, err

}

// Log response details

l.logger.Info("HTTP Response",

"method", req.Method,

"url", req.URL.String(),

"status", resp.StatusCode,

"duration", duration,

"headers", resp.Header,

)

return resp, nil

}