Skip to content

Commit db10bb9

Browse files
committed
chore: Modify obsolete wording and bad code smell
1 parent 5e44df4 commit db10bb9

File tree

7 files changed

+20
-13
lines changed

7 files changed

+20
-13
lines changed

src/Contrib/StackSdks/Masa.Contrib.StackSdks.Tsc.Elasticsearch/Extenistions/ServiceExtenistion.cs

+3-3
Original file line numberDiff line numberDiff line change
@@ -90,12 +90,12 @@ private static IServiceCollection AddElasticsearch(IServiceCollection services,
9090
});
9191
}
9292

93-
internal static IElasticClient CreateElasticClient(this IElasticsearchFactory elasticsearchFactory, bool isLog)
93+
internal static IElasticClient CreateElasticClient(this IElasticClientFactory elasticsearchFactory, bool isLog)
9494
{
9595
if (isLog)
96-
return elasticsearchFactory.CreateElasticClient(ElasticConstant.Log.IsIndependent ? ElasticConstant.LOG_CALLER_CLIENT_NAME : ElasticConstant.DEFAULT_CALLER_CLIENT_NAME);
96+
return elasticsearchFactory.Create(ElasticConstant.Log.IsIndependent ? ElasticConstant.LOG_CALLER_CLIENT_NAME : ElasticConstant.DEFAULT_CALLER_CLIENT_NAME);
9797
else
98-
return elasticsearchFactory.CreateElasticClient(ElasticConstant.Trace.IsIndependent ? ElasticConstant.TRACE_CALLER_CLIENT_NAME : ElasticConstant.DEFAULT_CALLER_CLIENT_NAME);
98+
return elasticsearchFactory.Create(ElasticConstant.Trace.IsIndependent ? ElasticConstant.TRACE_CALLER_CLIENT_NAME : ElasticConstant.DEFAULT_CALLER_CLIENT_NAME);
9999
}
100100

101101
internal static ICaller Create(this ICallerFactory callerFactory, bool isLog)

src/Contrib/StackSdks/Masa.Contrib.StackSdks.Tsc.Elasticsearch/LogService.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,9 @@ internal class LogService : ILogService
88
private readonly IElasticClient _client;
99
private readonly ICallerFactory _callerFactory;
1010

11-
public LogService(IElasticsearchFactory elasticsearchFactory, ICallerFactory callerFactory)
11+
public LogService(IElasticClientFactory elasticClientFactory, ICallerFactory callerFactory)
1212
{
13-
_client = elasticsearchFactory.CreateElasticClient(true);
13+
_client = elasticClientFactory.CreateElasticClient(true);
1414
_callerFactory = callerFactory;
1515
}
1616

src/Contrib/StackSdks/Masa.Contrib.StackSdks.Tsc.Elasticsearch/TraceService.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,9 @@ internal class TraceService : ITraceService
77
{
88
private readonly IElasticClient _client;
99

10-
public TraceService(IElasticsearchFactory elasticsearchFactory)
10+
public TraceService(IElasticClientFactory elasticClientFactory)
1111
{
12-
_client = elasticsearchFactory.CreateElasticClient(false);
12+
_client = elasticClientFactory.CreateElasticClient(false);
1313
}
1414

1515
public async Task<object> AggregateAsync(SimpleAggregateRequestDto query)

src/Contrib/StackSdks/Tests/Masa.Contrib.StackSdks.Tsc.Elasticsearch.Tests/Extensions/ServiceExtenistionTests.cs

+3
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33

44
namespace Masa.Contrib.StackSdks.Tsc.Elasticsearch.Tests.Extensions;
55

6+
#pragma warning disable CS0618
67
[TestClass]
78
public class ServiceExtenistionTests
89
{
@@ -23,6 +24,7 @@ public void AddLogNodesTest()
2324

2425
var factory = services.BuildServiceProvider().GetRequiredService<IElasticsearchFactory>();
2526
Assert.IsNotNull(factory);
27+
2628
Assert.IsNotNull(factory.CreateElasticClient(ElasticConstant.LOG_CALLER_CLIENT_NAME));
2729
Assert.ThrowsException<NotSupportedException>(() => factory.CreateElasticClient(ElasticConstant.TRACE_CALLER_CLIENT_NAME));
2830
Assert.ThrowsException<NotSupportedException>(() => factory.CreateElasticClient(ElasticConstant.DEFAULT_CALLER_CLIENT_NAME));
@@ -133,3 +135,4 @@ public void AddLogTraceOptionsTest()
133135
Assert.IsNotNull(factory.CreateElasticClient(ElasticConstant.DEFAULT_CALLER_CLIENT_NAME));
134136
}
135137
}
138+
#pragma warning restore CS0618

