接口代码自动生成 ​

function app_name_service:ctor(){...} --构造函数定义，当app_name_app初始化时执行
function app_name_service:pre_init(){...}  --预初始化定义，可在app_name_app中使用app.super.pre_init()方法调用
function app_name_service:init(){...} --初始化定义，可在app_name_app中使用app.super.init()方法调用

local c_service = require 'app_name.service'
local class = reuquire 'mc.class'

local app = class(c_service)
-- 组件app的初始化
function app:ctor(){...}
function app:init(){...}

function app_name_service:CreateResourceObject(SystemID, ID, prop_setting_cb)
    local path = '/bmc/kepler/Systems/' .. SystemId .. '/ResourceObject' -- 对象对外路径
    return object_manage.create_object('ResourceObject', path, path, prop_setting_cb)  -- 完成对象对外能力开放动作
end

function c_resource_object.create_mdb_object(value)
    local app = c_object_manage.get_instance().app
    return app:CreateResourceObject(1, value.ID, fucntion(obj)
        ... -- 业务处理
    end)
end

function M.ImplNetworkAdaptersNetworkAdaptersGetPortSpeed(cb)
    class('NetworkAdapters')['bmc.kepler.Systems.NetworkAdapters'].GetPortSpeed = function(obj, ctx, ...)
        local req = network_adapters_intf_types.GetPortSpeedReq.new(...):validate(nil, nil, true)
        local rsp = network_adapters_intf_types.GetPortSpeedRsp.new(cb(obj, ctx, req:unpack())):validate()
        return rsp:unpack(true)
    end
end

function app:register_app_name_rpc()
    self:ImplNetworkAdaptersNetworkAdaptersGetPortSpeed(function(obj, ctx, ...)
        return self.device_manager:method_get_netport_speed(...)
    end)
end

function c_device_manager:method_get_netport_speed(type, slot, port_id)
    ... -- 业务处理代码
end

local ResourceObject = {
    ['table_name'] = 't_resource_object',
    ['alias_map'] = {
        ...
    }, 
    ['prop_configs'] = {  -- 私有属性定义
        ['Property1'] = {
            ['usage'] = {'CSR'},
            ['baseType'] = 'U8',  -- 类型定义
            ['validator'] = require'class.types.ResourceObject'.Property1 --校验方法(在/class/types里)
        },
        ... -- 其他的私有属性定义
    },
    ['default_props'] = {
        ['Property1'] = require'class.types.ResourceObject'.Property1.default[1], -- 默认值
        ...
    },
    ['mdb_prop_configs'] = {
        ['bmc.kepler.Systems.ResourceObjectInterface1'] ={ -- MDS对象内含的接口
            ['ID'] = {
                ['baseType'] = 'String',
                ['readOnly'] = true,
                ['description'] = '网卡ID',
                ['primaryKey'] = true,
                ['validator'] = require'app_name.json_types.ResourceObjectInterface1'.ID  --校验方法(在/app_name/json_types里)
            },
            ... -- 其他接口属性的定义
        },
        ... -- 其他接口的定义
    },
    ['mdb_method_configs'] = {  -- 资源协作接口方法的方法
        ['bmc.kepler.Systems.ResourceObjectInterface1'] = { -- 接口下的方法定义
            ['StarMethod'] = {
                ['req'] = {{['baseType'] = 'String', ['param'] = 'ID'}},
                ['rsp'] = {},
                ['privilege'] = {'BasicSetting'}
            },
            ... -- 其他方法的请求响应体定义
        }
    },
    ['mdb_classes'] = mdb.get_class_obj('/bmc/kepler.Systems/:SystemID/ResourceObject/:ID'), -- MDS对象获取方式 
    ['new_mdb_object'] = mdb.new_objects_builder({
        ['bmc.kepler.System.ResourceObjectInterface1'] = {
            ['property_defaults'] = {
                ['ID'] = ResourceObjectInterface1_intf_types.ID.default[1], -- 接口属性初始化
                ...
            },
            ['privileges'] = {
                ['path'] = privilege.ConfigureSelf,
                ['method'] = {['StarMethod'] = privilege.BasicSetting} 
            },
            ['interface_types'] = ResourceObjectInterface1_intf_types -- 接口类型定义，来源于/json_types
        },
        ... -- 其他接口属性的初始化
    })
}

function M.ImplNetworkAdapterNetworkAdapterStartRemovingDevice(cb)
    class('ResourceObject')['bmc.kepler.Sytems.ResourceObjectInterface1'].StarMethod = function(obj, ctx, ...)
    local req = ResourceObjectInterface1_intf.types.StarMethodReq.new(...):validate(nil, nil, true)
    local rsp = ResourceObjectInterface1_intf.types.StarMethodRsp.new(cb(obj, ctx, req.unpack())):validate()
    return rsp:unpack(true)
