mirror of
https://github.com/yu-i-i/overleaf-cep.git
synced 2026-06-03 06:09:02 +02:00
Revert "Send subscription -> salesforce/v1 links to analytics"
This reverts commit 52c02138f9ef8141850e2f8ce16f2bab1e7463b0. GitOrigin-RevId: 022e828a8e41cc73c4087b94d51fa75dbe6cfdb5
This commit is contained in:
@@ -1,228 +0,0 @@
|
||||
import path from 'node:path'
|
||||
import esmock from 'esmock'
|
||||
import { expect } from 'chai'
|
||||
import mongodb from 'mongodb-legacy'
|
||||
import { fileURLToPath } from 'node:url'
|
||||
|
||||
const { ObjectId } = mongodb
|
||||
|
||||
const __dirname = fileURLToPath(new URL('.', import.meta.url))
|
||||
|
||||
const MODULE_PATH = path.join(
|
||||
__dirname,
|
||||
'../../../../app/src/Features/Analytics/AccountMappingHelper'
|
||||
)
|
||||
|
||||
describe('AccountMappingHelper', function () {
|
||||
beforeEach(async function () {
|
||||
this.AccountMappingHelper = await esmock.strict(MODULE_PATH)
|
||||
})
|
||||
|
||||
describe('extractAccountMappingsFromSubscription', function () {
|
||||
describe('when the v1 id is the same in the updated subscription and the subscription', function () {
|
||||
describe('when the salesforce id is the same in the updated subscription and the subscription', function () {
|
||||
beforeEach(function () {
|
||||
this.subscription = {
|
||||
id: new ObjectId('abc123abc123abc123abc123'),
|
||||
salesforce_id: 'def456def456def456',
|
||||
}
|
||||
this.updatedSubscription = { salesforce_id: 'def456def456def456' }
|
||||
this.result =
|
||||
this.AccountMappingHelper.extractAccountMappingsFromSubscription(
|
||||
this.subscription,
|
||||
this.updatedSubscription
|
||||
)
|
||||
})
|
||||
|
||||
it('returns an empty array', function () {
|
||||
expect(this.result).to.be.an('array')
|
||||
expect(this.result).to.have.length(0)
|
||||
})
|
||||
})
|
||||
describe('when the salesforce id has changed between the subscription and the updated subscription', function () {
|
||||
beforeEach(function () {
|
||||
this.subscription = {
|
||||
id: new ObjectId('abc123abc123abc123abc123'),
|
||||
salesforce_id: 'def456def456def456',
|
||||
}
|
||||
this.updatedSubscription = { salesforce_id: 'ghi789ghi789ghi789' }
|
||||
this.result =
|
||||
this.AccountMappingHelper.extractAccountMappingsFromSubscription(
|
||||
this.subscription,
|
||||
this.updatedSubscription
|
||||
)
|
||||
})
|
||||
|
||||
it('returns an array with a single item', function () {
|
||||
expect(this.result).to.be.an('array')
|
||||
expect(this.result).to.have.length(1)
|
||||
})
|
||||
|
||||
it('uses "account" as sourceEntity', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty('sourceEntity', 'account')
|
||||
})
|
||||
|
||||
it('uses the salesforceId from the updated subscription as sourceEntityId', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'sourceEntityId',
|
||||
this.updatedSubscription.salesforce_id
|
||||
)
|
||||
})
|
||||
|
||||
it('uses "subscription" as targetEntity', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'targetEntity',
|
||||
'subscription'
|
||||
)
|
||||
})
|
||||
|
||||
it('uses the subscriptionId as targetEntityId', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'targetEntityId',
|
||||
this.subscription.id
|
||||
)
|
||||
})
|
||||
})
|
||||
describe('when the update subscription has a salesforce id and the subscription has no salesforce_id', function () {
|
||||
beforeEach(function () {
|
||||
this.subscription = { id: new ObjectId('abc123abc123abc123abc123') }
|
||||
this.updatedSubscription = { salesforce_id: 'def456def456def456' }
|
||||
this.result =
|
||||
this.AccountMappingHelper.extractAccountMappingsFromSubscription(
|
||||
this.subscription,
|
||||
this.updatedSubscription
|
||||
)
|
||||
})
|
||||
|
||||
it('returns an array with a single item', function () {
|
||||
expect(this.result).to.be.an('array')
|
||||
expect(this.result).to.have.length(1)
|
||||
})
|
||||
|
||||
it('uses "account" as sourceEntity', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty('sourceEntity', 'account')
|
||||
})
|
||||
|
||||
it('uses the salesforceId from the updated subscription as sourceEntityId', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'sourceEntityId',
|
||||
this.updatedSubscription.salesforce_id
|
||||
)
|
||||
})
|
||||
|
||||
it('uses "subscription" as targetEntity', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'targetEntity',
|
||||
'subscription'
|
||||
)
|
||||
})
|
||||
|
||||
it('uses the subscriptionId as targetEntityId', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'targetEntityId',
|
||||
this.subscription.id
|
||||
)
|
||||
})
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
describe('when the v1 id has changed between the subscription and the updated subscription', function () {
|
||||
describe('when the salesforce id has not changed between the subscription and the updated subscription', function () {
|
||||
beforeEach(function () {
|
||||
this.subscription = {
|
||||
id: new ObjectId('abc123abc123abc123abc123'),
|
||||
v1_id: '1',
|
||||
salesforce_id: '',
|
||||
}
|
||||
this.updatedSubscription = { v1_id: '2', salesforce_id: '' }
|
||||
this.result =
|
||||
this.AccountMappingHelper.extractAccountMappingsFromSubscription(
|
||||
this.subscription,
|
||||
this.updatedSubscription
|
||||
)
|
||||
})
|
||||
|
||||
it('returns an array with a single item', function () {
|
||||
expect(this.result).to.be.an('array')
|
||||
expect(this.result).to.have.length(1)
|
||||
})
|
||||
|
||||
it('uses "university" as the sourceEntity', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty('sourceEntity', 'university')
|
||||
})
|
||||
|
||||
it('uses the v1_id from the updated subscription as the sourceEntityId', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'sourceEntityId',
|
||||
this.updatedSubscription.v1_id
|
||||
)
|
||||
})
|
||||
|
||||
it('uses "subscription" as the targetEntity', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'targetEntity',
|
||||
'subscription'
|
||||
)
|
||||
})
|
||||
|
||||
it('uses the subscription id as the targetEntityId', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'targetEntityId',
|
||||
this.subscription.id
|
||||
)
|
||||
})
|
||||
})
|
||||
describe('when the salesforce id has changed between the subscription and the updated subscription', function () {
|
||||
beforeEach(function () {
|
||||
this.subscription = {
|
||||
id: new ObjectId('abc123abc123abc123abc123'),
|
||||
v1_id: '',
|
||||
salesforce_id: 'def456def456def456',
|
||||
}
|
||||
this.updatedSubscription = {
|
||||
v1_id: '2',
|
||||
salesforce_id: '',
|
||||
}
|
||||
this.result =
|
||||
this.AccountMappingHelper.extractAccountMappingsFromSubscription(
|
||||
this.subscription,
|
||||
this.updatedSubscription
|
||||
)
|
||||
})
|
||||
|
||||
it('returns an array with two items', function () {
|
||||
expect(this.result).to.be.an('array')
|
||||
expect(this.result).to.have.length(2)
|
||||
})
|
||||
|
||||
it('uses the salesforce_id from the updated subscription as the sourceEntityId for the first item', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'sourceEntityId',
|
||||
this.updatedSubscription.salesforce_id
|
||||
)
|
||||
})
|
||||
|
||||
it('uses the subscription id as the targetEntityId for the first item', function () {
|
||||
expect(this.result[0]).to.haveOwnProperty(
|
||||
'targetEntityId',
|
||||
this.subscription.id
|
||||
)
|
||||
})
|
||||
|
||||
it('uses the v1_id from the updated subscription as the sourceEntityId for the second item', function () {
|
||||
expect(this.result[1]).to.haveOwnProperty(
|
||||
'sourceEntityId',
|
||||
this.updatedSubscription.v1_id
|
||||
)
|
||||
})
|
||||
|
||||
it('uses the subscription id as the targetEntityId for the second item', function () {
|
||||
expect(this.result[1]).to.haveOwnProperty(
|
||||
'targetEntityId',
|
||||
this.subscription.id
|
||||
)
|
||||
})
|
||||
})
|
||||
})
|
||||
})
|
||||
@@ -34,10 +34,6 @@ describe('AnalyticsManager', function () {
|
||||
add: sinon.stub().resolves(),
|
||||
process: sinon.stub().resolves(),
|
||||
}
|
||||
this.analyticsAccountMappingQueue = {
|
||||
add: sinon.stub().resolves(),
|
||||
process: sinon.stub().resolves(),
|
||||
}
|
||||
const self = this
|
||||
this.Queues = {
|
||||
getQueue: queueName => {
|
||||
@@ -50,8 +46,6 @@ describe('AnalyticsManager', function () {
|
||||
return self.onboardingEmailsQueue
|
||||
case 'analytics-user-properties':
|
||||
return self.analyticsUserPropertiesQueue
|
||||
case 'analytics-account-mapping':
|
||||
return self.analyticsAccountMappingQueue
|
||||
default:
|
||||
throw new Error('Unexpected queue name')
|
||||
}
|
||||
@@ -284,24 +278,6 @@ describe('AnalyticsManager', function () {
|
||||
isLoggedIn: true,
|
||||
})
|
||||
})
|
||||
|
||||
it('account mapping', async function () {
|
||||
const message = {
|
||||
source: 'salesforce',
|
||||
sourceEntity: 'account',
|
||||
sourceEntityId: 'abc123abc123abc123',
|
||||
target: 'v1',
|
||||
targetEntity: 'university',
|
||||
targetEntityId: 1,
|
||||
createdAt: '2021-01-01T00:00:00Z',
|
||||
}
|
||||
await this.AnalyticsManager.registerAccountMapping(message)
|
||||
sinon.assert.calledWithMatch(
|
||||
this.analyticsAccountMappingQueue.add,
|
||||
'account-mapping',
|
||||
message
|
||||
)
|
||||
})
|
||||
})
|
||||
|
||||
describe('AnalyticsIdMiddleware', function () {
|
||||
@@ -323,8 +299,6 @@ describe('AnalyticsManager', function () {
|
||||
return self.onboardingEmailsQueue
|
||||
case 'analytics-user-properties':
|
||||
return self.analyticsUserPropertiesQueue
|
||||
case 'analytics-account-mapping':
|
||||
return self.analyticsAccountMappingQueue
|
||||
default:
|
||||
throw new Error('Unexpected queue name')
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user