הקלטות במודול תור

[אז נדברו]

@שנאור כתב:

@אז-נדברו מה שאני יעלה את הקבצים בעצמי כול פעם ?

עם API זה יכול להתבצע אוטמטית.

[שנאור]

@אז-נדברו איך אני עושה את זה ?

[איל משולש]

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

[איל משולש]

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

Spoiler

/**
 * העתקת קבצים מתיקייה בימות המשיח – לתיקייה בימות ו/או לתיקייה בגוגל דרייב
 * ------------------------------------------------------------------------
 * הוראות:
 * 1. ב-script.google.com צור פרויקט חדש והדבק את כל הקוד.
 * 2. מלא את ההגדרות ב-CONFIG למטה.
 * 3. הרץ פעם אחת ידנית את הפונקציה copyFiles (כדי לאשר הרשאות ולבדוק).
 * 4. לתזמון: הרץ פעם אחת את createTrigger (או דרך "טריגרים" בתפריט השמאלי).
 */

const CONFIG = {
  // פרטי התחברות למערכת
  USERNAME: '07XXXXXXXX',
  PASSWORD: 'XXXXXX',

  // תיקיית המקור בימות (לדוגמה: '/1/2')
  SOURCE_PATH: '/1',

  // מצב: 'yemot' = העתקה לתיקייה בימות | 'drive' = שמירה בדרייב | 'both' = לשניהם
  MODE: 'both',

  // יעד בימות (רלוונטי ל-yemot / both). התיקייה צריכה להיות קיימת.
  YEMOT_TARGET_PATH: '/9',

  // מזהה תיקייה בדרייב (רלוונטי ל-drive / both)
  // מעתיקים מהכתובת: https://drive.google.com/drive/folders/<המזהה_כאן>
  DRIVE_FOLDER_ID: 'PUT_DRIVE_FOLDER_ID_HERE',

  // אילו סיומות להעתיק. מערך ריק [] = כל הקבצים
  EXTENSIONS: ['wav', 'mp3', 'ogg', 'txt', 'tts'],

  // כל כמה שעות להריץ (משמש את createTrigger)
  TRIGGER_EVERY_HOURS: 1
};

const API = 'https://www.call2all.co.il/ym/api/';
const MAX_RUNTIME_MS = 5 * 60 * 1000; // עצירה בטוחה לפני מגבלת 6 הדקות של גוגל

/* ===================== פונקציה ראשית ===================== */

function copyFiles() {
  const start = Date.now();
  const mode = String(CONFIG.MODE).toLowerCase();
  const toYemot = mode === 'yemot' || mode === 'both';
  const toDrive = mode === 'drive' || mode === 'both';
  if (!toYemot && !toDrive) throw new Error('MODE חייב להיות yemot / drive / both');

  const token = login_();
  try {
    const sourceDir = normalizePath_(CONFIG.SOURCE_PATH);
    const files = listFiles_(token, sourceDir);
    Logger.log('נמצאו ' + files.length + ' קבצים במקור ' + sourceDir);

    // רשימת קבצים קיימים ביעד – כדי לדלג עליהם
    let yemotTarget, yemotExisting, driveFolder, driveExisting;
    if (toYemot) {
      yemotTarget = normalizePath_(CONFIG.YEMOT_TARGET_PATH);
      if (yemotTarget === sourceDir) throw new Error('תיקיית היעד בימות זהה לתיקיית המקור');
      yemotExisting = new Set(listFiles_(token, yemotTarget, true).map(f => f.name));
    }
    if (toDrive) {
      driveFolder = DriveApp.getFolderById(CONFIG.DRIVE_FOLDER_ID);
      driveExisting = new Set();
      const it = driveFolder.getFiles();
      while (it.hasNext()) driveExisting.add(it.next().getName());
    }

    let copiedY = 0, copiedD = 0, skipped = 0, errors = 0;

    for (const f of files) {
      if (Date.now() - start > MAX_RUNTIME_MS) {
        Logger.log('הגעתי למגבלת זמן – ההמשך יתבצע בהרצה הבאה.');
        break;
      }
      const srcFile = joinPath_(sourceDir, f.name);

      // העתקה בתוך ימות
      if (toYemot) {
        if (yemotExisting.has(f.name)) {
          skipped++;
        } else {
          try {
            yemotCopy_(token, srcFile, joinPath_(yemotTarget, f.name));
            yemotExisting.add(f.name);
            copiedY++;
          } catch (e) {
            errors++;
            Logger.log('שגיאה בהעתקה בימות ' + srcFile + ': ' + e.message);
          }
        }
      }

      // הורדה ושמירה בדרייב
      if (toDrive) {
        if (driveExisting.has(f.name)) {
          skipped++;
        } else {
          try {
            const blob = downloadFile_(token, srcFile).setName(f.name);
            driveFolder.createFile(blob);
            driveExisting.add(f.name);
            copiedD++;
          } catch (e) {
            errors++;
            Logger.log('שגיאה בשמירה לדרייב ' + srcFile + ': ' + e.message);
          }
        }
      }
    }

    Logger.log('סיום: הועתקו לימות ' + copiedY + ', נשמרו בדרייב ' + copiedD +
               ', דולגו (קיימים) ' + skipped + ', שגיאות ' + errors);
  } finally {
    logout_(token);
  }
}

