request.go 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240
  1. package permission
  2. /*
  3. This is the handler to handle the permission request endpoints
  4. Group information are stored in database as follows
  5. group/{groupname} = module permissions
  6. isadmin/{groupname} = isAdmin
  7. quota/{groupname} = default quota in bytes
  8. */
  9. import (
  10. "encoding/json"
  11. "log"
  12. "net/http"
  13. "strconv"
  14. )
  15. //Handle group editing operations
  16. func (h *PermissionHandler) HandleListGroup(w http.ResponseWriter, r *http.Request) {
  17. listPermission, _ := mv(r, "showper", false)
  18. if listPermission == "" {
  19. //Only show the user group name
  20. results := []string{}
  21. for _, gp := range h.PermissionGroups {
  22. results = append(results, gp.Name)
  23. }
  24. jsonString, _ := json.Marshal(results)
  25. sendJSONResponse(w, string(jsonString))
  26. } else {
  27. //Show user group and its module permissions
  28. results := make(map[string][]interface{})
  29. for _, gp := range h.PermissionGroups {
  30. var thisGroupInfo []interface{}
  31. thisGroupInfo = append(thisGroupInfo, gp.AccessibleModules)
  32. thisGroupInfo = append(thisGroupInfo, gp.IsAdmin)
  33. thisGroupInfo = append(thisGroupInfo, gp.DefaultStorageQuota)
  34. results[gp.Name] = thisGroupInfo
  35. }
  36. jsonString, _ := json.Marshal(results)
  37. sendJSONResponse(w, string(jsonString))
  38. }
  39. }
  40. //Listing a group's detail for editing or updating the group content
  41. func (h *PermissionHandler) HandleGroupEdit(w http.ResponseWriter, r *http.Request) {
  42. groupname, err := mv(r, "groupname", true)
  43. if err != nil {
  44. sendErrorResponse(w, "Group name not defined")
  45. return
  46. }
  47. listmode, _ := mv(r, "list", false)
  48. if listmode == "" {
  49. //Edit update mode
  50. permission, err := mv(r, "permission", true)
  51. if err != nil {
  52. sendErrorResponse(w, "Group name not defined")
  53. return
  54. }
  55. permissionSlice := []string{}
  56. err = json.Unmarshal([]byte(permission), &permissionSlice)
  57. if err != nil {
  58. sendErrorResponse(w, "Failed to parse module list")
  59. return
  60. }
  61. isAdmin, err := mv(r, "isAdmin", true)
  62. if err != nil {
  63. sendErrorResponse(w, "Admin permission not defined")
  64. return
  65. }
  66. //Do not allow removal of admin permission from administrator group
  67. if isAdmin == "false" && groupname == "administrator" {
  68. sendErrorResponse(w, "You cannot unset admin permission from administrator group")
  69. return
  70. }
  71. quota, err := mv(r, "defaultQuota", true)
  72. if err != nil {
  73. sendErrorResponse(w, "Default Quota not defined")
  74. return
  75. }
  76. interfaceModule, err := mv(r, "interfaceModule", true)
  77. if err != nil {
  78. sendErrorResponse(w, "Default Interface Module not defined")
  79. return
  80. }
  81. //Check if the group name already exists
  82. if !h.GroupExists(groupname) {
  83. sendErrorResponse(w, "Group not exists")
  84. return
  85. }
  86. quotaInt, err := strconv.Atoi(quota)
  87. if err != nil {
  88. sendErrorResponse(w, "Invalid Quota.")
  89. return
  90. }
  91. h.UpdatePermissionGroup(groupname, isAdmin == "true", int64(quotaInt), permissionSlice, interfaceModule)
  92. sendOK(w)
  93. } else {
  94. //Listing mode
  95. //Check if the group exists
  96. if !h.GroupExists(groupname) {
  97. sendErrorResponse(w, "Group not exists")
  98. return
  99. }
  100. //OK. Get the group information
  101. pg := h.GetPermissionGroupByName(groupname)
  102. //pg will not be nil because group exists has checked it availbilty
  103. jsonString, _ := json.Marshal(pg)
  104. sendJSONResponse(w, string(jsonString))
  105. }
  106. }
  107. func (h *PermissionHandler) HandleGroupCreate(w http.ResponseWriter, r *http.Request) {
  108. groupname, err := mv(r, "groupname", true)
  109. if err != nil {
  110. sendErrorResponse(w, "Group name not defined")
  111. return
  112. }
  113. permission, err := mv(r, "permission", true)
  114. if err != nil {
  115. sendErrorResponse(w, "Group name not defined")
  116. return
  117. }
  118. permissionSlice := []string{}
  119. err = json.Unmarshal([]byte(permission), &permissionSlice)
  120. if err != nil {
  121. sendErrorResponse(w, "Failed to parse module list")
  122. return
  123. }
  124. isAdmin, err := mv(r, "isAdmin", true)
  125. if err != nil {
  126. sendErrorResponse(w, "Admin permission not defined")
  127. return
  128. }
  129. quota, err := mv(r, "defaultQuota", true)
  130. if err != nil {
  131. sendErrorResponse(w, "Default Quota not defined")
  132. return
  133. }
  134. interfaceModule, err := mv(r, "interfaceModule", true)
  135. if err != nil {
  136. sendErrorResponse(w, "Default Interface Module not defined")
  137. return
  138. }
  139. //Check if the group name already exists
  140. if h.GroupExists(groupname) {
  141. sendErrorResponse(w, "Group already exists")
  142. return
  143. }
  144. quotaInt, err := strconv.Atoi(quota)
  145. if err != nil {
  146. sendErrorResponse(w, "Invalid Quota.")
  147. return
  148. }
  149. if quotaInt < -1 {
  150. sendErrorResponse(w, "Quota cannot be smaller than -1. (Set to -1 for unlimited quota)")
  151. return
  152. }
  153. //Migrated the creation process to a seperated function
  154. h.NewPermissionGroup(groupname, isAdmin == "true", int64(quotaInt), permissionSlice, interfaceModule)
  155. /*
  156. //OK. Write the results into database
  157. h.database.Write("permission", "group/" + groupname, permission)
  158. h.database.Write("permission", "isadmin/" + groupname, isAdmin)
  159. h.database.Write("permission", "quota/" + groupname, int64(quotaInt))
  160. h.database.Write("permission", "interfaceModule/" + groupname, interfaceModule)
  161. //Update the current cached permission group table
  162. h.LoadPermissionGroupsFromDatabase()
  163. */
  164. sendOK(w)
  165. log.Println("Creating New Permission Group:", groupname, permission, isAdmin, quota)
  166. }
  167. func (h *PermissionHandler) HandleGroupRemove(w http.ResponseWriter, r *http.Request) {
  168. groupname, err := mv(r, "groupname", true)
  169. if err != nil {
  170. sendErrorResponse(w, "Group name not defined")
  171. return
  172. }
  173. //Check if the group name exists
  174. if !h.GroupExists(groupname) {
  175. sendErrorResponse(w, "Group not exists")
  176. return
  177. }
  178. //Check if this is administrator group
  179. if groupname == "administrator" {
  180. sendErrorResponse(w, "You cannot remove Administrator group.")
  181. return
  182. }
  183. //Get the group by its name
  184. group := h.GetPermissionGroupByName(groupname)
  185. //Remove the group
  186. group.Remove()
  187. //Update the current cached permission group table
  188. newGroupList := []*PermissionGroup{}
  189. for _, pg := range h.PermissionGroups {
  190. if pg.Name != groupname {
  191. newGroupList = append(newGroupList, pg)
  192. }
  193. }
  194. h.PermissionGroups = newGroupList
  195. //Update 27-12-2020: Replaced database reload with new group list creation
  196. //h.LoadPermissionGroupsFromDatabase()
  197. sendOK(w)
  198. }