MCPcopy Create free account
hub / github.com/ContentSquare/chproxy / TestWriteThenReadContent

Function TestWriteThenReadContent

cache/tmp_file_response_writer_test.go:129–164  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

127}
128
129func TestWriteThenReadContent(t *testing.T) {
130 srw := newFakeResponse()
131
132 tmpFileRespWriter, err := NewTmpFileResponseWriter(srw, testTmpWriterDir)
133 defer tmpFileRespWriter.Close()
134 if err != nil {
135 t.Fatalf("could not initate TmpFileResponseWriter error:%s", err)
136 return
137 }
138 expectedContent := "test content"
139 _, err = tmpFileRespWriter.Write([]byte(expectedContent))
140 if err != nil {
141 t.Fatalf("could not write into tmp file:%s", err)
142 return
143 }
144 reader, err := tmpFileRespWriter.Reader()
145 if err != nil {
146 t.Fatalf("could not read tmp file:%s", err)
147 return
148 }
149 tmpFileRespWriter.ResetFileOffset()
150 buffer, err := io.ReadAll(reader)
151 if err != nil {
152 t.Fatalf("could not read tmp file:%s", err)
153 return
154 }
155 if len(buffer) == 0 {
156 t.Fatalf("read 0 bytes file:")
157 return
158 }
159 s := string(buffer)
160
161 if s != expectedContent {
162 t.Fatalf("wrong value for contentLength, got %s, expected %s", s, expectedContent)
163 }
164}
165
166func TestWriteThenReadStatusCode(t *testing.T) {
167 srw := newFakeResponse()

Callers

nothing calls this directly

Calls 6

CloseMethod · 0.95
WriteMethod · 0.95
ReaderMethod · 0.95
ResetFileOffsetMethod · 0.95
newFakeResponseFunction · 0.85
NewTmpFileResponseWriterFunction · 0.85

Tested by

no test coverage detected