fix: unify cron job commands and remove redundant path handling

src/index.js

@@ -57,7 +57,7 @@ if (config.schedules.syncOnInit !== false) {
 		const jobResult = Cron.add({
 			name: "reflection-daily",
 			cron: "0 2 * * *",
-			command: `cd ${cwd} && node index.js --chat "/reflection"`,
+			command: `cd ${cwd} && node index.js --message run /reflection`,
 		});
 		if (jobResult.added || !jobResult.error) {
 			try {
@@ -70,7 +70,7 @@ if (config.schedules.syncOnInit !== false) {
 					const jobData = {
 						name: "reflection-daily",
 						cron: "0 2 * * *",
-						command: `cd ${cwd} && node index.js --chat "/reflection"`,
+						command: `cd ${cwd} && node index.js --message run /reflection`,
 						enabled: true,
 						createdAt: new Date().toISOString(),
 						updatedAt: new Date().toISOString(),

src/scheduler/autoSchedule.js

@@ -4,11 +4,12 @@ import { Cron } from "./cron.js";
 import { logger } from "../logger.js";
 import { loadConfig } from "../config/loader.js";
 
-const cwd = loadConfig().cwd;
+const config = loadConfig();
+const cwd = config.cwd;
 
 const JOB_CRON = "0 2 * * *";
 
-const SCHEDULES_DIR = "memory/schedules/";
+const SCHEDULES_DIR = config.memory?.schedulesDir || "memory/schedules/";
 
 /**
  * Job definition shape for the daily reflection cron job.
@@ -27,7 +28,7 @@ function createJobDefinition(cwd) {
 	return {
 		name: "reflection-daily",
 		cron: JOB_CRON,
-		command: `cd ${cwd} && timeout 300 node index.js "run /reflection"`,
+		command: `cd ${cwd} && timeout 300 node src/index.js --message run /reflection`,
 	};
 }
 
@@ -58,7 +59,7 @@ function persistJobFile(jobName, job, cwd) {
 		const jobData = Object.freeze({
 			name: job.name,
 			cron: job.cron,
-			command: `cd ${cwd} && timeout 300 node index.js "run /reflection"`,
+			command: `cd ${cwd} && timeout 300 node src/index.js --message run /reflection`,
 			enabled: true,
 			createdAt: new Date().toISOString(),
 			updatedAt: new Date().toISOString(),

src/scheduler/cron.js

@@ -1,7 +1,6 @@
 import { execSync } from "node:child_process";
 import { readdir, readFile } from "node:fs/promises";
 import { join } from "node:path";
-import { getLogDirectory } from "../logger.js";
 
 // Block delimiters for madz-managed crontab entries
 const BLOCK_START = "# --- BEGIN madz-schedules ---";
@@ -29,11 +28,8 @@ export function sanitizeCrontabCommand(command) {
  * @param {string} [logPath] - Optional log file path for output redirection
  * @returns {string} The prepared command
  */
-export function prepareCrontabCommand(command, logPath) {
-	const sanitized = sanitizeCrontabCommand(command);
-	const withAbsolutePath = sanitized.replace(/\bnode\b/g, "/usr/local/bin/node");
-	const logFile = logPath || join(getLogDirectory(), "madz_cron.log");
-	return `${withAbsolutePath} >> ${logFile} 2>&1`;
+export function prepareCrontabCommand(command) {
+	return sanitizeCrontabCommand(command);
 }
 
 /**

tests/unit/autoSchedule.test.js

@@ -65,8 +65,8 @@ describe("setupAutoSchedule", () => {
 		assert.strictEqual(capturedJob.cron, "0 2 * * *");
 		assert.ok(typeof capturedJob.command === "string");
 		assert.ok(
-			capturedJob.command.includes('node index.js "run /reflection"'),
-			"Command should include the run /reflection command",
+			capturedJob.command.includes("node src/index.js --message run /reflection"),
+			"Command should include the --message /reflection command",
 		);
 	});
 
@@ -99,7 +99,7 @@ describe("setupAutoSchedule", () => {
 		assert.strictEqual(content.cron, "0 2 * * *");
 		assert.ok(
 			content.command.startsWith("cd ") &&
-				content.command.includes('node index.js "run /reflection"'),
+				content.command.includes("node src/index.js --message run /reflection"),
 		);
 		assert.strictEqual(content.enabled, true);
 		assert.ok(content.createdAt);

tests/unit/scheduler/cron.test.js

@@ -1,12 +1,10 @@
 import { describe, it } from "node:test";
 import assert from "node:assert";
-import { join } from "node:path";
 import {
 	Cron,
 	sanitizeCrontabCommand,
 	prepareCrontabCommand,
 } from "../../../src/scheduler/cron.js";
-import { getLogDirectory } from "../../../src/logger.js";
 
 describe("cron - sanitizeCrontabCommand", () => {
 	it("strips carriage returns", () => {
@@ -31,42 +29,33 @@ describe("cron - sanitizeCrontabCommand", () => {
 });
 
 describe("cron - prepareCrontabCommand", () => {
-	it("replaces bare node with absolute path", () => {
+	it("returns the sanitized command as-is", () => {
 		const result = prepareCrontabCommand("node index.js", "/tmp/test.log");
-		assert.strictEqual(result, "/usr/local/bin/node index.js >> /tmp/test.log 2>&1");
+		assert.strictEqual(result, "node index.js");
 	});
 
-	it("uses provided log path", () => {
+	it("ignores logPath parameter", () => {
 		const result = prepareCrontabCommand("node test.js", "/custom/path.log");
-		assert.strictEqual(result, "/usr/local/bin/node test.js >> /custom/path.log 2>&1");
-	});
-
-	it("defaults to logger directory when no log path provided", () => {
-		const logDir = getLogDirectory();
-		const result = prepareCrontabCommand("node index.js");
-		assert.strictEqual(
-			result,
-			`/usr/local/bin/node index.js >> ${join(logDir, "madz_cron.log")} 2>&1`,
-		);
+		assert.strictEqual(result, "node test.js");
 	});
 
 	it("sanitizes newlines in command", () => {
 		const result = prepareCrontabCommand("node index.js\r\n", "/tmp/test.log");
-		assert.strictEqual(result, "/usr/local/bin/node index.js >> /tmp/test.log 2>&1");
+		assert.strictEqual(result, "node index.js");
 	});
 });
 
 describe("cron - Cron.setLogPath", () => {
 	it("sets the log path on the Cron instance", () => {
 		Cron.setLogPath("/custom/log/path.log");
 		const result = prepareCrontabCommand("node test.js", "/custom/log/path.log");
-		assert.strictEqual(result, "/usr/local/bin/node test.js >> /custom/log/path.log 2>&1");
+		assert.strictEqual(result, "node test.js");
 	});
 
 	it("is idempotent — subsequent calls overwrite", () => {
 		Cron.setLogPath("/first/path.log");
 		Cron.setLogPath("/second/path.log");
 		const result = prepareCrontabCommand("node test.js", "/second/path.log");
-		assert.strictEqual(result, "/usr/local/bin/node test.js >> /second/path.log 2>&1");
+		assert.strictEqual(result, "node test.js");
 	});
 });