864 lines
		
	
	
		
			31 KiB
		
	
	
	
		
			Haskell
		
	
	
	
	
	
			
		
		
	
	
			864 lines
		
	
	
		
			31 KiB
		
	
	
	
		
			Haskell
		
	
	
	
	
	
--- * doc
 | 
						|
-- Lines beginning "--- *" are collapsible orgstruct nodes. Emacs users,
 | 
						|
-- (add-hook 'haskell-mode-hook
 | 
						|
--   (lambda () (set-variable 'orgstruct-heading-prefix-regexp "--- " t))
 | 
						|
--   'orgstruct-mode)
 | 
						|
-- and press TAB on nodes to expand/collapse.
 | 
						|
 | 
						|
{-|
 | 
						|
 | 
						|
A reader for hledger's journal file format
 | 
						|
(<http://hledger.org/MANUAL.html#the-journal-file>).  hledger's journal
 | 
						|
format is a compatible subset of c++ ledger's
 | 
						|
(<http://ledger-cli.org/3.0/doc/ledger3.html#Journal-Format>), so this
 | 
						|
reader should handle many ledger files as well. Example:
 | 
						|
 | 
						|
@
 | 
						|
2012\/3\/24 gift
 | 
						|
    expenses:gifts  $10
 | 
						|
    assets:cash
 | 
						|
@
 | 
						|
 | 
						|
Journal format supports the include directive which can read files in
 | 
						|
other formats, so the other file format readers need to be importable
 | 
						|
here.  Some low-level journal syntax parsers which those readers also
 | 
						|
use are therefore defined separately in Hledger.Read.Common, avoiding
 | 
						|
import cycles.
 | 
						|
 | 
						|
-}
 | 
						|
 | 
						|
--- * module
 | 
						|
 | 
						|
{-# LANGUAGE CPP, RecordWildCards, NamedFieldPuns, NoMonoLocalBinds, ScopedTypeVariables, FlexibleContexts, TupleSections, OverloadedStrings, PackageImports #-}
 | 
						|
 | 
						|
module Hledger.Read.JournalReader (
 | 
						|
--- * exports
 | 
						|
 | 
						|
  -- * Reader
 | 
						|
  reader,
 | 
						|
 | 
						|
  -- * Parsing utils
 | 
						|
  genericSourcePos,
 | 
						|
  parseAndFinaliseJournal,
 | 
						|
  runJournalParser,
 | 
						|
  rjp,
 | 
						|
 | 
						|
  -- * Parsers used elsewhere
 | 
						|
  getParentAccount,
 | 
						|
  journalp,
 | 
						|
  directivep,
 | 
						|
  defaultyeardirectivep,
 | 
						|
  marketpricedirectivep,
 | 
						|
  datetimep,
 | 
						|
  datep,
 | 
						|
  -- codep,
 | 
						|
  -- accountnamep,
 | 
						|
  modifiedaccountnamep,
 | 
						|
  postingp,
 | 
						|
  -- amountp,
 | 
						|
  -- amountp',
 | 
						|
  -- mamountp',
 | 
						|
  -- numberp,
 | 
						|
  statusp,
 | 
						|
  emptyorcommentlinep,
 | 
						|
  followingcommentp
 | 
						|
 | 
						|
  -- * Tests
 | 
						|
  ,tests_Hledger_Read_JournalReader
 | 
						|
  ,easytests
 | 
						|
)
 | 
						|
where
 | 
						|
--- * imports
 | 
						|
import Prelude ()
 | 
						|
import "base-compat-batteries" Prelude.Compat hiding (readFile)
 | 
						|
import qualified Control.Exception as C
 | 
						|
import Control.Monad
 | 
						|
import Control.Monad.Except (ExceptT(..))
 | 
						|
import Control.Monad.State.Strict
 | 
						|
import Data.Bifunctor (first)
 | 
						|
import Data.Functor.Identity (Identity(..))
 | 
						|
import qualified Data.Map.Strict as M
 | 
						|
import Data.Text (Text)
 | 
						|
import Data.String
 | 
						|
import Data.List
 | 
						|
import qualified Data.Text as T
 | 
						|
import Data.Time.Calendar
 | 
						|
import Data.Time.LocalTime
 | 
						|
import Safe
 | 
						|
import Text.Megaparsec hiding (parse)
 | 
						|
import Text.Megaparsec.Char
 | 
						|
import Text.Megaparsec.Custom
 | 
						|
import Text.Printf
 | 
						|
import System.FilePath
 | 
						|
import "Glob" System.FilePath.Glob hiding (match)
 | 
						|
 | 
						|
import Hledger.Data hiding (easytests)
 | 
						|
import Hledger.Read.Common hiding (easytests)
 | 
						|
import Hledger.Read.TimeclockReader (timeclockfilep)
 | 
						|
import Hledger.Read.TimedotReader (timedotfilep)
 | 
						|
import Hledger.Utils
 | 
						|
 | 
						|
-- $setup
 | 
						|
-- >>> :set -XOverloadedStrings
 | 
						|
 | 
						|
--- * reader
 | 
						|
 | 
						|
reader :: Reader
 | 
						|
reader = Reader
 | 
						|
  {rFormat     = "journal"
 | 
						|
  ,rExtensions = ["journal", "j", "hledger", "ledger"]
 | 
						|
  ,rParser     = parse
 | 
						|
  ,rExperimental = False
 | 
						|
  }
 | 
						|
 | 
						|
-- | Parse and post-process a "Journal" from hledger's journal file
 | 
						|
-- format, or give an error.
 | 
						|
parse :: InputOpts -> FilePath -> Text -> ExceptT String IO Journal
 | 
						|
parse iopts = parseAndFinaliseJournal journalp' iopts
 | 
						|
  where
 | 
						|
    journalp' = do 
 | 
						|
      -- reverse parsed aliases to ensure that they are applied in order given on commandline
 | 
						|
      mapM_ addAccountAlias (reverse $ aliasesFromOpts iopts) 
 | 
						|
      journalp
 | 
						|
 | 
						|
-- | Get the account name aliases from options, if any.
 | 
						|
aliasesFromOpts :: InputOpts -> [AccountAlias]
 | 
						|
aliasesFromOpts = map (\a -> fromparse $ runParser accountaliasp ("--alias "++quoteIfNeeded a) $ T.pack a)
 | 
						|
                  . aliases_
 | 
						|
 | 
						|
--- * parsers
 | 
						|
--- ** journal
 | 
						|
 | 
						|
-- | A journal parser. Accumulates and returns a "ParsedJournal",
 | 
						|
-- which should be finalised/validated before use.
 | 
						|
--
 | 
						|
-- >>> rjp (journalp <* eof) "2015/1/1\n a  0\n"
 | 
						|
-- Right Journal  with 1 transactions, 1 accounts
 | 
						|
--
 | 
						|
journalp :: MonadIO m => JournalParser m ParsedJournal
 | 
						|
journalp = do
 | 
						|
  many addJournalItemP
 | 
						|
  eof
 | 
						|
  get
 | 
						|
 | 
						|
-- | A side-effecting parser; parses any kind of journal item
 | 
						|
-- and updates the parse state accordingly.
 | 
						|
addJournalItemP :: MonadIO m => JournalParser m ()
 | 
						|
addJournalItemP =
 | 
						|
  -- all journal line types can be distinguished by the first
 | 
						|
  -- character, can use choice without backtracking
 | 
						|
  choice [
 | 
						|
      directivep
 | 
						|
    , transactionp          >>= modify' . addTransaction
 | 
						|
    , transactionmodifierp  >>= modify' . addTransactionModifier
 | 
						|
    , periodictransactionp  >>= modify' . addPeriodicTransaction
 | 
						|
    , marketpricedirectivep >>= modify' . addMarketPrice
 | 
						|
    , void (lift emptyorcommentlinep)
 | 
						|
    , void (lift multilinecommentp)
 | 
						|
    ] <?> "transaction or directive"
 | 
						|
 | 
						|
--- ** directives
 | 
						|
 | 
						|
-- | Parse any journal directive and update the parse state accordingly.
 | 
						|
-- Cf http://hledger.org/manual.html#directives,
 | 
						|
-- http://ledger-cli.org/3.0/doc/ledger3.html#Command-Directives
 | 
						|
directivep :: MonadIO m => JournalParser m ()
 | 
						|
directivep = (do
 | 
						|
  optional $ char '!'
 | 
						|
  choice [
 | 
						|
    includedirectivep
 | 
						|
   ,aliasdirectivep
 | 
						|
   ,endaliasesdirectivep
 | 
						|
   ,accountdirectivep
 | 
						|
   ,applyaccountdirectivep
 | 
						|
   ,commoditydirectivep
 | 
						|
   ,endapplyaccountdirectivep
 | 
						|
   ,tagdirectivep
 | 
						|
   ,endtagdirectivep
 | 
						|
   ,defaultyeardirectivep
 | 
						|
   ,defaultcommoditydirectivep
 | 
						|
   ,commodityconversiondirectivep
 | 
						|
   ,ignoredpricecommoditydirectivep
 | 
						|
   ]
 | 
						|
  ) <?> "directive"
 | 
						|
 | 
						|
includedirectivep :: MonadIO m => JournalParser m ()
 | 
						|
includedirectivep = do
 | 
						|
  string "include"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  filename <- T.unpack <$> takeWhileP Nothing (/= '\n') -- don't consume newline yet
 | 
						|
 | 
						|
  parentpos <- getPosition
 | 
						|
 | 
						|
  filepaths <- getFilePaths parentpos filename
 | 
						|
 | 
						|
  forM_ filepaths $ parseChild parentpos
 | 
						|
 | 
						|
  void newline
 | 
						|
 | 
						|
  where
 | 
						|
    getFilePaths parserpos filename = do
 | 
						|
        curdir <- lift $ expandPath (takeDirectory $ sourceName parserpos) ""
 | 
						|
                         `orRethrowIOError` (show parserpos ++ " locating " ++ filename)
 | 
						|
        -- Compiling filename as a glob pattern works even if it is a literal
 | 
						|
        fileglob <- case tryCompileWith compDefault{errorRecovery=False} filename of
 | 
						|
            Right x -> pure x
 | 
						|
            Left e -> parseErrorAt parserpos $ "Invalid glob pattern: " ++ e
 | 
						|
        -- Get all matching files in the current working directory, sorting in
 | 
						|
        -- lexicographic order to simulate the output of 'ls'.
 | 
						|
        filepaths <- liftIO $ sort <$> globDir1 fileglob curdir
 | 
						|
        if (not . null) filepaths
 | 
						|
            then pure filepaths
 | 
						|
            else parseErrorAt parserpos $ "No existing files match pattern: " ++ filename
 | 
						|
 | 
						|
    parseChild parentpos filepath = do
 | 
						|
        parentfilestack <- fmap sourceName . statePos <$> getParserState
 | 
						|
        when (filepath `elem` parentfilestack)
 | 
						|
            $ parseErrorAt parentpos ("Cyclic include: " ++ filepath)
 | 
						|
 | 
						|
        childInput <- lift $ readFilePortably filepath
 | 
						|
                             `orRethrowIOError` (show parentpos ++ " reading " ++ filepath)
 | 
						|
 | 
						|
        -- save parent state
 | 
						|
        parentParserState <- getParserState
 | 
						|
        parentj <- get
 | 
						|
 | 
						|
        let childj = newJournalWithParseStateFrom parentj
 | 
						|
 | 
						|
        -- set child state
 | 
						|
        setInput childInput
 | 
						|
        pushPosition $ initialPos filepath
 | 
						|
        put childj
 | 
						|
 | 
						|
        -- parse include file
 | 
						|
        let parsers = [ journalp
 | 
						|
                      , timeclockfilep
 | 
						|
                      , timedotfilep
 | 
						|
                      ] -- can't include a csv file yet, that reader is special
 | 
						|
        updatedChildj <- journalAddFile (filepath, childInput) <$>
 | 
						|
                        region (withSource childInput) (choiceInState parsers)
 | 
						|
 | 
						|
        -- restore parent state, prepending the child's parse info
 | 
						|
        setParserState parentParserState
 | 
						|
        put $ updatedChildj <> parentj
 | 
						|
        -- discard child's parse info, prepend its (reversed) list data, combine other fields
 | 
						|
 | 
						|
 | 
						|
newJournalWithParseStateFrom :: Journal -> Journal
 | 
						|
newJournalWithParseStateFrom j = mempty{
 | 
						|
   jparsedefaultyear      = jparsedefaultyear j
 | 
						|
  ,jparsedefaultcommodity = jparsedefaultcommodity j
 | 
						|
  ,jparseparentaccounts   = jparseparentaccounts j
 | 
						|
  ,jparsealiases          = jparsealiases j
 | 
						|
  ,jcommodities           = jcommodities j
 | 
						|
  -- ,jparsetransactioncount = jparsetransactioncount j
 | 
						|
  ,jparsetimeclockentries = jparsetimeclockentries j
 | 
						|
  }
 | 
						|
 | 
						|
-- | Lift an IO action into the exception monad, rethrowing any IO
 | 
						|
-- error with the given message prepended.
 | 
						|
orRethrowIOError :: MonadIO m => IO a -> String -> TextParser m a
 | 
						|
orRethrowIOError io msg = do
 | 
						|
  eResult <- liftIO $ (Right <$> io) `C.catch` \(e::C.IOException) -> pure $ Left $ printf "%s:\n%s" msg (show e)
 | 
						|
  case eResult of
 | 
						|
    Right res -> pure res
 | 
						|
    Left errMsg -> fail errMsg
 | 
						|
 | 
						|
accountdirectivep :: JournalParser m ()
 | 
						|
accountdirectivep = do
 | 
						|
  string "account"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  acct <- modifiedaccountnamep  -- account directives can be modified by alias/apply account
 | 
						|
  macode' :: Maybe String <- (optional $ lift $ skipSome spacenonewline >> some digitChar)
 | 
						|
  let macode :: Maybe AccountCode = read <$> macode'
 | 
						|
  newline
 | 
						|
  skipMany indentedlinep
 | 
						|
    
 | 
						|
  modify' (\j -> j{jaccounts = (acct, macode) : jaccounts j})
 | 
						|
 | 
						|
indentedlinep :: JournalParser m String
 | 
						|
indentedlinep = lift (skipSome spacenonewline) >> (rstrip <$> lift restofline)
 | 
						|
 | 
						|
-- | Parse a one-line or multi-line commodity directive.
 | 
						|
--
 | 
						|
-- >>> Right _ <- rjp commoditydirectivep "commodity $1.00"
 | 
						|
-- >>> Right _ <- rjp commoditydirectivep "commodity $\n  format $1.00"
 | 
						|
-- >>> Right _ <- rjp commoditydirectivep "commodity $\n\n" -- a commodity with no format
 | 
						|
-- >>> Right _ <- rjp commoditydirectivep "commodity $1.00\n  format $1.00" -- both, what happens ?
 | 
						|
commoditydirectivep :: JournalParser m ()
 | 
						|
commoditydirectivep = commoditydirectiveonelinep <|> commoditydirectivemultilinep
 | 
						|
 | 
						|
-- | Parse a one-line commodity directive.
 | 
						|
--
 | 
						|
-- >>> Right _ <- rjp commoditydirectiveonelinep "commodity $1.00"
 | 
						|
-- >>> Right _ <- rjp commoditydirectiveonelinep "commodity $1.00 ; blah\n"
 | 
						|
commoditydirectiveonelinep :: JournalParser m ()
 | 
						|
commoditydirectiveonelinep = do
 | 
						|
  (pos, Amount{acommodity,astyle}) <- try $ do
 | 
						|
    string "commodity"
 | 
						|
    lift (skipSome spacenonewline)
 | 
						|
    pos <- getPosition
 | 
						|
    amount <- amountp
 | 
						|
    pure $ (pos, amount)
 | 
						|
  lift (skipMany spacenonewline)
 | 
						|
  _ <- lift followingcommentp
 | 
						|
  let comm = Commodity{csymbol=acommodity, cformat=Just $ dbg2 "style from commodity directive" astyle}
 | 
						|
  if asdecimalpoint astyle == Nothing
 | 
						|
  then parseErrorAt pos pleaseincludedecimalpoint
 | 
						|
  else modify' (\j -> j{jcommodities=M.insert acommodity comm $ jcommodities j})
 | 
						|
 | 
						|
pleaseincludedecimalpoint :: String
 | 
						|
pleaseincludedecimalpoint = "to avoid ambiguity, please include a decimal separator in commodity directives"
 | 
						|
 | 
						|
-- | Parse a multi-line commodity directive, containing 0 or more format subdirectives.
 | 
						|
--
 | 
						|
-- >>> Right _ <- rjp commoditydirectivemultilinep "commodity $ ; blah \n  format $1.00 ; blah"
 | 
						|
commoditydirectivemultilinep :: JournalParser m ()
 | 
						|
commoditydirectivemultilinep = do
 | 
						|
  string "commodity"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  sym <- lift commoditysymbolp
 | 
						|
  _ <- lift followingcommentp
 | 
						|
  mformat <- lastMay <$> many (indented $ formatdirectivep sym)
 | 
						|
  let comm = Commodity{csymbol=sym, cformat=mformat}
 | 
						|
  modify' (\j -> j{jcommodities=M.insert sym comm $ jcommodities j})
 | 
						|
  where
 | 
						|
    indented = (lift (skipSome spacenonewline) >>)
 | 
						|
 | 
						|
-- | Parse a format (sub)directive, throwing a parse error if its
 | 
						|
-- symbol does not match the one given.
 | 
						|
formatdirectivep :: CommoditySymbol -> JournalParser m AmountStyle
 | 
						|
formatdirectivep expectedsym = do
 | 
						|
  string "format"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  pos <- getPosition
 | 
						|
  Amount{acommodity,astyle} <- amountp
 | 
						|
  _ <- lift followingcommentp
 | 
						|
  if acommodity==expectedsym
 | 
						|
    then 
 | 
						|
      if asdecimalpoint astyle == Nothing
 | 
						|
      then parseErrorAt pos pleaseincludedecimalpoint
 | 
						|
      else return $ dbg2 "style from format subdirective" astyle
 | 
						|
    else parseErrorAt pos $
 | 
						|
         printf "commodity directive symbol \"%s\" and format directive symbol \"%s\" should be the same" expectedsym acommodity
 | 
						|
 | 
						|
keywordp :: String -> JournalParser m ()
 | 
						|
keywordp = (() <$) . string . fromString
 | 
						|
 | 
						|
spacesp :: JournalParser m ()
 | 
						|
spacesp = () <$ lift (skipSome spacenonewline)
 | 
						|
 | 
						|
-- | Backtracking parser similar to string, but allows varying amount of space between words
 | 
						|
keywordsp :: String -> JournalParser m ()
 | 
						|
keywordsp = try . sequence_ . intersperse spacesp . map keywordp . words
 | 
						|
 | 
						|
applyaccountdirectivep :: JournalParser m ()
 | 
						|
applyaccountdirectivep = do
 | 
						|
  keywordsp "apply account" <?> "apply account directive"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  parent <- lift accountnamep
 | 
						|
  newline
 | 
						|
  pushParentAccount parent
 | 
						|
 | 
						|
endapplyaccountdirectivep :: JournalParser m ()
 | 
						|
endapplyaccountdirectivep = do
 | 
						|
  keywordsp "end apply account" <?> "end apply account directive"
 | 
						|
  popParentAccount
 | 
						|
 | 
						|
aliasdirectivep :: JournalParser m ()
 | 
						|
aliasdirectivep = do
 | 
						|
  string "alias"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  alias <- lift accountaliasp
 | 
						|
  addAccountAlias alias
 | 
						|
 | 
						|
accountaliasp :: TextParser m AccountAlias
 | 
						|
accountaliasp = regexaliasp <|> basicaliasp
 | 
						|
 | 
						|
basicaliasp :: TextParser m AccountAlias
 | 
						|
basicaliasp = do
 | 
						|
  -- dbgparse 0 "basicaliasp"
 | 
						|
  old <- rstrip <$> (some $ noneOf ("=" :: [Char]))
 | 
						|
  char '='
 | 
						|
  skipMany spacenonewline
 | 
						|
  new <- rstrip <$> anyChar `manyTill` eolof  -- eol in journal, eof in command lines, normally
 | 
						|
  return $ BasicAlias (T.pack old) (T.pack new)
 | 
						|
 | 
						|
regexaliasp :: TextParser m AccountAlias
 | 
						|
regexaliasp = do
 | 
						|
  -- dbgparse 0 "regexaliasp"
 | 
						|
  char '/'
 | 
						|
  re <- some $ noneOf ("/\n\r" :: [Char]) -- paranoid: don't try to read past line end
 | 
						|
  char '/'
 | 
						|
  skipMany spacenonewline
 | 
						|
  char '='
 | 
						|
  skipMany spacenonewline
 | 
						|
  repl <- anyChar `manyTill` eolof
 | 
						|
  return $ RegexAlias re repl
 | 
						|
 | 
						|
endaliasesdirectivep :: JournalParser m ()
 | 
						|
endaliasesdirectivep = do
 | 
						|
  keywordsp "end aliases" <?> "end aliases directive"
 | 
						|
  clearAccountAliases
 | 
						|
 | 
						|
tagdirectivep :: JournalParser m ()
 | 
						|
tagdirectivep = do
 | 
						|
  string "tag" <?> "tag directive"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  _ <- lift $ some nonspace
 | 
						|
  lift restofline
 | 
						|
  return ()
 | 
						|
 | 
						|
endtagdirectivep :: JournalParser m ()
 | 
						|
endtagdirectivep = do
 | 
						|
  (keywordsp "end tag" <|> keywordp "pop") <?> "end tag or pop directive"
 | 
						|
  lift restofline
 | 
						|
  return ()
 | 
						|
 | 
						|
defaultyeardirectivep :: JournalParser m ()
 | 
						|
defaultyeardirectivep = do
 | 
						|
  char 'Y' <?> "default year"
 | 
						|
  lift (skipMany spacenonewline)
 | 
						|
  y <- some digitChar
 | 
						|
  let y' = read y
 | 
						|
  failIfInvalidYear y
 | 
						|
  setYear y'
 | 
						|
 | 
						|
defaultcommoditydirectivep :: JournalParser m ()
 | 
						|
defaultcommoditydirectivep = do
 | 
						|
  char 'D' <?> "default commodity"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  pos <- getPosition
 | 
						|
  Amount{acommodity,astyle} <- amountp
 | 
						|
  lift restofline
 | 
						|
  if asdecimalpoint astyle == Nothing
 | 
						|
  then parseErrorAt pos pleaseincludedecimalpoint
 | 
						|
  else setDefaultCommodityAndStyle (acommodity, astyle)
 | 
						|
 | 
						|
marketpricedirectivep :: JournalParser m MarketPrice
 | 
						|
marketpricedirectivep = do
 | 
						|
  char 'P' <?> "market price"
 | 
						|
  lift (skipMany spacenonewline)
 | 
						|
  date <- try (do {LocalTime d _ <- datetimep; return d}) <|> datep -- a time is ignored
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  symbol <- lift commoditysymbolp
 | 
						|
  lift (skipMany spacenonewline)
 | 
						|
  price <- amountp
 | 
						|
  lift restofline
 | 
						|
  return $ MarketPrice date symbol price
 | 
						|
 | 
						|
ignoredpricecommoditydirectivep :: JournalParser m ()
 | 
						|
ignoredpricecommoditydirectivep = do
 | 
						|
  char 'N' <?> "ignored-price commodity"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  lift commoditysymbolp
 | 
						|
  lift restofline
 | 
						|
  return ()
 | 
						|
 | 
						|
commodityconversiondirectivep :: JournalParser m ()
 | 
						|
commodityconversiondirectivep = do
 | 
						|
  char 'C' <?> "commodity conversion"
 | 
						|
  lift (skipSome spacenonewline)
 | 
						|
  amountp
 | 
						|
  lift (skipMany spacenonewline)
 | 
						|
  char '='
 | 
						|
  lift (skipMany spacenonewline)
 | 
						|
  amountp
 | 
						|
  lift restofline
 | 
						|
  return ()
 | 
						|
 | 
						|
--- ** transactions
 | 
						|
 | 
						|
transactionmodifierp :: JournalParser m TransactionModifier
 | 
						|
transactionmodifierp = do
 | 
						|
  char '=' <?> "modifier transaction"
 | 
						|
  lift (skipMany spacenonewline)
 | 
						|
  querytxt <- lift $ T.strip <$> descriptionp
 | 
						|
  (_comment, _tags) <- lift transactioncommentp   -- TODO apply these to modified txns ?
 | 
						|
  postings <- postingsp Nothing
 | 
						|
  return $ TransactionModifier querytxt postings
 | 
						|
 | 
						|
-- | Parse a periodic transaction
 | 
						|
periodictransactionp :: MonadIO m => JournalParser m PeriodicTransaction
 | 
						|
periodictransactionp = do
 | 
						|
 | 
						|
  -- first line
 | 
						|
  char '~' <?> "periodic transaction"
 | 
						|
  lift $ skipMany spacenonewline
 | 
						|
  -- a period expression
 | 
						|
  pos <- getPosition
 | 
						|
  d <- liftIO getCurrentDay
 | 
						|
  (periodtxt, (interval, span)) <- lift $ first T.strip <$> match (periodexprp d)
 | 
						|
  -- In periodic transactions, the period expression has an additional constraint:
 | 
						|
  case checkPeriodicTransactionStartDate interval span periodtxt of
 | 
						|
    Just e -> parseErrorAt pos e
 | 
						|
    Nothing -> pure ()
 | 
						|
  -- The line can end here, or it can continue with one or more spaces
 | 
						|
  -- and then zero or more of the following fields. A bit awkward.
 | 
						|
  (status, code, description, (comment, tags)) <-
 | 
						|
    (lift eolof >> return (Unmarked, "", "", ("", [])))
 | 
						|
    <|>
 | 
						|
    (do
 | 
						|
      lift $ skipSome spacenonewline 
 | 
						|
      s         <- lift statusp
 | 
						|
      c         <- lift codep
 | 
						|
      desc      <- lift $ T.strip <$> descriptionp
 | 
						|
      (cmt, ts) <- lift transactioncommentp
 | 
						|
      return (s,c,desc,(cmt,ts))
 | 
						|
    )
 | 
						|
 | 
						|
  -- next lines
 | 
						|
  postings <- postingsp (Just $ first3 $ toGregorian d)
 | 
						|
 | 
						|
  return $ nullperiodictransaction{
 | 
						|
     ptperiodexpr=periodtxt
 | 
						|
    ,ptinterval=interval
 | 
						|
    ,ptspan=span
 | 
						|
    ,ptstatus=status
 | 
						|
    ,ptcode=code
 | 
						|
    ,ptdescription=description
 | 
						|
    ,ptcomment=comment
 | 
						|
    ,pttags=tags
 | 
						|
    ,ptpostings=postings
 | 
						|
    }
 | 
						|
 | 
						|
-- | Parse a (possibly unbalanced) transaction.
 | 
						|
transactionp :: JournalParser m Transaction
 | 
						|
transactionp = do
 | 
						|
  -- dbgparse 0 "transactionp"
 | 
						|
  startpos <- getPosition
 | 
						|
  date <- datep <?> "transaction"
 | 
						|
  edate <- optional (lift $ secondarydatep date) <?> "secondary date"
 | 
						|
  lookAhead (lift spacenonewline <|> newline) <?> "whitespace or newline"
 | 
						|
  status <- lift statusp <?> "cleared status"
 | 
						|
  code <- lift codep <?> "transaction code"
 | 
						|
  description <- lift $ T.strip <$> descriptionp
 | 
						|
  (comment, tags) <- lift transactioncommentp
 | 
						|
  let year = first3 $ toGregorian date
 | 
						|
  postings <- postingsp (Just year)
 | 
						|
  endpos <- getPosition
 | 
						|
  let sourcepos = journalSourcePos startpos endpos
 | 
						|
  return $ txnTieKnot $ Transaction 0 sourcepos date edate status code description comment tags postings ""
 | 
						|
 | 
						|
test_transactionp = TestCase $ do
 | 
						|
    let s `gives` t = do
 | 
						|
                        let p = runIdentity $ parseWithState mempty transactionp s
 | 
						|
                        assertBool "Parse success" (isRight p)
 | 
						|
                        let Right t2 = p
 | 
						|
                            -- same f = assertEqual (f t) (f t2)
 | 
						|
                        assertEqual "Equal date" (tdate t) (tdate t2)
 | 
						|
                        assertEqual "Equal date2" (tdate2 t) (tdate2 t2)
 | 
						|
                        assertEqual "Equal status" (tstatus t) (tstatus t2)
 | 
						|
                        assertEqual "Equal code" (tcode t) (tcode t2)
 | 
						|
                        assertEqual "Equal description" (tdescription t) (tdescription t2)
 | 
						|
                        assertEqual "Equal comment" (tcomment t) (tcomment t2)
 | 
						|
                        assertEqual "Equal tags" (ttags t) (ttags t2)
 | 
						|
                        assertEqual "Equal preceding comments" (tpreceding_comment_lines t) (tpreceding_comment_lines t2)
 | 
						|
                        assertEqual "Equal postings" (show $ tpostings t) (show $ tpostings t2)
 | 
						|
    -- "0000/01/01\n\n" `gives` nulltransaction
 | 
						|
    T.unlines [
 | 
						|
      "2012/05/14=2012/05/15 (code) desc  ; tcomment1",
 | 
						|
      "    ; tcomment2",
 | 
						|
      "    ; ttag1: val1",
 | 
						|
      "    * a         $1.00  ; pcomment1",
 | 
						|
      "    ; pcomment2",
 | 
						|
      "    ; ptag1: val1",
 | 
						|
      "    ; ptag2: val2"
 | 
						|
      ]
 | 
						|
     `gives`
 | 
						|
     nulltransaction{
 | 
						|
      tdate=parsedate "2012/05/14",
 | 
						|
      tdate2=Just $ parsedate "2012/05/15",
 | 
						|
      tstatus=Unmarked,
 | 
						|
      tcode="code",
 | 
						|
      tdescription="desc",
 | 
						|
      tcomment="tcomment1\ntcomment2\nttag1: val1\n",
 | 
						|
      ttags=[("ttag1","val1")],
 | 
						|
      tpostings=[
 | 
						|
        nullposting{
 | 
						|
          pdate=Just $ parsedate "2012/05/14",
 | 
						|
          pstatus=Cleared,
 | 
						|
          paccount="a",
 | 
						|
          pamount=Mixed [usd 1],
 | 
						|
          pcomment="pcomment1\npcomment2\nptag1: val1\nptag2: val2\n",
 | 
						|
          ptype=RegularPosting,
 | 
						|
          ptags=[("ptag1","val1"),("ptag2","val2")],
 | 
						|
          ptransaction=Nothing
 | 
						|
          }
 | 
						|
        ],
 | 
						|
      tpreceding_comment_lines=""
 | 
						|
      }
 | 
						|
    T.unlines ["2015/1/1"]
 | 
						|
     `gives`
 | 
						|
     nulltransaction{ tdate=parsedate "2015/01/01" }
 | 
						|
 | 
						|
    assertBool "transactionp parses a well-formed transactionParse OK" $
 | 
						|
      isRight . runIdentity . parseWithState mempty transactionp $ T.unlines
 | 
						|
      ["2007/01/28 coopportunity"
 | 
						|
      ,"    expenses:food:groceries                   $47.18"
 | 
						|
      ,"    assets:checking                          $-47.18"
 | 
						|
      ,""
 | 
						|
      ]
 | 
						|
 | 
						|
    let p = runIdentity $ parseWithState mempty transactionp "2009/1/1 a ;comment\n b 1\n"
 | 
						|
    assertEqual "transactionp should not parse a following comment as part of the description"
 | 
						|
      (Right "a") (tdescription <$> p)
 | 
						|
 | 
						|
    assertBool "transactionp parses a following whitespace line" $
 | 
						|
      isRight . runIdentity . parseWithState mempty transactionp $ T.unlines
 | 
						|
        ["2012/1/1"
 | 
						|
        ,"  a  1"
 | 
						|
        ,"  b"
 | 
						|
        ," "
 | 
						|
        ]
 | 
						|
 | 
						|
    let p = runIdentity . parseWithState mempty transactionp $ T.unlines
 | 
						|
             ["2009/1/1 x  ; transaction comment"
 | 
						|
             ," a  1  ; posting 1 comment"
 | 
						|
             ," ; posting 1 comment 2"
 | 
						|
             ," b"
 | 
						|
             ," ; posting 2 comment"
 | 
						|
             ]
 | 
						|
    assertBool "transactionp parses parses comments anywhere" (isRight p)
 | 
						|
    assertEqual "Has 2 postings" 2 (let Right t = p in length $ tpostings t)
 | 
						|
 | 
						|
--- ** postings
 | 
						|
 | 
						|
-- Parse the following whitespace-beginning lines as postings, posting
 | 
						|
-- tags, and/or comments (inferring year, if needed, from the given date).
 | 
						|
postingsp :: Maybe Year -> JournalParser m [Posting]
 | 
						|
postingsp mTransactionYear = many (postingp mTransactionYear) <?> "postings"
 | 
						|
 | 
						|
-- linebeginningwithspaces :: JournalParser m String
 | 
						|
-- linebeginningwithspaces = do
 | 
						|
--   sp <- lift (skipSome spacenonewline)
 | 
						|
--   c <- nonspace
 | 
						|
--   cs <- lift restofline
 | 
						|
--   return $ sp ++ (c:cs) ++ "\n"
 | 
						|
 | 
						|
postingp :: Maybe Year -> JournalParser m Posting
 | 
						|
postingp mTransactionYear = do
 | 
						|
  -- lift $ dbgparse 0 "postingp"
 | 
						|
  (status, account) <- try $ do
 | 
						|
    lift (skipSome spacenonewline)
 | 
						|
    status <- lift statusp
 | 
						|
    lift (skipMany spacenonewline)
 | 
						|
    account <- modifiedaccountnamep
 | 
						|
    return (status, account)
 | 
						|
  let (ptype, account') = (accountNamePostingType account, textUnbracket account)
 | 
						|
  lift (skipMany spacenonewline)
 | 
						|
  amount <- option missingmixedamt $ Mixed . (:[]) <$> amountp
 | 
						|
  massertion <- partialbalanceassertionp
 | 
						|
  _ <- fixedlotpricep
 | 
						|
  lift (skipMany spacenonewline)
 | 
						|
  (comment,tags,mdate,mdate2) <- lift $ postingcommentp mTransactionYear
 | 
						|
  return posting
 | 
						|
   { pdate=mdate
 | 
						|
   , pdate2=mdate2
 | 
						|
   , pstatus=status
 | 
						|
   , paccount=account'
 | 
						|
   , pamount=amount
 | 
						|
   , pcomment=comment
 | 
						|
   , ptype=ptype
 | 
						|
   , ptags=tags
 | 
						|
   , pbalanceassertion=massertion
 | 
						|
   }
 | 
						|
 | 
						|
test_postingp = TestCase $ do
 | 
						|
    let s `gives` ep = do
 | 
						|
                         let parse = runIdentity $ parseWithState mempty (postingp Nothing) s
 | 
						|
                         assertBool "Example is parsed well" $ isRight parse
 | 
						|
                         let Right ap = parse
 | 
						|
                             same msg f = assertEqual ("Posting "++msg++" differs") (f ep) (f ap)
 | 
						|
                         same "date" pdate
 | 
						|
                         same "status" pstatus
 | 
						|
                         same "account" paccount
 | 
						|
                         -- same "amount" pamount
 | 
						|
                         -- more revealing:
 | 
						|
                         assertEqual "amount differs!" (showMixedAmountDebug $ pamount ep) (showMixedAmountDebug $ pamount ap)
 | 
						|
                         same "comment" pcomment
 | 
						|
                         same "type" ptype
 | 
						|
                         same "tags" ptags
 | 
						|
                         same "transaction" ptransaction
 | 
						|
    "  expenses:food:dining  $10.00   ; a: a a \n   ; b: b b \n" `gives`
 | 
						|
      posting{paccount="expenses:food:dining", pamount=Mixed [usd 10], pcomment="a: a a\nb: b b\n", ptags=[("a","a a"), ("b","b b")]}
 | 
						|
    
 | 
						|
    " a  1. ; [2012/11/28]\n" `gives`  -- trailing decimal point required to match num's asdecimalpoint
 | 
						|
      ("a" `post` num 1){pcomment="[2012/11/28]\n"
 | 
						|
                        ,pdate=parsedateM "2012/11/28"}
 | 
						|
 | 
						|
    " a  2. ; a:a, [=2012/11/28]\n" `gives`
 | 
						|
      ("a" `post` num 2){pcomment="a:a, [=2012/11/28]\n"
 | 
						|
                        ,ptags=[("a","a")]
 | 
						|
                        ,pdate=Nothing}
 | 
						|
 | 
						|
    " a  3. ; a:a\n  ; [2012/11/28=2012/11/29],b:b\n" `gives`
 | 
						|
      ("a" `post` num 3){pcomment="a:a\n[2012/11/28=2012/11/29],b:b\n"
 | 
						|
                        ,ptags=[("a","a"), ("[2012/11/28=2012/11/29],b","b")] -- XXX ugly tag name parsed
 | 
						|
                        ,pdate=parsedateM "2012/11/28"}
 | 
						|
 | 
						|
    assertBool "postingp parses a quoted commodity with numbers"
 | 
						|
      (isRight . runIdentity $ parseWithState mempty (postingp Nothing) "  a  1 \"DE123\"\n")
 | 
						|
 | 
						|
    assertBool "postingp parses balance assertions and fixed lot prices"
 | 
						|
      (isRight . runIdentity $ parseWithState mempty (postingp Nothing) "  a  1 \"DE123\" =$1 { =2.2 EUR} \n")
 | 
						|
 | 
						|
    -- let parse = parseWithState mempty postingp " a\n ;next-line comment\n"
 | 
						|
    -- assertRight parse
 | 
						|
    -- let Right p = parse
 | 
						|
    -- assertEqual "next-line comment\n" (pcomment p)
 | 
						|
    -- assertEqual (Just nullmixedamt) (pbalanceassertion p)
 | 
						|
 | 
						|
--- * more tests
 | 
						|
 | 
						|
tests_Hledger_Read_JournalReader = TestList [
 | 
						|
    test_transactionp,
 | 
						|
    test_postingp,
 | 
						|
    "showParsedMarketPrice" ~: do
 | 
						|
      let mp = parseWithState mempty marketpricedirectivep "P 2017/01/30 BTC $922.83\n"
 | 
						|
          mpString = (fmap . fmap) showMarketPrice mp
 | 
						|
      mpString `is` (Just (Right "P 2017/01/30 BTC $922.83"))
 | 
						|
    ]
 | 
						|
 | 
						|
{- old hunit tests
 | 
						|
 | 
						|
tests_Hledger_Read_JournalReader = TestList $ concat [
 | 
						|
    test_numberp,
 | 
						|
    test_amountp,
 | 
						|
    test_spaceandamountormissingp,
 | 
						|
    test_tagcomment,
 | 
						|
    test_inlinecomment,
 | 
						|
    test_comments,
 | 
						|
    test_ledgerDateSyntaxToTags,
 | 
						|
    test_postingp,
 | 
						|
    test_transactionp,
 | 
						|
    [
 | 
						|
   "transactionmodifierp" ~: do
 | 
						|
     assertParse (parseWithState mempty transactionmodifierp "= (some value expr)\n some:postings  1\n")
 | 
						|
 | 
						|
  ,"periodictransactionp" ~: do
 | 
						|
     assertParse (parseWithState mempty periodictransactionp "~ (some period expr)\n some:postings  1\n")
 | 
						|
 | 
						|
  ,"directivep" ~: do
 | 
						|
     assertParse (parseWithState mempty directivep "!include /some/file.x\n")
 | 
						|
     assertParse (parseWithState mempty directivep "account some:account\n")
 | 
						|
     assertParse (parseWithState mempty (directivep >> directivep) "!account a\nend\n")
 | 
						|
 | 
						|
  ,"comment" ~: do
 | 
						|
     assertParse (parseWithState mempty comment "; some comment \n")
 | 
						|
     assertParse (parseWithState mempty comment " \t; x\n")
 | 
						|
     assertParse (parseWithState mempty comment "#x")
 | 
						|
 | 
						|
  ,"datep" ~: do
 | 
						|
     assertParse (parseWithState mempty datep "2011/1/1")
 | 
						|
     assertParseFailure (parseWithState mempty datep "1/1")
 | 
						|
     assertParse (parseWithState mempty{jpsYear=Just 2011} datep "1/1")
 | 
						|
 | 
						|
  ,"datetimep" ~: do
 | 
						|
      let p = do {t <- datetimep; eof; return t}
 | 
						|
          bad = assertParseFailure . parseWithState mempty p
 | 
						|
          good = assertParse . parseWithState mempty p
 | 
						|
      bad "2011/1/1"
 | 
						|
      bad "2011/1/1 24:00:00"
 | 
						|
      bad "2011/1/1 00:60:00"
 | 
						|
      bad "2011/1/1 00:00:60"
 | 
						|
      good "2011/1/1 00:00"
 | 
						|
      good "2011/1/1 23:59:59"
 | 
						|
      good "2011/1/1 3:5:7"
 | 
						|
      -- timezone is parsed but ignored
 | 
						|
      let startofday = LocalTime (fromGregorian 2011 1 1) (TimeOfDay 0 0 (fromIntegral 0))
 | 
						|
      assertParseEqual (parseWithState mempty p "2011/1/1 00:00-0800") startofday
 | 
						|
      assertParseEqual (parseWithState mempty p "2011/1/1 00:00+1234") startofday
 | 
						|
 | 
						|
  ,"defaultyeardirectivep" ~: do
 | 
						|
     assertParse (parseWithState mempty defaultyeardirectivep "Y 2010\n")
 | 
						|
     assertParse (parseWithState mempty defaultyeardirectivep "Y 10001\n")
 | 
						|
 | 
						|
  ,"marketpricedirectivep" ~:
 | 
						|
    assertParseEqual (parseWithState mempty marketpricedirectivep "P 2004/05/01 XYZ $55.00\n") (MarketPrice (parsedate "2004/05/01") "XYZ" $ usd 55)
 | 
						|
 | 
						|
  ,"ignoredpricecommoditydirectivep" ~: do
 | 
						|
     assertParse (parseWithState mempty ignoredpricecommoditydirectivep "N $\n")
 | 
						|
 | 
						|
  ,"defaultcommoditydirectivep" ~: do
 | 
						|
     assertParse (parseWithState mempty defaultcommoditydirectivep "D $1,000.0\n")
 | 
						|
 | 
						|
  ,"commodityconversiondirectivep" ~: do
 | 
						|
     assertParse (parseWithState mempty commodityconversiondirectivep "C 1h = $50.00\n")
 | 
						|
 | 
						|
  ,"tagdirectivep" ~: do
 | 
						|
     assertParse (parseWithState mempty tagdirectivep "tag foo \n")
 | 
						|
 | 
						|
  ,"endtagdirectivep" ~: do
 | 
						|
     assertParse (parseWithState mempty endtagdirectivep "end tag \n")
 | 
						|
     assertParse (parseWithState mempty endtagdirectivep "pop \n")
 | 
						|
 | 
						|
  ,"accountnamep" ~: do
 | 
						|
    assertBool "accountnamep parses a normal account name" (isRight $ parsewith accountnamep "a:b:c")
 | 
						|
    assertBool "accountnamep rejects an empty inner component" (isLeft $ parsewith accountnamep "a::c")
 | 
						|
    assertBool "accountnamep rejects an empty leading component" (isLeft $ parsewith accountnamep ":b:c")
 | 
						|
    assertBool "accountnamep rejects an empty trailing component" (isLeft $ parsewith accountnamep "a:b:")
 | 
						|
 | 
						|
  ,"leftsymbolamountp" ~: do
 | 
						|
    assertParseEqual (parseWithState mempty leftsymbolamountp "$1")  (usd 1 `withPrecision` 0)
 | 
						|
    assertParseEqual (parseWithState mempty leftsymbolamountp "$-1") (usd (-1) `withPrecision` 0)
 | 
						|
    assertParseEqual (parseWithState mempty leftsymbolamountp "-$1") (usd (-1) `withPrecision` 0)
 | 
						|
 | 
						|
  ,"amount" ~: do
 | 
						|
     let -- | compare a parse result with an expected amount, showing the debug representation for clarity
 | 
						|
         assertAmountParse parseresult amount =
 | 
						|
             (either (const "parse error") showAmountDebug parseresult) ~?= (showAmountDebug amount)
 | 
						|
     assertAmountParse (parseWithState mempty amountp "1 @ $2")
 | 
						|
       (num 1 `withPrecision` 0 `at` (usd 2 `withPrecision` 0))
 | 
						|
 | 
						|
 ]]
 | 
						|
-}
 | 
						|
 | 
						|
easytests = tests "JournalReader" [
 | 
						|
  tests "periodictransactionp" [
 | 
						|
 | 
						|
    -- tests from #807
 | 
						|
    test "more-period-text-in-comment-after-one-space" $ expectParseEqIO periodictransactionp
 | 
						|
      "~ monthly from 2018/6 ;In 2019 we will change this\n" 
 | 
						|
      nullperiodictransaction {
 | 
						|
         ptperiodexpr  = "monthly from 2018/6"
 | 
						|
        ,ptinterval    = Months 1
 | 
						|
        ,ptspan        = DateSpan (Just $ parsedate "2018/06/01") Nothing
 | 
						|
        ,ptstatus      = Unmarked
 | 
						|
        ,ptcode        = ""
 | 
						|
        ,ptdescription = ""
 | 
						|
        ,ptcomment     = "In 2019 we will change this\n"
 | 
						|
        ,pttags        = []
 | 
						|
        ,ptpostings    = []
 | 
						|
        }
 | 
						|
 | 
						|
    ,_test "more-period-text-in-description-after-two-spaces" $ expectParseEqIO periodictransactionp -- TODO 
 | 
						|
      "~ monthly from 2018/6   In 2019 we will change this\n" 
 | 
						|
      nullperiodictransaction {
 | 
						|
         ptperiodexpr  = "monthly from 2018/6"
 | 
						|
        ,ptinterval    = Months 1
 | 
						|
        ,ptspan        = DateSpan (Just $ parsedate "2018/06/01") Nothing
 | 
						|
        ,ptdescription = "In 2019 we will change this\n"
 | 
						|
        }
 | 
						|
 | 
						|
    ,_test "more-period-text-in-description-after-one-space" $ expectParseEqIO periodictransactionp -- TODO
 | 
						|
      "~ monthly from 2018/6 In 2019 we will change this\n" 
 | 
						|
      nullperiodictransaction {
 | 
						|
         ptperiodexpr  = "monthly from 2018/6"
 | 
						|
        ,ptinterval    = Months 1
 | 
						|
        ,ptspan        = DateSpan (Just $ parsedate "2018/06/01") Nothing
 | 
						|
        ,ptdescription = "In 2019 we will change this\n"
 | 
						|
        }
 | 
						|
 | 
						|
    ,_test "Next-year-in-description" $ expectParseEqIO periodictransactionp -- TODO read error
 | 
						|
      "~ monthly  Next year blah blah\n"
 | 
						|
      nullperiodictransaction {
 | 
						|
         ptperiodexpr  = "monthly"
 | 
						|
        ,ptinterval    = Months 1
 | 
						|
        ,ptspan        = DateSpan Nothing Nothing
 | 
						|
        ,ptdescription = "Next year blah blah\n"
 | 
						|
        }
 | 
						|
 | 
						|
    ]
 | 
						|
  ]
 |