1
0
mirror of https://github.com/docker/docker-credential-helpers.git synced 2026-06-13 16:01:28 +05:30

Export credentials functions to be able to use them as a library.

Signed-off-by: David Calavera <david.calavera@gmail.com>
This commit is contained in:
David Calavera
2016-03-24 14:52:17 -04:00
parent 6bbb56ae3c
commit 039c315f22
3 changed files with 43 additions and 27 deletions
+32 -20
View File
@@ -10,36 +10,43 @@ import (
"strings" "strings"
) )
type credentialsGetResponse struct {
Username string
Secret string
}
// Serve initializes the credentials helper and parses the action argument. // Serve initializes the credentials helper and parses the action argument.
// This function is designed to be called from a command line interface.
// It uses os.Args[1] as the key for the action.
// It uses os.Stdin as input and os.Stdout as output.
// This function terminates the program with os.Exit(1) if there is an error.
func Serve(helper Helper) { func Serve(helper Helper) {
if err := handleCommand(helper); err != nil { var err error
if len(os.Args) != 2 {
err = fmt.Errorf("Usage: %s <store|get|erase>", os.Args[0])
}
if err == nil {
err = HandleCommand(helper, os.Args[1], os.Stdin, os.Stdout)
}
if err != nil {
fmt.Fprintf(os.Stdout, "%v\n", err) fmt.Fprintf(os.Stdout, "%v\n", err)
os.Exit(1) os.Exit(1)
} }
} }
func handleCommand(helper Helper) error { // HandleCommand uses a helper and a key to run a credential action.
if len(os.Args) != 2 { func HandleCommand(helper Helper, key string, in io.Reader, out io.Writer) error {
return fmt.Errorf("Usage: %s <store|get|erase>", os.Args[0]) switch key {
}
switch os.Args[1] {
case "store": case "store":
return store(helper, os.Stdin) return Store(helper, in)
case "get": case "get":
return get(helper, os.Stdin, os.Stdout) return Get(helper, in, out)
case "erase": case "erase":
return erase(helper, os.Stdin) return Erase(helper, in)
} }
return fmt.Errorf("Usage: %s <store|get|erase>", os.Args[0]) return fmt.Errorf("Unknown credential action `%s`", key)
} }
func store(helper Helper, reader io.Reader) error { // Store uses a helper and an input reader to save credentials.
// The reader must contain the JSON serialization of a Credentials struct.
func Store(helper Helper, reader io.Reader) error {
scanner := bufio.NewScanner(reader) scanner := bufio.NewScanner(reader)
buffer := new(bytes.Buffer) buffer := new(bytes.Buffer)
@@ -59,7 +66,10 @@ func store(helper Helper, reader io.Reader) error {
return helper.Add(&creds) return helper.Add(&creds)
} }
func get(helper Helper, reader io.Reader, writer io.Writer) error { // Get retrieves the credentials for a given server url.
// The reader must contain the server URL to search.
// The writer is used to write the JSON serialization of the credentials.
func Get(helper Helper, reader io.Reader, writer io.Writer) error {
scanner := bufio.NewScanner(reader) scanner := bufio.NewScanner(reader)
buffer := new(bytes.Buffer) buffer := new(bytes.Buffer)
@@ -78,7 +88,7 @@ func get(helper Helper, reader io.Reader, writer io.Writer) error {
return err return err
} }
resp := credentialsGetResponse{ resp := Credentials{
Username: username, Username: username,
Secret: secret, Secret: secret,
} }
@@ -92,7 +102,9 @@ func get(helper Helper, reader io.Reader, writer io.Writer) error {
return nil return nil
} }
func erase(helper Helper, reader io.Reader) error { // Erase removes credentials from the store.
// The reader must contain the server URL to remove.
func Erase(helper Helper, reader io.Reader) error {
scanner := bufio.NewScanner(reader) scanner := bufio.NewScanner(reader)
buffer := new(bytes.Buffer) buffer := new(bytes.Buffer)
+7 -7
View File
@@ -50,7 +50,7 @@ func TestStore(t *testing.T) {
in := bytes.NewReader(b) in := bytes.NewReader(b)
h := newMemoryStore() h := newMemoryStore()
if err := store(h, in); err != nil { if err := Store(h, in); err != nil {
t.Fatal(err) t.Fatal(err)
} }
@@ -82,13 +82,13 @@ func TestGet(t *testing.T) {
in := bytes.NewReader(b) in := bytes.NewReader(b)
h := newMemoryStore() h := newMemoryStore()
if err := store(h, in); err != nil { if err := Store(h, in); err != nil {
t.Fatal(err) t.Fatal(err)
} }
buf := strings.NewReader(serverURL) buf := strings.NewReader(serverURL)
w := new(bytes.Buffer) w := new(bytes.Buffer)
if err := get(h, buf, w); err != nil { if err := Get(h, buf, w); err != nil {
t.Fatal(err) t.Fatal(err)
} }
@@ -96,7 +96,7 @@ func TestGet(t *testing.T) {
t.Fatalf("expected output in the writer, got %d", w.Len()) t.Fatalf("expected output in the writer, got %d", w.Len())
} }
var c credentialsGetResponse var c Credentials
if err := json.NewDecoder(w).Decode(&c); err != nil { if err := json.NewDecoder(w).Decode(&c); err != nil {
t.Fatal(err) t.Fatal(err)
} }
@@ -124,17 +124,17 @@ func TestErase(t *testing.T) {
in := bytes.NewReader(b) in := bytes.NewReader(b)
h := newMemoryStore() h := newMemoryStore()
if err := store(h, in); err != nil { if err := Store(h, in); err != nil {
t.Fatal(err) t.Fatal(err)
} }
buf := strings.NewReader(serverURL) buf := strings.NewReader(serverURL)
if err := erase(h, buf); err != nil { if err := Erase(h, buf); err != nil {
t.Fatal(err) t.Fatal(err)
} }
w := new(bytes.Buffer) w := new(bytes.Buffer)
if err := get(h, buf, w); err == nil { if err := Get(h, buf, w); err == nil {
t.Fatal("expected error getting missing creds, got empty") t.Fatal("expected error getting missing creds, got empty")
} }
} }
+4
View File
@@ -11,8 +11,12 @@ type Credentials struct {
// Helper is the interface a credentials store helper must implement. // Helper is the interface a credentials store helper must implement.
type Helper interface { type Helper interface {
// Add appends credentials to the store.
Add(*Credentials) error Add(*Credentials) error
// Delete removes credentials from the store.
Delete(serverURL string) error Delete(serverURL string) error
// Get retrieves credentials from the store.
// It returns username and secret as strings.
Get(serverURL string) (string, string, error) Get(serverURL string) (string, string, error)
} }