Compare commits
2 Commits
e90e7b01dd
...
eb8d6a99a2
| Author | SHA1 | Date | |
|---|---|---|---|
| eb8d6a99a2 | |||
| 765c715d63 |
@@ -315,8 +315,6 @@ class JsonViewer(BaseComponent):
|
|||||||
def __hash__(self):
|
def __hash__(self):
|
||||||
return hash(self._key) if self._key is not None else super().__hash__()
|
return hash(self._key) if self._key is not None else super().__hash__()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def add_quotes(value: str):
|
def add_quotes(value: str):
|
||||||
if '"' in value and "'" in value:
|
if '"' in value and "'" in value:
|
||||||
|
|||||||
18
src/components/jsonviewer/JsonViewerApp.py
Normal file
18
src/components/jsonviewer/JsonViewerApp.py
Normal file
@@ -0,0 +1,18 @@
|
|||||||
|
import logging
|
||||||
|
|
||||||
|
from fasthtml.fastapp import fast_app
|
||||||
|
|
||||||
|
from components.jsonviewer.constants import Routes
|
||||||
|
from core.instance_manager import debug_session, InstanceManager
|
||||||
|
|
||||||
|
jsonviwer_app, rt = fast_app()
|
||||||
|
|
||||||
|
logger = logging.getLogger("JsonViewer")
|
||||||
|
|
||||||
|
|
||||||
|
@rt(Routes.Fold)
|
||||||
|
def post(session, _id: str, node_id: str, folding: str):
|
||||||
|
logger.debug(f"Entering {Routes.Fold} with args {debug_session(session)}, {_id=}, {node_id=}, {folding=}")
|
||||||
|
instance = InstanceManager.get(session, _id)
|
||||||
|
instance.set_node_folding(node_id, folding)
|
||||||
|
return instance.render_node(node_id)
|
||||||
0
src/components/jsonviewer/__init__.py
Normal file
0
src/components/jsonviewer/__init__.py
Normal file
0
src/components/jsonviewer/assets/__init__.py
Normal file
0
src/components/jsonviewer/assets/__init__.py
Normal file
27
src/components/jsonviewer/assets/icons.py
Normal file
27
src/components/jsonviewer/assets/icons.py
Normal file
@@ -0,0 +1,27 @@
|
|||||||
|
from fastcore.basics import NotStr
|
||||||
|
|
||||||
|
# Fluent CaretRight20Filled
|
||||||
|
icon_collapsed = NotStr("""<svg name="collapsed" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" viewBox="0 0 20 20">
|
||||||
|
<g fill="none">
|
||||||
|
<path d="M7 14.204a1 1 0 0 0 1.628.778l4.723-3.815a1.5 1.5 0 0 0 0-2.334L8.628 5.02A1 1 0 0 0 7 5.797v8.407z" fill="currentColor">
|
||||||
|
</path>
|
||||||
|
</g>
|
||||||
|
</svg>""")
|
||||||
|
|
||||||
|
# Fluent CaretDown20Filled
|
||||||
|
icon_expanded = NotStr("""<svg name="expanded" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" viewBox="0 0 20 20">
|
||||||
|
<g fill="none">
|
||||||
|
<path d="M5.797 7a1 1 0 0 0-.778 1.628l3.814 4.723a1.5 1.5 0 0 0 2.334 0l3.815-4.723A1 1 0 0 0 14.204 7H5.797z" fill="currentColor">
|
||||||
|
</path>
|
||||||
|
</g>
|
||||||
|
</svg>""")
|
||||||
|
|
||||||
|
icon_class = NotStr("""
|
||||||
|
<svg name="expanded" viewBox="0 0 20 20" xmlns="http://www.w3.org/2000/svg">
|
||||||
|
<g fill="none" stroke="currentColor" stroke-width="1.5" >
|
||||||
|
<polygon points="5,2 2,8 8,8" />
|
||||||
|
<rect x="12" y="2" width="6" height="6"/>
|
||||||
|
<circle cx="5" cy="15" r="3" />
|
||||||
|
<polygon points="11.5,15 15,11.5 18.5,15 15,18.5" />
|
||||||
|
</g>
|
||||||
|
</svg>""")
|
||||||
23
src/components/jsonviewer/commands.py
Normal file
23
src/components/jsonviewer/commands.py
Normal file
@@ -0,0 +1,23 @@
|
|||||||
|
from components.jsonviewer.constants import ROUTE_ROOT, Routes
|
||||||
|
|
||||||
|
|
||||||
|
class JsonViewerCommands:
|
||||||
|
def __init__(self, owner):
|
||||||
|
self._owner = owner
|
||||||
|
self._id = owner.get_id()
|
||||||
|
|
||||||
|
def fold(self, node_id: str, folding: str):
|
||||||
|
return {
|
||||||
|
"hx-post": f"{ROUTE_ROOT}{Routes.Fold}",
|
||||||
|
"hx-target": f"#{node_id}",
|
||||||
|
"hx-swap": "outerHTML",
|
||||||
|
"hx-vals": f'{{"_id": "{self._id}", "node_id": "{node_id}", "folding": "{folding}"}}',
|
||||||
|
}
|
||||||
|
|
||||||
|
def open_digest(self, user_id, digest):
|
||||||
|
return {
|
||||||
|
"hx-post": f"{ROUTE_ROOT}{Routes.DbEngineDigest}",
|
||||||
|
"hx-target": f"#{self._owner.get_owner().tabs_manager.get_id()}",
|
||||||
|
"hx-swap": "outerHTML",
|
||||||
|
"hx-vals": f'{{"_id": "{self._id}", "user_id": "{user_id}", "digest": "{digest}"}}',
|
||||||
|
}
|
||||||
464
src/components/jsonviewer/components/JsonViewer.py
Normal file
464
src/components/jsonviewer/components/JsonViewer.py
Normal file
@@ -0,0 +1,464 @@
|
|||||||
|
from dataclasses import dataclass, field
|
||||||
|
from typing import Any, Optional, Callable
|
||||||
|
|
||||||
|
from fasthtml.components import *
|
||||||
|
from pandas import DataFrame
|
||||||
|
|
||||||
|
from components.BaseComponent import BaseComponentMultipleInstance
|
||||||
|
from components.datagrid_new.components.DataGrid import DataGrid
|
||||||
|
from components.jsonviewer.assets.icons import icon_expanded, icon_collapsed, icon_class
|
||||||
|
from components.jsonviewer.commands import JsonViewerCommands
|
||||||
|
from components.jsonviewer.constants import NODES_KEYS_TO_NOT_EXPAND, NODE_OBJECT, INDENT_SIZE, MAX_TEXT_LENGTH
|
||||||
|
from components_helpers import apply_boundaries
|
||||||
|
from core.serializer import TAG_OBJECT
|
||||||
|
|
||||||
|
|
||||||
|
class FoldingMode:
|
||||||
|
COLLAPSE = "collapse"
|
||||||
|
EXPAND = "expand"
|
||||||
|
|
||||||
|
|
||||||
|
@dataclass
|
||||||
|
class Node:
|
||||||
|
value: Any
|
||||||
|
|
||||||
|
|
||||||
|
@dataclass
|
||||||
|
class ValueNode(Node):
|
||||||
|
hint: str = None
|
||||||
|
|
||||||
|
|
||||||
|
@dataclass
|
||||||
|
class ListNode(Node):
|
||||||
|
node_id: str
|
||||||
|
level: int
|
||||||
|
children: list[Node] = field(default_factory=list)
|
||||||
|
|
||||||
|
|
||||||
|
@dataclass
|
||||||
|
class DictNode(Node):
|
||||||
|
node_id: str
|
||||||
|
level: int
|
||||||
|
children: dict[str, Node] = field(default_factory=dict)
|
||||||
|
|
||||||
|
|
||||||
|
class NodeIdGenerator:
|
||||||
|
"""Manages unique node ID generation"""
|
||||||
|
|
||||||
|
def __init__(self, base_id: str):
|
||||||
|
self.base_id = base_id
|
||||||
|
self._counter = -1
|
||||||
|
|
||||||
|
def generate(self) -> str:
|
||||||
|
self._counter += 1
|
||||||
|
return f"{self.base_id}-{self._counter}"
|
||||||
|
|
||||||
|
def reset(self):
|
||||||
|
self._counter = -1
|
||||||
|
|
||||||
|
|
||||||
|
class FoldingManager:
|
||||||
|
"""Manages folding/unfolding state of nodes"""
|
||||||
|
|
||||||
|
# A little explanation on how the folding / unfolding work
|
||||||
|
# all the nodes are either fold or unfold... except when there are not !
|
||||||
|
# self._folding_mode keeps the current value (it's FoldingMode.COLLAPSE or FoldingMode.EXPAND
|
||||||
|
# self._nodes_to_track keeps track of the exceptions
|
||||||
|
# The idea is to minimize the memory usage
|
||||||
|
|
||||||
|
def __init__(self, default_mode: str = FoldingMode.COLLAPSE):
|
||||||
|
self._folding_mode = default_mode
|
||||||
|
self._nodes_to_track = set() # exceptions to the default mode
|
||||||
|
|
||||||
|
def set_folding_mode(self, mode: str):
|
||||||
|
"""Changes the global folding mode and clears exceptions"""
|
||||||
|
self._folding_mode = mode
|
||||||
|
self._nodes_to_track.clear()
|
||||||
|
|
||||||
|
def set_node_folding(self, node_id: str, folding: str):
|
||||||
|
"""Sets specific folding state for a node"""
|
||||||
|
if folding == self._folding_mode:
|
||||||
|
self._nodes_to_track.discard(node_id)
|
||||||
|
else:
|
||||||
|
self._nodes_to_track.add(node_id)
|
||||||
|
|
||||||
|
def must_expand(self, node: Node) -> Optional[bool]:
|
||||||
|
"""Determines if a node should be expanded"""
|
||||||
|
if not isinstance(node, (ListNode, DictNode)):
|
||||||
|
return None
|
||||||
|
|
||||||
|
if self._folding_mode == FoldingMode.COLLAPSE:
|
||||||
|
return node.node_id in self._nodes_to_track
|
||||||
|
else:
|
||||||
|
return node.node_id not in self._nodes_to_track
|
||||||
|
|
||||||
|
def get_folding_mode(self) -> str:
|
||||||
|
return self._folding_mode
|
||||||
|
|
||||||
|
def get_nodes_to_track(self) -> set[str]:
|
||||||
|
return self._nodes_to_track
|
||||||
|
|
||||||
|
|
||||||
|
class NodeFactory:
|
||||||
|
"""Factory for creating nodes from data"""
|
||||||
|
|
||||||
|
def __init__(self, id_generator: NodeIdGenerator, folding_manager: FoldingManager):
|
||||||
|
self.id_generator = id_generator
|
||||||
|
self.folding_manager = folding_manager
|
||||||
|
self._nodes_by_id = {}
|
||||||
|
|
||||||
|
def create_node(self, key: Any, data: Any, level: int = 0) -> Node:
|
||||||
|
"""Creates appropriate node type based on data"""
|
||||||
|
if isinstance(data, list):
|
||||||
|
return self._create_list_node(key, data, level)
|
||||||
|
elif isinstance(data, dict):
|
||||||
|
return self._create_dict_node(key, data, level)
|
||||||
|
else:
|
||||||
|
return self._create_value_node(key, data)
|
||||||
|
|
||||||
|
def _create_list_node(self, key: Any, data: list, level: int) -> ListNode:
|
||||||
|
node_id = self.id_generator.generate()
|
||||||
|
if level <= 1 and key not in NODES_KEYS_TO_NOT_EXPAND:
|
||||||
|
self.folding_manager._nodes_to_track.add(node_id)
|
||||||
|
|
||||||
|
node = ListNode(data, node_id, level)
|
||||||
|
self._nodes_by_id[node_id] = (key, node)
|
||||||
|
|
||||||
|
for index, item in enumerate(data):
|
||||||
|
node.children.append(self.create_node(index, item, level + 1))
|
||||||
|
|
||||||
|
return node
|
||||||
|
|
||||||
|
def _create_dict_node(self, key: Any, data: dict, level: int) -> DictNode:
|
||||||
|
node_id = self.id_generator.generate()
|
||||||
|
if level <= 1 and key not in NODES_KEYS_TO_NOT_EXPAND:
|
||||||
|
self.folding_manager._nodes_to_track.add(node_id)
|
||||||
|
|
||||||
|
node = DictNode(data, node_id, level)
|
||||||
|
self._nodes_by_id[node_id] = (key, node)
|
||||||
|
|
||||||
|
for child_key, value in data.items():
|
||||||
|
node.children[child_key] = self.create_node(child_key, value, level + 1)
|
||||||
|
|
||||||
|
return node
|
||||||
|
|
||||||
|
def _create_value_node(self, key: Any, data: Any) -> ValueNode:
|
||||||
|
hint = NODE_OBJECT if key == TAG_OBJECT else None
|
||||||
|
return ValueNode(data, hint)
|
||||||
|
|
||||||
|
def get_node_by_id(self, node_id: str) -> tuple[Any, Node]:
|
||||||
|
return self._nodes_by_id[node_id]
|
||||||
|
|
||||||
|
def clear(self):
|
||||||
|
"""Clears all stored nodes"""
|
||||||
|
self._nodes_by_id.clear()
|
||||||
|
|
||||||
|
|
||||||
|
class JsonViewerHelper:
|
||||||
|
class_string = f"mmt-jsonviewer-string"
|
||||||
|
class_bool = f"mmt-jsonviewer-bool"
|
||||||
|
class_number = f"mmt-jsonviewer-number"
|
||||||
|
class_null = f"mmt-jsonviewer-null"
|
||||||
|
class_digest = f"mmt-jsonviewer-digest"
|
||||||
|
class_object = f"mmt-jsonviewer-object"
|
||||||
|
class_dataframe = f"mmt-jsonviewer-dataframe"
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def is_sha256(_value):
|
||||||
|
return (isinstance(_value, str) and
|
||||||
|
len(_value) == 64 and
|
||||||
|
all(c in '0123456789abcdefABCDEF' for c in _value))
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def add_quotes(value: str) -> str:
|
||||||
|
if '"' in value and "'" in value:
|
||||||
|
return f'"{value.replace("\"", "\\\"")}"'
|
||||||
|
elif '"' in value:
|
||||||
|
return f"'{value}'"
|
||||||
|
else:
|
||||||
|
return f'"{value}"'
|
||||||
|
|
||||||
|
|
||||||
|
class NodeRenderer:
|
||||||
|
"""Single class handling all node rendering with helper methods"""
|
||||||
|
|
||||||
|
def __init__(self, session, jsonviewer_instance, folding_manager: FoldingManager,
|
||||||
|
commands: JsonViewerCommands, helper: JsonViewerHelper,
|
||||||
|
hooks: list[tuple[Callable, Callable]] = None):
|
||||||
|
self.session = session
|
||||||
|
self.jsonviewer = jsonviewer_instance # reference to main component
|
||||||
|
self.folding_manager = folding_manager
|
||||||
|
self.commands = commands
|
||||||
|
self.helper = helper
|
||||||
|
self.hooks = hooks or []
|
||||||
|
|
||||||
|
def render(self, key: Any, node: Node) -> Div:
|
||||||
|
"""Main rendering method for any node"""
|
||||||
|
must_expand = self.folding_manager.must_expand(node)
|
||||||
|
|
||||||
|
return Div(
|
||||||
|
self._create_folding_icon(node, must_expand),
|
||||||
|
Span(f'{key} : ') if key is not None else None,
|
||||||
|
self._render_value(key, node, must_expand),
|
||||||
|
style=f"margin-left: {INDENT_SIZE}px;",
|
||||||
|
id=getattr(node, "node_id", None)
|
||||||
|
)
|
||||||
|
|
||||||
|
def _create_folding_icon(self, node: Node, must_expand: Optional[bool]) -> Optional[Span]:
|
||||||
|
"""Creates folding/unfolding icon"""
|
||||||
|
if must_expand is None:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return Span(
|
||||||
|
icon_expanded if must_expand else icon_collapsed,
|
||||||
|
cls="icon-16-inline mmt-jsonviewer-folding",
|
||||||
|
style=f"margin-left: -{INDENT_SIZE}px;",
|
||||||
|
**self.commands.fold(
|
||||||
|
node.node_id,
|
||||||
|
FoldingMode.COLLAPSE if must_expand else FoldingMode.EXPAND
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
def _render_value(self, key: Any, node: Node, must_expand: Optional[bool]) -> Any:
|
||||||
|
"""Renders the value part of a node - extracted from original _render_value"""
|
||||||
|
if must_expand is False:
|
||||||
|
return self._render_collapsed_indicator(node)
|
||||||
|
|
||||||
|
# Check hooks first
|
||||||
|
for predicate, renderer in self.hooks:
|
||||||
|
if predicate(key, node, self.helper):
|
||||||
|
return renderer(key, node, self.helper)
|
||||||
|
|
||||||
|
# Route to appropriate helper method
|
||||||
|
if isinstance(node, DictNode):
|
||||||
|
return self._render_dict_node(key, node)
|
||||||
|
elif isinstance(node, ListNode):
|
||||||
|
return self._render_list_node(key, node)
|
||||||
|
else:
|
||||||
|
return self._render_value_node(key, node)
|
||||||
|
|
||||||
|
def _render_collapsed_indicator(self, node: Node) -> Span:
|
||||||
|
"""Renders collapsed indicator - extracted from original"""
|
||||||
|
indicator = "[...]" if isinstance(node, ListNode) else "{...}"
|
||||||
|
return Span(
|
||||||
|
indicator,
|
||||||
|
id=node.node_id,
|
||||||
|
**self.commands.fold(node.node_id, FoldingMode.EXPAND)
|
||||||
|
)
|
||||||
|
|
||||||
|
def _render_dict_node(self, key: Any, node: DictNode) -> Span:
|
||||||
|
"""Renders dictionary node - extracted from original _render_dict"""
|
||||||
|
return Span(
|
||||||
|
"{",
|
||||||
|
*[self.render(child_key, value) for child_key, value in node.children.items()],
|
||||||
|
Div("}"),
|
||||||
|
id=node.node_id
|
||||||
|
)
|
||||||
|
|
||||||
|
def _render_list_node(self, key: Any, node: ListNode) -> Span:
|
||||||
|
"""Renders list node - extracted from original _render_list"""
|
||||||
|
if self._should_render_list_as_grid(key, node):
|
||||||
|
return self._render_list_as_grid(key, node)
|
||||||
|
else:
|
||||||
|
return self._render_list_as_array(key, node)
|
||||||
|
|
||||||
|
def _should_render_list_as_grid(self, key: Any, node: ListNode) -> bool:
|
||||||
|
"""Determines if list should be rendered as grid - extracted from original _all_the_same"""
|
||||||
|
if len(node.children) == 0:
|
||||||
|
return False
|
||||||
|
|
||||||
|
sample_node = node.children[0]
|
||||||
|
sample_value = sample_node.value
|
||||||
|
|
||||||
|
if sample_value is None:
|
||||||
|
return False
|
||||||
|
|
||||||
|
type_ = type(sample_value)
|
||||||
|
if type_ in (int, float, str, bool, list, dict, ValueNode):
|
||||||
|
return False
|
||||||
|
|
||||||
|
# Check if a specific rendering is specified via hooks
|
||||||
|
for predicate, renderer in self.hooks:
|
||||||
|
if predicate(key, sample_node, self.helper):
|
||||||
|
return False
|
||||||
|
|
||||||
|
return all(type(item.value) == type_ for item in node.children)
|
||||||
|
|
||||||
|
def _render_list_as_grid(self, key: Any, node: ListNode) -> Span:
|
||||||
|
"""Renders list as grid - extracted from original _render_as_grid"""
|
||||||
|
type_ = type(node.children[0].value)
|
||||||
|
icon = icon_class
|
||||||
|
str_value = type_.__name__.split(".")[-1]
|
||||||
|
|
||||||
|
data = [child.value.__dict__ for child in node.children]
|
||||||
|
df = DataFrame(data)
|
||||||
|
dg = DataGrid(self.session)
|
||||||
|
dg.init_from_dataframe(df)
|
||||||
|
|
||||||
|
return Span(
|
||||||
|
Span(
|
||||||
|
Span(icon, cls="icon-16-inline mr-1"),
|
||||||
|
Span(str_value),
|
||||||
|
cls="mmt-jsonviewer-object"
|
||||||
|
),
|
||||||
|
dg,
|
||||||
|
id=node.node_id
|
||||||
|
)
|
||||||
|
|
||||||
|
def _render_list_as_array(self, key: Any, node: ListNode) -> Span:
|
||||||
|
"""Renders list as array - extracted from original _render_as_list"""
|
||||||
|
return Span(
|
||||||
|
"[",
|
||||||
|
*[self.render(index, item) for index, item in enumerate(node.children)],
|
||||||
|
Div("]"),
|
||||||
|
)
|
||||||
|
|
||||||
|
def _render_value_node(self, key: Any, node: ValueNode) -> Span:
|
||||||
|
"""Renders value node - extracted and simplified from original _render_value"""
|
||||||
|
data_tooltip = None
|
||||||
|
htmx_params = {}
|
||||||
|
icon = None
|
||||||
|
|
||||||
|
if isinstance(node.value, bool): # order is important bool is an int in Python !
|
||||||
|
str_value = "true" if node.value else "false"
|
||||||
|
data_class = "bool"
|
||||||
|
elif isinstance(node.value, (int, float)):
|
||||||
|
str_value = str(node.value)
|
||||||
|
data_class = "number"
|
||||||
|
elif node.value is None:
|
||||||
|
str_value = "null"
|
||||||
|
data_class = "null"
|
||||||
|
elif self.helper.is_sha256(node.value):
|
||||||
|
str_value = str(node.value)
|
||||||
|
data_class = "digest"
|
||||||
|
htmx_params = self.commands.open_digest(self.jsonviewer.user_id, node.value)
|
||||||
|
elif node.hint == NODE_OBJECT:
|
||||||
|
icon = icon_class
|
||||||
|
str_value = node.value.split(".")[-1]
|
||||||
|
data_class = "object"
|
||||||
|
elif isinstance(node.value, DataFrame):
|
||||||
|
return self._render_dataframe_value(node.value)
|
||||||
|
else:
|
||||||
|
str_value, data_tooltip = self._format_string_value(node.value)
|
||||||
|
data_class = "string"
|
||||||
|
|
||||||
|
return self._create_value_span(str_value, data_class, icon, data_tooltip, htmx_params)
|
||||||
|
|
||||||
|
def _render_dataframe_value(self, dataframe: DataFrame) -> Any:
|
||||||
|
"""Renders DataFrame value"""
|
||||||
|
dg = DataGrid(self.session)
|
||||||
|
dg.init_from_dataframe(dataframe)
|
||||||
|
return dg
|
||||||
|
|
||||||
|
def _format_string_value(self, value: Any) -> tuple[str, Optional[str]]:
|
||||||
|
"""Formats string value with tooltip if too long"""
|
||||||
|
as_str = str(value)
|
||||||
|
if len(as_str) > MAX_TEXT_LENGTH:
|
||||||
|
return as_str[:MAX_TEXT_LENGTH] + "...", as_str
|
||||||
|
else:
|
||||||
|
return self.helper.add_quotes(as_str), None
|
||||||
|
|
||||||
|
def _create_value_span(self, str_value: str, data_class: str, icon: Any,
|
||||||
|
data_tooltip: Optional[str], htmx_params: dict) -> Span:
|
||||||
|
"""Creates the final Span element for a value"""
|
||||||
|
css_class = f"mmt-jsonviewer-{data_class}"
|
||||||
|
if data_tooltip:
|
||||||
|
css_class += " mmt-tooltip"
|
||||||
|
|
||||||
|
if icon:
|
||||||
|
return Span(
|
||||||
|
Span(icon, cls="icon-16-inline mr-1"),
|
||||||
|
Span(str_value, data_tooltip=data_tooltip, **htmx_params),
|
||||||
|
cls=css_class
|
||||||
|
)
|
||||||
|
|
||||||
|
return Span(str_value, cls=css_class, data_tooltip=data_tooltip, **htmx_params)
|
||||||
|
|
||||||
|
|
||||||
|
class JsonViewer(BaseComponentMultipleInstance):
|
||||||
|
"""Main JsonViewer component with separated concerns"""
|
||||||
|
|
||||||
|
COMPONENT_INSTANCE_ID = "Jsonviewer"
|
||||||
|
|
||||||
|
def __init__(self, session, _id, data=None, hooks=None, key=None, boundaries=None):
|
||||||
|
super().__init__(session, _id)
|
||||||
|
self._key = key
|
||||||
|
self.data = data
|
||||||
|
self.hooks = hooks or []
|
||||||
|
self._boundaries = boundaries if boundaries else {"height": "600"}
|
||||||
|
self._commands = JsonViewerCommands(self)
|
||||||
|
|
||||||
|
# Initialize helper components
|
||||||
|
self._helper = JsonViewerHelper()
|
||||||
|
self._id_generator = NodeIdGenerator(_id)
|
||||||
|
self._folding_manager = FoldingManager()
|
||||||
|
self._node_factory = NodeFactory(self._id_generator, self._folding_manager)
|
||||||
|
|
||||||
|
# Initialize single renderer
|
||||||
|
self._node_renderer = NodeRenderer(
|
||||||
|
session, self, self._folding_manager,
|
||||||
|
self._commands, self._helper, self.hooks
|
||||||
|
)
|
||||||
|
|
||||||
|
# Create the initial node tree
|
||||||
|
self.node = self._node_factory.create_node(None, data)
|
||||||
|
|
||||||
|
@property
|
||||||
|
def user_id(self) -> str:
|
||||||
|
"""Gets user_id from session or returns default"""
|
||||||
|
# Preserve original behavior - this should be implemented based on your session management
|
||||||
|
return getattr(self, '_user_id', getattr(self._session, 'user_id', 'default_user'))
|
||||||
|
|
||||||
|
def set_data(self, data):
|
||||||
|
"""Updates the data and recreates the node tree"""
|
||||||
|
self.data = data
|
||||||
|
self._id_generator.reset()
|
||||||
|
self._node_factory.clear()
|
||||||
|
self.node = self._node_factory.create_node(None, data)
|
||||||
|
|
||||||
|
def set_node_folding(self, node_id: str, folding: str):
|
||||||
|
"""Sets folding state for a specific node"""
|
||||||
|
self._folding_manager.set_node_folding(node_id, folding)
|
||||||
|
|
||||||
|
def render_node(self, node_id: str):
|
||||||
|
"""Renders a specific node by ID"""
|
||||||
|
key, node = self._node_factory.get_node_by_id(node_id)
|
||||||
|
return self._node_renderer.render(key, node)
|
||||||
|
|
||||||
|
def set_folding_mode(self, folding_mode: str):
|
||||||
|
"""Sets global folding mode"""
|
||||||
|
self._folding_manager.set_folding_mode(folding_mode)
|
||||||
|
|
||||||
|
def get_folding_mode(self) -> str:
|
||||||
|
"""Gets current folding mode"""
|
||||||
|
return self._folding_manager.get_folding_mode()
|
||||||
|
|
||||||
|
def open_digest(self, user_id: str, digest: str):
|
||||||
|
"""Opens digest - preserves original method"""
|
||||||
|
return self._owner.db_engine_headers(user_id, digest)
|
||||||
|
|
||||||
|
def __ft__(self):
|
||||||
|
"""FastHTML rendering method"""
|
||||||
|
if self.node is None:
|
||||||
|
return Div("No data to display", cls="mmt-jsonviewer", id=f"{self._id}")
|
||||||
|
|
||||||
|
return Div(
|
||||||
|
Div(
|
||||||
|
self._node_renderer.render(None, self.node),
|
||||||
|
id=f"{self._id}-root",
|
||||||
|
style="margin-left: 0px;"
|
||||||
|
),
|
||||||
|
cls="mmt-jsonviewer",
|
||||||
|
id=f"{self._id}",
|
||||||
|
**apply_boundaries(self._boundaries)
|
||||||
|
)
|
||||||
|
|
||||||
|
def __eq__(self, other):
|
||||||
|
"""Equality comparison"""
|
||||||
|
if type(other) is type(self):
|
||||||
|
return self._key is not None and self._key == other._key
|
||||||
|
return False
|
||||||
|
|
||||||
|
def __hash__(self):
|
||||||
|
"""Hash method"""
|
||||||
|
return hash(self._key) if self._key is not None else super().__hash__()
|
||||||
0
src/components/jsonviewer/components/__init__.py
Normal file
0
src/components/jsonviewer/components/__init__.py
Normal file
10
src/components/jsonviewer/constants.py
Normal file
10
src/components/jsonviewer/constants.py
Normal file
@@ -0,0 +1,10 @@
|
|||||||
|
ROUTE_ROOT = "/jsonviewer"
|
||||||
|
|
||||||
|
INDENT_SIZE = 20
|
||||||
|
MAX_TEXT_LENGTH = 50
|
||||||
|
|
||||||
|
NODE_OBJECT = "Object"
|
||||||
|
NODES_KEYS_TO_NOT_EXPAND = ["Dataframe", "__parent__"]
|
||||||
|
|
||||||
|
class Routes:
|
||||||
|
Fold = "/fold"
|
||||||
@@ -510,7 +510,7 @@ class WorkflowDesigner(BaseComponent):
|
|||||||
)
|
)
|
||||||
|
|
||||||
def _mk_properties(self, oob=False):
|
def _mk_properties(self, oob=False):
|
||||||
return self.properties
|
return self.properties.__ft__(oob)
|
||||||
|
|
||||||
def _mk_jira_processor_details(self, component):
|
def _mk_jira_processor_details(self, component):
|
||||||
def _mk_option(name):
|
def _mk_option(name):
|
||||||
|
|||||||
@@ -1,8 +1,8 @@
|
|||||||
from fasthtml.common import *
|
from fasthtml.common import *
|
||||||
|
|
||||||
from components.BaseComponent import BaseComponent
|
from components.BaseComponent import BaseComponent
|
||||||
from components.debugger.components.JsonViewer import JsonViewer
|
|
||||||
from components.entryselector.components.EntrySelector import EntrySelector
|
from components.entryselector.components.EntrySelector import EntrySelector
|
||||||
|
from components.jsonviewer.components.JsonViewer import JsonViewer
|
||||||
from components.workflows.constants import COMPONENT_TYPES, PROCESSOR_TYPES
|
from components.workflows.constants import COMPONENT_TYPES, PROCESSOR_TYPES
|
||||||
from components_helpers import mk_dialog_buttons
|
from components_helpers import mk_dialog_buttons
|
||||||
from core.instance_manager import InstanceManager
|
from core.instance_manager import InstanceManager
|
||||||
@@ -33,15 +33,9 @@ class WorkflowDesignerProperties(BaseComponent):
|
|||||||
hooks={
|
hooks={
|
||||||
"on_entry_selected": self.on_entry_selector_changed})
|
"on_entry_selected": self.on_entry_selector_changed})
|
||||||
self._input_jsonviewer: JsonViewer = InstanceManager.new(self._session,
|
self._input_jsonviewer: JsonViewer = InstanceManager.new(self._session,
|
||||||
JsonViewer,
|
JsonViewer)
|
||||||
owner=self,
|
|
||||||
user_id=None,
|
|
||||||
data=None)
|
|
||||||
self._output_jsonviewer: JsonViewer = InstanceManager.new(self._session,
|
self._output_jsonviewer: JsonViewer = InstanceManager.new(self._session,
|
||||||
JsonViewer,
|
JsonViewer)
|
||||||
owner=self,
|
|
||||||
user_id=None,
|
|
||||||
data=None)
|
|
||||||
|
|
||||||
def set_entry_selector_data(self, data):
|
def set_entry_selector_data(self, data):
|
||||||
self.entry_selector.set_data(data)
|
self.entry_selector.set_data(data)
|
||||||
|
|||||||
@@ -147,6 +147,7 @@ register_component("main_layout", "components.drawerlayout", "DrawerLayoutApp")
|
|||||||
register_component("undo_redo", "components.undo_redo", "UndoRedoApp")
|
register_component("undo_redo", "components.undo_redo", "UndoRedoApp")
|
||||||
register_component("tabs", "components.tabs", "TabsApp") # before repositories
|
register_component("tabs", "components.tabs", "TabsApp") # before repositories
|
||||||
register_component("entryselector", "components.entryselector", "EntrySelectorApp")
|
register_component("entryselector", "components.entryselector", "EntrySelectorApp")
|
||||||
|
register_component("jsonviewer", "components.jsonviewer", "JsonViewerApp")
|
||||||
register_component("applications", "components.applications", "ApplicationsApp")
|
register_component("applications", "components.applications", "ApplicationsApp")
|
||||||
register_component("repositories", "components.repositories", "RepositoriesApp")
|
register_component("repositories", "components.repositories", "RepositoriesApp")
|
||||||
register_component("workflows", "components.workflows", "WorkflowsApp")
|
register_component("workflows", "components.workflows", "WorkflowsApp")
|
||||||
|
|||||||
@@ -1,12 +1,11 @@
|
|||||||
import pytest
|
import pytest
|
||||||
|
|
||||||
from components.debugger.components.JsonViewer import *
|
from components.jsonviewer.components.JsonViewer import *
|
||||||
from helpers import matches, span_icon, search_elements_by_name, extract_jsonviewer_node
|
from helpers import matches, span_icon, search_elements_by_name, extract_jsonviewer_node
|
||||||
|
|
||||||
JSON_VIEWER_INSTANCE_ID = "json_viewer"
|
JSON_VIEWER_INSTANCE_ID = "json_viewer"
|
||||||
ML_20 = "margin-left: 20px;"
|
ML_20 = "margin-left: 20px;"
|
||||||
CLS_PREFIX = "mmt-jsonviewer"
|
CLS_PREFIX = "mmt-jsonviewer"
|
||||||
USER_ID = "user_id"
|
|
||||||
|
|
||||||
dn = DictNode
|
dn = DictNode
|
||||||
ln = ListNode
|
ln = ListNode
|
||||||
@@ -15,7 +14,7 @@ n = ValueNode
|
|||||||
|
|
||||||
@pytest.fixture()
|
@pytest.fixture()
|
||||||
def json_viewer(session):
|
def json_viewer(session):
|
||||||
return JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, {})
|
return JsonViewer(session, JSON_VIEWER_INSTANCE_ID, {})
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture()
|
@pytest.fixture()
|
||||||
@@ -41,7 +40,7 @@ def jv_id(x):
|
|||||||
ln([{"a": [1, 2]}], jv_id(0), 0, [dn({"a": [1, 2]}, jv_id(1), 1, {"a": ln([1, 2], jv_id(2), 2, [n(1), n(2)])})]))
|
ln([{"a": [1, 2]}], jv_id(0), 0, [dn({"a": [1, 2]}, jv_id(1), 1, {"a": ln([1, 2], jv_id(2), 2, [n(1), n(2)])})]))
|
||||||
])
|
])
|
||||||
def test_i_can_create_node(data, expected_node):
|
def test_i_can_create_node(data, expected_node):
|
||||||
json_viewer_ = JsonViewer(None, JSON_VIEWER_INSTANCE_ID, None, USER_ID, data)
|
json_viewer_ = JsonViewer(None, JSON_VIEWER_INSTANCE_ID, data)
|
||||||
assert json_viewer_.node == expected_node
|
assert json_viewer_.node == expected_node
|
||||||
|
|
||||||
|
|
||||||
@@ -63,7 +62,7 @@ def test_i_can_render(json_viewer):
|
|||||||
(None, Span("null", cls=f"{CLS_PREFIX}-null")),
|
(None, Span("null", cls=f"{CLS_PREFIX}-null")),
|
||||||
])
|
])
|
||||||
def test_i_can_render_simple_value(session, value, expected_inner):
|
def test_i_can_render_simple_value(session, value, expected_inner):
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, value)
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, value)
|
||||||
actual = jsonv.__ft__()
|
actual = jsonv.__ft__()
|
||||||
to_compare = search_elements_by_name(actual, "div", attrs={"id": f"{jv_id('root')}"})[0]
|
to_compare = search_elements_by_name(actual, "div", attrs={"id": f"{jv_id('root')}"})[0]
|
||||||
expected = Div(
|
expected = Div(
|
||||||
@@ -81,7 +80,7 @@ def test_i_can_render_simple_value(session, value, expected_inner):
|
|||||||
|
|
||||||
def test_i_can_render_expanded_list_node(session):
|
def test_i_can_render_expanded_list_node(session):
|
||||||
value = [1, "hello", True]
|
value = [1, "hello", True]
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, value)
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, value)
|
||||||
# Force expansion of the node
|
# Force expansion of the node
|
||||||
jsonv.set_folding_mode("expand")
|
jsonv.set_folding_mode("expand")
|
||||||
|
|
||||||
@@ -107,7 +106,7 @@ def test_i_can_render_expanded_list_node(session):
|
|||||||
|
|
||||||
def test_i_can_render_expanded_dict_node(session):
|
def test_i_can_render_expanded_dict_node(session):
|
||||||
value = {"a": 1, "b": "hello", "c": True}
|
value = {"a": 1, "b": "hello", "c": True}
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, value)
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, value)
|
||||||
# Force expansion of the node
|
# Force expansion of the node
|
||||||
jsonv.set_folding_mode("expand")
|
jsonv.set_folding_mode("expand")
|
||||||
|
|
||||||
@@ -133,7 +132,7 @@ def test_i_can_render_expanded_dict_node(session):
|
|||||||
|
|
||||||
def test_i_can_render_expanded_list_of_dict_node(session):
|
def test_i_can_render_expanded_list_of_dict_node(session):
|
||||||
value = [{"a": 1, "b": "hello"}]
|
value = [{"a": 1, "b": "hello"}]
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, value)
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, value)
|
||||||
# Force expansion of all nodes
|
# Force expansion of all nodes
|
||||||
jsonv.set_folding_mode("expand")
|
jsonv.set_folding_mode("expand")
|
||||||
|
|
||||||
@@ -167,7 +166,7 @@ def test_i_can_render_expanded_list_of_dict_node(session):
|
|||||||
def test_render_with_collapse_folding_mode(session):
|
def test_render_with_collapse_folding_mode(session):
|
||||||
# Create a nested structure to test collapse rendering
|
# Create a nested structure to test collapse rendering
|
||||||
value = {"a": [1, 2, 3], "b": {"x": "y", "z": True}}
|
value = {"a": [1, 2, 3], "b": {"x": "y", "z": True}}
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, value)
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, value)
|
||||||
|
|
||||||
# Ensure folding mode is set to collapse (should be default)
|
# Ensure folding mode is set to collapse (should be default)
|
||||||
jsonv.set_folding_mode("collapse")
|
jsonv.set_folding_mode("collapse")
|
||||||
@@ -195,7 +194,7 @@ def test_render_with_collapse_folding_mode(session):
|
|||||||
def test_render_with_specific_node_expanded_in_collapse_mode(session):
|
def test_render_with_specific_node_expanded_in_collapse_mode(session):
|
||||||
# Create a nested structure to test mixed collapse/expand rendering
|
# Create a nested structure to test mixed collapse/expand rendering
|
||||||
value = {"a": [1, 2, 3], "b": {"x": "y", "z": True}}
|
value = {"a": [1, 2, 3], "b": {"x": "y", "z": True}}
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, value)
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, value)
|
||||||
|
|
||||||
# Ensure folding mode is set to collapse
|
# Ensure folding mode is set to collapse
|
||||||
jsonv.set_folding_mode(FoldingMode.COLLAPSE)
|
jsonv.set_folding_mode(FoldingMode.COLLAPSE)
|
||||||
@@ -230,7 +229,7 @@ def test_render_with_specific_node_expanded_in_collapse_mode(session):
|
|||||||
def test_multiple_folding_levels_in_collapse_mode(session):
|
def test_multiple_folding_levels_in_collapse_mode(session):
|
||||||
# Create a deeply nested structure
|
# Create a deeply nested structure
|
||||||
value = {"level1": {"level2": {"level3": [1, 2, 3]}}}
|
value = {"level1": {"level2": {"level3": [1, 2, 3]}}}
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, value)
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, value)
|
||||||
|
|
||||||
# Set folding mode to collapse
|
# Set folding mode to collapse
|
||||||
jsonv.set_folding_mode(FoldingMode.COLLAPSE)
|
jsonv.set_folding_mode(FoldingMode.COLLAPSE)
|
||||||
@@ -262,7 +261,7 @@ def test_multiple_folding_levels_in_collapse_mode(session):
|
|||||||
|
|
||||||
def test_toggle_between_folding_modes(session):
|
def test_toggle_between_folding_modes(session):
|
||||||
value = {"a": [1, 2, 3], "b": {"x": "y"}}
|
value = {"a": [1, 2, 3], "b": {"x": "y"}}
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, value)
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, value)
|
||||||
|
|
||||||
# Start with collapse mode
|
# Start with collapse mode
|
||||||
jsonv.set_folding_mode("collapse")
|
jsonv.set_folding_mode("collapse")
|
||||||
@@ -271,19 +270,19 @@ def test_toggle_between_folding_modes(session):
|
|||||||
jsonv.set_node_folding(f"{JSON_VIEWER_INSTANCE_ID}-0", "expand")
|
jsonv.set_node_folding(f"{JSON_VIEWER_INSTANCE_ID}-0", "expand")
|
||||||
|
|
||||||
# Verify node is in tracked nodes (exceptions to collapse mode)
|
# Verify node is in tracked nodes (exceptions to collapse mode)
|
||||||
assert f"{JSON_VIEWER_INSTANCE_ID}-0" in jsonv._nodes_to_track
|
assert f"{JSON_VIEWER_INSTANCE_ID}-0" in jsonv._folding_manager.get_nodes_to_track()
|
||||||
|
|
||||||
# Now switch to expand mode
|
# Now switch to expand mode
|
||||||
jsonv.set_folding_mode("expand")
|
jsonv.set_folding_mode("expand")
|
||||||
|
|
||||||
# Tracked nodes should be cleared
|
# Tracked nodes should be cleared
|
||||||
assert len(jsonv._nodes_to_track) == 0
|
assert len(jsonv._folding_manager.get_nodes_to_track()) == 0
|
||||||
|
|
||||||
# Collapse specific node
|
# Collapse specific node
|
||||||
jsonv.set_node_folding(f"{JSON_VIEWER_INSTANCE_ID}-0", "collapse")
|
jsonv.set_node_folding(f"{JSON_VIEWER_INSTANCE_ID}-0", "collapse")
|
||||||
|
|
||||||
# Verify node is in tracked nodes (exceptions to expand mode)
|
# Verify node is in tracked nodes (exceptions to expand mode)
|
||||||
assert f"{JSON_VIEWER_INSTANCE_ID}-0" in jsonv._nodes_to_track
|
assert f"{JSON_VIEWER_INSTANCE_ID}-0" in jsonv._folding_manager.get_nodes_to_track()
|
||||||
|
|
||||||
# Render and verify the output
|
# Render and verify the output
|
||||||
actual = jsonv.__ft__()
|
actual = jsonv.__ft__()
|
||||||
@@ -307,7 +306,7 @@ def test_custom_hook_rendering(session, helper):
|
|||||||
hooks = [(custom_predicate, custom_renderer)]
|
hooks = [(custom_predicate, custom_renderer)]
|
||||||
|
|
||||||
# Create JsonViewer with the custom hook
|
# Create JsonViewer with the custom hook
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, "custom_hook_test", hooks=hooks)
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, "custom_hook_test", hooks=hooks)
|
||||||
|
|
||||||
actual = jsonv.__ft__()
|
actual = jsonv.__ft__()
|
||||||
to_compare = search_elements_by_name(actual, "div", attrs={"id": f"{jv_id('root')}"})[0]
|
to_compare = search_elements_by_name(actual, "div", attrs={"id": f"{jv_id('root')}"})[0]
|
||||||
@@ -324,7 +323,7 @@ def test_custom_hook_rendering(session, helper):
|
|||||||
|
|
||||||
|
|
||||||
def test_folding_mode_operations(session):
|
def test_folding_mode_operations(session):
|
||||||
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, None, USER_ID, {"a": [1, 2, 3]})
|
jsonv = JsonViewer(session, JSON_VIEWER_INSTANCE_ID, {"a": [1, 2, 3]})
|
||||||
|
|
||||||
# Check default folding mode
|
# Check default folding mode
|
||||||
assert jsonv.get_folding_mode() == "collapse"
|
assert jsonv.get_folding_mode() == "collapse"
|
||||||
@@ -338,11 +337,11 @@ def test_folding_mode_operations(session):
|
|||||||
jsonv.set_node_folding(node_id, "collapse")
|
jsonv.set_node_folding(node_id, "collapse")
|
||||||
|
|
||||||
# Node should be in tracked nodes since it differs from the default mode
|
# Node should be in tracked nodes since it differs from the default mode
|
||||||
assert node_id in jsonv._nodes_to_track
|
assert node_id in jsonv._folding_manager.get_nodes_to_track()
|
||||||
|
|
||||||
# Restore to match default mode
|
# Restore to match default mode
|
||||||
jsonv.set_node_folding(node_id, "expand")
|
jsonv.set_node_folding(node_id, "expand")
|
||||||
assert node_id not in jsonv._nodes_to_track
|
assert node_id not in jsonv._folding_manager.get_nodes_to_track()
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.parametrize("input_value, expected_output", [
|
@pytest.mark.parametrize("input_value, expected_output", [
|
||||||
@@ -353,7 +352,7 @@ def test_folding_mode_operations(session):
|
|||||||
('', '""'), # Empty string
|
('', '""'), # Empty string
|
||||||
])
|
])
|
||||||
def test_add_quotes(input_value, expected_output):
|
def test_add_quotes(input_value, expected_output):
|
||||||
result = JsonViewer.add_quotes(input_value)
|
result = JsonViewerHelper.add_quotes(input_value)
|
||||||
assert result == expected_output
|
assert result == expected_output
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -73,6 +73,7 @@ def test_run_simple_workflow(engine):
|
|||||||
assert result == [1, 2, 3]
|
assert result == [1, 2, 3]
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.skip(reason="Not yet implemented")
|
||||||
def test_process_single_item(engine):
|
def test_process_single_item(engine):
|
||||||
"""Test the internal _process_single_item method."""
|
"""Test the internal _process_single_item method."""
|
||||||
mock_processor = MagicMock(spec=DataProcessor)
|
mock_processor = MagicMock(spec=DataProcessor)
|
||||||
|
|||||||
Reference in New Issue
Block a user