Reference Source

js/runtime/service_operation.js

  1. // NPM IMPORTS
  2. // import assert from 'assert'
  3.  
  4. // COMMON IMPORTS
  5. import T             from '../../../node_modules/devapt-core-common/dist/js/utils/types'
  6. import Stream        from '../../../node_modules/devapt-core-common/dist/js/messaging/stream'
  7.  
  8.  
  9. let context = 'browser/runtime/service_operation'
  10.  
  11.  
  12.  
  13. /**
  14.  * @file client ServiceOperation class.
  15.  * @author Luc BORIES
  16.  * @license Apache-2.0
  17.  */
  18. export default class ServiceOperation
  19. {
  20. 	/**
  21. 	 * Create a client Runtime instance.
  22. 	 * 
  23. 	 * @param {string} arg_svc_name - service name.
  24. 	 * @param {object} arg_svc_settings - service settiings.
  25. 	 * 
  26. 	 * @returns {nothing}
  27. 	 */
  28. 	constructor(arg_op_name, arg_op_settings)
  29. 	{
  30. 		this._name = arg_op_name
  31. 		this._settings = arg_op_settings
  32. 		this.is_service_operation = true
  33. 	}
  34.  
  35.  
  36.  
  37. 	/**
  38. 	 * Get service name.
  39. 	 * 
  40. 	 * @returns {string}
  41. 	 */
  42. 	get_name()
  43. 	{
  44. 		return this._name
  45. 	}
  46.  
  47.  
  48.  
  49. 	/**
  50. 	 * Execute operation on browser.
  51. 	 * 
  52. 	 * @param {any}    arg_operands    - operation operands.
  53. 	 * @param {object} arg_credentials - session credentials.
  54. 	 * 
  55. 	 * @returns {Stream} - service results stream.
  56. 	 */
  57. 	execute_on_browser()
  58. 	{
  59. 		// TODO
  60. 	}
  61. 	
  62. 	
  63. 	/**
  64. 	 * Execute operation on remote server.
  65. 	 * 
  66. 	 * @param {object} arg_svc_socket  - remote service socket.
  67. 	 * @param {string} arg_svc_path    - remote service socket.
  68. 	 * @param {any}    arg_operands    - operation operands.
  69. 	 * @param {object} arg_credentials - session credentials.
  70. 	 * @param {string} arg_session_uid - session unique id.
  71. 	 * 
  72. 	 * @returns {Stream} - service results stream.
  73. 	 */
  74. 	execute_on_server(arg_svc_socket, arg_svc_path, arg_operands, arg_credentials, arg_session_uid)
  75. 	{
  76. 		const op_name = this.get_name()
  77. 		// console.log(context + ':execute_remote:op=%s:path=%s:operands=%o', op_name, arg_svc_path, arg_operands)
  78.  
  79. 		// DEFINE REQUEST PAYLOAD
  80. 		const request = {
  81. 			session_uid:arg_session_uid,
  82. 			service:this._settings.service.get_name(),
  83. 			operation:op_name,
  84. 			operands: T.isArray(arg_operands) ? arg_operands : (arg_operands ? [arg_operands] : []),
  85. 			credentials:arg_credentials
  86. 		}
  87. 		
  88. 		// REPEAT EVERY xxx MILLISECONDS FOR LOCAL SETTINGS
  89. 		if ( T.isObject(arg_operands) && T.isObject(arg_operands.poller) )
  90. 		{
  91. 			const poller_settings = arg_operands.poller
  92. 			this.create_poller(poller_settings, op_name, arg_credentials, arg_svc_socket, [arg_operands])
  93. 		}
  94. 		
  95. 		let stream = Stream.from_emitter_event(arg_svc_socket, op_name)
  96.  
  97. 		// DEBOUNCE STREAM
  98. 		if ( T.isObject(arg_operands) && T.isNumber(arg_operands.debounce_milliseconds) )
  99. 		{
  100. 			stream = stream.debounce_immediate(arg_operands.debounce_milliseconds)
  101. 		}
  102.  
  103. 		stream.on_error(
  104. 			(error) => {
  105. 				console.error(context + 'svc=' + arg_svc_path + ':op_name=' + op_name + ':error=', error)
  106. 			}
  107. 		)
  108.  
  109. 		// SEND REQUEST
  110. 		console.log(context + ':execute_remote:request=', request)
  111. 		arg_svc_socket.emit(op_name, request)
  112.  
  113. 		
  114. 		// RETURN RESPONSE STREAM
  115. 		return stream
  116. 	}
  117. }