public class Main

{

// default settings

public const int DEFAULT_ACTIVITY_CIRCLE = 40;

public const int DEFAULT_FOLLOW_DISTANCE = 80;

const int MAX_INSTANCES = 4;

/// <summary>

/// Current version

/// </summary>

private static string version = "0.0.0";

// Version getter

public static string Version

{

get { return version; }

}

/// <summary>

/// Current name

/// </summary>

private static string name = "";

// Name getter

public static string Name

{

get { return name; }

}

/// <summary>

/// Storage path

/// </summary>

public string storagePath = ".";

/// <summary>

/// Documents path

/// </summary>

public string documentsPath = ".";

/// <summary>

/// Unique identifier for this installation

/// </summary>

public Guid guid = Guid.Empty;

public uint uuid = 0;

// modules

public Sim sim;

public Network network;

public Substitution substitution;

public Recorder recorder;

public AddressBook addressBook;

public Log log;

public Monitor monitor;

public Euroscope euroscope;

public Whazzup whazzup;

public Notes notes;

public Stats stats;

public VariableMgr variableMgr;

/// <summary>

/// Settings

/// </summary>

public bool settingsPortEnabled = false;

public ushort settingsPort = Network.DEFAULT_PORT;

public string settingsNickname = "";

public bool settingsConnectOnLaunch = false;

public int settingsActivityCircle = DEFAULT_ACTIVITY_CIRCLE;

public bool settingsAtc = false;

public string settingsAtcAirport = "";

public bool settingsHub = false;

public string settingsHubDomain = "";

public string settingsHubName = "";

public string settingsHubAbout = "";

public string settingsHubVoip = "";

public string settingsHubEvent = "";

public string settingsPassword = "";

public bool settingsWhazzup = false;

public bool settingsWhazzupPublic = false;

public bool settingsMultiObjects = false;

public bool settingsMinimized = false;

public bool settingsNoGui = false;

public bool settingsNoSim = false;

public bool settingsLoop = false;

public bool settingsXplane = false;

public bool settingsTcas = false;

public bool settingsScan = false;

public bool settingsUseAIFeatures = false;

#if XPLANE || CONSOLE

public bool settingsGenerateCsl = false;

public bool settingsSkipCsl = false;

#endif

public string settingsLocalAddress = "";

#if CONSOLE

public bool settingsBackground = false;

public string settingsComsWebhookUri = "";

public string settingsComsWebhookMethod = "PUT";

public bool settingsWebSocket = false;

public int settingsWebSocketPort = 8765;

public bool settingsWebSocketLog = false;

WebhookService webhookService;

WebSocketServer webSocketServer;

#endif

/// <summary>

/// shutdown JoinFS

/// </summary>

public string shutdown = null;

/// <summary>

/// Multithreading lock object

/// </summary>

public object conch = new();

/// <summary>

/// instance ID

/// </summary>

public int instanceCount = 1;

/// <summary>

/// Thread for updates

/// </summary>

private readonly Thread _workThread;

/// <summary>

/// Finish work flag

/// </summary>

public volatile bool workFinish = false;

/// <summary>

/// Close main

/// </summary>

public void Close()

{

// check for thread

if (_workThread != null)

{

// notify thread

workFinish = true;

_workThread.Join(5000);

}

// close systems

if (network != null)

{

// leave session

network.Leave();

// close network

network.localNode.Close();

// monitor

MonitorEvent("Closed UDP port " + network.localNode.GetLocalNuid().port);

}

sim ?. Close();

#if CONSOLE

webSocketServer?.Close();

#endif

// save settings

Settings.Default.Save();

}

// record time at launch

readonly Stopwatch stopwatch;

// get time since launch

public double ElapsedTime

{

get

{

return (double)stopwatch.ElapsedTicks / (double)Stopwatch.Frequency;

}

}

/// <summary>

/// Construct main

/// </summary>

public Main()

{

try

{

UpgradeSettingsIfRequired();

// get product name and file version

Assembly assembly = Assembly.GetExecutingAssembly();

// get name

name = assembly.GetName().Name;

// construct three part version number

FileVersionInfo info = FileVersionInfo.GetVersionInfo(assembly.Location);

version = info.FileMajorPart.ToString() + '.' + info.FileMinorPart.ToString() + '.' + info.FileBuildPart.ToString();

// get settings

settingsPortEnabled = Settings.Default.LocalPortEnabled;

settingsPort = Settings.Default.LocalPort;

settingsNickname = Settings.Default.Nickname;

settingsConnectOnLaunch = Settings.Default.ConnectOnLaunch;

settingsActivityCircle = Settings.Default.ActivityCircle;

settingsAtc = Settings.Default.Atc;

settingsAtcAirport = Settings.Default.AtcAirport.ToUpper();

settingsHub = Settings.Default.Hub;

settingsHubDomain = Settings.Default.HubAddress;

settingsHubName = Settings.Default.HubName;

settingsHubAbout = Settings.Default.HubAbout;

settingsHubVoip = Settings.Default.HubVoIP;

settingsHubEvent = Settings.Default.HubEvent;

settingsPassword = Settings.Default.Password;

settingsWhazzup = Settings.Default.Whazzup;

settingsWhazzupPublic = Settings.Default.WhazzupGlobal;

settingsMultiObjects = Settings.Default.MultipleObjectsEveryone;

settingsLoop = Settings.Default.Loop;

settingsXplane = Settings.Default.XPlane;

settingsTcas = Settings.Default.TCAS;

settingsScan = Settings.Default.ModelScanOnConnection;

settingsUseAIFeatures = Settings.Default.UseAIFeatures;

#if XPLANE || CONSOLE

settingsGenerateCsl = Settings.Default.GenerateCsl;

settingsSkipCsl = Settings.Default.SkipCsl;

#endif

#if SERVER

settingsNoSim = true;

#endif

#if XPLANE

settingsXplane = true;

#endif

// command line optins

bool doCreate = false;

string doJoin = null;

bool doGlobal = false;

string doPlay = "";

bool doRecord = false;

bool doQuit = false;

#if XPLANE || CONSOLE

bool doPlugin = false;

#endif

string simFolder = "";

// get command line

string[] args = Environment.GetCommandLineArgs();

// process command line

for (int index = 1; index < args.Length; index++)

{

// check for option

if (args[index].Length > 0 && args[index][0] == '-')

{

// handle -- type options as well

string option = args[index].StartsWith("--") ? args[index][1..] : args[index];

// process option

switch (option)

{

case "-play":

// next parameter

index++;

// check for file name

if (index < args.Length)

{

// play specified recording

doPlay = args[index];

}

break;

case "-record":

// start new recording

doRecord = true;

break;

case "-loop":

// enable looping

settingsLoop = true;

break;

case "-create":

// create network

doCreate = true;

break;

case "-rejoin":

// join network

doJoin = Settings.Default.JoinAddress;

break;

case "-join":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

// join network

doJoin = args[index];

}

break;

case "-port":

// next parameter

index++;

// check for file name

if (index < args.Length)

{

// get port

if (ushort.TryParse(args[index], NumberStyles.Number, CultureInfo.InvariantCulture, out settingsPort))

{

// use port

settingsPortEnabled = true;

}

}

break;

case "-hub":

// enable hub mode

settingsHub = true;

break;

case "-localaddress":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

settingsLocalAddress = args[index];

}

break;

case "-hubdomain":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

// update hub domain

settingsHubDomain = args[index];

}

break;

case "-hubname":

// next parameter

index++;

// check for parameter

if (index < args.Length && args[index].Length >= 3)

{

// update hub name

settingsHubName = args[index];

}

break;

case "-hubabout":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

// update hub about

settingsHubAbout = args[index];

}

break;

case "-hubvoip":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

// update hub voice server

settingsHubVoip = args[index];

}

break;

case "-hubevent":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

// update hub event

settingsHubEvent = args[index];

}

