aboutsummaryrefslogtreecommitdiffstats
path: root/auth/file_source.go
blob: 1c1150b49629fb7f15b5647f94719223e7a10864 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
package auth

import (
    "golang.org/x/oauth2"
    "encoding/json"
    "os"
    "io/ioutil"
)


func FileSource(path string, token *oauth2.Token, conf *oauth2.Config) oauth2.TokenSource {
    return &fileSource{
        tokenPath: path,
        tokenSource: conf.TokenSource(oauth2.NoContext, token),
    }
}

type fileSource struct {
    tokenPath string
    tokenSource oauth2.TokenSource
}

func (self *fileSource) Token() (*oauth2.Token, error) {
    token, err := self.tokenSource.Token()
    if err != nil {
        return token, err
    }

    // Save token to file
    SaveToken(self.tokenPath, token)

    return token, nil
}

func ReadToken(path string) (*oauth2.Token, bool, error) {
    if !fileExists(path) {
        return nil, false, nil
    }

    content, err := ioutil.ReadFile(path)
    if err != nil {
        return nil, true, err
    }
    token := &oauth2.Token{}
    return token, true, json.Unmarshal(content, token)
}

func SaveToken(path string, token *oauth2.Token) error {
    data, err := json.MarshalIndent(token, "", "  ")
    if err != nil {
        return err
    }

    if err = mkdir(path); err != nil {
        return err
    }

    // Write to temp file first
    tmpFile := path + ".tmp"
    err = ioutil.WriteFile(tmpFile, data, 0600)
    if err != nil {
        os.Remove(tmpFile)
        return err
    }

    // Move file to correct path
    return os.Rename(tmpFile, path)
}