refactor Node core module imports

This commit is a first pass at cleaning up the imports in the
project. It moves to the 'node:' scheme for core modules, removes
some unnecessary imports, and removes some unused imports.

Refs: kubernetes-client#1907

examples/typescript/apply/apply-from-file-example.ts

@@ -1,7 +1,7 @@
 // in a real program use require('@kubernetes/client-node')
 import * as k8s from '../../../dist';
 import * as yaml from 'js-yaml';
-import { promises as fs } from 'fs';
+import * as fs from 'node:fs/promises';
 
 /**
  * Replicate the functionality of `kubectl apply`.  That is, create the resources defined in the `specFile` if they do
@@ -51,4 +51,4 @@ export async function apply(specPath: string): Promise<k8s.KubernetesObject[]> {
     }
 
     return created;
-}
+}

examples/typescript/exec/exec-example.ts

@@ -1,6 +1,6 @@
 // in a real program use require('@kubernetes/client-node')
 import * as k8s from '../../../dist';
-import * as stream from 'stream';
+import * as stream from 'node:stream';
 
 const command = process.argv[2];
 

examples/typescript/port-forward/port-forward.ts

@@ -1,6 +1,6 @@
 // in a real program use require('@kubernetes/client-node')
 import * as k8s from '../../../dist';
-import * as net from 'net';
+import * as net from 'node:net';
 
 const kc = new k8s.KubeConfig();
 kc.loadFromDefault();

src/attach.ts

@@ -1,6 +1,6 @@
 import WebSocket = require('isomorphic-ws');
 import querystring = require('querystring');
-import stream = require('stream');
+import stream = require('node:stream');
 
 import { KubeConfig } from './config';
 import { isResizable, ResizableStream, TerminalSizeQueue } from './terminal-size-queue';

src/auth.ts

@@ -1,4 +1,4 @@
-import https = require('https');
+import https = require('node:https');
 
 import { User } from './config_types';
 import WebSocket = require('isomorphic-ws');

src/azure_auth.ts

@@ -1,5 +1,5 @@
-import * as proc from 'child_process';
-import https = require('https');
+import * as proc from 'node:child_process';
+import https = require('node:https');
 import * as jsonpath from 'jsonpath-plus';
 
 import { Authenticator } from './auth';

src/azure_auth_test.ts

@@ -1,6 +1,6 @@
 import { use, expect } from 'chai';
 import chaiAsPromised from 'chai-as-promised';
-import { join } from 'path';
+import { join } from 'node:path';
 
 import { User, Cluster } from './config_types';
 import { AzureAuth } from './azure_auth';

src/cache_test.ts

@@ -3,8 +3,6 @@ import chaiAsPromised = require('chai-as-promised');
 
 import * as mock from 'ts-mockito';
 
-import http = require('http');
-
 import { V1ListMeta, V1Namespace, V1NamespaceList, V1ObjectMeta, V1Pod } from './api';
 import { deleteItems, deleteObject, ListWatch } from './cache';
 import { KubeConfig } from './config';

src/config.ts

@@ -1,8 +1,8 @@
-import fs = require('fs');
-import https = require('https');
+import fs = require('node:fs');
+import https = require('node:https');
 import yaml = require('js-yaml');
-import net = require('net');
-import path = require('path');
+import net = require('node:net');
+import path = require('node:path');
 
 import { Headers, RequestInit } from 'node-fetch';
 import * as api from './api';
@@ -32,7 +32,7 @@ import {
 } from './gen';
 import { OpenIDConnectAuth } from './oidc_auth';
 import WebSocket = require('isomorphic-ws');
-import child_process = require('child_process');
+import child_process = require('node:child_process');
 
 const SERVICEACCOUNT_ROOT: string = '/var/run/secrets/kubernetes.io/serviceaccount';
 const SERVICEACCOUNT_CA_PATH: string = SERVICEACCOUNT_ROOT + '/ca.crt';

src/config_test.ts

@@ -1,12 +1,12 @@
-import { readFileSync } from 'fs';
-import * as https from 'https';
-import { Agent, RequestOptions } from 'https';
-import { join } from 'path';
+import { readFileSync } from 'node:fs';
+import * as https from 'node:https';
+import { Agent, RequestOptions } from 'node:https';
+import { join } from 'node:path';
 
 import { expect, use } from 'chai';
 import chaiAsPromised from 'chai-as-promised';
 import mockfs = require('mock-fs');
-import * as path from 'path';
+import * as path from 'node:path';
 
 import { Headers } from 'node-fetch';
 import { HttpMethod } from '.';

src/config_types.ts

@@ -1,4 +1,4 @@
-import * as fs from 'fs';
+import * as fs from 'node:fs';
 
 export enum ActionOnInvalid {
     THROW = 'throw',

src/cp.ts

@@ -1,4 +1,4 @@
-import * as fs from 'fs';
+import * as fs from 'node:fs';
 import { WritableStreamBuffer } from 'stream-buffers';
 import * as tar from 'tar';
 import * as tmp from 'tmp-promise';

src/cp_test.ts

@@ -1,5 +1,5 @@
 import { anything, anyFunction, instance, mock, verify, when } from 'ts-mockito';
-import * as querystring from 'querystring';
+import * as querystring from 'node:querystring';
 import WebSocket = require('isomorphic-ws');
 
 import { CallAwaiter } from '../test';

src/exec.ts

@@ -1,5 +1,5 @@
 import WebSocket = require('isomorphic-ws');
-import querystring = require('querystring');
+import querystring = require('node:querystring');
 import stream = require('stream');
 
 import { V1Status } from './api';

src/exec_auth.ts

@@ -1,10 +1,10 @@
-import { OutgoingHttpHeaders } from 'http';
-import https = require('https');
+import { OutgoingHttpHeaders } from 'node:http';
+import https = require('node:https');
 
 import { Authenticator } from './auth';
 import { User } from './config_types';
 
-import child_process = require('child_process');
+import child_process = require('node:child_process');
 
 export interface CredentialStatus {
     readonly token: string;

src/exec_auth_test.ts

@@ -2,14 +2,14 @@ import { expect, use } from 'chai';
 import chaiAsPromised from 'chai-as-promised';
 use(chaiAsPromised);
 
-import https from 'https';
-import { OutgoingHttpHeaders } from 'http';
+import https from 'node:https';
+import { OutgoingHttpHeaders } from 'node:http';
 
 import { ExecAuth } from './exec_auth';
 import { User } from './config_types';
-import { fail } from 'assert';
+import { fail } from 'node:assert';
 
-import child_process = require('child_process');
+import child_process = require('node:child_process');
 
 describe('ExecAuth', () => {
     it('should claim correctly', () => {

src/file_auth.ts

@@ -1,5 +1,5 @@
-import fs = require('fs');
-import https = require('https');
+import fs = require('node:fs');
+import https = require('node:https');
 
 import { Authenticator } from './auth';
 import { User } from './config_types';

src/file_auth_test.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
-import { OutgoingHttpHeaders } from 'http';
-import https from 'https';
+import { OutgoingHttpHeaders } from 'node:http';
+import https from 'node:https';
 import mockfs from 'mock-fs';
 
 import { User } from './config_types';

src/gcp_auth.ts

@@ -1,5 +1,5 @@
-import * as proc from 'child_process';
-import https = require('https');
+import * as proc from 'node:child_process';
+import https = require('node:https');
 import * as jsonpath from 'jsonpath-plus';
 
 import { Authenticator } from './auth';

src/gcp_auth_test.ts

@@ -1,11 +1,11 @@
 import { expect } from 'chai';
-import { join } from 'path';
+import { join } from 'node:path';
 
 import { User, Cluster } from './config_types';
 import { GoogleCloudPlatformAuth } from './gcp_auth';
 import { KubeConfig } from './config';
 import { HttpMethod, RequestContext } from './gen';
-import { Agent } from 'https';
+import { Agent } from 'node:https';
 
 describe('GoogleCloudPlatformAuth', () => {
     const testUrl1 = 'https://test-gcp.com';

src/log.ts

@@ -1,7 +1,6 @@
 import fetch from 'node-fetch';
 import { AbortSignal } from 'node-fetch/externals';
-import { Writable } from 'stream';
-import { URL, URLSearchParams } from 'url';
+import { Writable } from 'node:stream';
 import { ApiException } from './api';
 import { KubeConfig } from './config';
 import { V1Status } from './gen';

src/log_test.ts

@@ -1,6 +1,5 @@
 import { expect } from 'chai';
 import { AddOptionsToSearchParams, LogOptions } from './log';
-import { URLSearchParams } from 'url';
 
 describe('Log', () => {
     describe('AddOptionsToSearchParams', () => {

src/metrics_test.ts

@@ -1,8 +1,8 @@
-import { fail } from 'assert';
+import { fail } from 'node:assert';
 import { expect } from 'chai';
 import nock = require('nock');
 import { KubeConfig } from './config';
-import { V1Status, HttpException, ApiException } from './gen';
+import { V1Status, ApiException } from './gen';
 import { Metrics, NodeMetricsList, PodMetricsList } from './metrics';
 
 const emptyPodMetrics: PodMetricsList = {

src/object_test.ts

@@ -1,4 +1,4 @@
-import { fail } from 'assert';
+import { fail } from 'node:assert';
 import { expect } from 'chai';
 import nock = require('nock');
 import { Configuration, V1APIResource, V1APIResourceList, V1Secret } from './api';

src/oidc_auth.ts

@@ -1,7 +1,6 @@
-import https from 'https';
+import https from 'node:https';
 import { Client, Issuer } from 'openid-client';
 import { base64url } from 'rfc4648';
-import { TextDecoder } from 'util';
 
 import { Authenticator } from './auth';
 import { User } from './config_types';

src/oidc_auth_test.ts

@@ -1,8 +1,7 @@
 import { expect } from 'chai';
-import { OutgoingHttpHeaders } from 'http';
-import https from 'https';
+import { OutgoingHttpHeaders } from 'node:http';
+import https from 'node:https';
 import { base64url } from 'rfc4648';
-import { TextEncoder } from 'util';
 
 import { User } from './config_types';
 import { OpenIDConnectAuth } from './oidc_auth';

src/package_test.ts

@@ -1,5 +1,4 @@
 import { expect } from 'chai';
-import { URL } from 'url';
 
 // Generic set of tests to verify the package is built and configured correctly
 describe('package', () => {

src/portforward.ts

@@ -1,6 +1,6 @@
 import WebSocket = require('isomorphic-ws');
-import querystring = require('querystring');
-import stream = require('stream');
+import querystring = require('node:querystring');
+import stream = require('node:stream');
 
 import { KubeConfig } from './config';
 import { WebSocketHandler, WebSocketInterface } from './web-socket-handler';

src/portforward_test.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
 import { ReadableStreamBuffer, WritableStreamBuffer } from 'stream-buffers';
-import { anyFunction, capture, instance, mock, reset, verify } from 'ts-mockito';
+import { anyFunction, capture, instance, mock, verify } from 'ts-mockito';
 
 import { KubeConfig } from './config';
 import { PortForward } from './portforward';

src/proto-client.ts

@@ -1,5 +1,4 @@
-import http = require('http');
-import url = require('url');
+import http = require('node:http');
 
 import { KubeConfig } from './config';
 
@@ -8,7 +7,7 @@ export class ProtoClient {
 
     public async get(msgType: any, requestPath: string): Promise<any> {
         const server = this.config.getCurrentCluster()!.server;
-        const u = new url.URL(server);
+        const u = new URL(server);
         const options = {
             path: requestPath,
             hostname: u.hostname,

src/terminal-size-queue.ts

@@ -1,4 +1,4 @@
-import { Readable, ReadableOptions } from 'stream';
+import { Readable, ReadableOptions } from 'node:stream';
 
 export interface ResizableStream {
     columns: number;

src/watch.ts

@@ -1,7 +1,6 @@
 import { createInterface } from 'node:readline';
 import fetch from 'node-fetch';
 import { AbortSignal } from 'node-fetch/externals';
-import { URL } from 'url';
 import { KubeConfig } from './config';
 
 export class Watch {

src/watch_test.ts

@@ -1,12 +1,10 @@
 import { expect } from 'chai';
-// import { anything, capture, instance, mock, spy, verify, when } from 'ts-mockito';
-
 import nock = require('nock');
-import { PassThrough } from 'stream';
+import { PassThrough } from 'node:stream';
 import { KubeConfig } from './config';
 import { Cluster, Context, User } from './config_types';
 import { Watch } from './watch';
-import { IncomingMessage } from 'http';
+import { IncomingMessage } from 'node:http';
 
 const server = 'http://foo.company.com';
 

src/web-socket-handler.ts

@@ -1,5 +1,5 @@
 import WebSocket = require('isomorphic-ws');
-import stream = require('stream');
+import stream = require('node:stream');
 
 import { V1Status } from './api';
 import { KubeConfig } from './config';

src/web-socket-handler_test.ts

@@ -1,5 +1,5 @@
 import { Readable } from 'node:stream';
-import { promisify } from 'util';
+import { setImmediate as setImmediatePromise } from 'node:timers/promises';
 import { expect } from 'chai';
 import WebSocket = require('isomorphic-ws');
 import { WritableStreamBuffer } from 'stream-buffers';
@@ -9,8 +9,6 @@ import { KubeConfig } from './config';
 import { Cluster, Context, User } from './config_types';
 import { WebSocketHandler } from './web-socket-handler';
 
-const setImmediatePromise = promisify(setImmediate);
-
 describe('WebSocket', () => {
     it('should throw on unknown code', () => {
         const osStream = new WritableStreamBuffer();

test/call-awaiter.ts

@@ -1,4 +1,4 @@
-import { EventEmitter } from 'events';
+import { EventEmitter } from 'node:events';
 
 export class CallAwaiter extends EventEmitter {
   public awaitCall(event: string) {

test/match-buffer.ts

@@ -1,6 +1,5 @@
-import { deepStrictEqual } from 'assert';
 import { expect } from 'chai';
-import { RequestOptions, Agent } from 'https';
+import { RequestOptions, Agent } from 'node:https';
 import { Matcher } from 'ts-mockito/lib/matcher/type/Matcher';
 
 export function matchBuffer(channel: number, contents: string): StringBufferMatcher {