package main

import (
	"citrons.xyz/talk/client/client"
	"citrons.xyz/talk/client/object"
	"citrons.xyz/talk/client/buffer"
	"citrons.xyz/talk/proto"
	"citrons.xyz/talk/tui"
	"zgo.at/termfo/keys"
)

type application struct {
	client.Client
	reconnecting bool
	authenticated bool
	uid string
	cache object.ObjCache
	currentBuffer *buffer.Buffer
	cmdBuffer cmdBuffer
}

func newApplication(serverAddress string) *application {
	var app application
	app.Client = client.New(serverAddress)
	app.cache = object.NewCache(&app)
	app.cmdBuffer.Buffer = buffer.New("buffer")
	app.currentBuffer = &app.cmdBuffer.Buffer

	app.cmdBuffer.info("connecting to %s", app.Client.Address)
	return &app
}

func (a *application) OnConnect() {
	a.reconnecting = false
	a.cmdBuffer.info("connected to %s", a.Client.Address)

	a.auth("test user")
}

func (a *application) OnDisconnect(err error) {
	a.authenticated = false
	a.uid = ""
	if !a.reconnecting {
		a.cmdBuffer.err(
			"disconnected from %s: %s\nreconnecting...", a.Client.Address, err,
		)
		a.reconnecting = true
	}
}

func (a *application) OnEvent(cmd proto.Command) {
	switch cmd.Kind {
	case "update":
		if len(cmd.Args) > 0 {
			a.cache.Update(cmd.Target, cmd.Args[0])
		}
	case "delete":
		a.cache.Gone(cmd.Target)
	}
}

func (a *application) OnResponse(requestId string, cmd proto.Command) {
	switch cmd.Kind {
	case "you-are":
		if len(cmd.Args) > 0 {
			a.cmdBuffer.info("your name is: %s", cmd.Args[0].Fields[""])
		}
	}
}

func (a *application) Sub(id string) {
	a.Request(proto.NewCmd("s", id), func(cmd proto.Command) {
		if cmd.Kind == "i" && len(cmd.Args) > 0 {
			a.cache.Update(id, cmd.Args[0])
		}
	})
}

func (a *application) Unsub(id string) {
	a.Request(proto.NewCmd("u", id), nil)
}

func (a *application) GetInfo(id string, callback func(proto.Command)) {
	a.Request(proto.NewCmd("i", id), callback)
}

func (a *application) auth(name string) {
	callback := func(response proto.Command) {
		switch response.Kind {
		case "you-are":
			if len(response.Args) == 0 {
				break
			}
			me := response.Args[0]
			a.authenticated = true
			a.uid = me.Id
			a.cache.Watch(a.uid)
		case "fail":
			// todo
		}
	}
	a.Request(proto.NewCmd("auth", "", proto.Object {
		"anonymous", "", map[string]string {"": name},
	}), callback)
}

func (a *application) onInput(ev tui.Event) {
	a.currentBuffer.Scroll(-ev.Mouse.Scroll * 2)
	switch ev.Key {
	case keys.Up:
		a.currentBuffer.Scroll(1)
	case keys.Down:
		a.currentBuffer.Scroll(-1)
	}
}

func (a *application) show() {
	tui.Clear()
	s := tui.Size()
	tui.Push("", tui.Box {
		Width: tui.BoxSize(s.Width), Height: tui.BoxSize(s.Height),
	})
	a.currentBuffer.Show()
	tui.Pop()
	tui.DrawLayout()
	tui.Present()
}