diff --git a/src/opkg.lua b/src/opkg.lua
new file mode 100644
index 0000000..fd34ce3
--- /dev/null
+++ b/src/opkg.lua
@@ -0,0 +1,119 @@
+#!/usr/bin/lua
+-- WANT_JSON
+
+local Ansible = require("ansible")
+
+function update_package_db(module, opkg_path)
+	local rc, out, err = module:run_command(string.format("%s update", opkg_path))
+
+	if rc ~= 0 then
+		module:fail_json({msg = "could not update package db", opkg={rc=rc, out=out, err=err}})
+	end
+end
+
+function query_package(module, opkg_path, name)
+	local rc, out, err = module:run_command(string.format("%s list-installed", opkg_path))
+
+	if rc ~= 0 then
+		module:fail_json({msg = "failed to list installed packages", opkg={rc=rc, out=out, err=err}})
+	end
+
+	for line in string.gmatch(out, "[^\n]+") do
+		if name == string.match(line, "^(%S+)%s") then
+			return true
+		end
+	end
+
+	return false
+end
+
+function get_force(force)
+	if force and string.len(force) > 0 then
+		return "--force-" .. force
+	else
+		return ""
+	end
+end
+
+function remove_packages(module, opkg_path, packages)
+	local p = module:get_params()
+
+	local force = get_force(p["force"])
+
+	local remove_c = 0
+
+	for _,package in ipairs(packages) do
+		-- Query the package first, to see if we even need to remove
+		if query_package(module, opkg_path, package) then
+			local rc, out, err = module:run_command(string.format("%s remove %s %q", opkg_path, force, package))
+
+			if rc ~= 0 or query_package(module, opkg_path, package) then
+				module:fail_json({msg="failed to remove " .. package, opkg={rc=rc, out=out, err=err}})
+			end
+
+			remove_c = remove_c + 1;
+		end
+	end
+
+	if remove_c > 0 then
+		module:exit_json({changed=true, msg=string.format("removed %d package(s)", remove_c)})
+	else
+		module:exit_json({changed=false, msg="package(s) already absent"})
+	end
+end
+
+function install_packages(module, opkg_path, packages)
+	local p = module:get_params()
+
+	local force = get_force(p["force"])
+
+	local install_c = 0
+
+	for _,package in ipairs(packages) do
+		-- Query the package first, to see if we even need to remove
+		if not query_package(module, opkg_path, package) then
+			local rc, out, err = module:run_command(string.format("%s install %s %s", opkg_path, force, package))
+
+			if rc ~= 0 or not query_package(module, opkg_path, package) then
+				module:fail_json({msg=string.format("failed to install %s", package), opkg={rc=rc, out=out, err=err}})
+			end
+
+			install_c = install_c + 1;
+		end
+	end
+
+	if install_c > 0 then
+		module:exit_json({changed=true, msg=string.format("installed %s packages(s)", install_c)})
+	else
+		module:exit_json({changed=false, msg="package(s) already present"})
+	end
+end
+
+function main(arg)
+	local module = Ansible.new({
+		name =  { aliases = {"pkg"}, required=true , type='list'},
+		state = { default = "present", choices={"present", "installed", "absent", "removed"} },
+		force = { default = "", choices={"", "depends", "maintainer", "reinstall", "overwrite", "downgrade", "space", "postinstall", "remove", "checksum", "removal-of-dependent-packages"} } ,
+		update_cache = { default = "no", aliases={ "update-cache" }, type='bool' }
+	})
+
+	local opkg_path = module:get_bin_path('opkg', true, {'/bin'})
+
+	module:parse(arg[1])
+
+	local p = module:get_params()
+
+	if p["update_cache"] then
+		update_package_db(module, opkg_path)
+	end
+	
+	local state     = p["state"]
+	local packages  = p["name"]
+	if "present" == state or "installed" == state then
+		install_packages(module, opkg_path, packages)
+	elseif "absent" == state or "removed" == state then
+		remove_packages(module, opkg_path, packages)
+	end
+end
+
+main(arg)