src/server/player.ts

   1 import { db } from './lib/db';
   2 import {Player, maxHp} from "../shared/player";
   3 import { random } from 'lodash';
   4 import { Skills } from '../shared/skills';
   5 import {Profession} from 'shared/profession';
   6 import {logger} from './lib/logger';
   7
   8 export async function loadPlayer(authToken: string): Promise<Player> {
   9   const res = await db.first()
  10             .select(
  11               'players.*',
  12               'profession_levels.level',
  13               'profession_levels.exp',
  14               db.raw(`coalesce(pp.permissions, '[]'::json) as permissions`)
  15             )
  16             .from<Player>('players')
  17             .join('profession_levels', function() {
  18               this.on(function() {
  19                 this.on('profession_levels.player_id', '=', 'players.id')
  20                 this.andOn('profession_levels.profession', '=', 'players.profession')
  21               })
  22             })
  23             .leftJoin(
  24               db.raw(`(select json_agg(pp.permission) as permissions, pp.player_id from player_permissions pp group by pp.player_id) pp`),
  25               'pp.player_id','=', 'players.id'
  26             )
  27             .where({
  28               'players.id': authToken
  29             });
  30
  31   return res;
  32 }
  33
  34 export async function createPlayer(): Promise<Player> {
  35   const raw: Partial<Player> = {
  36     username: `Player${Date.now().toString().substr(-7)}`,
  37     strength: random(3, 5),
  38     constitution: random(3, 5),
  39     dexterity: random(3, 5),
  40     intelligence: random(3, 5),
  41   };
  42
  43   raw.hp = maxHp(raw.constitution, 1);
  44
  45   const res  = await db('players').insert(raw).returning<Player[]>('*');
  46   const player = res.pop();
  47
  48   logger.log(`Created player [${player.id}]`);
  49
  50   // await skills!
  51   const pairs = [];
  52   const values = [];
  53   const sql = `insert into player_skills (id, player_id) values `;
  54
  55   logger.log(`Inserted base skills for [${player.id}]`)
  56
  57   Skills.forEach(skill => {
  58     pairs.push('(?,?)');
  59     values.push(skill.id, player.id);
  60   });
  61
  62   await db.raw(sql + pairs.join(','), values);
  63
  64   // create the profession level
  65   await db('profession_levels').insert({
  66     player_id: player.id,
  67     profession: 'Wanderer',
  68     level: 1,
  69     exp: 0
  70   });
  71
  72   logger.log(`Inserted base profession level [${player.id}]`);
  73
  74   return player;
  75 }
  76
  77
  78 export async function updatePlayer(player: Player) {
  79   return Promise.all([
  80     db('players').where({
  81       id: player.id
  82     }).update({
  83       hp: player.hp,
  84       vigor: player.vigor,
  85       strength: player.strength,
  86       constitution: player.constitution,
  87       dexterity: player.dexterity,
  88       intelligence: player.intelligence,
  89       stat_points: player.stat_points,
  90       gold: player.gold
  91     }),
  92     db('profession_levels').where({
  93       player_id: player.id,
  94       profession: player.profession
  95     }).update({
  96       exp: player.exp,
  97       level: player.level
  98     })
  99   ]);
 100 }
 101
 102 export async function movePlayer(cityId: number, playerId: string) {
 103   return db('players').where({
 104     id: playerId
 105   }).update({city_id: cityId})
 106 }
 107
 108 export async function changeProfession(player_id: string, newProfession: Profession): Promise<{level: number, exp: number}> {
 109   let level = 1;
 110   let exp = 0;
 111   try {
 112     await db('profession_levels').insert({
 113       player_id,
 114       profession: newProfession,
 115       level,
 116       exp
 117     });
 118   }
 119   catch(e) {
 120     console.log(e);
 121     const res = await db.first().select('*').from('profession_levels').where({
 122       player_id,
 123       profession: newProfession
 124     })
 125
 126     level = res.level;
 127     exp = res.exp;
 128     // profession already exists, wahtever yo!
 129   }
 130
 131   await db('players').where({
 132     id: player_id
 133   }).update({ profession: newProfession });
 134
 135   return {
 136     level,
 137     exp
 138   };
 139 }