STEINNI
112 lines
4.1 KiB
JavaScript
112 lines
4.1 KiB
JavaScript
import { authGuard } from '../authGuard.js'
|
||
import { uuidv7obj, UUID } from "uuidv7"
|
||
|
||
|
||
export const mappings = [
|
||
{ method: 'put', url:'/keyframes', handler: 'createKeyframe', middlewares: [authGuard]},
|
||
{ method: 'put', url:'/keyframes/:kfid', handler: 'renameKeyframe', middlewares: [authGuard]},
|
||
{ method: 'put', url:'/keyframes/:kfid/agents', handler: 'saveKeyframeAgents', middlewares: [authGuard]},
|
||
]
|
||
|
||
export const methods = {
|
||
async createKeyframe(req, res) {
|
||
const[isOk, payload, errors] = this.utils.validateMapObject(req.body,
|
||
{
|
||
'kfName': ((val, obj) => ( (typeof(val)=='string') && (new RegExp(/^[\w\s]{5,50}$/).test(val))) ),
|
||
'prevKfId': ((val, obj) => ( (typeof(val)=='undefined') || (this.utils.isValidUUIDV7(val)) ) ),
|
||
},
|
||
{
|
||
'kfName': 'kfName',
|
||
'prevKfId': 'prevKfId',
|
||
})
|
||
if(!isOk){
|
||
this.err(req, res,`Cannot create this keyframe ! `, `Validations errors for creating KF : ${errors.join(', ')}`, 400)
|
||
return
|
||
}
|
||
|
||
const newKfId = uuidv7obj()
|
||
await this.db.execute(`
|
||
INSERT INTO p42SIM.edited_keyframes
|
||
(ekf_uuid, ekf_name, ekf_prev_uuid)
|
||
VALUES (?, ?, ?)`,
|
||
[ Buffer.from(newKfId.bytes),
|
||
payload.kfName,
|
||
payload.prevKfId ? UUID.parse(payload.prevKfId).bytes : null
|
||
])
|
||
|
||
this.ok(req, res, { kfId: newKfId.toString() })
|
||
},
|
||
|
||
async renameKeyframe(req, res) {
|
||
const kfid = req.params.kfid
|
||
if(!this.utils.isValidUUIDV7(kfid)) {
|
||
this.err(req, res,`Cannot create Keyframe ! `, `Invalid Keyframe ID !`, 400)
|
||
return
|
||
}
|
||
const[isOk, payload, errors] = this.utils.validateMapObject(req.body,
|
||
{
|
||
'kfName': ((val, obj) => ( (typeof(val)=='string') && (new RegExp(/^\w{5,50}$/).test(val))) ),
|
||
},
|
||
{
|
||
'kfName': 'kfName',
|
||
})
|
||
if(!isOk){
|
||
this.err(req, res,`Cannot rename this keyframe ! `, `Validations errors for renaming KF : ${errors.join(', ')}`, 400)
|
||
return
|
||
}
|
||
|
||
await this.db.execute(`
|
||
UPDATE p42SIM.edited_keyframes
|
||
SET ekf_name = ?
|
||
WHERE (ekf_uuid = ?)`,
|
||
[payload.kfName, UUID.parse(kfid).bytes])
|
||
|
||
this.ok(req, res, { kfId: kfid })
|
||
},
|
||
|
||
async saveKeyframeAgents(req, res) {
|
||
const kfid = req.params.kfid
|
||
if(!this.utils.isValidUUIDV7(kfid)) {
|
||
this.err(req, res,`Cannot create Keyframe ! `, `Invalid Keyframe ID !`, 400)
|
||
return
|
||
}
|
||
|
||
const[isOk, payload, errors] = this.utils.validateMapArray(req.body,
|
||
{
|
||
'aid': ((val, obj) => (this.utils.isValidUUIDV7(val)) ),
|
||
'storeValues': ((val, obj) => (typeof(val)==='object') ),
|
||
'gpsValues': ((val, obj) => (typeof(val)==='object') ),
|
||
},
|
||
{ 'aid': 'aid',
|
||
'storeValues': 'storeValues',
|
||
'gpsValues': 'gpsValues',
|
||
}
|
||
)
|
||
if(!isOk){
|
||
this.err(req, res,`Cannot save this keyframe ! `, `Validations errors for saving KF : ${errors.join(', ')}`, 400)
|
||
return
|
||
}
|
||
|
||
await this.db.execute(`DELETE FROM p42SIM.edited_kf_store WHERE ekfs_ekf_uuid = ?`, [UUID.parse(kfid).bytes])
|
||
for(const entry of payload){
|
||
await this.db.execute(`
|
||
INSERT INTO p42SIM.edited_kf_store
|
||
(ekfs_ekf_uuid, ekfs_agent_id, ekfs_store_value, ekfs_gps_values)
|
||
VALUES (?, ?, ?, ?)`,
|
||
[ UUID.parse(kfid).bytes,
|
||
UUID.parse(entry.aid).bytes,
|
||
entry.storeValues,
|
||
entry.gpsValues
|
||
])
|
||
}
|
||
|
||
this.ok(req, res, { kfId: kfid })
|
||
},
|
||
|
||
/*
|
||
REMEMBER READ BACK UUIDS from BINARY :
|
||
const uuid = uuidStringify(rows[0].ekf_uuid)
|
||
*/
|
||
|
||
|
||
} |