管理员休息 - 实施 aor-realtime

Question

我很难理解如何实现 aor-realtime（尝试将它与 firebase 一起使用；只能读取，不能写入）。

我卡住的第一个地方：这个库生成了一个传奇，对吧？如何将其与 restClient/resource 连接？我有一些自定义 sagas 会提醒我错误，但有一个主要的 restClient/resource 支持这些。那些传奇只是处理一些副作用。在这种情况下，我只是不明白客户端的角色是什么，以及它如何与生成的 saga 交互（反之亦然）

另一个问题是关于持久性的：更新流并没有一次性加载初始记录集。每次更新我都应该打电话给observer.next()吗？或者缓存更新的记录并调用 next() 与整个集合到日期。

这是我目前的尝试，但我仍然不知道如何将它连接到我的管理员/资源。

import realtimeSaga from 'aor-realtime';
import { client, getToken } from '../firebase';
import { union } from 'lodash'

let cachedToken 
const observeRequest = path => (type, resource, params) => {
    // Filtering so that only chats are updated in real time
    if (resource !== 'chat') return;

    let results = {}
    let ids = []

    return {
        subscribe(observer) {
            let databaseRef = client.database().ref(path).orderByChild('at')

            let events = [ 'child_added', 'child_changed' ]

            events.forEach(e => {
                databaseRef.on(e, ({ key, val }) => {
                    results[key] = val()
                    ids = union([ key ], ids)
                    observer.next(ids.map(id => results[id]))
                })  
            })          
            const subscription = {
                unsubscribe() {
                    // Clean up after ourselves
                    databaseRef.off()
                    results = {}
                    ids = []
                    // Notify the saga that we cleaned up everything
                    observer.complete();
                }
            };

            return subscription;
        },
    };
};

export default path => realtimeSaga(observeRequest(path));

Answer 1

如何将它与 restClient/resource 连接起来？

只需将创建的 saga 添加到您的 Admin 组件的 custom sagas 即可。

关于 restClient，如果您在观察者中需要它，然后将返回观察者的函数传递给它，就像您对 path 所做的那样。这实际上是在readme 中完成的。

我应该在每次更新时调用observer.next() 吗？或者缓存更新的记录并调用 next() 与整个集合到日期。

这取决于 type 参数，它是 admin-on-rest 提取类型之一：

• CRUD_GET_LIST：你应该返回整个集合，更新
• CRUD_GET_ONE: 你应该返回 params 中指定的资源（应该包含它的 id）

Answer 2

这是我在@gildas 的指导下提出的解决方案：

import realtimeSaga from "aor-realtime";
import { client } from "../../../clients/firebase";
import { union } from "lodash";
const observeRequest = path => {      
  return (type, resource, params) => {
    // Filtering so that only chats are updated in real time
    if (resource !== "chats") return;

    let results = {}
    let ids = []

    const updateItem = res => {
      results[res.key] = { ...res.val(), id: res.key }
      ids = Object.keys(results).sort((a, b) => results[b].at - results[a].at)
    }

    return {
      subscribe(observer) {
        const { page, perPage } = params.pagination
        const offset = perPage * (page - 1)

        const databaseRef = client
            .database()
            .ref(path)
            .orderByChild("at")
            .limitToLast(offset + perPage)

        const notify = () => observer.next({ data: ids.slice(offset, offset + perPage).map(e => results[e]), total: ids.length + 1 })

        databaseRef.once('value', snapshot => {
          snapshot.forEach(updateItem)
          notify()
        })

        databaseRef.on('child_changed', res => {
          updateItem(res)
          notify()    
        })


        const subscription = {
          unsubscribe() {
            // Clean up after ourselves
            databaseRef.off();
            // Notify the saga that we cleaned up everything
            observer.complete();
          }
        };

        return subscription;
      }
    };
  }
};

export default path => realtimeSaga(observeRequest(path));