Removing everything related to camera in favour of camera plugin

care/facility/api/serializers/asset.py

@@ -33,9 +33,6 @@
 )
 from care.users.api.serializers.user import UserBaseMinimumSerializer
 from care.utils.assetintegration.asset_classes import AssetClasses
-from care.utils.assetintegration.hl7monitor import HL7MonitorAsset
-from care.utils.assetintegration.onvif import OnvifAsset
-from care.utils.assetintegration.ventilator import VentilatorAsset
 from care.utils.models.validators import MiddlewareDomainAddressValidator
 from care.utils.queryset.facility import get_facility_queryset
 from care.utils.serializers.fields import ChoiceField
@@ -144,6 +141,7 @@ class AssetSerializer(ModelSerializer):
     id = UUIDField(source="external_id", read_only=True)
     status = ChoiceField(choices=StatusChoices, read_only=True)
     asset_type = ChoiceField(choices=AssetTypeChoices)
+    asset_class = serializers.CharField(required=False)
     location_object = AssetLocationSerializer(source="current_location", read_only=True)
     location = UUIDField(write_only=True, required=True)
     last_service = AssetServiceSerializer(read_only=True)
@@ -166,6 +164,13 @@ def validate_qr_code_id(self, value):
         return value
 
     def validate(self, attrs):
