Default page

Your IP: 216.73.216.134
Server IP: 68.65.123.197
Server: Linux premium49.web-hosting.com 4.18.0-553.54.1.lve.el8.x86_64 #1 SMP Wed Jun 4 13:01:13 UTC 2025 x86_64
Server Software: LiteSpeed
PHP Version: 8.2.29
Buat File | Buat Folder
Dir : ~/home/smarbgfw/whatsapp.smartech-hub.com/routes/
View File Name : flow.js

const router = require('express').Router()
const { query } = require('../database/dbpromise.js')
const bcrypt = require('bcrypt')
const { sign } = require('jsonwebtoken')
const validateUser = require('../middlewares/user.js')
const moment = require('moment')
const { writeJsonToFile, readJsonFromFile, deleteFileIfExists } = require('../functions/function.js')
const randomstring = require('randomstring')
const { getSession, } = require('../middlewares/req.js')
const csv = require('csv-parser');
const mime = require('mime-types')
const { checkChatbotPlan, checkPlanExpiry } = require('../middlewares/planValidator.js')

// add a flow 
router.post('/add_flow', validateUser, checkPlanExpiry, checkChatbotPlan, async (req, res) => {
    try {
        console.log("Hey")
        const { title, nodes, edges, flowId } = req.body

        if (!title) {
            return req.json({ success: false, msg: "Please give a title to the flow" })
        }

        if (!nodes || !edges || !flowId) {
            return res.json({ success: false, msg: "Nodes and Edges are required" })
        }

        // checking existing 
        const checkExisted = await query(`SELECT * FROM flow WHERE flow_id = ?`, [flowId])

        const nodepath = `${__dirname}/../flow-json/nodes/${req.decode.uid}/${flowId}.json`
        const edgepath = `${__dirname}/../flow-json/edges/${req.decode.uid}/${flowId}.json`

        await writeJsonToFile(nodepath, nodes)
        await writeJsonToFile(edgepath, edges)

        if (checkExisted.length > 0) {
            await query(`UPDATE flow SEt title = ? WHERE flow_id = ?`, [title, flowId])
        } else {
            await query(`INSERT INTO flow (uid, flow_id, title) VALUES (?,?,?)`, [
                req.decode.uid,
                flowId,
                title
            ])
        }

        res.json({ success: true, msg: "Flow was saved" })

    } catch (err) {
        res.json({ success: false, msg: "something went wrong", err })
        console.log(err)
    }
})

// get my flows 
router.get('/get_mine', validateUser, async (req, res) => {
    try {
        const data = await query(`SELECT * FROM flow WHERE uid = ?`, [req.decode.uid])
        res.json({ data, success: true })
    } catch (err) {
        res.json({ success: false, msg: "something went wrong", err })
        console.log(err)
    }
})

// get flow using flow id 
router.post("/get_by_flow_id", validateUser, async (req, res) => {
    try {
        const { flowId } = req.body

        if (!flowId) {
            return res.json({ success: false, msg: "Flow id missing" })
        }

        const nodePath = `${__dirname}/../flow-json/nodes/${req.decode.uid}/${flowId}.json`
        const edgePath = `${__dirname}/../flow-json/edges/${req.decode.uid}/${flowId}.json`

        const nodes = readJsonFromFile(nodePath)
        const edges = readJsonFromFile(edgePath)

        res.json({ nodes, edges, success: true })

    } catch (err) {
        res.json({ success: false, msg: "something went wrong" })
        console.log(err)
    }
})

// del a flow 
router.post('/del_flow', validateUser, async (req, res) => {
    try {
        const { flow_id } = req.body

        await query(`DELETE FROM flow WHERE flow_id = ?`, [flow_id])

        const nodePath = `${__dirname}/../flow-json/nodes/${req.decode.uid}/${flow_id}.json`
        const edgePath = `${__dirname}/../flow-json/edges/${req.decode.uid}/${flow_id}.json`

        deleteFileIfExists(nodePath)
        deleteFileIfExists(edgePath)

        res.json({ success: true, msg: "Flow was deleted" })

    } catch (err) {
        res.json({ success: false, msg: "something went wrong" })
        console.log(err)
    }
})

module.exports = router