flows.service.tsβ’942 B
import { FlowsContext } from '@activepieces/pieces-framework'
import { PopulatedFlow, SeekPage } from '@activepieces/shared'
type CreateFlowsServiceParams = {
engineToken: string
internalApiUrl: string
flowId: string
flowVersionId: string
}
export const createFlowsContext = ({ engineToken, internalApiUrl, flowId, flowVersionId }: CreateFlowsServiceParams): FlowsContext => {
return {
async list(): Promise<SeekPage<PopulatedFlow>> {
const response = await fetch(`${internalApiUrl}v1/engine/populated-flows`, {
method: 'GET',
headers: {
'Content-Type': 'application/json',
Authorization: `Bearer ${engineToken}`,
},
})
return response.json()
},
current: {
id: flowId,
version: {
id: flowVersionId,
},
},
}
}