Update metadata structure

This commit is contained in:
Will Miao
2025-01-25 22:19:32 +08:00
parent 1100363427
commit 9d64ebc5d6
4 changed files with 100 additions and 155 deletions

172
nodes.py
View File

@@ -1,4 +1,3 @@
# nodes.py 更新后的核心代码
import os import os
import json import json
import time import time
@@ -22,6 +21,8 @@ class LorasEndpoint:
) )
# 配置Loras根目录根据实际安装位置调整 # 配置Loras根目录根据实际安装位置调整
self.loras_root = os.path.join(Path(__file__).parents[2], "models", "loras") self.loras_root = os.path.join(Path(__file__).parents[2], "models", "loras")
# 添加 server 属性
self.server = PromptServer.instance
@classmethod @classmethod
def add_routes(cls): def add_routes(cls):
@@ -37,109 +38,45 @@ class LorasEndpoint:
def send_progress(self, current, total, status="Scanning"): def send_progress(self, current, total, status="Scanning"):
"""Send progress through websocket""" """Send progress through websocket"""
if self.server and hasattr(self.server, 'send_sync'): try:
self.server.send_sync("lora-scan-progress", { if hasattr(self.server, 'send_sync'):
"value": current, self.server.send_sync("lora-scan-progress", {
"max": total, "value": current,
"status": status "max": total,
}) "status": status
})
except Exception as e:
print(f"Error sending progress: {str(e)}")
async def scan_loras(self): async def scan_loras(self):
"""扫描Loras目录并返回结构化数据"""
loras = [] loras = []
folders = set()
# 遍历Loras目录包含子目录
for root, _, files in os.walk(self.loras_root): for root, _, files in os.walk(self.loras_root):
rel_path = os.path.relpath(root, self.loras_root) safetensors_files = [f for f in files if f.endswith('.safetensors')]
if rel_path == ".": total_files = len(safetensors_files)
current_folder = "root"
else: for idx, filename in enumerate(safetensors_files, 1):
current_folder = rel_path.replace(os.sep, "/") self.send_progress(idx, total_files, f"Scanning: {filename}")
folders.add(current_folder)
for file in files:
safetensors_files = [f for f in files if f.endswith('.safetensors')]
total_files = len(safetensors_files)
# 识别模型文件 file_path = os.path.join(root, filename)
if file.endswith('.safetensors'):
base_name = os.path.splitext(file)[0] # Try to load existing metadata first
model_path = os.path.join(root, file) metadata = await load_metadata(file_path)
# Get basic file info and metadata if metadata is None:
file_info = await get_file_info(model_path) # Only get file info and extract metadata if no existing metadata
base_model_info = await extract_lora_metadata(model_path) metadata = await get_file_info(file_path)
file_info.update(base_model_info) base_model_info = await extract_lora_metadata(file_path)
metadata.base_model = base_model_info['base_model']
# Load existing metadata or create new one await save_metadata(file_path, metadata)
metadata = await load_metadata(model_path)
if not metadata: # Convert to dict for API response
# First time scanning this file lora_data = metadata.to_dict()
await save_metadata(model_path, file_info)
metadata = file_info loras.append(lora_data)
else:
# Update basic file info in existing metadata
metadata.update(file_info)
await save_metadata(model_path, metadata)
# Add civitai data to return value if exists
if 'civitai' in metadata:
metadata.update(metadata['civitai'])
# 查找预览图
preview_path = os.path.join(root, f"{base_name}.preview.png")
preview_url = await self.get_preview_url(preview_path, root) if os.path.exists(preview_path) else None
loras.append({
"name": base_name,
"folder": current_folder,
"path": model_path,
"preview_url": preview_url,
"metadata": metadata,
"size": os.path.getsize(model_path),
"modified": os.path.getmtime(model_path)
})
self.send_progress(total_files, total_files, "Scan completed") self.send_progress(total_files, total_files, "Scan completed")
return { return loras
"loras": sorted(loras, key=lambda x: x["name"].lower()),
"folders": sorted(folders)
}
async def parse_model_metadata(self, file_path):
"""从safetensors文件中提取元数据"""
try:
with safe_open(file_path, framework="pt", device="cpu") as f:
metadata = f.metadata()
if metadata:
return metadata
except Exception as e:
print(f"Error reading metadata from {file_path}: {str(e)}")
return {}
async def parse_metadata(self, meta_file):
"""解析元数据文件"""
try:
if os.path.exists(meta_file):
with open(meta_file, 'r', encoding='utf-8') as f:
meta = json.load(f)
return {
"id": meta.get("id"),
"modelId": meta.get("modelId"),
"model": meta.get("model", {}).get("name"),
"base_model": meta.get("baseModel"),
"trained_words": meta.get("trainedWords", []),
"creator": meta.get("creator", {}).get("username"),
"downloads": meta.get("stats", {}).get("downloadCount", 0),
"images": [img["url"] for img in meta.get("images", [])[:3]],
"description": self.clean_description(
meta.get("model", {}).get("description", "")
)
}
except Exception as e:
print(f"Error parsing metadata {meta_file}: {str(e)}")
return {}
def clean_description(self, desc): def clean_description(self, desc):
"""清理HTML格式的描述""" """清理HTML格式的描述"""
@@ -157,10 +94,10 @@ class LorasEndpoint:
try: try:
scan_start = time.time() scan_start = time.time()
data = await self.scan_loras() data = await self.scan_loras()
print(f"Scanned {len(data['loras'])} loras in {time.time()-scan_start:.2f}s") print(f"Scanned {len(data)} loras in {time.time()-scan_start:.2f}s")
# Format the data for the template # Format the data for the template
formatted_loras = [self.format_lora(l) for l in data["loras"]] formatted_loras = [self.format_lora(l) for l in data]
# Debug logging # Debug logging
if formatted_loras: if formatted_loras:
@@ -169,17 +106,13 @@ class LorasEndpoint:
print("Warning: No loras found") print("Warning: No loras found")
context = { context = {
"folders": data.get("folders", []),
"loras": formatted_loras, "loras": formatted_loras,
# Only set single lora if we're viewing details # Only set single lora if we're viewing details
"lora": formatted_loras[0] if formatted_loras else { "lora": formatted_loras[0] if formatted_loras else {
"name": "", "model_name": "",
"folder": "",
"file_name": "", "file_name": "",
"preview_url": "", "preview_url": "",
"modified": "", "civitai": {
"size": "0MB",
"meta": {
"id": "", "id": "",
"model": "", "model": "",
"base_model": "", "base_model": "",
@@ -211,37 +144,20 @@ class LorasEndpoint:
def format_lora(self, lora): def format_lora(self, lora):
"""格式化前端需要的数据结构""" """格式化前端需要的数据结构"""
try: try:
metadata = lora.get("metadata", {})
return { return {
"name": lora["name"], "model_name": lora["model_name"],
"folder": lora["folder"], "file_name": lora["file_name"],
"preview_url": lora["preview_url"], "preview_url": lora["preview_url"],
"modified": time.strftime("%Y-%m-%d %H:%M", "civitai": lora.get("civitai", {}) or {} # 确保当 civitai 为 None 时返回空字典
time.localtime(lora["modified"])),
"size": f"{lora['size']/1024/1024:.1f}MB",
"meta": {
"id": metadata.get("id", ""),
"modelId": metadata.get("modelId", ""),
"model": metadata.get("model", ""),
"base_model": metadata.get("base_model", ""),
"trained_words": metadata.get("trained_words", []),
"creator": metadata.get("creator", ""),
"downloads": metadata.get("downloads", 0),
"images": metadata.get("images", []),
"description": metadata.get("description", "")
}
} }
except Exception as e: except Exception as e:
print(f"Error formatting lora: {str(e)}") print(f"Error formatting lora: {str(e)}")
print(f"Lora data: {lora}") print(f"Lora data: {lora}")
return { return {
"name": lora.get("name", "Unknown"), "model_name": lora.get("model_name", "Unknown"),
"folder": lora.get("folder", ""), "file_name": lora.get("file_name", ""),
"preview_url": lora.get("preview_url", ""), "preview_url": lora.get("preview_url", ""),
"modified": "", "civitai": {
"size": "0MB",
"meta": {
"id": "", "id": "",
"modelId": "", "modelId": "",
"model": "", "model": "",

View File

@@ -173,10 +173,23 @@ document.addEventListener('DOMContentLoaded', function() {
const progressBar = document.querySelector('.progress-bar'); const progressBar = document.querySelector('.progress-bar');
const loadingStatus = document.querySelector('.loading-status'); const loadingStatus = document.querySelector('.loading-status');
// Show loading overlay initially // 默认隐藏 loading overlay
loadingOverlay.style.display = 'flex'; loadingOverlay.style.display = 'none';
const api = new EventTarget();
window.api = api;
const ws = new WebSocket(`ws://${window.location.host}/ws`);
ws.onmessage = function(event) {
const data = JSON.parse(event.data);
if (data.type === 'lora-scan-progress') {
// 当收到扫描进度消息时显示 overlay
loadingOverlay.style.display = 'flex';
api.dispatchEvent(new CustomEvent('lora-scan-progress', { detail: data }));
}
};
// Listen for progress updates
api.addEventListener("lora-scan-progress", (event) => { api.addEventListener("lora-scan-progress", (event) => {
const data = event.detail; const data = event.detail;
const progress = (data.value / data.max) * 100; const progress = (data.value / data.max) * 100;
@@ -186,9 +199,12 @@ document.addEventListener('DOMContentLoaded', function() {
loadingStatus.textContent = data.status; loadingStatus.textContent = data.status;
if (data.value === data.max) { if (data.value === data.max) {
// Hide loading overlay when scan is complete // 确保在扫描完成时隐藏 overlay
setTimeout(() => { setTimeout(() => {
loadingOverlay.style.display = 'none'; loadingOverlay.style.display = 'none';
// 重置进度条
progressBar.style.width = '0%';
progressBar.setAttribute('aria-valuenow', 0);
}, 500); }, 500);
} }
}); });

View File

@@ -14,6 +14,15 @@
<!-- 添加模态窗口 --> <!-- 添加模态窗口 -->
<div id="loraModal" class="modal"></div> <div id="loraModal" class="modal"></div>
<div id="loading-overlay" class="loading-overlay" style="display: none;">
<div class="loading-content">
<div class="loading-spinner"></div>
<div class="loading-status">Scanning Loras...</div>
<div class="progress-container">
<div class="progress-bar" role="progressbar" aria-valuenow="0" aria-valuemin="0" aria-valuemax="100"></div>
</div>
</div>
</div>
<div class="container"> <div class="container">
<!-- 控制栏 --> <!-- 控制栏 -->
@@ -39,34 +48,33 @@
<div class="card-grid" id="loraGrid"> <div class="card-grid" id="loraGrid">
{% for lora in loras %} {% for lora in loras %}
<!-- 在卡片部分更新元数据展示 --> <!-- 在卡片部分更新元数据展示 -->
<div class="lora-card" data-folder="{{ lora.folder }}" data-name="{{ lora.name }}" data-date="{{ lora.modified }}" <div class="lora-card" data-name="{{ lora.model_name }}" data-file_name="{{ lora.file_name }}" data-meta="{{ lora.civitai | default({}) | tojson | forceescape }}">
data-size="{{ lora.size }}" data-meta="{{ lora.meta | default({}) | tojson | forceescape }}">
<div class="card-preview"> <div class="card-preview">
<img src="{{ lora.preview_url or '/loras_static/images/no-preview.png' }}" alt="{{ lora.name }}"> <img src="{{ lora.preview_url or '/loras_static/images/no-preview.png' }}" alt="{{ lora.name }}">
<div class="card-header"> <div class="card-header">
<span class="base-model-label" title="{{ lora.meta.base_model if lora.meta else 'Unknown' }}"> <span class="base-model-label" title="{{ lora.base_model }}">
{{ lora.meta.base_model if lora.meta and lora.meta.base_model else 'Unknown' }} {{ lora.base_model }}
</span> </span>
<div class="card-actions"> <div class="card-actions">
<i class="fas fa-globe" <i class="fas fa-globe"
title="View on Civitai" title="View on Civitai"
onclick="event.stopPropagation(); openCivitai('{{ lora.name }}')"></i> onclick="event.stopPropagation(); openCivitai('{{ lora.file_name }}')"></i>
<i class="fas fa-copy" <i class="fas fa-copy"
title="Copy Model Name" title="Copy Model Name"
onclick="event.stopPropagation(); navigator.clipboard.writeText(this.closest('.lora-card').dataset.name)"></i> onclick="event.stopPropagation(); navigator.clipboard.writeText(this.closest('.lora-card').dataset.file_name)"></i>
<i class="fas fa-trash" <i class="fas fa-trash"
title="Delete Model" title="Delete Model"
onclick="event.stopPropagation(); deleteModel('{{ lora.name }}')"></i> onclick="event.stopPropagation(); deleteModel('{{ lora.file_name }}')"></i>
</div> </div>
</div> </div>
<div class="card-footer"> <div class="card-footer">
<div class="model-info"> <div class="model-info">
<span class="model-name">{{ lora.name }}</span> <span class="model-name">{{ lora.model_name }}</span>
</div> </div>
<div class="card-actions"> <div class="card-actions">
<i class="fas fa-image" <i class="fas fa-image"
title="Replace Preview Image" title="Replace Preview Image"
onclick="event.stopPropagation(); replacePreview('{{ lora.name }}')"></i> onclick="event.stopPropagation(); replacePreview('{{ lora.file_name }}')"></i>
</div> </div>
</div> </div>
</div> </div>

View File

@@ -2,6 +2,7 @@ import os
import hashlib import hashlib
import json import json
from typing import Dict, Optional from typing import Dict, Optional
from .models import LoraMetadata
async def calculate_sha256(file_path: str) -> str: async def calculate_sha256(file_path: str) -> str:
"""Calculate SHA256 hash of a file""" """Calculate SHA256 hash of a file"""
@@ -11,35 +12,39 @@ async def calculate_sha256(file_path: str) -> str:
sha256_hash.update(byte_block) sha256_hash.update(byte_block)
return sha256_hash.hexdigest() return sha256_hash.hexdigest()
async def get_file_info(file_path: str) -> Dict: async def get_file_info(file_path: str) -> LoraMetadata:
"""Get basic file information""" """Get basic file information as LoraMetadata object"""
return { return LoraMetadata(
"name": os.path.splitext(os.path.basename(file_path))[0], file_name=os.path.splitext(os.path.basename(file_path))[0],
"file_path": file_path, model_name=os.path.splitext(os.path.basename(file_path))[0],
"size": os.path.getsize(file_path), file_path=file_path,
"modified": os.path.getmtime(file_path), size=os.path.getsize(file_path),
"sha256": await calculate_sha256(file_path) modified=os.path.getmtime(file_path),
} sha256=await calculate_sha256(file_path),
base_model="Unknown", # Will be updated later
preview_url="",
)
async def save_metadata(file_path: str, metadata: Dict) -> None: async def save_metadata(file_path: str, metadata: LoraMetadata) -> None:
"""Save metadata to .metadata.json file""" """Save metadata to .metadata.json file"""
metadata_path = f"{os.path.splitext(file_path)[0]}.metadata.json" metadata_path = f"{os.path.splitext(file_path)[0]}.metadata.json"
try: try:
with open(metadata_path, 'w', encoding='utf-8') as f: with open(metadata_path, 'w', encoding='utf-8') as f:
json.dump(metadata, f, indent=2, ensure_ascii=False) json.dump(metadata.to_dict(), f, indent=2, ensure_ascii=False)
except Exception as e: except Exception as e:
print(f"Error saving metadata to {metadata_path}: {str(e)}") print(f"Error saving metadata to {metadata_path}: {str(e)}")
async def load_metadata(file_path: str) -> Dict: async def load_metadata(file_path: str) -> Optional[LoraMetadata]:
"""Load metadata from .metadata.json file""" """Load metadata from .metadata.json file"""
metadata_path = f"{os.path.splitext(file_path)[0]}.metadata.json" metadata_path = f"{os.path.splitext(file_path)[0]}.metadata.json"
try: try:
if os.path.exists(metadata_path): if os.path.exists(metadata_path):
with open(metadata_path, 'r', encoding='utf-8') as f: with open(metadata_path, 'r', encoding='utf-8') as f:
return json.load(f) data = json.load(f)
return LoraMetadata.from_dict(data)
except Exception as e: except Exception as e:
print(f"Error loading metadata from {metadata_path}: {str(e)}") print(f"Error loading metadata from {metadata_path}: {str(e)}")
return {} return None
async def update_civitai_metadata(file_path: str, civitai_data: Dict) -> None: async def update_civitai_metadata(file_path: str, civitai_data: Dict) -> None:
"""Update metadata file with Civitai data""" """Update metadata file with Civitai data"""