feat(config): add config for dryccfile

Author: duanhongyi

rootfs/api/admissions.py

@@ -30,22 +30,27 @@ def handle(self, request: Request) -> bool:
         app = models.app.App.objects.filter(id=app_id).first()
         ptype = request["object"]["metadata"].get("labels", {}).get("type", "")
         if app and ptype:
-            status = request["object"]["status"]
-            replicas = request["object"]["spec"].get("replicas", 0)
-            if "active" in status:
-                replicas += 1
-            elif "succeeded" in status or "failed" in status:
-                replicas -= 1
-            replicas = 0 if replicas < 0 else replicas
-            if app.structure.get(ptype, 0) != replicas:
-                models.app.App.objects.filter(id=app.id).update(
-                    structure=Func(
-                        F("structure"),
-                        Value([ptype]),
-                        Value(replicas, JSONField()),
-                        function="jsonb_set",
+            lock = app.lock()
+            try:
+                lock.acquire()
+                status = request["object"]["status"]
+                replicas = request["object"]["spec"].get("replicas", 0)
+                if "active" in status:
+                    replicas += 1
+                elif "succeeded" in status or "failed" in status:
+                    replicas -= 1
+                replicas = 0 if replicas < 0 else replicas
+                if app.structure.get(ptype, 0) != replicas:
+                    models.app.App.objects.filter(id=app.id).update(
+                        structure=Func(
+                            F("structure"),
+                            Value([ptype]),
+                            Value(replicas, JSONField()),
+                            function="jsonb_set",
+                        )
                     )
-                )
+            finally:
+                lock.release()
         return True
 
 
@@ -70,16 +75,21 @@ def handle(self, request: Request) -> bool:
             if key == "type":
                 ptype = value
         if app and ptype:
-            replicas = request["object"]["spec"].get("replicas", 0)
-            if app.structure.get(ptype, 0) != replicas:
-                models.app.App.objects.filter(id=app.id).update(
-                    structure=Func(
-                        F("structure"),
-                        Value([ptype]),
-                        Value(replicas, JSONField()),
-                        function="jsonb_set",
+            lock = app.lock()
+            try:
+                lock.acquire()
+                replicas = request["object"]["spec"].get("replicas", 0)
+                if app.structure.get(ptype, 0) != replicas:
+                    models.app.App.objects.filter(id=app.id).update(
+                        structure=Func(
+                            F("structure"),
+                            Value([ptype]),
+                            Value(replicas, JSONField()),
+                            function="jsonb_set",
+                        )
                     )
-                )
+            finally:
+                lock.release()
         return True
 
 

rootfs/api/migrations/0017_migration_deployed_ptypes.py

@@ -5,7 +5,7 @@
 
 
 def migration_deployed_ptypes(apps, schema_editor):
-    for release in Release.objects.all():
+    for release in Release.objects.all().using("default"):
         deployed_ptypes = set()
         for condition in release.conditions:
             if condition["ptypes"] is None:

rootfs/api/migrations/0018_config_values_refs.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.16 on 2024-11-12 02:14
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('api', '0017_migration_deployed_ptypes'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='config',
+            name='values_refs',
+            field=models.JSONField(blank=True, default=dict),
+        ),
+    ]

rootfs/api/migrations/0019_migration_config_values_and_typed_values.py

@@ -0,0 +1,38 @@
+# Generated by Django 4.2.15 on 2024-09-06 03:58
+import json
+from django.db import connection, migrations
+from api.models.config import Config
+
+
+def migration_values(apps, schema_editor):
+    with connection.cursor() as cursor:
+        cursor.execute("SELECT uuid,values,typed_values FROM api_config")
+        for uuid, values, typed_values in cursor:
+            new_values = []
+            config = Config.objects.using('default').get(pk=uuid)
+            for name, value in json.loads(values).items():
+                new_values.append({
+                    "name": name,
+                    "group": "global",
+                    "value": value
+                })
+            for ptype, values in json.loads(typed_values).items():
+                for name, value in values.items():
+                    new_values.append({
+                        "name": name,
+                        "ptype": ptype,
+                        "value": value
+                    })
+            config.values = new_values
+            config.save(ignore_update_fields=config.allof_fields)
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('api', '0018_config_values_refs'),
+    ]
+
+    operations = [
+        migrations.RunPython(migration_values),
+    ]

rootfs/api/migrations/0020_remove_config_typed_values_alter_config_values.py

@@ -0,0 +1,22 @@
+# Generated by Django 4.2.16 on 2024-11-06 06:22
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('api', '0019_migration_config_values_and_typed_values'),
+    ]
+
+    operations = [
+        migrations.RemoveField(
+            model_name='config',
+            name='typed_values',
+        ),
+        migrations.AlterField(
+            model_name='config',
+            name='values',
+            field=models.JSONField(blank=True, default=list),
+        ),
+    ]