fix: nodejs push error

Author: piloking

example/node/allow_h2_for_push.ts

@@ -0,0 +1,14 @@
+import undici from "npm:undici";
+import { BaseClient } from "@evex/linejs/base";
+
+undici.setGlobalDispatcher(new undici.Agent({
+  allowH2: true
+}));
+
+//@ts-expect-error
+globalThis.Request = undici.Request;
+
+const client = new BaseClient({
+//@ts-expect-error
+    fetch: undici.fetch,
+});

packages/linejs/base/polling/mod.ts

@@ -162,10 +162,10 @@ export class Polling {
 			try {
 				cb && cb();
 				await this.client.push.InitAndRead(this.listenTarget);
-				await sleep(4);
+				await sleep(4000);
 			} catch (error) {
 				this.client.log("LegyPusherError", { error });
-				await sleep(4);
+				await sleep(4000);
 			}
 		}
 		this.islisten = false;

packages/linejs/base/push/conn.ts

@@ -222,7 +222,7 @@ export class Conn {
 			if (packet.pingType === LegyH2PingFrameType.ACK_REQUIRED) {
 				this.writeByte(packet.ackPacket());
 				this.manager.log(`[PUSH] send ping ack. pingId:${pingId}`, debugOnly);
-				this.manager.OnPingCallback(pingId);
+				this.manager.onPingCallback(pingId);
 			} else {
 				throw new Error(`ping type not Implemented: ${pingType}`);
 			}
@@ -245,7 +245,7 @@ export class Conn {
 					responsePayload = newPayload;
 					delete this.notFinPayloads[requestId];
 				}
-				this.manager.OnSignOnResponse(requestId, isFin, responsePayload);
+				this.manager.onSignOnResponse(requestId, isFin, responsePayload);
 			} else {
 				this.manager.log(
 					`[PUSH] receives long data. requestId: ${requestId}, req=${req}`,
@@ -287,7 +287,7 @@ export class Conn {
 						debugOnly,
 					);
 				}
-				this.manager.OnPushResponse(packet);
+				this.manager.onPushResponse(packet);
 			} else {
 				throw new Error(`push type not Implemented: ${pushType}`);
 			}

packages/linejs/base/push/connManager.ts

@@ -43,11 +43,11 @@ export class ConnManager {
 	conns: Conn[] = [];
 	currPingId = 0;
 	subscriptionIds: Record<number, number> = {};
-	SignOnRequests: Record<number, LooseType[]> = {};
-	OnPingCallback: (id: number) => void;
-	OnSignReqResp: Record<number, LooseType> = {};
-	OnSignOnResponse: (reqId: number, isFin: boolean, data: Uint8Array) => void;
-	OnPushResponse: (frame: LegyH2PushFrame) => void;
+	signOnRequests: Record<number, LooseType[]> = {};
+	onPingCallback: (id: number) => void;
+	onSignReqResp: Record<number, LooseType> = {};
+	onSignOnResponse: (reqId: number, isFin: boolean, data: Uint8Array) => void;
+	onPushResponse: (frame: LegyH2PushFrame) => void;
 	_eventSynced = false;
 	_pingInterval = 30;
 	authToken: string | null = null;
@@ -58,9 +58,9 @@ export class ConnManager {
 
 	constructor(base: BaseClient) {
 		this.client = base;
-		this.OnPingCallback = this._OnPingCallback.bind(this);
-		this.OnSignOnResponse = this._OnSignOnResponse.bind(this);
-		this.OnPushResponse = this._OnPushResponse.bind(this);
+		this.onPingCallback = this._OnPingCallback.bind(this);
+		this.onSignOnResponse = this._OnSignOnResponse.bind(this);
+		this.onPushResponse = this._OnPushResponse.bind(this);
 		this.opStream = this.createAsyncReadableStream<Operation>();
 		this.sqStream = this.createAsyncReadableStream<SquareEvent>();
 	}
@@ -142,6 +142,7 @@ export class ConnManager {
 		initServices = [3, 6, 8, 9, 10],
 	): Promise<Conn> {
 		const _conn = new Conn(this);
+		this.signOnRequests = {};
 		if (state === 1) {
 			this.conns[0] = _conn;
 			this.authToken = this.client.authToken!;
@@ -175,7 +176,7 @@ export class ConnManager {
 	): Promise<{ payload: Uint8Array<ArrayBuffer>; id: number; }> {
 		this.log("buildAndSendSignOnRequest", { serviceType, kwargs });
 		const cl = this.client;
-		const id = Object.keys(this.SignOnRequests).length + 1;
+		const id = Object.keys(this.signOnRequests).length + 1;
 		const idBuf = new Uint8Array(2);
 		idBuf[0] = (id >> 8) & 0xff;
 		idBuf[1] = id & 0xff;
@@ -207,7 +208,7 @@ export class ConnManager {
 		header[4] = (req.length >> 8) & 0xff;
 		header[5] = req.length & 0xff;
 		header.set(req, 6);
-		this.SignOnRequests[id] = [serviceType, methodName, null];
+		this.signOnRequests[id] = [serviceType, methodName, null];
 		this.log(
 			`[H2][PUSH] send sign-on-request. requestId:${id}, service:${serviceType}`,
 		);
@@ -222,11 +223,11 @@ export class ConnManager {
 	): Promise<false | undefined> {
 		// data = data.slice(5);
 		const cl = this.client;
-		if (!(reqId in this.SignOnRequests)) {
+		if (!(reqId in this.signOnRequests)) {
 			this.log(`[PUSH] unknown sign-on-response requestId:${reqId}`);
 			return;
 		}
-		const entry = this.SignOnRequests[reqId];
+		const entry = this.signOnRequests[reqId];
 		const serviceType: number = entry[0];
 		const methodName: string | undefined = entry[1];
 

resources/line/line.thrift

@@ -17142,3 +17142,32 @@ struct LoginResult {
     7: string displayMessage;
     8: VerificationSessionData sessionForSMSConfirm;
 }
+
+enum F61_EnumC10204a0 {
+    ALL = 0;
+    BLOCK = 1;
+    NOT_BLOCK = 2;
+}
+
+
+struct getUserFriendIds_args {
+    1: GetUserFriendIdsRequest request;
+}
+
+struct getUserFriendIds_result {
+    0: GetUserFriendIdsResponse success;
+    1: RejectedException re;
+    2: ServerFailureException sfe;
+    3: TalkException te;
+}
+
+
+struct GetUserFriendIdsRequest {
+    1: string userPageToken;
+    2: F61_EnumC10204a0 blockStatus;
+}
+
+struct GetUserFriendIdsResponse {
+    1: set<string> userFriendMids;
+    2: string nextUserPageToken;
+}