aswi2021tri-musketyri-gitlab/Server/ServerApp/Program.cs @ bf906ac5

using ServerApp.Connection;
using ServerApp.Connection.XMLProtocolHandler;
using ServerApp.DataDownload;
using ServerApp.Parser.InputData;
using ServerApp.Parser.OutputInfo;
using ServerApp.Parser.Parsers;
using ServerApp.Predictor;
using ServerApp.User;
using ServerApp.WeatherPredictionParser;
using System;
using System.Collections.Generic;
using System.IO;
using System.Threading;

namespace ServerApp
{

	class Config // TBD where this should go
	{
		public string DataWebsite { get; set; }
		public string DownloadedFilesNaming { get; set; }
		public string DataRootDir { get; set; }
		public string Port { get; set; }
	}

    public class Program
    {

		public static void NotifyUserMessage(string message)
		{
			Console.WriteLine("Received user message: " + message);
		}

        static void Main(string[] args)
        {

			// SETUP FOLDERS
			Config config = FillConfigInfo(args);
			if (config == null)
			{
				Console.ReadLine();
				return;
			}

            
			//create a thread for commands accepting:
			//Thread inputThread = new Thread(CommandsAcceptor.AcceptCommand);
			//inputThread.Start();



			//DataParser p = new DataParser("data/");
			//p.Parse();

			#region UNCOMMENT
			//test scenario -data download:
			DataDownloader dd = new DataDownloader(config.DataRootDir, config.DataWebsite, config.DownloadedFilesNaming);
			dd.OverwriteExisting = false;
			List<string> savedFiles = new List<string>();
			savedFiles.AddRange(dd.DownloadData(DataType.JIS, DataFormat.CSV, new DataDownload.Date(1, 2019), new DataDownload.Date(12, 2020)));
			savedFiles.AddRange(dd.DownloadData(DataType.STROJE, DataFormat.CSV, new DataDownload.Date(1, 2017), new DataDownload.Date(12, 2020)));
			savedFiles.AddRange(dd.DownloadData(DataType.POCASI, DataFormat.CSV, new DataDownload.Date(1, 2017), new DataDownload.Date(12, 2020)));



			//Console.WriteLine("Saved files: ");
			//foreach (string s in savedFiles)
			//{
			//	Console.WriteLine(s);
			//}

			//Console.WriteLine("subdirectories: ");
			//foreach (KeyValuePair<DataType, string> kvp in dd.DataSubDirectories)
			//{
			//	Console.WriteLine("Key = {0}, Value = {1}", kvp.Key, kvp.Value);
			//}

			//List<string> retrievedData = dd.GetData(dd.DataSubDirectories[DataType.JIS], new DataDownload.Date(10, 2019), new DataDownload.Date(12, 2020));
			//Console.WriteLine("Retrieved data: ");
			//foreach (string s in retrievedData)
			//{
			//	Console.WriteLine(s);
			//}
			//Console.WriteLine("all from directory:");
			//retrievedData = dd.GetData(dd.DataSubDirectories[DataType.JIS], null, null);
			//foreach (string s in retrievedData)
			//{
			//	Console.WriteLine(s);
			//}
			// test - connection:
			//ConnectionListener cl = new ConnectionListener(int.Parse(config.Port));
			//cl.StartListening();
			#endregion

			#region XML_TEST
			//Response response = Response.Randomize();
			//var xml = XmlCommunication.Serialize(response);
			//Console.WriteLine(xml);
			//Response responseDeserialized = XmlCommunication.Deserialize(response, xml);

			//Console.WriteLine("------");


			//Request request = Request.Randomize();
			//xml = XmlCommunication.Serialize(request);
			//Console.WriteLine(xml);
			//Request requestDeserialized = XmlCommunication.Deserialize(request, xml);
			#endregion


			//Console.WriteLine("Saved files: ");
			//foreach (string s in savedFiles)
			//{
			//	Console.WriteLine(s);
			//}

			//Console.WriteLine("subdirectories: ");
			//foreach (KeyValuePair<DataType, string> kvp in dd.DataSubDirectories)
			//{
			//	Console.WriteLine("Key = {0}, Value = {1}", kvp.Key, kvp.Value);
			//}

			/*
			
			List<string> retrievedData = dd.GetData(dd.DataSubDirectories[DataType.JIS], new Date(10, 2019), new Date(12, 2020));
			Console.WriteLine("Retrieved data: ");
			foreach (string s in retrievedData)
			{
				Console.WriteLine(s);
			}
			*/

            // PARSE DATA

            JsonParser jsonP = new JsonParser(dd, new CsvDataLoader());
			jsonP.ParsePrediction();

			var res = jsonP.GetPredictionForTime(jsonP.Predictions[5].startTime, jsonP.Predictions[20].startTime);
			Console.WriteLine("from " + jsonP.Predictions[5].startTime);
			Console.WriteLine("end " + jsonP.Predictions[20].startTime);
			foreach (WeatherInfo w in res)
				Console.WriteLine(w.ToString());


			// TODO nastavit čas
			IDataParser p = new DataParser(dd);
            IPredictionController predictionController = new PredictionController(p);
            //predictionController.Train();
            //var results = predictionController.Predict()
			

			//parse(new DateTime(2019, 10, 5), , interval = 1, wholeDay = true)


			// test - connection:
			//ConnectionListener cl = new ConnectionListener(int.Parse(args[0])/*8000*//*int.Parse(config.Port)*/);
			//cl.StartListening();

			Console.ReadLine();
        }


        private static Config FillConfigInfo(string[] args)
		{

			Config extractedConfigInfo = new Config();

			Console.WriteLine(Directory.GetCurrentDirectory());
			
			if (args.Length != 1)
				Console.WriteLine("Wrong usage of parameters, pass the path to a config file."); // todo better explanation?

			string fullPathConfig = Path.GetFullPath(args[0]);
			string[] lines = null;
			try {
				lines = File.ReadAllLines(fullPathConfig);
			}
			catch(Exception ex)
			{
				Console.WriteLine("Could not open " + fullPathConfig);
				return null;
			}
			
			for (var i = 0; i < lines.Length; i += 1)
			{
				string line = lines[i];
				Console.WriteLine(line);
				if (line.Length == 0 || line == null || line.StartsWith("#"))
					continue;

				switch (line)
				{
					case "!site!":
						extractedConfigInfo.DataWebsite = lines[++i].Trim();
						break;
					case "!naming_convention!":
						extractedConfigInfo.DownloadedFilesNaming = lines[++i].Trim();
						break;
					case "!data_root_dir!":
						string dirWithConfig = Path.GetDirectoryName(fullPathConfig);
						string rootPath = dirWithConfig + Path.DirectorySeparatorChar + lines[++i].Trim();
						extractedConfigInfo.DataRootDir = rootPath;
						
						break;
					case "!port!":
						extractedConfigInfo.Port = lines[++i].Trim();
						break;
					default: break;
				}
			}

			return extractedConfigInfo;
		}
    }
}