mirror of
https://github.com/johndoe6345789/metabuilder.git
synced 2026-04-25 14:25:02 +00:00
johndoe6345789
6e2f0c08c0
Created 11 packagerepo-specific workflow plugins: - auth_verify_jwt - JWT token verification - auth_check_scopes - Scope-based authorization - parse_path - URL path parameter extraction (Express-style) - normalize_entity - Field normalization (trim, lower, unique, sort) - validate_entity - JSON schema validation - kv_get/kv_put - RocksDB key-value operations - blob_put - Filesystem blob storage with SHA-256 hashing - index_upsert - Index entry management - respond_json/respond_error - Response formatting Created string.sha256 plugin: - Compute SHA256 hash of strings/bytes - Optional "sha256:" prefix - Used by packagerepo for content-addressed storage All plugins follow standard pattern: - Class extending NodeExecutor - Factory with create() function - package.json with metadata - Access external state via runtime parameter Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
57 lines
1.8 KiB
Python
57 lines
1.8 KiB
Python
"""Package repository workflow plugins.
|
|
|
|
Lazy-loading module to avoid import errors when optional dependencies are missing.
|
|
"""
|
|
|
|
__all__ = [
|
|
"create_auth_verify_jwt",
|
|
"create_auth_check_scopes",
|
|
"create_parse_path",
|
|
"create_normalize_entity",
|
|
"create_validate_entity",
|
|
"create_kv_get",
|
|
"create_kv_put",
|
|
"create_blob_put",
|
|
"create_index_upsert",
|
|
"create_respond_json",
|
|
"create_respond_error",
|
|
]
|
|
|
|
|
|
def __getattr__(name):
|
|
"""Lazy-load plugin factories on demand."""
|
|
if name == "create_auth_verify_jwt":
|
|
from .auth_verify_jwt.factory import create
|
|
return create
|
|
elif name == "create_auth_check_scopes":
|
|
from .auth_check_scopes.factory import create
|
|
return create
|
|
elif name == "create_parse_path":
|
|
from .parse_path.factory import create
|
|
return create
|
|
elif name == "create_normalize_entity":
|
|
from .normalize_entity.factory import create
|
|
return create
|
|
elif name == "create_validate_entity":
|
|
from .validate_entity.factory import create
|
|
return create
|
|
elif name == "create_kv_get":
|
|
from .kv_get.factory import create
|
|
return create
|
|
elif name == "create_kv_put":
|
|
from .kv_put.factory import create
|
|
return create
|
|
elif name == "create_blob_put":
|
|
from .blob_put.factory import create
|
|
return create
|
|
elif name == "create_index_upsert":
|
|
from .index_upsert.factory import create
|
|
return create
|
|
elif name == "create_respond_json":
|
|
from .respond_json.factory import create
|
|
return create
|
|
elif name == "create_respond_error":
|
|
from .respond_error.factory import create
|
|
return create
|
|
raise AttributeError(f"module {__name__!r} has no attribute {name!r}")
|