Hex Artifact Content
Not logged in

Artifact 1e3705615d8a2a8cca322cd12a9bc478897d67b0:


0000: 2f 2f 20 43 6f 70 79 72 69 67 68 74 20 32 30 31  // Copyright 201
0010: 37 20 4d 69 63 68 61 65 6c 20 54 65 6c 61 74 79  7 Michael Telaty
0020: 6e 73 6b 69 20 3c 37 74 33 63 68 67 75 79 40 67  nski <7t3chguy@g
0030: 6d 61 69 6c 2e 63 6f 6d 3e 0a 2f 2f 0a 2f 2f 20  mail.com>.//.// 
0040: 4c 69 63 65 6e 73 65 64 20 75 6e 64 65 72 20 74  Licensed under t
0050: 68 65 20 41 70 61 63 68 65 20 4c 69 63 65 6e 73  he Apache Licens
0060: 65 2c 20 56 65 72 73 69 6f 6e 20 32 2e 30 20 28  e, Version 2.0 (
0070: 74 68 65 20 22 4c 69 63 65 6e 73 65 22 29 3b 0a  the "License");.
0080: 2f 2f 20 79 6f 75 20 6d 61 79 20 6e 6f 74 20 75  // you may not u
0090: 73 65 20 74 68 69 73 20 66 69 6c 65 20 65 78 63  se this file exc
00a0: 65 70 74 20 69 6e 20 63 6f 6d 70 6c 69 61 6e 63  ept in complianc
00b0: 65 20 77 69 74 68 20 74 68 65 20 4c 69 63 65 6e  e with the Licen
00c0: 73 65 2e 0a 2f 2f 20 59 6f 75 20 6d 61 79 20 6f  se..// You may o
00d0: 62 74 61 69 6e 20 61 20 63 6f 70 79 20 6f 66 20  btain a copy of 
00e0: 74 68 65 20 4c 69 63 65 6e 73 65 20 61 74 0a 2f  the License at./
00f0: 2f 0a 2f 2f 20 20 20 20 20 68 74 74 70 3a 2f 2f  /.//     http://
0100: 77 77 77 2e 61 70 61 63 68 65 2e 6f 72 67 2f 6c  www.apache.org/l
0110: 69 63 65 6e 73 65 73 2f 4c 49 43 45 4e 53 45 2d  icenses/LICENSE-
0120: 32 2e 30 0a 2f 2f 0a 2f 2f 20 55 6e 6c 65 73 73  2.0.//.// Unless
0130: 20 72 65 71 75 69 72 65 64 20 62 79 20 61 70 70   required by app
0140: 6c 69 63 61 62 6c 65 20 6c 61 77 20 6f 72 20 61  licable law or a
0150: 67 72 65 65 64 20 74 6f 20 69 6e 20 77 72 69 74  greed to in writ
0160: 69 6e 67 2c 20 73 6f 66 74 77 61 72 65 0a 2f 2f  ing, software.//
0170: 20 64 69 73 74 72 69 62 75 74 65 64 20 75 6e 64   distributed und
0180: 65 72 20 74 68 65 20 4c 69 63 65 6e 73 65 20 69  er the License i
0190: 73 20 64 69 73 74 72 69 62 75 74 65 64 20 6f 6e  s distributed on
01a0: 20 61 6e 20 22 41 53 20 49 53 22 20 42 41 53 49   an "AS IS" BASI
01b0: 53 2c 0a 2f 2f 20 57 49 54 48 4f 55 54 20 57 41  S,.// WITHOUT WA
01c0: 52 52 41 4e 54 49 45 53 20 4f 52 20 43 4f 4e 44  RRANTIES OR COND
01d0: 49 54 49 4f 4e 53 20 4f 46 20 41 4e 59 20 4b 49  ITIONS OF ANY KI
01e0: 4e 44 2c 20 65 69 74 68 65 72 20 65 78 70 72 65  ND, either expre
01f0: 73 73 20 6f 72 20 69 6d 70 6c 69 65 64 2e 0a 2f  ss or implied../
0200: 2f 20 53 65 65 20 74 68 65 20 4c 69 63 65 6e 73  / See the Licens
0210: 65 20 66 6f 72 20 74 68 65 20 73 70 65 63 69 66  e for the specif
0220: 69 63 20 6c 61 6e 67 75 61 67 65 20 67 6f 76 65  ic language gove
0230: 72 6e 69 6e 67 20 70 65 72 6d 69 73 73 69 6f 6e  rning permission
0240: 73 20 61 6e 64 0a 2f 2f 20 6c 69 6d 69 74 61 74  s and.// limitat
0250: 69 6f 6e 73 20 75 6e 64 65 72 20 74 68 65 20 4c  ions under the L
0260: 69 63 65 6e 73 65 2e 0a 0a 70 61 63 6b 61 67 65  icense...package
0270: 20 6d 78 63 6c 69 65 6e 74 0a 0a 69 6d 70 6f 72   mxclient..impor
0280: 74 20 28 0a 09 22 65 6e 63 6f 64 69 6e 67 2f 6a  t (.."encoding/j
0290: 73 6f 6e 22 0a 09 22 65 72 72 6f 72 73 22 0a 09  son".."errors"..
02a0: 6c 6f 67 20 22 67 69 74 68 75 62 2e 63 6f 6d 2f  log "github.com/
02b0: 53 69 72 75 70 73 65 6e 2f 6c 6f 67 72 75 73 22  Sirupsen/logrus"
02c0: 0a 09 22 67 69 74 68 75 62 2e 63 6f 6d 2f 6d 61  .."github.com/ma
02d0: 74 72 69 78 2d 6f 72 67 2f 67 6f 6d 61 74 72 69  trix-org/gomatri
02e0: 78 22 0a 09 22 67 69 74 68 75 62 2e 63 6f 6d 2f  x".."github.com/
02f0: 6d 61 74 72 69 78 2d 6f 72 67 2f 6d 61 74 72 69  matrix-org/matri
0300: 78 2d 73 74 61 74 69 63 2f 75 74 69 6c 73 22 0a  x-static/utils".
0310: 09 22 69 6f 2f 69 6f 75 74 69 6c 22 0a 09 22 6e  ."io/ioutil".."n
0320: 65 74 2f 68 74 74 70 22 0a 09 22 6f 73 22 0a 09  et/http".."os"..
0330: 22 73 74 72 63 6f 6e 76 22 0a 09 22 74 69 6d 65  "strconv".."time
0340: 22 0a 29 0a 0a 2f 2f 20 54 68 69 73 20 69 73 20  ".)..// This is 
0350: 61 20 54 72 75 6e 63 61 74 65 64 20 52 65 73 70  a Truncated Resp
0360: 49 6e 69 74 69 61 6c 53 79 6e 63 20 61 73 20 77  InitialSync as w
0370: 65 20 6f 6e 6c 79 20 6e 65 65 64 20 53 4f 4d 45  e only need SOME
0380: 20 69 6e 66 6f 72 6d 61 74 69 6f 6e 20 66 72 6f   information fro
0390: 6d 20 69 74 2e 0a 74 79 70 65 20 52 65 73 70 49  m it..type RespI
03a0: 6e 69 74 69 61 6c 53 79 6e 63 20 73 74 72 75 63  nitialSync struc
03b0: 74 20 7b 0a 09 2f 2f 20 41 63 63 6f 75 6e 74 44  t {..// AccountD
03c0: 61 74 61 20 5b 5d 67 6f 6d 61 74 72 69 78 2e 45  ata []gomatrix.E
03d0: 76 65 6e 74 20 60 6a 73 6f 6e 3a 22 61 63 63 6f  vent `json:"acco
03e0: 75 6e 74 5f 64 61 74 61 22 60 0a 0a 09 4d 65 73  unt_data"`...Mes
03f0: 73 61 67 65 73 20 67 6f 6d 61 74 72 69 78 2e 52  sages gomatrix.R
0400: 65 73 70 4d 65 73 73 61 67 65 73 20 60 6a 73 6f  espMessages `jso
0410: 6e 3a 22 6d 65 73 73 61 67 65 73 22 60 0a 09 2f  n:"messages"`../
0420: 2f 20 4d 65 6d 62 65 72 73 68 69 70 20 73 74 72  / Membership str
0430: 69 6e 67 20 20 20 20 20 20 20 20 20 20 20 20 20  ing             
0440: 20 20 20 20 60 6a 73 6f 6e 3a 22 6d 65 6d 62 65      `json:"membe
0450: 72 73 68 69 70 22 60 0a 09 53 74 61 74 65 20 5b  rship"`..State [
0460: 5d 67 6f 6d 61 74 72 69 78 2e 45 76 65 6e 74 20  ]gomatrix.Event 
0470: 60 6a 73 6f 6e 3a 22 73 74 61 74 65 22 60 0a 09  `json:"state"`..
0480: 2f 2f 20 52 6f 6f 6d 49 44 20 20 20 20 20 73 74  // RoomID     st
0490: 72 69 6e 67 20 20 20 20 20 20 20 20 20 20 20 20  ring            
04a0: 20 20 20 20 20 60 6a 73 6f 6e 3a 22 72 6f 6f 6d       `json:"room
04b0: 5f 69 64 22 60 0a 09 2f 2f 20 52 65 63 65 69 70  _id"`..// Receip
04c0: 74 73 20 20 20 5b 5d 2a 67 6f 6d 61 74 72 69 78  ts   []*gomatrix
04d0: 2e 45 76 65 6e 74 20 20 20 20 20 20 60 6a 73 6f  .Event      `jso
04e0: 6e 3a 22 72 65 63 65 69 70 74 73 22 60 0a 09 2f  n:"receipts"`../
04f0: 2f 20 50 72 65 73 65 6e 63 65 20 20 20 5b 5d 2a  / Presence   []*
0500: 50 72 65 73 65 6e 63 65 45 76 65 6e 74 20 20 20  PresenceEvent   
0510: 20 20 20 20 60 6a 73 6f 6e 3a 22 70 72 65 73 65      `json:"prese
0520: 6e 63 65 22 60 0a 7d 0a 0a 2f 2f 20 4f 75 72 20  nce"`.}..// Our 
0530: 43 6c 69 65 6e 74 20 65 78 74 65 6e 73 69 6f 6e  Client extension
0540: 20 61 64 64 73 20 73 6f 6d 65 20 6d 65 74 68 6f   adds some metho
0550: 64 73 0a 2f 2f 20 61 6e 64 20 61 20 66 69 65 6c  ds.// and a fiel
0560: 64 20 65 78 70 61 6e 64 69 6e 67 20 61 6e 20 4d  d expanding an M
0570: 58 43 20 55 52 4c 0a 74 79 70 65 20 43 6c 69 65  XC URL.type Clie
0580: 6e 74 20 73 74 72 75 63 74 20 7b 0a 09 2a 67 6f  nt struct {..*go
0590: 6d 61 74 72 69 78 2e 43 6c 69 65 6e 74 0a 09 4d  matrix.Client..M
05a0: 65 64 69 61 42 61 73 65 55 52 4c 20 73 74 72 69  ediaBaseURL stri
05b0: 6e 67 0a 7d 0a 0a 2f 2f 20 52 65 67 69 73 74 65  ng.}..// Registe
05c0: 72 20 6d 61 6b 65 73 20 61 6e 20 48 54 54 50 20  r makes an HTTP 
05d0: 72 65 71 75 65 73 74 20 61 63 63 6f 72 64 69 6e  request accordin
05e0: 67 20 74 6f 20 68 74 74 70 3a 2f 2f 6d 61 74 72  g to http://matr
05f0: 69 78 2e 6f 72 67 2f 64 6f 63 73 2f 73 70 65 63  ix.org/docs/spec
0600: 2f 63 6c 69 65 6e 74 5f 73 65 72 76 65 72 2f 72  /client_server/r
0610: 30 2e 32 2e 30 2e 68 74 6d 6c 23 67 65 74 2d 6d  0.2.0.html#get-m
0620: 61 74 72 69 78 2d 63 6c 69 65 6e 74 2d 72 30 2d  atrix-client-r0-
0630: 72 6f 6f 6d 73 2d 72 6f 6f 6d 69 64 2d 69 6e 69  rooms-roomid-ini
0640: 74 69 61 6c 73 79 6e 63 0a 66 75 6e 63 20 28 6d  tialsync.func (m
0650: 20 2a 43 6c 69 65 6e 74 29 20 52 6f 6f 6d 49 6e   *Client) RoomIn
0660: 69 74 69 61 6c 53 79 6e 63 28 72 6f 6f 6d 49 44  itialSync(roomID
0670: 20 73 74 72 69 6e 67 2c 20 6c 69 6d 69 74 20 69   string, limit i
0680: 6e 74 29 20 28 72 65 73 70 20 2a 52 65 73 70 49  nt) (resp *RespI
0690: 6e 69 74 69 61 6c 53 79 6e 63 2c 20 65 72 72 20  nitialSync, err 
06a0: 65 72 72 6f 72 29 20 7b 0a 09 75 72 6c 50 61 74  error) {..urlPat
06b0: 68 20 3a 3d 20 6d 2e 42 75 69 6c 64 55 52 4c 57  h := m.BuildURLW
06c0: 69 74 68 51 75 65 72 79 28 5b 5d 73 74 72 69 6e  ithQuery([]strin
06d0: 67 7b 22 72 6f 6f 6d 73 22 2c 20 72 6f 6f 6d 49  g{"rooms", roomI
06e0: 44 2c 20 22 69 6e 69 74 69 61 6c 53 79 6e 63 22  D, "initialSync"
06f0: 7d 2c 20 6d 61 70 5b 73 74 72 69 6e 67 5d 73 74  }, map[string]st
0700: 72 69 6e 67 7b 0a 09 09 22 6c 69 6d 69 74 22 3a  ring{..."limit":
0710: 20 73 74 72 63 6f 6e 76 2e 49 74 6f 61 28 6c 69   strconv.Itoa(li
0720: 6d 69 74 29 2c 0a 09 7d 29 0a 09 65 72 72 20 3d  mit),..})..err =
0730: 20 6d 2e 4d 61 6b 65 52 65 71 75 65 73 74 28 22   m.MakeRequest("
0740: 47 45 54 22 2c 20 75 72 6c 50 61 74 68 2c 20 6e  GET", urlPath, n
0750: 69 6c 2c 20 26 72 65 73 70 29 0a 09 72 65 74 75  il, &resp)..retu
0760: 72 6e 0a 7d 0a 0a 74 79 70 65 20 52 65 73 70 52  rn.}..type RespR
0770: 6f 6f 6d 44 69 72 65 63 74 6f 72 79 41 6c 69 61  oomDirectoryAlia
0780: 73 20 73 74 72 75 63 74 20 7b 0a 09 52 6f 6f 6d  s struct {..Room
0790: 49 44 20 20 73 74 72 69 6e 67 20 20 20 60 6a 73  ID  string   `js
07a0: 6f 6e 3a 22 72 6f 6f 6d 5f 69 64 22 60 0a 09 53  on:"room_id"`..S
07b0: 65 72 76 65 72 73 20 5b 5d 73 74 72 69 6e 67 20  ervers []string 
07c0: 60 6a 73 6f 6e 3a 22 73 65 72 76 65 72 73 22 60  `json:"servers"`
07d0: 0a 7d 0a 0a 66 75 6e 63 20 28 6d 20 2a 43 6c 69  .}..func (m *Cli
07e0: 65 6e 74 29 20 47 65 74 52 6f 6f 6d 44 69 72 65  ent) GetRoomDire
07f0: 63 74 6f 72 79 41 6c 69 61 73 28 72 6f 6f 6d 41  ctoryAlias(roomA
0800: 6c 69 61 73 20 73 74 72 69 6e 67 29 20 28 72 65  lias string) (re
0810: 73 70 20 2a 52 65 73 70 52 6f 6f 6d 44 69 72 65  sp *RespRoomDire
0820: 63 74 6f 72 79 41 6c 69 61 73 2c 20 65 72 72 20  ctoryAlias, err 
0830: 65 72 72 6f 72 29 20 7b 0a 09 75 72 6c 50 61 74  error) {..urlPat
0840: 68 20 3a 3d 20 6d 2e 42 75 69 6c 64 55 52 4c 28  h := m.BuildURL(
0850: 22 64 69 72 65 63 74 6f 72 79 22 2c 20 22 72 6f  "directory", "ro
0860: 6f 6d 22 2c 20 72 6f 6f 6d 41 6c 69 61 73 29 0a  om", roomAlias).
0870: 09 65 72 72 20 3d 20 6d 2e 4d 61 6b 65 52 65 71  .err = m.MakeReq
0880: 75 65 73 74 28 22 47 45 54 22 2c 20 75 72 6c 50  uest("GET", urlP
0890: 61 74 68 2c 20 6e 69 6c 2c 20 26 72 65 73 70 29  ath, nil, &resp)
08a0: 0a 09 72 65 74 75 72 6e 0a 7d 0a 0a 63 6f 6e 73  ..return.}..cons
08b0: 74 20 6d 69 6e 69 6d 75 6d 50 61 67 69 6e 61 74  t minimumPaginat
08c0: 69 6f 6e 20 3d 20 36 34 0a 0a 2f 2f 20 54 4f 44  ion = 64..// TOD
08d0: 4f 20 73 70 6c 69 74 20 69 6e 74 6f 20 72 75 6e  O split into run
08e0: 73 20 6f 66 20 6d 61 78 20 73 69 7a 65 20 72 65  s of max size re
08f0: 63 75 72 73 69 76 65 6c 79 20 6f 74 68 65 72 77  cursively otherw
0900: 69 73 65 20 73 79 6e 61 70 73 65 20 6d 61 79 20  ise synapse may 
0910: 65 6e 66 6f 72 63 65 20 69 74 73 20 6f 77 6e 20  enforce its own 
0920: 6c 69 6d 69 74 20 28 39 39 39 3f 29 0a 66 75 6e  limit (999?).fun
0930: 63 20 28 6d 20 2a 43 6c 69 65 6e 74 29 20 62 61  c (m *Client) ba
0940: 63 6b 70 61 67 69 6e 61 74 65 52 6f 6f 6d 28 72  ckpaginateRoom(r
0950: 6f 6f 6d 20 2a 52 6f 6f 6d 2c 20 61 6d 6f 75 6e  oom *Room, amoun
0960: 74 20 69 6e 74 29 20 28 69 6e 74 2c 20 65 72 72  t int) (int, err
0970: 6f 72 29 20 7b 0a 09 6c 6f 67 67 65 72 57 69 74  or) {..loggerWit
0980: 68 46 69 65 6c 64 73 20 3a 3d 20 6c 6f 67 2e 57  hFields := log.W
0990: 69 74 68 46 69 65 6c 64 28 22 72 6f 6f 6d 49 44  ithField("roomID
09a0: 22 2c 20 72 6f 6f 6d 2e 49 44 29 2e 57 69 74 68  ", room.ID).With
09b0: 46 69 65 6c 64 28 22 61 6d 6f 75 6e 74 22 2c 20  Field("amount", 
09c0: 61 6d 6f 75 6e 74 29 0a 09 6c 6f 67 67 65 72 57  amount)..loggerW
09d0: 69 74 68 46 69 65 6c 64 73 2e 49 6e 66 6f 28 22  ithFields.Info("
09e0: 42 61 63 6b 70 61 67 69 6e 61 74 69 6e 67 20 52  Backpaginating R
09f0: 6f 6f 6d 22 29 0a 0a 09 61 6d 6f 75 6e 74 20 3d  oom")...amount =
0a00: 20 75 74 69 6c 73 2e 4d 61 78 28 61 6d 6f 75 6e   utils.Max(amoun
0a10: 74 2c 20 6d 69 6e 69 6d 75 6d 50 61 67 69 6e 61  t, minimumPagina
0a20: 74 69 6f 6e 29 0a 09 72 65 73 70 2c 20 65 72 72  tion)..resp, err
0a30: 20 3a 3d 20 6d 2e 4d 65 73 73 61 67 65 73 28 72   := m.Messages(r
0a40: 6f 6f 6d 2e 49 44 2c 20 72 6f 6f 6d 2e 62 61 63  oom.ID, room.bac
0a50: 6b 50 61 67 69 6e 61 74 69 6f 6e 54 6f 6b 65 6e  kPaginationToken
0a60: 2c 20 22 22 2c 20 27 62 27 2c 20 61 6d 6f 75 6e  , "", 'b', amoun
0a70: 74 29 0a 0a 09 69 66 20 65 72 72 20 21 3d 20 6e  t)...if err != n
0a80: 69 6c 20 7b 0a 09 09 6c 6f 67 67 65 72 57 69 74  il {...loggerWit
0a90: 68 46 69 65 6c 64 73 2e 57 69 74 68 45 72 72 6f  hFields.WithErro
0aa0: 72 28 65 72 72 29 2e 45 72 72 6f 72 28 22 46 61  r(err).Error("Fa
0ab0: 69 6c 65 64 20 42 61 63 6b 70 61 67 69 6e 61 74  iled Backpaginat
0ac0: 69 6e 67 20 52 6f 6f 6d 22 29 0a 09 09 72 65 74  ing Room")...ret
0ad0: 75 72 6e 20 2d 31 2c 20 65 72 72 0a 09 7d 0a 0a  urn -1, err..}..
0ae0: 09 72 6f 6f 6d 2e 63 6f 6e 63 61 74 42 61 63 6b  .room.concatBack
0af0: 70 61 67 69 6e 61 74 69 6f 6e 28 72 65 73 70 2e  pagination(resp.
0b00: 43 68 75 6e 6b 2c 20 72 65 73 70 2e 45 6e 64 29  Chunk, resp.End)
0b10: 0a 09 6c 6f 67 67 65 72 57 69 74 68 46 69 65 6c  ..loggerWithFiel
0b20: 64 73 2e 49 6e 66 6f 28 22 46 69 6e 69 73 68 65  ds.Info("Finishe
0b30: 64 20 42 61 63 6b 70 61 67 69 6e 61 74 69 6e 67  d Backpaginating
0b40: 20 52 6f 6f 6d 22 29 0a 09 72 65 74 75 72 6e 20   Room")..return 
0b50: 6c 65 6e 28 72 65 73 70 2e 43 68 75 6e 6b 29 2c  len(resp.Chunk),
0b60: 20 6e 69 6c 0a 7d 0a 0a 66 75 6e 63 20 28 6d 20   nil.}..func (m 
0b70: 2a 43 6c 69 65 6e 74 29 20 66 6f 72 77 61 72 64  *Client) forward
0b80: 70 61 67 69 6e 61 74 65 52 6f 6f 6d 28 72 6f 6f  paginateRoom(roo
0b90: 6d 20 2a 52 6f 6f 6d 2c 20 61 6d 6f 75 6e 74 20  m *Room, amount 
0ba0: 69 6e 74 29 20 28 69 6e 74 2c 20 65 72 72 6f 72  int) (int, error
0bb0: 29 20 7b 0a 09 61 6d 6f 75 6e 74 20 3d 20 75 74  ) {..amount = ut
0bc0: 69 6c 73 2e 4d 61 78 28 61 6d 6f 75 6e 74 2c 20  ils.Max(amount, 
0bd0: 6d 69 6e 69 6d 75 6d 50 61 67 69 6e 61 74 69 6f  minimumPaginatio
0be0: 6e 29 0a 09 72 65 73 70 2c 20 65 72 72 20 3a 3d  n)..resp, err :=
0bf0: 20 6d 2e 4d 65 73 73 61 67 65 73 28 72 6f 6f 6d   m.Messages(room
0c00: 2e 49 44 2c 20 72 6f 6f 6d 2e 66 6f 72 77 61 72  .ID, room.forwar
0c10: 64 50 61 67 69 6e 61 74 69 6f 6e 54 6f 6b 65 6e  dPaginationToken
0c20: 2c 20 22 22 2c 20 27 66 27 2c 20 61 6d 6f 75 6e  , "", 'f', amoun
0c30: 74 29 0a 0a 09 69 66 20 65 72 72 20 21 3d 20 6e  t)...if err != n
0c40: 69 6c 20 7b 0a 09 09 72 65 74 75 72 6e 20 2d 31  il {...return -1
0c50: 2c 20 65 72 72 0a 09 7d 0a 0a 09 2f 2f 20 49 20  , err..}...// I 
0c60: 77 6f 75 6c 64 20 68 61 76 65 20 74 68 6f 75 67  would have thoug
0c70: 68 74 20 74 6f 20 75 73 65 20 72 65 73 70 2e 53  ht to use resp.S
0c80: 74 61 72 74 20 68 65 72 65 20 62 75 74 20 4e 4f  tart here but NO
0c90: 50 45 0a 09 72 6f 6f 6d 2e 63 6f 6e 63 61 74 46  PE..room.concatF
0ca0: 6f 72 77 61 72 64 50 61 67 69 6e 61 74 69 6f 6e  orwardPagination
0cb0: 28 72 65 73 70 2e 43 68 75 6e 6b 2c 20 72 65 73  (resp.Chunk, res
0cc0: 70 2e 45 6e 64 29 0a 09 72 65 74 75 72 6e 20 6c  p.End)..return l
0cd0: 65 6e 28 72 65 73 70 2e 43 68 75 6e 6b 29 2c 20  en(resp.Chunk), 
0ce0: 6e 69 6c 0a 7d 0a 0a 2f 2f 20 4e 65 77 52 61 77  nil.}..// NewRaw
0cf0: 43 6c 69 65 6e 74 20 72 65 74 75 72 6e 73 20 61  Client returns a
0d00: 20 77 72 61 70 70 65 64 20 63 6c 69 65 6e 74 20   wrapped client 
0d10: 77 69 74 68 20 68 74 74 70 20 63 6c 69 65 6e 74  with http client
0d20: 20 74 69 6d 65 6f 75 74 73 20 61 70 70 6c 69 65   timeouts applie
0d30: 64 2e 0a 66 75 6e 63 20 4e 65 77 52 61 77 43 6c  d..func NewRawCl
0d40: 69 65 6e 74 28 68 6f 6d 65 73 65 72 76 65 72 55  ient(homeserverU
0d50: 52 4c 2c 20 6d 65 64 69 61 42 61 73 65 55 52 4c  RL, mediaBaseURL
0d60: 2c 20 75 73 65 72 49 44 2c 20 61 63 63 65 73 73  , userID, access
0d70: 54 6f 6b 65 6e 20 73 74 72 69 6e 67 29 20 28 2a  Token string) (*
0d80: 43 6c 69 65 6e 74 2c 20 65 72 72 6f 72 29 20 7b  Client, error) {
0d90: 0a 09 63 6c 69 2c 20 65 72 72 20 3a 3d 20 67 6f  ..cli, err := go
0da0: 6d 61 74 72 69 78 2e 4e 65 77 43 6c 69 65 6e 74  matrix.NewClient
0db0: 28 68 6f 6d 65 73 65 72 76 65 72 55 52 4c 2c 20  (homeserverURL, 
0dc0: 75 73 65 72 49 44 2c 20 61 63 63 65 73 73 54 6f  userID, accessTo
0dd0: 6b 65 6e 29 0a 09 63 6c 69 2e 43 6c 69 65 6e 74  ken)..cli.Client
0de0: 20 3d 20 26 68 74 74 70 2e 43 6c 69 65 6e 74 7b   = &http.Client{
0df0: 0a 09 09 54 69 6d 65 6f 75 74 3a 20 33 30 20 2a  ...Timeout: 30 *
0e00: 20 74 69 6d 65 2e 53 65 63 6f 6e 64 2c 0a 09 7d   time.Second,..}
0e10: 0a 09 72 65 74 75 72 6e 20 26 43 6c 69 65 6e 74  ..return &Client
0e20: 7b 63 6c 69 2c 20 6d 65 64 69 61 42 61 73 65 55  {cli, mediaBaseU
0e30: 52 4c 7d 2c 20 65 72 72 0a 7d 0a 0a 2f 2f 20 54  RL}, err.}..// T
0e40: 68 65 20 73 74 72 75 63 74 20 72 65 70 72 65 73  he struct repres
0e50: 65 6e 74 69 6e 67 20 74 68 65 20 6a 73 6f 6e 20  enting the json 
0e60: 63 6f 6e 66 69 67 20 66 69 6c 65 20 66 6f 72 6d  config file form
0e70: 61 74 2e 0a 74 79 70 65 20 43 6f 6e 66 69 67 20  at..type Config 
0e80: 73 74 72 75 63 74 20 7b 0a 09 41 63 63 65 73 73  struct {..Access
0e90: 54 6f 6b 65 6e 20 20 73 74 72 69 6e 67 20 60 6a  Token  string `j
0ea0: 73 6f 6e 3a 22 61 63 63 65 73 73 5f 74 6f 6b 65  son:"access_toke
0eb0: 6e 22 60 0a 09 44 65 76 69 63 65 49 44 20 20 20  n"`..DeviceID   
0ec0: 20 20 73 74 72 69 6e 67 20 60 6a 73 6f 6e 3a 22    string `json:"
0ed0: 64 65 76 69 63 65 5f 69 64 22 60 0a 09 48 6f 6d  device_id"`..Hom
0ee0: 65 53 65 72 76 65 72 20 20 20 73 74 72 69 6e 67  eServer   string
0ef0: 20 60 6a 73 6f 6e 3a 22 68 6f 6d 65 5f 73 65 72   `json:"home_ser
0f00: 76 65 72 22 60 0a 09 52 65 66 72 65 73 68 54 6f  ver"`..RefreshTo
0f10: 6b 65 6e 20 73 74 72 69 6e 67 20 60 6a 73 6f 6e  ken string `json
0f20: 3a 22 72 65 66 72 65 73 68 5f 74 6f 6b 65 6e 22  :"refresh_token"
0f30: 60 0a 09 55 73 65 72 49 44 20 20 20 20 20 20 20  `..UserID       
0f40: 73 74 72 69 6e 67 20 60 6a 73 6f 6e 3a 22 75 73  string `json:"us
0f50: 65 72 5f 69 64 22 60 0a 09 4d 65 64 69 61 42 61  er_id"`..MediaBa
0f60: 73 65 55 72 6c 20 73 74 72 69 6e 67 20 60 6a 73  seUrl string `js
0f70: 6f 6e 3a 22 6d 65 64 69 61 5f 62 61 73 65 5f 75  on:"media_base_u
0f80: 72 6c 22 60 0a 7d 0a 0a 2f 2f 20 4e 65 77 43 6c  rl"`.}..// NewCl
0f90: 69 65 6e 74 20 72 65 74 75 72 6e 73 20 61 20 43  ient returns a C
0fa0: 6c 69 65 6e 74 20 63 6f 6e 66 69 67 75 72 65 64  lient configured
0fb0: 20 62 79 20 74 68 65 20 63 6f 6e 66 69 67 20 66   by the config f
0fc0: 69 6c 65 20 66 6f 75 6e 64 20 61 74 20 63 6f 6e  ile found at con
0fd0: 66 69 67 50 61 74 68 20 6f 72 20 61 6e 20 65 72  figPath or an er
0fe0: 72 6f 72 20 69 66 20 65 6e 63 6f 75 6e 74 65 72  ror if encounter
0ff0: 65 64 2e 0a 66 75 6e 63 20 4e 65 77 43 6c 69 65  ed..func NewClie
1000: 6e 74 28 63 6f 6e 66 69 67 50 61 74 68 20 73 74  nt(configPath st
1010: 72 69 6e 67 29 20 28 2a 43 6c 69 65 6e 74 2c 20  ring) (*Client, 
1020: 65 72 72 6f 72 29 20 7b 0a 09 76 61 72 20 63 6f  error) {..var co
1030: 6e 66 69 67 20 43 6f 6e 66 69 67 0a 0a 09 69 66  nfig Config...if
1040: 20 5f 2c 20 65 72 72 20 3a 3d 20 6f 73 2e 53 74   _, err := os.St
1050: 61 74 28 63 6f 6e 66 69 67 50 61 74 68 29 3b 20  at(configPath); 
1060: 65 72 72 20 21 3d 20 6e 69 6c 20 7b 0a 09 09 72  err != nil {...r
1070: 65 74 75 72 6e 20 6e 69 6c 2c 20 65 72 72 6f 72  eturn nil, error
1080: 73 2e 4e 65 77 28 22 63 6f 6e 66 69 67 20 66 69  s.New("config fi
1090: 6c 65 20 6e 6f 74 20 66 6f 75 6e 64 22 29 0a 09  le not found")..
10a0: 7d 0a 0a 09 66 69 6c 65 2c 20 65 72 72 20 3a 3d  }...file, err :=
10b0: 20 69 6f 75 74 69 6c 2e 52 65 61 64 46 69 6c 65   ioutil.ReadFile
10c0: 28 63 6f 6e 66 69 67 50 61 74 68 29 0a 09 69 66  (configPath)..if
10d0: 20 65 72 72 20 21 3d 20 6e 69 6c 20 7b 0a 09 09   err != nil {...
10e0: 72 65 74 75 72 6e 20 6e 69 6c 2c 20 65 72 72 0a  return nil, err.
10f0: 09 7d 0a 0a 09 6a 73 6f 6e 2e 55 6e 6d 61 72 73  .}...json.Unmars
1100: 68 61 6c 28 66 69 6c 65 2c 20 26 63 6f 6e 66 69  hal(file, &confi
1110: 67 29 0a 0a 09 69 66 20 63 6f 6e 66 69 67 2e 48  g)...if config.H
1120: 6f 6d 65 53 65 72 76 65 72 20 3d 3d 20 22 22 20  omeServer == "" 
1130: 7b 0a 09 09 72 65 74 75 72 6e 20 6e 69 6c 2c 20  {...return nil, 
1140: 65 72 72 6f 72 73 2e 4e 65 77 28 22 6e 6f 20 75  errors.New("no u
1150: 73 65 72 20 63 6f 6e 66 69 67 75 72 61 74 69 6f  ser configuratio
1160: 6e 20 66 6f 75 6e 64 22 29 0a 09 7d 0a 0a 09 69  n found")..}...i
1170: 66 20 63 6f 6e 66 69 67 2e 4d 65 64 69 61 42 61  f config.MediaBa
1180: 73 65 55 72 6c 20 3d 3d 20 22 22 20 7b 0a 09 09  seUrl == "" {...
1190: 63 6f 6e 66 69 67 2e 4d 65 64 69 61 42 61 73 65  config.MediaBase
11a0: 55 72 6c 20 3d 20 63 6f 6e 66 69 67 2e 48 6f 6d  Url = config.Hom
11b0: 65 53 65 72 76 65 72 0a 09 7d 0a 0a 09 72 65 74  eServer..}...ret
11c0: 75 72 6e 20 4e 65 77 52 61 77 43 6c 69 65 6e 74  urn NewRawClient
11d0: 28 63 6f 6e 66 69 67 2e 48 6f 6d 65 53 65 72 76  (config.HomeServ
11e0: 65 72 2c 20 63 6f 6e 66 69 67 2e 4d 65 64 69 61  er, config.Media
11f0: 42 61 73 65 55 72 6c 2c 20 63 6f 6e 66 69 67 2e  BaseUrl, config.
1200: 55 73 65 72 49 44 2c 20 63 6f 6e 66 69 67 2e 41  UserID, config.A
1210: 63 63 65 73 73 54 6f 6b 65 6e 29 0a 7d 0a        ccessToken).}.