summaryrefslogtreecommitdiff
path: root/packages/backend/src/core
diff options
context:
space:
mode:
authorsyuilo <4439005+syuilo@users.noreply.github.com>2025-08-09 17:41:01 +0900
committersyuilo <4439005+syuilo@users.noreply.github.com>2025-08-09 17:41:01 +0900
commitecc033f10140a3b8fc9c8d1446f0946a10924343 (patch)
tree827a3bf2363b73155035f68fe0064f7a29e7bee6 /packages/backend/src/core
parentfix(deps): update [backend] update dependencies (#16201) (diff)
downloadmisskey-ecc033f10140a3b8fc9c8d1446f0946a10924343.tar.gz
misskey-ecc033f10140a3b8fc9c8d1446f0946a10924343.tar.bz2
misskey-ecc033f10140a3b8fc9c8d1446f0946a10924343.zip
fix(backend): fix type errors caused by dependency update
https: //github.com/misskey-dev/misskey/pull/16308 Co-Authored-By: かっこかり <67428053+kakkokari-gtyih@users.noreply.github.com>
Diffstat (limited to 'packages/backend/src/core')
-rw-r--r--packages/backend/src/core/HttpRequestService.ts19
1 files changed, 7 insertions, 12 deletions
diff --git a/packages/backend/src/core/HttpRequestService.ts b/packages/backend/src/core/HttpRequestService.ts
index e17cab5edf..f7973cbb66 100644
--- a/packages/backend/src/core/HttpRequestService.ts
+++ b/packages/backend/src/core/HttpRequestService.ts
@@ -6,6 +6,7 @@
import * as http from 'node:http';
import * as https from 'node:https';
import * as net from 'node:net';
+import * as stream from 'node:stream';
import ipaddr from 'ipaddr.js';
import CacheableLookup from 'cacheable-lookup';
import fetch from 'node-fetch';
@@ -26,12 +27,6 @@ export type HttpRequestSendOptions = {
validators?: ((res: Response) => void)[];
};
-declare module 'node:http' {
- interface Agent {
- createConnection(options: net.NetConnectOpts, callback?: (err: Error | null, stream: net.Socket) => void): net.Socket;
- }
-}
-
class HttpRequestServiceAgent extends http.Agent {
constructor(
private config: Config,
@@ -41,11 +36,11 @@ class HttpRequestServiceAgent extends http.Agent {
}
@bindThis
- public createConnection(options: net.NetConnectOpts, callback?: (err: Error | null, stream: net.Socket) => void): net.Socket {
+ public createConnection(options: http.ClientRequestArgs, callback?: (err: Error | null, stream: stream.Duplex) => void): stream.Duplex {
const socket = super.createConnection(options, callback)
.on('connect', () => {
- const address = socket.remoteAddress;
- if (process.env.NODE_ENV === 'production') {
+ if (socket instanceof net.Socket && process.env.NODE_ENV === 'production') {
+ const address = socket.remoteAddress;
if (address && ipaddr.isValid(address)) {
if (this.isPrivateIp(address)) {
socket.destroy(new Error(`Blocked address: ${address}`));
@@ -80,11 +75,11 @@ class HttpsRequestServiceAgent extends https.Agent {
}
@bindThis
- public createConnection(options: net.NetConnectOpts, callback?: (err: Error | null, stream: net.Socket) => void): net.Socket {
+ public createConnection(options: http.ClientRequestArgs, callback?: (err: Error | null, stream: stream.Duplex) => void): stream.Duplex {
const socket = super.createConnection(options, callback)
.on('connect', () => {
- const address = socket.remoteAddress;
- if (process.env.NODE_ENV === 'production') {
+ if (socket instanceof net.Socket && process.env.NODE_ENV === 'production') {
+ const address = socket.remoteAddress;
if (address && ipaddr.isValid(address)) {
if (this.isPrivateIp(address)) {
socket.destroy(new Error(`Blocked address: ${address}`));