update stripe subscription

DavidEggenberger · Mar 27, 2024 · 3b5ae4f · 3b5ae4f
1 parent 56a4cdb
commit 3b5ae4f
Show file tree

Hide file tree

Showing 4 changed files with 41 additions and 8 deletions.
diff --git a/...inFeatures/StripeSubscriptionAggregate/Application/Commands/CreateTrialingSubscription.cs b/...inFeatures/StripeSubscriptionAggregate/Application/Commands/CreateTrialingSubscription.cs
@@ -40,7 +40,13 @@ public async Task HandleAsync(CreateTrialingSubscription command, CancellationTo
 
             var tenantId = new Guid(command.CreatedStripeSubscription.Metadata["TenantId"]);
 
-            var stripeSubscription = StripeSubscription.Create(command.CreatedStripeSubscription.TrialEnd, subscriptionType, StripeSubscriptionStatus.Trialing, tenantId, stripeCustomer);
+            var stripeSubscription = StripeSubscription.Create(
+                command.CreatedStripeSubscription.TrialEnd, 
+                command.CreatedStripeSubscription.Id, 
+                subscriptionType,
+                StripeSubscriptionStatus.Trialing, 
+                tenantId, 
+                stripeCustomer);
 
             subscriptionDbContext.StripeSubscriptions.Add(stripeSubscription);
 

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

diff --git a/...mainFeatures/StripeSubscriptionAggregate/Application/Commands/UpdateSubscriptionPeriod.cs b/...mainFeatures/StripeSubscriptionAggregate/Application/Commands/UpdateSubscriptionPeriod.cs
@@ -1,4 +1,8 @@
-using Shared.Features.CQRS.Command;
+using Microsoft.EntityFrameworkCore;
+using Modules.Subscription.Features.Infrastructure.Configuration;
+using Modules.Subscription.Features.Infrastructure.EFCore;
+using Shared.Features.CQRS.Command;
+using Shared.Features.Server;
 
 namespace Modules.Subscriptions.Features.DomainFeatures.StripeSubscriptionAggregate.Application.Commands
 {
@@ -7,11 +11,31 @@ public class UpdateSubscriptionPeriod : ICommand
         public Stripe.Subscription Subscription { get; set; }
     }
 
-    public class UpdateSubscriptionPerioEndCommandHandler : ICommandHandler<UpdateSubscriptionPeriod>
+    public class UpdateSubscriptionPerioEndCommandHandler : ServerExecutionBase, ICommandHandler<UpdateSubscriptionPeriod>
     {
-        public Task HandleAsync(UpdateSubscriptionPeriod command, CancellationToken cancellationToken)
+        private readonly SubscriptionsDbContext subscriptionDbContext;
+        private readonly SubscriptionsConfiguration subscriptionConfiguration;
+
+        public UpdateSubscriptionPerioEndCommandHandler(
+            SubscriptionsDbContext subscriptionDbContext,
+            SubscriptionsConfiguration subscriptionConfiguration,
+            IServiceProvider serviceProvider) : base(serviceProvider)
+        {
+            this.subscriptionDbContext = subscriptionDbContext;
+            this.subscriptionConfiguration = subscriptionConfiguration;
+        }
+
+        public async Task HandleAsync(UpdateSubscriptionPeriod command, CancellationToken cancellationToken)
         {
-            throw new NotImplementedException();
+            var stripeSubscription = await subscriptionDbContext.StripeSubscriptions.FirstAsync(stripeSubscription => stripeSubscription.StripePortalSubscriptionId == command.Subscription.Id);
+
+            if (stripeSubscription.Status != StripeSubscriptionStatus.Active)
+            {
+                stripeSubscription.Status = StripeSubscriptionStatus.Active;
+            }
+            stripeSubscription.ExpirationDate = command.Subscription.CurrentPeriodEnd;
+
+            await subscriptionDbContext.SaveChangesAsync(cancellationToken);
         }
     }
 }
diff --git a/...s/Subscriptions/Features/DomainFeatures/StripeSubscriptionAggregate/StripeSubscription.cs b/...s/Subscriptions/Features/DomainFeatures/StripeSubscriptionAggregate/StripeSubscription.cs
@@ -8,6 +8,7 @@ public class StripeSubscription : AggregateRoot
     {
         private StripeSubscription() { }
 
+        public string StripePortalSubscriptionId { get; set; }
         public Guid StripeCustomerId { get; set; }
         public StripeCustomer StripeCustomer { get; set; }
         public DateTime? ExpirationDate { get; set; }
@@ -16,6 +17,7 @@ private StripeSubscription() { }
 
         public static StripeSubscription Create(
             DateTime? expirationDate,
+            string stripePortalSubscriptionId,
             SubscriptionPlanType subscriptionPlanType,
             StripeSubscriptionStatus stripeSubscriptionStatus,
             Guid tenantId,
@@ -24,6 +26,7 @@ public static StripeSubscription Create(
             return new StripeSubscription()
             {
                 ExpirationDate = expirationDate,
+                StripePortalSubscriptionId = stripePortalSubscriptionId,
                 PlanType = subscriptionPlanType,
                 Status = stripeSubscriptionStatus,
                 TenantId = tenantId,