FTN7: FutoIn Invoker Concept
Version: 1.4
Date: 2015-01-21
Copyright: 2014 FutoIn Project (http://futoin.org)
Authors: Andrey Galkin
CHANGES
- v1.4 - 2015-02-22
- v1.3 - 2015-01-21
- Synchronized actual API changes with documentation
- Added internal web browser communication channel based on HTML5 Web Messaging specification
- Documented optional "options" parameter of ccm.register()
- Added standard option definition
- Added Communication Errors notes
- Removed never implemented burst() calls
- Changed never implemented cache_lN() to cache( bucket )
- Added native event support
- Added CCM close()
- v1.2 - 2014-10-03
- Updated initialization cache API
- Updated endpoitn schemes
- v1.1 - 2014-09-30
- Added FTN14 Cache support
- Clarified "credentials" parameter
- Clarified "self://" scheme
- Added AdvancedCCM-specific startup optimization extensions
- v1.0 - 2014-09-26
Warning
This specification IS NOT mandatory. It is just a reference model.
Any implementation IS ALLOWED to provide own architecture with
drawback of breaking easy migration from one to another.
1. Concept
There must be a centralized connection and credentials manager (CCM) object.
It should be possible to create multiple independent instances of such type.
Each connection end-point should have a unique associative name in scope of
single CCM object. Connection end-points can be statically and/or dynamically
registered/configured. More advanced implementation may use centralized service to
resolve/retrieve connection end-points and related credentials on demand.
Invoker code retrieves FutoIn interface references from CCM object and invokes
FutoIn interface function through special "call" method, passing function name
and associative parameter map. Invocation result is returned as a map of result
values.
There should be a common FutoIn exception type from which Expected and Unexpected
FutoIn exception types must inherit as defined in FTN3.
By design, most Executor implementations also implement Invoker design as it is required
for separation of concerns on Service/RPC level, but not single project level.
There are several native events supported using FTN15 Native Event interface
1.1. Reserved interface names
Some of interface names can be reserved for internal semantics, like runtime
resolving service interface.
All names starting with hash "#" symbol are reserved for internal purpose in
Invoker implementation concept.
1.1.2. Pre-defined interfaces names:
- "#resolver" - Runtime Iface Resolver v1.x
- "#auth" - AuthService v1.x
- "#defense" - Defense system v1.x
- "#acl" - Access Control system v1.x
- "#log" - Audit Logging v1.x
- "#cache.{bucket}" - cache v1.x for "{bucket}"
1.2. Type and identifier safety
There should be a Simple CCM, which is lightweight and designed for small memory
footprint and/or high performance cases. Advanced CCM interface should inherit
from the Simple one.
Advanced CCM implementation must implement a special native dummy interface,
even if there is no difference with Simple one, so native link/resolve error is generated,
if Simple CCM implementation is provided to Client code, which expects Advanced CCM.
Advanced CCM implementation can retrieve FutoIn interface definitions and enforce
additional checks, including compile and/or run-time specialized native interface
building.
In such process, FutoIn interface functions must become native interface members with
every function parameter becoming native member's formal parameter. If multiple
values can be returned natively, result values are mapped to those. Otherwise,
map of result values is returned. If there are no
result values then native member returns nothing and should complete as soon
as request message is scheduled to be sent without waiting for reply.
Note: Simple CCM is not expected to parse interfaces. Therefore, all request
messages must have "forcersp" flag and Simple CCM must expect response for every call.
1.3. Invoker calls to Executor in scope of the same process
FutoIn implementations are allowed to optimize calls within single process in
implementation-defined way, keeping the same behavior between remote and local calls.
Local calls must never execute if there are Invoker frames on execution stack. It means, Invoker
function must return before Executor runs or Executor must run in a different thread. Yes, it may have performance
issues, but is natural for async programming.
1.4. Communication Errors
Invoker should transparently handle transitional communication errors with implicit retries.
1.5. HMAC signature support
Please referer to FTN6 Interface Executor Concept for details.
HMAC is supported only by AdvancedCCM.
2. Invoker interfaces
Reference Invoker concept is built around FTN12 Async API
2.1. Connection and Credentials Manager
Simple CCM:
- event 'register' ( name, ifacever, rawinfo ) - when new interface get registered
- event 'unregister' ( name, rawinfo ) - when interface get unregistered
- event 'close' - when CCM is shutdown
- void register( AsyncSteps as, name, ifacever, endpoint [, credentials [, options] ] )
- register standard MasterService end-point (adds steps to as)
- as - AsyncSteps instance as registration may be waiting for external resources
- name - unique identifier in scope of CCM instance
- ifacever - iface identifier and its version separated by colon, see note below
- endpoint - URI or any other resource identifier of iface implementing peer, accepted by CCM implementation
- "credentials* - optional, authentication credentials (string)
- 'master' - enable MasterService authentication logic (Advanced CCM only)
- '{user}:{clear-text-password}' - send as is in the 'sec' section
- '-hmac:{user}' - HMAC generation, see options.hmacKey and options.hmacAlgo for details
- NOTE: some more reserved words and/or patterns can appear in the future
- options - optional, override global options of CCM
- NativeIface iface( name )
- Get native interface wrapper for invocation of iface methods
- name - see register()
- Note: it can have template/generic counterpart like iface() for strict type languages
- void unRegister( name )
- unregister previously registered interface (should not be used, unless really needed)
- name - see register()
- NativeDefenseIface defense() - shortcut to iface( "#defense" )
- NativeLogIface log() - returns native API interface as defined in FTN9 IF AuditLogService
- NativeCacheIface cache( [bucket="default"] ) - returns native API interface for Cache as defined in FTN14 Cache
- void assertIface( name, ifacever )
- Assert that interface registered by name matches major version and minor is not less than required.
- This function must generate fatal error and forbid any further execution
- name - see register()
- ifacever - required interface and its version
- void alias( name, alias )
- Alias interface name with another name
- name - as provided in register()
- alias - register alias for name
- void close()
Advanced CCM extensions:
- void initFromCache( AsyncSteps as, cache_l1_endpoint )
- cache_l1_endpoint - end-point URL for Cache L1
- as.success(), if successfully initialized from cache (no need to register interfaces)
- Note: Cache L1 needs to be registered first
- void cacheInit( AsyncSteps as )
- call after all registrations are done to cache them
2.1.1. Unique interface name in CCM instance (name)
The idea behind is that each component/library/etc. assumes that end product registers interfaces,
their endpoints and possibly provides other information during initialization phase or
prior to using the specific component.
Example:
// Init
AsyncSteps as;
as.add( function( as ){
ccm.register( as, "some_id', "some.iface:1.3", "https://..." )
} )
.add( function( as ){
// register must complete, before the interface can be aliased
ccm.alias( "some_id', "componentA.ifaceA" )
ccm.alias( "some_id', "componentB.ifaceB" )
ComponentA.init( as );
ComponentB.init( as );
startService( as );
} )
// start actual execution
.execute();
// in Component A (note minor version less than registered)
ComponentA.init( as )
{
ccm.assertIface( "componentA.iface", "some.iface:1.0" )
iface = ccm.iface( "componentA.iface" )
iface.someFunc( as )
}
// in Component B (note different minor version)
ComponentB.init( as )
{
ccm.assertIface( "componentB.iface", "some.iface:1.1" )
iface = ccm.iface( "componentB.iface" )
iface.someFunc( as )
}
2.1.2. Interface and version
ifacever must be represented as FutoIn interface identifier and version, separated by colon ":"
Example: "futoin.master.service:1.0", "futoin.master.service:2.1".
Invoker implementation must ensure that major versions match and registered minor version is not less
than requested minor version.
2.1.3. End point URL
The following URL schemes should be supported:
- http://
- https://
- ws:// - with automatic fallback to http://, if not supported by Invoker implementation
- wss:// - with automatic fallback to https://, if not supported by Invoker implementation
- self:// - implemented in scope of the same Executor, when used as CCM for Executor
- SecureChannel
- The rest is implementation-defined name/pointer to implementation
- unix://{framing_type}/{file_path} - UNIX stream socket file with specified framing type
- SecureChannel
- Framing Type:
- browser://{name} - Web Browser communication channel
- SecureChannel, if options.targetOrigin parameter is set set
- Communication to be done through HTML5 Web Messaging
- options.targetOrigin of ccm.register() - the value for targetOrigin parameter of window.postMessage()
- name
- Either "parent" - send to current frame's parent window
- Or global variable name (must have postMessage() property)
- Or unique HTML id of target iframe element
- Note: messages are sent as-is using HTML5 structured cloning algorithm, but not JSON representation
- secure+{anyscheme}:// - force any scheme to be seen as secure (e.g. in controlled LAN)
- SecureChannel
- Example: secure+http://, secure+ws://
2.1.4. End point options
- specDirs - Search dirs for spec definition or spec instance directly
- executor - pass client-side executor for bi-directional communication channels
- targetOrigin - browser-only. Origin of target for window.postMessage()
- retryCount=1 - how many times to retry the call on CommError
- callTimeoutMS - Overall call timeout (int)
- nativeImpl - Native iface implementation class
- hmacKey - Base64-encoded key for HMAC
- hmacAlgo - one of pre-defined or custom hash algorithms for use with HMAC
2.2. Native FutoIn interface interface
- event 'connect' - called on bi-directional channels when connection is established
- event 'close' - called when interface is unregistered or CCM shutdown
- event 'disconnect' - called on bi-directional channel on disconnect
- void call( AsyncSteps as, name, params [, upload_data [, download_stream [, timeout ]]] )
- generic FutoIn function call interface
- result is passed through AsyncSteps.success() as a map
- as - AsyncSteps
- name - function name
- params - map of parameters
- upload_data - either raw data or input stream, if provided
- download_stream - output stream, if provided
- timeout - if provided, overrides the default from CCM configuration, <=0 - disable timeout
- Note: data transfer requests must not interleave with non-data calls, if parallel processing is possible
- InterfaceInfo ifaceInfo() - return interface to introspect interface information:
- void bindDerivedKey( AsyncSteps as )
- results with DerivedKeyAccessor through as.success()
Advanced CCM:
- void _member_call_intercept( AsyncSteps as, param1, param2, param3, ... )
- Platform/Language-specific interception of undefined method calls, converting to
- as - AsyncSteps
- paramN - unrolled list of parameters in exact sequence as defined in the iface
- NOTE: name is taken from invoker member name and/or stored in proxy function
2.3. Derived Key accessing wrapper
The same interface can be used in parallel. This feature generates and
binds specific DerivedKey for the following call.
- bindDerivedKey( AsyncSteps as )
- as - AsyncSteps
- results though as.success()
- arg1 - NativeInterface instance with predetermined derived key to be used
- arg2 - DerivedKey instance
2.4. Derived Key
See FTN6 Interface Executor Concept
2.5. AsyncSteps interface
See FTN12 Async API
2.5. InterfaceInfo
- name() - get FutoIn interface type
- version() - get FutoIn interface version
- inherits() - get list of inherited interfaces starting from the most derived, may be null
- funcs() - get list of available functions, may be null
- constraints() - get list of interface constraints, may be null
=END OF SPEC=