TimeSeries and TimeBucketStreams, Stream offloading etc

src/DataStreamSuite/DataStreamQueryAnalyzer/Program.cs

@@ -5,16 +5,31 @@ using bts.utils;
 using mbts.config;
 
 using System;
+using System.Linq;
 using System.Windows.Forms;
+using System.Threading.Tasks;
+using System.ComponentModel;
 
 static class Program {
-   [STAThread]
-   static void Main(string[] args) {
+   static void init(string[] args) {
+      Func<string, string, Task> login = async (l, p) => {
+         var login = l;
+         var passwd = p;
+         var service_ctx = bts.api.core.ServiceContext.create();
+         await service_ctx.login(login, passwd);
+      };
       BTSNativeMethods.provide_command_line(args, args.Length);
       Configuration.initialize();
-      bts.Log.Gen.info($"Starting DSQA");
-      Console.WriteLine("Starting DataStreamQueryAnalyzer...");
-      Console.WriteLine("Starting Test Publisher");
+      Task.Run(async () => await login("bts", String.Empty));
+   }
+   [STAThread]
+   static void Main(string[] args) {
+      init(args);
+      string args_concat = String.Empty;
+      args.ToList().ForEach(t => args_concat += t);
+      var init_log = $"Starting DSQA args: {args_concat} len: {args.Length}";
+      bts.Log.Gen.info(init_log);
+      Console.WriteLine(init_log);
       Console.WriteLine("Launching Main Window");
       MainForm mainForm = new MainForm();
       if (args.Length > 0) {