/* ===================== תזמון ===================== */

function createTrigger() {
  // מוחק טריגרים קודמים של הפונקציה כדי לא ליצור כפילויות
  ScriptApp.getProjectTriggers()
    .filter(t => t.getHandlerFunction() === 'copyFiles')
    .forEach(t => ScriptApp.deleteTrigger(t));

  ScriptApp.newTrigger('copyFiles')
    .timeBased()
    .everyHours(CONFIG.TRIGGER_EVERY_HOURS)
    .create();
  Logger.log('נוצר טריגר: כל ' + CONFIG.TRIGGER_EVERY_HOURS + ' שעות');
}

function removeTriggers() {
  ScriptApp.getProjectTriggers()
    .filter(t => t.getHandlerFunction() === 'copyFiles')
    .forEach(t => ScriptApp.deleteTrigger(t));
  Logger.log('הטריגרים נמחקו');
}

/* ===================== פונקציות API ===================== */

function login_() {
  const data = apiCall_('Login', { username: CONFIG.USERNAME, password: CONFIG.PASSWORD });
  if (!data.token) throw new Error('התחברות נכשלה – לא התקבל טוקן');
  return data.token;
}

function logout_(token) {
  try { apiCall_('Logout', { token: token }); } catch (e) { /* לא קריטי */ }
}

/** רשימת קבצים בתיקייה (כמו בקובץ ה-PHP: GetIVR2Dir + סינון לפי סיומת) */
function listFiles_(token, dirPath, allowMissing) {
  const apiPath = dirPath === '/' ? '/' : dirPath + '/';
  let data;
  try {
    data = apiCall_('GetIVR2Dir', { token: token, path: apiPath });
  } catch (e) {
    if (allowMissing) return [];
    throw e;
  }
  const raw = Array.isArray(data.files) ? data.files : [];
  const exts = (CONFIG.EXTENSIONS || []).map(x => String(x).toLowerCase());

  return raw.filter(f => {
    if (!f || !f.name) return false;
    if (exts.length === 0) return true;
    const ext = f.name.split('.').pop().toLowerCase();
    return exts.indexOf(ext) !== -1 || f.fileType === 'AUDIO';
  });
}

/** העתקה בתוך המערכת (FileAction action=copy) */
function yemotCopy_(token, what, target) {
  apiCall_('FileAction', {
    token: token,
    action: 'copy',
    what: 'ivr2:' + what.replace(/^\/+/, ''),
    target: 'ivr2:' + target.replace(/^\/+/, '')
  });
}

/** הורדת קובץ (DownloadFile) כ-Blob */
function downloadFile_(token, filePath) {
  const url = API + 'DownloadFile?' + toQuery_({
    token: token,
    path: 'ivr2:' + filePath.replace(/^\/+/, '')
  });
  const resp = UrlFetchApp.fetch(url, { muteHttpExceptions: true });
  if (resp.getResponseCode() !== 200) {
    throw new Error('HTTP ' + resp.getResponseCode());
  }
  // אם חזר JSON של שגיאה במקום הקובץ
  const ct = String(resp.getHeaders()['Content-Type'] || '');
  if (ct.indexOf('application/json') !== -1) {
    throw new Error('שגיאת API: ' + resp.getContentText());
  }
  return resp.getBlob();
}

function apiCall_(method, params) {
  const resp = UrlFetchApp.fetch(API + method + '?' + toQuery_(params), { muteHttpExceptions: true });
  let data;
  try {
    data = JSON.parse(resp.getContentText());
  } catch (e) {
    throw new Error(method + ': תשובה לא תקינה (HTTP ' + resp.getResponseCode() + ')');
  }
  if (data.responseStatus !== 'OK') {
    throw new Error(method + ': ' + (data.message || data.responseStatus || 'שגיאה לא ידועה'));
  }
  return data;
}

/* ===================== עזר ===================== */

function toQuery_(obj) {
  return Object.keys(obj)
    .map(k => encodeURIComponent(k) + '=' + encodeURIComponent(obj[k]))
    .join('&');
}

function normalizePath_(p) {
  const t = String(p || '').replace(/^ivr2:/, '').replace(/^\/+|\/+$/g, '');
  return '/' + t;
}

function joinPath_(dir, name) {
  return (dir === '/' ? '' : dir) + '/' + name;
}

[שנאור]

@איל-משולש כתב:

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

תודה רבה

[אז נדברו]

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

[CUBASE]

@אז-נדברו מבדיקה שלי עכשיו, העתקה ישירות מסל המחזור אינה מעתיקה לינק ולכן גם לאחר שהקובץ יימחק מסל המחזור - הוא לא ימחק משלוחת היעד

[אז נדברו]

@CUBASE כתב:

@אז-נדברו גם העתקה ישירות מסל המחזור מעתיקה לינק?

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

[CUBASE]

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

[אז נדברו]

@CUBASE כתב:

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

צודק.