n8nを使ったエラー通知フローの作成

import { Hono } from 'hono'
import { sentry } from '@hono/sentry'
 
type Bindings = {
  SENTRY_DSN: string
  SENTRY_RELEASE: string
  CUSTOM_PORT: string
}
 
const app = new Hono<{ Bindings: Bindings }>()
 
app.use('*', async (c, next) => {
  await sentry({
    dsn: c.env.SENTRY_DSN,
    release: c.env.SENTRY_RELEASE,
    transportOptions: {
      headers: {
        "X-CUSTOM-PORT": c.env.CUSTOM_PORT
      }
    }
  }).call(null, c, next)
})
 
app.get('/:id{[0-9]+}', (c) => {
  const { id } = c.req.param()
  switch (id) {
    case '1':
    case '2':
    case '3':
    case '4':
    case '5':
      c.get('sentry').captureException(new Error(id), { captureContext: { level: 'info' } })
      break;
    case '6':
    case '7':
    case '8':
    case '9':
      try {
        JSON.parse('not json')
      } catch (e) {
        c.get('sentry').captureException(e, { captureContext: { level: 'warning' } })
      }
      break;
    default:
      throw new RangeError(id)
  }
  return c.text('Hello World!')
})
 
app.onError((e, c) => {
  c.get('sentry').captureException(e, { captureContext: { level: 'error' } })
  return c.text('Internal Server Error', 500)
})
 
export default app

RangeError:10
 at <anonymous> (index.js:21:29258)
 at o (index.js:21:12992)
 at <anonymous> (index.js:21:13000)
 at <anonymous> (index.js:21:8979)
 at <anonymous> (index.js:21:28885)
 at o (index.js:21:12992)
 at <anonymous> (index.js:21:12734)
 at <anonymous> (index.js:21:20348)
 at _s.dispatch (index.js:21:20526)
 at _s.fetch (index.js:21:20549)

sentry-cli --url <GlitchTipのURL> login

[auth]
token=<保存されたトークン>

[defaults]
url=<GlitchTipのURL>

wrangler deploy --dry-run --outdir=dist src/index.ts
 
sentry-cli releases new <リリースのバージョン> --finalize --org <GlitchTipで作成した組織のslug> --project <GlitchTipで作成したプロジェクトのslug> && \
sentry-cli releases files <リリースのバージョン> upload-sourcemaps ./dist --org <GlitchTipで作成した組織のslug> --project <GlitchTipで作成したプロジェクトのslug>

RangeError:10
 at <anonymous> (dist/../src/index.ts:47:13)
 at dispatch (dist/../node_modules/hono/dist/compose.js:29:23)
 at <anonymous> (dist/../node_modules/hono/dist/compose.js:30:20)
 at <anonymous> (dist/../node_modules/@hono/sentry/dist/index.js:37:15)
 at <anonymous> (dist/../src/index.ts:21:6)
 at dispatch (dist/../node_modules/hono/dist/compose.js:29:23)
 at <anonymous> (dist/../node_modules/hono/dist/compose.js:6:12)
 at <anonymous> (dist/../node_modules/hono/dist/hono-base.js:188:31)
 at Hono2.dispatch (dist/../node_modules/hono/dist/hono-base.js:198:5)
 at Hono2.fetch (dist/../node_modules/hono/dist/hono-base.js:201:17)

SELECT
    iss.id,
    iss.level,
    iss.metadata,
    iss.title,
    iss.type,
    iss.last_seen,
    pj.id AS project_id,
    pj.name AS project_name,
    iss.count AS count
FROM
    issue_events_issue AS iss
    INNER JOIN projects_project AS pj ON iss.project_id = pj.id
WHERE
    iss.is_deleted = false
    AND iss.status = 0
    AND iss.last_seen + (interval '1.5 minute') > $1::TIMESTAMP WITH TIME ZONE

# \d issues
                                        Table "public.issues"
    Column    |           Type           | Collation | Nullable |              Default
--------------+--------------------------+-----------+----------+------------------------------------
 id           | integer                  |           | not null | nextval('issues_id_seq'::regclass)
 issue_id     | bigint                   |           | not null |
 level        | character varying        |           | not null |
 metadata     | jsonb                    |           | not null |
 title        | character varying        |           | not null |
 type         | smallint                 |           | not null |
 last_seen    | timestamp with time zone |           | not null |
 project_id   | bigint                   |           | not null |
 project_name | character varying        |           | not null |
 count        | integer                  |           | not null |
 created_at   | timestamp with time zone |           |          | now()

const levels = ['debug', 'info', 'warning', 'error', 'fatal']
 
for (const item of $input.all()) {
  const level = parseInt(item.json.level)
  item.json.level_label = levels[level - 1]
}
 
return $input.all()

SELECT
    COUNT(*) AS count
