gameServer/Actions.hs
author unc0rr
Wed, 10 Apr 2013 22:48:14 +0400
changeset 8897 d6c310c65c91
parent 8523 f13ae07d82d7
child 8833 c13ebed437cb
child 8983 a25e18295959
permissions -rw-r--r--
- Revert server workaround over desync from r98e2dbdda8c0 - Don't allow more than 48 hedgehogs
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
8403
fbc6e7602e05 - Allow server admins to use DELEGATE even when not room owner
unc0rr
parents: 8401
diff changeset
     1
{-# LANGUAGE CPP, OverloadedStrings, ScopedTypeVariables #-}
7766
98edc0724a28 Fix most of server warnings
unc0rr
parents: 7757
diff changeset
     2
{-# OPTIONS_GHC -fno-warn-orphans #-}
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
     3
module Actions where
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
     4
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
     5
import Control.Concurrent
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
     6
import qualified Data.Set as Set
8403
fbc6e7602e05 - Allow server admins to use DELEGATE even when not room owner
unc0rr
parents: 8401
diff changeset
     7
import qualified Data.Map as Map
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
     8
import qualified Data.List as L
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
     9
import qualified Control.Exception as Exception
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    10
import System.Log.Logger
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    11
import Control.Monad
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    12
import Data.Time
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    13
import Data.Maybe
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    14
import Control.Monad.Reader
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    15
import Control.Monad.State.Strict
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    16
import qualified Data.ByteString.Char8 as B
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    17
import Control.DeepSeq
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    18
import Data.Unique
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    19
import Control.Arrow
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    20
import Control.Exception
5209
f7a610e2ef5f On restart command close server socket and spawn new server, keep running until last client quits
unc0rr
parents: 5184
diff changeset
    21
import System.Process
f7a610e2ef5f On restart command close server socket and spawn new server, keep running until last client quits
unc0rr
parents: 5184
diff changeset
    22
import Network.Socket
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    23
-----------------------------
7766
98edc0724a28 Fix most of server warnings
unc0rr
parents: 7757
diff changeset
    24
#if defined(OFFICIAL_SERVER)
5996
2c72fe81dd37 Convert boolean variable + a bunch of fields which make sense only while game is going on into Maybe + structure
unc0rr
parents: 5426
diff changeset
    25
import OfficialServer.GameReplayStore
7766
98edc0724a28 Fix most of server warnings
unc0rr
parents: 7757
diff changeset
    26
#endif
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    27
import CoreTypes
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    28
import Utils
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    29
import ClientIO
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    30
import ServerState
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    31
import Consts
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    32
import ConfigFile
6068
e18713ecf1e0 Introduce EngineInteraction module
unc0rr
parents: 6012
diff changeset
    33
import EngineInteraction
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    34
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    35
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    36
type CmdHandler = [B.ByteString] -> Reader (ClientIndex, IRnC) [Action]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    37
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    38
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    39
othersChans :: StateT ServerState IO [ClientChan]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    40
othersChans = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    41
    cl <- client's id
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    42
    ri <- clientRoomA
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    43
    liftM (map sendChan . filter (/= cl)) $ roomClientsS ri
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    44
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    45
processAction :: Action -> StateT ServerState IO ()
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    46
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    47
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    48
processAction (AnswerClients chans msg) =
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    49
    io $ mapM_ (`writeChan` (msg `deepseq` msg)) (chans `deepseq` chans)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    50
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    51
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    52
processAction SendServerMessage = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    53
    chan <- client's sendChan
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    54
    protonum <- client's clientProto
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    55
    si <- liftM serverInfo get
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    56
    let message = if protonum < latestReleaseVersion si then
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    57
            serverMessageForOldVersions si
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    58
            else
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    59
            serverMessage si
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    60
    processAction $ AnswerClients [chan] ["SERVER_MESSAGE", message]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    61
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    62
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    63
processAction SendServerVars = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    64
    chan <- client's sendChan
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    65
    si <- gets serverInfo
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    66
    io $ writeChan chan ("SERVER_VARS" : vars si)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    67
    where
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    68
        vars si = [
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    69
            "MOTD_NEW", serverMessage si,
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    70
            "MOTD_OLD", serverMessageForOldVersions si,
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    71
            "LATEST_PROTO", showB $ latestReleaseVersion si
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    72
            ]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    73
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    74
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    75
processAction (ProtocolError msg) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    76
    chan <- client's sendChan
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    77
    processAction $ AnswerClients [chan] ["ERROR", msg]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    78
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    79
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    80
processAction (Warning msg) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    81
    chan <- client's sendChan
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    82
    processAction $ AnswerClients [chan] ["WARNING", msg]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    83
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    84
processAction (NoticeMessage n) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    85
    chan <- client's sendChan
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    86
    processAction $ AnswerClients [chan] ["NOTICE", showB . fromEnum $ n]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    87
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    88
processAction (ByeClient msg) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    89
    (Just ci) <- gets clientIndex
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    90
    ri <- clientRoomA
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    91
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    92
    chan <- client's sendChan
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    93
    clNick <- client's nick
8372
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
    94
    loggedIn <- client's isVisible
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    95
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    96
    when (ri /= lobbyId) $ do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    97
        processAction $ MoveToLobby ("quit: " `B.append` msg)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    98
        return ()
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
    99
8372
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   100
    clientsChans <- liftM (Prelude.map sendChan . Prelude.filter isVisible) $! allClientsS
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   101
    io $
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   102
        infoM "Clients" (show ci ++ " quits: " ++ B.unpack msg)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   103
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   104
    when loggedIn $ processAction $ AnswerClients clientsChans ["LOBBY:LEFT", clNick, msg]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   105
8158
5da1c26d5b10 Fix warning
unc0rr
parents: 8156
diff changeset
   106
    mapM_ processAction
7465
c2dcf97ca664 Okay, this is workaround over ping timeouts problem on the server. Could make server crash if recieve thread wakes up after second ping timeout event.
unc0rr
parents: 7351
diff changeset
   107
        [
c2dcf97ca664 Okay, this is workaround over ping timeouts problem on the server. Could make server crash if recieve thread wakes up after second ping timeout event.
unc0rr
parents: 7351
diff changeset
   108
        AnswerClients [chan] ["BYE", msg]
8372
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   109
        , ModifyClient (\c -> c{nick = "", isVisible = False}) -- this will effectively hide client from others while he isn't deleted from list
7465
c2dcf97ca664 Okay, this is workaround over ping timeouts problem on the server. Could make server crash if recieve thread wakes up after second ping timeout event.
unc0rr
parents: 7351
diff changeset
   110
        ]
c2dcf97ca664 Okay, this is workaround over ping timeouts problem on the server. Could make server crash if recieve thread wakes up after second ping timeout event.
unc0rr
parents: 7351
diff changeset
   111
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   112
    s <- get
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   113
    put $! s{removedClients = ci `Set.insert` removedClients s}
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   114
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   115
processAction (DeleteClient ci) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   116
    io $ debugM "Clients"  $ "DeleteClient: " ++ show ci
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   117
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   118
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   119
    io $ removeClient rnc ci
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   120
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   121
    s <- get
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   122
    put $! s{removedClients = ci `Set.delete` removedClients s}
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   123
5209
f7a610e2ef5f On restart command close server socket and spawn new server, keep running until last client quits
unc0rr
parents: 5184
diff changeset
   124
    sp <- gets (shutdownPending . serverInfo)
f7a610e2ef5f On restart command close server socket and spawn new server, keep running until last client quits
unc0rr
parents: 5184
diff changeset
   125
    cls <- allClientsS
f7a610e2ef5f On restart command close server socket and spawn new server, keep running until last client quits
unc0rr
parents: 5184
diff changeset
   126
    io $ when (sp && null cls) $ throwIO ShutdownException
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   127
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   128
processAction (ModifyClient f) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   129
    (Just ci) <- gets clientIndex
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   130
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   131
    io $ modifyClient rnc f ci
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   132
    return ()
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   133
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   134
processAction (ModifyClient2 ci f) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   135
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   136
    io $ modifyClient rnc f ci
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   137
    return ()
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   138
7757
c20e6c80e249 Don't accept ROUNDFINISHED message twice. Fixes game hangs when half of teams quit game.
unc0rr
parents: 7748
diff changeset
   139
processAction (ModifyRoomClients f) = do
c20e6c80e249 Don't accept ROUNDFINISHED message twice. Fixes game hangs when half of teams quit game.
unc0rr
parents: 7748
diff changeset
   140
    rnc <- gets roomsClients
c20e6c80e249 Don't accept ROUNDFINISHED message twice. Fixes game hangs when half of teams quit game.
unc0rr
parents: 7748
diff changeset
   141
    ri <- clientRoomA
c20e6c80e249 Don't accept ROUNDFINISHED message twice. Fixes game hangs when half of teams quit game.
unc0rr
parents: 7748
diff changeset
   142
    roomClIDs <- io $ roomClientsIndicesM rnc ri
c20e6c80e249 Don't accept ROUNDFINISHED message twice. Fixes game hangs when half of teams quit game.
unc0rr
parents: 7748
diff changeset
   143
    io $ mapM_ (modifyClient rnc f) roomClIDs
c20e6c80e249 Don't accept ROUNDFINISHED message twice. Fixes game hangs when half of teams quit game.
unc0rr
parents: 7748
diff changeset
   144
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   145
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   146
processAction (ModifyRoom f) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   147
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   148
    ri <- clientRoomA
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   149
    io $ modifyRoom rnc f ri
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   150
    return ()
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   151
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   152
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   153
processAction (ModifyServerInfo f) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   154
    modify (\s -> s{serverInfo = f $ serverInfo s})
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   155
    si <- gets serverInfo
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   156
    io $ writeServerConfig si
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   157
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   158
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   159
processAction (MoveToRoom ri) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   160
    (Just ci) <- gets clientIndex
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   161
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   162
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   163
    io $ do
8514
896b283f41a2 Clear player's clan info on room join
unc0rr
parents: 8510
diff changeset
   164
        modifyClient rnc (\cl -> cl{teamsInGame = 0, isReady = False, isMaster = False, isInGame = False, clientClan = Nothing}) ci
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   165
        modifyRoom rnc (\r -> r{playersIn = playersIn r + 1}) ri
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   166
        moveClientToRoom rnc ri ci
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   167
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   168
    chans <- liftM (map sendChan) $ roomClientsS ri
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   169
    clNick <- client's nick
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   170
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   171
    processAction $ AnswerClients chans ["JOINED", clNick]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   172
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   173
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   174
processAction (MoveToLobby msg) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   175
    (Just ci) <- gets clientIndex
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   176
    ri <- clientRoomA
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   177
    rnc <- gets roomsClients
7766
98edc0724a28 Fix most of server warnings
unc0rr
parents: 7757
diff changeset
   178
    playersNum <- io $ room'sM rnc playersIn ri
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   179
    master <- client's isMaster
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   180
--    client <- client's id
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   181
    clNick <- client's nick
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   182
    chans <- othersChans
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   183
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   184
    if master then
7521
093ea41051c5 Keep room till last player quits
unc0rr
parents: 7498
diff changeset
   185
        if playersNum > 1 then
8438
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   186
            mapM_ processAction [ChangeMaster Nothing, NoticeMessage AdminLeft, RemoveClientTeams, AnswerClients chans ["LEFT", clNick, msg]]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   187
            else
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   188
            processAction RemoveRoom
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   189
        else
8438
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   190
        mapM_ processAction [RemoveClientTeams, AnswerClients chans ["LEFT", clNick, msg]]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   191
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   192
    -- when not removing room
7351
34efdd1f230f - Check ready status only after deleting player's teams (should fix the bug when you're unable to start game)
unc0rr
parents: 7321
diff changeset
   193
    ready <- client's isReady
7521
093ea41051c5 Keep room till last player quits
unc0rr
parents: 7498
diff changeset
   194
    when (not master || playersNum > 1) . io $ do
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   195
        modifyRoom rnc (\r -> r{
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   196
                playersIn = playersIn r - 1,
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   197
                readyPlayers = if ready then readyPlayers r - 1 else readyPlayers r
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   198
                }) ri
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   199
        moveClientToLobby rnc ci
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   200
7710
fd5bcbd698a5 - Keep track of room name so correct name is displayed when you become room admin
unc0rr
parents: 7682
diff changeset
   201
8247
d7cf4a9ce685 Command to delegate room to other player
unc0rr
parents: 8245
diff changeset
   202
processAction (ChangeMaster delegateId)= do
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   203
    (Just ci) <- gets clientIndex
7710
fd5bcbd698a5 - Keep track of room name so correct name is displayed when you become room admin
unc0rr
parents: 7682
diff changeset
   204
    proto <- client's clientProto
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   205
    ri <- clientRoomA
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   206
    rnc <- gets roomsClients
8247
d7cf4a9ce685 Command to delegate room to other player
unc0rr
parents: 8245
diff changeset
   207
    newMasterId <- liftM (\ids -> fromMaybe (last . filter (/= ci) $ ids) delegateId) . io $ roomClientsIndicesM rnc ri
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   208
    newMaster <- io $ client'sM rnc id newMasterId
6733
5abbc345a82f Handle ROOM* commands in rooms list model
unc0rr
parents: 6541
diff changeset
   209
    oldRoomName <- io $ room'sM rnc name ri
7682
f6bfbe829008 'h' status for room admins
unc0rr
parents: 7668
diff changeset
   210
    oldMaster <- client's nick
8245
d1a830c304c7 Change room name if room admin is kicked
unc0rr
parents: 8241
diff changeset
   211
    kicked <- client's isKickedFromServer
7668
4cb423f42105 Show who is the room admin on join (no tested, also I don't like how it is done via server warnings, but it seems there's no other solution compatible with .17)
unc0rr
parents: 7664
diff changeset
   212
    thisRoomChans <- liftM (map sendChan) $ roomClientsS ri
8245
d1a830c304c7 Change room name if room admin is kicked
unc0rr
parents: 8241
diff changeset
   213
    let newRoomName = if (proto < 42) || kicked then nick newMaster else oldRoomName
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   214
    mapM_ processAction [
7775
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   215
        ModifyRoom (\r -> r{masterID = newMasterId
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   216
                , name = newRoomName
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   217
                , isRestrictedJoins = False
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   218
                , isRestrictedTeams = False
8232
fb5aa767a2a0 "Registered users only" room flag
unc0rr
parents: 8189
diff changeset
   219
                , isRegisteredOnly = False
7775
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   220
                , readyPlayers = if isReady newMaster then readyPlayers r else readyPlayers r + 1})
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   221
        , ModifyClient2 newMasterId (\c -> c{isMaster = True, isReady = True})
7682
f6bfbe829008 'h' status for room admins
unc0rr
parents: 7668
diff changeset
   222
        , AnswerClients [sendChan newMaster] ["ROOM_CONTROL_ACCESS", "1"]
f6bfbe829008 'h' status for room admins
unc0rr
parents: 7668
diff changeset
   223
        , AnswerClients thisRoomChans ["CLIENT_FLAGS", "-h", oldMaster]
7775
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   224
        , AnswerClients thisRoomChans ["CLIENT_FLAGS", "+hr", nick newMaster]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   225
        ]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   226
7766
98edc0724a28 Fix most of server warnings
unc0rr
parents: 7757
diff changeset
   227
    newRoom' <- io $ room'sM rnc id ri
6541
08ed346ed341 Send full room info on room add and update events. Less(?) traffic, but current frontend doesn't behave good with this change to server.
unc0rr
parents: 6191
diff changeset
   228
    chans <- liftM (map sendChan) $! sameProtoClientsS proto
7972
0dffb91eeb82 Oops, fix room info on room admin change
unc0rr
parents: 7947
diff changeset
   229
    processAction $ AnswerClients chans ("ROOM" : "UPD" : oldRoomName : roomInfo (nick newMaster) newRoom')
6541
08ed346ed341 Send full room info on room add and update events. Less(?) traffic, but current frontend doesn't behave good with this change to server.
unc0rr
parents: 6191
diff changeset
   230
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   231
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   232
processAction (AddRoom roomName roomPassword) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   233
    Just clId <- gets clientIndex
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   234
    rnc <- gets roomsClients
6541
08ed346ed341 Send full room info on room add and update events. Less(?) traffic, but current frontend doesn't behave good with this change to server.
unc0rr
parents: 6191
diff changeset
   235
    proto <- client's clientProto
08ed346ed341 Send full room info on room add and update events. Less(?) traffic, but current frontend doesn't behave good with this change to server.
unc0rr
parents: 6191
diff changeset
   236
    n <- client's nick
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   237
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   238
    let rm = newRoom{
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   239
            masterID = clId,
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   240
            name = roomName,
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   241
            password = roomPassword,
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   242
            roomProto = proto
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   243
            }
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   244
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   245
    rId <- io $ addRoom rnc rm
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   246
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   247
    processAction $ MoveToRoom rId
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   248
6541
08ed346ed341 Send full room info on room add and update events. Less(?) traffic, but current frontend doesn't behave good with this change to server.
unc0rr
parents: 6191
diff changeset
   249
    chans <- liftM (map sendChan) $! sameProtoClientsS proto
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   250
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   251
    mapM_ processAction [
7945
4006d77e1a28 Send notification about 1 player in room on room creation
unc0rr
parents: 7926
diff changeset
   252
      AnswerClients chans ("ROOM" : "ADD" : roomInfo n rm{playersIn = 1})
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   253
        ]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   254
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   255
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   256
processAction RemoveRoom = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   257
    Just clId <- gets clientIndex
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   258
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   259
    ri <- io $ clientRoomM rnc clId
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   260
    roomName <- io $ room'sM rnc name ri
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   261
    others <- othersChans
6541
08ed346ed341 Send full room info on room add and update events. Less(?) traffic, but current frontend doesn't behave good with this change to server.
unc0rr
parents: 6191
diff changeset
   262
    proto <- client's clientProto
08ed346ed341 Send full room info on room add and update events. Less(?) traffic, but current frontend doesn't behave good with this change to server.
unc0rr
parents: 6191
diff changeset
   263
    chans <- liftM (map sendChan) $! sameProtoClientsS proto
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   264
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   265
    mapM_ processAction [
6541
08ed346ed341 Send full room info on room add and update events. Less(?) traffic, but current frontend doesn't behave good with this change to server.
unc0rr
parents: 6191
diff changeset
   266
            AnswerClients chans ["ROOM", "DEL", roomName],
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   267
            AnswerClients others ["ROOMABANDONED", roomName]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   268
        ]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   269
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   270
    io $ removeRoom rnc ri
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   271
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   272
7921
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   273
processAction SendUpdateOnThisRoom = do
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   274
    Just clId <- gets clientIndex
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   275
    proto <- client's clientProto
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   276
    rnc <- gets roomsClients
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   277
    ri <- io $ clientRoomM rnc clId
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   278
    rm <- io $ room'sM rnc id ri
7926
550083f61a0e oops, fix incorrect room owner name in ROOM UPD command again
unc0rr
parents: 7924
diff changeset
   279
    n <- io $ client'sM rnc nick (masterID rm)
7921
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   280
    chans <- liftM (map sendChan) $! sameProtoClientsS proto
7924
351f970c60e1 oops, fix incorrect room owner name in ROOM UPD command
unc0rr
parents: 7921
diff changeset
   281
    processAction $ AnswerClients chans ("ROOM" : "UPD" : name rm : roomInfo n rm)
7921
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   282
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   283
6758
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   284
processAction UnreadyRoomClients = do
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   285
    ri <- clientRoomA
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   286
    roomPlayers <- roomClientsS ri
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   287
    pr <- client's clientProto
7757
c20e6c80e249 Don't accept ROUNDFINISHED message twice. Fixes game hangs when half of teams quit game.
unc0rr
parents: 7748
diff changeset
   288
    mapM_ processAction [
7775
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   289
        AnswerClients (map sendChan roomPlayers) $ notReadyMessage pr . map nick . filter (not . isMaster) $ roomPlayers
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   290
        , ModifyRoomClients (\cl -> cl{isReady = isMaster cl})
835ad028fb66 Keep room admin ready status always set
unc0rr
parents: 7766
diff changeset
   291
        , ModifyRoom (\r -> r{readyPlayers = 1})
7757
c20e6c80e249 Don't accept ROUNDFINISHED message twice. Fixes game hangs when half of teams quit game.
unc0rr
parents: 7748
diff changeset
   292
        ]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   293
    where
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   294
        notReadyMessage p nicks = if p < 38 then "NOT_READY" : nicks else "CLIENT_FLAGS" : "-r" : nicks
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   295
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   296
6758
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   297
processAction FinishGame = do
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   298
    rnc <- gets roomsClients
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   299
    ri <- clientRoomA
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   300
    thisRoomChans <- liftM (map sendChan) $ roomClientsS ri
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   301
    answerRemovedTeams <- io $
7126
8daa5c8e84c0 Bring leftTeams back (with a fix) as it is apparently needed for spectators.
unc0rr
parents: 7124
diff changeset
   302
         room'sM rnc (map (\t -> AnswerClients thisRoomChans ["REMOVE_TEAM", t]) . leftTeams . fromJust . gameInfo) ri
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   303
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   304
    mapM_ processAction $
7124
cfee05712896 - Restore pre-r9257cf8e7af2 behavior
unc0rr
parents: 7120
diff changeset
   305
        SaveReplay
7126
8daa5c8e84c0 Bring leftTeams back (with a fix) as it is apparently needed for spectators.
unc0rr
parents: 7124
diff changeset
   306
        : ModifyRoom
6758
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   307
            (\r -> r{
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   308
                gameInfo = Nothing,
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   309
                readyPlayers = 0
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   310
                }
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   311
            )
7126
8daa5c8e84c0 Bring leftTeams back (with a fix) as it is apparently needed for spectators.
unc0rr
parents: 7124
diff changeset
   312
        : UnreadyRoomClients
7921
6b074de32bea Send ROOM UPD message when team is added/deleted from room, and when game starts or finishes
unc0rr
parents: 7898
diff changeset
   313
        : SendUpdateOnThisRoom
8241
b15f165c080c Send "ROUND_FINISHED" to room clients when server thinks so
unc0rr
parents: 8239
diff changeset
   314
        : AnswerClients thisRoomChans ["ROUND_FINISHED"]
7126
8daa5c8e84c0 Bring leftTeams back (with a fix) as it is apparently needed for spectators.
unc0rr
parents: 7124
diff changeset
   315
        : answerRemovedTeams
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   316
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   317
6753
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   318
processAction (SendTeamRemovalMessage teamName) = do
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   319
    chans <- othersChans
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   320
    mapM_ processAction [
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   321
        AnswerClients chans ["EM", rmTeamMsg],
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   322
        ModifyRoom (\r -> r{
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   323
                gameInfo = liftM (\g -> g{
7124
cfee05712896 - Restore pre-r9257cf8e7af2 behavior
unc0rr
parents: 7120
diff changeset
   324
                    teamsInGameNumber = teamsInGameNumber g - 1
8369
31033e521653 Throw away stupid Data.Seq
unc0rr
parents: 8247
diff changeset
   325
                    , roundMsgs = rmTeamMsg : roundMsgs g
6753
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   326
                }) $ gameInfo r
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   327
            })
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   328
        ]
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   329
6758
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   330
    rnc <- gets roomsClients
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   331
    ri <- clientRoomA
26bf919aeb57 Oh, should also check for game finish when player quits without ROUNDFINISHED message: small refactoring, not tested at all
unc0rr
parents: 6756
diff changeset
   332
    gi <- io $ room'sM rnc gameInfo ri
8422
ec41194d4444 Okay, let's try not trust even room admin on this
unc0rr
parents: 8403
diff changeset
   333
    when (0 == teamsInGameNumber (fromJust gi)) $
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   334
        processAction FinishGame
6753
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   335
    where
e95b1f62d0de Don't remove client's teams from teams list on "ROUNDFINISHED 0", just send team removal message to others.
unc0rr
parents: 6733
diff changeset
   336
        rmTeamMsg = toEngineMsg $ 'F' `B.cons` teamName
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   337
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   338
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   339
processAction (RemoveTeam teamName) = do
8438
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   340
    (Just ci) <- gets clientIndex
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   341
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   342
    ri <- clientRoomA
8438
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   343
    inGame <- io $ do
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   344
        r <- room'sM rnc (isJust . gameInfo) ri
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   345
        c <- client'sM rnc isInGame ci
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   346
        return $ r && c
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   347
    chans <- othersChans
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   348
    mapM_ processAction $
7126
8daa5c8e84c0 Bring leftTeams back (with a fix) as it is apparently needed for spectators.
unc0rr
parents: 7124
diff changeset
   349
        ModifyRoom (\r -> r{
8daa5c8e84c0 Bring leftTeams back (with a fix) as it is apparently needed for spectators.
unc0rr
parents: 7124
diff changeset
   350
            teams = Prelude.filter (\t -> teamName /= teamname t) $ teams r
8daa5c8e84c0 Bring leftTeams back (with a fix) as it is apparently needed for spectators.
unc0rr
parents: 7124
diff changeset
   351
            , gameInfo = liftM (\g -> g{leftTeams = teamName : leftTeams g}) $ gameInfo r
8daa5c8e84c0 Bring leftTeams back (with a fix) as it is apparently needed for spectators.
unc0rr
parents: 7124
diff changeset
   352
            })
7947
0cf5277fef1a Better place for SendUpdateOnThisRoom
unc0rr
parents: 7945
diff changeset
   353
        : SendUpdateOnThisRoom
7124
cfee05712896 - Restore pre-r9257cf8e7af2 behavior
unc0rr
parents: 7120
diff changeset
   354
        : AnswerClients chans ["REMOVE_TEAM", teamName]
cfee05712896 - Restore pre-r9257cf8e7af2 behavior
unc0rr
parents: 7120
diff changeset
   355
        : [SendTeamRemovalMessage teamName | inGame]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   356
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   357
8438
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   358
processAction RemoveClientTeams = do
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   359
    (Just ci) <- gets clientIndex
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   360
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   361
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   362
    removeTeamActions <- io $ do
8438
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   363
        rId <- clientRoomM rnc ci
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   364
        roomTeams <- room'sM rnc teams rId
8438
64ac58abd02a Don't resend "team quit" message when client closes engine, then quits room:
unc0rr
parents: 8422
diff changeset
   365
        return . Prelude.map (RemoveTeam . teamname) . Prelude.filter (\t -> teamownerId t == ci) $ roomTeams
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   366
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   367
    mapM_ processAction removeTeamActions
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   368
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   369
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   370
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   371
processAction CheckRegistered = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   372
    (Just ci) <- gets clientIndex
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   373
    n <- client's nick
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   374
    h <- client's host
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   375
    p <- client's clientProto
8371
0551b5c3de9a - Start work on checker
unc0rr
parents: 8369
diff changeset
   376
    checker <- client's isChecker
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   377
    uid <- client's clUID
8371
0551b5c3de9a - Start work on checker
unc0rr
parents: 8369
diff changeset
   378
    -- allow multiple checker logins
0551b5c3de9a - Start work on checker
unc0rr
parents: 8369
diff changeset
   379
    haveSameNick <- liftM (not . null . tail . filter (\c -> (not $ isChecker c) && caseInsensitiveCompare (nick c) n)) allClientsS
8476
61d7269f16be Fix server crasher
unc0rr
parents: 8452
diff changeset
   380
    if (not checker) && haveSameNick then
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   381
        if p < 38 then
8401
87410ae372f6 Server messages localization using Qt's l10n subsystem:
unc0rr
parents: 8396
diff changeset
   382
            processAction $ ByeClient $ loc "Nickname is already in use"
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   383
            else
8239
c9359078a2ed Better check for bans
unc0rr
parents: 8232
diff changeset
   384
            processAction $ NoticeMessage NickAlreadyInUse
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   385
        else
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   386
        do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   387
        db <- gets (dbQueries . serverInfo)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   388
        io $ writeChan db $ CheckAccount ci (hashUnique uid) n h
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   389
        return ()
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   390
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   391
processAction ClearAccountsCache = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   392
    dbq <- gets (dbQueries . serverInfo)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   393
    io $ writeChan dbq ClearCache
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   394
    return ()
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   395
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   396
8189
328f429c3ecc - Disable in-room bans
unc0rr
parents: 8158
diff changeset
   397
processAction (ProcessAccountInfo info) = do
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   398
    case info of
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   399
        HasAccount passwd isAdmin -> do
8189
328f429c3ecc - Disable in-room bans
unc0rr
parents: 8158
diff changeset
   400
            b <- isBanned
8372
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   401
            c <- client's isChecker
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   402
            when (not b) $ (if c then checkerLogin else playerLogin) passwd isAdmin
8189
328f429c3ecc - Disable in-room bans
unc0rr
parents: 8158
diff changeset
   403
        Guest -> do
328f429c3ecc - Disable in-room bans
unc0rr
parents: 8158
diff changeset
   404
            b <- isBanned
8523
f13ae07d82d7 Forbit guest checkers
unc0rr
parents: 8519
diff changeset
   405
            c <- client's isChecker
8189
328f429c3ecc - Disable in-room bans
unc0rr
parents: 8158
diff changeset
   406
            when (not b) $
8523
f13ae07d82d7 Forbit guest checkers
unc0rr
parents: 8519
diff changeset
   407
                if c then
f13ae07d82d7 Forbit guest checkers
unc0rr
parents: 8519
diff changeset
   408
                    checkerLogin "" False
f13ae07d82d7 Forbit guest checkers
unc0rr
parents: 8519
diff changeset
   409
                    else
f13ae07d82d7 Forbit guest checkers
unc0rr
parents: 8519
diff changeset
   410
                    processAction JoinLobby
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   411
        Admin -> do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   412
            mapM_ processAction [ModifyClient (\cl -> cl{isAdministrator = True}), JoinLobby]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   413
            chan <- client's sendChan
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   414
            processAction $ AnswerClients [chan] ["ADMIN_ACCESS"]
8189
328f429c3ecc - Disable in-room bans
unc0rr
parents: 8158
diff changeset
   415
    where
328f429c3ecc - Disable in-room bans
unc0rr
parents: 8158
diff changeset
   416
    isBanned = do
8239
c9359078a2ed Better check for bans
unc0rr
parents: 8232
diff changeset
   417
        processAction $ CheckBanned False
8189
328f429c3ecc - Disable in-room bans
unc0rr
parents: 8158
diff changeset
   418
        liftM B.null $ client's nick
8401
87410ae372f6 Server messages localization using Qt's l10n subsystem:
unc0rr
parents: 8396
diff changeset
   419
    checkerLogin _ False = processAction $ ByeClient $ loc "No checker rights"
8372
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   420
    checkerLogin p True = do
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   421
        wp <- client's webPassword
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   422
        processAction $
8401
87410ae372f6 Server messages localization using Qt's l10n subsystem:
unc0rr
parents: 8396
diff changeset
   423
            if wp == p then ModifyClient $ \c -> c{logonPassed = True} else ByeClient $ loc "Authentication failed"
8372
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   424
    playerLogin p a = do
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   425
        chan <- client's sendChan
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   426
        mapM_ processAction [AnswerClients [chan] ["ASKPASSWORD"], ModifyClient (\c -> c{webPassword = p, isAdministrator = a})]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   427
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   428
processAction JoinLobby = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   429
    chan <- client's sendChan
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   430
    clientNick <- client's nick
7498
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   431
    isAuthenticated <- liftM (not . B.null) $ client's webPassword
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   432
    isAdmin <- client's isAdministrator
8372
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   433
    loggedInClients <- liftM (Prelude.filter isVisible) $! allClientsS
7498
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   434
    let (lobbyNicks, clientsChans) = unzip . L.map (nick &&& sendChan) $ loggedInClients
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   435
    let authenticatedNicks = L.map nick . L.filter (not . B.null . webPassword) $ loggedInClients
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   436
    let adminsNicks = L.map nick . L.filter isAdministrator $ loggedInClients
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   437
    let clFlags = B.concat . L.concat $ [["u" | isAuthenticated], ["a" | isAdmin]]
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   438
    mapM_ processAction . concat $ [
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   439
        [AnswerClients clientsChans ["LOBBY:JOINED", clientNick]]
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   440
        , [AnswerClients [chan] ("LOBBY:JOINED" : clientNick : lobbyNicks)]
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   441
        , [AnswerClients [chan] ("CLIENT_FLAGS" : "+u" : authenticatedNicks) | not $ null authenticatedNicks]
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   442
        , [AnswerClients [chan] ("CLIENT_FLAGS" : "+a" : adminsNicks) | not $ null adminsNicks]
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   443
        , [AnswerClients (chan : clientsChans) ["CLIENT_FLAGS",  B.concat["+" , clFlags], clientNick] | not $ B.null clFlags]
8372
3c193ec03e09 Logon procedure for checkers, introduce invisible clients
unc0rr
parents: 8371
diff changeset
   444
        , [ModifyClient (\cl -> cl{logonPassed = True, isVisible = True})]
7498
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   445
        , [SendServerMessage]
86984f6fa1b9 Introduce 'a' and 'u' client flags to mark admins and authenticated users
unc0rr
parents: 7465
diff changeset
   446
        ]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   447
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   448
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   449
processAction (KickClient kickId) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   450
    modify (\s -> s{clientIndex = Just kickId})
5214
d2ad737891b0 60 seconds cooldown ban on kick
unc0rr
parents: 5212
diff changeset
   451
    clHost <- client's host
d2ad737891b0 60 seconds cooldown ban on kick
unc0rr
parents: 5212
diff changeset
   452
    currentTime <- io getCurrentTime
d2ad737891b0 60 seconds cooldown ban on kick
unc0rr
parents: 5212
diff changeset
   453
    mapM_ processAction [
8401
87410ae372f6 Server messages localization using Qt's l10n subsystem:
unc0rr
parents: 8396
diff changeset
   454
        AddIP2Bans clHost (loc "60 seconds cooldown after kick") (addUTCTime 60 currentTime)
8245
d1a830c304c7 Change room name if room admin is kicked
unc0rr
parents: 8241
diff changeset
   455
        , ModifyClient (\c -> c{isKickedFromServer = True})
d1a830c304c7 Change room name if room admin is kicked
unc0rr
parents: 8241
diff changeset
   456
        , ByeClient "Kicked"
5214
d2ad737891b0 60 seconds cooldown ban on kick
unc0rr
parents: 5212
diff changeset
   457
        ]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   458
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   459
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   460
processAction (BanClient seconds reason banId) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   461
    modify (\s -> s{clientIndex = Just banId})
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   462
    clHost <- client's host
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   463
    currentTime <- io getCurrentTime
5426
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   464
    let msg = B.concat ["Ban for ", B.pack . show $ seconds, " (", reason, ")"]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   465
    mapM_ processAction [
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   466
        AddIP2Bans clHost msg (addUTCTime seconds currentTime)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   467
        , KickClient banId
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   468
        ]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   469
8245
d1a830c304c7 Change room name if room admin is kicked
unc0rr
parents: 8241
diff changeset
   470
5426
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   471
processAction (BanIP ip seconds reason) = do
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   472
    currentTime <- io getCurrentTime
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   473
    let msg = B.concat ["Ban for ", B.pack . show $ seconds, " (", reason, ")"]
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   474
    processAction $
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   475
        AddIP2Bans ip msg (addUTCTime seconds currentTime)
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   476
8245
d1a830c304c7 Change room name if room admin is kicked
unc0rr
parents: 8241
diff changeset
   477
8154
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   478
processAction (BanNick n seconds reason) = do
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   479
    currentTime <- io getCurrentTime
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   480
    let msg = 
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   481
            if seconds > 60 * 60 * 24 * 365 then
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   482
                B.concat ["Permanent ban (", reason, ")"]
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   483
                else
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   484
                B.concat ["Ban for ", B.pack . show $ seconds, " (", reason, ")"]
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   485
    processAction $
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   486
        AddNick2Bans n msg (addUTCTime seconds currentTime)
0ea76ea45e6a Implement ban by nickname
unc0rr
parents: 7972
diff changeset
   487
8245
d1a830c304c7 Change room name if room admin is kicked
unc0rr
parents: 8241
diff changeset
   488
5426
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   489
processAction BanList = do
8156
3ccc61102b58 - Fix UNBAN bug
unc0rr
parents: 8155
diff changeset
   490
    time <- io $ getCurrentTime
5426
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   491
    ch <- client's sendChan
8156
3ccc61102b58 - Fix UNBAN bug
unc0rr
parents: 8155
diff changeset
   492
    b <- gets (B.intercalate "\n" . concatMap (ban2Str time) . bans . serverInfo)
5426
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   493
    processAction $
7766
98edc0724a28 Fix most of server warnings
unc0rr
parents: 7757
diff changeset
   494
        AnswerClients [ch] ["BANLIST", b]
8156
3ccc61102b58 - Fix UNBAN bug
unc0rr
parents: 8155
diff changeset
   495
    where
3ccc61102b58 - Fix UNBAN bug
unc0rr
parents: 8155
diff changeset
   496
        ban2Str time (BanByIP b r t) = ["I", b, r, B.pack . show $ t `diffUTCTime` time]
3ccc61102b58 - Fix UNBAN bug
unc0rr
parents: 8155
diff changeset
   497
        ban2Str time (BanByNick b r t) = ["N", b, r, B.pack . show $ t `diffUTCTime` time]
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   498
8245
d1a830c304c7 Change room name if room admin is kicked
unc0rr
parents: 8241
diff changeset
   499
7748
f160fbc139b1 UNBAN implementation
unc0rr
parents: 7735
diff changeset
   500
processAction (Unban entry) = do
8156
3ccc61102b58 - Fix UNBAN bug
unc0rr
parents: 8155
diff changeset
   501
    processAction $ ModifyServerInfo (\s -> s{bans = filter (not . f) $ bans s})
7748
f160fbc139b1 UNBAN implementation
unc0rr
parents: 7735
diff changeset
   502
    where
f160fbc139b1 UNBAN implementation
unc0rr
parents: 7735
diff changeset
   503
        f (BanByIP bip _ _) = bip == entry
f160fbc139b1 UNBAN implementation
unc0rr
parents: 7735
diff changeset
   504
        f (BanByNick bn _ _) = bn == entry
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   505
8245
d1a830c304c7 Change room name if room admin is kicked
unc0rr
parents: 8241
diff changeset
   506
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   507
processAction (KickRoomClient kickId) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   508
    modify (\s -> s{clientIndex = Just kickId})
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   509
    ch <- client's sendChan
8401
87410ae372f6 Server messages localization using Qt's l10n subsystem:
unc0rr
parents: 8396
diff changeset
   510
    mapM_ processAction [AnswerClients [ch] ["KICKED"], MoveToLobby $ loc "kicked"]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   511
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   512
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   513
processAction (AddClient cl) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   514
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   515
    si <- gets serverInfo
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   516
    newClId <- io $ do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   517
        ci <- addClient rnc cl
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   518
        _ <- Exception.mask (forkIO . clientRecvLoop (clientSocket cl) (coreChan si) (sendChan cl) ci)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   519
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   520
        infoM "Clients" (show ci ++ ": New client. Time: " ++ show (connectTime cl))
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   521
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   522
        return ci
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   523
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   524
    modify (\s -> s{clientIndex = Just newClId})
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   525
    mapM_ processAction
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   526
        [
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   527
            AnswerClients [sendChan cl] ["CONNECTED", "Hedgewars server http://www.hedgewars.org/", serverVersion]
8239
c9359078a2ed Better check for bans
unc0rr
parents: 8232
diff changeset
   528
            , CheckBanned True
6809
unc0rr
parents: 6805
diff changeset
   529
            , AddIP2Bans (host cl) "Reconnected too fast" (addUTCTime 10 $ connectTime cl)
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   530
        ]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   531
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   532
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   533
processAction (AddNick2Bans n reason expiring) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   534
    processAction $ ModifyServerInfo (\s -> s{bans = BanByNick n reason expiring : bans s})
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   535
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   536
processAction (AddIP2Bans ip reason expiring) = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   537
    (Just ci) <- gets clientIndex
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   538
    rc <- gets removedClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   539
    when (not $ ci `Set.member` rc)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   540
        $ processAction $ ModifyServerInfo (\s -> s{bans = BanByIP ip reason expiring : bans s})
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   541
8519
98e2dbdda8c0 Workaround desync issue if I correctly understand its roots (barely tested)
unc0rr
parents: 8514
diff changeset
   542
8239
c9359078a2ed Better check for bans
unc0rr
parents: 8232
diff changeset
   543
processAction (CheckBanned byIP) = do
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   544
    clTime <- client's connectTime
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   545
    clNick <- client's nick
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   546
    clHost <- client's host
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   547
    si <- gets serverInfo
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   548
    let validBans = filter (checkNotExpired clTime) $ bans si
8239
c9359078a2ed Better check for bans
unc0rr
parents: 8232
diff changeset
   549
    let ban = L.find (checkBan byIP clHost clNick) $ validBans
5426
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   550
    mapM_ processAction $
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   551
        ModifyServerInfo (\s -> s{bans = validBans})
5426
109e9b5761c2 Implement command for banning by ip and a command for bans list
unc0rr
parents: 5214
diff changeset
   552
        : [ByeClient (getBanReason $ fromJust ban) | isJust ban]
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   553
    where
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   554
        checkNotExpired testTime (BanByIP _ _ time) = testTime `diffUTCTime` time <= 0
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   555
        checkNotExpired testTime (BanByNick _ _ time) = testTime `diffUTCTime` time <= 0
8239
c9359078a2ed Better check for bans
unc0rr
parents: 8232
diff changeset
   556
        checkBan True ip _ (BanByIP bip _ _) = bip `B.isPrefixOf` ip
c9359078a2ed Better check for bans
unc0rr
parents: 8232
diff changeset
   557
        checkBan False _ n (BanByNick bn _ _) = caseInsensitiveCompare bn n
c9359078a2ed Better check for bans
unc0rr
parents: 8232
diff changeset
   558
        checkBan _ _ _ _ = False
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   559
        getBanReason (BanByIP _ msg _) = msg
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   560
        getBanReason (BanByNick _ msg _) = msg
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   561
8519
98e2dbdda8c0 Workaround desync issue if I correctly understand its roots (barely tested)
unc0rr
parents: 8514
diff changeset
   562
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   563
processAction PingAll = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   564
    rnc <- gets roomsClients
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   565
    io (allClientsM rnc) >>= mapM_ (kickTimeouted rnc)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   566
    cis <- io $ allClientsM rnc
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   567
    chans <- io $ mapM (client'sM rnc sendChan) cis
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   568
    io $ mapM_ (modifyClient rnc (\cl -> cl{pingsQueue = pingsQueue cl + 1})) cis
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   569
    processAction $ AnswerClients chans ["PING"]
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   570
    where
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   571
        kickTimeouted rnc ci = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   572
            pq <- io $ client'sM rnc pingsQueue ci
7465
c2dcf97ca664 Okay, this is workaround over ping timeouts problem on the server. Could make server crash if recieve thread wakes up after second ping timeout event.
unc0rr
parents: 7351
diff changeset
   573
            when (pq > 0) $ do
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   574
                withStateT (\as -> as{clientIndex = Just ci}) $
8401
87410ae372f6 Server messages localization using Qt's l10n subsystem:
unc0rr
parents: 8396
diff changeset
   575
                    processAction (ByeClient $ loc "Ping timeout")
7600
31a177d2856c Disable workaround, as it still makes server crash and hung clients are hidden from players anyway
unc0rr
parents: 7537
diff changeset
   576
--                when (pq > 1) $
31a177d2856c Disable workaround, as it still makes server crash and hung clients are hidden from players anyway
unc0rr
parents: 7537
diff changeset
   577
--                    processAction $ DeleteClient ci -- smth went wrong with client io threads, issue DeleteClient here
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   578
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   579
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   580
processAction StatsAction = do
5211
8ebf92014447 Don't send stats after spawning new server
unc0rr
parents: 5210
diff changeset
   581
    si <- gets serverInfo
8ebf92014447 Don't send stats after spawning new server
unc0rr
parents: 5210
diff changeset
   582
    when (not $ shutdownPending si) $ do
5212
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   583
        rnc <- gets roomsClients
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   584
        (roomsNum, clientsNum) <- io $ withRoomsAndClients rnc st
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   585
        io $ writeChan (dbQueries si) $ SendStats clientsNum (roomsNum - 1)
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   586
    where
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   587
          st irnc = (length $ allRooms irnc, length $ allClients irnc)
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   588
7321
57bd4f201401 - Try sending remove message in 'finally' as a last resort
unc0rr
parents: 7126
diff changeset
   589
processAction RestartServer = do
5212
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   590
    sp <- gets (shutdownPending . serverInfo)
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   591
    when (not sp) $ do
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   592
        sock <- gets (fromJust . serverSocket . serverInfo)
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   593
        args <- gets (runArgs . serverInfo)
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   594
        io $ do
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   595
            noticeM "Core" "Closing listening socket"
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   596
            sClose sock
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   597
            noticeM "Core" "Spawning new server"
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   598
            _ <- createProcess (proc "./hedgewars-server" args)
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   599
            return ()
eaffb02f0053 Don't perform RestartServer action when already did it once
unc0rr
parents: 5211
diff changeset
   600
        processAction $ ModifyServerInfo (\s -> s{shutdownPending = True})
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   601
8403
fbc6e7602e05 - Allow server admins to use DELEGATE even when not room owner
unc0rr
parents: 8401
diff changeset
   602
processAction Stats = do
fbc6e7602e05 - Allow server admins to use DELEGATE even when not room owner
unc0rr
parents: 8401
diff changeset
   603
    cls <- allClientsS
8452
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   604
    rms <- allRoomsS
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   605
    let clientsMap = Map.fromListWith (+) . map (\c -> (clientProto c, 1 :: Int)) $ cls
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   606
    let roomsMap = Map.fromListWith (+) . map (\c -> (roomProto c, 1 :: Int)) . filter ((/=) 0 . roomProto) $ rms
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   607
    let keys = Map.keysSet clientsMap `Set.union` Map.keysSet roomsMap
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   608
    let versionsStats = B.concat . ((:) "<table border=1>") . (flip (++) ["</table>"])
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   609
            . concatMap (\p -> [
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   610
                    "<tr><td>", protoNumber2ver p
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   611
                    , "</td><td>", showB $ Map.findWithDefault 0 p clientsMap
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   612
                    , "</td><td>", showB $ Map.findWithDefault 0 p roomsMap
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   613
                    , "</td></tr>"])
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   614
            . Set.toList $ keys
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   615
    processAction $ Warning versionsStats
170afc3ac39f Also rooms per version stats
unc0rr
parents: 8439
diff changeset
   616
8403
fbc6e7602e05 - Allow server admins to use DELEGATE even when not room owner
unc0rr
parents: 8401
diff changeset
   617
6012
6bac93097da3 Store replays for further analysis
unc0rr
parents: 5996
diff changeset
   618
#if defined(OFFICIAL_SERVER)
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   619
processAction SaveReplay = do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   620
    ri <- clientRoomA
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   621
    rnc <- gets roomsClients
8371
0551b5c3de9a - Start work on checker
unc0rr
parents: 8369
diff changeset
   622
5184
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   623
    io $ do
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   624
        r <- room'sM rnc id ri
bf7bba60ed93 update iphone too
nemo
parents: 5143
diff changeset
   625
        saveReplay r
8479
8d71109b04d2 Some work on loading replay and interaction with checker
unc0rr
parents: 8476
diff changeset
   626
8d71109b04d2 Some work on loading replay and interaction with checker
unc0rr
parents: 8476
diff changeset
   627
8d71109b04d2 Some work on loading replay and interaction with checker
unc0rr
parents: 8476
diff changeset
   628
processAction CheckRecord = do
8d71109b04d2 Some work on loading replay and interaction with checker
unc0rr
parents: 8476
diff changeset
   629
    p <- client's clientProto
8482
5656a73fe3c3 Fix official server build
unc0rr
parents: 8479
diff changeset
   630
    c <- client's sendChan
8509
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   631
    (cinfo, l) <- io $ loadReplay (fromIntegral p)
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   632
    when (not . null $ l) $
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   633
        mapM_ processAction [
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   634
            AnswerClients [c] ("REPLAY" : l)
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   635
            , ModifyClient $ \c -> c{checkInfo = cinfo}
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   636
            ]
8479
8d71109b04d2 Some work on loading replay and interaction with checker
unc0rr
parents: 8476
diff changeset
   637
8509
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   638
processAction (CheckFailed msg) = do
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   639
    Just (CheckInfo fileName _) <- client's checkInfo
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   640
    io $ moveFailedRecord fileName
8507
f4475782cf45 Some more work on checker
unc0rr
parents: 8482
diff changeset
   641
8509
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   642
processAction (CheckSuccess info) = do
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   643
    Just (CheckInfo fileName _) <- client's checkInfo
eda9f2106d8d Sort checked files into dirs
unc0rr
parents: 8507
diff changeset
   644
    io $ moveCheckedRecord fileName
8507
f4475782cf45 Some more work on checker
unc0rr
parents: 8482
diff changeset
   645
6012
6bac93097da3 Store replays for further analysis
unc0rr
parents: 5996
diff changeset
   646
#else
6bac93097da3 Store replays for further analysis
unc0rr
parents: 5996
diff changeset
   647
processAction SaveReplay = return ()
8479
8d71109b04d2 Some work on loading replay and interaction with checker
unc0rr
parents: 8476
diff changeset
   648
processAction CheckRecord = return ()
8507
f4475782cf45 Some more work on checker
unc0rr
parents: 8482
diff changeset
   649
processAction (CheckFailed _) = return ()
f4475782cf45 Some more work on checker
unc0rr
parents: 8482
diff changeset
   650
processAction (CheckSuccess _) = return ()
6012
6bac93097da3 Store replays for further analysis
unc0rr
parents: 5996
diff changeset
   651
#endif