package main

import (
	"fmt"
	"flag"
	"io/ioutil"
	"os"
	"log"

	"github.com/coreos/coreos-cloudinit/cloudinit"
)

const version = "0.1.0+git"

func main() {
	var userdata []byte
	var err error

	var printVersion bool
	flag.BoolVar(&printVersion, "version", false, "Print the version and exit")

	var file string
	flag.StringVar(&file, "from-file", "", "Read user-data from provided file")

	var url string
	flag.StringVar(&url, "from-url", "", "Download user-data from provided url")

	var workspace string
	flag.StringVar(&workspace, "workspace", "/var/lib/coreos-cloudinit", "Base directory coreos-cloudinit should use to store data")

	flag.Parse()

	if printVersion == true {
		fmt.Printf("coreos-cloudinit version %s\n", version)
		os.Exit(0)
	}

	if file != "" && url != "" {
		fmt.Println("Provide one of --from-file or --from-url")
		os.Exit(1)
	}

	if file != "" {
		log.Printf("Reading user-data from file: %s", file)
		userdata, err = ioutil.ReadFile(file)
		if err != nil {
			log.Fatal(err.Error())
		}
	} else if url != "" {
		log.Printf("Reading user-data from metadata service")
		svc := cloudinit.NewMetadataService(url)
		userdata, err = svc.UserData()
		if err != nil {
			log.Fatal(err.Error())
		}
	} else {
		fmt.Println("Provide one of --from-file or --from-url")
		os.Exit(1)
	}

	parsed, err := cloudinit.ParseUserData(userdata)
	if err != nil {
		log.Fatalf("Failed parsing user-data: %v", err)
	}

	err = cloudinit.PrepWorkspace(workspace)
	if err != nil {
		log.Fatalf("Failed preparing workspace: %v", err)
	}

	switch t := parsed.(type) {
	case cloudinit.CloudConfig:
		err = cloudinit.ResolveCloudConfig(t)
	case cloudinit.Script:
		var path string
		path, err = cloudinit.PersistScriptInWorkspace(t, workspace)
		if err == nil {
			err = cloudinit.ExecuteScript(path)
		}
	}

	if err != nil {
		log.Fatalf("Failed resolving user-data: %v", err)
	}
}