package api

import (
	"bufio"
	"flag"
	"fmt"
	"log"
	"net/http"
	"os/exec"
	"strconv"
	"strings"

	"github.com/gin-gonic/gin"

	"git.nemunai.re/nemunaire/hathoris/config"
)

var cardId string = "0"

func init() {
	flag.StringVar(&cardId, "card-id", cardId, "ALSA card identifier for volume handling")
}

func declareVolumeRoutes(cfg *config.Config, router *gin.RouterGroup) {
	router.GET("/mixer", func(c *gin.Context) {
		cnt, err := parseAmixerContent()
		if err != nil {
			c.AbortWithStatusJSON(http.StatusInternalServerError, gin.H{"errmsg": err.Error()})
			return
		}

		var ret []*CardControlState

		for _, cc := range cnt {
			ret = append(ret, cc.ToCardControlState())
		}

		c.JSON(http.StatusOK, ret)
	})

	mixerRoutes := router.Group("/mixer/:mixer")
	mixerRoutes.Use(MixerHandler)

	mixerRoutes.GET("", func(c *gin.Context) {
		cc := c.MustGet("mixer").(*CardControl)

		c.JSON(http.StatusOK, cc.ToCardControlState())
	})
	mixerRoutes.POST("/values", func(c *gin.Context) {
		cc := c.MustGet("mixer").(*CardControl)

		var valuesINT []interface{}

		err := c.BindJSON(&valuesINT)
		if err != nil {
			c.AbortWithStatusJSON(http.StatusBadRequest, gin.H{"errmsg": fmt.Sprintf("Unable to parse values: %s", err.Error())})
			return
		}

		var values []string
		for _, v := range valuesINT {
			if t, ok := v.(float64); ok {
				if float64(int64(t)) == t {
					values = append(values, strconv.FormatInt(int64(t), 10))
				} else {
					values = append(values, fmt.Sprintf("%f", t))
				}
			} else if t, ok := v.(bool); ok {
				if t {
					values = append(values, "on")
				} else {
					values = append(values, "off")
				}
			}
		}

		err = cc.CsetAmixer(values...)
		if err != nil {
			c.AbortWithStatusJSON(http.StatusInternalServerError, gin.H{"errmsg": fmt.Sprintf("Unable to set values: %s", err.Error())})
			return
		}

		c.JSON(http.StatusOK, values)
	})
}

func MixerHandler(c *gin.Context) {
	mixers, err := parseAmixerContent()
	if err != nil {
		c.AbortWithStatusJSON(http.StatusInternalServerError, gin.H{"errmsg": err.Error()})
		return
	}

	mixer := c.Param("mixer")

	for _, m := range mixers {
		if strconv.FormatInt(m.NumID, 10) == mixer || m.Name == mixer {
			c.Set("mixer", m)
			c.Next()
			return
		}
	}

	c.AbortWithStatusJSON(http.StatusNotFound, gin.H{"errmsg": "Mixer not found"})
}

type CardControl struct {
	NumID     int64
	Interface string
	Name      string
	Type      string
	Access    string
	NValues   int64
	Min       int64
	Max       int64
	Step      int64
	DBScale   CardControldBScale
	Values    []string
	Items     []string
}

func (cc *CardControl) parseAmixerField(key, value string) (err error) {
	switch key {
	case "numid":
		cc.NumID, err = strconv.ParseInt(value, 10, 64)
	case "iface":
		cc.Interface = value
	case "name":
		cc.Name = strings.TrimPrefix(strings.TrimSuffix(value, "'"), "'")
	case "type":
		cc.Type = value
	case "access":
		cc.Access = value
	case "values":
		cc.NValues, err = strconv.ParseInt(value, 10, 64)
	case "min":
		cc.Min, err = strconv.ParseInt(value, 10, 64)
	case "max":
		cc.Max, err = strconv.ParseInt(value, 10, 64)
	case "step":
		cc.Step, err = strconv.ParseInt(value, 10, 64)
	}

	return
}

