mirror of
https://github.com/badkaktus/gorocket.git
synced 2024-12-12 11:15:05 +02:00
add group endpoint
This commit is contained in:
kolyuchy
parent
75b2958988
commit
309adb8aad
498
groups.go
Normal file
498
groups.go
Normal file
@ -0,0 +1,498 @@
|
||||
package gorocket
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"net/http"
|
||||
"time"
|
||||
)
|
||||
|
||||
type SimpleGroupId struct {
|
||||
RoomId string `json:"roomId,omitempty"`
|
||||
}
|
||||
|
||||
type GroupCountersRequest struct {
|
||||
RoomId string
|
||||
RoomName string
|
||||
UserId string
|
||||
}
|
||||
|
||||
type GroupCountersResponse struct {
|
||||
Joined bool `json:"joined"`
|
||||
Members int `json:"members"`
|
||||
Unreads int `json:"unreads"`
|
||||
UnreadsFrom time.Time `json:"unreadsFrom"`
|
||||
Msgs int `json:"msgs"`
|
||||
Latest time.Time `json:"latest"`
|
||||
UserMentions int `json:"userMentions"`
|
||||
Success bool `json:"success"`
|
||||
}
|
||||
|
||||
type CreateGroupRequest struct {
|
||||
Name string `json:"name"`
|
||||
Members []string `json:"members,omitempty"`
|
||||
ReadOnly bool `json:"readOnly,omitempty"`
|
||||
}
|
||||
|
||||
type CreateGroupResponse struct {
|
||||
Group channel `json:"group"`
|
||||
Success bool `json:"success"`
|
||||
}
|
||||
|
||||
type SimpleGroupRequest struct {
|
||||
RoomId string `json:"roomId,omitempty"`
|
||||
RoomName string `json:"roomName,omitempty"`
|
||||
}
|
||||
|
||||
type GroupInfoResponse struct {
|
||||
Group groupInfo `json:"group"`
|
||||
Success bool `json:"success"`
|
||||
}
|
||||
|
||||
type groupInfo struct {
|
||||
ID string `json:"_id"`
|
||||
Name string `json:"name"`
|
||||
Fname string `json:"fname"`
|
||||
T string `json:"t"`
|
||||
Msgs int `json:"msgs"`
|
||||
UsersCount int `json:"usersCount"`
|
||||
U uChat `json:"u"`
|
||||
CustomFields struct {
|
||||
} `json:"customFields"`
|
||||
Broadcast bool `json:"broadcast"`
|
||||
Encrypted bool `json:"encrypted"`
|
||||
Ts time.Time `json:"ts"`
|
||||
Ro bool `json:"ro"`
|
||||
Default bool `json:"default"`
|
||||
SysMes bool `json:"sysMes"`
|
||||
UpdatedAt time.Time `json:"_updatedAt"`
|
||||
}
|
||||
|
||||
type InviteGroupRequest struct {
|
||||
RoomId string `json:"roomId"`
|
||||
UserId string `json:"userId"`
|
||||
}
|
||||
|
||||
type InviteGroupResponse struct {
|
||||
Group struct {
|
||||
ID string `json:"_id"`
|
||||
Ts time.Time `json:"ts"`
|
||||
T string `json:"t"`
|
||||
Name string `json:"name"`
|
||||
Usernames []string `json:"usernames"`
|
||||
Msgs int `json:"msgs"`
|
||||
UpdatedAt time.Time `json:"_updatedAt"`
|
||||
Lm time.Time `json:"lm"`
|
||||
} `json:"group"`
|
||||
Success bool `json:"success"`
|
||||
}
|
||||
|
||||
type GroupListResponse struct {
|
||||
Groups []groupList `json:"groups"`
|
||||
Offset int `json:"offset"`
|
||||
Count int `json:"count"`
|
||||
Total int `json:"total"`
|
||||
Success bool `json:"success"`
|
||||
}
|
||||
|
||||
type groupList struct {
|
||||
ID string `json:"_id"`
|
||||
Name string `json:"name"`
|
||||
T string `json:"t"`
|
||||
Usernames []string `json:"usernames"`
|
||||
Msgs int `json:"msgs"`
|
||||
U uChat `json:"u"`
|
||||
Ts time.Time `json:"ts"`
|
||||
Ro bool `json:"ro"`
|
||||
SysMes bool `json:"sysMes"`
|
||||
UpdatedAt time.Time `json:"_updatedAt"`
|
||||
}
|
||||
|
||||
type GroupMembersResponse struct {
|
||||
Members []member `json:"members"`
|
||||
Count int `json:"count"`
|
||||
Offset int `json:"offset"`
|
||||
Total int `json:"total"`
|
||||
Success bool `json:"success"`
|
||||
}
|
||||
|
||||
type RenameGroupRequest struct {
|
||||
RoomId string `json:"roomId"`
|
||||
NewName string `json:"name"`
|
||||
}
|
||||
|
||||
type RenameGroupResponse struct {
|
||||
Group groupList `json:"group"`
|
||||
Success bool `json:"success"`
|
||||
}
|
||||
|
||||
// Archives a group.
|
||||
func (c *Client) ArchiveGroup(param *SimpleGroupId) (*SimpleSuccessResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.archive", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := SimpleSuccessResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Removes the group from the user's list of groups.
|
||||
func (c *Client) CloseGroup(param *SimpleGroupId) (*SimpleSuccessResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.close", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := SimpleSuccessResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Gets group counters.
|
||||
func (c *Client) GroupCounters(param *GroupCountersRequest) (*GroupCountersResponse, error) {
|
||||
|
||||
req, err := http.NewRequest("GET",
|
||||
fmt.Sprintf("%s/%s/groups.counters", c.baseURL, c.apiVersion),
|
||||
nil)
|
||||
|
||||
if param.RoomName == "" && param.RoomId == "" {
|
||||
return nil, fmt.Errorf("False parameters")
|
||||
}
|
||||
|
||||
url := req.URL.Query()
|
||||
if param.RoomName != "" {
|
||||
url.Add("roomName", param.RoomName)
|
||||
}
|
||||
if param.RoomId != "" {
|
||||
url.Add("roomId", param.RoomId)
|
||||
}
|
||||
req.URL.RawQuery = url.Encode()
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := GroupCountersResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Creates a new group.
|
||||
func (c *Client) CreateGroup(param *CreateGroupRequest) (*CreateGroupResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.create", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := CreateGroupResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Delete group.
|
||||
func (c *Client) DeleteGroup(param *SimpleGroupId) (*SimpleSuccessResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.delete", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := SimpleSuccessResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Get group info.
|
||||
func (c *Client) GroupInfo(param *SimpleGroupRequest) (*GroupInfoResponse, error) {
|
||||
|
||||
req, err := http.NewRequest("GET",
|
||||
fmt.Sprintf("%s/%s/groups.info", c.baseURL, c.apiVersion),
|
||||
nil)
|
||||
|
||||
if param.RoomName == "" && param.RoomId == "" {
|
||||
return nil, fmt.Errorf("False parameters")
|
||||
}
|
||||
|
||||
url := req.URL.Query()
|
||||
if param.RoomName != "" {
|
||||
url.Add("roomName", param.RoomName)
|
||||
}
|
||||
if param.RoomId != "" {
|
||||
url.Add("roomId", param.RoomId)
|
||||
}
|
||||
req.URL.RawQuery = url.Encode()
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := GroupInfoResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Adds a user to the group.
|
||||
func (c *Client) GroupInvite(param *InviteGroupRequest) (*InviteGroupResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.invite", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := InviteGroupResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Kick a user from the group.
|
||||
func (c *Client) GroupKick(param *InviteGroupRequest) (*InviteGroupResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.kick", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := InviteGroupResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Get groups list
|
||||
func (c *Client) GroupList() (*GroupListResponse, error) {
|
||||
req, err := http.NewRequest("GET",
|
||||
fmt.Sprintf("%s/%s/groups.list", c.baseURL, c.apiVersion),
|
||||
nil)
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := GroupListResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Gets group members
|
||||
func (c *Client) GroupMembers(param *SimpleGroupRequest) (*GroupMembersResponse, error) {
|
||||
|
||||
req, err := http.NewRequest("GET",
|
||||
fmt.Sprintf("%s/%s/groups.members", c.baseURL, c.apiVersion),
|
||||
nil)
|
||||
|
||||
if param.RoomName == "" && param.RoomId == "" {
|
||||
return nil, fmt.Errorf("False parameters")
|
||||
}
|
||||
|
||||
url := req.URL.Query()
|
||||
if param.RoomName != "" {
|
||||
url.Add("roomName", param.RoomName)
|
||||
}
|
||||
if param.RoomId != "" {
|
||||
url.Add("roomId", param.RoomId)
|
||||
}
|
||||
req.URL.RawQuery = url.Encode()
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := GroupMembersResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Adds the group back to the user's list of groups.
|
||||
func (c *Client) OpenGroup(param *SimpleGroupId) (*SimpleSuccessResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.open", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := SimpleSuccessResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Changes a group's name.
|
||||
func (c *Client) RenameGroup(param *RenameGroupRequest) (*RenameGroupResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.rename", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := RenameGroupResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Sets the announcement for the group.
|
||||
func (c *Client) SetAnnouncementGroup(param *SetAnnouncementRequest) (*SetAnnouncementResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.setAnnouncement", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := SetAnnouncementResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Sets the Description for the group.
|
||||
func (c *Client) SetDescriptionGroup(param *SetDescriptionRequest) (*SetDescriptionResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.setDescription", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := SetDescriptionResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Sets the topic for the group.
|
||||
func (c *Client) SetTopicGroup(param *SetTopicRequest) (*SetTopicResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.setTopic", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := SetTopicResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
|
||||
// Unarchive a group.
|
||||
func (c *Client) UnarchiveGroup(param *SimpleGroupId) (*SimpleSuccessResponse, error) {
|
||||
opt, _ := json.Marshal(param)
|
||||
|
||||
req, err := http.NewRequest("POST",
|
||||
fmt.Sprintf("%s/%s/groups.unarchive", c.baseURL, c.apiVersion),
|
||||
bytes.NewBuffer(opt))
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res := SimpleSuccessResponse{}
|
||||
|
||||
if err := c.sendRequest(req, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &res, nil
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user