biz

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Sep 8, 2022 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

This section is empty.

Types

type CTMeta

type CTMeta struct {
	Id       string   `json:"id"`
	Ver      string   `json:"ver"`
	Metadata MetaData `json:"metadata"`
}

func ParseMetadata

func ParseMetadata(meta []byte) (CTMeta, error)

type CheckInfo

type CheckInfo struct {
	Id          uint64
	BlockNumber uint64
	BlockHash   string
	CheckType   CheckType
}

type CheckInfoRepo

type CheckInfoRepo interface {
	FindLastCheckInfo(ctx context.Context, info *CheckInfo) error
	CreateCheckInfo(ctx context.Context, info *CheckInfo) error
	CleanCheckInfo(ctx context.Context, checkType CheckType) error
}

type CheckInfoUsecase

type CheckInfoUsecase struct {
	// contains filtered or unexported fields
}

func NewCheckInfoUsecase

func NewCheckInfoUsecase(repo CheckInfoRepo, logger *logger.Logger) *CheckInfoUsecase

func (*CheckInfoUsecase) Clean

func (uc *CheckInfoUsecase) Clean(ctx context.Context, checkType CheckType) error

func (*CheckInfoUsecase) Create

func (uc *CheckInfoUsecase) Create(ctx context.Context, checkInfo *CheckInfo) error

func (*CheckInfoUsecase) LastCheckInfo

func (uc *CheckInfoUsecase) LastCheckInfo(ctx context.Context, checkInfo *CheckInfo) error

type CheckType

type CheckType uint8
const (
	SyncBlock    CheckType = iota // SyncBlock = 0
	SyncMetadata                  // SyncMetadata = 1
)

func (CheckType) String

func (t CheckType) String() string

type ClaimedCotaNftKvPair

type ClaimedCotaNftKvPair struct {
	BlockNumber uint64
	CotaId      string
	CotaIdCRC   uint32
	TokenIndex  uint32
	OutPoint    string
	OutPointCrc uint32
	LockHash    string
	LockHashCrc uint32
}

type ClaimedCotaNftKvPairRepo

type ClaimedCotaNftKvPairRepo interface {
	CreateClaimedCotaNftKvPair(ctx context.Context, w *ClaimedCotaNftKvPair) error
	DeleteClaimedCotaNftKvPairs(ctx context.Context, blockNumber uint64) error
	ParseClaimedCotaEntries(blockNumber uint64, entry Entry) ([]HoldCotaNftKvPair, []ClaimedCotaNftKvPair, error)
	ParseClaimedUpdateCotaEntries(blockNumber uint64, entry Entry) ([]HoldCotaNftKvPair, []ClaimedCotaNftKvPair, error)
}

type ClaimedCotaNftKvPairUsecase

type ClaimedCotaNftKvPairUsecase struct {
	// contains filtered or unexported fields
}

func NewClaimedCotaNftKvPairUsecase

func NewClaimedCotaNftKvPairUsecase(repo ClaimedCotaNftKvPairRepo, logger *logger.Logger) *ClaimedCotaNftKvPairUsecase

func (*ClaimedCotaNftKvPairUsecase) Create

func (*ClaimedCotaNftKvPairUsecase) DeleteByBlockNumber

func (uc *ClaimedCotaNftKvPairUsecase) DeleteByBlockNumber(ctx context.Context, blockNumber uint64) error

func (ClaimedCotaNftKvPairUsecase) ParseClaimedCotaEntries

func (uc ClaimedCotaNftKvPairUsecase) ParseClaimedCotaEntries(blockNumber uint64, entry Entry) ([]HoldCotaNftKvPair, []ClaimedCotaNftKvPair, error)

func (ClaimedCotaNftKvPairUsecase) ParseClaimedUpdateCotaEntries

func (uc ClaimedCotaNftKvPairUsecase) ParseClaimedUpdateCotaEntries(blockNumber uint64, entry Entry) ([]HoldCotaNftKvPair, []ClaimedCotaNftKvPair, error)

