module OfficialServer.DBInteraction

(

	startDBConnection,

	DBQuery(HasRegistered, CheckPassword)

) where

import Database.HDBC

import Database.HDBC.MySQL

import System.IO

import Control.Concurrent

import Control.Concurrent.STM

import Control.Exception

data DBQuery =

	HasRegistered String

	| CheckPassword String

dbInteractionLoop queries dbConn = do

	q <- atomically $ readTChan queries

	case q of

		HasRegistered queryStr -> putStrLn queryStr

		CheckPassword queryStr -> putStrLn queryStr

	dbInteractionLoop queries dbConn

dbConnectionLoop queries = do

	Control.Exception.handle (\e -> print e) $ handleSqlError $

		bracket

			(connectMySQL defaultMySQLConnectInfo { mysqlHost = "192.168.50.5", mysqlDatabase = "glpi" })

			(disconnect)

			(dbInteractionLoop queries)

	threadDelay (15 * 10^6)

	dbConnectionLoop queries

startDBConnection queries = forkIO $ dbConnectionLoop queries