n8nを使ったイシュー管理フローの作成

git clone --depth 1 https://github.com/mattermost/mattermost-plugin-starter-template mattermost-plugin

{
    "id": "please input your plugin id",
    "name": "please input your plugin name",
    "description": "please input your plugin description",
    "homepage_url": "https://github.com/mattermost/mattermost-plugin-starter-template",
    "support_url": "https://github.com/mattermost/mattermost-plugin-starter-template/issues",
    "icon_path": "assets/starter-template-icon.svg",
    "min_server_version": "6.2.1",
    "server": {
        "executables": {
            "linux-amd64": "server/dist/plugin-linux-amd64",
            "linux-arm64": "server/dist/plugin-linux-arm64",
            "darwin-amd64": "server/dist/plugin-darwin-amd64",
            "darwin-arm64": "server/dist/plugin-darwin-arm64",
            "windows-amd64": "server/dist/plugin-windows-amd64.exe"
        }
    },
    "webapp": {
        "bundle_path": "webapp/dist/main.js"
    },
    "settings_schema": {
        "header": "Outgoing webhook plugin triggered by emoji reactions.",
        "footer": "",
        "settings": [
            {
                "key": "WebhookList",
                "display_name": "Webhook list",
                "type": "longtext",
                "help_text": "",
                "hosting": "on-prem"
            }
        ]
    }
}

package main
 
import (
	"bytes"
	"fmt"
	"log/slog"
	"net/http"
	"regexp"
	"sync"
 
	"github.com/mattermost/mattermost/server/public/model"
	"github.com/mattermost/mattermost/server/public/plugin"
	"github.com/mattermost/mattermost/server/public/pluginapi"
)
 
type Webhook struct {
	Emoji     string `json:"emoji"`
	Endpoint  string `json:"endpoint"`
	AuthToken string `json:"auth_token"`
}
 
type Plugin struct {
	plugin.MattermostPlugin
	client *pluginapi.Client
 
	configurationLock sync.RWMutex
 
	configuration *configuration
 
	webhookMap map[string]Webhook
}
 
func (p *Plugin) OnActivate() error {
	if p.client == nil {
		p.client = pluginapi.NewClient(p.API, p.Driver)
	}
 
	return nil
}
 
func (p *Plugin) ReactionHasBeenAdded(c *plugin.Context, reaction *model.Reaction) {
	post, appErr := p.client.Post.GetPost(reaction.PostId)
 
	if appErr != nil {
		return
	}
 
	re := regexp.MustCompile(`Issue ID: (.*)`)
	match := re.FindStringSubmatch(post.Message)
 
	var issueID string
	if len(match) > 1 {
		issueID = match[1]
	} else {
		return
	}
 
	webhook, ok := p.webhookMap[reaction.EmojiName]
	if !ok {
		slog.Info("Webhook not found", "info", reaction.EmojiName)
		return
	}
 
	url := webhook.Endpoint
	data := []byte(fmt.Sprintf(`{"issue_id": "%s"}`, issueID))
 
	req, err := http.NewRequest("POST", url, bytes.NewBuffer(data))
	if err != nil {
		slog.Error("Failed to create Webhook request", "error", err)
		return
	}
 
	req.Header.Set("Authorization", "Bearer "+webhook.AuthToken)
	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Accept", "application/json")
 
	client := &http.Client{}
	resp, err := client.Do(req)
	if err != nil {
		slog.Error("Failed to request Webhook", "error", err)
		return
	}
 
	defer resp.Body.Close()
 
	if resp.StatusCode != 200 {
		slog.Info("Webhook request was not successful", "info", resp.StatusCode)
	}
}
 
func (p *Plugin) ServeHTTP(c *plugin.Context, w http.ResponseWriter, r *http.Request) {
	fmt.Fprint(w, "Hello, world!")
}

func (p *Plugin) OnConfigurationChange() error {
	if p.client == nil {
		p.client = pluginapi.NewClient(p.API, p.Driver)
	}
 
	var configuration = new(configuration)
 
	// Load the public configuration fields from the Mattermost server configuration.
	if err := p.API.LoadPluginConfiguration(configuration); err != nil {
		return errors.Wrap(err, "failed to load plugin configuration")
	}
 
	var webhooks []Webhook
 
	bytes := []byte(configuration.WebhookList)
	err := json.Unmarshal(bytes, &webhooks)
	if err != nil {
		slog.Error("WebhookList misconfiguration", "error", err.Error())
	}
 
	p.webhookMap = make(map[string]Webhook)
	for _, webhook := range webhooks {
		p.webhookMap[webhook.Emoji] = webhook
	}
 
	p.setConfiguration(configuration)
 
	return nil
}