type ClassInfo

type ClassInfo struct {
	BlockNumber    uint64
	CotaId         string
	Version        string
	Name           string
	Symbol         string
	Description    string
	Image          string
	Audio          string
	Video          string
	Model          string
	Characteristic string
	Properties     string
	Localization   string
	TxIndex        uint32
}

type ClassInfoJson

type ClassInfoJson struct {
	CotaId         string         `json:"cota_id" mapstructure:"cota_id,omitempty"`
	Version        string         `json:"version" mapstructure:",omitempty"`
	Name           string         `json:"name" mapstructure:",omitempty"`
	Symbol         string         `json:"symbol" mapstructure:",omitempty"`
	Description    string         `json:"description" mapstructure:",omitempty"`
	Image          string         `json:"image" mapstructure:",omitempty"`
	Audio          string         `json:"audio"`
	Video          string         `json:"video" mapstructure:",omitempty"`
	Model          string         `json:"model" mapstructure:",omitempty"`
	Characteristic [][]any        `json:"characteristic" mapstructure:",omitempty"`
	Properties     map[string]any `json:"properties" mapstructure:",omitempty"`
	Localization   Localization   `json:"localization" mapstructure:",omitempty"`
}

type ClassInfoRepo

type ClassInfoRepo interface {
	CreateClassInfo(ctx context.Context, class *ClassInfo) error
	DeleteClassInfo(ctx context.Context, blockNumber uint64) error
	ParseClassInfo(blockNumber uint64, txIndex uint32, classMeta map[string]any) (ClassInfo, error)
}

type ClassInfoUsecase

type ClassInfoUsecase struct {
	// contains filtered or unexported fields
}

func NewClassInfoUsecase

func NewClassInfoUsecase(repo ClassInfoRepo, logger *logger.Logger) *ClassInfoUsecase

func (*ClassInfoUsecase) Create

func (uc *ClassInfoUsecase) Create(ctx context.Context, class *ClassInfo) error

func (*ClassInfoUsecase) DeleteByBlockNumber

func (uc *ClassInfoUsecase) DeleteByBlockNumber(ctx context.Context, blockNumber uint64) error

func (ClassInfoUsecase) ParseMetadata

func (uc ClassInfoUsecase) ParseMetadata(blockNumber uint64, txIndex uint32, classMeta map[string]any) (ClassInfo, error)

type DefineCotaNftKvPair

type DefineCotaNftKvPair struct {
	BlockNumber uint64
	CotaId      string
	Total       uint32
	Issued      uint32
	Configure   uint8
	LockHash    string
	LockHashCRC uint32
	TxIndex     uint32
	UpdatedAt   time.Time
}

type DefineCotaNftKvPairRepo

type DefineCotaNftKvPairRepo interface {
	CreateDefineCotaNftKvPair(ctx context.Context, d *DefineCotaNftKvPair) error
	DeleteDefineCotaNftKvPairs(ctx context.Context, blockNumber uint64) error
	ParseDefineCotaEntries(blockNumber uint64, entry Entry) ([]DefineCotaNftKvPair, error)
}

type DefineCotaNftKvPairUsecase

type DefineCotaNftKvPairUsecase struct {
	// contains filtered or unexported fields
}

func NewDefineCotaNftKvPairUsecase

func NewDefineCotaNftKvPairUsecase(repo DefineCotaNftKvPairRepo, logger *logger.Logger) *DefineCotaNftKvPairUsecase

func (*DefineCotaNftKvPairUsecase) Create

func (*DefineCotaNftKvPairUsecase) DeleteByBlockNumber

func (uc *DefineCotaNftKvPairUsecase) DeleteByBlockNumber(ctx context.Context, blockNumber uint64) error

func (*DefineCotaNftKvPairUsecase) ParseDefineCotaEntries

