[#182] Support gRPC stream flowable

*  _read method of readable steam learning test


[#177] Update minimum NodeJS version to Node@16

.github/workflows/main.yml

@@ -14,7 +14,6 @@ jobs:
     strategy:
       matrix:
         node_version:
-          - 14          
           - 16
           - 18
 

lib/client/bounded-buffer-readable-stream.js

@@ -0,0 +1,58 @@
+/**
+ * Pinpoint Node.js Agent
+ * Copyright 2021-present NAVER Corp.
+ * Apache License v2.0
+ */
+
+'use strict'
+
+const { Readable } = require('node:stream')
+
+class BoundedBufferReadableStream {
+    constructor(constructorOptions) {
+        this.buffer = []
+
+        const options = constructorOptions || {}
+        this.steam = new Readable(Object.assign({
+            read: () => {
+                this.readStart()
+            }
+        }, options))
+    }
+
+    push(data) {
+        if (!data) {
+            return
+        }
+        this.buffer.push(data)
+
+        if (this.canStart()) {
+            this.readStart()
+        }
+    }
+
+    canStart() {
+        return this.readable
+    }
+
+    end() {
+        this.steam.end()
+    }
+
+    readStart() {
+        this.readable = true
+
+        const length = this.buffer.length
+        for (let index = 0; index < length; index++) {
+            if (!this.steam.push(this.buffer.shift())) {
+                return this.readStop()
+            }
+        }
+    }
+
+    readStop() {
+        this.readable = false
+    }
+}
+
+module.exports = BoundedBufferReadableStream

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pinpoint-node-agent",
-  "version": "0.9.0-next.4",
+  "version": "1.0.0-next.1",
   "main": "index.js",
   "types": "index.d.ts",
   "type": "commonjs",
@@ -23,7 +23,7 @@
   },
   "homepage": "https://github.com/pinpoint-apm/pinpoint-node-agent",
   "engines": {
-    "node": ">=14.0"
+    "node": ">=16.0"
   },
   "keywords": [
     "pinpoint",
@@ -64,7 +64,7 @@
   "devDependencies": {
     "@types/semver": "^7.3.13",
     "@types/shimmer": "^1.0.2",
-    "axios": "^1.6.2",
+    "axios": "^1.6.8",
     "eslint": "^8.43.0",
     "eslint-config-prettier": "^3.6.0",
     "eslint-plugin-import": "^2.25.2",

test/agent.test.js

@@ -14,5 +14,5 @@ test('Should initialize agent', function (t) {
 
   const agent = require('./support/agent-singleton-mock')
   t.ok(agent)
-  t.equal(agent.pinpointClient.agentInfo.agentVersion, '0.9.0-next.4', 'agent version from package.json')
+  t.equal(agent.pinpointClient.agentInfo.agentVersion, '1.0.0-next.1', 'agent version from package.json')
 })

test/client/bounded-buffer-readable-stream.test.js

@@ -0,0 +1,21 @@
+/**
+ * Pinpoint Node.js Agent
+ * Copyright 2021-present NAVER Corp.
+ * Apache License v2.0
+ */
+
+'use strict'
+
+const test = require('tape')
+const BoundedBufferReadableStream = require('../../lib/client/bounded-buffer-readable-stream')
+
+test('no piped readable steam', (t) => {
+    const readable = new BoundedBufferReadableStream()
+    readable.push('test1')
+    readable.push('test2')
+    readable.push(null)
+
+    t.equal(readable.steam.readable, true, 'no writable stream piped readable steam not started')
+    t.equal(readable.buffer.length, 2, 'no writable stream piped readable steam buffer is not empty')
+    t.end()
+})