loopd: add hyperloop rpc call

Author: sputn1ck

loopd/perms/perms.go

@@ -116,4 +116,8 @@ var RequiredPermissions = map[string][]bakery.Op{
 		Entity: "swap",
 		Action: "read",
 	}},
+	"/looprpc.SwapClient/HyperLoopOut": {{
+		Entity: "swap",
+		Action: "write",
+	}},
 }

loopd/swapclient_server.go

@@ -18,6 +18,7 @@ import (
 	"github.com/lightninglabs/aperture/l402"
 	"github.com/lightninglabs/lndclient"
 	"github.com/lightninglabs/loop"
+	"github.com/lightninglabs/loop/hyperloop"
 	"github.com/lightninglabs/loop/instantout"
 	"github.com/lightninglabs/loop/instantout/reservation"
 	"github.com/lightninglabs/loop/labels"
@@ -83,6 +84,7 @@ type swapClientServer struct {
 	lnd                *lndclient.LndServices
 	reservationManager *reservation.Manager
 	instantOutManager  *instantout.Manager
+	hyperloopManager   *hyperloop.Manager
 	swaps              map[lntypes.Hash]loop.SwapInfo
 	subscribers        map[int]chan<- interface{}
 	statusChan         chan loop.SwapInfo
@@ -91,6 +93,24 @@ type swapClientServer struct {
 	mainCtx            context.Context
 }
 
+func (s *swapClientServer) HyperLoopOut(ctx context.Context,
+	req *clientrpc.HyperLoopOutRequest) (
+	*clientrpc.HyperLoopOutResponse, error) {
+
+	log.Infof("HyperLoop out request received")
+
+	hyperloop, err := s.hyperloopManager.NewHyperLoopOut(
+		ctx, btcutil.Amount(req.Amt), req.CustomSweepAddr,
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	return &clientrpc.HyperLoopOutResponse{
+		IdBytes: hyperloop.ID[:],
+	}, nil
+}
+
 // LoopOut initiates a loop out swap with the given parameters. The call returns
 // after the swap has been set up with the swap server. From that point onwards,
 // progress can be tracked via the LoopOutStatus stream that is returned from