add purchase handlers to server.dart in step 09

flutter · domesticmouse · Apr 18, 2023 · Mar 7, 2023 · Mar 7, 2023 · Mar 7, 2023
commit 7a33b4b9512365d1054410baa49724875071fcbb
diff --git a/in_app_purchases/step_09/dart-backend/bin/server.dart b/in_app_purchases/step_09/dart-backend/bin/server.dart
@@ -2,12 +2,101 @@
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
+import 'dart:convert';
+import 'dart:io';
+
+import 'package:firebase_backend_dart/app_store_purchase_handler.dart';
+import 'package:firebase_backend_dart/google_play_purchase_handler.dart';
 import 'package:firebase_backend_dart/helpers.dart';
+import 'package:firebase_backend_dart/iap_repository.dart';
+import 'package:firebase_backend_dart/products.dart';
+import 'package:firebase_backend_dart/purchase_handler.dart';
+import 'package:googleapis/androidpublisher/v3.dart' as ap;
+import 'package:googleapis/firestore/v1.dart' as fs;
+import 'package:googleapis_auth/auth_io.dart' as auth;
+import 'package:shelf/shelf.dart';
 import 'package:shelf_router/shelf_router.dart';
 
+/// Creates the Google Play and Apple Store [PurchaseHandler]
+/// and their dependencies
+Future<Map<String, PurchaseHandler>> _createPurchaseHandlers() async {
+  // Configure Android Publisher API access
+  final serviceAccountGooglePlay =
+      File('assets/service-account-google-play.json').readAsStringSync();
+  final clientCredentialsGooglePlay =
+      auth.ServiceAccountCredentials.fromJson(serviceAccountGooglePlay);
+  final clientGooglePlay =
+      await auth.clientViaServiceAccount(clientCredentialsGooglePlay, [
+    ap.AndroidPublisherApi.androidpublisherScope,
+  ]);
+  final androidPublisher = ap.AndroidPublisherApi(clientGooglePlay);
+
+  // Configure Firestore API access
+  final serviceAccountFirebase =
+      File('assets/service-account-firebase.json').readAsStringSync();
+  final clientCredentialsFirebase =
+      auth.ServiceAccountCredentials.fromJson(serviceAccountFirebase);
+  final clientFirebase =
+      await auth.clientViaServiceAccount(clientCredentialsFirebase, [
+    fs.FirestoreApi.cloudPlatformScope,
+  ]);
+  final firestoreApi = fs.FirestoreApi(clientFirebase);
+  final dynamic json = jsonDecode(serviceAccountFirebase);
+  final projectId = json['project_id'] as String;
+  final iapRepository = IapRepository(firestoreApi, projectId);
+
+  return {
+    'google_play': GooglePlayPurchaseHandler(
+      androidPublisher,
+      iapRepository,
+    ),
+    'app_store': AppStorePurchaseHandler(
+      iapRepository,
+    ),
+  };
+}
+
 Future<void> main() async {
   final router = Router();
 
+  final purchaseHandlers = await _createPurchaseHandlers();
+
+  /// Warning: This endpoint has no security
+  /// and does not implement user authentication.
+  /// Production applications should implement authentication.
+  // ignore: avoid_types_on_closure_parameters
+  router.post('/verifypurchase', (Request request) async {
+    final dynamic payload = json.decode(await request.readAsString());
+
+    // NOTE: userId should be obtained using authentication methods.
+    final userId = payload['userId'] as String;
+
+    // Value from PurchaseDetails.verificationData.source
+    final source = payload['source'] as String;
+
+    // Obtain product data based on the productId
+    final productData = productDataMap[payload['productId']]!;
+
+    // Value from PurchaseDetails.verificationData.serverVerificationData
+    final token = payload['verificationData'] as String;
+
+    // Will call to verifyPurchase on
+    // [GooglePlayPurchaseHandler] or [AppleStorePurchaseHandler]
+    final result = await purchaseHandlers[source]!.verifyPurchase(
+      userId: userId,
+      productData: productData,
+      token: token,
+    );
+
+    if (result) {
+      // Note: Better success response recommended
+      return Response.ok('all good!');
+    } else {
+      // Note: Better error handling recommended
+      return Response.internalServerError();
+    }
+  });
+
   // Start service
   await serveHandler(router);
 }