src/Utils/Data/Masa.Utils.Data.Elasticsearch/DefaultElasticClientFactory.cs

+3-3
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ public IElasticClient Create()
2121

2222
if (elasticsearchOptions.Nodes is null) elasticsearchOptions = _elasticsearchOptions.Get(_names.FirstOrDefault());
2323

24-
if (elasticsearchOptions.Nodes is null) throw new Exception("The default ElasticClient is not found, please check if Elasticsearch is added");
24+
if (elasticsearchOptions.Nodes is null) throw new ArgumentException("The default ElasticClient is not found, please check if Elasticsearch is added");
2525

2626
return Create(elasticsearchOptions);
2727
}
@@ -43,15 +43,15 @@ private IElasticClient Create(ElasticsearchOptions elasticsearchOptions)
4343
return new ElasticClient(settings);
4444
}
4545

46-
private ConnectionSettings GetConnectionSettingsBySingleNode(ElasticsearchOptions relation)
46+
private static ConnectionSettings GetConnectionSettingsBySingleNode(ElasticsearchOptions relation)
4747
{
4848
var connectionSetting = new ConnectionSettings(new Uri(relation.Nodes[0]))
4949
.EnableApiVersioningHeader();
5050
relation.Action?.Invoke(connectionSetting);
5151
return connectionSetting;
5252
}
5353

54-
private ConnectionSettings GetConnectionSettingsConnectionPool(ElasticsearchOptions relation)
54+
private static ConnectionSettings GetConnectionSettingsConnectionPool(ElasticsearchOptions relation)
5555
{
5656
var pool = new StaticConnectionPool(
5757
relation.Nodes.Select(node => new Uri(node)),

src/Utils/Data/Masa.Utils.Data.Elasticsearch/Extensions/ServiceCollectionExtensions.cs

+3-3
Original file line numberDiff line numberDiff line change
@@ -34,9 +34,9 @@ public static IServiceCollection AddElasticsearch(this IServiceCollection servic
3434
{
3535
ArgumentNullException.ThrowIfNull(name);
3636

37-
AddElasticsearchCore(services);
38-
39-
services.AddElasticsearchOptions(name, func.Invoke());
37+
services
38+
.AddElasticsearchCore()
39+
.AddElasticsearchOptions(name, func.Invoke());
4040

4141
return services;
4242
}

src/Utils/Data/Masa.Utils.Data.Elasticsearch/IElasticsearchFactory.cs

+4
Original file line numberDiff line numberDiff line change
@@ -5,11 +5,15 @@ namespace Masa.Utils.Data.Elasticsearch;
55

66
public interface IElasticsearchFactory
77
{
8+
[Obsolete("Please use IMasaElasticClientFactory.Create() instead")]
89
IMasaElasticClient CreateClient();
910

11+
[Obsolete("Please use IMasaElasticClientFactory.Create(name) instead")]
1012
IMasaElasticClient CreateClient(string name);
1113

14+
[Obsolete("Please use IElasticClientFactory.Create() instead")]
1215
IElasticClient CreateElasticClient();
1316

17+
[Obsolete("Please use IElasticClientFactory.Create(name) instead")]
1418
IElasticClient CreateElasticClient(string name);
1519
}

0 commit comments

Comments
 (0)