83 lines
2.1 KiB
Go
83 lines
2.1 KiB
Go
// Copyright (C) 2022 Storj Labs, Inc.
|
|
// See LICENSE for copying information.
|
|
|
|
package admin
|
|
|
|
import (
|
|
"encoding/json"
|
|
"net/http"
|
|
|
|
"github.com/gorilla/mux"
|
|
|
|
"storj.io/common/uuid"
|
|
"storj.io/storj/satellite/oidc"
|
|
)
|
|
|
|
func (server *Server) createOAuthClient(w http.ResponseWriter, r *http.Request) {
|
|
oauthClient := oidc.OAuthClient{}
|
|
err := json.NewDecoder(r.Body).Decode(&oauthClient)
|
|
if err != nil {
|
|
sendJSONError(w, "invalid json", err.Error(), http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
validID := oauthClient.ID.String() != ""
|
|
validSecret := len(oauthClient.Secret) > 0
|
|
validRedirectURL := oauthClient.RedirectURL != ""
|
|
validUserID := oauthClient.UserID.String() != ""
|
|
|
|
if !validID || !validSecret || !validRedirectURL || !validUserID {
|
|
sendJSONError(w, "", "missing required value", http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
err = server.db.OIDC().OAuthClients().Create(r.Context(), oauthClient)
|
|
if err != nil {
|
|
sendJSONError(w, "failed to create client", err.Error(), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|
|
|
|
func (server *Server) updateOAuthClient(w http.ResponseWriter, r *http.Request) {
|
|
id, err := uuid.FromString(mux.Vars(r)["id"])
|
|
if err != nil {
|
|
sendJSONError(w, "missing required client id", err.Error(), http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
oauthClient := oidc.OAuthClient{}
|
|
err = json.NewDecoder(r.Body).Decode(&oauthClient)
|
|
if err != nil {
|
|
sendJSONError(w, "invalid json", err.Error(), http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
oauthClient.ID = id
|
|
|
|
err = server.db.OIDC().OAuthClients().Update(r.Context(), oauthClient)
|
|
if err != nil {
|
|
sendJSONError(w, "failed to update client", err.Error(), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|
|
|
|
func (server *Server) deleteOAuthClient(w http.ResponseWriter, r *http.Request) {
|
|
id, err := uuid.FromString(mux.Vars(r)["id"])
|
|
if err != nil {
|
|
sendJSONError(w, "missing required client id", err.Error(), http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
err = server.db.OIDC().OAuthClients().Delete(r.Context(), id)
|
|
if err != nil {
|
|
sendJSONError(w, "failed to delete client", err.Error(), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|