Channels.archive

example/rest/main.go

@@ -0,0 +1,113 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"log"
+	"net/url"
+	"os"
+
+	"github.com/RocketChat/Rocket.Chat.Go.SDK/models"
+	"github.com/RocketChat/Rocket.Chat.Go.SDK/rest"
+)
+
+func main() {
+
+	hostPtr := flag.String("host", "", "Rocket.chat server host")
+	schemePtr := flag.String("scheme", "https", "http/https")
+	userPtr := flag.String("user", "", "Rocket.chat user")
+	passPtr := flag.String("pass", "", "Rocket.chat password")
+
+	required := []string{"host", "user", "pass"}
+	flag.Parse()
+
+	seen := make(map[string]bool)
+	flag.Visit(func(f *flag.Flag) { seen[f.Name] = true })
+	for _, req := range required {
+		if !seen[req] {
+			fmt.Fprintf(os.Stderr, "Missing required argument -%s\n", req)
+			os.Exit(2)
+		}
+	}
+
+	rockerServer := &url.URL{Host: *hostPtr, Scheme: *schemePtr}
+	debug := false
+
+	credentials := &models.UserCredentials{Email: *userPtr, Password: *passPtr}
+	rc, err := rest.NewRestClient(rockerServer, debug)
+	if err != nil {
+		log.Fatal(err)
+	}
+	err = rc.Rest.Login(credentials)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	myroom := &models.Channel{Name: "myroom"}
+
+	err = rc.Rest.ChannelsCreate(myroom)
+	if err != nil {
+		log.Println(err)
+	}
+
+	rcChannels, err := rc.Rest.GetPublicChannels()
+	if err != nil {
+		log.Println(err)
+	}
+
+	for _, channel := range rcChannels.Channels {
+		fmt.Printf("channel\n\tName:\t%s\n\tID:\t%s\n", channel.Name, channel.ID)
+
+		if channel.Name == "myroom" {
+			closeThisRoom := &models.Channel{ID: channel.ID}
+			err = rc.Rest.ChannelClose(closeThisRoom)
+			if err != nil {
+				log.Println(err)
+			}
+		}
+	}
+
+	general := &models.Channel{ID: "GENERAL", Name: "general"}
+
+	members, _ := rc.Rest.GetMembersList("GENERAL")
+	fmt.Println(members)
+
+	messages, err := rc.Rest.GetMessages(general, &models.Pagination{Count: 5})
+	if err != nil {
+		log.Println(err)
+	}
+
+	for _, message := range messages {
+		fmt.Printf("%s %s\n", message.Timestamp, message.User.UserName)
+		fmt.Printf("%s\n", message.Msg)
+		fmt.Println("")
+	}
+
+	msgOBJ := models.Attachment{
+		Color:    "#00ff00",
+		Text:     "Yay for the gopher!",
+		ImageURL: "https://ih1.redbubble.net/image.377846240.0222/ap,550x550,12x16,1,transparent,t.png",
+		Title:    "PostMessage Example for Go",
+		Fields: []models.AttachmentField{
+			models.AttachmentField{Short: true, Title: "Get the package", Value: "[Link](https://github.com/RocketChat/Rocket.Chat.Go.SDK) Rocket.Chat.Go.SDK"},
+		},
+	}
+
+	msgPOST := models.PostMessage{
+		RoomID:  "GENERAL",
+		Channel: "general",
+		Emoji:   ":smirk:",
+		Text:    "PostMessage API using GoLang works ok",
+		Attachments: []models.Attachment{
+			msgOBJ,
+		},
+	}
+
+	message, err := rc.Rest.PostMessage(&msgPOST)
+	log.Println(message)
+
+	if err != nil {
+		log.Println(err)
+	}
+}
+

models/channel.go

@@ -2,6 +2,7 @@ package models
 
 import "time"
 
