{"type":"doc","content":[{"type":"extension","attrs":{"layout":"default","extensionType":"com.atlassian.confluence.macro.core","extensionKey":"toc","parameters":{"macroParams":{},"macroMetadata":{"macroId":{"value":"7bd2fa52-2827-4a67-9d2f-f2b654b959e4"},"schemaVersion":{"value":"1"},"title":"Table of Contents"}}}},{"type":"heading","attrs":{"level":1},"content":[{"text":"Introduction","type":"text"}]},{"type":"paragraph","content":[{"text":"This document covers the specifics of writing a VCI component in the C++ programming language. For general VCI concepts please refer to the ","type":"text"},{"text":"VCI API","type":"text","marks":[{"type":"link","attrs":{"href":"https://danosproject.atlassian.net/wiki/spaces/DAN/pages/684654694/VCI+API"}}]},{"text":" overview documentation.","type":"text"}]},{"type":"paragraph","content":[{"text":"When creating a brand new implementation one gets to choose a language to build it in based on the needs of the feature and what you are comfortable with. VCI supports Go, C++ and Python 3 for implementing feature components. Like anything there are tradeoffs with each of language for the purposes of implementing a component below are the tradeoffs to consider when choosing C++.","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Pros","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Fast compiled code","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Fast interface to VCI bus","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Decent concurrency support","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Good for string handling","type":"text"}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Cons","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"No standard library support for RFC7951 data (JSON libraries are available to bridge the gap, such as ","type":"text"},{"text":"this one.","type":"text","marks":[{"type":"link","attrs":{"href":"https://github.com/nlohmann/json"}}]},{"text":")","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"No standard library support for generating config files (libraries like ","type":"text"},{"text":"'{{mustache}}'","type":"text","marks":[{"type":"link","attrs":{"href":"https://mustache.github.io/"}}]},{"text":" exist)","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"No existing library to interface with the dataplane or vplaned","type":"text"}]}]}]},{"type":"heading","attrs":{"level":1},"content":[{"text":"Debian Packaging","type":"text"}]},{"type":"paragraph","content":[{"text":"DANOS uses the Debian packaging system for packages and we have created helpers to aid in creating VCI components. To use these, we have to setup the debian build environment to use the right helpers and create the component descriptor file (.component file) in the directory.","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"VCI Helpers","type":"text"}]},{"type":"paragraph","content":[{"text":"To enable the VCI helper one needs to pass \"–with=vci\" to the \"dh\" command in debian/rules. An example is included below.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"#!/usr/bin/make -f\n#\n# This debian/rules uses debhelper.\n#\n \nexport DEB_BUILD_HARDENING=1\n# Uncomment this for verbose logging\n#export DH_VERBOSE=1\n \n%:\n dh $@ --with=vci,yang","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Component Descriptor","type":"text"}]},{"type":"paragraph","content":[{"text":"dh-vci uses a component descriptor file in the debian directory to generate system specific configurations. One must also supply this component descriptor file for dh-vci to work properly. A sample is included below.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"[Vyatta Component]\nName=com.example.myfeature\nDescription=VCI component for My Feature\nExecName=/lib/myfeature/vci-myfeature\nConfigFile=/etc/myfeature.conf\n \n[Model com.example.myfeature.v1]\nModules=myfeature-v1,myfeature-interfaces-dataplane-v1,my-feature-interfaces-vhost-v1\nModelSets=vyatta-v1","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":1},"content":[{"text":"Component Structure","type":"text"}]},{"type":"paragraph","content":[{"text":"VCI components implement the logic for a given set of YANG modules. A component owns the data for the modules defined in the \".component\" file. In the VCI API there are 6 important concepts, the component, the models the component implements, the features that a model supports (Configuration, Operational State and RPCs) and the client. Components are simply containers for models. Models are containers for the Config, State and RPC objects. The Config object implements the logic to validate and apply configuration data for the YANG modules that a component manages. The State object retrieves and formats operational state data for the YANG modules that a component manages. The RPC object implements RPC handlers for any RPC defined in the managed YANG modules.","type":"text"}]},{"type":"paragraph","content":[{"text":"The C++ VCI API is defined in the \"libvci\" library. For the Config and State objects, virtual base classes are defined for the required objects. One implements one of these base classes and passes the object to libvci so that the appropriate calls are made when the operation is requested on the bus. In C++ RPCs are implemented as a virtual Method class that may be implemented or any std::function of the form \"std::function\". In all cases in the C++ VCI API strings are encoded rfc7951 objects. One may use most standard JSON decoders to read this format. All method invocations can happen concurrently so one must be careful to use proper techniques for concurrent access of managed data.","type":"text"}]},{"type":"heading","attrs":{"level":1},"content":[{"text":"API Documentation","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Component","type":"text"}]},{"type":"paragraph","content":[{"text":"Creating a component is a relatively straightforward process. One needs to create the objects for the desired functionality, attach them to a model and attach the model to a component object. Finally, one starts the component bus process, and waits for it to exit.","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Config Object","type":"text"}]},{"type":"paragraph","content":[{"text":"The Config Object is as follows:","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"class Config {\npublic:\n\tvirtual void set(const std::string& input) = 0;\n\tvirtual void check(const std::string& input) = 0;\n\tvirtual std::string get() { return \"{}\"; }\n\tvirtual ~Config() {};\n};","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"One must implement both \"set\" and \"check\" methods with ones own class that inherits from this class definition. One may override the \"get\" function but this API is no longer used and is only provided for compatibility with existing components.","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"State Object","type":"text"}]},{"type":"paragraph","content":[{"text":"The state object is defined as follows.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"class State {\npublic:\n\tvirtual std::string get() = 0;\n\tvirtual ~State() {};\n};","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"RPCs","type":"text"}]},{"type":"paragraph","content":[{"text":"RPCs are implemented by a class implementing the following virtual base class, or by implementing a \"std::function\". These are associated with the YANG module name and RPC name when creating the Model object.","type":"text"}]},{"type":"paragraph","content":[{"type":"hardBreak"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"class Method {\npublic:\n\tvirtual EncodedOutput operator()(const EncodedInput& input) = 0;\n\tvirtual ~Method() {};\n};","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Model","type":"text"}]},{"type":"paragraph","content":[{"text":"A Model is created by associating Config, State and RPC objects with the model name as defined in the \".component\" file. When one defines a model, one may chain together the method invocations to implement the full thing declaratively as in the example below. Config and state object lifetimes are managed by the VCI library.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"vci::Model(\"net.vyatta.eng.vci.template-cpp.v1\")\n\t.config(new Config())\n\t.state(new State())\n\t.rpc(\"vci-template-cpp-v1\", \"rpc1\", new RPC1()) //As vci::Method\n\t.rpc(\"vci-template-cpp-v1\", \"rpc2\", RPC1()) //As std::function\n\t.rpc(\"vci-template-cpp-v1\", \"rpc3\",\n\t\t[](const std::string &in)->std::string {\n\t\t\t// implement the RPC.\n\t\t\treturn in;\n\t\t});","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Component","type":"text"}]},{"type":"paragraph","content":[{"text":"The Component is the mechanism that starts the process that listens on the VCI Bus for messages and dispatches to the appropriate object in the program. One defines a component by creating the component and attaching the model to it. An example is included below.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"auto comp = vci::Component(\"net.vyatta.eng.vci.template-cpp\")\n\t.model(vci::Model(\"net.vyatta.eng.vci.template-cpp.v1\")\n\t\t.config(new Config())\n\t\t.state(new State())\n\t\t.rpc(\"vci-template-cpp-v1\", \"rpc1\", new RPC1()) //As vci::Method\n\t\t.rpc(\"vci-template-cpp-v1\", \"rpc2\", RPC1()) //As std::function\n\t\t.rpc(\"vci-template-cpp-v1\", \"rpc3\",\n\t\t\t[](const std::string &in)->std::string {\n\t\t\t\t// implement the RPC.\n\t\t\t\treturn in;\n\t\t\t}));","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"Once defined one can start the component process using the \"run\" method.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"comp.run();","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"The \"run\" method starts the bus process and returns immediately. One may block until component to exit using the \"wait\" method.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"comp.wait();","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"One may tell the component to cleanup gracefully if required using the \"stop\" method. If the process exits without calling stop the VCI bus will cleanup automatically.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"comp.stop();","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Client","type":"text"}]},{"type":"paragraph","content":[{"text":"When one creates a component, one may use the same connection to the VCI Bus as a VCI client to talk to other components. One uses the \"client\" method of the component to access this part of the connection.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"auto client = comp.client();","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"The client can subscribe to notifications, request configuration and state data for a given model, and call RPCs via the VCI bus directly. ","type":"text"}]},{"type":"paragraph","content":[{"text":"One may also create a new client connection to the VCI Bus if one doesn't need a full component.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"vci::Client client;","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Notifications","type":"text"}]},{"type":"paragraph","content":[{"text":"One of the most useful operations for the client is to subscribe to and emit notifications on the VCI bus.","type":"text"}]},{"type":"heading","attrs":{"level":4},"content":[{"text":"Emit","type":"text"}]},{"type":"paragraph","content":[{"text":"Emitting notifications is easy. One simply uses the \"client.Emit\" method providing the module name the notification is modeled in, the name of the notification and the body as a RFC7951 encoded string.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"client.emit(\"vyatta-routing-v1\", \"instance-added\", \"{ \\\"vyatta-routing-v1:name\\\": \\\"blue\\\" }\");","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"The body of the notification will be validated against the data-model before emission on the bus occurs. This means that an invalid notification will be discarded. Any bus client may emit any notification and no access control is provided to ensure notifications come from a given source. This is a tradeoff was chosen to allow flexibility for integrating with existing open-source projects in the most efficient way possible (e.g. a script that is called when a given event occurs).","type":"text"}]},{"type":"heading","attrs":{"level":4},"content":[{"text":"Subscribe","type":"text"}]},{"type":"paragraph","content":[{"text":"One may also subscribe to notifications via the VCI client object. Subscriptions have several buffering mechanisms which may be chosen for a given notification based on the desired semantics. By default all notifications are \"infinitely buffered\". One may choose to coalesce notifications such that only the last received notification is delivered dropping all previous messages, this can be useful when subscribing to notifications that act like state updates. One may choose to drop or block after some limit. One may also remove any previously instantiated limit.","type":"text"}]},{"type":"paragraph","content":[{"text":"Subscriptions are not active until one calls \"run\" on the subscription object and one may stop delivery of a subscription via the \"cancel\" operation. Subscriptions are delivered via registered functions of the type \"std::function\" or implementing the vci::Subscriber interface.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"auto sub = client.subscribe(\"vyatta-routing-v1\", \"instance-added\",\n\t[](const std::string &body) {\n\t\tstd::cout << \"got notification vyatta-routing-v1:instance-added: \" << body << std::endl;\n\t})\nsub.run();\n// ...\nsub.cancel();","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"RPC","type":"text"}]},{"type":"paragraph","content":[{"text":"The client can call RPCs directly on the bus. This is only for use when calling RPCs between components. On should use CallRPC in the configd API for management interface applications.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"auto call = client.call(\"vyatta-op-v1\", \"ping\", \"{\\\"host\\\":\\\"1.1.1.1\\\"}\");\nstd::cout << \"output: \" << call.output() << std::endl;","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"State","type":"text"}]},{"type":"paragraph","content":[{"text":"The client can request the state of a given model via the bus directly. This is mostly for the interface from configd to the components.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"auto state = client.state_by_model(\"com.example.myfeature.v1\");\nstd::cout << \"state: \" << state << std::endl;","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Config","type":"text"}]},{"type":"paragraph","content":[{"text":"The client can request the configuration for a given model via the bus directly. This generally shouldn't be used as one component shouldn't depend on the configuration of another. This is mostly for the interface from configd to the components.","type":"text"}]},{"type":"table","attrs":{"layout":"default"},"content":[{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[680.0]},"content":[{"type":"codeBlock","content":[{"text":"auto config = client.config_by_model(\"com.example.myfeature.v1\");\nstd::cout << \"config: \" << config << std::endl;","type":"text"}]}]}]}]},{"type":"paragraph"}],"version":1}