//Setup export default async function({login, q, imports, graphql, queries, data, account}, {enabled = false, extras = false} = {}) { //Plugin execution try { //Check if plugin is enabled and requirements are met if ((!q.discussions) || (!imports.metadata.plugins.discussions.enabled(enabled, {extras}))) return null //Load inputs const {categories: _categories, "categories.limit": _categories_limit} = imports.metadata.plugins.discussions.inputs({data, account, q}) const discussions = {categories: {}, upvotes: {discussions: 0, comments: 0}} discussions.display = {categories: _categories ? {limit: _categories_limit || Infinity} : null} //Fetch general statistics const stats = Object.fromEntries(Object.entries((await graphql(queries.discussions.statistics({login}))).user).map(([key, value]) => [key, value.totalCount])) Object.assign(discussions, stats) //Load started discussions { const fetched = [] const categories = {} let cursor = null let pushed = 0 do { console.debug(`metrics/compute/${login}/discussions > retrieving discussions after ${cursor}`) const {user: {repositoryDiscussions: {edges = [], nodes = []} = {}}} = await graphql(queries.discussions.categories({login, after: cursor ? `after: "${cursor}"` : ""})) cursor = edges?.[edges?.length - 1]?.cursor fetched.push(...nodes) pushed = nodes.length console.debug(`metrics/compute/${login}/discussions > retrieved ${pushed} discussions after ${cursor}`) } while ((pushed) && (cursor)) //Compute upvotes fetched.map(({upvoteCount}) => discussions.upvotes.discussions += upvoteCount) //Compute favorite category for (const category of [...fetched.map(({category: {emoji, name}}) => `${imports.emoji.get(emoji) ?? emoji} ${name}`)]) categories[category] = (categories[category] ?? 0) + 1 const categoryEntries = Object.entries(categories).sort((a, b) => b[1] - a[1]) discussions.categories.stats = Object.fromEntries(categoryEntries) discussions.categories.favorite = categoryEntries[0]?.[0] ?? null } //Load comments { const fetched = [] let cursor = null let pushed = 0 do { console.debug(`metrics/compute/${login}/discussions > retrieving comments after ${cursor}`) const {user: {repositoryDiscussionComments: {edges = [], nodes = []} = {}}} = await graphql(queries.discussions.comments({login, after: cursor ? `after: "${cursor}"` : ""})) cursor = edges?.[edges?.length - 1]?.cursor fetched.push(...nodes) pushed = nodes.length console.debug(`metrics/compute/${login}/discussions > retrieved ${pushed} comments after ${cursor}`) } while ((pushed) && (cursor)) //Compute upvotes fetched.map(({upvoteCount}) => discussions.upvotes.comments += upvoteCount) } //Results return discussions } //Handle errors catch (error) { throw imports.format.error(error) } }