restapi.go 26 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046
  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. // GuildChannels returns an array of Channel structures for all channels of a
  398. // given guild.
  399. // guildID : The ID of a Guild.
  400. func (s *Session) GuildChannels(guildID string) (st []*Channel, err error) {
  401. body, err := s.Request("GET", GUILD_CHANNELS(guildID), nil)
  402. if err != nil {
  403. return
  404. }
  405. err = unmarshal(body, &st)
  406. return
  407. }
  408. // GuildChannelCreate creates a new channel in the given guild
  409. // guildID : The ID of a Guild.
  410. // name : Name of the channel (2-100 chars length)
  411. // ctype : Tpye of the channel (voice or text)
  412. func (s *Session) GuildChannelCreate(guildID, name, ctype string) (st *Channel, err error) {
  413. data := struct {
  414. Name string `json:"name"`
  415. Type string `json:"type"`
  416. }{name, ctype}
  417. body, err := s.Request("POST", GUILD_CHANNELS(guildID), data)
  418. if err != nil {
  419. return
  420. }
  421. err = unmarshal(body, &st)
  422. return
  423. }
  424. // GuildInvites returns an array of Invite structures for the given guild
  425. // guildID : The ID of a Guild.
  426. func (s *Session) GuildInvites(guildID string) (st []*Invite, err error) {
  427. body, err := s.Request("GET", GUILD_INVITES(guildID), nil)
  428. if err != nil {
  429. return
  430. }
  431. err = unmarshal(body, &st)
  432. return
  433. }
  434. // GuildInviteCreate creates a new invite for the given guild.
  435. // guildID : The ID of a Guild.
  436. // i : An Invite struct with the values MaxAge, MaxUses, Temporary,
  437. // and XkcdPass defined.
  438. func (s *Session) GuildInviteCreate(guildID string, i *Invite) (st *Invite, err error) {
  439. data := struct {
  440. MaxAge int `json:"max_age"`
  441. MaxUses int `json:"max_uses"`
  442. Temporary bool `json:"temporary"`
  443. XKCDPass bool `json:"xkcdpass"`
  444. }{i.MaxAge, i.MaxUses, i.Temporary, i.XkcdPass}
  445. body, err := s.Request("POST", GUILD_INVITES(guildID), data)
  446. if err != nil {
  447. return
  448. }
  449. err = unmarshal(body, &st)
  450. return
  451. }
  452. // GuildRoles returns all roles for a given guild.
  453. // guildID : The ID of a Guild.
  454. func (s *Session) GuildRoles(guildID string) (st []*Role, err error) {
  455. body, err := s.Request("GET", GUILD_ROLES(guildID), nil)
  456. if err != nil {
  457. return
  458. }
  459. err = unmarshal(body, &st)
  460. return // TODO return pointer
  461. }
  462. // GuildRoleCreate returns a new Guild Role.
  463. // guildID: The ID of a Guild.
  464. func (s *Session) GuildRoleCreate(guildID string) (st *Role, err error) {
  465. body, err := s.Request("POST", GUILD_ROLES(guildID), nil)
  466. if err != nil {
  467. return
  468. }
  469. err = unmarshal(body, &st)
  470. return
  471. }
  472. // GuildRoleEdit updates an existing Guild Role with new values
  473. // guildID : The ID of a Guild.
  474. // roleID : The ID of a Role.
  475. // name : The name of the Role.
  476. // color : The color of the role (decimal, not hex).
  477. // hoist : Whether to display the role's users separately.
  478. // perm : The permissions for the role.
  479. func (s *Session) GuildRoleEdit(guildID, roleID, name string, color int, hoist bool, perm int) (st *Role, err error) {
  480. data := struct {
  481. Name string `json:"name"` // The color the role should have (as a decimal, not hex)
  482. Color int `json:"color"` // Whether to display the role's users separately
  483. Hoist bool `json:"hoist"` // The role's name (overwrites existing)
  484. Permissions int `json:"permissions"` // The overall permissions number of the role (overwrites existing)
  485. }{name, color, hoist, perm}
  486. body, err := s.Request("PATCH", GUILD_ROLE(guildID, roleID), data)
  487. if err != nil {
  488. return
  489. }
  490. err = unmarshal(body, &st)
  491. return
  492. }
  493. // GuildRoleReorder reoders guild roles
  494. // guildID : The ID of a Guild.
  495. // roles : A list of ordered roles.
  496. func (s *Session) GuildRoleReorder(guildID string, roles []*Role) (st []*Role, err error) {
  497. body, err := s.Request("PATCH", GUILD_ROLES(guildID), roles)
  498. if err != nil {
  499. return
  500. }
  501. err = unmarshal(body, &st)
  502. return
  503. }
  504. // GuildRoleDelete deletes an existing role.
  505. // guildID : The ID of a Guild.
  506. // roleID : The ID of a Role.
  507. func (s *Session) GuildRoleDelete(guildID, roleID string) (err error) {
  508. _, err = s.Request("DELETE", GUILD_ROLE(guildID, roleID), nil)
  509. return
  510. }
  511. // GuildIcon returns an image.Image of a guild icon.
  512. // guildID : The ID of a Guild.
  513. func (s *Session) GuildIcon(guildID string) (img image.Image, err error) {
  514. g, err := s.Guild(guildID)
  515. if err != nil {
  516. return
  517. }
  518. if g.Icon == "" {
  519. err = errors.New("Guild does not have an icon set.")
  520. return
  521. }
  522. body, err := s.Request("GET", GUILD_ICON(guildID, g.Icon), nil)
  523. if err != nil {
  524. return
  525. }
  526. img, _, err = image.Decode(bytes.NewReader(body))
  527. return
  528. }
  529. // GuildSplash returns an image.Image of a guild splash image.
  530. // guildID : The ID of a Guild.
  531. func (s *Session) GuildSplash(guildID string) (img image.Image, err error) {
  532. g, err := s.Guild(guildID)
  533. if err != nil {
  534. return
  535. }
  536. if g.Splash == "" {
  537. err = errors.New("Guild does not have a splash set.")
  538. return
  539. }
  540. body, err := s.Request("GET", GUILD_SPLASH(guildID, g.Splash), nil)
  541. if err != nil {
  542. return
  543. }
  544. img, _, err = image.Decode(bytes.NewReader(body))
  545. return
  546. }
  547. // ------------------------------------------------------------------------------------------------
  548. // Functions specific to Discord Channels
  549. // ------------------------------------------------------------------------------------------------
  550. // Channel returns a Channel strucutre of a specific Channel.
  551. // channelID : The ID of the Channel you want returned.
  552. func (s *Session) Channel(channelID string) (st *Channel, err error) {
  553. body, err := s.Request("GET", CHANNEL(channelID), nil)
  554. if err != nil {
  555. return
  556. }
  557. err = unmarshal(body, &st)
  558. return
  559. }
  560. // ChannelEdit edits the given channel
  561. // channelID : The ID of a Channel
  562. // name : The new name to assign the channel.
  563. func (s *Session) ChannelEdit(channelID, name string) (st *Channel, err error) {
  564. data := struct {
  565. Name string `json:"name"`
  566. }{name}
  567. body, err := s.Request("PATCH", CHANNEL(channelID), data)
  568. if err != nil {
  569. return
  570. }
  571. err = unmarshal(body, &st)
  572. return
  573. }
  574. // ChannelDelete deletes the given channel
  575. // channelID : The ID of a Channel
  576. func (s *Session) ChannelDelete(channelID string) (st *Channel, err error) {
  577. body, err := s.Request("DELETE", CHANNEL(channelID), nil)
  578. if err != nil {
  579. return
  580. }
  581. err = unmarshal(body, &st)
  582. return
  583. }
  584. // ChannelTyping broadcasts to all members that authenticated user is typing in
  585. // the given channel.
  586. // channelID : The ID of a Channel
  587. func (s *Session) ChannelTyping(channelID string) (err error) {
  588. _, err = s.Request("POST", CHANNEL_TYPING(channelID), nil)
  589. return
  590. }
  591. // ChannelMessages returns an array of Message structures for messages within
  592. // a given channel.
  593. // channelID : The ID of a Channel.
  594. // limit : The number messages that can be returned.
  595. // beforeID : If provided all messages returned will be before given ID.
  596. // afterID : If provided all messages returned will be after given ID.
  597. func (s *Session) ChannelMessages(channelID string, limit int, beforeID int, afterID int) (st []*Message, err error) {
  598. uri := CHANNEL_MESSAGES(channelID)
  599. v := url.Values{}
  600. if limit > 0 {
  601. v.Set("limit", strconv.Itoa(limit))
  602. }
  603. if afterID > 0 {
  604. v.Set("after", strconv.Itoa(afterID))
  605. }
  606. if beforeID > 0 {
  607. v.Set("before", strconv.Itoa(beforeID))
  608. }
  609. if len(v) > 0 {
  610. uri = fmt.Sprintf("%s?%s", uri, v.Encode())
  611. }
  612. body, err := s.Request("GET", uri, nil)
  613. if err != nil {
  614. return
  615. }
  616. err = unmarshal(body, &st)
  617. return
  618. }
  619. // ChannelMessageAck acknowledges and marks the given message as read
  620. // channeld : The ID of a Channel
  621. // messageID : the ID of a Message
  622. func (s *Session) ChannelMessageAck(channelID, messageID string) (err error) {
  623. _, err = s.Request("POST", CHANNEL_MESSAGE_ACK(channelID, messageID), nil)
  624. return
  625. }
  626. // channelMessageSend sends a message to the given channel.
  627. // channelID : The ID of a Channel.
  628. // content : The message to send.
  629. // tts : Whether to send the message with TTS.
  630. func (s *Session) channelMessageSend(channelID, content string, tts bool) (st *Message, err error) {
  631. // TODO: nonce string ?
  632. data := struct {
  633. Content string `json:"content"`
  634. TTS bool `json:"tts"`
  635. }{content, tts}
  636. // Send the message to the given channel
  637. response, err := s.Request("POST", CHANNEL_MESSAGES(channelID), data)
  638. if err != nil {
  639. return
  640. }
  641. err = unmarshal(response, &st)
  642. return
  643. }
  644. // ChannelMessageSend sends a message to the given channel.
  645. // channelID : The ID of a Channel.
  646. // content : The message to send.
  647. func (s *Session) ChannelMessageSend(channelID string, content string) (st *Message, err error) {
  648. return s.channelMessageSend(channelID, content, false)
  649. }
  650. // ChannelMessageSendTTS sends a message to the given channel with Text to Speech.
  651. // channelID : The ID of a Channel.
  652. // content : The message to send.
  653. func (s *Session) ChannelMessageSendTTS(channelID string, content string) (st *Message, err error) {
  654. return s.channelMessageSend(channelID, content, true)
  655. }
  656. // ChannelMessageEdit edits an existing message, replacing it entirely with
  657. // the given content.
  658. // channeld : The ID of a Channel
  659. // messageID : the ID of a Message
  660. func (s *Session) ChannelMessageEdit(channelID, messageID, content string) (st *Message, err error) {
  661. data := struct {
  662. Content string `json:"content"`
  663. }{content}
  664. response, err := s.Request("PATCH", CHANNEL_MESSAGE(channelID, messageID), data)
  665. if err != nil {
  666. return
  667. }
  668. err = unmarshal(response, &st)
  669. return
  670. }
  671. // ChannelMessageDelete deletes a message from the Channel.
  672. func (s *Session) ChannelMessageDelete(channelID, messageID string) (err error) {
  673. _, err = s.Request("DELETE", CHANNEL_MESSAGE(channelID, messageID), nil)
  674. return
  675. }
  676. // ChannelFileSend sends a file to the given channel.
  677. // channelID : The ID of a Channel.
  678. // io.Reader : A reader for the file contents.
  679. func (s *Session) ChannelFileSend(channelID, name string, r io.Reader) (st *Message, err error) {
  680. body := &bytes.Buffer{}
  681. bodywriter := multipart.NewWriter(body)
  682. writer, err := bodywriter.CreateFormFile("file", name)
  683. if err != nil {
  684. return nil, err
  685. }
  686. _, err = io.Copy(writer, r)
  687. if err != nil {
  688. return
  689. }
  690. err = bodywriter.Close()
  691. if err != nil {
  692. return
  693. }
  694. response, err := s.request("POST", CHANNEL_MESSAGES(channelID), bodywriter.FormDataContentType(), body.Bytes())
  695. if err != nil {
  696. return
  697. }
  698. err = unmarshal(response, &st)
  699. return
  700. }
  701. // ChannelInvites returns an array of Invite structures for the given channel
  702. // channelID : The ID of a Channel
  703. func (s *Session) ChannelInvites(channelID string) (st []*Invite, err error) {
  704. body, err := s.Request("GET", CHANNEL_INVITES(channelID), nil)
  705. if err != nil {
  706. return
  707. }
  708. err = unmarshal(body, &st)
  709. return
  710. }
  711. // ChannelInviteCreate creates a new invite for the given channel.
  712. // channelID : The ID of a Channel
  713. // i : An Invite struct with the values MaxAge, MaxUses, Temporary,
  714. // and XkcdPass defined.
  715. func (s *Session) ChannelInviteCreate(channelID string, i Invite) (st *Invite, err error) {
  716. data := struct {
  717. MaxAge int `json:"max_age"`
  718. MaxUses int `json:"max_uses"`
  719. Temporary bool `json:"temporary"`
  720. XKCDPass bool `json:"xkcdpass"`
  721. }{i.MaxAge, i.MaxUses, i.Temporary, i.XkcdPass}
  722. body, err := s.Request("POST", CHANNEL_INVITES(channelID), data)
  723. if err != nil {
  724. return
  725. }
  726. err = unmarshal(body, &st)
  727. return
  728. }
  729. // ChannelPermissionSet creates a Permission Override for the given channel.
  730. // NOTE: This func name may changed. Using Set instead of Create because
  731. // you can both create a new override or update an override with this function.
  732. func (s *Session) ChannelPermissionSet(channelID, targetID, targetType string, allow, deny int) (err error) {
  733. data := struct {
  734. ID string `json:"id"`
  735. Type string `json:"type"`
  736. Allow int `json:"allow"`
  737. Deny int `json:"deny"`
  738. }{targetID, targetType, allow, deny}
  739. _, err = s.Request("PUT", CHANNEL_PERMISSION(channelID, targetID), data)
  740. return
  741. }
  742. // ChannelPermissionDelete deletes a specific permission override for the given channel.
  743. // NOTE: Name of this func may change.
  744. func (s *Session) ChannelPermissionDelete(channelID, targetID string) (err error) {
  745. _, err = s.Request("DELETE", CHANNEL_PERMISSION(channelID, targetID), nil)
  746. return
  747. }
  748. // ------------------------------------------------------------------------------------------------
  749. // Functions specific to Discord Invites
  750. // ------------------------------------------------------------------------------------------------
  751. // Invite returns an Invite structure of the given invite
  752. // inviteID : The invite code (or maybe xkcdpass?)
  753. func (s *Session) Invite(inviteID string) (st *Invite, err error) {
  754. body, err := s.Request("GET", INVITE(inviteID), nil)
  755. if err != nil {
  756. return
  757. }
  758. err = unmarshal(body, &st)
  759. return
  760. }
  761. // InviteDelete deletes an existing invite
  762. // inviteID : the code (or maybe xkcdpass?) of an invite
  763. func (s *Session) InviteDelete(inviteID string) (st *Invite, err error) {
  764. body, err := s.Request("DELETE", INVITE(inviteID), nil)
  765. if err != nil {
  766. return
  767. }
  768. err = unmarshal(body, &st)
  769. return
  770. }
  771. // InviteAccept accepts an Invite to a Guild or Channel
  772. // inviteID : The invite code (or maybe xkcdpass?)
  773. func (s *Session) InviteAccept(inviteID string) (st *Invite, err error) {
  774. body, err := s.Request("POST", INVITE(inviteID), nil)
  775. if err != nil {
  776. return
  777. }
  778. err = unmarshal(body, &st)
  779. return
  780. }
  781. // ------------------------------------------------------------------------------------------------
  782. // Functions specific to Discord Voice
  783. // ------------------------------------------------------------------------------------------------
  784. // VoiceRegions returns the voice server regions
  785. func (s *Session) VoiceRegions() (st []*VoiceRegion, err error) {
  786. body, err := s.Request("GET", VOICE_REGIONS, nil)
  787. if err != nil {
  788. return
  789. }
  790. err = unmarshal(body, &st)
  791. return
  792. }
  793. // VoiceICE returns the voice server ICE information
  794. func (s *Session) VoiceICE() (st *VoiceICE, err error) {
  795. body, err := s.Request("GET", VOICE_ICE, nil)
  796. if err != nil {
  797. return
  798. }
  799. err = unmarshal(body, &st)
  800. return
  801. }
  802. // ------------------------------------------------------------------------------------------------
  803. // Functions specific to Discord Websockets
  804. // ------------------------------------------------------------------------------------------------
  805. // Gateway returns the a websocket Gateway address
  806. func (s *Session) Gateway() (gateway string, err error) {
  807. response, err := s.Request("GET", GATEWAY, nil)
  808. if err != nil {
  809. return
  810. }
  811. temp := struct {
  812. URL string `json:"url"`
  813. }{}
  814. err = unmarshal(response, &temp)
  815. if err != nil {
  816. return
  817. }
  818. gateway = temp.URL
  819. return
  820. }