SolarNetwork/Swarm
2
3
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🐛 Fix jetstream

Browse Source
This commit is contained in:
LittleSheep
2025-09-11 18:52:59 +08:00
parent aa062932cf
commit dbc2c54ab0
5 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
DysonNetwork.Drive/Startup/BroadcastEventHandler.cs
View File

@@ -18,7 +18,7 @@ public class BroadcastEventHandler(
{ {
var js = new NatsJSContext(nats); var js = new NatsJSContext(nats);
var stream = await js.GetStreamAsync(AccountDeletedEvent.Type, cancellationToken: stoppingToken); var stream = await js.GetStreamAsync(AccountDeletedEvent.Type, cancellationToken: stoppingToken);
var consumer = await stream.CreateOrUpdateConsumerAsync(new ConsumerConfig("DysonNetwork_Drive_AccountDeleted"), cancellationToken: stoppingToken); var consumer = await stream.CreateOrUpdateConsumerAsync(new ConsumerConfig("Dy_Drive_AccountDeleted"), cancellationToken: stoppingToken);
await foreach (var msg in consumer.ConsumeAsync<byte[]>(cancellationToken: stoppingToken)) await foreach (var msg in consumer.ConsumeAsync<byte[]>(cancellationToken: stoppingToken))
{ {

2
DysonNetwork.Pass/Startup/BroadcastEventHandler.cs
View File

@@ -17,7 +17,7 @@ public class BroadcastEventHandler(
{ {
var js = new NatsJSContext(nats); var js = new NatsJSContext(nats);
var stream = await js.GetStreamAsync(PaymentOrderEventBase.Type, cancellationToken: stoppingToken); var stream = await js.GetStreamAsync(PaymentOrderEventBase.Type, cancellationToken: stoppingToken);
var consumer = await stream.CreateOrUpdateConsumerAsync(new ConsumerConfig("DysonNetwork_Pass_Stellar"), cancellationToken: stoppingToken); var consumer = await stream.CreateOrUpdateConsumerAsync(new ConsumerConfig("Dy_Pass_Stellar"), cancellationToken: stoppingToken);
await foreach (var msg in consumer.ConsumeAsync<byte[]>(cancellationToken: stoppingToken)) await foreach (var msg in consumer.ConsumeAsync<byte[]>(cancellationToken: stoppingToken))
{ {

2
DysonNetwork.Shared/Stream/AccountEvent.cs
View File

@@ -4,7 +4,7 @@ namespace DysonNetwork.Shared.Stream;
public class AccountDeletedEvent public class AccountDeletedEvent
{ {
public static string Type => "account.deleted"; public static string Type => "account_deleted";
public Guid AccountId { get; set; } = Guid.NewGuid(); public Guid AccountId { get; set; } = Guid.NewGuid();
public Instant DeletedAt { get; set; } = SystemClock.Instance.GetCurrentInstant(); public Instant DeletedAt { get; set; } = SystemClock.Instance.GetCurrentInstant();

2
DysonNetwork.Shared/Stream/PaymentEvent.cs
View File

@@ -7,7 +7,7 @@ public class PaymentOrderEvent : PaymentOrderEventBase
public class PaymentOrderEventBase public class PaymentOrderEventBase
{ {
public static string Type => "payments.orders"; public static string Type => "payment_orders";
public Guid OrderId { get; set; } public Guid OrderId { get; set; }
public Guid WalletId { get; set; } public Guid WalletId { get; set; }

4
DysonNetwork.Sphere/Startup/BroadcastEventHandler.cs
View File

@@ -48,7 +48,7 @@ public class BroadcastEventHandler(
{ {
var js = new NatsJSContext(nats); var js = new NatsJSContext(nats);
var stream = await js.GetStreamAsync(PaymentOrderEventBase.Type, cancellationToken: stoppingToken); var stream = await js.GetStreamAsync(PaymentOrderEventBase.Type, cancellationToken: stoppingToken);
var consumer = await stream.CreateOrUpdateConsumerAsync(new ConsumerConfig("DysonNetwork_Sphere_PaymentOrder"), var consumer = await stream.CreateOrUpdateConsumerAsync(new ConsumerConfig("Dy_Sphere_PaymentOrder"),
cancellationToken: stoppingToken); cancellationToken: stoppingToken);
await foreach (var msg in consumer.ConsumeAsync<byte[]>(cancellationToken: stoppingToken)) await foreach (var msg in consumer.ConsumeAsync<byte[]>(cancellationToken: stoppingToken))
@@ -107,7 +107,7 @@ public class BroadcastEventHandler(
var js = new NatsJSContext(nats); var js = new NatsJSContext(nats);
var stream = await js.GetStreamAsync(AccountDeletedEvent.Type, cancellationToken: stoppingToken); var stream = await js.GetStreamAsync(AccountDeletedEvent.Type, cancellationToken: stoppingToken);
var consumer = var consumer =
await stream.CreateOrUpdateConsumerAsync(new ConsumerConfig("DysonNetwork_Sphere_AccountDeleted"), await stream.CreateOrUpdateConsumerAsync(new ConsumerConfig("Dy_Sphere_AccountDeleted"),
cancellationToken: stoppingToken); cancellationToken: stoppingToken);
await foreach (var msg in consumer.ConsumeAsync<byte[]>(cancellationToken: stoppingToken)) await foreach (var msg in consumer.ConsumeAsync<byte[]>(cancellationToken: stoppingToken))