Pratham

backend/.env.sample

@@ -4,4 +4,9 @@ GITHUB_CLIENT_SECRET=
 GITHUB_CALLBACK_URL=
 JWT_SECRET_KEY=
 JWT_REFRESH_SECRET_KEY=
-REDIS_URL=
+REDIS_PASSWORD=
+REDIS_HOST=
+REDIS_PORT=
+GITHUB_WEBHOOK_SECRET=
+EMAIL_USER=  
+EMAIL_PASS=

backend/config/redisClient.js

@@ -1,11 +1,15 @@
 import { createClient } from 'redis';
 
 const redisClient = createClient({
-  url: process.env.REDIS_URL || 'redis://localhost:6379'
+  username: 'default',
+    password: process.env.REDIS_PASSWORD,
+    socket: {
+        host: process.env.REDIS_HOST,
+        port: process.env.REDIS_PORT
+    }
 });
 
 redisClient.on('error', (err) => console.error('Redis Client Error', err));
 
-await redisClient.connect();
 
 export default redisClient;

backend/config/redisConnect.js

@@ -0,0 +1,9 @@
+import redisClient from "./redisClient.js";
+
+async function redisConnect() {
+     redisClient.on('error', err => console.log('Redis Client Error', err));
+    console.log('Redis client connected');
+    await redisClient.connect();
+}
+
+export default redisConnect ; 

backend/controllers/auth/callback.js

@@ -0,0 +1,4 @@
+export default function callback(req, res) {
+    const code = req.query.code;
+    res.redirect(`http://localhost:5173/login?code=${code}`);
+}

backend/controllers/auth/exchangecode.js

@@ -1,7 +1,6 @@
-
 import jwt from "jsonwebtoken";
 import axios from "axios";
