package fiko_socket_io

import (
	"fmt"
	"reflect"
	FikoYTMap "server/sistem/fikoyt_map"
	"time"

	"github.com/gofiber/fiber/v3"
	"github.com/gofiber/fiber/v3/middleware/adaptor"
	EIOLog "github.com/zishang520/engine.io/v2/log"
	"github.com/zishang520/engine.io/v2/types"
	"github.com/zishang520/socket.io/v2/socket"
)

var FikoSocketIo *socket.Server

func Ayarla(app *fiber.App) {
	EIOLog.DEBUG = true
	socketioSettings := socket.DefaultServerOptions()
	socketioSettings.SetServeClient(true)
	// c.SetConnectionStateRecovery(&socket.ConnectionStateRecovery{})
	socketioSettings.SetAllowEIO3(true)
	socketioSettings.SetAllowUpgrades(true)
	socketioSettings.SetTransports(types.NewSet("polling", "websocket", "webtransport"))

	socketioSettings.SetPingInterval(2000 * time.Millisecond)
	socketioSettings.SetPingTimeout(2000 * time.Millisecond)
	socketioSettings.SetMaxHttpBufferSize(1000000)
	socketioSettings.SetConnectTimeout(3000 * time.Millisecond)
	socketioSettings.SetCors(&types.Cors{
		Origin:      "*",
		Credentials: true,
	})
	FikoSocketIo = socket.NewServer(nil, nil)

	FikoSocketIo.On("connection", func(clients ...interface{}) {
		client := clients[0].(*socket.Socket)

		// fmt.Println(clients...)
		client.Use(func(a []any, next func(error)) {
			//  delete(a[0].(map[string]interface{}), "deviceUuid")

			fmt.Println("Burada----->", a)
			if reflect.TypeOf(a[len(a)-2]).Kind() == reflect.Map {
				if hasKey(a[1], "FikoYT") {
					fmt.Println("Burada----->", a[1], len(a))
					if reflect.TypeOf(a[len(a)-2]).Kind() != reflect.Map || !reflect.ValueOf(a[len(a)-2]).MapIndex(reflect.ValueOf("FikoYT")).IsValid() {
						// Yeni bir map ekle
						a[len(a)-2] = FikoYTMap.FikoYTMap{"FikoYT": FikoYTMap.FikoYTMap{"kid": nil, "cihaz_kimlik": nil}}
						// a = append(a[:1], a[2:]...)
					}
					//
				}
			}
			// a = ensureSecondLastIncludesFikoYTMap(a)

			next(nil)
		})
		ClientBaglandi(client)
	})

	//
	app.Get("/socket.io/", adaptor.HTTPHandler(FikoSocketIo.ServeHandler(socketioSettings)))
	app.Post("/socket.io/", adaptor.HTTPHandler(FikoSocketIo.ServeHandler(socketioSettings)))

	// FikoSocketIo.Use(func(socket *socket.Socket, next func(*socket.ExtendedError)) {
	// 	fmt.Println(socket.Request().Headers())
	// 	next(nil)
	// })
	// FikoSocketIo.FetchSockets()
}

func ClientBaglandi(client *socket.Socket) {
	// log.Println("Base İo Client Connect", client.Id())

	// client.On("message", func(args ...interface{}) {
	// 	client.Emit("message-back", args...)
	// 	log.Println(args)

	// })

	// client.On("disconnect", func(clients ...interface{}) {
	// 	// log.Println("Base İo Client Disconnect", client.Id())
	// })

}