Skip to content

Commit

Permalink
Update constant packages with the new names and unify all http header…
Browse files Browse the repository at this point in the history
…s in one place

Signed-off-by: Burak Sekili <buraksekili@gmail.com>
  • Loading branch information
buraksekili committed Nov 2, 2023
1 parent 93daaa4 commit 1c4fa8b
Show file tree
Hide file tree
Showing 6 changed files with 26 additions and 26 deletions.
4 changes: 1 addition & 3 deletions data/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,6 @@ package data
import (
"context"
"fmt"

Check failure on line 5 in data/config.go

View workflow job for this annotation

GitHub Actions / linter

File is not `gofumpt`-ed with `-extra` (gofumpt)
"tyk/tyk/bootstrap/constants"

"github.com/kelseyhightower/envconfig"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/labels"
Expand Down Expand Up @@ -126,7 +124,7 @@ func discoverDashboardSvc() (string, error) {
}

ls := metav1.LabelSelector{MatchLabels: map[string]string{
constants.TykBootstrapLabel: constants.TykBootstrapDashboardSvcLabel,
TykBootstrapLabel: TykBootstrapDashboardSvcLabel,
}}

l := labels.Set(ls.MatchLabels).String()
Expand Down
6 changes: 5 additions & 1 deletion data/constants.go
Original file line number Diff line number Diff line change
@@ -1,8 +1,12 @@
package constants
package data

const (
TykBootstrapLabel = "tyk.tyk.io/k8s-bootstrap"
TykBootstrapPreDeleteLabel = "tyk-k8s-bootstrap-pre-delete"
TykBootstrapDashboardDeployLabel = "tyk-dashboard"
TykBootstrapDashboardSvcLabel = "tyk-dashboard"

AuthorizationHeader = "Authorization"
ContentTypeHeader = "Content-Type"
AdminAuthHeader = "admin-auth"
)
12 changes: 6 additions & 6 deletions helpers/organisation.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,13 +31,13 @@ func CheckForExistingOrganisation(client http.Client) error {

orgsApiEndpoint := data.BootstrapConf.K8s.DashboardSvcUrl + AdminOrganisationsEndpoint

req, err := http.NewRequest("GET", orgsApiEndpoint, nil)
req, err := http.NewRequest(http.MethodGet, orgsApiEndpoint, nil)
if err != nil {
return err
}

req.Header.Set("admin-auth", data.BootstrapConf.Tyk.Admin.Secret)
req.Header.Set("Content-Type", "application/json")
req.Header.Set(data.AdminAuthHeader, data.BootstrapConf.Tyk.Admin.Secret)
req.Header.Set(data.ContentTypeHeader, "application/json")

res, err := client.Do(req)
if err != nil {
Expand Down Expand Up @@ -91,13 +91,13 @@ func CreateOrganisation(client http.Client, dashBoardUrl string) (string, error)
return "", err
}

req, err := http.NewRequest("POST", dashBoardUrl+AdminOrganisationsEndpoint, bytes.NewReader(reqBodyBytes))
req, err := http.NewRequest(http.MethodPost, dashBoardUrl+AdminOrganisationsEndpoint, bytes.NewReader(reqBodyBytes))
if err != nil {
return "", err
}

req.Header.Set("admin-auth", data.BootstrapConf.Tyk.Admin.Secret)
req.Header.Set("Content-Type", "application/json")
req.Header.Set(data.AdminAuthHeader, data.BootstrapConf.Tyk.Admin.Secret)
req.Header.Set(data.ContentTypeHeader, "application/json")

res, err := client.Do(req)
if err != nil {
Expand Down
11 changes: 5 additions & 6 deletions helpers/portal.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ import (
"io"
"net/http"
"time"
"tyk/tyk/bootstrap/constants"
"tyk/tyk/bootstrap/data"

metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
Expand Down Expand Up @@ -70,7 +69,7 @@ func SetPortalCname(client http.Client) error {
return err
}

req.Header.Set("Authorization", data.BootstrapConf.Tyk.UserAuth)
req.Header.Set(data.AuthorizationHeader, data.BootstrapConf.Tyk.UserAuth)

res, err := client.Do(req)
if err != nil {
Expand Down Expand Up @@ -104,7 +103,7 @@ func InitialiseCatalogue(client http.Client) error {
return err
}

req.Header.Set("Authorization", data.BootstrapConf.Tyk.UserAuth)
req.Header.Set(data.AuthorizationHeader, data.BootstrapConf.Tyk.UserAuth)

res, err := client.Do(req)
if err != nil || res.StatusCode != http.StatusOK {
Expand Down Expand Up @@ -143,7 +142,7 @@ func CreatePortalHomepage(client http.Client) error {
return err
}

req.Header.Set("Authorization", data.BootstrapConf.Tyk.UserAuth)
req.Header.Set(data.AuthorizationHeader, data.BootstrapConf.Tyk.UserAuth)

res, err := client.Do(req)
if err != nil || res.StatusCode != http.StatusOK {
Expand Down Expand Up @@ -232,7 +231,7 @@ func CreatePortalDefaultSettings(client http.Client) error {
data.BootstrapConf.K8s.DashboardSvcUrl+ApiPortalConfigurationEndpoint,
nil,
)
req.Header.Set("Authorization", data.BootstrapConf.Tyk.UserAuth)
req.Header.Set(data.AuthorizationHeader, data.BootstrapConf.Tyk.UserAuth)

if err != nil {
return err
Expand All @@ -259,7 +258,7 @@ func RestartDashboard() error {

if data.BootstrapConf.K8s.DashboardDeploymentName == "" {
ls := metav1.LabelSelector{MatchLabels: map[string]string{
constants.TykBootstrapLabel: constants.TykBootstrapDashboardDeployLabel,
data.TykBootstrapLabel: data.TykBootstrapDashboardDeployLabel,
}}

deployments, err := clientset.
Expand Down
12 changes: 6 additions & 6 deletions helpers/user.go
Original file line number Diff line number Diff line change
Expand Up @@ -43,15 +43,15 @@ func SetUserPassword(client http.Client, userId, authCode, dashboardUrl string)
}

req, err := http.NewRequest(
"POST",
http.MethodPost,
fmt.Sprintf(ApiUsersActionsResetEndpoint, dashboardUrl, userId),
bytes.NewReader(reqBody))
if err != nil {
return err
}

req.Header.Set("authorization", authCode)
req.Header.Set("Content-Type", "application/json")
req.Header.Set(data.AuthorizationHeader, authCode)
req.Header.Set(data.ContentTypeHeader, "application/json")

res, err := client.Do(req)
if err != nil {
Expand Down Expand Up @@ -135,13 +135,13 @@ func GetUserData(client http.Client, dashboardUrl, orgId string) (NeededUserData
return NeededUserData{}, err
}

req, err := http.NewRequest("POST", dashboardUrl+"/admin/users", bytes.NewReader(reqBytes))
req, err := http.NewRequest(http.MethodPost, dashboardUrl+"/admin/users", bytes.NewReader(reqBytes))
if err != nil {
return NeededUserData{}, err
}

req.Header.Set("admin-auth", data.BootstrapConf.Tyk.Admin.Secret)
req.Header.Set("Content-Type", "application/json")
req.Header.Set(data.AdminAuthHeader, data.BootstrapConf.Tyk.Admin.Secret)
req.Header.Set(data.ContentTypeHeader, "application/json")

res, err := client.Do(req)
if err != nil {
Expand Down
7 changes: 3 additions & 4 deletions predelete/predelete.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ package predelete
import (
"context"
"fmt"
"tyk/tyk/bootstrap/constants"
"tyk/tyk/bootstrap/data"

metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
Expand Down Expand Up @@ -126,7 +125,7 @@ func PreDeleteBootstrappingJobs(clientset *kubernetes.Clientset) error {
List(
context.TODO(),
metav1.ListOptions{
LabelSelector: constants.TykBootstrapLabel,
LabelSelector: data.TykBootstrapLabel,
},
)
if err != nil {
Expand All @@ -139,8 +138,8 @@ func PreDeleteBootstrappingJobs(clientset *kubernetes.Clientset) error {
job := jobs.Items[i]

// Do not need to delete pre-delete job. It will be deleted by Helm.
jobLabel := job.ObjectMeta.Labels[constants.TykBootstrapLabel]
if jobLabel != constants.TykBootstrapPreDeleteLabel {
jobLabel := job.ObjectMeta.Labels[data.TykBootstrapLabel]
if jobLabel != data.TykBootstrapPreDeleteLabel {
deletePropagationType := metav1.DeletePropagationBackground

err2 := clientset.
Expand Down

0 comments on commit 1c4fa8b

Please sign in to comment.