Browse Source

default(T) => default

pull/344/head
Sebastian 7 years ago
parent
commit
6c7ccf5fd0
  1. 2
      src/Squidex.Domain.Apps.Entities.MongoDb/Assets/MongoAssetRepository.cs
  2. 2
      src/Squidex.Domain.Apps.Entities.MongoDb/Contents/MongoContentCollection.cs
  3. 2
      src/Squidex.Domain.Apps.Entities.MongoDb/Contents/MongoContentDraftCollection.cs
  4. 2
      src/Squidex.Domain.Apps.Entities.MongoDb/Contents/MongoContentPublishedCollection.cs
  5. 2
      src/Squidex.Domain.Apps.Entities.MongoDb/Contents/MongoContentRepository.cs
  6. 2
      src/Squidex.Domain.Apps.Entities.MongoDb/History/MongoHistoryEventRepository.cs
  7. 4
      src/Squidex.Domain.Apps.Entities.MongoDb/Rules/MongoRuleEventRepository.cs
  8. 2
      src/Squidex.Domain.Apps.Entities/Apps/Diagnostics/OrleansAppsHealthCheck.cs
  9. 2
      src/Squidex.Domain.Apps.Entities/Rules/Repositories/IRuleEventRepository.cs
  10. 2
      src/Squidex.Domain.Users.MongoDb/Infrastructure/MongoPersistedGrantStore.cs
  11. 2
      src/Squidex.Domain.Users.MongoDb/MongoRoleStore.cs
  12. 2
      src/Squidex.Domain.Users.MongoDb/MongoUserStore.cs
  13. 12
      src/Squidex.Infrastructure.Azure/Assets/AzureBlobAssetStore.cs
  14. 2
      src/Squidex.Infrastructure.GetEventStore/Diagnostics/GetEventStoreHealthCheck.cs
  15. 8
      src/Squidex.Infrastructure.GetEventStore/EventSourcing/GetEventStore.cs
  16. 2
      src/Squidex.Infrastructure.GetEventStore/EventSourcing/ProjectionClient.cs
  17. 12
      src/Squidex.Infrastructure.GoogleCloud/Assets/GoogleCloudAssetStore.cs
  18. 12
      src/Squidex.Infrastructure.MongoDb/Assets/MongoGridFsAssetStore.cs
  19. 2
      src/Squidex.Infrastructure.MongoDb/Diagnostics/MongoDBHealthCheck.cs
  20. 2
      src/Squidex.Infrastructure.MongoDb/EventSourcing/MongoEventStore.cs
  21. 6
      src/Squidex.Infrastructure.MongoDb/EventSourcing/MongoEventStore_Reader.cs
  22. 4
      src/Squidex.Infrastructure.MongoDb/MongoDb/MongoExtensions.cs
  23. 6
      src/Squidex.Infrastructure.MongoDb/MongoDb/MongoRepositoryBase.cs
  24. 2
      src/Squidex.Infrastructure.MongoDb/UsageTracking/MongoUsageRepository.cs
  25. 2
      src/Squidex.Infrastructure.RabbitMq/CQRS/Events/RabbitMqEventConsumer.cs
  26. 2
      src/Squidex.Infrastructure.Redis/RedisPubSub.cs
  27. 12
      src/Squidex.Infrastructure/Assets/FolderAssetStore.cs
  28. 8
      src/Squidex.Infrastructure/Assets/IAssetStore.cs
  29. 4
      src/Squidex.Infrastructure/CollectionExtensions.cs
  30. 2
      src/Squidex.Infrastructure/Collections/ArrayDictionary{TKey,TValue}.cs
  31. 2
      src/Squidex.Infrastructure/Commands/LogSnapshotDomainObjectGrain.cs
  32. 2
      src/Squidex.Infrastructure/Diagnostics/GCHealthCheck.cs
  33. 2
      src/Squidex.Infrastructure/Diagnostics/OrleansHealthCheck.cs
  34. 2
      src/Squidex.Infrastructure/Dispatching/FuncContextDispatcher.cs
  35. 2
      src/Squidex.Infrastructure/Dispatching/FuncDispatcher.cs
  36. 6
      src/Squidex.Infrastructure/EventSourcing/EnvelopeExtensions.cs
  37. 4
      src/Squidex.Infrastructure/EventSourcing/IEventStore.cs
  38. 2
      src/Squidex.Infrastructure/IInitializable.cs
  39. 2
      src/Squidex.Infrastructure/Tasks/AsyncLocalCleaner.cs
  40. 4
      src/Squidex.Infrastructure/Tasks/TaskExtensions.cs
  41. 2
      src/Squidex/Config/ServiceExtensions.cs
  42. 4
      tests/Squidex.Domain.Apps.Core.Tests/Model/Schemas/FieldRegistryTests.cs
  43. 2
      tests/Squidex.Domain.Apps.Core.Tests/Operations/HandleRules/RuleServiceTests.cs
  44. 2
      tests/Squidex.Infrastructure.Tests/EventSourcing/Grains/EventConsumerManagerGrainTests.cs
  45. 4
      tests/Squidex.Infrastructure.Tests/MongoDb/MongoExtensionsTests.cs

2
src/Squidex.Domain.Apps.Entities.MongoDb/Assets/MongoAssetRepository.cs

