Flutter对接Firebase Realtime Database 用户故事页筛选失效问题排查

问题根因 #

• 核心失效原因：未为Realtime Database查询配置索引
  Firebase Realtime Database 执行orderBy="creatorId"类字段查询时，必须提前在数据库规则中为目标字段建立索引。未配置索引时，Firebase 会直接忽略所有过滤参数，返回story节点全量数据，且默认不会向前端抛出可捕获的查询错误，最终导致筛选逻辑完全不生效。
• 请求地址拼写错误
  代码中拼接的数据库请求域名存在多连字符、冗余点号的格式问题，可能导致请求未正确携带查询参数，直接拉取全量数据。
• 状态管理未做数据集隔离
  全局共享的_storys列表未区分“公共全量故事”和“当前用户自有故事”，调用筛选接口时会直接覆盖全局列表。同时编辑、删除操作未做创建者身份校验，导致可跨用户操作其他账号的故事内容。

修复步骤 #

• 第一步：配置数据库规则与索引
  更新Firebase Realtime Database 规则，添加creatorId字段索引，同时在数据层增加权限校验，拦截非创建者的编辑、删除操作：

  {
    "rules": {
      "story": {
        ".indexOn": ["creatorId"],
        ".read": "auth != null",
        "$storyId": {
          ".write": "auth != null && data.child('creatorId').val() == auth.uid"
        }
      },
      "userFavorites": {
        "$userId": {
          ".read": "auth != null && auth.uid == $userId",
          ".write": "auth != null && auth.uid == $userId"
        }
      }
    }
  }
  

• 第二步：修正请求URL格式
  去掉域名中多余的连字符、拼写错误的点号，保证请求地址格式正确：

  // 修正前错误地址
  // 'https://unified-adviser--#####..firebaseio.com/story.json?auth=$authToken&$filterString'
  // 修正后正确地址
  var url = 'https://unified-adviser-#####.firebaseio.com/story.json?auth=$authToken&$filterString';
  

• 第三步：优化状态管理逻辑
  调整Stories类结构，新增独立的用户自有故事存储字段，避免和公共全量故事数据互相覆盖：

  class Stories with ChangeNotifier {
    // 存储公共全量故事列表
    List<Story> _storys = [];
    // 存储当前登录用户的自有故事列表
    List<Story> _userOwnStories = [];
  
    final String authToken;
    final String userId;
    Stories(this.authToken, this.userId, this._storys);
  
    // 新增用户自有故事的访问入口
    List<Story> get userOwnStories => [..._userOwnStories];
  
    // 原有公共故事相关访问入口保持不变
    List<Story> get storys => [..._storys];
    List<Story> get favoriteItems => _storys.where((item) => item.isFavorite).toList();
    Story findById(String id) => _storys.firstWhere((story) => story.id == id);
  
    Future<void> fetchAndSetProducts([bool filterByUser = false]) async {
      final filterString = filterByUser ? 'orderBy="creatorId"&equalTo="$userId"' : '';
      var url = 'https://unified-adviser-#####.firebaseio.com/story.json?auth=$authToken&$filterString';
      try {
        final response = await http.get(url);
        final extractedData = json.decode(response.body) as Map<String, dynamic>;
        if (extractedData == null) {
          // 拉取空数据时清空对应数据集
          if(filterByUser) {
            _userOwnStories = [];
          } else {
            _storys = [];
          }
          notifyListeners();
          return;
        }
        url = 'https://unified-adviser-#####.firebaseio.com/userFavorites/$userId.json?auth=$authToken';
        final favoriteResponse = await http.get(url);
        final favoriteData = json.decode(favoriteResponse.body);
        final List<Story> loadedProducts = [];
        extractedData.forEach((prodId, prodData) {
          loadedProducts.add(Story(
            id: prodId,
            title: prodData['title'],
            story: prodData['story'],
            isFavorite: favoriteData == null ? false : favoriteData[prodId] ?? false,
            img: prodData['img'],
          ));
        });
        // 根据是否筛选用户数据，存入对应数据集，避免互相覆盖
        if(filterByUser) {
          _userOwnStories = loadedProducts;
        } else {
          _storys = loadedProducts;
        }
        notifyListeners();
      } catch (error) {
        throw (error);
      }
    }
  }
  

• 第四步：调整UserStory页面的数据源
  替换页面中读取的全局故事列表为用户自有故事列表，保证页面只渲染当前用户创建的内容：

  // 原错误数据源
  // itemCount: productsData.storys.length,
  // 替换为用户自有故事列表
  itemCount: productsData.userOwnStories.length,
  itemBuilder: (_, i) => Column(
    children: [
      UserStoryItem(
        productsData.userOwnStories[i].id,
        productsData.userOwnStories[i].title,
        productsData.userOwnStories[i].img,
      ),
      Divider(),
    ],
  ),
  

内容的提问来源于stack exchange，提问作者M Mela