Skip to content

Commit

Permalink
Moved internal packages to exist public packages (#277)
Browse files Browse the repository at this point in the history
* Moved InMemoryTransport

* Moved SequentialGuid

* Moved all locks

* Moved event hooks
  • Loading branch information
adimiko authored Jun 12, 2024
1 parent 976b255 commit 99e0e36
Show file tree
Hide file tree
Showing 94 changed files with 157 additions and 376 deletions.
62 changes: 0 additions & 62 deletions TransactionalBox.sln
Original file line number Diff line number Diff line change
Expand Up @@ -23,26 +23,6 @@ Project("{E53339B2-1760-4266-BCC7-CA923CBCF16C}") = "TransactionalBoxWithWorkers
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.Sample.WebApi.InMemory", "samples\TransactionalBox.Sample.WebApi.InMemory\TransactionalBox.Sample.WebApi.InMemory.csproj", "{5C2EB157-F976-42F9-8B26-42A50898714C}"
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Internals", "Internals", "{9C70A8B9-322F-49D5-AF08-889B6BBB161C}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.Internals.EventHooks", "source\Internals\TransactionalBox.Internals.EventHooks\TransactionalBox.Internals.EventHooks.csproj", "{891F6713-08CE-4FCF-881C-BBA258C18C72}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.Internals.KeyedInMemoryLock", "source\Internals\TransactionalBox.Internals.KeyedInMemoryLock\TransactionalBox.Internals.KeyedInMemoryLock.csproj", "{59EA3E37-092B-4E7C-A14F-CC6FD58709FC}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.Internals.Transport.InMemory", "source\Internals\TransactionalBox.Internals.Transport.InMemory\TransactionalBox.Internals.Transport.InMemory.csproj", "{876EE663-DA64-460F-91C1-4FC281D17D00}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.Internals.DistributedLock.EntityFrameworkCore", "source\Internals\TransactionalBox.Internals.DistributedLock.EntityFrameworkCore\TransactionalBox.Internals.DistributedLock.EntityFrameworkCore.csproj", "{504D1EFF-49E7-460D-8531-ECC4B43FBBBC}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.Internals.DistributedLock", "source\Internals\TransactionalBox.Internals.DistributedLock\TransactionalBox.Internals.DistributedLock.csproj", "{2EBB9634-0717-4A5C-9D83-5FC19CC15C80}"
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Internals", "Internals", "{824310B6-2605-450F-B959-88411A7BD6BE}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.Internals.DistributedLock.EntityFrameworkCore.Tests", "tests\Internals\TransactionalBox.Internals.DistributedLock.EntityFrameworkCore.Tests\TransactionalBox.Internals.DistributedLock.EntityFrameworkCore.Tests.csproj", "{FFA83AFD-4303-4447-99DD-6FEEEB9FC2C4}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.Internals.KeyedInMemoryLock.Tests", "tests\Internals\TransactionalBox.Internals.KeyedInMemoryLock.Tests\TransactionalBox.Internals.KeyedInMemoryLock.Tests.csproj", "{032F6352-5C69-49AF-9275-28E813254591}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.Internals.SequentialGuid", "source\Internals\TransactionalBox.Internals.SequentialGuid\TransactionalBox.Internals.SequentialGuid.csproj", "{57CFF2F1-FB52-4719-A373-A2171A390FEC}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TransactionalBox.End2EndTests", "tests\TransactionalBox.End2EndTests\TransactionalBox.End2EndTests.csproj", "{06A55E8C-9D5B-4E12-B64B-EC59690818C9}"
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Bank", "Bank", "{6BB61EDF-B793-4CD2-94F5-9B11E131845E}"
Expand Down Expand Up @@ -99,38 +79,6 @@ Global
{5C2EB157-F976-42F9-8B26-42A50898714C}.Debug|Any CPU.Build.0 = Debug|Any CPU
{5C2EB157-F976-42F9-8B26-42A50898714C}.Release|Any CPU.ActiveCfg = Release|Any CPU
{5C2EB157-F976-42F9-8B26-42A50898714C}.Release|Any CPU.Build.0 = Release|Any CPU
{891F6713-08CE-4FCF-881C-BBA258C18C72}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{891F6713-08CE-4FCF-881C-BBA258C18C72}.Debug|Any CPU.Build.0 = Debug|Any CPU
{891F6713-08CE-4FCF-881C-BBA258C18C72}.Release|Any CPU.ActiveCfg = Release|Any CPU
{891F6713-08CE-4FCF-881C-BBA258C18C72}.Release|Any CPU.Build.0 = Release|Any CPU
{59EA3E37-092B-4E7C-A14F-CC6FD58709FC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{59EA3E37-092B-4E7C-A14F-CC6FD58709FC}.Debug|Any CPU.Build.0 = Debug|Any CPU
{59EA3E37-092B-4E7C-A14F-CC6FD58709FC}.Release|Any CPU.ActiveCfg = Release|Any CPU
{59EA3E37-092B-4E7C-A14F-CC6FD58709FC}.Release|Any CPU.Build.0 = Release|Any CPU
{876EE663-DA64-460F-91C1-4FC281D17D00}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{876EE663-DA64-460F-91C1-4FC281D17D00}.Debug|Any CPU.Build.0 = Debug|Any CPU
{876EE663-DA64-460F-91C1-4FC281D17D00}.Release|Any CPU.ActiveCfg = Release|Any CPU
{876EE663-DA64-460F-91C1-4FC281D17D00}.Release|Any CPU.Build.0 = Release|Any CPU
{504D1EFF-49E7-460D-8531-ECC4B43FBBBC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{504D1EFF-49E7-460D-8531-ECC4B43FBBBC}.Debug|Any CPU.Build.0 = Debug|Any CPU
{504D1EFF-49E7-460D-8531-ECC4B43FBBBC}.Release|Any CPU.ActiveCfg = Release|Any CPU
{504D1EFF-49E7-460D-8531-ECC4B43FBBBC}.Release|Any CPU.Build.0 = Release|Any CPU
{2EBB9634-0717-4A5C-9D83-5FC19CC15C80}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{2EBB9634-0717-4A5C-9D83-5FC19CC15C80}.Debug|Any CPU.Build.0 = Debug|Any CPU
{2EBB9634-0717-4A5C-9D83-5FC19CC15C80}.Release|Any CPU.ActiveCfg = Release|Any CPU
{2EBB9634-0717-4A5C-9D83-5FC19CC15C80}.Release|Any CPU.Build.0 = Release|Any CPU
{FFA83AFD-4303-4447-99DD-6FEEEB9FC2C4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{FFA83AFD-4303-4447-99DD-6FEEEB9FC2C4}.Debug|Any CPU.Build.0 = Debug|Any CPU
{FFA83AFD-4303-4447-99DD-6FEEEB9FC2C4}.Release|Any CPU.ActiveCfg = Release|Any CPU
{FFA83AFD-4303-4447-99DD-6FEEEB9FC2C4}.Release|Any CPU.Build.0 = Release|Any CPU
{032F6352-5C69-49AF-9275-28E813254591}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{032F6352-5C69-49AF-9275-28E813254591}.Debug|Any CPU.Build.0 = Debug|Any CPU
{032F6352-5C69-49AF-9275-28E813254591}.Release|Any CPU.ActiveCfg = Release|Any CPU
{032F6352-5C69-49AF-9275-28E813254591}.Release|Any CPU.Build.0 = Release|Any CPU
{57CFF2F1-FB52-4719-A373-A2171A390FEC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{57CFF2F1-FB52-4719-A373-A2171A390FEC}.Debug|Any CPU.Build.0 = Debug|Any CPU
{57CFF2F1-FB52-4719-A373-A2171A390FEC}.Release|Any CPU.ActiveCfg = Release|Any CPU
{57CFF2F1-FB52-4719-A373-A2171A390FEC}.Release|Any CPU.Build.0 = Release|Any CPU
{06A55E8C-9D5B-4E12-B64B-EC59690818C9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{06A55E8C-9D5B-4E12-B64B-EC59690818C9}.Debug|Any CPU.Build.0 = Debug|Any CPU
{06A55E8C-9D5B-4E12-B64B-EC59690818C9}.Release|Any CPU.ActiveCfg = Release|Any CPU
Expand Down Expand Up @@ -179,16 +127,6 @@ Global
{26ECF009-798E-4AEA-B8B1-E11FEED33FB0} = {D018E603-5AE9-4B1B-BF33-04EB0B5D6913}
{D89EDC24-3316-4A91-8442-6D1ABAFEDEBF} = {D018E603-5AE9-4B1B-BF33-04EB0B5D6913}
{5C2EB157-F976-42F9-8B26-42A50898714C} = {D018E603-5AE9-4B1B-BF33-04EB0B5D6913}
{9C70A8B9-322F-49D5-AF08-889B6BBB161C} = {8FC46C4A-3C0C-458F-ACF5-F35F728A2988}
{891F6713-08CE-4FCF-881C-BBA258C18C72} = {9C70A8B9-322F-49D5-AF08-889B6BBB161C}
{59EA3E37-092B-4E7C-A14F-CC6FD58709FC} = {9C70A8B9-322F-49D5-AF08-889B6BBB161C}
{876EE663-DA64-460F-91C1-4FC281D17D00} = {9C70A8B9-322F-49D5-AF08-889B6BBB161C}
{504D1EFF-49E7-460D-8531-ECC4B43FBBBC} = {9C70A8B9-322F-49D5-AF08-889B6BBB161C}
{2EBB9634-0717-4A5C-9D83-5FC19CC15C80} = {9C70A8B9-322F-49D5-AF08-889B6BBB161C}
{824310B6-2605-450F-B959-88411A7BD6BE} = {6DEFBC37-33F1-4E42-9A7E-2752E9AD3187}
{FFA83AFD-4303-4447-99DD-6FEEEB9FC2C4} = {824310B6-2605-450F-B959-88411A7BD6BE}
{032F6352-5C69-49AF-9275-28E813254591} = {824310B6-2605-450F-B959-88411A7BD6BE}
{57CFF2F1-FB52-4719-A373-A2171A390FEC} = {9C70A8B9-322F-49D5-AF08-889B6BBB161C}
{06A55E8C-9D5B-4E12-B64B-EC59690818C9} = {6DEFBC37-33F1-4E42-9A7E-2752E9AD3187}
{6BB61EDF-B793-4CD2-94F5-9B11E131845E} = {D018E603-5AE9-4B1B-BF33-04EB0B5D6913}
{580972A5-B9DC-49B0-8CFB-28412E3FC5C5} = {6BB61EDF-B793-4CD2-94F5-9B11E131845E}
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
using Microsoft.EntityFrameworkCore;
using TransactionalBox.EntityFrameworkCore.Internals.Inbox.EntityTypeConfigurations;
using TransactionalBox.EntityFrameworkCore.Internals.InternalPackages.DistributedLock;
using TransactionalBox.Internals.Inbox.Storage;

namespace TransactionalBox
Expand All @@ -10,7 +11,7 @@ public static void AddInbox(this ModelBuilder modelBuilder)
{
modelBuilder.ApplyConfiguration(new InboxMessageEntityTypeConfiguration());
modelBuilder.ApplyConfiguration(new IdempotentInboxKeyEntityTypeConfiguration());
modelBuilder.AddDistributedLock<InboxDistributedLock>();
modelBuilder.AddEntityFrameworkCoreDistributedLock<InboxDistributedLock>();
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,8 @@
using TransactionalBox.Configurators.Inbox;
using TransactionalBox.Internals.Inbox.Storage;
using TransactionalBox.Internals.Inbox.Storage.ContractsToImplement;
using TransactionalBox.Internals.InternalPackages.DistributedLock;
using TransactionalBox.EntityFrameworkCore.Internals.InternalPackages.DistributedLock;

namespace TransactionalBox
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
using Microsoft.EntityFrameworkCore;
using TransactionalBox.EntityFrameworkCore.Internals.InternalPackages.DistributedLock;
using TransactionalBox.EntityFrameworkCore.Internals.Outbox.EntityTypeConfigurations;
using TransactionalBox.Internals.Outbox.Storage;

Expand All @@ -9,7 +10,7 @@ public static class OutboxExtensionAddOutbox
public static void AddOutbox(this ModelBuilder modelBuilder)
{
modelBuilder.ApplyConfiguration(new OutboxMessageEntityTypeConfiguration());
modelBuilder.AddDistributedLock<OutboxDistributedLock>();
modelBuilder.AddEntityFrameworkCoreDistributedLock<OutboxDistributedLock>();
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,8 @@
using TransactionalBox.Configurators.Outbox;
using TransactionalBox.Internals.Outbox.Storage.ContractsToImplement;
using TransactionalBox.Internals.Outbox.Storage;
using TransactionalBox.Internals.InternalPackages.DistributedLock;
using TransactionalBox.EntityFrameworkCore.Internals.InternalPackages.DistributedLock;

namespace TransactionalBox
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
using Microsoft.EntityFrameworkCore;
using TransactionalBox.Internals.DistributedLock;
using System.Data;
using TransactionalBox.Internals.Inbox.Storage;
using TransactionalBox.Internals.Inbox.Storage.ContractsToImplement;
using TransactionalBox.Internals.InternalPackages.DistributedLock;

namespace TransactionalBox.EntityFrameworkCore.Internals.Inbox.ImplementedContracts
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
using Microsoft.EntityFrameworkCore;
using System.Data;
using TransactionalBox.Internals.DistributedLock.Internals.Contracts;
using TransactionalBox.Internals.InternalPackages.DistributedLock;

namespace TransactionalBox.Internals.DistributedLock.EntityFrameworkCore.Internals
namespace TransactionalBox.EntityFrameworkCore.Internals.InternalPackages.DistributedLock
{
internal sealed class EntityFrameworkDistributedLockStorage : IDistributedLockStorage
{
Expand All @@ -13,8 +13,8 @@ public EntityFrameworkDistributedLockStorage(DbContext dbContext)
_dbContext = dbContext;
}

public async Task AddFirstLock<T>(T @lock)
where T : Lock, new()
public async Task AddFirstLock<T>(T @lock)
where T : Lock, new()
{
if (!await _dbContext.Set<T>().AnyAsync(x => x.Key == @lock.Key).ConfigureAwait(false))
{
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
using Microsoft.EntityFrameworkCore;
using TransactionalBox.Internals.InternalPackages.DistributedLock;

namespace TransactionalBox.EntityFrameworkCore.Internals.InternalPackages.DistributedLock
{
internal static class ExtensionAddEntityFrameworkCoreDistributedLock
{
internal static void AddEntityFrameworkCoreDistributedLock<T>(this ModelBuilder modelBuilder)
where T : Lock, new()
{
modelBuilder.ApplyConfiguration(new LockEntityTypeConfiguration<T>());
}
}
}
Original file line number Diff line number Diff line change
@@ -1,10 +1,8 @@
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using TransactionalBox.Internals.DistributedLock.Configurators;
using TransactionalBox.Internals.DistributedLock.EntityFrameworkCore.Internals;
using TransactionalBox.Internals.DistributedLock.Internals.Contracts;
using TransactionalBox.Internals.InternalPackages.DistributedLock;

namespace TransactionalBox
namespace TransactionalBox.EntityFrameworkCore.Internals.InternalPackages.DistributedLock
{
internal static class ExtensionUseEntityFrameworkCore
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Metadata.Builders;
using TransactionalBox.Internals.InternalPackages.DistributedLock;

namespace TransactionalBox.Internals.DistributedLock.EntityFrameworkCore.Internals
namespace TransactionalBox.EntityFrameworkCore.Internals.InternalPackages.DistributedLock
{
internal sealed class LockEntityTypeConfiguration<T> : IEntityTypeConfiguration<T>
where T : Lock
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using Microsoft.EntityFrameworkCore;
using System.Data;
using TransactionalBox.Internals.DistributedLock;
using TransactionalBox.Internals.InternalPackages.DistributedLock;
using TransactionalBox.Internals.Outbox.Storage;
using TransactionalBox.Internals.Outbox.Storage.ContractsToImplement;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,13 @@
<Project Sdk="Microsoft.NET.Sdk">
<ItemGroup>
<PackageReference Include="Microsoft.EntityFrameworkCore" />
<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\Internals\TransactionalBox.Internals.DistributedLock.EntityFrameworkCore\TransactionalBox.Internals.DistributedLock.EntityFrameworkCore.csproj" />
<ProjectReference Include="..\TransactionalBox\TransactionalBox.csproj" />
</ItemGroup>

<ItemGroup>
<InternalsVisibleTo Include="TransactionalBox.End2EndTests" />
</ItemGroup>
</Project>
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
using TransactionalBox.Settings.Inbox;
using TransactionalBox.Internals.Inbox.Configurators;
using TransactionalBox.Internals.Inbox.InboxDefinitions;
using TransactionalBox.Internals.InternalPackages.EventHooks;

namespace TransactionalBox
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,5 @@
using Microsoft.Extensions.DependencyInjection;
using TransactionalBox.Builders;
using TransactionalBox.Internals.SequentialGuid;
using TransactionalBox.Internals.SequentialGuid.Internals;
using TransactionalBox.Settings.Outbox;
using TransactionalBox.Configurators.Outbox;
using TransactionalBox.Internals.Outbox.Configurators;
Expand All @@ -16,6 +14,8 @@
using TransactionalBox.Internals.Outbox.Hooks.Handlers.AddMessagesToTransport.Logger;
using TransactionalBox.Internals.Outbox;
using TransactionalBox.Internals.Outbox.OutboxDefinitions;
using TransactionalBox.Internals.InternalPackages.SequentialGuid;
using TransactionalBox.Internals.InternalPackages.EventHooks;

namespace TransactionalBox
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
using Microsoft.Extensions.DependencyInjection;
using System.Text.Json;
using TransactionalBox.Internals.EventHooks;
using TransactionalBox.Internals;
using TransactionalBox.Internals.Inbox.Contexts;
using TransactionalBox.Internals.Inbox.BackgroundProcesses.AddMessagesToInbox.Logger;
Expand All @@ -11,6 +10,7 @@
using TransactionalBox.Internals.Inbox.Transport.ContractsToImplement;
using TransactionalBox.Internals.Inbox.Transport.Topics;
using TransactionalBox.Internals.Inbox.Decompression;
using TransactionalBox.Internals.InternalPackages.EventHooks;

namespace TransactionalBox.Internals.Inbox.BackgroundProcesses.AddMessagesToInbox
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
using TransactionalBox.Internals.Inbox.Storage.ContractsToImplement;
using TransactionalBox.Internals.Inbox.Storage.InMemory;
using TransactionalBox.Configurators.Inbox;
using TransactionalBox.Internals.InternalPackages.KeyedInMemoryLock;

namespace TransactionalBox.Internals.Inbox.Extensions
{
Expand Down
Loading

0 comments on commit 99e0e36

Please sign in to comment.