break;

case "-nickname":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

// update nickname

settingsNickname = args[index];

}

break;

case "-activitycircle":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

if (int.TryParse(args[index], NumberStyles.Number, CultureInfo.InvariantCulture, out int val))

{

// update activity circle

settingsActivityCircle = val;

}

}

break;

case "-follow":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

if (Int32.TryParse(args[index], NumberStyles.Number, CultureInfo.InvariantCulture, out int val))

{

// update follow distance

Settings.Default.FollowDistance = val;

}

}

break;

case "-atc":

// enable ATC mode

settingsAtc = true;

break;

case "-airport":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

// write airport

settingsAtcAirport = args[index][..Math.Min(4, args[index].Length)].ToUpper();

}

break;

case "-autobroadcast":

// update auto broadcast

Settings.Default.AutoBroadcast = true;

break;

case "-lowbandwidth":

// update low bandwidth enabled

Settings.Default.LowBandwidth = true;

break;

case "-minimize":

// minimize

settingsMinimized = true;

break;

case "-global":

doGlobal = true;

break;

case "-whazzup":

settingsWhazzup = true;

break;

case "-whazzup-public":

settingsWhazzup = true;

settingsWhazzupPublic = true;

break;

case "-nosim":

settingsNoSim = true;

settingsConnectOnLaunch = false;

