aljaz/lspd
1
0
Fork 0
mirror of https://github.com/aljazceru/lspd.git synced 2025-12-19 14:54:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

always use mempool api

Browse Source
This commit is contained in:
Jesse de Wit
2023-05-12 09:22:11 +02:00
parent d0de038d45
commit cad6540f42
3 changed files with 28 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
itest/lspd_node.go
View File

@@ -129,7 +129,6 @@ func newLspd(h *lntest.TestHarness, name string, nodeConfig *config.NodeConfig,
nodes, nodes,
fmt.Sprintf("DATABASE_URL=%s", postgresBackend.ConnectionString()), fmt.Sprintf("DATABASE_URL=%s", postgresBackend.ConnectionString()),
fmt.Sprintf("LISTEN_ADDRESS=%s", grpcAddress), fmt.Sprintf("LISTEN_ADDRESS=%s", grpcAddress),
"USE_MEMPOOL_FEE_ESTIMATION=true",
"MEMPOOL_API_BASE_URL=https://mempool.space/api/v1/", "MEMPOOL_API_BASE_URL=https://mempool.space/api/v1/",
"MEMPOOL_PRIORITY=economy", "MEMPOOL_PRIORITY=economy",
} }

52
main.go
View File

@@ -41,34 +41,34 @@ func main() {
log.Fatalf("need at least one node configured in NODES.") log.Fatalf("need at least one node configured in NODES.")
} }
var feeEstimator chain.FeeEstimator mempoolUrl := os.Getenv("MEMPOOL_API_BASE_URL")
var feeStrategy chain.FeeStrategy if mempoolUrl == "" {
useMempool := os.Getenv("USE_MEMPOOL_FEE_ESTIMATION") == "true" log.Fatalf("No mempool url configured.")
if useMempool {
mempoolUrl := os.Getenv("MEMPOOL_API_BASE_URL")
feeEstimator, err = mempool.NewMempoolClient(mempoolUrl)
if err != nil {
log.Fatalf("failed to initialize mempool client: %v", err)
}
envFeeStrategy := os.Getenv("MEMPOOL_PRIORITY")
switch strings.ToLower(envFeeStrategy) {
case "minimum":
feeStrategy = chain.FeeStrategyMinimum
case "economy":
feeStrategy = chain.FeeStrategyEconomy
case "hour":
feeStrategy = chain.FeeStrategyHour
case "halfhour":
feeStrategy = chain.FeeStrategyHalfHour
case "fastest":
feeStrategy = chain.FeeStrategyFastest
default:
feeStrategy = chain.FeeStrategyEconomy
}
log.Printf("using mempool api for fee estimation: %v, fee strategy: %v:%v", mempoolUrl, envFeeStrategy, feeStrategy)
} }
feeEstimator, err := mempool.NewMempoolClient(mempoolUrl)
if err != nil {
log.Fatalf("failed to initialize mempool client: %v", err)
}
var feeStrategy chain.FeeStrategy
envFeeStrategy := os.Getenv("MEMPOOL_PRIORITY")
switch strings.ToLower(envFeeStrategy) {
case "minimum":
feeStrategy = chain.FeeStrategyMinimum
case "economy":
feeStrategy = chain.FeeStrategyEconomy
case "hour":
feeStrategy = chain.FeeStrategyHour
case "halfhour":
feeStrategy = chain.FeeStrategyHalfHour
case "fastest":
feeStrategy = chain.FeeStrategyFastest
default:
feeStrategy = chain.FeeStrategyEconomy
}
log.Printf("using mempool api for fee estimation: %v, fee strategy: %v:%v", mempoolUrl, envFeeStrategy, feeStrategy)
databaseUrl := os.Getenv("DATABASE_URL") databaseUrl := os.Getenv("DATABASE_URL")
pool, err := postgresql.PgConnect(databaseUrl) pool, err := postgresql.PgConnect(databaseUrl)
if err != nil { if err != nil {

6
sample.env
View File

@@ -30,10 +30,8 @@ CHANNELMISMATCH_NOTIFICATION_TO='["Name1 <user1@domain.com>"]'
CHANNELMISMATCH_NOTIFICATION_CC='["Name2 <user2@domain.com>","Name3 <user3@domain.com>"]' CHANNELMISMATCH_NOTIFICATION_CC='["Name2 <user2@domain.com>","Name3 <user3@domain.com>"]'
CHANNELMISMATCH_NOTIFICATION_FROM="Name4 <user4@domain.com>" CHANNELMISMATCH_NOTIFICATION_FROM="Name4 <user4@domain.com>"
# By default lspd uses the fee estimation from the lightning node it is connected # lspd uses the fee estimation from mempool.space for opening new channels.
# to for opening new channels. You can use mempool fee estimation instead by # Change below setting for you own mempool instance.
# setting below variables.
USE_MEMPOOL_FEE_ESTIMATION=true
MEMPOOL_API_BASE_URL=https://mempool.space/api/v1/ MEMPOOL_API_BASE_URL=https://mempool.space/api/v1/
# Priority to use for opening channels when using the mempool api. # Priority to use for opening channels when using the mempool api.