-
Notifications
You must be signed in to change notification settings - Fork 7
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Replace MQ with ServiceStack Jobs implementation
- Loading branch information
Showing
11 changed files
with
143 additions
and
135 deletions.
There are no files selected for viewing
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,17 @@ | ||
| import { useSearchParams } from "react-router-dom" | ||
|
|
||
| export default () => { | ||
| const [query, _] = useSearchParams() | ||
| const message = query.get('message') ?? 'Unknown error' | ||
|
|
||
| return (<> | ||
| <div className="text-black bg-white h-screen text-center flex flex-col items-center justify-center"> | ||
| <div> | ||
| <div className="inline-block text-left h-8 align-middle"> | ||
| <h2 className="text-2xl text-red-700 leading-10 font-normal m-0 p-0">{message}</h2> | ||
| </div> | ||
| </div> | ||
| </div> | ||
| </> | ||
| ) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,62 @@ | ||
| using Microsoft.AspNetCore.Identity; | ||
| using MyApp.Data; | ||
| using MyApp.ServiceInterface; | ||
| using ServiceStack.Jobs; | ||
|
|
||
| [assembly: HostingStartup(typeof(MyApp.ConfigureBackgroundJobs))] | ||
|
|
||
| namespace MyApp; | ||
|
|
||
| public class ConfigureBackgroundJobs : IHostingStartup | ||
| { | ||
| public void Configure(IWebHostBuilder builder) => builder | ||
| .ConfigureServices(services => { | ||
| services.AddPlugin(new CommandsFeature()); | ||
| services.AddPlugin(new BackgroundsJobFeature()); | ||
| services.AddHostedService<JobsHostedService>(); | ||
| }).ConfigureAppHost(afterAppHostInit: appHost => { | ||
| var services = appHost.GetApplicationServices(); | ||
| var jobs = services.GetRequiredService<IBackgroundJobs>(); | ||
| // Example of registering a Recurring Job to run Every Hour | ||
| //jobs.RecurringCommand<MyCommand>(Schedule.Hourly); | ||
| }); | ||
| } | ||
|
|
||
| public class JobsHostedService(ILogger<JobsHostedService> log, IBackgroundJobs jobs) : BackgroundService | ||
| { | ||
| protected override async Task ExecuteAsync(CancellationToken stoppingToken) | ||
| { | ||
| await jobs.StartAsync(stoppingToken); | ||
|
|
||
| using var timer = new PeriodicTimer(TimeSpan.FromSeconds(3)); | ||
| while (!stoppingToken.IsCancellationRequested && await timer.WaitForNextTickAsync(stoppingToken)) | ||
| { | ||
| await jobs.TickAsync(); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Sends emails by executing SendEmailCommand in a background job where it's serially processed by 'smtp' worker | ||
| /// </summary> | ||
| public class EmailSender(IBackgroundJobs jobs) : IEmailSender<ApplicationUser> | ||
| { | ||
| public Task SendEmailAsync(string email, string subject, string htmlMessage) | ||
| { | ||
| jobs.EnqueueCommand<SendEmailCommand>(new SendEmail { | ||
| To = email, | ||
| Subject = subject, | ||
| BodyHtml = htmlMessage, | ||
| }); | ||
| return Task.CompletedTask; | ||
| } | ||
|
|
||
| public Task SendConfirmationLinkAsync(ApplicationUser user, string email, string confirmationLink) => | ||
| SendEmailAsync(email, "Confirm your email", $"Please confirm your account by <a href='{confirmationLink}'>clicking here</a>."); | ||
|
|
||
| public Task SendPasswordResetLinkAsync(ApplicationUser user, string email, string resetLink) => | ||
| SendEmailAsync(email, "Reset your password", $"Please reset your password by <a href='{resetLink}'>clicking here</a>."); | ||
|
|
||
| public Task SendPasswordResetCodeAsync(ApplicationUser user, string email, string resetCode) => | ||
| SendEmailAsync(email, "Reset your password", $"Please reset your password using the following code: {resetCode}"); | ||
| } |
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,7 @@ | ||
| <?xml version="1.0" encoding="utf-8"?> | ||
| <configuration> | ||
| <packageSources> | ||
| <add key="ServiceStack MyGet feed" value="https://www.myget.org/F/servicestack" /> | ||
| <add key="nuget.org" value="https://api.nuget.org/v3/index.json" protocolVersion="3" /> | ||
| </packageSources> | ||
| </configuration> |