Overview
Comment: | Include "since" in sync |
---|---|
Downloads: | Tarball | ZIP archive | SQL archive |
Timelines: | family | ancestors | descendants | both | trunk |
Files: | files | file ages | folders |
SHA3-256: |
2682b2dc32f3396d458e29df26ee65d9 |
User & Date: | js on 2020-10-04 01:18:14 |
Other Links: | manifest | tags |
Context
2020-10-04
| ||
01:33 | MTXStorage: Add transactions check-in: 5d9f93730c user: js tags: trunk | |
01:18 | Include "since" in sync check-in: 2682b2dc32 user: js tags: trunk | |
2020-10-03
| ||
22:32 | Store next batch check-in: 6ab44895eb user: js tags: trunk | |
Changes
Modified src/MTXClient.m from [00b0c5338a] to [ebe5b898bb].
︙ | ︙ | |||
199 200 201 202 203 204 205 | - (void)syncWithTimeout: (of_time_interval_t)timeout block: (mtx_client_response_block_t)block { void *pool = objc_autoreleasePoolPush(); MTXRequest *request = [self requestWithPath: @"/_matrix/client/r0/sync"]; unsigned long long timeoutMs = timeout * 1000; | > > > > | | 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 | - (void)syncWithTimeout: (of_time_interval_t)timeout block: (mtx_client_response_block_t)block { void *pool = objc_autoreleasePoolPush(); MTXRequest *request = [self requestWithPath: @"/_matrix/client/r0/sync"]; unsigned long long timeoutMs = timeout * 1000; OFMutableDictionary<OFString *, OFString *> *query = [OFMutableDictionary dictionaryWithObject: @(timeoutMs).stringValue forKey: @"timeout"]; query[@"since"] = [_storage nextBatchForDeviceID: _deviceID]; request.query = query; [request performWithBlock: ^ (mtx_response_t response, int statusCode, id exception) { if (exception != nil) { block(exception); return; } |
︙ | ︙ |
Modified src/MTXRequest.h from [9c39efc51b] to [a3c3ccbf3a].
︙ | ︙ | |||
69 70 71 72 73 74 75 | * @brief The path of the request. */ @property (copy, nonatomic) OFString *path; /** * @brief The query for the request. */ | | > | 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 | * @brief The path of the request. */ @property (copy, nonatomic) OFString *path; /** * @brief The query for the request. */ @property (copy, nullable, nonatomic) OFDictionary<OFString *, OFString *> *query; /** * @brief An optional body to send along with the request. * * This is a dictionary that gets serialized to JSON when the request is sent. */ @property (copy, nullable, nonatomic) OFDictionary<OFString *, id> *body; |
︙ | ︙ |
Modified src/MTXRequest.m from [88ddaafdca] to [6c0156e037].
︙ | ︙ | |||
93 94 95 96 97 98 99 | if (_block != nil) /* Not the best exception to indicate it's already in-flight. */ @throw [OFAlreadyConnectedException exception]; OFMutableURL *requestURL = [[_homeserver mutableCopy] autorelease]; requestURL.path = _path; | | | 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 | if (_block != nil) /* Not the best exception to indicate it's already in-flight. */ @throw [OFAlreadyConnectedException exception]; OFMutableURL *requestURL = [[_homeserver mutableCopy] autorelease]; requestURL.path = _path; requestURL.queryDictionary = _query; OFMutableDictionary *headers = [OFMutableDictionary dictionary]; headers[@"User-Agent"] = @"ObjMatrix"; if (_accessToken != nil) headers[@"Authorization"] = [OFString stringWithFormat: @"Bearer %@", _accessToken]; if (_body != nil) |
︙ | ︙ |