JasperFx · Hona · Aug 7, 2024
diff --git a/.nuke/build.schema.json b/.nuke/build.schema.json
@@ -89,8 +89,8 @@
               "Mocha",
               "NpmInstall",
               "Pack",
-              "PublicDocs",
-              "PublicDocsPreview",
+              "PublishDocs",
+              "PublishDocsPreview",
               "RebuildDb",
               "RecordBenchmarks",
               "Restore",
@@ -135,8 +135,8 @@
               "Mocha",
               "NpmInstall",
               "Pack",
-              "PublicDocs",
-              "PublicDocsPreview",
+              "PublishDocs",
+              "PublishDocsPreview",
               "RebuildDb",
               "RecordBenchmarks",
               "Restore",

diff --git a/Directory.Build.props b/Directory.Build.props
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="utf-8"?>
 <Project>
     <PropertyGroup>
-        <Version>7.26.1</Version>
+        <Version>8.0.2</Version>
         <LangVersion>12.0</LangVersion>
         <Authors>Jeremy D. Miller;Babu Annamalai;Oskar Dudycz;Joona-Pekka Kokko</Authors>
         <PackageIconUrl>https://martendb.io/logo.png</PackageIconUrl>

diff --git a/src/CoreTests/AssemblyInfo.cs b/src/CoreTests/AssemblyInfo.cs
@@ -0,0 +1,2 @@
+using Xunit;
+[assembly: CollectionBehavior(DisableTestParallelization = true)]
diff --git a/src/CoreTests/CoreTests.csproj b/src/CoreTests/CoreTests.csproj
@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateRuntimeConfigurationFiles>true</GenerateRuntimeConfigurationFiles>
         <GenerateAssemblyTitleAttribute>false</GenerateAssemblyTitleAttribute>
     </PropertyGroup>

diff --git a/src/DaemonTests/DaemonTests.csproj b/src/DaemonTests/DaemonTests.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <LangVersion>latest</LangVersion>
     </PropertyGroup>
     <ItemGroup>

diff --git a/src/DocumentDbTests/AssemblyInfo.cs b/src/DocumentDbTests/AssemblyInfo.cs
@@ -0,0 +1,2 @@
+using Xunit;
+[assembly: CollectionBehavior(DisableTestParallelization = true)]
diff --git a/src/DocumentDbTests/DocumentDbTests.csproj b/src/DocumentDbTests/DocumentDbTests.csproj
@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateRuntimeConfigurationFiles>true</GenerateRuntimeConfigurationFiles>
         <GenerateAssemblyTitleAttribute>false</GenerateAssemblyTitleAttribute>
     </PropertyGroup>

diff --git a/src/EventSourceWorker/EventSourceWorker.csproj b/src/EventSourceWorker/EventSourceWorker.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk.Worker">
 
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <UserSecretsId>dotnet-EventSourceWorker-01BE20B5-3C2D-434B-8822-823B56E3F401</UserSecretsId>
         <nullable>enable</nullable>
     </PropertyGroup>

diff --git a/src/EventSourcingTests/AssemblyInfo.cs b/src/EventSourcingTests/AssemblyInfo.cs
@@ -0,0 +1,2 @@
+using Xunit;
+[assembly: CollectionBehavior(DisableTestParallelization = true)]
diff --git a/src/EventSourcingTests/EventSourcingTests.csproj b/src/EventSourcingTests/EventSourcingTests.csproj
@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateRuntimeConfigurationFiles>true</GenerateRuntimeConfigurationFiles>
         <GenerateAssemblyTitleAttribute>false</GenerateAssemblyTitleAttribute>
     </PropertyGroup>

diff --git a/src/IssueService/IssueService.csproj b/src/IssueService/IssueService.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk.Web">
 
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
     </PropertyGroup>
 
     <ItemGroup>

