Initial commit

Author: AFcPPe

Readme-CN.md

@@ -0,0 +1,49 @@
+
+# AdvancedFlightServer-Go
+
+[English Version](Readme.md)
+
+## 简介
+
+AdvancedFlightServer-Go 是一个用 Go 语言编写的模拟飞行联机服务器，支持 Swift、Echo、Euroscope 或其他自定义的客户端。
+
+## 特点
+
+- 更快的速度
+- 使用 FSD Version 3.000 Draft 9 协议
+- 使用 JSON 进行数据输出
+- 使用 PostgreSQL 数据库进行账户存储
+- 支持高并发
+- 跨平台支持（开发测试环境为 Windows 11 和 CentOS 8，理论上支持所有 Golang 支持的平台）
+- 解决了 FSD V3.000 Draft 9 在 Linux 系统运行时随机崩溃的问题
+- 自带的METAR数据源
+
+## 使用指南
+
+1. 使用 `go build AdvancedFlightServer/main` 进行编译。
+2. 运行编译后的可执行文件。
+3. 第一次运行程序会生成一个 `config.ini` 文件，请先关闭程序。
+4. 填写 `config.ini` 文件中的相关条目。
+5. 重新打开程序即可。
+
+## 开源许可
+
+本软件使用 AGPL v3.0 开源许可。
+
+## 贡献
+
+欢迎通过提交 PR 的方式为本代码库做出贡献。
+
+## 商业版本
+
+除了开源版本外，我们还提供商业版本，该版本具有以下特性：
+
+- 使用 Vatsim v3.4 协议
+- 支持管制员修改飞行计划
+- 支持 Euroscope 内置 ATIS
+- 支持管制员 INFO line 和 Logoff time
+- 支持 VisualPosition 刷新（飞机在地面上时，每 0.2 秒钟刷新一次位置信息）
+- 支持锁定飞行计划（管制员修改过的飞行计划自动锁定，直到下线）
+- 支持标牌操作记录等
+
+请注意，商业版本的详细信息和许可要求可能会有所不同。如有兴趣了解商业版本，请联系我们获取更多信息。

Readme.md

@@ -0,0 +1,48 @@
+# AdvancedFlightServer-Go
+
+[中文版](Readme-CN.md)
+
+## Introduction
+
+AdvancedFlightServer-Go is a flight simulation multiplayer server written in Go. It supports Swift, Echo, Euroscope or other custom clients.
+
+## Features
+
+- Faster speed
+- Uses FSD Version 3.000 Draft 9 protocol
+- Outputs data in JSON format
+- Stores accounts in PostgreSQL database
+- Supports high concurrency
+- Cross-platform support (developed and tested on Windows 11 and CentOS 8, theoretically supports all platforms supported by Golang)
+- Resolves the issue of random crashes when running FSD V3.000 Draft 9 on Linux systems
+- Built-in METAR data.
+
+## Usage Guide
+
+1. Compile the code using `go build AdvancedFlightServer/main`.
+2. Run the compiled executable.
+3. The program will generate a `config.ini` file on the first run. Close the program.
+4. Fill in the entries in the `config.ini` file.
+5. Reopen the program.
+
+## Open Source License
+
+This software is licensed under the AGPL v3.0.
+
+## Contribution
+
+Contributions to this codebase are welcome via pull requests.
+
+## Commercial Version
+
+In addition to the open-source version, we also offer a commercial version with the following features:
+
+- Uses Vatsim v3.4 protocol
+- Supports modification of flight plans by controllers
+- Supports Euroscope built-in ATIS
+- Supports INFO line and Logoff time for controllers
+- Supports VisualPosition refresh (refreshes position information every 0.2 seconds when the aircraft is on the ground)
+- Supports locking of flight plans (automatically locks modified flight plans until the controller goes offline)
+- Supports operation record of labels, and more
+
+Please note that the commercial version may have different details and licensing requirements. If you are interested in the commercial version, please contact us for more information.

config/Config.go

