בירור | הרצת כמה סקריפטים במקביל

[עידו300]

טוב, אל תבהלו זה הקוד המלא.
ניסיתי לשנות אותו לפי הקוספט של זה
app.use('/login', login);
אבל יש בו קצת בעיה כי הוא משתמש בראוטר אחר או משהו כזה.
אשמח לעזרה איך להתאים אותו למה שהסברתם לי, שאוכל לדעת לטפל בשאר.

import express from 'express';
import { YemotRouter } from 'yemot-router2';
import { fileURLToPath } from 'url';
import process from 'process';
import { streets, regions, citys } from './streets_data.js';
import {
    chooseBuyorrent,
    chooseCity,
    chooseBetShemesh,
    chooseregion,
    choosestreet,
    choosenumber,
    choosefloor,
    chooseroom,
    chooseprice,
    choosephone
} from './validate_func.js';

export const app = express();

export const router = YemotRouter({
    printLog: true,
    uncaughtErrorHandler: (error, call) => {
        console.log(`Uncaught error in ${call.req.path} from ${call.phone}. error stack: ${error.stack}`);
        return call.id_list_message([{ type: 'text', data: 'אירעה שגיאה' }]);
    }
});

router.events.on('call_hangup', call => console.log(`[example.js] call ${call.callId} was hangup`));
router.events.on('call_continue', call => console.log(`[example.js] call ${call.callId} was continue`));
router.events.on('new_call', call => console.log(`[example.js] new call ${call.callId} from ${call.phone}`));

/**
 * @typedef {Object} AdData
 * @property {number} id
 * @property {string} buyorrent
 * @property {string} city
 * @property {string} betShemesh
 * @property {string} region
 * @property {string} street
 * @property {number} number
 * @property {number} floor
 * @property {number} room
 * @property {number} price
 * @property {string} phone
 * @property {string} phone2
 * @property {string} created_at
 */

/**
 * @typedef {Object} AdResponse
 * @property {string} status
 * @property {string} [message]
 * @property {AdData[]} [data]
 */

/** @param {import('yemot-router2').Call} call */
async function callHandler(call) {
    console.log("מכין בקשה");
    let phone = call.ApiPhone.replace("+972", "0");
    const params = new URLSearchParams({ phone });
    const url = `https://stamandsefer.co.il/appart/new/getSellerAds.php?${params}`;
    console.log(url);
    console.log("שולח בקשה");

    /** @type {AdResponse} */
    let response;

    try {
        const res = await fetch(url, { method: 'GET' });
        if (!res.ok) throw new Error(`שגיאת HTTP: ${res.status} ${res.statusText}`);

        try {
            response = await res.json();
        } catch {
            throw new Error("התשובה שהתקבלה אינה JSON תקין");
        }

        console.log('Response:', response);

        if (response.status !== "success" || !Array.isArray(response?.data)) {
            console.error('שגיאת שרת:', response);
            call.id_list_message([{ type: "text", data: "אירעה שגיאה בעת שמירת המודעה" }]);
            return;
        }
    } catch (err) {
        console.error('שגיאה בשליחת הבקשה:', err.message);
        call.id_list_message([{ type: "text", data: "שגיאה בשליחת המודעה" }]);
        return;
    }

    // עיבוד מודעות
    for (const adBase of response.data) {
        let ad = `המודעה היא דירה ל${adBase.buyorrent} ב${adBase.city}`;
        if (adBase.city === "בית שמש") ad += `ה${adBase.betShemesh}`;
        ad += ` בשכונה ${adBase.region} ברחוב ${adBase.street} מספר ${adBase.number} קומה ${adBase.floor} ${adBase.room} חדרים במחיר ${adBase.price} טלפון ליצירת קשר ${adBase.phone}`;
        if (adBase.phone2) ad += ` טלפון נוסף ${adBase.phone2}`;
        ad = ad.replace(".5", " וחצי").replace("-", "מינוס ").replace(".0","");
        console.log(ad);

        let ok = false;
        for (let i = 0; i < 3 && !ok; i++) {
            let toDo = await call.read(
                [{ type: 'text', data: `${ad}  לעריכת המודעה הקש 1 למחיקה 2 ולמודעה הבאה 3` }],
                'tap',
                { max_digits: 1, min_digits: 1, typing_playback_mode: "No", digits_allowed: [1, 2, 3] }
            );

            if (toDo === "1") {
              ok =  await editAd(call, adBase);
            } else if (toDo === "2" && "1" === await call.read(
                [{ type: 'text', data: `האם אתה בטוח שברצונך למחוק את המודעה 1 לאישור 2 לביטול` }],
                'tap',
                { max_digits: 1, min_digits: 1, typing_playback_mode: "No", digits_allowed: [1, 2] }
            )) {
                await deleteAd(call, adBase, phone);
                ok = true;
            } else if (toDo === "3") {
                ok = true;
            } else {
                if (i === 2) call.id_list_message([{ type: 'text', data: 'ניסיון לא חוקי, שלום ולהתראות' }]);
            }
        }
    }
}

