synapsecns/sanguine

// nolint: wrapcheck
package processlog

import (
    "bufio"
    "bytes"
    "context"
    "io"
    "os"
    "time"
)

// ReadLine exports the readLine function for testing.
func ReadLine(r *bufio.Reader) ([]byte, error) {
    return readLine(r)
}

// CombinedPipe exports buffered pipe for testing
// In buffered pipe the Close() method being defined for both ReadCloser and WriteCloser in the CombinedPipe interface.
// Since the bufferedPipe struct embeds two separate ReadCloser and WriteCloser fields, Go cannot determine which Close() method to use when the CombinedPipe interface is implemented.
// To resolve this, we define separate methods and call close on both in our test.
type CombinedPipe interface {
    io.Reader
    io.Writer
    CloseReader() error
    CloseWriter() error
}

// NewBufferedPipe exports the newBufferedPipe function for testing.
func NewBufferedPipe() CombinedPipe {
    return newBufferedPipe()
}

func (bp *bufferedPipe) CloseReader() error {
    return bp.ReadCloser.Close()
}

func (bp *bufferedPipe) CloseWriter() error {
    return bp.WriteCloser.Close()
}

// MakeArgs exports the makeArgs function for testing.
// only returns the error.
func MakeArgs(opts []StdStreamLogArgsOption) error {
    _, err := makeArgs(opts)
    return err
}

// WritePrintFunc exports the writePrintFunc function for testing.
func WritePrintFunc(ctx context.Context, printFunc PrintFunc, logFrequency time.Duration, stdOut, stdErr io.ReadCloser) {
    writePrintFunc(ctx, printFunc, logFrequency, stdOut, stdErr)
}

// PipeSingleOutput exports the pipeSingleOutput function for testing.
func PipeSingleOutput(file *os.File, reader io.ReadCloser) (err error) {
    return pipeSingleOutput(file, reader)
}

// PipeCombinedOutput exports the pipeCombinedOutput function for testing.
func PipeCombinedOutput(ctx context.Context, file *os.File, acc *bytes.Buffer, readers ...io.ReadCloser) error {
    return pipeCombinedOutput(ctx, file, acc, readers...)
}