One referrer per user (#808)

packages/api/src/routers/_app.ts

@@ -7,6 +7,7 @@ import { tagRouter } from './tag'
 import { secretShopRouter } from './secretShop'
 import { sendAccountRouter } from './sendAccount'
 import { accountRecoveryRouter } from './account-recovery/router'
+import { referralsRouter } from './referrals'
 
 export const appRouter = createTRPCRouter({
   chainAddress: chainAddressRouter,
@@ -16,6 +17,7 @@ export const appRouter = createTRPCRouter({
   distribution: distributionRouter,
   secretShop: secretShopRouter,
   sendAccount: sendAccountRouter,
+  referrals: referralsRouter,
 })
 
 export type AppRouter = typeof appRouter

packages/api/src/routers/referrals.ts

@@ -0,0 +1,44 @@
+import { TRPCError } from '@trpc/server'
+import { createTRPCRouter, protectedProcedure } from '../trpc'
+import debug from 'debug'
+import { supabaseAdmin } from 'app/utils/supabase/admin'
+const log = debug('api:routers:referrals')
+
+export const referralsRouter = createTRPCRouter({
+  getReferred: protectedProcedure.query(async ({ ctx }) => {
+    const { user } = ctx.session
+    if (!user) {
+      throw new TRPCError({
+        code: 'UNAUTHORIZED',
+        message: 'Unauthorized',
+      })
+    }
+    const { data: referred, error } = await supabaseAdmin
+      .from('referrals')
+      .select('*')
+      .eq('referred_id', user.id)
+      .single()
+    if (error && error.code !== 'PGRST116') {
+      log('referrals error', error)
+      throw new TRPCError({
+        code: 'INTERNAL_SERVER_ERROR',
+        message: error.message,
+      })
+    }
+    if (!referred) return null
+    const { data: referrerSendAccount, error: referrerError } = await supabaseAdmin
+      .from('send_accounts')
+      .select('*')
+      .eq('id', referred.referrer_id)
+      .single()
+    if (referrerError && referrerError.code !== 'PGRST116') {
+      log('referrals error', referrerError)
+      throw new TRPCError({
+        code: 'INTERNAL_SERVER_ERROR',
+        message: referrerError.message,
+      })
+    }
+
+    return { referred, referrerSendAccount }
+  }),
+})