aboutsummaryrefslogtreecommitdiff
path: root/PagerFetchService.cs
diff options
context:
space:
mode:
authorJake Mannens <jake@asger.xyz>2024-10-18 14:51:26 +1100
committerJake Mannens <jake@asger.xyz>2024-10-29 11:42:54 +1100
commit09ade38700ae3795c47826cf4c80c65f9c3338f3 (patch)
tree2bc877d130f70a89cc891fb18e034e00a337478a /PagerFetchService.cs
parente8e3c4cba8ffa0056e984c113cfbb75319e00022 (diff)
Diffstat (limited to 'PagerFetchService.cs')
-rw-r--r--PagerFetchService.cs18
1 files changed, 9 insertions, 9 deletions
diff --git a/PagerFetchService.cs b/PagerFetchService.cs
index aa014a3..f823ffd 100644
--- a/PagerFetchService.cs
+++ b/PagerFetchService.cs
@@ -3,13 +3,13 @@ using System.Text.RegularExpressions;
namespace PagerParser;
-public class PagerMessageEventArgs : EventArgs {
- public PagerMessage Message { get; init; }
+internal class PagerMessageEventArgs : EventArgs {
+ internal PagerMessage Message { get; init; }
}
-public delegate void PagerMessageHandler(object sender, PagerMessageEventArgs e);
+internal delegate void PagerMessageHandler(object sender, PagerMessageEventArgs e);
-public interface IPagerProvider {
+internal interface IPagerProvider {
public event EventHandler OnConnect;
public event EventHandler<string> OnDisconnect;
public event PagerMessageHandler OnPagerMessage;
@@ -21,7 +21,7 @@ public interface IPagerProvider {
}
[AttributeUsage(AttributeTargets.Class, AllowMultiple = true)]
-public class PagerProviderAttribute : Attribute {}
+internal class PagerProviderAttribute : Attribute {}
public class PagerFetchService : IHostedService {
private readonly TimeSpan FetchInterval = TimeSpan.FromMinutes(1);
@@ -138,7 +138,7 @@ public class PagerFetchService : IHostedService {
db.SaveChanges();
}
- public async Task FetchAsync() {
+ private async Task FetchAsync() {
await lastFetchLock.WaitAsync(cts.Token);
try {
var fetchUntil = lastFetch ?? LastPageTimestamp ?? DateTime.MinValue;
@@ -163,7 +163,7 @@ public class PagerFetchService : IHostedService {
}
}
- public void OnConnect(object? sender, EventArgs e) {
+ private void OnConnect(object? sender, EventArgs e) {
logger.LogInformation(
$"Connected to pager message provider {pagerProvider.GetType().Name}");
@@ -172,7 +172,7 @@ public class PagerFetchService : IHostedService {
fetchTimer.AutoReset = false;
}
- public async void OnDisconnect(object? sender, string e) {
+ private async void OnDisconnect(object? sender, string e) {
logger.LogInformation(
$"Disconnected from pager message provider {pagerProvider.GetType().Name}");
@@ -188,7 +188,7 @@ public class PagerFetchService : IHostedService {
fetchTimer.Start();
}
- public async void PagerMessageReceived(object sender, PagerMessageEventArgs e) {
+ private async void PagerMessageReceived(object sender, PagerMessageEventArgs e) {
logger.LogInformation($"PagerMessage: {e.Message.Message}");
AddMessages([ e.Message ]);