fix: #49 #50 #52 #53 — critical legacy compat fixes

#49: Install creates persistent symlinks:
  - current/log → {baseDir}/log (logs survive redeploy/rollback)
  - current/{data_dir} → {baseDir}/{data_dir} (for each data_dirs entry)

#50: Start command passes server IP as argument:
  cd current && bin/start.sh {srv.Host}
  (legacy compat: NSM passes hostname to start scripts)

#52: noriter tow.yaml: added log_path for 6 infrastructure modules:
  kafka=server.log, zookeeper=zookeeper.out, s3-connector=connect.log,
  redis=redis.log, mongodb=mongod.log, grafana=grafana.log

#53: noriter tow.yaml: zookeeper post_install hook creates myid file

Remaining: #51 (package structure) needs package.sh equivalent or hooks

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: comchangs

internal/deploy/deploy.go

@@ -175,9 +175,14 @@ cd %s
 rm -f current
 ln -s deploy/%s current
 
+# Create persistent log symlink: current/log → {baseDir}/log
+mkdir -p %s/log
+ln -sfn %s/log %s/current/log 2>/dev/null || true
+
 echo "DEPLOY_OK"
 `, deployDir, deployDir, baseDir, packageFile, baseDir, packageFile,
-			baseDir, ts)
+			baseDir, ts,
+			baseDir, baseDir, baseDir)
 
 		result, err := d.ssh.Exec(env, srv.Host, installCmd)
 		if err != nil {
@@ -199,6 +204,15 @@ TOWEOF
 `, baseDir, ts, gitCommit, gitBranch, gitMsg, os.Getenv("USER"))
 		d.ssh.Exec(env, srv.Host, deployInfoCmd)
 
+		// Create persistent data symlinks for data_dirs
+		if len(mod.DataDirs) > 0 {
+			for _, dir := range mod.DataDirs {
+				symlinkCmd := fmt.Sprintf("mkdir -p %s/%s && ln -sfn %s/%s %s/current/%s 2>/dev/null || true",
+					baseDir, dir, baseDir, dir, baseDir, dir)
+				d.ssh.Exec(env, srv.Host, symlinkCmd)
+			}
+		}
+
 		configPath := d.cfg.GetConfigPathByName(moduleName, envName, srv.Name, srv.Number)
 		if configPath != "" {
 			if info, err := os.Stat(configPath); err == nil && info.IsDir() {

internal/deploy/lifecycle.go

@@ -31,7 +31,8 @@ func (d *Deployer) Start(envName, moduleName string, serverNum int) error {
 			d.execHook(env, srv.Host, "pre_start", mod.Hooks.PreStart)
 		}
 
-		cmd := fmt.Sprintf("cd %s/current && %s", baseDir, startCmd)
+		// Pass server host as argument (legacy compat: bin/server start {IP})
+		cmd := fmt.Sprintf("cd %s/current && %s %s", baseDir, startCmd, srv.Host)
 		result, err := d.ssh.Exec(env, srv.Host, cmd)
 		if err != nil {
 			return fmt.Errorf("start failed: %w", err)
@@ -80,7 +81,7 @@ func (d *Deployer) StartRolling(envName, moduleName string, serverNum int) error
 			d.execHook(env, srv.Host, "pre_start", mod.Hooks.PreStart)
 		}
 
-		cmd := fmt.Sprintf("cd %s/current && %s", baseDir, startCmd)
+		cmd := fmt.Sprintf("cd %s/current && %s %s", baseDir, startCmd, srv.Host)
 		result, err := d.ssh.Exec(env, srv.Host, cmd)
 		if err != nil {
 			return fmt.Errorf("[%s] start failed: %w", srv.Host, err)