server

package
v2.0.0-alpha Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 9, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Copyright IBM Corp. All Rights Reserved.

SPDX-License-Identifier: Apache-2.0

Copyright IBM Corp. All Rights Reserved.

SPDX-License-Identifier: Apache-2.0

Copyright IBM Corp. All Rights Reserved.

SPDX-License-Identifier: Apache-2.0

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func UnmarshalCommand 

func UnmarshalCommand(raw []byte) (*token.Command, error)

UnmarshalCommand unmarshal token.Command messages

Types

type ACLProvider 

type ACLProvider interface {
	// CheckACL checks access control for the resource for the given channel.
	// idinfo is an object such as []*protoutil.SignedData from which
	// an id can be extracted for testing against a policy
	CheckACL(resName string, channelID string, idinfo interface{}) error
}

type ACLResources 

type ACLResources struct {
	IssueTokens    string
	TransferTokens string
	ListTokens     string
}

type CapabilityChecker 

type CapabilityChecker interface {
	FabToken(channelId string) (bool, error)
}

CapabilityChecker is used to check whether or not a channel supports token functions.

type Issuer 

type Issuer interface {
	// RequestIssue creates an issue request transaction.
	RequestIssue(tokensToIssue []*token.Token) (*token.TokenTransaction, error)

	// RequestTokenOperation returns a token transaction matching the requested issue operation
	RequestTokenOperation(op *token.TokenOperation) (*token.TokenTransaction, error)
}

An Issuer creates token import requests.

type Manager 

type Manager struct {
	LedgerManager              ledger.LedgerManager
	TokenOwnerValidatorManager identity.TokenOwnerValidatorManager
}

Manager implements token/server/TMSManager interface TODO: it will be updated after lscc-baased tms configuration is available

func (*Manager) GetIssuer 

func (m *Manager) GetIssuer(channel string, privateCredential, publicCredential []byte) (Issuer, error)

For now it returns a plain issuer. After lscc-based tms configuration is available, it will be updated to return an issuer configured for the specific channel

func (*Manager) GetTransactor 

func (m *Manager) GetTransactor(channel string, privateCredential, publicCredential []byte) (Transactor, error)

GetTransactor returns a Transactor bound to the passed channel and whose credential is the tuple (privateCredential, publicCredential).

type Marshaler 

type Marshaler interface {
	MarshalCommandResponse(command []byte, responsePayload interface{}) (*token.SignedCommandResponse, error)
}

A Marshaler is responsible for marshaling and signging command responses.

type PeerLedgerManager 

type PeerLedgerManager struct {
}

PeerLedgerManager implements the LedgerManager interface by using the peer infrastructure

func (*PeerLedgerManager) GetLedgerReader 

func (*PeerLedgerManager) GetLedgerReader(channel string) (ledger.LedgerReader, error)

type PeerTokenOwnerValidatorManager 

type PeerTokenOwnerValidatorManager struct {
	IdentityDeserializerManager identity.DeserializerManager
}

PeerTokenOwnerValidatorManager is TokenOwnerValidatorManager based on a DeserializerManager

func (*PeerTokenOwnerValidatorManager) Get 

func (p *PeerTokenOwnerValidatorManager) Get(channel string) (identity.TokenOwnerValidator, error)

type PolicyBasedAccessControl 

type PolicyBasedAccessControl struct {
	ACLProvider  ACLProvider
	ACLResources *ACLResources
}

PolicyBasedAccessControl implements token command access control functions.

func (*PolicyBasedAccessControl) Check 

func (ac *PolicyBasedAccessControl) Check(sc *token.SignedCommand, c *token.Command) error

type PolicyChecker 

type PolicyChecker interface {
	Check(sc *token.SignedCommand, c *token.Command) error
}

A PolicyChecker is responsible for performing policy based access control checks related to token commands.

type Prover 

type Prover struct {
	CapabilityChecker CapabilityChecker
	Marshaler         Marshaler
	PolicyChecker     PolicyChecker
	TMSManager        TMSManager
}

A Provider is responslble for processing token commands.

func (*Prover) ListUnspentTokens 

func (s *Prover) ListUnspentTokens(ctxt context.Context, header *token.Header, listRequest *token.ListRequest) (*token.CommandResponse_UnspentTokens, error)

