Skip to content

Commit

Permalink
Testing something
Browse files Browse the repository at this point in the history
  • Loading branch information
@w1am
w1am committed Jan 7, 2025
1 parent 740872b commit f68cec0
Show file tree
Hide file tree
Showing 2 changed files with 72 additions and 68 deletions.
70 changes: 36 additions & 34 deletions test/Kurrent.Client.Tests.Common/Fixtures/KurrentPermanentFixture.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ protected KurrentPermanentFixture(ConfigureFixture configure) {
public KurrentFixtureOptions Options { get; }
public Faker Faker { get; } = new Faker();

// public Version EventStoreVersion { get; private set; } = null!;
public Version EventStoreVersion { get; private set; } = null!;
public bool EventStoreHasLastStreamPosition { get; private set; }

public KurrentClient Streams { get; private set; } = null!;
Expand Down Expand Up @@ -87,9 +87,9 @@ public async Task InitializeAsync() {
await ContainerSemaphore.WaitAsync();
try {
await Service.Start();
// EventStoreVersion = GetEventStoreVersion();
// EventStoreHasLastStreamPosition = (EventStoreVersion?.Major ?? int.MaxValue) >= 21;
EventStoreHasLastStreamPosition = true;
EventStoreVersion = GetEventStoreVersion();
EventStoreHasLastStreamPosition = (EventStoreVersion?.Major ?? int.MaxValue) >= 21;
// EventStoreHasLastStreamPosition = true;
} finally {
ContainerSemaphore.Release();
}
Expand Down Expand Up @@ -133,36 +133,38 @@ async Task<T> InitClient<T>(Func<T, Task> action, bool execute = true) where T :
return client;
}

// static Version GetEventStoreVersion() {
// const string versionPrefix = "EventStoreDB version";
//
// using var cancellator = new CancellationTokenSource(FromSeconds(30));
// using var eventstore = new Builder()
// .UseContainer()
// .UseImage(GlobalEnvironment.DockerImage)
// .Command("--version")
// .Build()
// .Start();
//
// using var log = eventstore.Logs(true, cancellator.Token);
// foreach (var line in log.ReadToEnd()) {
// if (line.StartsWith(versionPrefix) &&
// Version.TryParse(
// new string(ReadVersion(line[(versionPrefix.Length + 1)..]).ToArray()),
// out var version
// )) {
// return version;
// }
// }
//
// throw new InvalidOperationException("Could not determine server version.");
//
// IEnumerable<char> ReadVersion(string s) {
// foreach (var c in s.TakeWhile(c => c == '.' || char.IsDigit(c))) {
// yield return c;
// }
// }
// }
static Version GetEventStoreVersion() {
const string versionPrefix = "EventStoreDB version";

using var cancellator = new CancellationTokenSource(FromSeconds(30));
using var eventstore = new Builder()
.UseContainer()
.UseImage(GlobalEnvironment.DockerImage)
.Command("--version")
.Build()
.Start();

using var log = eventstore.Logs(true, cancellator.Token);
foreach (var line in log.ReadToEnd()) {
Logger.Warning("line---> {line}", line);

if (line.StartsWith(versionPrefix) &&
Version.TryParse(
new string(ReadVersion(line[(versionPrefix.Length + 1)..]).ToArray()),
out var version
)) {
return version;
}
}

throw new InvalidOperationException("Could not determine server version.");

IEnumerable<char> ReadVersion(string s) {
foreach (var c in s.TakeWhile(c => c == '.' || char.IsDigit(c))) {
yield return c;
}
}
}
}

public async Task DisposeAsync() {
Expand Down
70 changes: 36 additions & 34 deletions test/Kurrent.Client.Tests.Common/Fixtures/KurrentTemporaryFixture.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ protected KurrentTemporaryFixture(ConfigureFixture configure) {
public KurrentFixtureOptions Options { get; }
public Faker Faker { get; } = new Faker();

// public Version EventStoreVersion { get; private set; } = null!;
public Version EventStoreVersion { get; private set; } = null!;
public bool EventStoreHasLastStreamPosition { get; private set; }

public KurrentClient Streams { get; private set; } = null!;
Expand Down Expand Up @@ -89,9 +89,9 @@ public async Task InitializeAsync() {
await ContainerSemaphore.WaitAsync();
try {
await Service.Start();
// EventStoreVersion = GetEventStoreVersion();
// EventStoreHasLastStreamPosition = (EventStoreVersion?.Major ?? int.MaxValue) >= 21;
EventStoreHasLastStreamPosition = true;
EventStoreVersion = GetEventStoreVersion();
EventStoreHasLastStreamPosition = (EventStoreVersion?.Major ?? int.MaxValue) >= 21;
// EventStoreHasLastStreamPosition = true;
} finally {
ContainerSemaphore.Release();
}
Expand Down Expand Up @@ -135,36 +135,38 @@ async Task<T> InitClient<T>(Func<T, Task> action, bool execute = true) where T :
return client;
}

// static Version GetEventStoreVersion() {
// const string versionPrefix = "EventStoreDB version";
//
// using var cancellator = new CancellationTokenSource(FromSeconds(30));
// using var eventstore = new Builder()
// .UseContainer()
// .UseImage(GlobalEnvironment.DockerImage)
// .Command("--version")
// .Build()
// .Start();
//
// using var log = eventstore.Logs(true, cancellator.Token);
// foreach (var line in log.ReadToEnd()) {
// if (line.StartsWith(versionPrefix) &&
// Version.TryParse(
// new string(ReadVersion(line[(versionPrefix.Length + 1)..]).ToArray()),
// out var version
// )) {
// return version;
// }
// }
//
// throw new InvalidOperationException("Could not determine server version.");
//
// IEnumerable<char> ReadVersion(string s) {
// foreach (var c in s.TakeWhile(c => c == '.' || char.IsDigit(c))) {
// yield return c;
// }
// }
// }
static Version GetEventStoreVersion() {
const string versionPrefix = "EventStoreDB version";

using var cancellator = new CancellationTokenSource(FromSeconds(30));
using var eventstore = new Builder()
.UseContainer()
.UseImage(GlobalEnvironment.DockerImage)
.Command("--version")
.Build()
.Start();

using var log = eventstore.Logs(true, cancellator.Token);
foreach (var line in log.ReadToEnd()) {
Logger.Warning("line---> {line}", line);

if (line.StartsWith(versionPrefix) &&
Version.TryParse(
new string(ReadVersion(line[(versionPrefix.Length + 1)..]).ToArray()),
out var version
)) {
return version;
}
}

throw new InvalidOperationException("Could not determine server version.");

IEnumerable<char> ReadVersion(string s) {
foreach (var c in s.TakeWhile(c => c == '.' || char.IsDigit(c))) {
yield return c;
}
}
}
}

public async Task DisposeAsync() {
Expand Down

0 comments on commit f68cec0

Please sign in to comment.