update account table to add oauth_token, oauth_token_secret.

package.json

@@ -36,8 +36,8 @@
     "http-proxy": "^1.18.1",
     "install": "^0.13.0",
     "micro": "^10.0.1",
-    "next": "^13.4.9",
-    "next-auth": "^4.19.2",
+    "next": "^13.3.1",
+    "next-auth": "^4.22.1",
     "next-plugin-graphql": "^0.0.2",
     "npm": "^9.6.1",
     "prisma": "^4.9.0",

prisma/migrations/20230713130227_twitter_oauth/migration.sql

@@ -0,0 +1,3 @@
+-- AlterTable
+ALTER TABLE "Account" ADD COLUMN     "oauth_token" TEXT,
+ADD COLUMN     "oauth_token_secret" TEXT;

prisma/schema.prisma

@@ -21,6 +21,8 @@ model Account {
   scope             String?
   id_token          String? @db.Text
   session_state     String?
+  oauth_token       String? @db.Text
+  oauth_token_secret String? @db.Text
 
   user User @relation(fields: [userId], references: [id], onDelete: Cascade)
 

src/app/Home.tsx

@@ -26,6 +26,7 @@ interface HomeProps {
 
 export default function Home({ session }: HomeProps) {
   const me = useMe();
+  console.log('me in home', me);
   const dropQuery = useQuery(GetDrop);
   const collection = dropQuery.data?.drop.collection;
   const metadataJson = collection?.metadataJson;

src/app/page.tsx

@@ -1,19 +1,19 @@
-import { Drop as DropType, Project } from "@/graphql.types";
-import { getServerSession } from "next-auth/next";
-import { authOptions } from "@/pages/api/auth/[...nextauth]";
-import Home from "./Home";
+import { Drop as DropType, Project } from '@/graphql.types';
+import { getServerSession } from 'next-auth/next';
+import { authOptions } from '@/pages/api/auth/[...nextauth]';
+import Home from './Home';
 
 interface GetDropVars {
   project: string;
   drop: string;
 }
 
 interface GetDropData {
-  project: Pick<Project, "drop">;
+  project: Pick<Project, 'drop'>;
 }
 
 export default async function HomePage() {
   const session = await getServerSession(authOptions);
-
+  console.log('session', session);
   return <Home session={session} />;
 }

src/modules/user.ts

@@ -1,10 +1,10 @@
-import { ApolloClient, NormalizedCacheObject } from "@apollo/client";
-import { PrismaClient } from "@prisma/client";
-import { Project, AssetType, User } from "@/graphql.types";
-import { GetCustomerWallet } from "@/queries/customer.graphql";
+import { ApolloClient, NormalizedCacheObject } from '@apollo/client';
+import { PrismaClient } from '@prisma/client';
+import { Project, AssetType, User } from '@/graphql.types';
+import { GetCustomerWallet } from '@/queries/customer.graphql';
 
 interface GetCustomerWalletData {
-  project: Pick<Project, "customer">;
+  project: Pick<Project, 'customer'>;
 }
 
 interface GetCustomerWalletVars {
@@ -28,27 +28,27 @@ export default class UserSource {
     }
 
     const user = await this.db.user.findFirst({
-      where: { email },
+      where: { email }
     });
 
     const { data } = await this.holaplex.query<
       GetCustomerWalletData,
       GetCustomerWalletVars
     >({
-      fetchPolicy: "network-only",
+      fetchPolicy: 'network-only',
       query: GetCustomerWallet,
       variables: {
         project: process.env.HOLAPLEX_PROJECT_ID as string,
         customer: user?.holaplexCustomerId as string,
-        assetType: process.env.HOLAPLEX_WALLET_ASSET_TYPE as AssetType,
-      },
+        assetType: process.env.HOLAPLEX_WALLET_ASSET_TYPE as AssetType
+      }
     });
 
     return {
       name: user?.name,
       email: user?.email,
       image: user?.image,
-      wallet: data.project.customer?.treasury?.wallet,
+      wallet: data.project.customer?.treasury?.wallet
     } as User;
   }
 }

src/pages/api/auth/[...nextauth].ts

@@ -78,6 +78,7 @@ export const authOptions: NextAuthOptions = {
     TwitterProvider({
       clientId: process.env.TWITTER_CLIENT_ID as string,
       clientSecret: process.env.TWITTER_CLIENT_SECRET as string
+      //version: '2.0' // opt-in to Twitter OAuth 2.0
     })
   ],
   events: {
@@ -94,6 +95,7 @@ export const authOptions: NextAuthOptions = {
         }
       });
 
+      console.log('customer data', createCustomerResponse.data);
       const customer = createCustomerResponse.data?.createCustomer.customer;
 
       const me = await db.user.update({
@@ -105,6 +107,8 @@ export const authOptions: NextAuthOptions = {
         }
       });
 
+      console.log('me', me);
+
       await waitUntil(customerTreasuryReady(customer?.id as string), {
         intervalBetweenAttempts: 100
       });
@@ -122,15 +126,19 @@ export const authOptions: NextAuthOptions = {
         }
       });
 
+      console.log('customer wallet', createCustomerWalletResponse);
+
       const wallet =
         createCustomerWalletResponse.data?.createCustomerWallet.wallet;
 
-      await db.wallet.create({
+      const savedWallet = await db.wallet.create({
         data: {
           holaplexCustomerId: me.holaplexCustomerId as string,
           address: wallet?.address as string
         }
       });
+
+      console.log('saved wallet', savedWallet);
     }
   }
 };