func (uc *DefineCotaNftKvPairUsecase) ParseDefineCotaEntries(blockNumber uint64, entry Entry) ([]DefineCotaNftKvPair, error)

type Entry

type Entry struct {
	InputType  []byte
	OutputType []byte
	LockScript *ckbTypes.Script
	TxIndex    uint32
	Version    uint8
	TxHash     ckbTypes.Hash
}

type HoldCotaNftKvPair

type HoldCotaNftKvPair struct {
	ID             uint
	BlockNumber    uint64
	CotaId         string
	TokenIndex     uint32
	State          uint8
	Configure      uint8
	Characteristic string
	LockHash       string
	LockHashCRC    uint32
	TxIndex        uint32
	UpdatedAt      time.Time
}

type HoldCotaNftKvPairRepo

type HoldCotaNftKvPairRepo interface {
	CreateHoldCotaNftKvPair(ctx context.Context, h *HoldCotaNftKvPair) error
	DeleteHoldCotaNftKvPairs(ctx context.Context, blockNumber uint64) error
	ParseHoldCotaEntries(blockNumber uint64, entry Entry) ([]HoldCotaNftKvPair, error)
}

type HoldCotaNftKvPairUsecase

type HoldCotaNftKvPairUsecase struct {
	// contains filtered or unexported fields
}

func NewHoldCotaNftKvPairUsecase

func NewHoldCotaNftKvPairUsecase(repo HoldCotaNftKvPairRepo, logger *logger.Logger) *HoldCotaNftKvPairUsecase

func (*HoldCotaNftKvPairUsecase) Create

func (*HoldCotaNftKvPairUsecase) DeleteByBlockNumber

func (uc *HoldCotaNftKvPairUsecase) DeleteByBlockNumber(ctx context.Context, blockNumber uint64) error

func (HoldCotaNftKvPairUsecase) ParseHoldCotaEntries

func (uc HoldCotaNftKvPairUsecase) ParseHoldCotaEntries(blockNumber uint64, entry Entry) ([]HoldCotaNftKvPair, error)

type InvalidDataRepo

type InvalidDataRepo interface {
	Clean(ctx context.Context, blockNumber uint64) error
}

type InvalidDataUsecase

type InvalidDataUsecase struct {
	// contains filtered or unexported fields
}

func NewInvalidDataUsecase

func NewInvalidDataUsecase(repo InvalidDataRepo, logger *logger.Logger) *InvalidDataUsecase

func (*InvalidDataUsecase) Clean

func (uc *InvalidDataUsecase) Clean(ctx context.Context, blockNumber uint64) error

type IssuerInfo

type IssuerInfo struct {
	BlockNumber  uint64
	LockHash     string
	Version      string
	Name         string
	Avatar       string
	Description  string
	Localization string
	TxIndex      uint32
}

type IssuerInfoJson

type IssuerInfoJson struct {
	Version      string       `json:"version" mapstructure:",omitempty"`
	Name         string       `json:"name" mapstructure:",omitempty"`
	Avatar       string       `json:"avatar" mapstructure:",omitempty"`
	Description  string       `json:"description" mapstructure:",omitempty"`
	Localization Localization `json:"localization" mapstructure:",omitempty"`
}

type IssuerInfoRepo

type IssuerInfoRepo interface {
	CreateIssuerInfo(ctx context.Context, issuer *IssuerInfo) error
	DeleteIssuerInfo(ctx context.Context, blockNumber uint64) error
	ParseIssuerInfo(blockNumber uint64, txIndex uint32, lockScript *ckbTypes.Script, issuerMeta map[string]any) (IssuerInfo, error)
}

type IssuerInfoUsecase

type IssuerInfoUsecase struct {
	// contains filtered or unexported fields
}

func NewIssuerInfoUsecase

func NewIssuerInfoUsecase(repo IssuerInfoRepo, logger *logger.Logger) *IssuerInfoUsecase

func (*IssuerInfoUsecase) Create

func (uc *IssuerInfoUsecase) Create(ctx context.Context, issuer *IssuerInfo) error