break;

case "-nogui":

settingsNoGui = true;

break;

case "-quit":

doQuit = true;

settingsNoGui = true;

break;

case "-multiobjects":

settingsMultiObjects = true;

break;

case "-xplane":

settingsXplane = true;

break;

case "-tcas":

settingsTcas = true;

break;

case "-simfolder":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

// get sim folder

simFolder = args[index];

}

break;

#if XPLANE || CONSOLE

case "-installplugin":

// do plugin

doPlugin = true;

break;

#endif

case "-password":

// next parameter

index++;

// check for parameter

if (index < args.Length)

{

// get password

settingsPassword = args[index];

}

break;

case "-scan":

settingsScan = true;

break;

#if XPLANE || CONSOLE

case "-generatecsl":

settingsGenerateCsl = true;

break;

case "-skipcsldone":

settingsSkipCsl = true;

break;

#endif

#if CONSOLE

case "-background":

settingsBackground = true;

break;

case "-comswebhookuri":

index++;

if (index < args.Length) settingsComsWebhookUri = args[index];

break;

case "-comswebhookmethod":

index++;

if (index < args.Length) settingsComsWebhookMethod = args[index].ToUpper();

break;

case "-websocket":

settingsWebSocket = true;

break;

case "-websocketport":

index++;

if (index < args.Length && int.TryParse(args[index], out int wsPort)) settingsWebSocketPort = wsPort;

break;

case "-websocketlog":

settingsWebSocketLog = true;

break;

case "-help":

Console.WriteLine(name + " (" + version + ")");

Console.WriteLine("");

Console.WriteLine("Usage: dotnet " + name + ".dll [options]");

Console.WriteLine("");

Console.WriteLine(" --create " + Resources.Strings.Options_Create);

Console.WriteLine(" --join <address> " + Resources.Strings.Options_Join);

Console.WriteLine(" --rejoin " + Resources.Strings.Options_Rejoin);

Console.WriteLine(" --global " + Resources.Strings.Options_Global);

Console.WriteLine(" --nickname <name> " + Resources.Strings.Options_Nickname);

Console.WriteLine(" --port " + Resources.Strings.Options_Port);

Console.WriteLine(" --localaddress <ip> Override local network address (use host LAN IP when running in Docker)");

Console.WriteLine(" --hub " + Resources.Strings.Tip_HubMode);

Console.WriteLine(" --hubdomain <domain> " + Resources.Strings.Tip_HubDomain);

Console.WriteLine(" --hubname <name> " + Resources.Strings.Tip_HubName);

Console.WriteLine(" --hubabout <details> " + Resources.Strings.Tip_HubAbout);

Console.WriteLine(" --hubvoip <details> " + Resources.Strings.Tip_HubVoice);

