mirror of
https://github.com/sasjs/server.git
synced 2026-01-16 02:10:05 +00:00
feat(deploy): add route to deploy a file tree to @sasjs/server
This commit is contained in:
59
src/controllers/deploy.ts
Normal file
59
src/controllers/deploy.ts
Normal file
@@ -0,0 +1,59 @@
|
|||||||
|
import { MemberType, FolderMember, ServiceMember } from '../types'
|
||||||
|
import { getTmpFilesFolderPath } from '../utils/file'
|
||||||
|
import { createFolder, createFile, asyncForEach } from '@sasjs/utils'
|
||||||
|
import path from 'path'
|
||||||
|
|
||||||
|
export const createFileTree = async (
|
||||||
|
members: [FolderMember, ServiceMember],
|
||||||
|
parentFolders: string[] = []
|
||||||
|
) => {
|
||||||
|
const destinationPath = path.join(
|
||||||
|
getTmpFilesFolderPath(),
|
||||||
|
path.join(...parentFolders)
|
||||||
|
)
|
||||||
|
|
||||||
|
await asyncForEach(members, async (member: FolderMember | ServiceMember) => {
|
||||||
|
const name = member.name
|
||||||
|
|
||||||
|
if (member.type === MemberType.folder) {
|
||||||
|
await createFolder(path.join(destinationPath, name)).catch((err) =>
|
||||||
|
Promise.reject({ error: err, failedToCreate: name })
|
||||||
|
)
|
||||||
|
|
||||||
|
await createFileTree(member.members, [...parentFolders, name]).catch(
|
||||||
|
(err) => Promise.reject({ error: err, failedToCreate: name })
|
||||||
|
)
|
||||||
|
} else {
|
||||||
|
await createFile(path.join(destinationPath, name), member.code).catch(
|
||||||
|
(err) => Promise.reject({ error: err, failedToCreate: name })
|
||||||
|
)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
return Promise.resolve()
|
||||||
|
}
|
||||||
|
|
||||||
|
export const getTreeExample = () => ({
|
||||||
|
message: 'Provided not supported data format.',
|
||||||
|
supportedFormat: {
|
||||||
|
members: [
|
||||||
|
{
|
||||||
|
name: 'jobs',
|
||||||
|
type: 'folder',
|
||||||
|
members: [
|
||||||
|
{
|
||||||
|
name: 'extract',
|
||||||
|
type: 'folder',
|
||||||
|
members: [
|
||||||
|
{
|
||||||
|
name: 'makedata1',
|
||||||
|
type: 'service',
|
||||||
|
code: '%put Hello World!;'
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
})
|
||||||
@@ -1,46 +1,2 @@
|
|||||||
import { execFile } from 'child_process'
|
export * from './sas'
|
||||||
import { readFile, generateTimestamp, deleteFile } from '@sasjs/utils'
|
export * from './deploy'
|
||||||
import path from 'path'
|
|
||||||
import { ExecutionResult, RequestQuery } from '../types'
|
|
||||||
|
|
||||||
// FIXME
|
|
||||||
const sasExePath = `C:\\Program Files\\SASHome\\SASFoundation\\9.4\\sas.exe`
|
|
||||||
const baseSasLogPath = 'C:\\Users\\YuryShkoda\\projects\\server\\sas\\logs'
|
|
||||||
const baseSasCodePath = `sas`
|
|
||||||
|
|
||||||
// TODO: create utils isSasFile
|
|
||||||
|
|
||||||
export const processSas = async (
|
|
||||||
query: RequestQuery
|
|
||||||
): Promise<ExecutionResult> =>
|
|
||||||
new Promise((resolve, reject) => {
|
|
||||||
let sasCodePath = query._program
|
|
||||||
sasCodePath = path.join(baseSasCodePath, `${sasCodePath}.sas`)
|
|
||||||
sasCodePath = sasCodePath.replace(new RegExp('/', 'g'), path.sep)
|
|
||||||
|
|
||||||
const sasFile: string = sasCodePath.split(path.sep).pop() || 'default'
|
|
||||||
|
|
||||||
const sasLogPath = [
|
|
||||||
baseSasLogPath,
|
|
||||||
path.sep,
|
|
||||||
sasFile.replace(/\.sas/g, ''),
|
|
||||||
'-',
|
|
||||||
generateTimestamp(),
|
|
||||||
'.log'
|
|
||||||
].join('')
|
|
||||||
|
|
||||||
execFile(
|
|
||||||
sasExePath,
|
|
||||||
['-SYSIN', sasCodePath, '-log', sasLogPath, '-nosplash'],
|
|
||||||
async (err, _, stderr) => {
|
|
||||||
if (err) reject(err)
|
|
||||||
if (stderr) reject(stderr)
|
|
||||||
|
|
||||||
const log = await readFile(sasLogPath)
|
|
||||||
|
|
||||||
deleteFile(sasLogPath)
|
|
||||||
|
|
||||||
resolve({ log: log, logPath: sasLogPath })
|
|
||||||
}
|
|
||||||
)
|
|
||||||
})
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
import express from 'express'
|
import express from 'express'
|
||||||
import { processSas } from '../controllers'
|
import { processSas, createFileTree, getTreeExample } from '../controllers'
|
||||||
import { ExecutionResult, RequestQuery, isRequestQuery } from '../types'
|
import { ExecutionResult, isRequestQuery, isFileTree } from '../types'
|
||||||
|
|
||||||
const router = express.Router()
|
const router = express.Router()
|
||||||
|
|
||||||
@@ -20,4 +20,20 @@ router.get('/', async (req, res) => {
|
|||||||
<p>Log:</p> <textarea style="width: 100%; height: 100%">${result.log}</textarea>`)
|
<p>Log:</p> <textarea style="width: 100%; height: 100%">${result.log}</textarea>`)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
router.post('/deploy', async (req, res) => {
|
||||||
|
if (!isFileTree(req.body)) {
|
||||||
|
res.status(400).send(getTreeExample())
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
await createFileTree(req.body.members)
|
||||||
|
.then(() => {
|
||||||
|
res.status(200).send('Files deployed successfully to @sasjs/server.')
|
||||||
|
})
|
||||||
|
.catch((err) => {
|
||||||
|
res.status(500).send({ message: 'Deployment failed!', ...err })
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
export default router
|
export default router
|
||||||
|
|||||||
47
src/types/fileTree.ts
Normal file
47
src/types/fileTree.ts
Normal file
@@ -0,0 +1,47 @@
|
|||||||
|
export interface FileTree {
|
||||||
|
members: [FolderMember, ServiceMember]
|
||||||
|
}
|
||||||
|
|
||||||
|
export enum MemberType {
|
||||||
|
folder = 'folder',
|
||||||
|
service = 'service'
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface FolderMember {
|
||||||
|
name: string
|
||||||
|
type: MemberType.folder
|
||||||
|
members: [FolderMember, ServiceMember]
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface ServiceMember {
|
||||||
|
name: string
|
||||||
|
type: MemberType.service
|
||||||
|
code: string
|
||||||
|
}
|
||||||
|
|
||||||
|
export const isFileTree = (arg: any): arg is FileTree =>
|
||||||
|
arg &&
|
||||||
|
arg.members &&
|
||||||
|
Array.isArray(arg.members) &&
|
||||||
|
arg.members.filter(
|
||||||
|
(member: FolderMember | ServiceMember) =>
|
||||||
|
!isFolderMember(member) && !isServiceMember(member)
|
||||||
|
).length === 0
|
||||||
|
|
||||||
|
const isFolderMember = (arg: any): arg is FolderMember =>
|
||||||
|
arg &&
|
||||||
|
typeof arg.name === 'string' &&
|
||||||
|
arg.type === MemberType.folder &&
|
||||||
|
arg.members &&
|
||||||
|
Array.isArray(arg.members) &&
|
||||||
|
arg.members.filter(
|
||||||
|
(member: FolderMember | ServiceMember) =>
|
||||||
|
!isFolderMember(member) && !isServiceMember(member)
|
||||||
|
).length === 0
|
||||||
|
|
||||||
|
const isServiceMember = (arg: any): arg is ServiceMember =>
|
||||||
|
arg &&
|
||||||
|
typeof arg.name === 'string' &&
|
||||||
|
arg.type === MemberType.service &&
|
||||||
|
arg.code &&
|
||||||
|
typeof arg.code === 'string'
|
||||||
@@ -1,2 +1,3 @@
|
|||||||
export * from './sas'
|
export * from './sas'
|
||||||
export * from './request'
|
export * from './request'
|
||||||
|
export * from './fileTree'
|
||||||
|
|||||||
8
src/utils/file.ts
Normal file
8
src/utils/file.ts
Normal file
@@ -0,0 +1,8 @@
|
|||||||
|
import path from 'path'
|
||||||
|
import { getRealPath } from '@sasjs/utils'
|
||||||
|
|
||||||
|
export const getTmpFolderPath = () =>
|
||||||
|
getRealPath(path.join(__dirname, '..', '..', 'tmp'))
|
||||||
|
|
||||||
|
export const getTmpFilesFolderPath = () =>
|
||||||
|
path.join(getTmpFolderPath(), 'files')
|
||||||
Reference in New Issue
Block a user