Add bsync scanPurchaseOperations route

bluesky-social · Dec 11, 2024 · 6a39b89 · 6a39b89
1 parent c919743
commit 6a39b89
Show file tree

Hide file tree

Showing 7 changed files with 518 additions and 122 deletions.
diff --git a/packages/bsync/proto/bsync.proto b/packages/bsync/proto/bsync.proto
@@ -68,12 +68,6 @@ message ScanNotifOperationsResponse {
   string cursor = 2;
 }
 
-message RefreshPurchasesRequest {
-  string actor_did = 1;
-}
-
-message RefreshPurchasesResponse {}
-
 message Subscription {
   string status = 1;
   string renewalStatus = 2;
@@ -108,6 +102,28 @@ message GetSubscriptionGroupResponse {
   repeated SubscriptionOffering offerings = 1;
 }
 
+message RefreshPurchasesRequest {
+  string actor_did = 1;
+}
+
+message RefreshPurchasesResponse {}
+
+message PurchaseOperation {
+  string id = 1;
+  string actor_did = 2;
+  repeated string entitlements = 3;
+}
+
+message ScanPurchaseOperationsRequest {
+  string cursor = 1;
+  int32 limit = 2;
+}
+
+message ScanPurchaseOperationsResponse {
+  repeated PurchaseOperation operations = 1;
+  string cursor = 2;
+}
+
 // Ping
 message PingRequest {}
 message PingResponse {}
@@ -120,9 +136,10 @@ service Service {
   rpc AddNotifOperation(AddNotifOperationRequest) returns (AddNotifOperationResponse);
   rpc ScanNotifOperations(ScanNotifOperationsRequest) returns (ScanNotifOperationsResponse);
   // Purchase
-  rpc RefreshPurchases(RefreshPurchasesRequest) returns (RefreshPurchasesResponse);
   rpc GetSubscriptions(GetSubscriptionsRequest) returns (GetSubscriptionsResponse);
   rpc GetSubscriptionGroup(GetSubscriptionGroupRequest) returns (GetSubscriptionGroupResponse);
+  rpc RefreshPurchases(RefreshPurchasesRequest) returns (RefreshPurchasesResponse);
+  rpc ScanPurchaseOperations(ScanPurchaseOperationsRequest) returns (ScanPurchaseOperationsResponse);
   // Ping
   rpc Ping(PingRequest) returns (PingResponse);
 }
diff --git a/packages/bsync/src/index.ts b/packages/bsync/src/index.ts
@@ -104,6 +104,7 @@ export class BsyncService {
     // if these error, unhandled rejection should cause process to exit
     conn.query(`listen ${createMuteOpChannel}`)
     conn.query(`listen ${createNotifOpChannel}`)
+    conn.query(`listen ${createPurchaseOpChannel}`)
     conn.on('notification', (notif) => {
       if (notif.channel === createMuteOpChannel) {
         this.ctx.events.emit(createMuteOpChannel)

diff --git a/packages/bsync/src/proto/bsync_connect.ts b/packages/bsync/src/proto/bsync_connect.ts
@@ -20,6 +20,8 @@ import {
   ScanMuteOperationsResponse,
   ScanNotifOperationsRequest,
   ScanNotifOperationsResponse,
+  ScanPurchaseOperationsRequest,
+  ScanPurchaseOperationsResponse,
 } from './bsync_pb'
 import { MethodKind } from '@bufbuild/protobuf'
 
@@ -70,15 +72,6 @@ export const Service = {
     /**
      * Purchase
      *
-     * @generated from rpc bsync.Service.RefreshPurchases
-     */
-    refreshPurchases: {
-      name: 'RefreshPurchases',
-      I: RefreshPurchasesRequest,
-      O: RefreshPurchasesResponse,
-      kind: MethodKind.Unary,
-    },
-    /**
      * @generated from rpc bsync.Service.GetSubscriptions
      */
     getSubscriptions: {
@@ -96,6 +89,24 @@ export const Service = {
       O: GetSubscriptionGroupResponse,
       kind: MethodKind.Unary,
     },
+    /**
+     * @generated from rpc bsync.Service.RefreshPurchases
+     */
+    refreshPurchases: {
+      name: 'RefreshPurchases',
+      I: RefreshPurchasesRequest,
+      O: RefreshPurchasesResponse,
+      kind: MethodKind.Unary,
+    },
+    /**
+     * @generated from rpc bsync.Service.ScanPurchaseOperations
+     */
+    scanPurchaseOperations: {
+      name: 'ScanPurchaseOperations',
+      I: ScanPurchaseOperationsRequest,
+      O: ScanPurchaseOperationsResponse,
+      kind: MethodKind.Unary,
+    },
     /**
      * Ping
      *