package common

import (
	"fmt"
	"io"
	"io/ioutil"
	"testing"

	"github.com/anchore/imgbom/imgbom/pkg"
	"github.com/anchore/imgbom/internal"
	"github.com/anchore/stereoscope/pkg/file"
)

type testResolver struct {
	contents map[file.Reference]string
}

func newTestResolver() *testResolver {
	return &testResolver{
		contents: make(map[file.Reference]string),
	}
}

func (r *testResolver) FilesByPath(paths ...file.Path) ([]file.Reference, error) {
	results := make([]file.Reference, len(paths))

	for idx, p := range paths {
		results[idx] = file.NewFileReference(p)
		r.contents[results[idx]] = fmt.Sprintf("%s file contents!", p)
	}

	return results, nil
}

func (r *testResolver) FilesByGlob(patterns ...string) ([]file.Reference, error) {
	path := "/a-path.txt"
	ref := file.NewFileReference(file.Path(path))
	r.contents[ref] = fmt.Sprintf("%s file contents!", path)
	return []file.Reference{ref}, nil
}

func parser(_ string, reader io.Reader) ([]pkg.Package, error) {
	contents, err := ioutil.ReadAll(reader)
	if err != nil {
		panic(err)
	}
	return []pkg.Package{
		{
			Name: string(contents),
		},
	}, nil
}

func TestGenericCataloger(t *testing.T) {

	globParsers := map[string]ParserFn{
		"**a-path.txt": parser,
	}
	pathParsers := map[string]ParserFn{
		"/another-path.txt": parser,
		"/last/path.txt":    parser,
	}

	resolver := newTestResolver()
	cataloger := NewGenericCataloger(pathParsers, globParsers)

	selected := cataloger.SelectFiles(resolver)

	if len(selected) != 3 {
		t.Fatalf("unexpected selection length: %d", len(selected))
	}

	expectedSelection := internal.NewStringSetFromSlice([]string{"/last/path.txt", "/another-path.txt", "/a-path.txt"})
	selectionByPath := make(map[string]file.Reference)
	for _, s := range selected {
		if !expectedSelection.Contains(string(s.Path)) {
			t.Errorf("unexpected selection path: %+v", s.Path)
		}
		selectionByPath[string(s.Path)] = s
	}

	upstream := "some-other-cataloger"
	expectedPkgs := make(map[file.Reference]pkg.Package)
	for path, ref := range selectionByPath {
		expectedPkgs[ref] = pkg.Package{
			FoundBy: upstream,
			Source:  []file.Reference{ref},
			Name:    fmt.Sprintf("%s file contents!", path),
		}
	}

	actualPkgs, err := cataloger.Catalog(resolver.contents, upstream)
	if err != nil {
		t.Fatalf("cataloger catalog action failed: %+v", err)
	}

	if len(actualPkgs) != len(expectedPkgs) {
		t.Fatalf("unexpected packages len: %d", len(actualPkgs))
	}

	for _, p := range actualPkgs {
		ref := p.Source[0]
		exP, ok := expectedPkgs[ref]
		if !ok {
			t.Errorf("missing expected pkg: ref=%+v", ref)
			continue
		}

		if p.FoundBy != exP.FoundBy {
			t.Errorf("bad upstream: %s", p.FoundBy)
		}

		if exP.Name != p.Name {
			t.Errorf("bad contents mapping: %+v", p.Source)
		}
	}
}