Add Retention Messaging response body

Author: Chris Ballinger

appstoreserverlibrary/models/DecodedRealtimeRequestBody.py

@@ -131,30 +131,6 @@ def verify_and_decode_app_transaction(self, signed_app_transaction: str) -> AppT
             raise VerificationException(VerificationStatus.INVALID_ENVIRONMENT)
         return decoded_app_transaction
 
-    def verify_and_decode_retention_request(self, signed_payload: str):
-        """
-        Verifies and decodes a retention messaging request from the App Store.
-        Uses the same x509 certificate chain verification as other Apple notifications.
-
-        :param signed_payload: The signedPayload field from the retention request
-        :return: The decoded retention request after verification
-        :throws VerificationException: Thrown if the data could not be verified
-        """
-        from .models.DecodedRealtimeRequestBody import DecodedRealtimeRequestBody
-
-        decoded_dict = self._decode_signed_object(signed_payload)
-        decoded_request = _get_cattrs_converter(DecodedRealtimeRequestBody).structure(
-            decoded_dict, DecodedRealtimeRequestBody
-        )
-
-        if self._app_apple_id is not None and decoded_request.appAppleId != self._app_apple_id:
-            raise VerificationException(VerificationStatus.INVALID_APP_IDENTIFIER)
-
-        if decoded_request.environment != self._environment:
-            raise VerificationException(VerificationStatus.INVALID_ENVIRONMENT)
-
-        return decoded_request
-
     def _decode_signed_object(self, signed_obj: str) -> dict:
         try:
             decoded_jwt = jwt.decode(signed_obj, options={"verify_signature": False})

appstoreserverlibrary/models/RealtimeRequestBody.py

@@ -68,25 +68,5 @@ def test_malformed_jwt_with_malformed_data(self):
             verifier.verify_and_decode_notification("a.b.c")
         self.assertEqual(context.exception.status, VerificationStatus.VERIFICATION_FAILURE)
 
-    def test_retention_request_decoding(self):
-        verifier = get_signed_data_verifier(Environment.LOCAL_TESTING, "com.example")
-        retention_request = read_data_from_file('tests/resources/mock_signed_data/retentionRequest')
-        decoded_request = verifier.verify_and_decode_retention_request(retention_request)
-        self.assertEqual(decoded_request.originalTransactionId, "1000000000000001")
-        self.assertEqual(decoded_request.appAppleId, 1234)
-        self.assertEqual(decoded_request.productId, "com.example.subscription")
-        self.assertEqual(decoded_request.locale, "en_US")
-        self.assertEqual(decoded_request.requestIdentifier, "550e8400-e29b-41d4-a716-446655440000")
-        self.assertEqual(decoded_request.environment, Environment.LOCAL_TESTING)
-        self.assertEqual(decoded_request.signedDate, 1681314324000)
-
-
-    def test_retention_request_wrong_app_id(self):
-        verifier = get_signed_data_verifier(Environment.LOCAL_TESTING, "com.example", 5678)
-        retention_request = read_data_from_file('tests/resources/mock_signed_data/retentionRequest')
-        with self.assertRaises(VerificationException) as context:
-            verifier.verify_and_decode_retention_request(retention_request)
-        self.assertEqual(context.exception.status, VerificationStatus.INVALID_APP_IDENTIFIER)
-
 if __name__ == '__main__':
     unittest.main()