diff --git a/.env.local b/.env.local
index 742678a..33e0e13 100644
--- a/.env.local
+++ b/.env.local
@@ -12,4 +12,7 @@ NEXT_PUBLIC_PAPER_URL=/api/paper
#"https://api.openai.com/v1/chat/completions" "https://api.liuweiqing.top" "https://api.liuweiqing.top/v1/chat/completions"
#node转发设置为 /api/v1/chat/completions https://one.caifree.com sk-aiHrrRLYUUelHstX69E9484509254dBf92061d6744FfFaD1
VERCEL_URL=https://www.paperai.life
-NODE_ENV=development
\ No newline at end of file
+NODE_ENV=development
+CLIENT_ID=UrgIEI0n03tveTmaOV0IU8qRY4DttGY4
+CLIENT_SECRET=ljShbIlIrfULu4BTUVTT4azeR90PtAif
+REDIRECT_URI=http://localhost:3000/api/oauth/callback
\ No newline at end of file
diff --git a/.env.production b/.env.production
index 9a7a8b3..bd4e5d0 100644
--- a/.env.production
+++ b/.env.production
@@ -7,3 +7,6 @@ NEXT_PUBLIC_SEMANTIC_API_KEY=hEQvK6ARe84dzDPcMnpzX4n9jfoqztkMfaftPWnb
NEXT_PUBLIC_PUBMED_API_KEY=057616e7ce6c722f2ae8679e38a8be9b1a09
VERCEL_URL=https://www.paperai.life
NODE_ENV=production
+CLIENT_ID=RcgInz3KqEhb2KdW2yg5WUgAf3KHcJAC
+CLIENT_SECRET=U4z8TgPIV1GWCXhFFNEVQyfmDotf91K6
+REDIRECT_URI=https://www.paperai.life/api/oauth/callback
\ No newline at end of file
diff --git a/app/[lng]/login/page.tsx b/app/[lng]/login/page.tsx
index 85ccf5b..3fe6d7b 100644
--- a/app/[lng]/login/page.tsx
+++ b/app/[lng]/login/page.tsx
@@ -12,6 +12,7 @@ import { FooterBase } from "@/components/Footer/FooterBase";
import { insertUserProfile } from "@/utils/supabase/supabaseutils";
// SignInWithProvider
import { SignInWithProvider } from "@/components/SignInWithProvider";
+import LinuxdoSignin from "@/components/LinuxdoSignin";
export default async function Login({
searchParams,
params: { lng },
@@ -146,6 +147,7 @@ export default async function Login({
)}
+
{isSupabaseConnected &&
}
+ {/* 如果用户没有登录会出现谷歌的sign in按钮登录之后不会出现 */}
{!user &&
}
diff --git a/app/api/oauth/callback/route.ts b/app/api/oauth/callback/route.ts
new file mode 100644
index 0000000..693246c
--- /dev/null
+++ b/app/api/oauth/callback/route.ts
@@ -0,0 +1,106 @@
+// api/oauth/callback.js
+import { createClient } from "@/utils/supabase/server";
+import { NextResponse } from "next/server";
+import { cookies } from "next/headers";
+import axios from "axios";
+//supabase
+import { insertUserProfile } from "@/utils/supabase/supabaseutils";
+import { setVip } from "@/utils/supabase/serverutils";
+export async function GET(request: Request) {
+ const requestUrl = new URL(request.url);
+ const code = requestUrl.searchParams.get("code");
+ if (code) {
+ const cookieStore = cookies();
+ const supabase = createClient(cookieStore);
+ // await supabase.auth.exchangeCodeForSession(code);
+
+ // 使用授权码请求访问令牌
+ const tokenResponse = await getToken(code);
+
+ const accessToken = tokenResponse!.data.access_token;
+ console.log("accessToekn", accessToken);
+ // 使用访问令牌获取用户信息
+ const userResponse = await axios.get("https://connect.linux.do/api/user", {
+ headers: { Authorization: `Bearer ${accessToken}` },
+ });
+
+ const userInfo = userResponse.data;
+ const uuid = "9e1c30b5-723c-4805-b3b8-0ac3c1923514"; //生成密码
+ let userId = null;
+ // 尝试注册新用户
+ const signUpResponse = await supabase.auth.signUp({
+ email: `${userInfo.username}@linux.do`, // 使用模板字符串构建email
+ password: uuid, // 使用uuid作为密码
+ });
+
+ if (signUpResponse.error) {
+ // 如果用户已存在,尝试登录来获取用户信息
+ await supabase.auth.signOut();
+ const signInResponse = await supabase.auth.signInWithPassword({
+ email: `${userInfo.username}@linux.do`,
+ password: uuid,
+ });
+ if (signInResponse.error) {
+ console.error("Error logging in existing user:", signInResponse.error);
+ // 处理登录失败的情况
+ } else {
+ //signin成功
+ userId = signInResponse.data.user!.id;
+ }
+ } else {
+ //signup成功之后可能要signin一次
+ const signInResponse = await supabase.auth.signInWithPassword({
+ email: `${userInfo.username}@linux.do`,
+ password: uuid,
+ });
+ console.log("signInResponse:", signInResponse);
+ userId = signUpResponse.data.user!.id;
+ }
+ // 如果获取到了用户ID,进行后续操作
+ if (userId) {
+ // console.log("signUpResponse.data:", signUpResponse.data);
+ //插入信息并设置VIP
+ await insertUserProfile(signUpResponse.data, supabase);
+ await setVip(supabase, userId, true, "Linuxdo");
+ } else {
+ return new Response(
+ JSON.stringify({ error: "Unable to register or login the user" }),
+ {
+ status: 500,
+ headers: {
+ "Content-Type": "application/json",
+ },
+ }
+ );
+ }
+
+ // URL to redirect to after sign in process completes
+ return NextResponse.redirect(requestUrl.origin);
+ }
+
+ async function getToken(code: string) {
+ // 使用client_id和client_secret创建Basic Auth凭证
+ try {
+ const tokenResponse = await axios.post(
+ "https://connect.linux.do/oauth2/token",
+ `grant_type=authorization_code&code=${code}&redirect_uri=${encodeURIComponent(
+ process.env.REDIRECT_URI
+ )}`,
+ {
+ headers: {
+ Authorization: `Basic ${Buffer.from(
+ `${process.env.CLIENT_ID}:${process.env.CLIENT_SECRET}`
+ ).toString("base64")}`,
+ "Content-Type": "application/x-www-form-urlencoded",
+ },
+ }
+ );
+
+ // 处理tokenResponse...
+ return tokenResponse;
+ } catch (error) {
+ // 处理错误...
+ console.error(error);
+ }
+ }
+}
diff --git a/components/LinuxdoSignin.tsx b/components/LinuxdoSignin.tsx
new file mode 100644
index 0000000..66599a1
--- /dev/null
+++ b/components/LinuxdoSignin.tsx
@@ -0,0 +1,28 @@
+"use client";
+import React from "react";
+
+const LinuxdoSignin = () => {
+ const handleLogin = () => {
+ // 构建授权URL
+ const clientId = "UrgIEI0n03tveTmaOV0IU8qRY4DttGY4";
+ const responseType = "code";
+ const authUrl = `https://connect.linux.do/oauth2/authorize?response_type=${responseType}&client_id=${clientId}&state=ttt1`;
+
+ // 重定向到授权页面
+ window.location.href = authUrl;
+ };
+
+ return (
+
+
+
+ );
+};
+
+export default LinuxdoSignin;
diff --git a/middleware.ts b/middleware.ts
index 96936e2..2843cd3 100644
--- a/middleware.ts
+++ b/middleware.ts
@@ -69,6 +69,6 @@ export const config = {
* - favicon.ico (favicon file)
* Feel free to modify this pattern to include more paths.
*/
- "/((?!_next/static|_next/image|favicon.ico|twitter-image.png|opengraph-image.png|manifest.json|site.webmanifest|favicon-32x32.png|favicon-16x16.png|apple-touch-icon.png|android-chrome-512x512.png|android-chrome-192x192.png|service-worker.js|serviceregister.js|global.css|sitemap.xml|robots.txt).*)",
+ "/((?!_next/static|_next/image|favicon.ico|twitter-image.png|opengraph-image.png|manifest.json|site.webmanifest|favicon-32x32.png|favicon-16x16.png|apple-touch-icon.png|android-chrome-512x512.png|android-chrome-192x192.png|service-worker.js|serviceregister.js|global.css|sitemap.xml|robots.txt|api/oauth/callback).*)",
],
};
diff --git a/utils/supabase/serverutils.ts b/utils/supabase/serverutils.ts
new file mode 100644
index 0000000..29fa989
--- /dev/null
+++ b/utils/supabase/serverutils.ts
@@ -0,0 +1,47 @@
+import { NextResponse } from "next/server";
+
+import { SupabaseClient } from "@supabase/supabase-js";
+export async function setVip(
+ supabaseAdmin: SupabaseClient,
+ userId: string,
+ isVip = true,
+ source = "Linuxdo",
+ startDate = new Date(),
+ endDate = new Date()
+) {
+ if (!userId)
+ return NextResponse.json({ message: "No user found" }, { status: 403 });
+ const { data, error } = await supabaseAdmin.from("vip_statuses").upsert(
+ {
+ user_id: userId,
+ is_vip: isVip,
+ source: source,
+ start_date: startDate,
+ end_date: endDate,
+ },
+ { onConflict: "user_id" }
+ );
+ if (error) {
+ console.error("设置 VIP 失败:", error);
+ return NextResponse.json(
+ { message: "Failed to set VIP 设置 VIP 状态失败" },
+ { status: 403 }
+ );
+ }
+ return NextResponse.json({ message: "Success VIP 状态已更新:" });
+}
+
+async function getUserId(supabaseAdmin: SupabaseClient, email: string) {
+ const { data, error } = await supabaseAdmin
+ .from("profiles")
+ .select("id")
+ .eq("email", email)
+ .single();
+
+ if (error) {
+ console.error("查询用户 ID 失败:", error);
+ return null;
+ }
+
+ return data.id;
+}
diff --git a/utils/supabase/supabaseutils.ts b/utils/supabase/supabaseutils.ts
index 1f40756..36669db 100644
--- a/utils/supabase/supabaseutils.ts
+++ b/utils/supabase/supabaseutils.ts
@@ -186,6 +186,7 @@ export async function insertUserProfile(data: any, supabase: SupabaseClient) {
}
if (user) {
+ // console.log("user in insertUserProfile:", user);
const currentTime = new Date().toISOString(); // 生成ISO格式的时间字符串
const { data, error: profileError } = await supabase