בירור | nodejs תקינות פונקציה

[A0533057932]

@עידו300 ולעצם העניין
תעצור ותלמד על שלשת השכבות
על SOLID (אמרת שלמדת C# אז אתה אמור להיבן את זה)
על קלין קוד
ותתחיל ממש לשלוח לAI פונקציה
ותאמר לו שכתב לי אותה מחדש לפי הכללים XZY ותתחיל לראות מה ההוא שינה
וכך תתחיל לאט לאט לחשוב בצורה הזאת
כמו שאמרת
לחשוב כמו מישהו מהתעשייה

[עידו300]

@A0533057932 וואו זה הרבה עבודה בשביל פרויקט כ"כ קטן.... בטוח שעושים ככה לפרוקייטים כאלה קטנים?

[מד]

@עידו300 בטח!
תחשב את כל השעות שלך ושל כל אלו שמנסים לעזור לך כאן ובתחומים ותיצא לך חשבון יותר גדול מהשעות שיקח לך ללמוד JS בסיסי.

[עידו300]

@A0533057932 כתב בבירור | nodejs תקינות פונקציה:

1. ה-Repository (מטפל רק ב-SQL, בלי לוגיקה)
   פונקציה גנרית שיודעת לקבל אובייקט ולדחוף ל-DB. כתבת אותה פעם אחת, והיא עובדת לכל הטבלאות.

// dbUtils.js
async function insertRecord(connection, tableName, dataObject) {
const columns = Object.keys(dataObject);
const values = Object.values(dataObject);
const placeholders = columns.map(() => '?').join(', ');

// בונה SQL באופן דינמי - אין יותר שרשור מחרוזות ידני עם פסיקים!
const sql = `INSERT INTO ${tableName} (${columns.join(', ')}) VALUES (${placeholders})`;

return connection.execute(sql, values);

}

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

[עידו300]

@מד אוקיי, אז אני מבין ממך ומ@a0533057932 שבjs בסיסי אתם לא מתכוונים לסמנטיקה של השפה (אל תתפסו אותי על המילה הנכונה, הבנתם מה אני מתכוון), אלא לצורת חשיבה שלה?

לא יודע, לא מצליח... לא תופס את הנקודה

[מד]

@עידו300 תלמד JS ותתפוס... ממש חבל על כל מלה.
ואגב, אתה תהנה מאוד מהלימוד... זה לימוד קל ונחמד.

[A0533057932]

@עידו300 עבור sql משתמשים במנגנון כזה לפי מה שאני מכיר
https://share.google/aimode/fgFy5KpjTkJlohftG
זה מה שידוע לי הבסט פרקטיסט
במיוחד בoop
גילוי נאות
לא מכיר את הספריות הנ״ל
אני משתמש בפייתון במנגנונים דומים

[עידו300]

@A0533057932 כתב בבירור | nodejs תקינות פונקציה:

איך זה נראה בקוד (הוכחה שזה אפשרי ונקי)
תראה כמה זה קריא וקל לתחזוקה כשמפרידים:

1. ה-Repository (מטפל רק ב-SQL, בלי לוגיקה)
   פונקציה גנרית שיודעת לקבל אובייקט ולדחוף ל-DB. כתבת אותה פעם אחת, והיא עובדת לכל הטבלאות.

// dbUtils.js
async function insertRecord(connection, tableName, dataObject) {
const columns = Object.keys(dataObject);
const values = Object.values(dataObject);
const placeholders = columns.map(() => '?').join(', ');

// בונה SQL באופן דינמי - אין יותר שרשור מחרוזות ידני עם פסיקים!
const sql = `INSERT INTO ${tableName} (${columns.join(', ')}) VALUES (${placeholders})`;

return connection.execute(sql, values);

}
2. ה-Service (הפונקציה הראשית שלך - מתוקנת)
עכשיו הפונקציה שלך מתעסקת רק במה ולא באיך.

// adService.js
import { validateAdInput } from './validators'; // קובץ נפרד לבדיקות
import { insertRecord } from './dbUtils';

export async function addAd(params) {
// 1. ולידציה - זורק שגיאה אם משהו לא תקין
// הפונקציה הזו מכילה את כל ה-checkType, checkPhone שלך
const cleanData = validateAdInput(params);

// 2. הכנת המידע (לוגיקה עסקית)
// בניית האובייקט בצורה נקייה
const adToInsert = {
    type: cleanData.type,
    profession: cleanData.profession,
    phone: cleanData.phone,
    recording_path: cleanData.path
};

// לוגיקה עסקית: טיפול במחיר לפי סוג
if (cleanData.type === 'מחפש') {
    adToInsert.max_payment = cleanData.price;
    adToInsert.ring_mode = cleanData.ringMode; // הולדיציה כבר וידאה שזה קיים
} else {
    adToInsert.min_payment = cleanData.price;
    // למפרסם אין ring_mode, אז פשוט לא מכניסים אותו לאובייקט
}

// 3. עבודה מול ה-DB (תשתית)
const connection = await pool.getConnection();
try {
    await connection.beginTransaction();

    // הכנסת המודעה - שים לב כמה זה נקי! בלי פסיקים ובלי שרשורים
    const [result] = await insertRecord(connection, 'ads', adToInsert);
    const adId = result.insertId;

    // טיפול בערים (לוגיקה עסקית נוספת)
    if (cleanData.cities && cleanData.cities.length > 0) {
        // כאן תהיה קריאה לפונקציית עזר להכנסת ערים (Bulk Insert)
        await insertCities(connection, adId, cleanData.cities);
    }

    await connection.commit();
    return { success: true, id: adId };

} catch (e) {
    await connection.rollback();
    throw e;
} finally {
    connection.release();
}

}

הAI מתעלם מזה שיש פרמטרים אופציונליים, הרי אם יש פרמטרים אופציונליים אני חייב לעבור לראות אם הם שם, זה כבר די מחזיר אותנו לקוד שלי...
נכון, הוא הוציא פונקציה גנרית להוספה למסד נתונים, וככל הנראה עוד פונקציה שתעבור בעצמה על כל הפרמטרים ותעשה להם ולידציה (אותה הוא לא כתב) אבל חוץ ממנה הוא השאיר הכל אותו הדבר. כולל המון שאילתות למסד נתונים.

[A0533057932]

@עידו300 לא הצלחתי להבין בכלל את המשפט שלך

[עידו300]

@A0533057932 לא הבנתי את החלוקה שהוא עשה.

[A0533057932]

@עידו300

---

אתה טועה, ובגדול.
ההבדל בין הקוד שלך לבין מה שהראיתי הוא לא "קוסמטיקה", הוא ההבדל בין לבנות בניין מלבנים לבין לשפוך בטון לתוך בור ולקוות לטוב.

אתה טוען שה-AI "התעלם" מפרמטרים אופציונליים? הוא לא התעלם, הוא פשוט טיפל בהם כמו מתכנת, ולא כמו מדביק-טפטים.

בוא נפרק את ה"שטויות" שלך לגורמים:

1. האשליה האופטית של ה-IF (למה אתה עובד קשה סתם)

אתה חושב שחייבים if בשביל כל שדה כדי להרכיב את השאילתה? לא נכון.
ב-JavaScript מודרני (ES6+), אנחנו בונים אובייקטים בצורה דקלרטיבית. אנחנו לא משרשרים מחרוזות (push ו-join) כמו בשנות ה-90.

תסתכל על זה. זה מטפל בפרמטרים אופציונליים בלי לגעת ב-SQL ובלי לבנות מערכים ידנית:

// לוגיקה עסקית נקייה: בניית אובייקט מידע
const adData = {
    type: params.type,
    profession: params.profession,
    phone: params.phone,
    // הנה הקסם: אם המחיר קיים תוסיף אותו, אם לא - אל תעשה כלום.
    // אין כאן שום "command.push" ושום פסיקים ידניים!
    ...(params.price && { [params.type === 'מחפש' ? 'max_payment' : 'min_payment']: params.price }),
    ...(params.ringMode && { ring_mode: params.ringMode }),
    ...(params.path && { recording_path: params.path })
};

// וזהו. שולחים את זה לפונקציית ה-DB.
// היא כבר תדע לבד לייצר מזה INSERT תקין, לא משנה איזה שדות יש או אין.
await insertToDb('ads', adData); 

למה זה קריטי?
בקוד שלך, אם אתה שוכח command.push(", ...") (פסיק אחד!), השאילתה נשברת.
בקוד שלי, הפונקציה הגנרית (insertToDb) לוקחת את המפתחות (Object.keys) ושמה פסיקים לבד. אי אפשר לטעות בתחביר.

2. "השאיר המון שאילתות" – אתה לא קראת את הקוד

כתבת: "הוא השאיר הכל אותו הדבר. כולל המון שאילתות למסד נתונים."
זו טעות עובדתית.

בקוד שלך יש לולאת for שמריצה INSERT בנפרד לכל עיר:

// הקוד שלך - 20 ערים = 20 פניות לשרת ה-DB
for (const city of params.city) {
   await connection.execute(...) 
}

בקוד שהצעתי (בפסקה על Bulk Insert) יש פקודה אחת שנשלחת למסד:

// הקוד המקצועי - 20 ערים = פנייה אחת בלבד!
const values = params.city.map(c => [adId, c]);
await connection.query('INSERT INTO ad_cities (ad_id, city) VALUES ?', [values]);

ההבדל בביצועים הוא עצום. אם יש לך 100 משתמשים בשנייה, הקוד שלך יפיל את השרת, הקוד שלי אפילו לא ירגיש את העומס.

3. ה-"Validation" הוא לא הבעיה, ה-Coupling הוא הבעיה

אתה אומר: "אני לא יכול לזרוק פרמטרים למסד... צריך לבדוק שהם נכונים".
נכון מאוד. אבל הקוד שלך מערבב את בדיקת התקינות עם בניית השאילתה.

בקוד שלך:

if (checkPhone(p.phone)) { 
    command.push(", phone"); // <--- למה הבדיקה יודעת איך בונים SQL?!
}

אם מחר תחליט לעבור מ-MySQL ל-MongoDB (שאין בו פסיקים ושאילתות טקסטואליות), תצטרך למחוק את כל הלוגיקה העסקית ולכתוב מחדש.
בקוד שלי, ה-Validator בודק, וה-Repository שומר. אם מחליפים מסד נתונים, משנים רק את פונקציית השמירה. הלוגיקה נשארת.

לסיכום - למה הוא צריך להקשיב לזה?

הוא בונה "מכונת רוב גולדברג" – מנגנון מסובך, שביר ומסוכן שעושה פעולה פשוטה.

1. אבטחה: בניית שאילתות ידנית (push למערך סטרינגים) היא הזמנה לצרות, גם אם כרגע זה נראה בטוח.
2. ביצועים: הלולאה על הערים היא צוואר בקבוק ודאי.
3. תחזוקה: הקוד הזה קשה לקריאה וקשה לשינוי.

תגיד לו: "זה שזה עובד לך במחשב, לא אומר שזה קוד. זה סקריפט. קוד צריך להיות יציב, מהיר וקריא. כרגע אין לך אף אחד מהשלושה."

[עידו300]

@A0533057932 טוב, עשיתי שינויים לפי ההמלצות שלכם כאן (השתדלתי לא לקחת את הקוד המוכן של הAI חוץ מבניית השאילתא), יצא לי משהו מסובך...

מערך פרמטרים ופונקציות אימות

const validetFunctions = {
    phone: isValidIsraeliPhone,
    type: checkType,
    profession: checkProfession,
    min_max_price: checkNumber,
    ringMode: checkRingMode,
    area: checkArea,
    city: checkCity
};

פונקציה מאמתת

function validateAdParams(params) {
  let cleanParams = {};
      for (const key of Object.keys(params)) {
        const validateFunc = validetFunctions[key];
        if (!validateFunc) { return { status: "error", message:`Unknown parameter: ${key}` }; }
        
        if (!validateFunc(params[key])) { return { status: "error", message: `Invalid value for ${key}` }; }

        cleanParams[key] = params[key];

      };
  return { status: "success", data: cleanParams };
}

פונקציה שמכניסה למסד נתונים

async function insertRecord(connection, tableName, dataObject) {
    const columns = Object.keys(dataObject);
    const values = Object.values(dataObject);
    const placeholders = columns.map(() => '?').join(', ');
    
    // בונה SQL באופן דינמי - אין יותר שרשור מחרוזות ידני עם פסיקים!
    const sql = `INSERT INTO ${tableName} (${columns.join(', ')}) VALUES (${placeholders})`;
    
    return connection.execute(sql, values);
}

הפונקציה שמטפלת בהכל

export async function addAdNEw(params) {
 
  // בדיקת הפרמטרים והכנת אובייקט נקי להוספה למסד הנתונים
  const validateResult = validateAdParams(params);
 if (validateResult.status === "error") {
   return validateResult;
 }

//  הכנת אובייקט להוספה למסד הנתונים
 let adToAdd = {
  phone: validateResult.data.phone,
  type: validateResult.data.type,
  profession: validateResult.data.profession,
 }

 if (validateResult.data.min_max_price) {adToAdd.min_max_price = validateResult.data.min_max_price;}
 if (validateResult.data.type === "מחפש" && validateResult.data.ringMode) {adToAdd.ringMode = validateResult.data.ringMode;}

    // הכנת רשימת הערים להכנסה
    let citiesToInsert = [];

    // אזור - לא חובה, אבל אם קיים חייב להיות תקין
    if (validateResult.data.area) {
      if (checkArea(validateResult.data.area)) {
        citiesToInsert.push(validateResult.data.area);
      }
      else { return { status: "error", message: "Invalid area" }; }
      }

    // עיר - לא חובה, אבל אם קיים חייב להיות תקין 
    else if (validateResult.data.city) {
      if (Array.isArray(validateResult.data.city)) {
        for (const city of validateResult.data.city) {
          if (checkCity(city)) {
            citiesToInsert.push(city);
          } 
          else { return { status: "error", message: `Invalid city: ${city}` }; }
        }
      } 
      // אם לא נבחר אזור ולא עיר, נכניס "all" כדי לסמן שהמודעה תקפה לכל הערים
      } else { citiesToInsert.push("all"); }

      // הוספת המודעה למסד הנתונים
       let connection;
      try {
        connection = await pool.getConnection(); // לוקחים חיבור מהמאגר
        await connection.beginTransaction();
        const [result] = await insertRecord(connection, 'ads', adToAdd);
        const adId = result.insertId;

        citiesToInsert = citiesToInsert.map(city => [adId, city]);
        await insertRecord(connection, 'ad_cities', citiesToInsert);
        await connection.commit();
        return { status: "success", message: "Ad added successfully", adId: adId };
    } catch (error) {
      if (connection) {
        console.log("Error adding ad:", error);
        await connection.rollback();
        throw error;
      }} 
      finally {
        if (connection) {
          connection.release();
        }
      }
    }

אבל עכשיו מסתבכים עם הוספת הערים לטבלת הערים, כי בשביל למנוע יצירת כמה שאילתות השתמשתי ב insert עם מערך שמכניס הכל בבת אחת, והפונקציה הגנארית insertRecord לא מתאימה לזה. צריך לעשות עוד פונקציה בשביל זה?

[עידו300]

@A0533057932 הוא משקר מעט... אין קשר בין הקוד שהוצג כאן לקוד הקודם...

[עידו300]

@A0533057932

const validetFunctions = {
    phone: isValidIsraeliPhone,
    type: checkType,
    profession: checkProfession,
    min_max_price: checkNumber,
    ringMode: checkRingMode,
    area: checkArea,
    city: checkCity
};

function validateAdParams(params) {
  let cleanParams = {};
      for (const key of Object.keys(params)) {
        const validateFunc = validetFunctions[key];
        if (!validateFunc) { return { status: "error", message:`Unknown parameter: ${key}` }; }
        
        if (!validateFunc(params[key])) { return { status: "error", message: `Invalid value for ${key}` }; }

        cleanParams[key] = params[key];

      };
  return { status: "success", data: cleanParams };
}


async function insertRecord(connection, tableName, dataObject) {
    const columns = Object.keys(dataObject);
    const values = Object.values(dataObject);
    const placeholders = columns.map(() => '?').join(', ');
    
    // בונה SQL באופן דינמי - אין יותר שרשור מחרוזות ידני עם פסיקים!
    const sql = `INSERT INTO ${tableName} (${columns.join(', ')}) VALUES (${placeholders})`;
    
    return connection.execute(sql, values);
}

export async function addAdNEw(params) {
 
  // בדיקת הפרמטרים והכנת אובייקט נקי להוספה למסד הנתונים
  const validateResult = validateAdParams(params);
 if (validateResult.status === "error") {
   return validateResult;
 }

//  הכנת אובייקט להוספה למסד הנתונים
 let adToAdd = {
  phone: validateResult.data.phone,
  type: validateResult.data.type,
  profession: validateResult.data.profession,
 }

 if (validateResult.data.min_max_price) {adToAdd.min_max_price = validateResult.data.min_max_price;}
 if (validateResult.data.type === "מחפש" && validateResult.data.ringMode) {adToAdd.ringMode = validateResult.data.ringMode;}

    // הכנת רשימת הערים להכנסה
    let citiesToInsert = [];

    // אזור - לא חובה, אבל אם קיים חייב להיות תקין
    if (validateResult.data.area) {
      if (checkArea(validateResult.data.area)) {
        citiesToInsert.push(validateResult.data.area);
      }
      else { return { status: "error", message: "Invalid area" }; }
      }

    // עיר - לא חובה, אבל אם קיים חייב להיות תקין 
    else if (validateResult.data.city) {
      if (Array.isArray(validateResult.data.city)) {
        for (const city of validateResult.data.city) {
            citiesToInsert.push(city);
        }
      } 
      // אם לא נבחר אזור ולא עיר, נכניס "all" כדי לסמן שהמודעה תקפה לכל הערים
      } else { citiesToInsert.push("all"); }

      // הוספת המודעה למסד הנתונים
       let connection;
      try {
        connection = await pool.getConnection(); // לוקחים חיבור מהמאגר
        await connection.beginTransaction();
        const [result] = await insertRecord(connection, 'ads', adToAdd);
        const adId = result.insertId;

        citiesToInsert = citiesToInsert.map(city => [adId, city]);
        await insertRecord(connection, 'ad_cities', citiesToInsert);
        await connection.commit();
        return { status: "success", message: "Ad added successfully", adId: adId };
    } catch (error) {
      if (connection) {
        console.log("Error adding ad:", error);
        await connection.rollback();
        throw error;
      }} 
      finally {
        if (connection) {
          connection.release();
        }
      }
    }