Merge branch 'dev' of https://github.com/datalust/seqcli into feat/trace-support

Author: KodrAus

global.json

@@ -2,4 +2,4 @@
   "sdk": {
     "version": "8.0.100"
   }
-}
+}

src/Roastery/Roastery.csproj

@@ -6,7 +6,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Serilog" Version="3.1.0-dev-02078" />
+        <PackageReference Include="Serilog" Version="3.1.1" />
     </ItemGroup>
 
 </Project>

src/SeqCli/Apps/Definitions/AppDefinition.cs

@@ -12,8 +12,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-#nullable enable
-
 using System.Collections.Generic;
 using Newtonsoft.Json;
 

src/SeqCli/Apps/Definitions/AppMetadataReader.cs

@@ -19,8 +19,6 @@
 using System.Reflection;
 using Seq.Apps;
 
-#nullable  enable
-
 namespace SeqCli.Apps.Definitions;
 
 static class AppMetadataReader

src/SeqCli/Apps/Definitions/AppSettingDefinition.cs

@@ -14,8 +14,6 @@
 
 using Newtonsoft.Json;
 
-#nullable enable
-
 namespace SeqCli.Apps.Definitions;
 
 // ReSharper disable all

src/SeqCli/Cli/CommandLineHost.cs

@@ -21,8 +21,6 @@
 using Serilog.Core;
 using Serilog.Events;
 
-#nullable enable
-
 namespace SeqCli.Cli;
 
 class CommandLineHost

src/SeqCli/Cli/Commands/App/InstallCommand.cs

@@ -22,8 +22,6 @@
 using SeqCli.Util;
 using Serilog;
 
-#nullable enable
-
 namespace SeqCli.Cli.Commands.App;
 
 [Command("app", "install", "Install an app package",

src/SeqCli/Cli/Commands/App/UpdateCommand.cs

@@ -21,8 +21,6 @@
 using SeqCli.Util;
 using Serilog;
 
-#nullable enable
-
 namespace SeqCli.Cli.Commands.App;
 
 [Command("app", "update", "Update an installed app package",

src/SeqCli/Cli/Commands/AppInstance/CreateCommand.cs

@@ -6,6 +6,7 @@
 using SeqCli.Cli.Features;
 using SeqCli.Config;
 using SeqCli.Connection;
+using SeqCli.Signals;
 using SeqCli.Util;
 using Serilog;
 
@@ -20,9 +21,10 @@ class CreateCommand : Command
     readonly ConnectionFeature _connection;
     readonly OutputFormatFeature _output;
 
-    string? _title, _appId;
+    string? _title, _appId, _streamIncomingEventsSignal;
     readonly Dictionary<string, string> _settings = new();
     readonly List<string> _overridable = new();
+    bool _streamIncomingEvents;
 
     public CreateCommand(SeqConnectionFactory connectionFactory, SeqCliConfig config)
     {
@@ -48,12 +50,24 @@ public CreateCommand(SeqConnectionFactory connectionFactory, SeqCliConfig config
                 _settings.Add(name, valueText ?? "");
             });
 
+        Options.Add(
+            "stream:",
+            "Stream incoming events to this app instance as they're ingested; optionally accepts a signal expression limiting which events should be streamed",
+            s =>
+            {
+                _streamIncomingEvents = true;
+
+                if (!string.IsNullOrEmpty(s))
+                {
+                    _streamIncomingEventsSignal = s;
+                }
+            }
+        );
+
         Options.Add(
             "overridable=",
             "Specify setting names that may be overridden by users when invoking the app",
             s => _overridable.Add(s));
-        
-        // The command doesn't yet implement "Stream incoming events".
 
         _connection = Enable<ConnectionFeature>();
         _output = Enable(new OutputFormatFeature(config.Output));
@@ -77,6 +91,8 @@ bool ValidateSettingName(string settingName)
         }
 
         instance.Title = _title;
+        instance.AcceptStreamedEvents = _streamIncomingEvents;
+        instance.StreamedSignalExpression = !string.IsNullOrWhiteSpace(_streamIncomingEventsSignal) ? SignalExpressionParser.ParseExpression(_streamIncomingEventsSignal) : null;
 
         foreach (var setting in _settings)
         {

src/SeqCli/Cli/Commands/Bench/BenchCase.cs

@@ -12,8 +12,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-#nullable enable
-
 namespace SeqCli.Cli.Commands.Bench;
 
 // ReSharper disable ClassNeverInstantiated.Global AutoPropertyCanBeMadeGetOnly.Global UnusedAutoPropertyAccessor.Global