Skip to content

Commit d18baee

Browse files
johnsimonsjohnsimons
committed
Fix casing name
1 parent 69769a0 commit d18baee

File tree

3 files changed

+18
-20
lines changed

3 files changed

+18
-20
lines changed

‎src/ServiceControl.Audit.Persistence.PostgreSQL/PostgreSQLAuditDataStore.cs‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public async Task<MessageBodyView> GetMessageBody(string messageId, Cancellation
4545

4646
public Task<QueryResult<IList<MessagesView>>> GetMessages(bool includeSystemMessages, PagingInfo pagingInfo, SortInfo sortInfo, DateTimeRange timeSentRange, CancellationToken cancellationToken)
4747
{
48-
var builder = new PostgresqlMessagesQueryBuilder()
48+
var builder = new PostgreSQLMessagesQueryBuilder()
4949
.WithSystemMessages(includeSystemMessages)
5050
.WithTimeSentRange(timeSentRange)
5151
.WithSorting(sortInfo)
@@ -124,7 +124,7 @@ public async Task<QueryResult<IList<KnownEndpointsView>>> QueryKnownEndpoints(Ca
124124

125125
public Task<QueryResult<IList<MessagesView>>> QueryMessages(string searchParam, PagingInfo pagingInfo, SortInfo sortInfo, DateTimeRange? timeSentRange = null, CancellationToken cancellationToken = default)
126126
{
127-
var builder = new PostgresqlMessagesQueryBuilder()
127+
var builder = new PostgreSQLMessagesQueryBuilder()
128128
.WithSearch(searchParam)
129129
.WithTimeSentRange(timeSentRange)
130130
.WithSorting(sortInfo)
@@ -134,7 +134,7 @@ public Task<QueryResult<IList<MessagesView>>> QueryMessages(string searchParam,
134134

135135
public Task<QueryResult<IList<MessagesView>>> QueryMessagesByConversationId(string conversationId, PagingInfo pagingInfo, SortInfo sortInfo, CancellationToken cancellationToken)
136136
{
137-
var builder = new PostgresqlMessagesQueryBuilder()
137+
var builder = new PostgreSQLMessagesQueryBuilder()
138138
.WithConversationId(conversationId)
139139
.WithSorting(sortInfo)
140140
.WithPaging(pagingInfo);
@@ -143,7 +143,7 @@ public Task<QueryResult<IList<MessagesView>>> QueryMessagesByConversationId(stri
143143

144144
public Task<QueryResult<IList<MessagesView>>> QueryMessagesByReceivingEndpoint(bool includeSystemMessages, string endpointName, PagingInfo pagingInfo, SortInfo sortInfo, DateTimeRange? timeSentRange = null, CancellationToken cancellationToken = default)
145145
{
146-
var builder = new PostgresqlMessagesQueryBuilder()
146+
var builder = new PostgreSQLMessagesQueryBuilder()
147147
.WithSystemMessages(includeSystemMessages)
148148
.WithEndpointName(endpointName)
149149
.WithTimeSentRange(timeSentRange)
@@ -154,7 +154,7 @@ public Task<QueryResult<IList<MessagesView>>> QueryMessagesByReceivingEndpoint(b
154154

155155
public Task<QueryResult<IList<MessagesView>>> QueryMessagesByReceivingEndpointAndKeyword(string endpoint, string keyword, PagingInfo pagingInfo, SortInfo sortInfo, DateTimeRange? timeSentRange = null, CancellationToken cancellationToken = default)
156156
{
157-
var builder = new PostgresqlMessagesQueryBuilder()
157+
var builder = new PostgreSQLMessagesQueryBuilder()
158158
.WithSearch(keyword)
159159
.WithEndpointName(endpoint)
160160
.WithTimeSentRange(timeSentRange)
@@ -198,7 +198,7 @@ FROM saga_snapshots
198198
}
199199

200200
async Task<QueryResult<IList<MessagesView>>> ExecuteMessagesQuery(
201-
PostgresqlMessagesQueryBuilder builder,
201+
PostgreSQLMessagesQueryBuilder builder,
202202
CancellationToken cancellationToken)
203203
{
204204
await using var conn = await connectionFactory.OpenConnection(cancellationToken);

src/ServiceControl.Audit.Persistence.PostgreSQL/PostgresqlMessagesQueryBuilder.cs renamed to src/ServiceControl.Audit.Persistence.PostgreSQL/PostgreSQLMessagesQueryBuilder.cs

Lines changed: 11 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1,19 +1,16 @@
1-
2-
3-
41
namespace ServiceControl.Audit.Persistence.PostgreSQL;
52

6-
using System;
73
using System.Collections.Generic;
84
using System.Text;
95
using Npgsql;
106
using ServiceControl.Audit.Infrastructure;
11-
public class PostgresqlMessagesQueryBuilder
7+
8+
public class PostgreSQLMessagesQueryBuilder
129
{
1310
readonly StringBuilder sql = new();
1411
readonly List<NpgsqlParameter> parameters = [];
1512

16-
public PostgresqlMessagesQueryBuilder()
13+
public PostgreSQLMessagesQueryBuilder()
1714
{
1815
sql.Append(@"select unique_message_id,
1916
message_metadata,
@@ -32,7 +29,7 @@ conversation_id from processed_messages
3229
where 1 = 1");
3330
}
3431

35-
public PostgresqlMessagesQueryBuilder WithSystemMessages(bool? includeSystemMessages)
32+
public PostgreSQLMessagesQueryBuilder WithSystemMessages(bool? includeSystemMessages)
3633
{
3734
if (includeSystemMessages.HasValue)
3835
{
@@ -42,7 +39,7 @@ public PostgresqlMessagesQueryBuilder WithSystemMessages(bool? includeSystemMess
4239
return this;
4340
}
4441

45-
public PostgresqlMessagesQueryBuilder WithSearch(string? q)
42+
public PostgreSQLMessagesQueryBuilder WithSearch(string? q)
4643
{
4744
if (!string.IsNullOrWhiteSpace(q))
4845
{
@@ -52,7 +49,7 @@ public PostgresqlMessagesQueryBuilder WithSearch(string? q)
5249
return this;
5350
}
5451

55-
public PostgresqlMessagesQueryBuilder WithConversationId(string? conversationId)
52+
public PostgreSQLMessagesQueryBuilder WithConversationId(string? conversationId)
5653
{
5754
if (!string.IsNullOrWhiteSpace(conversationId))
5855
{
@@ -62,7 +59,7 @@ public PostgresqlMessagesQueryBuilder WithConversationId(string? conversationId)
6259
return this;
6360
}
6461

65-
public PostgresqlMessagesQueryBuilder WithMessageId(string? messageId)
62+
public PostgreSQLMessagesQueryBuilder WithMessageId(string? messageId)
6663
{
6764
if (!string.IsNullOrWhiteSpace(messageId))
6865
{
@@ -72,7 +69,7 @@ public PostgresqlMessagesQueryBuilder WithMessageId(string? messageId)
7269
return this;
7370
}
7471

75-
public PostgresqlMessagesQueryBuilder WithEndpointName(string? endpointName)
72+
public PostgreSQLMessagesQueryBuilder WithEndpointName(string? endpointName)
7673
{
7774
if (!string.IsNullOrWhiteSpace(endpointName))
7875
{
@@ -82,7 +79,7 @@ public PostgresqlMessagesQueryBuilder WithEndpointName(string? endpointName)
8279
return this;
8380
}
8481

85-
public PostgresqlMessagesQueryBuilder WithTimeSentRange(DateTimeRange? timeSentRange)
82+
public PostgreSQLMessagesQueryBuilder WithTimeSentRange(DateTimeRange? timeSentRange)
8683
{
8784
if (timeSentRange?.From != null)
8885
{
@@ -97,7 +94,7 @@ public PostgresqlMessagesQueryBuilder WithTimeSentRange(DateTimeRange? timeSentR
9794
return this;
9895
}
9996

100-
public PostgresqlMessagesQueryBuilder WithSorting(SortInfo sortInfo)
97+
public PostgreSQLMessagesQueryBuilder WithSorting(SortInfo sortInfo)
10198
{
10299
sql.Append(" ORDER BY");
103100
switch (sortInfo.Sort)
@@ -132,7 +129,7 @@ public PostgresqlMessagesQueryBuilder WithSorting(SortInfo sortInfo)
132129
return this;
133130
}
134131

135-
public PostgresqlMessagesQueryBuilder WithPaging(PagingInfo pagingInfo)
132+
public PostgreSQLMessagesQueryBuilder WithPaging(PagingInfo pagingInfo)
136133
{
137134
sql.Append($" LIMIT {pagingInfo.PageSize} OFFSET {pagingInfo.Offset};");
138135
return this;

‎src/ServiceControlInstaller.Packaging.UnitTests/AuditDeploymentPackageTests.cs‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ public AuditDeploymentPackageTests()
1616
public void Should_package_storages_individually()
1717
{
1818
var expectedPersisters = new[] {
19+
"PostgreSQL",
1920
"RavenDB35", // Still must exist, as Raven35 persistence.manifest file must be available for SCMU to understand old versions
2021
"RavenDB"
2122
};

0 commit comments

Comments
 (0)