20260604172448_event_sourced_session_input.ts · part 1

18 text occurrences from packages/core/src/database/migration/20260604172448_event_sourced_session_input.ts, part 1. Every entry preserves the shipped literal and its saved verdict or selection reason.

File contents and all parts · All files

DELETE FROM `session_input`;

DELETE FROM `session_message`;

DELETE FROM `event`;

DELETE FROM `event_sequence`;

UPDATE `session` SET `workspace_id` = NULL;

DELETE FROM `workspace`;

DROP INDEX IF EXISTS `event_aggregate_seq_idx`;

CREATE UNIQUE INDEX `event_aggregate_seq_idx` ON `event` (`aggregate_id`,`seq`);

DROP INDEX IF EXISTS `session_message_session_seq_idx`;

CREATE UNIQUE INDEX `session_message_session_seq_idx` ON `session_message` (`session_id`,`seq`);

PRAGMA foreign_keys=OFF;

        CREATE TABLE `__new_session_input` (
          `id` text PRIMARY KEY,
          `session_id` text NOT NULL,
          `prompt` text NOT NULL,
          `delivery` text NOT NULL,
          `admitted_seq` integer NOT NULL,
          `promoted_seq` integer,
          `time_created` integer NOT NULL,
          CONSTRAINT `fk_session_input_session_id_session_id_fk` FOREIGN KEY (`session_id`) REFERENCES `session`(`id`) ON DELETE CASCADE
        );
      

DROP TABLE `session_input`;

ALTER TABLE `__new_session_input` RENAME TO `session_input`;

PRAGMA foreign_keys=ON;

CREATE INDEX `session_input_session_pending_delivery_seq_idx` ON `session_input` (`session_id`,`promoted_seq`,`delivery`,`admitted_seq`);

CREATE UNIQUE INDEX `session_input_session_admitted_seq_idx` ON `session_input` (`session_id`,`admitted_seq`);

CREATE UNIQUE INDEX `session_input_session_promoted_seq_idx` ON `session_input` (`session_id`,`promoted_seq`);