Release 0.16.0

pephub/_version.py

@@ -1 +1 @@
-__version__ = "0.15.8"
+__version__ = "0.16.0"

pephub/const.py

@@ -6,18 +6,20 @@
 import pandas as pd
 from fastapi import __version__ as fastapi_version
 from pepdbagent import __version__ as pepdbagent_version
-from peppy import __version__ as peppy_version
-from peppy.const import PEP_LATEST_VERSION
 
 from ._version import __version__ as pephub_version
 
+# peprs has no __version__ attribute and no PEP_LATEST_VERSION constant.
+PEP_LATEST_VERSION = "2.1.0"
+peprs_version = "unknown"
+
 PKG_NAME = "pephub"
 DATA_REPO = "https://github.com/pepkit/data.pephub.git"
 
 
 ALL_VERSIONS = {
     "pephub_version": pephub_version,
-    "peppy_version": peppy_version,
+    "peprs_version": peprs_version,
     "python_version": python_version(),
     "fastapi_version": fastapi_version,
     "pepdbagent_version": pepdbagent_version,

pephub/helpers.py

@@ -9,16 +9,18 @@
 import json
 from fastapi import Response, UploadFile
 from fastapi.exceptions import HTTPException
-from peppy.const import (
-    CFG_SAMPLE_TABLE_KEY,
-    CFG_SUBSAMPLE_TABLE_KEY,
+from peprs.const import (
     CONFIG_KEY,
-    NAME_KEY,
     SAMPLE_RAW_DICT_KEY,
-    SUBSAMPLE_RAW_LIST_KEY,
+    SUBSAMPLE_RAW_DICT_KEY,
 )
 from .const import JWT_EXPIRATION, JWT_SECRET
 
+# peprs.const does not export these — they are PEP config schema strings.
+CFG_SAMPLE_TABLE_KEY = "sample_table"
+CFG_SUBSAMPLE_TABLE_KEY = "subsample_table"
+NAME_KEY = "name"
+
 
 def jwt_encode_user_data(user_data: dict, exp: datetime = None) -> str:
     """
@@ -53,15 +55,15 @@ def zip_pep(project: Dict[str, Any]) -> Response:
             project[SAMPLE_RAW_DICT_KEY]
         ).to_csv(index=False)
 
-    if project[SUBSAMPLE_RAW_LIST_KEY] is not None:
-        if not isinstance(project[SUBSAMPLE_RAW_LIST_KEY], list):
+    if project[SUBSAMPLE_RAW_DICT_KEY] is not None:
+        if not isinstance(project[SUBSAMPLE_RAW_DICT_KEY], list):
             config[CFG_SUBSAMPLE_TABLE_KEY] = ["subsample_table1.csv"]
             content_to_zip["subsample_table1.csv"] = pd.DataFrame(
-                project[SUBSAMPLE_RAW_LIST_KEY]
+                project[SUBSAMPLE_RAW_DICT_KEY]
             ).to_csv(index=False)
         else:
             config[CFG_SUBSAMPLE_TABLE_KEY] = []
-            for number, file in enumerate(project[SUBSAMPLE_RAW_LIST_KEY]):
+            for number, file in enumerate(project[SUBSAMPLE_RAW_DICT_KEY]):
                 file_name = f"subsample_table{number + 1}.csv"
                 config[CFG_SUBSAMPLE_TABLE_KEY].append(file_name)
                 content_to_zip[file_name] = pd.DataFrame(file).to_csv(index=False)

pephub/main.py

@@ -28,12 +28,12 @@
     fmt="[%(levelname)s] [%(asctime)s] [PEPDBAGENT] %(message)s",
 )
 
-_LOGGER_PEPPY = logging.getLogger("peppy")
+_LOGGER_PEPRS = logging.getLogger("peprs")
 coloredlogs.install(
-    logger=_LOGGER_PEPPY,
+    logger=_LOGGER_PEPRS,
     level=logging.ERROR,
     datefmt="%b %d %Y %H:%M:%S",
-    fmt="[%(levelname)s] [%(asctime)s] [PEPPY] %(message)s",
+    fmt="[%(levelname)s] [%(asctime)s] [PEPRS] %(message)s",
 )
 
 _LOGGER_PEPHUB = logging.getLogger("uvicorn.access")

pephub/routers/api/v1/helpers.py

@@ -1,16 +1,14 @@
 import logging
 
-import eido
-from eido.validation import validate_config
-from eido.exceptions import EidoValidationError
-import peppy
+import peprs
 import yaml
 from fastapi.exceptions import HTTPException
-from peppy import Project
-from peppy.const import (
+from peprs import Project
+from peprs.eido import EidoValidationError, validate_config, validate_project
+from peprs.const import (
     CONFIG_KEY,
     SAMPLE_RAW_DICT_KEY,
-    SUBSAMPLE_RAW_LIST_KEY,
+    SUBSAMPLE_RAW_DICT_KEY,
 )
 from ....dependencies import (
     get_db,
@@ -22,7 +20,7 @@
 DEFAULT_SCHEMA_VERSION = "2.1.0"
 
 
-async def verify_updated_project(updated_project) -> peppy.Project:
+async def verify_updated_project(updated_project) -> peprs.Project:
     new_raw_project = {}
 
     agent = get_db()
@@ -37,43 +35,23 @@ async def verify_updated_project(updated_project) -> peppy.Project:
             status_code=400,
             detail="Please provide a sample table and project config yaml to update project",
         )
-    try:
-        validate_config(
-            yaml.safe_load(updated_project.project_config_yaml), default_schema
-        )
-    except EidoValidationError as e:
-        raise HTTPException(
-            status_code=400,
-            detail=f"Config structure error: {', '.join(list(e.errors_by_type.keys()))}. Please check schema definition and try again.",
-        )
-    # sample table update
-    new_raw_project[SAMPLE_RAW_DICT_KEY] = updated_project.sample_table
 
     try:
         yaml_dict = yaml.safe_load(updated_project.project_config_yaml)
-        new_raw_project[CONFIG_KEY] = yaml_dict
     except yaml.scanner.ScannerError as e:
         raise HTTPException(
             status_code=400,
             detail=f"Could not parse provided yaml. Error: {e}",
         )
 
-    # sample_table_index_col = yaml_dict.get(
-    #     SAMPLE_TABLE_INDEX_KEY, SAMPLE_NAME_ATTR  # default to sample_name
-    # )
-
-    # await check_sample_names(
-    #     new_raw_project[SAMPLE_RAW_DICT_KEY], sample_table_index_col
-    # )
+    new_raw_project[CONFIG_KEY] = yaml_dict
+    new_raw_project[SAMPLE_RAW_DICT_KEY] = updated_project.sample_table
 
     # subsample table update
     if updated_project.subsample_tables is not None:
         subsamples = list(updated_project.subsample_tables[0][0].values())
-        new_raw_project[SUBSAMPLE_RAW_LIST_KEY] = (
-            updated_project.subsample_tables
-            if len(subsamples) > 0 and subsamples[0]
-            else None
-        )
+        if len(subsamples) > 0 and subsamples[0]:
+            new_raw_project[SUBSAMPLE_RAW_DICT_KEY] = updated_project.subsample_tables
 
     try:
         new_project = Project.from_dict(new_raw_project)
@@ -83,9 +61,19 @@ async def verify_updated_project(updated_project) -> peppy.Project:
             detail=f"Could not create PEP from provided data. Error: {e}",
         )
 
+    # peprs.eido.validate_config takes a Project (not a raw dict like eido did),
+    # so we validate after constructing the Project.
+    try:
+        validate_config(new_project, default_schema)
+    except EidoValidationError as e:
+        raise HTTPException(
+            status_code=400,
+            detail=f"Config structure error: {', '.join(list(e.errors_by_type.keys()))}. Please check schema definition and try again.",
+        )
+
     try:
         # validate project (it will also validate samples)
-        eido.validate_project(new_project, default_schema)
+        validate_project(new_project, default_schema)
     except Exception as _:
         raise HTTPException(
             status_code=400,

pephub/routers/api/v1/namespace.py

@@ -3,7 +3,7 @@
 from typing import List, Literal, Optional, Union
 import os
 
-import peppy
+import peprs
 from dotenv import load_dotenv
 from fastapi import APIRouter, Depends, File, Form, HTTPException, UploadFile, Request
 from fastapi.responses import JSONResponse
@@ -22,10 +22,13 @@
     NamespaceStats,
     TarNamespaceModelReturn,
 )
-from peppy import Project
-from peppy.const import DESC_KEY, NAME_KEY
+from peprs import Project
 from typing_extensions import Annotated
 
+# peprs.const does not export these — they are PEP config schema strings.
+NAME_KEY = "name"
+DESC_KEY = "description"
+
 from ....const import (
     DEFAULT_TAG,
     ARCHIVE_URL_PATH,
@@ -213,7 +216,7 @@ async def create_pep(
                 },
                 status_code=202,
             )
-    # create a blank peppy.Project object with fake files
+    # create a blank peprs.Project object with fake files
     else:
         raise HTTPException(
             detail="Project files were not provided",
@@ -258,21 +261,23 @@ async def upload_raw_pep(
         # This configurations needed due to Issue #124 Should be removed in the future
         project_dict = ProjectRawModel(**project_from_json.pep_dict.dict())
         ff = project_dict.model_dump(by_alias=True)
-        p_project = peppy.Project().from_dict(ff)
+        p_project = peprs.Project.from_dict(ff)
 
-        p_project.namespace = name
+        # peprs.Project has no `namespace` attribute, so we set the registry name
+        # in the config and pass `name` separately to agent.project.create.
+        p_project.name = name
         p_project.description = description
 
     except Exception as e:
         raise HTTPException(
-            detail=f"Incorrect raw project was provided. Couldn't initiate peppy object: {e}",
+            detail=f"Incorrect raw project was provided. Couldn't initiate peprs object: {e}",
             status_code=417,
         )
     try:
         agent.project.create(
             p_project,
             namespace=namespace,
-            name=p_project.namespace,
+            name=name,
             tag=tag,
             description=description,
             is_private=is_private,
@@ -282,15 +287,15 @@ async def upload_raw_pep(
         )
     except ProjectUniqueNameError:
         raise HTTPException(
-            detail=f"Project '{namespace}/{p_project.namespace}:{tag}' already exists in namespace",
+            detail=f"Project '{namespace}/{name}:{tag}' already exists in namespace",
             status_code=400,
         )
     return JSONResponse(
         content={
             "namespace": namespace,
-            "name": p_project.namespace,
+            "name": name,
             "tag": tag,
-            "registry_path": f"{namespace}/{p_project.namespace}:{tag}",
+            "registry_path": f"{namespace}/{name}:{tag}",
         },
         status_code=202,
     )