@@ -0,0 +1,38 @@
+package config
+
+import (
+	"AdvancedFlightServer/util"
+	"fmt"
+	"github.com/spf13/viper"
+	"log"
+)
+
+func defaultConfig() {
+	viper.SetDefault("server.port", 6809)
+	viper.SetDefault("db.addr", "127.0.0.1")
+	viper.SetDefault("db.port", 3306)
+	viper.SetDefault("db.username", "root")
+	viper.SetDefault("db.password", "123456")
+	viper.SetDefault("db.dbname", "flightserver")
+	viper.SetDefault("server.motd", fmt.Sprintf("Advanced Flight Server v%s. Open source by AFcPPe under CC-BY-NC-SA 4.0", util.Version))
+	viper.SetDefault("server.weather_url", "http://metar.flightsim.top/getall")
+	viper.SetDefault("server.output_dir", "./whazzup.json")
+	err := viper.SafeWriteConfigAs("config.ini")
+	if err != nil {
+		return
+	}
+}
+
+func ReadConfig() {
+	log.Println("Reading config file from config.ini...")
+	viper.SetConfigName("config")
+	viper.AddConfigPath(".")
+	defaultConfig()
+	err := viper.ReadInConfig()
+	if err != nil {
+		log.Println("Error while reading config file. Using default config.")
+		log.Fatal(err)
+		return
+	}
+
+}

main.go

@@ -0,0 +1,16 @@
+package main
+
+import (
+	"AdvancedFlightServer/config"
+	"AdvancedFlightServer/service"
+	"AdvancedFlightServer/tasks"
+	"AdvancedFlightServer/util"
+)
+
+func main() {
+	config.ReadConfig()
+	util.ConnectToDatabase()
+	util.SetupCron()
+	tasks.SetupCron()
+	service.StartServer()
+}

model/orm/User.go

@@ -0,0 +1,9 @@
+package orm
+
+type User struct {
+	Uid      int
+	Username string
+	Password string
+	Salt     string
+	Rating   int
+}

model/pdu/ATCPosition.go

@@ -0,0 +1,79 @@
+package pdu
+
+import (
+	"AdvancedFlightServer/model/server"
+	"fmt"
+	"strconv"
+	"strings"
+)
+
+type ATCPosition struct {
+	Base
+	Frequencies     []string
+	Facility        server.NetworkFacility
+	VisibilityRange int
+	Rating          server.NetworkRating
+	Lat             float64
+	Lon             float64
+}
+
+func NewPDUATCPosition(from string, freq []string, facility, visRange, rating int, lat, lon float64) *ATCPosition {
+	return &ATCPosition{
+		Base: Base{
+			From: from,
+			To:   "",
+		},
+		Frequencies:     freq,
+		Facility:        server.NetworkFacility(facility),
+		VisibilityRange: visRange,
+		Rating:          server.NetworkRating(rating),
+		Lat:             lat,
+		Lon:             lon,
+	}
+}
+
+func ATCPositionFromTokens(tokens []string) (*ATCPosition, error) {
+	if len(tokens) < 7 {
+		return nil, fmt.Errorf("PDUError tokens length < 7")
+	}
+	freq := strings.Split(tokens[1], "&")
+	facility, err := strconv.Atoi(tokens[2])
+	if err != nil {
+		return nil, err
+	}
+	visRange, err := strconv.Atoi(tokens[3])
+	if err != nil {
+		return nil, err
+	}
+	rating, err := strconv.Atoi(tokens[4])
+	if err != nil {
+		return nil, err
+	}
+	lat, err := strconv.ParseFloat(tokens[5], 64)
+	if err != nil {
+		return nil, err
+	}
+	lon, err := strconv.ParseFloat(tokens[6], 64)
+	if err != nil {
+		return nil, err
+	}
+	return NewPDUATCPosition(tokens[0], freq, facility, visRange, rating, lat, lon), nil
+}
+
+func (pdu *ATCPosition) ToTokens() []string {
+	freq := strings.Join(pdu.Frequencies, "&")
+	return []string{
+		pdu.From,
+		freq,
+		strconv.Itoa(int(pdu.Facility)),
+		strconv.Itoa(pdu.VisibilityRange),
+		strconv.Itoa(int(pdu.Rating)),
+		strconv.FormatFloat(pdu.Lat, 'f', -1, 64),
+		strconv.FormatFloat(pdu.Lon, 'f', -1, 64),
+		"0",
+	}
+}
+
+func (pdu *ATCPosition) GetHeader() string {
+	return "%"
+}