Console.WriteLine(" --hubevent <details> " + Resources.Strings.Tip_HubEvent);

Console.WriteLine(" --password <password> " + Resources.Strings.Tip_Password);

Console.WriteLine(" --play <.jfs file> " + Resources.Strings.Options_Play);

Console.WriteLine(" --record " + Resources.Strings.Options_Record);

Console.WriteLine(" --loop " + Resources.Strings.Tip_Loop);

Console.WriteLine(" --activitycircle <nm> " + Resources.Strings.Options_ActivityCircle);

Console.WriteLine(" --follow <nm> " + Resources.Strings.Options_Follow);

Console.WriteLine(" --atc " + Resources.Strings.Options_Atc);

Console.WriteLine(" --airport <code> " + Resources.Strings.Options_Airport);

Console.WriteLine(" --lowbandwidth " + Resources.Strings.Tip_LowBandwidth);

Console.WriteLine(" --whazzup " + Resources.Strings.Tip_Whazzup);

Console.WriteLine(" --whazzup-public " + Resources.Strings.Tip_WhazzupGlobal);

Console.WriteLine(" --minimize " + Resources.Strings.Options_Minimize);

Console.WriteLine(" --background " + Resources.Strings.Options_Background);

Console.WriteLine(" --nosim " + Resources.Strings.Options_NoSim);

Console.WriteLine(" --nogui " + Resources.Strings.Options_NoGui);

Console.WriteLine(" --multiobjects " + Resources.Strings.Tip_MultiObjects);

Console.WriteLine(" --simfolder \"<folder>\" " + Resources.Strings.Options_SimFolder);

Console.WriteLine(" --scan " + Resources.Strings.ScanForModels);

Console.WriteLine(" --generatecsl " + Resources.Strings.Option_GenerateCsl);

Console.WriteLine(" --skipcsldone " + Resources.Strings.Option_SkipCsl);

Console.WriteLine(" --xplane " + Resources.Strings.Tip_Xplane);

Console.WriteLine(" --installplugin " + Resources.Strings.Options_InstallPlugin);

Console.WriteLine(" --tcas " + Resources.Strings.Tip_TCAS);

Console.WriteLine(" --quit " + Resources.Strings.Options_Quit);

Console.WriteLine(" --help " + Resources.Strings.Options_Help);

Console.WriteLine(" --comswebhookuri <uri> Send COM1/COM2 changes as webhook POST/PUT/PATCH/GET to this URI");

Console.WriteLine(" --comswebhookmethod HTTP method for COM webhook (POST|PUT|PATCH|GET, default PUT)");

Console.WriteLine(" --websocket Enable WebSocket server broadcasting aircraft data");

Console.WriteLine(" --websocketport <port> WebSocket server port (default 8765)");

Console.WriteLine(" --websocketlog Log WebSocket events and webhook calls (default false)");

Console.WriteLine("");

Console.WriteLine("Interactive key commands:");

Console.WriteLine("");

Console.WriteLine("S Show session details");

Console.WriteLine("A Show aircraft details");

Console.WriteLine("Escape Close JoinFS");

Console.WriteLine("Ctrl + N Toggle the network connection");

Console.WriteLine("Ctrl + S Toggle the simulator connection");

Console.WriteLine("Ctrl + Q Scan for models");

Console.WriteLine("");

Console.WriteLine("");

Console.WriteLine("Install the X-Plane plugin:");

Console.WriteLine("");

Console.WriteLine("dotnet " + name + ".dll --installplugin --simfolder \"<folder>\"");

throw new Exception();

#endif

}

}

}

// create stopwatch

stopwatch = Stopwatch.StartNew();

// get all JoinFS instances

Process[] instances = System.Diagnostics.Process.GetProcessesByName(System.IO.Path.GetFileNameWithoutExtension(System.Reflection.Assembly.GetEntryAssembly().Location));

// get this instance

Process thisInstance = System.Diagnostics.Process.GetCurrentProcess();

// check for quit

if (doQuit)

