fix: script not found

backend/src/backend/scripts.py

@@ -21,6 +21,7 @@ from fastapi import (
 from sqlalchemy import func, select
 from sqlalchemy.ext.asyncio import AsyncSession
 
+from common.config import settings
 from common.db.models import (
     Scripts,
     StorageObjects,
@@ -356,19 +357,40 @@ async def create_script_record(
             detail=exc.detail,
         ) from exc
 
-    # Synthesise a storage_data-shaped dict from the Jupyter response
-    # so the existing script_payload + response shape keep working.
-    # The storage_object_id is a fresh ULID — there is no real
-    # StorageObject row for this file; downstream list/get operations
-    # that JOIN StorageObjects will skip jupyter-only scripts.
+    # Build a real StorageObjects row so the file participates in
+    # workspace-tree / list / get queries that JOIN this table. The
+    # bytes live in the Jupyter mount; rclone replicates them to
+    # RustFS asynchronously. We mark the row "available" because the
+    # file is queryable as a workspace file from the user's POV; the
+    # storage_uri points at where the replicated bytes will land.
     object_id = new_ulid()
-    storage_data = {
-        "storage_object_id": object_id,
-        "relative_path": jupyter_name,
-        "object_key": f"{workspace_id}/{jupyter_name}",
-        "content_hash": content_hash,
-        "size_bytes": size_bytes,
-    }
+    object_key = f"{workspace_id}/{jupyter_name}"
+    bucket_name = settings.rustfs_workspace_bucket
+    relative_path = user_relative_path(context, jupyter_name)
+    mime_type = mimetypes.guess_type(jupyter_name)[0]
+    storage_object = StorageObjects(
+        storage_object_id=object_id,
+        workspace_id=context.workspace.workspace_id,
+        owner_user_id=context.user.user_id,
+        object_type="file",
+        usage_type="working_copy",
+        storage_backend="rustfs",
+        bucket_name=bucket_name,
+        object_key=object_key,
+        object_key_hash=hashlib.sha256(object_key.encode("utf-8")).digest(),
+        storage_uri=f"s3://{bucket_name}/{object_key}",
+        file_name=name,
+        file_extension=PurePosixPath(jupyter_name).suffix.lower() or None,
+        mime_type=mime_type,
+        size_bytes=size_bytes,
+        content_hash=content_hash,
+        visibility=visibility,
+        is_immutable=0,
+        object_status="available",
+        created_by=context.user.user_id,
+        relative_path=relative_path,
+        path_hash=hashlib.sha256(relative_path.encode("utf-8")).digest(),
+    )
     script = Scripts(
         script_id=script_id,
         workspace_id=context.workspace.workspace_id,
@@ -379,10 +401,12 @@ async def create_script_record(
         visibility=visibility,
         status="active",
     )
+    session.add(storage_object)
     session.add(script)
     await session.flush()
+    await session.refresh(storage_object)
     await session.refresh(script)
-    return script, storage_data
+    return script, storage_object
 
 
 @router.post("/api/v1/scripts", status_code=status.HTTP_201_CREATED)