71 lines
2.2 KiB
TypeScript
71 lines
2.2 KiB
TypeScript
import {
|
|
apId,
|
|
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 {
|
|
createMockFlow,
|
|
createMockFlowVersion,
|
|
createMockProject,
|
|
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('Flow API for Worker', () => {
|
|
describe('Get Flow from Worker', () => {
|
|
it('List other flow for another project', async () => {
|
|
// arrange
|
|
const { mockPlatform, mockOwner, mockProject } = await mockAndSaveBasicSetup()
|
|
|
|
const mockProject2 = createMockProject({
|
|
platformId: mockPlatform.id,
|
|
ownerId: mockOwner.id,
|
|
})
|
|
|
|
await databaseConnection().getRepository('project').save([mockProject2])
|
|
|
|
const mockFlow = createMockFlow({
|
|
projectId: mockProject.id,
|
|
})
|
|
await databaseConnection().getRepository('flow').save([mockFlow])
|
|
|
|
const mockFlowVersion = createMockFlowVersion({
|
|
flowId: mockFlow.id,
|
|
})
|
|
await databaseConnection().getRepository('flow_version').save([mockFlowVersion])
|
|
|
|
const mockToken = await generateMockToken({
|
|
id: apId(),
|
|
type: PrincipalType.WORKER,
|
|
projectId: mockProject2.id,
|
|
})
|
|
|
|
const response = await app?.inject({
|
|
method: 'GET',
|
|
url: `/v1/worker/flows/${mockFlowVersion.id}`,
|
|
headers: {
|
|
authorization: `Bearer ${mockToken}`,
|
|
},
|
|
})
|
|
expect(response?.statusCode).toBe(StatusCodes.NOT_FOUND)
|
|
})
|
|
})
|
|
|
|
})
|