git clone https://github.com/flutter/codelabs.git flutter-codelabs

gh repo clone flutter/codelabs flutter-codelabs

cd flutter-codelabs/in_app_purchases/step_00

$ cd app$ flutter pub add in_app_purchase dev:in_app_purchase_platform_interfaceResolving dependencies... Downloading packages...   characters 1.4.0 (1.4.1 available)  flutter_lints 5.0.0 (6.0.0 available)+ in_app_purchase 3.2.3+ in_app_purchase_android 0.4.0+3+ in_app_purchase_platform_interface 1.4.0+ in_app_purchase_storekit 0.4.4+ json_annotation 4.9.0  lints 5.1.1 (6.0.0 available)  material_color_utilities 0.11.1 (0.13.0 available)  meta 1.16.0 (1.17.0 available)  provider 6.1.5 (6.1.5+1 available)  test_api 0.7.6 (0.7.7 available)Changed 5 dependencies!7 packages have newer versions incompatible with dependency constraints.Try `flutter pub outdated` for more information.

dependencies:flutter:sdk:fluttercloud_firestore:^6.0.0cupertino_icons:^1.0.8firebase_auth:^6.0.1firebase_core:^4.0.0google_sign_in:^7.1.1http:^1.5.0intl:^0.20.2provider:^6.1.5logging:^1.3.0in_app_purchase:^3.2.3dev_dependencies:flutter_test:sdk:flutterflutter_lints:^5.0.0in_app_purchase_platform_interface:^1.4.0

keytool -genkey -v -keystore ~/key.jks -keyalg RSA -keysize 2048 -validity 10000 -alias key

keytool -genkey -v -keystore c:\Users\USER_NAME\key.jks -storetype JKS -keyalg RSA -keysize 2048 -validity 10000 -alias key

flutter build appbundle