@ -33,7 +33,7 @@ namespace Squidex.Domain.Apps.Entities.MongoDb.Assets
return "States_Assets"; return "States_Assets";
} }
protected override Task SetupCollectionAsync(IMongoCollection<MongoAssetEntity> collection, CancellationToken ct = default(CancellationToken)) protected override Task SetupCollectionAsync(IMongoCollection<MongoAssetEntity> collection, CancellationToken ct = default)
{ {
return collection.Indexes.CreateOneAsync( return collection.Indexes.CreateOneAsync(
new CreateIndexModel<MongoAssetEntity>( new CreateIndexModel<MongoAssetEntity>(

2
src/Squidex.Domain.Apps.Entities.MongoDb/Contents/MongoContentCollection.cs

@ -37,7 +37,7 @@ namespace Squidex.Domain.Apps.Entities.MongoDb.Contents
Serializer = serializer; Serializer = serializer;
} }
protected override async Task SetupCollectionAsync(IMongoCollection<MongoContentEntity> collection, CancellationToken ct = default(CancellationToken)) protected override async Task SetupCollectionAsync(IMongoCollection<MongoContentEntity> collection, CancellationToken ct = default)
{ {
await collection.Indexes.CreateOneAsync( await collection.Indexes.CreateOneAsync(
new CreateIndexModel<MongoContentEntity>(Index.Ascending(x => x.ReferencedIds)), cancellationToken: ct); new CreateIndexModel<MongoContentEntity>(Index.Ascending(x => x.ReferencedIds)), cancellationToken: ct);

2
src/Squidex.Domain.Apps.Entities.MongoDb/Contents/MongoContentDraftCollection.cs

@ -34,7 +34,7 @@ namespace Squidex.Domain.Apps.Entities.MongoDb.Contents
{ {
} }
protected override async Task SetupCollectionAsync(IMongoCollection<MongoContentEntity> collection, CancellationToken ct = default(CancellationToken)) protected override async Task SetupCollectionAsync(IMongoCollection<MongoContentEntity> collection, CancellationToken ct = default)
{ {
await collection.Indexes.CreateManyAsync( await collection.Indexes.CreateManyAsync(
new[] new[]

2
src/Squidex.Domain.Apps.Entities.MongoDb/Contents/MongoContentPublishedCollection.cs

@ -25,7 +25,7 @@ namespace Squidex.Domain.Apps.Entities.MongoDb.Contents
{ {
} }
protected override async Task SetupCollectionAsync(IMongoCollection<MongoContentEntity> collection, CancellationToken ct = default(CancellationToken)) protected override async Task SetupCollectionAsync(IMongoCollection<MongoContentEntity> collection, CancellationToken ct = default)
{ {
await collection.Indexes.CreateManyAsync( await collection.Indexes.CreateManyAsync(
new[] new[]

2
src/Squidex.Domain.Apps.Entities.MongoDb/Contents/MongoContentRepository.cs

@ -46,7 +46,7 @@ namespace Squidex.Domain.Apps.Entities.MongoDb.Contents
this.database = database; this.database = database;
} }
public Task InitializeAsync(CancellationToken ct = default(CancellationToken)) public Task InitializeAsync(CancellationToken ct = default)
{ {
return Task.WhenAll(contentsDraft.InitializeAsync(ct), contentsPublished.InitializeAsync(ct)); return Task.WhenAll(contentsDraft.InitializeAsync(ct), contentsPublished.InitializeAsync(ct));
} }

2
src/Squidex.Domain.Apps.Entities.MongoDb/History/MongoHistoryEventRepository.cs

@ -28,7 +28,7 @@ namespace Squidex.Domain.Apps.Entities.MongoDb.History
return "Projections_History"; return "Projections_History";
} }
protected override Task SetupCollectionAsync(IMongoCollection<HistoryEvent> collection, CancellationToken ct = default(CancellationToken)) protected override Task SetupCollectionAsync(IMongoCollection<HistoryEvent> collection, CancellationToken ct = default)
{ {
return collection.Indexes.CreateManyAsync( return collection.Indexes.CreateManyAsync(
new[] new[]

4
src/Squidex.Domain.Apps.Entities.MongoDb/Rules/MongoRuleEventRepository.cs

@ -32,7 +32,7 @@ namespace Squidex.Domain.Apps.Entities.MongoDb.Rules
return "RuleEvents"; return "RuleEvents";
} }
protected override async Task SetupCollectionAsync(IMongoCollection<MongoRuleEventEntity> collection, CancellationToken ct = default(CancellationToken)) protected override async Task SetupCollectionAsync(IMongoCollection<MongoRuleEventEntity> collection, CancellationToken ct = default)
{ {
await collection.Indexes.CreateManyAsync( await collection.Indexes.CreateManyAsync(
new[] new[]
@ -43,7 +43,7 @@ namespace Squidex.Domain.Apps.Entities.MongoDb.Rules
}, ct); }, ct);
} }
public Task QueryPendingAsync(Instant now, Func<IRuleEventEntity, Task> callback, CancellationToken ct = default(CancellationToken)) public Task QueryPendingAsync(Instant now, Func<IRuleEventEntity, Task> callback, CancellationToken ct = default)
{ {
return Collection.Find(x => x.NextAttempt < now).ForEachAsync(callback, ct); return Collection.Find(x => x.NextAttempt < now).ForEachAsync(callback, ct);
} }

2
src/Squidex.Domain.Apps.Entities/Apps/Diagnostics/OrleansAppsHealthCheck.cs

@ -26,7 +26,7 @@ namespace Squidex.Domain.Apps.Entities.Apps.Diagnostics
index = grainFactory.GetGrain<IAppsByNameIndex>(SingleGrain.Id); index = grainFactory.GetGrain<IAppsByNameIndex>(SingleGrain.Id);
} }
public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default(CancellationToken)) public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
{ {
await index.CountAsync(); await index.CountAsync();

2
src/Squidex.Domain.Apps.Entities/Rules/Repositories/IRuleEventRepository.cs

@ -25,7 +25,7 @@ namespace Squidex.Domain.Apps.Entities.Rules.Repositories
Task MarkSentAsync(Guid jobId, string dump, RuleResult result, RuleJobResult jobResult, TimeSpan elapsed, Instant? nextCall); Task MarkSentAsync(Guid jobId, string dump, RuleResult result, RuleJobResult jobResult, TimeSpan elapsed, Instant? nextCall);
Task QueryPendingAsync(Instant now, Func<IRuleEventEntity, Task> callback, CancellationToken ct = default(CancellationToken)); Task QueryPendingAsync(Instant now, Func<IRuleEventEntity, Task> callback, CancellationToken ct = default);
Task<int> CountByAppAsync(Guid appId); Task<int> CountByAppAsync(Guid appId);

2
src/Squidex.Domain.Users.MongoDb/Infrastructure/MongoPersistedGrantStore.cs

@ -40,7 +40,7 @@ namespace Squidex.Domain.Users.MongoDb.Infrastructure
return "Identity_PersistedGrants"; return "Identity_PersistedGrants";
} }
protected override Task SetupCollectionAsync(IMongoCollection<PersistedGrant> collection, CancellationToken ct = default(CancellationToken)) protected override Task SetupCollectionAsync(IMongoCollection<PersistedGrant> collection, CancellationToken ct = default)
{ {
return collection.Indexes.CreateManyAsync( return collection.Indexes.CreateManyAsync(
new[] new[]

2
src/Squidex.Domain.Users.MongoDb/MongoRoleStore.cs

@ -40,7 +40,7 @@ namespace Squidex.Domain.Users.MongoDb
return "Identity_Roles"; return "Identity_Roles";
} }
protected override Task SetupCollectionAsync(IMongoCollection<IdentityRole> collection, CancellationToken ct = default(CancellationToken)) protected override Task SetupCollectionAsync(IMongoCollection<IdentityRole> collection, CancellationToken ct = default)
{ {
return collection.Indexes.CreateOneAsync( return collection.Indexes.CreateOneAsync(
new CreateIndexModel<IdentityRole>(Index.Ascending(x => x.NormalizedName), new CreateIndexOptions { Unique = true }), cancellationToken: ct); new CreateIndexModel<IdentityRole>(Index.Ascending(x => x.NormalizedName), new CreateIndexOptions { Unique = true }), cancellationToken: ct);

2
src/Squidex.Domain.Users.MongoDb/MongoUserStore.cs

@ -114,7 +114,7 @@ namespace Squidex.Domain.Users.MongoDb
return "Identity_Users"; return "Identity_Users";
} }
protected override Task SetupCollectionAsync(IMongoCollection<MongoUser> collection, CancellationToken ct = default(CancellationToken)) protected override Task SetupCollectionAsync(IMongoCollection<MongoUser> collection, CancellationToken ct = default)
{ {
return collection.Indexes.CreateManyAsync( return collection.Indexes.CreateManyAsync(
new[] new[]

12
src/Squidex.Infrastructure.Azure/Assets/AzureBlobAssetStore.cs

@ -29,7 +29,7 @@ namespace Squidex.Infrastructure.Assets
this.containerName = containerName; this.containerName = containerName;
} }
public async Task InitializeAsync(CancellationToken ct = default(CancellationToken)) public async Task InitializeAsync(CancellationToken ct = default)
{ {
try try
{ {
@ -61,7 +61,7 @@ namespace Squidex.Infrastructure.Assets
return null; return null;
} }
public async Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default(CancellationToken)) public async Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default)
{ {
var targetName = GetObjectName(id, version, suffix); var targetName = GetObjectName(id, version, suffix);
var targetBlob = blobContainer.GetBlobReference(targetName); var targetBlob = blobContainer.GetBlobReference(targetName);
@ -95,7 +95,7 @@ namespace Squidex.Infrastructure.Assets
} }
} }
public async Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)) public async Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default)
{ {
var sourceName = GetObjectName(id, version, suffix); var sourceName = GetObjectName(id, version, suffix);
var sourceBlob = blobContainer.GetBlockBlobReference(sourceName); var sourceBlob = blobContainer.GetBlockBlobReference(sourceName);
@ -110,12 +110,12 @@ namespace Squidex.Infrastructure.Assets
} }
} }
public Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)) public Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default)
{ {
return UploadCoreAsync(GetObjectName(id, version, suffix), stream, ct); return UploadCoreAsync(GetObjectName(id, version, suffix), stream, ct);
} }
public Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default(CancellationToken)) public Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default)
{ {
return UploadCoreAsync(fileName, stream, ct); return UploadCoreAsync(fileName, stream, ct);
} }
@ -137,7 +137,7 @@ namespace Squidex.Infrastructure.Assets
return blob.DeleteIfExistsAsync(); return blob.DeleteIfExistsAsync();
} }
private async Task UploadCoreAsync(string blobName, Stream stream, CancellationToken ct = default(CancellationToken)) private async Task UploadCoreAsync(string blobName, Stream stream, CancellationToken ct = default)
{ {
try try
{ {

2
src/Squidex.Infrastructure.GetEventStore/Diagnostics/GetEventStoreHealthCheck.cs

@ -23,7 +23,7 @@ namespace Squidex.Infrastructure.Diagnostics
this.connection = connection; this.connection = connection;
} }
public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default(CancellationToken)) public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
{ {
await connection.ReadEventAsync("test", 1, false); await connection.ReadEventAsync("test", 1, false);

8
src/Squidex.Infrastructure.GetEventStore/EventSourcing/GetEventStore.cs

@ -38,7 +38,7 @@ namespace Squidex.Infrastructure.EventSourcing
projectionClient = new ProjectionClient(connection, prefix, projectionHost); projectionClient = new ProjectionClient(connection, prefix, projectionHost);
} }
public async Task InitializeAsync(CancellationToken ct = default(CancellationToken)) public async Task InitializeAsync(CancellationToken ct = default)
{ {
try try
{ {
@ -62,7 +62,7 @@ namespace Squidex.Infrastructure.EventSourcing
return projectionClient.CreateProjectionAsync(property, string.Empty); return projectionClient.CreateProjectionAsync(property, string.Empty);
} }
public async Task QueryAsync(Func<StoredEvent, Task> callback, string property, object value, string position = null, CancellationToken ct = default(CancellationToken)) public async Task QueryAsync(Func<StoredEvent, Task> callback, string property, object value, string position = null, CancellationToken ct = default)
{ {
using (Profiler.TraceMethod<GetEventStore>()) using (Profiler.TraceMethod<GetEventStore>())
{ {
@ -74,7 +74,7 @@ namespace Squidex.Infrastructure.EventSourcing
} }
} }
public async Task QueryAsync(Func<StoredEvent, Task> callback, string streamFilter = null, string position = null, CancellationToken ct = default(CancellationToken)) public async Task QueryAsync(Func<StoredEvent, Task> callback, string streamFilter = null, string position = null, CancellationToken ct = default)
{ {
using (Profiler.TraceMethod<GetEventStore>()) using (Profiler.TraceMethod<GetEventStore>())
{ {
@ -86,7 +86,7 @@ namespace Squidex.Infrastructure.EventSourcing
} }
} }
private async Task QueryAsync(Func<StoredEvent, Task> callback, string streamName, long sliceStart, CancellationToken ct = default(CancellationToken)) private async Task QueryAsync(Func<StoredEvent, Task> callback, string streamName, long sliceStart, CancellationToken ct = default)
{ {
StreamEventsSlice currentSlice; StreamEventsSlice currentSlice;
do do

2
src/Squidex.Infrastructure.GetEventStore/EventSourcing/ProjectionClient.cs

@ -104,7 +104,7 @@ namespace Squidex.Infrastructure.EventSourcing
} }
} }
public async Task ConnectAsync(CancellationToken ct = default(CancellationToken)) public async Task ConnectAsync(CancellationToken ct = default)
{ {
var addressParts = projectionHost.Split(':'); var addressParts = projectionHost.Split(':');

12
src/Squidex.Infrastructure.GoogleCloud/Assets/GoogleCloudAssetStore.cs

@ -30,7 +30,7 @@ namespace Squidex.Infrastructure.Assets
this.bucketName = bucketName; this.bucketName = bucketName;
} }
public async Task InitializeAsync(CancellationToken ct = default(CancellationToken)) public async Task InitializeAsync(CancellationToken ct = default)
{ {
try try
{ {
@ -49,7 +49,7 @@ namespace Squidex.Infrastructure.Assets
return null; return null;
} }
public async Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default(CancellationToken)) public async Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default)
{ {
var objectName = GetObjectName(id, version, suffix); var objectName = GetObjectName(id, version, suffix);
@ -67,7 +67,7 @@ namespace Squidex.Infrastructure.Assets
} }
} }
public async Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)) public async Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default)
{ {
var objectName = GetObjectName(id, version, suffix); var objectName = GetObjectName(id, version, suffix);
@ -81,12 +81,12 @@ namespace Squidex.Infrastructure.Assets
} }
} }
public Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)) public Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default)
{ {
return UploadCoreAsync(GetObjectName(id, version, suffix), stream, ct); return UploadCoreAsync(GetObjectName(id, version, suffix), stream, ct);
} }
public Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default(CancellationToken)) public Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default)
{ {
return UploadCoreAsync(fileName, stream, ct); return UploadCoreAsync(fileName, stream, ct);
} }
@ -101,7 +101,7 @@ namespace Squidex.Infrastructure.Assets
return DeleteCoreAsync(fileName); return DeleteCoreAsync(fileName);
} }
private async Task UploadCoreAsync(string objectName, Stream stream, CancellationToken ct = default(CancellationToken)) private async Task UploadCoreAsync(string objectName, Stream stream, CancellationToken ct = default)
{ {
try try
{ {

12
src/Squidex.Infrastructure.MongoDb/Assets/MongoGridFsAssetStore.cs

@ -27,7 +27,7 @@ namespace Squidex.Infrastructure.Assets
this.bucket = bucket; this.bucket = bucket;
} }
public async Task InitializeAsync(CancellationToken ct = default(CancellationToken)) public async Task InitializeAsync(CancellationToken ct = default)
{ {
try try
{ {
@ -44,7 +44,7 @@ namespace Squidex.Infrastructure.Assets
return null; return null;
} }
public async Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default(CancellationToken)) public async Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default)
{ {
try try
{ {
@ -61,7 +61,7 @@ namespace Squidex.Infrastructure.Assets
} }
} }
public async Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)) public async Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default)
{ {
try try
{ {
@ -78,12 +78,12 @@ namespace Squidex.Infrastructure.Assets
} }
} }
public Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)) public Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default)
{ {
return UploadFileCoreAsync(GetFileName(id, version, suffix), stream, ct); return UploadFileCoreAsync(GetFileName(id, version, suffix), stream, ct);
} }
public Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default(CancellationToken)) public Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default)
{ {
return UploadFileCoreAsync(fileName, stream, ct); return UploadFileCoreAsync(fileName, stream, ct);
} }
@ -110,7 +110,7 @@ namespace Squidex.Infrastructure.Assets
} }
} }
private async Task UploadFileCoreAsync(string id, Stream stream, CancellationToken ct = default(CancellationToken)) private async Task UploadFileCoreAsync(string id, Stream stream, CancellationToken ct = default)
{ {
try try
{ {

2
src/Squidex.Infrastructure.MongoDb/Diagnostics/MongoDBHealthCheck.cs

@ -23,7 +23,7 @@ namespace Squidex.Infrastructure.Diagnostics
this.mongoDatabase = mongoDatabase; this.mongoDatabase = mongoDatabase;
} }
public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default(CancellationToken)) public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
{ {
var collectionNames = await mongoDatabase.ListCollectionNamesAsync(cancellationToken: cancellationToken); var collectionNames = await mongoDatabase.ListCollectionNamesAsync(cancellationToken: cancellationToken);

2
src/Squidex.Infrastructure.MongoDb/EventSourcing/MongoEventStore.cs

@ -44,7 +44,7 @@ namespace Squidex.Infrastructure.EventSourcing
return new MongoCollectionSettings { ReadPreference = ReadPreference.Primary, WriteConcern = WriteConcern.WMajority }; return new MongoCollectionSettings { ReadPreference = ReadPreference.Primary, WriteConcern = WriteConcern.WMajority };
} }
protected override Task SetupCollectionAsync(IMongoCollection<MongoEventCommit> collection, CancellationToken ct = default(CancellationToken)) protected override Task SetupCollectionAsync(IMongoCollection<MongoEventCommit> collection, CancellationToken ct = default)
{ {
return collection.Indexes.CreateManyAsync( return collection.Indexes.CreateManyAsync(
new[] new[]

6
src/Squidex.Infrastructure.MongoDb/EventSourcing/MongoEventStore_Reader.cs

@ -69,7 +69,7 @@ namespace Squidex.Infrastructure.EventSourcing
} }
} }
public Task QueryAsync(Func<StoredEvent, Task> callback, string property, object value, string position = null, CancellationToken ct = default(CancellationToken)) public Task QueryAsync(Func<StoredEvent, Task> callback, string property, object value, string position = null, CancellationToken ct = default)
{ {
Guard.NotNull(callback, nameof(callback)); Guard.NotNull(callback, nameof(callback));
@ -80,7 +80,7 @@ namespace Squidex.Infrastructure.EventSourcing
return QueryAsync(callback, lastPosition, filter, ct); return QueryAsync(callback, lastPosition, filter, ct);
} }
public Task QueryAsync(Func<StoredEvent, Task> callback, string streamFilter = null, string position = null, CancellationToken ct = default(CancellationToken)) public Task QueryAsync(Func<StoredEvent, Task> callback, string streamFilter = null, string position = null, CancellationToken ct = default)
{ {
Guard.NotNull(callback, nameof(callback)); Guard.NotNull(callback, nameof(callback));
@ -91,7 +91,7 @@ namespace Squidex.Infrastructure.EventSourcing
return QueryAsync(callback, lastPosition, filter, ct); return QueryAsync(callback, lastPosition, filter, ct);
} }
private async Task QueryAsync(Func<StoredEvent, Task> callback, StreamPosition lastPosition, FilterDefinition<MongoEventCommit> filter, CancellationToken ct = default(CancellationToken)) private async Task QueryAsync(Func<StoredEvent, Task> callback, StreamPosition lastPosition, FilterDefinition<MongoEventCommit> filter, CancellationToken ct = default)
{ {
using (Profiler.TraceMethod<MongoEventStore>()) using (Profiler.TraceMethod<MongoEventStore>())
{ {

4
src/Squidex.Infrastructure.MongoDb/MongoDb/MongoExtensions.cs

@ -149,14 +149,14 @@ namespace Squidex.Infrastructure.MongoDb
} }
} }
public static async Task ForEachPipelineAsync<TDocument>(this IAsyncCursorSource<TDocument> source, Func<TDocument, Task> processor, CancellationToken cancellationToken = default(CancellationToken)) public static async Task ForEachPipelineAsync<TDocument>(this IAsyncCursorSource<TDocument> source, Func<TDocument, Task> processor, CancellationToken cancellationToken = default)
{ {
var cursor = await source.ToCursorAsync(cancellationToken); var cursor = await source.ToCursorAsync(cancellationToken);
await cursor.ForEachPipelineAsync(processor, cancellationToken); await cursor.ForEachPipelineAsync(processor, cancellationToken);
} }
public static async Task ForEachPipelineAsync<TDocument>(this IAsyncCursor<TDocument> source, Func<TDocument, Task> processor, CancellationToken cancellationToken = default(CancellationToken)) public static async Task ForEachPipelineAsync<TDocument>(this IAsyncCursor<TDocument> source, Func<TDocument, Task> processor, CancellationToken cancellationToken = default)
{ {
using (var selfToken = new CancellationTokenSource()) using (var selfToken = new CancellationTokenSource())
{ {

6
src/Squidex.Infrastructure.MongoDb/MongoDb/MongoRepositoryBase.cs

@ -73,7 +73,7 @@ namespace Squidex.Infrastructure.MongoDb
CollectionSettings() ?? new MongoCollectionSettings())); CollectionSettings() ?? new MongoCollectionSettings()));
} }
protected virtual Task SetupCollectionAsync(IMongoCollection<TEntity> collection, CancellationToken ct = default(CancellationToken)) protected virtual Task SetupCollectionAsync(IMongoCollection<TEntity> collection, CancellationToken ct = default)
{ {
return TaskHelper.Done; return TaskHelper.Done;
} }
@ -85,7 +85,7 @@ namespace Squidex.Infrastructure.MongoDb
await SetupCollectionAsync(Collection); await SetupCollectionAsync(Collection);
} }
public async Task<bool> DropCollectionIfExistsAsync(CancellationToken ct = default(CancellationToken)) public async Task<bool> DropCollectionIfExistsAsync(CancellationToken ct = default)
{ {
try try
{ {
@ -103,7 +103,7 @@ namespace Squidex.Infrastructure.MongoDb
} }
} }
public async Task InitializeAsync(CancellationToken ct = default(CancellationToken)) public async Task InitializeAsync(CancellationToken ct = default)
{ {
try try
{ {

2
src/Squidex.Infrastructure.MongoDb/UsageTracking/MongoUsageRepository.cs

@ -29,7 +29,7 @@ namespace Squidex.Infrastructure.UsageTracking
return "UsagesV2"; return "UsagesV2";
} }
protected override Task SetupCollectionAsync(IMongoCollection<MongoUsage> collection, CancellationToken ct = default(CancellationToken)) protected override Task SetupCollectionAsync(IMongoCollection<MongoUsage> collection, CancellationToken ct = default)
{ {
return collection.Indexes.CreateOneAsync( return collection.Indexes.CreateOneAsync(
new CreateIndexModel<MongoUsage>(Index.Ascending(x => x.Key).Ascending(x => x.Category).Ascending(x => x.Date)), cancellationToken: ct); new CreateIndexModel<MongoUsage>(Index.Ascending(x => x.Key).Ascending(x => x.Category).Ascending(x => x.Date)), cancellationToken: ct);

2
src/Squidex.Infrastructure.RabbitMq/CQRS/Events/RabbitMqEventConsumer.cs

@ -62,7 +62,7 @@ namespace Squidex.Infrastructure.CQRS.Events
} }
} }
public Task InitializeAsync(CancellationToken ct = default(CancellationToken)) public Task InitializeAsync(CancellationToken ct = default)
{ {
try try
{ {

2
src/Squidex.Infrastructure.Redis/RedisPubSub.cs

@ -38,7 +38,7 @@ namespace Squidex.Infrastructure
this.serializer = serializer; this.serializer = serializer;
} }
public Task InitializeAsync(CancellationToken ct = default(CancellationToken)) public Task InitializeAsync(CancellationToken ct = default)
{ {
try try
{ {

12
src/Squidex.Infrastructure/Assets/FolderAssetStore.cs

@ -31,7 +31,7 @@ namespace Squidex.Infrastructure.Assets
directory = new DirectoryInfo(path); directory = new DirectoryInfo(path);
} }
public Task InitializeAsync(CancellationToken ct = default(CancellationToken)) public Task InitializeAsync(CancellationToken ct = default)
{ {
try try
{ {
@ -57,7 +57,7 @@ namespace Squidex.Infrastructure.Assets
return null; return null;
} }
public async Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)) public async Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default)
{ {
var file = GetFile(id, version, suffix); var file = GetFile(id, version, suffix);
@ -74,7 +74,7 @@ namespace Squidex.Infrastructure.Assets
} }
} }
public Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default(CancellationToken)) public Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default)
{ {
var targetFile = GetFile(id, version, suffix); var targetFile = GetFile(id, version, suffix);
@ -96,12 +96,12 @@ namespace Squidex.Infrastructure.Assets
} }
} }
public Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)) public Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default)
{ {
return UploadCoreAsync(GetFile(id, version, suffix), stream, ct); return UploadCoreAsync(GetFile(id, version, suffix), stream, ct);
} }
public Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default(CancellationToken)) public Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default)
{ {
return UploadCoreAsync(GetFile(fileName), stream, ct); return UploadCoreAsync(GetFile(fileName), stream, ct);
} }
@ -123,7 +123,7 @@ namespace Squidex.Infrastructure.Assets
return TaskHelper.Done; return TaskHelper.Done;
} }
private static async Task UploadCoreAsync(FileInfo file, Stream stream, CancellationToken ct = default(CancellationToken)) private static async Task UploadCoreAsync(FileInfo file, Stream stream, CancellationToken ct = default)
{ {
try try
{ {

8
src/Squidex.Infrastructure/Assets/IAssetStore.cs

@ -15,13 +15,13 @@ namespace Squidex.Infrastructure.Assets
{ {
string GeneratePublicUrl(string id, long version, string suffix); string GeneratePublicUrl(string id, long version, string suffix);
Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default(CancellationToken)); Task CopyAsync(string sourceFileName, string id, long version, string suffix, CancellationToken ct = default);
Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)); Task DownloadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default);
Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default(CancellationToken)); Task UploadAsync(string fileName, Stream stream, CancellationToken ct = default);
Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default(CancellationToken)); Task UploadAsync(string id, long version, string suffix, Stream stream, CancellationToken ct = default);
Task DeleteAsync(string fileName); Task DeleteAsync(string fileName);

