fix: remove unused request dependency

Author: rbnayax

.github/workflows/test.yml

@@ -11,7 +11,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        node: [ '16', '14', '12' ]
+        node: [ '18', '16', '14', '12' ]
     name: Node ${{ matrix.node }} validation
     steps:
       - uses: actions/checkout@v2

package-lock.json

@@ -117,14 +117,14 @@ export class Log {
         const requestURL = new URL(cluster.server + path);
 
         const searchParams = requestURL.searchParams;
+        searchParams.set('container', containerName);
         AddOptionsToSearchParams(options, searchParams);
 
-        const requestOptions: RequestOptions = {};
-
-        const requestInit = await this.config.applytoFetchOptions(requestOptions);
+        const requestInit = await this.config.applytoFetchOptions({});
 
         const controller = new AbortControllerCtor();
         requestInit.signal = controller.signal;
+        requestInit.method = 'GET';
 
         await fetch(requestURL.toString(), requestInit)
             .then((response) => {

src/log.ts

@@ -84,9 +84,8 @@ export class Metrics {
 
         const requestURL = cluster.server + path;
 
-        const requestInit = await this.config.applytoFetchOptions({
-            method: 'GET',
-        });
+        const requestInit = await this.config.applytoFetchOptions({});
+        requestInit.method = 'GET';
 
         return fetch(requestURL, requestInit)
             .then((response) => {

src/metrics.ts

@@ -41,11 +41,11 @@ export class Watch {
             }
         }
 
-        const requestOptions: RequestOptions = {};
-        const requestInit = await this.config.applytoFetchOptions(requestOptions);
+        const requestInit = await this.config.applytoFetchOptions({});
 
         const controller = new AbortControllerCtor();
         requestInit.signal = controller.signal;
+        requestInit.method = 'GET';
 
         let doneCalled: boolean = false;
         const doneCallOnce = (err: any) => {
@@ -58,6 +58,7 @@ export class Watch {
         const stream = byline.createStream();
         stream.on('error', doneCallOnce);
         stream.on('close', () => doneCallOnce(null));
+        stream.on('finish', () => doneCallOnce(null));
         stream.on('data', (line) => {
             try {
                 const data = JSON.parse(line.toString());
@@ -71,6 +72,8 @@ export class Watch {
             .then((response) => {
                 if (response.status === 200) {
                     response.body.on('error', doneCallOnce);
+                    response.body.on('close', () => doneCallOnce(null));
+                    response.body.on('finish', () => doneCallOnce(null));
                     response.body.pipe(stream);
                 } else {
                     const error = new Error(response.statusText) as Error & {