wip: prepared stubs for next functions to be implemented

Signed-off-by: Nick Waywood <nwaywood@au1.ibm.com>

Author: Nick Waywood

src/Interfaces.hs

@@ -124,7 +124,8 @@ class ChaincodeStubInterface ccs where
     -- Call Close() on the returned StateQueryIteratorInterface object when done.
     -- The query is re-executed during validation phase to ensure result set
     -- has not changed since transaction endorsement (phantom reads detected).
-    -- getStateByPartialCompositeKey :: ccs -> String -> [String] -> Either Error StateQueryIterator
+    getStateByPartialCompositeKey :: ccs -> Text -> [Text] -> ExceptT Error IO StateQueryIterator
+
     -- GetStateByPartialCompositeKeyWithPagination queries the state in the ledger based on
     -- a given partial composite key. This function returns an iterator
     -- which can be used to iterate over the composite keys whose
@@ -143,18 +144,22 @@ class ChaincodeStubInterface ccs where
     -- code point). See related functions SplitCompositeKey and CreateCompositeKey.
     -- Call Close() on the returned StateQueryIteratorInterface object when done.
     -- This call is only supported in a read only transaction.
-    -- getStateByPartialCompositeKeyWithPagination :: ccs -> String -> [String] -> Int32 -> String -> Either Error (StateQueryIterator, Pb.QueryResponseMetadata)
+    getStateByPartialCompositeKeyWithPagination
+        :: ccs -> Text -> [Text] -> Int -> Text -> ExceptT Error IO (StateQueryIterator, Pb.QueryResponseMetadata)
+
     -- CreateCompositeKey combines the given `attributes` to form a composite
     -- key. The objectType and attributes are expected to have only valid utf8
     -- strings and should not contain U+0000 (nil byte) and U+10FFFF
     -- (biggest and unallocated code point).
     -- The resulting composite key can be used as the key in PutState().
-    -- createCompositeKey :: ccs -> String -> [String] -> Either Error String
+    createCompositeKey :: ccs -> Text -> [Text] -> Either Error Text
+
     -- SplitCompositeKey splits the specified key into attributes on which the
     -- composite key was formed. Composite keys found during range queries
     -- or partial composite key queries can therefore be split into their
     -- composite parts.
-    -- splitCompositeKey :: ccs -> String -> Either Error (String, [String])
+    splitCompositeKey :: ccs -> Text -> Either Error (Text, [Text])
+
     -- GetQueryResult performs a "rich" query against a state database. It is
     -- only supported for state databases that support rich query,
     -- e.g.CouchDB. The query string is in the native syntax
@@ -170,7 +175,8 @@ class ChaincodeStubInterface ccs where
     -- be detected at validation/commit time.  Applications susceptible to this
     -- should therefore not use GetQueryResult as part of transactions that update
     -- ledger, and should limit use to read-only chaincode operations.
-    -- getQueryResult :: ccs -> String -> Either Error StateQueryIterator
+    getQueryResult :: ccs -> Text -> ExceptT Error IO StateQueryIterator
+
     -- GetQueryResultWithPagination performs a "rich" query against a state database.
     -- It is only supported for state databases that support rich query,
     -- e.g., CouchDB. The query string is in the native syntax
@@ -184,7 +190,9 @@ class ChaincodeStubInterface ccs where
     -- can be used as a value to the bookmark argument. Otherwise, an empty string
     -- must be passed as bookmark.
     -- This call is only supported in a read only transaction.
-    -- getQueryResultWithPagination :: ccs -> String -> Int32 -> String -> Either Error (StateQueryIterator, Pb.QueryResponseMetadata)
+    getQueryResultWithPagination
+        :: ccs -> Text -> Int -> Text -> ExceptT Error IO (StateQueryIterator, Pb.QueryResponseMetadata)
+
     -- GetHistoryForKey returns a history of key values across time.
     -- For each historic key update, the historic value and associated
     -- transaction id and timestamp are returned. The timestamp is the
@@ -197,7 +205,9 @@ class ChaincodeStubInterface ccs where
     -- detected at validation/commit time. Applications susceptible to this
     -- should therefore not use GetHistoryForKey as part of transactions that
     -- update ledger, and should limit use to read-only chaincode operations.
-    -- getHistoryForKey :: ccs -> Either Error HistoryQueryIterator
+    -- TODO: value should be HistoryQueryIterator
+    getHistoryForKey :: ccs -> Text -> ExceptT Error IO StateQueryIterator
+
     -- GetPrivateData returns the value of the specified `key` from the specified
     -- `collection`. Note that GetPrivateData doesn't read data from the
     -- private writeset, which has not been committed to the `collection`. In

src/Stub.hs

@@ -6,7 +6,7 @@ module Stub where
 
 import qualified Common.Common                    as Pb
 
-import           Control.Monad.Except             ( ExceptT(..), runExceptT )
+import           Control.Monad.Except             ( ExceptT(..), runExceptT, throwError )
 
 -- import           Data.Int                      (fromIntegral)
 import           Data.Bifunctor
