New Mention - Pipedream

import common from "../common/common-polling.mjs"; export default { ...common, key: "github-new-mention", name: "New Mention", description: "Emit new event when you are @mentioned in a new commit, comment, issue or pull request. [See the documentation](https://docs.github.com/en/rest/activity/notifications?apiVersion=2022-11-28#list-notifications-for-the-authenticated-user)", version: "0.2.1", type: "source", dedupe: "unique", methods: { ...common.methods, _getUserLogin() { return this.db.get("userLogin"); }, _setUserLogin(userLogin) { this.db.set("userLogin", userLogin); }, _getLastDate() { return this.db.get("lastDate"); }, _setLastDate(value) { this.db.set("lastDate", value); }, async retrieveUserLogin() { let login = this._getUserLogin(); if (!login) { const user = await this.github.getAuthenticatedUser(); login = user.login; this._setUserLogin(login); } return login; }, async getItems() { const date = this._getLastDate(); this._setLastDate(new Date().toISOString()); return this.github.getFilteredNotifications({ reason: "mention", data: { participating: true, all: true, ...(date && { since: date, }), }, }); }, async getAndProcessData(maxEmits = 0) { const login = await this.retrieveUserLogin(); const savedIds = this._getSavedIds(); const items = await this.getItems(); const urlData = new Map(); let amountEmits = 0; const promises = items?.map((item) => (async () => { const url = item?.subject?.url; if (!urlData.has(url)) { urlData.set(url, await this.github.getFromUrl({ url: item.subject.url, })); } const subject = urlData.get(url); const commentsUrl = subject.comments_url; if (!commentsUrl) return; if (!urlData.has(commentsUrl)) { urlData.set(commentsUrl, await this.github.getFromUrl({ url: commentsUrl, })); } const comments = urlData.get(commentsUrl); comments?.filter?.((comment) => { return !savedIds.includes(comment.id) && comment.body?.includes(`@${login}`); }).forEach((comment) => { if (!maxEmits || (amountEmits < maxEmits)) { this.$emit(comment, { id: comment.id, summary: `New mention: ${comment.id}`, ts: Date.parse(comment.created_at), }); amountEmits++; } savedIds.push(comment.id); }); })()); if (promises?.length) await Promise.allSettled(promises); this._setSavedIds(savedIds); }, }, };

Label	Prop	Type	Description
GitHub	`github`	`app`	This component uses the GitHub app.
	`timer`	`$.interface.timer`
N/A	`db`	`$.service.db`	This component uses `$.service.db` to maintain state between executions.

Label

Prop

Type

Description

GitHub

github

app

This component uses the GitHub app.

timer

$.interface.timer

N/A

db

$.service.db

This component uses $.service.db to maintain state between executions.

More Ways to Use GitHub#

Triggers#

New Branch Created from the GitHub API

Emit new event when a branch is created.

Try it

New Card in Column (Classic Projects) from the GitHub API

Emit new event when a (classic) project card is created or moved to a specific column. For Projects V2 use New Issue with Status trigger. More information here

Try it

New Collaborator from the GitHub API

Emit new event when a collaborator is added

Try it

New Commit from the GitHub API

Emit new event when commits are pushed to a branch

Try it

New Commit Comment from the GitHub API

Emit new event when a commit comment is created

Try it