-
{-# LANGUAGE DeriveAnyClass #-}
-
{-# LANGUAGE DeriveGeneric #-}
-
{-# LANGUAGE DerivingStrategies #-}
-
{-# LANGUAGE FlexibleInstances #-}
-
{-# LANGUAGE NamedFieldPuns #-}
-
{-# LANGUAGE OverloadedStrings #-}
-
{-# LANGUAGE PackageImports #-}
-
{-# LANGUAGE PatternSynonyms #-}
-
{-# LANGUAGE QuasiQuotes #-}
-
{-# LANGUAGE RecordWildCards #-}
-
{-# LANGUAGE TemplateHaskell #-}
+
{-# LANGUAGE DeriveGeneric #-}
+
{-# LANGUAGE DerivingStrategies #-}
+
{-# LANGUAGE FlexibleInstances #-}
+
{-# LANGUAGE NamedFieldPuns #-}
+
{-# LANGUAGE OverloadedStrings #-}
+
{-# LANGUAGE PackageImports #-}
+
{-# LANGUAGE PatternSynonyms #-}
+
{-# LANGUAGE QuasiQuotes #-}
+
{-# LANGUAGE RecordWildCards #-}
+
{-# LANGUAGE TemplateHaskell #-}
+
{-# LANGUAGE UndecidableInstances #-}
{-# OPTIONS_GHC -Wno-orphans #-}
+
{-# OPTIONS_GHC -Wno-name-shadowing #-}
-- | Back-end support for Utxo Indexer
-- This module will create the SQL tables:
+ table: unspentTransactions
|---------+------+-------+-----------+-------+-------+------------------+--------------+------+-------------|
-
| Address | TxId | TxIdx | DatumHash | Datum | Value | InlineScriptHash | InlineScript | Slot | BlockNumber |
+
| Address | TxId | TxIx | DatumHash | Datum | Value | InlineScriptHash | InlineScript | Slot | BlockNumber |
|---------+------+-------+-----------+-------+-------+------------------+--------------+------+-------------|
+
|------+------|--------+-----------|
+
| txId | txIx | slotNo | blockHash |
+
|------+------|--------+-----------|
-
module Marconi.Index.Utxo
-
import Codec.Serialise (Serialise (encode), deserialiseOrFail, serialise)
-
import Codec.Serialise.Class (Serialise (decode))
+
module Marconi.Index.Utxo where
import Control.Concurrent.Async (concurrently_)
import Control.Exception (bracket_)
-
import Control.Lens (filtered, folded, traversed)
import Control.Lens.Combinators (imap)
-
import Control.Lens.Operators ((%~), (&), (^.), (^..))
+
import Control.Lens.Operators ((^.))
import Control.Lens.TH (makeLenses)
import Control.Monad (unless, when)
-
import Data.ByteString (ByteString)
+
import Data.Aeson (eitherDecode, encode)
import Data.ByteString.Lazy (toStrict)
-
import Data.Foldable (foldl')
-
import Data.List (union)
-
import Data.Maybe (fromJust)
+
import Data.Foldable (foldl', toList)
+
import Data.Functor ((<&>))
+
import Data.List (elemIndex)
+
import Data.List.NonEmpty (NonEmpty)
+
import Data.Maybe (fromMaybe)
import Data.Proxy (Proxy (Proxy))
import Data.Set qualified as Set
-
import Database.SQLite.Simple (Only (Only), SQLData (SQLBlob, SQLInteger, SQLText))
+
import Database.SQLite.Simple (Only (Only), SQLData (SQLBlob, SQLInteger))
import Database.SQLite.Simple qualified as SQL
import Database.SQLite.Simple.FromField (FromField (fromField), ResultError (ConversionFailed), returnError)
import Database.SQLite.Simple.FromRow (FromRow (fromRow), field)
import Database.SQLite.Simple.ToField (ToField (toField))
import Database.SQLite.Simple.ToRow (ToRow (toRow))
import GHC.Generics (Generic)
import System.Random.MWC (createSystemRandom, uniformR)
-
import Text.ParserCombinators.Parsec (parse)
import Text.RawString.QQ (r)
import Cardano.Api qualified as C
import "cardano-api" Cardano.Api.Shelley qualified as Shelley
-
import Cardano.Binary (fromCBOR, toCBOR)
import Marconi.Types (CurrentEra, TargetAddresses, TxOut, pattern CurrentEra)
-
import RewindableIndex.Index.VSqlite (SqliteIndex)
-
import RewindableIndex.Index.VSqlite qualified as Ix
-
{ _utxoAddress :: !C.AddressAny
-
, _utxoDatum :: Maybe C.ScriptData
-
, _utxoDatumHash :: Maybe (C.Hash C.ScriptData)
-
, _utxoValue :: C.Value
-
, _utxoInlineScript :: Maybe ByteString
-
, _utxoInlineScriptHash :: Maybe (C.ScriptHash)
-
} deriving (Show, Generic)
+
import RewindableIndex.Storable (Buffered (getStoredEvents, persistToStorage), HasPoint (getPoint),
+
QueryInterval (QEverything, QInterval), Queryable (queryStorage),
+
Resumable (resumeFromStorage), Rewindable (rewindStorage), StorableEvent,
+
StorableMonad, StorablePoint, StorableQuery, StorableResult, emptyState,
+
filterWithQueryInterval)
+
import RewindableIndex.Storable qualified as Storable
-
u1 == u2 = (_utxoTxId u1) == (_utxoTxId u2)
-
compare u1 u2 = compare (_utxoTxId u1) (_utxoTxId u2)
+
type UtxoIndexer = Storable.State UtxoHandle
-
data UtxoEvent = UtxoEvent
-
{ _utxoEventUtxos :: [Utxo]
-
, _utxoEventInputs :: !(Set C.TxIn)
-
, _utxoEventSlotNo :: !C.SlotNo
-
, _utxoEventBlockNo :: !C.BlockNo
+
data UtxoHandle = UtxoHandle
+
{ hdlConnection :: SQL.Connection
-
$(makeLenses ''UtxoEvent)
+
newtype instance StorableQuery UtxoHandle =
+
UtxoAddress C.AddressAny deriving (Show, Eq)
-
, _utxoRowSlotNo :: !C.SlotNo
-
, _utxoRowBlockNo :: !C.BlockNo
-
} deriving (Show, Eq, Ord, Generic)
+
type QueryableAddresses = NonEmpty (StorableQuery UtxoHandle)
+
type instance StorableMonad UtxoHandle = IO
-
type Result = Maybe [UtxoRow]
+
type instance StorablePoint UtxoHandle = C.ChainPoint
+
newtype Depth = Depth Int
+
{ _address :: C.AddressAny
+
, _datum :: Maybe C.ScriptData
+
, _datumHash :: Maybe (C.Hash C.ScriptData)
+
, _inlineScript :: Maybe Shelley.ScriptInAnyLang -- ByteString -- ^ ReferenceScript
+
, _inlineScriptHash :: Maybe C.ScriptHash
+
} deriving (Show, Eq, Generic)
-
newtype Depth = Depth Int
+
= _txId left <= _txId right
+
&& _txIx left <= _txIx right
![iohk-bors[bot]](https://avatars.githubusercontent.com/in/17473?v=4&s=80)
