代码拉取完成,页面将自动刷新
/*
Copyright IBM Corp. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
package channel
import (
"fmt"
"io/ioutil"
"strconv"
"strings"
"github.com/golang/protobuf/proto"
cb "github.com/hyperledger/fabric-protos-go/common"
"github.com/hyperledger/fabric/internal/peer/common"
"github.com/hyperledger/fabric/protoutil"
"github.com/spf13/cobra"
)
func fetchCmd(cf *ChannelCmdFactory) *cobra.Command {
fetchCmd := &cobra.Command{
Use: "fetch <newest|oldest|config|(number)> [outputfile]",
Short: "Fetch a block",
Long: "Fetch a specified block, writing it to a file.",
RunE: func(cmd *cobra.Command, args []string) error {
return fetch(cmd, args, cf)
},
}
flagList := []string{
"channelID",
"bestEffort",
}
attachFlags(fetchCmd, flagList)
return fetchCmd
}
func fetch(cmd *cobra.Command, args []string, cf *ChannelCmdFactory) error {
if len(args) == 0 {
return fmt.Errorf("fetch target required, oldest, newest, config, or a number")
}
if len(args) > 2 {
return fmt.Errorf("trailing args detected")
}
// Parsing of the command line is done so silence cmd usage
cmd.SilenceUsage = true
// default to fetching from orderer
ordererRequired := OrdererRequired
peerDeliverRequired := PeerDeliverNotRequired
if len(strings.Split(common.OrderingEndpoint, ":")) != 2 {
// if no orderer endpoint supplied, connect to peer's deliver service
ordererRequired = OrdererNotRequired
peerDeliverRequired = PeerDeliverRequired
}
var err error
if cf == nil {
cf, err = InitCmdFactory(EndorserNotRequired, peerDeliverRequired, ordererRequired)
if err != nil {
return err
}
}
var block *cb.Block
switch args[0] {
case "oldest":
block, err = cf.DeliverClient.GetOldestBlock()
case "newest":
block, err = cf.DeliverClient.GetNewestBlock()
case "config":
iBlock, err2 := cf.DeliverClient.GetNewestBlock()
if err2 != nil {
return err2
}
lc, err2 := protoutil.GetLastConfigIndexFromBlock(iBlock)
if err2 != nil {
return err2
}
logger.Infof("Retrieving last config block: %d", lc)
block, err = cf.DeliverClient.GetSpecifiedBlock(lc)
default:
num, err2 := strconv.Atoi(args[0])
if err2 != nil {
return fmt.Errorf("fetch target illegal: %s", args[0])
}
block, err = cf.DeliverClient.GetSpecifiedBlock(uint64(num))
}
if err != nil {
return err
}
b, err := proto.Marshal(block)
if err != nil {
return err
}
var file string
if len(args) == 1 {
file = channelID + "_" + args[0] + ".block"
} else {
file = args[1]
}
if err = ioutil.WriteFile(file, b, 0644); err != nil {
return err
}
return nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。