Daniel Gak Anagrov
82547b1411
* add file import job to nextGen import endpoint * moved queue, organized code * add tests, minor refactoring
50 lines
1.5 KiB
TypeScript
50 lines
1.5 KiB
TypeScript
import { CreateAndStoreAppToken } from '@/modules/core/domain/tokens/operations'
|
|
import { DefaultAppIds } from '@/modules/auth/defaultApps'
|
|
import { Scopes, TIME, TIME_MS } from '@speckle/shared'
|
|
import { TokenResourceIdentifierType } from '@/test/graphql/generated/graphql'
|
|
import { getServerOrigin } from '@/modules/shared/helpers/envHelper'
|
|
import { scheduleJob } from '@/modules/fileuploads/queues/fileimports'
|
|
import { PushJobToFileImporter } from '@/modules/fileuploads/domain/operations'
|
|
|
|
const twentyMinutes = 20 * TIME.minute
|
|
|
|
export const pushJobToFileImporterFactory =
|
|
(deps: {
|
|
createAppToken: CreateAndStoreAppToken
|
|
getServerOrigin: typeof getServerOrigin
|
|
scheduleJob: typeof scheduleJob
|
|
}): PushJobToFileImporter =>
|
|
async ({ modelId, projectId, userId, fileType, blobId, jobId }): Promise<void> => {
|
|
const token = await deps.createAppToken({
|
|
appId: DefaultAppIds.Web,
|
|
name: `fileimport-${projectId}@${modelId}`,
|
|
userId,
|
|
scopes: [Scopes.Streams.Write],
|
|
lifespan: 2 * TIME_MS.hour,
|
|
limitResources: [
|
|
{
|
|
id: projectId,
|
|
type: TokenResourceIdentifierType.Project
|
|
}
|
|
]
|
|
})
|
|
|
|
const url = new URL(
|
|
`/projects/${projectId}/fileimporter/jobs/${jobId}/results`,
|
|
deps.getServerOrigin()
|
|
).toString()
|
|
|
|
await deps.scheduleJob({
|
|
type: 'file-import',
|
|
payload: {
|
|
token,
|
|
url,
|
|
modelId,
|
|
fileType,
|
|
projectId,
|
|
timeOutSeconds: twentyMinutes,
|
|
blobId
|
|
}
|
|
})
|
|
}
|