mirror of
https://github.com/onsonr/sonr.git
synced 2025-03-11 13:29:12 +00:00
Prad Nukala
60c48d2409
* feat: add support for DID number as primary key for Controllers * refactor: rename pkg/proxy to app/proxy * feat: add vault module keeper tests * feat(vault): add DID keeper to vault module * refactor: move vault client code to its own package * refactor(vault): extract schema definition * refactor: use vaulttypes for MsgAllocateVault * refactor: update vault assembly logic to use new methods * feat: add dwn-proxy command * refactor: remove unused context.go file * refactor: remove unused web-related code * feat: add DWN proxy server * feat: add BuildTx RPC to vault module * fix: Implement BuildTx endpoint * feat: add devbox integration to project
57 lines
1.3 KiB
Go
57 lines
1.3 KiB
Go
package proxy
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"os"
|
|
"os/signal"
|
|
"time"
|
|
|
|
"github.com/labstack/echo/v4"
|
|
"github.com/labstack/gommon/log"
|
|
"github.com/onsonr/sonr/nebula/pages"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
func NewProxyCmd() *cobra.Command {
|
|
return &cobra.Command{
|
|
Use: "dwn-proxy",
|
|
Short: "Starts the DWN proxy server for the local IPFS node",
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
// Echo instance
|
|
e := echo.New()
|
|
e.Logger.SetLevel(log.INFO)
|
|
|
|
// Load config
|
|
_, err := LoadConfig("./")
|
|
if err != nil {
|
|
e.Logger.Error(err)
|
|
}
|
|
|
|
// Configure the server
|
|
e.GET("/", pages.Home)
|
|
e.GET("/allocate", pages.Profile)
|
|
|
|
// Start server
|
|
ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
|
|
defer stop()
|
|
// Start server
|
|
go func() {
|
|
if err := e.Start(":1323"); err != nil && err != http.ErrServerClosed {
|
|
e.Logger.Fatal("shutting down the server")
|
|
}
|
|
}()
|
|
|
|
// Wait for interrupt signal to gracefully shutdown the server with a timeout of 10 seconds.
|
|
<-ctx.Done()
|
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
|
defer cancel()
|
|
|
|
// Shutdown the server with 10 seconds timeout.
|
|
if err := e.Shutdown(ctx); err != nil {
|
|
e.Logger.Fatal(err)
|
|
}
|
|
},
|
|
}
|
|
}
|