model/pdu/AddATC.go

@@ -0,0 +1,58 @@
+package pdu
+
+import (
+	"AdvancedFlightServer/model/server"
+	"fmt"
+	"strconv"
+)
+
+type AddATC struct {
+	Base
+	Callsign         string
+	Name             string
+	Cid              string
+	Password         string
+	Rating           server.NetworkRating
+	ProtocolRevision int
+}
+
+func NewPDUAddATC(from, to, name, cid, password string, rating int, protocolRevision int) *AddATC {
+	return &AddATC{
+		Base: Base{
+			From: from,
+			To:   to,
+		},
+		Callsign:         from,
+		Name:             name,
+		Cid:              cid,
+		Password:         password,
+		Rating:           server.NetworkRating(rating),
+		ProtocolRevision: protocolRevision,
+	}
+}
+
+func AddATCFromTokens(tokens []string) (*AddATC, error) {
+	if len(tokens) < 7 {
+		return nil, fmt.Errorf("invalid number of tokens")
+	}
+
+	rating, err := strconv.Atoi(tokens[5])
+	if err != nil {
+		return nil, fmt.Errorf("invalid rating value")
+	}
+
+	protocolRevision, err := strconv.Atoi(tokens[6])
+	if err != nil {
+		return nil, fmt.Errorf("invalid protocol revision value")
+	}
+
+	return NewPDUAddATC(tokens[0], tokens[1], tokens[2], tokens[3], tokens[4], rating, protocolRevision), nil
+}
+
+func (p *AddATC) ToTokens() []string {
+	return []string{p.Callsign, p.To, p.Name, p.Cid, p.Password, strconv.Itoa(int(p.Rating)), strconv.Itoa(p.ProtocolRevision)}
+}
+
+func (p *AddATC) GetHeader() string {
+	return "#AA"
+}

model/pdu/AddPilot.go

@@ -0,0 +1,70 @@
+package pdu
+
+import (
+	"AdvancedFlightServer/model/server"
+	"fmt"
+	"strconv"
+)
+
+type AddPilot struct {
+	Base
+	Callsign        string
+	Cid             string
+	Password        string
+	Rating          server.NetworkRating
+	ProtocolVersion int
+	RealName        string
+	SimType         string
+}
+
+func NewPDUAddPilot(from, to, cid, password string, networkRating, protocolVersion int, simType int, realName string) *AddPilot {
+	return &AddPilot{
+		Base: Base{
+			From: from,
+			To:   to,
+		},
+		Callsign:        from,
+		Cid:             cid,
+		Password:        password,
+		Rating:          server.NetworkRating(networkRating),
+		ProtocolVersion: protocolVersion,
+		RealName:        realName,
+		SimType:         strconv.Itoa(simType),
+	}
+}
+
+func AddPilotFromTokens(tokens []string) (*AddPilot, error) {
+	if len(tokens) < 8 {
+		return nil, fmt.Errorf("PDUError tokens length < 8")
+	}
+	networkRating, err := strconv.Atoi(tokens[4])
+	if err != nil {
+		return nil, err
+	}
+	protocolVersion, err := strconv.Atoi(tokens[5])
+	if err != nil {
+		return nil, err
+	}
+	simType, err := strconv.Atoi(tokens[6])
+	if err != nil {
+		return nil, err
+	}
+	return NewPDUAddPilot(tokens[0], tokens[1], tokens[2], tokens[3], networkRating, protocolVersion, simType, tokens[7]), nil
+}
+
+func (pdu *AddPilot) ToTokens() []string {
+	return []string{
+		pdu.From,
+		pdu.To,
+		pdu.Cid,
+		pdu.Password,
+		strconv.Itoa(int(pdu.Rating)),
+		strconv.Itoa(pdu.ProtocolVersion),
+		pdu.SimType,
+		pdu.RealName,
+	}
+}
+
+func (pdu *AddPilot) GetHeader() string {
+	return "#AP"
+}