Coverage / app/src/main/java/io/oxygenhub/android/api/HubClient.kt 36.8%
68 of 185 lines run, 33 of 89 functions, 16 of 42 branches · run #1654 on main · run missed
| 1 | package io.oxygenhub.android.api | |
| 2 | ||
| 3 | import java.io.IOException | |
| 4 | import kotlinx.serialization.KSerializer | |
| 5 | import kotlinx.serialization.builtins.ListSerializer | |
| 6 | import kotlinx.serialization.json.JsonArray | |
| 7 | import kotlinx.serialization.json.JsonObject | |
| 8 | import kotlinx.serialization.json.JsonPrimitive | |
| 9 | import kotlinx.serialization.json.buildJsonObject | |
| 10 | import kotlinx.serialization.json.put | |
| 11 | import okhttp3.HttpUrl | |
| 12 | import okhttp3.HttpUrl.Companion.toHttpUrl | |
| 13 | import okhttp3.OkHttpClient | |
| 14 | import okhttp3.Request | |
| 15 | import okhttp3.RequestBody.Companion.toRequestBody | |
| 16 | ||
| 17 | /** | |
| 18 | * What the app asks of a hub, signed in. The view models see only this, so | |
| 19 | * their tests give them a fake. Later screens (oxygenhub-android#3–#5) add | |
| 20 | * to it: a repository's tree, history, proposals, runs. | |
| 21 | */ | |
| 22 | interface HubApi { | |
| 23 | /** The signed-in account (`GET /user`, scope `user:read`). */ | |
| 24 | suspend fun user(): User | |
| 25 | ||
| 26 | /** Every repository the caller can read (`GET /repos`). */ | |
| 27 | suspend fun repositories(): List<Repository> | |
| 28 | ||
| 29 | /** A repository's issues (`GET /repos/{owner}/{name}/issues?state=`). */ | |
| 30 | suspend fun issues(owner: String, name: String, state: IssueState = IssueState.Open): List<Issue> | |
| 31 | ||
| 32 | /** The inbox: the unread count and the newest entries (`GET /notifications`). */ | |
| 33 | suspend fun inbox(limit: Int = 50): Inbox | |
| 34 | ||
| 35 | /** Marks one notification read (`POST /notifications/{id}/read`). */ | |
| 36 | suspend fun markRead(id: Long) | |
| 37 | ||
| 38 | /** Marks the whole inbox read (`POST /notifications/read`). */ | |
| 39 | suspend fun markAllRead() | |
| 40 | ||
| 41 | /** Revokes the token this client signs in with (`DELETE /user/token`). */ | |
| 42 | suspend fun revokeToken() | |
| 43 | ||
| 44 | /** | |
| 45 | * This phone takes alerts (#16): its Cloud Messaging [fcmToken] and its | |
| 46 | * alert key's [publicKey] (hex), for the token it signed in with | |
| 47 | * (`PUT /user/push`). Whether the hub sends alerts at all. | |
| 48 | */ | |
| 49 | suspend fun registerPush(fcmToken: String, publicKey: String): Boolean | |
| 50 | ||
| 51 | /** | |
| 52 | * The proposals the caller should act on, across repositories (the hub's | |
| 53 | * dashboard); with [landable], also those it can land now (#20, oxygenhub#311). | |
| 54 | */ | |
| 55 | suspend fun userProposals(landable: Boolean = false): UserProposals | |
| 56 | ||
| 57 | /** The open issues assigned to the caller, across repositories (#31, oxygenhub#359); a hub before it answers 404. */ | |
| 58 | suspend fun userIssues(): List<IssueBrief> | |
| 59 | ||
| 60 | /** Your sky's data, the dashboard backdrop's (#23); a hub before it answers 404. */ | |
| 61 | suspend fun userSky(): UserSky | |
| 62 | ||
| 63 | /** The organisations the account belongs to (oxygenhub#302). */ | |
| 64 | suspend fun userOrgs(): List<UserOrg> | |
| 65 | ||
| 66 | /** Create a repository (#27): `repo:admin`. */ | |
| 67 | suspend fun createRepository(owner: String, name: String, description: String, visibility: Visibility): Repository | |
| 68 | ||
| 69 | /** The assistants a new repository under [owner] may ask for its starting files (oxygenhub#347). */ | |
| 70 | suspend fun starterAssistants(owner: String): List<StarterAssistant> | |
| 71 | ||
| 72 | /** Ask an assistant for an empty repository's starting files; it works in the background. */ | |
| 73 | suspend fun startStarter(owner: String, name: String, description: String): StarterStatus | |
| 74 | ||
| 75 | suspend fun starterStatus(owner: String, name: String): StarterStatus | |
| 76 | ||
| 77 | /** The newest runs of your repositories, with their jobs (#26); [before] (ms) pages back. */ | |
| 78 | suspend fun userFlowRuns(before: Long? = null): List<UserFlowRun> | |
| 79 | ||
| 80 | /** One repository's sky, its pages' backdrop (#23); a hub before it answers 404. */ | |
| 81 | suspend fun repoSky(owner: String, name: String): UserSky | |
| 82 | ||
| 83 | /** A repository's proposals: open (with drafts), landed, closed or all. */ | |
| 84 | suspend fun proposals(owner: String, name: String, state: ProposalState = ProposalState.Open): List<Proposal> | |
| 85 | ||
| 86 | suspend fun proposal(owner: String, name: String, number: Long): Proposal | |
| 87 | ||
| 88 | /** The checks on a proposal's projected state. */ | |
| 89 | suspend fun checks(owner: String, name: String, number: Long): List<Check> | |
| 90 | ||
| 91 | /** | |
| 92 | * Land it (`repo:write`); the proposal as landed. The hub refuses with 409 | |
| 93 | * and its reason when it may not land, and 403 when the token lacks the scope. | |
| 94 | */ | |
| 95 | suspend fun land(owner: String, name: String, number: Long): Proposal | |
| 96 | ||
| 97 | /** Land it by itself when its checks pass, or not (`repo:write`); the proposal after. */ | |
| 98 | suspend fun setAutoLand(owner: String, name: String, number: Long, on: Boolean): Proposal | |
| 99 | ||
| 100 | /** A one-time token registering this phone as a runner for the account's repositories (`repo:write`). */ | |
| 101 | suspend fun runnerToken(): RunnerToken | |
| 102 | ||
| 103 | suspend fun issue(owner: String, name: String, number: Long): Issue | |
| 104 | ||
| 105 | /** A repository's releases, newest first. */ | |
| 106 | suspend fun releases(owner: String, name: String): List<Release> | |
| 107 | ||
| 108 | /** Issues and proposals matching [query], across the repositories the caller can read. */ | |
| 109 | suspend fun search(query: String): List<SearchHit> | |
| 110 | ||
| 111 | /** A repository's runs, newest first. */ | |
| 112 | suspend fun runs(owner: String, name: String): List<FlowRun> | |
| 113 | ||
| 114 | /** One run, with its jobs. */ | |
| 115 | suspend fun run(owner: String, name: String, number: Long): FlowRun | |
| 116 | ||
| 117 | /** A job's log lines after [after] (0: from the start). */ | |
| 118 | suspend fun jobLog(owner: String, name: String, number: Long, job: String, after: Long): List<LogLine> | |
| 119 | ||
| 120 | suspend fun rerunRun(owner: String, name: String, number: Long) | |
| 121 | ||
| 122 | /** Run [job] again in the same run, with the jobs that depend on it. */ | |
| 123 | suspend fun rerunJob(owner: String, name: String, number: Long, job: String) | |
| 124 | ||
| 125 | suspend fun cancelRun(owner: String, name: String, number: Long) | |
| 126 | ||
| 127 | /** Approve, or reject, a job that waits for a person (#5, oxygenflow#57); its approval rules decide who may. */ | |
| 128 | suspend fun decideJob(owner: String, name: String, number: Long, job: String, approve: Boolean) | |
| 129 | ||
| 130 | /** Make a run urgent, saying why (#5, oxygenhub#244): a maintainer's, within the owner's cap. */ | |
| 131 | suspend fun expediteRun(owner: String, name: String, number: Long, reason: String) | |
| 132 | ||
| 133 | /** [owner]'s project boards the caller can see. */ | |
| 134 | suspend fun projects(owner: String): List<Project> | |
| 135 | ||
| 136 | suspend fun board(owner: String, number: Long): Board | |
| 137 | ||
| 138 | /** Move a card to the column named [column]. */ | |
| 139 | suspend fun moveCard(owner: String, number: Long, card: Long, column: String) | |
| 140 | ||
| 141 | suspend fun issueComments(owner: String, name: String, number: Long): List<Comment> | |
| 142 | ||
| 143 | suspend fun comment(owner: String, name: String, number: Long, body: String): Comment | |
| 144 | ||
| 145 | /** Close (with why: `completed` or `not_planned`) or reopen. */ | |
| 146 | suspend fun setIssueState(owner: String, name: String, number: Long, open: Boolean, reason: String = "completed"): Issue | |
| 147 | ||
| 148 | suspend fun createIssue(owner: String, name: String, title: String, body: String): Issue | |
| 149 | ||
| 150 | /** The repository's labels, to choose from. */ | |
| 151 | suspend fun labels(owner: String, name: String): List<Label> | |
| 152 | ||
| 153 | /** The issue's whole set of labels (triage). */ | |
| 154 | suspend fun setIssueLabels(owner: String, name: String, number: Long, labels: List<String>): Issue | |
| 155 | ||
| 156 | /** The issue's whole set of assignees (triage, #4). */ | |
| 157 | suspend fun setIssueAssignees(owner: String, name: String, number: Long, assignees: List<String>): Issue | |
| 158 | ||
| 159 | /** One repository (`GET /repos/{owner}/{name}`): its default bookmark, for the code browser. */ | |
| 160 | suspend fun repository(owner: String, name: String): Repository | |
| 161 | ||
| 162 | /** A directory of the tree at [ref] (a bookmark, tag or change), [path] "" for the top. */ | |
| 163 | suspend fun tree(owner: String, name: String, ref: String, path: String = ""): List<TreeEntry> | |
| 164 | ||
| 165 | /** A file's bytes at [ref], as text. */ | |
| 166 | suspend fun file(owner: String, name: String, ref: String, path: String): String | |
| 167 | ||
| 168 | /** [ref]'s history, newest first; only changes to [path] when given. */ | |
| 169 | suspend fun history(owner: String, name: String, ref: String, path: String? = null, offset: Int = 0, limit: Int = 50): History | |
| 170 | ||
| 171 | suspend fun change(owner: String, name: String, hash: String): ChangeDetail | |
| 172 | ||
| 173 | /** Review a proposal (#4): [verdict] is `approve`, `changes` or `comment`, with [body] said. */ | |
| 174 | suspend fun review(owner: String, name: String, number: Long, verdict: String, body: String) | |
| 175 | ||
| 176 | /** The files a proposal changes, each with its diff, as the proposal page shows them (#4). */ | |
| 177 | suspend fun proposalDiff(owner: String, name: String, number: Long): List<FileChange> | |
| 178 | ||
| 179 | /** The repository's bookmarks and tags, to browse at. */ | |
| 180 | suspend fun refs(owner: String, name: String): Pair<List<String>, List<String>> | |
| 181 | ||
| 182 | /** An account's picture (`/avatar/{name}`, public); null when the hub has none this app can draw. */ | |
| 183 | suspend fun avatar(name: String): Avatar? | |
| 184 | ||
| 185 | /** An account's public profile, and an organisation's (with its members). */ | |
| 186 | suspend fun account(name: String): User | |
| 187 | ||
| 188 | suspend fun organisation(name: String): Organisation | |
| 189 | } | |
| 190 | ||
| 191 | /** | |
| 192 | * The hub's JSON API over OkHttp. [onUnauthorized] runs when the hub | |
| 193 | * refuses the token (revoked on the web, or 90 days unused), so the app | |
| 194 | * can drop the session and ask for a new sign-in. | |
| 195 | */ | |
| 196 | class HubClient( | |
| 197 | hub: String, | |
| 198 | private val token: String, | |
| 199 | private val http: OkHttpClient, | |
| 200 | private val onUnauthorized: () -> Unit = {}, | |
| 201 | ) : HubApi { | |
| 202 | private val base: HttpUrl = "${hub.trimEnd('/')}/api/v1/".toHttpUrl() | |
| 203 | private val root: HttpUrl = "${hub.trimEnd('/')}/".toHttpUrl() | |
| 204 | ||
| 205 | override suspend fun user(): User = get("user", User.serializer()) | |
| 206 | ||
| 207 | override suspend fun repositories(): List<Repository> = get("repos", ListSerializer(Repository.serializer())) | |
| 208 | ||
| 209 | override suspend fun issues(owner: String, name: String, state: IssueState): List<Issue> = | |
| 210 | get(url("repos", owner, name, "issues") { addQueryParameter("state", state.query) }, ListSerializer(Issue.serializer())) | |
| 211 | ||
| 212 | override suspend fun inbox(limit: Int): Inbox = | |
| 213 | get(url("notifications") { addQueryParameter("limit", limit.coerceIn(1, 200).toString()) }, Inbox.serializer()) | |
| 214 | ||
| 215 | override suspend fun runnerToken(): RunnerToken = send("POST", url("user", "runner-token"), RunnerToken.serializer()) | |
| 216 | ||
| 217 | override suspend fun releases(owner: String, name: String): List<Release> = | |
| 218 | get(url("repos", owner, name, "releases"), ListSerializer(Release.serializer())) | |
| 219 | ||
| 220 | override suspend fun search(query: String): List<SearchHit> = | |
| 221 | get(url("search") { addQueryParameter("q", query) }, ListSerializer(SearchHit.serializer())) | |
| 222 | ||
| 223 | override suspend fun runs(owner: String, name: String): List<FlowRun> = | |
| 224 | get(url("repos", owner, name, "flow", "runs"), ListSerializer(FlowRun.serializer())) | |
| 225 | ||
| 226 | override suspend fun run(owner: String, name: String, number: Long): FlowRun = | |
| 227 | get(url("repos", owner, name, "flow", "runs", number.toString()), FlowRun.serializer()) | |
| 228 | ||
| 229 | override suspend fun jobLog(owner: String, name: String, number: Long, job: String, after: Long): List<LogLine> = | |
| 230 | get( | |
| 231 | url("repos", owner, name, "flow", "runs", number.toString(), "jobs", job, "log") { addQueryParameter("after", after.toString()) }, | |
| 232 | ListSerializer(LogLine.serializer()), | |
| 233 | ) | |
| 234 | ||
| 235 | override suspend fun rerunRun(owner: String, name: String, number: Long) { | |
| 236 | send("POST", url("repos", owner, name, "flow", "runs", number.toString(), "rerun")) | |
| 237 | } | |
| 238 | ||
| 239 | override suspend fun rerunJob(owner: String, name: String, number: Long, job: String) { | |
| 240 | send("POST", url("repos", owner, name, "flow", "runs", number.toString(), "jobs", job, "rerun")) | |
| 241 | } | |
| 242 | ||
| 243 | override suspend fun cancelRun(owner: String, name: String, number: Long) { | |
| 244 | send("POST", url("repos", owner, name, "flow", "runs", number.toString(), "cancel")) | |
| 245 | } | |
| 246 | ||
| 247 | override suspend fun decideJob(owner: String, name: String, number: Long, job: String, approve: Boolean) { | |
| 248 | send("POST", url("repos", owner, name, "flow", "runs", number.toString(), "jobs", job, if (approve) "approve" else "reject")) | |
| 249 | } | |
| 250 | ||
| 251 | override suspend fun expediteRun(owner: String, name: String, number: Long, reason: String) { | |
| 252 | sendJson("POST", url("repos", owner, name, "flow", "runs", number.toString(), "expedite"), buildJsonObject { | |
| 253 | put("reason", reason) | |
| 254 | }, Expedited.serializer()) | |
| 255 | } | |
| 256 | ||
| 257 | override suspend fun projects(owner: String): List<Project> = get(url("projects", owner), ListSerializer(Project.serializer())) | |
| 258 | ||
| 259 | override suspend fun board(owner: String, number: Long): Board = get(url("projects", owner, number.toString()), Board.serializer()) | |
| 260 | ||
| 261 | override suspend fun moveCard(owner: String, number: Long, card: Long, column: String) { | |
| 262 | val json = buildJsonObject { put("column", column) } | |
| 263 | call(request(url("projects", owner, number.toString(), "cards", card.toString())).method("PATCH", json.toString().toRequestBody(JsonMedia)).build(), true) | |
| 264 | } | |
| 265 | ||
| 266 | override suspend fun issue(owner: String, name: String, number: Long): Issue = | |
| 267 | get(url("repos", owner, name, "issues", number.toString()), Issue.serializer()) | |
| 268 | ||
| 269 | override suspend fun issueComments(owner: String, name: String, number: Long): List<Comment> = | |
| 270 | get(url("repos", owner, name, "issues", number.toString(), "comments"), ListSerializer(Comment.serializer())) | |
| 271 | ||
| 272 | override suspend fun comment(owner: String, name: String, number: Long, body: String): Comment = | |
| 273 | sendJson("POST", url("repos", owner, name, "issues", number.toString(), "comments"), buildJsonObject { put("body", body) }, Comment.serializer()) | |
| 274 | ||
| 275 | override suspend fun setIssueState(owner: String, name: String, number: Long, open: Boolean, reason: String): Issue = | |
| 276 | sendJson( | |
| 277 | "POST", | |
| 278 | url("repos", owner, name, "issues", number.toString()), | |
| 279 | buildJsonObject { | |
| 280 | put("state", if (open) "open" else "closed") | |
| 281 | if (!open) put("reason", reason) | |
| 282 | }, | |
| 283 | Issue.serializer(), | |
| 284 | ) | |
| 285 | ||
| 286 | override suspend fun createIssue(owner: String, name: String, title: String, body: String): Issue = | |
| 287 | sendJson("POST", url("repos", owner, name, "issues"), buildJsonObject { | |
| 288 | put("title", title) | |
| 289 | put("body", body) | |
| 290 | }, Issue.serializer()) | |
| 291 | ||
| 292 | override suspend fun labels(owner: String, name: String): List<Label> = | |
| 293 | get(url("repos", owner, name, "labels"), ListSerializer(Label.serializer())) | |
| 294 | ||
| 295 | override suspend fun setIssueAssignees(owner: String, name: String, number: Long, assignees: List<String>): Issue = | |
| 296 | sendJson("PATCH", url("repos", owner, name, "issues", number.toString()), buildJsonObject { | |
| 297 | put("assignees", JsonArray(assignees.map { JsonPrimitive(it) })) | |
| 298 | }, Issue.serializer()) | |
| 299 | ||
| 300 | override suspend fun setIssueLabels(owner: String, name: String, number: Long, labels: List<String>): Issue = | |
| 301 | sendJson("PATCH", url("repos", owner, name, "issues", number.toString()), buildJsonObject { | |
| 302 | put("labels", JsonArray(labels.map { JsonPrimitive(it) })) | |
| 303 | }, Issue.serializer()) | |
| 304 | ||
| 305 | override suspend fun account(name: String): User = get(url("users", name), User.serializer()) | |
| 306 | ||
| 307 | override suspend fun organisation(name: String): Organisation = get(url("orgs", name), Organisation.serializer()) | |
| 308 | ||
| 309 | override suspend fun repository(owner: String, name: String): Repository = get(url("repos", owner, name), Repository.serializer()) | |
| 310 | ||
| 311 | private fun parts(path: String): Array<String> = path.split('/').filter { it.isNotEmpty() }.toTypedArray() | |
| 312 | ||
| 313 | override suspend fun tree(owner: String, name: String, ref: String, path: String): List<TreeEntry> = | |
| 314 | get(url("repos", owner, name, "tree", ref, *parts(path)), ListSerializer(TreeEntry.serializer())) | |
| 315 | ||
| 316 | override suspend fun file(owner: String, name: String, ref: String, path: String): String = | |
| 317 | call(request(url("repos", owner, name, "file", ref, *parts(path))).get().build(), notifyUnauthorized = true) | |
| 318 | ||
| 319 | override suspend fun history(owner: String, name: String, ref: String, path: String?, offset: Int, limit: Int): History = | |
| 320 | get( | |
| 321 | url("repos", owner, name, "history", ref) { | |
| 322 | path?.let { addQueryParameter("path", it) } | |
| 323 | addQueryParameter("offset", offset.toString()) | |
| 324 | addQueryParameter("limit", limit.toString()) | |
| 325 | }, | |
| 326 | History.serializer(), | |
| 327 | ) | |
| 328 | ||
| 329 | override suspend fun review(owner: String, name: String, number: Long, verdict: String, body: String) { | |
| 330 | sendJson("POST", url("repos", owner, name, "proposals", number.toString(), "reviews"), buildJsonObject { | |
| 331 | put("verdict", verdict) | |
| 332 | put("body", body) | |
| 333 | }, ReviewPosted.serializer()) | |
| 334 | } | |
| 335 | ||
| 336 | override suspend fun proposalDiff(owner: String, name: String, number: Long): List<FileChange> = | |
| 337 | get(url("repos", owner, name, "proposals", number.toString(), "diff"), ListSerializer(FileChange.serializer())) | |
| 338 | ||
| 339 | override suspend fun change(owner: String, name: String, hash: String): ChangeDetail = | |
| 340 | get(url("repos", owner, name, "changes", hash), ChangeDetail.serializer()) | |
| 341 | ||
| 342 | override suspend fun refs(owner: String, name: String): Pair<List<String>, List<String>> { | |
| 343 | val bookmarks = get(url("repos", owner, name, "bookmarks"), ListSerializer(NamedRef.serializer())).map { it.name } | |
| 344 | val tags = get(url("repos", owner, name, "tags"), ListSerializer(NamedRef.serializer())).map { it.name } | |
| 345 | return bookmarks to tags | |
| 346 | } | |
| 347 | ||
| 348 | override suspend fun userSky(): UserSky = get(url("user", "sky"), UserSky.serializer()) | |
| 349 | ||
| 350 | override suspend fun userOrgs(): List<UserOrg> = get(url("user", "orgs"), ListSerializer(UserOrg.serializer())) | |
| 351 | ||
| 352 | override suspend fun createRepository(owner: String, name: String, description: String, visibility: Visibility): Repository { | |
| 353 | val json = buildJsonObject { | |
| 354 | put("owner", owner) | |
| 355 | put("name", name) | |
| 356 | put("description", description) | |
| 357 | put("visibility", HubJson.encodeToJsonElement(Visibility.serializer(), visibility)) | |
| 358 | } | |
| 359 | return sendJson("POST", url("repos"), json, Repository.serializer()) | |
| 360 | } | |
| 361 | ||
| 362 | override suspend fun starterAssistants(owner: String): List<StarterAssistant> = | |
| 363 | get(url("user", "starter") { addQueryParameter("owner", owner) }, StarterAssistants.serializer()).assistants | |
| 364 | ||
| 365 | override suspend fun startStarter(owner: String, name: String, description: String): StarterStatus = | |
| 366 | sendJson("POST", url("repos", owner, name, "starter"), buildJsonObject { put("description", description) }, StarterStatus.serializer()) | |
| 367 | ||
| 368 | override suspend fun starterStatus(owner: String, name: String): StarterStatus = | |
| 369 | get(url("repos", owner, name, "starter"), StarterStatus.serializer()) | |
| 370 | ||
| 371 | override suspend fun userFlowRuns(before: Long?): List<UserFlowRun> = | |
| 372 | get(url("user", "flow", "runs") { before?.let { addQueryParameter("before", it.toString()) } }, ListSerializer(JsonObject.serializer())) | |
| 373 | .map { o -> UserFlowRun((o["repository"] as? JsonPrimitive)?.content.orEmpty(), HubJson.decodeFromJsonElement(FlowRun.serializer(), o)) } | |
| 374 | ||
| 375 | override suspend fun repoSky(owner: String, name: String): UserSky = get(url("repos", owner, name, "sky"), UserSky.serializer()) | |
| 376 | ||
| 377 | override suspend fun userProposals(landable: Boolean): UserProposals = | |
| 378 | get(url("user", "proposals") { if (landable) addQueryParameter("landable", "true") }, UserProposals.serializer()) | |
| 379 | ||
| 380 | override suspend fun userIssues(): List<IssueBrief> = get(url("user", "issues"), ListSerializer(IssueBrief.serializer())) | |
| 381 | ||
| 382 | override suspend fun proposals(owner: String, name: String, state: ProposalState): List<Proposal> = | |
| 383 | get(url("repos", owner, name, "proposals") { addQueryParameter("state", state.query) }, ListSerializer(Proposal.serializer())) | |
| 384 | ||
| 385 | override suspend fun proposal(owner: String, name: String, number: Long): Proposal = | |
| 386 | get(url("repos", owner, name, "proposals", number.toString()), Proposal.serializer()) | |
| 387 | ||
| 388 | override suspend fun checks(owner: String, name: String, number: Long): List<Check> = | |
| 389 | get(url("repos", owner, name, "proposals", number.toString(), "checks"), ListSerializer(Check.serializer())) | |
| 390 | ||
| 391 | override suspend fun land(owner: String, name: String, number: Long): Proposal = | |
| 392 | send("POST", url("repos", owner, name, "proposals", number.toString(), "land"), Proposal.serializer()) | |
| 393 | ||
| 394 | override suspend fun setAutoLand(owner: String, name: String, number: Long, on: Boolean): Proposal = | |
| 395 | send(if (on) "POST" else "DELETE", url("repos", owner, name, "proposals", number.toString(), "auto-land"), Proposal.serializer()) | |
| 396 | ||
| 397 | override suspend fun markRead(id: Long) { | |
| 398 | send("POST", url("notifications", id.toString(), "read")) | |
| 399 | } | |
| 400 | ||
| 401 | override suspend fun markAllRead() { | |
| 402 | send("POST", url("notifications", "read")) | |
| 403 | } | |
| 404 | ||
| 405 | override suspend fun revokeToken() { | |
| 406 | send("DELETE", url("user", "token"), notifyUnauthorized = false) | |
| 407 | } | |
| 408 | ||
| 409 | override suspend fun registerPush(fcmToken: String, publicKey: String): Boolean = | |
| 410 | sendJson("PUT", url("user", "push"), buildJsonObject { | |
| 411 | put("fcm_token", fcmToken) | |
| 412 | put("public_key", publicKey) | |
| 413 | }, PushRegistered.serializer()).alerts | |
| 414 | ||
| 415 | override suspend fun avatar(name: String): Avatar? { | |
| 416 | val url = root.newBuilder().addPathSegment("avatar").addPathSegment(name).build() | |
| 417 | // A public picture: no token goes with it. | |
| 418 | val response = try { | |
| 419 | http.newCall(Request.Builder().url(url).get().build()).await() | |
| 420 | } catch (e: IOException) { | |
| 421 | throw HubException.Network(e) | |
| 422 | } | |
| 423 | response.use { r -> | |
| 424 | if (r.code == 404) return null | |
| 425 | val bytes = try { | |
| 426 | r.body?.bytes() ?: ByteArray(0) | |
| 427 | } catch (e: IOException) { | |
| 428 | throw HubException.Network(e) | |
| 429 | } | |
| 430 | if (!r.isSuccessful) throw HubException.Http(r.code, errorDetail(bytes.decodeToString())) | |
| 431 | return Avatar.parse(r.header("Content-Type"), bytes) | |
| 432 | } | |
| 433 | } | |
| 434 | ||
| 435 | // The bearer token is never part of a string anything prints. | |
| 436 | override fun toString(): String = "HubClient(${base})" | |
| 437 | ||
| 438 | private fun url(vararg segments: String, query: HttpUrl.Builder.() -> Unit = {}): HttpUrl { | |
| 439 | val b = base.newBuilder() | |
| 440 | // Each segment is encoded on its own: an owner or name never adds a path level. | |
| 441 | segments.forEach { b.addPathSegment(it) } | |
| 442 | b.query() | |
| 443 | return b.build() | |
| 444 | } | |
| 445 | ||
| 446 | private suspend fun <T> get(path: String, serializer: KSerializer<T>): T = get(url(*path.split('/').toTypedArray()), serializer) | |
| 447 | ||
| 448 | private suspend fun <T> get(url: HttpUrl, serializer: KSerializer<T>): T { | |
| 449 | val body = call(request(url).get().build(), notifyUnauthorized = true) | |
| 450 | return try { | |
| 451 | HubJson.decodeFromString(serializer, body) | |
| 452 | } catch (e: IllegalArgumentException) { | |
| 453 | // kotlinx.serialization's errors are IllegalArgumentExceptions. | |
| 454 | throw HubException.Unreadable("GET ${url.encodedPath}", e) | |
| 455 | } | |
| 456 | } | |
| 457 | ||
| 458 | private suspend fun send(method: String, url: HttpUrl, notifyUnauthorized: Boolean = true): String { | |
| 459 | val body = if (method == "DELETE") null else "{}".toRequestBody(JsonMedia) | |
| 460 | return call(request(url).method(method, body).build(), notifyUnauthorized) | |
| 461 | } | |
| 462 | ||
| 463 | private suspend fun <T> send(method: String, url: HttpUrl, serializer: KSerializer<T>): T { | |
| 464 | val body = send(method, url) | |
| 465 | return try { | |
| 466 | HubJson.decodeFromString(serializer, body) | |
| 467 | } catch (e: IllegalArgumentException) { | |
| 468 | throw HubException.Unreadable("$method ${url.encodedPath}", e) | |
| 469 | } | |
| 470 | } | |
| 471 | ||
| 472 | /** [json] as the body; the answer read with [serializer]. */ | |
| 473 | private suspend fun <T> sendJson(method: String, url: HttpUrl, json: JsonObject, serializer: KSerializer<T>): T { | |
| 474 | val body = call(request(url).method(method, json.toString().toRequestBody(JsonMedia)).build(), notifyUnauthorized = true) | |
| 475 | return try { | |
| 476 | HubJson.decodeFromString(serializer, body) | |
| 477 | } catch (e: IllegalArgumentException) { | |
| 478 | throw HubException.Unreadable("$method ${url.encodedPath}", e) | |
| 479 | } | |
| 480 | } | |
| 481 | ||
| 482 | private fun request(url: HttpUrl): Request.Builder = Request.Builder() | |
| 483 | .url(url) | |
| 484 | .header("Accept", "application/json") | |
| 485 | .header("Authorization", "Bearer $token") | |
| 486 | ||
| 487 | private suspend fun call(request: Request, notifyUnauthorized: Boolean): String { | |
| 488 | val response = try { | |
| 489 | http.newCall(request).await() | |
| 490 | } catch (e: IOException) { | |
| 491 | throw HubException.Network(e) | |
| 492 | } | |
| 493 | response.use { r -> | |
| 494 | val text = try { | |
| 495 | r.body?.string().orEmpty() | |
| 496 | } catch (e: IOException) { | |
| 497 | throw HubException.Network(e) | |
| 498 | } | |
| 499 | if (!r.isSuccessful) { | |
| 500 | if (r.code == 401 && notifyUnauthorized) onUnauthorized() | |
| 501 | throw HubException.Http(r.code, errorDetail(text)) | |
| 502 | } | |
| 503 | return text | |
| 504 | } | |
| 505 | } | |
| 506 | } |