diff --git a/src/LinqTests/LinqTests.csproj b/src/LinqTests/LinqTests.csproj
@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateRuntimeConfigurationFiles>true</GenerateRuntimeConfigurationFiles>
         <GenerateAssemblyTitleAttribute>false</GenerateAssemblyTitleAttribute>
     </PropertyGroup>

diff --git a/src/Marten.AspNetCore.Testing/AssemblyInfo.cs b/src/Marten.AspNetCore.Testing/AssemblyInfo.cs
@@ -0,0 +1,2 @@
+using Xunit;
+[assembly: CollectionBehavior(DisableTestParallelization = true)]
diff --git a/src/Marten.AspNetCore.Testing/Marten.AspNetCore.Testing.csproj b/src/Marten.AspNetCore.Testing/Marten.AspNetCore.Testing.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <IsPackable>false</IsPackable>
     </PropertyGroup>
 

diff --git a/src/Marten.AspNetCore/Marten.AspNetCore.csproj b/src/Marten.AspNetCore/Marten.AspNetCore.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <Description>Helpers for Marten-backed AspNetCore applications</Description>
         <VersionPrefix>7.0.0-beta.5</VersionPrefix>
         <GenerateAssemblyTitleAttribute>true</GenerateAssemblyTitleAttribute>

diff --git a/src/Marten.CommandLine.Tests/Marten.CommandLine.Tests.csproj b/src/Marten.CommandLine.Tests/Marten.CommandLine.Tests.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <ImplicitUsings>enable</ImplicitUsings>
         <Nullable>enable</Nullable>
         <IsPackable>false</IsPackable>

diff --git a/src/Marten.CommandLine/Marten.CommandLine.csproj b/src/Marten.CommandLine/Marten.CommandLine.csproj
@@ -2,7 +2,7 @@
 
     <PropertyGroup>
         <Description>Command line tooling for Marten</Description>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateAssemblyConfigurationAttribute>false</GenerateAssemblyConfigurationAttribute>
         <GenerateAssemblyCompanyAttribute>false</GenerateAssemblyCompanyAttribute>
         <GenerateAssemblyDescriptionAttribute>false</GenerateAssemblyDescriptionAttribute>

diff --git a/src/Marten.NodaTime.Testing/AssemblyInfo.cs b/src/Marten.NodaTime.Testing/AssemblyInfo.cs
@@ -1,2 +1,2 @@
 using Xunit;
-[assembly: CollectionBehavior(DisableTestParallelization = false)]
+[assembly: CollectionBehavior(DisableTestParallelization = true)]
diff --git a/src/Marten.NodaTime.Testing/Marten.NodaTime.Testing.csproj b/src/Marten.NodaTime.Testing/Marten.NodaTime.Testing.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <RootNamespace>Marten.NodaTimePlugin.Testing</RootNamespace>
     </PropertyGroup>
 

diff --git a/src/Marten.NodaTime/Marten.NodaTime.csproj b/src/Marten.NodaTime/Marten.NodaTime.csproj
@@ -2,7 +2,7 @@
     <PropertyGroup>
         <Description>NodaTime extension for Marten</Description>
         <VersionPrefix>7.0.0-beta.5</VersionPrefix>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateAssemblyTitleAttribute>true</GenerateAssemblyTitleAttribute>
         <GenerateAssemblyDescriptionAttribute>true</GenerateAssemblyDescriptionAttribute>
         <GenerateAssemblyProductAttribute>true</GenerateAssemblyProductAttribute>

diff --git a/src/Marten.PLv8.Testing/AssemblyInfo.cs b/src/Marten.PLv8.Testing/AssemblyInfo.cs
@@ -0,0 +1,2 @@
+using Xunit;
+[assembly: CollectionBehavior(DisableTestParallelization = true)]
diff --git a/src/Marten.PLv8.Testing/Marten.PLv8.Testing.csproj b/src/Marten.PLv8.Testing/Marten.PLv8.Testing.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
 
         <IsPackable>false</IsPackable>
     </PropertyGroup>

