59 lines
1.3 KiB
Go
59 lines
1.3 KiB
Go
package tasks
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"net/http"
|
|
"ocl/portainer-devtool/configs"
|
|
"ocl/portainer-devtool/tasks/common"
|
|
)
|
|
|
|
type GenerateJwtTokenTask struct {
|
|
common.GeneralTask
|
|
}
|
|
|
|
type GenerateJwtTokenResponse struct {
|
|
JWT string `json:"jwt"`
|
|
}
|
|
|
|
func NewGenerateJwtTokenTask(cfg *configs.Config) *GenerateJwtTokenTask {
|
|
return &GenerateJwtTokenTask{
|
|
GeneralTask: *common.NewGeneralTask(cfg),
|
|
}
|
|
}
|
|
|
|
func (task *GenerateJwtTokenTask) Execute() error {
|
|
postBody, _ := json.Marshal(map[string]string{
|
|
"username": task.Config.LoginCredential.Username,
|
|
"password": task.Config.LoginCredential.Password,
|
|
})
|
|
|
|
responseBody := bytes.NewBuffer(postBody)
|
|
resp, err := http.Post(task.Config.LoginCredential.Address, "application/json", responseBody)
|
|
if err != nil {
|
|
return fmt.Errorf("http requset error: %s", err.Error())
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
//Read the response body
|
|
body, err := ioutil.ReadAll(resp.Body)
|
|
if err != nil {
|
|
return fmt.Errorf("failed to parse the response body: %s", err.Error())
|
|
}
|
|
|
|
var ret GenerateJwtTokenResponse
|
|
err = json.Unmarshal(body, &ret)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
fmt.Printf("jwt token is:\n%s\n", ret.JWT)
|
|
return nil
|
|
}
|
|
|
|
func (task *GenerateJwtTokenTask) String() string {
|
|
return "Generate JWT Token"
|
|
}
|