package main

import (
	"encoding/json"
	"flag"
	"fmt"
	"io"
	"net"
	"os"
	"os/exec"
	"time"
)

type MPVRequest struct {
	Command []string `json:"command"`
}
type MPVResponse struct {
	Data string `json:"data"`
}

type MPV struct {
	cmd        *exec.Cmd
	socketPath string
}

func NewMPV(streamUrl string, socketPath string) MPV {
	return MPV{
		cmd:        exec.Command("mpv", fmt.Sprintf("--input-ipc-server=%s", socketPath), streamUrl),
		socketPath: socketPath,
	}
}

func (mpv *MPV) Spawn() error {
	mpv.cmd.Stdout = io.Discard
	mpv.cmd.Stderr = os.Stderr

	return mpv.cmd.Start()
}

func (mpv *MPV) Stop() error {
	return mpv.cmd.Process.Kill()
}

func (mpv *MPV) ExecuteIPC(req *MPVRequest) ([]byte, error) {
	reqBytes, err := json.Marshal(req)
	if err != nil {
		return nil, err
	}
	reqBytes = append(reqBytes, byte('\n'))

	conn, err := net.Dial("unix", mpv.socketPath)
	if err != nil {
		return nil, err
	}
	defer conn.Close()

	_, err = conn.Write(reqBytes)
	if err != nil {
		return nil, err
	}

	resBytes := make([]byte, 1024)
	n, err := conn.Read(resBytes)
	if err != nil {
		return nil, err
	}

	return resBytes[:n], nil
}

var testUrl string

func main() {
	flag.StringVar(&testUrl, "test-url", "", "test url")
	flag.Parse()

	mpv := NewMPV(testUrl, "/tmp/mptv3.sock")
	mpv.Spawn()
	defer mpv.Stop()

	time.Sleep(time.Second * 2)
	fmt.Println("EXECUTING IPC!!!!")
	res, err := mpv.ExecuteIPC(&MPVRequest{
		Command: []string{"get_property", "playback-time"},
	})

	fmt.Println(res, err)
}