feat: support restify v9-v11

.readme-partials.yaml

@@ -59,7 +59,7 @@ body: |-
     * [gRPC](https://www.npmjs.com/package/grpc) server (version ^1.1)
     * [hapi](https://www.npmjs.com/package/hapi) (versions 8 - 19)
     * [koa](https://www.npmjs.com/package/koa) (version 1 - 2)
-    * [restify](https://www.npmjs.com/package/restify) (versions 3 - 8)
+    * [restify](https://www.npmjs.com/package/restify) (versions 3 - 11)
 
     The agent will also automatically trace RPCs from the following modules:
     * Outbound HTTP requests through `http`, `https`, and `http2` core modules

README.md

@@ -112,7 +112,7 @@ The trace agent can do automatic tracing of the following web frameworks:
 * [gRPC](https://www.npmjs.com/package/grpc) server (version ^1.1)
 * [hapi](https://www.npmjs.com/package/hapi) (versions 8 - 19)
 * [koa](https://www.npmjs.com/package/koa) (version 1 - 2)
-* [restify](https://www.npmjs.com/package/restify) (versions 3 - 8)
+* [restify](https://www.npmjs.com/package/restify) (versions 3 - 11)
 
 The agent will also automatically trace RPCs from the following modules:
 * Outbound HTTP requests through `http`, `https`, and `http2` core modules

src/plugins/plugin-restify.ts

@@ -25,7 +25,7 @@ type Response = restify_5.Response;
 type Next = restify_5.Next;
 type CreateServerFn = (options?: restify_5.ServerOptions) => restify_5.Server;
 
-const SUPPORTED_VERSIONS = '<=8.x';
+const SUPPORTED_VERSIONS = '<=11.x';
 
 function unpatchRestify(restify: Restify5) {
   shimmer.unwrap(restify, 'createServer');

test/fixtures/plugin-fixtures.json

@@ -243,5 +243,20 @@
     "dependencies": {
       "restify": "^8.5.1"
     }
+  },
+  "restify9": {
+    "dependencies": {
+      "restify": "^9.0.0"
+    }
+  },
+  "restify10": {
+    "dependencies": {
+      "restify": "^10.0.0"
+    }
+  },
+  "restify11": {
+    "dependencies": {
+      "restify": "^11.0.0"
+    }
   }
 }

test/test-trace-web-frameworks.ts

@@ -42,6 +42,9 @@ import {
   Restify6,
   Restify7,
   Restify8,
+  Restify9,
+  Restify10,
+  Restify11,
 } from './web-frameworks/restify';
 
 // The type of a stack trace object after being parsed from a trace span's stack
@@ -70,6 +73,9 @@ const FRAMEWORKS: WebFrameworkConstructor[] = [
   Restify6,
   Restify7,
   Restify8,
+  Restify9,
+  Restify10,
+  Restify11,
 ];
 
 /**

test/web-frameworks/restify.ts

@@ -17,7 +17,7 @@
 import {
   WebFramework,
   WebFrameworkAddHandlerOptions,
   WebFrameworkResponse,
 } from './base';
 
 export class Restify implements WebFramework {
@@ -35,31 +35,26 @@
       );
     }
     if (options.hasResponse) {
-      this.server.get(options.path, async (req, res, next) => {
-        let response: WebFrameworkResponse;
-        try {
-          response = await options.fn(req.headers);
-        } catch (e) {
-          next(e);
-          return;
-        }
-        res.statusCode = response.statusCode;
-        res.end(response.message);
-        next();
+      this.server.get(options.path, (req, res, next) => {
+        Promise.resolve()
+          .then(() => options.fn(req.headers))
+          .then((response) => {
+            res.statusCode = response.statusCode;
+            res.end(response.message);
+            next();
+          })
+          .catch(e => next(e));
       });
     } else {
-      this.server.use(async (req, res, next) => {
+      this.server.use((req, res, next) => {
         if (req.getPath() !== options.path) {
           next();
           return;
         }
-        try {
-          await options.fn(req.headers);
-        } catch (e) {
-          next(e);
-          return;
-        }
-        next();
+        Promise.resolve()
+          .then(() => options.fn(req.headers))
+          .then(() => next())
+          .catch(e => next(e));
       });
     }
   }
@@ -91,3 +86,6 @@
 export const Restify6 = makeRestifyClass(6);
 export const Restify7 = makeRestifyClass(7);
 export const Restify8 = makeRestifyClass(8);
+export const Restify9 = makeRestifyClass(9);
+export const Restify10 = makeRestifyClass(10);
+export const Restify11 = makeRestifyClass(11);