efritz/ij

package registry

import (
    "context"
    "fmt"
    "io/ioutil"

    "github.com/efritz/ij/command"
    "github.com/efritz/ij/config"
    "github.com/efritz/ij/environment"
    "github.com/efritz/ij/logging"
)

type gcrLogin struct {
    ctx      context.Context
    logger   logging.Logger
    env      environment.Environment
    registry *config.GCRRegistry
    runner   command.Runner
}

func NewGCRLogin(
    ctx context.Context,
    logger logging.Logger,
    env environment.Environment,
    registry *config.GCRRegistry,
) Login {
    return newGCRLogin(
        ctx,
        logger,
        env,
        registry,
        command.NewRunner(logger),
    )
}

func newGCRLogin(
    ctx context.Context,
    logger logging.Logger,
    env environment.Environment,
    registry *config.GCRRegistry,
    runner command.Runner,
) Login {
    return &gcrLogin{
        ctx:      ctx,
        logger:   logger,
        env:      env,
        registry: registry,
        runner:   runner,
    }
}

func (l *gcrLogin) GetServer() (string, error) {
    return fmt.Sprintf("https://%s", l.registry.Hostname), nil
}

func (l *gcrLogin) Login() error {
    server, err := l.GetServer()
    if err != nil {
        return err
    }

    password, err := getGCRPassword(l.env, l.registry)
    if err != nil {
        return err
    }

    return login(
        l.ctx,
        l.runner,
        server,
        "_json_key",
        string(password),
    )
}

func getGCRPassword(
    env environment.Environment,
    registry *config.GCRRegistry,
) (string, error) {
    key, err := env.ExpandString(registry.Key)
    if err != nil {
        return "", err
    }

    if key != "" {
        return key, nil
    }

    keyFile, err := env.ExpandString(registry.KeyFile)
    if err != nil {
        return "", err
    }

    password, err := ioutil.ReadFile(keyFile)
    if err != nil {
        return "", err
    }

    return string(password), nil
}