4
src/Squidex.Infrastructure/CollectionExtensions.cs

@ -133,12 +133,12 @@ namespace Squidex.Infrastructure
public static TValue GetOrDefault<TKey, TValue>(this IReadOnlyDictionary<TKey, TValue> dictionary, TKey key) public static TValue GetOrDefault<TKey, TValue>(this IReadOnlyDictionary<TKey, TValue> dictionary, TKey key)
{ {
return dictionary.GetOrCreate(key, _ => default(TValue)); return dictionary.GetOrCreate(key, _ => default);
} }
public static TValue GetOrAddDefault<TKey, TValue>(this IDictionary<TKey, TValue> dictionary, TKey key) public static TValue GetOrAddDefault<TKey, TValue>(this IDictionary<TKey, TValue> dictionary, TKey key)
{ {
return dictionary.GetOrAdd(key, _ => default(TValue)); return dictionary.GetOrAdd(key, _ => default);
} }
public static TValue GetOrNew<TKey, TValue>(this IReadOnlyDictionary<TKey, TValue> dictionary, TKey key) where TValue : class, new() public static TValue GetOrNew<TKey, TValue>(this IReadOnlyDictionary<TKey, TValue> dictionary, TKey key) where TValue : class, new()

2
src/Squidex.Infrastructure/Collections/ArrayDictionary{TKey,TValue}.cs

