mirror of
https://github.com/getAlby/lndhub.go.git
synced 2026-01-16 19:35:40 +01:00
628071160c
* remove cmd folder as we are going to have only one entrypoint * get rid of pkg directory * rename test -> integration_tests as unit tests should reside next to the actual files they are testing * database migration WIP * reinstate gorm boilerplate in the addinvoice for now to make it compile * introduce migrations * add Makefile * don't use unsigned types for database mappings * migrations work now * add build target * use echo groups * gorm removed * add envconfig * fix comments
88 lines
2.2 KiB
Go
88 lines
2.2 KiB
Go
package controllers
|
|
|
|
import (
|
|
"context"
|
|
"math/rand"
|
|
"net/http"
|
|
|
|
"github.com/bumi/lndhub.go/db/models"
|
|
"github.com/bumi/lndhub.go/lib"
|
|
"github.com/golang-jwt/jwt"
|
|
"github.com/labstack/echo/v4"
|
|
"github.com/labstack/gommon/random"
|
|
"github.com/sirupsen/logrus"
|
|
)
|
|
|
|
// AddInvoiceController : Add invoice controller struct
|
|
type AddInvoiceController struct{}
|
|
|
|
// AddInvoice : Add invoice Controller
|
|
func (AddInvoiceController) AddInvoice(c echo.Context) error {
|
|
ctx := c.(*lib.IndhubContext)
|
|
user := c.Get("user").(*jwt.Token)
|
|
claims := user.Claims.(jwt.MapClaims)
|
|
userID := claims["id"].(float64)
|
|
|
|
type RequestBody struct {
|
|
Amt uint `json:"amt" validate:"required"`
|
|
Memo string `json:"memo"`
|
|
DescriptionHash string `json:"description_hash"`
|
|
}
|
|
|
|
var body RequestBody
|
|
|
|
if err := c.Bind(&body); err != nil {
|
|
return c.JSON(http.StatusBadRequest, echo.Map{
|
|
"message": "failed to bind json, amt field with positive value is required",
|
|
})
|
|
}
|
|
|
|
if err := c.Validate(&body); err != nil {
|
|
return c.JSON(http.StatusBadRequest, echo.Map{
|
|
"message": "amt with positive value is required",
|
|
})
|
|
}
|
|
|
|
db := ctx.DB
|
|
|
|
invoice := models.Invoice{
|
|
Type: "",
|
|
UserID: uint(userID),
|
|
TransactionEntryID: 0,
|
|
Amount: body.Amt,
|
|
Memo: body.Memo,
|
|
DescriptionHash: body.DescriptionHash,
|
|
PaymentRequest: "",
|
|
RHash: "",
|
|
State: "",
|
|
}
|
|
|
|
// TODO: move this to a service layer and call a method
|
|
_, err := db.NewInsert().Model(&invoice).Exec(context.TODO())
|
|
if err != nil {
|
|
logrus.Errorf("error saving an invoice: %v", err)
|
|
// TODO: better error handling, possibly panic and catch in an error handler
|
|
return c.JSON(http.StatusInternalServerError, nil)
|
|
}
|
|
|
|
var responseBody struct {
|
|
RHash string `json:"r_hash"`
|
|
PaymentRequest string `json:"payment_request"`
|
|
PayReq string `json:"pay_req"`
|
|
}
|
|
|
|
responseBody.PayReq = makePreimageHex()
|
|
|
|
return c.JSON(http.StatusOK, &responseBody)
|
|
}
|
|
|
|
const hexBytes = random.Hex
|
|
|
|
func makePreimageHex() string {
|
|
b := make([]byte, 32)
|
|
for i := range b {
|
|
b[i] = hexBytes[rand.Intn(len(hexBytes))]
|
|
}
|
|
return string(b)
|
|
}
|