Method sendRequestAsync

psynetrpc.go:238–286

(ctx context.Context, service string, data interface{})

}

func (p *PsyNetRPC) sendRequestAsync(ctx context.Context, service string, data interface{}) (<-chan *PsyResponse, error) {
	if !p.IsConnected() {
		return nil, fmt.Errorf("websocket connection not established")
	}

	requestID := p.requestID.getID()
	p.logger.Debug("sending websocket request", slog.String("requestID", requestID), slog.String("service", service), slog.Any("data", data))

	respCh := make(chan *PsyResponse, 1)

	headers := map[string]string{
		"PsyService":   service,
		"PsyRequestID": requestID,
	}
	message, err := p.buildMessage(headers, data)
	if err != nil {
		return nil, fmt.Errorf("failed to buildm message: %w", err)
	}

	p.mu.Lock()
	if !p.connected || p.wsConn == nil {
		p.mu.Unlock()
		return nil, fmt.Errorf("connection lost while preparing to send")
	}

	p.pendingReqs[requestID] = respCh
	err = p.wsConn.WriteMessage(websocket.TextMessage, []byte(message))
	if err != nil {
		delete(p.pendingReqs, requestID)
		p.mu.Unlock()
		return nil, fmt.Errorf("failed to send request: %w", err)
	}

	p.mu.Unlock()

	go func() {
		<-ctx.Done()
		p.mu.Lock()
		ch := p.pendingReqs[requestID]
		delete(p.pendingReqs, requestID)
		p.mu.Unlock()

		if ch != nil {
			close(ch)
		}
	}()

	return respCh, nil
}

func (p *PsyNetRPC) awaitResponse(ctx context.Context, respCh <-chan *PsyResponse, result interface{}) error {
	select {