api_entity_related_actions.go 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  1. package api
  2. import (
  3. "sort"
  4. apiv1 "github.com/OliveTin/OliveTin/gen/olivetin/api/v1"
  5. authpublic "github.com/OliveTin/OliveTin/internal/auth/authpublic"
  6. config "github.com/OliveTin/OliveTin/internal/config"
  7. "github.com/OliveTin/OliveTin/internal/entities"
  8. "github.com/OliveTin/OliveTin/internal/executor"
  9. "github.com/OliveTin/OliveTin/internal/tpl"
  10. )
  11. type relatedActionCandidate struct {
  12. binding *executor.ActionBinding
  13. prefilled map[string]string
  14. }
  15. func (api *oliveTinAPI) relatedActionsForEntity(user *authpublic.AuthenticatedUser, entityType string, entity *entities.Entity) []*apiv1.EntityRelatedAction {
  16. rr := api.createDashboardRenderRequest(user, entityType, entity.UniqueKey)
  17. populateActiveBindingStates(rr)
  18. candidates := collectRelatedActionCandidates(api, user, entityType, entity)
  19. sortRelatedActionCandidates(candidates)
  20. return buildEntityRelatedActions(candidates, rr)
  21. }
  22. func collectRelatedActionCandidates(api *oliveTinAPI, user *authpublic.AuthenticatedUser, entityType string, entity *entities.Entity) []relatedActionCandidate {
  23. seen := make(map[string]bool)
  24. candidates := make([]relatedActionCandidate, 0)
  25. api.executor.MapActionBindingsLock.RLock()
  26. defer api.executor.MapActionBindingsLock.RUnlock()
  27. for _, binding := range api.executor.MapActionBindings {
  28. tryAppendRelatedCandidate(&candidates, seen, api, user, entityType, entity, binding)
  29. }
  30. return candidates
  31. }
  32. func tryAppendRelatedCandidate(candidates *[]relatedActionCandidate, seen map[string]bool, api *oliveTinAPI, user *authpublic.AuthenticatedUser, entityType string, entity *entities.Entity, binding *executor.ActionBinding) {
  33. prefilled, ok := relatedPrefillForBinding(binding, entityType, entity)
  34. if !ok || !bindingViewableForRelated(seen, api, user, binding) {
  35. return
  36. }
  37. seen[binding.ID] = true
  38. *candidates = append(*candidates, relatedActionCandidate{
  39. binding: binding,
  40. prefilled: prefilled,
  41. })
  42. }
  43. func bindingViewableForRelated(seen map[string]bool, api *oliveTinAPI, user *authpublic.AuthenticatedUser, binding *executor.ActionBinding) bool {
  44. return binding != nil && binding.Action != nil && !seen[binding.ID] && api.userCanViewAction(user, binding.Action)
  45. }
  46. func relatedPrefillForBinding(binding *executor.ActionBinding, entityType string, entity *entities.Entity) (map[string]string, bool) {
  47. if isEntityBoundBindingFor(binding, entityType, entity) {
  48. return nil, true
  49. }
  50. return argumentEntityPrefill(binding, entityType, entity)
  51. }
  52. func argumentEntityPrefill(binding *executor.ActionBinding, entityType string, entity *entities.Entity) (map[string]string, bool) {
  53. if binding == nil || binding.Entity != nil || binding.Action == nil {
  54. return nil, false
  55. }
  56. prefilled := buildPrefilledArgumentsForEntity(binding.Action, entityType, entity)
  57. return prefilled, len(prefilled) > 0
  58. }
  59. func isEntityBoundBindingFor(binding *executor.ActionBinding, entityType string, entity *entities.Entity) bool {
  60. if entity == nil || !bindingHasEntity(binding) {
  61. return false
  62. }
  63. return binding.Action.Entity == entityType && binding.Entity.UniqueKey == entity.UniqueKey
  64. }
  65. func bindingHasEntity(binding *executor.ActionBinding) bool {
  66. return binding != nil && binding.Entity != nil && binding.Action != nil
  67. }
  68. func buildPrefilledArgumentsForEntity(action *config.Action, entityType string, entity *entities.Entity) map[string]string {
  69. prefilled := make(map[string]string)
  70. for i := range action.Arguments {
  71. arg := &action.Arguments[i]
  72. if arg.Entity != entityType || len(arg.Choices) != 1 {
  73. continue
  74. }
  75. prefilled[arg.Name] = tpl.ParseTemplateOfActionBeforeExec(arg.Choices[0].Value, entity)
  76. }
  77. return prefilled
  78. }
  79. func sortRelatedActionCandidates(candidates []relatedActionCandidate) {
  80. sort.Slice(candidates, func(i, j int) bool {
  81. return candidates[i].binding.ConfigOrder < candidates[j].binding.ConfigOrder
  82. })
  83. }
  84. func buildEntityRelatedActions(candidates []relatedActionCandidate, rr *DashboardRenderRequest) []*apiv1.EntityRelatedAction {
  85. result := make([]*apiv1.EntityRelatedAction, 0, len(candidates))
  86. for _, candidate := range candidates {
  87. action := buildAction(candidate.binding, rr)
  88. if action == nil {
  89. continue
  90. }
  91. result = append(result, &apiv1.EntityRelatedAction{
  92. Action: action,
  93. PrefilledArguments: candidate.prefilled,
  94. })
  95. }
  96. return result
  97. }