func (*IssuerInfoUsecase) DeleteByBlockNumber

func (uc *IssuerInfoUsecase) DeleteByBlockNumber(ctx context.Context, blockNumber uint64) error

func (IssuerInfoUsecase) ParseMetadata

func (uc IssuerInfoUsecase) ParseMetadata(blockNumber uint64, txIndex uint32, lockScript *ckbTypes.Script, issuerMeta map[string]any) (IssuerInfo, error)

type KvPair

type KvPair struct {
	Registers          []RegisterCotaKvPair
	DefineCotas        []DefineCotaNftKvPair
	UpdatedDefineCotas []DefineCotaNftKvPair
	HoldCotas          []HoldCotaNftKvPair
	UpdatedHoldCotas   []HoldCotaNftKvPair
	WithdrawCotas      []WithdrawCotaNftKvPair
	ClaimedCotas       []ClaimedCotaNftKvPair
	IssuerInfos        []IssuerInfo
	ClassInfos         []ClassInfo
}

func (KvPair) HasClaimedCotas

func (p KvPair) HasClaimedCotas() bool

func (KvPair) HasClassInfos

func (p KvPair) HasClassInfos() bool

func (KvPair) HasDefineCotas

func (p KvPair) HasDefineCotas() bool

func (KvPair) HasHoldCotas

func (p KvPair) HasHoldCotas() bool

func (KvPair) HasIssuerInfos

func (p KvPair) HasIssuerInfos() bool

func (KvPair) HasRegisters

func (p KvPair) HasRegisters() bool

func (KvPair) HasUpdatedDefineCotas

func (p KvPair) HasUpdatedDefineCotas() bool

func (KvPair) HasUpdatedHoldCotas

func (p KvPair) HasUpdatedHoldCotas() bool

func (KvPair) HasWithdrawCotas

func (p KvPair) HasWithdrawCotas() bool

type KvPairRepo

type KvPairRepo interface {
	CreateCotaEntryKvPairs(ctx context.Context, checkInfo CheckInfo, kvPair *KvPair) error
	RestoreCotaEntryKvPairs(ctx context.Context, blockNumber uint64) error
	CreateMetadataKvPairs(ctx context.Context, checkInfo CheckInfo, kvPair *KvPair) error
	RestoreMetadataKvPairs(ctx context.Context, blockNumber uint64) error
}

type Localization

type Localization struct {
	Uri     string   `json:"uri,omitempty" mapstructure:",omitempty"`
	Default string   `json:"default,omitempty" mapstructure:",omitempty"`
	Locales []string `json:"locales,omitempty" mapstructure:",omitempty"`
}

type MetaData

type MetaData struct {
	Target string         `json:"target"`
	Type   string         `json:"type"`
	Data   map[string]any `json:"data"`
}

type MetaType

type MetaType int

type MintCotaKvPair

type MintCotaKvPair struct{}

type MintCotaKvPairRepo

type MintCotaKvPairRepo interface {
	ParseMintCotaEntries(blockNumber uint64, entry Entry) ([]DefineCotaNftKvPair, []WithdrawCotaNftKvPair, error)
	FindOrCreateScript(ctx context.Context, script *Script) error
}

type MintCotaKvPairUsecase

type MintCotaKvPairUsecase struct {
	// contains filtered or unexported fields
}

func NewMintCotaKvPairUsecase

func NewMintCotaKvPairUsecase(repo MintCotaKvPairRepo, logger *logger.Logger) *MintCotaKvPairUsecase

func (*MintCotaKvPairUsecase) FindOrCreateScript

func (uc *MintCotaKvPairUsecase) FindOrCreateScript(ctx context.Context, script *Script) error

func (*MintCotaKvPairUsecase) ParseMintCotaEntries

func (uc *MintCotaKvPairUsecase) ParseMintCotaEntries(blockNumber uint64, entry Entry) ([]DefineCotaNftKvPair, []WithdrawCotaNftKvPair, error)

