blob: 78c72286143f18f283c78bec2cf8bd201f4b97be [file] [log] [blame]
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
package oauth2
import (
const (
FILE = "file://"
DATA = "data://"
type KeyFileProvider struct {
KeyFile string
type KeyFile struct {
Type string `json:"type"`
ClientID string `json:"client_id"`
ClientSecret string `json:"client_secret"`
ClientEmail string `json:"client_email"`
IssuerURL string `json:"issuer_url"`
func NewClientCredentialsProviderFromKeyFile(keyFile string) *KeyFileProvider {
return &KeyFileProvider{
KeyFile: keyFile,
var _ ClientCredentialsProvider = &KeyFileProvider{}
func (k *KeyFileProvider) GetClientCredentials() (*KeyFile, error) {
var keyFile []byte
var err error
switch {
case strings.HasPrefix(k.KeyFile, FILE):
filename := strings.TrimPrefix(k.KeyFile, FILE)
keyFile, err = ioutil.ReadFile(filename)
case strings.HasPrefix(k.KeyFile, "data://"):
keyFile = []byte(strings.TrimPrefix(k.KeyFile, DATA))
keyFile, err = ioutil.ReadFile(k.KeyFile)
if err != nil {
return nil, err
var v KeyFile
err = json.Unmarshal(keyFile, &v)
if err != nil {
return nil, err
return &v, nil