kairos/kairos-sdk
1
0
Fork 0
mirror of https://github.com/kairos-io/kairos-sdk.git synced 2025-09-28 15:35:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Lint

Browse Source 
Signed-off-by: Itxaka <itxaka@kairos.io>
This commit is contained in:
Itxaka
2025-04-16 16:44:07 +02:00
parent ad27b44804
commit d6d4e50cfc
2 changed files with 10 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
kcrypt/bus/bus.go
View File

@@ -2,9 +2,9 @@ package bus
import (
"fmt"
"github.com/kairos-io/kairos-sdk/types"
"os"
"github.com/kairos-io/kairos-sdk/types"
"github.com/mudler/go-pluggable"
)
@@ -41,7 +41,7 @@ type Bus struct {
func (b *Bus) LoadProviders() {
wd, _ := os.Getwd()
b.Manager.Autoload(prefix, append(extensionPaths, wd)...).Register()
b.Autoload(prefix, append(extensionPaths, wd)...).Register()
}
func (b *Bus) Initialize() {
@@ -57,17 +57,16 @@ func (b *Bus) Initialize() {
log := types.NewKairosLogger("kcrypt", level, false)
b.LoadProviders()
for i := range b.Manager.Events {
e := b.Manager.Events[i]
b.Manager.Response(e, func(p *pluggable.Plugin, r *pluggable.EventResponse) {
for i := range b.Events {
e := b.Events[i]
b.Response(e, func(p *pluggable.Plugin, r *pluggable.EventResponse) {
log.Logger.Debug().Str("from", p.Name).Str("at", p.Executable).Str("type", string(e)).Msg("Received event from provider")
if r.Errored() {
log.Logger.Error().Err(fmt.Errorf(r.Error)).Str("from", p.Name).Str("at", p.Executable).Str("type", string(e)).Msg("Error in provider")
log.Logger.Error().Err(fmt.Errorf("%s", r.Error)).Str("from", p.Name).Str("at", p.Executable).Str("type", string(e)).Msg("Error in provider")
os.Exit(1)
} else {
if r.State != "" {
log.Logger.Debug().Str("state", r.State).Str("from", p.Name).Str("at", p.Executable).Str("type", string(e)).Msg("Received event from provider")
}
}
if r.State != "" {
log.Logger.Debug().Str("state", r.State).Str("from", p.Name).Str("at", p.Executable).Str("type", string(e)).Msg("Received event from provider")
}
})
}

2
kcrypt/unlock.go
View File

@@ -79,7 +79,7 @@ func UnlockDisk(b *block.Partition) error {
func getPassword(b *block.Partition) (password string, err error) {
bus.Reload()
bus.Manager.Response(bus.EventDiscoveryPassword, func(p *pluggable.Plugin, r *pluggable.EventResponse) {
bus.Manager.Response(bus.EventDiscoveryPassword, func(_ *pluggable.Plugin, r *pluggable.EventResponse) {
password = r.Data
if r.Errored() {
err = fmt.Errorf("failed discovery: %s", r.Error)