update kv usage

Author: brendan-defi

apps/web/pages/api/checkNftProof/index.ts

@@ -1,5 +1,5 @@
 import type { NextApiRequest, NextApiResponse } from 'next';
-import { redis } from 'apps/web/src/utils/redis';
+import { kv } from 'apps/web/src/utils/kv';
 import { logger } from 'apps/web/src/utils/logger';
 
 type RequestBody = {
@@ -21,7 +21,7 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
   const { address } = req.body as RequestBody;
 
   try {
-    const proof = await redis.get<string[]>(`proof:${address}`);
+    const proof = await kv.get<string[]>(`proof:${address}`);
 
     if (proof) {
       return res.status(200).json({ result: proof });

apps/web/pages/api/registry/entries.ts

@@ -1,12 +1,11 @@
 import { NextApiRequest, NextApiResponse } from 'next';
 import { db } from 'apps/web/src/utils/ocsRegistry';
-import { redis } from 'apps/web/src/utils/redis';
+import { kv } from 'apps/web/src/utils/kv';
 import { logger } from 'apps/web/src/utils/logger';
 import { withTimeout } from 'apps/web/pages/api/decorators';
 
 const pageKey = 'api.ocs_registry.entries';
 async function handler(req: NextApiRequest, res: NextApiResponse) {
-  const redisClient = await redis.getClient();
   const { page = '1', limit = '10', category, curation } = req.query;
 
   const pageNum = parseInt(page as string, 10);
@@ -50,7 +49,7 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
   };
 
   try {
-    await redisClient.incr(`stat:requests.${pageKey}`);
+    await kv.incr(`stat:requests.${pageKey}`);
   } catch (error) {
     logger.error('error getting registry entries', error);
   }

apps/web/pages/api/registry/featured.ts

@@ -1,12 +1,11 @@
 import { NextApiRequest, NextApiResponse } from 'next';
 import { db } from 'apps/web/src/utils/ocsRegistry';
-import { redis } from 'apps/web/src/utils/redis';
+import { kv } from 'apps/web/src/utils/kv';
 import { logger } from 'apps/web/src/utils/logger';
 import { withTimeout } from 'apps/web/pages/api/decorators';
 
 const pageKey = 'api.ocs_registry.featured';
 async function handler(req: NextApiRequest, res: NextApiResponse) {
-  const redisClient = await redis.getClient();
   const content = await db
     .selectFrom('content')
     .where('is_featured', '=', true)
@@ -21,7 +20,7 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
   };
 
   try {
-    await redisClient.incr(`stat:requests.${pageKey}`);
+    await kv.incr(`stat:requests.${pageKey}`);
   } catch (error) {
     logger.error('error getting featured registry entries', error);
   }

apps/web/src/utils/proofs/sybil_resistance.ts

@@ -1,5 +1,5 @@
 import { getAttestations } from '@coinbase/onchainkit/identity';
-import { redis } from 'apps/web/src/utils/redis'
+import { kv } from 'apps/web/src/utils/kv';
 import { CoinbaseProofResponse } from 'apps/web/pages/api/proofs/coinbase';
 import RegistrarControllerABI from 'apps/web/src/abis/RegistrarControllerABI';
 import {
@@ -193,7 +193,7 @@ export async function sybilResistantUsernameSigning(
 
   const kvKey = `${previousClaimsKVPrefix}${idemKey}`;
   //check kv for previous claim entries
-  let previousClaims = (await redis.get<PreviousClaims>(kvKey)) ?? {};
+  let previousClaims = (await kv.get<PreviousClaims>(kvKey)) ?? {};
   const previousClaim = previousClaims[discountType];
   if (previousClaim) {
     if (previousClaim.address != address) {
@@ -223,7 +223,7 @@ export async function sybilResistantUsernameSigning(
     const claim: PreviousClaim = { address, signedMessage };
     previousClaims[discountType] = claim;
 
-    await redis.set<PreviousClaims>(kvKey, previousClaims, { nx: true, ex: parseInt(EXPIRY) });
+    await kv.set<PreviousClaims>(kvKey, previousClaims, { nx: true, ex: parseInt(EXPIRY) });
 
     return {
       signedMessage: claim.signedMessage,