Initial Debezium Outbox support

rbac/management/debezium/__init__.py

@@ -0,0 +1 @@
+# noqa

rbac/management/debezium/model.py

@@ -0,0 +1,31 @@
+#
+# Copyright 2019 Red Hat, Inc.
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <https://www.gnu.org/licenses/>.
+#
+
+"""Debezium model for outbox messages."""
+from uuid import uuid4
+
+from django.db import models
+
+
+class Outbox(models.Model):
+    """Outbox Table for Debezium."""
+
+    id = models.UUIDField(primary_key=True, default=uuid4, editable=False)
+    aggregatetype = models.CharField(max_length=255)
+    aggregateid = models.CharField(max_length=255)
+    event_type = models.CharField(max_length=255, db_column="type")
+    payload = models.JSONField()

rbac/management/migrations/0048_outbox.py

@@ -0,0 +1,32 @@
+# Generated by Django 4.2.15 on 2024-08-21 17:38
+
+from django.db import migrations, models
+import uuid
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ("management", "0047_rolemapping_rolev2_rolemapping_role_v2_rolebinding"),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name="Outbox",
+            fields=[
+                (
+                    "id",
+                    models.UUIDField(
+                        default=uuid.uuid4,
+                        editable=False,
+                        primary_key=True,
+                        serialize=False,
+                    ),
+                ),
+                ("aggregatetype", models.CharField(max_length=255)),
+                ("aggregateid", models.CharField(max_length=255)),
+                ("event_type", models.CharField(db_column="type", max_length=255)),
+                ("payload", models.JSONField()),
+            ],
+        ),
+    ]

rbac/management/models.py

@@ -24,3 +24,4 @@
 from management.policy.model import Policy
 from management.audit_log.model import AuditLog
 from management.workspace.model import Workspace
+from management.debezium.model import Outbox