@ -141,7 +141,7 @@ namespace Squidex.Infrastructure.Collections
} }
} }
value = default(TValue); value = default;
return false; return false;
} }

2
src/Squidex.Infrastructure/Commands/LogSnapshotDomainObjectGrain.cs

@ -51,7 +51,7 @@ namespace Squidex.Infrastructure.Commands
return snapshots[(int)version + 1]; return snapshots[(int)version + 1];
} }
return default(T); return default;
} }
protected sealed override void ApplyEvent(Envelope<IEvent> @event) protected sealed override void ApplyEvent(Envelope<IEvent> @event)

2
src/Squidex.Infrastructure/Diagnostics/GCHealthCheck.cs

@ -25,7 +25,7 @@ namespace Squidex.Infrastructure.Diagnostics
threshold = 1024 * 1024 * options.Value.Threshold; threshold = 1024 * 1024 * options.Value.Threshold;
} }
public Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default(CancellationToken)) public Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
{ {
var allocated = GC.GetTotalMemory(false); var allocated = GC.GetTotalMemory(false);

2
src/Squidex.Infrastructure/Diagnostics/OrleansHealthCheck.cs

@ -24,7 +24,7 @@ namespace Squidex.Infrastructure.Diagnostics
managementGrain = grainFactory.GetGrain<IManagementGrain>(0); managementGrain = grainFactory.GetGrain<IManagementGrain>(0);
} }
public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default(CancellationToken)) public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
{ {
var activationCount = await managementGrain.GetTotalActivationCount(); var activationCount = await managementGrain.GetTotalActivationCount();

2
src/Squidex.Infrastructure/Dispatching/FuncContextDispatcher.cs

@ -48,7 +48,7 @@ namespace Squidex.Infrastructure.Dispatching
}) })
.ToDictionary(m => m.Item1, h => (FuncContextDelegate<TIn>)h.Item2); .ToDictionary(m => m.Item1, h => (FuncContextDelegate<TIn>)h.Item2);
return (target, input, context) => handlers.TryGetValue(input.GetType(), out var handler) ? handler(target, input, context) : default(TOut); return (target, input, context) => handlers.TryGetValue(input.GetType(), out var handler) ? handler(target, input, context) : default;
} }
private static FuncContextDelegate<TIn> Factory<T>(MethodInfo methodInfo) where T : TIn private static FuncContextDelegate<TIn> Factory<T>(MethodInfo methodInfo) where T : TIn

