Add graphql subscriptions and mutations

api/api.go

@@ -12,6 +12,7 @@ package api
 //  * Generate openrpc blobs
 
 type Boost interface {
+	Market
 	Common
 	Net
 }

api/market.go

@@ -0,0 +1,29 @@
+package api
+
+import (
+	"context"
+	"time"
+)
+
+//                       MODIFYING THE API INTERFACE
+//
+// When adding / changing methods in this file:
+// * Do the change here
+// * Adjust implementation in `node/impl/`
+// * Run `make gen` - this will:
+//  * Generate proxy structs
+//  * Generate mocks
+//  * Generate markdown docs
+//  * Generate openrpc blobs
+
+type Market interface {
+	// MethodGroup: Market
+
+	MarketDummyDeal(context.Context) (*ProviderDealRejectionInfo, error) //perm:admin
+}
+
+// ProviderDealRejectionInfo is the information sent by the Storage Provider to the Client when it rejects a valid deal.
+type ProviderDealRejectionInfo struct {
+	Reason  string
+	Backoff time.Duration
+}

cmd/boost/dummydeal.go

@@ -1,7 +1,8 @@
 package main
 
 import (
-	"github.com/davecgh/go-spew/spew"
+	"fmt"
+
 	"github.com/urfave/cli/v2"
 	"golang.org/x/xerrors"
 
@@ -21,14 +22,17 @@ var dummydealCmd = &cli.Command{
 
 		ctx := lcli.DaemonContext(cctx)
 
-		log.Debug("Get boost identity")
-
-		res, err := boostApi.ID(ctx)
+		log.Debug("Make API call to start dummy deal")
+		rej, err := boostApi.MarketDummyDeal(ctx)
 		if err != nil {
-			return xerrors.Errorf("couldnt get boost identity: %w", err)
+			return xerrors.Errorf("creating dummy deal: %w", err)
 		}
 
-		spew.Dump(res)
+		if rej != nil && rej.Reason != "" {
+			fmt.Printf("Dummy deal rejected: %s\n", rej.Reason)
+			return nil
+		}
+		fmt.Println("Made dummy deal")
 
 		return nil
 	},

cmd/boost/main.go

@@ -18,6 +18,8 @@ const (
 
 func main() {
 	_ = logging.SetLogLevel("boost", "INFO")
+	_ = logging.SetLogLevel("provider", "INFO")
+	_ = logging.SetLogLevel("gql", "INFO")
 
 	app := &cli.App{
 		Name:                 "boost",