// src/core/observer/index.js
class Observer {
  constructor(value) {
    this.value = value
    this.dep = new Dep() // 給對(duì)象/數(shù)組本身創(chuàng)建Dep
    def(value, '__ob__', this) // 給數(shù)據(jù)添加__ob__屬性，標(biāo)記為響應(yīng)式
    
    if (Array.isArray(value)) {
      // 處理數(shù)組的響應(yīng)式（重寫(xiě)push/pop等方法）
      this.observeArray(value)
    } else {
      // 處理對(duì)象的響應(yīng)式：遍歷屬性并定義get/set
      this.walk(value)
    }
  }

  // 遍歷對(duì)象屬性，定義響應(yīng)式
  walk(obj) {
    const keys = Object.keys(obj)
    for (let i = 0; i < keys.length; i++) {
      defineReactive(obj, keys[i])
    }
  }

  // 遍歷數(shù)組，給每個(gè)元素做響應(yīng)式處理
  observeArray(items) {
    for (let i = 0, l = items.length; i < l; i++) {
      observe(items[i])
    }
  }
}

// 核心：給單個(gè)屬性定義get/set
export function defineReactive(
  obj,
  key,
  val,
  customSetter,
  shallow
) {
  // 每個(gè)響應(yīng)式屬性都有一個(gè)專屬的Dep實(shí)例
  const dep = new Dep()

  const property = Object.getOwnPropertyDescriptor(obj, key)
  if (property && property.configurable === false) {
    return
  }

  // 保留原有的get/set
  const getter = property && property.get
  const setter = property && property.set

  // 遞歸處理子屬性，保證深層數(shù)據(jù)也是響應(yīng)式
  let childOb = !shallow && observe(val)

  // 定義新的getter/setter
  Object.defineProperty(obj, key, {
    enumerable: true,
    configurable: true,
    // 讀取屬性時(shí)觸發(fā)：依賴收集的入口
    get: function reactiveGetter() {
      const value = getter ? getter.call(obj) : val
      
      // 關(guān)鍵：如果當(dāng)前有活躍的Watcher，就收集依賴
      if (Dep.target) {
        dep.depend() // 1. 讓Dep記錄當(dāng)前Watcher
        if (childOb) {
          // 2. 給對(duì)象/數(shù)組本身也收集依賴（處理數(shù)組/對(duì)象整體變更）
          childOb.dep.depend()
          if (Array.isArray(value)) {
            // 3. 數(shù)組特殊處理：遍歷子元素收集依賴
            dependArray(value)
          }
        }
      }
      return value
    },
    // 修改屬性時(shí)觸發(fā)：通知依賴更新
    set: function reactiveSetter(newVal) {
      const value = getter ? getter.call(obj) : val
      // 新舊值相同則不處理
      if (newVal === value || (newVal !== newVal && value !== value)) {
        return
      }
      
      if (setter) {
        setter.call(obj, newVal)
      } else {
        val = newVal
      }
      // 新值也要做響應(yīng)式處理
      childOb = !shallow && observe(newVal)
      // 關(guān)鍵：通知所有依賴更新
      dep.notify()
    }
  })
}

// src/core/observer/dep.js
export default class Dep {
  static target: ?Watcher; // 靜態(tài)屬性，存儲(chǔ)當(dāng)前活躍的Watcher
  id: number; // 唯一標(biāo)識(shí)
  subs: Array<Watcher>; // 存儲(chǔ)依賴的Watcher數(shù)組

  constructor() {
    this.id = uid++
    this.subs = []
  }

  // 添加一個(gè)Watcher到依賴列表
  addSub(sub: Watcher) {
    this.subs.push(sub)
  }

  // 移除一個(gè)Watcher
  removeSub(sub: Watcher) {
    remove(this.subs, sub)
  }

  // 核心：收集依賴（讓Dep和Watcher互相記錄）
  depend() {
    if (Dep.target) {
      // 調(diào)用當(dāng)前Watcher的addDep方法，雙向綁定
      Dep.target.addDep(this)
    }
  }

  // 核心：通知所有Watcher更新
  notify() {
    // 復(fù)制一份依賴列表，避免更新過(guò)程中列表變化
    const subs = this.subs.slice()
    for (let i = 0, l = subs.length; i < l; i++) {
      // 調(diào)用Watcher的update方法
      subs[i].update()
    }
  }
}

// 全局唯一的Dep.target棧（處理嵌套Watcher，比如computed嵌套）
Dep.target = null
const targetStack = []

// 入棧：設(shè)置當(dāng)前活躍的Watcher
export function pushTarget(target: ?Watcher) {
  targetStack.push(target)
  Dep.target = target
}

// 出棧：恢復(fù)上一個(gè)Watcher
export function popTarget() {
  targetStack.pop()
  Dep.target = targetStack[targetStack.length - 1]
}

