pauseactivesubscription command

DavidEggenberger · Mar 26, 2024 · 56a4cdb · 56a4cdb
1 parent cc393a7
commit 56a4cdb
Show file tree

Hide file tree

Showing 7 changed files with 31 additions and 47 deletions.
diff --git a/...ds/CreateTrialingSubscriptionForTenant.cs → ...on/Commands/CreateTrialingSubscription.cs b/...ds/CreateTrialingSubscriptionForTenant.cs → ...on/Commands/CreateTrialingSubscription.cs
@@ -9,19 +9,18 @@
 
 namespace Modules.Subscriptions.Features.DomainFeatures.StripeSubscriptionAggregate.Application.Commands
 {
-    public class CreateTrialingSubscriptionForTenant : ICommand
+    public class CreateTrialingSubscription : ICommand
     {
         public Guid UserId { get; set; }
         public Guid TenantId { get; set; }
         public string StripeCustomerId { get; set; }
         public Stripe.Subscription CreatedStripeSubscription { get; set; }
     }
 
-    public class CreateTrialingSubscriptionCommandHandler : ServerExecutionBase, ICommandHandler<CreateTrialingSubscriptionForTenant>
+    public class CreateTrialingSubscriptionCommandHandler : ServerExecutionBase, ICommandHandler<CreateTrialingSubscription>
     {
         private readonly SubscriptionsDbContext subscriptionDbContext;
         private readonly SubscriptionsConfiguration subscriptionConfiguration;
-        private readonly IIntegrationEventDispatcher integrationEventDispatcher;
 
         public CreateTrialingSubscriptionCommandHandler(
             SubscriptionsDbContext subscriptionDbContext,
@@ -32,7 +31,7 @@ public CreateTrialingSubscriptionCommandHandler(
             this.subscriptionConfiguration = subscriptionConfiguration;
         }
 
-        public async Task HandleAsync(CreateTrialingSubscriptionForTenant command, CancellationToken cancellationToken)
+        public async Task HandleAsync(CreateTrialingSubscription command, CancellationToken cancellationToken)
         {
             var subscriptionType = subscriptionConfiguration.Subscriptions.First(s => s.StripePriceId == command.CreatedStripeSubscription.Items.First().Price.Id).Type;
 

diff --git a/...res/DomainFeatures/StripeSubscriptionAggregate/Application/Commands/DeleteSubscription.cs b/...res/DomainFeatures/StripeSubscriptionAggregate/Application/Commands/DeleteSubscription.cs
diff --git a/...n/Commands/UpdateSubscriptionPeriodEnd.cs → ...ation/Commands/PauseActiveSubscription.cs b/...n/Commands/UpdateSubscriptionPeriodEnd.cs → ...ation/Commands/PauseActiveSubscription.cs
@@ -2,14 +2,14 @@
 
 namespace Modules.Subscriptions.Features.DomainFeatures.StripeSubscriptionAggregate.Application.Commands
 {
-    public class UpdateSubscriptionPeriodEnd : ICommand
+    public class UpdateSubscriptionPeriod : ICommand
     {
         public Stripe.Subscription Subscription { get; set; }
     }
 
-    public class UpdateSubscriptionPerioEndCommandHandler : ICommandHandler<UpdateSubscriptionPeriodEnd>
+    public class UpdateSubscriptionPerioEndCommandHandler : ICommandHandler<UpdateSubscriptionPeriod>
     {
-        public Task HandleAsync(UpdateSubscriptionPeriodEnd command, CancellationToken cancellationToken)
+        public Task HandleAsync(UpdateSubscriptionPeriod command, CancellationToken cancellationToken)
         {
             throw new NotImplementedException();
         }

diff --git a/...mainFeatures/StripeSubscriptionAggregate/Application/Commands/UpdateSubscriptionPeriod.cs b/...mainFeatures/StripeSubscriptionAggregate/Application/Commands/UpdateSubscriptionPeriod.cs
@@ -0,0 +1,17 @@
+using Shared.Features.CQRS.Command;
+
+namespace Modules.Subscriptions.Features.DomainFeatures.StripeSubscriptionAggregate.Application.Commands
+{
+    public class UpdateSubscriptionPeriod : ICommand
+    {
+        public Stripe.Subscription Subscription { get; set; }
+    }
+
+    public class UpdateSubscriptionPerioEndCommandHandler : ICommandHandler<UpdateSubscriptionPeriod>
+    {
+        public Task HandleAsync(UpdateSubscriptionPeriod command, CancellationToken cancellationToken)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}
diff --git a/...tion/Commands/GetSubscriptionForTenant.cs → ...ation/Queries/GetSubscriptionForTenant.cs b/...tion/Commands/GetSubscriptionForTenant.cs → ...ation/Queries/GetSubscriptionForTenant.cs
@@ -1,7 +1,7 @@
 using Shared.Features.CQRS.Query;
 using Shared.Kernel.BuildingBlocks.Auth.Attributes;
 
-namespace Modules.Subscriptions.Features.DomainFeatures.StripeSubscriptionAggregate.Application.Commands
+namespace Modules.Subscriptions.Features.DomainFeatures.StripeSubscriptionAggregate.Application.Queries
 {
     [AuthorizeTenantAdmin]
     public class GetSubscriptionForTenant : IQuery<object>

diff --git a/Source/Modules/Subscriptions/Features/Infrastructure/StripePayments/StripeOptions.cs b/Source/Modules/Subscriptions/Features/Infrastructure/StripePayments/StripeOptions.cs
diff --git a/Source/Modules/Subscriptions/Web/Server/WebHooks/StripeWebhook.cs b/Source/Modules/Subscriptions/Web/Server/WebHooks/StripeWebhook.cs
@@ -39,7 +39,7 @@ public async Task<IActionResult> Index()
                     var subscription = await new SubscriptionService().GetAsync(session.SubscriptionId);
                     var userId = subscription.Metadata["UserId"];
 
-                    var createTrialingSubscription = new CreateTrialingSubscriptionForTenant
+                    var createTrialingSubscription = new CreateTrialingSubscription
                     {
                         UserId = Guid.Parse(userId),
                         StripeCustomerId = subscription.CustomerId,
@@ -55,7 +55,12 @@ public async Task<IActionResult> Index()
 
                     var subscription = await new SubscriptionService().GetAsync(invoice.SubscriptionId);
 
-
+                    var updateSubscriptionPeriod = new UpdateSubscriptionPeriod
+                    {
+
+                    };
+
+
                 }
                 // Sent each billing interval if there is an issue with your customer’s payment method. (Stripe)
                 else if (stripeEvent.Type == Events.InvoicePaymentFailed)