Update carlos pr

CHANGELOG.md

@@ -2,6 +2,14 @@
 
 Observes [Semantic Versioning](https://semver.org/spec/v2.0.0.html) standard and [Keep a Changelog](https://keepachangelog.com/en/1.0.0/) convention.
 
+## [0.5.0] - 2022-09-01
+### Fixed
+- Bugs with UUID and NaN in component_interface.py JSON encoder PR #128
+
+### Added
+- Support for creating virtual modules with `-` in the schema name, use `__` PR #128
+- Support for new `antd-table`, old table filtering will no longer work and the entire table will be deprecated in a later release PR #128
+
 ## [0.4.1] - 2022-03-24
 ### Fixed
 - Bug with otumat version not being tied to the latest PR #119

pharus/component_interface.py

@@ -1,6 +1,5 @@
 """This module is a GUI component library of various common interfaces."""
 import json
-from base64 import b64decode
 import datajoint as dj
 import re
 import inspect
@@ -12,6 +11,7 @@
 import types
 import io
 import numpy as np
+from uuid import UUID
 from functools import reduce
 
 
@@ -36,6 +36,10 @@ class NumpyEncoder(json.JSONEncoder):
     def default(self, o):
         if type(o) in self.npmap:
             return self.npmap[type(o)](o)
+        if type(o) is UUID:
+            return str(o)
+        if type(o) is str and o == "NaN":
+            return None
         if type(o) in (datetime, date):
             return o.isoformat()
         return json.JSONEncoder.default(self, o)
@@ -72,7 +76,7 @@ def __init__(self, name, component_config, static_config, jwt_payload: dict):
         self.vm_list = [
             dj.VirtualModule(
                 s,
-                s,
+                s.replace("__", "-"),
                 connection=dj.conn(
                     host=jwt_payload["databaseAddress"],
                     user=jwt_payload["username"],
@@ -314,30 +318,35 @@ def __init__(self, *args, **kwargs):
     def dj_query_route(self):
         fetch_metadata = self.fetch_metadata
         record_header, table_records, total_count = _DJConnector._fetch_records(
-            query=fetch_metadata["query"] & self.restriction[0],
+            query=fetch_metadata["query"] & self.restriction,
             fetch_args=fetch_metadata["fetch_args"],
-            **{
-                k: (
-                    int(v)
-                    if k in ("limit", "page")
-                    else (
-                        v.split(",")
-                        if k == "order"
-                        else json.loads(b64decode(v.encode("utf-8")).decode("utf-8"))
-                    )
-                )
-                for k, v in request.args.items()
-            },
+            limit=int(request.args["limit"]) if "limit" in request.args else 1000,
+            page=int(request.args["page"]) if "page" in request.args else 1,
+            order=request.args["order"].split(",") if "order" in request.args else None,
         )
-        return dict(
-            recordHeader=record_header, records=table_records, totalCount=total_count
+
+        return NumpyEncoder.dumps(
+            dict(
+                recordHeader=record_header,
+                records=table_records,
+                totalCount=total_count,
+            )
         )
 
     def attributes_route(self):
         attributes_meta = _DJConnector._get_attributes(self.fetch_metadata["query"])
-        return dict(
-            attributeHeaders=attributes_meta["attribute_headers"],
-            attributes=attributes_meta["attributes"],
+        query = self.fetch_metadata["query"] & self.restriction[0]
+        unique_values = []
+        for key in query.heading.attributes.keys():
+            result = (dj.U(key) & query).fetch()
+            unique_values.append(
+                [dict({"text": str(x[0]), "value": x[0]}) for x in result]
+            )
+        return NumpyEncoder.dumps(
+            dict(
+                attributeHeaders=attributes_meta["attribute_headers"],
+                attributes=attributes_meta["attributes"],
+            )
         )
 
 
@@ -381,8 +390,12 @@ def dj_query_route(self):
             query=fetch_metadata["query"] & self.restriction,
             fetch_args=fetch_metadata["fetch_args"],
         )
-        return dict(
-            recordHeader=record_header, records=table_records, totalCount=total_count
+        return NumpyEncoder.dumps(
+            dict(
+                recordHeader=record_header,
+                records=table_records,
+                totalCount=total_count,
+            )
         )
 
 
@@ -441,6 +454,7 @@ def dj_query_route(self):
     "basicquery": FetchComponent,
     "plot:plotly:stored_json": PlotPlotlyStoredjsonComponent,
     "table": TableComponent,
+    "antd-table": TableComponent,
     "metadata": MetadataComponent,
     "file:image:attach": FileImageAttachComponent,
     "slider": FetchComponent,

pharus/dynamic_api_gen.py

@@ -113,14 +113,22 @@ def {method_name}() -> dict:
                             method_name_type="dj_query_route",
                         )
                     )
-
                 for comp_name, comp in (
                     grid["component_templates"]
                     if "component_templates" in grid
                     else grid["components"]
                 ).items():
                     if re.match(
-                        r"^(table|metadata|plot|file|slider|dropdown-query|form).*$",
+                        r"^("
+                        + r"table|"
+                        + r"antd-table|"
+                        + r"metadata|"
+                        + r"plot|"
+                        + r"file|"
+                        + r"slider|"
+                        + r"dropdown-query|"
+                        + r"form"
+                        + r").*$",
                         comp["type"],
                     ):
                         f.write(

pharus/interface.py

@@ -248,6 +248,10 @@ def _get_attributes(query) -> dict:
                         attribute_info.nullable,
                         attribute_info.default,
                         attribute_info.autoincrement,
+                        [
+                            dict({"text": str(x[0]), "value": x[0]})
+                            for x in (dj.U(attribute_name) & query).fetch()
+                        ],
                     )
                 )
             else:
@@ -258,6 +262,10 @@ def _get_attributes(query) -> dict:
                         attribute_info.nullable,
                         attribute_info.default,
                         attribute_info.autoincrement,
+                        [
+                            dict({"text": str(x[0]), "value": x[0]})
+                            for x in (dj.U(attribute_name) & query).fetch()
+                        ],
                     )
                 )
 

pharus/version.py

@@ -1,2 +1,2 @@
 """Package metadata."""
-__version__ = "0.4.1"
+__version__ = "0.5.0"

tests/test_api_gen.py

@@ -77,17 +77,56 @@ def test_get_attributes(token, client, schemas_simple):
         "attributeHeaders": ["name", "type", "nullable", "default", "autoincrement"],
         "attributes": {
             "primary": [
-                ["a_id", "int", False, None, False],
-                ["b_id", "int", False, None, False],
+                [
+                    "a_id",
+                    "int",
+                    False,
+                    None,
+                    False,
+                    [{"text": "0", "value": 0}, {"text": "1", "value": 1}],
+                ],
+                [
+                    "b_id",
+                    "int",
+                    False,
+                    None,
+                    False,
+                    [
+                        {"text": "10", "value": 10},
+                        {"text": "11", "value": 11},
+                        {"text": "21", "value": 21},
+                    ],
+                ],
             ],
             "secondary": [
-                ["a_name", "varchar(30)", False, None, False],
-                ["b_number", "float", False, None, False],
+                [
+                    "a_name",
+                    "varchar(30)",
+                    False,
+                    None,
+                    False,
+                    [
+                        {"text": "Raphael", "value": "Raphael"},
+                        {"text": "Bernie", "value": "Bernie"},
+                    ],
+                ],
+                [
+                    "b_number",
+                    "float",
+                    False,
+                    None,
+                    False,
+                    [
+                        {"text": "22.12", "value": 22.12},
+                        {"text": "-1.21", "value": -1.21},
+                        {"text": "7.77", "value": 7.77},
+                    ],
+                ],
             ],
         },
     }
 
-    assert expected_json == REST_response.get_json()
+    assert expected_json == REST_response.get_json(force=True)
 
 
 def test_dynamic_restriction(token, client, schemas_simple):