Received a "setCheckpoint" request
(rq *blip.Message)
| 238 | |
| 239 | // Received a "setCheckpoint" request |
| 240 | func (bh *blipHandler) handleSetCheckpoint(rq *blip.Message) error { |
| 241 | |
| 242 | checkpointMessage := SetCheckpointMessage{rq} |
| 243 | bh.logEndpointEntry(rq.Profile(), checkpointMessage.String()) |
| 244 | |
| 245 | var checkpoint Body |
| 246 | if err := checkpointMessage.ReadJSONBody(&checkpoint); err != nil { |
| 247 | return err |
| 248 | } |
| 249 | if revID := checkpointMessage.rev(); revID != "" { |
| 250 | checkpoint[BodyRev] = revID |
| 251 | } |
| 252 | revID, _, err := bh.collection.PutSpecial(DocTypeLocal, CheckpointDocIDPrefix+checkpointMessage.client(), checkpoint) |
| 253 | if err != nil { |
| 254 | return err |
| 255 | } |
| 256 | |
| 257 | checkpointResponse := SetCheckpointResponse{checkpointMessage.Response()} |
| 258 | checkpointResponse.setRev(revID) |
| 259 | |
| 260 | return nil |
| 261 | } |
| 262 | |
| 263 | // ////// CHANGES |
| 264 |
nothing calls this directly
no test coverage detected