nil-server 0.4.22

Multiplayer strategy game
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

// Copyright (C) Call of Nil contributors
// SPDX-License-Identifier: AGPL-3.0-only

use crate::app::App;
use crate::middleware::authorization::CurrentPlayer;
use crate::res;
use crate::response::{EitherExt, from_err};
use axum::extract::{Extension, Json, State};
use axum::response::Response;
use itertools::Itertools;
use nil_payload::report::*;

pub async fn forward(
  State(app): State<App>,
  Extension(player): Extension<CurrentPlayer>,
  Json(req): Json<ForwardReportRequest>,
) -> Response {
  if player == req.recipient {
    res!(FORBIDDEN)
  } else {
    app
      .world_mut(req.world, |world| {
        world.forward_report(req.id, req.recipient);
      })
      .await
      .map_left(|()| res!(OK))
      .into_inner()
  }
}

pub async fn get(State(app): State<App>, Json(req): Json<GetReportRequest>) -> Response {
  app
    .report_manager(req.world, |rm| rm.report(req.id).cloned())
    .await
    .try_map_left(|report| res!(OK, Json(report)))
    .into_inner()
}

pub async fn get_by(State(app): State<App>, Json(req): Json<GetReportsRequest>) -> Response {
  if req.ids.is_empty() {
    return res!(OK, Json(Vec::<()>::new()));
  }

  match app.get(req.world) {
    Ok(world) => {
      let world = world.read().await;
      let reports = world
        .report()
        .reports_by(|(id, _)| req.ids.contains(&id))
        .take(req.limit.unwrap_or(1_000))
        .sorted_unstable_by_key(|report| report.as_dyn().id())
        .rev()
        .cloned()
        .collect_vec();

      res!(OK, Json(reports))
    }
    Err(err) => from_err(err),
  }
}