add paillier homomorphic encryption

plugin/crypto/paillier/paillier.go

+package paillier
+
+import (
+	"bytes"
+	"encoding/binary"
+	"encoding/hex"
+	"fmt"
+	"github.com/33cn/chain33/common"
+	"github.com/33cn/chain33/types"
+	"math/big"
+)
+
+func CiphertextAdd(ciphertext1, ciphertext2 string) (string, error) {
+	cipherbytes1, err := common.FromHex(ciphertext1)
+	if err != nil {
+		fmt.Errorf("CiphertextAdd.FromHex. ciphertext1:%s, error:%v", ciphertext1, err)
+		return "", err
+	}
+
+	cipherbytes2, err := common.FromHex(ciphertext2)
+	if err != nil {
+		fmt.Errorf("CiphertextAdd.FromHex. ciphertext2:%s, error:%v", ciphertext2, err)
+		return "", err
+	}
+
+	res, err := CiphertextAddBytes(cipherbytes1, cipherbytes2)
+	if err != nil {
+		fmt.Errorf("CiphertextAdd.CiphertextAddBytes. error:%v", err)
+		return "", nil
+	}
+
+	return hex.EncodeToString(res), nil
+}
+
+func CiphertextAddBytes(cipherbytes1, cipherbytes2 []byte) ([]byte, error) {
+	nlen1 := bytesToInt(cipherbytes1[0:2])
+	if nlen1 >= len(cipherbytes1)-2 {
+		fmt.Errorf("CiphertextAddBytes. error param length")
+		return nil, types.ErrInvalidParam
+	}
+
+	nBytes1 := make([]byte, nlen1)
+	copy(nBytes1, cipherbytes1[2:2+nlen1])
+
+	nlen2 := bytesToInt(cipherbytes2[0:2])
+	if nlen2 >= len(cipherbytes2)-2 {
+		fmt.Errorf("CiphertextAddBytes. error param length")
+		return nil, types.ErrInvalidParam
+	}
+
+	nBytes2 := make([]byte, nlen2)
+	copy(nBytes2, cipherbytes2[2:2+nlen2])
+
+	if !bytes.Equal(nBytes1, nBytes2) {
+		fmt.Errorf("CiphertextAddBytes. error: param error n1!=n2")
+		return nil, types.ErrInvalidParam
+	}
+
+	data1 := make([]byte, len(cipherbytes1)-nlen1-2)
+	copy(data1, cipherbytes1[2+nlen1:])
+
+	data2 := make([]byte, len(cipherbytes2)-nlen2-2)
+	copy(data2, cipherbytes2[2+nlen2:])
+
+
+	cipher1 := new(big.Int).SetBytes(data1)
+	cipher2 := new(big.Int).SetBytes(data2)
+
+	n1 := new(big.Int).SetBytes(nBytes1)
+	nsquare := new(big.Int).Mul(n1, n1)
+
+	res := big.NewInt(0)
+	res.Mul(cipher1, cipher2).Mod(res, nsquare)
+
+	data := make([]byte, nlen1+2+len(res.Bytes()))
+	copy(data[:nlen1+2], cipherbytes1[:nlen1+2])
+	copy(data[nlen1+2:], res.Bytes())
+
+	return data, nil
+}
+
+func bytesToInt(cipherbytes []byte) int {
+	bytebuff := bytes.NewBuffer(cipherbytes)
+	var data int16
+	binary.Read(bytebuff, binary.BigEndian, &data)
+	return int(data)
+}
\ No newline at end of file

plugin/crypto/paillier/paillier_test.go