func (cc *CardControl) ToCardControlState() *CardControlState {
	ccs := &CardControlState{
		NumID: cc.NumID,
		Type:  cc.Type,
		Name:  cc.Name,
		RW:    strings.HasPrefix(cc.Access, "rw"),
		Items: cc.Items,
	}

	if cc.DBScale.Min != 0 || cc.DBScale.Step != 0 {
		ccs.DBScale = &cc.DBScale
	}

	// Convert values
	for _, v := range cc.Values {
		if cc.Type == "INTEGER" || cc.Type == "ENUMERATED" {
			if tmp, err := strconv.ParseFloat(v, 10); err == nil {
				ccs.Current = append(ccs.Current, tmp)
			}
		} else if cc.Type == "BOOLEAN" {
			if v == "on" {
				ccs.Current = append(ccs.Current, true)
			} else {
				ccs.Current = append(ccs.Current, false)
			}
		}
	}

	ccs.Min = cc.Min
	ccs.Max = cc.Max

	return ccs
}

type CardControldBScale struct {
	Min  float64
	Step float64
	Mute int64 `json:",omitempty"`
}

func (cc *CardControldBScale) parseAmixerField(key, value string) (err error) {
	switch key {
	case "min":
		cc.Min, err = strconv.ParseFloat(strings.TrimSuffix(value, "dB"), 10)
	case "step":
		cc.Step, err = strconv.ParseFloat(strings.TrimSuffix(value, "dB"), 10)
	case "mute":
		cc.Mute, err = strconv.ParseInt(value, 10, 64)
	}

	return
}

type CardControlState struct {
	NumID   int64
	Name    string
	Type    string
	RW      bool `json:"RW,omitempty"`
	Min     int64
	Max     int64
	DBScale *CardControldBScale `json:",omitempty"`
	Current []interface{}       `json:"values,omitempty"`
	Items   []string            `json:"items,omitempty"`
}

func parseAmixerContent() ([]*CardControl, error) {
	cmd := exec.Command("amixer", "-c", cardId, "-M", "contents")

	stdout, err := cmd.StdoutPipe()
	if err != nil {
		return nil, err
	}
	if err := cmd.Start(); err != nil {
		return nil, err
	}

	var ret []*CardControl

	fscanner := bufio.NewScanner(stdout)
	for fscanner.Scan() {
		line := fscanner.Text()

		if strings.HasPrefix(line, "  ; Item #") {
			cc := ret[len(ret)-1]
			cc.Items = append(cc.Items, strings.TrimSuffix(line[strings.Index(line, "'")+1:], "'"))
		} else if strings.HasPrefix(line, "  :") {
			cc := ret[len(ret)-1]
			line = strings.TrimPrefix(line, "  : ")

			kv := strings.SplitN(line, "=", 2)
			if kv[0] == "values" {
				cc.Values = strings.Split(kv[1], ",")
			}
		} else if strings.HasPrefix(line, "  |") || strings.HasPrefix(line, "    |") {
			cc := ret[len(ret)-1]
			line = strings.TrimSpace(line)
			if strings.HasPrefix(line, "| dBscale-") {
				line = strings.TrimPrefix(line, "| dBscale-")

				fields := strings.Split(line, ",")

				var scale CardControldBScale
				for _, field := range fields {
					kv := strings.SplitN(field, "=", 2)
					scale.parseAmixerField(kv[0], kv[1])
				}
				cc.DBScale = scale
			}
		} else {
			var cc *CardControl

			if strings.HasPrefix(line, "numid=") {
				cc = &CardControl{}
				ret = append(ret, cc)
			} else {
				cc = ret[len(ret)-1]
				line = strings.TrimPrefix(line, "  ; ")
			}

			fields := strings.Split(line, ",")

			for _, field := range fields {
				kv := strings.SplitN(field, "=", 2)
				cc.parseAmixerField(kv[0], kv[1])
			}
		}
	}

	err = cmd.Wait()
	return ret, err
}

func (cc *CardControl) CsetAmixer(values ...string) error {
	opts := []string{
		"-c",
		cardId,
		"-M",
		"cset",
		fmt.Sprintf("numid=%d", cc.NumID),
	}
	opts = append(opts, strings.Join(values, ","))
	log.Println(opts)
	cmd := exec.Command("amixer", opts...)

	if err := cmd.Start(); err != nil {
		return err
	}

	return cmd.Wait()
}