restapi.go 27 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067
  1. // Discordgo - Discord bindings for Go
  2. // Available at https://github.com/bwmarrin/discordgo
  3. // Copyright 2015-2016 Bruce Marriner <bruce@sqls.net>. All rights reserved.
  4. // Use of this source code is governed by a BSD-style
  5. // license that can be found in the LICENSE file.
  6. // This file contains functions for interacting with the Discord REST/JSON API
  7. // at the lowest level.
  8. package discordgo
  9. import (
  10. "bytes"
  11. "encoding/json"
  12. "errors"
  13. "fmt"
  14. "image"
  15. _ "image/jpeg" // For JPEG decoding
  16. _ "image/png" // For PNG decoding
  17. "io"
  18. "io/ioutil"
  19. "mime/multipart"
  20. "net/http"
  21. "net/url"
  22. "strconv"
  23. "time"
  24. )
  25. // ErrJSONUnmarshal is returned for JSON Unmarshall errors.
  26. var ErrJSONUnmarshal = errors.New("json unmarshal")
  27. // Request makes a (GET/POST/...) Requests to Discord REST API with JSON data.
  28. // All the other Discord REST Calls in this file use this function.
  29. func (s *Session) Request(method, urlStr string, data interface{}) (response []byte, err error) {
  30. if s.Debug {
  31. fmt.Println("API REQUEST PAYLOAD :: [" + fmt.Sprintf("%+v", data) + "]")
  32. }
  33. var body []byte
  34. if data != nil {
  35. body, err = json.Marshal(data)
  36. if err != nil {
  37. return
  38. }
  39. }
  40. return s.request(method, urlStr, "application/json", body)
  41. }
  42. // request makes a (GET/POST/...) Requests to Discord REST API.
  43. func (s *Session) request(method, urlStr, contentType string, b []byte) (response []byte, err error) {
  44. if s.Debug {
  45. fmt.Printf("API REQUEST %8s :: %s\n", method, urlStr)
  46. }
  47. req, err := http.NewRequest(method, urlStr, bytes.NewBuffer(b))
  48. if err != nil {
  49. return
  50. }
  51. // Not used on initial login..
  52. // TODO: Verify if a login, otherwise complain about no-token
  53. if s.Token != "" {
  54. req.Header.Set("authorization", s.Token)
  55. }
  56. req.Header.Set("Content-Type", contentType)
  57. // TODO: Make a configurable static variable.
  58. req.Header.Set("User-Agent", fmt.Sprintf("DiscordBot (https://github.com/bwmarrin/discordgo, v%s)", VERSION))
  59. if s.Debug {
  60. for k, v := range req.Header {
  61. fmt.Printf("API REQUEST HEADER :: [%s] = %+v\n", k, v)
  62. }
  63. }
  64. client := &http.Client{Timeout: (20 * time.Second)}
  65. resp, err := client.Do(req)
  66. if err != nil {
  67. return
  68. }
  69. defer func() {
  70. err := resp.Body.Close()
  71. if err != nil {
  72. fmt.Println("error closing resp body")
  73. }
  74. }()
  75. response, err = ioutil.ReadAll(resp.Body)
  76. if err != nil {
  77. return
  78. }
  79. if s.Debug {
  80. fmt.Printf("API RESPONSE STATUS :: %s\n", resp.Status)
  81. for k, v := range resp.Header {
  82. fmt.Printf("API RESPONSE HEADER :: [%s] = %+v\n", k, v)
  83. }
  84. fmt.Printf("API RESPONSE BODY :: [%s]\n", response)
  85. }
  86. // See http://www.w3.org/Protocols/rfc2616/rfc2616-sec10.html
  87. switch resp.StatusCode {
  88. case 200: // OK
  89. case 204: // No Content
  90. // TODO check for 401 response, invalidate token if we get one.
  91. case 429: // TOO MANY REQUESTS - Rate limiting
  92. // This will be changed to a more robust method later.
  93. // which may be hugely different as this method could cause
  94. // unending recursion
  95. rl := RateLimit{}
  96. err = json.Unmarshal(response, &rl)
  97. if err != nil {
  98. err = fmt.Errorf("Request unmarshal rate limit error : %+v", err)
  99. return
  100. }
  101. time.Sleep(rl.RetryAfter)
  102. response, err = s.request(method, urlStr, contentType, b)
  103. default: // Error condition
  104. err = fmt.Errorf("HTTP %s, %s", resp.Status, response)
  105. }
  106. return
  107. }
  108. func unmarshal(data []byte, v interface{}) error {
  109. err := json.Unmarshal(data, v)
  110. if err != nil {
  111. return ErrJSONUnmarshal
  112. }
  113. return nil
  114. }
  115. // ------------------------------------------------------------------------------------------------
  116. // Functions specific to Discord Sessions
  117. // ------------------------------------------------------------------------------------------------
  118. // Login asks the Discord server for an authentication token.
  119. func (s *Session) Login(email, password string) (err error) {
  120. data := struct {
  121. Email string `json:"email"`
  122. Password string `json:"password"`
  123. }{email, password}
  124. response, err := s.Request("POST", LOGIN, data)
  125. if err != nil {
  126. return
  127. }
  128. temp := struct {
  129. Token string `json:"token"`
  130. }{}
  131. err = unmarshal(response, &temp)
  132. if err != nil {
  133. return
  134. }
  135. s.Token = temp.Token
  136. return
  137. }
  138. // Register sends a Register request to Discord, and returns the authentication token
  139. // Note that this account is temporary and should be verified for future use.
  140. // Another option is to save the authentication token external, but this isn't recommended.
  141. func (s *Session) Register(username string) (token string, err error) {
  142. data := struct {
  143. Username string `json:"username"`
  144. }{username}
  145. response, err := s.Request("POST", REGISTER, data)
  146. if err != nil {
  147. return
  148. }
  149. temp := struct {
  150. Token string `json:"token"`
  151. }{}
  152. err = unmarshal(response, &temp)
  153. if err != nil {
  154. return
  155. }
  156. token = temp.Token
  157. return
  158. }
  159. // Logout sends a logout request to Discord.
  160. // This does not seem to actually invalidate the token. So you can still
  161. // make API calls even after a Logout. So, it seems almost pointless to
  162. // even use.
  163. func (s *Session) Logout() (err error) {
  164. // _, err = s.Request("POST", LOGOUT, fmt.Sprintf(`{"token": "%s"}`, s.Token))
  165. if s.Token == "" {
  166. return
  167. }
  168. data := struct {
  169. Token string `json:"token"`
  170. }{s.Token}
  171. _, err = s.Request("POST", LOGOUT, data)
  172. return
  173. }
  174. // ------------------------------------------------------------------------------------------------
  175. // Functions specific to Discord Users
  176. // ------------------------------------------------------------------------------------------------
  177. // User returns the user details of the given userID
  178. // userID : A user ID or "@me" which is a shortcut of current user ID
  179. func (s *Session) User(userID string) (st *User, err error) {
  180. body, err := s.Request("GET", USER(userID), nil)
  181. if err != nil {
  182. return
  183. }
  184. err = unmarshal(body, &st)
  185. return
  186. }
  187. // UserAvatar returns an image.Image of a users Avatar.
  188. // userID : A user ID or "@me" which is a shortcut of current user ID
  189. func (s *Session) UserAvatar(userID string) (img image.Image, err error) {
  190. u, err := s.User(userID)
  191. if err != nil {
  192. return
  193. }
  194. body, err := s.Request("GET", USER_AVATAR(userID, u.Avatar), nil)
  195. if err != nil {
  196. return
  197. }
  198. img, _, err = image.Decode(bytes.NewReader(body))
  199. return
  200. }
  201. // UserUpdate updates a users settings.
  202. func (s *Session) UserUpdate(email, password, username, avatar, newPassword string) (st *User, err error) {
  203. // NOTE: Avatar must be either the hash/id of existing Avatar or
  204. // data:image/png;base64,BASE64_STRING_OF_NEW_AVATAR_PNG
  205. // to set a new avatar.
  206. // If left blank, avatar will be set to null/blank
  207. data := struct {
  208. Email string `json:"email"`
  209. Password string `json:"password"`
  210. Username string `json:"username"`
  211. Avatar string `json:"avatar,omitempty"`
  212. NewPassword string `json:"new_password,omitempty"`
  213. }{email, password, username, avatar, newPassword}
  214. body, err := s.Request("PATCH", USER("@me"), data)
  215. if err != nil {
  216. return
  217. }
  218. err = unmarshal(body, &st)
  219. return
  220. }
  221. // UserSettings returns the settings for a given user
  222. func (s *Session) UserSettings() (st *Settings, err error) {
  223. body, err := s.Request("GET", USER_SETTINGS("@me"), nil)
  224. if err != nil {
  225. return
  226. }
  227. err = unmarshal(body, &st)
  228. return
  229. }
  230. // UserChannels returns an array of Channel structures for all private
  231. // channels.
  232. func (s *Session) UserChannels() (st []*Channel, err error) {
  233. body, err := s.Request("GET", USER_CHANNELS("@me"), nil)
  234. if err != nil {
  235. return
  236. }
  237. err = unmarshal(body, &st)
  238. return
  239. }
  240. // UserChannelCreate creates a new User (Private) Channel with another User
  241. // recipientID : A user ID for the user to which this channel is opened with.
  242. func (s *Session) UserChannelCreate(recipientID string) (st *Channel, err error) {
  243. data := struct {
  244. RecipientID string `json:"recipient_id"`
  245. }{recipientID}
  246. body, err := s.Request("POST", USER_CHANNELS("@me"), data)
  247. if err != nil {
  248. return
  249. }
  250. err = unmarshal(body, &st)
  251. return
  252. }
  253. // UserGuilds returns an array of Guild structures for all guilds.
  254. func (s *Session) UserGuilds() (st []*Guild, err error) {
  255. body, err := s.Request("GET", USER_GUILDS("@me"), nil)
  256. if err != nil {
  257. return
  258. }
  259. err = unmarshal(body, &st)
  260. return
  261. }
  262. // ------------------------------------------------------------------------------------------------
  263. // Functions specific to Discord Guilds
  264. // ------------------------------------------------------------------------------------------------
  265. // Guild returns a Guild structure of a specific Guild.
  266. // guildID : The ID of a Guild
  267. func (s *Session) Guild(guildID string) (st *Guild, err error) {
  268. if s.StateEnabled {
  269. // Attempt to grab the guild from State first.
  270. st, err = s.State.Guild(guildID)
  271. if err == nil {
  272. return
  273. }
  274. }
  275. body, err := s.Request("GET", GUILD(guildID), nil)
  276. if err != nil {
  277. return
  278. }
  279. err = unmarshal(body, &st)
  280. return
  281. }
  282. // GuildCreate creates a new Guild
  283. // name : A name for the Guild (2-100 characters)
  284. func (s *Session) GuildCreate(name string) (st *Guild, err error) {
  285. data := struct {
  286. Name string `json:"name"`
  287. }{name}
  288. body, err := s.Request("POST", GUILDS, data)
  289. if err != nil {
  290. return
  291. }
  292. err = unmarshal(body, &st)
  293. return
  294. }
  295. // GuildEdit edits a new Guild
  296. // guildID : The ID of a Guild
  297. // name : A name for the Guild (2-100 characters)
  298. func (s *Session) GuildEdit(guildID, name string) (st *Guild, err error) {
  299. data := struct {
  300. Name string `json:"name"`
  301. }{name}
  302. body, err := s.Request("POST", GUILD(guildID), data)
  303. if err != nil {
  304. return
  305. }
  306. err = unmarshal(body, &st)
  307. return
  308. }
  309. // GuildDelete deletes a Guild.
  310. // guildID : The ID of a Guild
  311. func (s *Session) GuildDelete(guildID string) (st *Guild, err error) {
  312. body, err := s.Request("DELETE", GUILD(guildID), nil)
  313. if err != nil {
  314. return
  315. }
  316. err = unmarshal(body, &st)
  317. return
  318. }
  319. // GuildLeave leaves a Guild.
  320. // guildID : The ID of a Guild
  321. func (s *Session) GuildLeave(guildID string) (err error) {
  322. _, err = s.Request("DELETE", USER_GUILD("@me", guildID), nil)
  323. return
  324. }
  325. // GuildBans returns an array of User structures for all bans of a
  326. // given guild.
  327. // guildID : The ID of a Guild.
  328. func (s *Session) GuildBans(guildID string) (st []*User, err error) {
  329. body, err := s.Request("GET", GUILD_BANS(guildID), nil)
  330. if err != nil {
  331. return
  332. }
  333. err = unmarshal(body, &st)
  334. return
  335. }
  336. // GuildBanCreate bans the given user from the given guild.
  337. // guildID : The ID of a Guild.
  338. // userID : The ID of a User
  339. // days : The number of days of previous comments to delete.
  340. func (s *Session) GuildBanCreate(guildID, userID string, days int) (err error) {
  341. uri := GUILD_BAN(guildID, userID)
  342. if days > 0 {
  343. uri = fmt.Sprintf("%s?delete-message-days=%d", uri, days)
  344. }
  345. _, err = s.Request("PUT", uri, nil)
  346. return
  347. }
  348. // GuildBanDelete removes the given user from the guild bans
  349. // guildID : The ID of a Guild.
  350. // userID : The ID of a User
  351. func (s *Session) GuildBanDelete(guildID, userID string) (err error) {
  352. _, err = s.Request("DELETE", GUILD_BAN(guildID, userID), nil)
  353. return
  354. }
  355. // GuildMembers returns a list of members for a guild.
  356. // guildID : The ID of a Guild.
  357. func (s *Session) GuildMembers(guildID string) (st []*Member, err error) {
  358. body, err := s.Request("GET", GUILD_MEMBERS(guildID), nil)
  359. if err != nil {
  360. return
  361. }
  362. err = unmarshal(body, &st)
  363. return
  364. }
  365. // GuildMember returns a members of a guild.
  366. // guildID : The ID of a Guild.
  367. // userID : The ID of a User
  368. func (s *Session) GuildMember(guildID, userID string) (st *Member, err error) {
  369. body, err := s.Request("GET", GUILD_MEMBER(guildID, userID), nil)
  370. if err != nil {
  371. return
  372. }
  373. err = unmarshal(body, &st)
  374. return
  375. }
  376. // GuildMemberDelete removes the given user from the given guild.
  377. // guildID : The ID of a Guild.
  378. // userID : The ID of a User
  379. func (s *Session) GuildMemberDelete(guildID, userID string) (err error) {
  380. _, err = s.Request("DELETE", GUILD_MEMBER(guildID, userID), nil)
  381. return
  382. }
  383. // GuildMemberEdit edits the roles of a member.
  384. // guildID : The ID of a Guild.
  385. // userID : The ID of a User.
  386. // roles : A list of role ID's to set on the member.
  387. func (s *Session) GuildMemberEdit(guildID, userID string, roles []string) (err error) {
  388. data := struct {
  389. Roles []string `json:"roles"`
  390. }{roles}
  391. _, err = s.Request("PATCH", GUILD_MEMBER(guildID, userID), data)
  392. if err != nil {
  393. return
  394. }
  395. return
  396. }
  397. // GuildMemberMove moves a guild member from one voice channel to another/none
  398. // guildID : The ID of a Guild.
  399. // userID : The ID of a User.
  400. // channelID : The ID of a channel to move user to, or null?
  401. // NOTE : I am not entirely set on the name of this function and it may change
  402. // prior to the final 1.0.0 release of Discordgo
  403. func (s *Session) GuildMemberMove(guildID, userID, channelID string) (err error) {
  404. data := struct {
  405. ChannelID string `json:"channel_id"`
  406. }{channelID}
  407. _, err = s.Request("PATCH", GUILD_MEMBER(guildID, userID), data)
  408. if err != nil {
  409. return
  410. }
  411. return
  412. }
  413. // GuildChannels returns an array of Channel structures for all channels of a
  414. // given guild.
  415. // guildID : The ID of a Guild.
  416. func (s *Session) GuildChannels(guildID string) (st []*Channel, err error) {
  417. body, err := s.Request("GET", GUILD_CHANNELS(guildID), nil)
  418. if err != nil {
  419. return
  420. }
  421. err = unmarshal(body, &st)
  422. return
  423. }
  424. // GuildChannelCreate creates a new channel in the given guild
  425. // guildID : The ID of a Guild.
  426. // name : Name of the channel (2-100 chars length)
  427. // ctype : Tpye of the channel (voice or text)
  428. func (s *Session) GuildChannelCreate(guildID, name, ctype string) (st *Channel, err error) {
  429. data := struct {
  430. Name string `json:"name"`
  431. Type string `json:"type"`
  432. }{name, ctype}
  433. body, err := s.Request("POST", GUILD_CHANNELS(guildID), data)
  434. if err != nil {
  435. return
  436. }
  437. err = unmarshal(body, &st)
  438. return
  439. }
  440. // GuildInvites returns an array of Invite structures for the given guild
  441. // guildID : The ID of a Guild.
  442. func (s *Session) GuildInvites(guildID string) (st []*Invite, err error) {
  443. body, err := s.Request("GET", GUILD_INVITES(guildID), nil)
  444. if err != nil {
  445. return
  446. }
  447. err = unmarshal(body, &st)
  448. return
  449. }
  450. // GuildInviteCreate creates a new invite for the given guild.
  451. // guildID : The ID of a Guild.
  452. // i : An Invite struct with the values MaxAge, MaxUses, Temporary,
  453. // and XkcdPass defined.
  454. func (s *Session) GuildInviteCreate(guildID string, i *Invite) (st *Invite, err error) {
  455. data := struct {
  456. MaxAge int `json:"max_age"`
  457. MaxUses int `json:"max_uses"`
  458. Temporary bool `json:"temporary"`
  459. XKCDPass bool `json:"xkcdpass"`
  460. }{i.MaxAge, i.MaxUses, i.Temporary, i.XkcdPass}
  461. body, err := s.Request("POST", GUILD_INVITES(guildID), data)
  462. if err != nil {
  463. return
  464. }
  465. err = unmarshal(body, &st)
  466. return
  467. }
  468. // GuildRoles returns all roles for a given guild.
  469. // guildID : The ID of a Guild.
  470. func (s *Session) GuildRoles(guildID string) (st []*Role, err error) {
  471. body, err := s.Request("GET", GUILD_ROLES(guildID), nil)
  472. if err != nil {
  473. return
  474. }
  475. err = unmarshal(body, &st)
  476. return // TODO return pointer
  477. }
  478. // GuildRoleCreate returns a new Guild Role.
  479. // guildID: The ID of a Guild.
  480. func (s *Session) GuildRoleCreate(guildID string) (st *Role, err error) {
  481. body, err := s.Request("POST", GUILD_ROLES(guildID), nil)
  482. if err != nil {
  483. return
  484. }
  485. err = unmarshal(body, &st)
  486. return
  487. }
  488. // GuildRoleEdit updates an existing Guild Role with new values
  489. // guildID : The ID of a Guild.
  490. // roleID : The ID of a Role.
  491. // name : The name of the Role.
  492. // color : The color of the role (decimal, not hex).
  493. // hoist : Whether to display the role's users separately.
  494. // perm : The permissions for the role.
  495. func (s *Session) GuildRoleEdit(guildID, roleID, name string, color int, hoist bool, perm int) (st *Role, err error) {
  496. data := struct {
  497. Name string `json:"name"` // The color the role should have (as a decimal, not hex)
  498. Color int `json:"color"` // Whether to display the role's users separately
  499. Hoist bool `json:"hoist"` // The role's name (overwrites existing)
  500. Permissions int `json:"permissions"` // The overall permissions number of the role (overwrites existing)
  501. }{name, color, hoist, perm}
  502. body, err := s.Request("PATCH", GUILD_ROLE(guildID, roleID), data)
  503. if err != nil {
  504. return
  505. }
  506. err = unmarshal(body, &st)
  507. return
  508. }
  509. // GuildRoleReorder reoders guild roles
  510. // guildID : The ID of a Guild.
  511. // roles : A list of ordered roles.
  512. func (s *Session) GuildRoleReorder(guildID string, roles []*Role) (st []*Role, err error) {
  513. body, err := s.Request("PATCH", GUILD_ROLES(guildID), roles)
  514. if err != nil {
  515. return
  516. }
  517. err = unmarshal(body, &st)
  518. return
  519. }
  520. // GuildRoleDelete deletes an existing role.
  521. // guildID : The ID of a Guild.
  522. // roleID : The ID of a Role.
  523. func (s *Session) GuildRoleDelete(guildID, roleID string) (err error) {
  524. _, err = s.Request("DELETE", GUILD_ROLE(guildID, roleID), nil)
  525. return
  526. }
  527. // GuildIcon returns an image.Image of a guild icon.
  528. // guildID : The ID of a Guild.
  529. func (s *Session) GuildIcon(guildID string) (img image.Image, err error) {
  530. g, err := s.Guild(guildID)
  531. if err != nil {
  532. return
  533. }
  534. if g.Icon == "" {
  535. err = errors.New("Guild does not have an icon set.")
  536. return
  537. }
  538. body, err := s.Request("GET", GUILD_ICON(guildID, g.Icon), nil)
  539. if err != nil {
  540. return
  541. }
  542. img, _, err = image.Decode(bytes.NewReader(body))
  543. return
  544. }
  545. // GuildSplash returns an image.Image of a guild splash image.
  546. // guildID : The ID of a Guild.
  547. func (s *Session) GuildSplash(guildID string) (img image.Image, err error) {
  548. g, err := s.Guild(guildID)
  549. if err != nil {
  550. return
  551. }
  552. if g.Splash == "" {
  553. err = errors.New("Guild does not have a splash set.")
  554. return
  555. }
  556. body, err := s.Request("GET", GUILD_SPLASH(guildID, g.Splash), nil)
  557. if err != nil {
  558. return
  559. }
  560. img, _, err = image.Decode(bytes.NewReader(body))
  561. return
  562. }
  563. // ------------------------------------------------------------------------------------------------
  564. // Functions specific to Discord Channels
  565. // ------------------------------------------------------------------------------------------------
  566. // Channel returns a Channel strucutre of a specific Channel.
  567. // channelID : The ID of the Channel you want returned.
  568. func (s *Session) Channel(channelID string) (st *Channel, err error) {
  569. body, err := s.Request("GET", CHANNEL(channelID), nil)
  570. if err != nil {
  571. return
  572. }
  573. err = unmarshal(body, &st)
  574. return
  575. }
  576. // ChannelEdit edits the given channel
  577. // channelID : The ID of a Channel
  578. // name : The new name to assign the channel.
  579. func (s *Session) ChannelEdit(channelID, name string) (st *Channel, err error) {
  580. data := struct {
  581. Name string `json:"name"`
  582. }{name}
  583. body, err := s.Request("PATCH", CHANNEL(channelID), data)
  584. if err != nil {
  585. return
  586. }
  587. err = unmarshal(body, &st)
  588. return
  589. }
  590. // ChannelDelete deletes the given channel
  591. // channelID : The ID of a Channel
  592. func (s *Session) ChannelDelete(channelID string) (st *Channel, err error) {
  593. body, err := s.Request("DELETE", CHANNEL(channelID), nil)
  594. if err != nil {
  595. return
  596. }
  597. err = unmarshal(body, &st)
  598. return
  599. }
  600. // ChannelTyping broadcasts to all members that authenticated user is typing in
  601. // the given channel.
  602. // channelID : The ID of a Channel
  603. func (s *Session) ChannelTyping(channelID string) (err error) {
  604. _, err = s.Request("POST", CHANNEL_TYPING(channelID), nil)
  605. return
  606. }
  607. // ChannelMessages returns an array of Message structures for messages within
  608. // a given channel.
  609. // channelID : The ID of a Channel.
  610. // limit : The number messages that can be returned.
  611. // beforeID : If provided all messages returned will be before given ID.
  612. // afterID : If provided all messages returned will be after given ID.
  613. func (s *Session) ChannelMessages(channelID string, limit int, beforeID int, afterID int) (st []*Message, err error) {
  614. uri := CHANNEL_MESSAGES(channelID)
  615. v := url.Values{}
  616. if limit > 0 {
  617. v.Set("limit", strconv.Itoa(limit))
  618. }
  619. if afterID > 0 {
  620. v.Set("after", strconv.Itoa(afterID))
  621. }
  622. if beforeID > 0 {
  623. v.Set("before", strconv.Itoa(beforeID))
  624. }
  625. if len(v) > 0 {
  626. uri = fmt.Sprintf("%s?%s", uri, v.Encode())
  627. }
  628. body, err := s.Request("GET", uri, nil)
  629. if err != nil {
  630. return
  631. }
  632. err = unmarshal(body, &st)
  633. return
  634. }
  635. // ChannelMessageAck acknowledges and marks the given message as read
  636. // channeld : The ID of a Channel
  637. // messageID : the ID of a Message
  638. func (s *Session) ChannelMessageAck(channelID, messageID string) (err error) {
  639. _, err = s.Request("POST", CHANNEL_MESSAGE_ACK(channelID, messageID), nil)
  640. return
  641. }
  642. // channelMessageSend sends a message to the given channel.
  643. // channelID : The ID of a Channel.
  644. // content : The message to send.
  645. // tts : Whether to send the message with TTS.
  646. func (s *Session) channelMessageSend(channelID, content string, tts bool) (st *Message, err error) {
  647. // TODO: nonce string ?
  648. data := struct {
  649. Content string `json:"content"`
  650. TTS bool `json:"tts"`
  651. }{content, tts}
  652. // Send the message to the given channel
  653. response, err := s.Request("POST", CHANNEL_MESSAGES(channelID), data)
  654. if err != nil {
  655. return
  656. }
  657. err = unmarshal(response, &st)
  658. return
  659. }
  660. // ChannelMessageSend sends a message to the given channel.
  661. // channelID : The ID of a Channel.
  662. // content : The message to send.
  663. func (s *Session) ChannelMessageSend(channelID string, content string) (st *Message, err error) {
  664. return s.channelMessageSend(channelID, content, false)
  665. }
  666. // ChannelMessageSendTTS sends a message to the given channel with Text to Speech.
  667. // channelID : The ID of a Channel.
  668. // content : The message to send.
  669. func (s *Session) ChannelMessageSendTTS(channelID string, content string) (st *Message, err error) {
  670. return s.channelMessageSend(channelID, content, true)
  671. }
  672. // ChannelMessageEdit edits an existing message, replacing it entirely with
  673. // the given content.
  674. // channeld : The ID of a Channel
  675. // messageID : the ID of a Message
  676. func (s *Session) ChannelMessageEdit(channelID, messageID, content string) (st *Message, err error) {
  677. data := struct {
  678. Content string `json:"content"`
  679. }{content}
  680. response, err := s.Request("PATCH", CHANNEL_MESSAGE(channelID, messageID), data)
  681. if err != nil {
  682. return
  683. }
  684. err = unmarshal(response, &st)
  685. return
  686. }
  687. // ChannelMessageDelete deletes a message from the Channel.
  688. func (s *Session) ChannelMessageDelete(channelID, messageID string) (err error) {
  689. _, err = s.Request("DELETE", CHANNEL_MESSAGE(channelID, messageID), nil)
  690. return
  691. }
  692. // ChannelFileSend sends a file to the given channel.
  693. // channelID : The ID of a Channel.
  694. // io.Reader : A reader for the file contents.
  695. func (s *Session) ChannelFileSend(channelID, name string, r io.Reader) (st *Message, err error) {
  696. body := &bytes.Buffer{}
  697. bodywriter := multipart.NewWriter(body)
  698. writer, err := bodywriter.CreateFormFile("file", name)
  699. if err != nil {
  700. return nil, err
  701. }
  702. _, err = io.Copy(writer, r)
  703. if err != nil {
  704. return
  705. }
  706. err = bodywriter.Close()
  707. if err != nil {
  708. return
  709. }
  710. response, err := s.request("POST", CHANNEL_MESSAGES(channelID), bodywriter.FormDataContentType(), body.Bytes())
  711. if err != nil {
  712. return
  713. }
  714. err = unmarshal(response, &st)
  715. return
  716. }
  717. // ChannelInvites returns an array of Invite structures for the given channel
  718. // channelID : The ID of a Channel
  719. func (s *Session) ChannelInvites(channelID string) (st []*Invite, err error) {
  720. body, err := s.Request("GET", CHANNEL_INVITES(channelID), nil)
  721. if err != nil {
  722. return
  723. }
  724. err = unmarshal(body, &st)
  725. return
  726. }
  727. // ChannelInviteCreate creates a new invite for the given channel.
  728. // channelID : The ID of a Channel
  729. // i : An Invite struct with the values MaxAge, MaxUses, Temporary,
  730. // and XkcdPass defined.
  731. func (s *Session) ChannelInviteCreate(channelID string, i Invite) (st *Invite, err error) {
  732. data := struct {
  733. MaxAge int `json:"max_age"`
  734. MaxUses int `json:"max_uses"`
  735. Temporary bool `json:"temporary"`
  736. XKCDPass bool `json:"xkcdpass"`
  737. }{i.MaxAge, i.MaxUses, i.Temporary, i.XkcdPass}
  738. body, err := s.Request("POST", CHANNEL_INVITES(channelID), data)
  739. if err != nil {
  740. return
  741. }
  742. err = unmarshal(body, &st)
  743. return
  744. }
  745. // ChannelPermissionSet creates a Permission Override for the given channel.
  746. // NOTE: This func name may changed. Using Set instead of Create because
  747. // you can both create a new override or update an override with this function.
  748. func (s *Session) ChannelPermissionSet(channelID, targetID, targetType string, allow, deny int) (err error) {
  749. data := struct {
  750. ID string `json:"id"`
  751. Type string `json:"type"`
  752. Allow int `json:"allow"`
  753. Deny int `json:"deny"`
  754. }{targetID, targetType, allow, deny}
  755. _, err = s.Request("PUT", CHANNEL_PERMISSION(channelID, targetID), data)
  756. return
  757. }
  758. // ChannelPermissionDelete deletes a specific permission override for the given channel.
  759. // NOTE: Name of this func may change.
  760. func (s *Session) ChannelPermissionDelete(channelID, targetID string) (err error) {
  761. _, err = s.Request("DELETE", CHANNEL_PERMISSION(channelID, targetID), nil)
  762. return
  763. }
  764. // ------------------------------------------------------------------------------------------------
  765. // Functions specific to Discord Invites
  766. // ------------------------------------------------------------------------------------------------
  767. // Invite returns an Invite structure of the given invite
  768. // inviteID : The invite code (or maybe xkcdpass?)
  769. func (s *Session) Invite(inviteID string) (st *Invite, err error) {
  770. body, err := s.Request("GET", INVITE(inviteID), nil)
  771. if err != nil {
  772. return
  773. }
  774. err = unmarshal(body, &st)
  775. return
  776. }
  777. // InviteDelete deletes an existing invite
  778. // inviteID : the code (or maybe xkcdpass?) of an invite
  779. func (s *Session) InviteDelete(inviteID string) (st *Invite, err error) {
  780. body, err := s.Request("DELETE", INVITE(inviteID), nil)
  781. if err != nil {
  782. return
  783. }
  784. err = unmarshal(body, &st)
  785. return
  786. }
  787. // InviteAccept accepts an Invite to a Guild or Channel
  788. // inviteID : The invite code (or maybe xkcdpass?)
  789. func (s *Session) InviteAccept(inviteID string) (st *Invite, err error) {
  790. body, err := s.Request("POST", INVITE(inviteID), nil)
  791. if err != nil {
  792. return
  793. }
  794. err = unmarshal(body, &st)
  795. return
  796. }
  797. // ------------------------------------------------------------------------------------------------
  798. // Functions specific to Discord Voice
  799. // ------------------------------------------------------------------------------------------------
  800. // VoiceRegions returns the voice server regions
  801. func (s *Session) VoiceRegions() (st []*VoiceRegion, err error) {
  802. body, err := s.Request("GET", VOICE_REGIONS, nil)
  803. if err != nil {
  804. return
  805. }
  806. err = unmarshal(body, &st)
  807. return
  808. }
  809. // VoiceICE returns the voice server ICE information
  810. func (s *Session) VoiceICE() (st *VoiceICE, err error) {
  811. body, err := s.Request("GET", VOICE_ICE, nil)
  812. if err != nil {
  813. return
  814. }
  815. err = unmarshal(body, &st)
  816. return
  817. }
  818. // ------------------------------------------------------------------------------------------------
  819. // Functions specific to Discord Websockets
  820. // ------------------------------------------------------------------------------------------------
  821. // Gateway returns the a websocket Gateway address
  822. func (s *Session) Gateway() (gateway string, err error) {
  823. response, err := s.Request("GET", GATEWAY, nil)
  824. if err != nil {
  825. return
  826. }
  827. temp := struct {
  828. URL string `json:"url"`
  829. }{}
  830. err = unmarshal(response, &temp)
  831. if err != nil {
  832. return
  833. }
  834. gateway = temp.URL
  835. return
  836. }