common: send message to subscriptions server on email confirmed

This commit is contained in:
Abdullah Atta
2026-08-05 13:42:49 +05:00
parent 13ab0ba039
commit d694ed2fee
3 changed files with 35 additions and 0 deletions
+14
View File
@@ -42,6 +42,20 @@ namespace Streetwriters.Common
PackageName = "com.streetwriters.notesnook",
OnEmailConfirmed = async (userId) =>
{
if (!Constants.IS_SELF_HOSTED)
{
await WampServers.SubscriptionServer.PublishMessageAsync(
SubscriptionServerTopics.EmailConfirmedTopic,
new EmailConfirmedMessage
{
UserId = userId,
ClientId = "notesnook",
AppId = ApplicationType.NOTESNOOK,
ConfirmedAt = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
}
);
}
await WampServers.MessengerServer.PublishMessageAsync(MessengerServerTopics.SendSSETopic, new SendSSEMessage
{
UserId = userId,
@@ -0,0 +1,20 @@
using System.Text.Json.Serialization;
using Streetwriters.Common.Enums;
namespace Streetwriters.Common.Messages
{
public class EmailConfirmedMessage
{
[JsonPropertyName("userId")]
public required string UserId { get; set; }
[JsonPropertyName("clientId")]
public required string ClientId { get; set; }
[JsonPropertyName("appId")]
public ApplicationType AppId { get; set; }
[JsonPropertyName("confirmedAt")]
public long ConfirmedAt { get; set; }
}
}
+1
View File
@@ -110,6 +110,7 @@ namespace Streetwriters.Common
public const string CreateSubscriptionTopic = "co.streetwriters.subscriptions.create";
public const string CreateSubscriptionV2Topic = "co.streetwriters.subscriptions.v2.create";
public const string DeleteSubscriptionTopic = "co.streetwriters.subscriptions.delete";
public const string EmailConfirmedTopic = "co.streetwriters.subscriptions.email_confirmed";
}
public struct IdentityServerTopics