diff --git a/Src/LiquidProjections.NEventStore/.nuspec b/Src/LiquidProjections.NEventStore/.nuspec index 041186d..5eed17a 100644 --- a/Src/LiquidProjections.NEventStore/.nuspec +++ b/Src/LiquidProjections.NEventStore/.nuspec @@ -13,7 +13,7 @@ - + diff --git a/Src/LiquidProjections.NEventStore/LiquidProjections.NEventStore.csproj b/Src/LiquidProjections.NEventStore/LiquidProjections.NEventStore.csproj index 47d9744..4f6312e 100644 --- a/Src/LiquidProjections.NEventStore/LiquidProjections.NEventStore.csproj +++ b/Src/LiquidProjections.NEventStore/LiquidProjections.NEventStore.csproj @@ -42,8 +42,8 @@ ..\..\packages\LiquidProjections.Abstractions.2.3.0\lib\netstandard1.1\LiquidProjections.Abstractions.dll - - ..\..\packages\NEventStore.5.2.0\lib\net40\NEventStore.dll + + ..\..\packages\NEventStore.7.0.0\lib\net45\NEventStore.dll diff --git a/Src/LiquidProjections.NEventStore/NEventStoreAdapter.cs b/Src/LiquidProjections.NEventStore/NEventStoreAdapter.cs index e145fd5..ec55fe5 100644 --- a/Src/LiquidProjections.NEventStore/NEventStoreAdapter.cs +++ b/Src/LiquidProjections.NEventStore/NEventStoreAdapter.cs @@ -66,7 +66,7 @@ public StreamPersisterAdapter(IPersistStreams streamPersister) public IEnumerable GetFrom(long? checkpoint) { return streamPersister - .GetFrom((!checkpoint.HasValue || checkpoint == 0) ? null : checkpoint.ToString()) + .GetFrom(checkpoint ?? 0) .Select(ToTransaction); } @@ -76,7 +76,7 @@ private Transaction ToTransaction(ICommit commit) { Id = commit.CommitId.ToString(), StreamId = commit.StreamId, - Checkpoint = long.Parse(commit.CheckpointToken), + Checkpoint = commit.CheckpointToken, TimeStampUtc = commit.CommitStamp, Events = new List(commit.Events.Select(@event => new EventEnvelope { diff --git a/Src/LiquidProjections.NEventStore/packages.config b/Src/LiquidProjections.NEventStore/packages.config index 1d9633f..b4972a5 100644 --- a/Src/LiquidProjections.NEventStore/packages.config +++ b/Src/LiquidProjections.NEventStore/packages.config @@ -3,6 +3,6 @@ - + \ No newline at end of file diff --git a/Tests/LiquidProjections.NEventStore.Specs/CommitBuilder.cs b/Tests/LiquidProjections.NEventStore.Specs/CommitBuilder.cs index effe631..c905f75 100644 --- a/Tests/LiquidProjections.NEventStore.Specs/CommitBuilder.cs +++ b/Tests/LiquidProjections.NEventStore.Specs/CommitBuilder.cs @@ -14,7 +14,7 @@ public class CommitBuilder : TestDataBuilder private string streamId = Guid.NewGuid().ToString(); private int sequence = ++nextSequence; private static int nextSequence = 1; - private string checkpointToken = "1"; + private long checkpoint = 1; private Guid commitId = Guid.NewGuid(); protected override Commit OnBuild() @@ -27,8 +27,8 @@ protected override Commit OnBuild() }); } - long streamRevision = events.Max(e => ((Event) e.Body).Version); - return new Commit("default", streamId, (int) streamRevision, commitId, sequence, timeStamp, checkpointToken, + long streamRevision = events.Max(e => ((Event)e.Body).Version); + return new Commit("default", streamId, (int)streamRevision, commitId, sequence, timeStamp, checkpoint, new Dictionary(), events); } @@ -81,15 +81,9 @@ public CommitBuilder WithSequence(int sequence) return this; } - public CommitBuilder WithCheckpoint(string checkpointToken) - { - this.checkpointToken = checkpointToken; - return this; - } - public CommitBuilder WithCheckpoint(long checkpoint) { - checkpointToken = checkpoint.ToString(); + this.checkpoint = checkpoint; return this; } diff --git a/Tests/LiquidProjections.NEventStore.Specs/LiquidProjections.NEventStore.Specs.csproj b/Tests/LiquidProjections.NEventStore.Specs/LiquidProjections.NEventStore.Specs.csproj index ed656f0..82050f3 100644 --- a/Tests/LiquidProjections.NEventStore.Specs/LiquidProjections.NEventStore.Specs.csproj +++ b/Tests/LiquidProjections.NEventStore.Specs/LiquidProjections.NEventStore.Specs.csproj @@ -1,5 +1,7 @@  + + Debug @@ -11,6 +13,8 @@ LiquidProjections.NEventStore.Specs v4.5.2 512 + + true @@ -49,8 +53,8 @@ ..\..\packages\LiquidProjections.Abstractions.2.3.0\lib\netstandard1.1\LiquidProjections.Abstractions.dll - - ..\..\packages\NEventStore.5.2.0\lib\net40\NEventStore.dll + + ..\..\packages\NEventStore.7.0.0\lib\net45\NEventStore.dll ..\..\packages\AutoFixture.3.50.3\lib\net40\Ploeh.AutoFixture.dll @@ -64,16 +68,16 @@ - ..\..\packages\xunit.abstractions.2.0.1\lib\net35\xunit.abstractions.dll + ..\..\packages\xunit.abstractions.2.0.3\lib\net35\xunit.abstractions.dll - - ..\..\packages\xunit.assert.2.2.0\lib\netstandard1.1\xunit.assert.dll + + ..\..\packages\xunit.assert.2.4.1\lib\netstandard1.1\xunit.assert.dll - - ..\..\packages\xunit.extensibility.core.2.2.0\lib\netstandard1.1\xunit.core.dll + + ..\..\packages\xunit.extensibility.core.2.4.1\lib\net452\xunit.core.dll - - ..\..\packages\xunit.extensibility.execution.2.2.0\lib\net452\xunit.execution.desktop.dll + + ..\..\packages\xunit.extensibility.execution.2.4.1\lib\net452\xunit.execution.desktop.dll @@ -97,7 +101,19 @@ + + + + + + This project references NuGet package(s) that are missing on this computer. Use NuGet Package Restore to download them. For more information, see http://go.microsoft.com/fwlink/?LinkID=322105. The missing file is {0}. + + + + + +