Use OVSDB client in order to retrive port list

Gemfile

@@ -3,6 +3,8 @@ source 'https://rubygems.org'
 
 gemspec
 
+gem 'active_flow', github: 'shun159/active_flow', branch: 'feature/ovsdb/core'
+
 group :guard do
   gem 'guard', require: false
   gem 'guard-bundler', require: false

Gemfile.lock

@@ -1,3 +1,17 @@
+GIT
+  remote: git://github.com/shun159/active_flow.git
+  revision: cfca63f79a926cdf6733f523bac05ea859331fd8
+  branch: feature/ovsdb/core
+  specs:
+    active_flow (0.0.1)
+      activemodel (~> 4.2, >= 4.2.6)
+      activesupport (~> 4.2, >= 4.2.6)
+      bundler (~> 1.11.2)
+      ffi-yajl (~> 2.2.3)
+      multi_json (>= 1.11.1)
+      representable (~> 3.0.0)
+      yajl-ruby (~> 1.2.1)
+
 PATH
   remote: .
   specs:
@@ -10,6 +24,9 @@ PATH
 GEM
   remote: https://rubygems.org/
   specs:
+    activemodel (4.2.6)
+      activesupport (= 4.2.6)
+      builder (~> 3.1)
     activesupport (4.2.6)
       i18n (~> 0.7)
       json (~> 1.7, >= 1.7.7)
@@ -58,6 +75,8 @@ GEM
     cucumber-core (1.5.0)
       gherkin (~> 4.0)
     cucumber-wire (0.0.1)
+    declarative (0.0.7)
+      uber (>= 0.0.15)
     descendants_tracker (0.0.4)
       thread_safe (~> 0.3, >= 0.3.1)
     diff-lcs (1.2.5)
@@ -69,6 +88,8 @@ GEM
     faker (1.6.3)
       i18n (~> 0.5)
     ffi (1.9.10)
+    ffi-yajl (2.2.3)
+      libyajl2 (~> 1.2)
     flay (2.8.0)
       erubis (~> 2.7.0)
       path_expander (~> 1.0)
@@ -113,6 +134,7 @@ GEM
     i18n (0.7.0)
     ice_nine (0.11.2)
     json (1.8.3)
+    libyajl2 (1.2.0)
     listen (3.0.8)
       rb-fsevent (~> 0.9, >= 0.9.4)
       rb-inotify (~> 0.9, >= 0.9.7)
@@ -151,6 +173,9 @@ GEM
       archive-tar-minitar (>= 0.5.2)
       json (>= 1.4.6)
       rest-client (>= 1.7.2)
+    representable (3.0.0)
+      declarative (~> 0.0.5)
+      uber (~> 0.0.15)
     rest-client (1.8.0)
       http-cookie (>= 1.0.2, < 2.0)
       mime-types (>= 1.16, < 3.0)
@@ -196,6 +221,7 @@ GEM
     tins (1.6.0)
     tzinfo (1.2.2)
       thread_safe (~> 0.1)
+    uber (0.0.15)
     unf (0.1.4)
       unf_ext
     unf_ext (0.0.7.2)
@@ -205,12 +231,14 @@ GEM
       coercible (~> 1.0)
       descendants_tracker (~> 0.0, >= 0.0.3)
       equalizer (~> 0.0, >= 0.0.9)
+    yajl-ruby (1.2.1)
     yard (0.8.7.6)
 
 PLATFORMS
   ruby
 
 DEPENDENCIES
+  active_flow!
   aruba
   codeclimate-test-reporter
   coveralls

lib/phut/open_vswitch.rb

@@ -123,6 +123,7 @@ def <=>(other)
     private
 
     def start
+      @vsctl.set_manager
       @vsctl.add_bridge
       @vsctl.set_openflow_version_and_dpid
       @vsctl.controller_tcp_port = @tcp_port

lib/phut/vsctl.rb

@@ -1,11 +1,14 @@
 # frozen_string_literal: true
 require 'phut/shell_runner'
 require 'pio'
+require 'active_flow'
 
 module Phut
   # ovs-vsctl wrapper
   class Vsctl
     extend ShellRunner
+    include ActiveFlow::OVSDB::Transact
+    extend ActiveFlow::OVSDB::Transact
 
     def self.list_br(prefix)
       sudo('ovs-vsctl list-br').split.each_with_object([]) do |each, list|
@@ -18,6 +21,7 @@ def self.list_br(prefix)
     include ShellRunner
 
     def initialize(name:, name_prefix:, dpid:, bridge:)
+      @client = ActiveFlow::OVSDB::Client.new('localhost', 6632)
       @name = name
       @prefix = name_prefix
       @dpid = dpid
@@ -38,6 +42,10 @@ def del_bridge
       sudo "ovs-vsctl del-br #{@bridge}"
     end
 
+    def set_manager
+      sudo 'ovs-vsctl set-manager ptcp:6632'
+    end
+
     def set_openflow_version_and_dpid
       sudo "ovs-vsctl set bridge #{@bridge} "\
            "protocols=#{Pio::OpenFlow.version} "\
@@ -75,7 +83,22 @@ def bring_port_down(port_number)
     end
 
     def ports
-      sudo("ovs-vsctl list-ports #{@bridge}").split
+      br_query = [select('Bridge', [[:name, :==, @bridge]], [:ports])]
+      br_ports = @client.transact(1, 'Open_vSwitch', br_query).first[:rows].first[:ports]
+      ports = if br_ports.include? "set"
+                br_ports[1]
+              else
+                [br_ports]
+              end
+      port_query = ports.map do |port|
+        select('Port', [[:_uuid, :==, port]], [:name])
+      end
+      iface_query = @client.transact(1, 'Open_vSwitch', port_query).map do |iface|
+        select('Interface', [[:name, :==, iface[:rows].first[:name]]], [:ofport, :name])
+      end
+      @client.transact(1, 'Open_vSwitch', iface_query).map do |iface|
+        OpenStruct.new(iface[:rows].first)
+      end
     end
 
     private