Update Launch method to convert input strings (#497) (#498)

* Update Launch method to convert input strings

* Update command execution

src/net/KNet/KNetCore.cs

@@ -21,6 +21,8 @@
 using System.Collections.Generic;
 using System.IO;
 using MASES.JNet;
+using MASES.JCOBridge.C2JBridge;
+using System.Linq;
 
 namespace MASES.KNet
 {
@@ -303,6 +305,67 @@ protected override IList<string> PathToParse
             }
         }
 
+        /// <summary>
+        /// Launch the <typeparamref name="TClass"/> class with the <paramref name="args"/> arguments
+        /// </summary>
+        /// <typeparam name="TClass">A type which is defined as Main-Class</typeparam>
+        /// <param name="args">The arguments of the main method</param>
+        public static new void Launch<TClass>(params string[] args)
+            where TClass : IJVMBridgeMain
+        {
+            Launch(typeof(TClass), args);
+        }
+
+        /// <summary>
+        /// Launch the <paramref name="type"/> with the <paramref name="args"/> arguments
+        /// </summary>
+        /// <param name="type">The <see cref="Type"/> extending <see cref="IJVMBridgeMain"/></param>
+        /// <param name="args">The arguments of the main method</param>
+        public static new void Launch(Type type, params string[] args)
+        {
+            if (type == null) throw new ArgumentNullException(nameof(type));
+
+            try
+            {
+                JNetCore<T>.Launch(type, args);
+            }
+            catch (ArgumentException)
+            {
+                if (type.GetInterface(typeof(IJVMBridgeMain).Name) == null) throw;
+                var execType = type;
+                do
+                {
+                    if (args.Length == 0)
+                    {
+                        System.Reflection.MethodInfo method = execType.GetMethods().FirstOrDefault(method => method.Name == "SExecute" & method.GetParameters().Length == 2 & method.IsGenericMethod == false);
+                        if (method != null)
+                        {
+                            method.Invoke(null, new object[] { "main", new object[] { args } });
+                            return;
+                        }
+                    }
+                    else
+                    {
+                        System.Reflection.MethodInfo method = execType.GetMethod("Main", new Type[] { typeof(Java.Lang.String[]) });
+                        if (method != null)
+                        {
+                            Java.Lang.String[] strings = new Java.Lang.String[args.Length];
+                            for (int i = 0; i < args.Length; i++)
+                            {
+                                strings[i] = args[i];
+                            }
+                            method.Invoke(null, new object[] { strings });
+                        }
+                        return;
+                    }
+                    execType = execType.BaseType;
+                }
+                while (execType != null && execType != typeof(object));
+
+            }
+            throw new ArgumentException($"{type} does not define any IJVMBridgeMain type or interface", "type");
+        }
+
 #if DEBUG
         /// <inheritdoc cref="JNetCoreBase{T}.EnableDebug"/>
         public override bool EnableDebug => true;

src/net/KNetConnect/Program.cs

@@ -79,7 +79,7 @@ static void ShowHelp(string errorString = null)
             var assembly = typeof(Program).Assembly;
 
             Console.WriteLine("KNetConnect - KNet Connect command line interface - Version " + assembly.GetName().Version.ToString());
-            Console.WriteLine(assembly.GetName().Name + " -[d|s] connect-standalone.properties [-KafkaLocation kafkaFolder] <JCOBridgeArguments> <ClassArguments>");
+            Console.WriteLine(assembly.GetName().Name + " -[d|s] [-k] connect-standalone.properties [-KafkaLocation kafkaFolder] <JCOBridgeArguments> <ClassArguments>");
             Console.WriteLine();
             if (!string.IsNullOrEmpty(errorString))
             {
@@ -88,14 +88,16 @@ static void ShowHelp(string errorString = null)
 
             Console.WriteLine("s: start Connect in standalone mode. ");
             Console.WriteLine("d: start Connect in distributed mode. ");
+            Console.WriteLine("k: start Connect in distributed/standalone mode using KNet version. ");
             Console.WriteLine("KafkaLocation: The folder where Kafka package is available. Default consider this application uses the package jars folder.");
             Console.WriteLine("ScalaVersion: the scala version to be used. The default version (2.13.6) is binded to the deafult Apache Kafka version available in the package.");
             Console.WriteLine("Log4JConfiguration: the log4j configuration file; the default uses the file within the package.");
             Console.WriteLine("JCOBridgeArguments: the arguments of JCOBridge (see online at https://www.jcobridge.com/net-examples/command-line-options/ for the possible values). ");
             Console.WriteLine("ClassArguments: the arguments of the class. Depends on the ClassToRun value, to obtain them runs the application or look at Apache Kafka documentation.");
             Console.WriteLine();
             Console.WriteLine("Examples:");
-            Console.WriteLine(assembly.GetName().Name + " -ClassToRun ConsoleConsumer --bootstrap-server SERVER-ADDRESS:9093 --topic topic_name --from-beginning");
+            Console.WriteLine(assembly.GetName().Name + " -s connect-standalone.properties specific-connector.properties");
+            Console.WriteLine(assembly.GetName().Name + " -d connect-distributed.properties");
         }
     }
 }

src/net/KNetPS/Cmdlet/KafkaClassToRunCmdletCommandBase.cs

@@ -50,7 +50,7 @@ protected override void OnAfterCreateGlobalInstance()
 
             try
             {
-                JNetPSHelper<KNetPSCore>.Launch(KNetPSCore.MainClassToRun, arguments);
+                KNetPSHelper<KNetPSCore>.Launch(KNetPSCore.MainClassToRun, arguments);
             }
             catch (TargetInvocationException tie)
             {

src/net/KNetPS/KNetPSHelper.cs

@@ -37,5 +37,10 @@ public static class KNetPSHelper<TClass> where TClass : KNetCore<TClass>
         public static void SetScalaVersion(string scalaVersion) { JNetPSHelper<TClass>.Set(typeof(KNetCore<>), nameof(KNetPSCore.ApplicationScalaVersion), scalaVersion); }
 
         public static void SetDisableJMX(bool? disableJMX) { JNetPSHelper<TClass>.Set(typeof(KNetCore<>), nameof(KNetPSCore.ApplicationDisableJMX), disableJMX); }
+
+        public static void Launch(System.Type type, params string[] args)
+        {
+            typeof(TClass).RunStaticMethodOn(typeof(KNetCore<TClass>), "Launch", type, args);
+        }
     }
 }