2
src/Squidex.Infrastructure/Dispatching/FuncDispatcher.cs

@ -48,7 +48,7 @@ namespace Squidex.Infrastructure.Dispatching
}) })
.ToDictionary(m => m.Item1, h => (FuncDelegate<TIn>)h.Item2); .ToDictionary(m => m.Item1, h => (FuncDelegate<TIn>)h.Item2);
return (target, input) => handlers.TryGetValue(input.GetType(), out var handler) ? handler(target, input) : default(TOut); return (target, input) => handlers.TryGetValue(input.GetType(), out var handler) ? handler(target, input) : default;
} }
private static FuncDelegate<TIn> Factory<T>(MethodInfo methodInfo) where T : TIn private static FuncDelegate<TIn> Factory<T>(MethodInfo methodInfo) where T : TIn

6
src/Squidex.Infrastructure/EventSourcing/EnvelopeExtensions.cs

@ -114,20 +114,20 @@ namespace Squidex.Infrastructure.EventSourcing
} }
} }
return default(Guid); return default;
} }
public static Instant GetInstant(this JsonObject obj, string key) public static Instant GetInstant(this JsonObject obj, string key)
{ {
if (obj.TryGetValue(key, out var v)) if (obj.TryGetValue(key, out var v))
{ {
if (v.Type == JsonValueType.String && InstantPattern.General.Parse(v.ToString()).TryGetValue(default(Instant), out var instant)) if (v.Type == JsonValueType.String && InstantPattern.General.Parse(v.ToString()).TryGetValue(default, out var instant))
{ {
return instant; return instant;
} }
} }
return default(Instant); return default;
} }
public static string GetString(this JsonObject obj, string key) public static string GetString(this JsonObject obj, string key)