func (*Prover) MarshalErrorResponse 

func (s *Prover) MarshalErrorResponse(command []byte, e error) (*token.SignedCommandResponse, error)

func (*Prover) ProcessCommand 

func (s *Prover) ProcessCommand(ctx context.Context, sc *token.SignedCommand) (cr *token.SignedCommandResponse, err error)

func (*Prover) RequestIssue 

func (s *Prover) RequestIssue(ctx context.Context, header *token.Header, requestImport *token.IssueRequest) (*token.CommandResponse_TokenTransaction, error)

func (*Prover) RequestRedeem 

func (s *Prover) RequestRedeem(ctx context.Context, header *token.Header, request *token.RedeemRequest) (*token.CommandResponse_TokenTransaction, error)

func (*Prover) RequestTokenOperations 

func (s *Prover) RequestTokenOperations(ctx context.Context, header *token.Header, request *token.TokenOperationRequest) (*token.CommandResponse_TokenTransactions, error)

RequestTokenOperation gets an issuer or transactor and creates a token transaction response for import, transfer or redemption.

func (*Prover) RequestTransfer 

func (s *Prover) RequestTransfer(ctx context.Context, header *token.Header, request *token.TransferRequest) (*token.CommandResponse_TokenTransaction, error)

func (*Prover) ValidateHeader 

func (s *Prover) ValidateHeader(header *token.Header) error

type ResponseMarshaler 

type ResponseMarshaler struct {
	Signer  Signer
	Creator []byte
	Time    TimeFunc
}

ResponseMarshaler produces token.SignedCommandResponse

func NewResponseMarshaler 

func NewResponseMarshaler(signerID SignerIdentity) (*ResponseMarshaler, error)

func (*ResponseMarshaler) MarshalCommandResponse 

func (s *ResponseMarshaler) MarshalCommandResponse(command []byte, responsePayload interface{}) (*token.SignedCommandResponse, error)

type Signer 

type Signer interface {
	// Sign signs the given payload and returns a signature
	Sign([]byte) ([]byte, error)
}

type SignerIdentity 

type SignerIdentity interface {
	Signer

	// Serialize returns a byte representation of this identity which is used to verify
	// messages signed by this SignerIdentity
	Serialize() ([]byte, error)
}

SignerIdentity signs messages and serializes its public identity to bytes

type TMSManager 

type TMSManager interface {
	// GetIssuer returns an Issuer bound to the passed channel and whose credential
	// is the tuple (privateCredential, publicCredential).
	GetIssuer(channel string, privateCredential, publicCredential []byte) (Issuer, error)

	// GetTransactor returns a Transactor bound to the passed channel and whose credential
	// is the tuple (privateCredential, publicCredential).
	GetTransactor(channel string, privateCredential, publicCredential []byte) (Transactor, error)
}

type TimeFunc 

type TimeFunc func() time.Time

type TokenCapabilityChecker 

type TokenCapabilityChecker struct {
	PeerOps peer.Operations
}

TokenCapabilityChecker implements CapabilityChecker interface

func (*TokenCapabilityChecker) FabToken 

func (c *TokenCapabilityChecker) FabToken(channelId string) (bool, error)

type Transactor 

type Transactor interface {
	// RequestTransfer Create data associated to the transfer of a token assuming
	// an application-level identity. The inTokens bytes are the identifiers
	// of the outputs, the details of which need to be looked up from the ledger.
	RequestTransfer(request *token.TransferRequest) (*token.TokenTransaction, error)

	// RequestRedeem allows the redemption of the tokens in the input tokenIds
	// It queries the ledger to read detail for each token id.
	// It creates a token transaction with an output for redeemed tokens and
	// possibly another output to transfer the remaining tokens, if any, to the creator
	RequestRedeem(request *token.RedeemRequest) (*token.TokenTransaction, error)

	// ListTokens returns a slice of unspent tokens owned by this transactor
	ListTokens() (*token.UnspentTokens, error)

	// RequestTokenOperation returns a token transaction matching the requested transfer operation
	RequestTokenOperation(tokenIDs []*token.TokenId, op *token.TokenOperation) (*token.TokenTransaction, int, error)

	// Done releases any resources held by this transactor
	Done()
}

Transactor allows to operate on issued tokens

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.