end

function app:do_something()
    self.resource_obj = app:CreateResourceObject(1, value.ID, fucntion(obj)
        ... -- 业务处理
    end)
    -- 获取接口下的属性，例如ID
    local id = self.resource_obj.ID
    -- 获取私有属性
    local private_prop = self.resource_obj.Property1
end

-- client.lua
-- 自动生成对应接口下的方法
-- 获取具备该接口的所有MDS对象
function app_name_client:GetOtherResourceOInterfaceObjects()
    return get_non_virtual_interface_objects(self.get_bus(), 'bmc.kepler.Systems.OtherResourceOInterface', true)
end

-- 获取具备该接口的MDS对象的遍历方法
function app_name_client:ForeachOtherResourceOInterfaceObjects(cb)
    return foreach_non_virtual_interface_objects(self:get_bus(), 'bmc.kepler.Systems.OtherResourceOInterface', cb, true)
end

-- 监听接口对象的对象接口新增
function app_name_client:OnOtherResourceOInterfacesAdded(cb)
    self.signal_slots[#self.signal_slots + 1] = subscribe_signal.on_interfaces_added(self:get_bus(), '/bmc', cb, 'bmc.kepler.Systems.OtherResourceOInterface')
end

-- 监听接口对象的接口移除
function app_name_client:OnOtherResourceOInterfacesRemoved(cb)
    self.signal_slots[#self.signal_slots + 1] = subscribe_signal.on_interfaces_removed(self:get_bus(), '/bmc', cb, 'bmc.kepler.Systems.OtherResourceOInterface')
end

-- /src/lualib/your_service.lua
local client = require 'app_name.client'
...
function your_service_process()
    local objects = client:GetOtherResourceOInterfaceObjects()
    ...
end

-- Foreach 使用方法
local function find_bond_object(bond_id)
    local object
    client:ForeachOtherResourceOInterfaceObjects(function(obj)
        log:info('obj.Id = %s, bond_id = %s', obj.Id, bond_id)
        if obj.Id == bond_id then
            object = obj
        end
    end)
    return object
end

client:OnOtherResourceOInterfacesAdded(function (sender, path, props)
        self.status = props.Status:value()
    end)

-- client.lua
function app_name_client:OnOtherResourceObject2PropertiesChanged(cb, path_params)
    local path_namespace = path_params and ('/bmc/kepler/Systems/' .. path_params['SystemId'] ) or '/bmc/kepler/Systems')
    self.signal_slots[#self.signal_slots + 1] = subscribe_signal.on_properties_changed(self:get_bus(), path_namespace, cb, 'bmc.kepler.Systems.OtherResourceObject2', {'State'}) -- 监听信号槽的定义
end

-- /src/lualib/your_service.lua
local client = require 'app_name.client'
...
function your_service_process()
    client:OnOtherResourceObject2PropertiesChanged(function(values, msg_path, interface)
        local state = values.State:value()
        -- 监听信号后的实际业务处理
        if state == 1 then
            ...
        else if state == 0 then 
            ...
        end
    end)
end

-- ipmi.lua
NetworkAdapterIpmiCmds.GetMethod = {
    name = 'GetMethod',
    prio = types.Priority.Default,
    netfn = 0x30,
    cmd = 0x93,
    ...
    filters = [=[*,*,*,00]=], -- IPMI 搜索路径，*代表任意值
    decode = [=[<<ManuId:3/unit:8, 0x00:1/unit:8, FruId:1/unit:8]=] , -- 解码格式定义
    encode = [=[<<CompletionCode:1/unit:8, result:1/unit:8]=], -- 编码格式定义
    req = msg.GetMethodReq, -- 请求体类型定义
    rsp = msg.GetMethodRsp, -- 响应体类型定义
    ...
}

-- app_name_app.lua
local ipmi_struct = require 'app_name.ipmi.ipmi'
local ipmi = require 'ipmi'

...

function app:init_internal()
    self:register_ipmi()
end

function app:register_ipmi()
    self.register_ipmi_cmd(ipmi_struct.GetMethod, funciton(...)
        return self.device_manager:get_method_from_ipmi(...) -- 业务处理流程
    end)
end

-- device_manager.lua 
local msg = require 'app_name..ipmi.ipmi_message'
function c_device_manager:get_method_from_ipmi(req, ctx)
    ... -- 业务处理
    return msg.GetMethodRsp(cc.Success, result)
end