Update sync-notes.js

sync-notes.js

@@ -1,13 +1,25 @@
-const { exec } = require('child_process');
+const { execSync, exec } = require('child_process');
+const fs = require('fs');
 const path = require('path');
 const cron = require('node-cron');
 
 const WATCH_DIR = path.join(__dirname, 'notes');
 
+function gitPull() {
+  try {
+    console.log('Đang thực hiện git pull...');
+    execSync('git pull', { cwd: WATCH_DIR, stdio: 'inherit' });
+    console.log('Git pull hoàn tất.');
+  } catch (error) {
+    console.error('Lỗi khi thực hiện git pull:', error.message);
+    // Có thể xử lý lỗi ở đây, ví dụ: cố gắng merge hoặc reset
+  }
+}
+
 function gitStatusHasChanges(callback) {
   exec('git status --porcelain', { cwd: WATCH_DIR }, (err, stdout, stderr) => {
     if (err) {
-      console.error('Error running git status:', err);
+      console.error('Lỗi khi chạy git status:', err);
       callback(false);
       return;
     }
@@ -15,52 +27,80 @@ function gitStatusHasChanges(callback) {
   });
 }
 
-function gitCommitAndPush() {
+function gitCommitAndPush(callback) {
   const now = new Date();
   const timeString = now.toISOString();
 
   exec('git add .', { cwd: WATCH_DIR }, (err, stdout, stderr) => {
     if (err) {
-      console.error('Error running git add:', err);
+      console.error('Lỗi khi chạy git add:', err);
+      callback(false);
       return;
     }
     exec(`git commit -m "Database Sync - ${timeString}"`, { cwd: WATCH_DIR }, (err2, stdout2, stderr2) => {
       if (err2) {
         if (stderr2.includes('nothing to commit')) {
-          console.log('No changes to commit.');
+          console.log('Không có thay đổi để commit.');
+          callback(true); // Coi như thành công vì không có gì để commit
         } else {
-          console.error('Error running git commit:', err2);
+          console.error('Lỗi khi chạy git commit:', err2);
+          callback(false);
         }
         return;
       }
       exec('git push', { cwd: WATCH_DIR }, (err3, stdout3, stderr3) => {
         if (err3) {
-          console.error('Error running git push:', err3);
+          console.error('Lỗi khi chạy git push:', err3);
+          callback(false);
           return;
         }
-        console.log('Changes pushed successfully at', timeString);
+        console.log('Thay đổi đã được đẩy thành công vào lúc', timeString);
+        callback(true);
       });
     });
   });
 }
 
-function checkForChanges() {
+function initialSync() {
+  console.log('Đang thực hiện đồng bộ hóa ban đầu...');
   gitStatusHasChanges((hasChanges) => {
     if (hasChanges) {
-      console.log('Changes detected, committing and pushing...');
-      gitCommitAndPush();
+      console.log('Phát hiện thay đổi cục bộ, đang commit và đẩy...');
+      gitCommitAndPush((success) => {
+        if (success) {
+          gitPull();
+        } else {
+          console.error('Không thể đẩy thay đổi cục bộ. Bỏ qua git pull.');
+        }
+      });
     } else {
-      console.log('No changes detected.');
+      console.log('Không có thay đổi cục bộ. Đang thực hiện git pull.');
+      gitPull();
     }
   });
 }
 
 function startWatching() {
-  console.log(`Starting to watch directory: ${WATCH_DIR}`);
-  // Schedule to run every minute
+  console.log(`Bắt đầu theo dõi thư mục: ${WATCH_DIR}`);
+  // Lên lịch chạy mỗi phút
   cron.schedule('* * * * *', () => {
-    checkForChanges();
+    gitStatusHasChanges((hasChanges) => {
+      if (hasChanges) {
+        console.log('Phát hiện thay đổi, đang commit và đẩy...');
+        gitCommitAndPush((success) => {
+          if (success) {
+            gitPull();
+          }
+        });
+      } else {
+        console.log('Không phát hiện thay đổi.');
+        gitPull(); // Vẫn pull định kỳ để đảm bảo cập nhật từ xa
+      }
+    });
   });
 }
 
+// Thực hiện đồng bộ hóa ban đầu một lần khi script khởi động
+initialSync();
+// Sau đó bắt đầu theo dõi định kỳ
 startWatching();