mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-03-03 10:46:42 +01:00
Code Issues Projects Releases Packages Wiki Activity

Tor endpoints for the oracle explorer client (#4314)

Browse source
This commit is contained in:
rorp 2022-05-06 05:21:33 -07:00 • committed by GitHub
parent a3faa0c56f
commit c9502babba
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 23 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
app-commons/src/main/scala/org/bitcoins/commons/jsonmodels/ExplorerEnv.scala
View file

@ -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)

22
oracle-explorer-client/src/main/scala/org/bitcoins/explorer/client/SbExplorerClient.scala
View file

@ -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 =>