src/Pure/General/rsync.scala
author wenzelm
Sun, 11 Dec 2022 12:52:46 +0100
changeset 76617 d5adc9126ae8
parent 76616 e6c11ef4fb51
child 77369 df17355f1e2c
permissions -rw-r--r--
clarified signature;
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
75523
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
     1
/*  Title:      Pure/General/rsync.scala
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
     2
    Author:     Makarius
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
     3
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
     4
Support for rsync: see also https://rsync.samba.org
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
     5
*/
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
     6
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
     7
package isabelle
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
     8
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
     9
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    10
object Rsync {
75527
a66fd84a30b7 clarified context with global defaults;
wenzelm
parents: 75526
diff changeset
    11
  sealed case class Context(progress: Progress,
76136
1bb677cceea4 let rsync re-use ssh connection via control path;
wenzelm
parents: 76131
diff changeset
    12
    ssh_port: Int = 0,
1bb677cceea4 let rsync re-use ssh connection via control path;
wenzelm
parents: 76131
diff changeset
    13
    ssh_control_path: String = "",
75527
a66fd84a30b7 clarified context with global defaults;
wenzelm
parents: 75526
diff changeset
    14
    archive: Boolean = true,
75554
be33ca6f45d7 more comments;
wenzelm
parents: 75534
diff changeset
    15
    protect_args: Boolean = true  // requires rsync 3.0.0, or later
75527
a66fd84a30b7 clarified context with global defaults;
wenzelm
parents: 75526
diff changeset
    16
  ) {
76136
1bb677cceea4 let rsync re-use ssh connection via control path;
wenzelm
parents: 76131
diff changeset
    17
    def command: String = {
76170
5912209b4fb6 clarified modules;
wenzelm
parents: 76136
diff changeset
    18
      val ssh_command = SSH.client_command(port = ssh_port, control_path = ssh_control_path)
76136
1bb677cceea4 let rsync re-use ssh connection via control path;
wenzelm
parents: 76131
diff changeset
    19
      "rsync --rsh=" + Bash.string(ssh_command) +
75527
a66fd84a30b7 clarified context with global defaults;
wenzelm
parents: 75526
diff changeset
    20
        (if (archive) " --archive" else "") +
a66fd84a30b7 clarified context with global defaults;
wenzelm
parents: 75526
diff changeset
    21
        (if (protect_args) " --protect-args" else "")
76136
1bb677cceea4 let rsync re-use ssh connection via control path;
wenzelm
parents: 76131
diff changeset
    22
    }
75525
68162e4f60a7 clarified signature: more explicit type Rsync.Context;
wenzelm
parents: 75524
diff changeset
    23
  }
68162e4f60a7 clarified signature: more explicit type Rsync.Context;
wenzelm
parents: 75524
diff changeset
    24
75526
57b6a28e4eba tuned signature;
wenzelm
parents: 75525
diff changeset
    25
  def exec(
75525
68162e4f60a7 clarified signature: more explicit type Rsync.Context;
wenzelm
parents: 75524
diff changeset
    26
    context: Context,
75523
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    27
    verbose: Boolean = false,
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    28
    thorough: Boolean = false,
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    29
    prune_empty_dirs: Boolean = false,
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    30
    dry_run: Boolean = false,
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    31
    clean: Boolean = false,
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    32
    list: Boolean = false,
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    33
    filter: List[String] = Nil,
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    34
    args: List[String] = Nil
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    35
  ): Process_Result = {
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    36
    val script =
75525
68162e4f60a7 clarified signature: more explicit type Rsync.Context;
wenzelm
parents: 75524
diff changeset
    37
      context.command +
75523
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    38
        (if (verbose) " --verbose" else "") +
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    39
        (if (thorough) " --ignore-times" else " --omit-dir-times") +
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    40
        (if (prune_empty_dirs) " --prune-empty-dirs" else "") +
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    41
        (if (dry_run) " --dry-run" else "") +
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    42
        (if (clean) " --delete-excluded" else "") +
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    43
        (if (list) " --list-only --no-human-readable" else "") +
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    44
        filter.map(s => " --filter=" + Bash.string(s)).mkString +
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    45
        (if (args.nonEmpty) " " + Bash.strings(args) else "")
75525
68162e4f60a7 clarified signature: more explicit type Rsync.Context;
wenzelm
parents: 75524
diff changeset
    46
    context.progress.bash(script, echo = true)
75523
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    47
  }
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    48
75526
57b6a28e4eba tuned signature;
wenzelm
parents: 75525
diff changeset
    49
  def init(context: Context, target: String,
75523
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    50
    contents: List[File.Content] = Nil
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    51
  ): Unit =
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    52
    Isabelle_System.with_tmp_dir("sync") { tmp_dir =>
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    53
      val init_dir = Isabelle_System.make_directory(tmp_dir + Path.explode("init"))
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    54
      contents.foreach(_.write(init_dir))
75534
1d937b12204d more robust: no change of directory attributes of initial test, notably target without .hg_sync meta data;
wenzelm
parents: 75527
diff changeset
    55
      exec(context.copy(archive = false),
1d937b12204d more robust: no change of directory attributes of initial test, notably target without .hg_sync meta data;
wenzelm
parents: 75527
diff changeset
    56
        thorough = true,
1d937b12204d more robust: no change of directory attributes of initial test, notably target without .hg_sync meta data;
wenzelm
parents: 75527
diff changeset
    57
        args =
1d937b12204d more robust: no change of directory attributes of initial test, notably target without .hg_sync meta data;
wenzelm
parents: 75527
diff changeset
    58
          List(if (contents.nonEmpty) "--archive" else "--dirs",
1d937b12204d more robust: no change of directory attributes of initial test, notably target without .hg_sync meta data;
wenzelm
parents: 75527
diff changeset
    59
            File.bash_path(init_dir) + "/.", target)).check
75523
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    60
    }
0dcaf0e5107b clarified modules;
wenzelm
parents:
diff changeset
    61
}