mirror of
https://github.com/overleaf/overleaf.git
synced 2024-11-21 20:47:08 -05:00
Revert "use user_id for tpds queue name"
This reverts commit 76d7badd001e0902e55d54efdca53d01124bcc77. GitOrigin-RevId: 75e480660c6a1682cf20ba9575fd90f0ce726abc
This commit is contained in:
parent
673669e41a
commit
a0bb38750a
2 changed files with 8 additions and 8 deletions
|
@ -112,7 +112,7 @@ const TpdsUpdateSender = {
|
|||
streamOrigin: options.streamOrigin
|
||||
}
|
||||
return TpdsUpdateSender._enqueue(
|
||||
user_id,
|
||||
options.project_id,
|
||||
'pipeStreamFrom',
|
||||
postOptions,
|
||||
function(err) {
|
||||
|
@ -204,7 +204,7 @@ const TpdsUpdateSender = {
|
|||
}
|
||||
}
|
||||
return TpdsUpdateSender._enqueue(
|
||||
user_id,
|
||||
options.project_id,
|
||||
'standardHttpRequest',
|
||||
moveOptions,
|
||||
callback
|
||||
|
@ -237,7 +237,7 @@ const TpdsUpdateSender = {
|
|||
sl_all_user_ids: JSON.stringify(allUserIds)
|
||||
}
|
||||
return TpdsUpdateSender._enqueue(
|
||||
user_id,
|
||||
options.project_id,
|
||||
'standardHttpRequest',
|
||||
deleteOptions,
|
||||
callback
|
||||
|
|
|
@ -109,7 +109,7 @@ describe('TpdsUpdateSender', function() {
|
|||
const file_id = '4545345'
|
||||
const path = '/some/path/here.jpg'
|
||||
this.updateSender._enqueue = function(uid, method, job, callback) {
|
||||
uid.should.equal(user_id)
|
||||
uid.should.equal(project_id)
|
||||
job.method.should.equal('post')
|
||||
job.streamOrigin.should.equal(
|
||||
`${filestoreUrl}/project/${project_id}/file/${file_id}`
|
||||
|
@ -135,7 +135,7 @@ describe('TpdsUpdateSender', function() {
|
|||
const lines = ['line1', 'line2', 'line3']
|
||||
|
||||
this.updateSender._enqueue = (uid, method, job, callback) => {
|
||||
uid.should.equal(user_id)
|
||||
uid.should.equal(project_id)
|
||||
job.method.should.equal('post')
|
||||
const expectedUrl = `${thirdPartyDataStoreApiUrl}/user/${user_id}/entity/${encodeURIComponent(
|
||||
project_name
|
||||
|
@ -161,7 +161,7 @@ describe('TpdsUpdateSender', function() {
|
|||
it('deleting entity', function(done) {
|
||||
const path = '/path/here/t.tex'
|
||||
this.updateSender._enqueue = function(uid, method, job, callback) {
|
||||
uid.should.equal(user_id)
|
||||
uid.should.equal(project_id)
|
||||
job.method.should.equal('DELETE')
|
||||
const expectedUrl = `${thirdPartyDataStoreApiUrl}/user/${user_id}/entity/${encodeURIComponent(
|
||||
project_name
|
||||
|
@ -179,7 +179,7 @@ describe('TpdsUpdateSender', function() {
|
|||
const startPath = 'staring/here/file.tex'
|
||||
const endPath = 'ending/here/file.tex'
|
||||
this.updateSender._enqueue = function(uid, method, job, callback) {
|
||||
uid.should.equal(user_id)
|
||||
uid.should.equal(project_id)
|
||||
job.method.should.equal('put')
|
||||
job.uri.should.equal(
|
||||
`${thirdPartyDataStoreApiUrl}/user/${user_id}/entity`
|
||||
|
@ -203,7 +203,7 @@ describe('TpdsUpdateSender', function() {
|
|||
const oldProjectName = '/oldProjectName/'
|
||||
const newProjectName = '/newProjectName/'
|
||||
this.updateSender._enqueue = function(uid, method, job, callback) {
|
||||
uid.should.equal(user_id)
|
||||
uid.should.equal(project_id)
|
||||
job.method.should.equal('put')
|
||||
job.uri.should.equal(
|
||||
`${thirdPartyDataStoreApiUrl}/user/${user_id}/entity`
|
||||
|
|
Loading…
Reference in a new issue