router.get('/', callHandler);
app.use(express.urlencoded({ extended: true }));
app.use('/manageSellersAd', router);

const port = 3000;
const isMain = process.argv[1] === fileURLToPath(import.meta.url);
if (isMain) {
    app.listen(port, () => console.log(`example yemot-router2 running on port ${port}`));
}

/**********************************************************************/
/** @param {import('yemot-router2').Call} call @param {AdData} adBase */
async function editAd(call, adBase) {
    let { city, betShemesh, region, street, number, floor, room, price, phone, phone2 } = adBase;
    let paramsToChange = {};
    let ad="";
    do {
        const choice = await call.read(
            [{ type: 'text', data: 'לעריכת עיר שכונה ורחוב הקש 1, בנין הקש 2, קומה הקש 3 מספר חדרים הקש 4 מחיר הקש 5 טלפון ליצירת קשר הקש 6 וטלפון נוסף 7' }],
            'tap',
            { max_digits: 1, min_digits: 1, typing_playback_mode: "No", digits_allowed: [1, 2, 3, 4, 5, 6, 7] }
        );

        switch (choice) {
            case "1":
                city = await chooseCity(call);
                betShemesh = city === "בית שמש" ? await chooseBetShemesh(call) : "";
                region = await chooseregion(call, betShemesh, city);
                street = await choosestreet(call, city);
                Object.assign(paramsToChange, { city, betShemesh, region, street });
                break;
            case "2": number = await choosenumber(call); paramsToChange.number = number; break;
            case "3": floor = await choosefloor(call); paramsToChange.floor = floor; break;
            case "4": room = await chooseroom(call); paramsToChange.room = room; break;
            case "5": price = await chooseprice(call); paramsToChange.price = price; break;
            case "6": phone = await choosephone(call); paramsToChange.newPhone = phone; break;
            case "7": phone2 = await choosephone(call); paramsToChange.phone2 = phone2; break;
            default: return false;
        }

        ad = `המודעה היא דירה ל${adBase.buyorrent} ב${city}`;
        if (city === "בית שמש") ad += `ה${betShemesh}`;
        ad += ` בשכונה ${region} ברחוב ${street} מספר ${number} קומה ${floor} ${room} חדרים במחיר ${price} טלפון ליצירת קשר ${phone}`;
        if (phone2) ad += ` טלפון נוסף ${phone2}`;
        ad = ad.replace(".5", " וחצי").replace("-", "מינוס ").replace(".0","");
        console.log(ad);

    } while (await call.read(
        [{ type: 'text', data: `${ad} , לעריכת המודעה הקש 1 לפרסום ושמירה 2` }],
        'tap',
        { max_digits: 1, min_digits: 1, typing_playback_mode: "No", digits_allowed: [1, 2] }
    ) !== "2");

    paramsToChange.phone = call.ApiPhone.replace("+972", "0");
    paramsToChange.adId = adBase.id;
    const params = new URLSearchParams(paramsToChange);
    const url = `https://stamandsefer.co.il/appart/new/updateAd.php?${params}`;
    console.log("שולח בקשה");

    try {
        const res = await fetch(url, { method: 'GET' });
        if (!res.ok) throw new Error(`שגיאת HTTP: ${res.status} ${res.statusText}`);
        const response = await res.json();
        console.log('Response:', response);

        if (response.status !== "success") {
            call.id_list_message([{ type: "text", data: "אירעה שגיאה בעת שמירת המודעה" }]);
            console.error('שגיאת שרת:', response);
        }
        return true;
    } catch (err) {
        console.error('שגיאה בשליחת הבקשה:', err.message);
        call.id_list_message([{ type: "text", data: "שגיאה בשליחת המודעה" }]);
    }
}

