Method LoadAuth

config/auth.go:114–169

(ctx context.Context)

}

func (a *CliAuthenticator) LoadAuth(ctx context.Context) (*scalingo.User, *auth.UserToken, error) {
	file, err := os.OpenFile(C.AuthFile, os.O_RDONLY, 0600)
	if os.IsNotExist(err) {
		return nil, nil, ErrUnauthenticated
	}
	if err != nil {
		return nil, nil, errors.Wrapf(ctx, err, "open authentication file for read")
	}

	var authConfig auth.ConfigData
	if err := json.NewDecoder(file).Decode(&authConfig); err != nil {
		file.Close()
		return nil, nil, errors.Wrapf(ctx, err, "decode authentication file")
	}
	file.Close()

	if authConfig.AuthDataVersion != auth.ConfigVersionV2 && authConfig.AuthDataVersion != auth.ConfigVersionV21 {
		err = writeAuthFile(ctx, &authConfig)
		if err != nil {
			return nil, nil, errors.Wrapf(ctx, err, "fail to update to authv2")
		}
		return nil, nil, ErrUnauthenticated
	}

	var configPerHost auth.ConfigPerHostV2
	err = json.Unmarshal(authConfig.AuthConfigPerHost, &configPerHost)
	if err != nil {
		return nil, nil, errors.Wrapf(ctx, err, "unmarshal authentication config per host")
	}

	if authConfig.AuthDataVersion == auth.ConfigVersionV2 {
		authConfig.AuthDataVersion = auth.ConfigVersionV21
		configPerHost["auth.scalingo.com"] = configPerHost["api.scalingo.com"]
		delete(configPerHost, "api.scalingo.com")
		buffer, err := json.Marshal(&configPerHost)
		if err != nil {
			return nil, nil, errors.Wrapf(ctx, err, "migrate auth config v2.0 to v2.1")
		}
		authConfig.AuthConfigPerHost = json.RawMessage(buffer)
		err = writeAuthFile(ctx, &authConfig)
		if err != nil {
			return nil, nil, errors.Wrapf(ctx, err, "migrate auth config v2.0 to v2.1")
		}
	}

	authHost, err := a.authHost(ctx)
	if err != nil {
		return nil, nil, errors.Wrapf(ctx, err, "fail to get authentication service host")
	}

	creds, ok := configPerHost[authHost]
	if !ok || creds.User == nil {
		return nil, nil, ErrUnauthenticated
	}
	return creds.User, creds.Tokens, nil
}

func (a *CliAuthenticator) RemoveAuth(ctx context.Context) error {