[PAY-2450][PAY-2451] Purchase indexing uses access from memo (#7510)

AudiusProject · Feb 8, 2024 · 328e805 · 328e805
1 parent fd2a0a8
commit 328e805
Show file tree

Hide file tree

Showing 10 changed files with 1,245 additions and 93 deletions.
diff --git a/packages/common/src/models/PurchaseContent.ts b/packages/common/src/models/PurchaseContent.ts
@@ -8,3 +8,8 @@ export enum PurchaseVendor {
   STRIPE = 'Stripe',
   COINFLOW = 'Coinflow'
 }
+
+export enum PurchaseAccess {
+  STREAM = 'stream',
+  DOWNLOAD = 'download'
+}
diff --git a/packages/common/src/services/audius-backend/solana.ts b/packages/common/src/services/audius-backend/solana.ts
@@ -20,7 +20,13 @@ import BN from 'bn.js'
 
 import { BN_USDC_CENT_WEI } from '~/utils/wallet'
 
-import { AnalyticsEvent, ID, Name, SolanaWalletAddress } from '../../models'
+import {
+  AnalyticsEvent,
+  ID,
+  Name,
+  SolanaWalletAddress,
+  PurchaseAccess
+} from '../../models'
 
 import { AudiusBackend } from './AudiusBackend'
 
@@ -378,6 +384,7 @@ export type PurchaseContentArgs = {
   type: 'track'
   splits: Record<string, number | BN>
   purchaserUserId: ID
+  purchaseAccess: PurchaseAccess
 }
 export const purchaseContent = async (
   audiusBackendInstance: AudiusBackend,
@@ -397,6 +404,7 @@ export type PurchaseContentWithPaymentRouterArgs = {
   recentBlockhash?: string
   purchaserUserId: ID
   wallet: Keypair
+  purchaseAccess: PurchaseAccess
 }
 
 export const purchaseContentWithPaymentRouter = async (
@@ -408,7 +416,8 @@ export const purchaseContentWithPaymentRouter = async (
     extraAmount = 0,
     purchaserUserId,
     splits,
-    wallet
+    wallet,
+    purchaseAccess
   }: PurchaseContentWithPaymentRouterArgs
 ) => {
   const solanaWeb3Manager = (await audiusBackendInstance.getAudiusLibs())
@@ -421,7 +430,8 @@ export const purchaseContentWithPaymentRouter = async (
     splits,
     purchaserUserId,
     senderKeypair: wallet,
-    skipSendAndReturnTransaction: true
+    skipSendAndReturnTransaction: true,
+    purchaseAccess
   })
   return tx
 }
@@ -474,7 +484,8 @@ export const createRootWalletRecoveryTransaction = async (
       blocknumber: 0, // ignored
       splits: { [userBank.toString()]: new BN(amount.toString()) },
       purchaserUserId: 0, // ignored
-      senderAccount: wallet.publicKey
+      senderAccount: wallet.publicKey,
+      purchaseAccess: PurchaseAccess.STREAM //ignored
     })
 
   const recentBlockhash = await getRecentBlockhash(audiusBackendInstance)
