-
Notifications
You must be signed in to change notification settings - Fork 52
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
WIP: Uses basic auth instead of mtls for components
- Loading branch information
1 parent
3305ba9
commit f13d062
Showing
40 changed files
with
698 additions
and
305 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,232 @@ | ||
| package server_test | ||
|
|
||
| import ( | ||
| "strconv" | ||
|
|
||
| "code.cloudfoundry.org/app-autoscaler/src/autoscaler/fakes" | ||
| "code.cloudfoundry.org/app-autoscaler/src/autoscaler/helpers" | ||
| "code.cloudfoundry.org/app-autoscaler/src/autoscaler/models" | ||
| "code.cloudfoundry.org/app-autoscaler/src/autoscaler/routes" | ||
| "code.cloudfoundry.org/app-autoscaler/src/autoscaler/scalingengine/config" | ||
| . "code.cloudfoundry.org/app-autoscaler/src/autoscaler/scalingengine/server" | ||
| "code.cloudfoundry.org/lager/v3" | ||
| . "github.com/onsi/ginkgo/v2" | ||
| . "github.com/onsi/gomega" | ||
| "github.com/tedsuo/ifrit" | ||
| "github.com/tedsuo/ifrit/ginkgomon_v2" | ||
|
|
||
| "bytes" | ||
| "encoding/json" | ||
| "io" | ||
| "net/http" | ||
| "net/url" | ||
| ) | ||
|
|
||
| var ( | ||
| serverUrl *url.URL | ||
| server ifrit.Process | ||
| scalingEngineDB *fakes.FakeScalingEngineDB | ||
| sychronizer *fakes.FakeActiveScheduleSychronizer | ||
| ) | ||
|
|
||
| var _ = Describe("Server", func() { | ||
| var ( | ||
| rsp *http.Response | ||
| req *http.Request | ||
| body []byte | ||
| err error | ||
| method string | ||
| bodyReader io.Reader | ||
| route = routes.ScalingEngineRoutes() | ||
| ) | ||
|
|
||
| BeforeEach(func() { | ||
| port := 2222 + GinkgoParallelProcess() | ||
| conf := &config.Config{ | ||
| Server: helpers.ServerConfig{ | ||
| Port: port, | ||
| BasicAuth: models.BasicAuth{ | ||
| Username: "scalingengine", | ||
| Password: "some-password", | ||
| }, | ||
| }, | ||
| } | ||
| scalingEngineDB = &fakes.FakeScalingEngineDB{} | ||
| scalingEngine := &fakes.FakeScalingEngine{} | ||
| policyDb := &fakes.FakePolicyDB{} | ||
| schedulerDB := &fakes.FakeSchedulerDB{} | ||
| sychronizer = &fakes.FakeActiveScheduleSychronizer{} | ||
|
|
||
| httpServer, err := NewServer(lager.NewLogger("test"), conf, policyDb, scalingEngineDB, schedulerDB, scalingEngine, sychronizer) | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| server = ginkgomon_v2.Invoke(httpServer) | ||
| serverUrl, err = url.Parse("http://127.0.0.1:" + strconv.Itoa(port)) | ||
| Expect(err).ToNot(HaveOccurred()) | ||
| }) | ||
|
|
||
| AfterEach(func() { | ||
| ginkgomon_v2.Interrupt(server) | ||
| }) | ||
|
|
||
| Context("when triggering scaling action", func() { | ||
| BeforeEach(func() { | ||
| body, err = json.Marshal(models.Trigger{Adjustment: "+1"}) | ||
| Expect(err).NotTo(HaveOccurred()) | ||
|
|
||
| uPath, err := route.Get(routes.ScaleRouteName).URLPath("appid", "test-app-id") | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| serverUrl.Path = uPath.Path | ||
| }) | ||
|
|
||
| Context("when requesting correctly", func() { | ||
| JustBeforeEach(func() { | ||
| rsp, err = http.Post(serverUrl.String(), "application/json", bytes.NewReader(body)) | ||
| }) | ||
|
|
||
| It("should return 200", func() { | ||
| Expect(err).ToNot(HaveOccurred()) | ||
| Expect(rsp.StatusCode).To(Equal(http.StatusOK)) | ||
| rsp.Body.Close() | ||
| }) | ||
| }) | ||
| }) | ||
|
|
||
| Context("when getting scaling histories", func() { | ||
| BeforeEach(func() { | ||
| uPath, err := route.Get(routes.GetScalingHistoriesRouteName).URLPath("guid", "8ea70e4e-e0bc-4e15-9d32-cd69daaf012a") | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| serverUrl.Path = uPath.Path | ||
| }) | ||
|
|
||
| Context("when requesting correctly", func() { | ||
| JustBeforeEach(func() { | ||
| req, err = http.NewRequest(http.MethodGet, serverUrl.String(), nil) | ||
| req.Header.Set("Authorization", "Bearer ignore") | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| rsp, err = (&http.Client{}).Do(req) | ||
| }) | ||
|
|
||
| It("should return 200", func() { | ||
| Expect(err).ToNot(HaveOccurred()) | ||
| Expect(rsp.StatusCode).To(Equal(http.StatusOK)) | ||
| rsp.Body.Close() | ||
| }) | ||
| }) | ||
| }) | ||
|
|
||
| Context("when requesting active shedule", func() { | ||
|
|
||
| JustBeforeEach(func() { | ||
| req, err = http.NewRequest(method, serverUrl.String(), bodyReader) | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| rsp, err = http.DefaultClient.Do(req) | ||
| }) | ||
|
|
||
| Context("when setting active schedule", func() { | ||
| BeforeEach(func() { | ||
| uPath, err := route.Get(routes.SetActiveScheduleRouteName).URLPath("appid", "test-app-id", "scheduleid", "test-schedule-id") | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| serverUrl.Path = urlPath | ||
| bodyReader = bytes.NewReader([]byte(`{"instance_min_count":1, "instance_max_count":5, "initial_min_instance_count":3}`)) | ||
| }) | ||
|
|
||
| Context("when requesting correctly", func() { | ||
| BeforeEach(func() { | ||
| method = http.MethodPut | ||
| }) | ||
|
|
||
| It("should return 200", func() { | ||
| Expect(err).ToNot(HaveOccurred()) | ||
| Expect(rsp.StatusCode).To(Equal(http.StatusOK)) | ||
| rsp.Body.Close() | ||
| }) | ||
| }) | ||
| }) | ||
|
|
||
| Context("when deleting active schedule", func() { | ||
| BeforeEach(func() { | ||
| uPath, err := route.Get(routes.DeleteActiveScheduleRouteName).URLPath("appid", "test-app-id", "scheduleid", "test-schedule-id") | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| serverUrl.Path = uPath.Path | ||
| bodyReader = nil | ||
| method = http.MethodDelete | ||
| }) | ||
| Context("when requesting correctly", func() { | ||
| It("should return 200", func() { | ||
| Expect(err).ToNot(HaveOccurred()) | ||
| Expect(rsp.StatusCode).To(Equal(http.StatusOK)) | ||
| rsp.Body.Close() | ||
| }) | ||
| }) | ||
| }) | ||
|
|
||
| Context("when getting active schedule", func() { | ||
| BeforeEach(func() { | ||
| uPath, err := route.Get(routes.GetActiveSchedulesRouteName).URLPath("appid", "test-app-id") | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| serverUrl.Path = uPath.Path | ||
| bodyReader = nil | ||
| method = http.MethodGet | ||
| }) | ||
|
|
||
| Context("when requesting correctly", func() { | ||
| BeforeEach(func() { | ||
| activeSchedule := &models.ActiveSchedule{ | ||
| ScheduleId: "a-schedule-id", | ||
| InstanceMin: 1, | ||
| InstanceMax: 5, | ||
| InstanceMinInitial: 3, | ||
| } | ||
|
|
||
| scalingEngineDB.GetActiveScheduleReturns(activeSchedule, nil) | ||
| }) | ||
|
|
||
| It("should return 200", func() { | ||
| Expect(err).ToNot(HaveOccurred()) | ||
| Expect(rsp.StatusCode).To(Equal(http.StatusOK)) | ||
| rsp.Body.Close() | ||
| }) | ||
| }) | ||
| }) | ||
| }) | ||
|
|
||
| Context("when requesting sync shedule", func() { | ||
| JustBeforeEach(func() { | ||
| uPath, err := route.Get(routes.SyncActiveSchedulesRouteName).URLPath() | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| serverUrl.Path = uPath.Path | ||
| bodyReader = nil | ||
|
|
||
| req, err = http.NewRequest(method, serverUrl, bodyReader) | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| rsp, err = http.DefaultClient.Do(req) | ||
| Expect(err).NotTo(HaveOccurred()) | ||
| }) | ||
|
|
||
| Context("when requesting correctly", func() { | ||
| BeforeEach(func() { | ||
| method = http.MethodPut | ||
| }) | ||
|
|
||
| It("should return 200", func() { | ||
| Eventually(sychronizer.SyncCallCount).Should(Equal(1)) | ||
| Expect(err).ToNot(HaveOccurred()) | ||
| Expect(rsp.StatusCode).To(Equal(http.StatusOK)) | ||
| rsp.Body.Close() | ||
| }) | ||
| }) | ||
|
|
||
| Context("when requesting with incorrect http method", func() { | ||
| BeforeEach(func() { | ||
| method = http.MethodGet | ||
| }) | ||
|
|
||
| It("should return 405", func() { | ||
| Expect(err).ToNot(HaveOccurred()) | ||
| Expect(rsp.StatusCode).To(Equal(http.StatusMethodNotAllowed)) | ||
| rsp.Body.Close() | ||
| }) | ||
| }) | ||
|
|
||
| }) | ||
| }) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file was deleted.
Oops, something went wrong.
This file was deleted.
Oops, something went wrong.
Oops, something went wrong.