type RegisterCotaKvPair

type RegisterCotaKvPair struct {
	BlockNumber uint64
	LockHash    string
}

type RegisterCotaKvPairRepo

type RegisterCotaKvPairRepo interface {
	CreateRegisterCotaKvPair(ctx context.Context, register *RegisterCotaKvPair) error
	DeleteRegisterCotaKvPairs(ctx context.Context, blockNumber uint64) error
	ParseRegistryEntries(ctx context.Context, blockNumber uint64, tx *ckbTypes.Transaction) ([]RegisterCotaKvPair, error)
}

type RegisterCotaKvPairUsecase

type RegisterCotaKvPairUsecase struct {
	// contains filtered or unexported fields
}

func NewRegisterCotaKvPairUsecase

func NewRegisterCotaKvPairUsecase(repo RegisterCotaKvPairRepo, logger *logger.Logger) *RegisterCotaKvPairUsecase

func (*RegisterCotaKvPairUsecase) Create

func (*RegisterCotaKvPairUsecase) DeleteByBlockNumber

func (uc *RegisterCotaKvPairUsecase) DeleteByBlockNumber(ctx context.Context, blockNumber uint64) error

func (*RegisterCotaKvPairUsecase) ParseRegistryEntries

func (uc *RegisterCotaKvPairUsecase) ParseRegistryEntries(ctx context.Context, blockNumber uint64, tx *ckbTypes.Transaction) ([]RegisterCotaKvPair, error)

type Script

type Script struct {
	ID       uint
	CodeHash string
	HashType string
	Args     string
}

type SyncKvPairUsecase

type SyncKvPairUsecase struct {
	// contains filtered or unexported fields
}

func NewSyncKvPairUsecase

func NewSyncKvPairUsecase(repo KvPairRepo, logger *logger.Logger) *SyncKvPairUsecase

func (SyncKvPairUsecase) CreateCotaEntryKvPairs

func (uc SyncKvPairUsecase) CreateCotaEntryKvPairs(ctx context.Context, checkInfo CheckInfo, kvPair *KvPair) error

func (SyncKvPairUsecase) CreateMetadataKvPairs

func (uc SyncKvPairUsecase) CreateMetadataKvPairs(ctx context.Context, checkInfo CheckInfo, kvPair *KvPair) error

func (SyncKvPairUsecase) RestoreCotaEntryKvPairs

func (uc SyncKvPairUsecase) RestoreCotaEntryKvPairs(ctx context.Context, blockNumber uint64) error

func (SyncKvPairUsecase) RestoreMetadataKvPairs

func (uc SyncKvPairUsecase) RestoreMetadataKvPairs(ctx context.Context, blockNumber uint64) error

type TransferCotaKvPair

type TransferCotaKvPair struct{}

type TransferCotaKvPairRepo

type TransferCotaKvPairRepo interface {
	ParseTransferCotaEntries(blockNumber uint64, entry Entry) ([]ClaimedCotaNftKvPair, []WithdrawCotaNftKvPair, error)
	ParseTransferUpdateCotaEntries(blockNumber uint64, entry Entry) ([]ClaimedCotaNftKvPair, []WithdrawCotaNftKvPair, error)
	FindOrCreateScript(ctx context.Context, script *Script) error
}

type TransferCotaKvPairUsecase

type TransferCotaKvPairUsecase struct {
	// contains filtered or unexported fields
}

func NewTransferCotaKvPairUsecase

func NewTransferCotaKvPairUsecase(repo TransferCotaKvPairRepo, logger *logger.Logger) *TransferCotaKvPairUsecase

func (*TransferCotaKvPairUsecase) FindOrCreateScript

func (uc *TransferCotaKvPairUsecase) FindOrCreateScript(ctx context.Context, script *Script) error

func (*TransferCotaKvPairUsecase) ParseTransferCotaEntries

