Package Exports

@mushi-mushi/adapters
@mushi-mushi/adapters/bugsnag
@mushi-mushi/adapters/cloudwatch
@mushi-mushi/adapters/crashlytics
@mushi-mushi/adapters/datadog
@mushi-mushi/adapters/firebase-analytics
@mushi-mushi/adapters/grafana-loki
@mushi-mushi/adapters/honeycomb
@mushi-mushi/adapters/new-relic
@mushi-mushi/adapters/opsgenie
@mushi-mushi/adapters/rollbar
@mushi-mushi/adapters/sentry

Readme

`@mushi-mushi/adapters`

Inbound webhook translators that turn third-party observability events into Mushi Mushi reports. Use these when you want production monitors (Sentry, Datadog, CloudWatch, …) and crash reports (Bugsnag, Rollbar, Crashlytics) to land in the same triage + fix pipeline as your user-filed bugs.

Install

npm i @mushi-mushi/adapters

Supported sources

Source	Translator	Webhook handler
Sentry	`translateSentry`	`createSentryAdapter`
Bugsnag	`translateBugsnag`	`createBugsnagAdapter`
Rollbar	`translateRollbar`	`createRollbarAdapter`
Crashlytics (Firebase)	`translateCrashlytics`	`createCrashlyticsAdapter`
Firebase Analytics	`translateFirebaseAnalytics`	`createFirebaseAnalyticsAdapter`
AWS CloudWatch (SNS)	`translateCloudWatch`	`createCloudWatchAdapter`
Opsgenie	`translateOpsGenie`	`createOpsGenieAdapter`
Datadog	`translateDatadog`	`createDatadogWebhookHandler`
New Relic	`translateNewRelic`	`createNewRelicWebhookHandler`
Honeycomb	`translateHoneycomb`	`createHoneycombWebhookHandler`
Grafana / Loki (AM)	`translateGrafanaLoki`	`createGrafanaLokiWebhookHandler`

Every translator outputs MushiCaptureEventInput (from @mushi-mushi/core) so you can route the result to any sink — the hosted Mushi API, a queue, a local database, a fan-out of several. Subpath imports are supported, e.g. @mushi-mushi/adapters/cloudwatch.

Quick start — Datadog → Hono

import { Hono } from 'hono'
import { createDatadogWebhookHandler } from '@mushi-mushi/adapters'
import { MushiNodeClient } from '@mushi-mushi/node'

const mushi = new MushiNodeClient({
  apiKey: process.env.MUSHI_API_KEY!,
  projectId: process.env.MUSHI_PROJECT_ID!,
})

const handler = createDatadogWebhookHandler({
  secret: process.env.DATADOG_WEBHOOK_SECRET!,
  sink: async (event) => {
    await mushi.captureReport({
      description: event.description,
      severity: event.severity,
      component: event.component,
      metadata: { ...event.metadata, source: event.source, tags: event.tags },
    })
  },
})

const app = new Hono()
app.post('/webhooks/datadog', async (c) => {
  const raw = await c.req.text()
  const res = await handler({
    rawBody: raw,
    headers: Object.fromEntries(c.req.raw.headers),
  })
  return c.json(res.body ?? {}, res.status)
})

Severity mapping

Each adapter maps the source's native severity onto Mushi's four-level scale:

Mushi	Datadog	New Relic	Honeycomb	Grafana/AM
`critical`	P1	critical	critical	critical
`high`	P2	high	warning	high
`medium`	P3	medium	info	warning
`low`	P4–P5	low	—	info

Authentication

Each adapter uses the strongest auth its upstream supports:

Adapter	Method	Header
Sentry	shared secret (timing-safe)	`sentry-hook-secret`
Bugsnag	HMAC-SHA256 (hex)	`X-Bugsnag-Signature`
Rollbar	shared token (timing-safe)	`X-Rollbar-Access-Token`
Crashlytics	Firebase ID Token JWT (`aud`)	`X-Firebase-ID-Token`
Firebase Analytics	Google OIDC bearer (`aud`)	`Authorization: Bearer …`
CloudWatch (SNS)	RSA-SHA1 / SHA256 cert verify	`x-amz-sns-message-type`
Opsgenie	HMAC-SHA256 (base64)	`X-OG-Signature`
Datadog	shared secret (timing-safe)	`x-datadog-secret-token`
New Relic	HMAC-SHA256 (hex)	`X-NewRelic-Signature`
Honeycomb	HMAC-SHA256 (`sha256=…`)	`X-Honeycomb-Signature`
Grafana / Loki (AM)	shared token (timing-safe)	`X-Grafana-Token`

Tests under src/__tests__/ cover both the happy-path and forged-signature cases (89 tests total).

License

MIT