@@ -137,13 +137,6 @@ instance ChaincodeStubInterface DefaultChaincodeStub where
                     Right _ -> pure ()
                 listenForResponse (recvStream ccs)
 
-      --
-      -- -- setStateValidationParameter :: ccs -> String -> [ByteString] -> Maybe Error
-      -- setStateValidationParameter ccs key parameters = Right notImplemented
-      --
-      -- -- getStateValiationParameter :: ccs -> String -> Either Error [ByteString]
-      -- getStateValiationParameter ccs key = Left notImplemented
-      --
     -- TODO: Implement better error handling/checks etc
     -- getStateByRange :: ccs -> Text -> Text -> IO (Either Error StateQueryIterator)
     getStateByRange ccs startKey endKey =
@@ -173,7 +166,29 @@ instance ChaincodeStubInterface DefaultChaincodeStub where
                     Right _ -> pure ()
                 runExceptT $ ExceptT (listenForResponse (recvStream ccs)) >>= (bsToSqiAndMeta ccs)
 
-  -- TODO : implement all these interface functions
+    -- TODO: This is the next TODO! Implement these 7 function because they are needed in marbles.hs
+    -- getStateByPartialCompositeKey :: ccs -> String -> [String] -> Either Error StateQueryIterator
+    getStateByPartialCompositeKey ccs objectType keys = throwError $ Error "not implemented"
+
+    --getStateByPartialCompositeKeyWithPagination :: ccs -> String -> [String] -> Int32 -> String -> Either Error (StateQueryIterator, Pb.QueryResponseMetadata)
+    getStateByPartialCompositeKeyWithPagination ccs objectType keys pageSize bookmark =
+        throwError $ Error "not implemented"
+
+    --createCompositeKey :: ccs -> String -> [String] -> Either Error String
+    createCompositeKey ccs objectType keys = throwError $ Error "not implemented"
+
+    --splitCompositeKey :: ccs -> String -> Either Error (String, [String])
+    splitCompositeKey ccs key = throwError $ Error "not implemented"
+
+    --getQueryResult :: ccs -> String -> Either Error StateQueryIterator
+    getQueryResult ccs query = throwError $ Error "not implemented"
+
+    --getQueryResultWithPagination :: ccs -> String -> Int32 -> String -> Either Error (StateQueryIterator, Pb.QueryResponseMetadata)
+    getQueryResultWithPagination ccs key pageSize bookmark = throwError $ Error "not implemented"
+
+    --getHistoryForKey :: ccs -> String -> Either Error HistoryQueryIterator
+    getHistoryForKey ccs key = throwError $ Error "not implemented"
+
 instance StateQueryIteratorInterface StateQueryIterator where
     -- TODO: remove the IO from this function (possibly with the State monad)
       -- hasNext :: sqi -> IO Bool
@@ -184,6 +199,7 @@ instance StateQueryIteratorInterface StateQueryIterator where
         pure $ (currentLoc < Prelude.length (Pb.queryResponseResults queryResponse))
             || (Pb.queryResponseHasMore queryResponse)
 
+    -- TODO : implement close function (need to do anything here in haskell?)
     -- close :: sqi -> IO (Maybe Error)
     close _ = pure Nothing
 
@@ -296,28 +312,6 @@ fetchNextQueryResult sqi = do
                     Left err -> error ("Error while streaming: " ++ show err)
                     Right _ -> pure ()
                 runExceptT $ ExceptT (listenForResponse (recvStream $ sqiChaincodeStub sqi)) >>= bsToQueryResponse
---
--- -- getStateByPartialCompositeKey :: ccs -> String -> [String] -> Either Error StateQueryIterator
--- getStateByPartialCompositeKey ccs objectType keys  = Left notImplemented
---
--- --getStateByPartialCompositeKeyWithPagination :: ccs -> String -> [String] -> Int32 -> String -> Either Error (StateQueryIterator, Pb.QueryResponseMetadata)
--- getStateByPartialCompositeKeyWithPagination ccs objectType keys pageSize bookmark = Left notImplemented
---
--- --createCompositeKey :: ccs -> String -> [String] -> Either Error String
--- createCompositeKey ccs objectType keys = Left notImplemented
---
--- --splitCompositeKey :: ccs -> String -> Either Error (String, [String])
--- splitCompositeKey ccs key = Left notImplemented
---
--- --getQueryResult :: ccs -> String -> Either Error StateQueryIterator
--- getQueryResult ccs query = Left notImplemented
---
--- --getQueryResultWithPagination :: ccs -> String -> Int32 -> String -> Either Error (StateQueryIterator, Pb.QueryResponseMetadata)
--- getQueryResultWithPagination ccs key pageSize bookmark = Left notImplemented
---
--- --getHistoryForKey :: ccs -> String -> Either Error HistoryQueryIterator
--- getHistoryForKey ccs key = Left notImplemented
---
 -- --getPrivateData :: ccs -> String -> String -> Either Error ByteString
 -- getPrivateData ccs collection key = Left notImplemented
 --