|
|
@@ -100,6 +100,21 @@ module.exports = TrackChangesClient =
|
|
|
response.statusCode.should.equal 204
|
|
|
callback(error)
|
|
|
|
|
|
+ waitForS3: (done, retries=42) ->
|
|
|
+ if !Settings.trackchanges.s3.endpoint
|
|
|
+ return done()
|
|
|
+
|
|
|
+ request.get "#{Settings.trackchanges.s3.endpoint}/", (err, res) ->
|
|
|
+ if res && res.statusCode < 500
|
|
|
+ return done()
|
|
|
+
|
|
|
+ if retries == 0
|
|
|
+ return done(err or new Error("s3 returned #{res.statusCode}"))
|
|
|
+
|
|
|
+ setTimeout () ->
|
|
|
+ TrackChangesClient.waitForS3(done, --retries)
|
|
|
+ , 1000
|
|
|
+
|
|
|
getS3Doc: (project_id, doc_id, pack_id, callback = (error, body) ->) ->
|
|
|
params =
|
|
|
Bucket: S3_BUCKET
|