mirror
/
moonstream
kopia lustrzana https://github.com/bugout-dev/moonstream
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Renamed env var for nb app id

pull/787/head
kompotkot 2023-05-31 12:05:57 +00:00
rodzic 8cff6ba00f
commit f6883d87a9
5 zmienionych plików z 10 dodań i 10 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

10
nodes/node_balancer/cmd/nodebalancer/cli.go
Wyświetl plik

@ -260,14 +260,14 @@ func cli() {
NB_CONTROLLER_TOKEN, NB_CONTROLLER_TOKEN,
map[string]string{ map[string]string{
"user_id": proposedClientResourceData.UserID, "user_id": proposedClientResourceData.UserID,
"application_id": NB_APPLICATION_ID, "application_id": MOONSTREAM_APPLICATION_ID,
}, },
) )
if err != nil { if err != nil {
fmt.Printf("User does not exists, err: %v\n", err) fmt.Printf("User does not exists, err: %v\n", err)
os.Exit(1) os.Exit(1)
} }
resource, err := bugoutClient.Brood.CreateResource(NB_CONTROLLER_TOKEN, NB_APPLICATION_ID, proposedClientResourceData) resource, err := bugoutClient.Brood.CreateResource(NB_CONTROLLER_TOKEN, MOONSTREAM_APPLICATION_ID, proposedClientResourceData)
if err != nil { if err != nil {
fmt.Printf("Unable to create user access, err: %v\n", err) fmt.Printf("Unable to create user access, err: %v\n", err)
os.Exit(1) os.Exit(1)
@ -304,7 +304,7 @@ func cli() {
} }
resources, err := bugoutClient.Brood.GetResources( resources, err := bugoutClient.Brood.GetResources(
NB_CONTROLLER_TOKEN, NB_CONTROLLER_TOKEN,
NB_APPLICATION_ID, MOONSTREAM_APPLICATION_ID,
queryParameters, queryParameters,
) )
if err != nil { if err != nil {
@ -408,7 +408,7 @@ func cli() {
} }
resources, err := bugoutClient.Brood.GetResources( resources, err := bugoutClient.Brood.GetResources(
NB_CONTROLLER_TOKEN, NB_CONTROLLER_TOKEN,
NB_APPLICATION_ID, MOONSTREAM_APPLICATION_ID,
queryParameters, queryParameters,
) )
if err != nil { if err != nil {
@ -466,7 +466,7 @@ func cli() {
} }
resources, err := bugoutClient.Brood.GetResources( resources, err := bugoutClient.Brood.GetResources(
NB_CONTROLLER_TOKEN, NB_CONTROLLER_TOKEN,
NB_APPLICATION_ID, MOONSTREAM_APPLICATION_ID,
queryParameters, queryParameters,
) )
if err != nil { if err != nil {

2
nodes/node_balancer/cmd/nodebalancer/configs.go
Wyświetl plik

@ -23,7 +23,7 @@ var (
// Bugout and application configuration // Bugout and application configuration
BUGOUT_AUTH_CALL_TIMEOUT = time.Second * 5 BUGOUT_AUTH_CALL_TIMEOUT = time.Second * 5
NB_APPLICATION_ID = os.Getenv("NB_APPLICATION_ID") MOONSTREAM_APPLICATION_ID = os.Getenv("MOONSTREAM_APPLICATION_ID")
NB_CONTROLLER_TOKEN = os.Getenv("NB_CONTROLLER_TOKEN") NB_CONTROLLER_TOKEN = os.Getenv("NB_CONTROLLER_TOKEN")
NB_CONTROLLER_ACCESS_ID = os.Getenv("NB_CONTROLLER_ACCESS_ID") NB_CONTROLLER_ACCESS_ID = os.Getenv("NB_CONTROLLER_ACCESS_ID")

4
nodes/node_balancer/cmd/nodebalancer/middleware.go
Wyświetl plik

@ -225,7 +225,7 @@ func fetchClientAccessFromResources(accessID, authorizationToken string, tsNow i
var resources brood.Resources var resources brood.Resources
resources, err = bugoutClient.Brood.GetResources( resources, err = bugoutClient.Brood.GetResources(
token, token,
NB_APPLICATION_ID, MOONSTREAM_APPLICATION_ID,
queryParameters, queryParameters,
) )
if err != nil { if err != nil {
@ -242,7 +242,7 @@ func fetchClientAccessFromResources(accessID, authorizationToken string, tsNow i
return nil, fmt.Errorf("unable to find user with provided authorization token") return nil, fmt.Errorf("unable to find user with provided authorization token")
} }
newResource, err := bugoutClient.Brood.CreateResource( newResource, err := bugoutClient.Brood.CreateResource(
NB_CONTROLLER_TOKEN, NB_APPLICATION_ID, ClientResourceData{ NB_CONTROLLER_TOKEN, MOONSTREAM_APPLICATION_ID, ClientResourceData{
UserID: user.Id, UserID: user.Id,
AccessID: uuid.New().String(), AccessID: uuid.New().String(),
Name: user.Username, Name: user.Username,

2
nodes/node_balancer/cmd/nodebalancer/server.go
Wyświetl plik

@ -121,7 +121,7 @@ func Server() {
// Fetch access id for internal usage (crawlers, infrastructure, etc) // Fetch access id for internal usage (crawlers, infrastructure, etc)
resources, err := bugoutClient.Brood.GetResources( resources, err := bugoutClient.Brood.GetResources(
NB_CONTROLLER_TOKEN, NB_CONTROLLER_TOKEN,
NB_APPLICATION_ID, MOONSTREAM_APPLICATION_ID,
map[string]string{"access_id": NB_CONTROLLER_ACCESS_ID}, map[string]string{"access_id": NB_CONTROLLER_ACCESS_ID},
) )
if err != nil { if err != nil {

2
nodes/node_balancer/sample.env
Wyświetl plik

@ -1,6 +1,6 @@
# Required environment variables for load balancer # Required environment variables for load balancer
export BUGOUT_BROOD_URL="https://auth.bugout.dev" export BUGOUT_BROOD_URL="https://auth.bugout.dev"
export NB_APPLICATION_ID="<application_id_to_controll_access>" export MOONSTREAM_APPLICATION_ID="<application_id_to_controll_access>"
export NB_CONTROLLER_TOKEN="<token_of_controller_user>" export NB_CONTROLLER_TOKEN="<token_of_controller_user>"
export NB_CONTROLLER_ACCESS_ID="<controller_access_id_for_internal_usage>" export NB_CONTROLLER_ACCESS_ID="<controller_access_id_for_internal_usage>"