fix(servers): use correct timeout for sleeping (#1076)

<!-- Please make sure there is an issue that this PR is correlated to. -->

## Changes

<!-- If there are frontend changes, please include screenshots. -->

svc/api/servers/src/route/servers.rs

@@ -180,6 +180,19 @@ pub async fn destroy(
 
 	assert::server_for_env(&ctx, server_id, game_id, env_id).await?;
 
+	ensure_with!(
+		query.override_kill_timeout.unwrap_or(0) >= 0,
+		API_BAD_QUERY_PARAMETER,
+		parameter = "override_kill_timeout",
+		error = "must be positive"
+	);
+	ensure_with!(
+		query.override_kill_timeout.unwrap_or(0) < 2 * 60 * 60 * 1000,
+		API_BAD_QUERY_PARAMETER,
+		parameter = "override_kill_timeout",
+		error = "cannot be longer than 2 hours"
+	);
+
 	let mut sub = ctx
 		.subscribe::<ds::workflows::server::destroy::DestroyStarted>(&json!({
 			"server_id": server_id,
@@ -191,7 +204,7 @@ pub async fn destroy(
 			"server_id": server_id,
 		}),
 		ds::workflows::server::Destroy {
-			override_kill_timeout_ms: query.override_kill_timeout.unwrap_or_default(),
+			override_kill_timeout_ms: query.override_kill_timeout,
 		},
 	)
 	.await?;

svc/pkg/ds/src/workflows/server/destroy.rs

@@ -1,3 +1,5 @@
+use std::convert::TryInto;
+
 use chirp_workflow::prelude::*;
 use futures_util::FutureExt;
 use serde_json::json;
@@ -13,7 +15,7 @@ pub struct DestroyComplete {}
 #[derive(Debug, Serialize, Deserialize)]
 pub(crate) struct Input {
 	pub server_id: Uuid,
-	pub override_kill_timeout_ms: i64,
+	pub override_kill_timeout_ms: Option<i64>,
 }
 
 #[workflow]
@@ -43,6 +45,9 @@ pub(crate) async fn ds_server_destroy(ctx: &mut WorkflowCtx, input: &Input) -> G
 			if let Some(alloc_id) = &dynamic_server.alloc_id {
 				ctx.activity(KillAllocInput {
 					alloc_id: alloc_id.clone(),
+					kill_timeout_ms: input
+						.override_kill_timeout_ms
+						.unwrap_or(dynamic_server.kill_timeout_ms),
 				})
 				.await?;
 			}
@@ -69,6 +74,7 @@ struct UpdateDbInput {
 struct UpdateDbOutput {
 	server_id: Uuid,
 	datacenter_id: Uuid,
+	kill_timeout_ms: i64,
 	dispatched_job_id: Option<String>,
 	alloc_id: Option<String>,
 }
@@ -96,6 +102,7 @@ async fn update_db(ctx: &ActivityCtx, input: &UpdateDbInput) -> GlobalResult<Upd
 				RETURNING
 					s1.server_id,
 					s1.datacenter_id,
+					s1.kill_timeout_ms,
 					sn.nomad_dispatched_job_id AS dispatched_job_id,
 					sn.nomad_alloc_id AS alloc_id
 				",
@@ -155,16 +162,20 @@ async fn delete_job(ctx: &ActivityCtx, input: &DeleteJobInput) -> GlobalResult<D
 #[derive(Debug, Serialize, Deserialize, Hash)]
 struct KillAllocInput {
 	alloc_id: String,
+	kill_timeout_ms: i64,
 }
 
+/// Kills the server's allocation after 30 seconds
+///
+/// See `docs/packages/job/JOB_DRAINING_AND_KILL_TIMEOUTS.md`
 #[activity(KillAlloc)]
+#[timeout = 45]
 async fn kill_alloc(ctx: &ActivityCtx, input: &KillAllocInput) -> GlobalResult<()> {
-	// Kills the allocation after 30 seconds
-	//
-	// See `docs/packages/job/JOB_DRAINING_AND_KILL_TIMEOUTS.md`
-
 	// TODO: Move this to a workflow sleep RVTEE-497
-	tokio::time::sleep(util_job::JOB_STOP_TIMEOUT).await;
+	tokio::time::sleep(std::time::Duration::from_millis(
+		input.kill_timeout_ms.try_into()?,
+	))
+	.await;
 
 	// TODO: Handle 404 safely. See RVTEE-498
 	if let Err(err) = signal_allocation(

svc/pkg/ds/src/workflows/server/mod.rs

@@ -1103,7 +1103,7 @@ pub struct CreateFailed {}
 
 #[signal("ds_server_destroy")]
 pub struct Destroy {
-	pub override_kill_timeout_ms: i64,
+	pub override_kill_timeout_ms: Option<i64>,
 }
 
 /// Choose which port to assign for a job's ingress port.