@yume-chan/adb-server-node-tcp
Advanced tools
Comparing version 0.0.24 to 1.0.0
# Change Log - @yume-chan/adb-server-node-tcp | ||
## 1.0.1 | ||
### Patch Changes | ||
- 53688d3: Use PNPM workspace and Changesets to manage the monorepo. | ||
Because Changesets doesn't support alpha versions (`0.x.x`), this version is `1.0.0`. Future versions will follow SemVer rules, for example, breaking API changes will introduce a new major version. | ||
- Updated dependencies [53688d3] | ||
- Updated dependencies [db8466f] | ||
- Updated dependencies [db8466f] | ||
- Updated dependencies [ea5002b] | ||
- Updated dependencies [db8466f] | ||
- @yume-chan/stream-extra@1.0.1 | ||
- @yume-chan/struct@1.0.1 | ||
- @yume-chan/adb@1.0.1 | ||
This log was last generated on Tue, 18 Jun 2024 02:49:43 GMT and should not be manually modified. | ||
## 0.0.24 | ||
Tue, 18 Jun 2024 02:49:43 GMT | ||
@@ -11,2 +29,3 @@ | ||
## 0.0.23 | ||
Thu, 21 Mar 2024 03:15:10 GMT | ||
@@ -17,2 +36,3 @@ | ||
## 0.0.22 | ||
Wed, 13 Dec 2023 05:57:27 GMT | ||
@@ -23,5 +43,5 @@ | ||
## 0.0.21 | ||
Fri, 25 Aug 2023 14:05:18 GMT | ||
_Initial release_ | ||
@@ -1,5 +0,7 @@ | ||
/// <reference types="node" resolution-mode="require"/> | ||
import type { SocketConnectOpts } from "net"; | ||
import type { AdbIncomingSocketHandler, AdbServerClient } from "@yume-chan/adb"; | ||
import type { ValueOrPromise } from "@yume-chan/struct"; | ||
import type { MaybePromiseLike } from "@yume-chan/async"; | ||
/** | ||
* An `AdbServerClient.ServerConnector` implementation for Node.js. | ||
*/ | ||
export declare class AdbServerNodeTcpConnector implements AdbServerClient.ServerConnector { | ||
@@ -11,5 +13,5 @@ #private; | ||
addReverseTunnel(handler: AdbIncomingSocketHandler, address?: string): Promise<string>; | ||
removeReverseTunnel(address: string): ValueOrPromise<void>; | ||
clearReverseTunnels(): ValueOrPromise<void>; | ||
removeReverseTunnel(address: string): MaybePromiseLike<void>; | ||
clearReverseTunnels(): MaybePromiseLike<void>; | ||
} | ||
//# sourceMappingURL=index.d.ts.map |
import { Server, Socket } from "net"; | ||
import { MaybeConsumable, PushReadableStream, WrapWritableStream, WritableStream, } from "@yume-chan/stream-extra"; | ||
import { MaybeConsumable, PushReadableStream, tryClose, } from "@yume-chan/stream-extra"; | ||
function nodeSocketToConnection(socket) { | ||
@@ -20,13 +20,8 @@ socket.setNoDelay(true); | ||
socket.on("end", () => { | ||
try { | ||
controller.close(); | ||
} | ||
catch (e) { | ||
// controller already closed | ||
} | ||
tryClose(controller); | ||
}); | ||
}), | ||
writable: new WritableStream({ | ||
write: async (chunk) => { | ||
await new Promise((resolve, reject) => { | ||
writable: new MaybeConsumable.WritableStream({ | ||
write: (chunk) => { | ||
return new Promise((resolve, reject) => { | ||
socket.write(chunk, (err) => { | ||
@@ -51,2 +46,5 @@ if (err) { | ||
} | ||
/** | ||
* An `AdbServerClient.ServerConnector` implementation for Node.js. | ||
*/ | ||
export class AdbServerNodeTcpConnector { | ||
@@ -78,3 +76,3 @@ spec; | ||
readable: connection.readable, | ||
writable: new WrapWritableStream(connection.writable).bePipedThroughFrom(new MaybeConsumable.UnwrapStream()), | ||
writable: connection.writable, | ||
get closed() { | ||
@@ -113,3 +111,3 @@ return connection.closed; | ||
const info = server.address(); | ||
address = `tcp:${info.address}:${info.port}`; | ||
address = `tcp:${info.port}`; | ||
} | ||
@@ -116,0 +114,0 @@ this.#listeners.set(address, server); |
{ | ||
"name": "@yume-chan/adb-server-node-tcp", | ||
"version": "0.0.24", | ||
"version": "1.0.0", | ||
"description": "ADB server connector for `@yume-chan/adb` using Node.js' `net` module", | ||
@@ -29,20 +29,20 @@ "keywords": [ | ||
"types": "esm/index.d.ts", | ||
"sideEffects": false, | ||
"dependencies": { | ||
"@yume-chan/adb": "^0.0.24", | ||
"@yume-chan/stream-extra": "^0.0.24", | ||
"@yume-chan/struct": "^0.0.24" | ||
"@yume-chan/async": "^4.0.2", | ||
"@yume-chan/adb": "^1.0.0", | ||
"@yume-chan/struct": "^1.0.0", | ||
"@yume-chan/stream-extra": "^1.0.0" | ||
}, | ||
"devDependencies": { | ||
"@types/node": "^20.14.2", | ||
"@types/node": "^22.10.0", | ||
"prettier": "^3.4.1", | ||
"typescript": "^5.7.2", | ||
"@yume-chan/eslint-config": "^1.0.0", | ||
"@yume-chan/tsconfig": "^1.0.0", | ||
"jest": "^30.0.0-alpha.4", | ||
"prettier": "^3.3.2", | ||
"typescript": "^5.4.5" | ||
"@yume-chan/tsconfig": "^1.0.0" | ||
}, | ||
"scripts": { | ||
"build": "tsc -b tsconfig.build.json", | ||
"build:watch": "tsc -b tsconfig.build.json", | ||
"lint": "run-eslint && prettier src/**/*.ts --write --tab-width 4" | ||
} | ||
} |
@@ -18,5 +18,8 @@ <p align="center"> | ||
</a> | ||
<a href="https://www.npmjs.com/package/@yume-chan/adb"> | ||
<img alt="npm" src="https://img.shields.io/npm/dm/%40yume-chan/adb?logo=npm"> | ||
<a href="https://bundlephobia.com/package/@yume-chan/adb-server-node-tcp"> | ||
<img alt="Package Size" src="https://img.shields.io/bundlephobia/minzip/%40yume-chan%2Fadb-server-node-tcp"> | ||
</a> | ||
<a href="https://www.npmjs.com/package/@yume-chan/adb-server-node-tcp"> | ||
<img alt="npm" src="https://img.shields.io/npm/dm/%40yume-chan/adb-server-node-tcp?logo=npm"> | ||
</a> | ||
<a href="https://discord.gg/26k3ttC2PN"> | ||
@@ -31,3 +34,3 @@ <img alt="Discord" src="https://img.shields.io/discord/1120215514732564502?logo=discord&logoColor=%23ffffff&label=Discord"> | ||
Check the latest documentation at https://tango-adb.github.io/docs/ | ||
Check the latest documentation at https://docs.tangoapp.dev/tango/server/ | ||
@@ -34,0 +37,0 @@ ## Sponsors |
@@ -5,9 +5,8 @@ import type { AddressInfo, SocketConnectOpts } from "net"; | ||
import type { AdbIncomingSocketHandler, AdbServerClient } from "@yume-chan/adb"; | ||
import type { MaybePromiseLike } from "@yume-chan/async"; | ||
import { | ||
MaybeConsumable, | ||
PushReadableStream, | ||
WrapWritableStream, | ||
WritableStream, | ||
tryClose, | ||
} from "@yume-chan/stream-extra"; | ||
import type { ValueOrPromise } from "@yume-chan/struct"; | ||
@@ -36,12 +35,8 @@ function nodeSocketToConnection( | ||
socket.on("end", () => { | ||
try { | ||
controller.close(); | ||
} catch (e) { | ||
// controller already closed | ||
} | ||
tryClose(controller); | ||
}); | ||
}), | ||
writable: new WritableStream<Uint8Array>({ | ||
write: async (chunk) => { | ||
await new Promise<void>((resolve, reject) => { | ||
writable: new MaybeConsumable.WritableStream<Uint8Array>({ | ||
write: (chunk) => { | ||
return new Promise<void>((resolve, reject) => { | ||
socket.write(chunk, (err) => { | ||
@@ -66,2 +61,5 @@ if (err) { | ||
/** | ||
* An `AdbServerClient.ServerConnector` implementation for Node.js. | ||
*/ | ||
export class AdbServerNodeTcpConnector | ||
@@ -104,5 +102,3 @@ implements AdbServerClient.ServerConnector | ||
readable: connection.readable, | ||
writable: new WrapWritableStream( | ||
connection.writable, | ||
).bePipedThroughFrom(new MaybeConsumable.UnwrapStream()), | ||
writable: connection.writable, | ||
get closed() { | ||
@@ -140,3 +136,3 @@ return connection.closed; | ||
const info = server.address() as AddressInfo; | ||
address = `tcp:${info.address}:${info.port}`; | ||
address = `tcp:${info.port}`; | ||
} | ||
@@ -148,3 +144,3 @@ | ||
removeReverseTunnel(address: string): ValueOrPromise<void> { | ||
removeReverseTunnel(address: string): MaybePromiseLike<void> { | ||
const server = this.#listeners.get(address); | ||
@@ -158,3 +154,3 @@ if (!server) { | ||
clearReverseTunnels(): ValueOrPromise<void> { | ||
clearReverseTunnels(): MaybePromiseLike<void> { | ||
for (const server of this.#listeners.values()) { | ||
@@ -161,0 +157,0 @@ server.close(); |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
75195
5
0
50
4
300
+ Added@yume-chan/async@^4.0.2
+ Added@yume-chan/adb@1.1.0(transitive)
+ Added@yume-chan/async@4.0.2(transitive)
+ Added@yume-chan/event@1.0.0(transitive)
+ Added@yume-chan/no-data-view@1.0.0(transitive)
+ Added@yume-chan/stream-extra@1.0.0(transitive)
+ Added@yume-chan/struct@1.0.0(transitive)
- Removed@yume-chan/adb@0.0.24(transitive)
- Removed@yume-chan/async@2.2.0(transitive)
- Removed@yume-chan/event@0.0.24(transitive)
- Removed@yume-chan/no-data-view@0.0.24(transitive)
- Removed@yume-chan/stream-extra@0.0.24(transitive)
- Removed@yume-chan/struct@0.0.24(transitive)
- Removedtslib@2.8.1(transitive)
Updated@yume-chan/adb@^1.0.0
Updated@yume-chan/struct@^1.0.0