# Generated for the Phase 1 Timetabler -> Resource Booking integration. import uuid import django.db.models.deletion from django.db import migrations, models class Migration(migrations.Migration): dependencies = [ ("api", "0099_ttactivity_max_day_ttactivity_max_hour_and_more"), ] operations = [ migrations.CreateModel( name="AppliedEngineResponse", fields=[ ("id", models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name="ID")), ("request_id", models.CharField(max_length=190, unique=True)), ("response_hash", models.CharField(max_length=64)), ("protocol_version", models.CharField(default="1", max_length=32)), ("change_set_id", models.UUIDField(db_index=True)), ( "outcome", models.CharField( choices=[("applied", "Applied"), ("no_changes", "No changes")], default="applied", max_length=24, ), ), ("response_received_at", models.DateTimeField(blank=True, null=True)), ("applied_at", models.DateTimeField(auto_now_add=True)), ], options={"db_table": "applied_engine_response"}, ), migrations.CreateModel( name="IntegrationAggregateVersion", fields=[ ("id", models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name="ID")), ("aggregate_type", models.CharField(max_length=64)), ("aggregate_id", models.CharField(max_length=190)), ("version", models.PositiveBigIntegerField(default=0)), ("updated_at", models.DateTimeField(auto_now=True)), ], options={"db_table": "integration_aggregate_version"}, ), migrations.CreateModel( name="PostCommitDelivery", fields=[ ("id", models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name="ID")), ("delivery_id", models.UUIDField(default=uuid.uuid4, editable=False, unique=True)), ("channel", models.CharField(default="kafka", max_length=32)), ("target", models.CharField(max_length=255)), ("method", models.CharField(max_length=120)), ("socket_id", models.CharField(blank=True, max_length=190, null=True)), ("payload", models.JSONField(default=dict)), ("correlation_id", models.CharField(blank=True, db_index=True, max_length=190, null=True)), ( "status", models.CharField( choices=[ ("pending", "Pending"), ("publishing", "Publishing"), ("retry", "Retry"), ("published", "Published"), ("dead_letter", "Dead letter"), ], db_index=True, default="pending", max_length=24, ), ), ("attempts", models.PositiveIntegerField(default=0)), ("next_attempt_at", models.DateTimeField(blank=True, db_index=True, null=True)), ("claimed_at", models.DateTimeField(blank=True, null=True)), ("published_at", models.DateTimeField(blank=True, null=True)), ("dead_letter_at", models.DateTimeField(blank=True, db_index=True, null=True)), ("last_error", models.TextField(blank=True, null=True)), ("created_at", models.DateTimeField(auto_now_add=True, db_index=True)), ], options={"db_table": "post_commit_delivery"}, ), migrations.CreateModel( name="EngineResponseQuarantine", fields=[ ("id", models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name="ID")), ("quarantine_id", models.UUIDField(default=uuid.uuid4, editable=False, unique=True)), ("fingerprint", models.CharField(max_length=64, unique=True)), ("request_id", models.CharField(blank=True, db_index=True, max_length=190, null=True)), ("response_hash", models.CharField(max_length=64)), ("reason", models.CharField(db_index=True, max_length=120)), ("payload", models.JSONField(default=dict)), ("headers", models.JSONField(default=dict)), ("occurrences", models.PositiveIntegerField(default=1)), ("first_seen_at", models.DateTimeField(auto_now_add=True)), ("last_seen_at", models.DateTimeField(auto_now=True)), ], options={"db_table": "engine_response_quarantine"}, ), migrations.CreateModel( name="IntegrationOutbox", fields=[ ("id", models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name="ID")), ("event_id", models.UUIDField(default=uuid.uuid4, editable=False, unique=True)), ("schema_version", models.CharField(default="1", max_length=32)), ("event_type", models.CharField(max_length=120)), ("aggregate_type", models.CharField(max_length=64)), ("aggregate_id", models.CharField(max_length=190)), ("event_version", models.PositiveBigIntegerField()), ("ordering_key", models.CharField(db_index=True, max_length=255)), ("change_set_id", models.UUIDField(db_index=True, default=uuid.uuid4)), ("origin", models.CharField(default="timetabler", max_length=64)), ("correlation_id", models.CharField(blank=True, db_index=True, max_length=190, null=True)), ("causation_id", models.CharField(blank=True, max_length=190, null=True)), ("request_id", models.CharField(blank=True, db_index=True, max_length=190, null=True)), ("actor_id", models.BigIntegerField(blank=True, null=True)), ("payload", models.JSONField(default=dict)), ( "status", models.CharField( choices=[ ("pending", "Pending"), ("publishing", "Publishing"), ("retry", "Retry"), ("published", "Published"), ("dead_letter", "Dead letter"), ("superseded", "Superseded by replay"), ], db_index=True, default="pending", max_length=24, ), ), ("attempts", models.PositiveIntegerField(default=0)), ("next_attempt_at", models.DateTimeField(blank=True, db_index=True, null=True)), ("last_error", models.TextField(blank=True, null=True)), ("claimed_at", models.DateTimeField(blank=True, null=True)), ("published_at", models.DateTimeField(blank=True, null=True)), ("dead_letter_at", models.DateTimeField(blank=True, null=True)), ("superseded_at", models.DateTimeField(blank=True, null=True)), ("replay_requested_by", models.BigIntegerField(blank=True, null=True)), ("replay_reason", models.TextField(blank=True, null=True)), ("created_at", models.DateTimeField(auto_now_add=True, db_index=True)), ( "replay_of", models.ForeignKey( blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name="replays", to="api.integrationoutbox", ), ), ], options={"db_table": "integration_outbox"}, ), migrations.AddConstraint( model_name="integrationaggregateversion", constraint=models.UniqueConstraint( fields=("aggregate_type", "aggregate_id"), name="uq_integration_aggregate_version", ), ), migrations.AddConstraint( model_name="integrationoutbox", constraint=models.UniqueConstraint( fields=("aggregate_type", "aggregate_id", "event_version"), name="uq_integration_outbox_aggregate_version", ), ), migrations.AddIndex( model_name="integrationoutbox", index=models.Index( fields=["status", "next_attempt_at", "created_at"], name="ix_outbox_eligible", ), ), migrations.AddIndex( model_name="integrationoutbox", index=models.Index( fields=["status", "created_at"], name="ix_outbox_state_created", ), ), migrations.AddIndex( model_name="integrationoutbox", index=models.Index( fields=["aggregate_type", "aggregate_id", "event_version"], name="ix_outbox_aggregate_order", ), ), migrations.AddIndex( model_name="postcommitdelivery", index=models.Index( fields=["status", "next_attempt_at", "created_at"], name="ix_delivery_eligible", ), ), ]