bumi/lntip
1
1
Fork 0
mirror of https://github.com/bumi/lntip synced 2025-06-16 17:55:35 +00:00
Code Issues Releases Wiki Activity

Formatting

Browse Source
This commit is contained in:
bumi 2020-10-24 11:38:44 +02:00
parent 37ebaf3834
commit 9afa340725
1 changed files with 18 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
lnme.go
View File

@ -3,7 +3,7 @@ package main
import ( import (
"flag" "flag"
"github.com/GeertJohan/go.rice" "github.com/GeertJohan/go.rice"
"github.com/bumi/lntip/ln" "github.com/bumi/lnme/ln"
"github.com/didip/tollbooth/v6" "github.com/didip/tollbooth/v6"
"github.com/didip/tollbooth/v6/limiter" "github.com/didip/tollbooth/v6/limiter"
"github.com/labstack/echo/v4" "github.com/labstack/echo/v4"
@ -48,10 +48,10 @@ func main() {
e := echo.New() e := echo.New()
// Serve static files if configured // Serve static files if configured
if *staticPath != "" { if *staticPath != "" {
e.Static("/", *staticPath) e.Static("/", *staticPath)
// Serve default page // Serve default page
} else if !*disableWebsite { } else if !*disableWebsite {
rootBox := rice.MustFindBox("files/root") rootBox := rice.MustFindBox("files/root")
indexPage, err := rootBox.String("index.html") indexPage, err := rootBox.String("index.html")
@ -62,28 +62,27 @@ func main() {
}) })
} else { } else {
stdOutLogger.Printf("Failed to run embedded website: %s", err) stdOutLogger.Printf("Failed to run embedded website: %s", err)
} }
} }
// Embed static files and serve those on /lnme (e.g. /lnme/lnme.js) // Embed static files and serve those on /lnme (e.g. /lnme/lnme.js)
assetHandler := http.FileServer(rice.MustFindBox("files/assets").HTTPBox()) assetHandler := http.FileServer(rice.MustFindBox("files/assets").HTTPBox())
e.GET("/lnme/*", echo.WrapHandler(http.StripPrefix("/lnme/", assetHandler))) e.GET("/lnme/*", echo.WrapHandler(http.StripPrefix("/lnme/", assetHandler)))
// CORS settings
// CORS settings
if !*disableCors { if !*disableCors {
e.Use(middleware.CORS()) e.Use(middleware.CORS())
} }
// Recover middleware recovers from panics anywhere in the request chain // Recover middleware recovers from panics anywhere in the request chain
e.Use(middleware.Recover()) e.Use(middleware.Recover())
// Request limit per second. DoS protection // Request limit per second. DoS protection
if *requestLimit > 0 { if *requestLimit > 0 {
limiter := tollbooth.NewLimiter(*requestLimit, nil) limiter := tollbooth.NewLimiter(*requestLimit, nil)
e.Use(LimitMiddleware(limiter)) e.Use(LimitMiddleware(limiter))
} }
// Setup lightning client // Setup lightning client
stdOutLogger.Printf("Connection to %s using macaroon %s and cert %s", *address, *macaroonFile, *certFile) stdOutLogger.Printf("Connection to %s using macaroon %s and cert %s", *address, *macaroonFile, *certFile)
lndOptions := ln.LNDoptions{ lndOptions := ln.LNDoptions{
Address: *address, Address: *address,
@ -97,8 +96,8 @@ func main() {
} }
// Endpoint URLs compatible to the LND REST API v1 // Endpoint URLs compatible to the LND REST API v1
// //
// Create new invoice // Create new invoice
e.POST("/v1/invoices", func(c echo.Context) error { e.POST("/v1/invoices", func(c echo.Context) error {
i := new(Invoice) i := new(Invoice)
if err := c.Bind(i); err != nil { if err := c.Bind(i); err != nil {
@ -115,17 +114,17 @@ func main() {
return c.JSON(http.StatusOK, invoice) return c.JSON(http.StatusOK, invoice)
}) })
// Get next BTC onchain address // Get next BTC onchain address
e.POST("/v1/newaddress", func(c echo.Context) error { e.POST("/v1/newaddress", func(c echo.Context) error {
address, err := lnClient.NewAddress() address, err := lnClient.NewAddress()
if err != nil { if err != nil {
stdOutLogger.Printf("Error getting a new BTC address: %s", err) stdOutLogger.Printf("Error getting a new BTC address: %s", err)
return c.JSON(http.StatusInternalServerError, "Error getting address") return c.JSON(http.StatusInternalServerError, "Error getting address")
} }
return c.JSON(http.StatusOK, address) return c.JSON(http.StatusOK, address)
}) })
// Check invoice status // Check invoice status
e.GET("/v1/invoice/:invoiceId", func(c echo.Context) error { e.GET("/v1/invoice/:invoiceId", func(c echo.Context) error {
invoiceId := c.Param("invoiceId") invoiceId := c.Param("invoiceId")
invoice, err := lnClient.GetInvoice(invoiceId) invoice, err := lnClient.GetInvoice(invoiceId)