github
/
portainer
mirror of https://github.com/portainer/portainer
1
0
Fork 0
Code Issues Releases Wiki Activity

fix(edge/async): onboarding agent without predefined group cannot be associated [BE-11281] (#83)

pull/12292/merge
Oscar Zhou 2024-11-05 09:32:25 +13:00 committed by GitHub
parent c1316532eb
commit ca7e4dd66e
2 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
api/http/handler/endpoints/endpoint_update_relations.go
View File

@ -88,13 +88,11 @@ func (handler *Handler) updateRelations(w http.ResponseWriter, r *http.Request)
} }
if updateRelations { if updateRelations {
err := tx.Endpoint().UpdateEndpoint(endpoint.ID, endpoint) if err := tx.Endpoint().UpdateEndpoint(endpoint.ID, endpoint); err != nil {
if err != nil {
return errors.WithMessage(err, "Unable to update environment") return errors.WithMessage(err, "Unable to update environment")
} }
err = handler.updateEdgeRelations(tx, endpoint) if err := handler.updateEdgeRelations(tx, endpoint); err != nil {
if err != nil {
return errors.WithMessage(err, "Unable to update environment relations") return errors.WithMessage(err, "Unable to update environment relations")
} }
} }

11
api/http/handler/endpoints/update_edge_relations.go
View File

@ -17,7 +17,16 @@ func (handler *Handler) updateEdgeRelations(tx dataservices.DataStoreTx, endpoin
relation, err := tx.EndpointRelation().EndpointRelation(endpoint.ID) relation, err := tx.EndpointRelation().EndpointRelation(endpoint.ID)
if err != nil { if err != nil {
return errors.WithMessage(err, "Unable to find environment relation inside the database") if !tx.IsErrObjectNotFound(err) {
return errors.WithMessage(err, "Unable to retrieve environment relation inside the database")
}
relation = &portainer.EndpointRelation{
EndpointID: endpoint.ID,
}
if err := tx.EndpointRelation().Create(relation); err != nil {
return errors.WithMessage(err, "Unable to create environment relation inside the database")
}
} }
endpointGroup, err := tx.EndpointGroup().Read(endpoint.GroupID) endpointGroup, err := tx.EndpointGroup().Read(endpoint.GroupID)