aboutsummaryrefslogtreecommitdiff
path: root/server/src/Persistence/Income.hs
blob: cee98922c71317a91d7718f9bae0f1d1f7b98e42 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
module Persistence.Income
  ( list
  , create
  , edit
  , delete
  ) where

import           Data.Maybe             (listToMaybe)
import           Data.Time.Calendar     (Day)
import           Data.Time.Clock        (getCurrentTime)
import           Database.SQLite.Simple (FromRow (fromRow), Only (Only))
import qualified Database.SQLite.Simple as SQLite
import           Prelude                hiding (id)

import           Common.Model           (Income (..), IncomeId, PaymentId,
                                         UserId)

import           Model.Query            (Query (Query))

newtype Row = Row Income

instance FromRow Row where
  fromRow = Row <$> (Income <$>
    SQLite.field <*>
    SQLite.field <*>
    SQLite.field <*>
    SQLite.field <*>
    SQLite.field <*>
    SQLite.field <*>
    SQLite.field)

list :: Query [Income]
list =
  Query (\conn ->
    map (\(Row i) -> i) <$>
      SQLite.query_ conn "SELECT * FROM income WHERE deleted_at IS NULL"
  )

create :: UserId -> Day -> Int -> Query IncomeId
create incomeUserId incomeDate incomeAmount =
  Query (\conn -> do
    now <- getCurrentTime
    SQLite.execute
      conn
      "INSERT INTO income (user_id, date, amount, created_at) VALUES (?, ?, ?, ?)"
      (incomeUserId, incomeDate, incomeAmount, now)
    SQLite.lastInsertRowId conn
  )

edit :: UserId -> IncomeId -> Day -> Int -> Query Bool
edit incomeUserId incomeId incomeDate incomeAmount =
  Query (\conn -> do
    mbIncome <- fmap (\(Row i) -> i) . listToMaybe <$>
      SQLite.query conn "SELECT * FROM income WHERE id = ?" (Only incomeId)
    case mbIncome of
      Just income ->
        if _income_userId income == incomeUserId
          then do
            now <- getCurrentTime
            SQLite.execute
              conn
              "UPDATE income SET edited_at = ?, date = ?, amount = ? WHERE id = ?"
              (now, incomeDate, incomeAmount, incomeId)
            return True
          else
            return False
      Nothing ->
        return False
  )

delete :: UserId -> PaymentId -> Query ()
delete userId paymentId =
  Query (\conn ->
    SQLite.execute
      conn
      "UPDATE income SET deleted_at = datetime('now') WHERE id = ? AND user_id = ?"
      (paymentId, userId)
  )