66 lines
1.7 KiB
TypeScript
66 lines
1.7 KiB
TypeScript
import { expect } from 'chai'
|
|
import 'mocha'
|
|
import { In } from 'typeorm'
|
|
import { StatusType } from '../../src/entity/user'
|
|
import {
|
|
createUsers,
|
|
deleteUsers,
|
|
findUsersByIds,
|
|
} from '../../src/services/user'
|
|
import { request } from '../util'
|
|
|
|
describe('User Service Router', () => {
|
|
const token = process.env.PUBSUB_VERIFICATION_TOKEN || ''
|
|
|
|
describe('prune', () => {
|
|
let toDeleteUserIds: string[] = []
|
|
|
|
before(async () => {
|
|
// create test users
|
|
const users = await createUsers([
|
|
{
|
|
name: 'user_1',
|
|
email: 'user_1@omnivore.app',
|
|
status: StatusType.Deleted,
|
|
updatedAt: new Date(Date.now() - 1000 * 60 * 60 * 24 * 2), // 2 days ago
|
|
source: 'GOOGLE',
|
|
sourceUserId: '123',
|
|
},
|
|
{
|
|
name: 'user_2',
|
|
email: 'user_2@omnivore.app',
|
|
status: StatusType.Deleted,
|
|
updatedAt: new Date(Date.now() - 1000 * 60 * 60 * 24 * 2), // 2 days ago
|
|
source: 'GOOGLE',
|
|
sourceUserId: '456',
|
|
},
|
|
])
|
|
toDeleteUserIds = users.map((u) => u.id)
|
|
})
|
|
|
|
after(async () => {
|
|
// delete test users
|
|
await deleteUsers({ id: In(toDeleteUserIds) })
|
|
})
|
|
|
|
it('prunes soft deleted users a day ago', async () => {
|
|
const data = {
|
|
message: {
|
|
data: Buffer.from(
|
|
JSON.stringify({ subDays: 1 }) // 1 day ago
|
|
).toString('base64'),
|
|
publishTime: new Date().toISOString(),
|
|
},
|
|
}
|
|
|
|
await request
|
|
.post('/svc/pubsub/user/prune?token=' + token)
|
|
.send(data)
|
|
.expect(200)
|
|
|
|
const deletedUsers = await findUsersByIds(toDeleteUserIds)
|
|
expect(deletedUsers.length).to.equal(0)
|
|
})
|
|
})
|
|
})
|