Updated mappings, sample yml and options.

dup.rb

@@ -7,6 +7,16 @@ require 'ostruct'
 require 'json'
 
 MAPPINGS = [
+	# Syntax:
+	# [name_in_yml, docker_option_name, lambda_for_creating_yml_for_container=nil, options={}]
+	# Options are:
+	#   type: Sets type of this option
+	#     switch: Only adds the docker_option_name to the command, ignoring the value.
+	#     name: Value will be set to the name of the container (from yml filename or root element)
+	#     hidden: Will not be added to the run command
+	#   allow_empty: May be empty.
+	#   escape: If set to false, will not be shellescaped
+
 	['stdin_open', '--interactive', lambda{|c,i| c.Config.OpenStdin}, {:type=>:switch}],
 	['tty', '--tty', lambda{|c,i| c.Config.Tty}, {:type=>:switch}],
 	#['detach', '--detach', {:type=>:switch}],
@@ -23,6 +33,7 @@ MAPPINGS = [
 	['devices', '--device'],
 	['net', '--net'],
 	['ipv6', '--ipv6'],
+	['user', '--user'],
 	['networks', '--network', lambda{|c,i| c.NetworkSettings.Networks.to_h.keys.map(&:to_s)}, {:type=>:hidden}],
 	['entrypoint', '--entrypoint', lambda{|c,i| (ep=c.Config.Entrypoint) == i.Config.Entrypoint ? nil : ep}, {:allow_empty=>true}],
 	['labels', '--label', lambda{|c,i| l=Hash[c.Config.Labels.to_h.delete_if{|k,v| i.Config.Labels[k]==v rescue false}.map{|k,v| [k.to_s, v]}] ; l}],
@@ -30,17 +41,19 @@ MAPPINGS = [
 	['working_dir', '--workdir', lambda{|c,i| (wd=c.Config.WorkingDir) == i.Config.WorkingDir ? nil : wd}],
 	['init', '--init', lambda{|c,i| c.Config.Init}, {:type=>:switch}],
 	['image', nil, lambda{|c,i| c.Config.Image}],
-	['command', nil, lambda{|c,i| (cmd=c.Config.Cmd.join(" ") rescue nil) == (i.Config.Cmd.join(" ") rescue nil)? nil : cmd}, {:escape=>false}]
+	['command', nil, lambda{|c,i| (cmd=c.Config.Cmd.join(" ") rescue nil) == (i.Config.Cmd.join(" ") rescue nil)? nil : cmd}, {:escape=>false}],
+	['test', nil, nil, {type: :hidden}],
+	['auto_update', nil, nil, {type: :hidden}]
 ]
 
 
 def get_sample(name="container")
 	return <<~HEREDOC
-		#{name}:
 		image: "my/image:1.2.3"
 		restart: always
 		detach: true
 		test: true # Having this set to true will prevent dup from creating a label de.fabianonline.dup
+		auto_update: true # Enabling this adds a label to allow watchtower to automatically update this container
 		  
 		ports:
 		  - "1234:1234"
@@ -54,24 +67,22 @@ def get_sample(name="container")
 		volumes:
 		  - "/etc/localtime:/etc/localtime:ro"
 		  
-		  links:
-		    - "another_container"
-		
 		labels:
-		    com.centurylinklabs.watchtower.enable: true
+		  nginx_virtual_host: container.home.schle.nz
-		    nginx_virtual_host: container.home.fabianonline.de
 		  nginx_port: 80
+		  nginx_additional_ports: "443, 5050"
 		  nginx_allow: fabian # "user" or "@group" or "user, user, @group" or "all"
 		  nginx_no_robots: true
 		  nginx_public_paths: "/public, /api"
-		    nginx_type: # "http" (default), "fastcgi", "skip" (doesn't create any entries)
+		  nginx_type: # "http" (default), "https", "skip" (doesn't create any entries)
+		  nginx_client_max_body_size: 25M
 		  
 		networks:
 		  - "nginx"
 		  - "mosquitto"
 		  - "bridge"
 		  
-		  test: true
+		user: "1000:1000"
 		command: "/bin/bash"
 		entrypoint: "/script.sh"
 		build: "/data/dir"
@@ -115,18 +126,21 @@ def action_help
 	puts "-l, --list              Lists all available containers."
 	puts "    --host              Starts a container with net: host - which implies not using ports, networks and/or links."
 	puts "    --regenerate        Generates YAML content from a running container."
+	puts "    --all               Use all containers defined in yml files."
+	puts "-v, --verbose           More verbose output."
 	exit 1
 end
 
-def run_cmd(cmd, ignore_returnvalue=false, catch_interrupt=false)
+def run_cmd(cmd, ignore_returnvalue=false, catch_interrupt=false, ignore_dry_run: false)
-	puts "+ #{cmd}" if $dry_run
+	verbose "+ #{cmd}"
 	returnvalue=false
 	begin
-		returnvalue = $dry_run ? true : system("bash -c #{cmd.shellescape}")
+		returnvalue = ($dry_run && !ignore_dry_run) ? true : system("bash -c #{cmd.shellescape}")
 	rescue Interrupt
 		raise if not catch_interrupt
 	end
 	raise "Command returned a non-zero exit value." if returnvalue!=true && !ignore_returnvalue
+	return returnvalue
 end
 
 def esc(obj, escape=true)
@@ -202,6 +216,10 @@ class Container
 		@name = name
 	end
 	
+	def exists?
+		run_cmd("docker inspect --format='1' #{@name.shellescape} >/dev/null 2>&1", true, ignore_dry_run: true)
+	end
+	
 	def load
 		raise "File #{self.filename} not found." unless File.exists?(self.filename)
 
@@ -217,23 +235,32 @@ class Container
 	
 	def filename; "%s/%s.yml" % [$base_dir, @name]; end
 
-	def build_run_command
+	def add_label(key, value)
-		cmd = ["docker", "create"]
+		if @data["labels"].is_a? Array
-		cmd << "--net" << @data["networks"][0] if @data["networks"] && !$net_host
+			@data["labels"] << "#{key}=#{value}"
-		cmd << "--net" << "host" if $net_host
-		
-		if !@data["test"]
-			if @data["labels"]==nil
-				@data["labels"] = ["de.fabianonline.dup=true"]
-			elsif @data["labels"].is_a? Array
-				@data["labels"] << "de.fabianonline.dup=true"
 		elsif @data["labels"].is_a? Hash
-				@data["labels"]["de.fabianonline.dup"] = "true"
+			@data["labels"][key] = value
 		else
 			raise "data['labels'] is of an unexpected type: #{@data["labels"].class}"
 		end
 	end
 	
+	def build_run_command
+		$net_host = true if @data["net"]=="host"
+		cmd = ["docker", "create"]
+		cmd << "--net" << @data["networks"][0] if @data["networks"] && @data["networks"].count>0 && !$net_host
+		cmd << "--net" << "host" if $net_host
+
+		@data["labels"] ||= []
+		
+		if !@data["test"]
+			add_label("de.fabianonline.dup", "true")
+		end
+
+		if @data["auto_update"]
+			add_label("com.centurylinklabs.watchtower.enable", "true")
+		end
+
 		MAPPINGS.each do |mapping|
 			yml_name, cmd_name, reverse_lambda, options = *mapping
 			next if $net_host && %w(links net ports).include?(yml_name)
@@ -281,7 +308,7 @@ class Container
 	end
 	
 	def stop_and_remove
-		puts "Stopping and removing old container..."
+		verbose "Stopping and removing old container..."
 		run_cmd("docker rm -f #{@name.shellescape} >/dev/null 2>&1", true)
 	end
 	
@@ -290,9 +317,9 @@ class Container
 			networks = `docker network ls --format '{{.Name}}'`.split
 			@data["networks"].each do |network|
 				if networks.include?(network)
-					puts "Network #{network} exists."
+					verbose "Network #{network} exists."
 				else
-					puts "Creating network #{network}..."
+					verbose "Creating network #{network}..."
 					run_cmd("docker network create #{network.shellescape}", true)
 				end
 			end
@@ -302,14 +329,14 @@ class Container
 	def connect_to_networks
 		if !$net_host && @data["networks"].count>0
 			@data["networks"].each do |network|
-				puts "Connecting container to network #{network}..."
+				verbose "Connecting container to network #{network}..."
 				run_cmd("docker network connect #{network.shellescape} #{@name.shellescape} >/dev/null", true)
 			end
 		end
 	end
 	
 	def attach
-		puts "Attaching container..."
+		verbose "Attaching container..."
 		run_cmd("docker attach #{@name.shellescape}")
 	end
 	
@@ -332,17 +359,23 @@ class Container
 			self.pull
 		end
 		
+		if self.exists?
+			puts "Recreating #{@name}..."
+		else
+			puts "Creating   #{@name}..."
+		end
+		
 		self.stop_and_remove
 		
 		self.create_networks
 		
-		puts "Creating container..."
+		verbose "Creating container..."
 		cmd = build_run_command
 		run_cmd(cmd.compact.join(" ") + " >/dev/null")
 		
 		self.connect_to_networks
 		
-		puts "Starting container..."
+		verbose "Starting container..."
 		run_cmd("docker start #{@name.shellescape} >/dev/null")
 		
 		(@data["after_run"] || []).each{|cmd| run_cmd(cmd)}
@@ -379,9 +412,12 @@ class Container
 	end
 end
 
+def verbose(str); puts(str) if $verbose; end
+
 action = :run
 container = nil
 $dry_run = false
+$verbose = false
 $pull = false
 needs_container = true
 completion_str = ""
@@ -405,7 +441,9 @@ opts = GetoptLong.new(
 	[ '--update', '-u', GetoptLong::NO_ARGUMENT ],
 	[ '--_completion', GetoptLong::OPTIONAL_ARGUMENT ],
 	[ '--host', GetoptLong::NO_ARGUMENT ],
-	[ '--regenerate', GetoptLong::NO_ARGUMENT ]
+	[ '--regenerate', GetoptLong::NO_ARGUMENT ],
+	[ '--verbose', '-v', GetoptLong::NO_ARGUMENT ],
+	[ '--all', GetoptLong::NO_ARGUMENT ],
 )
 
 opts.each do |opt, arg|
@@ -436,10 +474,14 @@ opts.each do |opt, arg|
 			$net_host = true
 		when '--regenerate'
 			action = :regenerate
+		when '--verbose'
+			$verbose = true
+		when '--all'
+			container = Dir[$base_dir + "/*.yml"].sort.map{|f| Container.new(File.basename(f, ".yml"))}
 	end
 end
 
-container = ARGV.map{|c| Container.new(c)}
+container ||= ARGV.map{|c| Container.new(c)}
 
 if needs_container
 	if container.empty?