[Integration] Typescript Node

packages/delivery-node/package.json

@@ -1,7 +1,15 @@
 {
   "name": "@bugsnag/delivery-node",
   "version": "8.4.0",
-  "main": "delivery.js",
+  "main": "dist/delivery.js",
+  "types": "dist/types/delivery.d.ts",
+  "exports": {
+    ".": {
+      "types": "./dist/types/delivery.d.ts",
+      "default": "./dist/delivery.js",
+      "import": "./dist/delivery.mjs"
+    }
+  },
   "description": "@bugsnag/node delivery mechanism",
   "homepage": "https://www.bugsnag.com/",
   "repository": {
@@ -12,10 +20,16 @@
     "access": "public"
   },
   "files": [
-    "*.js"
+    "dist"
   ],
   "author": "Bugsnag",
   "license": "MIT",
+  "scripts": {
+    "build": "npm run build:npm",
+    "build:npm": "rollup --config rollup.config.npm.mjs",
+    "clean": "rm -rf dist/*",
+    "test:types": "tsc -p tsconfig.json"
+  },
   "devDependencies": {
     "@bugsnag/core": "^8.4.0"
   },

packages/delivery-node/rollup.config.npm.mjs

@@ -0,0 +1,6 @@
+import createRollupConfig from "../../.rollup/index.mjs"
+
+export default createRollupConfig({
+    input: "src/delivery.ts",
+    external: ['http', 'https', 'url'],
+})

packages/delivery-node/src/delivery.ts

@@ -0,0 +1,79 @@
+import type { Client, Config, Delivery } from '@bugsnag/core'
+import * as jsonPayload from '@bugsnag/json-payload'
+import request from './request'
+import http from 'http'
+
+interface PluginConfig extends Config {
+  agent?: http.Agent
+}
+
+interface InternalClient extends Client {
+  _config: Required<PluginConfig>
+}
+
+const delivery = (client: Client): Delivery => ({
+  sendEvent: (event, cb = () => {}) => {
+    const internalClient = client as InternalClient
+    const body = jsonPayload.event(event, internalClient._config.redactedKeys)
+
+    const _cb = (err: Error | null) => {
+      if (err) internalClient._logger.error(`Event failed to send…\n${(err && err.stack) ? err.stack : err}`, err)
+      if (body.length > 10e5) {
+        internalClient._logger.warn(`Event oversized (${(body.length / 10e5).toFixed(2)} MB)`)
+      }
+      cb(err)
+    }
+
+    if (internalClient._config.endpoints.notify === null) {
+      const err = new Error('Event not sent due to incomplete endpoint configuration')
+      return _cb(err)
+    }
+
+    try {
+      request({
+        url: internalClient._config.endpoints.notify,
+        headers: {
+          'Content-Type': 'application/json',
+          'Bugsnag-Api-Key': event.apiKey || internalClient._config.apiKey,
+          'Bugsnag-Payload-Version': '4',
+          'Bugsnag-Sent-At': (new Date()).toISOString()
+        },
+        body,
+        agent: internalClient._config.agent
+      }, (err) => _cb(err))
+    } catch (e: any) {
+      _cb(e)
+    }
+  },
+  sendSession: (session, cb = () => {}) => {
+    const internalClient = client as InternalClient
+    const _cb = (err: Error | null) => {
+      if (err) internalClient._logger.error(`Session failed to send…\n${(err && err.stack) ? err.stack : err}`, err)
+      cb(err)
+    }
+
+    if (internalClient._config.endpoints.sessions === null) {
+      const err = new Error('Session not sent due to incomplete endpoint configuration')
+      return _cb(err)
+    }
+
+    try {
+      request({
+        url: internalClient._config.endpoints.sessions,
+        headers: {
+          'Content-Type': 'application/json',
+          'Bugsnag-Api-Key': internalClient._config.apiKey,
+          'Bugsnag-Payload-Version': '1',
+          'Bugsnag-Sent-At': (new Date()).toISOString()
+        },
+        body: jsonPayload.session(session, internalClient._config.redactedKeys),
+        agent: internalClient._config.agent
+      }, err => _cb(err))
+    } catch (e: any) {
+      _cb(e)
+    }
+  }
+})
+
+
+export default delivery

packages/delivery-node/request.js → packages/delivery-node/src/request.ts

@@ -1,10 +1,17 @@
-const http = require('http')
-const https = require('https')
-const { parse } = require('url')
+import http from 'http'
+import https from 'https'
+import { parse } from 'url'
 
-module.exports = ({ url, headers, body, agent }, cb) => {
+interface RequestOptions {
+  url: string
+  headers?: http.OutgoingHttpHeaders
+  body?: string
+  agent?: http.Agent
+}
+
+const request = ({ url, headers, body, agent }: RequestOptions, cb: (err: Error | null, body?: string) => void) => {
   let didError = false
-  const onError = (err) => {
+  const onError = (err: Error) => {
     if (didError) return
     didError = true
     cb(err)
@@ -25,7 +32,7 @@ module.exports = ({ url, headers, body, agent }, cb) => {
   req.on('response', res => {
     bufferResponse(res, (err, body) => {
       if (err) return onError(err)
-      if (res.statusCode < 200 || res.statusCode >= 300) {
+      if (res.statusCode && (res.statusCode < 200 || res.statusCode >= 300)) {
         return onError(new Error(`Bad statusCode from API: ${res.statusCode}\n${body}`))
       }
       cb(null, body)
@@ -35,10 +42,12 @@ module.exports = ({ url, headers, body, agent }, cb) => {
   req.end()
 }
 
-const bufferResponse = (stream, cb) => {
+const bufferResponse = (stream: NodeJS.ReadableStream, cb: (err: Error | null, body?: string) => void) => {
   let data = ''
   stream.on('error', cb)
   stream.setEncoding('utf8')
   stream.on('data', d => { data += d })
   stream.on('end', () => cb(null, data))
 }
+
+export default request

packages/delivery-node/test/delivery.test.ts

@@ -1,4 +1,4 @@
-import delivery from '../'
+import delivery from '../src/delivery'
 import http from 'http'
 import type { Client, EventDeliveryPayload, SessionDeliveryPayload } from '@bugsnag/core'
 import type { AddressInfo } from 'net'

packages/delivery-node/tsconfig.json

@@ -0,0 +1,8 @@
+{
+  "extends": "../../tsconfig.json",
+  "include": ["src/**/*.ts"],
+  "compilerOptions": {
+    "lib": ["es2017"],
+    "types": ["node"]
+  }
+}