+package paillier
+
+import (
+	"github.com/stretchr/testify/assert"
+	"testing"
+)
+
+func TestCiphertextAdd(t *testing.T) {
+	c1 := "010070061bde0fc57d38e0ce9c82c088f793a93a20f830ed94a5f7e01f5af0decccf0ee7f70a711dc78b69b40f7e411f7f6ff34a5de4ad32fa5dc9d09b09dbbcf8e49bb1c9be19b215577167458b969bb40634f71dba00bdfdd12f1c878effd9e08475b8301a214bc7dfc95c2f341aa8fbd985a5da05af046336c23cf356570772530017c9a8bb96140977698d50c3258e8d31c040bb887c56d3d6e583db7a4ff2ea28aa93885312dfa50bf86a15618288b2c2701e6d75743fec9f3ca35b7e20ad902ad6985fe0b3c389b9582b3c62d9bea90230d1512a07c66a5404bf804693b6bb677a4ff038ae4a762f89f6a877d7621f7461431a7d4cadaf1687057ca4a9d1570e4ceeab32c86856d89731d50edf6f0886ccf348cc4565227f1df6b813569c49b3170e9efd722e4f4e957add9a115a2122a9f5c00780a1b8020d44b8b865d16113eadcfd15d1b755aed7c983b3d4b9390eda68d22d165a32d4055eee95adee79d7d28d2ee6d593d4eff217cd3e3d70bb9c32a6608af78afb7d5cb7ee0422500273b934209b950cd07842ab7e10c0dfc790d212c9085058d39c667b7dfff0963478118451ec64af30aff518384cc47758b2aa4331c8b5f36d6d1b9c3a6ee7ba77d28ea6ca844960e24ab6384e36127745f1285f3b71cea6c5c6a41c51ca7edbfae07766a3fb7bd9ef6b8f999460741a5b44eeb0b98937b57f4582294e18fd70d402dee2e557fa7df5cfb13240458f77b62a32169940ab5a1fce95b52583ecb13e21c22749f7620caaa6fd998e4f9bd0e617c925b83bed5ed2215ec8a404357a782b70d2c6ece6fa7a4fb30d18a01b81b2f3a8e38cc12f32becfdf195e02879b710f2feda5b0c2e86ba6df2a0fa25c60cef58224ee466787034cc5d0872a28cf8d6bad106125660b0b4bfe86eacb829dbb073420ff3af3ac76e5718c199fcf53258397a9e4fed0d98f360d16248693aced1ecbc5ca5211f48df011d14d372ee07f9b7c24bc219f3cdc403ebeb5b452643ddd1f4276779fab76a19c8b195a1213a235f7facf67a26b8a7804cb326f58200d756d62d40edb650498c198a524c091f0"
+
+	c2 := "010070061bde0fc57d38e0ce9c82c088f793a93a20f830ed94a5f7e01f5af0decccf0ee7f70a711dc78b69b40f7e411f7f6ff34a5de4ad32fa5dc9d09b09dbbcf8e49bb1c9be19b215577167458b969bb40634f71dba00bdfdd12f1c878effd9e08475b8301a214bc7dfc95c2f341aa8fbd985a5da05af046336c23cf356570772530017c9a8bb96140977698d50c3258e8d31c040bb887c56d3d6e583db7a4ff2ea28aa93885312dfa50bf86a15618288b2c2701e6d75743fec9f3ca35b7e20ad902ad6985fe0b3c389b9582b3c62d9bea90230d1512a07c66a5404bf804693b6bb677a4ff038ae4a762f89f6a877d7621f7461431a7d4cadaf1687057ca4a9d157195acafe73f5eed77b314dd640999ee20de461600ce3d3620cef84abc256774a514db5b65721cd93d1601e0fa8f53630dbe8567493018588e9619783e1526eb9bc56cc7b37c99025a9bdc10465bfb01605232292e50ac3b56b2ffefe48f0615651649d1db4ebff57d955e434f0c564b2a6842d3af04be1bfc5e968abe390f15bc89b9a4ed7a00b82beea07cf8e03c82bdd6a40b6c6334e51a432024caf9247db25058eb0cbce567ed49c56730058480e5854f3888e988053c403045239098ba6977aa0adb7f6dec785d31bacee8276a87d7a8f2114bb6662a117e3e37846c5b713e599801fbae5185cf21360760721376efe0736b7f4fa049d0c9f3086324be3a0f44d6cae5450d87d79a7bcaa0a2aa259b738ed85a59fead48d985597f6d77022ecdf37685df4182267d4fbdb24747f208a9e1b3126251b320066d8499ab5298395dab0340a78325b39d383d34a31a27f223114a9774498a314e3ba3cf4b87150e1f959f29556e67ae136a6290922e8cd3890c3b93bb68f38990ac3a4700cbe075795f7603755a28f3226e31c29a2eab2bff2423dc6177a6d8eaa950fbe2320b9bee89b8bbc3149b7ee177224e59726f28bcb796ccb09ac6b3feb3256ca033eb177aeea997be798f0e1b63b284dc8361ff870de717263cb86838a0c6cd5a82e12d162bd04f9c85267d4abd3a6828639fd0584a023388cc220d404d4646d0318"
+
+	c3 := "010070061bde0fc57d38e0ce9c82c088f793a93a20f830ed94a5f7e01f5af0decccf0ee7f70a711dc78b69b40f7e411f7f6ff34a5de4ad32fa5dc9d09b09dbbcf8e49bb1c9be19b215577167458b969bb40634f71dba00bdfdd12f1c878effd9e08475b8301a214bc7dfc95c2f341aa8fbd985a5da05af046336c23cf356570772530017c9a8bb96140977698d50c3258e8d31c040bb887c56d3d6e583db7a4ff2ea28aa93885312dfa50bf86a15618288b2c2701e6d75743fec9f3ca35b7e20ad902ad6985fe0b3c389b9582b3c62d9bea90230d1512a07c66a5404bf804693b6bb677a4ff038ae4a762f89f6a877d7621f7461431a7d4cadaf1687057ca4a9d1571d74c0a358b73242b65cf84139071503ffa45c824d84cb0336510de9a1ad1a7c56142efa23f8b69b4094c940adb42df385fc11bf2704a2608b1a65c5d17f2a051114832ab141290c16201b59eae28639ece329eb5b8003b4f1025e57066115d7d378581268359e0ca94117451ca3aa6b0d597cf8f621b66bf20fc488b18848aa47e31d5939d59b8058def7df416f6734b3821bacd1fc8f4f1d422fc2c17c9bd903e80fabea7eb0f6237f771d0be65941cfca8ed6ec0e412bc940fc09cb0033abe4e668fee7f07a9cba77da04815747271eb32a5a9278ca0f57d7e05cffa6bdb5902984586259fab80be0460e9af3391f2a3212a1e4f350e060f988781e6ab2254e76c972e5611151fa501607d1d342667253d21e9ca113f2b87d823a55e70d4f5899e0ba8121477dded3d3b858438c4d0486a0c9846eb05b737a734ba37cdfdaaca8a4a38f2bd1c1ed0b4583b96c2fd2d1675991b4a151470811b4f4bfbad46ddbaa0e1fa28a81a3801e8c211137db822fb5a07344dc719b13e50562bd1e3a391a7747709db2445543f7412fd9c3011141d9ad4f05182593e6e75033764395fa8be80039cb47ed5d750f62836312e7b23152f69a65e41a9782d841b3c48719403e98bd8e72c824083275a29a53d681dc25b7df6c60cb0c4c74feab1d7b1edc76c09a1fe4da1acf9979d3c200233b082f66710725867ef6418e866cd93d26c7fd"
+
+	data, err := CiphertextAdd(c1, c2)
+	assert.Nil(t, err)
+	assert.Equal(t, c3, data)
+}

plugin/dapp/storage/executor/exec.go

@@ -35,3 +35,8 @@ func (s *storage) Exec_EncryptShareStorage(payload *storagetypes.EncryptShareNot
 	action := newStorageAction(s, tx, index)
 	return action.EncryptShareStorage(payload)
 }
+
+func (s *storage) Exec_EncryptAdd(payload *storagetypes.EncryptNotaryAdd, tx *types.Transaction, index int) (*types.Receipt, error) {
+	action := newStorageAction(s, tx, index)
+	return action.EncryptAdd(payload)
+}
\ No newline at end of file

