forked from dinstein/fabric
-
Notifications
You must be signed in to change notification settings - Fork 2
/
legacy_node.go
66 lines (54 loc) · 1.96 KB
/
legacy_node.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
package legacynode
import (
"fmt"
"github.com/abchain/fabric/consensus/helper"
"github.com/abchain/fabric/core/ledger"
"github.com/abchain/fabric/core/peer"
"github.com/abchain/fabric/core/util"
"github.com/abchain/fabric/node"
"github.com/abchain/fabric/node/start"
pb "github.com/abchain/fabric/protos"
proto "github.com/golang/protobuf/proto"
"github.com/op/go-logging"
)
var logger = logging.MustGetLogger("legacymode")
type LegacyEngineAdapter struct {
peer.Engine
}
func (e *LegacyEngineAdapter) Init() error {
defPeer := startnode.GetNode().DefaultPeer()
var err error
e.Engine, err = helper.GetEngine(defPeer.Peer, defPeer.Syncer())
if err != nil {
return err
}
logger.Info("Init legacy engine in old consensus module")
//IMPORTANT: also notify ledger use legacy mode
ledger.UseLegacyModeOnLedger()
return nil
}
func (e *LegacyEngineAdapter) Scheme(thenode *node.NodeEngine) {
//set node is not pool and topic, all tx is handled by legacy module
for _, pr := range thenode.Peers {
pr.TxHandlerOpts.NoPooling = true
}
delete(thenode.TxTopic, "")
legacyHandler := pb.TxFuncAsTxPreHandler(func(transaction *pb.Transaction) (*pb.Transaction, error) {
logger.Debugf("Marshalling transaction %s to send to local engine", transaction.Type)
data, err := proto.Marshal(transaction)
if err != nil {
return nil, fmt.Errorf("Error sending transaction to local engine: %s", err)
}
var response *pb.Response
msg := &pb.Message{Type: pb.Message_CHAIN_TRANSACTION, Payload: data, Timestamp: util.CreateUtcTimestamp()}
logger.Debugf("Sending message %s with timestamp %v to local engine", msg.Type, msg.Timestamp)
response = e.ProcessTransactionMsg(msg, transaction)
if response.Status == pb.Response_SUCCESS {
return transaction, nil
} else {
return nil, fmt.Errorf("resp from engine fail: %s", string(response.Msg))
}
})
thenode.CustomFilters = append(thenode.CustomFilters, legacyHandler)
thenode.Options.MakeGenesisForLedger = true
}