Skip to content

Commit 4438be3

Browse files
committed
fix(migrations): Remove old messenger code
1 parent 72af202 commit 4438be3

File tree

1 file changed

+0
-16
lines changed

1 file changed

+0
-16
lines changed

migrations/Version20240828180154.php

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -38,21 +38,6 @@ public function up(Schema $schema): void
3838
$this->addSql('CREATE UNIQUE INDEX UNIQ_IDENTIFIER_EMAIL ON "user" (email)');
3939
$this->addSql('COMMENT ON COLUMN "user".created_at IS \'(DC2Type:datetime_immutable)\'');
4040
$this->addSql('COMMENT ON COLUMN "user".updated_at IS \'(DC2Type:datetime_immutable)\'');
41-
$this->addSql('CREATE TABLE messenger_messages (id BIGSERIAL NOT NULL, body TEXT NOT NULL, headers TEXT NOT NULL, queue_name VARCHAR(190) NOT NULL, created_at TIMESTAMP(0) WITHOUT TIME ZONE NOT NULL, available_at TIMESTAMP(0) WITHOUT TIME ZONE NOT NULL, delivered_at TIMESTAMP(0) WITHOUT TIME ZONE DEFAULT NULL, PRIMARY KEY(id))');
42-
$this->addSql('CREATE INDEX IDX_75EA56E0FB7336F0 ON messenger_messages (queue_name)');
43-
$this->addSql('CREATE INDEX IDX_75EA56E0E3BD61CE ON messenger_messages (available_at)');
44-
$this->addSql('CREATE INDEX IDX_75EA56E016BA31DB ON messenger_messages (delivered_at)');
45-
$this->addSql('COMMENT ON COLUMN messenger_messages.created_at IS \'(DC2Type:datetime_immutable)\'');
46-
$this->addSql('COMMENT ON COLUMN messenger_messages.available_at IS \'(DC2Type:datetime_immutable)\'');
47-
$this->addSql('COMMENT ON COLUMN messenger_messages.delivered_at IS \'(DC2Type:datetime_immutable)\'');
48-
$this->addSql('CREATE OR REPLACE FUNCTION notify_messenger_messages() RETURNS TRIGGER AS $$
49-
BEGIN
50-
PERFORM pg_notify(\'messenger_messages\', NEW.queue_name::text);
51-
RETURN NEW;
52-
END;
53-
$$ LANGUAGE plpgsql;');
54-
$this->addSql('DROP TRIGGER IF EXISTS notify_trigger ON messenger_messages;');
55-
$this->addSql('CREATE TRIGGER notify_trigger AFTER INSERT OR UPDATE ON messenger_messages FOR EACH ROW EXECUTE PROCEDURE notify_messenger_messages();');
5641
$this->addSql('ALTER TABLE question ADD CONSTRAINT FK_B6F7494EEA1BEF35 FOREIGN KEY (schema_id) REFERENCES schema (id) NOT DEFERRABLE INITIALLY IMMEDIATE');
5742
$this->addSql('ALTER TABLE "user" ADD CONSTRAINT FK_8D93D649FE54D947 FOREIGN KEY (group_id) REFERENCES "group" (id) NOT DEFERRABLE INITIALLY IMMEDIATE');
5843
}
@@ -70,6 +55,5 @@ public function down(Schema $schema): void
7055
$this->addSql('DROP TABLE question');
7156
$this->addSql('DROP TABLE schema');
7257
$this->addSql('DROP TABLE "user"');
73-
$this->addSql('DROP TABLE messenger_messages');
7458
}
7559
}

0 commit comments

Comments
 (0)