Record join to the game

O01eg

Oct 17, 2022, 12:24 PM

H7NQUYI6KVTFBUHE5MPM6JF6RF4NKYNIYS3AEIT4M2AO7ESSUPNAC

Dependencies

• [2] NY766BOQ Accept form to add player
• [3] LTQCLSBU Split database usage in pages
• [4] 6NYILMKI Add page for slow game
• [5] 6BDGQ4VM Show player names for registered players
• [6] BVCWJKEX Get auth info for slow game page

Change contents

• replacement in src/pages/slow_game.rs at line 8
  [3.127]→[3.200:234](∅→∅),[3.746]→[3.200:234](∅→∅)
  − use crate::{DataBaseRo, WebData};
  [3.127]

  [3.126]
  + use crate::{DataBaseRo, DataBaseRw, WebData};
• edit in src/pages/slow_game.rs at line 199
  [2.295]

  [2.295]
  + data_rw: web::Data<DataBaseRw>,
• edit in src/pages/slow_game.rs at line 223
  [2.934]

  [2.934]
  + let dbclient_rw = match data_rw.0.get().await {

  + Ok(c) => c,

  + Err(e) => {

  + log::error!("Pool RW error {}", e);

  + return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());

  + }

  + };

  + let stmt = match dbclient_rw

  + .prepare("insert into games.players (game_uid, player_name, is_confirmed, species, client_type) values ($1, $2, true, 'RANDOM', 'p');")

  + .await

  + {

  + Ok(stmt) => stmt,

  + Err(e) => {

  + log::error!("Pool RW statement error {}", e);

  + return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());

  + }

  + };

  + let inserted = match dbclient_rw

  + .execute(&stmt, &[&cached_data.0, &cached_data.1])

  + .await

  + {

  + Ok(c) => c,

  + Err(e) => {

  + log::error!("Pool RW execute insert error {}", e);

  + return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());

  + }

  + };

  + if inserted == 0 {

  + log::error!("Pool RW execute insert row error");

  + return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());

  + }

  +