httpwriter

README

httpwriter

Package for writing each http request/response to some storage.
This package is used with http logging packages.

Usage

Examples

Documentation

Index

• func MustDirectoryWriter(directory *Directory) func(*http.Request) (io.WriteCloser, error)
• func NewDirectoryWriter(directory *Directory) (func(*http.Request) (io.WriteCloser, error), error)
• func NewMemoryWriter(memory *Memory) func(*http.Request) (io.WriteCloser, error)
• type Buffer
  • func (b *Buffer) Close() error
• type Directory
  • func (d *Directory) CreateFilePath(req *http.Request) (string, error)
• type Memory
  • func (m *Memory) CreateBuffer(req *http.Request) *Buffer
• type Transport
  • func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)

Examples

• Directory
• Memory

Functions

func MustDirectoryWriter

func MustDirectoryWriter(directory *Directory) func(*http.Request) (io.WriteCloser, error)

func NewDirectoryWriter

func NewDirectoryWriter(directory *Directory) (func(*http.Request) (io.WriteCloser, error), error)

func NewMemoryWriter

func NewMemoryWriter(memory *Memory) func(*http.Request) (io.WriteCloser, error)

Types

type Buffer

type Buffer struct {
	bytes.Buffer
	Request *http.Request
}

func (*Buffer) Close

func (b *Buffer) Close() error

type Directory

type Directory struct {
	Path           string
	CreateFileName func(req *http.Request, counter uint64) (string, error)
	// contains filtered or unexported fields
}

Example

handler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {})
server := httptest.NewServer(handler)
defer server.Close()

path := os.TempDir()
directory := httpwriter.Directory{Path: path}
client := http.Client{
	Transport: &httpwriter.Transport{
		TransportFactory: func(w io.Writer) http.RoundTripper {
			logger := log.New(os.Stdout, "", 0)
			logger.SetOutput(w)
			return TransportFunc(func(req *http.Request) (*http.Response, error) {
				logger.Printf("-> %s", req.URL.Path)
				return http.DefaultTransport.RoundTrip(req)
			})
		},
		GetWriter: httpwriter.MustDirectoryWriter(&directory),
	},
}

_, err := client.Get(server.URL + "/hello")
if err != nil {
	panic(err)
}

serverURL, err := url.Parse(server.URL)
if err != nil {
	panic(err)
}

tmpfs := os.DirFS(path)
fileName := fmt.Sprintf("0001_GET@http:@@%s@hello", serverURL.Host)
f, err := tmpfs.Open(fileName)
if err != nil {
	panic(err)
}
fileContent, err := io.ReadAll(f)
if err != nil {
	panic(err)
}

fmt.Println(string(fileContent))

Output:

-> /hello

func (*Directory) CreateFilePath

func (d *Directory) CreateFilePath(req *http.Request) (string, error)

type Memory

type Memory struct {
	Buffers []*Buffer
	// contains filtered or unexported fields
}

Example

handler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {})
server := httptest.NewServer(handler)
defer server.Close()

memory := httpwriter.Memory{}
client := http.Client{
	Transport: &httpwriter.Transport{
		TransportFactory: func(w io.Writer) http.RoundTripper {
			logger := log.New(os.Stdout, "", 0)
			logger.SetOutput(w)
			return TransportFunc(func(req *http.Request) (*http.Response, error) {
				logger.Printf("-> %s", req.URL.Path)
				return http.DefaultTransport.RoundTrip(req)
			})
		},
		GetWriter: httpwriter.NewMemoryWriter(&memory),
	},
}

{
	_, err := client.Get(server.URL + "/hello1")
	if err != nil {
		panic(err)
	}
}
{
	_, err := client.Get(server.URL + "/hello2")
	if err != nil {
		panic(err)
	}
}

fmt.Println(memory.Buffers[1].String())

Output:

-> /hello2

func (*Memory) CreateBuffer

func (m *Memory) CreateBuffer(req *http.Request) *Buffer

type Transport

type Transport struct {
	GetWriter        func(*http.Request) (io.WriteCloser, error)
	TransportFactory func(io.Writer) http.RoundTripper
}

func (*Transport) RoundTrip

func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)