$ make
 
./build/bin/manifest check
./build/bin/manifest apply
 
 
plugin built at: dist/dev.86world.emoji.webhook-0.0.0+4e15acf.tar.gz

[{"emoji": "github", "endpoint": "エンドポイントのURL", "auth_token": "認証用トークン"}]

SELECT 
  iss.id, 
  iss.level, 
  iss.metadata, 
  iss.title, 
  iss.last_seen, 
  issev.data 
FROM 
  issue_events_issue iss 
  INNER JOIN issue_events_issueevent issev ON iss.id = issev.issue_id 
WHERE 
  iss.id = $1 
  AND iss.is_deleted = false 
  AND iss.status = 0 
ORDER BY 
  issev.received DESC 
LIMIT 
  1

for (const item of $input.all()) {
  const type = item.json.data.exception[0].type
  const value = item.json.data.exception[0].value
  const frames = item.json.data.exception[0].stacktrace.frames.reverse()
  let stacktrace = type + ':' + value + '\n'
  for (const frame of frames) {
    stacktrace += 'at ' + frame.function + '(' + frame.filename + ':' + frame.lineno + ':' + frame.colno + ')\n'
  }
  item.json.stacktrace = stacktrace
}
 
return $input.all()

# \d issue_tickets
                                       Table "public.issue_tickets"
   Column    |           Type           | Collation | Nullable |                  Default
-------------+--------------------------+-----------+----------+-------------------------------------------
 id          | integer                  |           | not null | nextval('issue_tickets_id_seq'::regclass)
 issue_id    | bigint                   |           | not null |
 gh_issue_id | character varying        |           | not null |
 url         | character varying        |           | not null |
 created_at  | timestamp with time zone |           |          | now()
 updated_at  | timestamp with time zone |           |          | now()

\d gh_issues
                               Table "public.gh_issues"
          Column          |           Type           | Collation | Nullable | Default
--------------------------+--------------------------+-----------+----------+---------
 id                       | bigint                   |           |          |
 url                      | character varying        |           |          |
 body                     | character varying        |           |          |
 user                     | jsonb                    |           |          |
 draft                    | boolean                  |           |          |
 state                    | character varying        |           |          |
 title                    | character varying        |           |          |
 labels                   | jsonb                    |           |          |
 locked                   | boolean                  |           |          |
 number                   | bigint                   |           |          |
 node_id                  | character varying        |           |          |
 user_id                  | bigint                   |           |          |
 assignee                 | jsonb                    |           |          |
 comments                 | bigint                   |           |          |
 html_url                 | character varying        |           |          |
 assignees                | jsonb                    |           |          |
 closed_at                | timestamp with time zone |           |          |
 milestone                | jsonb                    |           |          |
 reactions                | jsonb                    |           |          |
 created_at               | timestamp with time zone |           |          |
 events_url               | character varying        |           |          |
 labels_url               | character varying        |           |          |
 repository               | character varying        |           |          |
 updated_at               | timestamp with time zone |           |          |
 comments_url             | character varying        |           |          |
 pull_request             | jsonb                    |           |          |
 state_reason             | character varying        |           |          |
 timeline_url             | character varying        |           |          |
 repository_url           | character varying        |           |          |
 active_lock_reason       | character varying        |           |          |
 author_association       | character varying        |           |          |
 performed_via_github_app | jsonb                    |           |          |
 _airbyte_raw_id          | character varying(36)    |           | not null |
 _airbyte_extracted_at    | timestamp with time zone |           | not null |
 _airbyte_meta            | jsonb                    |           | not null |

const open = [], noAssignee = []
 
for (const item of $input.all()) {
  open.push(item.json.html_url)
  
  if (item.json.assignee === null) {
    noAssignee.push(item.json.html_url)
  }
}
 
return { open, noAssignee }

Currently open issues are as follows:
{{ $json.open.map(i => '- ' + i).join('\n') }}

Issues with no assignees in the above list are as follows:
{{ $json.noAssignee.map(i => '- ' + i).join('\n') }}