From c9502babba6fab669a2e49266ac1ef972153d3e3 Mon Sep 17 00:00:00 2001
From: rorp <rorp@users.noreply.github.com>
Date: Fri, 6 May 2022 05:21:33 -0700
Subject: [PATCH] Tor endpoints for the oracle explorer client (#4314)

---
 .../commons/jsonmodels/ExplorerEnv.scala      | 12 ++++++++++
 .../explorer/client/SbExplorerClient.scala    | 22 +++++++++----------
 2 files changed, 23 insertions(+), 11 deletions(-)

diff --git a/app-commons/src/main/scala/org/bitcoins/commons/jsonmodels/ExplorerEnv.scala b/app-commons/src/main/scala/org/bitcoins/commons/jsonmodels/ExplorerEnv.scala
index 863449bc53..05934ae83b 100644
--- a/app-commons/src/main/scala/org/bitcoins/commons/jsonmodels/ExplorerEnv.scala
+++ b/app-commons/src/main/scala/org/bitcoins/commons/jsonmodels/ExplorerEnv.scala
@@ -12,6 +12,8 @@ import org.bitcoins.crypto.StringFactory
 sealed trait ExplorerEnv {
   def siteUrl: String
   def baseUri: String
+  def torUrl: String
+  def torBaseUri: String
 }
 
 object ExplorerEnv extends StringFactory[ExplorerEnv] {
@@ -19,17 +21,27 @@ object ExplorerEnv extends StringFactory[ExplorerEnv] {
   case object Production extends ExplorerEnv {
     override val siteUrl: String = "https://oracle.suredbits.com/"
     override val baseUri: String = s"${siteUrl}v2/"
+
+    override val torUrl: String =
+      "http://oraclez4zobtsekasdz5aq3pgw75cwrso5dbckfz5wrfexfhv7755oid.onion/"
+    override val torBaseUri: String = s"${torUrl}v2/"
   }
 
   case object Test extends ExplorerEnv {
     override val siteUrl: String = "https://test.oracle.suredbits.com/"
     override val baseUri: String = s"${siteUrl}v2/"
+
+    override val torUrl: String =
+      "http://ps2u26igy7p4ykbniaog4scqn6sjcsbcwglnuv4gq6amtchrzurxy4ad.onion/"
+    override val torBaseUri: String = s"${torUrl}v2/"
   }
 
   /** For local testing purposes */
   case object Local extends ExplorerEnv {
     override val siteUrl: String = "http://localhost:9000/"
     override val baseUri: String = s"${siteUrl}v2/"
+    override val torUrl: String = siteUrl
+    override val torBaseUri: String = baseUri
   }
 
   val all: Vector[ExplorerEnv] = Vector(Production, Test, Local)
diff --git a/oracle-explorer-client/src/main/scala/org/bitcoins/explorer/client/SbExplorerClient.scala b/oracle-explorer-client/src/main/scala/org/bitcoins/explorer/client/SbExplorerClient.scala
index 08c58c29e9..51f725b125 100644
--- a/oracle-explorer-client/src/main/scala/org/bitcoins/explorer/client/SbExplorerClient.scala
+++ b/oracle-explorer-client/src/main/scala/org/bitcoins/explorer/client/SbExplorerClient.scala
@@ -40,8 +40,13 @@ case class SbExplorerClient(
   import system.dispatcher
   private val httpClient: HttpExt = Http(system)
 
+  private val baseUri: String = proxyParams match {
+    case Some(_) => env.torBaseUri
+    case None    => env.baseUri
+  }
+
   private val httpConnectionPoolSettings =
-    Socks5ClientTransport.createConnectionPoolSettings(new URI(env.baseUri),
+    Socks5ClientTransport.createConnectionPoolSettings(new URI(baseUri),
                                                        proxyParams)
 
   /** Lists all events on oracle explorer
@@ -49,8 +54,7 @@ case class SbExplorerClient(
     * @return
     */
   def listAnnouncements(): Future[Vector[SbAnnouncementEvent]] = {
-    val base = env.baseUri
-    val uri = Uri(base + "announcements")
+    val uri = Uri(baseUri + "announcements")
     val httpReq = HttpRequest(uri = uri)
     val responseF = sendRequest(httpReq)
     responseF.flatMap { response =>
@@ -79,8 +83,7 @@ case class SbExplorerClient(
     */
   def getAnnouncement(
       announcementHash: Sha256Digest): Future[SbAnnouncementEvent] = {
-    val base = env.baseUri
-    val uri = Uri(base + s"announcements/${announcementHash.hex}")
+    val uri = Uri(baseUri + s"announcements/${announcementHash.hex}")
     val httpReq = HttpRequest(uri = uri)
     val responseF = sendRequest(httpReq)
     responseF.flatMap { response =>
@@ -101,8 +104,7 @@ case class SbExplorerClient(
     */
   def createAnnouncement(
       oracleEventExplorer: CreateAnnouncementExplorer): Future[Unit] = {
-    val base = env.baseUri
-    val uri = Uri(base + s"announcements")
+    val uri = Uri(baseUri + s"announcements")
     val string = oracleEventExplorer.toString
     val httpReq =
       HttpRequest(
@@ -118,9 +120,8 @@ case class SbExplorerClient(
     * @see https://gist.github.com/Christewart/a9e55d9ba582ac9a5ceffa96db9d7e1f#create-an-events-attestation
     */
   def createAttestations(attestations: CreateAttestations): Future[Unit] = {
-    val base = env.baseUri
     val uri = Uri(
-      base + s"announcements/${attestations.announcementHash.hex}/attestations")
+      baseUri + s"announcements/${attestations.announcementHash.hex}/attestations")
     val string = attestations.toString
     val httpReq =
       HttpRequest(
@@ -133,8 +134,7 @@ case class SbExplorerClient(
   }
 
   def getOracleName(pubkey: SchnorrPublicKey): Future[Option[String]] = {
-    val base = env.baseUri
-    val uri = Uri(base + s"oracle/${pubkey.hex}")
+    val uri = Uri(baseUri + s"oracle/${pubkey.hex}")
     val httpReq = HttpRequest(uri = uri)
     val responseF = sendRequest(httpReq)
     responseF.flatMap { response =>