-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #5 from 0x9n0p/panel
Implement panel APIs
- Loading branch information
Showing
150 changed files
with
5,541 additions
and
44 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 |
|---|---|---|
|
|
@@ -4,6 +4,7 @@ import ( | |
| "fmt" | ||
| "os" | ||
| "pluto" | ||
| _ "pluto/panel" | ||
| ) | ||
|
|
||
| func init() { | ||
|
|
||
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,16 @@ | ||
| package panel | ||
|
|
||
| import ( | ||
| "pluto" | ||
| "pluto/panel/pipeline" | ||
| _ "pluto/panel/pipeline/delivery" | ||
| _ "pluto/panel/processor/delivery" | ||
|
|
||
| "go.uber.org/zap" | ||
| ) | ||
|
|
||
| func init() { | ||
| if err := pipeline.GetStorage().ReloadExecutionCache(); err != nil { | ||
| pluto.Log.Fatal("Reload execution cache", zap.Error(err)) | ||
| } | ||
| } |
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,63 @@ | ||
| package delivery | ||
|
|
||
| import ( | ||
| "errors" | ||
| "fmt" | ||
| "net/http" | ||
| "pluto" | ||
| "pluto/panel/pipeline" | ||
| "pluto/panel/pkg/wrapper" | ||
| ) | ||
|
|
||
| func init() { | ||
| WriteError := func(err error, writer wrapper.ResponseWriter) error { | ||
| var perr *pluto.Error | ||
| if errors.As(err, &perr) { | ||
| return writer.JSON(perr.HTTPCode, perr) | ||
| } | ||
| return writer.JSON(http.StatusInternalServerError, map[string]string{"message": "Internal server error"}) | ||
| } | ||
|
|
||
| pluto.HTTPAdmin.GET("/pipelines", | ||
| wrapper.New[wrapper.EmptyRequest](func(request wrapper.EmptyRequest, writer wrapper.ResponseWriter) error { | ||
| list, err := pipeline.GetStorage().List() | ||
| if err != nil { | ||
| return WriteError(err, writer) | ||
| } | ||
| return writer.JSON(http.StatusOK, list) | ||
| }).Handle(), | ||
| ) | ||
|
|
||
| pluto.HTTPAdmin.POST("/pipelines", | ||
| wrapper.New[pipeline.Pipeline](func(p pipeline.Pipeline, writer wrapper.ResponseWriter) error { | ||
| if err := p.Save(); err != nil { | ||
| return WriteError(err, writer) | ||
| } | ||
|
|
||
| if err := pipeline.GetStorage().ReloadExecutionCache(); err != nil { | ||
| return WriteError(fmt.Errorf("reload execution cache: %v", err), writer) | ||
| } | ||
|
|
||
| return writer.JSON(http.StatusCreated, p) | ||
| }).Handle(), | ||
| ) | ||
|
|
||
| pluto.HTTPAdmin.DELETE("/pipelines", | ||
| wrapper.New[struct { | ||
| Name string `query:"name" validate:"required"` | ||
| }](func(r struct { | ||
| Name string `query:"name" validate:"required"` | ||
| }, writer wrapper.ResponseWriter) error { | ||
| p, err := pipeline.GetStorage().Find(r.Name) | ||
| if err != nil { | ||
| return WriteError(err, writer) | ||
| } | ||
|
|
||
| if err := p.Delete(); err != nil { | ||
| return WriteError(err, writer) | ||
| } | ||
|
|
||
| return writer.JSON(http.StatusOK, p) | ||
| }).Handle(), | ||
| ) | ||
| } |
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,23 @@ | ||
| package pipeline | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "os" | ||
| "pluto" | ||
| "strings" | ||
|
|
||
| "github.com/kelseyhightower/envconfig" | ||
| ) | ||
|
|
||
| var Env EnvSpec | ||
|
|
||
| type EnvSpec struct { | ||
| StoragePath string `envconfig:"PANEL_STORAGE" required:"true"` | ||
| } | ||
|
|
||
| func init() { | ||
| if err := envconfig.Process(strings.ToUpper(pluto.Name), &Env); err != nil { | ||
| _, _ = fmt.Fprintf(os.Stderr, "Environment variables: %v\n", err) | ||
| os.Exit(1) | ||
| } | ||
| } |
Oops, something went wrong.