we dont use those
This commit is contained in:
Alex Grintsvayg
parent
2f0a1072e4
commit
2bcf072aee
1 changed files with 0 additions and 313 deletions
|
|
@ -1,313 +0,0 @@
|
||||||
package lbrycrd
|
|
||||||
|
|
||||||
import (
|
|
||||||
"encoding/json"
|
|
||||||
"reflect"
|
|
||||||
|
|
||||||
lbryschema "github.com/lbryio/lbryschema.go/pb"
|
|
||||||
|
|
||||||
"github.com/go-errors/errors"
|
|
||||||
"github.com/shopspring/decimal"
|
|
||||||
)
|
|
||||||
|
|
||||||
type Currency string
|
|
||||||
|
|
||||||
const (
|
|
||||||
CurrencyLBC = Currency("LBC")
|
|
||||||
CurrencyUSD = Currency("USD")
|
|
||||||
CurrencyBTC = Currency("BTC")
|
|
||||||
)
|
|
||||||
|
|
||||||
type Fee struct {
|
|
||||||
Currency Currency `json:"currency"`
|
|
||||||
Amount decimal.Decimal `json:"amount"`
|
|
||||||
Address *string `json:"address"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type Support struct {
|
|
||||||
Amount decimal.Decimal `json:"amount"`
|
|
||||||
Nout int `json:"nout"`
|
|
||||||
Txid string `json:"txid"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type Claim struct {
|
|
||||||
Address string `json:"address"`
|
|
||||||
Amount decimal.Decimal `json:"amount"`
|
|
||||||
ClaimID string `json:"claim_id"`
|
|
||||||
ClaimSequence int `json:"claim_sequence"`
|
|
||||||
DecodedClaim bool `json:"decoded_claim"`
|
|
||||||
Depth int `json:"depth"`
|
|
||||||
EffectiveAmount decimal.Decimal `json:"effective_amount"`
|
|
||||||
Height int `json:"height"`
|
|
||||||
Hex string `json:"hex"`
|
|
||||||
Name string `json:"name"`
|
|
||||||
Nout int `json:"nout"`
|
|
||||||
Supports []Support `json:"supports"`
|
|
||||||
Txid string `json:"txid"`
|
|
||||||
ValidAtHeight int `json:"valid_at_height"`
|
|
||||||
Value lbryschema.Claim `json:"value"`
|
|
||||||
Error *string `json:"error,omitempty"`
|
|
||||||
ChannelName *string `json:"channel_name,omitempty"`
|
|
||||||
HasSignature *bool `json:"has_signature,omitempty"`
|
|
||||||
SignatureIsValid *bool `json:"signature_is_valid,omitempty"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type File struct {
|
|
||||||
ClaimID string `json:"claim_id"`
|
|
||||||
Completed bool `json:"completed"`
|
|
||||||
DownloadDirectory string `json:"download_directory"`
|
|
||||||
DownloadPath string `json:"download_path"`
|
|
||||||
FileName string `json:"file_name"`
|
|
||||||
Key string `json:"key"`
|
|
||||||
Message string `json:"message"`
|
|
||||||
Metadata *lbryschema.Claim `json:"metadata"`
|
|
||||||
MimeType string `json:"mime_type"`
|
|
||||||
Name string `json:"name"`
|
|
||||||
Outpoint string `json:"outpoint"`
|
|
||||||
PointsPaid decimal.Decimal `json:"points_paid"`
|
|
||||||
SdHash string `json:"sd_hash"`
|
|
||||||
Stopped bool `json:"stopped"`
|
|
||||||
StreamHash string `json:"stream_hash"`
|
|
||||||
StreamName string `json:"stream_name"`
|
|
||||||
SuggestedFileName string `json:"suggested_file_name"`
|
|
||||||
TotalBytes uint64 `json:"total_bytes"`
|
|
||||||
WrittenBytes uint64 `json:"written_bytes"`
|
|
||||||
ChannelName *string `json:"channel_name,omitempty"`
|
|
||||||
HasSignature *bool `json:"has_signature,omitempty"`
|
|
||||||
SignatureIsValid *bool `json:"signature_is_valid,omitempty"`
|
|
||||||
}
|
|
||||||
|
|
||||||
func getEnumVal(enum map[string]int32, data interface{}) (int32, error) {
|
|
||||||
s, ok := data.(string)
|
|
||||||
if !ok {
|
|
||||||
return 0, errors.New("expected a string")
|
|
||||||
}
|
|
||||||
val, ok := enum[s]
|
|
||||||
if !ok {
|
|
||||||
return 0, errors.New("invalid enum key")
|
|
||||||
}
|
|
||||||
return val, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func fixDecodeProto(src, dest reflect.Type, data interface{}) (interface{}, error) {
|
|
||||||
switch dest {
|
|
||||||
case reflect.TypeOf(uint64(0)):
|
|
||||||
if n, ok := data.(json.Number); ok {
|
|
||||||
val, err := n.Int64()
|
|
||||||
if err != nil {
|
|
||||||
return nil, errors.Wrap(err, 0)
|
|
||||||
} else if val < 0 {
|
|
||||||
return nil, errors.New("must be unsigned int")
|
|
||||||
}
|
|
||||||
return uint64(val), nil
|
|
||||||
}
|
|
||||||
case reflect.TypeOf([]byte{}):
|
|
||||||
if s, ok := data.(string); ok {
|
|
||||||
return []byte(s), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
case reflect.TypeOf(decimal.Decimal{}):
|
|
||||||
if n, ok := data.(json.Number); ok {
|
|
||||||
val, err := n.Float64()
|
|
||||||
if err != nil {
|
|
||||||
return nil, errors.Wrap(err, 0)
|
|
||||||
}
|
|
||||||
return decimal.NewFromFloat(val), nil
|
|
||||||
} else if s, ok := data.(string); ok {
|
|
||||||
d, err := decimal.NewFromString(s)
|
|
||||||
if err != nil {
|
|
||||||
return nil, errors.Wrap(err, 0)
|
|
||||||
}
|
|
||||||
return d, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
case reflect.TypeOf(lbryschema.Metadata_Version(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Metadata_Version_value, data)
|
|
||||||
return lbryschema.Metadata_Version(val), err
|
|
||||||
case reflect.TypeOf(lbryschema.Metadata_Language(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Metadata_Language_value, data)
|
|
||||||
return lbryschema.Metadata_Language(val), err
|
|
||||||
|
|
||||||
case reflect.TypeOf(lbryschema.Stream_Version(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Stream_Version_value, data)
|
|
||||||
return lbryschema.Stream_Version(val), err
|
|
||||||
|
|
||||||
case reflect.TypeOf(lbryschema.Claim_Version(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Claim_Version_value, data)
|
|
||||||
return lbryschema.Claim_Version(val), err
|
|
||||||
case reflect.TypeOf(lbryschema.Claim_ClaimType(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Claim_ClaimType_value, data)
|
|
||||||
return lbryschema.Claim_ClaimType(val), err
|
|
||||||
|
|
||||||
case reflect.TypeOf(lbryschema.Fee_Version(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Fee_Version_value, data)
|
|
||||||
return lbryschema.Fee_Version(val), err
|
|
||||||
case reflect.TypeOf(lbryschema.Fee_Currency(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Fee_Currency_value, data)
|
|
||||||
return lbryschema.Fee_Currency(val), err
|
|
||||||
|
|
||||||
case reflect.TypeOf(lbryschema.Source_Version(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Source_Version_value, data)
|
|
||||||
return lbryschema.Source_Version(val), err
|
|
||||||
case reflect.TypeOf(lbryschema.Source_SourceTypes(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Source_SourceTypes_value, data)
|
|
||||||
return lbryschema.Source_SourceTypes(val), err
|
|
||||||
|
|
||||||
case reflect.TypeOf(lbryschema.KeyType(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.KeyType_value, data)
|
|
||||||
return lbryschema.KeyType(val), err
|
|
||||||
|
|
||||||
case reflect.TypeOf(lbryschema.Signature_Version(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Signature_Version_value, data)
|
|
||||||
return lbryschema.Signature_Version(val), err
|
|
||||||
|
|
||||||
case reflect.TypeOf(lbryschema.Certificate_Version(0)):
|
|
||||||
val, err := getEnumVal(lbryschema.Certificate_Version_value, data)
|
|
||||||
return lbryschema.Certificate_Version(val), err
|
|
||||||
}
|
|
||||||
|
|
||||||
return data, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
type CommandsResponse []string
|
|
||||||
|
|
||||||
type WalletBalanceResponse decimal.Decimal
|
|
||||||
|
|
||||||
type VersionResponse struct {
|
|
||||||
Build string `json:"build"`
|
|
||||||
LbrynetVersion string `json:"lbrynet_version"`
|
|
||||||
LbryschemaVersion string `json:"lbryschema_version"`
|
|
||||||
LbryumVersion string `json:"lbryum_version"`
|
|
||||||
OsRelease string `json:"os_release"`
|
|
||||||
OsSystem string `json:"os_system"`
|
|
||||||
Platform string `json:"platform"`
|
|
||||||
Processor string `json:"processor"`
|
|
||||||
PythonVersion string `json:"python_version"`
|
|
||||||
}
|
|
||||||
type StatusResponse struct {
|
|
||||||
BlockchainStatus struct {
|
|
||||||
BestBlockhash string `json:"best_blockhash"`
|
|
||||||
Blocks int `json:"blocks"`
|
|
||||||
BlocksBehind int `json:"blocks_behind"`
|
|
||||||
} `json:"blockchain_status"`
|
|
||||||
BlocksBehind int `json:"blocks_behind"`
|
|
||||||
ConnectionStatus struct {
|
|
||||||
Code string `json:"code"`
|
|
||||||
Message string `json:"message"`
|
|
||||||
} `json:"connection_status"`
|
|
||||||
InstallationID string `json:"installation_id"`
|
|
||||||
IsFirstRun bool `json:"is_first_run"`
|
|
||||||
IsRunning bool `json:"is_running"`
|
|
||||||
LbryID string `json:"lbry_id"`
|
|
||||||
StartupStatus struct {
|
|
||||||
Code string `json:"code"`
|
|
||||||
Message string `json:"message"`
|
|
||||||
} `json:"startup_status"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type ClaimListResponse struct {
|
|
||||||
Claims []Claim `json:"claims"`
|
|
||||||
LastTakeoverHeight int `json:"last_takeover_height"`
|
|
||||||
SupportsWithoutClaims []Support `json:"supports_without_claims"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type ClaimShowResponse Claim
|
|
||||||
|
|
||||||
type PeerListResponsePeer struct {
|
|
||||||
IP string
|
|
||||||
Port uint
|
|
||||||
IsAvailable bool
|
|
||||||
}
|
|
||||||
type PeerListResponse []PeerListResponsePeer
|
|
||||||
|
|
||||||
type BlobGetResponse struct {
|
|
||||||
Blobs []struct {
|
|
||||||
BlobHash string `json:"blob_hash,omitempty"`
|
|
||||||
BlobNum int `json:"blob_num"`
|
|
||||||
IV string `json:"iv"`
|
|
||||||
Length int `json:"length"`
|
|
||||||
} `json:"blobs"`
|
|
||||||
Key string `json:"key"`
|
|
||||||
StreamHash string `json:"stream_hash"`
|
|
||||||
StreamName string `json:"stream_name"`
|
|
||||||
StreamType string `json:"stream_type"`
|
|
||||||
SuggestedFileName string `json:"suggested_file_name"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type StreamCostEstimateResponse decimal.Decimal
|
|
||||||
|
|
||||||
type GetResponse File
|
|
||||||
type FileListResponse []File
|
|
||||||
|
|
||||||
type ResolveResponse map[string]ResolveResponseItem
|
|
||||||
type ResolveResponseItem struct {
|
|
||||||
Certificate *Claim `json:"certificate,omitempty"`
|
|
||||||
Claim *Claim `json:"claim,omitempty"`
|
|
||||||
ClaimsInChannel *uint64 `json:"claims_in_channel,omitempty"`
|
|
||||||
Error *string `json:"error,omitempty"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type ChannelNewResponse struct {
|
|
||||||
ClaimID string `json:"claim_id"`
|
|
||||||
Fee decimal.Decimal `json:"fee"`
|
|
||||||
Nout int `json:"nout"`
|
|
||||||
Success bool `json:"success"`
|
|
||||||
Tx string `json:"tx"`
|
|
||||||
Txid string `json:"txid"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type ChannelListMineResponse []struct {
|
|
||||||
Address string `json:"address"`
|
|
||||||
Amount decimal.Decimal `json:"amount"`
|
|
||||||
BlocksToExpiration int `json:"blocks_to_expiration"`
|
|
||||||
CanSign bool `json:"can_sign"`
|
|
||||||
Category string `json:"category"`
|
|
||||||
ClaimID string `json:"claim_id"`
|
|
||||||
Confirmations int `json:"confirmations"`
|
|
||||||
DecodedClaim bool `json:"decoded_claim"`
|
|
||||||
ExpirationHeight int `json:"expiration_height"`
|
|
||||||
Expired bool `json:"expired"`
|
|
||||||
HasSignature bool `json:"has_signature"`
|
|
||||||
Height int `json:"height"`
|
|
||||||
Hex string `json:"hex"`
|
|
||||||
IsPending bool `json:"is_pending"`
|
|
||||||
IsSpent bool `json:"is_spent"`
|
|
||||||
Name string `json:"name"`
|
|
||||||
Nout int `json:"nout"`
|
|
||||||
Txid string `json:"txid"`
|
|
||||||
Value *lbryschema.Claim `json:"value"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type WalletListResponse []string
|
|
||||||
|
|
||||||
type PublishResponse struct {
|
|
||||||
ClaimID string `json:"claim_id"`
|
|
||||||
Fee decimal.Decimal `json:"fee"`
|
|
||||||
Nout int `json:"nout"`
|
|
||||||
Tx string `json:"tx"`
|
|
||||||
Txid string `json:"txid"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type BlobAnnounceResponse bool
|
|
||||||
|
|
||||||
type WalletPrefillAddressesResponse struct {
|
|
||||||
Broadcast bool `json:"broadcast"`
|
|
||||||
Complete bool `json:"complete"`
|
|
||||||
Hex string `json:"hex"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type UTXOListResponse []struct {
|
|
||||||
Address string `json:"address"`
|
|
||||||
Amount decimal.Decimal `json:"amount"`
|
|
||||||
Height int `json:"height"`
|
|
||||||
IsClaim bool `json:"is_claim"`
|
|
||||||
IsCoinbase bool `json:"is_coinbase"`
|
|
||||||
IsSupport bool `json:"is_support"`
|
|
||||||
IsUpdate bool `json:"is_update"`
|
|
||||||
Nout int `json:"nout"`
|
|
||||||
Txid string `json:"txid"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type WalletNewAddressResponse string
|
|
||||||
|
|
||||||
type WalletUnusedAddressResponse string
|
|
||||||
Loading…
Reference in a new issue