Feature/sckan 226

backend/composer/enums.py

@@ -61,6 +61,7 @@ class CSState(models.TextChoices):
     CONNECTION_MISSING = "connection_missing"
     NPO_APPROVED = "npo_approved"
     EXPORTED = "exported"
+    INVALID = "invalid"
 
 
 class NoteType(models.TextChoices):

backend/composer/management/commands/ingest_statements.py

@@ -5,5 +5,13 @@
 class Command(BaseCommand):
     help = "Ingests Statements from neurondm pyp package"
 
+    def add_arguments(self, parser):
+        parser.add_argument(
+            '--update_upstream',
+            action='store_true',
+            help='Set this flag to update upstream statements.',
+        )
+
     def handle(self, *args, **options):
-        ingest_statements()
+        update_upstream = options['update_upstream']
+        ingest_statements(update_upstream)

backend/composer/migrations/0033_alter_connectivitystatement_reference_uri.py

@@ -0,0 +1,17 @@
+# Generated by Django 4.1.4 on 2024-01-05 15:46
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+    dependencies = [
+        ("composer", "0032_alter_connectivitystatement_projection"),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name="connectivitystatement",
+            name="reference_uri",
+            field=models.URLField(blank=True, null=True, unique=True),
+        ),
+    ]

backend/composer/models.py

@@ -413,7 +413,7 @@ class ConnectivityStatement(models.Model):
     )
     apinatomy_model = models.CharField(max_length=200, null=True, blank=True)
     additional_information = models.TextField(null=True, blank=True)
-    reference_uri = models.URLField(null=True, blank=True)
+    reference_uri = models.URLField(null=True, blank=True, unique=True)
     functional_circuit_role = models.ForeignKey(
         FunctionalCircuitRole,
         on_delete=models.DO_NOTHING,
@@ -443,6 +443,7 @@ def __str__(self):
             CSState.REJECTED,
             CSState.NPO_APPROVED,
             CSState.EXPORTED,
+            CSState.INVALID
         ],
         permission=lambda instance, user: ConnectivityStatementService.has_permission_to_transition_to_compose_now(
             instance, user
@@ -500,6 +501,16 @@ def npo_approved(self, *args, **kwargs):
     def exported(self, *args, **kwargs):
         ...
 
+    @transition(
+        field=state,
+        source=CSState.EXPORTED,
+        target=CSState.INVALID,
+        permission=lambda instance, user: ConnectivityStatementService.has_permission_to_transition_to_invalid(
+            instance, user
+        ), )
+    def invalid(self, *args, **kwargs):
+        ...
+
     @property
     def export_id(self):
         return f"CPR:{self.id:06d}"
@@ -590,7 +601,7 @@ class Destination(AbstractConnectionLayer):
         choices=DestinationType.choices,
         default=DestinationType.UNKNOWN
     )
-    
+
     objects = DestinationManager()
 
     class Meta:
@@ -604,7 +615,7 @@ class Meta:
 
 class Via(AbstractConnectionLayer):
     anatomical_entities = models.ManyToManyField(AnatomicalEntity, blank=True, related_name='via_connection_layers')
-    
+
     objects = ViaManager()
 
     type = models.CharField(