1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

function observe(target, options = {}) {
  const { attributeOldValue: aov, attributeFilter: af, attributes: as } = options

  // 1. 当 attributeOldValue 或 attributeFilter 有一个设置了时，自动启用 attributes 监听
  if (as === undefined && ( aov === true || af === true )) {
    options.attributes = true
  }

  // 2. 当 characterDataOldValue 设置了会自动启用 characterData 监听
  const { characterDataOldValue: cdov, characterData: cd } = options
  if (cd === undefined && cdov === true) {
    options.characterData = true
  }

  // 3. 如果 childList, attributes, characterData 一个都没启用，抛出异常
  // 即：必须要指定至少一个监听项
  const { childList: cl } = options

  if (cl === undefined && as === undefined && cd === undefined) {
    throw new TypeError('必须要指定至少一个监听项(attributes, characterData, 或 childList)')
  }

  // 4. 设置了 attributeOldValue 就必须启用 attributes 监听
  if (aov === true && as === false) {
    throw new TypeError('设置了 attributeOldValue 就必须启用 attributes 监听')
  }

  // 5. 设置了 characterDataOldValue 就必须启用 characterData 监听
  if (cdov === true && cd === false) {
    throw new TypeError('设置了 characterDataOldValue 就必须启用 characterData 监听')
  }

  // 6. 遍历 target 已经注册了的 observer list，如果 observer === this:
  // 这里可能不太对，没怎么完全理解 7 & 8
  const obList = target.observerList
  for (let i = 0; i < obList.length; i++) {
    const ob = obList[i]
    if (ob === this) {
      this.nodeList.forEach(node => {
        // 移除所有的 transient registered observers
        remove node.observers
        // 将选项设置到各个节点上
        node.options = options
      })
    } else {
      // 追加新的 observer 和 options 到 target
      this.append(new Observer())
      this.nodeList.append(target)
    }
  }
}

1
2
3
4
5
6

function disconnect() {
  // 1. 遍历 node 的 nodeList, 移除所有的 registered observer
  this.nodeList.forEach(node => remove node.registeredObserver)
  // 2. 清空 record queue
  clear node.recordQueue
}

1
2
3
4
5
6
7
8

function takeRecords() {
  // 1. 先备份队列
  let records = clone(this.recordQueue)
  // 2. 清空队列
  this.recordQueue = []
  // 3. 返回备份的队列
  return records
}