func (uc *TransferCotaKvPairUsecase) ParseTransferCotaEntries(blockNumber uint64, entry Entry) ([]ClaimedCotaNftKvPair, []WithdrawCotaNftKvPair, error)

func (*TransferCotaKvPairUsecase) ParseTransferUpdateCotaEntries

func (uc *TransferCotaKvPairUsecase) ParseTransferUpdateCotaEntries(blockNumber uint64, entry Entry) ([]ClaimedCotaNftKvPair, []WithdrawCotaNftKvPair, error)

type WithdrawCotaNftKvPair

type WithdrawCotaNftKvPair struct {
	BlockNumber          uint64
	CotaId               string
	CotaIdCRC            uint32
	TokenIndex           uint32
	OutPoint             string
	OutPointCrc          uint32
	TxHash               string
	State                uint8
	Configure            uint8
	Characteristic       string
	ReceiverLockScriptId uint
	LockHash             string
	LockHashCrc          uint32
	LockScriptId         uint
	Version              uint8
}

type WithdrawCotaNftKvPairRepo

type WithdrawCotaNftKvPairRepo interface {
	CreateWithdrawCotaNftKvPair(ctx context.Context, w *WithdrawCotaNftKvPair) error
	DeleteWithdrawCotaNftKvPairs(ctx context.Context, blockNumber uint64) error
	ParseWithdrawCotaEntries(blockNumber uint64, entry Entry) ([]WithdrawCotaNftKvPair, error)
	FindOrCreateScript(ctx context.Context, script *Script) error
}

type WithdrawCotaNftKvPairUsecase

type WithdrawCotaNftKvPairUsecase struct {
	// contains filtered or unexported fields
}

func (*WithdrawCotaNftKvPairUsecase) Create

func (*WithdrawCotaNftKvPairUsecase) DeleteByBlockNumber

func (uc *WithdrawCotaNftKvPairUsecase) DeleteByBlockNumber(ctx context.Context, blockNumber uint64) error

func (*WithdrawCotaNftKvPairUsecase) FindOrCreateScript

func (uc *WithdrawCotaNftKvPairUsecase) FindOrCreateScript(ctx context.Context, script *Script) error

func (*WithdrawCotaNftKvPairUsecase) ParseWithdrawCotaEntries

func (uc *WithdrawCotaNftKvPairUsecase) ParseWithdrawCotaEntries(blockNumber uint64, entry Entry) ([]WithdrawCotaNftKvPair, error)

type WithdrawExtraInfoRepo

type WithdrawExtraInfoRepo interface {
	CreateExtraInfo(ctx context.Context, outPoint string, txHash string, lockScriptId uint) error
	FindQueryInfos(ctx context.Context, page int, pageSize int) ([]WithdrawQueryInfo, error)
	FindOrCreateScript(ctx context.Context, script *Script) error
}

type WithdrawExtraInfoUsecase

type WithdrawExtraInfoUsecase struct {
	// contains filtered or unexported fields
}

func NewWithdrawExtraInfoUsecase

func NewWithdrawExtraInfoUsecase(repo WithdrawExtraInfoRepo, logger *logger.Logger) *WithdrawExtraInfoUsecase

func (*WithdrawExtraInfoUsecase) CreateExtraInfo

func (uc *WithdrawExtraInfoUsecase) CreateExtraInfo(ctx context.Context, outPoint string, txHash string, lockScriptId uint) error

func (*WithdrawExtraInfoUsecase) FindOrCreateScript

func (uc *WithdrawExtraInfoUsecase) FindOrCreateScript(ctx context.Context, script *Script) error

func (*WithdrawExtraInfoUsecase) FindQueryInfos

func (uc *WithdrawExtraInfoUsecase) FindQueryInfos(ctx context.Context, page int, pageSize int) ([]WithdrawQueryInfo, error)

type WithdrawQueryInfo

type WithdrawQueryInfo struct {
	BlockNumber uint64
	OutPoint    string
	LockHash    string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL