package main

import (
	"fmt"
	"github.com/ProjectSegfault/publapi/pages"
	"github.com/gofiber/fiber/v2"
	log "github.com/sirupsen/logrus"
	"gopkg.in/yaml.v3"
	"io/ioutil"
	"os"
	"os/exec"
	"runtime"

	"strings"
)

type Userstruct struct {
	Status int
	Online int
	Users  []Userinfo
}
type Userinfo struct {
	name     string
	fullname string
	loc      string
	email    string
	desc     string
	website  string
	capsule  string
	online   string
}

func Dedup(input string) string {
	unique := []string{}

	words := strings.Split(input, " ")
	for _, word := range words {
		// If we alredy have this word, skip.
		if contains(unique, word) {
			continue
		}

		unique = append(unique, word)
	}

	return strings.Join(unique, " ")
}

func contains(strs []string, str string) bool {
	for _, s := range strs {
		if s == str {
			return true
		}
	}
	return false
}

func confparse(username, item string) string {
	filename := "/home/" + username + "/meta-info.yaml"
	file, err := ioutil.ReadFile(filename)
	if err != nil {
		log.Error(err)
	}
	parsedData := make(map[interface{}]interface{})
	err2 := yaml.Unmarshal(file, &parsedData)
	if err2 != nil {
		log.Error(err2)
	}
	val, err3 := parsedData[item].(string)
	if !err3 {
		log.Error(err3)
	}
	return val
}
func userdata(username string) Userinfo {
	var user Userinfo
	user.name = confparse(username, "name")
	user.fullname = confparse(username, "fullname")
	user.capsule = confparse(username, "capsule")
	user.website = confparse(username, "website")
	user.desc = confparse(username, "desc")
	user.email = confparse(username, "email")
	user.loc = confparse(username, "loc")
	//fmt.Println(user)
	return user
}

// publapi is a simple API for Project Segfault's public shared server (pubnix).
func main() {
	app := fiber.New()

	app.Get("/", func(c *fiber.Ctx) error {
		return c.JSON(fiber.Map{
			"message": "welcome to publapi",
			"status":  c.Response().StatusCode(),
		})
	})

	app.Get("/online", func(c *fiber.Ctx) error {
		if runtime.GOOS == "windows" {
			return c.JSON(fiber.Map{
				"message": "/online is not supported on Windows",
				"status":  c.Response().StatusCode(),
			})
		}
		// Get the number of users online
		usersonline, err := exec.Command("bash", "-c", "/usr/bin/users").Output()
		usersonlinestr := string(usersonline)
		usersonlinededup := Dedup(usersonlinestr)
		outputa := int(strings.Count(usersonlinededup, " "))
		var output int = 0
		output = outputa + 1
		if err != nil {
			log.Error(err)
		}
		users, err2 := exec.Command("bash", "-c", "/usr/bin/ls /home").Output()
		if err2 != nil {
			log.Error(err2)
		}
		userstr := string(users)
		userstr2 := strings.TrimSuffix(userstr, "\n")
		usersarr := strings.Split(userstr2, "\n")
		//var userinfoarr []interface{}
		var userinfostruct []Userinfo
		for i := 0; i < len(usersarr); i++ {
			uname := string(usersarr[i])
			userinfostruct = append(userinfostruct, userdata(uname))
		}
		data := Userstruct{
			Status: c.Response().StatusCode(),
			Online: output,
			Users:  userinfostruct,
		}
		return c.JSON(data)
	})

	app.Post("/signup", pages.SignupPage)

	app.Listen(GetPort())
}

// GetPort returns the port to listen on
func GetPort() string {
	port := os.Getenv("PUBLAPI_PORT")
	if port == "" {
		port = "3000"
	}
	return ":" + port
}