feat: update worklow details

Author: pulkitxm

scripts/src/fetchFollowers.js

@@ -8,7 +8,7 @@ if(process.env.ACCESS_TOKEN === undefined){
 
 import { Octokit } from "@octokit/rest";
 import { readFileSync, writeFileSync } from "fs";
-import { updateWorkflowNumber } from "./updateWorkflowNumber.js";
+import { updateWorkflowNumber } from "./updateWorkflow.js";
 import { READMEFILE_PATH } from "./config.js";
 
 const octokit = new Octokit({

scripts/src/fetchLatestBlogPosts.js

@@ -3,7 +3,7 @@ dotenv.config();
 
 import axios from "axios";
 import { readFileSync, writeFileSync } from "fs";
-import { updateWorkflowNumber } from "./updateWorkflowNumber.js";
+import { updateWorkflowNumber } from "./updateWorkflow.js";
 import { BlogsResponseSchema, READMEFILE_PATH } from "./config.js";
 
 const fetchLatestBlogs = async () => {

scripts/src/langGraph.js

@@ -0,0 +1,82 @@
+import dotenv from "dotenv";
+dotenv.config();
+
+if (process.env.ACCESS_TOKEN === undefined) {
+  console.error("Please provide ACCESS_TOKEN in .env file");
+  process.exit(1);
+}
+
+import { Octokit } from "@octokit/rest";
+import axios from "axios";
+import fs from "fs";
+
+async function getAllRepositories(octokit) {
+  try {
+    const repos = await octokit.paginate(
+      octokit.repos.listForAuthenticatedUser,
+      {
+        per_page: 100,
+        affiliation: "owner",
+        sort: "updated",
+        direction: "desc",
+      }
+    );
+
+    const nonForkedRepos = repos.filter((repo) => !repo.fork);
+    console.log(`Fetched ${nonForkedRepos.length} non-forked repositories`);
+    return nonForkedRepos;
+  } catch (error) {
+    console.log(`Error fetching repositories: ${error.message}`);
+    throw error;
+  }
+}
+
+async function getLanguageStats(octokit, repos) {
+  const languageStats = {};
+
+  for (const repo of repos) {
+    try {
+      const languages = await octokit.repos.listLanguages({
+        owner: repo.owner.login,
+        repo: repo.name,
+      });
+
+      for (const [language, bytes] of Object.entries(languages.data)) {
+        languageStats[language] = (languageStats[language] || 0) + bytes;
+      }
+      console.log(`Processed languages for ${repo.name}`);
+    } catch (error) {
+      console.log(
+        `Error fetching languages for ${repo.name}: ${error.message}`
+      );
+    }
+  }
+
+  return languageStats;
+}
+
+async function main() {
+  try {
+    if (!process.env.ACCESS_TOKEN) {
+      throw new Error(
+        "GitHub token not found. Please set ACCESS_TOKEN in .env file."
+      );
+    }
+
+    const octokit = new Octokit({ auth: process.env.ACCESS_TOKEN });
+
+    console.log("Starting repository and language analysis...");
+
+    const repos = await getAllRepositories(octokit);
+    const languageStats = await getLanguageStats(octokit, repos);
+
+    console.log(languageStats);
+
+    console.log("Analysis completed successfully!");
+  } catch (error) {
+    console.log(`Fatal error: ${error.message}`);
+    process.exit(1);
+  }
+}
+
+main();

scripts/src/updateWorkflowNumber.js renamed to scripts/src/updateWorkflow.js

@@ -14,33 +14,44 @@ const octokit = new Octokit({
   auth: process.env.ACCESS_TOKEN,
 });
 
-const getWorflowCount = async () => {
+const getLatestWorkflow = async () => {
   const username = "pulkitxm";
   const repoName = username;
   try {
     const response = await octokit.actions.listWorkflowRunsForRepo({
       owner: username,
       repo: repoName,
     });
-    return response.data.total_count;
+    return {
+      count: response.data.total_count,
+      timeStamp: response.data.workflow_runs[0].created_at,
+    };
   } catch (error) {
     console.error(error.message);
-    return 0;
+    return {
+      count: 0,
+      timeStamp: new Date().toISOString(),
+    };
   }
 };
 
 export async function updateWorkflowNumber() {
-  const workflowCount = await getWorflowCount();
+  const workflowDetails = await getLatestWorkflow();
+  const count = workflowDetails.count;
+  const timeStamp = new Date(workflowDetails.timeStamp);
+
   const readmeContent = readFileSync(READMEFILE_PATH, "utf-8");
 
-  // *Note: All the data displayed above is updated automatically via GitHub Actions. There have been **3** workflow runs so far.*
   const updatedContent = readmeContent.replace(
-    /Note: All the data displayed above is updated automatically via GitHub Actions. There have been \*\*\d+\*\* workflow runs so far./,
-    `Note: All the data displayed above is updated automatically via GitHub Actions. There have been **${workflowCount}** workflow runs so far.`
+    /(?<=<!--START_SECTION:workflows-update-->\n)[\s\S]*(?=\n<!--END_SECTION:workflows-update-->)/,
+    `\n<p align="center">
+      This <i>README</i> file is refreshed <b>every 24 hours</b>!<br/>
+      Last refresh: <b>${timeStamp.toUTCString().split(",")[1]}</b><br/>
+      Number of workflows: ${count}<br/><br/>
+      Made with ❤️ by Pulkit
+    </p>\n`
   );
 
   writeFileSync(READMEFILE_PATH, updatedContent, "utf-8");
-  console.log(
-    `README file updated with the latest workflow count(${workflowCount}).`
-  );
+  console.log(`README file updated with the latest workflow count(${count}).`);
 }