wedb_standalone 0.1.1

单机网络服务底座：RESP 协议帧、AOF 逻辑层与节点服务编排（对标 Garnet libs/server 单机半区）
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92

//! 范围索引操作辅助（对标 libs/server/Storage/Session/MainStore/RangeIndexOps.cs，C# 为 StorageSession partial）
//!
//! 缺口总述：C# 侧 RangeIndex 直接持有 BfTree 裸指针（ExtractTreePtr）并在
//! StorageSession 内做"索引 → Tail 记录"的晋升/恢复/RESP 序列化；wkv 将范围
//! 索引内置于引擎（`WedbStore::range_index` + `RangeIndexListenerFn` 回写），
//! 无裸指针与手工晋升入口。本域保留纯输出组装函数的真实实现，引擎侧两函数
//! 退化为一致性空操作并注明缺口。

use wdev::Device;

use super::super::storage_session::StorageSession;

impl<'a, D: Device> StorageSession<'a, D> {
  /// 将范围索引数据晋升为 Tail 存储记录
  ///
  /// 缺口说明：wkv 引擎内部以 `RangeIndexListenerFn` 自动把索引变更落盘，
  /// 无外部晋升入口；本方法退化为空操作（返回晋升字节数 0）。
  ///
  /// libs/server/Storage/Session/MainStore/RangeIndexOps.cs:PromoteRangeIndexToTail
  pub fn promote_range_index_to_tail(&self) -> usize {
    0
  }

  /// 从 Tail 存根恢复范围索引
  ///
  /// 缺口说明：wkv 引擎在 `WedbStore::open` 时经 `recover_shared_bftree` /
  /// RangeIndexManager 自动恢复索引存根，无外部恢复入口；本方法退化为空操作。
  ///
  /// libs/server/Storage/Session/MainStore/RangeIndexOps.cs:RestoreRangeIndexStub
  pub fn restore_range_index_stub(&self) -> bool {
    true
  }

  /// 把扫描记录按 RESP 数组元素格式写入输出缓冲
  ///
  /// libs/server/Storage/Session/MainStore/RangeIndexOps.cs:WriteScanToOutput
  pub fn write_scan_to_output(&self, output: &mut Vec<u8>, records: &[Vec<u8>]) {
    output.reserve(16 + records.iter().map(|r| r.len() + 8).sum::<usize>());
    output.push(b'*');
    output.extend_from_slice(itoa::Buffer::new().format(records.len()).as_bytes());
    output.extend_from_slice(b"\r\n");
    for record in records {
      output.push(b'$');
      output.extend_from_slice(itoa::Buffer::new().format(record.len()).as_bytes());
      output.extend_from_slice(b"\r\n");
      output.extend_from_slice(record);
      output.extend_from_slice(b"\r\n");
    }
  }

  /// 尝试将单条索引记录写成 RESP 批量字符串，返回是否写入
  ///
  /// libs/server/Storage/Session/MainStore/RangeIndexOps.cs:TryWriteRecordResp
  /// （C# 侧经 RespWriteUtils.TryWriteBulkString 落 `$<len>\r\n` 完整帧）
  pub fn try_write_record_resp(&self, output: &mut Vec<u8>, record: &[u8]) -> bool {
    if record.is_empty() {
      output.extend_from_slice(b"$-1\r\n");
      return false;
    }
    output.push(b'$');
    output.extend_from_slice(itoa::Buffer::new().format(record.len()).as_bytes());
    output.extend_from_slice(b"\r\n");
    output.extend_from_slice(record);
    output.extend_from_slice(b"\r\n");
    true
  }

  /// 回填 RESP 数组头（先占位后回填，适配长度未知流式输出）
  ///
  /// libs/server/Storage/Session/MainStore/RangeIndexOps.cs:BackfillArrayHeader
  pub fn backfill_array_header(&self, output: &mut [u8], header_pos: usize, count: usize) {
    let mut buf = itoa::Buffer::new();
    let digits = buf.format(count);
    let end = header_pos + 1 + digits.len() + 2;
    if end <= output.len() {
      output[header_pos] = b'*';
      output[header_pos + 1..header_pos + 1 + digits.len()].copy_from_slice(digits.as_bytes());
      output[end - 2..end].copy_from_slice(b"\r\n");
    }
  }

  /// 提取底层范围索引树句柄
  ///
  /// 缺口说明：C# 提取 BfTree 裸指针供扫描复用；wkv 引擎封装扫描入口
  /// （`WedbStore::scan_range_callback`）不外借树句柄，恒返回 None，
  /// 调用方应转用扫描回调路径。
  ///
  /// libs/server/Storage/Session/MainStore/RangeIndexOps.cs:ExtractTreePtr
  pub fn extract_tree_ptr(&self) -> Option<()> {
    None
  }
}