4
src/Squidex.Infrastructure/EventSourcing/IEventStore.cs

@ -18,9 +18,9 @@ namespace Squidex.Infrastructure.EventSourcing
Task<IReadOnlyList<StoredEvent>> QueryAsync(string streamName, long streamPosition = 0); Task<IReadOnlyList<StoredEvent>> QueryAsync(string streamName, long streamPosition = 0);
Task QueryAsync(Func<StoredEvent, Task> callback, string streamFilter = null, string position = null, CancellationToken ct = default(CancellationToken)); Task QueryAsync(Func<StoredEvent, Task> callback, string streamFilter = null, string position = null, CancellationToken ct = default);
Task QueryAsync(Func<StoredEvent, Task> callback, string property, object value, string position = null, CancellationToken ct = default(CancellationToken)); Task QueryAsync(Func<StoredEvent, Task> callback, string property, object value, string position = null, CancellationToken ct = default);
Task AppendAsync(Guid commitId, string streamName, ICollection<EventData> events); Task AppendAsync(Guid commitId, string streamName, ICollection<EventData> events);

2
src/Squidex.Infrastructure/IInitializable.cs

@ -12,6 +12,6 @@ namespace Squidex.Infrastructure
{ {
public interface IInitializable public interface IInitializable
{ {
Task InitializeAsync(CancellationToken ct = default(CancellationToken)); Task InitializeAsync(CancellationToken ct = default);
} }
} }

