Merge remote-tracking branch 'refs/remotes/gitdedalo/v7_developer' into v7_developer

Author: alex-render

.gitignore

@@ -87,6 +87,7 @@ vendor/*
 #composer.json
 #composer.lock
 composer.phar
+composer.local.json
 /var
 
 # Ignore paths that contain generated content.

config/sample.config.php

@@ -132,6 +132,8 @@
 
 
 // required files
+	// version. Info about current version and build
+	include(DEDALO_CORE_PATH . '/base/version.inc');
 	// logger. Logger class
 	include(DEDALO_CORE_PATH . '/logger/class.logger.php');
 	// core_functions. Basic common functions (before session start)
@@ -142,21 +144,36 @@
 	include(DEDALO_CONFIG_PATH . '/config_db.php');
 	// dd_tipos. List of main Dédalo resolved tipos
 	include(DEDALO_CORE_PATH . '/base/dd_tipos.php');
-	// version. Info about current version and build
-	include(DEDALO_CORE_PATH . '/base/version.inc');
 
 
 
-// SESSIONS
+// sessions
 	define('DEDALO_SESSIONS_PATH', dirname(DEDALO_ROOT_PATH, 2) . '/sessions');
 
-	if (session_status()!==PHP_SESSION_ACTIVE) {
+	// handler: files | redis | memcached | postgresql | user
+	if (!defined('DEDALO_SESSION_HANDLER')) {
+		define('DEDALO_SESSION_HANDLER', 'files');
+	}
 
-		// HANDLER
-		$SESSION_HANDLER = 'files';	// files | memcached | user | postgresql
-		define('DEDALO_SESSION_HANDLER', $SESSION_HANDLER);
+	// save_path: define explicitly if needed (e.g. redis)
+	if (!defined('DEDALO_SESSION_SAVE_PATH')) {
+		switch (DEDALO_SESSION_HANDLER) {
+			case 'redis':
+				define('DEDALO_SESSION_SAVE_PATH', 'tcp://127.0.0.1:6379');
+				break;
+			case 'memcached':
+				define('DEDALO_SESSION_SAVE_PATH', '127.0.0.1:11211');
+				break;
+			case 'files':
+			default:
+				define('DEDALO_SESSION_SAVE_PATH', DEDALO_SESSIONS_PATH);
+				break;
+		}
+	}
+
+	if (session_status()!==PHP_SESSION_ACTIVE && !defined('DEDALO_RR_WORKER')) {
 
-		// LIFETIME
+		// lifetime
 		// Set max duration of dedalo user session
 		// Use ini directive to set session.gc_maxlifetime (Garbage Collection lifetime)
 		// Use session_cache_expire to set duration of session
@@ -165,16 +182,20 @@
 		$session_duration_hours	= $session_duration_hours ?? 8;
 		$timeout_seconds		= intval($session_duration_hours*3600); // in seconds
 
+		// session name
+		$sesion_name = 'dedalo_'.DEDALO_ENTITY;
+
 		// session start
 		$cookie_secure		= (DEDALO_PROTOCOL==='https://');
 		$cookie_samesite	= (DEVELOPMENT_SERVER===true) ? 'Lax' : 'Strict';
+
 		session_start_manager([
-			'save_handler'				=> 'files',
+			'save_handler'				=> DEDALO_SESSION_HANDLER,
 			'timeout_seconds'			=> $timeout_seconds,
-			'save_path'					=> DEDALO_SESSIONS_PATH,
+			'save_path'					=> DEDALO_SESSION_SAVE_PATH,
 			// 'additional_save_path'	=> false, bool optional
 			'prevent_session_lock'		=> defined('PREVENT_SESSION_LOCK') ? PREVENT_SESSION_LOCK : false,
-			'session_name'				=> 'dedalo_'.DEDALO_ENTITY,
+			'session_name'				=> $sesion_name,
 			// cookie params
 			'cookie_secure'				=> $cookie_secure, // Only https (true | false)
 			'cookie_samesite'			=> $cookie_samesite // (None | Lax | Strict)

core/api/v1/common/class.dd_utils_api.php

@@ -1543,6 +1543,105 @@ public static function get_process_status(object $rqo) {
 
 
 
+	/**
+	* GET_PROCESS_STATUS_POLL
+	* One-shot polling version of get_process_status.
+	* Reads the process file once and returns a standard JSON response.
+	* Unlike the SSE version (`get_process_status`), this method does NOT use
+	* streaming, die(), or blocking loops — making it compatible with both
+	* PHP-FPM and RoadRunner worker contexts.
+	*
+	* The client calls this endpoint repeatedly via setInterval to monitor
+	* process progress with the same functional result as SSE at 1s update_rate.
+	*
+	* @param object $rqo
+	* {
+	*   options: {
+	*     pid:   int    Process ID
+	*     pfile: string Process output file name
+	*   }
+	* }
+	* @return object $response
+	* {
+	*   result:     bool
+	*   pid:        int
+	*   pfile:      string
+	*   is_running: bool
+	*   data:       object  { msg, counter, total, ... }
+	*   time:       string  Current server time
+	*   errors:     array
+	* }
+	*/
+	public static function get_process_status_poll(object $rqo) : object {
+
+		// session unlock
+			session_write_close();
+
+		// response
+			$response = new stdClass();
+				$response->result		= false;
+				$response->msg			= 'Error. Request failed ['.__FUNCTION__.']';
+				$response->errors		= [];
+
+		// only logged users can access process status
+			if (login::is_logged()!==true) {
+				$response->msg = 'Authentication error: please login';
+				$response->errors[] = 'Not logged';
+				return $response;
+			}
+
+		// options
+			$pfile	= $rqo->options->pfile ?? null;
+			$pid	= $rqo->options->pid ?? null;
+
+		// mandatory vars
+			if (empty($pfile) || empty($pid)) {
+				$response->msg = 'Error: pfile and pid are mandatory';
+				$response->errors[] = 'Missing pfile or pid';
+				return $response;
+			}
+
+		// process
+			$process = new process();
+				$process->setPid($pid);
+				$process->setFile(process::get_process_path() .'/'. $pfile);
+
+		// read process info (one shot)
+			$is_running	= $process->status(); // bool
+			$array_data	= $process->read(); // array
+
+			// decode last line
+			$value = isset($array_data[0])
+				? (json_decode($array_data[0]) ?? $array_data[0])
+				: '';
+
+			$data = is_object($value)
+				? $value
+				: (object)['msg' => $value];
+
+		// clean up finished process
+			if ($is_running===false) {
+				processes::delete_process_item(
+					$pid,
+					logged_user_id()
+				);
+			}
+
+		// response
+			$response->result		= true;
+			$response->pid			= $pid;
+			$response->pfile		= $pfile;
+			$response->is_running	= $is_running;
+			$response->data			= $data;
+			$response->time			= date("Y-m-d H:i:s");
+			$response->errors		= [];
+
+
+		return $response;
+	}//end get_process_status_poll
+
+
+
 	/**
 	* STOP_PROCESS
 	* @param object $rqo

core/common/js/ui.js

@@ -485,6 +485,7 @@ export const ui = {
 
 				// css
 					const ar_css = [
+						'mini',
 						instance.model + '_mini' // add suffix '_mini'
 					]
 					wrapper.classList.add(...ar_css)

core/component_common/js/component_common.js

@@ -1573,7 +1573,7 @@ export const get_dataframe = async function(options) {
 	const mode					= options.mode
 	const lang					= options.lang
 
-	const request_config = self.context.request_config || null
+	const request_config = self.context?.request_config || null
 
 	// original_dataframe_ddo
 	const original_dataframe_ddo = request_config

core/component_relation_common/trait.search_component_relation_common.php

@@ -60,6 +60,12 @@ protected static function extract_normalized_relation_q(object $query_object) :
         // remove the id property from q_raw if exists
         if (is_object($q_raw) && isset($q_raw->id)) {
             unset($q_raw->id);
+        } elseif (is_array($q_raw)) {
+            foreach ($q_raw as $item) {
+                if (is_object($item) && isset($item->id)) {
+                    unset($item->id);
+                }
+            }
         }
 
         // For unification, all non string are JSON encoded

core/component_select/js/component_select.js

@@ -167,4 +167,76 @@ component_select.prototype.add_new_element = async function(target_section_tipo)
 
 
 
+/**
+* BUILD_CHANGED_DATA_ITEM
+* Parses the select value and builds a frozen changed_data_item object.
+* Used by edit views (via handle_select_change) and search view (directly).
+* @param HTMLSelectElement select
+* @param int|null id
+* @return object {changed_data_item, parsed_value}
+*/
+export const build_changed_data_item = function(select, id=null) {
+
+	// parse select value from JSON string to object locator
+	const parsed_value = (select.value.length > 0)
+		? JSON.parse(select.value)
+		: null
+
+	// add id to parsed_value if available
+	if (parsed_value && id) {
+		parsed_value.id = id
+	}
+
+	// build changed_data_item
+	const changed_data_item = Object.freeze({
+		action	: (parsed_value != null) ? 'update' : 'remove',
+		id		: id,
+		value	: parsed_value // object locator or null expected
+	})
+
+	return {
+		changed_data_item	: changed_data_item,
+		parsed_value		: parsed_value
+	}
+}//end build_changed_data_item
+
+
+
+/**
+* HANDLE_SELECT_CHANGE
+* Common change handler for component_select across all edit views.
+* Parses the select value, builds changed_data_item, sets changed_data,
+* and saves via change_value. Returns parsed_value for view-specific hooks.
+* @param object self - Component instance
+* @param HTMLSelectElement select - The select DOM element
+* @param int|null id - Entry id from data
+* @return object|null parsed_value - The parsed locator or null
+*/
+export const handle_select_change = async function(self, select, id=null) {
+
+	// resolve id from current data if not provided
+	// (when component was initially empty, the closure id is null,
+	// but after first save the entry gets an id from the API)
+	if (id === null) {
+		id = self.data.entries?.[0]?.id ?? null
+	}
+
+	// build changed_data_item (parse + freeze)
+	const {changed_data_item, parsed_value} = build_changed_data_item(select, id)
+
+	// fix instance changed_data
+	self.set_changed_data(changed_data_item)
+
+	// force to save on every change
+	await self.change_value({
+		changed_data	: [changed_data_item],
+		refresh			: false,
+		remove_dialog	: false
+	})
+
+	return parsed_value
+}//end handle_select_change
+
+
+
 // @license-end

core/component_select/js/render_search_component_select.js

@@ -7,6 +7,7 @@
 // imports
 	import {event_manager} from '../../common/js/event_manager.js'
 	import {ui} from '../../common/js/ui.js'
+	import {build_changed_data_item} from './component_select.js'
 
 
 
@@ -143,18 +144,13 @@ const get_content_value = (i, current_value, self) => {
 		// change event
 			select.addEventListener('change', function(){
 
-				const parsed_value = (select.value.length>0) ? JSON.parse(select.value) : null
-
-				const changed_data_item = Object.freeze({
-					action	: (parsed_value != null) ? 'update' : 'remove',
-					id		: (parsed_value != null) ? parsed_value.id : null,
-					value	: parsed_value
-				})
+				// build changed_data_item from select value
+				// read id dynamically from self.data (not from stale closure)
+				const current_id = self.data.entries?.[i]?.id ?? null
+				const {changed_data_item} = build_changed_data_item(select, current_id)
 
 				// update the instance data (previous to save)
 					self.update_data_value(changed_data_item)
-				// set data.changed_data. The change_data to the instance
-					// self.data.changed_data = changed_data
 				// publish search. Event to update the dom elements of the instance
 					event_manager.publish('change_search_element', self)
 			})//end event change