/**********************************************************************/
/** @param {import('yemot-router2').Call} call @param {AdData} adBase @param {string} phone */
async function deleteAd(call, adBase, phone) {
    const params = new URLSearchParams({ phone, adId: String(adBase.id) });
    const url = `https://stamandsefer.co.il/appart/new/deleteAd.php?${params}`;
    console.log("שולח בקשה");

    try {
        const res = await fetch(url, { method: 'GET' });
        if (!res.ok) throw new Error(`שגיאת HTTP: ${res.status} ${res.statusText}`);
        const response = await res.json();
        console.log('Response:', response);

        if (response.status !== "success") {
            call.id_list_message([{ type: "text", data: "אירעה שגיאה בעת מחיקת המודעה" }]);
            console.error('שגיאת שרת:', response);
        }
    } catch (err) {
        console.error('שגיאה בשליחת הבקשה:', err.message);
        call.id_list_message([{ type: "text", data: "שגיאה בשליחת המודעה" }]);
    }
}

אשמח כאן גם ל @צדיק-תמים (אתה אחראי על הספריה לא?)

[צדיק תמים]

@עידו300 כתב בבירור | הרצת כמה סקריפטים במקביל:

gpt מתעקש על הדרך שהוא כתב.
תראו https://chatgpt.com/share/68f7352d-e9cc-8000-8072-3de179fe6480

