///|
fn help_message() -> String {
  let message =
    #|Usage: split [OPTION]... [FILE [PREFIX]]
    #|Split FILE (or stdin) into byte-preserving pieces; default PREFIX is x.
    #|  -l, --lines=NUMBER        put NUMBER records in each piece (default 1000)
    #|  -b, --bytes=SIZE          put SIZE bytes in each piece
    #|  -C, --line-bytes=SIZE     put at most SIZE bytes of records in each piece
    #|  -n, --number=CHUNKS       N, K/N, l/N, l/K/N, r/N or r/K/N
    #|  -a, --suffix-length=N     fixed suffix width; zero selects automatic width
    #|  -d, --numeric-suffixes[=FROM]  numeric suffixes
    #|  -x, --hex-suffixes[=FROM]      hexadecimal suffixes
    #|      --additional-suffix=SUFFIX  append SUFFIX to generated names
    #|  -e, --elide-empty-files   omit empty outputs
    #|      --filter=COMMAND     run pure shell source per piece with FILE set
    #|      --help               display this help and exit
    #|      --version            display version and exit
    #|Existing named outputs are refused; filters own their explicit file writes.
    #|Line-byte and unknown-size partition layouts require temporary write access.
  message
}

///|
async fn process(
  reader : &@io.Reader,
  options : Options,
  known_size : Int64?,
) -> Unit {
  @async.with_task_group() <| group => {
    let outputs = Outputs::new(options, group)
    defer outputs.close()
    match options.layout {
      BytesPer(size) => split_bytes(reader, outputs, size)
      LinesPer(size) => split_lines(reader, outputs, size)
      LineBytes(size) => {
        let directory = @fs.tmpdir(prefix="split-")
        defer @fs.rmdir(directory, recursive=true)
        let spool = @fs.open(
          directory + "/record",
          mode=ReadWrite,
          create_mode=CreateNew,
          permission=0o600,
        )
        defer spool.close()
        split_line_bytes(reader, outputs, size, spool)
      }
      RoundRobin(count, selected) =>
        split_round_robin(reader, outputs, count, selected)
      Chunks(count, selected, lines) =>
        match known_size {
          Some(size) =>
            split_chunks(reader, outputs, size, count, selected, lines)
          None => {
            let directory = @fs.tmpdir(prefix="split-")
            defer @fs.rmdir(directory, recursive=true)
            let path = directory + "/input"
            let size = {
              let spool = @fs.open(
                path,
                mode=WriteOnly,
                create_mode=CreateNew,
                permission=0o600,
              )
              defer spool.close()
              let mut size = 0L
              while reader.read_some(max_len=65536) is Some(bytes) {
                spool.write(bytes)
                size = byte_position(size, bytes.length())
              }
              size
            }
            let spool = @fs.open(path, mode=ReadOnly)
            defer spool.close()
            split_chunks(spool, outputs, size, count, selected, lines)
          }
        }
    }
  }
}

///|
async fn main {
  let metadata_args = @env.args()[1:]
  if metadata_args.length() == 1 && metadata_args[0] == "--version" {
    @stdio.stdout.write("split 0.1.3\n")
    return
  }
  let parsed = parse_args(@env.args()[1:]) catch {
    @cli.CliError(message~, option~, ..) => {
      @stdio.stderr.write("split: \{message}: '\{option}'\n")
      @sys.exit(2)
      return
    }
  }
  if parsed.contains("help") {
    @stdio.stdout.write(help_message() + "\n")
    return
  }
  if parsed.contains("version") {
    @stdio.stdout.write("split 0.1.3\n")
    return
  }
  try {
    let options = options(parsed)
    let input = parsed.operands.get(0).unwrap_or("-")
    if input == "-" {
      process(@stdio.stdin, options, None)
    } else {
      let file = @fs.open(input, mode=ReadOnly)
      defer file.close()
      let size = if file.kind() == Regular { Some(file.size()) } else { None }
      process(file, options, size)
    }
  } catch {
    SplitError(status, message) => {
      @stdio.stderr.write("split: \{message}\n")
      @sys.exit(status)
    }
    error => {
      @stdio.stderr.write("split: \{error}\n")
      @sys.exit(1)
    }
  }
}