author | sheepluva |
Thu, 12 Jun 2014 05:40:58 +0200 | |
changeset 10281 | dedc8f23e35e |
parent 9661 | 788fd9eedfb0 |
child 10460 | 8dcea9087d75 |
permissions | -rw-r--r-- |
4906 | 1 |
{-# LANGUAGE CPP, ScopedTypeVariables, OverloadedStrings #-} |
1804 | 2 |
module OfficialServer.DBInteraction |
3 |
( |
|
2869 | 4 |
startDBConnection |
1804 | 5 |
) where |
6 |
||
1979 | 7 |
import Prelude hiding (catch); |
4932 | 8 |
import Control.Concurrent |
9 |
import Control.Monad |
|
10 |
import Data.List as L |
|
11 |
import Data.ByteString.Char8 as B |
|
12 |
#if defined(OFFICIAL_SERVER) |
|
2116
dec7ead2d178
Bring back authentication to official server, now using separate process to perform database interaction
unc0rr
parents:
1979
diff
changeset
|
13 |
import System.Process |
4921 | 14 |
import System.IO as SIO |
2296
19f2f76dc346
Patch for compiling with 6.10 (define NEW_EXCEPTIONS to do that)
unc0rr
parents:
2245
diff
changeset
|
15 |
import qualified Control.Exception as Exception |
2117
1ac0e10e546f
Add caching for accounts information (entries are stored in memory forever)
unc0rr
parents:
2116
diff
changeset
|
16 |
import qualified Data.Map as Map |
4295
1f5604cd99be
This revision should, in theory, correctly merge 0.9.14 and tip, so that future merges of 0.9.14 should work properly
nemo
parents:
4242
diff
changeset
|
17 |
import Data.Maybe |
4932 | 18 |
import Data.Time |
1839
5dd4cb7fd7e5
Server now send ASKPASSWORD command to frontend when user has web account
unc0rr
parents:
1834
diff
changeset
|
19 |
import System.Log.Logger |
4932 | 20 |
#endif |
1833 | 21 |
------------------------ |
22 |
import CoreTypes |
|
4932 | 23 |
#if defined(OFFICIAL_SERVER) |
2116
dec7ead2d178
Bring back authentication to official server, now using separate process to perform database interaction
unc0rr
parents:
1979
diff
changeset
|
24 |
import Utils |
4932 | 25 |
#endif |
1804 | 26 |
|
4932 | 27 |
localAddressList :: [B.ByteString] |
1921 | 28 |
localAddressList = ["127.0.0.1", "0:0:0:0:0:0:0:1", "0:0:0:0:0:ffff:7f00:1"] |
1839
5dd4cb7fd7e5
Server now send ASKPASSWORD command to frontend when user has web account
unc0rr
parents:
1834
diff
changeset
|
29 |
|
4989 | 30 |
fakeDbConnection :: forall b. ServerInfo -> IO b |
4943
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
31 |
fakeDbConnection si = forever $ do |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
32 |
q <- readChan $ dbQueries si |
2869 | 33 |
case q of |
4932 | 34 |
CheckAccount clId clUid _ clHost -> |
4943
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
35 |
writeChan (coreChan si) $ ClientAccountInfo clId clUid (if clHost `L.elem` localAddressList then Admin else Guest) |
2869 | 36 |
ClearCache -> return () |
37 |
SendStats {} -> return () |
|
1857
b835395659e2
Fake database connection with routine which marks all users as guests, when no database host was specified
unc0rr
parents:
1847
diff
changeset
|
38 |
|
4996
76ef3d8bd78e
Fix crash (accessing already deleted client record) by reverting to old client removing handling + throwTo
unc0rr
parents:
4992
diff
changeset
|
39 |
dbConnectionLoop :: ServerInfo -> IO () |
76ef3d8bd78e
Fix crash (accessing already deleted client record) by reverting to old client removing handling + throwTo
unc0rr
parents:
4992
diff
changeset
|
40 |
|
2116
dec7ead2d178
Bring back authentication to official server, now using separate process to perform database interaction
unc0rr
parents:
1979
diff
changeset
|
41 |
#if defined(OFFICIAL_SERVER) |
4989 | 42 |
flushRequests :: ServerInfo -> IO () |
4943
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
43 |
flushRequests si = do |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
44 |
e <- isEmptyChan $ dbQueries si |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
45 |
unless e $ do |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
46 |
q <- readChan $ dbQueries si |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
47 |
case q of |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
48 |
CheckAccount clId clUid _ clHost -> |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
49 |
writeChan (coreChan si) $ ClientAccountInfo clId clUid (if clHost `L.elem` localAddressList then Admin else Guest) |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
50 |
ClearCache -> return () |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
51 |
SendStats {} -> return () |
9661 | 52 |
GetReplayName {} -> return () |
53 |
StoreAchievements {} -> return () |
|
4943
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
54 |
flushRequests si |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
55 |
|
4944 | 56 |
pipeDbConnectionLoop :: Chan DBQuery -> Chan CoreMessage -> Handle -> Handle -> Map.Map ByteString (UTCTime, AccountInfo) -> Int -> IO (Map.Map ByteString (UTCTime, AccountInfo), Int) |
57 |
pipeDbConnectionLoop queries cChan hIn hOut accountsCache req = |
|
58 |
Exception.handle (\(e :: Exception.IOException) -> warningM "Database" (show e) >> return (accountsCache, req)) $ |
|
2869 | 59 |
do |
60 |
q <- readChan queries |
|
4944 | 61 |
(updatedCache, newReq) <- case q of |
4921 | 62 |
CheckAccount clId clUid clNick _ -> do |
2869 | 63 |
let cacheEntry = clNick `Map.lookup` accountsCache |
64 |
currentTime <- getCurrentTime |
|
7331
0e50456d652c
Well, since we have database on the same computer as game server, could remove caching, but I just set expiration time to 10 minutes
unc0rr
parents:
4996
diff
changeset
|
65 |
if (isNothing cacheEntry) || (currentTime `diffUTCTime` (fst . fromJust) cacheEntry > 10 * 60) then |
2869 | 66 |
do |
4921 | 67 |
SIO.hPutStrLn hIn $ show q |
2869 | 68 |
hFlush hIn |
2117
1ac0e10e546f
Add caching for accounts information (entries are stored in memory forever)
unc0rr
parents:
2116
diff
changeset
|
69 |
|
4921 | 70 |
(clId', clUid', accountInfo) <- SIO.hGetLine hOut >>= (maybeException . maybeRead) |
2117
1ac0e10e546f
Add caching for accounts information (entries are stored in memory forever)
unc0rr
parents:
2116
diff
changeset
|
71 |
|
4943
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
72 |
writeChan cChan $ ClientAccountInfo clId' clUid' accountInfo |
2117
1ac0e10e546f
Add caching for accounts information (entries are stored in memory forever)
unc0rr
parents:
2116
diff
changeset
|
73 |
|
4944 | 74 |
return $ (Map.insert clNick (currentTime, accountInfo) accountsCache, req + 1) |
2869 | 75 |
`Exception.onException` |
4944 | 76 |
(unGetChan queries q) |
2869 | 77 |
else |
78 |
do |
|
4943
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
79 |
writeChan cChan $ ClientAccountInfo clId clUid (snd $ fromJust cacheEntry) |
4944 | 80 |
return (accountsCache, req) |
2155
d897222d3339
Implement ability for server admin to clear accounts cache
unc0rr
parents:
2129
diff
changeset
|
81 |
|
9446 | 82 |
GetReplayName {} -> do |
83 |
SIO.hPutStrLn hIn $ show q |
|
84 |
hFlush hIn |
|
85 |
||
86 |
(clId', clUid', accountInfo) <- SIO.hGetLine hOut >>= (maybeException . maybeRead) |
|
87 |
||
88 |
writeChan cChan $ ClientAccountInfo clId' clUid' accountInfo |
|
9450 | 89 |
return (accountsCache, req) |
9446 | 90 |
|
4944 | 91 |
ClearCache -> return (Map.empty, req) |
9399 | 92 |
StoreAchievements {} -> ( |
93 |
(SIO.hPutStrLn hIn $ show q) >> |
|
94 |
hFlush hIn >> |
|
95 |
return (accountsCache, req)) |
|
96 |
`Exception.onException` |
|
97 |
(unGetChan queries q) |
|
2869 | 98 |
SendStats {} -> ( |
4921 | 99 |
(SIO.hPutStrLn hIn $ show q) >> |
2869 | 100 |
hFlush hIn >> |
4944 | 101 |
return (accountsCache, req)) |
2869 | 102 |
`Exception.onException` |
103 |
(unGetChan queries q) |
|
2184 | 104 |
|
4944 | 105 |
pipeDbConnectionLoop queries cChan hIn hOut updatedCache newReq |
2869 | 106 |
where |
107 |
maybeException (Just a) = return a |
|
108 |
maybeException Nothing = ioError (userError "Can't read") |
|
1804 | 109 |
|
4992 | 110 |
pipeDbConnection :: |
4982
3572eaf14340
Add dbName parameter to .ini file, fix some warnings
unc0rr
parents:
4975
diff
changeset
|
111 |
Map.Map ByteString (UTCTime, AccountInfo) |
4989 | 112 |
-> ServerInfo |
4992 | 113 |
-> Int |
114 |
-> IO () |
|
4982
3572eaf14340
Add dbName parameter to .ini file, fix some warnings
unc0rr
parents:
4975
diff
changeset
|
115 |
|
4943
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
116 |
pipeDbConnection accountsCache si errNum = do |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
117 |
(updatedCache, newErrNum) <- |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
118 |
Exception.handle (\(e :: Exception.IOException) -> warningM "Database" (show e) >> return (accountsCache, errNum + 1)) $ do |
2869 | 119 |
(Just hIn, Just hOut, _, _) <- createProcess (proc "./OfficialServer/extdbinterface" []) |
120 |
{std_in = CreatePipe, |
|
121 |
std_out = CreatePipe} |
|
122 |
hSetBuffering hIn LineBuffering |
|
123 |
hSetBuffering hOut LineBuffering |
|
1804 | 124 |
|
4921 | 125 |
B.hPutStrLn hIn $ dbHost si |
4982
3572eaf14340
Add dbName parameter to .ini file, fix some warnings
unc0rr
parents:
4975
diff
changeset
|
126 |
B.hPutStrLn hIn $ dbName si |
4921 | 127 |
B.hPutStrLn hIn $ dbLogin si |
128 |
B.hPutStrLn hIn $ dbPassword si |
|
4944 | 129 |
(c, r) <- pipeDbConnectionLoop (dbQueries si) (coreChan si) hIn hOut accountsCache 0 |
130 |
return (c, if r > 0 then 0 else errNum + 1) |
|
2184 | 131 |
|
4943
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
132 |
when (newErrNum > 1) $ flushRequests si |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
133 |
threadDelay (3000000) |
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
134 |
pipeDbConnection updatedCache si newErrNum |
2116
dec7ead2d178
Bring back authentication to official server, now using separate process to perform database interaction
unc0rr
parents:
1979
diff
changeset
|
135 |
|
4921 | 136 |
dbConnectionLoop si = |
137 |
if (not . B.null $ dbHost si) then |
|
4943
21d6b2b79cfe
Allow users to join official server even when there's no db connection
unc0rr
parents:
4932
diff
changeset
|
138 |
pipeDbConnection Map.empty si 0 |
2869 | 139 |
else |
4921 | 140 |
fakeDbConnection si |
1979 | 141 |
#else |
142 |
dbConnectionLoop = fakeDbConnection |
|
143 |
#endif |
|
1804 | 144 |
|
4989 | 145 |
startDBConnection :: ServerInfo -> IO () |
1833 | 146 |
startDBConnection serverInfo = |
4932 | 147 |
forkIO (dbConnectionLoop serverInfo) >> return () |