Skip to content

Commit

Permalink
fix(cross-region-prop): fixing standards
Browse files Browse the repository at this point in the history
  • Loading branch information
0x0elliot committed Mar 7, 2024
1 parent d71beba commit 0ee2fd9
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions db-connector.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,8 @@ var requestCache = cache.New(60*time.Minute, 60*time.Minute)
var memcached = os.Getenv("SHUFFLE_MEMCACHED")
var mc = gomemcache.New(memcached)
var gceProject = os.Getenv("SHUFFLE_GCEPROJECT")
var propagateUrl = os.Getenv("SHUFFLE_PROPAGATE_URL")
var propagateToken = os.Getenv("SHUFFLE_PROPAGATE_TOKEN")

var maxCacheSize = 1020000

Expand Down Expand Up @@ -3481,7 +3483,6 @@ func propagateOrg(org Org) error {
return errors.New("no ID provided for org")
}

propagateUrl := os.Getenv("PROPAGATE_URL")
if len(propagateUrl) == 0 {
return errors.New("no PROPAGATE_URL provided")
}
Expand All @@ -3502,7 +3503,7 @@ func propagateOrg(org Org) error {

// Set headers
req.Header.Set("Content-Type", "application/json")
req.Header.Set("Authorization", os.Getenv("PROPAGATE_TOKEN"))
req.Header.Set("Authorization", propagateToken)

// Send the request via a client
client := &http.Client{}
Expand All @@ -3527,7 +3528,6 @@ func propagateUser(user User) error {
return errors.New("no ID provided for user")
}

propagateUrl := os.Getenv("PROPAGATE_URL")
if len(propagateUrl) == 0 {
return errors.New("no PROPAGATE_URL provided")
}
Expand All @@ -3548,7 +3548,7 @@ func propagateUser(user User) error {

// Set headers
req.Header.Set("Content-Type", "application/json")
req.Header.Set("Authorization", os.Getenv("PROPAGATE_TOKEN"))
req.Header.Set("Authorization", propagateToken)

// Send the request via a client
client := &http.Client{}
Expand Down

0 comments on commit 0ee2fd9

Please sign in to comment.