Function publish_plugin_version

components/webapi/src/routes/plugins.rs:272–308

(
    State(state): State<AppState>,
    Extension(session): Extension<LoggedInSession>,
    Extension(plugin): Extension<Plugin>,
    Json(body): Json<PublishPluginVersionData>,
)

}

pub async fn publish_plugin_version(
    State(state): State<AppState>,
    Extension(session): Extension<LoggedInSession>,
    Extension(plugin): Extension<Plugin>,
    Json(body): Json<PublishPluginVersionData>,
) -> ApiResult<impl IntoResponse> {
    if let Err(err) = validate(&body, &()) {
        return Err(ApiErrorResponse::ValidationFailed(err));
    }

    if plugin.author_id != session.session.user.id {
        return Err(ApiErrorResponse::NoAccessToPlugin);
    }

    let guilds = state
        .db
        .publish_script_plugin_version(plugin.id, body.new_source)
        .await
        .map_err(|err| {
            error!(?err, "failed updating plugin");
            ApiErrorResponse::InternalError
        })?;

    // restart relevant guild vms
    // TODO: this should be done as a background task, and potentially throttled to avoid a spike
    for guild_id in guilds {
        if let Err(err) = state
            .bot_rpc_client
            .reload_vm(botrpc::types::GuildSpecifier { guild_id })
            .await
        {
            error!(%err, "failed reloading guild vm");
        }
    }

    Ok(EmptyResponse)
}

#[derive(Deserialize)]
pub struct GuildAddPluginData {