diff --git a/src/Marten.PLv8/Marten.PLv8.csproj b/src/Marten.PLv8/Marten.PLv8.csproj
@@ -3,7 +3,7 @@
     <PropertyGroup>
         <Description>Document transforms and patching extension for Marten</Description>
         <VersionPrefix>7.0.0-beta.5</VersionPrefix>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateAssemblyTitleAttribute>true</GenerateAssemblyTitleAttribute>
         <GenerateAssemblyDescriptionAttribute>true</GenerateAssemblyDescriptionAttribute>
         <GenerateAssemblyProductAttribute>true</GenerateAssemblyProductAttribute>

diff --git a/src/Marten.Testing.OtherAssembly/Marten.Testing.OtherAssembly.csproj b/src/Marten.Testing.OtherAssembly/Marten.Testing.OtherAssembly.csproj
@@ -2,7 +2,7 @@
 
     <PropertyGroup>
         <Description>Dummy project for test scenario</Description>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateAssemblyTitleAttribute>false</GenerateAssemblyTitleAttribute>
         <GenerateAssemblyDescriptionAttribute>false</GenerateAssemblyDescriptionAttribute>
         <GenerateAssemblyConfigurationAttribute>false</GenerateAssemblyConfigurationAttribute>

diff --git a/src/Marten.Testing.ThirdAssembly/Marten.Testing.ThirdAssembly.csproj b/src/Marten.Testing.ThirdAssembly/Marten.Testing.ThirdAssembly.csproj
@@ -2,7 +2,7 @@
 
     <PropertyGroup>
         <Description>Dummy project for test scenario</Description>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateAssemblyTitleAttribute>false</GenerateAssemblyTitleAttribute>
         <GenerateAssemblyDescriptionAttribute>false</GenerateAssemblyDescriptionAttribute>
         <GenerateAssemblyConfigurationAttribute>false</GenerateAssemblyConfigurationAttribute>

diff --git a/src/Marten.Testing/AssemblyInfo.cs b/src/Marten.Testing/AssemblyInfo.cs
@@ -0,0 +1,2 @@
+using Xunit;
+[assembly: CollectionBehavior(DisableTestParallelization = true)]
diff --git a/src/Marten.Testing/Marten.Testing.csproj b/src/Marten.Testing/Marten.Testing.csproj
@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
     <PropertyGroup>
-        <TargetFrameworks>net6.0;net7.0;net8.0</TargetFrameworks>
+        <TargetFrameworks><!--net6.0;net7.0;-->net8.0</TargetFrameworks>
         <GenerateRuntimeConfigurationFiles>true</GenerateRuntimeConfigurationFiles>
         <GenerateAssemblyTitleAttribute>false</GenerateAssemblyTitleAttribute>
     </PropertyGroup>

diff --git a/src/Marten/Events/EventGraph.Actions.cs b/src/Marten/Events/EventGraph.Actions.cs
@@ -1,12 +1,13 @@
 using System;
 using System.Linq;