אתה צריך לצאת מהראש של סקריפטים בPHP ולעבור לראש של אפליקציה שרצה קבוע, זה לא שהראוטר "מריץ קובץ" JS לפי הנתיב (לא ברור למה נראה לך שזה טוחן מעבד, להיפך PHP הרבה יותר כבד, ואכמ"ל)
ממליץ על https://did.li/zg9Hw

יש לך אגב בתחומים הרבה שרשורים דומים של מתכנתים שעברו מPHP לנוד והתקשו להבין את הגישה השונה

[עידו300]

@צדיק-תמים כתב בבירור | הרצת כמה סקריפטים במקביל:

(לא ברור למה נראה לך שזה טוחן מעבד, להיפך PHP הרבה יותר כבד, ואכמ"ל)

אני רואה איך המעבד מגיע ל100%...

@צדיק-תמים כתב בבירור | הרצת כמה סקריפטים במקביל:

אתה צריך לצאת מהראש של סקריפטים בPHP ולעבור לראש של אפליקציה שרצה קבוע

אני בעד, במה זה מתבטא? במה זה שונה?

תכלס, איך משנים את זה? מה עושים הלאה?

יש לי עוד שאלה על הספריה המדהימה הזאת (לגבי השמעת call.id_list_message והמשך ביצוע פעולות), אשאל פה או שאפתח שרשור חדש?

[צדיק תמים]

@עידו300 קודם כל תראה את הפלייליסט ששלחתי, לפחות את פרקים 1-5
שאלות ספציפיות על הספריה בנושא נפרד כמובן

@עידו300 כתב בבירור | הרצת כמה סקריפטים במקביל:

אני רואה איך המעבד מגיע ל100%...

זה לא תקין, מה הקוד שלך עושה?

[ע"ה דכו"ע]

@עידו300 כתב בבירור | הרצת כמה סקריפטים במקביל:

אני רואה איך המעבד מגיע ל100%...

איזה מעבד יש לך בשרת? זה נשמע שאתה במבצע חיסכון

[עידו300]

בעז"ה אבל @צדיק-תמים קריטי לי עכשיו החלק של app.use('/login', login);
שבספריה א"א בגלל שמשתמשים בראוטר אחר.
אשמח לעזרה (אני צריך להראות דוגמא ללקוח ולא יכול בגלל שלא מצליח לחבר את שתיהן ביחד ולא רוצה לפתוח עוד פורט למרות שבמקרה הצורך זה מה שאעשה..)

[צדיק תמים]

@ע-ה-דכו-ע כתב בבירור | הרצת כמה סקריפטים במקביל:

@עידו300 כתב בבירור | הרצת כמה סקריפטים במקביל:

אני רואה איך המעבד מגיע ל100%...

כמה ליבות מעבד יש לך בשרת? זה נשמע שאתה במבצע חיסכון

זה לא ממש משנה כמה ליבות כי נוד משתמש רק באחת...
אבל בהנחה שהוא לא עושה חישובים כבדים זה ממש לא תקין

[עידו300]

@ע-ה-דכו-ע יש לי 2 ליבות ואני רואה עכשיו שזה על 100% למרות שכלום לא בשימוש

[עידו300]

@צדיק-תמים כתב בבירור | הרצת כמה סקריפטים במקביל:

אבל בהנחה שהוא לא עושה חישובים כבדים זה ממש לא תקין

לא יודע אם חישובים כבדים אבל עושה דברים.

[עידו300]

@צדיק-תמים כתב בבירור | הרצת כמה סקריפטים במקביל:

זה לא ממש משנה כמה ליבות כי נוד משתמש רק באחת...

ובדיוק זו הבעיה...

בכל מקרה פתחתי עוד פורט 1... לא היתה ברירה, אם יש למישהו פתרון, אשמח.

תודה

[צדיק תמים]

@עידו300 אתה רוצה לפתור את הצורך הנקודתי אבל בלי ללמוד איך זה עובד? זכותך אבל זה לא מתאים לי, אם תלמד איך עובדת האסינכרוניות של נוד ואיך להשתמש באקספרס אשמח לענות על שאלות

@עידו300 כתב בבירור | הרצת כמה סקריפטים במקביל:

ובדיוק זו הבעיה...

זה לא הבעיה

[עידו300]

@צדיק-תמים חחח, זה יפה שיש לך כאלו עקרונות, גם אני לא אוהב לעשות העתק-הדבק, אבל לפעמים צריך SOS פתרון ואח"כ יהיה זמן ללמוד את הנושא...

בכל מקרה עכשיו יש קשיים אחרים, הPM2 לא מריץ את זה, זאת אומרת כתוב אונליין אבל תכלס שניגשים לכתובת "וְאֵין קוֹל וְאֵין עֹנֶה וְאֵין קָשֶׁב".
כשמריצים כרגיל עם node *.js הכל טוב, אבל עם הPM2 לא... וגם כשמוסיפים & זה לא גורם לו להשאר אחרי שהטרמינל נסגר.

אני כבר משתגע מזה, בושות מהלקוח, טוב שהוא עוד לא התקשר לקו לבדוק.

[עידו300]

השבתתי את זה

const isMain = process.argv[1] === fileURLToPath(import.meta.url);
if (isMain) {
}

ועכשיו זה עובד ב"ה

[עידו300]

@צדיק-תמים כתב בבירור | הרצת כמה סקריפטים במקביל:

ממליץ על https://did.li/zg9Hw

התחלתי לראות, מאוד טוב אבל מניח ידע מוקדם, הוא לא מסביר את הבסיס של מה שעשה שם, שזה מה שחסר לי.
הוא מניח שכולם יודעים מה זה midlleware ומה זה app.get וapp.use מה זה ראוט.

[צדיק תמים]

@עידו300 באיזה אחד אתה אוחז?
אני למדתי מזה בזמנו בלי ידע קודם, אז נראה לי שאתה פשוט צריך להמשיך

[עידו300]

@צדיק-תמים עכשיו צריך להתחיל את ה5

[עידו300]

@צדיק-תמים יצא לך להשתמש עם ראוטים רגילים בשילוב הספריה הזו? הכונה שהראוטר מעביר לעמוד אחר (מה שהוא עושה שם עם הimport מה controller), כאילו נראה לי משום מה שזה פשוט לא אמור לעבוד ביחד.

[צדיק תמים]

@עידו300 למה לא?

[עידו300]

@צדיק-תמים כתב בבירור | הרצת כמה סקריפטים במקביל:

@עידו300 למה לא?

אבל זה הראוטר של הספריה שלך, לא? לא של האקספרס

[צדיק תמים]

@עידו300 הראוטר של הספריה הוא עטיפה לראוטר של אקספרס
לדוגמה באותו פרויקט שהראיתי יש ראוטר נוסף רגיל של אקספרס עבור API רגיל