Skip to content

Commit

Permalink
Add permissions checks to assignments (#173)
Browse files Browse the repository at this point in the history
This commit adds permissions checks to role assignments. Rather than
define new actions here, we just use the already-defined actions for
role management.

Signed-off-by: John Schaeffer <jschaeffer@equinix.com>
  • Loading branch information
jnschaeffer authored Sep 7, 2023
1 parent 5a66391 commit 92f3aa8
Showing 1 changed file with 63 additions and 6 deletions.
69 changes: 63 additions & 6 deletions internal/api/assignments.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,21 +29,40 @@ func (r *Router) assignmentCreate(c echo.Context) error {
return echo.NewHTTPError(http.StatusBadRequest, "error parsing request body").SetInternal(err)
}

subjID, err := gidx.Parse(reqBody.SubjectID)
assigneeID, err := gidx.Parse(reqBody.SubjectID)
if err != nil {
return echo.NewHTTPError(http.StatusBadRequest, "error parsing subject ID").SetInternal(err)
}

subjResource, err := r.engine.NewResourceFromID(subjID)
assigneeResource, err := r.engine.NewResourceFromID(assigneeID)
if err != nil {
return echo.NewHTTPError(http.StatusBadRequest, "error creating resource").SetInternal(err)
}

subjectResource, err := r.currentSubject(c)
if err != nil {
return err
}

roleResource, err := r.engine.NewResourceFromID(roleID)
if err != nil {
return echo.NewHTTPError(http.StatusBadRequest, "error getting resource").SetInternal(err)
}

resource, err := r.engine.GetRoleResource(ctx, roleResource, "")
if err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, "error getting resource").SetInternal(err)
}

if err := r.checkActionWithResponse(ctx, subjectResource, actionRoleUpdate, resource); err != nil {
return err
}

role := types.Role{
ID: roleID,
}

_, err = r.engine.AssignSubjectRole(ctx, subjResource, role)
_, err = r.engine.AssignSubjectRole(ctx, assigneeResource, role)
if err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, "error creating resource").SetInternal(err)
}
Expand All @@ -66,6 +85,25 @@ func (r *Router) assignmentsList(c echo.Context) error {
ctx, span := tracer.Start(c.Request().Context(), "api.assignmentCreate", trace.WithAttributes(attribute.String("role_id", roleIDStr)))
defer span.End()

subjectResource, err := r.currentSubject(c)
if err != nil {
return err
}

roleResource, err := r.engine.NewResourceFromID(roleID)
if err != nil {
return echo.NewHTTPError(http.StatusBadRequest, "error getting resource").SetInternal(err)
}

resource, err := r.engine.GetRoleResource(ctx, roleResource, "")
if err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, "error getting resource").SetInternal(err)
}

if err := r.checkActionWithResponse(ctx, subjectResource, actionRoleGet, resource); err != nil {
return err
}

role := types.Role{
ID: roleID,
}
Expand Down Expand Up @@ -110,21 +148,40 @@ func (r *Router) assignmentDelete(c echo.Context) error {
return echo.NewHTTPError(http.StatusBadRequest, "error parsing request body").SetInternal(err)
}

subjID, err := gidx.Parse(reqBody.SubjectID)
assigneeID, err := gidx.Parse(reqBody.SubjectID)
if err != nil {
return echo.NewHTTPError(http.StatusBadRequest, "error parsing subject ID").SetInternal(err)
}

subjResource, err := r.engine.NewResourceFromID(subjID)
assigneeResource, err := r.engine.NewResourceFromID(assigneeID)
if err != nil {
return echo.NewHTTPError(http.StatusBadRequest, "error parsing resource type from subject").SetInternal(err)
}

subjectResource, err := r.currentSubject(c)
if err != nil {
return err
}

roleResource, err := r.engine.NewResourceFromID(roleID)
if err != nil {
return echo.NewHTTPError(http.StatusBadRequest, "error getting resource").SetInternal(err)
}

resource, err := r.engine.GetRoleResource(ctx, roleResource, "")
if err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, "error getting resource").SetInternal(err)
}

if err := r.checkActionWithResponse(ctx, subjectResource, actionRoleUpdate, resource); err != nil {
return err
}

role := types.Role{
ID: roleID,
}

_, err = r.engine.UnassignSubjectRole(ctx, subjResource, role)
_, err = r.engine.UnassignSubjectRole(ctx, assigneeResource, role)
if err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, "error deleting assignment").SetInternal(err)
}
Expand Down

0 comments on commit 92f3aa8

Please sign in to comment.