+using JasperFx.Core;
 using Marten.Internal.Sessions;
 
 namespace Marten.Events;
 
 public partial class EventGraph
 {
-    internal StreamAction Append(DocumentSessionBase session, Guid stream, params object[] events)
+    internal StreamAction Append(DocumentSessionBase session, Guid stream, DateTimeOffset? backfillTimestamp = null, params object[] events)
     {
         EnsureAsGuidStorage(session);
 
@@ -22,6 +23,11 @@ internal StreamAction Append(DocumentSessionBase session, Guid stream, params ob
             return e;
         }).ToArray();
 
+        if (backfillTimestamp is not null)
+        {
+            wrapped.Each(x => x.Timestamp = backfillTimestamp.Value);
+        }
+
         if (session.WorkTracker.TryFindStream(stream, out var eventStream))
         {
             eventStream.AddEvents(wrapped);
@@ -37,7 +43,7 @@ internal StreamAction Append(DocumentSessionBase session, Guid stream, params ob
         return eventStream;
     }
 
-    internal StreamAction Append(DocumentSessionBase session, string stream, params object[] events)
+    internal StreamAction Append(DocumentSessionBase session, string stream, DateTimeOffset? backfillTimestamp = null, params object[] events)
     {
         EnsureAsStringStorage(session);
 
@@ -53,6 +59,11 @@ internal StreamAction Append(DocumentSessionBase session, string stream, params
             return e;
         }).ToArray();
 
+        if (backfillTimestamp is not null)
+        {
+            wrapped.Each(x => x.Timestamp = backfillTimestamp.Value);
+        }
+
         if (session.WorkTracker.TryFindStream(stream, out var eventStream))
         {
             eventStream.AddEvents(wrapped);

diff --git a/src/Marten/Events/EventStore.Append.cs b/src/Marten/Events/EventStore.Append.cs
@@ -7,33 +7,33 @@ namespace Marten.Events;
 
 internal partial class EventStore
 {
-    public StreamAction Append(Guid stream, IEnumerable<object> events)
+    public StreamAction Append(Guid stream, IEnumerable<object> events, DateTimeOffset? backfillTimestamp = null)
     {
         //TODO NRT: We're ignoring null here as to not unintentionally change any downstream behaviour - Replace with null guards in the future.
-        return Append(stream, events?.ToArray()!);
+        return Append(stream, backfillTimestamp, events?.ToArray()!);
     }
 
-    public StreamAction Append(Guid stream, params object[] events)
+    public StreamAction Append(Guid stream, DateTimeOffset? backfillTimestamp = null, params object[] events)
     {
-        return _store.Events.Append(_session, stream, events);
+        return _store.Events.Append(_session, stream,backfillTimestamp, events);
     }
 
-    public StreamAction Append(string stream, IEnumerable<object> events)
+    public StreamAction Append(string stream, IEnumerable<object> events, DateTimeOffset? backfillTimestamp = null)
     {
-        return Append(stream, events?.ToArray()!);
+        return Append(stream, backfillTimestamp, events?.ToArray()!);
     }
 
-    public StreamAction Append(string stream, params object[] events)
+    public StreamAction Append(string stream, DateTimeOffset? backfillTimestamp = null, params object[] events)
     {
-        return _store.Events.Append(_session, stream, events);
+        return _store.Events.Append(_session, stream,backfillTimestamp, events);
     }
 
-    public StreamAction Append(Guid stream, long expectedVersion, IEnumerable<object> events)
+    public StreamAction Append(Guid stream, long expectedVersion, IEnumerable<object> events, DateTimeOffset? backfillTimestamp = null)
     {
-        return Append(stream, expectedVersion, events?.ToArray()!);
+        return Append(stream, expectedVersion, backfillTimestamp, events?.ToArray()!);
     }
 
-    public StreamAction Append(Guid stream, long expectedVersion, params object[] events)
+    public StreamAction Append(Guid stream, long expectedVersion, DateTimeOffset? backfillTimestamp = null, params object[] events)
     {
         var eventStream = Append(stream, events);
         eventStream.ExpectedVersionOnServer = expectedVersion - eventStream.Events.Count;
@@ -45,14 +45,14 @@ public StreamAction Append(Guid stream, long expectedVersion, params object[] ev
         return eventStream;
     }
 
-    public StreamAction Append(string stream, long expectedVersion, IEnumerable<object> events)
+    public StreamAction Append(string stream, long expectedVersion, IEnumerable<object> events, DateTimeOffset? backfillTimestamp = null)
     {
-        return Append(stream, expectedVersion, events?.ToArray()!);
+        return Append(stream, expectedVersion, backfillTimestamp, events?.ToArray()!);
     }
 
-    public StreamAction Append(string stream, long expectedVersion, params object[] events)
+    public StreamAction Append(string stream, long expectedVersion, DateTimeOffset? backfillTimestamp = null, params object[] events)
     {
-        var eventStream = Append(stream, events);
+        var eventStream = Append(stream, events, backfillTimestamp);
         eventStream.ExpectedVersionOnServer = expectedVersion - eventStream.Events.Count;
 
         return eventStream;

diff --git a/src/Marten/Events/IEventOperations.cs b/src/Marten/Events/IEventOperations.cs
@@ -10,28 +10,28 @@ public interface IEventOperations
     /// </summary>
     /// <param name="stream"></param>
     /// <param name="events"></param>
-    StreamAction Append(Guid stream, IEnumerable<object> events);
+    StreamAction Append(Guid stream, IEnumerable<object> events, DateTimeOffset? backfillTimestamp = null);
 
     /// <summary>
     ///     Append one or more events in order to an existing stream
     /// </summary>
     /// <param name="stream"></param>
     /// <param name="events"></param>
-    StreamAction Append(Guid stream, params object[] events);
+    StreamAction Append(Guid stream, DateTimeOffset? backfillTimestamp = null, params object[] events);
 
     /// <summary>
     ///     Append one or more events in order to an existing stream
     /// </summary>
     /// <param name="stream"></param>
     /// <param name="events"></param>
-    StreamAction Append(string stream, IEnumerable<object> events);
+    StreamAction Append(string stream, IEnumerable<object> events, DateTimeOffset? backfillTimestamp = null);
 
     /// <summary>
     ///     Append one or more events in order to an existing stream
     /// </summary>
     /// <param name="stream"></param>
     /// <param name="events"></param>
-    StreamAction Append(string stream, params object[] events);
+    StreamAction Append(string stream, DateTimeOffset? backfillTimestamp = null, params object[] events);
 
     /// <summary>
     ///     Append one or more events in order to an existing stream and verify that maximum event id for the stream
@@ -40,7 +40,7 @@ public interface IEventOperations
     /// <param name="stream"></param>
     /// <param name="expectedVersion">Expected maximum event version after append</param>
     /// <param name="events"></param>
-    StreamAction Append(Guid stream, long expectedVersion, params object[] events);
+    StreamAction Append(Guid stream, long expectedVersion, DateTimeOffset? backfillTimestamp = null, params object[] events);
 
     /// <summary>
     ///     Append one or more events in order to an existing stream and verify that maximum event id for the stream
@@ -49,7 +49,7 @@ public interface IEventOperations
     /// <param name="stream"></param>
     /// <param name="expectedVersion">Expected maximum event version after append</param>
     /// <param name="events"></param>
-    StreamAction Append(string stream, long expectedVersion, IEnumerable<object> events);
+    StreamAction Append(string stream, long expectedVersion, IEnumerable<object> events, DateTimeOffset? backfillTimestamp = null);
 
     /// <summary>
     ///     Append one or more events in order to an existing stream and verify that maximum event id for the stream
@@ -58,7 +58,7 @@ public interface IEventOperations
     /// <param name="stream"></param>
     /// <param name="expectedVersion">Expected maximum event version after append</param>
     /// <param name="events"></param>
-    StreamAction Append(string stream, long expectedVersion, params object[] events);
+    StreamAction Append(string stream, long expectedVersion, DateTimeOffset? backfillTimestamp = null, params object[] events);
 
     /// <summary>
     ///     Creates a new event stream based on a user-supplied Guid and appends the events in order to the new stream

diff --git a/src/Marten/Events/IEventStore.cs b/src/Marten/Events/IEventStore.cs
@@ -16,7 +16,7 @@ public interface IEventStore: IEventOperations, IQueryEventStore
     /// <param name="stream"></param>
     /// <param name="expectedVersion">Expected maximum event version after append</param>
     /// <param name="events"></param>
-    StreamAction Append(Guid stream, long expectedVersion, IEnumerable<object> events);
+    StreamAction Append(Guid stream, long expectedVersion, IEnumerable<object> events, DateTimeOffset? backfillTimestamp = null);
 
     /// <summary>
     ///     Creates a new event stream based on a user-supplied Guid and appends the events in order to the new stream
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		using Xunit;
		[assembly: CollectionBehavior(DisableTestParallelization = true)]