{

// for each instance

foreach (var instance in instances)

{

// check for this instance

if (instance.Id != thisInstance.Id)

{

// kill instance

instance.Kill();

}

}

// shutdown

shutdown = "";

}

// check for maximum instance count

if (instances.Length > MAX_INSTANCES)

{

// close

shutdown = Resources.Strings.MaxInstances;

}

try

{

// get storage path

storagePath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData), name);

// check if it does not exist

if (Directory.Exists(storagePath) == false)

{

// create storage path

Directory.CreateDirectory(storagePath);

}

// get documents path

documentsPath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments), name);

// check if it does not exist

if (Directory.Exists(documentsPath) == false)

{

// create storage path

Directory.CreateDirectory(documentsPath);

}

}

catch (Exception ex)

{

ShowMessage(ex.Message);

}

// read guid

try

{

// check for invalid guid

if (Settings.Default.LastPosition == Guid.Empty)

{

// generate new one

Settings.Default.LastPosition = Guid.NewGuid();

}

// get guid

guid = Settings.Default.LastPosition;

}

catch

{

// create new guid

guid = Guid.NewGuid();

// save guid

Settings.Default.LastPosition = guid;

}

#if !NO_HUBS

// four byte identifier

uuid = Network.MakeUuid(guid);

#endif

// create monitor module

monitor = new Monitor(this);

#if FS2020

MonitorEvent("Starting JoinFS-FS2020 v" + version);

#elif FS2024

MonitorEvent("Starting JoinFS-FS2024 v" + version);

#elif XPLANE

MonitorEvent("Starting JoinFS-XPLANE v" + version);

#elif P3D

MonitorEvent("Starting JoinFS-P3D v" + version);

#elif FSX

MonitorEvent("Starting JoinFS-FSX v" + version);

#elif SERVER

MonitorEvent("Starting JoinFS-SERVER v" + version);

#elif CONSOLE

MonitorEvent("Starting JoinFS-CONSOLE v" + version);

#else

MonitorEvent("Starting JoinFS v" + version);

#endif

// create modules

log = new Log(this);

sim = new Sim(this);

network = new Network(this);

#if !SERVER

substitution = new Substitution(this);

// try to resolve the simulator folder from the simulator's own recorded

// install location before ever asking the user - see SimPathDetector

#if FS2020

if (substitution.EnsureFoldersConfigured("Microsoft Flight Simulator 2020", out string fs2020SimName) == false)

{

scheduleSimFolderPrompt = true;

pendingSimFolderName = fs2020SimName;

}

// no eager scan here - the FS2020 addons list isn't loaded until the sim connects

#elif FS2024

if (substitution.EnsureFoldersConfigured("Microsoft Flight Simulator 2024", out string fs2024SimName) == false)

{

scheduleSimFolderPrompt = true;

pendingSimFolderName = fs2024SimName;

}

// no eager scan here - FS2024 community models come from a live SimConnect request

#elif FSX

if (substitution.EnsureFoldersConfigured("Microsoft Flight Simulator X", out string fsxSimName))

{

substitution.Scan(false, fsxSimName);

}

else

{

scheduleSimFolderPrompt = true;

pendingSimFolderName = fsxSimName;

}

#elif P3D

if (substitution.EnsureFoldersConfigured("Prepar3D v5", out string p3dSimName))

{

substitution.Scan(false, p3dSimName);

}

else

{

scheduleSimFolderPrompt = true;

pendingSimFolderName = p3dSimName;

}

#elif XPLANE

if (substitution.EnsureFoldersConfigured("X-Plane", out string xplaneSimName))

{

substitution.Scan(false, xplaneSimName);

}

else

{

scheduleSimFolderPrompt = true;

pendingSimFolderName = xplaneSimName;

}

#endif

#endif

recorder = new Recorder(this);

addressBook = new AddressBook(this);

euroscope = new Euroscope(this);

whazzup = new Whazzup(this);

notes = new Notes(this);

stats = new Stats();

variableMgr = new VariableMgr(this);

#if !CONSOLE

// fetch the pilot's SimBrief flight plan on startup if a username is already saved -