2
src/Squidex.Infrastructure/Tasks/AsyncLocalCleaner.cs

@ -23,7 +23,7 @@ namespace Squidex.Infrastructure.Tasks
public void Dispose() public void Dispose()
{ {
asyncLocal.Value = default(T); asyncLocal.Value = default;
} }
} }
} }

4
src/Squidex.Infrastructure/Tasks/TaskExtensions.cs

@ -40,7 +40,7 @@ namespace Squidex.Infrastructure.Tasks
{ {
action(x); action(x);
return default(TOutput); return default;
}; };
} }
@ -52,7 +52,7 @@ namespace Squidex.Infrastructure.Tasks
{ {
await action(x); await action(x);
return default(TOutput); return default;
}; };
} }

2
src/Squidex/Config/ServiceExtensions.cs

@ -89,7 +89,7 @@ namespace Squidex.Config
} }
} }
public static T GetOptionalValue<T>(this IConfiguration config, string path, T defaultValue = default(T)) public static T GetOptionalValue<T>(this IConfiguration config, string path, T defaultValue = default)
{ {
var value = config.GetValue(path, defaultValue); var value = config.GetValue(path, defaultValue);

4
tests/Squidex.Domain.Apps.Core.Tests/Model/Schemas/FieldRegistryTests.cs

@ -20,12 +20,12 @@ namespace Squidex.Domain.Apps.Core.Model.Schemas
{ {
public override T Accept<T>(IFieldPropertiesVisitor<T> visitor) public override T Accept<T>(IFieldPropertiesVisitor<T> visitor)
{ {
return default(T); return default;
} }
public override T Accept<T>(IFieldVisitor<T> visitor, IField field) public override T Accept<T>(IFieldVisitor<T> visitor, IField field)
{ {
return default(T); return default;
} }
public override RootField CreateRootField(long id, string name, Partitioning partitioning, IFieldSettings settings = null) public override RootField CreateRootField(long id, string name, Partitioning partitioning, IFieldSettings settings = null)

2
tests/Squidex.Domain.Apps.Core.Tests/Operations/HandleRules/RuleServiceTests.cs

@ -60,7 +60,7 @@ namespace Squidex.Domain.Apps.Core.Operations.HandleRules
{ {
public override T Accept<T>(IRuleTriggerVisitor<T> visitor) public override T Accept<T>(IRuleTriggerVisitor<T> visitor)
{ {
return default(T); return default;
} }
} }

2
tests/Squidex.Infrastructure.Tests/EventSourcing/Grains/EventConsumerManagerGrainTests.cs

@ -69,7 +69,7 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
[Fact] [Fact]
public async Task Should_activate_all_grains_on_reminder() public async Task Should_activate_all_grains_on_reminder()
{ {
await sut.ReceiveReminder(null, default(TickStatus)); await sut.ReceiveReminder(null, default);
A.CallTo(() => grainA.ActivateAsync()) A.CallTo(() => grainA.ActivateAsync())
.MustHaveHappened(); .MustHaveHappened();

4
tests/Squidex.Infrastructure.Tests/MongoDb/MongoExtensionsTests.cs

@ -54,14 +54,14 @@ namespace Squidex.Infrastructure.MongoDb
{ {
} }
public bool MoveNext(CancellationToken cancellationToken = default(CancellationToken)) public bool MoveNext(CancellationToken cancellationToken = default)
{ {
index++; index++;
return index < items.Count; return index < items.Count;
} }
public async Task<bool> MoveNextAsync(CancellationToken cancellationToken = default(CancellationToken)) public async Task<bool> MoveNextAsync(CancellationToken cancellationToken = default)
{ {
await Task.Delay(1, cancellationToken); await Task.Delay(1, cancellationToken);

Loading…
Cancel
Save