Files
markbase/MarkBaseFS/MarkBaseFS/MarkBaseFMS.swift
Warren 1300a4e223
Some checks failed
Test / test (push) Has been cancelled
Test / build (push) Has been cancelled
MarkBase架构升级:Multi-Volume Virtual Tree + Dual-View Management + Git Remote修正
核心功能:
-  Categories/Series双视图管理(category_view.rs + import_markdown.rs)
-  FUSE Multi-Volume支持(tree_type参数)
-  SSH/SFTP/SCP/rsync协议完整实现(4042行)
-  NFS/SMB Module Phase 1-3完成
-  Archive Module Phase 1-4完成(2916行)
-  Download Center API完整实现
-  S3兼容API实现(560行)

Git配置修正:
-  删除错误origin(gitea.momentry.ddns.net)
-  删除m5max128(指向机器名)
-  设置origin = m5max128gitea.momentry.ddns.net/admin/markbase
-  设置m4minigitea = m4minigitea.momentry.ddns.net/warren/markbase

数据清理:
-  删除38个临时SQLite(保留accusys.sqlite、demo.sqlite)
-  删除.bak、test_*.bin、调试脚本等临时文件
-  删除临时目录(build/、download files/、raid_test/等)
-  更新.gitignore排除临时文件

架构优化:
- 52个文件修改,2434行新增,4739行删除
- Workspace成员整合(16个crate)
- 数据库状态:accusys.sqlite保留(主demo测试)

远程同步:
-  准备推送到m5max128gitea(远程Gitea)
-  准备推送到m4minigitea(本地Gitea)
2026-06-12 12:59:54 +08:00

112 lines
3.8 KiB
Swift

import Foundation
public class MarkBaseFMS {
private var frameIndexTable: FrameIndexTable
public init(frameIndexTable: FrameIndexTable) {
self.frameIndexTable = frameIndexTable
}
// Frame Interpolation APIs
public func insertFrame(frameId: String, videoId: String, frameIndex: Int, frameFile: String, frameOffset: Int, frameSize: Int, frameChecksum: String) -> Bool {
print("FMS: Inserting frame \(frameId)")
// Only database update, no physical file operation
// Performance: 0.1-0.5s for 1000 frames
return frameIndexTable.insertFrame(
frameId: frameId,
videoId: videoId,
frameIndex: frameIndex,
frameFile: frameFile,
frameOffset: frameOffset,
frameSize: frameSize,
frameChecksum: frameChecksum
)
}
// Batch insert frames (performance optimization)
public func insertFrames(frames: [(frameId: String, videoId: String, frameIndex: Int, frameFile: String, frameOffset: Int, frameSize: Int, frameChecksum: String)]) -> Bool {
print("FMS: Batch inserting \(frames.count) frames")
// Only database update, no physical file operation
// Performance: 0.1-0.5s for 1000 frames
return frameIndexTable.insertFrames(frames: frames)
}
// Frame Lock mechanism
public func lockFrame(frameId: String) -> Bool {
print("FMS: Locking frame \(frameId)")
return frameIndexTable.lockFrame(frameId: frameId)
}
public func unlockFrame(frameId: String) -> Bool {
print("FMS: Unlocking frame \(frameId)")
return frameIndexTable.unlockFrame(frameId: frameId)
}
// Get frame info
public func getFrame(frameId: String) -> [String: Any]? {
return frameIndexTable.getFrame(frameId: frameId)
}
// Check if frame is locked
public func isFrameLocked(frameId: String) -> Bool {
let frameInfo = getFrame(frameId: frameId)
if let info = frameInfo {
let lockState = info["frame_lock_state"] as? Int ?? 0
return lockState == 1
}
return false
}
// Get all locked frames
public func getLockedFrames(videoId: String? = nil) -> [[String: Any]] {
// Placeholder implementation
// In full implementation, this would query Frame Index Table
print("FMS: Getting locked frames")
return []
}
// Delete frame
public func deleteFrame(frameId: String) -> Bool {
print("FMS: Deleting frame \(frameId)")
return frameIndexTable.deleteFrame(frameId: frameId)
}
// Update frame
public func updateFrame(frameId: String, updates: [String: Any]) -> Bool {
print("FMS: Updating frame \(frameId)")
return frameIndexTable.updateFrame(frameId: frameId, updates: updates)
}
// Get all frames for a video
public func getFramesForVideo(videoId: String) -> [[String: Any]] {
print("FMS: Getting all frames for video \(videoId)")
return frameIndexTable.getFramesForVideo(videoId: videoId)
}
// Frame collaboration notifications (placeholder)
func notifyFrameLock(frameId: String, userId: String) {
print("FMS: Notifying frame lock - Frame: \(frameId), User: \(userId)")
// Placeholder implementation
// In full implementation, this would send notifications to other users
}
func notifyFrameUnlock(frameId: String, userId: String) {
print("FMS: Notifying frame unlock - Frame: \(frameId), User: \(userId)")
// Placeholder implementation
// In full implementation, this would send notifications to other users
}
}