prehistoric-systems/omnivore
1
0
Fork 0
mirror of https://github.com/omnivore-app/omnivore.git synced 2026-03-11 08:54:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Enqueue or delete sync task when create or disable integration

Browse source
This commit is contained in:
Hongbo Wu 2022-08-05 13:10:22 +08:00
parent 5a8184da3a
commit 22ce59a198
1 changed files with 22 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
packages/api/src/resolvers/integrations/index.ts
View file

@ -11,6 +11,8 @@ import { Integration } from '../../entity/integration'
import { analytics } from '../../utils/analytics'
import { env } from '../../env'
import { validateToken } from '../../services/integrations'
import { deleteTask, enqueueSyncWithIntegration } from '../../utils/createTask'
import { AppDataSource } from '../../server'
export const setIntegrationResolver = authorized<
SetIntegrationSuccess,
@ -73,7 +75,26 @@ export const setIntegrationResolver = authorized<
}
}
const integration = await getRepository(Integration).save(integrationToSave)
const integration = await AppDataSource.transaction(async (t) => {
const integration = await t
.getRepository(Integration)
.save(integrationToSave)
if (integration.enabled) {
// create a task to sync all the pages
const taskName = await enqueueSyncWithIntegration(
user.id,
integration.type
)
log.info('enqueued task', taskName)
await t
.getRepository(Integration)
.update({ id: integration.id }, { taskName })
} else if (integration.taskName) {
await deleteTask(integration.taskName)
log.info('task deleted', integration.taskName)
}
return integration
})
analytics.track({
userId: uid,