2017-03-07 09:45:14 +01:00
|
|
|
package task
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"fmt"
|
|
|
|
|
"io/ioutil"
|
2017-06-16 11:24:01 -03:00
|
|
|
"path/filepath"
|
2017-03-07 09:45:14 +01:00
|
|
|
"runtime"
|
|
|
|
|
|
|
|
|
|
"github.com/imdario/mergo"
|
|
|
|
|
"gopkg.in/yaml.v2"
|
|
|
|
|
)
|
|
|
|
|
|
2017-12-29 18:27:32 -02:00
|
|
|
// Taskfile represents a Taskfile.yml
|
|
|
|
|
type Taskfile struct {
|
|
|
|
|
// TODO: version is still not used
|
|
|
|
|
Version int
|
|
|
|
|
Tasks Tasks
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// UnmarshalYAML implements yaml.Unmarshaler interface
|
|
|
|
|
func (tf *Taskfile) UnmarshalYAML(unmarshal func(interface{}) error) error {
|
|
|
|
|
if err := unmarshal(&tf.Tasks); err == nil {
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var taskfile struct {
|
|
|
|
|
Version int
|
|
|
|
|
Tasks Tasks
|
|
|
|
|
}
|
|
|
|
|
if err := unmarshal(&taskfile); err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
tf.Version = taskfile.Version
|
|
|
|
|
tf.Tasks = taskfile.Tasks
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
2017-06-04 16:02:04 -03:00
|
|
|
// ReadTaskfile parses Taskfile from the disk
|
|
|
|
|
func (e *Executor) ReadTaskfile() error {
|
2017-06-16 11:24:01 -03:00
|
|
|
path := filepath.Join(e.Dir, TaskFilePath)
|
|
|
|
|
|
2017-06-04 16:02:04 -03:00
|
|
|
var err error
|
2017-12-29 18:27:32 -02:00
|
|
|
e.Taskfile, err = e.readTaskfileData(path)
|
2017-03-07 09:45:14 +01:00
|
|
|
if err != nil {
|
2017-06-04 16:02:04 -03:00
|
|
|
return err
|
2017-03-07 09:45:14 +01:00
|
|
|
}
|
2017-06-04 16:02:04 -03:00
|
|
|
|
2017-06-16 11:24:01 -03:00
|
|
|
osTasks, err := e.readTaskfileData(fmt.Sprintf("%s_%s", path, runtime.GOOS))
|
2017-03-07 09:45:14 +01:00
|
|
|
if err != nil {
|
|
|
|
|
switch err.(type) {
|
|
|
|
|
case taskFileNotFound:
|
2017-06-04 16:02:04 -03:00
|
|
|
default:
|
|
|
|
|
return err
|
2017-03-07 09:45:14 +01:00
|
|
|
}
|
2017-12-29 18:27:32 -02:00
|
|
|
} else {
|
|
|
|
|
if err := mergo.MapWithOverwrite(&e.Taskfile.Tasks, osTasks.Tasks); err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
2017-03-07 09:45:14 +01:00
|
|
|
}
|
2017-12-29 18:27:32 -02:00
|
|
|
for name, task := range e.Taskfile.Tasks {
|
2017-09-16 11:44:13 -03:00
|
|
|
task.Task = name
|
|
|
|
|
}
|
|
|
|
|
|
2017-07-08 15:10:01 -03:00
|
|
|
return e.readTaskvars()
|
2017-03-07 09:45:14 +01:00
|
|
|
}
|
|
|
|
|
|
2017-12-29 18:27:32 -02:00
|
|
|
func (e *Executor) readTaskfileData(path string) (*Taskfile, error) {
|
2017-03-07 09:45:14 +01:00
|
|
|
if b, err := ioutil.ReadFile(path + ".yml"); err == nil {
|
2017-12-29 18:27:32 -02:00
|
|
|
var taskfile Taskfile
|
|
|
|
|
return &taskfile, yaml.UnmarshalStrict(b, &taskfile)
|
2017-03-07 09:45:14 +01:00
|
|
|
}
|
|
|
|
|
return nil, taskFileNotFound{path}
|
|
|
|
|
}
|
2017-07-03 21:16:10 -03:00
|
|
|
|
2017-07-08 15:10:01 -03:00
|
|
|
func (e *Executor) readTaskvars() error {
|
2017-07-15 13:46:35 -03:00
|
|
|
var (
|
|
|
|
|
file = filepath.Join(e.Dir, TaskvarsFilePath)
|
|
|
|
|
osSpecificFile = fmt.Sprintf("%s_%s", file, runtime.GOOS)
|
|
|
|
|
)
|
2017-07-03 21:16:10 -03:00
|
|
|
|
|
|
|
|
if b, err := ioutil.ReadFile(file + ".yml"); err == nil {
|
2017-07-15 13:36:22 -03:00
|
|
|
if err := yaml.UnmarshalStrict(b, &e.taskvars); err != nil {
|
2017-07-03 21:16:10 -03:00
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
}
|
2017-07-15 13:46:35 -03:00
|
|
|
|
|
|
|
|
if b, err := ioutil.ReadFile(osSpecificFile + ".yml"); err == nil {
|
|
|
|
|
osTaskvars := make(Vars, 10)
|
|
|
|
|
if err := yaml.UnmarshalStrict(b, &osTaskvars); err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
for k, v := range osTaskvars {
|
|
|
|
|
e.taskvars[k] = v
|
|
|
|
|
}
|
|
|
|
|
}
|
2017-07-03 21:16:10 -03:00
|
|
|
return nil
|
|
|
|
|
}
|