it sorta works, still need to actually use interpreter

NadekoBot/Modules/Programming/Commands/HaskellRepl.cs

@@ -1,8 +1,10 @@
 using Discord;
 using Discord.Commands;
 using NadekoBot.Classes;
+using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Diagnostics;
+using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 
@@ -13,7 +15,7 @@ namespace NadekoBot.Modules.Programming.Commands
 {
     class HaskellRepl : DiscordCommand
     {
-        Queue<KeyValuePair<string, Channel>> commandQueue = new Queue<KeyValuePair<string, Channel>>();
+        ConcurrentQueue<KeyValuePair<string, Channel>> commandQueue = new ConcurrentQueue<KeyValuePair<string, Channel>>();
 
         Thread haskellThread;
 
@@ -23,27 +25,51 @@ namespace NadekoBot.Modules.Programming.Commands
 
             haskellThread = new Thread(new ThreadStart(() =>
             {
-                Process.Start(new ProcessStartInfo
+                var p = Process.Start(new ProcessStartInfo
                 {
                     FileName = "stack", //shouldn't use repl, but a Language.Haskell.Interpreter somehow
-                    Arguments = "repl"
+                    Arguments = "repl",
+                    UseShellExecute = false,
+                    RedirectStandardInput = true,
+                    RedirectStandardOutput = true,
+                    CreateNoWindow = true,
+                });
+
+                Task.Run(async () =>
+                {
+                    while (true)
+                    {
+                        while (commandQueue.Count == 0)
+                            await Task.Delay(100);
+
+                        //read from queue
+                        KeyValuePair<string, Channel> com;
+                        if (!commandQueue.TryDequeue(out com))
+                        {
+                            await Task.Delay(100);
+                            continue;
+                        }
+                        //var bytes = Encoding.ASCII.GetBytes(com.Key);
+
+                        //send the command to the process
+                        p.StandardInput.WriteLine(com.Key);
+
+                        //wait 50 ms for execution
+                        await Task.Delay(50);
+
+                        //read everything from the output
+                        var outBuffer = new byte[1500];
+
+                        p.StandardOutput.BaseStream.Read(outBuffer, 0, 1500);
+
+                        var outStr = Encoding.ASCII.GetString(outBuffer);
+                        //send to channel
+                        await com.Value.SendMessage($"```hs\nPrelude> {com.Key}\n" + outStr + "\n```");
+                    }
                 });
 
             }));
-
-
-            Task.Run(() =>
-            {
-                //read from queue
-
-                //send the command to the process
-
-                //wait 50 ms for execution
-
-                //read everything from the output
-
-                //send to chanenl
-            });
+            haskellThread.Start();
 
         }
 
@@ -51,9 +77,15 @@ namespace NadekoBot.Modules.Programming.Commands
         {
             cgb.CreateCommand(Module.Prefix + "hs")
                 .Description("Executes a haskell express with LAMBDABOT")
-                .Do(async e =>
+                .Parameter("command", ParameterType.Unparsed)
+                .Do(e =>
                 {
+                    var com = e.GetArg("command")?.Trim();
+                    if (string.IsNullOrWhiteSpace(com))
+                        return;
+
                     //send a command and a channel to the queue
+                    commandQueue.Enqueue(new KeyValuePair<string, Channel>(com, e.Channel));
                 });
         }
     }