deal

Documentation

Index

• Variables

Variables

var ListCmd = &cli.Command{
	Name:  "list",
	Usage: "List all deals",
	Flags: []cli.Flag{
		&cli.StringSliceFlag{
			Name:  "dataset",
			Usage: "Filter deals by dataset name",
		},
		&cli.UintSliceFlag{
			Name:  "schedule",
			Usage: "Filter deals by schedule",
		},
		&cli.StringSliceFlag{
			Name:  "provider",
			Usage: "Filter deals by provider",
		},
		&cli.StringSliceFlag{
			Name:  "state",
			Usage: "Filter deals by state: proposed, published, active, expired, proposal_expired, slashed",
		},
	},
	Action: func(c *cli.Context) error {
		db := database.MustOpenFromCLI(c)
		deals, err := deal.ListHandler(db, deal.ListDealRequest{})
		if err != nil {
			return err
		}
		cliutil.PrintToConsole(deals, c.Bool("json"), nil)
		return nil
	},
}

var SendManualCmd = &cli.Command{
	Name:      "send-manual",
	Usage:     "Send a manual deal proposal to boost or legacy market",
	ArgsUsage: "CLIENT_ADDRESS PROVIDER_ID PIECE_CID PIECE_SIZE",
	Flags: []cli.Flag{
		&cli.StringSliceFlag{
			Name:     "http-header",
			Category: "Boost Only",
			Usage:    "http headers to be passed with the request (i.e. key=value)",
		},
		&cli.StringFlag{
			Name:     "url-template",
			Category: "Boost Only",
			Usage:    "URL template with PIECE_CID placeholder for boost to fetch the CAR file, i.e. http://127.0.0.1/piece/{PIECE_CID}.car",
			Value:    "",
		},
		&cli.Uint64Flag{
			Name:     "file-size",
			Category: "Boost Only",
			Usage:    "File size in bytes for boost to fetch the CAR file",
			Value:    0,
		},
		&cli.Float64Flag{
			Name:     "price-per-gb-epoch",
			Category: "Deal Proposal",
			Usage:    "Price in FIL per GiB per epoch",
			Value:    0,
		},
		&cli.Float64Flag{
			Name:     "price-per-gb",
			Category: "Deal Proposal",
			Usage:    "Price in FIL  per GiB",
			Value:    0,
		},
		&cli.Float64Flag{
			Name:     "price-per-deal",
			Category: "Deal Proposal",
			Usage:    "Price in FIL per deal",
			Value:    0,
		},
		&cli.StringFlag{
			Name:        "root-cid",
			Category:    "Deal Proposal",
			Usage:       "Root CID that is required as part of the deal proposal, if empty, will be set to empty CID",
			Value:       "bafkqaaa",
			DefaultText: "Empty CID",
		},
		&cli.BoolFlag{
			Name:     "verified",
			Category: "Deal Proposal",
			Usage:    "Whether to propose deals as verified",
			Value:    true,
		},
		&cli.BoolFlag{
			Name:     "ipni",
			Category: "Boost Only",
			Usage:    "Whether to announce the deal to IPNI",
			Value:    true,
		},
		&cli.BoolFlag{
			Name:     "keep-unsealed",
			Category: "Deal Proposal",
			Usage:    "Whether to keep unsealed copy",
			Value:    true,
		},
		&cli.StringFlag{
			Name:        "start-delay",
			Category:    "Deal Proposal",
			Aliases:     []string{"s"},
			Usage:       "Deal start delay in epoch or in duration format, i.e. 1000, 72h",
			Value:       "72h",
			DefaultText: "72h[3 days]",
		},
		&cli.StringFlag{
			Name:        "duration",
			Category:    "Deal Proposal",
			Aliases:     []string{"d"},
			Usage:       "Duration in epoch or in duration format, i.e. 1500000, 2400h",
			Value:       "12840h",
			DefaultText: "12840h[535 days]",
		},
		&cli.StringFlag{
			Name:     "lotus-api",
			Category: "Lotus",
			Usage:    "Lotus RPC API endpoint, only used to get miner info",
			Value:    "https://api.node.glif.io/rpc/v1",
		},
		&cli.StringFlag{
			Name:     "lotus-token",
			Category: "Lotus",
			Usage:    "Lotus RPC API token, only used to get miner info",
			Value:    "",
		},
		&cli.DurationFlag{
			Name:        "timeout",
			Usage:       "Timeout for the deal proposal",
			Value:       time.Minute,
			DefaultText: "1m",
		},
	},
	Action: func(cctx *cli.Context) error {
		proposal := deal.Proposal{
			HTTPHeaders:     cctx.StringSlice("http-header"),
			URLTemplate:     cctx.String("url-template"),
			PricePerGBEpoch: cctx.Float64("price-per-gb-epoch"),
			PricePerGB:      cctx.Float64("price-per-gb"),
			PricePerDeal:    cctx.Float64("price-per-deal"),
			RootCID:         cctx.String("root-cid"),
			Verified:        cctx.Bool("verified"),
			IPNI:            cctx.Bool("ipni"),
			KeepUnsealed:    cctx.Bool("keep-unsealed"),
			StartDelay:      cctx.String("start-delay"),
			Duration:        cctx.String("duration"),
			ClientAddress:   cctx.Args().Get(0),
			ProviderID:      cctx.Args().Get(1),
			PieceCID:        cctx.Args().Get(2),
			PieceSize:       cctx.Args().Get(3),
			FileSize:        cctx.Uint64("file-size"),
		}
		timeout := cctx.Duration("timeout")
		db := database.MustOpenFromCLI(cctx)
		ctx, cancel := context.WithTimeout(cctx.Context, timeout)
		defer cancel()
		h, err := util.InitHost(nil)
		if err != nil {
			return errors.Wrap(err, "failed to init host")
		}
		dealMaker := replication.NewDealMaker(
			cctx.String("lotus-api"),
			cctx.String("lotus-token"),
			h,
			10*timeout,
			timeout,
		)
		proposalID, err2 := deal.SendManualHandler(db.WithContext(ctx), ctx, proposal, dealMaker)
		if err2 != nil {
			return err2
		}

		if cctx.Bool("json") {
			content, err := json.Marshal(map[string]string{"proposalId": proposalID})
			if err != nil {
				return err
			}
			fmt.Println(string(content))
			return nil
		} else {
			fmt.Println("Deal proposal sent with proposal ID: ", proposalID)
			return nil
		}
	},
}