main.go

package main

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

	"github.com/cryptix/goPshdlRest/api"
)

const widFname = ".wid"

var (
	streamVHDL = flag.Bool("vhdl", false, "download generated vhdl")
	streamCSim = flag.Bool("csim", false, "download generated C Simulation code")
)

func main() {
	flag.Parse()

	if flag.NArg() != 0 {
		log.Fatal(`
		This automatically fetches changes to the workspace.

		Use these flags to download the wanted files.
		-vhdl 	For generated VHDL
		-csim 	For generated C Simulation
		`)
	}

	if *streamCSim {
		log.Println("Csim download active")
	}

	if *streamVHDL {
		log.Println("VHDL download active")
	}

	widStat, widStatErr := os.Stat(widFname)

	if os.IsNotExist(widStatErr) {
		log.Fatal("No .wid file")
	}

	if !widStat.Mode().IsRegular() {

	}
	wid, err := ioutil.ReadFile(widFname)
	if err != nil {
		log.Fatalf("Error: %s\n", err)
	}

	// TODO: pshdlApi.OpenWorkspace()
	client := pshdlApi.NewClientWithID(nil, string(wid[:16]))

	evChan, err := client.Streaming.OpenEventStream()
	if err != nil {
		log.Fatalf("Error: %s\n", err)
	}
	log.Println("EventStream open. PID:", os.Getpid())

	if err = client.Streaming.SendClientConnected(); err != nil {
		log.Fatalf("Error: %s\n", err)
	}

	for ev := range evChan {
		subj := ev.GetSubject()
		log.Println("[R]", subj)

		switch {

		case strings.HasPrefix(subj, "P:WORKSPACE:"):
			for _, file := range ev.GetFiles() {
				log.Printf("[*] %s\n", file.RelPath)
			}

		case subj == "P:COMPILER:VHDL" && *streamVHDL:
			err = client.Workspace.DownloadRecords(ev.GetFiles())
			if err != nil {
				log.Fatalf("Workspace.DownloadRecords() Error:. %s", err)
				break
			}
			log.Println("[*] VHDL Download finished..")

		case subj == "P:COMPILER:C" && *streamCSim:
			err = client.Workspace.DownloadRecords(ev.GetFiles())
			if err != nil {
				log.Fatalf("Could not load all files. %s", err)
				break
			}
			log.Println("[*] CSim Download finished..")
		}

	}
}