Method install

crates/create-rust-app_cli/src/plugins/tasks.rs:23–159

(&self, install_config: InstallConfig)

    }

    fn install(&self, install_config: InstallConfig) -> Result<()> {
        // ===============================
        // Check if the plugin is supported
        // ===============================

        if install_config.backend_database != BackendDatabase::Postgres {
            return Err(anyhow::anyhow!("The tasks plugin only supports Postgres"));
        }

        if install_config.backend_framework != BackendFramework::ActixWeb {
            return Err(anyhow::anyhow!("The tasks plugin only supports actix-web"));
        }

        // ===============================
        // Copy over template files
        // ===============================

        for filename in Asset::iter() {
            let file_contents = Asset::get(filename.as_ref()).unwrap();
            let mut file_path = std::path::PathBuf::from(&install_config.project_dir);
            file_path.push(filename.as_ref());
            let mut directory_path = std::path::PathBuf::from(&file_path);
            directory_path.pop();

            add_file_msg(filename.as_ref());
            std::fs::create_dir_all(directory_path)?;
            std::fs::write(file_path, file_contents.data)?;
        }

        // ===============================
        // Create migration
        // ===============================

        crate::content::migration::create(
            "plugin_tasks",
            indoc! {r#"CREATE EXTENSION IF NOT EXISTS "uuid-ossp";

CREATE TYPE fang_task_state AS ENUM ('new', 'in_progress', 'failed', 'finished', 'retried');

CREATE TABLE fang_tasks (
    id uuid PRIMARY KEY DEFAULT uuid_generate_v4(),
    metadata jsonb NOT NULL,
    error_message TEXT,
    state fang_task_state DEFAULT 'new' NOT NULL,
    task_type VARCHAR DEFAULT 'common' NOT NULL,
    uniq_hash CHAR(64),
    retries INTEGER DEFAULT 0 NOT NULL,
    scheduled_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
    created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
    updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
);

CREATE INDEX fang_tasks_state_index ON fang_tasks(state);
CREATE INDEX fang_tasks_type_index ON fang_tasks(task_type);
CREATE INDEX fang_tasks_scheduled_at_index ON fang_tasks(scheduled_at);
CREATE INDEX fang_tasks_uniq_hash ON fang_tasks(uniq_hash);
"#},
            r"DROP TABLE fang_tasks;",