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

Revert "Fix nodebalancer CLI and removed autogen accesses"

pull/1147/head
Sergei Sumarokov 2024-12-13 12:55:37 +03:00 zatwierdzone przez GitHub
rodzic be2086d8a7
commit d0a5226b0c
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: B5690EEEBB952194
12 zmienionych plików z 629 dodań i 774 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

29
nodebalancer/README.md
Wyświetl plik

@ -3,36 +3,37 @@
## Installation
- Prepare environment variables, according to `sample.env`.
- Build an application
- Build application
```bash
go build -o nodebalancer .
```
## CLI
## Work with nodebalancer
**IMPORTANT** Do not use flag `-debug` in production.
Node balancer access manipulation requires an administration token to create and modify resources within the Bugout moonstream application.
### add new access
### add-access
Add new access for user:
```bash
./nodebalancer access add \
--access-token "<bugout_access_token>"
nodebalancer add-access \
--user-id "<user_uuid>" \
--access-id "<access_uuid>" \
--name "Access name" \
--description "Description of access"
--description "Description of access" \
--extended-methods false \
--blockchain--access true
```
### delete access
### delete-access
Delete user access:
```bash
./nodebalancer access delete \
--access-token "<bugout_access_token>"
nodebalancer delete-access \
--user-id "<user_uuid>" \
--access-id "<access_uuid>"
```
@ -41,10 +42,10 @@ If `access-id` not specified, all user accesses will be deleted.
### users
```bash
./nodebalancer access list --access-token "<bugout_access_token>" | jq .
nodebalancer users | jq .
```
This command will return a list of bugout resources of registered users to access node balancer.
This command will return a list of bugout resources of registered users to access node balancer with their `crawlers/app/project` (in our project we will call it `crawlers`).
```json
[
@ -71,7 +72,7 @@ This command will return a list of bugout resources of registered users to acces
### server
```bash
./nodebalancer server --host 0.0.0.0 --port 8544 --healthcheck
nodebalancer server -host 0.0.0.0 -port 8544 -healthcheck
```
Flag `--healthcheck` will execute background process to ping-pong available nodes to keep their status and current block number.

1055
nodebalancer/cmd/nodebalancer/cli.go
Wyświetl plik

Plik diff jest za duży Load Diff

115
nodebalancer/cmd/nodebalancer/clients.go
Wyświetl plik

@ -1,15 +1,10 @@
package main
import (
"encoding/json"
"fmt"
"log"
"reflect"
"sync"
"time"
"github.com/bugout-dev/bugout-go/pkg/brood"
"github.com/google/uuid"
)
var (
@ -60,7 +55,7 @@ func (ca *ClientAccess) CheckClientCallPeriodLimits(tsNow int64) bool {
}
} else {
// Client period should be refreshed
if NB_ENABLE_DEBUG {
if stateCLI.enableDebugFlag {
log.Printf("Refresh client's period_start_ts with time.now() and reset calls_per_period")
}
ca.ClientResourceData.CallsPerPeriod = 0
@ -193,111 +188,3 @@ func (cpool *ClientPool) CleanInactiveClientNodes() int {
return cnt
}
// Creates new Bugout resource according to nodebalancer type to grant user or application access to call JSON RPC nodes
func AddNewAccess(accessToken, accessId, userId, name, description string, blockchainAccess, extendedMethods bool, periodDuration, maxCallsPerPeriod uint) (*ClientAccess, error) {
if userId == "" {
userId = NB_CONTROLLER_USER_ID
} else {
_, findErr := bugoutClient.Brood.FindUser(
accessToken,
map[string]string{
"user_id": userId,
"application_id": MOONSTREAM_APPLICATION_ID,
},
)
if findErr != nil {
return nil, fmt.Errorf("user does not exists, err: %v", findErr)
}
}
if accessId == "" {
accessId = uuid.NewString()
}
proposedClientResourceData := ClientResourceData{
AccessID: accessId,
UserID: userId,
Name: name,
Description: description,
BlockchainAccess: blockchainAccess,
ExtendedMethods: extendedMethods,
PeriodDuration: int64(periodDuration),
PeriodStartTs: int64(time.Now().Unix()),
MaxCallsPerPeriod: int64(maxCallsPerPeriod),
CallsPerPeriod: 0,
Type: BUGOUT_RESOURCE_TYPE_NODEBALANCER_ACCESS,
}
resource, err := bugoutClient.Brood.CreateResource(accessToken, MOONSTREAM_APPLICATION_ID, proposedClientResourceData)
if err != nil {
return nil, fmt.Errorf("unable to create user access, err: %v", err)
}
resourceData, err := json.Marshal(resource.ResourceData)
if err != nil {
return nil, fmt.Errorf("unable to encode resource %s data interface to json, err: %v", resource.Id, err)
}
var newUserAccess ClientAccess
err = json.Unmarshal(resourceData, &newUserAccess)
if err != nil {
return nil, fmt.Errorf("unable to decode resource %s data json to structure, err: %v", resource.Id, err)
}
newUserAccess.ResourceID = resource.Id
return &newUserAccess, nil
}
// Share access represented as Brood resource with new holder. Mostly used to share with nodebalancer application user
func ShareAccess(accessToken, resourceId, userId, holderType string, permissions []string) (*brood.ResourceHolders, error) {
resourceHolderPermissions, holdErr := bugoutClient.Brood.AddResourceHolderPermissions(
accessToken, resourceId, brood.ResourceHolder{
Id: userId,
HolderType: holderType,
Permissions: permissions,
},
)
if holdErr != nil {
return nil, fmt.Errorf("unable to grant permissions to user with ID %s at resource with ID %s, err: %v", userId, resourceId, holdErr)
}
return &resourceHolderPermissions, nil
}
// Get resource with nodebalancer access type
func GetResources(accessToken, accessId, userId string) (*brood.Resources, error) {
queryParameters := map[string]string{
"type": BUGOUT_RESOURCE_TYPE_NODEBALANCER_ACCESS,
}
if userId != "" {
queryParameters["user_id"] = userId
}
if accessId != "" {
queryParameters["access_id"] = accessId
}
resources, getResErr := bugoutClient.Brood.GetResources(accessToken, MOONSTREAM_APPLICATION_ID, queryParameters)
if getResErr != nil {
return nil, fmt.Errorf("unable to get Bugout resources, err: %v", getResErr)
}
return &resources, nil
}
// Parse Brood resource to nodebalancer client access representation
func ParseResourceDataToClientAccess(resource brood.Resource) (*ClientAccess, error) {
resourceData, marErr := json.Marshal(resource.ResourceData)
if marErr != nil {
return nil, fmt.Errorf("unable to encode resource %s data interface to json, err: %v", resource.Id, marErr)
}
var clientAccess ClientAccess
clientAccess.ResourceID = resource.Id
unmarErr := json.Unmarshal(resourceData, &clientAccess.ClientResourceData)
if unmarErr != nil {
return nil, fmt.Errorf("unable to decode resource %s data json to structure, err: %v", resource.Id, unmarErr)
}
return &clientAccess, nil
}

17
nodebalancer/cmd/nodebalancer/configs.go
Wyświetl plik

@ -23,25 +23,20 @@ var (
supportedBlockchains map[string]bool
bugoutClient *bugout.BugoutClient
// Bugout client
// TODO(kompotkot): Find out why it cuts out the port
// BUGOUT_BROOD_URL = "https://auth.bugout.dev"
BUGOUT_BROOD_URL = os.Getenv("BUGOUT_BROOD_URL")
BUGOUT_BROOD_URL = "https://auth.bugout.dev"
// BUGOUT_BROOD_URL = os.Getenv("BUGOUT_BROOD_URL")
NB_BUGOUT_TIMEOUT_SECONDS_RAW = os.Getenv("NB_BUGOUT_TIMEOUT_SECONDS")
// Bugout and application configuration
BUGOUT_AUTH_CALL_TIMEOUT = time.Second * 5
MOONSTREAM_APPLICATION_ID = os.Getenv("MOONSTREAM_APPLICATION_ID")
NB_CONTROLLER_USER_ID = os.Getenv("NB_CONTROLLER_USER_ID")
NB_CONTROLLER_TOKEN = os.Getenv("NB_CONTROLLER_TOKEN")
NB_CONTROLLER_ACCESS_ID = os.Getenv("NB_CONTROLLER_ACCESS_ID")
MOONSTREAM_CORS_ALLOWED_ORIGINS = os.Getenv("MOONSTREAM_CORS_ALLOWED_ORIGINS")
CORS_WHITELIST_MAP = make(map[string]bool)
NB_ENABLE_DEBUG = false
NB_CONNECTION_RETRIES = 2
NB_CONNECTION_RETRIES_INTERVAL = time.Millisecond * 10
NB_HEALTH_CHECK_INTERVAL = os.Getenv("NB_HEALTH_CHECK_INTERVAL")
@ -69,15 +64,15 @@ var (
DEFAULT_AUTOGENERATED_MAX_CALLS_PER_PERIOD = int64(1000)
)
func CreateBugoutClient() (*bugout.BugoutClient, error) {
func CreateBugoutClient() (bugout.BugoutClient, error) {
bugoutTimeoutSeconds, err := strconv.Atoi(NB_BUGOUT_TIMEOUT_SECONDS_RAW)
if err != nil {
return nil, fmt.Errorf("unable to parse environment variable as integer: %v", err)
return bugout.BugoutClient{}, fmt.Errorf("unable to parse environment variable as integer: %v", err)
}
NB_BUGOUT_TIMEOUT_SECONDS := time.Duration(bugoutTimeoutSeconds) * time.Second
bugoutClient := bugout.ClientBrood(BUGOUT_BROOD_URL, NB_BUGOUT_TIMEOUT_SECONDS)
return &bugoutClient, nil
broodClient := bugout.ClientBrood(BUGOUT_BROOD_URL, NB_BUGOUT_TIMEOUT_SECONDS)
return broodClient, nil
}
func CheckEnvVarSet() {

10
nodebalancer/cmd/nodebalancer/main.go
Wyświetl plik

@ -1,13 +1,5 @@
package main
import (
"log"
"os"
)
func main() {
app := NodebalancerAppCli()
if err := app.Run(os.Args); err != nil {
log.Fatal(err)
}
cli()
}

56
nodebalancer/cmd/nodebalancer/middleware.go
Wyświetl plik

@ -236,12 +236,50 @@ func fetchClientAccessFromResources(accessID, authorizationToken string, tsNow i
if len(resources.Resources) == 0 {
if authorizationToken != "" {
// Generate new autogenerated access resource with default parameters and grant user permissions to work with it
// TODO(kompotkot): Not working because of permissions models changed at Brood layer
return nil, fmt.Errorf("unsupported authentication method")
user, err := bugoutClient.Brood.GetUser(authorizationToken)
if err != nil {
log.Printf("Unable to get user, err: %v", err)
return nil, fmt.Errorf("unable to find user with provided authorization token")
}
newResource, err := bugoutClient.Brood.CreateResource(
NB_CONTROLLER_TOKEN, MOONSTREAM_APPLICATION_ID, ClientResourceData{
UserID: user.Id,
AccessID: uuid.New().String(),
Name: user.Username,
Description: "Autogenerated access ID",
BlockchainAccess: true,
ExtendedMethods: false,
PeriodDuration: DEFAULT_AUTOGENERATED_PERIOD_DURATION,
PeriodStartTs: tsNow,
MaxCallsPerPeriod: DEFAULT_AUTOGENERATED_MAX_CALLS_PER_PERIOD,
CallsPerPeriod: 0,
Type: BUGOUT_RESOURCE_TYPE_NODEBALANCER_ACCESS,
},
)
if err != nil {
log.Printf("Unable to create resource with autogenerated access for user with ID %s, err: %v", user.Id, err)
return nil, fmt.Errorf("unable to create resource with autogenerated access for user")
}
resourceHolderPermissions, err := bugoutClient.Brood.AddResourceHolderPermissions(
NB_CONTROLLER_TOKEN, newResource.Id, brood.ResourceHolder{
Id: user.Id,
HolderType: "user",
Permissions: DEFAULT_AUTOGENERATED_USER_PERMISSIONS,
},
)
if err != nil {
log.Printf("Unable to grant permissions to user with ID %s at resource with ID %s, err: %v", newResource.Id, user.Id, err)
return nil, fmt.Errorf("unable to create resource with autogenerated access for user")
}
log.Printf("Created new resource with ID %s with autogenerated access for user with ID %s", resourceHolderPermissions.ResourceId, user.Id)
resources.Resources = append(resources.Resources, newResource)
} else {
return nil, fmt.Errorf("there are no provided access identifier")
}
} else if len(resources.Resources) > 1 {
// TODO(kompotkot): Write support of multiple resources, be careful, because NB_CONTROLLER has several resources
return nil, fmt.Errorf("there are no provided access identifier")
@ -441,7 +479,7 @@ func logMiddleware(next http.Handler) http.Handler {
}
}
if NB_ENABLE_DEBUG {
if stateCLI.enableDebugFlag {
if r.URL.RawQuery != "" {
logStr += fmt.Sprintf(" %s", r.URL.RawQuery)
}
@ -488,14 +526,14 @@ func accessMiddleware(next http.Handler) http.Handler {
// If access id does not belong to internal crawlers, then check cache or find it in Bugout resources
if accessID != "" && accessID == NB_CONTROLLER_ACCESS_ID {
if NB_ENABLE_DEBUG {
if stateCLI.enableDebugFlag {
log.Printf("Access ID belongs to internal usage for user with ID %s", currentClientAccess.ClientResourceData.UserID)
}
currentClientAccess = internalUsageAccess
currentClientAccess.LastAccessTs = tsNow
currentClientAccess.requestedDataSource = requestedDataSource
} else if accessID != "" && accessCache.isAccessIdInCache(accessID) {
if NB_ENABLE_DEBUG {
if stateCLI.enableDebugFlag {
log.Printf("Access ID found in cache for user with ID %s", currentClientAccess.ClientResourceData.UserID)
}
currentClientAccess = *accessCache.accessIds[accessID]
@ -507,7 +545,7 @@ func accessMiddleware(next http.Handler) http.Handler {
currentClientAccess.requestedDataSource = requestedDataSource
accessCache.UpdateAccessAtCache(accessID, authorizationToken, requestedDataSource, tsNow)
} else if accessID == "" && accessCache.isAuthorizationTokenInCache(authorizationToken) {
if NB_ENABLE_DEBUG {
if stateCLI.enableDebugFlag {
log.Printf("Client connected with Authorization token")
}
currentClientAccess = *accessCache.authorizationTokens[authorizationToken]
@ -519,7 +557,7 @@ func accessMiddleware(next http.Handler) http.Handler {
currentClientAccess.requestedDataSource = requestedDataSource
accessCache.UpdateAccessAtCache(accessID, authorizationToken, requestedDataSource, tsNow)
} else {
if NB_ENABLE_DEBUG {
if stateCLI.enableDebugFlag {
log.Printf("No access identity found in cache, looking at Brood resources")
}
@ -543,7 +581,7 @@ func accessMiddleware(next http.Handler) http.Handler {
if authorizationToken != "" && accessCache.isAccessIdInCache(currentClientAccess.ClientResourceData.AccessID) {
accessCache.authorizationTokens[authorizationToken] = accessCache.accessIds[currentClientAccess.ClientResourceData.AccessID]
} else {
if NB_ENABLE_DEBUG {
if stateCLI.enableDebugFlag {
log.Printf("Adding new access identifier in cache")
}
err := accessCache.AddAccessToCache(currentClientAccess, tsNow)

71
nodebalancer/cmd/nodebalancer/server.go
Wyświetl plik

@ -5,11 +5,13 @@ package main
import (
"context"
"encoding/json"
"fmt"
"log"
"net/http"
"net/http/httputil"
"net/url"
"os"
"strconv"
"strings"
"time"
@ -105,7 +107,7 @@ func proxyErrorHandler(proxy *httputil.ReverseProxy, url *url.URL) {
}
}
func Server(configPath, listeningHostAddr, listeningPort string, enableHealthCheck bool) error {
func Server() {
// Create Access ID cache
CreateAccessCache()
@ -115,26 +117,47 @@ func Server(configPath, listeningHostAddr, listeningPort string, enableHealthChe
consent := humbug.CreateHumbugConsent(humbug.True)
reporter, err = humbug.CreateHumbugReporter(consent, "moonstream-node-balancer", sessionID, HUMBUG_REPORTER_NB_TOKEN)
if err != nil {
return fmt.Errorf("invalid Humbug Crash configuration, err: %v", err)
fmt.Printf("Invalid Humbug Crash configuration, err: %v\n", err)
os.Exit(1)
}
// Record system information
reporter.Publish(humbug.SystemReport())
// Fetch access id for internal usage (crawlers, infrastructure, etc)
resources, getErr := GetResources(NB_CONTROLLER_TOKEN, NB_CONTROLLER_ACCESS_ID, "")
if getErr != nil {
return fmt.Errorf("unable to get user with provided access identifier, err: %v", getErr)
resources, err := bugoutClient.Brood.GetResources(
NB_CONTROLLER_TOKEN,
MOONSTREAM_APPLICATION_ID,
map[string]string{"access_id": NB_CONTROLLER_ACCESS_ID},
)
if err != nil {
fmt.Printf("Unable to get user with provided access identifier, err: %v\n", err)
os.Exit(1)
}
if len(resources.Resources) == 1 {
clientAccess, parseErr := ParseResourceDataToClientAccess(resources.Resources[0])
if parseErr != nil {
return parseErr
resourceData, err := json.Marshal(resources.Resources[0].ResourceData)
if err != nil {
fmt.Printf("Unable to encode resource data interface to json, err: %v\n", err)
os.Exit(1)
}
var clientResourceData ClientResourceData
err = json.Unmarshal(resourceData, &clientResourceData)
if err != nil {
fmt.Printf("Unable to decode resource data json to structure, err: %v\n", err)
os.Exit(1)
}
internalUsageAccess = ClientAccess{
ClientResourceData: ClientResourceData{
UserID: clientResourceData.UserID,
AccessID: clientResourceData.AccessID,
Name: clientResourceData.Name,
Description: clientResourceData.Description,
BlockchainAccess: clientResourceData.BlockchainAccess,
ExtendedMethods: clientResourceData.ExtendedMethods,
},
}
internalUsageAccess = *clientAccess
log.Printf(
"Internal crawlers access set, resource id: %s, blockchain access: %t, extended methods: %t",
resources.Resources[0].Id, internalUsageAccess.ClientResourceData.BlockchainAccess, internalUsageAccess.ClientResourceData.ExtendedMethods,
resources.Resources[0].Id, clientResourceData.BlockchainAccess, clientResourceData.ExtendedMethods,
)
} else if len(resources.Resources) == 0 {
@ -150,13 +173,15 @@ func Server(configPath, listeningHostAddr, listeningPort string, enableHealthChe
}
fmt.Printf("There are no provided NB_CONTROLLER_ACCESS_ID records in Brood resources. Using provided with environment variable or randomly generated\n")
} else {
return fmt.Errorf("user with provided access identifier has wrong number of resources: %d\n", len(resources.Resources))
fmt.Printf("User with provided access identifier has wrong number of resources: %d\n", len(resources.Resources))
os.Exit(1)
}
// Fill NodeConfigList with initial nodes from environment variables
err = LoadConfig(configPath)
err = LoadConfig(stateCLI.configPathFlag)
if err != nil {
return err
fmt.Println(err)
os.Exit(1)
}
supportedBlockchains = make(map[string]bool)
@ -164,7 +189,8 @@ func Server(configPath, listeningHostAddr, listeningPort string, enableHealthChe
for i, nodeConfig := range nodeConfigs {
endpoint, err := url.Parse(nodeConfig.Endpoint)
if err != nil {
return err
fmt.Println(err)
os.Exit(1)
}
// Append to supported blockchain set
@ -225,7 +251,7 @@ func Server(configPath, listeningHostAddr, listeningPort string, enableHealthChe
commonHandler = panicMiddleware(commonHandler)
server := http.Server{
Addr: fmt.Sprintf("%s:%s", listeningHostAddr, listeningPort),
Addr: fmt.Sprintf("%s:%s", stateCLI.listeningAddrFlag, stateCLI.listeningPortFlag),
Handler: commonHandler,
ReadTimeout: 40 * time.Second,
WriteTimeout: 40 * time.Second,
@ -233,18 +259,17 @@ func Server(configPath, listeningHostAddr, listeningPort string, enableHealthChe
// Start node health checking and current block fetching
blockchainPool.HealthCheck()
if enableHealthCheck {
go initHealthCheck(NB_ENABLE_DEBUG)
if stateCLI.enableHealthCheckFlag {
go initHealthCheck(stateCLI.enableDebugFlag)
}
// Start access id cache cleaning
go initCacheCleaning(NB_ENABLE_DEBUG)
go initCacheCleaning(stateCLI.enableDebugFlag)
log.Printf("Starting node load balancer HTTP server at %s:%s", listeningHostAddr, listeningPort)
log.Printf("Starting node load balancer HTTP server at %s:%s", stateCLI.listeningAddrFlag, stateCLI.listeningPortFlag)
err = server.ListenAndServe()
if err != nil {
return fmt.Errorf("failed to start server listener, err: %v", err)
fmt.Printf("Failed to start server listener, err: %v\n", err)
os.Exit(1)
}
return nil
}

2
nodebalancer/cmd/nodebalancer/version.go
Wyświetl plik

@ -1,3 +1,3 @@
package main
var NB_VERSION = "0.2.8"
var NB_VERSION = "0.2.7"

8
nodebalancer/deploy/nodebalancer.service
Wyświetl plik

@ -10,10 +10,10 @@ EnvironmentFile=/home/ubuntu/nodebalancer-secrets/app.env
Restart=on-failure
RestartSec=15s
ExecStart=/home/ubuntu/api/nodebalancer/nodebalancer server \
--host "${AWS_LOCAL_IPV4}" \
--port 8544 \
--healthcheck \
--config /home/ubuntu/.nodebalancer/config.json
-host "${AWS_LOCAL_IPV4}" \
-port 8544 \
-healthcheck \
-config /home/ubuntu/.nodebalancer/config.json
SyslogIdentifier=nodebalancer
[Install]

13
nodebalancer/go.mod
Wyświetl plik

@ -3,14 +3,7 @@ module github.com/bugout-dev/moonstream/nodes/node_balancer
go 1.17
require (
github.com/bugout-dev/bugout-go v0.4.6
github.com/bugout-dev/humbug/go v0.0.0-20230713220619-2cd74a2b36d7
github.com/google/uuid v1.6.0
github.com/urfave/cli/v2 v2.27.5
)
require (
github.com/cpuguy83/go-md2man/v2 v2.0.5 // indirect
github.com/russross/blackfriday/v2 v2.1.0 // indirect
github.com/xrash/smetrics v0.0.0-20240521201337-686a1a2994c1 // indirect
github.com/bugout-dev/bugout-go v0.4.3
github.com/bugout-dev/humbug/go v0.0.0-20211206230955-57607cd2d205
github.com/google/uuid v1.3.0
)

22
nodebalancer/go.sum
Wyświetl plik

@ -12,7 +12,6 @@ cloud.google.com/go/pubsub v1.0.1/go.mod h1:R0Gpsv3s54REJCy4fxDixWD93lHJMoZTyQ2k
cloud.google.com/go/storage v1.0.0/go.mod h1:IhtSnM/ZTZV8YYJWCY8RULGVqBDmpoyjwiyrjsg+URw=
dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
github.com/BurntSushi/toml v1.4.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
@ -24,10 +23,10 @@ github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24
github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8=
github.com/bgentry/speakeasy v0.1.0/go.mod h1:+zsyZBPWlz7T6j88CTgSN5bM796AkVf0kBD4zp0CCIs=
github.com/bketelsen/crypt v0.0.3-0.20200106085610-5cbc8cc4026c/go.mod h1:MKsuJmJgSg28kpZDP6UIiPt0e0Oz0kqKNGyRaWEPv84=
github.com/bugout-dev/bugout-go v0.4.6 h1:HaXoVNVZYqd6BaPwlQGhWKBYdGc2lhF3BRxIgyL+1SY=
github.com/bugout-dev/bugout-go v0.4.6/go.mod h1:P4+788iHtt/32u2wIaRTaiXTWpvSVBYxZ01qQ8N7eB8=
github.com/bugout-dev/humbug/go v0.0.0-20230713220619-2cd74a2b36d7 h1:Mn6t3HO056/++m5UESl/06FdSxz84S1p7pfQA+NZwVo=
github.com/bugout-dev/humbug/go v0.0.0-20230713220619-2cd74a2b36d7/go.mod h1:U/NXHfc3tzGeQz+xVfpifXdPZi7p6VV8xdP/4ZKeWJU=
github.com/bugout-dev/bugout-go v0.4.3 h1:sTwMgNDZR8mK0BkPVfXIsFWZAkL8ePKr5Xmj35A2O3o=
github.com/bugout-dev/bugout-go v0.4.3/go.mod h1:P4+788iHtt/32u2wIaRTaiXTWpvSVBYxZ01qQ8N7eB8=
github.com/bugout-dev/humbug/go v0.0.0-20211206230955-57607cd2d205 h1:UQ7XGjvoOVKGRIuTFXgqGtU/UgMOk8+ikpoHWrWefjQ=
github.com/bugout-dev/humbug/go v0.0.0-20211206230955-57607cd2d205/go.mod h1:U/NXHfc3tzGeQz+xVfpifXdPZi7p6VV8xdP/4ZKeWJU=
github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc=
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
github.com/coreos/bbolt v1.3.2/go.mod h1:iRUV2dpdMOn7Bo10OQBFzIJO9kkE559Wcmn+qkEiiKk=
@ -36,8 +35,6 @@ github.com/coreos/go-semver v0.3.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3Ee
github.com/coreos/go-systemd v0.0.0-20190321100706-95778dfbb74e/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
github.com/coreos/pkg v0.0.0-20180928190104-399ea9e2e55f/go.mod h1:E3G3o1h8I7cfcXa63jLwjI0eiQQMgzzUDFVpN/nH/eA=
github.com/cpuguy83/go-md2man/v2 v2.0.0/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
github.com/cpuguy83/go-md2man/v2 v2.0.5 h1:ZtcqGrnekaHpVLArFSe4HK5DoKx1T0rq2DwVB0alcyc=
github.com/cpuguy83/go-md2man/v2 v2.0.5/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
@ -68,8 +65,8 @@ github.com/google/martian v2.1.0+incompatible/go.mod h1:9I4somxYTbIHy5NJKHRl3wXi
github.com/google/pprof v0.0.0-20181206194817-3ea8567a2e57/go.mod h1:zfwlbNMJ+OItoe0UupaVj+oy1omPYYDuagoSzA8v9mc=
github.com/google/pprof v0.0.0-20190515194954-54271f7e092f/go.mod h1:zfwlbNMJ+OItoe0UupaVj+oy1omPYYDuagoSzA8v9mc=
github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/googleapis/gax-go/v2 v2.0.4/go.mod h1:0Wqv26UfaUD9n4G6kQubkQ+KchISgw+vpHVxEJEs9eg=
github.com/googleapis/gax-go/v2 v2.0.5/go.mod h1:DWXyrwAJ9X0FpwwEdw+IPEYBICEFu5mhpdKc/us6bOk=
github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY=
@ -145,8 +142,6 @@ github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40T
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
github.com/russross/blackfriday/v2 v2.1.0 h1:JIOH55/0cWyOuilr9/qlrm0BSXldqnqwMsf35Ld67mk=
github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529/go.mod h1:DxrIzT+xaE7yg65j358z/aeFdxmN0P9QXhEzd20vsDc=
github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc=
@ -168,11 +163,7 @@ github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXf
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
github.com/subosito/gotenv v1.2.0/go.mod h1:N0PQaV/YGNqwC0u51sEeR/aUtSLEXKX9iv69rRypqCw=
github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
github.com/urfave/cli/v2 v2.27.5 h1:WoHEJLdsXr6dDWoJgMq/CboDmyY/8HMMH1fTECbih+w=
github.com/urfave/cli/v2 v2.27.5/go.mod h1:3Sevf16NykTbInEnD0yKkjDAeZDS0A6bzhBH5hrMvTQ=
github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU=
github.com/xrash/smetrics v0.0.0-20240521201337-686a1a2994c1 h1:gEOO8jv9F4OT7lGCjxCBTO/36wtF6j2nSip77qHd4x4=
github.com/xrash/smetrics v0.0.0-20240521201337-686a1a2994c1/go.mod h1:Ohn+xnUBiLI6FVj/9LpzZWtj1/D6lUovWYBkxHVV3aM=
go.etcd.io/bbolt v1.3.2/go.mod h1:IbVyRI1SCnLcuJnV2u8VeU0CEYM7e686BmAb1XKL+uU=
go.opencensus.io v0.21.0/go.mod h1:mSImk1erAIZhrmZN+AvHh14ztQfjbGwt4TtuofqLduU=
go.opencensus.io v0.22.0/go.mod h1:+kGneAE2xo2IficOXnaByMWTGM9T73dGwxeWcUqIpI8=
@ -291,7 +282,6 @@ gopkg.in/yaml.v2 v2.0.0-20170812160011-eb3733d160e7/go.mod h1:JAlM8MvJe8wmxCU4Bl
gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
honnef.co/go/tools v0.0.0-20190418001031-e561f6794a2a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=

5
nodebalancer/sample.env
Wyświetl plik

@ -3,9 +3,8 @@ export BUGOUT_BROOD_URL="https://auth.bugout.dev"
export NB_BUGOUT_TIMEOUT_SECONDS=15
export MOONSTREAM_APPLICATION_ID="<application_id_to_controll_access>"
export MOONSTREAM_CORS_ALLOWED_ORIGINS="http://localhost:3000,https://moonstream.to,https://portal.moonstream.to"
export NB_CONTROLLER_USER_ID="<bugout_id_of_nodebalancer_user>"
export NB_CONTROLLER_TOKEN="<token_of_nodebalancer_user>"
export NB_CONTROLLER_ACCESS_ID="<nodebalancer_access_id_for_internal_usage>"
export NB_CONTROLLER_TOKEN="<token_of_controller_user>"
export NB_CONTROLLER_ACCESS_ID="<controller_access_id_for_internal_usage>"
# Error humbug reporter
export HUMBUG_REPORTER_NODE_BALANCER_TOKEN="<bugout_humbug_token_for_crash_reports>"