MCPcopy
hub / github.com/SurgeDM/Surge / NewStreamingMockServer

Function NewStreamingMockServer

internal/testutil/mock_server.go:403–426  ·  view source on GitHub ↗

NewStreamingMockServer creates a mock server that streams generated data.

(fileSize int64, opts ...MockServerOption)

Source from the content-addressed store, hash-verified

401
402// NewStreamingMockServer creates a mock server that streams generated data.
403func NewStreamingMockServer(fileSize int64, opts ...MockServerOption) *StreamingMockServer {
404 // Create base server with minimal data
405 m := &MockServer{
406 FileSize: fileSize,
407 SupportsRanges: true,
408 ContentType: "application/octet-stream",
409 Filename: "testfile.bin",
410 RandomData: false,
411 }
412
413 for _, opt := range opts {
414 opt(m)
415 }
416
417 // Only allocate a small buffer for streaming
418 m.data = make([]byte, 64*types.KB) // 64KB buffer
419 if m.RandomData {
420 _, _ = rand.Read(m.data)
421 }
422
423 s := &StreamingMockServer{MockServer: m}
424 m.Server = NewHTTPServer(http.HandlerFunc(s.handleStreamingRequest))
425 return s
426}
427
428// NewStreamingMockServerT creates a streaming mock server and skips the test if binding fails.
429func NewStreamingMockServerT(t *testing.T, fileSize int64, opts ...MockServerOption) *StreamingMockServer {

Callers

nothing calls this directly

Calls 2

NewHTTPServerFunction · 0.85
ReadMethod · 0.45

Tested by

no test coverage detected