Method handleData

src/shared/services/tooling_daemon.ts:105–152

(data: string)

	}

	private async handleData(data: string) {
		this.logTraffic(`<== ${data}\n`);
		const json = JSON.parse(data) as DtdMessage;
		const id = json.id;
		const method = json.method;

		if (method === "streamNotify") {
			const notification = json as DtdNotification;
			this.notificationsEmitters[notification.params?.streamId]?.fire(notification.params.eventKind, notification.params.eventData);

		} else if (id !== undefined && method) {
			const request = json as DtdRequest;
			// Handle service request.
			const serviceHandler = this.serviceHandlers[method];
			if (serviceHandler) {
				try {
					const result = await serviceHandler(request.params);
					this.send({
						id,
						jsonrpc: "2.0",
						result,
					});
				} catch (e: unknown) {
					const error = this.asDtdError(e);
					this.logger.error(`Failed handling service request ${method}: ${error.message}`);
					this.send({
						id,
						jsonrpc: "2.0",
						error,
					});
				}
			}

		} else if (id) {
			// Handle response.
			const completer: PromiseCompleter<DtdResult> = this.completers[id];
			const response = json as DtdResponse;

			if (completer) {
				delete this.completers[id];

				if ("error" in response)
					completer.reject(response.error);
				else
					completer.resolve(response.result);
			}
		}
	}

	public onNotification(stream: string, eventKind: string, listener: (e: any) => any, thisArgs?: any): IAmDisposable {
		if (!this.notificationsEmitters[stream])