#    This file is part of Metasm, the Ruby assembly manipulation suite
#    Copyright (C) 2006-2009 Yoann GUILLOT
#
#    Licence is LGPL, see LICENCE in the top-level directory


require 'metasm/cpu/ia32/main'

module Metasm
class Ia32
	# temporarily setup dasm.address_binding so that backtracking
	# stack-related offsets resolve in :frameptr (relative to func start)
	def decompile_makestackvars(dasm, funcstart, blocks)
		esp = register_symbols[4]
		oldfuncbd = dasm.address_binding[funcstart]
		dasm.address_binding[funcstart] = { esp => :frameptr }
		patched_binding = [funcstart]	# list of addresses to cleanup later

		if blocks.length <= 12
			blocks.each { |block| yield block }
			return
		end

		# for large function, pre-trace and cache esp/ebp for every block start to improve decompilation time

		ebp = register_symbols[5]
		ebp_frame = true

		# pretrace esp and ebp for each function block (cleared later)
		# TODO with more than 1 unknown __stdcall ext func per path, esp -> unknown, which makes very ugly C (*esp-- = 12...); add heuristics ?
		blocks.each { |block|
			blockstart = block.address
			if not dasm.address_binding[blockstart]
				patched_binding << blockstart
				dasm.address_binding[blockstart] = {}
				foo = dasm.backtrace(esp, blockstart, :snapshot_addr => funcstart)
				if foo.length == 1 and ee = foo.first and ee.kind_of?(Expression) and (ee == Expression[:frameptr] or
						(ee.lexpr == :frameptr and ee.op == :+ and ee.rexpr.kind_of?(::Integer)))
					dasm.address_binding[blockstart][esp] = ee
				end
				if ebp_frame
					foo = dasm.backtrace(ebp, blockstart, :snapshot_addr => funcstart)
					if foo.length == 1 and ee = foo.first and ee.kind_of?(Expression) and (ee == Expression[:frameptr] or
							(ee.lexpr == :frameptr and ee.op == :+ and ee.rexpr.kind_of?(::Integer)))
						dasm.address_binding[blockstart][ebp] = ee
					else
						ebp_frame = false	# func does not use ebp as frame ptr, no need to bt for later blocks
					end
				end
			end

			yield block
		}

	ensure
		patched_binding.each { |a| dasm.address_binding.delete a }
		dasm.address_binding[funcstart] = oldfuncbd if oldfuncbd
	end

	# add di-specific registry written/accessed
	def decompile_func_finddeps_di(dcmp, func, di, a, w)
		a << register_symbols[0] if di.opcode.name == 'ret' and (not func.type.kind_of?(C::BaseType) or func.type.type.name != :void)	# standard ABI
	end

	# list variable dependency for each block, remove useless writes
	# returns { blockaddr => [list of vars that are needed by a following block] }
	def decompile_func_finddeps(dcmp, blocks, func)
		# TODO honor user-defined prototype if available (eg no, really, eax is not read in this function returning al)
		#regargs.sort_by { |r| r.to_s }.each { |r|
			#a = C::Variable.new(r.to_s, C::BaseType.new(:int, :unsigned))
			#a.add_attribute("register(#{r})")
			#func.type.args << a
		#}
	end

	# return the array of arguments (symbols, indirections wrt frameptr) to be used as arguments for decompilation of the function call in di
	def decompile_get_func_args(dcmp, func_entry, di, f)
		bt = dcmp.dasm.backtrace(:esp, di.address, :snapshot_addr => func_entry, :include_start => true)
		stackoff = Expression[[bt, :+, @size/8], :-, :esp].bind(:esp => :frameptr).reduce rescue nil
		args_todo = f.type.args.to_a.dup
		args = []
		if f.has_attribute('fastcall')	# XXX DRY
			if a = args_todo.shift
				mask = (1 << (8*dcmp.c_parser.sizeof(a))) - 1
				mask = 0 if a.has_attribute('unused')
				args << Expression[:ecx, :&, mask]
			end
			if a = args_todo.shift
				mask = (1 << (8*dcmp.c_parser.sizeof(a))) - 1	# char => dl
				mask = 0 if a.has_attribute('unused')
				args << Expression[:edx, :&, mask]
			end
		end
		args_todo.each { |a_|
			if r = a_.has_attribute_var('register')
				args << Expression[r.to_sym]
			elsif stackoff.kind_of?(Integer)
				args << Indirection[[:frameptr, :+, stackoff], @size/8]
				stackoff += [dcmp.sizeof(a_), @size/8].max
			else
				args << Expression[0]
			end
		}

		if f.type.varargs and f.type.args.last.type.pointer? and stackoff.kind_of?(Integer)
			# check if last arg is a fmtstring
			bt = dcmp.dasm.backtrace(args.last, di.address, :snapshot_addr => func_entry, :include_start => true)
			if bt.length == 1 and s = dcmp.dasm.get_section_at(bt.first)
				fmt = s[0].read(512)
				fmt = fmt.unpack('v*').pack('C*') if dcmp.sizeof(f.type.args.last.type.untypedef.type) == 2
				if fmt.index(?\0)
					fmt = fmt[0...fmt.index(?\0)]
					fmt.gsub('%%', '').count('%').times {	# XXX %.*s etc..
						args << Indirection[[:frameptr, :+, stackoff], @size/8]
						stackoff += @size/8
					}
				end
			end
		end

		args
	end

	def decompile_special_instr(dcmp, di, stmts, scope)
		di_addr = di.address
		ce  = lambda { |*e|
			ret = dcmp.decompile_cexpr(Expression[Expression[*e].reduce], scope)
			dcmp.walk_ce(ret) { |ee| ee.with_misc(:di_addr => di_addr) }
			ret
		}

		case di.opcode.name
		when 'mov'
			# mov cr0 etc
			a1, a2 = di.instruction.args
			case a1
			when Ia32::CtrlReg, Ia32::DbgReg, Ia32::TstReg, Ia32::SegReg
				sz = a1.kind_of?(Ia32::SegReg) ? 16 : 32
				if not dcmp.c_parser.toplevel.symbol["intrinsic_set_#{a1}"]
					dcmp.c_parser.parse("void intrinsic_set_#{a1}(__int#{sz});")
				end
				f = dcmp.c_parser.toplevel.symbol["intrinsic_set_#{a1}"]
				a2 = a2.symbolic(di)
				a2 = [a2, :&, 0xffff] if sz == 16
				stmts << ce[C::CExpression.new(f, :funcall, [ce[a2]], f.type.type)]
				return true
			end
			case a2
			when Ia32::CtrlReg, Ia32::DbgReg, Ia32::TstReg, Ia32::SegReg
				if not dcmp.c_parser.toplevel.symbol["intrinsic_get_#{a2}"]
					sz = a2.kind_of?(Ia32::SegReg) ? 16 : 32
					dcmp.c_parser.parse("__int#{sz} intrinsic_get_#{a2}(void);")
				end
				f = dcmp.c_parser.toplevel.symbol["intrinsic_get_#{a2}"]
				t = f.type.type
				stmts << ce[a1.symbolic(di), :'=', C::CExpression.new(f, :funcall, [], t)]
				return true
			end
		when 'lgdt'
			if not dcmp.c_parser.toplevel.struct['segment_descriptor']
				dcmp.c_parser.parse('struct segment_descriptor { __int16 limit; __int16 base0_16; __int8 base16_24; __int8 flags1; __int8 flags2_limit_16_20; __int8 base24_32; };')
				dcmp.c_parser.parse('struct segment_table { __int16 size; struct segment_descriptor *table; } __attribute__((pack(2)));')
			end
			if not dcmp.c_parser.toplevel.symbol['intrinsic_lgdt']
				dcmp.c_parser.parse('void intrinsic_lgdt(struct segment_table *);')
			end
			# need a way to transform arg => :frameptr+12
			arg = di.backtrace_binding.keys.grep(Indirection).first.pointer
			stmts << C::CExpression.new(dcmp.c_parser.toplevel.symbol['intrinsic_lgdt'], :funcall, [ce[arg]], C::BaseType.new(:void)).with_misc(:di_addr => di_addr)
			return true
		when 'lidt'
			if not dcmp.c_parser.toplevel.struct['interrupt_descriptor']
				dcmp.c_parser.parse('struct interrupt_descriptor { __int16 offset0_16; __int16 segment; __int16 flags; __int16 offset16_32; };')
				dcmp.c_parser.parse('struct interrupt_table { __int16 size; struct interrupt_descriptor *table; } __attribute__((pack(2)));')
			end
			if not dcmp.c_parser.toplevel.symbol['intrinsic_lidt']
				dcmp.c_parser.parse('void intrinsic_lidt(struct interrupt_table *);')
			end
			arg = di.backtrace_binding.keys.grep(Indirection).first.pointer
			stmts << C::CExpression.new(dcmp.c_parser.toplevel.symbol['intrinsic_lidt'], :funcall, [ce[arg]], C::BaseType.new(:void)).with_misc(:di_addr => di_addr)
			return true
		when 'ltr', 'lldt'
			if not dcmp.c_parser.toplevel.symbol["intrinsic_#{di.opcode.name}"]
				dcmp.c_parser.parse("void intrinsic_#{di.opcode.name}(int);")
			end
			arg = di.backtrace_binding.keys.first
			stmts << C::CExpression.new(dcmp.c_parser.toplevel.symbol["intrinsic_#{di.opcode.name}"], :funcall, [ce[arg]], C::BaseType.new(:void)).with_misc(:di_addr => di_addr)
			return true
		when 'out'
			sz = di.instruction.args.find { |a_| a_.kind_of?(Ia32::Reg) and a_.val == 0 }.sz
			if not dcmp.c_parser.toplevel.symbol["intrinsic_out#{sz}"]
				dcmp.c_parser.parse("void intrinsic_out#{sz}(unsigned short port, __int#{sz} value);")
			end
			port = di.instruction.args.grep(Expression).first || edx
			stmts << C::CExpression.new(dcmp.c_parser.toplevel.symbol["intrinsic_out#{sz}"], :funcall, [ce[port], ce[eax]], C::BaseType.new(:void)).with_misc(:di_addr => di_addr)
			return true
		when 'in'
			sz = di.instruction.args.find { |a_| a_.kind_of?(Ia32::Reg) and a_.val == 0 }.sz
			if not dcmp.c_parser.toplevel.symbol["intrinsic_in#{sz}"]
				dcmp.c_parser.parse("__int#{sz} intrinsic_in#{sz}(unsigned short port);")
			end
			port = di.instruction.args.grep(Expression).first || edx
			f = dcmp.c_parser.toplevel.symbol["intrinsic_in#{sz}"]
			stmts << C::CExpression.new(ce[eax], :'=', C::CExpression.new(f, :funcall, [ce[port]], f.type.type), f.type.type).with_misc(:di_addr => di_addr)
			return true
		when 'sti', 'cli'
			stmts << C::Asm.new(di.instruction.to_s, nil, [], [], nil, nil)
			return true
		when /^(mov|sto|lod)s([bwdq])/
			op, sz = $1, $2
			eax, ecx, edx, ebx, esp, ebp, esi, edi = register_symbols
			eax, ecx, edx, ebx, esp, ebp, esi, edi = eax, ecx, edx, ebx, esp, ebp, esi, edi
			sz = { 'b' => 1, 'w' => 2, 'd' => 4, 'q' => 8 }[sz]
			pt = C::Pointer.new(C::BaseType.new("__int#{sz*8}".to_sym))

			blk = C::Block.new(scope)
			case op
			when 'mov'
				blk.statements << C::CExpression[[:*, [[ce[edi]], pt]], :'=', [:*, [[ce[esi]], pt]]].with_misc(:di_addr => di_addr)
				blk.statements << C::CExpression[ce[edi], :'=', [ce[edi], :+, [sz]]].with_misc(:di_addr => di_addr)
				blk.statements << C::CExpression[ce[esi], :'=', [ce[esi], :+, [sz]]].with_misc(:di_addr => di_addr)
			when 'sto'
				blk.statements << C::CExpression[[:*, [[ce[edi]], pt]], :'=', ce[eax]].with_misc(:di_addr => di_addr)
				blk.statements << C::CExpression[ce[edi], :'=', [ce[edi], :+, [sz]]].with_misc(:di_addr => di_addr)
			when 'lod'
				blk.statements << C::CExpression[ce[eax], :'=', [:*, [[ce[esi]], pt]]].with_misc(:di_addr => di_addr)
				blk.statements << C::CExpression[ce[esi], :'=', [ce[esi], :+, [sz]]].with_misc(:di_addr => di_addr)
			#when 'sca'
			#when 'cmp'
			end

			case (di.instruction.prefix || {})[:rep]
			when nil
				stmts.concat blk.statements
			when 'rep'
				blk.statements << C::CExpression[ce[ecx], :'=', [ce[ecx], :-, [1]]].with_misc(:di_addr => di_addr)
				stmts << C::While.new(C::CExpression[ce[ecx]], blk).with_misc(:di_addr => di_addr)
			#when 'repz'	# sca/cmp only
			#when 'repnz'
			end
			return true
		end

		false
	end

	def decompile_blocks(dcmp, myblocks, deps, func, nextaddr = nil)
		eax, ecx, edx, ebx, esp, ebp, esi, edi = register_symbols
		eax, ecx, edx, ebx, esp, ebp, esi, edi = eax, ecx, edx, ebx, esp, ebp, esi, edi	# fix ruby unused var warning
		scope = func.initializer
		func.type.args.each { |a| scope.symbol[a.name] = a }
		stmts = scope.statements
		blocks_toclean = myblocks.dup
		func_entry = myblocks.first[0]
		di_addr = nil
		until myblocks.empty?
			b, to = myblocks.shift
			if l = dcmp.dasm.get_label_at(b)
				stmts << C::Label.new(l).with_misc(:di_addr => b)
			end

			# Expr => CExpr
			ce  = lambda { |*e|
				ret = dcmp.decompile_cexpr(Expression[Expression[*e].reduce], scope)
				dcmp.walk_ce(ret) { |ee| ee.with_misc(:di_addr => di_addr) } if di_addr
				ret
			}

			# go !
			dcmp.dasm.decoded[b].block.list.each_with_index { |di, didx|
				di_addr = di.address
				a = di.instruction.args
				if di.opcode.props[:setip] and not di.opcode.props[:stopexec]
					# conditional jump
					n = dcmp.backtrace_target(get_xrefs_x(dcmp.dasm, di).first, di.address)
					if di.opcode.name =~ /^loop(.+)?/
						loopcc = decode_cc_to_expr($1) if $1
						cx = C::CExpression[:'--', ce[ecx]]
						cc = loopcc ? C::CExpression[cx, :'&&', ce[loopcc]] : cx
					else
						cc = ce[decode_cc_to_expr(di.opcode.name[1..-1])]
					end
					# XXX switch/indirect/multiple jmp
					stmts << C::If.new(C::CExpression[cc], C::Goto.new(n).with_misc(:di_addr => di_addr)).with_misc(:di_addr => di_addr)
					to.delete dcmp.dasm.normalize(n)
					next
				end

				if decompile_special_instr(dcmp, di, stmts, scope)
					next
				end

				case di.opcode.name
				when 'ret'
					# TODO no to_normal => ret, else jmp
					ret = nil
					ret = C::CExpression[ce[eax]] unless func.type.type.kind_of?(C::BaseType) and func.type.type.name == :void
					stmts << C::Return.new(ret).with_misc(:di_addr => di_addr)
				when 'call'	# :saveip
					# TODO check actual funcall VS call/pop
					n = dcmp.backtrace_target(get_xrefs_x(dcmp.dasm, di).first, di.address)
					if f = dcmp.c_parser.toplevel.symbol[n] and f.type.kind_of?(C::Function) and f.type.args
					elsif defined?(@dasm_func_default_off) and o = @dasm_func_default_off[[dcmp.dasm, di.address]] and o.kind_of?(::Integer) and o > @size/8
						f = C::Variable.new
						f.type = C::Function.new(C::BaseType.new(:int), [])
						((o/(@size/8))-1).times { f.type.args << C::Variable.new(nil, C::BaseType.new(:int)) }
					else
						f = C::Variable.new
						f.type = C::Function.new(C::BaseType.new(:int), [])
					end
					args = decompile_get_func_args(dcmp, func_entry, di, f).map { |arg| ce[arg] } 
					#next if not di.block.to_subfuncret

					if not n.kind_of?(::String) or (f and not f.type.kind_of?(C::Function))
						# indirect funcall
						fptr = ce[n]
						proto = C::Function.new(C::BaseType.new(:int))
						proto = f.type if f and f.type.kind_of?(C::Function)
						f = C::CExpression[[fptr], C::Pointer.new(proto)]
					elsif not f
						# internal functions are predeclared, so this one is extern
						f = C::Variable.new
						f.name = n
						f.type = C::Function.new(C::BaseType.new(:int))
						if dcmp.recurse > 0
							dcmp.c_parser.toplevel.symbol[n] = f
							dcmp.c_parser.toplevel.statements << C::Declaration.new(f)
						end
					end
					e = C::CExpression[f, :funcall, args].with_misc(:di_addr => di_addr)
					e = C::CExpression[ce[eax], :'=', e, f.type.type].with_misc(:di_addr => di_addr) if f.type.type != C::BaseType.new(:void)
					stmts << e
				when 'jmp'
					#if di.comment.to_a.include?('switch')
					#	n = di.instruction.args.first.symbolic(di)
					#	fptr = ce[n]
					#	sw = C::Switch.new(fptr, C::Block.new(scope))
					#	di.block.to_normal.to_a.each { |addr|
					#		addr = dcmp.dasm.normalize addr
					#		to.delete addr
					#		next if not l = dcmp.dasm.get_label_at(addr)
					#		sw.body.statements << C::Goto.new(l)
					#	}
					#	stmts << sw
					a = di.instruction.args.first
					if a.kind_of?(Expression)
					elsif not a.respond_to?(:symbolic)
						stmts << C::Asm.new(di.instruction.to_s, nil, [], [], nil, nil).with_misc(:di_addr => di_addr)
					else
						n = di.instruction.args.first.symbolic(di)
						fptr = ce[n]
						if fptr.kind_of?(C::CExpression) and fptr.type.pointer? and fptr.type.untypedef.type.kind_of?(C::Function)
							proto = fptr.type.untypedef.type
							args = decompile_get_func_args(dcmp, func_entry, di, fptr.type).map { |arg| ce[arg] } 
						else
							proto = C::Function.new(C::BaseType.new(:void))
							fptr = C::CExpression[[fptr], C::Pointer.new(proto)].with_misc(:di_addr => di_addr)
							args = []
						end
						ret = C::Return.new(C::CExpression[fptr, :funcall, args].with_misc(:di_addr => di_addr)).with_misc(:di_addr => di_addr)
						stmts << ret
						to = []
					end
				else
					bd = get_fwdemu_binding(di)
					if di.backtrace_binding[:incomplete_binding]
						stmts << C::Asm.new(di.instruction.to_s, nil, nil, nil, nil, nil).with_misc(:di_addr => di_addr)
					else
						bd.each { |k, v|
							stmts << ce[k, :'=', v]
							stmts.pop if stmts.last.kind_of?(C::Variable)	# [:eflag_s, :=, :unknown].reduce
						}
					end
				end
				di_addr = nil
			}

			case to.length
			when 0
				if not myblocks.empty? and not %w[ret jmp].include?(dcmp.dasm.decoded[b].block.list.last.instruction.opname)
					if not stmts.last.kind_of?(C::CExpression) or stmts.last.op != :funcall or not stmts.last.lexpr.has_attribute('noreturn')
						puts "  block #{Expression[b]} has no to and don't end in ret"
					end
				end
			when 1
				if (myblocks.empty? ? nextaddr != to[0] : myblocks.first.first != to[0])
					stmts << C::Goto.new(dcmp.dasm.auto_label_at(to[0], 'unknown_goto'))
				end
			else
				puts "  block #{Expression[b]} with multiple to"
			end
		end

		# cleanup di.bt_binding (we set :frameptr etc in those, this may confuse the dasm)
		blocks_toclean.each { |b_, to_|
			dcmp.dasm.decoded[b_].block.list.each { |di|
				di.backtrace_binding = nil
			}
		}
	end

	def decompile_check_abi(dcmp, entry, func)
		a = func.type.args || []
		a.delete_if { |arg| arg.has_attribute_var('register') and arg.has_attribute('unused') }
		ra =  a.map { |arg| arg.has_attribute_var('register') }.compact
		if (a.length == 1 and ra == ['ecx']) or (a.length >= 2 and ra.sort == ['ecx', 'edx'])
			func.add_attribute 'fastcall'
			# reorder args
			ecx = a.find { |arg| arg.has_attribute_var('register') == 'ecx' }
			edx = a.find { |arg| arg.has_attribute_var('register') == 'edx' }
			a.insert(0, a.delete(ecx))
			a.insert(1, a.delete(edx)) if edx
		end

		if not f = dcmp.dasm.function[entry] or not f.return_address
			#func.add_attribute 'noreturn'
		else
			adj = f.return_address.map { |ra_| dcmp.dasm.backtrace(:esp, ra_, :include_start => true, :stopaddr => entry) }.flatten.uniq
			if adj.length == 1 and so = Expression[adj.first, :-, :esp].reduce and so.kind_of?(::Integer)
				argsz = a.map { |fa|
					next if not fa.stackoff
					(fa.stackoff + [dcmp.sizeof(fa), dcmp.c_parser.typesize[:ptr]].max-1) / dcmp.c_parser.typesize[:ptr]
				}.compact.max.to_i
				so /= dcmp.dasm.cpu.size/8
				so -= 1
				if so > argsz
					aso = a.empty? ? 0 : a.last.stackoff.to_i + dcmp.c_parser.typesize[:ptr]
					(so-argsz).times {
						a << C::Variable.new(dcmp.stackoff_to_varname(aso), C::BaseType.new(:int))
						a.last.add_attribute('unused')
						aso += dcmp.sizeof(a.last)
					}
					argsz = so
				end
				case so
				when 0
				when argsz
					func.add_attribute 'stdcall' if not func.has_attribute('fastcall')
				else
					func.add_attribute "stackoff:#{so*dcmp.dasm.cpu.size/8}"
				end
			else
				func.add_attribute "breakstack:#{adj.inspect}"
			end
		end
	end
end
end