@@ -660,7 +671,8 @@ export const createPaymentRouterRouteTransaction = async (
       blocknumber: 0, // ignored
       splits,
       purchaserUserId: 0, // ignored
-      senderAccount: sender
+      senderAccount: sender,
+      purchaseAccess: PurchaseAccess.STREAM //ignored
     })
   return new Transaction({
     recentBlockhash: blockhash,

diff --git a/packages/common/src/store/purchase-content/sagas.ts b/packages/common/src/store/purchase-content/sagas.ts
@@ -5,7 +5,11 @@ import { call, put, race, select, take } from 'typed-redux-saga'
 import { FavoriteSource, Name } from '~/models/Analytics'
 import { ErrorLevel } from '~/models/ErrorReporting'
 import { ID } from '~/models/Identifiers'
-import { PurchaseMethod, PurchaseVendor } from '~/models/PurchaseContent'
+import {
+  PurchaseMethod,
+  PurchaseVendor,
+  PurchaseAccess
+} from '~/models/PurchaseContent'
 import { Track, isContentUSDCPurchaseGated } from '~/models/Track'
 import { User } from '~/models/User'
 import { BNUSDC } from '~/models/Wallet'
@@ -94,6 +98,12 @@ function* getContentInfo({ contentId, contentType }: GetPurchaseConfigArgs) {
   const trackInfo = yield* select(getTrack, { id: contentId })
   const purchaseConditions =
     trackInfo?.stream_conditions ?? trackInfo?.download_conditions
+  // Stream access is a superset of download access - purchasing a stream-gated
+  // track also gets you download access, but purchasing a download-gated track
+  // only gets you download access (because the track was already free to stream).
+  const purchaseAccess = trackInfo?.is_stream_gated
+    ? PurchaseAccess.STREAM
+    : PurchaseAccess.DOWNLOAD
   if (!trackInfo || !isContentUSDCPurchaseGated(purchaseConditions)) {
     throw new Error('Content is missing purchase conditions')
   }
@@ -105,7 +115,7 @@ function* getContentInfo({ contentId, contentType }: GetPurchaseConfigArgs) {
   const title = trackInfo.title
   const price = purchaseConditions.usdc_purchase.price
 
-  return { price, title, artistInfo, trackInfo }
+  return { price, title, artistInfo, purchaseAccess, trackInfo }
 }
 
 const getUserPurchaseMetadata = ({
@@ -261,6 +271,7 @@ type PurchaseWithCoinflowArgs = {
   purchaserUserId: ID
   /** USDC in dollars */
   price: number
+  purchaseAccess: PurchaseAccess
 }
 
 function* purchaseWithCoinflow(args: PurchaseWithCoinflowArgs) {
@@ -270,7 +281,8 @@ function* purchaseWithCoinflow(args: PurchaseWithCoinflowArgs) {
     splits,
     contentId,
     purchaserUserId,
-    price
+    price,
+    purchaseAccess
   } = args
   const audiusBackendInstance = yield* getContext('audiusBackendInstance')
   const feePayerAddress = yield* select(getFeePayer)
@@ -292,7 +304,8 @@ function* purchaseWithCoinflow(args: PurchaseWithCoinflowArgs) {
       blocknumber,
       recentBlockhash,
       purchaserUserId,
-      wallet: rootAccount
+      wallet: rootAccount,
+      purchaseAccess
     }
   )
 
@@ -399,10 +412,13 @@ function* doStartPurchaseContentFlow({
   const reportToSentry = yield* getContext('reportToSentry')
   const { track, make } = yield* getContext('analytics')
 
-  const { price, title, artistInfo } = yield* call(getContentInfo, {
-    contentId,
-    contentType
-  })
+  const { price, title, artistInfo, purchaseAccess } = yield* call(
+    getContentInfo,
+    {
+      contentId,
+      contentType
+    }
+  )
 
   const analyticsInfo = {
     price: price / 100,
@@ -471,7 +487,8 @@ function* doStartPurchaseContentFlow({
         extraAmount: extraAmountBN,
         splits,
         type: 'track',
-        purchaserUserId
+        purchaserUserId,
+        purchaseAccess
       })
     } else {
       // We need to acquire USDC before the purchase can continue
@@ -494,7 +511,8 @@ function* doStartPurchaseContentFlow({
             contentId,
             contentType,
             purchaserUserId,
-            price: purchaseAmount
+            price: purchaseAmount,
+            purchaseAccess
           })
           break
         case PurchaseVendor.STRIPE:
@@ -506,7 +524,8 @@ function* doStartPurchaseContentFlow({
             extraAmount: extraAmountBN,
             splits,
             type: 'track',
-            purchaserUserId
+            purchaserUserId,
+            purchaseAccess
           })
           break
       }