// this is a cloud API call independent of the simulator, so it doesn't need to wait for a connection

if (string.IsNullOrWhiteSpace(Settings.Default.SimBriefUsername) == false)

{

_ = sim.RefreshUserFlightPlanFromSimBriefAsync();

}

#endif

// check for specified sim folder

if (simFolder.Length > 0)

{

// initialize sim folder

substitution.LoadFolders();

substitution.simFolder = simFolder;

substitution.SaveFolders();

Settings.Default.XPlaneFolder = simFolder;

}

#if NO_CREATE

// disable hub mode

doCreate = false;

settingsHub = false;

#endif

#if CONSOLE

// disable nogui option

settingsNoGui = true;

#endif

// load airports

LoadAirportDetails();

// load log

log.Load();

#if XPLANE || CONSOLE

// check for xplane

if (settingsXplane)

{

// load substitution

ScheduleSubstitutionLoad();

}

// check for install plugin

if (doPlugin)

{

sim.xplane.InstallPlugin(Settings.Default.XPlaneFolder);

shutdown = "Finished plugin install.";

}

#endif

// port

ushort port = settingsPortEnabled ? settingsPort : Network.DEFAULT_PORT;

// open port

if (network.localNode.Open(port))

{

// monitor

MonitorEvent("Opened UDP port " + port);

if (settingsHub)

{

// monitor

MonitorEvent("Started hub '" + settingsHubName + "'");

}

}

// check for Hub mode enabled

if (doCreate || settingsHub)

{

// leave network

network.ScheduleLeave();

// create network

network.ScheduleCreate();

}

// check for join global option

if (doGlobal || Settings.Default.Global)

{

// auto join

network.ScheduleJoinGlobal();

}

// check for join option

if (doJoin != null)

{

// join network

#if NO_HUBS

Join(Network.DecodeIP(doJoin.TrimStart(' ').TrimEnd(' ')));

#else

Join(doJoin.TrimStart(' ').TrimEnd(' '));

#endif

}

// check for play option

if (doPlay != "")

{

// try to open file

try

{

StreamReader stream = new(doPlay);

if (stream != null)

{

// try to open file

BinaryReader reader = new(stream.BaseStream);

if (reader != null)

{

// read recording

recorder.Read(reader);

// start playing

recorder.StartPlay();

}

}

}

catch (Exception ex)

{

ShowMessage(ex.Message);

}

}

// check for record option

if (doRecord)

{

// start recording

recorder.StartRecord(false);

}

// monitor

MonitorEvent("Start complete");

// start work thread

_workThread = new Thread(new ThreadStart(DoWork));

_workThread.Start();

#if CONSOLE

webhookService = settingsComsWebhookUri.Length > 0 ? new WebhookService(this) : null;

webSocketServer = settingsWebSocket ? new WebSocketServer(this) : null;

#endif

}

catch (Exception ex)

{

shutdown = "ERROR - " + ex.Message;

}

}

static void UpgradeSettingsIfRequired()

{

if (Settings.Default.MigratedSettings == false)

{

// Prevent multiple instances from upgrading settings at the same time.

System.Threading.Mutex mutex = new(false, "JoinFS_SettingsUpgrade_Mutex");

bool acquired = false;

try

{

try

{

acquired = mutex.WaitOne(5000);

}

catch (AbandonedMutexException)

{

// another process terminated while holding the mutex, we can continue

acquired = true;

}

try

{

// Try to upgrade settings. Only mark as migrated if Upgrade() succeeds.

Settings.Default.Upgrade();

Settings.Default.MigratedSettings = true;

Settings.Default.Save();

}

catch (System.Configuration.ConfigurationErrorsException ex)

{

// Log and continue with defaults; do not let this abort startup.

System.Diagnostics.Trace.WriteLine("Settings upgrade failed: " + ex);

}

catch (Exception ex)

{

// Catch-all to avoid crashing the application during startup.

System.Diagnostics.Trace.WriteLine("Settings upgrade unexpected error: " + ex);

}

}

finally