//Setup export default async function ({login, data, graphql, rest, q, queries, imports, account}, {enabled = false} = {}) { //Plugin execution try { //Check if plugin is enabled and requirements are met if ((!enabled)||(!q.people)) return null //Context let context = { mode:"user", types:account === "organization" ? ["sponsorshipsAsMaintainer", "sponsorshipsAsSponsor", "thanks"] : ["followers", "following", "sponsorshipsAsMaintainer", "sponsorshipsAsSponsor", "thanks"], default:"followers, following", alias:{followed:"following", sponsors:"sponsorshipsAsMaintainer", sponsored:"sponsorshipsAsSponsor", sponsoring:"sponsorshipsAsSponsor"}, sponsorships:{sponsorshipsAsMaintainer:"sponsorEntity", sponsorshipsAsSponsor:"sponsorable"} } if (q.repo) { console.debug(`metrics/compute/${login}/plugins > people > switched to repository mode`) const {owner, repo} = data.user.repositories.nodes.map(({name:repo, owner:{login:owner}}) => ({repo, owner})).shift() context = {...context, mode:"repository", types:["contributors", "stargazers", "watchers", "sponsorshipsAsMaintainer", "thanks"], default:"stargazers, watchers", owner, repo} } //Parameters override let {"people.limit":limit = 28, "people.types":types = context.default, "people.size":size = 28, "people.identicons":identicons = false, "people.thanks":thanks = []} = q //Limit limit = Math.max(1, limit) //Repositories projects types = [...new Set(decodeURIComponent(types ?? "").split(",").map(type => type.trim()).map(type => (context.alias[type] ?? type)).filter(type => context.types.includes(type)) ?? [])] //Special thanks thanks = decodeURIComponent(thanks ?? "").split(",").map(user => user.trim()).filter(user => user) //Retrieve followers from graphql api console.debug(`metrics/compute/${login}/plugins > people > querying api`) const result = Object.fromEntries(types.map(type => [type, []])) for (const type of types) { //Iterate through people console.debug(`metrics/compute/${login}/plugins > people > retrieving ${type}`) //Rest if (type === "contributors") { const {owner, repo} = context const {data:nodes} = await rest.repos.listContributors({owner, repo}) result[type].push(...nodes.map(({login, avatar_url}) => ({login, avatarUrl:avatar_url}))) } else if (type === "thanks") { const nodes = await Promise.all(thanks.map(async username => (await rest.users.getByUsername({username})).data)) result[type].push(...nodes.map(({login, avatar_url}) => ({login, avatarUrl:avatar_url}))) } //GraphQL else { let cursor = null let pushed = 0 do { console.debug(`metrics/compute/${login}/plugins > people > retrieving ${type} after ${cursor}`) const {[type]:{edges}} = ( type in context.sponsorships ? (await graphql(queries["people.sponsors"]({login:context.owner ?? login, type, size, after:cursor ? `after: "${cursor}"` : "", target:context.sponsorships[type], account})))[account] : context.mode === "repository" ? (await graphql(queries["people.repository"]({login:context.owner, repository:context.repo, type, size, after:cursor ? `after: "${cursor}"` : "", account})))[account].repository : (await graphql(queries.people({login, type, size, after:cursor ? `after: "${cursor}"` : ""}))).user ) cursor = edges?.[edges?.length-1]?.cursor result[type].push(...edges.map(({node}) => node[context.sponsorships[type]] ?? node)) pushed = edges.length } while ((pushed)&&(cursor)&&(result[type].length <= limit)) } //Limit people if (limit > 0) { console.debug(`metrics/compute/${login}/plugins > people > keeping only ${limit} ${type}`) result[type].splice(limit) } //Hide real avator with identicons if enabled if (identicons) { console.debug(`metrics/compute/${login}/plugins > people > using identicons`) result[type].map(user => user.avatarUrl = `https://github.com/identicons/${user.login}.png`) } //Convert avatars to base64 console.debug(`metrics/compute/${login}/plugins > people > loading avatars`) await Promise.all(result[type].map(async user => user.avatar = user.avatarUrl ? await imports.imgb64(user.avatarUrl) : "iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAADUlEQVR42mOcOnfpfwAGfgLYttYINwAAAABJRU5ErkJggg==")) } //Results return {types, size, ...result} } //Handle errors catch (error) { throw {error:{message:"An error occured", instance:error}} } }