Stripe Course

Author: jhades

firestore.rules

@@ -28,6 +28,10 @@ service cloud.firestore {
 
      }
 
+     match /purchaseSessions/{purchaseId} {
+        allow read: if resource.data.userId == request.auth.uid;
+     }
+
   }
 
 }

src/app/services/checkout.service.ts

@@ -2,14 +2,18 @@ import {Injectable} from '@angular/core';
 import {HttpClient} from '@angular/common/http';
 import {Observable} from 'rxjs';
 import {CheckoutSession} from '../model/checkout-session.model';
+import {AngularFirestore} from '@angular/fire/firestore';
+import {filter, first} from 'rxjs/operators';
 
 
 @Injectable({
   providedIn: 'root'
 })
 export class CheckoutService {
 
-  constructor(private http: HttpClient) {
+  constructor(
+    private http: HttpClient,
+    private afs: AngularFirestore) {
 
   }
 
@@ -31,5 +35,12 @@ export class CheckoutService {
   }
 
 
-
+  waitForPurchaseToComplete(ongoingPurchaseSessionId: string): Observable<any> {
+    return this.afs.doc<any>(`purchaseSessions/${ongoingPurchaseSessionId}`)
+      .valueChanges()
+      .pipe(
+        filter(purchase => purchase.status == "completed"),
+        first()
+      )
+  }
 }

src/app/stripe-checkout/stripe-checkout.component.ts

@@ -26,10 +26,19 @@ export class StripeCheckoutComponent implements OnInit {
 
     if (result == "success") {
 
+      const ongoingPurchaseSessionId = this.route.snapshot.queryParamMap.get('ongoingPurchaseSessionId');
+
+      this.checkout.waitForPurchaseToComplete(ongoingPurchaseSessionId)
+        .subscribe(
+          () => {
+            this.waiting = false;
+            this.message = "Purchase SUCCESSFUL, redirecting...";
+            setTimeout(() => this.router.navigateByUrl("/courses"), 3000);
+          });
     }
     else {
       this.waiting = false;
-      this.message = "Purchase canceled or failed, redirecting...";
+      this.message = "Purchase CANCELED or FAILED, redirecting...";
       setTimeout(() => this.router.navigateByUrl("/courses"), 3000);
     }