trufflehog/pkg/common/test_helpers.go

package common

import (
	"errors"
	"fmt"
	"github.com/trufflesecurity/trufflehog/pkg/sources"
	"time"
)

type ChunkFunc func(chunk *sources.Chunk) error

var MatchError error = errors.New("chunk doesn't match")

func HandleTestChannel(chunksCh chan *sources.Chunk, cf ChunkFunc) error {
	for {
		select {
		case gotChunk := <-chunksCh:
			err := cf(gotChunk)
			if err != nil {
				if errors.Is(err, MatchError) {
					continue
				}
				return err
			}
			return nil
		case <-time.After(10 * time.Second):
			return fmt.Errorf("no new chunks recieved after 10 seconds")
		}
	}
}