Method upsert_script_derived

components/stores/src/config.rs:338–376

Upserts the derived state observed for a script during a vm boot.

(
        &self,
        guild_id: Id<GuildMarker>,
        script_id: u64,
        update: UpdateScriptDerived,
    )

    /// Upserts the derived state observed for a script during a vm boot.
    pub async fn upsert_script_derived(
        &self,
        guild_id: Id<GuildMarker>,
        script_id: u64,
        update: UpdateScriptDerived,
    ) -> ConfigStoreResult<()> {
        let commands_enc = serde_json::to_value(update.contributes.commands).unwrap();
        let intervals_enc = serde_json::to_value(update.contributes.interval_timers).unwrap();
        let settings_definitions_enc = serde_json::to_value(update.settings_definitions).unwrap();

        sqlx::query!(
            "
                    INSERT INTO guild_script_derived (script_id, guild_id, source_hash, \
             settings_hash, runtime_version, contributes_commands, contributes_interval_timers, \
             settings_definitions, updated_at)
                    VALUES ($1, $2, $3, $4, $5, $6, $7, $8, now())
                    ON CONFLICT (script_id) DO UPDATE SET
                    source_hash = $3,
                    settings_hash = $4,
                    runtime_version = $5,
                    contributes_commands = $6,
                    contributes_interval_timers = $7,
                    settings_definitions = $8,
                    updated_at = now();
                ",
            script_id as i64,
            guild_id.get() as i64,
            update.source_hash,
            update.settings_hash,
            SCRIPT_RUNTIME_VERSION,
            commands_enc,
            intervals_enc,
            settings_definitions_enc,
        )
        .execute(&self.pool)
        .await?;

        Ok(())
    }

    /// The inputs each of the guild's derived-state rows was observed under,
    /// used to skip the [Self::upsert_script_derived] write when nothing changed.