Endorse TX store alternative implementation

alexandrosfilios · alexandrosfilios · commit 767d9feffd3c · 2025-01-21T15:29:14.000+01:00
Signed-off-by: Alexandros Filios &lt;alexandros.filios@ibm.com&gt;
diff --git a/platform/fabric/driver/kvs.go b/platform/fabric/driver/kvs.go
@@ -6,14 +6,22 @@ SPDX-License-Identifier: Apache-2.0
 
 package driver
 
-import "github.com/hyperledger-labs/fabric-smart-client/platform/common/driver"
+import (
+	"fmt"
+
+	"github.com/hyperledger-labs/fabric-smart-client/platform/common/driver"
+)
 
 type Key struct {
-	Network string
-	Channel string
+	Network driver.Network
+	Channel driver.Channel
 	TxID    driver.TxID
 }
 
+func (k Key) UniqueKey() string {
+	return fmt.Sprintf("%s.%s.%s", k.Network, k.Channel, k.TxID)
+}
+
 type MetadataStore interface {
 	driver.MetadataStore[Key, TransientMap]
 }
diff --git a/platform/fabric/sdk/dig/generic/providers.go b/platform/fabric/sdk/dig/generic/providers.go
@@ -10,6 +10,7 @@ import (
 	"github.com/hyperledger-labs/fabric-smart-client/pkg/utils/errors"
 	committer2 "github.com/hyperledger-labs/fabric-smart-client/platform/common/core/generic/committer"
 	driver2 "github.com/hyperledger-labs/fabric-smart-client/platform/common/driver"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/common/utils"
 	digutils "github.com/hyperledger-labs/fabric-smart-client/platform/common/utils/dig"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/core"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/core/generic"
@@ -23,8 +24,11 @@ import (
 	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/core/generic/rwset"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/core/generic/vault"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/driver"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/services"
 	vdriver "github.com/hyperledger-labs/fabric-smart-client/platform/view/driver"
+	sdk "github.com/hyperledger-labs/fabric-smart-client/platform/view/sdk/dig"
 	dbdriver "github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db/driver"
+	mem "github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db/driver/memory"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/events"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/hash"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/kvs"
@@ -176,3 +180,21 @@ func NewChannelProvider(in struct {
 		[]common.HeaderType{common.HeaderType_ENDORSER_TRANSACTION},
 	)
 }
+
+func NewEndorseTxStore(in struct {
+	dig.In
+	KVS     *kvs.KVS
+	Config  driver.ConfigService
+	Drivers []dbdriver.NamedDriver `group:"db-drivers"`
+}) (driver.EndorseTxStore, error) {
+	driverName := driver2.PersistenceType(utils.DefaultString(in.Config.GetString("fsc.endorsetx.persistence.type"), string(mem.MemoryPersistence)))
+	if sdk.UnsupportedStores.Contains(driverName) {
+		return services.NewKVSBasedEndorseTxStore(in.KVS), nil
+	}
+	for _, d := range in.Drivers {
+		if d.Name == driverName {
+			return services.NewDBBasedEndorseTxStore(d.Driver, "_default", in.Config)
+		}
+	}
+	return nil, errors.New("driver not found")
+}
diff --git a/platform/fabric/sdk/dig/sdk.go b/platform/fabric/sdk/dig/sdk.go
@@ -73,7 +73,7 @@ func (p *SDK) Install() error {
 		p.Container().Provide(generic2.NewEndorserTransactionHandlerProvider),
 		p.Container().Provide(committer2.NewSerialDependencyResolver, dig.As(new(committer2.DependencyResolver))),
 		p.Container().Provide(services.NewKVSBasedMetadataStore, dig.As(new(driver.MetadataStore))),
-		p.Container().Provide(services.NewKVSBasedEnvelopeStore, dig.As(new(driver.EnvelopeStore))),
+		p.Container().Provide(generic2.NewEndorseTxStore, dig.As(new(driver.EnvelopeStore))),
 		p.Container().Provide(services.NewKVSBasedEndorseTxStore, dig.As(new(driver.EndorseTxStore))),
 	)
 	if err != nil {
diff --git a/platform/fabric/services/store.go b/platform/fabric/services/store.go
@@ -8,6 +8,8 @@ package services
 
 import (
 	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/driver"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db"
+	driver2 "github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db/driver"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/kvs"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/storage/endorsetx"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/storage/envelope"
@@ -25,8 +27,13 @@ func NewKVSBasedEnvelopeStore(kvss *kvs.KVS) driver.EnvelopeStore {
 func NewKVSBasedEndorseTxStore(kvss *kvs.KVS) driver.EndorseTxStore {
 	return endorsetx.NewKVSBased[driver.Key](kvss, keyMapper("etx"))
 }
+
 func keyMapper(prefix string) kvs.KeyMapper[driver.Key] {
 	return func(k driver.Key) (string, error) {
 		return kvs.CreateCompositeKey(prefix, []string{k.Channel, k.Network, k.TxID})
 	}
 }
+
+func NewDBBasedEndorseTxStore(dbDriver driver2.Driver, namespace string, cp db.Config) (driver.EndorseTxStore, error) {
+	return endorsetx.NewWithConfig[driver.Key](dbDriver, namespace, cp)
+}
diff --git a/platform/orion/driver/kvs.go b/platform/orion/driver/kvs.go
@@ -6,13 +6,21 @@ SPDX-License-Identifier: Apache-2.0
 
 package driver
 
-import "github.com/hyperledger-labs/fabric-smart-client/platform/common/driver"
+import (
+	"fmt"
+
+	"github.com/hyperledger-labs/fabric-smart-client/platform/common/driver"
+)
 
 type Key struct {
-	Network string
+	Network driver.Network
 	TxID    driver.TxID
 }
 
+func (k Key) UniqueKey() string {
+	return fmt.Sprintf("%s.%s", k.Network, k.TxID)
+}
+
 type MetadataStore interface {
 	driver.MetadataStore[Key, TransientMap]
 }
diff --git a/platform/orion/sdk/dig/providers.go b/platform/orion/sdk/dig/providers.go
@@ -0,0 +1,39 @@
+/*
+Copyright IBM Corp. All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package orion
+
+import (
+	driver2 "github.com/hyperledger-labs/fabric-smart-client/platform/common/driver"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/common/utils"
+	driver3 "github.com/hyperledger-labs/fabric-smart-client/platform/orion/driver"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/orion/services"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/view/driver"
+	sdk "github.com/hyperledger-labs/fabric-smart-client/platform/view/sdk/dig"
+	dbdriver "github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db/driver"
+	mem "github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db/driver/memory"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/kvs"
+	"github.com/pkg/errors"
+	"go.uber.org/dig"
+)
+
+func NewEndorseTxStore(in struct {
+	dig.In
+	KVS     *kvs.KVS
+	Config  driver.ConfigService
+	Drivers []dbdriver.NamedDriver `group:"db-drivers"`
+}) (driver3.EndorseTxStore, error) {
+	driverName := driver2.PersistenceType(utils.DefaultString(in.Config.GetString("fsc.endorsetx.persistence.type"), string(mem.MemoryPersistence)))
+	if sdk.UnsupportedStores.Contains(driverName) {
+		return services.NewKVSBasedEndorseTxStore(in.KVS), nil
+	}
+	for _, d := range in.Drivers {
+		if d.Name == driverName {
+			return services.NewDBBasedEndorseTxStore(d.Driver, "_default", in.Config)
+		}
+	}
+	return nil, errors.New("driver not found")
+}
diff --git a/platform/orion/sdk/dig/sdk.go b/platform/orion/sdk/dig/sdk.go
@@ -79,7 +79,7 @@ func (p *SDK) Install() error {
 		p.Container().Provide(digutils.Identity[*core.ONSProvider](), dig.As(new(driver2.OrionNetworkServiceProvider))),
 		p.Container().Provide(finality2.NewHandler, dig.Group("finality-handlers")),
 		p.Container().Provide(services.NewKVSBasedMetadataStore, dig.As(new(driver2.MetadataStore))),
-		p.Container().Provide(services.NewKVSBasedEndorseTxStore, dig.As(new(driver2.EndorseTxStore))),
+		p.Container().Provide(NewEndorseTxStore, dig.As(new(driver2.EndorseTxStore))),
 		p.Container().Provide(services.NewKVSBasedEnvelopeStore, dig.As(new(driver2.EnvelopeStore))),
 	)
 	if err != nil {
diff --git a/platform/orion/services/store.go b/platform/orion/services/store.go
@@ -8,6 +8,8 @@ package services
 
 import (
 	"github.com/hyperledger-labs/fabric-smart-client/platform/orion/driver"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db"
+	driver2 "github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db/driver"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/kvs"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/storage/endorsetx"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/storage/envelope"
@@ -29,3 +31,7 @@ func NewKVSBasedEndorseTxStore(kvss *kvs.KVS) driver.EndorseTxStore {
 func keyMapper(prefix string) kvs.KeyMapper[driver.Key] {
 	return func(k driver.Key) (string, error) { return kvs.CreateCompositeKey(prefix, []string{k.Network, k.TxID}) }
 }
+
+func NewDBBasedEndorseTxStore(dbDriver driver2.Driver, namespace string, cp db.Config) (driver.EndorseTxStore, error) {
+	return endorsetx.NewWithConfig[driver.Key](dbDriver, namespace, cp)
+}
diff --git a/platform/view/sdk/dig/providers.go b/platform/view/sdk/dig/providers.go
@@ -38,7 +38,7 @@ func newKVS(in struct {
 	return nil, errors.New("driver not found")
 }
 
-var unsupportedStores = collections.NewSet(badger.FilePersistence, badger.BadgerPersistence)
+var UnsupportedStores = collections.NewSet(badger.FilePersistence, badger.BadgerPersistence)
 
 func newBindingStore(in struct {
 	dig.In
@@ -47,7 +47,7 @@ func newBindingStore(in struct {
 	Drivers []driver2.NamedDriver `group:"db-drivers"`
 }) (driver4.BindingStore, error) {
 	driverName := driver4.PersistenceType(utils.DefaultString(in.Config.GetString("fsc.binding.persistence.type"), string(mem.MemoryPersistence)))
-	if unsupportedStores.Contains(driverName) {
+	if UnsupportedStores.Contains(driverName) {
 		return binding.NewKVSBased(in.KVS), nil
 	}
 	for _, d := range in.Drivers {
@@ -65,7 +65,7 @@ func newSignerInfoStore(in struct {
 	Drivers []driver2.NamedDriver `group:"db-drivers"`
 }) (driver4.SignerInfoStore, error) {
 	driverName := driver4.PersistenceType(utils.DefaultString(in.Config.GetString("fsc.signerinfo.persistence.type"), string(mem.MemoryPersistence)))
-	if unsupportedStores.Contains(driverName) {
+	if UnsupportedStores.Contains(driverName) {
 		return signerinfo.NewKVSBased(in.KVS), nil
 	}
 	for _, d := range in.Drivers {
@@ -83,7 +83,7 @@ func newAuditInfoStore(in struct {
 	Drivers []driver2.NamedDriver `group:"db-drivers"`
 }) (driver4.AuditInfoStore, error) {
 	driverName := driver4.PersistenceType(utils.DefaultString(in.Config.GetString("fsc.auditinfo.persistence.type"), string(mem.MemoryPersistence)))
-	if unsupportedStores.Contains(driverName) {
+	if UnsupportedStores.Contains(driverName) {
 		return auditinfo.NewKVSBased(in.KVS), nil
 	}
 	for _, d := range in.Drivers {
diff --git a/platform/view/services/db/driver/badger/driver.go b/platform/view/services/db/driver/badger/driver.go
@@ -76,3 +76,7 @@ func (d *Driver) NewSignerInfo(string, driver.Config) (driver.SignerInfoPersiste
 func (d *Driver) NewAuditInfo(string, driver.Config) (driver.AuditInfoPersistence, error) {
 	panic("not implemented")
 }
+
+func (d *Driver) NewEndorseTx(string, driver.Config) (driver.EndorseTxPersistence, error) {
+	panic("not implemented")
+}
diff --git a/platform/view/services/db/driver/driver.go b/platform/view/services/db/driver/driver.go
@@ -51,6 +51,8 @@ type SignerInfoPersistence = driver.SignerInfoStore
 
 type AuditInfoPersistence = driver.AuditInfoStore
 
+type EndorseTxPersistence = driver.EndorseTxStore[string]
+
 type BasePersistence[V any, R any] interface {
 	// SetState sets the given value for the given namespace, key, and version
 	SetState(namespace driver.Namespace, key driver.PKey, value V) error
@@ -158,6 +160,8 @@ type Driver interface {
 	NewSignerInfo(string, Config) (SignerInfoPersistence, error)
 	// NewAuditInfo returns a new AuditInfoPersistence for the passed data source and config
 	NewAuditInfo(string, Config) (AuditInfoPersistence, error)
+	// NewEndorseTx returns a new EndorseTxPersistence for the passed data source and config
+	NewEndorseTx(string, Config) (EndorseTxPersistence, error)
 }
 
 type (
diff --git a/platform/view/services/db/driver/memory/driver.go b/platform/view/services/db/driver/memory/driver.go
@@ -72,3 +72,7 @@ func (d *Driver) NewSignerInfo(string, driver.Config) (driver.SignerInfoPersiste
 func (d *Driver) NewAuditInfo(string, driver.Config) (driver.AuditInfoPersistence, error) {
 	return sql.NewPersistenceWithOpts(utils.GenerateUUIDOnlyLetters(), opts, sql.AuditInfoConstructors)
 }
+
+func (d *Driver) NewEndorseTx(string, driver.Config) (driver.EndorseTxPersistence, error) {
+	return sql.NewPersistenceWithOpts(utils.GenerateUUIDOnlyLetters(), opts, sql.EndorseTxConstructors)
+}
diff --git a/platform/view/services/db/driver/sql/common/endorsetx.go b/platform/view/services/db/driver/sql/common/endorsetx.go
@@ -0,0 +1,69 @@
+/*
+Copyright IBM Corp. All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package common
+
+import (
+	"database/sql"
+	"fmt"
+
+	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db/driver"
+	"github.com/pkg/errors"
+)
+
+func NewEndorseTxPersistence(writeDB *sql.DB, readDB *sql.DB, table string, errorWrapper driver.SQLErrorWrapper, ci Interpreter) *EndorseTxPersistence {
+	return &EndorseTxPersistence{
+		table:        table,
+		errorWrapper: errorWrapper,
+		readDB:       readDB,
+		writeDB:      writeDB,
+		ci:           ci,
+	}
+}
+
+type EndorseTxPersistence struct {
+	table        string
+	errorWrapper driver.SQLErrorWrapper
+	readDB       *sql.DB
+	writeDB      *sql.DB
+	ci           Interpreter
+}
+
+func (db *EndorseTxPersistence) GetEndorseTx(key string) ([]byte, error) {
+	where, params := Where(db.ci.Cmp("key", "=", key))
+	query := fmt.Sprintf("SELECT data FROM %s %s", db.table, where)
+	logger.Debug(query, params)
+
+	return QueryUnique[[]byte](db.readDB, query, params...)
+}
+
+func (db *EndorseTxPersistence) ExistsEndorseTx(key string) (bool, error) {
+	data, err := db.GetEndorseTx(key)
+	return len(data) > 0, err
+}
+
+func (db *EndorseTxPersistence) PutEndorseTx(key string, etx []byte) error {
+	query := fmt.Sprintf("INSERT INTO %s (key, data) VALUES ($1, $2)", db.table)
+	logger.Debugf(query, key, len(etx))
+	_, err := db.writeDB.Exec(query, key, etx)
+	if err != nil && errors.Is(db.errorWrapper.WrapError(err), driver.UniqueKeyViolation) {
+		logger.Warnf("Endorse TX [%s] already in db. Skipping...", key)
+		return nil
+	}
+	if err != nil {
+		return errors.Wrapf(err, "failed executing query [%s]", query)
+	}
+	logger.Debugf("Endorse TX [%s] registered", key)
+	return nil
+}
+
+func (db *EndorseTxPersistence) CreateSchema() error {
+	return InitSchema(db.writeDB, fmt.Sprintf(`
+	CREATE TABLE IF NOT EXISTS %s (
+		key TEXT NOT NULL PRIMARY KEY,
+		data BYTEA NOT NULL
+	);`, db.table))
+}
diff --git a/platform/view/services/db/driver/sql/driver.go b/platform/view/services/db/driver/sql/driver.go
@@ -78,6 +78,11 @@ type auditInfoPersistence interface {
 	dbObject
 }
 
+type endorseTxPersistence interface {
+	driver.EndorseTxPersistence
+	dbObject
+}
+
 var UnversionedConstructors = map[common.SQLDriverType]persistenceConstructor[unversionedPersistence]{
 	Postgres: func(o common.Opts, t string) (unversionedPersistence, error) { return postgres.NewUnversioned(o, t) },
 	SQLite:   func(o common.Opts, t string) (unversionedPersistence, error) { return sqlite.NewUnversioned(o, t) },
@@ -106,6 +111,15 @@ var AuditInfoConstructors = map[common.SQLDriverType]persistenceConstructor[audi
 	},
 }
 
+var EndorseTxConstructors = map[common.SQLDriverType]persistenceConstructor[endorseTxPersistence]{
+	Postgres: func(o common.Opts, t string) (endorseTxPersistence, error) {
+		return postgres.NewEndorseTxPersistence(o, t)
+	},
+	SQLite: func(o common.Opts, t string) (endorseTxPersistence, error) {
+		return sqlite.NewEndorseTxPersistence(o, t)
+	},
+}
+
 func (d *Driver) NewVersioned(dataSourceName string, config driver.Config) (driver.VersionedPersistence, error) {
 	return d.NewTransactionalVersioned(dataSourceName, config)
 }
@@ -138,6 +152,10 @@ func (d *Driver) NewAuditInfo(dataSourceName string, config driver.Config) (driv
 	return newPersistence(dataSourceName, config, AuditInfoConstructors)
 }
 
+func (d *Driver) NewEndorseTx(dataSourceName string, config driver.Config) (driver.EndorseTxPersistence, error) {
+	return newPersistence(dataSourceName, config, EndorseTxConstructors)
+}
+
 func newPersistence[V dbObject](dataSourceName string, config driver.Config, constructors map[common.SQLDriverType]persistenceConstructor[V]) (V, error) {
 	logger.Infof("opening new transactional database %s", dataSourceName)
 	opts, err := getOps(config)
diff --git a/platform/view/services/db/driver/sql/postgres/endorsetx.go b/platform/view/services/db/driver/sql/postgres/endorsetx.go
@@ -0,0 +1,30 @@
+/*
+Copyright IBM Corp. All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package postgres
+
+import (
+	"database/sql"
+	"fmt"
+
+	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db/driver/sql/common"
+)
+
+type EndorseTxPersistence struct {
+	*common.EndorseTxPersistence
+}
+
+func NewEndorseTxPersistence(opts common.Opts, table string) (*EndorseTxPersistence, error) {
+	readWriteDB, err := OpenDB(opts.DataSource, opts.MaxOpenConns, opts.MaxIdleConns, opts.MaxIdleTime)
+	if err != nil {
+		return nil, fmt.Errorf("error opening db: %w", err)
+	}
+	return newEndorseTxPersistence(readWriteDB, readWriteDB, table), nil
+}
+
+func newEndorseTxPersistence(readDB, writeDB *sql.DB, table string) *EndorseTxPersistence {
+	return &EndorseTxPersistence{EndorseTxPersistence: common.NewEndorseTxPersistence(readDB, writeDB, table, &errorMapper{}, NewInterpreter())}
+}
diff --git a/platform/view/services/db/driver/sql/postgres/test_utils.go b/platform/view/services/db/driver/sql/postgres/test_utils.go
diff --git a/platform/view/services/db/driver/sql/sqlite/endorsetx.go b/platform/view/services/db/driver/sql/sqlite/endorsetx.go
diff --git a/platform/view/services/db/driver/sql/sqlite/test_utils.go b/platform/view/services/db/driver/sql/sqlite/test_utils.go
diff --git a/platform/view/services/storage/endorsetx/standalone.go b/platform/view/services/storage/endorsetx/standalone.go

Original file line number	Diff line number	Diff line change
`@@ -73,7 +73,7 @@ func (p *SDK) Install() error {`
`73`	`73`	`p.Container().Provide(generic2.NewEndorserTransactionHandlerProvider),`
`74`	`74`	`p.Container().Provide(committer2.NewSerialDependencyResolver, dig.As(new(committer2.DependencyResolver))),`
`75`	`75`	`p.Container().Provide(services.NewKVSBasedMetadataStore, dig.As(new(driver.MetadataStore))),`
`76`		`- p.Container().Provide(services.NewKVSBasedEnvelopeStore, dig.As(new(driver.EnvelopeStore))),`
	`76`	`+ p.Container().Provide(generic2.NewEndorseTxStore, dig.As(new(driver.EnvelopeStore))),`
`77`	`77`	`p.Container().Provide(services.NewKVSBasedEndorseTxStore, dig.As(new(driver.EndorseTxStore))),`
`78`	`78`	`)`
`79`	`79`	`if err != nil {`
Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,7 @@ func (p *SDK) Install() error {`
`79`	`79`	`p.Container().Provide(digutils.Identity[*core.ONSProvider](), dig.As(new(driver2.OrionNetworkServiceProvider))),`
`80`	`80`	`p.Container().Provide(finality2.NewHandler, dig.Group("finality-handlers")),`
`81`	`81`	`p.Container().Provide(services.NewKVSBasedMetadataStore, dig.As(new(driver2.MetadataStore))),`
`82`		`- p.Container().Provide(services.NewKVSBasedEndorseTxStore, dig.As(new(driver2.EndorseTxStore))),`
	`82`	`+ p.Container().Provide(NewEndorseTxStore, dig.As(new(driver2.EndorseTxStore))),`
`83`	`83`	`p.Container().Provide(services.NewKVSBasedEnvelopeStore, dig.As(new(driver2.EnvelopeStore))),`
`84`	`84`	`)`
`85`	`85`	`if err != nil {`
Original file line number	Diff line number	Diff line change
`@@ -76,3 +76,7 @@ func (d *Driver) NewSignerInfo(string, driver.Config) (driver.SignerInfoPersiste`
`76`	`76`	`func (d *Driver) NewAuditInfo(string, driver.Config) (driver.AuditInfoPersistence, error) {`
`77`	`77`	`panic("not implemented")`
`78`	`78`	`}`
	`79`	`+`
	`80`	`+func (d *Driver) NewEndorseTx(string, driver.Config) (driver.EndorseTxPersistence, error) {`
	`81`	`+ panic("not implemented")`
	`82`	`+}`