//Setup

export default async function({login, q, imports, data, rest, account}, {enabled = false} = {}) {

//Plugin execution

try {

//Check if plugin is enabled and requirements are met

if ((!enabled) || (!q.code))

return null

//Context

let context = {mode: "user"}

if (q.repo) {

console.debug(`metrics/compute/${login}/plugins > code > switched to repository mode`)

const {owner, repo} = data.user.repositories.nodes.map(({name: repo, owner: {login: owner}}) => ({repo, owner})).shift()

context = {...context, mode: "repository", owner, repo}

}

//Load inputs

let {load, days, lines, visibility, languages, skipped} = imports.metadata.plugins.code.inputs({data, q, account})

if (!days)

days = Infinity

skipped.push(...data.shared["repositories.skipped"])

const pages = Math.ceil(load / 100)

//Get user recent code

console.debug(`metrics/compute/${login}/plugins > code > querying api`)

const events = []

try {

for (let page = 1; page <= pages; page++) {

console.debug(`metrics/compute/${login}/plugins > code > loading page ${page}/${pages}`)

events.push(

...[

...await Promise.all([

...(context.mode === "repository"

? await rest.activity.listRepoEvents({owner: context.owner, repo: context.repo})

: await rest.activity.listEventsForAuthenticatedUser({username: login, per_page: 100, page})).data

.filter(({type}) => type === "PushEvent")

.filter(({actor}) => account === "organization" ? true : actor.login?.toLocaleLowerCase() === login.toLocaleLowerCase())

.filter(({repo: {name: repo}}) => !((skipped.includes(repo.split("/").pop())) || (skipped.includes(repo))))

.filter(event => visibility === "public" ? event.public : true)

.filter(({created_at}) => Number.isFinite(days) ? new Date(created_at) > new Date(Date.now() - days * 24 * 60 * 60 * 1000) : true)

.flatMap(({created_at: created, payload}) => Promise.all(payload.commits.map(async commit => ({created: new Date(created), ...(await rest.request(commit.url)).data})))),

]),

]

.flat()

.filter(({parents}) => parents.length <= 1)

.filter(({author}) => data.shared["commits.authoring"].filter(authoring => author?.login?.toLocaleLowerCase().includes(authoring) || author?.email?.toLocaleLowerCase().includes(authoring) || author?.name?.toLocaleLowerCase().includes(authoring)).length),

)

}

}

catch {

console.debug(`metrics/compute/${login}/plugins > code > no more page to load`)

}

console.debug(`metrics/compute/${login}/plugins > code > ${events.length} events loaded`)

//Search for a random snippet

let files = events

.flatMap(({created, sha, commit: {message, url}, files}) => files.map(({filename, status, additions, deletions, patch}) => ({created, sha, message, filename, status, additions, deletions, patch, repo: url.match(/repos[/](?<repo>[\s\S]+)[/]git[/]commits/)?.groups?.repo})))

.filter(({patch}) => (patch ? (patch.match(/\n/mg)?.length ?? 1) : Infinity) < lines)

for (const file of files)

file.language = await imports.language({...file, prefix: login}).catch(() => "unknown")

files = files.filter(({language}) => (!languages.length) || (languages.includes(language.toLocaleLowerCase())))

const snippet = files[Math.floor(Math.random() * files.length)] ?? null

if (snippet) {

//Trim common indent from content and change line feed

if (!snippet.patch.split("\n").shift().endsWith("@@"))

snippet.patch = snippet.patch.replace(/^(?<coord>@@.*?@@).*/, "$<coord>")

const indent = Math.min(...(snippet.patch.match(/^.\s+/mg) ?? [0]).map(line => line.length - 1)) || 0

const content = imports.htmlescape(snippet.patch.replace(new RegExp(`^(.)[\\t ]{0,${indent}}`, "mg"), "$1"))

//Format patch

snippet.patch = imports.htmlunescape(await imports.highlight(content, "diff"))

.trim()

.replace(/\r?\n/g, "<br/>")

.replace(/<span class="token prefix unchanged"> <\/span>/g, '<span class="token prefix unchanged">·</span>')

}

//Results

return {snippet}

}

//Handle errors

catch (error) {

throw {error: {message: "An error occured", instance: error}}

}

}