Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions input/chainsync/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,15 +27,15 @@ import (

var cmdlineOptions struct {
network string
networkMagic uint
address string
socketPath string
intersectPoint string
networkMagic uint
delayConfirmations uint
ntcTcp bool
intersectTip bool
intersectPoint string
includeCbor bool
autoReconnect bool
delayConfirmations uint
}

func init() {
Expand Down
2 changes: 1 addition & 1 deletion input/chainsync/transaction_output.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@ import (
// ResolvedTransactionOutput represents a concrete implementation of the TransactionOutput interface
type ResolvedTransactionOutput struct {
AddressField common.Address `json:"address"`
AmountField uint64 `json:"amount"`
AssetsField *common.MultiAsset[uint64] `json:"assets,omitempty"`
AmountField uint64 `json:"amount"`
}

func ExtractAssetDetailsFromMatch(
Expand Down
6 changes: 3 additions & 3 deletions internal/config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,14 @@ const (
)

type Config struct {
Api ApiConfig `yaml:"api"`
Logging LoggingConfig `yaml:"logging"`
Debug DebugConfig `yaml:"debug"`
Plugin map[string]map[string]map[any]any `yaml:"plugins"`
Logging LoggingConfig `yaml:"logging"`
ConfigFile string `yaml:"-"`
Input string `yaml:"input" envconfig:"INPUT"`
Output string `yaml:"output" envconfig:"OUTPUT"`
KupoUrl string `yaml:"kupo_url" envconfig:"KUPO_URL"`
Api ApiConfig `yaml:"api"`
Debug DebugConfig `yaml:"debug"`
Version bool `yaml:"-"`
}

Expand Down
2 changes: 1 addition & 1 deletion output/push/fcm/message.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,9 @@ type Message struct {
}

type MessageContent struct {
Token string `json:"token"`
Notification *NotificationContent `json:"notification,omitempty"`
Data map[string]any `json:"data,omitempty"`
Token string `json:"token"`
}

type NotificationContent struct {
Expand Down
6 changes: 3 additions & 3 deletions pipeline/pipeline.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,13 +24,13 @@ import (
)

type Pipeline struct {
inputs []plugin.Plugin
filters []plugin.Plugin
outputs []plugin.Plugin
filterChan chan event.Event
outputChan chan event.Event
errorChan chan error
doneChan chan bool
inputs []plugin.Plugin
filters []plugin.Plugin
outputs []plugin.Plugin
wg sync.WaitGroup
stopOnce sync.Once
}
Expand Down
6 changes: 3 additions & 3 deletions plugin/option.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,13 +32,13 @@ const (
)

type PluginOption struct {
DefaultValue any
Dest any
Name string
Type PluginOptionType
CustomEnvVar string
CustomFlag string
Description string
DefaultValue any
Dest any
Type PluginOptionType
}

func (p *PluginOption) AddToFlagSet(
Expand Down
4 changes: 2 additions & 2 deletions plugin/register.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,11 +41,11 @@ func PluginTypeName(pluginType PluginType) string {
}

type PluginEntry struct {
Type PluginType
NewFromOptionsFunc func() Plugin
Name string
Description string
Options []PluginOption
NewFromOptionsFunc func() Plugin
Type PluginType
}

var pluginEntries []PluginEntry
Expand Down