feat(cloud): Add endpoint for subscription pricing

celest-dev · Oct 3, 2024 · 7843741 · 7843741
1 parent 734e9c9
commit 7843741
Show file tree

Hide file tree

Showing 11 changed files with 821 additions and 9 deletions.
diff --git a/packages/celest_cloud/CHANGELOG.md b/packages/celest_cloud/CHANGELOG.md
@@ -1,3 +1,7 @@
+# 0.1.2
+
+- feat: Add `Subscriptions.DescribePricing` endpoint
+
 # 0.1.1
 
 - feat: Add subscriptions and project environments

diff --git a/packages/celest_cloud/lib/src/cloud/subscriptions/subscriptions.dart b/packages/celest_cloud/lib/src/cloud/subscriptions/subscriptions.dart
@@ -74,6 +74,21 @@ final class Subscriptions with BaseService {
       action: _protocol.cancel,
     );
   }
+
+  Future<DescribePricingResponse> describePricing({
+    String? regionCode,
+    String? currencyCode,
+  }) {
+    final request = DescribePricingRequest(
+      regionCode: regionCode,
+      currencyCode: currencyCode,
+    );
+    return run(
+      'Subscriptions.DescribePricing',
+      request: request,
+      action: _protocol.describePricing,
+    );
+  }
 }
 
 sealed class SubscriptionPlan {

diff --git a/packages/celest_cloud/lib/src/cloud/subscriptions/subscriptions_protocol.dart b/packages/celest_cloud/lib/src/cloud/subscriptions/subscriptions_protocol.dart
@@ -5,4 +5,7 @@ abstract interface class SubscriptionsProtocol {
   Future<ChangePlanResponse> changePlan(ChangePlanRequest request);
   Future<PauseSubscriptionResponse> pause(PauseSubscriptionRequest request);
   Future<CancelSubscriptionResponse> cancel(CancelSubscriptionRequest request);
+  Future<DescribePricingResponse> describePricing(
+    DescribePricingRequest request,
+  );
 }
diff --git a/packages/celest_cloud/lib/src/cloud/subscriptions/subscriptions_protocol.grpc.dart b/packages/celest_cloud/lib/src/cloud/subscriptions/subscriptions_protocol.grpc.dart
@@ -29,4 +29,11 @@ final class SubscriptionsProtocolGrpc implements SubscriptionsProtocol {
   Future<PauseSubscriptionResponse> pause(PauseSubscriptionRequest request) {
     return _client.pauseSubscription(request);
   }
+
+  @override
+  Future<DescribePricingResponse> describePricing(
+    DescribePricingRequest request,
+  ) {
+    return _client.describePricing(request);
+  }
 }
diff --git a/packages/celest_cloud/lib/src/cloud/subscriptions/subscriptions_protocol.http.dart b/packages/celest_cloud/lib/src/cloud/subscriptions/subscriptions_protocol.http.dart
@@ -120,4 +120,34 @@ final class SubscriptionsProtocolHttp
         typeRegistry: CelestCloud.typeRegistry,
       );
   }
+
+  @override
+  Future<DescribePricingResponse> describePricing(
+    DescribePricingRequest request,
+  ) async {
+    const path = '/v1alpha1/subscriptions:describePricing';
+    final uri = _baseUri.replace(
+      path: path,
+      queryParameters: {
+        if (request.currencyCode.isNotEmpty)
+          'currencyCode': request.currencyCode,
+        if (request.regionCode.isNotEmpty) 'regionCode': request.regionCode,
+      },
+    );
+    final req = http.Request('GET', uri)
+      ..headers['accept'] = 'application/json';
+    final res = await _client.send(req);
+    final body = await res.stream.bytesToString();
+    if (res.statusCode != 200) {
+      httpError(
+        statusCode: res.statusCode,
+        body: body,
+      );
+    }
+    return DescribePricingResponse()
+      ..mergeFromProto3Json(
+        jsonDecode(body),
+        typeRegistry: CelestCloud.typeRegistry,
+      );
+  }
 }
