mirror of
https://github.com/amir20/dozzle.git
synced 2025-12-21 13:23:07 +01:00
36 lines
1.0 KiB
Go
36 lines
1.0 KiB
Go
package cli
|
|
|
|
import (
|
|
"context"
|
|
"embed"
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
|
|
"github.com/amir20/dozzle/internal/healthcheck"
|
|
"github.com/rs/zerolog/log"
|
|
)
|
|
|
|
type HealthcheckCmd struct{}
|
|
|
|
func (h *HealthcheckCmd) Run(args Args, embeddedCerts embed.FS) error {
|
|
if matches, err := filepath.Glob("/tmp/agent-*.addr"); err == nil && len(matches) == 1 {
|
|
data, err := os.ReadFile(matches[0])
|
|
if err != nil {
|
|
return fmt.Errorf("failed to read file: %w", err)
|
|
}
|
|
agentAddress := string(data)
|
|
certs, err := ReadCertificates(embeddedCerts, args.CertPath, args.KeyPath)
|
|
if err != nil {
|
|
return fmt.Errorf("failed to read certificates: %w", err)
|
|
}
|
|
ctx, cancel := context.WithTimeout(context.Background(), args.Timeout)
|
|
defer cancel()
|
|
log.Info().Str("address", agentAddress).Msg("Making RPC request to agent")
|
|
return healthcheck.RPCRequest(ctx, agentAddress, certs)
|
|
} else {
|
|
log.Info().Str("address", args.Addr).Str("base", args.Base).Msg("Making HTTP request to server")
|
|
return healthcheck.HttpRequest(args.Addr, args.Base)
|
|
}
|
|
}
|