hakurei/cmd/hpkg/proc.go

package main

import (
	"context"
	"encoding/json"
	"errors"
	"io"
	"log"
	"os"
	"os/exec"

	"hakurei.app/container"
	"hakurei.app/hst"
	"hakurei.app/internal"
)

var hakureiPath = internal.MustHakureiPath()

func mustRunApp(ctx context.Context, msg container.Msg, config *hst.Config, beforeFail func()) {
	var (
		cmd *exec.Cmd
		st  io.WriteCloser
	)

	if r, w, err := os.Pipe(); err != nil {
		beforeFail()
		log.Fatalf("cannot pipe: %v", err)
	} else {
		if msg.IsVerbose() {
			cmd = exec.CommandContext(ctx, hakureiPath.String(), "-v", "app", "3")
		} else {
			cmd = exec.CommandContext(ctx, hakureiPath.String(), "app", "3")
		}
		cmd.Stdin, cmd.Stdout, cmd.Stderr = os.Stdin, os.Stdout, os.Stderr
		cmd.ExtraFiles = []*os.File{r}
		st = w
	}

	go func() {
		if err := json.NewEncoder(st).Encode(config); err != nil {
			beforeFail()
			log.Fatalf("cannot send configuration: %v", err)
		}
	}()

	if err := cmd.Start(); err != nil {
		beforeFail()
		log.Fatalf("cannot start hakurei: %v", err)
	}
	if err := cmd.Wait(); err != nil {
		var exitError *exec.ExitError
		if errors.As(err, &exitError) {
			beforeFail()
			msg.BeforeExit()
			os.Exit(exitError.ExitCode())
		} else {
			beforeFail()
			log.Fatalf("cannot wait: %v", err)
		}
	}
}