ChangeNotifierProvider<DashPurchases>(  create: (context) => DashPurchases(    context.read<DashCounter>(),  ),  lazy: false,                                             // Add this line),

// Gives the option to override in tests.classIAPConnection{staticInAppPurchase?_instance;staticsetinstance(InAppPurchasevalue){_instance=value;}staticInAppPurchasegetinstance{_instance??=InAppPurchase.instance;return_instance!;}}

import'package:dashclicker/main.dart';import'package:flutter_test/flutter_test.dart';import'package:in_app_purchase/in_app_purchase.dart';//Addthisimportimport'package:in_app_purchase_platform_interface/src/in_app_purchase_platform_addition.dart';//Andthisimportvoidmain(){testWidgets('App starts',(tester)async{IAPConnection.instance=TestIAPConnection();//Addthislineawaittester.pumpWidget(constMyApp());expect(find.text('Tim Sneath'),findsOneWidget);});}classTestIAPConnectionimplementsInAppPurchase{//Addfromhere@overrideFuture<bool>buyConsumable({requiredPurchaseParampurchaseParam,boolautoConsume=true,}){returnFuture.value(false);}@overrideFuture<bool>buyNonConsumable({requiredPurchaseParampurchaseParam}){returnFuture.value(false);}@overrideFuture<void>completePurchase(PurchaseDetailspurchase){returnFuture.value();}@overrideFuture<bool>isAvailable(){returnFuture.value(false);}@overrideFuture<ProductDetailsResponse>queryProductDetails(Set<String>identifiers){returnFuture.value(ProductDetailsResponse(productDetails:[],notFoundIDs:[]),);}@overrideTgetPlatformAddition<TextendsInAppPurchasePlatformAddition?>(){//TODO:implementgetPlatformAdditionthrowUnimplementedError();}@overrideStream<List<PurchaseDetails>>getpurchaseStream=>Stream.value(<PurchaseDetails>[]);@overrideFuture<void>restorePurchases({String?applicationUserName}){//TODO:implementrestorePurchasesthrowUnimplementedError();}@overrideFuture<String>countryCode(){//TODO:implementcountryCodethrowUnimplementedError();}}//Tohere.

import'dart:async';import'package:flutter/foundation.dart';import'package:flutter/material.dart';import'package:in_app_purchase/in_app_purchase.dart';//Addthisimportimport'../main.dart';//Andthisimportimport'../model/purchasable_product.dart';import'../model/store_state.dart';import'dash_counter.dart';classDashPurchasesextendsChangeNotifier{DashCountercounter;StoreStatestoreState=StoreState.available;lateStreamSubscription<List<PurchaseDetails>>_subscription;//AddthislineList<PurchasableProduct>products=[PurchasableProduct('Spring is in the air','Many dashes flying out from their nests','\$0.99',),PurchasableProduct('Jet engine','Doubles you clicks per second for a day','\$1.99',),];boolgetbeautifiedDash=>false;finaliapConnection=IAPConnection.instance;//AndthislineDashPurchases(this.counter);Future<void>buy(PurchasableProductproduct)async{product.status=ProductStatus.pending;notifyListeners();awaitFuture<void>.delayed(constDuration(seconds:5));product.status=ProductStatus.purchased;notifyListeners();awaitFuture<void>.delayed(constDuration(seconds:5));product.status=ProductStatus.purchasable;notifyListeners();}}

import'dart:async';import'package:flutter/foundation.dart';import'package:flutter/material.dart';import'package:in_app_purchase/in_app_purchase.dart';import'../main.dart';import'../model/purchasable_product.dart';import'../model/store_state.dart';import'dash_counter.dart';classDashPurchasesextendsChangeNotifier{DashCountercounter;StoreStatestoreState=StoreState.notAvailable;//ModifythislinelateStreamSubscription<List<PurchaseDetails>>_subscription;List<PurchasableProduct>products=[PurchasableProduct('Spring is in the air','Many dashes flying out from their nests','\$0.99',),PurchasableProduct('Jet engine','Doubles you clicks per second for a day','\$1.99',),];boolgetbeautifiedDash=>false;finaliapConnection=IAPConnection.instance;DashPurchases(this.counter){//AddfromherefinalpurchaseUpdated=iapConnection.purchaseStream;_subscription=purchaseUpdated.listen(_onPurchaseUpdate,onDone:_updateStreamOnDone,onError:_updateStreamOnError,);}@overridevoiddispose(){_subscription.cancel();super.dispose();}//Tohere.Future<void>buy(PurchasableProductproduct)async{product.status=ProductStatus.pending;notifyListeners();awaitFuture<void>.delayed(constDuration(seconds:5));product.status=ProductStatus.purchased;notifyListeners();awaitFuture<void>.delayed(constDuration(seconds:5));product.status=ProductStatus.purchasable;notifyListeners();}//Addfromherevoid_onPurchaseUpdate(List<PurchaseDetails>purchaseDetailsList){//Handlepurchaseshere}void_updateStreamOnDone(){_subscription.cancel();}void_updateStreamOnError(dynamicerror){//Handleerrorhere}//Tohere.}

$ flutter test00:01 +1: All tests passed!

import'package:in_app_purchase/in_app_purchase.dart';enumProductStatus{purchasable,purchased,pending}classPurchasableProduct{Stringgetid=>productDetails.id;Stringgettitle=>productDetails.title;Stringgetdescription=>productDetails.description;Stringgetprice=>productDetails.price;ProductStatusstatus;ProductDetailsproductDetails;PurchasableProduct(this.productDetails):status=ProductStatus.purchasable;}

Future<void>loadPurchases()async{finalavailable=awaitiapConnection.isAvailable();if(!available){storeState=StoreState.notAvailable;notifyListeners();return;}}

import'../constants.dart';//...Future<void>loadPurchases()async{finalavailable=awaitiapConnection.isAvailable();if(!available){storeState=StoreState.notAvailable;notifyListeners();return;}constids= <String>{storeKeyConsumable,storeKeySubscription,storeKeyUpgrade,};finalresponse=awaitiapConnection.queryProductDetails(ids);products=response.productDetails.map((e)=>PurchasableProduct(e)).toList();storeState=StoreState.available;notifyListeners();}

DashPurchases(this.counter){finalpurchaseUpdated=iapConnection.purchaseStream;_subscription=purchaseUpdated.listen(_onPurchaseUpdate,onDone:_updateStreamOnDone,onError:_updateStreamOnError,);loadPurchases();//Addthisline}

StoreStatestoreState=StoreState.loading;

class_PurchaseListextendsStatelessWidget{@overrideWidgetbuild(BuildContextcontext){varpurchases=context.watch<DashPurchases>();varproducts=purchases.products;returnColumn(children:products.map((product)=>_PurchaseWidget(product:product,onPressed:(){purchases.buy(product);},),).toList(),);}}

Future<void>buy(PurchasableProductproduct)async{finalpurchaseParam=PurchaseParam(productDetails:product.productDetails);switch(product.id){casestoreKeyConsumable:awaitiapConnection.buyConsumable(purchaseParam:purchaseParam);casestoreKeySubscription:casestoreKeyUpgrade:awaitiapConnection.buyNonConsumable(purchaseParam:purchaseParam);default:throwArgumentError.value(product.productDetails,'${product.id}isnotaknownproduct',);}}

  bool get beautifiedDash => _beautifiedDashUpgrade;  bool _beautifiedDashUpgrade = false;

Future<void>_onPurchaseUpdate(List<PurchaseDetails>purchaseDetailsList,)async{for(varpurchaseDetailsinpurchaseDetailsList){await_handlePurchase(purchaseDetails);}notifyListeners();}Future<void>_handlePurchase(PurchaseDetailspurchaseDetails)async{if(purchaseDetails.status==PurchaseStatus.purchased){switch(purchaseDetails.productID){casestoreKeySubscription:counter.applyPaidMultiplier();casestoreKeyConsumable:counter.addBoughtDashes(2000);casestoreKeyUpgrade:_beautifiedDashUpgrade=true;}}if(purchaseDetails.pendingCompletePurchase){awaitiapConnection.completePurchase(purchaseDetails);}}

import'package:flutter/material.dart';import'package:provider/provider.dart';import'../logic/dash_purchases.dart';import'../logic/firebase_notifier.dart';//Addthisimportimport'../model/firebase_state.dart';//Andthisimportimport'../model/purchasable_product.dart';import'../model/store_state.dart';import'../repo/iap_repo.dart';import'login_page.dart';//AndthisoneaswellclassPurchasePageextendsStatelessWidget{constPurchasePage({super.key});@overrideWidgetbuild(BuildContextcontext){//UpdatefromherevarfirebaseNotifier=context.watch<FirebaseNotifier>();if(firebaseNotifier.state==FirebaseState.loading){return_PurchasesLoading();}elseif(firebaseNotifier.state==FirebaseState.notAvailable){return_PurchasesNotAvailable();}if(!firebaseNotifier.loggedIn){returnconstLoginPage();}//Tohere.//...

import'dart:async';import'dart:convert';//Addthisimportimport'package:flutter/foundation.dart';import'package:flutter/material.dart';import'package:http/http.dart'ashttp;//Andthisimportimport'package:in_app_purchase/in_app_purchase.dart';import'../constants.dart';import'../main.dart';import'../model/purchasable_product.dart';import'../model/store_state.dart';import'dash_counter.dart';import'firebase_notifier.dart';//AndthisoneclassDashPurchasesextendsChangeNotifier{DashCountercounter;FirebaseNotifierfirebaseNotifier;//AddthislineStoreStatestoreState=StoreState.loading;lateStreamSubscription<List<PurchaseDetails>>_subscription;List<PurchasableProduct>products=[];boolgetbeautifiedDash=>_beautifiedDashUpgrade;bool_beautifiedDashUpgrade=false;finaliapConnection=IAPConnection.instance;DashPurchases(this.counter,this.firebaseNotifier){//UpdatethislinefinalpurchaseUpdated=iapConnection.purchaseStream;_subscription=purchaseUpdated.listen(_onPurchaseUpdate,onDone:_updateStreamOnDone,onError:_updateStreamOnError,);loadPurchases();}

        ChangeNotifierProvider<DashPurchases>(          create: (context) => DashPurchases(            context.read<DashCounter>(),            context.read<FirebaseNotifier>(),          ),          lazy: false,        ),

Future<FirebaseFirestore>getfirestoreasync{varisInitialized=await_isInitialized.future;if(!isInitialized){throwException('Firebase is not initialized');}returnFirebaseFirestore.instance;}User?getuser=>FirebaseAuth.instance.currentUser;//AddthislineFuture<void>load()async{//...

Future<bool>_verifyPurchase(PurchaseDetailspurchaseDetails)async{finalurl=Uri.parse('http://$serverIp:8080/verifypurchase');constheaders={'Content-type':'application/json','Accept':'application/json',};finalresponse=awaithttp.post(url,body:jsonEncode({'source':purchaseDetails.verificationData.source,'productId':purchaseDetails.productID,'verificationData':purchaseDetails.verificationData.serverVerificationData,'userId':firebaseNotifier.user?.uid,}),headers:headers,);if(response.statusCode==200){returntrue;}else{returnfalse;}}

Future<void>_onPurchaseUpdate(List<PurchaseDetails>purchaseDetailsList,)async{for(varpurchaseDetailsinpurchaseDetailsList){await_handlePurchase(purchaseDetails);}notifyListeners();}Future<void>_handlePurchase(PurchaseDetailspurchaseDetails)async{if(purchaseDetails.status==PurchaseStatus.purchased){//SendtoservervarvalidPurchase=await_verifyPurchase(purchaseDetails);if(validPurchase){//Applychangeslocallyswitch(purchaseDetails.productID){casestoreKeySubscription:counter.applyPaidMultiplier();casestoreKeyConsumable:counter.addBoughtDashes(2000);casestoreKeyUpgrade:_beautifiedDashUpgrade=true;}}}if(purchaseDetails.pendingCompletePurchase){awaitiapConnection.completePurchase(purchaseDetails);}}

import'products.dart';///Genericpurchasehandler,///mustbeimplementedforGooglePlayandAppleStoreabstractclassPurchaseHandler{///Verifyifnon-subscriptionpurchase(akaconsumable)isvalid///andupdatethedatabaseFuture<bool>handleNonSubscription({requiredStringuserId,requiredProductDataproductData,requiredStringtoken,});///Verifyifsubscriptionpurchase(akanon-consumable)isvalid///andupdatethedatabaseFuture<bool>handleSubscription({requiredStringuserId,requiredProductDataproductData,requiredStringtoken,});}

/// Verify if purchase is valid and update the databaseFuture<bool>verifyPurchase({requiredStringuserId,requiredProductDataproductData,requiredStringtoken,})async{switch(productData.type){caseProductType.subscription:returnhandleSubscription(userId:userId,productData:productData,token:token,);caseProductType.nonSubscription:returnhandleNonSubscription(userId:userId,productData:productData,token:token,);}}

classProductData{finalStringproductId;finalProductTypetype;constProductData(this.productId,this.type);}

enumProductType{subscription,nonSubscription}

constproductDataMap={'dash_consumable_2k':ProductData('dash_consumable_2k',ProductType.nonSubscription,),'dash_upgrade_3d':ProductData('dash_upgrade_3d',ProductType.nonSubscription,),'dash_subscription_doubler':ProductData('dash_subscription_doubler',ProductType.subscription,),};

import'dart:async';import'package:googleapis/androidpublisher/v3.dart'asap;import'constants.dart';import'iap_repository.dart';import'products.dart';import'purchase_handler.dart';classGooglePlayPurchaseHandlerextendsPurchaseHandler{finalap.AndroidPublisherApiandroidPublisher;finalIapRepositoryiapRepository;GooglePlayPurchaseHandler(this.androidPublisher,this.iapRepository);@overrideFuture<bool>handleNonSubscription({requiredString?userId,requiredProductDataproductData,requiredStringtoken,})async{returntrue;}@overrideFuture<bool>handleSubscription({requiredString?userId,requiredProductDataproductData,requiredStringtoken,})async{returntrue;}}

import'dart:async';import'package:app_store_server_sdk/app_store_server_sdk.dart';import'constants.dart';import'iap_repository.dart';import'products.dart';import'purchase_handler.dart';classAppStorePurchaseHandlerextendsPurchaseHandler{finalIapRepositoryiapRepository;AppStorePurchaseHandler(this.iapRepository);@overrideFuture<bool>handleNonSubscription({requiredStringuserId,requiredProductDataproductData,requiredStringtoken,})async{returntrue;}@overrideFuture<bool>handleSubscription({requiredStringuserId,requiredProductDataproductData,requiredStringtoken,})async{returntrue;}}

import'dart:convert';import'package:firebase_backend_dart/helpers.dart';import'package:firebase_backend_dart/products.dart';import'package:shelf/shelf.dart';import'package:shelf_router/shelf_router.dart';Future<void>main()async{finalrouter=Router();finalpurchaseHandlers=await_createPurchaseHandlers();router.post('/verifypurchase',(Requestrequest)async{finaldynamicpayload=json.decode(awaitrequest.readAsString());final(:userId,:source,:productData,:token)=getPurchaseData(payload);finalresult=awaitpurchaseHandlers[source]!.verifyPurchase(userId:userId,productData:productData,token:token,);if(result){returnResponse.ok('all good!');}else{returnResponse.internalServerError();}});awaitserveHandler(router.call);}({StringuserId,Stringsource,ProductDataproductData,Stringtoken})getPurchaseData(dynamicpayload){if(payloadcase{'userId':StringuserId,'source':Stringsource,'productId':StringproductId,'verificationData':Stringtoken,}){return(userId:userId,source:source,productData:productDataMap[productId]!,token:token,);}else{throwconstFormatException('Unexpected JSON');}}

import'dart:convert';import'dart:io';//newimport'package:firebase_backend_dart/app_store_purchase_handler.dart';//newimport'package:firebase_backend_dart/google_play_purchase_handler.dart';//newimport'package:firebase_backend_dart/helpers.dart';import'package:firebase_backend_dart/iap_repository.dart';//newimport'package:firebase_backend_dart/products.dart';import'package:firebase_backend_dart/purchase_handler.dart';//newimport'package:googleapis/androidpublisher/v3.dart'asap;//newimport'package:googleapis/firestore/v1.dart'asfs;//newimport'package:googleapis_auth/auth_io.dart'asauth;//newimport'package:shelf/shelf.dart';import'package:shelf_router/shelf_router.dart';Future<Map<String,PurchaseHandler>>_createPurchaseHandlers()async{//ConfigureAndroidPublisherAPIaccessfinalserviceAccountGooglePlay=File('assets/service-account-google-play.json').readAsStringSync();finalclientCredentialsGooglePlay=auth.ServiceAccountCredentials.fromJson(serviceAccountGooglePlay);finalclientGooglePlay=awaitauth.clientViaServiceAccount(clientCredentialsGooglePlay,[ap.AndroidPublisherApi.androidpublisherScope,]);finalandroidPublisher=ap.AndroidPublisherApi(clientGooglePlay);//ConfigureFirestoreAPIaccessfinalserviceAccountFirebase=File('assets/service-account-firebase.json').readAsStringSync();finalclientCredentialsFirebase=auth.ServiceAccountCredentials.fromJson(serviceAccountFirebase);finalclientFirebase=awaitauth.clientViaServiceAccount(clientCredentialsFirebase,[fs.FirestoreApi.cloudPlatformScope,]);finalfirestoreApi=fs.FirestoreApi(clientFirebase);finaldynamicjson=jsonDecode(serviceAccountFirebase);finalprojectId=json['project_id']asString;finaliapRepository=IapRepository(firestoreApi,projectId);return{'google_play':GooglePlayPurchaseHandler(androidPublisher,iapRepository,),'app_store':AppStorePurchaseHandler(iapRepository,),};}

///Handlenon-subscriptionpurchases(onetimepurchases).//////RetrievesthepurchasestatusfromGooglePlayandupdates///theFirestoreDatabaseaccordingly.@overrideFuture<bool>handleNonSubscription({requiredString?userId,requiredProductDataproductData,requiredStringtoken,})async{print('GooglePlayPurchaseHandler.handleNonSubscription''($userId,${productData.productId},${token.substring(0,5)}...)',);try{//VerifypurchasewithGooglefinalresponse=awaitandroidPublisher.purchases.products.get(androidPackageId,productData.productId,token,);print('Purchasesresponse:${response.toJson()}');//MakesureanorderIDexistsif(response.orderId==null){print('Couldnothandlepurchasewithoutorderid');returnfalse;}finalorderId=response.orderId!;finalpurchaseData=NonSubscriptionPurchase(purchaseDate:DateTime.fromMillisecondsSinceEpoch(int.parse(response.purchaseTimeMillis??'0'),),orderId:orderId,productId:productData.productId,status:_nonSubscriptionStatusFrom(response.purchaseState),userId:userId,iapSource:IAPSource.googleplay,);//Updatethedatabaseif(userId!=null){//IfweknowtheuserId,//updatetheexistingpurchaseorcreateitifitdoesnotexist.awaitiapRepository.createOrUpdatePurchase(purchaseData);}else{//Ifwedon'tknowtheuserID,apreviousentrymustalready//exist,andthuswe'llonlyupdateit.awaitiapRepository.updatePurchase(purchaseData);}returntrue;}onap.DetailedApiRequestErrorcatch(e){print('ErroronhandleNonSubscription:$e\n''JSON:${e.jsonResponse}',);}catch(e){print('ErroronhandleNonSubscription:$e\n');}returnfalse;}

///Handlesubscriptionpurchases.//////RetrievesthepurchasestatusfromGooglePlayandupdates///theFirestoreDatabaseaccordingly.@overrideFuture<bool>handleSubscription({requiredString?userId,requiredProductDataproductData,requiredStringtoken,})async{print('GooglePlayPurchaseHandler.handleSubscription''($userId,${productData.productId},${token.substring(0,5)}...)',);try{//VerifypurchasewithGooglefinalresponse=awaitandroidPublisher.purchases.subscriptions.get(androidPackageId,productData.productId,token,);print('Subscriptionresponse:${response.toJson()}');//MakesureanorderIDexistsif(response.orderId==null){print('Couldnothandlepurchasewithoutorderid');returnfalse;}finalorderId=extractOrderId(response.orderId!);finalpurchaseData=SubscriptionPurchase(purchaseDate:DateTime.fromMillisecondsSinceEpoch(int.parse(response.startTimeMillis??'0'),),orderId:orderId,productId:productData.productId,status:_subscriptionStatusFrom(response.paymentState),userId:userId,iapSource:IAPSource.googleplay,expiryDate:DateTime.fromMillisecondsSinceEpoch(int.parse(response.expiryTimeMillis??'0'),),);//Updatethedatabaseif(userId!=null){//IfweknowtheuserId,//updatetheexistingpurchaseorcreateitifitdoesnotexist.awaitiapRepository.createOrUpdatePurchase(purchaseData);}else{//Ifwedon'tknowtheuserID,apreviousentrymustalready//exist,andthuswe'llonlyupdateit.awaitiapRepository.updatePurchase(purchaseData);}returntrue;}onap.DetailedApiRequestErrorcatch(e){print('ErroronhandleSubscription:$e\n''JSON:${e.jsonResponse}',);}catch(e){print('ErroronhandleSubscription:$e\n');}returnfalse;}}

NonSubscriptionStatus_nonSubscriptionStatusFrom(int? state) {  return switch (state) {    0 => NonSubscriptionStatus.completed,    2 => NonSubscriptionStatus.pending,    _ => NonSubscriptionStatus.cancelled,  };}SubscriptionStatus_subscriptionStatusFrom(int? state) {  return switch (state) {    // Payment pending    0 => SubscriptionStatus.pending,    // Payment received    1 => SubscriptionStatus.active,    // Free trial    2 => SubscriptionStatus.active,    // Pending deferred upgrade/downgrade    3 => SubscriptionStatus.pending,    // Expired or cancelled    _ => SubscriptionStatus.expired,  };}/// If a subscription suffix is present (..#) extract the orderId.String extractOrderId(String orderId) {  final orderIdSplit = orderId.split('..');  if (orderIdSplit.isNotEmpty) {    orderId = orderIdSplit[0];  }  return orderId;}

final_iTunesAPI=ITunesApi(ITunesHttpClient(ITunesEnvironment.sandbox(),loggingEnabled:true),);

@overrideFuture<bool>handleNonSubscription({requiredStringuserId,requiredProductDataproductData,requiredStringtoken,}){returnhandleValidation(userId:userId,token:token);}@overrideFuture<bool>handleSubscription({requiredStringuserId,requiredProductDataproductData,requiredStringtoken,}){returnhandleValidation(userId:userId,token:token);}///Handlepurchasevalidation.Future<bool>handleValidation({requiredStringuserId,requiredStringtoken,})async{//Seenextstep}

///Handlepurchasevalidation.Future<bool>handleValidation({requiredStringuserId,requiredStringtoken,})async{print('AppStorePurchaseHandler.handleValidation');finalresponse=await_iTunesAPI.verifyReceipt(password:appStoreSharedSecret,receiptData:token,);print('response:$response');if(response.status==0){print('Successfullyverifiedpurchase');finalreceipts=response.latestReceiptInfo??[];for(finalreceiptinreceipts){finalproduct=productDataMap[receipt.productId];if(product==null){print('Error:Unknownproduct:${receipt.productId}');continue;}switch(product.type){caseProductType.nonSubscription:awaitiapRepository.createOrUpdatePurchase(NonSubscriptionPurchase(userId:userId,productId:receipt.productId??'',iapSource:IAPSource.appstore,orderId:receipt.originalTransactionId??'',purchaseDate:DateTime.fromMillisecondsSinceEpoch(int.parse(receipt.originalPurchaseDateMs??'0'),),type:product.type,status:NonSubscriptionStatus.completed,),);break;caseProductType.subscription:awaitiapRepository.createOrUpdatePurchase(SubscriptionPurchase(userId:userId,productId:receipt.productId??'',iapSource:IAPSource.appstore,orderId:receipt.originalTransactionId??'',purchaseDate:DateTime.fromMillisecondsSinceEpoch(int.parse(receipt.originalPurchaseDateMs??'0'),),type:product.type,expiryDate:DateTime.fromMillisecondsSinceEpoch(int.parse(receipt.expiresDateMs??'0'),),status:SubscriptionStatus.active,),);break;}}returntrue;}else{print('Error:Status:${response.status}');returnfalse;}}

$ dart bin/server.dartServing at http://0.0.0.0:8080

import'package:googleapis/pubsub/v1.dart'aspubsub;

classGooglePlayPurchaseHandlerextendsPurchaseHandler{finalap.AndroidPublisherApiandroidPublisher;finalIapRepositoryiapRepository;finalpubsub.PubsubApipubsubApi;//newGooglePlayPurchaseHandler(this.androidPublisher,this.iapRepository,this.pubsubApi,//new){//PollmessagesfromPub/Subevery10secondsTimer.periodic(Duration(seconds:10),(_){_pullMessageFromPubSub();});}

///ProcessmessagesfromGooglePlay///Calledevery10secondsFuture<void>_pullMessageFromPubSub()async{print('Polling Google Play messages');finalrequest=pubsub.PullRequest(maxMessages:1000);finaltopicName='projects/$googleCloudProjectId/subscriptions/$googlePlayPubsubBillingTopic-sub';finalpullResponse=awaitpubsubApi.projects.subscriptions.pull(request,topicName,);finalmessages=pullResponse.receivedMessages??[];for(finalmessageinmessages){finaldata64=message.message?.data;if(data64!=null){await_processMessage(data64,message.ackId);}}}Future<void>_processMessage(Stringdata64,String?ackId)async{finaldataRaw=utf8.decode(base64Decode(data64));print('Received data: $dataRaw');finaldynamicdata=jsonDecode(dataRaw);if(data['testNotification']!=null){print('Skip test messages');if(ackId!=null){await_ackMessage(ackId);}return;}finaldynamicsubscriptionNotification=data['subscriptionNotification'];finaldynamiconeTimeProductNotification=data['oneTimeProductNotification'];if(subscriptionNotification!=null){print('Processing Subscription');finalsubscriptionId=subscriptionNotification['subscriptionId']asString;finalpurchaseToken=subscriptionNotification['purchaseToken']asString;finalproductData=productDataMap[subscriptionId]!;finalresult=awaithandleSubscription(userId:null,productData:productData,token:purchaseToken,);if(result &&ackId!=null){await_ackMessage(ackId);}}elseif(oneTimeProductNotification!=null){print('Processing NonSubscription');finalsku=oneTimeProductNotification['sku']asString;finalpurchaseToken=oneTimeProductNotification['purchaseToken']asString;finalproductData=productDataMap[sku]!;finalresult=awaithandleNonSubscription(userId:null,productData:productData,token:purchaseToken,);if(result &&ackId!=null){await_ackMessage(ackId);}}else{print('invalid data');}}///ACKMessagesfromPub/SubFuture<void>_ackMessage(Stringid)async{print('ACK Message');finalrequest=pubsub.AcknowledgeRequest(ackIds:[id]);finalsubscriptionName='projects/$googleCloudProjectId/subscriptions/$googlePlayPubsubBillingTopic-sub';awaitpubsubApi.projects.subscriptions.acknowledge(request,subscriptionName,);}

import'package:googleapis/pubsub/v1.dart'aspubsub;//AddthisimportfinalclientGooglePlay=awaitauth.clientViaServiceAccount(clientCredentialsGooglePlay,[ap.AndroidPublisherApi.androidpublisherScope,pubsub.PubsubApi.cloudPlatformScope,//Addthisline]);

  final pubsubApi = pubsub.PubsubApi(clientGooglePlay);

  return {    'google_play': GooglePlayPurchaseHandler(      androidPublisher,      iapRepository,      pubsubApi,                                           // Add this line    ),    'app_store': AppStorePurchaseHandler(      iapRepository,    ),  };

  final AppStoreServerAPI appStoreServerAPI;                 // Add this member  AppStorePurchaseHandler(    this.iapRepository,    this.appStoreServerAPI,                                  // And this parameter  );

AppStorePurchaseHandler(this.iapRepository,this.appStoreServerAPI){//PollSubscriptionstatusevery10seconds.Timer.periodic(Duration(seconds:10),(_){_pullStatus();});}

/// Request the App Store for the latest subscription status./// Updates all App Store subscriptions in the database./// NOTE: This code only handles when a subscription expires as example.Future<void>_pullStatus()async{print('PollingAppStore');finalpurchases=awaitiapRepository.getPurchases();// filter for App Store subscriptionsfinalappStoreSubscriptions=purchases.where((element)=>element.type==ProductType.subscription&&element.iapSource==IAPSource.appstore,);for(finalpurchaseinappStoreSubscriptions){finalstatus=awaitappStoreServerAPI.getAllSubscriptionStatuses(purchase.orderId,);// Obtain all subscriptions for the order ID.for(finalsubscriptioninstatus.data){// Last transaction contains the subscription status.for(finaltransactioninsubscription.lastTransactions){finalexpirationDate=DateTime.fromMillisecondsSinceEpoch(transaction.transactionInfo.expiresDate??0,);// Check if subscription has expired.finalisExpired=expirationDate.isBefore(DateTime.now());print('ExpirationDate:$expirationDate-isExpired:$isExpired');// Update the subscription status with the new expiration date and status.awaitiapRepository.updatePurchase(SubscriptionPurchase(userId:null,productId:transaction.transactionInfo.productId,iapSource:IAPSource.appstore,orderId:transaction.originalTransactionId,purchaseDate:DateTime.fromMillisecondsSinceEpoch(transaction.transactionInfo.originalPurchaseDate,),type:ProductType.subscription,expiryDate:expirationDate,status:isExpired?SubscriptionStatus.expired:SubscriptionStatus.active,),);}}}}

import'package:app_store_server_sdk/app_store_server_sdk.dart';//Addthisimportimport'package:firebase_backend_dart/constants.dart';//Andthisone.//addfromherefinalsubscriptionKeyAppStore=File('assets/SubscriptionKey.p8',).readAsStringSync();//ConfigureAppleStoreAPIaccessvarappStoreEnvironment=AppStoreEnvironment.sandbox(bundleId:bundleId,issuerId:appStoreIssuerId,keyId:appStoreKeyId,privateKey:subscriptionKeyAppStore,);//StoredtokenforAppleStoreAPIaccess,ifavailablefinalfile=File('assets/appstore.token');String?appStoreToken;if(file.existsSync() &&file.lengthSync() >0){appStoreToken=file.readAsStringSync();}finalappStoreServerAPI=AppStoreServerAPI(AppStoreServerHttpClient(appStoreEnvironment,jwt:appStoreToken,jwtTokenUpdatedCallback:(token){file.writeAsStringSync(token);},),);//toherereturn{'google_play':GooglePlayPurchaseHandler(androidPublisher,iapRepository,pubsubApi,),'app_store':AppStorePurchaseHandler(iapRepository,appStoreServerAPI,//Addthisargument),};

voidupdatePurchases(){_purchaseSubscription?.cancel();varuser=_user;if(user==null){purchases=[];hasActiveSubscription=false;hasUpgrade=false;return;}varpurchaseStream=_firestore.collection('purchases').where('userId',isEqualTo:user.uid).snapshots();_purchaseSubscription=purchaseStream.listen((snapshot){purchases=snapshot.docs.map((document){vardata=document.data();returnPastPurchase.fromJson(data);}).toList();hasActiveSubscription=purchases.any((element)=>element.productId==storeKeySubscription&&element.status!=Status.expired,);hasUpgrade=purchases.any((element)=>element.productId==storeKeyUpgrade,);notifyListeners();});}

import'../repo/iap_repo.dart';//AddthisimportclassDashPurchasesextendsChangeNotifier{DashCountercounter;FirebaseNotifierfirebaseNotifier;StoreStatestoreState=StoreState.loading;lateStreamSubscription<List<PurchaseDetails>>_subscription;List<PurchasableProduct>products=[];IAPRepoiapRepo;//AddthislineboolgetbeautifiedDash=>_beautifiedDashUpgrade;bool_beautifiedDashUpgrade=false;finaliapConnection=IAPConnection.instance;//Addthis.iapRepoasaparameterDashPurchases(this.counter,this.firebaseNotifier,this.iapRepo){finalpurchaseUpdated=iapConnection.purchaseStream;_subscription=purchaseUpdated.listen(_onPurchaseUpdate,onDone:_updateStreamOnDone,onError:_updateStreamOnError,);iapRepo.addListener(purchasesUpdate);loadPurchases();}Future<void>loadPurchases()async{//Elided.}@overridevoiddispose(){_subscription.cancel();iapRepo.removeListener(purchasesUpdate);//Addthislinesuper.dispose();}voidpurchasesUpdate(){//TODOmanageupdates}

        ChangeNotifierProvider<DashPurchases>(          create: (context) => DashPurchases(            context.read<DashCounter>(),            context.read<FirebaseNotifier>(),            context.read<IAPRepo>(),                         // Add this line          ),          lazy: false,        ),

voidpurchasesUpdate(){varsubscriptions=<PurchasableProduct>[];varupgrades=<PurchasableProduct>[];//Getalistofpurchasableproductsforthesubscriptionandupgrade.//Thisshouldbe1pertype.if(products.isNotEmpty){subscriptions=products.where((element)=>element.productDetails.id==storeKeySubscription).toList();upgrades=products.where((element)=>element.productDetails.id==storeKeyUpgrade).toList();}//Setthesubscriptioninthecounterlogicandshow/hidepurchasedonthe//purchasespage.if(iapRepo.hasActiveSubscription){counter.applyPaidMultiplier();for(varelementinsubscriptions){_updateStatus(element,ProductStatus.purchased);}}else{counter.removePaidMultiplier();for(varelementinsubscriptions){_updateStatus(element,ProductStatus.purchasable);}}//SettheDashbeautifierandshow/hidepurchasedon//thepurchasespage.if(iapRepo.hasUpgrade!=_beautifiedDashUpgrade){_beautifiedDashUpgrade=iapRepo.hasUpgrade;for(varelementinupgrades){_updateStatus(element,_beautifiedDashUpgrade?ProductStatus.purchased:ProductStatus.purchasable,);}notifyListeners();}}void_updateStatus(PurchasableProductproduct,ProductStatusstatus){if(product.status!=ProductStatus.purchased){product.status=ProductStatus.purchased;notifyListeners();}}