// src/core/observer/watcher.js
export default class Watcher {
  constructor(
    vm: Component,
    expOrFn: string | Function,
    cb: Function,
    options?: ?Object,
    isRenderWatcher?: boolean
  ) {
    this.vm = vm
    if (isRenderWatcher) {
      vm._watcher = this
    }
    vm._watchers.push(this)
    
    // 處理配置項(xiàng)（比如lazy、deep、sync）
    if (options) {
      this.lazy = !!options.lazy // computed用
      this.deep = !!options.deep // 深度監(jiān)聽(tīng)用
      this.sync = !!options.sync // 同步更新用
    } else {
      this.lazy = this.deep = this.sync = false
    }
    
    this.cb = cb // 更新回調(diào)
    this.id = uid++ // 唯一標(biāo)識(shí)
    this.deps = [] // 存儲(chǔ)當(dāng)前Watcher依賴的Dep
    this.newDeps = [] // 臨時(shí)存儲(chǔ)新依賴（用于依賴清理）
    this.depIds = new Set() // 去重
    this.newDepIds = new Set()
    
    // 解析表達(dá)式/函數(shù)，得到最終要執(zhí)行的函數(shù)
    this.getter = typeof expOrFn === 'function' ? expOrFn : parsePath(expOrFn)
    
    // 非lazy模式（比如render、watch）立即執(zhí)行g(shù)et，觸發(fā)依賴收集
    this.value = this.lazy ? undefined : this.get()
  }

  // 核心：執(zhí)行g(shù)etter并收集依賴
  get() {
    // 1. 將當(dāng)前Watcher入棧，設(shè)置為Dep.target
    pushTarget(this)
    let value
    const vm = this.vm
    try {
      // 2. 執(zhí)行g(shù)etter（比如render函數(shù)），觸發(fā)數(shù)據(jù)的getter
      // 此時(shí)數(shù)據(jù)的getter會(huì)檢測(cè)到Dep.target，從而收集當(dāng)前Watcher
      value = this.getter.call(vm, vm)
    } catch (e) {
      // 錯(cuò)誤處理
    } finally {
      // 3. 深度監(jiān)聽(tīng)處理
      if (this.deep) {
        traverse(value)
      }
      // 4. 出棧，恢復(fù)Dep.target
      popTarget()
      // 5. 清理無(wú)用的依賴
      this.cleanupDeps()
    }
    return value
  }

  // 核心：添加Dep到Watcher（與Dep.depend()配合）
  addDep(dep: Dep) {
    const id = dep.id
    // 避免重復(fù)收集
    if (!this.newDepIds.has(id)) {
      this.newDepIds.add(id)
      this.newDeps.push(dep)
      if (!this.depIds.has(id)) {
        // 讓Dep也記錄當(dāng)前Watcher
        dep.addSub(this)
      }
    }
  }

  // 清理無(wú)用依賴（比如數(shù)據(jù)從視圖中移除后，不再監(jiān)聽(tīng)）
  cleanupDeps() {
    // 省略清理邏輯...
  }

  // 核心：響應(yīng)式數(shù)據(jù)更新時(shí)，觸發(fā)Watcher更新
  update() {
    if (this.lazy) {
      // computed：標(biāo)記為臟值，下次訪問(wèn)時(shí)重新計(jì)算
      this.dirty = true
    } else if (this.sync) {
      // 同步更新：立即執(zhí)行run
      this.run()
    } else {
      // 異步更新（Vue默認(rèn)）：加入隊(duì)列，批量更新
      queueWatcher(this)
    }
  }

  // 執(zhí)行g(shù)etter并觸發(fā)回調(diào)
  run() {
    const value = this.get()
    if (value !== this.value || this.deep) {
      const oldValue = this.value
      this.value = value
      // 執(zhí)行回調(diào)（比如watch的回調(diào)函數(shù)）
      this.cb.call(this.vm, value, oldValue)
    }
  }

  // computed專用：計(jì)算并返回最新值
  evaluate() {
    this.value = this.get()
    this.dirty = false
  }

  // 重新收集依賴
  depend() {
    let i = this.deps.length
    while (i--) {
      this.deps[i].depend()
    }
  }
}

// src/core/observer/array.js
const arrayProto = Array.prototype
export const arrayMethods = Object.create(arrayProto)

// 重寫(xiě)的7個(gè)方法
const methodsToPatch = [
  'push',
  'pop',
  'shift',
  'unshift',
  'splice',
  'sort',
  'reverse'
]

methodsToPatch.forEach(function (method) {
  // 保留原方法
  const original = arrayProto[method]
  def(arrayMethods, method, function mutator(...args) {
    // 執(zhí)行原方法
    const result = original.apply(this, args)
    // 獲取數(shù)組的__ob__（Observer實(shí)例）
    const ob = this.__ob__
    // 處理新增元素（push/unshift/splice），轉(zhuǎn)為響應(yīng)式
    let inserted
    switch (method) {
      case 'push':
      case 'unshift':
        inserted = args
        break
      case 'splice':
        inserted = args.slice(2)
        break
    }
    if (inserted) ob.observeArray(inserted)
    // 關(guān)鍵：通知依賴更新
    ob.dep.notify()
    return result
  })
})

// src/core/instance/state.js
function createComputedGetter(key) {
  return function computedGetter() {
    const watcher = this._computedWatchers && this._computedWatchers[key]
    if (watcher) {
      if (watcher.dirty) {
        // 只有臟值時(shí)才重新計(jì)算
        watcher.evaluate()
      }
      // 收集渲染W(wǎng)atcher到computed的依賴中
      if (Dep.target) {
        watcher.depend()
      }
      return watcher.value
    }
  }
}