-import UserModel from "../../models/user/userSchema.js"; 
+import UserModel from "../../models/user/userSchema.js";
 
 export default async function exchangeToken(req, res) {
   const code = req.params.code;
@@ -23,7 +22,21 @@ export default async function exchangeToken(req, res) {
       { headers: { Accept: "application/json" } }
     );
 
-    const access_token = tokenResponse.data.access_token;
+    const {
+      access_token,
+      refresh_token,
+      refresh_token_expires_in,
+      expires_in,
+    } = tokenResponse.data;
+
+    const ghAccessTokenExpiresAt = expires_in
+      ? new Date(Date.now() + expires_in * 1000)
+      : new Date(Date.now() + 2 * 60 * 60 * 1000);
+
+    const ghRefreshTokenExpiresAt = refresh_token_expires_in
+      ? new Date(Date.now() + refresh_token_expires_in * 1000)
+      : new Date(Date.now() + 180 * 24 * 60 * 60 * 1000);
+
     if (!access_token) {
       return res.status(400).json({
         success: false,
@@ -37,59 +50,54 @@ export default async function exchangeToken(req, res) {
 
     const ghUser = userResponse.data;
 
-
-    // Encrypting the GitHub token using jwt before sorting
-    const encryptedAccessToken = jwt.sign(
-      { access_token },
-      process.env.JWT_SECRET_KEY,
-      { expiresIn: "7d" }
-    );
-
     let user = await UserModel.findOne({ userId: ghUser.id });
     if (!user) {
       user = new UserModel({
         userId: ghUser.id,
         email: ghUser.email || `${ghUser.login}@users.noreply.github.com`,
         username: ghUser.login,
-        accessToken: encryptedAccessToken,
+        avatarUrl: ghUser.avatar_url,
+        accessToken: access_token,
+        accessTokenExpiresAt: ghAccessTokenExpiresAt,
+        refreshToken: refresh_token,
+        refreshTokenExpiresAt: ghRefreshTokenExpiresAt,
       });
     } else {
-      user.accessToken = encryptedAccessToken;
+      user.accessToken = access_token;
+      user.accessTokenExpiresAt = ghAccessTokenExpiresAt;
+      user.refreshToken = refresh_token;
+      user.refreshTokenExpiresAt = ghRefreshTokenExpiresAt;
+      user.avatarUrl = ghUser.avatar_url;
     }
 
-    // Generate access and refresh tokens
     const accessToken = jwt.sign(
       {
         id: user.userId,
         username: user.username,
         email: user.email,
+        avatarUrl: user.avatarUrl,
+        ghTokenExpiresAt: ghAccessTokenExpiresAt,
+        ghAccessToken: access_token,
       },
       process.env.JWT_SECRET_KEY,
-      { expiresIn: "2hr" } // access token vaise 1hr ya usse kam rkhna chiye
+      { expiresIn: "4d" }
     );
 
-    const refreshToken = jwt.sign(
-      {
-        id: user.userId,
-        username: user.username,
-        email: user.email,
-      },
-      process.env.JWT_REFRESH_SECRET_KEY,
-      { expiresIn: "7d" } // refresh token abhi k liye 7 din bad expire hoga
-    );
-
-    user.refreshToken = refreshToken;
     await user.save();
 
-    res.cookie("accesstoken", accessToken, { httpOnly: true, maxAge:  2 * 60 * 60 * 1000 });
-    res.cookie("refreshToken", refreshToken, { httpOnly: true, maxAge: 7 * 24 * 60 * 60 * 1000 });
+    res.cookie("accesstoken", accessToken, {
+      httpOnly: true,
+      maxAge: 2 * 60 * 60 * 1000,
+    });
+    req.user = user ; 
     res.status(201).json({
       success: true,
       message: "User logged in successfully",
       data: {
         username: user.username,
         email: user.email,
         userId: user.userId,
+        avatarUrl: user.avatarUrl,
       },
     });
   } catch (err) {

backend/controllers/auth/getRepoPullRequests.js

@@ -0,0 +1,35 @@
+import getDecryptedGithubToken from "../../utils/decryptGithubToken.js";
+import axios from "axios";
+
+export default async function getRepoPullRequests(req, res) {
+  try {
+    // Use authenticated user
+    const user = req.user;
+    if (!user || !user.userId) return res.status(401).json({ success: false, message: "User not authenticated" });
+ const accesstoken = req.cookies.accesstoken;
+  if (!accesstoken) return res.status(401).json({ success: false, message: "GitHub token not found" });
+    const payload = await getDecryptedGithubToken(accesstoken);
+   // console.log(payload);
+    if (!payload) return res.status(401).json({ success: false, message: "GitHub data not found" });
+
+    // Repo name comes from the URL; owner is the authenticated user's GitHub username
+    const repo = req.params.repo;
+    // console.log(repo);
+
+    const owner = user.username;
+    if (!repo) return res.status(400).json({ success: false, message: "Missing repo name" });
+    //console.log(payload.ghAccessToken);
+
+    const per_page = (req.pagination && req.pagination.limit) ? req.pagination.limit : 5;
+    const page = (req.pagination && req.pagination.page) ? req.pagination.page : 1;
+
+    const response = await axios.get(`https://api.github.com/repos/${owner}/${repo}/pulls`, {
+      headers: { Authorization: `token ${payload.ghAccessToken}` },
+      params: { state: "open", per_page, page }
+    });
+    res.json({ success: true, pulls: response.data, pagination: req.pagination || { limit: per_page, page } });
+  } catch (err) {
+    console.error("getRepoPullRequests error:", err.message);
+    res.status(500).json({ success: false, message: err.message });
+  }
+}

backend/controllers/auth/getUserRepos.js

@@ -0,0 +1,59 @@
+import getDecryptedGithubToken from "../../utils/decryptGithubToken.js";
+import axios from "axios";
+
+export default async function getUserRepos(req, res) {
+  try {
+    const user = req.user;
+    if (!user || !user.userId) {
+      return res.status(401).json({ success: false, message: "User not authenticated" });
+    }
+
+    const accessToken = req.cookies.accesstoken;
+    if (!accessToken) {
+      return res.status(401).json({ success: false, message: "GitHub token not found" });
+    }
+
+    const payload = await getDecryptedGithubToken(accessToken);
+
+    // Use pagination middleware values if present, otherwise fall back
+    const per_page = (req.pagination && req.pagination.limit) ? req.pagination.limit : 5;
+    const page = (req.pagination && req.pagination.page) ? req.pagination.page : 1;
+
+    const response = await axios.get("https://api.github.com/user/repos", {
+      headers: { Authorization: `token ${payload.ghAccessToken}` },
+      params: { page, per_page, sort: "updated" }
+    });
+
+    const repos = response.data || [];
+
+    const filtered = repos.map(repo => ({
+      id: repo.id,
+      name: repo.name,
+      full_name: repo.full_name,
+      private: repo.private,
+      url: repo.url,
+
+      owner: repo.owner ? {
+        login: repo.owner.login,
+        id: repo.owner.id,
+        avatar_url: repo.owner.avatar_url,
+        html_url: repo.owner.html_url,
+        type: repo.owner.type
+      } : null,
+
+      html_url: repo.html_url,
+      description: repo.description,
+      forks_count: repo.forks_count,
+      stargazers_count: repo.stargazers_count,
+      watchers_count: repo.watchers_count,
+      open_issues_count: repo.open_issues_count,
+      language: repo.language
+    }));
+
+    return res.json({ success: true, repos: filtered, pagination: req.pagination || { limit: per_page, page } });
+
+  } catch (err) {
+    console.error("getUserRepos error:", err.message);
+    return res.status(500).json({ success: false, message: err.message });
+  }
+}

backend/controllers/auth/logoutuser.js

@@ -19,7 +19,18 @@ export default async function logoutUser(req, res) {
       }
     }
 
-    const userId = req.user?.id || req.body.userId;
+
+    // Extract userId from access token payload (verify signature)
+    let userId;
+    if (accessToken) {
+      try {
+        const payload = jwt.verify(accessToken, process.env.JWT_SECRET_KEY);
+        userId = payload.id;
+        console.log("userid found: " + userId);
+      } catch (e) {
+      throw new error ("userid couldnt be found" + e);  
+      }
+    }
     if (userId) {
       await UserModel.updateOne({ userId }, { $unset: { refreshToken: "" } });
     }

backend/controllers/auth/redirect.js

@@ -27,7 +27,7 @@
  * // User visits endpoint triggering this function
  * // Gets redirected to: https://github.com/login/oauth/authorize?client_id=123&redirect_uri=https://app.com/callback&scope=read:user%20user:email%20repo
  */
-export default function redirectUser(req,res){
-    const redirectURL = `https://github.com/login/oauth/authorize?client_id=${process.env.GITHUB_CLIENT_ID}&redirect_uri=${process.env.GITHUB_CALLBACK_URL}&scope=read:user%20user:email%20repo`
-    res.redirect(redirectURL) ; 
+export default function redirectUser(req, res) {
+    const redirectURL = `https://github.com/login/oauth/authorize?client_id=${process.env.GITHUB_CLIENT_ID}&redirect_uri=http://localhost:3000/auth/callback&scope=read:user%20user:email%20repo`
+    res.redirect(redirectURL);
 }