ref: refs/heads/network
commit 7380f768119ed432c1cc306826e0fabadaa79dd5
Author: Klaus Kämpf
Date: Fri Sep 25 18:00:10 2009 +0200
Make PackageKit mocking complete
This commit completes the mocking of PackageKit via D-Bus.
It introduces a PackageKitStub class and a PackageKitResult class.
PackageKitStub covers the complete D-Bus communication, PackageKitResult
the expected results from a function call (i.e. "GetUpdates").
The mocking is complete up to and including the socket level. The
results are sent to the socket and then processed through ruby-dbus,
making it completely transparent to the application.
---
plugins/patches/test/packagekit_stub.rb | 114 +++++++++++++++++++++---------
1 files changed, 80 insertions(+), 34 deletions(-)
diff --git a/plugins/patches/test/packagekit_stub.rb b/plugins/patches/test/packagekit_stub.rb
index 103d7b1..014d361 100644
--- a/plugins/patches/test/packagekit_stub.rb
+++ b/plugins/patches/test/packagekit_stub.rb
@@ -7,6 +7,20 @@
require File.join(File.dirname(__FILE__), "test_helper")
+class PackageKitResult
+ attr_reader :info, :id, :summary
+
+ def initialize info, id, summary
+ @info = info
+ @id = id
+ @summary = summary
+ end
+
+ def to_dbus
+ [ @info.to_s, @id.to_s, @summary.to_s ]
+ end
+end
+
class PackageKitStub
SERVICE = "org.freedesktop.PackageKit"
@@ -14,7 +28,7 @@ class PackageKitStub
TRANSACTION = "#{SERVICE}.Transaction"
TID = 42 # (dummy) transaction id
- def self.stub!
+ def initialize
#
# PackageKit stubbing
@@ -29,64 +43,96 @@ class PackageKitStub
# PackageKit service
#
- # create (dormant) pk_service
- pk_service = DBus::Service.new(SERVICE, DBus::SystemBus.instance)
+ # create (dormant) @pk_service
+ @pk_service = DBus::Service.new(SERVICE, DBus::SystemBus.instance)
- # stub: pk_service = system_bus.service("org.freedesktop.PackageKit")
- DBus::SystemBus.instance.stubs(:service).with(SERVICE).returns(pk_service)
+ # stub: @pk_service = system_bus.service("org.freedesktop.PackageKit")
+ DBus::SystemBus.instance.stubs(:service).with(SERVICE).returns(@pk_service)
#
# PackageKit proxy object
#
- packagekit_proxy = DBus::ProxyObject.new(DBus::SystemBus.instance, SERVICE, PATH)
+ @packagekit_proxy = DBus::ProxyObject.new(DBus::SystemBus.instance, SERVICE, PATH)
- # stub: packagekit_proxy = pk_service.object("/org/freedesktop/PackageKit")
- pk_service.stubs(:object).with(PATH).returns(packagekit_proxy)
+ # stub: @packagekit_proxy = @pk_service.object("/org/freedesktop/PackageKit")
+ @pk_service.stubs(:object).with(PATH).returns(@packagekit_proxy)
- # stub: packagekit_proxy.introspect
- packagekit_proxy.stubs(:introspect).returns(true)
- packagekit_proxy.stubs(:has_iface?).returns(true)
+ # stub: @packagekit_proxy.introspect
+ @packagekit_proxy.stubs(:introspect).returns(true)
+ @packagekit_proxy.stubs(:has_iface?).returns(true)
#
# PackageKit interface
#
- packagekit_iface = DBus::ProxyObjectInterface.new(packagekit_proxy, SERVICE)
+ @packagekit_iface = DBus::ProxyObjectInterface.new(@packagekit_proxy, SERVICE)
- # stub: packagekit_iface = packagekit_proxy["org.freedesktop.PackageKit"]
- packagekit_proxy[SERVICE] = packagekit_iface
+ # stub: @packagekit_iface = @packagekit_proxy["org.freedesktop.PackageKit"]
+ @packagekit_proxy[SERVICE] = @packagekit_iface
- # stub: tid = packagekit_iface.GetTid
- packagekit_iface.stubs(:GetTid).returns([TID])
+ # stub: tid = @packagekit_iface.GetTid
+ @packagekit_iface.stubs(:GetTid).returns([TID])
#
# PackageKit transaction proxy
#
- transaction_proxy = DBus::ProxyObject.new(DBus::SystemBus.instance, SERVICE, PATH)
-
- # stub: transaction_proxy = pk_service.object(tid[0])
- pk_service.stubs(:object).with(TID).returns(transaction_proxy)
+ @transaction_proxy = DBus::ProxyObject.new(DBus::SystemBus.instance, SERVICE, PATH)
- # stub: transaction_proxy.introspect
- transaction_proxy.stubs(:introspect).returns(true)
- transaction_proxy.stubs(:has_iface?).returns(true)
+ # stub: @transaction_proxy = @pk_service.object(tid[0])
+ @pk_service.stubs(:object).with(TID).returns(@transaction_proxy)
+
+ # stub: @transaction_proxy.introspect
+ @transaction_proxy.stubs(:introspect).returns(true)
+ @transaction_proxy.stubs(:has_iface?).returns(true)
#
# PackageKit transaction interface
#
- transaction_iface = DBus::ProxyObjectInterface.new(transaction_proxy, TRANSACTION)
+ @transaction_iface = DBus::ProxyObjectInterface.new(@transaction_proxy, TRANSACTION)
- # stub: transaction_iface = transaction_proxy["org.freedesktop.PackageKit.Transaction"]
- transaction_proxy[TRANSACTION] = transaction_iface
+ # stub: @transaction_iface = @transaction_proxy["org.freedesktop.PackageKit.Transaction"]
+ @transaction_proxy[TRANSACTION] = @transaction_iface
- # stub: packagekit_iface.SuggestDaemonQuit
- packagekit_iface.stubs(:SuggestDaemonQuit).returns(true)
+ # stub: @packagekit_iface.SuggestDaemonQuit
+ @packagekit_iface.stubs(:SuggestDaemonQuit).returns(true)
- # stub: transaction_iface.GetUpdates("NONE")
- transaction_iface.stubs(:GetUpdates).with("NONE").returns(true)
-
- # stub: transaction_iface.SearchName(...)
- transaction_iface.stubs(:SearchName).returns(true)
+ # stub: @transaction_iface.GetUpdates("NONE")
+ @transaction_iface.stubs(:GetUpdates).with("NONE").returns(true)
+ # stub: @transaction_iface.SearchName(...)
+ @transaction_iface.stubs(:SearchName).returns(true)
+
end # stub !
-
+
+ # now mock DBus::Main.run to emit "Package" signals on the SystemBus
+ # pass it an Array of 'PackageKitResult's
+ #
+ def run(signal, results)
+ # copy to local variables since instance vars are not(!) accessible inside the 'run' block
+ pks = @pk_service
+ ti = @transaction_iface
+
+ # alias 'run' as 'orig_run'
+ DBus::Main.class_eval { alias :orig_run :run }
+
+ # Now overlay 'run' with our own implementation
+ # This will fake a sender (via .emit) sending signals
+ # then we call orig_run to process these signals
+ #
+ # pass a closure(!) to 'run'
+ DBus::Main.send(:define_method, :run) do
+ sig = DBus::Signal.new(signal)
+ sig.add_param( [ "info", "s" ] )
+ sig.add_param( [ "id", "s" ] )
+ sig.add_param( [ "summary", "s" ] )
+ # this block is executed in DBus::Main context
+ results.each do |result|
+ # emit(service, obj, intf, sig, *args)
+ DBus::SystemBus.instance.emit(pks, ti.object, ti, sig, *result.to_dbus)
+ end
+ DBus::SystemBus.instance.emit(pks, ti.object, ti, DBus::Signal.new("Finished"))
+ # now call the original 'run' to process the signals we just emitted
+ self.orig_run
+ end
+ end
+
end # PackageKitStub
--
To unsubscribe, e-mail: yast-commit+unsubscribe@opensuse.org
For additional commands, e-mail: yast-commit+help@opensuse.org
