New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@yume-chan/adb-server-node-tcp

Package Overview
Dependencies
Maintainers
0
Versions
10
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@yume-chan/adb-server-node-tcp - npm Package Compare versions

Comparing version 0.0.24 to 1.0.0

LICENSE

22

CHANGELOG.md
# 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_

10

esm/index.d.ts

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc