Compare commits
No commits in common. "ac86d1ee599fda157971c79a210fe4d9e3268a27" and "a134947df6af5b0729be20540addffdc91fd36c6" have entirely different histories.
ac86d1ee59
...
a134947df6
7 changed files with 93 additions and 418 deletions
|
@ -23,8 +23,7 @@ main = do
|
|||
putStrLn "Connected to MongoDB!"
|
||||
checkZcashPrices pipe (c_dbName loadedConfig)
|
||||
scanZcash' loadedConfig pipe
|
||||
{-scanPayments loadedConfig pipe-}
|
||||
scanTxNative loadedConfig pipe
|
||||
scanPayments loadedConfig pipe
|
||||
checkPayments pipe (c_dbName loadedConfig)
|
||||
expireOwners pipe (c_dbName loadedConfig)
|
||||
updateLogins pipe loadedConfig
|
||||
|
|
|
@ -420,7 +420,8 @@ findExpiringOwners now =
|
|||
|
||||
findWithKeys :: Action IO [Document]
|
||||
findWithKeys =
|
||||
rest =<< find (select ["paid" =: True, "payconf" =: True] "owners")
|
||||
rest =<<
|
||||
find (select ["paid" =: True, "invoices" =: True, "payconf" =: True] "owners")
|
||||
|
||||
removePro :: T.Text -> Action IO ()
|
||||
removePro o =
|
||||
|
|
|
@ -52,7 +52,6 @@ import Numeric
|
|||
import Order
|
||||
import Owner
|
||||
import Payment
|
||||
import System.IO
|
||||
import System.IO.Unsafe
|
||||
import System.Random
|
||||
import Test.QuickCheck
|
||||
|
@ -70,7 +69,6 @@ import ZcashHaskell.Orchard
|
|||
import ZcashHaskell.Sapling
|
||||
import ZcashHaskell.Types
|
||||
( BlockResponse(..)
|
||||
, DecodedNote(..)
|
||||
, RawData(..)
|
||||
, RawTxResponse(..)
|
||||
, RpcCall(..)
|
||||
|
@ -373,7 +371,12 @@ listCountries :: Action IO [Document]
|
|||
listCountries = rest =<< find (select [] "countries")
|
||||
|
||||
sendPin ::
|
||||
BS.ByteString -> BS.ByteString -> T.Text -> T.Text -> T.Text -> IO String
|
||||
BS.ByteString
|
||||
-> BS.ByteString
|
||||
-> T.Text
|
||||
-> T.Text
|
||||
-> T.Text
|
||||
-> Action IO String
|
||||
sendPin nodeUser nodePwd nodeAddress addr pin = do
|
||||
let pd =
|
||||
[ Data.Aeson.String nodeAddress
|
||||
|
@ -385,73 +388,17 @@ sendPin nodeUser nodePwd nodeAddress addr pin = do
|
|||
, "memo" .= encodeHexText ("ZGo PIN: " <> pin)
|
||||
]
|
||||
])
|
||||
, Data.Aeson.Number $ SC.scientific 1 1
|
||||
, Data.Aeson.Null
|
||||
, Data.Aeson.String "AllowRevealedAmounts"
|
||||
]
|
||||
r <- liftIO $ try $ makeZcashCall nodeUser nodePwd "z_sendmany" pd
|
||||
r <- liftIO $ try $ makeZcashCall nodeUser nodePwd "z_sendmany" pd -- IO (Either HttpException (Response Object))
|
||||
case r of
|
||||
Right res -> do
|
||||
let sCode = getResponseStatus (res :: Response (RpcResponse T.Text))
|
||||
let rBody = getResponseBody res
|
||||
let sCode = getResponseStatus (res :: Response Object)
|
||||
if sCode == ok200
|
||||
then do
|
||||
case result rBody of
|
||||
Nothing -> return "Couldn't parse node response"
|
||||
Just x -> do
|
||||
putStr " Sending."
|
||||
checkOpResult nodeUser nodePwd x
|
||||
return "Pin sent!"
|
||||
then return "Pin sent!"
|
||||
else return "Pin sending failed :("
|
||||
Left ex ->
|
||||
return $ "Failed to send tx to node :(" ++ show (ex :: HttpException)
|
||||
|
||||
-- | Type for Operation Result
|
||||
data OpResult = OpResult
|
||||
{ opsuccess :: T.Text
|
||||
, opmessage :: Maybe T.Text
|
||||
, optxid :: Maybe T.Text
|
||||
} deriving (Show, Eq)
|
||||
|
||||
instance FromJSON OpResult where
|
||||
parseJSON =
|
||||
withObject "OpResult" $ \obj -> do
|
||||
s <- obj .: "status"
|
||||
r <- obj .:? "result"
|
||||
e <- obj .:? "error"
|
||||
t <-
|
||||
case r of
|
||||
Nothing -> return Nothing
|
||||
Just r' -> r' .: "txid"
|
||||
m <-
|
||||
case e of
|
||||
Nothing -> return Nothing
|
||||
Just m' -> m' .: "message"
|
||||
pure $ OpResult s m t
|
||||
|
||||
checkOpResult :: BS.ByteString -> BS.ByteString -> T.Text -> IO ()
|
||||
checkOpResult user pwd opid = do
|
||||
response <-
|
||||
makeZcashCall
|
||||
user
|
||||
pwd
|
||||
"z_getoperationstatus"
|
||||
[Data.Aeson.Array (V.fromList [Data.Aeson.String opid])]
|
||||
let rpcResp = getResponseBody response :: (RpcResponse [OpResult])
|
||||
case result rpcResp of
|
||||
Nothing -> putStrLn "Couldn't read response from node"
|
||||
Just opCode -> mapM_ showResult opCode
|
||||
where
|
||||
showResult t =
|
||||
case opsuccess t of
|
||||
"success" ->
|
||||
putStrLn $ " Success! Tx ID: " ++ maybe "" T.unpack (optxid t)
|
||||
"executing" -> do
|
||||
putStr "."
|
||||
hFlush stdout
|
||||
threadDelay 1000000 >> checkOpResult user pwd opid
|
||||
_ -> putStrLn $ " Failed :( " ++ maybe "" T.unpack (opmessage t)
|
||||
|
||||
-- | Function to create user from ZGoTx
|
||||
addUser ::
|
||||
BS.ByteString
|
||||
|
@ -466,7 +413,7 @@ addUser nodeUser nodePwd p db node (Just tx) = do
|
|||
isNew <- liftIO $ isUserNew p db tx
|
||||
when isNew $ do
|
||||
newPin <- liftIO generatePin
|
||||
_ <- liftIO $ sendPin nodeUser nodePwd node (address tx) (T.pack newPin)
|
||||
_ <- sendPin nodeUser nodePwd node (address tx) (T.pack newPin)
|
||||
let pinHash =
|
||||
BLK.hash
|
||||
[ BA.pack . BS.unpack . C.pack . T.unpack $
|
||||
|
@ -1228,9 +1175,8 @@ routes pipe config = do
|
|||
case cast' . Doc =<< u of
|
||||
Nothing -> status unauthorized401
|
||||
Just u' -> do
|
||||
if isValidSaplingViewingKey $ C.pack q
|
||||
then do
|
||||
if matchSaplingAddress
|
||||
if isValidSaplingViewingKey qBytes
|
||||
then if matchSaplingAddress
|
||||
qBytes
|
||||
(bytes . decodeBech32 . C.pack . T.unpack $ uaddress u')
|
||||
then do
|
||||
|
@ -1239,45 +1185,27 @@ routes pipe config = do
|
|||
Nothing -> status badRequest400
|
||||
Just o' -> do
|
||||
unless (oviewkey o' /= "") $ do
|
||||
vkInfo <-
|
||||
liftAndCatchIO $
|
||||
makeZcashCall
|
||||
nodeUser
|
||||
nodePwd
|
||||
"z_importviewingkey"
|
||||
[ Data.Aeson.String (T.strip . T.pack $ q)
|
||||
, "no"
|
||||
] -- TODO: Remove this call to the node
|
||||
let content =
|
||||
getResponseBody vkInfo :: RpcResponse Object
|
||||
if isNothing (err content)
|
||||
then do
|
||||
_ <-
|
||||
liftAndCatchIO $ run (upsertViewingKey o' q)
|
||||
status created201
|
||||
else status forbidden403
|
||||
else case decodeUfvk (C.pack q) of
|
||||
Nothing -> status badRequest400
|
||||
Just fvk -> do
|
||||
if isValidUnifiedAddress $
|
||||
C.pack . T.unpack $ uaddress u'
|
||||
then do
|
||||
if matchOrchardAddress
|
||||
(C.pack q)
|
||||
(C.pack . T.unpack $ uaddress u')
|
||||
then do
|
||||
owner <-
|
||||
liftAndCatchIO $ run (findOwner $ uaddress u')
|
||||
case cast' . Doc =<< owner of
|
||||
Nothing -> status badRequest400
|
||||
Just o' -> do
|
||||
unless (oviewkey o' /= "") $ do
|
||||
liftAndCatchIO $
|
||||
run (upsertViewingKey o' q)
|
||||
status created201
|
||||
else status forbidden403
|
||||
else do
|
||||
if matchSaplingAddress
|
||||
(s_key fvk)
|
||||
(bytes . decodeBech32 . C.pack . T.unpack $
|
||||
uaddress u')
|
||||
then do
|
||||
owner <-
|
||||
liftAndCatchIO $ run (findOwner $ uaddress u')
|
||||
case cast' . Doc =<< owner of
|
||||
Nothing -> status badRequest400
|
||||
Just o' -> do
|
||||
unless (oviewkey o' /= "") $ do
|
||||
liftAndCatchIO $
|
||||
run (upsertViewingKey o' q)
|
||||
status created201
|
||||
text $ L.pack . show $ err content
|
||||
status badRequest400
|
||||
else status forbidden403
|
||||
else status badRequest400 -- TODO: add Unified VK support
|
||||
--Get items associated with the given address
|
||||
get "/api/items" $ do
|
||||
session <- param "session"
|
||||
|
@ -1875,14 +1803,9 @@ generateToken = do
|
|||
runCryptoRNGT rngState $ randomString 24 "abcdef0123456789"
|
||||
|
||||
getBlockInfo ::
|
||||
BS.ByteString -> BS.ByteString -> T.Text -> IO (Maybe BlockResponse)
|
||||
BS.ByteString -> BS.ByteString -> SC.Scientific -> IO (Maybe BlockResponse)
|
||||
getBlockInfo nodeUser nodePwd bh = do
|
||||
blockInfo <-
|
||||
makeZcashCall
|
||||
nodeUser
|
||||
nodePwd
|
||||
"getblock"
|
||||
[Data.Aeson.String bh, Number $ SC.scientific 1 0]
|
||||
blockInfo <- makeZcashCall nodeUser nodePwd "getblock" [Number bh]
|
||||
let content = getResponseBody blockInfo :: RpcResponse BlockResponse
|
||||
if isNothing (err content)
|
||||
then return $ result content
|
||||
|
@ -1890,61 +1813,38 @@ getBlockInfo nodeUser nodePwd bh = do
|
|||
print $ err content
|
||||
return Nothing
|
||||
|
||||
scanTxNative :: Config -> Pipe -> IO ()
|
||||
scanTxNative config pipe = do
|
||||
let db = c_dbName config
|
||||
scanTxNative :: Pipe -> T.Text -> BS.ByteString -> BS.ByteString -> IO ()
|
||||
scanTxNative pipe db nodeUser nodePwd = do
|
||||
keyOwnerList <- access pipe master db findWithKeys
|
||||
unless (null keyOwnerList) $ do
|
||||
let nodeUser = c_nodeUser config
|
||||
let nodePwd = c_nodePwd config
|
||||
let ownerList = mapMaybe (cast' . Doc) keyOwnerList
|
||||
let ownerList = cast' . Doc <$> keyOwnerList
|
||||
let keyList = map (maybe "" oviewkey) ownerList
|
||||
lastBlockData <- access pipe master db findBlock
|
||||
latestBlock <- getBlockInfo nodeUser nodePwd "-1"
|
||||
latestBlock <- getBlockInfo nodeUser nodePwd (SC.scientific (-1) 0)
|
||||
case latestBlock of
|
||||
Nothing -> fail "No block data from node"
|
||||
Just lB -> do
|
||||
case cast' . Doc =<< lastBlockData of
|
||||
Nothing -> do
|
||||
print "Getting blocks"
|
||||
blockList <-
|
||||
mapM
|
||||
(getBlockInfo nodeUser nodePwd . T.pack . show)
|
||||
[(bl_height lB - 50) .. (bl_height lB)]
|
||||
print "filtering blocks..."
|
||||
(getBlockInfo nodeUser nodePwd . fromInteger)
|
||||
[2220000 .. (bl_height lB)]
|
||||
let filteredBlockList = filter filterBlock blockList
|
||||
print "extracting txs from blocks..."
|
||||
let txIdList = concatMap extractTxs filteredBlockList
|
||||
print "getting tx data from node..."
|
||||
txList <- mapM (getTxData nodeUser nodePwd) txIdList
|
||||
print "filtering txs..."
|
||||
let filteredTxList = map fromJust $ filter filterTx txList
|
||||
print "checking txs against keys..."
|
||||
mapM_ (checkTx filteredTxList) ownerList
|
||||
access pipe master (c_dbName config) $
|
||||
upsertBlock (last $ catMaybes filteredBlockList)
|
||||
mapM_ (checkTx filteredTxList) keyList
|
||||
Just lastBlock -> do
|
||||
blockList' <-
|
||||
mapM
|
||||
(getBlockInfo nodeUser nodePwd . T.pack . show)
|
||||
[(bl_height lastBlock + 1) .. (bl_height lB)]
|
||||
print "filtering blocks..."
|
||||
let filteredBlockList = filter filterBlock blockList'
|
||||
print "extracting txs from blocks..."
|
||||
let txIdList = concatMap extractTxs filteredBlockList
|
||||
print "getting tx data from node..."
|
||||
txList <- mapM (getTxData nodeUser nodePwd) txIdList
|
||||
print "filtering txs..."
|
||||
let filteredTxList = map fromJust $ filter filterTx txList
|
||||
print "checking txs against keys..."
|
||||
mapM_ (checkTx filteredTxList) ownerList
|
||||
access pipe master (c_dbName config) $
|
||||
upsertBlock (last $ catMaybes filteredBlockList)
|
||||
let blockList' = [(bl_height lastBlock + 1) .. (bl_height lB)]
|
||||
print blockList'
|
||||
print keyList
|
||||
where
|
||||
filterBlock :: Maybe BlockResponse -> Bool
|
||||
filterBlock b = maybe 0 bl_confirmations b >= 5
|
||||
filterTx :: Maybe RawTxResponse -> Bool
|
||||
filterTx t =
|
||||
not (null (maybe [] rt_shieldedOutputs t)) ||
|
||||
not (null (maybe [] rt_shieldedOutputs t)) &&
|
||||
not (null (maybe [] rt_orchardActions t))
|
||||
extractTxs :: Maybe BlockResponse -> [T.Text]
|
||||
extractTxs = maybe [] bl_txs
|
||||
|
@ -1956,145 +1856,39 @@ scanTxNative config pipe = do
|
|||
nodeUser
|
||||
nodePwd
|
||||
"getrawtransaction"
|
||||
[Data.Aeson.String txid, Number $ SC.scientific 1 0]
|
||||
[Data.Aeson.String txid]
|
||||
let content = getResponseBody txInfo :: RpcResponse RawTxResponse
|
||||
if isNothing (err content)
|
||||
then return $ result content
|
||||
else do
|
||||
print $ err content
|
||||
return Nothing
|
||||
checkTx :: [RawTxResponse] -> Owner -> IO ()
|
||||
checkTx txList' k = do
|
||||
let sOutList = concatMap rt_shieldedOutputs txList'
|
||||
if isValidSaplingViewingKey (E.encodeUtf8 $ oviewkey k)
|
||||
checkTx :: [RawTxResponse] -> T.Text -> IO ()
|
||||
checkTx txList k = do
|
||||
if isValidSaplingViewingKey (E.encodeUtf8 k)
|
||||
then do
|
||||
print "decoding Sapling tx"
|
||||
let decodedSapList' = concatMap (decodeSaplingTx $ oviewkey k) txList'
|
||||
let zList = catMaybes decodedSapList'
|
||||
mapM_ (recordPayment pipe (c_dbName config) (oaddress k)) zList
|
||||
let decodedTxList =
|
||||
map
|
||||
(decodeSaplingOutput (E.encodeUtf8 k))
|
||||
(concatMap
|
||||
rt_shieldedOutputs
|
||||
(filter (\x -> rt_shieldedOutputs x /= []) txList))
|
||||
print decodedTxList
|
||||
else do
|
||||
let vk = decodeUfvk $ E.encodeUtf8 $ oviewkey k
|
||||
let vk = decodeUfvk $ E.encodeUtf8 k
|
||||
case vk of
|
||||
Nothing -> print "Not a valid key"
|
||||
Just v -> do
|
||||
let decodedSapList =
|
||||
concatMap (decodeUnifiedSaplingTx (s_key v)) txList'
|
||||
let zList' = catMaybes decodedSapList
|
||||
mapM_ (recordPayment pipe (c_dbName config) (oaddress k)) zList'
|
||||
let decodedOrchList = concatMap (decodeUnifiedOrchardTx v) txList'
|
||||
let oList = catMaybes decodedOrchList
|
||||
mapM_ (recordPayment pipe (c_dbName config) (oaddress k)) oList
|
||||
decodeSaplingTx :: T.Text -> RawTxResponse -> [Maybe ZcashTx]
|
||||
decodeSaplingTx k t =
|
||||
map
|
||||
(buildZcashTx t .
|
||||
decodeSaplingOutput (bytes (decodeBech32 $ E.encodeUtf8 k)))
|
||||
(rt_shieldedOutputs t)
|
||||
decodeUnifiedSaplingTx :: BS.ByteString -> RawTxResponse -> [Maybe ZcashTx]
|
||||
decodeUnifiedSaplingTx k t =
|
||||
map (buildZcashTx t . decodeSaplingOutput k) (rt_shieldedOutputs t)
|
||||
decodeUnifiedOrchardTx ::
|
||||
UnifiedFullViewingKey -> RawTxResponse -> [Maybe ZcashTx]
|
||||
decodeUnifiedOrchardTx k t =
|
||||
map (buildZcashTx t . decryptOrchardAction k) (rt_orchardActions t)
|
||||
buildZcashTx :: RawTxResponse -> Maybe DecodedNote -> Maybe ZcashTx
|
||||
buildZcashTx t n =
|
||||
case n of
|
||||
Nothing -> Nothing
|
||||
Just n ->
|
||||
Just $
|
||||
ZcashTx
|
||||
(rt_id t)
|
||||
(fromIntegral (a_value n) / 100000000)
|
||||
(toInteger $ a_value n)
|
||||
(rt_blockheight t)
|
||||
(rt_blocktime t)
|
||||
False
|
||||
(rt_confirmations t)
|
||||
(E.decodeUtf8Lenient $ a_memo n)
|
||||
recordPayment :: Pipe -> T.Text -> T.Text -> ZcashTx -> IO ()
|
||||
recordPayment p dbName z x = do
|
||||
let zM = runParser pZGoMemo (T.unpack . ztxid $ x) (zmemo x)
|
||||
case zM of
|
||||
Right m -> do
|
||||
case m_orderId m of
|
||||
Nothing -> print "Not an order Tx"
|
||||
Just orderId -> do
|
||||
print orderId
|
||||
o <- access p master dbName $ findOrderById (T.unpack orderId)
|
||||
let xOrder = o >>= (cast' . Doc)
|
||||
case xOrder of
|
||||
Nothing -> error "Failed to retrieve order from database"
|
||||
Just xO -> do
|
||||
when
|
||||
(not (qpaid xO) &&
|
||||
qtotalZec xO == zamount x && z == qaddress xO) $ do
|
||||
let sReg = mkRegex "(.*)-([a-fA-f0-9]{24})"
|
||||
let sResult = matchAllText sReg (T.unpack $ qsession xO)
|
||||
if not (null sResult)
|
||||
then case fst $ head sResult ! 1 of
|
||||
"Xero" -> do
|
||||
xeroConfig <- access p master dbName findXero
|
||||
let xC = xeroConfig >>= (cast' . Doc)
|
||||
case xC of
|
||||
Nothing -> error "Failed to read Xero config"
|
||||
Just xConf -> do
|
||||
requestXeroToken
|
||||
p
|
||||
dbName
|
||||
xConf
|
||||
""
|
||||
(qaddress xO)
|
||||
payXeroInvoice
|
||||
p
|
||||
dbName
|
||||
(qexternalInvoice xO)
|
||||
(qaddress xO)
|
||||
(qtotal xO)
|
||||
(qtotalZec xO)
|
||||
liftIO $
|
||||
access p master dbName $
|
||||
markOrderPaid (T.unpack orderId, zamount x)
|
||||
"WC" -> do
|
||||
let wOwner = fst $ head sResult ! 2
|
||||
wooT <-
|
||||
access p master dbName $
|
||||
findWooToken $ Just (read wOwner)
|
||||
let wT = wooT >>= (cast' . Doc)
|
||||
case wT of
|
||||
Nothing ->
|
||||
error "Failed to read WooCommerce token"
|
||||
Just wt -> do
|
||||
let iReg = mkRegex "(.*)-(.*)-.*"
|
||||
let iResult =
|
||||
matchAllText
|
||||
iReg
|
||||
(T.unpack $ qexternalInvoice xO)
|
||||
if not (null iResult)
|
||||
then do
|
||||
let wUrl =
|
||||
E.decodeUtf8With lenientDecode .
|
||||
B64.decodeLenient . C.pack $
|
||||
fst $ head iResult ! 1
|
||||
let iNum = fst $ head iResult ! 2
|
||||
payWooOrder
|
||||
(T.unpack wUrl)
|
||||
(C.pack iNum)
|
||||
(C.pack $ maybe "" show (q_id xO))
|
||||
(C.pack . T.unpack $ w_token wt)
|
||||
(C.pack . show $ qprice xO)
|
||||
(C.pack . show $ qtotalZec xO)
|
||||
liftIO $
|
||||
access p master dbName $
|
||||
markOrderPaid
|
||||
(T.unpack orderId, zamount x)
|
||||
else error
|
||||
"Couldn't parse externalInvoice for WooCommerce"
|
||||
_ -> putStrLn "Not an integration order"
|
||||
else liftIO $
|
||||
access p master dbName $
|
||||
markOrderPaid (T.unpack orderId, zamount x)
|
||||
Left e -> print "Unable to parse order memo"
|
||||
(decodeSaplingOutput (s_key v))
|
||||
(concatMap rt_shieldedOutputs txList)
|
||||
print decodedSapList
|
||||
let decodedOrchList =
|
||||
map
|
||||
(decryptOrchardAction v)
|
||||
(concatMap rt_orchardActions txList)
|
||||
print decodedOrchList
|
||||
|
||||
debug = flip trace
|
||||
|
||||
|
|
19
src/ZGoTx.hs
19
src/ZGoTx.hs
|
@ -105,7 +105,6 @@ data ZGoMemo = ZGoMemo
|
|||
{ m_session :: Maybe U.UUID
|
||||
, m_address :: Maybe T.Text
|
||||
, m_payment :: Bool
|
||||
, m_orderId :: Maybe T.Text
|
||||
} deriving (Eq, Show)
|
||||
|
||||
data MemoToken
|
||||
|
@ -113,7 +112,6 @@ data MemoToken
|
|||
| PayMsg !U.UUID
|
||||
| Address !T.Text
|
||||
| Msg !T.Text
|
||||
| OrderId !T.Text
|
||||
deriving (Show, Eq)
|
||||
|
||||
type Parser = Parsec Void T.Text
|
||||
|
@ -148,12 +146,6 @@ pUnifiedAddress = do
|
|||
then pure $ Address $ T.pack ("u1" <> a)
|
||||
else fail "Failed to parse Unified Address"
|
||||
|
||||
pOrderId :: Parser MemoToken
|
||||
pOrderId = do
|
||||
string "ZGo Order::"
|
||||
a <- some hexDigitChar
|
||||
pure $ OrderId . T.pack $ a
|
||||
|
||||
pMsg :: Parser MemoToken
|
||||
pMsg = do
|
||||
msg <-
|
||||
|
@ -165,7 +157,7 @@ pMsg = do
|
|||
pMemo :: Parser MemoToken
|
||||
pMemo = do
|
||||
optional $ some spaceChar
|
||||
t <- pSession <|> pSaplingAddress <|> pUnifiedAddress <|> pOrderId <|> pMsg
|
||||
t <- pSession <|> pSaplingAddress <|> pMsg
|
||||
optional $ some spaceChar
|
||||
return t
|
||||
|
||||
|
@ -190,15 +182,8 @@ isMemoToken kind t =
|
|||
pZGoMemo :: Parser ZGoMemo
|
||||
pZGoMemo = do
|
||||
tks <- some pMemo
|
||||
pure $ ZGoMemo (isSession tks) (isAddress tks) (isPayment tks) (isOrder tks)
|
||||
pure $ ZGoMemo (isSession tks) (isAddress tks) (isPayment tks)
|
||||
where
|
||||
isOrder [] = Nothing
|
||||
isOrder tks =
|
||||
if not (null tks)
|
||||
then case head tks of
|
||||
OrderId x -> Just x
|
||||
_ -> isOrder $ tail tks
|
||||
else Nothing
|
||||
isPayment [] = False
|
||||
isPayment tks =
|
||||
not (null tks) &&
|
||||
|
|
|
@ -45,7 +45,7 @@ extra-deps:
|
|||
- git: https://github.com/reach-sh/haskell-hexstring.git
|
||||
commit: 085c16fb21b9f856a435a3faab980e7e0b319341
|
||||
- git: https://git.vergara.tech/Vergara_Tech/zcash-haskell.git
|
||||
commit: 1d558fc646a7758d60a721124812070de222c2e1
|
||||
commit: d78c269d96fe7d8a626cf701b8051c40f251e232
|
||||
- git: https://git.vergara.tech/Vergara_Tech/haskell-foreign-rust.git
|
||||
commit: 787c2e813eb3a5d16c375d4b37dfefbd2adcdf05
|
||||
- git: https://github.com/well-typed/borsh.git
|
||||
|
|
|
@ -16,15 +16,15 @@ packages:
|
|||
commit: 085c16fb21b9f856a435a3faab980e7e0b319341
|
||||
git: https://github.com/reach-sh/haskell-hexstring.git
|
||||
- completed:
|
||||
commit: 1d558fc646a7758d60a721124812070de222c2e1
|
||||
commit: d78c269d96fe7d8a626cf701b8051c40f251e232
|
||||
git: https://git.vergara.tech/Vergara_Tech/zcash-haskell.git
|
||||
name: zcash-haskell
|
||||
pantry-tree:
|
||||
sha256: eab3c6817bb3cb5738725824d16eb023cb2967ef3bbaa8f8252524602f606dbb
|
||||
sha256: 69201a27ac966be478ef0b8e3fa8e8bf5cbcc67a58cd254326545eb4f3e93569
|
||||
size: 1229
|
||||
version: 0.2.0
|
||||
original:
|
||||
commit: 1d558fc646a7758d60a721124812070de222c2e1
|
||||
commit: d78c269d96fe7d8a626cf701b8051c40f251e232
|
||||
git: https://git.vergara.tech/Vergara_Tech/zcash-haskell.git
|
||||
- completed:
|
||||
commit: 787c2e813eb3a5d16c375d4b37dfefbd2adcdf05
|
||||
|
|
120
test/Spec.hs
120
test/Spec.hs
|
@ -101,9 +101,8 @@ main = do
|
|||
case m of
|
||||
Left e -> putStrLn $ errorBundlePretty e
|
||||
Right m' ->
|
||||
m_address m' `shouldBe`
|
||||
Just
|
||||
"u17n7hpwaujyq7ux8f9jpyymtnk5urw7pyrf60smp5mawy7jgz325hfvz3jn3zsfya8yxryf9q7ldk8nu8df0emra5wne28zq9d9nm2pu4x6qwjha565av9aze0xgujgslz74ufkj0c0cylqwjyrh9msjfh7jzal6d3qzrnhkkqy3pqm8j63y07jxj7txqeac982778rmt64f32aum94x"
|
||||
m_session m' `shouldBe`
|
||||
U.fromString "5d3d4494-51c0-432d-8495-050419957aea"
|
||||
it "parse YWallet memo - Orchard" $ do
|
||||
let m =
|
||||
runParser
|
||||
|
@ -113,9 +112,8 @@ main = do
|
|||
case m of
|
||||
Left e -> putStrLn $ errorBundlePretty e
|
||||
Right m' ->
|
||||
m_address m' `shouldBe`
|
||||
Just
|
||||
"u17n7hpwaujyq7ux8f9jpyymtnk5urw7pyrf60smp5mawy7jgz325hfvz3jn3zsfya8yxryf9q7ldk8nu8df0emra5wne28zq9d9nm2pu4x6qwjha565av9aze0xgujgslz74ufkj0c0cylqwjyrh9msjfh7jzal6d3qzrnhkkqy3pqm8j63y07jxj7txqeac982778rmt64f32aum94x"
|
||||
m_session m' `shouldBe`
|
||||
U.fromString "ad8477d3-4fdd-4c97-90b2-76630b5f77e1"
|
||||
it "parse Zingo memo - Orchard" $ do
|
||||
let m =
|
||||
runParser
|
||||
|
@ -125,9 +123,8 @@ main = do
|
|||
case m of
|
||||
Left e -> putStrLn $ errorBundlePretty e
|
||||
Right m' ->
|
||||
m_address m' `shouldBe`
|
||||
Just
|
||||
"u17n7hpwaujyq7ux8f9jpyymtnk5urw7pyrf60smp5mawy7jgz325hfvz3jn3zsfya8yxryf9q7ldk8nu8df0emra5wne28zq9d9nm2pu4x6qwjha565av9aze0xgujgslz74ufkj0c0cylqwjyrh9msjfh7jzal6d3qzrnhkkqy3pqm8j63y07jxj7txqeac982778rmt64f32aum94x"
|
||||
m_session m' `shouldBe`
|
||||
U.fromString "5d3d4494-51c0-432d-8495-050419957aea"
|
||||
describe "PIN generator" $ do
|
||||
it "should give a 7 digit" $ do
|
||||
pin <- generatePin
|
||||
|
@ -691,8 +688,6 @@ main = do
|
|||
"zxviews1qdjagrrpqqqqpq8es75mlu6rref0qyrstchf8dxzeygtsejwfqu8ckhwl2qj5m8am7lmupxk3vkvdjm8pawjpmesjfapvsqw96pa46c2z0kk7letrxf7mkltwz54fwpxc7kc79mm5kce3rwn5ssl009zwsra2spppwgrx25s9k5hq65f69l4jz2tjmqgy0pl49qmtaj3nudk6wglwe2hpa327hydlchtyq9av6wjd6hu68e04ahwk9a9n2kt0kj3nj99nue65awtu5cwwcpjs"
|
||||
let vk2 =
|
||||
"zxviews1qdjagrrpqqqqpq8es75mlufakef0qyrstchf8dxzeygtsejwfqu8ckhwl2qj5m8am7lmupxk3vkvdjm8pawjpmesjfapvsqw96pa46c2z0kk7letrxf7mkltwz54fwpxc7kc79mm5kce3rwn5ssl009zwsra2spppwgrx25s9k5hq65f69l4jz2tjmqgy0pl49qmtaj3nudk6wglwe2hpa327hydlchtyq9av6wjd6hu68e04ahwk9a9n2kt0kj3nj99nue65awtu5cwwcpjs"
|
||||
let vk3 =
|
||||
"uview1u833rp8yykd7h4druwht6xp6k8krle45fx8hqsw6vzw63n24atxpcatws82z092kryazuu6d7rayyut8m36wm4wpjy2z8r9hj48fx5pf49gw4sjrq8503qpz3vqj5hg0vg9vsqeasg5qjuyh94uyfm7v76udqcm2m0wfc25hcyqswcn56xxduq3xkgxkr0l73cjy88fdvf90eq5fda9g6x7yv7d0uckpevxg6540wc76xrc4axxvlt03ptaa2a0rektglmdy68656f3uzcdgqqyu0t7wk5cvwghyyvgqc0rp3vgu5ye4nd236ml57rjh083a2755qemf6dk6pw0qrnfm7246s8eg2hhzkzpf9h73chhng7xhmyem2sjh8rs2m9nhfcslsgenm"
|
||||
it "returns 401 with bad session" $ do
|
||||
req <-
|
||||
testPostJson "/api/ownervk" $
|
||||
|
@ -733,7 +728,7 @@ main = do
|
|||
[("session", Just "35bfb9c2-9ad2-4fe5-adda-99d63b8dcdcd")]
|
||||
req
|
||||
getResponseStatus res `shouldBe` badRequest400
|
||||
it "succeeds with correct Sapling key" $ do
|
||||
it "succeeds with correct key" $ do
|
||||
req <-
|
||||
testPostJson "/api/ownervk" $
|
||||
A.object ["payload" A..= (vk1 :: String)]
|
||||
|
@ -743,26 +738,6 @@ main = do
|
|||
[("session", Just "35bfb9c2-9ad2-4fe5-adda-99d63b8dcdcd")]
|
||||
req
|
||||
getResponseStatus res `shouldBe` created201
|
||||
it "succeeds with correct Unified key and UA" $ do
|
||||
req <-
|
||||
testPostJson "/api/ownervk" $
|
||||
A.object ["payload" A..= (vk3 :: String)]
|
||||
res <-
|
||||
httpLBS $
|
||||
setRequestQueryString
|
||||
[("session", Just "35bfb9c2-9ad2-4fe5-daad-99d63b8dcdaa")]
|
||||
req
|
||||
getResponseStatus res `shouldBe` created201
|
||||
xit "succeeds with correct Unified key and Sapling address" $ do
|
||||
req <-
|
||||
testPostJson "/api/ownervk" $
|
||||
A.object ["payload" A..= (vk3 :: String)]
|
||||
res <-
|
||||
httpLBS $
|
||||
setRequestQueryString
|
||||
[("session", Just "35bfb9c2-a92d-4fe5-daad-99d63b8dcdaa")]
|
||||
req
|
||||
getResponseStatus res `shouldBe` created201
|
||||
around handleDb $
|
||||
describe "Database actions" $ do
|
||||
describe "authentication" $ do
|
||||
|
@ -1201,25 +1176,8 @@ startAPI config = do
|
|||
1613487
|
||||
"8ea140fbb30615d6cae383c4f62f3ad9afb10b804f63138d5b53990bd56e0162"
|
||||
True
|
||||
let myUser3 =
|
||||
User
|
||||
(Just (read "6272a90f2b05a74cf1500003" :: ObjectId))
|
||||
"u15hjz9v46azzmdept050heh8795qxzwy2pykg097lg69jpk4qzah90cj2q4amq0c07gta60x8qgw00qewcy3hg9kv9h6zjkh3jc66vr40u6uu2dxmqkqhypud95vm0gq7y5ga7c8psdqgthsrwvgd676a2pavpcd4euwwapgackxa3qhvga0wnl0k6vncskxlq94vqwjd7zepy3qd5jh"
|
||||
"35bfb9c2-9ad2-4fe5-daad-99d63b8dcdaa"
|
||||
1613487
|
||||
"8ea140fbb30615d6cae383c4f62f3ad9afb10b804f63138d5b53990bd56e0162"
|
||||
True
|
||||
let myUser4 =
|
||||
User
|
||||
(Just (read "6272a90f2b05a74cf7500003" :: ObjectId))
|
||||
"zs1fau9x305eztcdm5f08q9uc4hmvvjpjrgjcwcj0mjwhd83pdj0j92rxwqp6zkjmz3e49ej4xrcc8"
|
||||
"35bfb9c2-a92d-4fe5-daad-99d63b8dcdaa"
|
||||
1613487
|
||||
"8ea140fbb30615d6cae383c4f62f3ad9afb10b804f63138d5b53990bd56e0162"
|
||||
True
|
||||
let userList =
|
||||
map unwrapDoc $
|
||||
filter filterDocs $ val <$> [myUser, myUser1, myUser2, myUser3, myUser4]
|
||||
map unwrapDoc $ filter filterDocs $ val <$> [myUser, myUser1, myUser2]
|
||||
_ <- access pipe master "test" (insertAll_ "users" userList)
|
||||
let myOwner =
|
||||
Owner
|
||||
|
@ -1275,60 +1233,6 @@ startAPI config = do
|
|||
False
|
||||
""
|
||||
""
|
||||
let myOwner2 =
|
||||
Owner
|
||||
(Just (read "627ad3492b05a76be3700008"))
|
||||
"u15hjz9v46azzmdept050heh8795qxzwy2pykg097lg69jpk4qzah90cj2q4amq0c07gta60x8qgw00qewcy3hg9kv9h6zjkh3jc66vr40u6uu2dxmqkqhypud95vm0gq7y5ga7c8psdqgthsrwvgd676a2pavpcd4euwwapgackxa3qhvga0wnl0k6vncskxlq94vqwjd7zepy3qd5jh"
|
||||
"Test shop 3"
|
||||
"usd"
|
||||
False
|
||||
0
|
||||
False
|
||||
0
|
||||
"Roxy"
|
||||
"Foo"
|
||||
"roxy@zgo.cash"
|
||||
"1 Main St"
|
||||
"Mpls"
|
||||
"Minnesota"
|
||||
"55401"
|
||||
""
|
||||
"missyfoo.io"
|
||||
"United States"
|
||||
True
|
||||
False
|
||||
False
|
||||
(UTCTime (fromGregorian 2024 8 6) (secondsToDiffTime 0))
|
||||
False
|
||||
""
|
||||
""
|
||||
let myOwner3 =
|
||||
Owner
|
||||
(Just (read "627ad3492b05a76be3750008"))
|
||||
"zs1fau9x305eztcdm5f08q9uc4hmvvjpjrgjcwcj0mjwhd83pdj0j92rxwqp6zkjmz3e49ej4xrcc8"
|
||||
"Test shop 4"
|
||||
"usd"
|
||||
False
|
||||
0
|
||||
False
|
||||
0
|
||||
"Roxy"
|
||||
"Foo"
|
||||
"roxy@zgo.cash"
|
||||
"1 Main St"
|
||||
"Mpls"
|
||||
"Minnesota"
|
||||
"55401"
|
||||
""
|
||||
"missyfoo.io"
|
||||
"United States"
|
||||
True
|
||||
False
|
||||
False
|
||||
(UTCTime (fromGregorian 2024 8 6) (secondsToDiffTime 0))
|
||||
False
|
||||
""
|
||||
""
|
||||
_ <- access pipe master "test" (Database.MongoDB.delete (select [] "owners"))
|
||||
let o = val myOwner
|
||||
case o of
|
||||
|
@ -1338,14 +1242,6 @@ startAPI config = do
|
|||
case o1 of
|
||||
Doc d1 -> access pipe master "test" (insert_ "owners" d1)
|
||||
_ -> fail "Couldn't save Owner1 in DB"
|
||||
let o2 = val myOwner2
|
||||
case o2 of
|
||||
Doc d2 -> access pipe master "test" (insert_ "owners" d2)
|
||||
_ -> fail "Couldn't save Owner2 in DB"
|
||||
let o3 = val myOwner3
|
||||
case o3 of
|
||||
Doc d3 -> access pipe master "test" (insert_ "owners" d3)
|
||||
_ -> fail "Couldn't save Owner2 in DB"
|
||||
_ <- access pipe master "test" (Database.MongoDB.delete (select [] "orders"))
|
||||
myTs <- liftIO getCurrentTime
|
||||
let myOrder =
|
||||
|
|
Loading…
Reference in a new issue