+        if (
+            "asset_class" in attrs
+            and attrs["asset_class"] not in Asset.get_asset_class_choices()
+        ):
+            error = f"{attrs['asset_class']} is not a valid asset class"
+            raise ValidationError(error)
+
         user = self.context["request"].user
         if "location" in attrs:
             location = get_object_or_404(
@@ -233,8 +238,9 @@ def validate(self, attrs):
                     )
                     .filter(
                         asset_class__in=[
-                            AssetClasses.ONVIF.name,
-                            AssetClasses.HL7MONITOR.name,
+                            member.name
+                            for member in AssetClasses.all()
+                            if member.value.can_be_linked_to_asset_bed()  # need better naming
                         ],
                         current_location__facility=current_location.facility_id,
                         resolved_middleware_hostname=middleware_hostname,
@@ -410,19 +416,12 @@ class Meta:
 
 
 class AssetActionSerializer(Serializer):
-    def action_choices():
-        actions = [
-            OnvifAsset.OnvifActions,
-            HL7MonitorAsset.HL7MonitorActions,
-            VentilatorAsset.VentilatorActions,
-        ]
-        choices = []
-        for action in actions:
-            choices += [(e.value, e.name) for e in action]
-        return choices
-
     type = ChoiceField(
-        choices=action_choices(),
+        choices=[
+            choice
+            for asset_class in AssetClasses.all()
+            for choice in asset_class.value.get_action_choices()
+        ],
         required=True,
     )
     data = JSONField(required=False)

care/facility/api/serializers/bed.py

@@ -121,11 +121,16 @@ def validate(self, attrs):
                 raise ValidationError(
                     {"non_field_errors": "Asset is already linked to bed"}
                 )
-            if asset.asset_class not in [
-                AssetClasses.HL7MONITOR.name,
-                AssetClasses.ONVIF.name,
-            ]:
-                raise ValidationError({"asset": "Asset is not a monitor or camera"})
+
+            valid_asset_classes = [
+                member.name
+                for member in AssetClasses.all()
+                if member.value.can_be_linked_to_asset_bed()
+            ]
+            if asset.asset_class not in valid_asset_classes:
+                raise ValidationError(
+                    {"asset": "This Asset Class cannot be linked to a bed"}
+                )
             attrs["asset"] = asset
             attrs["bed"] = bed
             if asset.current_location.facility.id != bed.facility.id:
@@ -315,6 +320,11 @@ def create(self, validated_data) -> ConsultationBed:
             if assets_ids := validated_data.pop("assets", None):
                 # we check assets in use here as they might have been in use in
                 # the previous bed
+                exclude_asset_classes = [
+                    member.name
+                    for member in AssetClasses.all()
+                    if not member.value.can_be_linked_to_consultation_bed()
+                ]
                 assets = (
                     Asset.objects.annotate(
                         is_in_use=Exists(
@@ -330,12 +340,7 @@ def create(self, validated_data) -> ConsultationBed:
                         external_id__in=assets_ids,
                         current_location__facility=consultation.facility_id,
                     )
-                    .exclude(
-                        asset_class__in=[
-                            AssetClasses.HL7MONITOR.name,
-                            AssetClasses.ONVIF.name,
-                        ]
-                    )
+                    .exclude(asset_class__in=exclude_asset_classes)
                     .values_list("external_id", flat=True)
                 )
                 not_found_assets = set(assets_ids) - set(assets)

care/facility/api/viewsets/asset.py

@@ -74,7 +74,6 @@
 
 logger = logging.getLogger(__name__)
 
-
 inverse_asset_type = inverse_choices(AssetTypeChoices)
 inverse_asset_status = inverse_choices(StatusChoices)
 
@@ -202,20 +201,15 @@ def filter_in_use_by_consultation(self, queryset, _, value):
 
     def filter_is_permanent(self, queryset, _, value):
         if value not in EMPTY_VALUES:
+            movable_assets = [
+                member.name
+                for member in AssetClasses.all()
+                if not member.value.is_movable()
+            ]
             if value:
-                queryset = queryset.filter(
-                    asset_class__in=[
-                        AssetClasses.ONVIF.name,
-                        AssetClasses.HL7MONITOR.name,
-                    ]
-                )
+                queryset = queryset.filter(asset_class__in=movable_assets)
             else:
-                queryset = queryset.exclude(
-                    asset_class__in=[
-                        AssetClasses.ONVIF.name,
-                        AssetClasses.HL7MONITOR.name,
-                    ]
-                )
+                queryset = queryset.exclude(asset_class__in=movable_assets)
         return queryset.distinct()
 
 
@@ -398,6 +392,15 @@ def operate_assets(self, request, *args, **kwargs):
                 or asset.current_location.middleware_address
                 or asset.current_location.facility.middleware_address
             )
+            available_asset_classes = [asset.name for asset in AssetClasses.all()]
+            if asset.asset_class not in available_asset_classes:
+                return Response(
+                    {
+                        "error": f"Cannot operate asset: Plugin for {asset.asset_class} is not installed",
+                    },
+                    status=status.HTTP_400_BAD_REQUEST,
+                )
+
             asset_class: BaseAssetIntegration = AssetClasses[asset.asset_class].value(
                 {
                     **asset.meta,
@@ -466,14 +469,14 @@ def list(self, request, *args, **kwargs):
                 {"middleware_hostname": "Invalid middleware hostname"},
                 status=status.HTTP_400_BAD_REQUEST,
             )
-
         queryset = (
             self.get_queryset()
             .filter(
                 current_location__facility=self.request.user.facility,
                 asset_class__in=[
-                    AssetClasses.ONVIF.name,
-                    AssetClasses.HL7MONITOR.name,
+                    member.name
+                    for member in AssetClasses.all()
+                    if member.value.can_be_linked_to_asset_bed()  # better naming required
                 ],
             )
             .annotate(

care/facility/migrations/0468_alter_asset_asset_class_alter_asset_meta.py

@@ -0,0 +1,25 @@
+# Generated by Django 5.1.2 on 2024-11-20 20:53
+
+import care.facility.models.json_schema.asset
+import care.utils.models.validators
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('facility', '0468_alter_facilitypatientstatshistory_unique_together_and_more'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='asset',
+            name='asset_class',
+            field=models.CharField(blank=True, default=None, max_length=20, null=True),
+        ),
+        migrations.AlterField(
+            model_name='asset',
+            name='meta',
+            field=models.JSONField(blank=True, default=dict, validators=[care.utils.models.validators.DynamicJSONFieldSchemaValidator(care.facility.models.json_schema.asset.get_dynamic_asset_meta)]),
+        ),
+    ]