startAndStopCommand.go

package main

import (
	"encoding/json"
	"fmt"
	"io/ioutil"
	"net/http"
	"os"

	"github.com/mkideal/cli"
)

type LocalServerCommand string

const (
	LocalServerStart LocalServerCommand = "start"
	LocalServerStop  LocalServerCommand = "stop"
)

func (command LocalServerCommand) String() string {
	switch command {
	case LocalServerStart:
		return "local:server:start --daemon"
	case LocalServerStop:
		return "local:server:stop"
	default:
		return ""
	}
}

type startT struct {
	cli.Helper
}

var startCommand = &cli.Command{
	Name: "start",
	Desc: "start all apps linked to your symfony binary",
	Argv: func() interface{} { return new(startT) },
	Fn: func(ctx *cli.Context) error {
		printHeader()
		startOrStopCommand(LocalServerStart, "started ✔")

		return nil
	},
}

type stopT struct {
	cli.Helper
}

var stopCommand = &cli.Command{
	Name: "stop",
	Desc: "stop all apps linked to your symfony binary",
	Argv: func() interface{} { return new(stopT) },
	Fn: func(ctx *cli.Context) error {
		printHeader()
		startOrStopCommand(LocalServerStop, "stopped 🛑")
		runCommand("symfony proxy:stop")

		return nil
	},
}

func startOrStopCommand(serverCommand LocalServerCommand, message string) {
	command := serverCommand.String()
	if command == "" {
		return
	}

	if false == symfonyProxyRunning() {
		runCommand("symfony proxy:start")
		fmt.Print("Started Symfony proxy server 👮\n")
	}

	symfonyProxyConfigPath := fmt.Sprintf("%s/proxy.json", getSymfonyCliConfigPath())
	if _, err := os.Stat(symfonyProxyConfigPath); os.IsNotExist(err) {
		fmt.Printf("Symfony proxy configuration does not exists 🙊. Maybe you should run %s before %s ? 🧐\n", yellow("init"), yellow("start"))
		return
	}
	file, _ := ioutil.ReadFile(symfonyProxyConfigPath)

	symfonyJSONData := SymfonyJSONProxy{}
	json.Unmarshal(file, &symfonyJSONData)

	for domain, path := range symfonyJSONData.Domains {
		forcedPort := symfonyJSONData.Ports[domain]
		formattedCommand := fmt.Sprintf("symfony %s --dir=%s", command, path)
		serverRunning := symfonyServerRunning(path)

		if (serverCommand == LocalServerStart && !serverRunning) || (serverCommand == LocalServerStop && serverRunning) {
			if serverCommand == LocalServerStart && forcedPort != 0 {
				formattedCommand = fmt.Sprintf("symfony %s --port=%d --dir=%s", command, forcedPort, path)
			}

			runCommand(formattedCommand)
		}

		fmt.Printf("%s %s\n", message, yellow(fmt.Sprintf("%s.%s", domain, symfonyJSONData.Tld)))
	}

	return
}

func symfonyProxyRunning() bool {
	response, err := http.Get("http://127.0.0.1:7080/")

	if nil != err || 200 != response.StatusCode {
		return false
	}

	return true
}

func symfonyServerRunning(path string) bool {
	grepNotRunning := " grep -A 1 'Local Web Server' | grep 'Not Running'"
	return len(outputCommand(fmt.Sprintf("symfony local:server:status --dir=%s | %s", path, grepNotRunning))) == 0
}