feat: add swap icy webhook

Author: quanghuynguyen1902

cmd/revert-icy/main.go

@@ -0,0 +1,28 @@
+package main
+
+import (
+	"github.com/dwarvesf/fortress-api/pkg/config"
+	"github.com/dwarvesf/fortress-api/pkg/controller"
+	"github.com/dwarvesf/fortress-api/pkg/job"
+	"github.com/dwarvesf/fortress-api/pkg/logger"
+	"github.com/dwarvesf/fortress-api/pkg/service"
+	"github.com/dwarvesf/fortress-api/pkg/store"
+)
+
+func main() {
+	cfg := config.LoadConfig(config.DefaultConfigLoaders())
+	log := logger.NewLogrusLogger()
+	log.Infof("Server starting")
+
+	s := store.New()
+	repo := store.NewPostgresStore(cfg)
+	svc := service.New(cfg, s, repo)
+	ctrl := controller.New(s, repo, svc, nil, log, cfg)
+
+	if err := job.NewRevertIcy(ctrl, s, repo, svc, log, cfg).Run(); err != nil {
+		log.Fatal(err, "failed to run job")
+		return
+	}
+
+	log.Infof("done")
+}

codebase.md

@@ -19,7 +19,6 @@ require (
 	github.com/go-playground/validator/v10 v10.14.1
 	github.com/go-testfixtures/testfixtures/v3 v3.9.0
 	github.com/goccy/go-json v0.10.2
-	github.com/golang-jwt/jwt v3.2.2+incompatible
 	github.com/golang-jwt/jwt/v4 v4.5.0
 	github.com/golang/mock v1.6.0
 	github.com/google/go-cmp v0.6.0

go.mod

@@ -276,8 +276,6 @@ github.com/gofrs/flock v0.8.1/go.mod h1:F1TvTiK9OcQqauNUHlbJvyl9Qa1QvF/gOUDKA14j
 github.com/gofrs/uuid v4.0.0+incompatible/go.mod h1:b2aQJv3Z4Fp6yNu3cdSllBxTCLRxnplIgP/c0N/04lM=
 github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=
 github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=
-github.com/golang-jwt/jwt v3.2.2+incompatible h1:IfV12K8xAKAnZqdXVzCZ+TOjboZ2keLg81eXfW3O+oY=
-github.com/golang-jwt/jwt v3.2.2+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
 github.com/golang-jwt/jwt/v4 v4.5.0 h1:7cYmW1XlMY7h7ii7UhUyChSgS5wUJEnm9uZVTGqOWzg=
 github.com/golang-jwt/jwt/v4 v4.5.0/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0=
 github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA=

go.sum

@@ -0,0 +1,31 @@
+-- +migrate Up
+CREATE TABLE icy_swap_btc_requests (
+   id uuid PRIMARY KEY DEFAULT (uuid()),
+   profile_id varchar(255) NOT NULL,
+   request_code varchar(255) NOT NULL,
+   tx_status varchar(255),
+   tx_id int,
+   btc_address varchar(255),
+   timestamp integer,
+   amount varchar(255),
+   token_name varchar(255),
+   token_id varchar(255),
+   swap_request_status varchar(255),
+   swap_request_error text,
+   revert_status varchar(255),
+   revert_error text,
+   withdraw_status varchar(255),
+   withdraw_error text,
+   tx_swap text,
+   tx_deposit text,
+   created_at TIMESTAMP(6) DEFAULT NOW(),
+   updated_at TIMESTAMP(6) DEFAULT NOW()
+);
+
+CREATE INDEX idx_icy_swap_btc_profile_id ON icy_swap_btc_requests(profile_id);
+CREATE INDEX idx_icy_swap_btc_request_code ON icy_swap_btc_requests(request_code);
+
+-- +migrate Down
+DROP INDEX IF EXISTS idx_icy_swap_btc_profile_id;
+DROP INDEX IF EXISTS idx_icy_swap_btc_request_code;
+DROP TABLE icy_swap_btc_requests;

migrations/schemas/20250320153030-create-icy_btc_swap_request.sql

@@ -29,6 +29,7 @@ type Config struct {
 	Mochi         Mochi
 	MochiPay      MochiPay
 	MochiProfile  MochiProfile
+	IcyBackend    IcyBackend
 	Tono          Tono
 	ImprovMX      ImprovMX
 	CommunityNft  CommunityNft
@@ -118,13 +119,24 @@ type Mochi struct {
 }
 
 type MochiPay struct {
-	BaseURL string
+	BaseURL               string
+	ApplicationName       string
+	ApplicationPrivateKey string
+	ApplicationId         string
+	ApplicationVaultId    string
+	ApplicationOwnerId    string
+	IcyPoolPrivateKey     string
+	IcyPoolPublicKey      string
 }
 
 type MochiProfile struct {
 	BaseURL string
 }
 
+type IcyBackend struct {
+	BaseURL string
+}
+
 type Tono struct {
 	BaseURL string
 }
@@ -325,11 +337,21 @@ func Generate(v ENV) *Config {
 			APIKey:          v.GetString("MOCHI_API_KEY"),
 		},
 		MochiPay: MochiPay{
-			BaseURL: v.GetString("MOCHI_PAY_BASE_URL"),
+			BaseURL:               v.GetString("MOCHI_PAY_BASE_URL"),
+			ApplicationName:       v.GetString("MOCHI_PAY_APPLICATION_NAME"),
+			ApplicationPrivateKey: v.GetString("MOCHI_PAY_APPLICATION_PRIVATE_KEY"),
+			ApplicationId:         v.GetString("MOCHI_PAY_APPLICATION_ID"),
+			ApplicationVaultId:    v.GetString("MOCHI_PAY_APPLICATION_VAULT_ID"),
+			ApplicationOwnerId:    v.GetString("MOCHI_PAY_APPLICATION_OWNER_ID"),
+			IcyPoolPrivateKey:     v.GetString("MOCHI_PAY_ICY_POOL_PRIVATE_KEY"),
+			IcyPoolPublicKey:      v.GetString("MOCHI_PAY_ICY_POOL_PUBLIC_KEY"),
 		},
 		MochiProfile: MochiProfile{
 			BaseURL: v.GetString("MOCHI_PROFILE_BASE_URL"),
 		},
+		IcyBackend: IcyBackend{
+			BaseURL: v.GetString("ICY_BACKEND_BASE_URL"),
+		},
 		Tono: Tono{
 			BaseURL: v.GetString("TONO_BASE_URL"),
 		},