Method authenticate

grpc_auth.go:113–147

(r requestParser)

}

func (a *authWrapper) authenticate(r requestParser) (bool, error) {
	var authType string
	if a.mgr != nil && a.mgr.Options() != nil {
		authType = a.mgr.Options()["authType"]
	}

	if authType == "" {
		return true, nil
	}

	if authType != "cbauth" {
		return false, nil
	}

	perms, err := preparePerms(a.mgr, r, a.method, a.path)
	if err != nil {
		return false, fmt.Errorf("grpc_auth: preparePerms err: %v", err)
	}

	if len(perms) <= 0 {
		return true, nil
	}

	for _, perm := range perms {
		allowed, err := CBAuthIsAllowed(a.creds, perm)
		if err != nil {
			return false, err
		}

		if !allowed {
			return false, err
		}
	}
	return true, nil
}

// rpcRequestParser implements the requestParser interface
type rpcRequestParser struct {