Method handleAPIRequestClientSocketMessage

keyserver/src/socket/socket.js:572–590

(
    message: APIRequestClientSocketMessage,
  )

  }

  async handleAPIRequestClientSocketMessage(
    message: APIRequestClientSocketMessage,
  ): Promise<ServerServerSocketMessage[]> {
    if (!endpointIsSocketSafe(message.payload.endpoint)) {
      throw new ServerError('endpoint_unsafe_for_socket');
    }
    const { viewer } = this;
    invariant(viewer, 'should be set');
    const responder = jsonEndpoints[message.payload.endpoint];
    await policiesValidator(viewer, responder.requiredPolicies);
    const response = await responder.responder(viewer, message.payload.input);
    return [
      {
        type: serverSocketMessageTypes.API_RESPONSE,
        responseTo: message.id,
        payload: response,
      },
    ];
  }

  onRedisMessage = async (message: RedisMessage) => {
    try {