. mkTransaction:

   - removeDataInputs

Author: monyedavid

modules/explorer-api/src/main/scala/org/ergoplatform/explorer/http/api/v1/shared/MempoolProps.scala

@@ -15,6 +15,7 @@ import org.ergoplatform.explorer.http.api.v1.models.{Balance, UOutputInfo, UTran
 import org.ergoplatform.explorer.settings.{ServiceSettings, UtxCacheSettings}
 import org.ergoplatform.explorer.{Address, ErgoTree}
 import org.ergoplatform.ErgoAddressEncoder
+import org.ergoplatform.explorer.db.models.aggregates.ExtendedUDataInput
 import org.ergoplatform.explorer.http.api.v1.utils.BuildUnconfirmedBalance
 import org.ergoplatform.explorer.protocol.sigma.addressToErgoTreeNewtype
 import org.ergoplatform.explorer.syntax.stream._
@@ -84,18 +85,19 @@ object MempoolProps {
         flattened <- Stream.emits(outsInfo.toList)
       } yield flattened
 
-    def mkTransaction: Pipe[D, Chunk[UTransaction], UTransactionInfo] =
+    def mkTransaction(removeDataInputs: Boolean = false): Pipe[D, Chunk[UTransaction], UTransactionInfo] =
       for {
         chunk        <- _
         txIds        <- Stream.emit(chunk.map(_.id).toNel).unNone
         ins          <- Stream.eval(inputs.getAllByTxIds(txIds))
         inIds        <- Stream.emit(ins.map(_.input.boxId).toNel).unNone
         inAssets     <- Stream.eval(assets.getAllByBoxIds(inIds))
         confInAssets <- Stream.eval(confirmedAssets.getAllByBoxIds(inIds))
-        dataIns      <- Stream.eval(dataInputs.getAllByTxIds(txIds))
-        outs         <- Stream.eval(outputs.getAllByTxIds(txIds))
-        outIds       <- Stream.emit(outs.map(_.output.boxId).toNel).unNone
-        outAssets    <- Stream.eval(assets.getAllByBoxIds(outIds))
+        dataIns <- if (removeDataInputs) Stream.emit(List[ExtendedUDataInput]().pure[D])
+                   else Stream.eval(dataInputs.getAllByTxIds(txIds))
+        outs      <- Stream.eval(outputs.getAllByTxIds(txIds))
+        outIds    <- Stream.emit(outs.map(_.output.boxId).toNel).unNone
+        outAssets <- Stream.eval(assets.getAllByBoxIds(outIds))
         txInfo <-
           Stream.emits(
             UTransactionInfo.unFlattenBatch(chunk.toList, ins, dataIns, outs, inAssets, confInAssets, outAssets)