DBC22-5477: DMS layer

Author: ray-oxd

.env.example

@@ -79,6 +79,7 @@ DRIVEBC_COSTAL_FERRY_DATA_URL=<costal ferry data url>
 DRIVEBC_OPENMAPS_API_URL=<openmaps api url>
 WEATHER_CLIENT_ID=<weather client id>
 WEATHER_CLIENT_SECRET=<weather client secret>
+DRIVEBC_DMS_API_BASE_URL=<dms api url>
 
 # TESTS
 # optional: set to config.test.DbcRunner to user test runner allowing for

src/backend/apps/dms/__init__.py

@@ -0,0 +1,8 @@
+from apps.dms.models import Dms
+from django.contrib.gis import admin
+
+
+class DmsAdmin(admin.GISModelAdmin):
+    readonly_fields = ('id', )
+
+admin.site.register(Dms, DmsAdmin)

src/backend/apps/dms/admin.py

@@ -0,0 +1,5 @@
+from django.apps import AppConfig
+
+
+class DmsConfig(AppConfig):
+    name = 'apps.dms'

src/backend/apps/dms/apps.py

@@ -0,0 +1,7 @@
+from apps.dms.tasks import populate_all_dms_data
+from django.core.management.base import BaseCommand
+
+
+class Command(BaseCommand):
+    def handle(self, *args, **options):
+        populate_all_dms_data()

src/backend/apps/dms/management/__init__.py

@@ -0,0 +1,45 @@
+# Generated by Django 5.2.10 on 2026-01-28 15:11
+
+import django.contrib.gis.db.models.fields
+import django_prometheus.models
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    initial = True
+
+    dependencies = [
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='Dms',
+            fields=[
+                ('created_at', models.DateTimeField(auto_now_add=True)),
+                ('modified_at', models.DateTimeField(auto_now=True)),
+                ('id', models.CharField(blank=True, default='', max_length=128, primary_key=True, serialize=False)),
+                ('name', models.CharField(blank=True, default='', max_length=128)),
+                ('name_override', models.CharField(blank=True, max_length=128)),
+                ('category', models.CharField(blank=True, default='', max_length=128)),
+                ('description', models.CharField(blank=True, default='', max_length=750)),
+                ('roadway_name', models.CharField(blank=True, default='', max_length=128)),
+                ('roadway_direction', models.CharField(blank=True, default='', max_length=64)),
+                ('static_text', models.CharField(blank=True, default='', max_length=256)),
+                ('message_text', models.CharField(blank=True, default='', max_length=512)),
+                ('status', models.CharField(blank=True, default='', max_length=64)),
+                ('location', django.contrib.gis.db.models.fields.GeometryField(blank=True, null=True, srid=4326)),
+                ('updated_datetime_utc', models.DateTimeField(blank=True, null=True)),
+                ('message_expiry_datetime_utc', models.DateTimeField(blank=True, null=True)),
+                ('cache_datetime_utc', models.DateTimeField(blank=True, null=True)),
+                ('message_display_1', models.TextField(blank=True, default='')),
+                ('message_display_2', models.TextField(blank=True, default='')),
+                ('message_display_3', models.TextField(blank=True, default='')),
+                ('is_on', models.BooleanField(default=True)),
+            ],
+            options={
+                'abstract': False,
+            },
+            bases=(django_prometheus.models.ExportModelOperationsMixin('dms'), models.Model),
+        ),
+    ]

src/backend/apps/dms/management/commands/__init__.py

@@ -0,0 +1,73 @@
+from apps.shared.models import BaseModel
+from django.contrib.gis.db import models
+from django.contrib.gis.geos import Point
+from django.core.cache import cache
+from django_prometheus.models import ExportModelOperationsMixin
+from apps.shared.enums import CacheKey
+import re
+from typing import Tuple
+
+NTCIP_TOKEN_PATTERN = re.compile(r"\[[^\]]+\]")
+
+def parse_dms_pages(raw: str) -> Tuple[str, str, str]:
+    if not raw:
+        return "", "", ""
+
+    text = raw
+
+    # Normalize newlines
+    text = re.sub(r"\[nl\]", "\n", text, flags=re.IGNORECASE)
+
+    # Split pages BEFORE removing other tokens
+    pages = re.split(r"\[np\]", text, flags=re.IGNORECASE)
+
+    cleaned_pages = []
+
+    for page in pages[:3]:  # max 3 pages
+        # Remove remaining NTCIP formatting tokens
+        page = NTCIP_TOKEN_PATTERN.sub("", page)
+
+        # Normalize whitespace
+        page = re.sub(r"[ \t]+", " ", page)
+        page = re.sub(r"\n{3,}", "\n\n", page)
+
+        cleaned_pages.append(page.strip())
+
+    # Pad missing pages
+    while len(cleaned_pages) < 3:
+        cleaned_pages.append("")
+
+    return tuple(cleaned_pages)
+
+
+class Dms(ExportModelOperationsMixin('dms'), BaseModel):
+    id = models.CharField(primary_key=True, max_length=128, blank=True, default='')
+    name = models.CharField(max_length=128, blank=True, default='')
+    name_override = models.CharField(blank=True, max_length=128)
+    category = models.CharField(max_length=128, blank=True, default='')
+    description = models.CharField(max_length=750, blank=True, default='')
+    roadway_name = models.CharField(max_length=128, blank=True, default='')
+    roadway_direction = models.CharField(max_length=64, blank=True, default='')
+    static_text = models.CharField(max_length=256, blank=True, default='')
+    message_text = models.CharField(max_length=512, blank=True, default='')
+    status = models.CharField(max_length=64, blank=True, default='')
+    location = models.GeometryField(blank=True, null=True)
+    updated_datetime_utc = models.DateTimeField(blank=True, null=True)
+    message_expiry_datetime_utc = models.DateTimeField(blank=True, null=True)
+    cache_datetime_utc = models.DateTimeField(blank=True, null=True)
+
+    message_display_1 = models.TextField(blank=True, default="")
+    message_display_2 = models.TextField(blank=True, default="")
+    message_display_3 = models.TextField(blank=True, default="")
+
+    is_on = models.BooleanField(default=True)
+
+    def __str__(self):
+        return f"dms for {self.pk}"
+
+    def save(self, *args, **kwargs):
+        self.message_display_1, self.message_display_2, self.message_display_3 = (
+            parse_dms_pages(self.message_text)
+        )
+        super().save(*args, **kwargs)
+        cache.delete(CacheKey.DMS_LIST)