diff --git a/packages/celest_cloud/lib/src/proto/celest/cloud/v1alpha1/organizations.pbjson.dart b/packages/celest_cloud/lib/src/proto/celest/cloud/v1alpha1/organizations.pbjson.dart
@@ -178,10 +178,9 @@ final $typed_data.Uint8List createOrganizationRequestDescriptor = $convert.base6
     'D29yZ2FuaXphdGlvbl9pZBgCIAEoCUJ/4EECukh5ugF2Chh2YWxpZF9vcmdhbml6YXRpb25fYW'
     'xpYXMSMm9yZ2FuaXphdGlvbl9pZCBtdXN0IGJlIGEgdmFsaWQgb3JnYW5pemF0aW9uIGFsaWFz'
     'GiZ0aGlzLm1hdGNoZXMoJ15bYS16XVthLXowLTktXXs1LDI5fSQnKVIOb3JnYW5pemF0aW9uSW'
-    'QSoQEKDG9yZ2FuaXphdGlvbhgDIAEoCzIjLmNlbGVzdC5jbG91ZC52MWFscGhhMS5Pcmdhbml6'
-    'YXRpb25CWOBBArpIUroBTwoUdmFsaWRfcHJpbWFyeV9yZWdpb24SHW11c3QgcHJvdmlkZSBhIH'
-    'ByaW1hcnkgcmVnaW9uGhh0aGlzLnByaW1hcnlfcmVnaW9uICE9IDBSDG9yZ2FuaXphdGlvbhIo'
-    'Cg12YWxpZGF0ZV9vbmx5GAQgASgIQgPgQQFSDHZhbGlkYXRlT25seQ==');
+    'QSTAoMb3JnYW5pemF0aW9uGAMgASgLMiMuY2VsZXN0LmNsb3VkLnYxYWxwaGExLk9yZ2FuaXph'
+    'dGlvbkID4EECUgxvcmdhbml6YXRpb24SKAoNdmFsaWRhdGVfb25seRgEIAEoCEID4EEBUgx2YW'
+    'xpZGF0ZU9ubHk=');
 
 @$core.Deprecated('Use updateOrganizationRequestDescriptor instead')
 const UpdateOrganizationRequest$json = {

diff --git a/packages/celest_cloud/lib/src/proto/celest/cloud/v1alpha1/projects.pbjson.dart b/packages/celest_cloud/lib/src/proto/celest/cloud/v1alpha1/projects.pbjson.dart
@@ -162,9 +162,10 @@ final $typed_data.Uint8List createProjectRequestDescriptor = $convert.base64Deco
     '9uIG5hbWUaJXRoaXMubWF0Y2hlcygnXm9yZ2FuaXphdGlvbnMvW14vXSskJylSBnBhcmVudBKH'
     'AQoKcHJvamVjdF9pZBgCIAEoCUJo4EECukhiugFfChN2YWxpZF9wcm9qZWN0X2FsaWFzEiBwcm'
     '9qZWN0X2lkIG11c3QgYmUgYSB2YWxpZCBhbGlhcxomdGhpcy5tYXRjaGVzKCdeW2Etel1bYS16'
-    'MC05LV17NSwyOX0kJylSCXByb2plY3RJZBI9Cgdwcm9qZWN0GAMgASgLMh4uY2VsZXN0LmNsb3'
-    'VkLnYxYWxwaGExLlByb2plY3RCA+BBAlIHcHJvamVjdBIoCg12YWxpZGF0ZV9vbmx5GAQgASgI'
-    'QgPgQQFSDHZhbGlkYXRlT25seQ==');
+    'MC05LV17NSwyOX0kJylSCXByb2plY3RJZBKYAQoHcHJvamVjdBgDIAEoCzIeLmNlbGVzdC5jbG'
+    '91ZC52MWFscGhhMS5Qcm9qZWN0Ql7gQQK6SFi6AVUKDXZhbGlkX3JlZ2lvbnMSKm9ubHkgb25l'
+    'IHJlZ2lvbiBtYXkgYmUgc3BlY2lmaWVkIGN1cnJlbnRseRoYdGhpcy5yZWdpb25zLnNpemUoKS'
+    'A8PSAxUgdwcm9qZWN0EigKDXZhbGlkYXRlX29ubHkYBCABKAhCA+BBAVIMdmFsaWRhdGVPbmx5');
 
 @$core.Deprecated('Use getProjectRequestDescriptor instead')
 const GetProjectRequest$json = {