pas/main.go

package pas

import (
	"bufio"
	"log"
	"net"
	"strconv"
	"strings"

	"git.gay/exhq/pas/Constants"
	"git.gay/exhq/pas/helper"
	"git.gay/exhq/pas/parser"
)

func StartServer(port int, handler func(request Constants.Request, response func(Constants.Response)), errr error) error {
	ln, err := net.Listen("tcp", ":"+strconv.Itoa(port))
	if err != nil {
		return err
	}
	for {
		conn, err := ln.Accept()
		if err != nil {
			return err
		}
		go handleConnection(conn, handler)
	}
}

func handleConnection(conn net.Conn, handler func(request Constants.Request, response func(Constants.Response))) {
	defer conn.Close()
	raw, err := helper.ReadUntilNullString(bufio.NewReader(conn))
	if err != nil {
		log.Println(err)
		return
	}
	parsed := parser.ParseIntent(raw)
	body := strings.SplitN(raw, "\n\n", 2)
	if len(body) < 2 {
		conn.Write(helper.StringToByteWithEnd(helper.IntentGenerator(Constants.Response{OperationSuccessClassification: Constants.INTERNALSERVERERROR, ResponseHeader: map[string]string{}, Body: "shit you sent wasnt pas bruh"})))
		return
	}
	request := Constants.Request{Intent: parsed, Body: body[1]}

	handler(request, func(c Constants.Response) {
		conn.Write(helper.StringToByteWithEnd(helper.IntentGenerator(c)))
	})
}