get default product name

Author: pcrespov

services/web/server/src/simcore_service_webserver/products/_repository.py

@@ -10,6 +10,7 @@
 from simcore_postgres_database.models.products import products
 from simcore_postgres_database.utils_products import (
     execute_get_or_create_product_group,
+    get_default_product_name,
 )
 from simcore_postgres_database.utils_products_prices import (
     ProductPriceInfo,
@@ -54,7 +55,7 @@
 ]
 
 
-async def get_product_payment_fields(
+async def _get_product_payment_fields(
     conn: AsyncConnection, product_name: ProductName
 ) -> PaymentFieldsTuple:
     price_info = await get_product_latest_price_info_or_none(
@@ -98,7 +99,7 @@ async def list_products(
             async for row in rows:
                 name = row.name
 
-                payments = await get_product_payment_fields(conn, product_name=name)
+                payments = await _get_product_payment_fields(conn, product_name=name)
 
                 app_products.append(
                     Product(
@@ -130,9 +131,10 @@ async def get_product(
         async with pass_or_acquire_connection(self.engine, connection) as conn:
 
             result = await conn.execute(query)
-            row = result.one_or_none()
-            if row:
-                payments = await get_product_payment_fields(conn, product_name=row.name)
+            if row := result.one_or_none():
+                payments = await _get_product_payment_fields(
+                    conn, product_name=row.name
+                )
                 return Product(
                     **row._asdict(),
                     is_payment_enabled=payments.enabled,
@@ -143,7 +145,8 @@ async def get_product(
     async def get_default_product_name(
         self, connection: AsyncConnection | None = None
     ) -> ProductName:
-        raise NotImplementedError
+        async with pass_or_acquire_connection(self.engine, connection) as conn:
+            return await get_default_product_name(conn)
 
     async def get_product_latest_price_info_or_none(
         self, product_name: str, connection: AsyncConnection | None = None

services/web/server/src/simcore_service_webserver/products/_service.py

@@ -30,7 +30,8 @@ async def load_products(app: web.Application) -> list[Product]:
 
 
 async def get_default_product_name(app: web.Application) -> ProductName:
-    raise NotImplementedError
+    repo = ProductRepository.create_from_app(app)
+    return await repo.get_default_product_name()
 
 
 def get_product(app: web.Application, product_name: ProductName) -> Product:

services/web/server/src/simcore_service_webserver/products/_web_events.py

@@ -8,7 +8,7 @@
 
 from ..constants import APP_PRODUCTS_KEY
 from . import _service
-from .models import Product
+from ._models import Product
 
 _logger = logging.getLogger(__name__)