org.go 8.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342
  1. // Copyright 2014 The Gogs Authors. All rights reserved.
  2. // Use of this source code is governed by a MIT-style
  3. // license that can be found in the LICENSE file.
  4. package models
  5. import (
  6. "errors"
  7. "os"
  8. "strings"
  9. "github.com/gogits/gogs/modules/base"
  10. )
  11. var (
  12. ErrOrgNotExist = errors.New("Organization does not exist")
  13. ErrTeamAlreadyExist = errors.New("Team already exist")
  14. )
  15. // IsOrgOwner returns true if given user is in the owner team.
  16. func (org *User) IsOrgOwner(uid int64) bool {
  17. return IsOrganizationOwner(org.Id, uid)
  18. }
  19. // IsOrgMember returns true if given user is member of organization.
  20. func (org *User) IsOrgMember(uid int64) bool {
  21. return IsOrganizationMember(org.Id, uid)
  22. }
  23. // GetOwnerTeam returns owner team of organization.
  24. func (org *User) GetOwnerTeam() (*Team, error) {
  25. t := &Team{
  26. OrgId: org.Id,
  27. Name: OWNER_TEAM,
  28. }
  29. _, err := x.Get(t)
  30. return t, err
  31. }
  32. // GetTeams returns all teams that belong to organization.
  33. func (org *User) GetTeams() error {
  34. return x.Where("org_id=?", org.Id).Find(&org.Teams)
  35. }
  36. // GetMembers returns all members of organization.
  37. func (org *User) GetMembers() error {
  38. ous, err := GetOrgUsersByOrgId(org.Id)
  39. if err != nil {
  40. return err
  41. }
  42. org.Members = make([]*User, len(ous))
  43. for i, ou := range ous {
  44. org.Members[i], err = GetUserById(ou.Uid)
  45. if err != nil {
  46. return err
  47. }
  48. }
  49. return nil
  50. }
  51. // CreateOrganization creates record of a new organization.
  52. func CreateOrganization(org, owner *User) (*User, error) {
  53. if !IsLegalName(org.Name) {
  54. return nil, ErrUserNameIllegal
  55. }
  56. isExist, err := IsUserExist(org.Name)
  57. if err != nil {
  58. return nil, err
  59. } else if isExist {
  60. return nil, ErrUserAlreadyExist
  61. }
  62. isExist, err = IsEmailUsed(org.Email)
  63. if err != nil {
  64. return nil, err
  65. } else if isExist {
  66. return nil, ErrEmailAlreadyUsed
  67. }
  68. org.LowerName = strings.ToLower(org.Name)
  69. org.FullName = org.Name
  70. org.Avatar = base.EncodeMd5(org.Email)
  71. org.AvatarEmail = org.Email
  72. // No password for organization.
  73. org.NumTeams = 1
  74. org.NumMembers = 1
  75. sess := x.NewSession()
  76. defer sess.Close()
  77. if err = sess.Begin(); err != nil {
  78. return nil, err
  79. }
  80. if _, err = sess.Insert(org); err != nil {
  81. sess.Rollback()
  82. return nil, err
  83. }
  84. if err = os.MkdirAll(UserPath(org.Name), os.ModePerm); err != nil {
  85. sess.Rollback()
  86. return nil, err
  87. }
  88. // Create default owner team.
  89. t := &Team{
  90. OrgId: org.Id,
  91. Name: OWNER_TEAM,
  92. Authorize: ORG_ADMIN,
  93. NumMembers: 1,
  94. }
  95. if _, err = sess.Insert(t); err != nil {
  96. sess.Rollback()
  97. return nil, err
  98. }
  99. // Add initial creator to organization and owner team.
  100. ou := &OrgUser{
  101. Uid: owner.Id,
  102. OrgId: org.Id,
  103. IsOwner: true,
  104. NumTeam: 1,
  105. }
  106. if _, err = sess.Insert(ou); err != nil {
  107. sess.Rollback()
  108. return nil, err
  109. }
  110. tu := &TeamUser{
  111. Uid: owner.Id,
  112. OrgId: org.Id,
  113. TeamId: t.Id,
  114. }
  115. if _, err = sess.Insert(tu); err != nil {
  116. sess.Rollback()
  117. return nil, err
  118. }
  119. return org, sess.Commit()
  120. }
  121. // TODO: need some kind of mechanism to record failure.
  122. // DeleteOrganization completely and permanently deletes everything of organization.
  123. func DeleteOrganization(org *User) (err error) {
  124. if err := DeleteUser(org); err != nil {
  125. return err
  126. }
  127. sess := x.NewSession()
  128. defer sess.Close()
  129. if err = sess.Begin(); err != nil {
  130. return err
  131. }
  132. if _, err = sess.Delete(&Team{OrgId: org.Id}); err != nil {
  133. sess.Rollback()
  134. return err
  135. }
  136. if _, err = sess.Delete(&OrgUser{OrgId: org.Id}); err != nil {
  137. sess.Rollback()
  138. return err
  139. }
  140. if _, err = sess.Delete(&TeamUser{OrgId: org.Id}); err != nil {
  141. sess.Rollback()
  142. return err
  143. }
  144. return sess.Commit()
  145. }
  146. // ___________
  147. // \__ ___/___ _____ _____
  148. // | |_/ __ \\__ \ / \
  149. // | |\ ___/ / __ \| Y Y \
  150. // |____| \___ >____ /__|_| /
  151. // \/ \/ \/
  152. type AuthorizeType int
  153. const (
  154. ORG_READABLE AuthorizeType = iota + 1
  155. ORG_WRITABLE
  156. ORG_ADMIN
  157. )
  158. const OWNER_TEAM = "Owners"
  159. // Team represents a organization team.
  160. type Team struct {
  161. Id int64
  162. OrgId int64 `xorm:"INDEX"`
  163. LowerName string
  164. Name string
  165. Description string
  166. Authorize AuthorizeType
  167. RepoIds string `xorm:"TEXT"`
  168. NumMembers int
  169. NumRepos int
  170. Members []*User `xorm:"-"`
  171. }
  172. // IsTeamMember returns true if given user is a member of team.
  173. func (t *Team) IsMember(uid int64) bool {
  174. return IsTeamMember(t.OrgId, t.Id, uid)
  175. }
  176. // GetMembers returns all members in given team of organization.
  177. func (t *Team) GetMembers() (err error) {
  178. t.Members, err = GetTeamMembers(t.OrgId, t.Id)
  179. return err
  180. }
  181. // NewTeam creates a record of new team.
  182. // It's caller's responsibility to assign organization ID.
  183. func NewTeam(t *Team) error {
  184. has, err := x.Id(t.OrgId).Get(new(User))
  185. if err != nil {
  186. return err
  187. } else if !has {
  188. return ErrOrgNotExist
  189. }
  190. t.LowerName = strings.ToLower(t.Name)
  191. has, err = x.Where("org_id=?", t.OrgId).And("lower_name=?", t.LowerName).Get(new(Team))
  192. if err != nil {
  193. return err
  194. } else if has {
  195. return ErrTeamAlreadyExist
  196. }
  197. sess := x.NewSession()
  198. defer sess.Close()
  199. if err = sess.Begin(); err != nil {
  200. return err
  201. }
  202. if _, err = sess.Insert(t); err != nil {
  203. sess.Rollback()
  204. return err
  205. }
  206. // Update organization number of teams.
  207. rawSql := "UPDATE `user` SET num_teams = num_teams + 1 WHERE id = ?"
  208. if _, err = sess.Exec(rawSql, t.OrgId); err != nil {
  209. sess.Rollback()
  210. return err
  211. }
  212. return sess.Commit()
  213. }
  214. // UpdateTeam updates information of team.
  215. func UpdateTeam(t *Team) error {
  216. if len(t.Description) > 255 {
  217. t.Description = t.Description[:255]
  218. }
  219. t.LowerName = strings.ToLower(t.Name)
  220. _, err := x.Id(t.Id).AllCols().Update(t)
  221. return err
  222. }
  223. // ________ ____ ___
  224. // \_____ \_______ ____ | | \______ ___________
  225. // / | \_ __ \/ ___\| | / ___// __ \_ __ \
  226. // / | \ | \/ /_/ > | /\___ \\ ___/| | \/
  227. // \_______ /__| \___ /|______//____ >\___ >__|
  228. // \/ /_____/ \/ \/
  229. // OrgUser represents an organization-user relation.
  230. type OrgUser struct {
  231. Id int64
  232. Uid int64 `xorm:"INDEX"`
  233. OrgId int64 `xorm:"INDEX"`
  234. IsPublic bool
  235. IsOwner bool
  236. NumTeam int
  237. }
  238. // IsOrganizationOwner returns true if given user is in the owner team.
  239. func IsOrganizationOwner(orgId, uid int64) bool {
  240. has, _ := x.Where("is_owner=?", true).And("uid=?", uid).And("org_id=?", orgId).Get(new(OrgUser))
  241. return has
  242. }
  243. // IsOrganizationMember returns true if given user is member of organization.
  244. func IsOrganizationMember(orgId, uid int64) bool {
  245. has, _ := x.Where("uid=?", uid).And("org_id=?", orgId).Get(new(OrgUser))
  246. return has
  247. }
  248. // GetOrgUsersByUserId returns all organization-user relations by user ID.
  249. func GetOrgUsersByUserId(uid int64) ([]*OrgUser, error) {
  250. ous := make([]*OrgUser, 0, 10)
  251. err := x.Where("uid=?", uid).Find(&ous)
  252. return ous, err
  253. }
  254. // GetOrgUsersByOrgId returns all organization-user relations by organization ID.
  255. func GetOrgUsersByOrgId(orgId int64) ([]*OrgUser, error) {
  256. ous := make([]*OrgUser, 0, 10)
  257. err := x.Where("org_id=?", orgId).Find(&ous)
  258. return ous, err
  259. }
  260. // ___________ ____ ___
  261. // \__ ___/___ _____ _____ | | \______ ___________
  262. // | |_/ __ \\__ \ / \| | / ___// __ \_ __ \
  263. // | |\ ___/ / __ \| Y Y \ | /\___ \\ ___/| | \/
  264. // |____| \___ >____ /__|_| /______//____ >\___ >__|
  265. // \/ \/ \/ \/ \/
  266. // TeamUser represents an team-user relation.
  267. type TeamUser struct {
  268. Id int64
  269. Uid int64
  270. OrgId int64 `xorm:"INDEX"`
  271. TeamId int64
  272. }
  273. // IsTeamMember returns true if given user is a member of team.
  274. func IsTeamMember(orgId, teamId, uid int64) bool {
  275. has, _ := x.Where("uid=?", uid).And("org_id=?", orgId).And("team_id=?", teamId).Get(new(TeamUser))
  276. return has
  277. }
  278. // GetTeamMembers returns all members in given team of organization.
  279. func GetTeamMembers(orgId, teamId int64) ([]*User, error) {
  280. tus := make([]*TeamUser, 0, 10)
  281. err := x.Where("org_id=?", orgId).And("team_id=?", teamId).Find(&tus)
  282. if err != nil {
  283. return nil, err
  284. }
  285. us := make([]*User, len(tus))
  286. for i, tu := range tus {
  287. us[i], err = GetUserById(tu.Uid)
  288. if err != nil {
  289. return nil, err
  290. }
  291. }
  292. return us, nil
  293. }