refactor: use egg v4

.eslintrc

@@ -1,6 +1,6 @@
 {
-  "extends": "eslint-config-egg/typescript",
-  "rules": {
-
-  }
+  "extends": [
+    "eslint-config-egg/typescript",
+    "eslint-config-egg/lib/rules/enforce-node-prefix"
+  ]
 }

INTEGRATE.md

@@ -59,7 +59,7 @@
     {
       redis: {
         enable: true,
-        package: 'egg-redis',
+        package: '@eggjs/redis',
       },
       teggOrm: {
         enable: true,
@@ -71,7 +71,7 @@
       },
       tracer: {
         enable: true,
-        package: 'egg-tracer',
+        package: '@eggjs/tracer',
       },
       typeboxValidate: {
         enable: true,

app.ts

@@ -1,5 +1,5 @@
-import path from 'path';
-import { readFile } from 'fs/promises';
+import path from 'node:path';
+import { readFile } from 'node:fs/promises';
 import { Application } from 'egg';
 import { ChangesStreamService } from './app/core/service/ChangesStreamService';
 

app/common/CryptoUtil.ts

@@ -1,4 +1,4 @@
-import { generateKeyPairSync } from 'crypto';
+import { generateKeyPairSync } from 'node:crypto';
 import NodeRSA from 'node-rsa';
 
 // generate rsa key pair

app/common/UserUtil.ts

@@ -1,4 +1,4 @@
-import crypto from 'crypto';
+import crypto from 'node:crypto';
 import base from 'base-x';
 import { crc32 } from '@node-rs/crc32';
 import * as ssri from 'ssri';

app/common/adapter/CacheAdapter.ts

@@ -3,8 +3,8 @@ import {
   AccessLevel,
   Inject,
 } from '@eggjs/tegg';
-// FIXME: egg-redis should use ioredis v5
-// https://github.com/eggjs/egg-redis/issues/35
+// FIXME: @eggjs/redis should use ioredis v5
+// https://github.com/eggjs/redis/issues/35
 import type { Redis } from 'ioredis';
 
 const ONE_DAY = 3600 * 24;

app/common/adapter/NFSAdapter.ts

@@ -1,4 +1,5 @@
-import { Readable } from 'stream';
+import { Readable } from 'node:stream';
+import { IncomingHttpHeaders } from 'node:http';
 import {
   SingletonProto,
   AccessLevel,
@@ -8,7 +9,6 @@ import { Pointcut } from '@eggjs/tegg/aop';
 import { EggLogger } from 'egg';
 import { AsyncTimer } from '../aop/AsyncTimer';
 import { NFSClient } from '../typing';
-import { IncomingHttpHeaders } from 'http';
 
 const INSTANCE_NAME = 'nfsAdapter';
 

app/common/adapter/NPMRegistry.ts

@@ -1,4 +1,4 @@
-import { setTimeout } from 'timers/promises';
+import { setTimeout } from 'node:timers/promises';
 import {
   ContextProto,
   AccessLevel,

app/common/adapter/binary/BucketBinary.ts

@@ -1,7 +1,7 @@
 import { SingletonProto } from '@eggjs/tegg';
 import { BinaryType } from '../../enum/Binary';
 import binaries, { BinaryName, BinaryTaskConfig } from '../../../../config/binaries';
-import path from 'path';
+import path from 'node:path';
 import { AbstractBinary, FetchResult, BinaryItem, BinaryAdapter } from './AbstractBinary';
 
 @SingletonProto()

app/common/adapter/binary/ChromeForTestingBinary.ts

@@ -1,4 +1,4 @@
-import { basename } from 'path';
+import { basename } from 'node:path';
 import { SingletonProto } from '@eggjs/tegg';
 import { BinaryType } from '../../enum/Binary';
 import { AbstractBinary, FetchResult, BinaryItem, BinaryAdapter } from './AbstractBinary';

app/common/adapter/binary/NodePreGypBinary.ts

@@ -1,7 +1,7 @@
 import { SingletonProto } from '@eggjs/tegg';
 import { BinaryType } from '../../enum/Binary';
 import binaries, { BinaryName } from '../../../../config/binaries';
-import { join } from 'path';
+import { join } from 'node:path';
 import { AbstractBinary, FetchResult, BinaryItem, BinaryAdapter } from './AbstractBinary';
 
 @SingletonProto()

app/common/adapter/binary/PlaywrightBinary.ts

@@ -1,7 +1,7 @@
 
 import { AbstractBinary, BinaryAdapter, BinaryItem, FetchResult } from './AbstractBinary';
-import util from 'util';
-import path from 'path';
+import util from 'node:util';
+import path from 'node:path';
 import { SingletonProto } from '@eggjs/tegg';
 import { BinaryType } from '../../enum/Binary';
 

app/common/aop/AsyncTimer.ts

@@ -1,4 +1,4 @@
-import { performance } from 'perf_hooks';
+import { performance } from 'node:perf_hooks';
 import { Advice, AdviceContext, IAdvice } from '@eggjs/tegg/aop';
 import { Inject } from '@eggjs/tegg';
 import { EggLogger } from 'egg';

app/common/typing.ts

@@ -1,8 +1,8 @@
-import { CnpmcoreConfig } from '../port/config';
-import { Readable } from 'stream';
-import { IncomingHttpHeaders } from 'http';
+import { Readable } from 'node:stream';
+import { IncomingHttpHeaders } from 'node:http';
 import { EggContext } from '@eggjs/tegg';
 import { estypes } from '@elastic/elasticsearch';
+import { CnpmcoreConfig } from '../port/config';
 
 export interface UploadResult {
   key: string;

app/core/entity/Hook.ts

@@ -1,7 +1,7 @@
 import { Entity, EntityData } from './Entity';
 import { EasyData, EntityUtil } from '../util/EntityUtil';
 import { HookType } from '../../common/enum/Hook';
-import crypto from 'crypto';
+import crypto from 'node:crypto';
 
 export type CreateHookData = Omit<EasyData<HookData, 'hookId'>, 'enable' | 'latestTaskId'>;
 

app/core/entity/Task.ts

@@ -1,5 +1,5 @@
-import os from 'os';
-import path from 'path';
+import os from 'node:os';
+import path from 'node:path';
 import { Entity, EntityData } from './Entity';
 import { EasyData, EntityUtil } from '../util/EntityUtil';
 import { TaskType, TaskState } from '../../common/enum/Task';

app/core/service/BinarySyncerService.ts

@@ -1,4 +1,3 @@
-import { rm } from 'fs/promises';
 import {
   AccessLevel,
   SingletonProto,
@@ -8,7 +7,7 @@ import {
 import {
   EggHttpClient,
 } from 'egg';
-import fs from 'fs/promises';
+import fs from 'node:fs/promises';
 import { sortBy } from 'lodash';
 import binaries, { BinaryName, CategoryName } from '../../../config/binaries';
 import { BinaryRepository } from '../../repository/BinaryRepository';
@@ -223,7 +222,7 @@ export class BinarySyncerService extends AbstractService {
             logs = [];
           } finally {
             if (localFile) {
-              await rm(localFile, { force: true });
+              await fs.rm(localFile, { force: true });
             }
           }
         }

app/core/service/ChangesStreamService.ts

@@ -1,5 +1,5 @@
-import os from 'os';
-import { setTimeout } from 'timers/promises';
+import os from 'node:os';
+import { setTimeout } from 'node:timers/promises';
 import {
   AccessLevel,
   SingletonProto,

app/core/service/ProxyCacheService.ts

@@ -1,6 +1,6 @@
-import { EggHttpClient, HttpClientRequestOptions, HttpClientResponse } from 'egg';
+import { EggHttpClient, HttpClientRequestOptions, HttpClientResponse, Context } from 'egg';
 import { ForbiddenError } from 'egg-errors';
-import { SingletonProto, AccessLevel, Inject, EggContext } from '@eggjs/tegg';
+import { SingletonProto, AccessLevel, Inject } from '@eggjs/tegg';
 import { BackgroundTaskHelper } from '@eggjs/tegg-background-task';
 import { valid as semverValid } from 'semver';
 import { AbstractService } from '../../common/AbstractService';
@@ -51,7 +51,7 @@ export class ProxyCacheService extends AbstractService {
   @Inject()
   private readonly backgroundTaskHelper:BackgroundTaskHelper;
 
-  async getPackageVersionTarResponse(fullname: string, ctx: EggContext): Promise<HttpClientResponse> {
+  async getPackageVersionTarResponse(fullname: string, ctx: Context): Promise<HttpClientResponse> {
     if (this.config.cnpmcore.syncPackageBlockList.includes(fullname)) {
       throw new ForbiddenError(`stop proxy by block list: ${JSON.stringify(this.config.cnpmcore.syncPackageBlockList)}`);
     }
@@ -244,7 +244,7 @@ export class ProxyCacheService extends AbstractService {
     await this.nfsAdapter.uploadBytes(storeKey, nfsBytes);
   }
 
-  async getProxyResponse(ctx: Partial<EggContext>, options?: HttpClientRequestOptions): Promise<HttpClientResponse> {
+  async getProxyResponse(ctx: Partial<Context>, options?: HttpClientRequestOptions): Promise<HttpClientResponse> {
     const registry = this.npmRegistry.registry;
     const remoteAuthToken = await this.registryManagerService.getAuthTokenByRegistryHost(registry);
     const authorization = this.npmRegistry.genAuthorizationHeader(remoteAuthToken);

app/core/service/UserService.ts

@@ -1,4 +1,4 @@
-import crypto from 'crypto';
+import crypto from 'node:crypto';
 import {
   AccessLevel,
   SingletonProto,

app/infra/AuthAdapter.ts

@@ -5,7 +5,7 @@ import {
   SingletonProto,
 } from '@eggjs/tegg';
 import { Redis } from 'ioredis';
-import { randomUUID } from 'crypto';
+import { randomUUID } from 'node:crypto';
 import { AuthClient, AuthUrlResult, userResult } from '../common/typing';
 
 const ONE_DAY = 3600 * 24;

app/infra/NFSClientAdapter.ts

@@ -7,7 +7,7 @@ import {
 import { EggAppConfig, EggLogger } from 'egg';
 import FSClient from 'fs-cnpm';
 import { AppendResult, NFSClient, UploadOptions, UploadResult, DownloadOptions } from '../common/typing';
-import { Readable } from 'stream';
+import { Readable } from 'node:stream';
 
 @SingletonProto({
   name: 'nfsClient',

app/port/UserRoleManager.ts

@@ -105,7 +105,7 @@ export class UserRoleManager {
       };
     }
     this.handleAuthorized = true;
-    const authorization = ctx.get('authorization');
+    const authorization = ctx.get<string>('authorization');
     if (!authorization) return null;
     const authorizedUserAndToken = await this.tokenService.getUserAndToken(authorization);
     if (!authorizedUserAndToken) {
@@ -187,3 +187,9 @@ export class UserRoleManager {
     return user.name in this.config.cnpmcore.admins;
   }
 }
+
+declare module 'egg' {
+  export interface Context {
+    userId?: string;
+  }
+}

app/port/controller/BinarySyncController.ts

@@ -7,7 +7,7 @@ import {
   EggContext,
   Inject,
 } from '@eggjs/tegg';
-import path from 'path';
+import path from 'node:path';
 import { NotFoundError } from 'egg-errors';
 import { AbstractController } from './AbstractController';
 import { BinarySyncerService } from '../../core/service/BinarySyncerService';

app/port/controller/ChangesStreamController.ts

@@ -7,7 +7,7 @@ import {
   Context,
   EggContext,
 } from '@eggjs/tegg';
-import { Type } from '@sinclair/typebox';
+import { Type } from 'egg-typebox-validate-fengmk2/typebox';
 import { AbstractController } from './AbstractController';
 import { ChangeRepository } from '../../repository/ChangeRepository';
 

app/port/controller/HomeController.ts

@@ -1,4 +1,4 @@
-import { performance } from 'perf_hooks';
+import { performance } from 'node:perf_hooks';
 import {
   HTTPController,
   HTTPMethod,

app/port/controller/ProxyCacheController.ts

@@ -11,7 +11,7 @@ import {
 import { ForbiddenError, NotFoundError, UnauthorizedError, NotImplementedError } from 'egg-errors';
 import { AbstractController } from './AbstractController';
 import { ProxyCacheRepository } from '../../repository/ProxyCacheRepository';
-import { Static } from 'egg-typebox-validate/typebox';
+import { Static } from 'egg-typebox-validate-fengmk2/typebox';
 import { QueryPageOptions } from '../typebox';
 import { FULLNAME_REG_STRING } from '../../common/PackageUtil';
 import {

app/port/controller/RegistryController.ts

@@ -12,7 +12,7 @@ import {
 } from '@eggjs/tegg';
 import { NotFoundError } from 'egg-errors';
 import { AbstractController } from './AbstractController';
-import { Static } from 'egg-typebox-validate/typebox';
+import { Static } from 'egg-typebox-validate-fengmk2/typebox';
 import { RegistryManagerService, UpdateRegistryCmd } from '../../core/service/RegistryManagerService';
 import { AdminAccess } from '../middleware/AdminAccess';
 import { ScopeManagerService } from '../../core/service/ScopeManagerService';

app/port/controller/ScopeController.ts

@@ -11,7 +11,7 @@ import {
 } from '@eggjs/tegg';
 import { E400 } from 'egg-errors';
 import { AbstractController } from './AbstractController';
-import { Static } from 'egg-typebox-validate/typebox';
+import { Static } from 'egg-typebox-validate-fengmk2/typebox';
 import { AdminAccess } from '../middleware/AdminAccess';
 import { ScopeManagerService } from '../../core/service/ScopeManagerService';
 import { RegistryManagerService } from '../../core/service/RegistryManagerService';

app/port/controller/TokenController.ts

@@ -10,7 +10,7 @@ import {
   EggContext,
   Inject,
 } from '@eggjs/tegg';
-import { Static, Type } from '@sinclair/typebox';
+import { Static, Type } from 'egg-typebox-validate-fengmk2/typebox';
 import { AbstractController } from './AbstractController';
 import { TokenType, isGranularToken } from '../../core/entity/Token';
 

app/port/controller/UserController.ts

@@ -13,7 +13,7 @@ import {
   UnauthorizedError,
   ForbiddenError,
 } from 'egg-errors';
-import { Static, Type } from '@sinclair/typebox';
+import { Static, Type } from 'egg-typebox-validate-fengmk2/typebox';
 import { AbstractController } from './AbstractController';
 import { LoginResultCode } from '../../common/enum/User';
 import { sha512 } from '../../common/UserUtil';

app/port/controller/package/DownloadPackageVersionTar.ts

@@ -119,7 +119,7 @@ export class DownloadPackageVersionTarController extends AbstractController {
   private async getTgzProxyStream(ctx: EggContext, fullname: string, version: string) {
     const { headers, status, res } = await this.proxyCacheService.getPackageVersionTarResponse(fullname, ctx);
     ctx.status = status;
-    ctx.set(headers as { [key: string]: string | string[] });
+    ctx.set(headers as Record<string, string>);
     ctx.runInBackground(async () => {
       const task = await this.packageSyncerService.createTask(fullname, {
         authorIp: ctx.ip,

app/port/controller/package/SavePackageVersionController.ts

@@ -17,7 +17,7 @@ import {
 } from '@eggjs/tegg';
 import * as ssri from 'ssri';
 import validateNpmPackageName from 'validate-npm-package-name';
-import { Static, Type } from '@sinclair/typebox';
+import { Static, Type } from 'egg-typebox-validate-fengmk2/typebox';
 import { AbstractController } from '../AbstractController';
 import { getScopeAndName, FULLNAME_REG_STRING, extractPackageJSON } from '../../../common/PackageUtil';
 import { PackageManagerService } from '../../../core/service/PackageManagerService';
@@ -268,9 +268,9 @@ export class SavePackageVersionController extends AbstractController {
     // forbidden star/unstar request
     // npm@6: referer: 'star [REDACTED]'
     // npm@>=7: 'npm-command': 'star'
-    let command = ctx.get('npm-command');
+    let command = ctx.get<string>('npm-command');
     if (!command) {
-      command = ctx.get('referer').split(' ', 1)[0];
+      command = ctx.get<string>('referer').split(' ', 1)[0];
     }
     if (command === 'star' || command === 'unstar') {
       throw new ForbiddenError(`npm ${command} is not allowed`);

app/port/controller/package/SearchPackageController.ts

@@ -9,7 +9,7 @@ import {
   Context,
   EggContext,
 } from '@eggjs/tegg';
-import { Static } from 'egg-typebox-validate/typebox';
+import { Static } from 'egg-typebox-validate-fengmk2/typebox';
 import { E451 } from 'egg-errors';
 
 import { AbstractController } from '../AbstractController';

app/port/controller/package/ShowPackageController.ts

@@ -42,7 +42,7 @@ export class ShowPackageController extends AbstractController {
     try {
       const cacheEtag = await this.cacheService.getPackageEtag(fullname, isFullManifests);
       if (!isSync && cacheEtag) {
-        let requestEtag = ctx.request.get('if-none-match');
+        let requestEtag = ctx.request.get<string>('if-none-match');
         if (requestEtag.startsWith('W/')) {
           requestEtag = requestEtag.substring(2);
         }

app/port/controller/package/UpdatePackageController.ts

@@ -12,7 +12,7 @@ import {
   Context,
   EggContext,
 } from '@eggjs/tegg';
-import { Static, Type } from '@sinclair/typebox';
+import { Static, Type } from 'egg-typebox-validate-fengmk2/typebox';
 import { AbstractController } from '../AbstractController';
 import { FULLNAME_REG_STRING } from '../../../common/PackageUtil';
 import { User as UserEntity } from '../../../core/entity/User';
@@ -71,9 +71,9 @@ export class UpdatePackageController extends AbstractController {
   private getNpmCommand(ctx: EggContext) {
     // npm@6: referer: 'xxx [REDACTED]'
     // npm@>=7: 'npm-command': 'xxx'
-    let npmCommand = ctx.get('npm-command');
+    let npmCommand = ctx.get<string>('npm-command');
     if (!npmCommand) {
-      npmCommand = ctx.get('referer').split(' ', 1)[0];
+      npmCommand = ctx.get<string>('referer').split(' ', 1)[0];
     }
 
     return npmCommand;