49 lines
1.5 KiB
TypeScript
49 lines
1.5 KiB
TypeScript
import { PrincipalType } from '@activepieces/shared'
|
|
import { FastifyInstance } from 'fastify'
|
|
import { StatusCodes } from 'http-status-codes'
|
|
import { initializeDatabase } from '../../../../src/app/database'
|
|
import { databaseConnection } from '../../../../src/app/database/database-connection'
|
|
import { setupServer } from '../../../../src/app/server'
|
|
import { generateMockToken } from '../../../helpers/auth'
|
|
import { mockAndSaveBasicSetup } from '../../../helpers/mocks'
|
|
|
|
let app: FastifyInstance | null = null
|
|
|
|
beforeAll(async () => {
|
|
await initializeDatabase({ runMigrations: false })
|
|
app = await setupServer()
|
|
})
|
|
|
|
afterAll(async () => {
|
|
await databaseConnection().destroy()
|
|
await app?.close()
|
|
})
|
|
|
|
describe('Project Worker API', () => {
|
|
describe('Get worker project endpoint', () => {
|
|
it('Returns worker project', async () => {
|
|
// arrange
|
|
const { mockProject } = await mockAndSaveBasicSetup()
|
|
|
|
const mockToken = await generateMockToken({
|
|
type: PrincipalType.ENGINE,
|
|
projectId: mockProject.id,
|
|
})
|
|
|
|
// act
|
|
const response = await app?.inject({
|
|
method: 'GET',
|
|
url: '/v1/worker/project',
|
|
headers: {
|
|
authorization: `Bearer ${mockToken}`,
|
|
},
|
|
})
|
|
|
|
// assert
|
|
expect(response?.statusCode).toBe(StatusCodes.OK)
|
|
const responseBody = response?.json()
|
|
expect(responseBody?.id).toBe(mockProject.id)
|
|
})
|
|
})
|
|
})
|