, cereal

    , protobuf

makePrisms ''SubscriptionId

import Data.ProtocolBuffers (encodeMessage)
import           Data.Serialize.Put                   (runPut)

import           Aftok.Payments

creditToParser :: FieldParser (RowParser CreditTo)
creditToParser f v =   

creditToParser :: RowParser CreditTo
creditToParser = join $ fieldWith creditToParser'
creditToParser' :: FieldParser (RowParser CreditTo)
creditToParser' f v =   

  LogEntry <$> join (fieldWith creditToParser)

  LogEntry <$> creditToParser

    \(project_id, event_id, name, description, recurrence_type, recurrence_count, billing_amount, grace_period_days)\

    \(project_id, event_id, name, description, recurrence_type, recurrence_count, billing_amount, grace_period_days) \

updateCache (CreateSubscription _ _) = error "Not implemented"
updateCache (CreatePaymentRequest _) = error "Not implemented"

updateCache dbop @ (CreateSubscription uid bid) = do
  eventId <- requireEventId dbop
  pinsert BI.SubscriptionId
    "INSERT INTO subscriptions \
    \(user_id, billable_id, event_id) \
    \VALUES (?, ?, ?) RETURNING id"
    (uid ^. _UserId, bid ^. BI._BillableId, eventId ^. _EventId)
updateCache dbop @ (CreatePaymentRequest req) = do
  eventId <- requireEventId dbop
  pinsert PaymentRequestId
    "INSERT INTO payment_requests \
    \(subscription_id, event_id, request_data) \
    \VALUES (?, ?, ?) RETURNING id"
    ( req ^. (subscription . BI._SubscriptionId)
    , eventId ^. _EventId 
    , req ^. (paymentRequest . to (runPut . encodeMessage))
    )