212 lines
10 KiB
JavaScript
212 lines
10 KiB
JavaScript
/**Indepth analyzer */
|
|
export async function indepth({login, data, imports, repositories}, {skipped}) {
|
|
//Check prerequisites
|
|
if (!await imports.which("github-linguist"))
|
|
throw new Error("Feature requires github-linguist")
|
|
|
|
//Compute repositories stats from fetched repositories
|
|
const results = {total:0, lines:{}, stats:{}}
|
|
for (const repository of repositories) {
|
|
//Skip repository if asked
|
|
if ((skipped.includes(repository.name.toLocaleLowerCase())) || (skipped.includes(`${repository.owner.login}/${repository.name}`.toLocaleLowerCase()))) {
|
|
console.debug(`metrics/compute/${login}/plugins > languages > skipped repository ${repository.owner.login}/${repository.name}`)
|
|
continue
|
|
}
|
|
|
|
//Repository handle
|
|
const repo = `${repository.owner.login}/${repository.name}`
|
|
console.debug(`metrics/compute/${login}/plugins > languages > indepth > checking ${repo}`)
|
|
|
|
//Temporary directory
|
|
const path = imports.paths.join(imports.os.tmpdir(), `${data.user.databaseId}-${repo.replace(/[^\w]/g, "_")}`)
|
|
console.debug(`metrics/compute/${login}/plugins > languages > indepth > cloning ${repo} to temp dir ${path}`)
|
|
|
|
//Process
|
|
try {
|
|
//Git clone into temporary directory
|
|
await imports.fs.rmdir(path, {recursive:true})
|
|
await imports.fs.mkdir(path, {recursive:true})
|
|
const git = await imports.git(path)
|
|
await git.clone(`https://github.com/${repo}`, ".").status()
|
|
|
|
//Analyze repository
|
|
await analyze(arguments[0], {results, path})
|
|
}
|
|
catch {
|
|
console.debug(`metrics/compute/${login}/plugins > languages > indepth > an error occured while processing ${repo}, skipping...`)
|
|
}
|
|
finally {
|
|
//Cleaning
|
|
console.debug(`metrics/compute/${login}/plugins > languages > indepth > cleaning temp dir ${path}`)
|
|
await imports.fs.rmdir(path, {recursive:true})
|
|
}
|
|
}
|
|
return results
|
|
}
|
|
|
|
/**Recent languages activity */
|
|
export async function recent({login, data, imports, rest, account}, {skipped = [], days = 0, load = 0, tempdir = "recent"}) {
|
|
//Check prerequisites
|
|
if (!await imports.which("github-linguist"))
|
|
throw new Error("Feature requires github-linguist")
|
|
|
|
//Get user recent activity
|
|
console.debug(`metrics/compute/${login}/plugins > languages > querying api`)
|
|
const commits = [], pages = Math.ceil(load/100), results = {total:0, lines:{}, stats:{}, commits:0, files:0, days}
|
|
try {
|
|
for (let page = 1; page <= pages; page++) {
|
|
console.debug(`metrics/compute/${login}/plugins > languages > loading page ${page}`)
|
|
commits.push(...(await rest.activity.listEventsForAuthenticatedUser({username:login, per_page:100, page})).data
|
|
.filter(({type}) => type === "PushEvent")
|
|
.filter(({actor}) => account === "organization" ? true : actor.login === login)
|
|
.filter(({repo:{name:repo}}) => (!skipped.includes(repo.toLocaleLowerCase())) && (!skipped.includes(repo.toLocaleLowerCase().split("/").pop())))
|
|
.filter(({created_at}) => new Date(created_at) > new Date(Date.now() - days * 24 * 60 * 60 * 1000))
|
|
)
|
|
}
|
|
}
|
|
catch {
|
|
console.debug(`metrics/compute/${login}/plugins > languages > no more page to load`)
|
|
}
|
|
console.debug(`metrics/compute/${login}/plugins > languages > ${commits.length} commits loaded`)
|
|
results.commits = commits.length
|
|
results.latest = Math.round((new Date().getTime() - new Date(commits.slice(-1).shift()?.created_at).getTime()) / (1000 * 60 * 60 * 24))
|
|
|
|
//Retrieve edited files and filter edited lines (those starting with +/-) from patches
|
|
console.debug(`metrics/compute/${login}/plugins > languages > loading patches`)
|
|
console.debug(`metrics/compute/${login}/plugins > languages > commits authoring set to ${JSON.stringify(data.shared["commits.authoring"])}`)
|
|
const patches = [
|
|
...await Promise.allSettled(
|
|
commits
|
|
.flatMap(({payload}) => payload.commits)
|
|
.filter(({author}) => data.shared["commits.authoring"].filter(authoring => author?.email?.toLocaleLowerCase().includes(authoring)||author?.name?.toLocaleLowerCase().includes(authoring)).length)
|
|
.map(commit => commit.url)
|
|
.map(async commit => (await rest.request(commit)).data.files),
|
|
),
|
|
]
|
|
.filter(({status}) => status === "fulfilled")
|
|
.map(({value}) => value)
|
|
.flatMap(files => files.map(file => ({name:imports.paths.basename(file.filename), directory:imports.paths.dirname(file.filename), patch:file.patch ?? "", repo:file.raw_url.match(/(?<=^https:..github.com\/)(?<repo>.*)(?=\/raw)/)?.groups.repo ?? "_"})))
|
|
.map(({name, directory, patch, repo}) => ({name, directory:`${repo.replace(/[/]/g, "@")}/${directory}`, patch:patch.split("\n").filter(line => /^[+]/.test(line)).map(line => line.substring(1)).join("\n")}))
|
|
|
|
//Temporary directory
|
|
const path = imports.paths.join(imports.os.tmpdir(), `${data.user.databaseId}-${tempdir}`)
|
|
console.debug(`metrics/compute/${login}/plugins > languages > creating temp dir ${path} with ${patches.length} files`)
|
|
results.files = patches.length
|
|
|
|
//Process
|
|
try {
|
|
//Save patches in temporary directory matching respective repository and filename
|
|
await imports.fs.rmdir(path, {recursive:true})
|
|
await imports.fs.mkdir(path, {recursive:true})
|
|
await Promise.all(patches.map(async ({name, directory, patch}) => {
|
|
await imports.fs.mkdir(imports.paths.join(path, directory), {recursive:true})
|
|
imports.fs.writeFile(imports.paths.join(path, directory, name), patch)
|
|
}))
|
|
|
|
//Process temporary repositories
|
|
for (const directory of await imports.fs.readdir(path)) {
|
|
//Pull gitattributes if possible
|
|
for (const branch of ["main", "master"]) {
|
|
const repo = directory.replace("@", "/")
|
|
try {
|
|
await imports.fs.writeFile(imports.paths.join(path, directory, ".gitattributes"), await imports.fetch(`https://raw.githubusercontent.com/${repo}/${branch}/.gitattributes`).then(response => response.text()).catch(() => ""))
|
|
console.debug(`metrics/compute/${login}/plugins > languages > successfully fetched .gitattributes for ${repo}`)
|
|
break
|
|
}
|
|
catch {
|
|
console.debug(`metrics/compute/${login}/plugins > languages > cannot load .gitattributes on branch ${branch} for ${repo}`)
|
|
}
|
|
}
|
|
|
|
//Create temporary git repository
|
|
console.debug(`metrics/compute/${login}/plugins > languages > creating temp git repository for ${directory}`)
|
|
const git = await imports.git(imports.paths.join(path, directory))
|
|
await git.init().add(".").addConfig("user.name", data.shared["commits.authoring"]?.[0] ?? login).addConfig("user.email", "<>").commit("linguist").status()
|
|
|
|
//Analyze repository
|
|
await analyze(arguments[0], {results, path:imports.paths.join(path, directory)})
|
|
}
|
|
}
|
|
catch {
|
|
console.debug(`metrics/compute/${login}/plugins > languages > an error occured while processing recently used languages`)
|
|
}
|
|
finally {
|
|
//Cleaning
|
|
console.debug(`metrics/compute/${login}/plugins > languages > cleaning temp dir ${path}`)
|
|
await imports.fs.rmdir(path, {recursive:true})
|
|
}
|
|
return results
|
|
}
|
|
|
|
/**Analyze a single repository */
|
|
async function analyze({login, imports, data}, {results, path}) {
|
|
//Spawn linguist process and map files to languages
|
|
console.debug(`metrics/compute/${login}/plugins > languages > indepth > running linguist`)
|
|
const files = Object.fromEntries(Object.entries(JSON.parse(await imports.run("github-linguist --json", {cwd:path}, {log:false}))).flatMap(([lang, files]) => files.map(file => [file, lang])))
|
|
|
|
//Processing diff
|
|
const per_page = 1
|
|
console.debug(`metrics/compute/${login}/plugins > languages > indepth > checking git log`)
|
|
for (let page = 0; ; page++) {
|
|
try {
|
|
const stdout = await imports.run(`git log ${data.shared["commits.authoring"].map(authoring => `--author="${authoring}"`).join(" ")} --regexp-ignore-case --format="" --patch --max-count=${per_page} --skip=${page*per_page}`, {cwd:path}, {log:false})
|
|
let file = null, lang = null
|
|
if (!stdout.trim().length) {
|
|
console.debug(`metrics/compute/${login}/plugins > languages > indepth > no more commits`)
|
|
break
|
|
}
|
|
console.debug(`metrics/compute/${login}/plugins > languages > indepth > processing commits ${page*per_page} from ${(page+1)*per_page}`)
|
|
for (const line of stdout.split("\n").map(line => line.trim())) {
|
|
//Ignore empty lines or unneeded lines
|
|
if ((!/^[+]/.test(line))||(!line.length))
|
|
continue
|
|
//File marker
|
|
if (/^[+]{3}\sb[/](?<file>[\s\S]+)$/.test(line)) {
|
|
file = line.match(/^[+]{3}\sb[/](?<file>[\s\S]+)$/)?.groups?.file ?? null
|
|
lang = files[file] ?? null
|
|
continue
|
|
}
|
|
//Ignore unkonwn languages
|
|
if (!lang)
|
|
continue
|
|
//Added line marker
|
|
if (/^[+]\s*(?<line>[\s\S]+)$/.test(line)) {
|
|
const size = Buffer.byteLength(line.match(/^[+]\s*(?<line>[\s\S]+)$/)?.groups?.line ?? "", "utf-8")
|
|
results.stats[lang] = (results.stats[lang] ?? 0) + size
|
|
results.lines[lang] = (results.lines[lang] ?? 0) + 1
|
|
results.total += size
|
|
}
|
|
}
|
|
}
|
|
catch {
|
|
console.debug(`metrics/compute/${login}/plugins > languages > indepth > an error occured on page ${page}, skipping...`)
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
//import.meta.main
|
|
if (/languages.analyzers.mjs$/.test(process.argv[1])) {
|
|
(async function() {
|
|
//Parse inputs
|
|
const [_authoring, path] = process.argv.slice(2)
|
|
if ((!_authoring)||(!path)) {
|
|
console.log("Usage is:\n npm run indepth -- <commits authoring> <repository local path>\n\n")
|
|
process.exit(1)
|
|
}
|
|
const {default:setup} = await import("../../app/metrics/setup.mjs")
|
|
const {conf:{metadata}} = await setup({log:false, nosettings:true})
|
|
const {"commits.authoring":authoring} = await metadata.plugins.base.inputs({q:{"commits.authoring":_authoring}, account:"bypass"})
|
|
const data = {shared:{"commits.authoring":authoring}}
|
|
|
|
//Prepare call
|
|
const imports = await import("../../app/metrics/utils.mjs")
|
|
const results = {total:0, lines:{}, stats:{}}
|
|
console.debug = log => /exited with code null/.test(log) ? console.error(log.replace(/^.*--max-count=(?<step>\d+) --skip=(?<start>\d+).*$/, (_, step, start) => `error: skipped commits ${start} from ${Number(start)+Number(step)}`)) : null
|
|
|
|
//Analyze repository
|
|
console.log(`commits authoring | ${authoring}\nrepository path | ${path}\n`)
|
|
await analyze({login:"cli", data, imports}, {results, path})
|
|
console.log(results)
|
|
})()
|
|
} |