Method handleGetUserDocAccessSpan

rest/diagnostic_api.go:222–326

()

}

func (h *handler) handleGetUserDocAccessSpan() error {
	h.assertAdminOnly()
	user, err := h.db.Authenticator(h.ctx()).GetUser(internalUserName(mux.Vars(h.rq)["name"]))
	if err != nil {
		return fmt.Errorf("could not get user %s: %w", user.Name(), err)
	}
	if user == nil {
		return kNotFoundError
	}
	ks := h.PathVar("keyspace")

	docids := h.getQuery("docids")
	docidsList := strings.Split(docids, ",")
	var docList []*db.Document

	var scope, coll string
	parts := strings.Split(ks, base.ScopeCollectionSeparator)
	switch len(parts) {
	case 1:
		// if default collection, some calls using {{.keyspace}} will call /db/
		scope = "_default"
		coll = "_default"
	case 3:
		scope = parts[1]
		coll = parts[2]
	default:
		return fmt.Errorf("unable to get scope and collection from keyspace")
	}

	if err != nil {
		return err
	}

	keyspace := scope + "." + coll

	for _, docID := range docidsList {
		if docID == "" {
			return base.HTTPErrorf(http.StatusBadRequest, "empty doc id given in request")
		}
		doc, err := h.collection.GetDocument(h.ctx(), docID, db.DocUnmarshalSync)
		if doc == nil {
			return base.HTTPErrorf(http.StatusNotFound, "doc %s not found", docID)
		}
		if err != nil {
			return err
		}
		docList = append(docList, doc)
	}

	resp := make(map[string]map[string]channelHistory)
	for _, doc := range docList {
		docChannelToSeqs := populateDocChannelInfo(*doc)
		userChannels, err := h.getAllUserChannelsResponse(user)
		if err != nil {
			return err
		}

		// Only keep current keyspace