FROM
    issue_events_issueevent
WHERE
    issue_id = $1
    AND received + (interval '1.5 minute') > $2::TIMESTAMP WITH TIME ZONE

INSERT INTO issues (issue_id, level, metadata, title, type, last_seen, project_id, project_name, count) 
VALUES ($1, $2, $3, $4, $5, $6::TIMESTAMP WITH TIME ZONE, $7, $8, $9)

SELECT
    COUNT(*) AS count
FROM
    issues
WHERE
    issue_id = $1
    AND last_seen BETWEEN $2::TIMESTAMP WITH TIME ZONE - (interval '1 hour')
    AND $2::TIMESTAMP WITH TIME ZONE

The following error has occurred.

>Title: {{ $('前出Codeノードの名前').item.json.title }}
>Project: {{ $('前出Codeノードの名前').item.json.project_name }}
>Level: {{ $('前出Codeノードの名前').item.json.level_label }}
>Occurred at: {{ $('前出Codeノードの名前').item.json.last_seen }}
>File: {{ $('前出Codeノードの名前').item.json.metadata.filename }}

CREATE VIEW last_30days_issue_total
AS
SELECT 
  cal.last_seen::DATE AS date, 
  cal.level, 
  COALESCE(issue_count.total, 0) AS total 
FROM 
  (
    SELECT 
      DATE_TRUNC('day', last_seen) AS last_seen, 
      level, 
      SUM(count) AS total 
    FROM 
      (
        SELECT 
          * 
        FROM 
          issues 
        WHERE 
          last_seen >= DATE_TRUNC('DAY', now()) - INTERVAL '6 DAYS' 
          AND last_seen < DATE_TRUNC('DAY', now()) + INTERVAL '30 DAYS'
      ) AS wk_issue 
    GROUP BY 
      DATE_TRUNC('day', last_seen), 
      level
  ) AS issue_count 
  RIGHT OUTER JOIN (
    SELECT 
      g.day AS last_seen, 
      level, 
      0 AS count 
    FROM 
      GENERATE_SERIES(
        DATE_TRUNC('DAY', now()) - INTERVAL '30 DAYS', 
        DATE_TRUNC('DAY', now()), 
        '1 DAYS'
      ) AS g(day) CROSS 
      JOIN (
        SELECT 
          * 
        FROM 
          (
            VALUES 
              ('error'), 
              ('warning')
          ) AS t(level)
      )
  ) AS cal ON cal.last_seen = issue_count.last_seen 
  AND cal.level = issue_count.level 
ORDER BY 
  date

SELECT
    date,
    total
FROM
    last_30days_issue_total
WHERE
	date >= DATE_TRUNC('DAY', now()) - INTERVAL '1 DAYS'
AND
	level = 'error'

SELECT
    date,
    total
FROM
    last_30days_issue_total
WHERE
	date >= DATE_TRUNC('DAY', now()) - INTERVAL '1 DAYS'
AND
	level = 'warning'

SELECT 
  to_char(cal.last_seen, 'HH24:MI') AS last_seen, 
  cal.level, 
  COALESCE(issue_count.count, null) AS count 
FROM 
  (
    SELECT 
      DATE_TRUNC('HOUR', last_seen) AS last_seen, 
      level, 
      count 
    FROM 
      issues 
    WHERE
      last_seen >= DATE_TRUNC('DAY', now())
  ) AS issue_count 
  RIGHT OUTER JOIN (
    SELECT 
      DATE_TRUNC('HOUR', g.hour) AS last_seen, 
      level, 
      0 AS count 
    FROM 
      GENERATE_SERIES(
        DATE_TRUNC('DAY', now()), 
        DATE_TRUNC('DAY', now()) + INTERVAL '23 HOURS', 
        '1 HOURS'
      ) AS g(hour) CROSS 
      JOIN (
        SELECT 
          * 
        FROM 
          (
            VALUES 
              ('error'), 
              ('warning')
          ) AS t(level)
      )
  ) AS cal ON cal.last_seen = issue_count.last_seen 
  AND cal.level = issue_count.level 
ORDER BY 
  last_seen

SELECT 
  ROW_NUMBER() OVER(
    ORDER BY 
      count DESC
  ) AS no, 
  issue_id,
  level, 
  title, 
  count 
FROM 
  (
    SELECT 
      issue_id, 
      level, 
      title, 
      SUM(count) AS count 
    FROM 
      issues 
    WHERE 
      last_seen >= DATE_TRUNC('DAY', now()) 
    GROUP BY 
      issue_id, 
      level, 
      title 
    ORDER BY 
      count DESC 
    LIMIT 
      5
  )

SELECT
    *
FROM
    last_30days_issue_total
WHERE
	date >= DATE_TRUNC('DAY', now()) - INTERVAL '6 DAYS'