+// Channel ...
 type Channel struct {
 	ID    string `json:"_id"`
 	Name  string `json:"name"`
@@ -25,15 +26,33 @@ type Channel struct {
 	// } `json:"customFields,omitempty"`
 }
 
+// ChannelSubscription ...
 type ChannelSubscription struct {
 	ID          string   `json:"_id"`
 	Alert       bool     `json:"alert"`
 	Name        string   `json:"name"`
 	DisplayName string   `json:"fname"`
 	Open        bool     `json:"open"`
-	RoomId      string   `json:"rid"`
+	RoomID      string   `json:"rid"`
 	Type        string   `json:"c"`
 	User        User     `json:"u"`
 	Roles       []string `json:"roles"`
 	Unread      float64  `json:"unread"`
 }
+
+//MembersList members in a channel
+type MembersList struct {
+	Members []Member `json:"members"`
+	Count   int      `json:"count"`
+	Offset  int      `json:"offset"`
+	Total   int      `json:"total"`
+	Success bool     `json:"success"`
+}
+
+// Member ...
+type Member struct {
+	ID       string `json:"_id"`
+	Username string `json:"username"`
+	Name     string `json:"name"`
+	Status   string `json:"status"`
+}

models/info.go

@@ -2,6 +2,7 @@ package models
 
 import "time"
 
+// Info ...
 type Info struct {
 	Version string `json:"version"`
 
@@ -22,12 +23,14 @@ type Info struct {
 	} `json:"commit"`
 }
 
+// Pagination ...
 type Pagination struct {
 	Count  int `json:"count"`
 	Offset int `json:"offset"`
 	Total  int `json:"total"`
 }
 
+// Directory ...
 type Directory struct {
 	Result []struct {
 		ID        string    `json:"_id"`
@@ -43,11 +46,13 @@ type Directory struct {
 	Pagination
 }
 
+// Spotlight ...
 type Spotlight struct {
 	Users []User    `json:"users"`
 	Rooms []Channel `json:"rooms"`
 }
 
+// Statistics ...
 type Statistics struct {
 	ID       string `json:"_id"`
 	UniqueID string `json:"uniqueId"`
@@ -122,10 +127,12 @@ type Statistics struct {
 	UpdatedAt     time.Time `json:"_updatedAt"`
 }
 
+// StatisticsInfo ...
 type StatisticsInfo struct {
 	Statistics Statistics `json:"statistics"`
 }
 
+// StatisticsList ...
 type StatisticsList struct {
 	Statistics []Statistics `json:"statistics"`
 

models/message.go

@@ -2,6 +2,7 @@ package models
 
 import "time"
 
+// Message ...
 type Message struct {
 	ID       string `json:"_id"`
 	RoomID   string `json:"rid"`

models/permission.go

@@ -1,5 +1,6 @@
 package models
 
+// Permission ...
 type Permission struct {
 	ID        string   `json:"_id"`
 	UpdatedAt string   `json:"_updatedAt.$date"`

models/setting.go

@@ -1,5 +1,6 @@
 package models
 
+// Setting ...
 type Setting struct {
 	ID           string  `json:"_id"`
 	Blocked      bool    `json:"blocked"`
@@ -16,6 +17,7 @@ type Setting struct {
 	ValueAsset   Asset   `json:"asset"`
 }
 
+// Asset ...
 type Asset struct {
-	DefaultUrl string `json:"defaultUrl"`
+	DefaultURL string `json:"defaultUrl"`
 }

models/user.go

@@ -1,5 +1,6 @@
 package models
 
+// User ...
 type User struct {
 	ID           string `json:"_id"`
 	Name         string `json:"name"`

models/userCredentials.go

@@ -1,5 +1,6 @@
 package models
 
+// UserCredentials model
 type UserCredentials struct {
 	ID    string `json:"id"`
 	Token string `json:"token"`

realtime/channels.go

@@ -7,7 +7,8 @@ import (
 	"github.com/RocketChat/Rocket.Chat.Go.SDK/models"
 )
 
-func (c *Client) GetChannelId(name string) (string, error) {
+// GetChannelID ...
+func (c *Client) GetChannelID(name string) (string, error) {
 	rawResponse, err := c.ddp.Call("getRoomIdByNameOrId", name)
 	if err != nil {
 		return "", err
@@ -99,8 +100,8 @@ func (c *Client) GetChannelSubscriptions() ([]models.ChannelSubscription, error)
 // GetChannelRoles returns room roles
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/get-room-roles
-func (c *Client) GetChannelRoles(roomId string) error {
-	_, err := c.ddp.Call("getRoomRoles", roomId)
+func (c *Client) GetChannelRoles(roomID string) error {
+	_, err := c.ddp.Call("getRoomRoles", roomID)
 	if err != nil {
 		return err
 	}
@@ -138,8 +139,8 @@ func (c *Client) CreateGroup(name string, users []string) error {
 // Takes roomId
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/joining-channels
-func (c *Client) JoinChannel(roomId string) error {
-	_, err := c.ddp.Call("joinRoom", roomId)
+func (c *Client) JoinChannel(roomID string) error {
+	_, err := c.ddp.Call("joinRoom", roomID)
 	if err != nil {
 		return err
 	}
@@ -151,8 +152,8 @@ func (c *Client) JoinChannel(roomId string) error {
 // Takes roomId
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/leaving-rooms
-func (c *Client) LeaveChannel(roomId string) error {
-	_, err := c.ddp.Call("leaveRoom", roomId)
+func (c *Client) LeaveChannel(roomID string) error {
+	_, err := c.ddp.Call("leaveRoom", roomID)
 	if err != nil {
 		return err
 	}
@@ -164,8 +165,8 @@ func (c *Client) LeaveChannel(roomId string) error {
 // Takes roomId
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/archive-rooms
-func (c *Client) ArchiveChannel(roomId string) error {
-	_, err := c.ddp.Call("archiveRoom", roomId)
+func (c *Client) ArchiveChannel(roomID string) error {
+	_, err := c.ddp.Call("archiveRoom", roomID)
 	if err != nil {
 		return err
 	}
@@ -177,8 +178,8 @@ func (c *Client) ArchiveChannel(roomId string) error {
 // Takes roomId
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/unarchive-rooms
-func (c *Client) UnArchiveChannel(roomId string) error {
-	_, err := c.ddp.Call("unarchiveRoom", roomId)
+func (c *Client) UnArchiveChannel(roomID string) error {
+	_, err := c.ddp.Call("unarchiveRoom", roomID)
 	if err != nil {
 		return err
 	}
@@ -190,8 +191,8 @@ func (c *Client) UnArchiveChannel(roomId string) error {
 // Takes roomId
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/delete-rooms
-func (c *Client) DeleteChannel(roomId string) error {
-	_, err := c.ddp.Call("eraseRoom", roomId)
+func (c *Client) DeleteChannel(roomID string) error {
+	_, err := c.ddp.Call("eraseRoom", roomID)
 	if err != nil {
 		return err
 	}
@@ -203,8 +204,8 @@ func (c *Client) DeleteChannel(roomId string) error {
 // takes roomId and topic
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/save-room-settings
-func (c *Client) SetChannelTopic(roomId string, topic string) error {
-	_, err := c.ddp.Call("saveRoomSettings", roomId, "roomTopic", topic)
+func (c *Client) SetChannelTopic(roomID string, topic string) error {
+	_, err := c.ddp.Call("saveRoomSettings", roomID, "roomTopic", topic)
 	if err != nil {
 		return err
 	}
@@ -216,8 +217,8 @@ func (c *Client) SetChannelTopic(roomId string, topic string) error {
 // takes roomId and roomType
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/save-room-settings
-func (c *Client) SetChannelType(roomId string, roomType string) error {
-	_, err := c.ddp.Call("saveRoomSettings", roomId, "roomType", roomType)
+func (c *Client) SetChannelType(roomID string, roomType string) error {
+	_, err := c.ddp.Call("saveRoomSettings", roomID, "roomType", roomType)
 	if err != nil {
 		return err
 	}
@@ -226,11 +227,11 @@ func (c *Client) SetChannelType(roomId string, roomType string) error {
 }
 
 // SetChannelJoinCode sets channel join code
-// takes roomId and joinCode
+// takes roomID and joinCode
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/save-room-settings
-func (c *Client) SetChannelJoinCode(roomId string, joinCode string) error {
-	_, err := c.ddp.Call("saveRoomSettings", roomId, "joinCode", joinCode)
+func (c *Client) SetChannelJoinCode(roomID string, joinCode string) error {
+	_, err := c.ddp.Call("saveRoomSettings", roomID, "joinCode", joinCode)
 	if err != nil {
 		return err
 	}
@@ -242,8 +243,8 @@ func (c *Client) SetChannelJoinCode(roomId string, joinCode string) error {
 // takes roomId and boolean
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/save-room-settings
-func (c *Client) SetChannelReadOnly(roomId string, readOnly bool) error {
-	_, err := c.ddp.Call("saveRoomSettings", roomId, "readOnly", readOnly)
+func (c *Client) SetChannelReadOnly(roomID string, readOnly bool) error {
+	_, err := c.ddp.Call("saveRoomSettings", roomID, "readOnly", readOnly)
 	if err != nil {
 		return err
 	}
@@ -255,8 +256,8 @@ func (c *Client) SetChannelReadOnly(roomId string, readOnly bool) error {
 // takes roomId and description
 //
 // https://rocket.chat/docs/developer-guides/realtime-api/method-calls/save-room-settings
-func (c *Client) SetChannelDescription(roomId string, description string) error {
-	_, err := c.ddp.Call("saveRoomSettings", roomId, "roomDescription", description)
+func (c *Client) SetChannelDescription(roomID string, description string) error {
+	_, err := c.ddp.Call("saveRoomSettings", roomID, "roomDescription", description)
 	if err != nil {
 		return err
 	}