// replication-manager - Replication Manager Monitoring and CLI for MariaDB
// Authors: Guillaume Lefranc <[email protected]>
//          Stephane Varoqui  <[email protected]>
// This source code is licensed under the GNU General Public License, version 3.
// Redistribution/Reuse of this code is permitted under the GNU v3 license, as
// an additional term, ALL code must carry the original Author(s) credit in comment form.
// See LICENSE in this directory for the integral text.

// display.go
package main

import (
	"fmt"
	"io"
	"log"
	"time"

	"github.com/nsf/termbox-go"
)

func display() {
	termbox.Clear(termbox.ColorWhite, termbox.ColorBlack)
	headstr := fmt.Sprintf(" MariaDB Replication Monitor and Health Checker version %s ", repmgrVersion)
	if cfgGroup != "" {
		headstr += fmt.Sprintf("| Group: %s", cfgGroup)
	}
	if conf.Interactive == false {
		headstr += " |  Mode: Automatic "
	} else {
		headstr += " |  Mode: Manual "
	}
	printfTb(0, 0, termbox.ColorWhite, termbox.ColorBlack|termbox.AttrReverse|termbox.AttrBold, headstr)
	printfTb(0, 2, termbox.ColorWhite|termbox.AttrBold, termbox.ColorBlack, "%15s %6s %15s %10s %12s %20s %20s %30s %6s %3s", "Host", "Port", "Status", "Failures", "Using GTID", "Current GTID", "Slave GTID", "Replication Health", "Delay", "RO")
	tlog.Line = 3
	for _, server := range servers {
		// server.refresh()
		var gtidCurr string
		var gtidSlave string
		if server.CurrentGtid != nil {
			gtidCurr = server.CurrentGtid.Sprint()
		} else {
			gtidCurr = ""
		}
		if server.SlaveGtid != nil {
			gtidSlave = server.SlaveGtid.Sprint()
		} else {
			gtidSlave = ""
		}
		repHeal := server.replicationCheck()
		var fgCol termbox.Attribute
		switch server.State {
		case "Master":
			fgCol = termbox.ColorGreen
		case "Failed":
			fgCol = termbox.ColorRed
		case "Unconnected":
			fgCol = termbox.ColorBlue
		case "Suspect":
			fgCol = termbox.ColorMagenta
		case "SlaveErr":
			fgCol = termbox.ColorMagenta
		case "SlaveLate":
			fgCol = termbox.ColorYellow
		default:
			fgCol = termbox.ColorWhite
		}
		printfTb(0, tlog.Line, fgCol, termbox.ColorBlack, "%15s %6s %15s %10d %12s %20s %20s %30s %6d %3s", server.Host, server.Port, server.State, server.FailCount, server.UsingGtid, gtidCurr, gtidSlave, repHeal, server.Delay.Int64, server.ReadOnly)
		tlog.Line++
	}
	tlog.Line++
	if master != nil {
		if master.State != stateFailed {
			printTb(0, tlog.Line, termbox.ColorWhite, termbox.ColorBlack, " Ctrl-Q to quit, Ctrl-S to switchover")
		} else {
			printTb(0, tlog.Line, termbox.ColorWhite, termbox.ColorBlack, " Ctrl-Q to quit, Ctrl-F to failover")
		}
	}
	tlog.Line = tlog.Line + 3
	tlog.Print()
	if !conf.Daemon {
		termbox.Flush()
		_, newlen := termbox.Size()
		if newlen == 0 {
			// pass
		} else if newlen > termlength {
			termlength = newlen
			tlog.Len = termlength - 9 - (len(hostList) * 3)
			tlog.Extend()
		} else if newlen < termlength {
			termlength = newlen
			tlog.Len = termlength - 9 - (len(hostList) * 3)
			tlog.Shrink()
		}
	}
}

func displayHelp() {
	logprint("HELP : Ctrl-D  Print debug information")
	logprint("HELP : Ctrl-F  Manual Failover")
	logprint("HELP : Ctrl-I  Toggle automatic/manual failover mode")
	logprint("HELP : Ctrl-R  Set slaves read-only")
	logprint("HELP : Ctrl-S  Switchover")
	logprint("HELP : Ctrl-Q  Quit")
	logprint("HELP : Ctrl-W  Set slaves read-write")
}

func printTb(x, y int, fg, bg termbox.Attribute, msg string) {
	for _, c := range msg {
		termbox.SetCell(x, y, c, fg, bg)
		x++
	}
}

func printfTb(x, y int, fg, bg termbox.Attribute, format string, args ...interface{}) {
	s := fmt.Sprintf(format, args...)
	printTb(x, y, fg, bg, s)
}

func logprint(msg ...interface{}) {
	stamp := fmt.Sprint(time.Now().Format("2006/01/02 15:04:05"))
	if conf.LogFile != "" {
		s := fmt.Sprint(stamp, " ", fmt.Sprint(msg...))
		io.WriteString(logPtr, fmt.Sprintln(s))
	}
	if tlog.Len > 0 {
		tlog.Add(fmt.Sprint(msg...))
		display()
	}
	if conf.Daemon {
		log.Println(msg...)
	}
}

func logprintf(format string, args ...interface{}) {
	if conf.LogFile != "" {
		f := fmt.Sprintln(fmt.Sprint(time.Now().Format("2006/01/02 15:04:05")), format)
		io.WriteString(logPtr, fmt.Sprintf(f, args...))
	}
	if tlog.Len > 0 {
		tlog.Add(fmt.Sprintf(format, args...))
		display()
	}
	if conf.Daemon {
		log.Printf(format, args...)
	}
}