factories.go

package age

import (
	"github.com/snivilised/pants"
)

// Walk requests a sequential traversal of a directory tree.
func Walk() NavigatorFactory {
	return &walkerFac{}
}

// Run requests a concurrent traversal of a directory tree.
func Run(wg pants.WaitGroup) NavigatorFactory {
	return &runnerFac{
		wg: wg,
	}
}

type factory struct {
}

type walkerFac struct {
	factory
}

func (f *walkerFac) Configure(addons ...Addon) Director {
	return director(func(bs *Builders) Navigator {
		artefacts, err := bs.buildAll(addons...)

		return &driver{
			session{
				sync: &sequential{
					trunk: trunk{
						kc:  artefacts.kc,
						o:   artefacts.o,
						ext: artefacts.ext,
						err: err,
					},
				},
				plugins: artefacts.plugins,
			},
		}
	})
}

type runnerFac struct {
	factory
	wg pants.WaitGroup
}

func (f *runnerFac) Configure(addons ...Addon) Director {
	return director(func(bs *Builders) Navigator {
		artefacts, err := bs.buildAll(addons...)

		return &driver{
			session{
				sync: &concurrent{
					trunk: trunk{
						kc:  artefacts.kc,
						o:   artefacts.o,
						ext: artefacts.ext,
						err: err,
					},
					wg:      f.wg,
					swapper: artefacts.swappable,
				},
				plugins: artefacts.plugins,
			},
		}
	})
}

type (
	Addon interface{}
)