plugin/dapp/storage/executor/exec_local.go

@@ -115,6 +115,27 @@ func (s *storage) ExecLocal_EncryptShareStorage(payload *ety.EncryptShareNotaryS
 	return s.addAutoRollBack(tx, dbSet.KV), nil
 }
 
+func (s *storage) ExecLocal_EncryptAdd(payload *ety.EncryptNotaryAdd, tx *types.Transaction, receiptData *types.ReceiptData, index int) (*types.LocalDBSet, error) {
+	dbSet := &types.LocalDBSet{}
+	cfg := s.GetAPI().GetConfig()
+	if cfg.IsDappFork(s.GetHeight(), ety.StorageX, ety.ForkStorageLocalDB) {
+		if receiptData.Ty == types.ExecOk {
+			for _, log := range receiptData.Logs {
+				switch log.Ty {
+				case ety.TyEncryptAddLog:
+					storage := &ety.Storage{}
+					if err := types.Decode(log.Log, storage); err != nil {
+						return nil, err
+					}
+					kv := &types.KeyValue{Key: getLocalDBKey(storage.GetEncryptStorage().Key), Value: types.Encode(storage)}
+					dbSet.KV = append(dbSet.KV, kv)
+				}
+			}
+		}
+	}
+	return s.addAutoRollBack(tx, dbSet.KV), nil
+}
+
 //设置自动回滚
 func (s *storage) addAutoRollBack(tx *types.Transaction, kv []*types.KeyValue) *types.LocalDBSet {
 

plugin/dapp/storage/executor/storagedb.go

@@ -2,6 +2,7 @@ package executor
 
 import (
 	"fmt"
+	"github.com/33cn/plugin/plugin/crypto/paillier"
 
 	"github.com/33cn/chain33/client"
 	"github.com/33cn/chain33/common"
@@ -190,6 +191,49 @@ func (s *StorageAction) EncryptShareStorage(payload *ety.EncryptShareNotaryStora
 	return receipt, nil
 }
 
+//EncryptAdd ...
+func (s *StorageAction) EncryptAdd(payload *ety.EncryptNotaryAdd) (*types.Receipt, error) {
+	var logs []*types.ReceiptLog
+	var kvs []*types.KeyValue
+	cfg := s.api.GetConfig()
+
+	store, err := QueryStorage(s.db, s.localdb, payload.ContentHash)
+	if err != nil {
+		fmt.Errorf("EncryptAdd.QueryStorage. err:%v", err)
+		return nil, err
+	}
+
+	cipherText := store.GetEncryptStorage().EncryptContent
+	res, err := paillier.CiphertextAddBytes(cipherText, payload.EncryptAdd)
+	if err != nil {
+		fmt.Errorf("EncryptAdd.CiphertextAddBytes. err:%v", err)
+		return nil, err
+	}
+
+	store.GetEncryptStorage().EncryptContent = res
+
+	newStore := &ety.EncryptNotaryStorage{
+		ContentHash:          store.GetEncryptStorage().ContentHash,
+		EncryptContent:       res,
+		Nonce:                store.GetEncryptStorage().Nonce,
+		Key:                  store.GetEncryptStorage().Key,
+		Value:                store.GetEncryptStorage().Value,
+	}
+
+	if cfg.IsDappFork(s.height, ety.StorageX, ety.ForkStorageLocalDB) {
+		stg := &ety.Storage{Value: &ety.Storage_EncryptStorage{EncryptStorage: newStore}, Ty: ety.TyEncryptStorageAction}
+		log := &types.ReceiptLog{Ty: ety.TyEncryptAddLog, Log: types.Encode(stg)}
+		logs = append(logs, log)
+	} else {
+		log := &types.ReceiptLog{Ty: ety.TyEncryptAddLog}
+		logs = append(logs, log)
+		kvs = append(kvs, &types.KeyValue{Key: Key(payload.ContentHash), Value: types.Encode(newStore)})
+	}
+
+	receipt := &types.Receipt{Ty: types.ExecOk, KV: kvs, Logs: logs}
+	return receipt, nil
+}
+
 //QueryStorageByTxHash ...
 func QueryStorageByTxHash(db dbm.KV, txhash string) (*ety.Storage, error) {
 	data, err := db.Get(Key(txhash))

plugin/dapp/storage/proto/storage.proto

@@ -8,8 +8,9 @@ message Storage {
         LinkNotaryStorage         linkStorage         = 3;
         EncryptNotaryStorage      encryptStorage      = 4;
         EncryptShareNotaryStorage encryptShareStorage = 5;
+        EncryptNotaryAdd          encryptAdd          = 6;
     }
-    int32 ty = 6;
+    int32 ty = 7;
 }
 
 message StorageAction {
@@ -19,8 +20,9 @@ message StorageAction {
         LinkNotaryStorage         linkStorage         = 3;
         EncryptNotaryStorage      encryptStorage      = 4;
         EncryptShareNotaryStorage encryptShareStorage = 5;
+        EncryptNotaryAdd          encryptAdd          = 6;
     }
-    int32 ty = 6;
+    int32 ty = 7;
 }
 // 内容存证模型
 message ContentOnlyNotaryStorage {
@@ -85,6 +87,14 @@ message EncryptShareNotaryStorage {
     string value = 5;
 }
 
+// 加密存证数据运算
+message EncryptNotaryAdd {
+    //存证明文内容的hash值，推荐使用sha256哈希，限制256位得摘要值
+    string contentHash = 1;
+    //待操作数据
+    bytes encryptAdd = 2;
+}
+
 service storage {}
 //根据txhash去状态数据库中查询存储内容
 message QueryStorage {

plugin/dapp/storage/rpc/types.go

@@ -2,7 +2,6 @@ package rpc
 
 import (
 	rpctypes "github.com/33cn/chain33/rpc/types"
-	storagetypes "github.com/33cn/plugin/plugin/dapp/storage/types"
 )
 
 /*
@@ -30,5 +29,5 @@ func Init(name string, s rpctypes.RPCServer) {
 	grpc := &Grpc{channelClient: cli}
 	cli.Init(name, s, &Jrpc{cli: cli}, grpc)
 	//存在grpc service时注册grpc server，需要生成对应的pb.go文件
-	storagetypes.RegisterStorageServer(s.GRPC(), grpc)
+	//storagetypes.RegisterStorageServer(s.GRPC(), grpc)
 }

plugin/dapp/storage/types/storage.go

@@ -20,12 +20,14 @@ const (
 	TyLinkStorageAction
 	TyEncryptStorageAction
 	TyEncryptShareStorageAction
+	TyEncryptAddAction
 
 	NameContentStorageAction      = "ContentStorage"
 	NameHashStorageAction         = "HashStorage"
 	NameLinkStorageAction         = "LinkStorage"
 	NameEncryptStorageAction      = "EncryptStorage"
 	NameEncryptShareStorageAction = "EncryptShareStorage"
+	NameEncryptAddAction          = "EncryptAdd"
 
 	FuncNameQueryStorage      = "QueryStorage"
 	FuncNameBatchQueryStorage = "BatchQueryStorage"
@@ -39,6 +41,7 @@ const (
 	TyLinkStorageLog
 	TyEncryptStorageLog
 	TyEncryptShareStorageLog
+	TyEncryptAddLog
 )
 
 //storage op
@@ -61,6 +64,7 @@ var (
 		NameLinkStorageAction:         TyLinkStorageAction,
 		NameEncryptStorageAction:      TyEncryptStorageAction,
 		NameEncryptShareStorageAction: TyEncryptShareStorageAction,
+		NameEncryptAddAction:          TyEncryptAddAction,
 	}
 	//定义log的id和具体log类型及名称，填入具体自定义log类型
 	logMap = map[int64]*types.LogInfo{
@@ -69,6 +73,7 @@ var (
 		TyLinkStorageLog:         {Ty: reflect.TypeOf(Storage{}), Name: "LogLinkStorage"},
 		TyEncryptStorageLog:      {Ty: reflect.TypeOf(Storage{}), Name: "LogEncryptStorage"},
 		TyEncryptShareStorageLog: {Ty: reflect.TypeOf(Storage{}), Name: "LogEncryptShareStorage"},
+		TyEncryptAddLog:          {Ty: reflect.TypeOf(Storage{}), Name: "LogEncryptAdd"},
 	}
 )
 

plugin/dapp/storage/types/storage.pb.go

@@ -4,12 +4,9 @@
 package types
 
 import (
-	context "context"
 	fmt "fmt"
-	math "math"
-
 	proto "github.com/golang/protobuf/proto"
-	grpc "google.golang.org/grpc"
+	math "math"
 )
 
 // Reference imports to suppress errors if they are not otherwise used.
@@ -31,8 +28,9 @@ type Storage struct {
 	//	*Storage_LinkStorage
 	//	*Storage_EncryptStorage
 	//	*Storage_EncryptShareStorage
+	//	*Storage_EncryptAdd
 	Value                isStorage_Value `protobuf_oneof:"value"`
-	Ty                   int32           `protobuf:"varint,6,opt,name=ty,proto3" json:"ty,omitempty"`
+	Ty                   int32           `protobuf:"varint,7,opt,name=ty,proto3" json:"ty,omitempty"`
 	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
 	XXX_unrecognized     []byte          `json:"-"`
 	XXX_sizecache        int32           `json:"-"`
@@ -87,6 +85,10 @@ type Storage_EncryptShareStorage struct {
 	EncryptShareStorage *EncryptShareNotaryStorage `protobuf:"bytes,5,opt,name=encryptShareStorage,proto3,oneof"`
 }
 
+type Storage_EncryptAdd struct {
+	EncryptAdd *EncryptNotaryAdd `protobuf:"bytes,6,opt,name=encryptAdd,proto3,oneof"`
+}
+
 func (*Storage_ContentStorage) isStorage_Value() {}
 
 func (*Storage_HashStorage) isStorage_Value() {}
@@ -97,6 +99,8 @@ func (*Storage_EncryptStorage) isStorage_Value() {}
 
 func (*Storage_EncryptShareStorage) isStorage_Value() {}
 
+func (*Storage_EncryptAdd) isStorage_Value() {}
+
 func (m *Storage) GetValue() isStorage_Value {
 	if m != nil {
 		return m.Value
@@ -139,6 +143,13 @@ func (m *Storage) GetEncryptShareStorage() *EncryptShareNotaryStorage {
 	return nil
 }
 
+func (m *Storage) GetEncryptAdd() *EncryptNotaryAdd {
+	if x, ok := m.GetValue().(*Storage_EncryptAdd); ok {
+		return x.EncryptAdd
+	}
+	return nil
+}
+
 func (m *Storage) GetTy() int32 {
 	if m != nil {
 		return m.Ty
@@ -154,6 +165,7 @@ func (*Storage) XXX_OneofWrappers() []interface{} {
 		(*Storage_LinkStorage)(nil),
 		(*Storage_EncryptStorage)(nil),
 		(*Storage_EncryptShareStorage)(nil),
+		(*Storage_EncryptAdd)(nil),
 	}
 }
 
@@ -164,8 +176,9 @@ type StorageAction struct {
 	//	*StorageAction_LinkStorage
 	//	*StorageAction_EncryptStorage
 	//	*StorageAction_EncryptShareStorage
+	//	*StorageAction_EncryptAdd
 	Value                isStorageAction_Value `protobuf_oneof:"value"`
-	Ty                   int32                 `protobuf:"varint,6,opt,name=ty,proto3" json:"ty,omitempty"`
+	Ty                   int32                 `protobuf:"varint,7,opt,name=ty,proto3" json:"ty,omitempty"`
 	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
 	XXX_unrecognized     []byte                `json:"-"`
 	XXX_sizecache        int32                 `json:"-"`
@@ -220,6 +233,10 @@ type StorageAction_EncryptShareStorage struct {
 	EncryptShareStorage *EncryptShareNotaryStorage `protobuf:"bytes,5,opt,name=encryptShareStorage,proto3,oneof"`
 }
 
+type StorageAction_EncryptAdd struct {
+	EncryptAdd *EncryptNotaryAdd `protobuf:"bytes,6,opt,name=encryptAdd,proto3,oneof"`
+}
+
 func (*StorageAction_ContentStorage) isStorageAction_Value() {}
 
 func (*StorageAction_HashStorage) isStorageAction_Value() {}
@@ -230,6 +247,8 @@ func (*StorageAction_EncryptStorage) isStorageAction_Value() {}
 
 func (*StorageAction_EncryptShareStorage) isStorageAction_Value() {}
 
+func (*StorageAction_EncryptAdd) isStorageAction_Value() {}
+
 func (m *StorageAction) GetValue() isStorageAction_Value {
 	if m != nil {
 		return m.Value
@@ -272,6 +291,13 @@ func (m *StorageAction) GetEncryptShareStorage() *EncryptShareNotaryStorage {
 	return nil
 }
 
+func (m *StorageAction) GetEncryptAdd() *EncryptNotaryAdd {
+	if x, ok := m.GetValue().(*StorageAction_EncryptAdd); ok {
+		return x.EncryptAdd
+	}
+	return nil
+}
+
 func (m *StorageAction) GetTy() int32 {
 	if m != nil {
 		return m.Ty
@@ -287,6 +313,7 @@ func (*StorageAction) XXX_OneofWrappers() []interface{} {
 		(*StorageAction_LinkStorage)(nil),
 		(*StorageAction_EncryptStorage)(nil),
 		(*StorageAction_EncryptShareStorage)(nil),
+		(*StorageAction_EncryptAdd)(nil),
 	}
 }
 
@@ -639,6 +666,56 @@ func (m *EncryptShareNotaryStorage) GetValue() string {
 	return ""
 }
 
+// 加密存证数据运算
+type EncryptNotaryAdd struct {
+	//存证明文内容的hash值，推荐使用sha256哈希，限制256位得摘要值
+	ContentHash string `protobuf:"bytes,1,opt,name=contentHash,proto3" json:"contentHash,omitempty"`
+	//待操作数据
+	EncryptAdd           []byte   `protobuf:"bytes,2,opt,name=encryptAdd,proto3" json:"encryptAdd,omitempty"`
+	XXX_NoUnkeyedLiteral struct{} `json:"-"`
+	XXX_unrecognized     []byte   `json:"-"`
+	XXX_sizecache        int32    `json:"-"`
+}
+
+func (m *EncryptNotaryAdd) Reset()         { *m = EncryptNotaryAdd{} }
+func (m *EncryptNotaryAdd) String() string { return proto.CompactTextString(m) }
+func (*EncryptNotaryAdd) ProtoMessage()    {}
+func (*EncryptNotaryAdd) Descriptor() ([]byte, []int) {
+	return fileDescriptor_0d2c4ccf1453ffdb, []int{7}
+}
+
+func (m *EncryptNotaryAdd) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_EncryptNotaryAdd.Unmarshal(m, b)
+}
+func (m *EncryptNotaryAdd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_EncryptNotaryAdd.Marshal(b, m, deterministic)
+}
+func (m *EncryptNotaryAdd) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_EncryptNotaryAdd.Merge(m, src)
+}
+func (m *EncryptNotaryAdd) XXX_Size() int {
+	return xxx_messageInfo_EncryptNotaryAdd.Size(m)
+}
+func (m *EncryptNotaryAdd) XXX_DiscardUnknown() {
+	xxx_messageInfo_EncryptNotaryAdd.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_EncryptNotaryAdd proto.InternalMessageInfo
+
+func (m *EncryptNotaryAdd) GetContentHash() string {
+	if m != nil {
+		return m.ContentHash
+	}
+	return ""
+}
+
+func (m *EncryptNotaryAdd) GetEncryptAdd() []byte {
+	if m != nil {
+		return m.EncryptAdd
+	}
+	return nil
+}
+
 //根据txhash去状态数据库中查询存储内容
 type QueryStorage struct {
 	TxHash               string   `protobuf:"bytes,1,opt,name=txHash,proto3" json:"txHash,omitempty"`
@@ -651,7 +728,7 @@ func (m *QueryStorage) Reset()         { *m = QueryStorage{} }
 func (m *QueryStorage) String() string { return proto.CompactTextString(m) }
 func (*QueryStorage) ProtoMessage()    {}
 func (*QueryStorage) Descriptor() ([]byte, []int) {
-	return fileDescriptor_0d2c4ccf1453ffdb, []int{7}
+	return fileDescriptor_0d2c4ccf1453ffdb, []int{8}
 }
 
 func (m *QueryStorage) XXX_Unmarshal(b []byte) error {
@@ -691,7 +768,7 @@ func (m *BatchQueryStorage) Reset()         { *m = BatchQueryStorage{} }
 func (m *BatchQueryStorage) String() string { return proto.CompactTextString(m) }
 func (*BatchQueryStorage) ProtoMessage()    {}
 func (*BatchQueryStorage) Descriptor() ([]byte, []int) {
-	return fileDescriptor_0d2c4ccf1453ffdb, []int{8}
+	return fileDescriptor_0d2c4ccf1453ffdb, []int{9}
 }
 
 func (m *BatchQueryStorage) XXX_Unmarshal(b []byte) error {
@@ -730,7 +807,7 @@ func (m *BatchReplyStorage) Reset()         { *m = BatchReplyStorage{} }
 func (m *BatchReplyStorage) String() string { return proto.CompactTextString(m) }
 func (*BatchReplyStorage) ProtoMessage()    {}
 func (*BatchReplyStorage) Descriptor() ([]byte, []int) {
-	return fileDescriptor_0d2c4ccf1453ffdb, []int{9}
+	return fileDescriptor_0d2c4ccf1453ffdb, []int{10}
 }
 
 func (m *BatchReplyStorage) XXX_Unmarshal(b []byte) error {
@@ -768,7 +845,7 @@ func (m *ReceiptStorage) Reset()         { *m = ReceiptStorage{} }
 func (m *ReceiptStorage) String() string { return proto.CompactTextString(m) }
 func (*ReceiptStorage) ProtoMessage()    {}
 func (*ReceiptStorage) Descriptor() ([]byte, []int) {
-	return fileDescriptor_0d2c4ccf1453ffdb, []int{10}
+	return fileDescriptor_0d2c4ccf1453ffdb, []int{11}
 }
 
 func (m *ReceiptStorage) XXX_Unmarshal(b []byte) error {
@@ -797,89 +874,49 @@ func init() {
 	proto.RegisterType((*LinkNotaryStorage)(nil), "types.LinkNotaryStorage")
 	proto.RegisterType((*EncryptNotaryStorage)(nil), "types.EncryptNotaryStorage")
 	proto.RegisterType((*EncryptShareNotaryStorage)(nil), "types.EncryptShareNotaryStorage")
+	proto.RegisterType((*EncryptNotaryAdd)(nil), "types.EncryptNotaryAdd")
 	proto.RegisterType((*QueryStorage)(nil), "types.QueryStorage")
 	proto.RegisterType((*BatchQueryStorage)(nil), "types.BatchQueryStorage")
 	proto.RegisterType((*BatchReplyStorage)(nil), "types.BatchReplyStorage")
 	proto.RegisterType((*ReceiptStorage)(nil), "types.ReceiptStorage")
 }
 
-func init() {
-	proto.RegisterFile("storage.proto", fileDescriptor_0d2c4ccf1453ffdb)
-}
+func init() { proto.RegisterFile("storage.proto", fileDescriptor_0d2c4ccf1453ffdb) }
 
 var fileDescriptor_0d2c4ccf1453ffdb = []byte{
-	// 488 bytes of a gzipped FileDescriptorProto
-	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xec, 0x55, 0xc1, 0x8a, 0xd4, 0x40,
-	0x10, 0x35, 0xc9, 0x64, 0x62, 0x2a, 0xb3, 0x61, 0xb7, 0x5d, 0x97, 0x88, 0x82, 0x21, 0x87, 0x65,
-	0x10, 0x9c, 0xc3, 0x78, 0x15, 0xd4, 0x95, 0x85, 0x11, 0x45, 0xb1, 0xd7, 0x1f, 0xc8, 0x86, 0xc6,
-	0x0c, 0x13, 0xba, 0x43, 0xd2, 0x23, 0xe6, 0x17, 0x3c, 0xf9, 0x05, 0xde, 0xfc, 0x4f, 0x49, 0xa7,
-	0xba, 0x37, 0x99, 0x64, 0xc1, 0x83, 0xe0, 0x65, 0x6f, 0x5d, 0x5d, 0xaf, 0xde, 0x7b, 0x55, 0x95,
-	0xd0, 0x70, 0x54, 0x4b, 0x51, 0xa5, 0x5f, 0xd9, 0xaa, 0xac, 0x84, 0x14, 0xc4, 0x95, 0x4d, 0xc9,
-	0xea, 0xe4, 0x87, 0x03, 0xde, 0x55, 0x97, 0x20, 0xef, 0x20, 0xcc, 0x04, 0x97, 0x8c, 0x4b, 0xbc,
-	0x89, 0xac, 0xd8, 0x5a, 0x06, 0xeb, 0xa7, 0x2b, 0x85, 0x5d, 0xbd, 0xed, 0x92, 0x9f, 0x78, 0xd1,
-	0x7c, 0x14, 0x32, 0xad, 0x1a, 0x84, 0x6d, 0xee, 0xd1, 0x83, 0x42, 0xf2, 0x1a, 0x82, 0x3c, 0xad,
-	0x73, 0xcd, 0x63, 0x2b, 0x9e, 0x27, 0xc8, 0xb3, 0x49, 0xeb, 0x7c, 0x8a, 0xa4, 0x5f, 0x42, 0x5e,
-	0x42, 0x50, 0x6c, 0xf9, 0x4e, 0x33, 0x38, 0x8a, 0x21, 0x42, 0x86, 0x0f, 0x5b, 0xbe, 0x1b, 0x55,
-	0xf7, 0xe0, 0xe4, 0x12, 0x42, 0xc6, 0xb3, 0xaa, 0x29, 0x4d, 0x2b, 0x33, 0x45, 0xf0, 0x18, 0x09,
-	0x2e, 0xbb, 0xe4, 0xa8, 0x8d, 0x61, 0x11, 0xf9, 0x02, 0x0f, 0xf4, 0x4d, 0x9e, 0x56, 0x4c, 0x73,
-	0xb9, 0x8a, 0x2b, 0x1e, 0x72, 0x29, 0xc4, 0x21, 0xe1, 0x54, 0x39, 0x09, 0xc1, 0x96, 0x4d, 0x34,
-	0x8f, 0xad, 0xa5, 0x4b, 0x6d, 0xd9, 0x5c, 0x78, 0xe0, 0x7e, 0x4b, 0x8b, 0x3d, 0x4b, 0x7e, 0x3a,
-	0x70, 0x84, 0xa0, 0x37, 0x99, 0xdc, 0x0a, 0x7e, 0xb7, 0x92, 0xff, 0xbd, 0x92, 0x02, 0xa2, 0xdb,
-	0x66, 0x4c, 0x22, 0xf0, 0x70, 0xc6, 0x6a, 0x2b, 0x0b, 0xaa, 0x43, 0x72, 0x0c, 0xce, 0x8e, 0x35,
-	0x6a, 0xc6, 0x3e, 0x6d, 0x8f, 0xad, 0x80, 0x28, 0xd5, 0xc8, 0x5c, 0x6a, 0x8b, 0x92, 0x9c, 0xa2,
-	0x80, 0x1a, 0x82, 0x4f, 0x51, 0xed, 0x0a, 0x1e, 0x4e, 0x6e, 0x82, 0x10, 0x98, 0xb5, 0x9b, 0x40,
-	0x1d, 0x75, 0x9e, 0x10, 0x31, 0xa4, 0x4e, 0x9f, 0x34, 0x83, 0x93, 0xd1, 0x72, 0x5a, 0xc2, 0x76,
-	0x39, 0x9a, 0xb0, 0x3d, 0x1b, 0x11, 0x7b, 0x2c, 0xe2, 0x4c, 0x88, 0x0c, 0x9c, 0xff, 0xb2, 0xe0,
-	0x74, 0x6a, 0x83, 0x24, 0x86, 0x00, 0xa7, 0xb2, 0xb9, 0x69, 0xa0, 0x7f, 0x45, 0xce, 0xcd, 0x87,
-	0x81, 0x93, 0x46, 0x03, 0x07, 0xb7, 0xad, 0x30, 0x17, 0x3c, 0xeb, 0xba, 0x5b, 0xd0, 0x2e, 0xd0,
-	0x06, 0x67, 0x13, 0x06, 0xdd, 0xbe, 0xc1, 0xdf, 0x16, 0x3c, 0xba, 0xf5, 0xb3, 0xf8, 0x87, 0x2e,
-	0xcf, 0x60, 0x5e, 0xee, 0xaf, 0xdf, 0xe3, 0xcc, 0x16, 0x14, 0xa3, 0xbf, 0xf6, 0x79, 0x0e, 0x8b,
-	0xcf, 0x7b, 0x76, 0xe3, 0xec, 0x0c, 0xe6, 0xf2, 0xbb, 0x31, 0xe5, 0x53, 0x8c, 0x92, 0xe7, 0x70,
-	0x72, 0x91, 0xca, 0x2c, 0x1f, 0x80, 0x23, 0xf0, 0xba, 0x74, 0x1d, 0x59, 0xb1, 0xb3, 0xf4, 0xa9,
-	0x0e, 0x93, 0x57, 0x08, 0xa7, 0xac, 0x2c, 0x0c, 0xfc, 0x19, 0xdc, 0xc7, 0x47, 0xa1, 0xc3, 0x07,
-	0xeb, 0x10, 0x7f, 0x20, 0x44, 0x50, 0x93, 0x4f, 0x8e, 0x21, 0xa4, 0x2c, 0x63, 0x5b, 0xf3, 0x27,
-	0xae, 0x7d, 0xf0, 0x30, 0x7b, 0x3d, 0x57, 0x6f, 0xca, 0x8b, 0x3f, 0x01, 0x00, 0x00, 0xff, 0xff,
-	0x38, 0xc7, 0xa7, 0x39, 0x64, 0x06, 0x00, 0x00,
-}
-
-// Reference imports to suppress errors if they are not otherwise used.
-var _ context.Context
-var _ grpc.ClientConnInterface
-
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the grpc package it is being compiled against.
-const _ = grpc.SupportPackageIsVersion6
-
-// StorageClient is the client API for Storage service.
-//
-// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
-type StorageClient interface {
-}
-
-type storageClient struct {
-	cc grpc.ClientConnInterface
-}
-
-func NewStorageClient(cc grpc.ClientConnInterface) StorageClient {
-	return &storageClient{cc}
-}
-
-// StorageServer is the server API for Storage service.
-type StorageServer interface {
-}
-
-// UnimplementedStorageServer can be embedded to have forward compatible implementations.
-type UnimplementedStorageServer struct {
-}
-
-func RegisterStorageServer(s *grpc.Server, srv StorageServer) {
-	s.RegisterService(&_Storage_serviceDesc, srv)
-}
-
-var _Storage_serviceDesc = grpc.ServiceDesc{
-	ServiceName: "types.storage",
-	HandlerType: (*StorageServer)(nil),
-	Methods:     []grpc.MethodDesc{},
-	Streams:     []grpc.StreamDesc{},
-	Metadata:    "storage.proto",
+	// 530 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xec, 0x95, 0xd1, 0x8a, 0xd3, 0x4c,
+	0x14, 0xc7, 0x37, 0x49, 0xd3, 0x7c, 0x39, 0xe9, 0x86, 0xee, 0x7c, 0xeb, 0x1a, 0x51, 0x34, 0xe4,
+	0x62, 0x29, 0x82, 0xbd, 0xa8, 0x57, 0x82, 0xa0, 0x5d, 0x59, 0xa8, 0x28, 0x8a, 0xb3, 0xfb, 0x02,
+	0xd9, 0x74, 0x30, 0xa5, 0x61, 0x26, 0x24, 0x53, 0x31, 0x2f, 0xe3, 0x9d, 0x8f, 0xe2, 0x95, 0x2f,
+	0x25, 0x99, 0x9c, 0x64, 0x93, 0x76, 0x16, 0xbc, 0xf0, 0x46, 0xf0, 0x6e, 0xe6, 0x9c, 0x33, 0xbf,
+	0xf3, 0x9f, 0xf3, 0x9f, 0x36, 0x70, 0x5c, 0x4a, 0x51, 0xc4, 0x9f, 0xd9, 0x3c, 0x2f, 0x84, 0x14,
+	0xc4, 0x96, 0x55, 0xce, 0xca, 0xe8, 0x87, 0x05, 0xce, 0x55, 0x93, 0x20, 0x6f, 0xc1, 0x4f, 0x04,
+	0x97, 0x8c, 0x4b, 0x8c, 0x04, 0x46, 0x68, 0xcc, 0xbc, 0xc5, 0x93, 0xb9, 0xaa, 0x9d, 0xbf, 0x69,
+	0x92, 0x1f, 0x79, 0x56, 0x7d, 0x10, 0x32, 0x2e, 0x2a, 0x2c, 0x5b, 0x1d, 0xd1, 0xbd, 0x83, 0xe4,
+	0x35, 0x78, 0x69, 0x5c, 0xa6, 0x2d, 0xc7, 0x54, 0x9c, 0x47, 0xc8, 0x59, 0xc5, 0x65, 0xaa, 0x83,
+	0xf4, 0x8f, 0x90, 0x97, 0xe0, 0x65, 0x1b, 0xbe, 0x6d, 0x09, 0x96, 0x22, 0x04, 0x48, 0x78, 0xbf,
+	0xe1, 0xdb, 0x83, 0xd3, 0xbd, 0x72, 0x72, 0x09, 0x3e, 0xe3, 0x49, 0x51, 0xe5, 0xdd, 0x55, 0x46,
+	0x0a, 0xf0, 0x10, 0x01, 0x97, 0x4d, 0xf2, 0xe0, 0x1a, 0xc3, 0x43, 0xe4, 0x1a, 0xfe, 0x6f, 0x23,
+	0x69, 0x5c, 0xb0, 0x96, 0x65, 0x2b, 0x56, 0x38, 0x64, 0xa9, 0x8a, 0x7d, 0xa0, 0xee, 0x38, 0x79,
+	0x01, 0x80, 0xe1, 0xe5, 0x7a, 0x1d, 0x8c, 0x15, 0xec, 0xbe, 0x4e, 0xd8, 0x72, 0xbd, 0x5e, 0x1d,
+	0xd1, 0x5e, 0x31, 0xf1, 0xc1, 0x94, 0x55, 0xe0, 0x84, 0xc6, 0xcc, 0xa6, 0xa6, 0xac, 0x2e, 0x1c,
+	0xb0, 0xbf, 0xc4, 0xd9, 0x8e, 0x45, 0x3f, 0x2d, 0x38, 0x46, 0xfe, 0x32, 0x91, 0x1b, 0xc1, 0xff,
+	0xb9, 0xf9, 0x17, 0xbb, 0x99, 0x41, 0x70, 0x97, 0x3d, 0x24, 0x00, 0x07, 0xed, 0x51, 0x86, 0x4e,
+	0x68, 0xbb, 0x25, 0x53, 0xb0, 0xb6, 0xac, 0x52, 0xf6, 0xb8, 0xb4, 0x5e, 0xd6, 0x0d, 0x44, 0xae,
+	0xa6, 0x6d, 0x53, 0x53, 0xe4, 0xe4, 0x14, 0x1b, 0xa8, 0xf9, 0xb9, 0x14, 0xbb, 0x5d, 0xc1, 0x3d,
+	0xad, 0x89, 0x84, 0xc0, 0xa8, 0x36, 0x11, 0xfb, 0xa8, 0xb5, 0xa6, 0x49, 0x07, 0xb5, 0xfa, 0xd0,
+	0x04, 0x4e, 0x0e, 0x7c, 0xad, 0x81, 0xb5, 0xaf, 0x2d, 0xb0, 0x5e, 0x77, 0x4d, 0xcc, 0xc3, 0x26,
+	0x96, 0xa6, 0xc9, 0x40, 0xf9, 0x37, 0x03, 0x4e, 0x75, 0xe6, 0x93, 0x10, 0x3c, 0x9c, 0xca, 0xea,
+	0xf6, 0x02, 0xfd, 0x10, 0x39, 0xef, 0xde, 0x14, 0x4e, 0x1a, 0x05, 0xec, 0x45, 0xeb, 0xc6, 0x5c,
+	0xf0, 0xa4, 0xb9, 0xdd, 0x84, 0x36, 0x9b, 0x56, 0xe0, 0x48, 0x23, 0xd0, 0xee, 0x0b, 0xfc, 0x6e,
+	0xc0, 0x83, 0x3b, 0x5f, 0xd4, 0x1f, 0x54, 0x79, 0x06, 0xe3, 0x7c, 0x77, 0xf3, 0x0e, 0x67, 0x36,
+	0xa1, 0xb8, 0xfb, 0x6d, 0x9d, 0xd7, 0x30, 0xdd, 0x7f, 0xab, 0x3a, 0x75, 0xee, 0x50, 0xdd, 0xe3,
+	0xc1, 0xd3, 0x6f, 0x94, 0xf5, 0x22, 0xd1, 0x39, 0x4c, 0x3e, 0xed, 0xd8, 0xed, 0x7d, 0xcf, 0x60,
+	0x2c, 0xbf, 0xf6, 0x60, 0xb8, 0x8b, 0x9e, 0xc1, 0xc9, 0x45, 0x2c, 0x93, 0x74, 0x50, 0x1c, 0x80,
+	0xd3, 0xa4, 0xcb, 0xc0, 0x08, 0xad, 0x99, 0x4b, 0xdb, 0x6d, 0xf4, 0x0a, 0xcb, 0x29, 0xcb, 0xb3,
+	0xae, 0xfc, 0x29, 0xfc, 0x87, 0x1f, 0xb8, 0xa6, 0xde, 0x5b, 0xf8, 0xf8, 0x23, 0xc4, 0x0a, 0xda,
+	0xe5, 0xa3, 0x29, 0xf8, 0x94, 0x25, 0x6c, 0xd3, 0xfd, 0x35, 0x2c, 0x5c, 0x70, 0x30, 0x7b, 0x33,
+	0x56, 0xdf, 0xc7, 0xe7, 0xbf, 0x02, 0x00, 0x00, 0xff, 0xff, 0x5c, 0x62, 0x13, 0xfb, 0x30, 0x07,
+	0x00, 0x00,
 }