diff --git a/application/cmdbabstract.class.inc.php b/application/cmdbabstract.class.inc.php
index 8c0441e84c..a5d0983477 100644
--- a/application/cmdbabstract.class.inc.php
+++ b/application/cmdbabstract.class.inc.php
@@ -524,6 +524,11 @@ JS
$sLabel = Dict::S('Tag:Synchronized');
$sSynchroTagId = 'synchro_icon-'.$this->GetKey();
$aTags[$sSynchroTagId] = ['title' => $sTip, 'css_classes' => 'ibo-object-details--tag--synchronized', 'decoration_classes' => 'fas fa-lock', 'label' => $sLabel];
+ if (UserRights::IsActionAllowed('SynchroReplica', UR_ACTION_READ)) {
+ $sFilter = 'SELECT SynchroReplica WHERE dest_class=\''.get_class($this).'\' AND dest_id='.$this->GetKey();
+ $sUrlSearchReplica = 'UI.php?operation=search&filter='.urlencode(json_encode([$sFilter, [], []]));
+ $oPage->add_ready_script("$('#$sSynchroTagId').on('click',function() {window.location = '$sUrlSearchReplica' });");
+ }
}
}
diff --git a/synchro/replica.php b/synchro/replica.php
index 0c9c16726d..26aedfa6fc 100644
--- a/synchro/replica.php
+++ b/synchro/replica.php
@@ -19,6 +19,7 @@
*/
use Combodo\iTop\Application\WebPage\iTopWebPage;
+use Combodo\iTop\Core\CMDBChange\CMDBChangeOrigin;
require_once('../approot.inc.php');
require_once(APPROOT.'/application/application.inc.php');
@@ -34,6 +35,90 @@ $oP = new iTopWebPage("iTop - Synchro Replicas");
// Main program
$sOperation = utils::ReadParam('operation', 'details');
+
+/**
+ * @param \DBObject|null $oReplica
+ * @param $this
+ *
+ * @return \SynchroLog
+ * @throws \ArchivedObjectException
+ * @throws \CoreCannotSaveObjectException
+ * @throws \CoreException
+ * @throws \CoreUnexpectedValue
+ * @throws \CoreWarning
+ * @throws \MySQLException
+ * @throws \OQLException
+ * @throws \SynchroExceptionNotStarted
+ */
+function Synchro($oReplica): SynchroLog
+{
+ $oDataSource = MetaModel::GetObject('SynchroDataSource', $oReplica->Get('sync_source_id'));
+
+ $oStatLog = new SynchroLog();
+ $oStatLog->Set('sync_source_id', $oDataSource->GetKey());
+ $oStatLog->Set('start_date', time());
+ $oStatLog->Set('status', 'running');
+ $oStatLog->AddTrace('Manual synchro');
+
+ // Get the list of SQL columns
+ $aAttCodesExpected = array();
+ $aAttCodesToReconcile = array();
+ $aAttCodesToUpdate = array();
+ $sSelectAtt = 'SELECT SynchroAttribute WHERE sync_source_id = :source_id AND (update = 1 OR reconcile = 1)';
+ $oSetAtt = new DBObjectSet(DBObjectSearch::FromOQL($sSelectAtt), array() /* order by*/, array('source_id' => $oDataSource->GetKey()) /* aArgs */);
+ while ($oSyncAtt = $oSetAtt->Fetch()) {
+ if ($oSyncAtt->Get('update')) {
+ $aAttCodesToUpdate[$oSyncAtt->Get('attcode')] = $oSyncAtt;
+ }
+ if ($oSyncAtt->Get('reconcile')) {
+ $aAttCodesToReconcile[$oSyncAtt->Get('attcode')] = $oSyncAtt;
+ }
+ $aAttCodesExpected[$oSyncAtt->Get('attcode')] = $oSyncAtt;
+ }
+
+ // Get the list of attributes, determine reconciliation keys and update targets
+ //
+ if ($oDataSource->Get('reconciliation_policy') == 'use_attributes') {
+ $aReconciliationKeys = $aAttCodesToReconcile;
+ } elseif ($oDataSource->Get('reconciliation_policy') == 'use_primary_key') {
+ // Override the settings made at the attribute level !
+ $aReconciliationKeys = array('primary_key' => null);
+ }
+
+ if (count($aAttCodesToUpdate) == 0) {
+ $oStatLog->AddTrace('No attribute to update');
+ throw new SynchroExceptionNotStarted('There is no attribute to update');
+ }
+ if (count($aReconciliationKeys) == 0) {
+ $oStatLog->AddTrace('No attribute for reconciliation');
+ throw new SynchroExceptionNotStarted('No attribute for reconciliation');
+ }
+
+
+ $aAttributesToUpdate = array();
+ foreach ($aAttCodesToUpdate as $sAttCode => $oSyncAtt) {
+ $oAttDef = MetaModel::GetAttributeDef($oDataSource->GetTargetClass(), $sAttCode);
+ if ($oAttDef->IsWritable()) {
+ $aAttributesToUpdate[$sAttCode] = $oSyncAtt;
+ }
+ }
+ // Create a change used for logging all the modifications/creations happening during the synchro
+ $oChange = MetaModel::NewObject('CMDBChange');
+ $oChange->Set('date', time());
+ $sUserString = CMDBChange::GetCurrentUserName();
+ $oChange->Set('userinfo', $sUserString.' '.Dict::S('Core:SyncDataExchangeComment'));
+ $oChange->Set('origin', CMDBChangeOrigin::SYNCHRO_DATA_SOURCE);
+ $oChange->DBInsert();
+ CMDBObject::SetCurrentChange($oChange);
+
+ $oReplica->InitExtendedData($oDataSource);
+
+ $oReplica->Synchro($oDataSource, $aReconciliationKeys, $aAttributesToUpdate, $oChange, $oStatLog);
+ $oReplica->DBUpdate();
+
+ return $oStatLog;
+}
+
try {
switch ($sOperation) {
case 'details':
@@ -69,6 +154,44 @@ try {
$sDelete = utils::GetAbsoluteUrlAppRoot().'pages/UI.php?'.$_SERVER['QUERY_STRING'];
header("Location: $sDelete");
break;
+
+ case 'unlinksynchro':
+ $iId = utils::ReadParam('id', null);
+ if ($iId == null) {
+ throw new ApplicationException(Dict::Format('UI:Error:1ParametersMissing', 'id'));
+ }
+ $oReplica = MetaModel::GetObject('SynchroReplica', $iId);
+ $oReplica->Set('dest_id', '');
+ $oReplica->Set('status', 'new');
+ $oReplica->DBWrite();
+
+ $oStatLog = Synchro($oReplica);
+ $oP->add(implode('
', $oStatLog->GetTraces()));
+
+ $oReplica->DisplayDetails($oP);
+ break;
+
+ case 'unlink':
+ $iId = utils::ReadParam('id', null);
+ if ($iId == null) {
+ throw new ApplicationException(Dict::Format('UI:Error:1ParametersMissing', 'id'));
+ }
+ $oReplica = MetaModel::GetObject('SynchroReplica', $iId);
+ $oReplica->Set('dest_id', '');
+ $oReplica->Set('status', 'new');
+ $oReplica->DBWrite();
+
+ $oReplica->DisplayDetails($oP);
+ break;
+
+ case 'synchro':
+ $iId = utils::ReadParam('id', null);
+ if ($iId == null) {
+ throw new ApplicationException(Dict::Format('UI:Error:1ParametersMissing', 'id'));
+ }
+ $oReplica = MetaModel::GetObject('SynchroReplica', $iId);
+ $oStatLog = Synchro($oReplica);
+ break;
}
} catch (CoreException $e) {
$oP->p('An error occured while running the query:');
diff --git a/synchro/synchrodatasource.class.inc.php b/synchro/synchrodatasource.class.inc.php
index 46ad018f42..7f5bfac90d 100644
--- a/synchro/synchrodatasource.class.inc.php
+++ b/synchro/synchrodatasource.class.inc.php
@@ -6,6 +6,11 @@
*/
use Combodo\iTop\Application\WebPage\WebPage;
+use Combodo\iTop\Application\UI\Base\Component\Button\ButtonUIBlockFactory;
+use Combodo\iTop\Application\UI\Base\Component\PopoverMenu\PopoverMenu;
+use Combodo\iTop\Application\UI\Base\Component\Title\TitleUIBlockFactory;
+use Combodo\iTop\Application\UI\Base\Component\Toolbar\ToolbarUIBlockFactory;
+use Combodo\iTop\Application\UI\Base\Layout\UIContentBlockUIBlockFactory;
class SynchroDataSource extends cmdbAbstractObject
{
@@ -2108,6 +2113,12 @@ class SynchroReplica extends DBObject implements iDisplay
// MetaModel::Init_SetZListItems('advanced_search', array('name')); // Criteria of the advanced search form
}
+ public function InitExtendedData($oSource)
+ {
+ $sSQLTable = $oSource->GetDataTable();
+ $this->m_aExtendedData = $this->LoadExtendedDataFromTable($sSQLTable);
+ }
+
public function __construct($aRow = null, $sClassAlias = '', $aAttToLoad = null, $aExtendedDataSpec = null)
{
parent::__construct($aRow, $sClassAlias, $aAttToLoad, $aExtendedDataSpec);
@@ -2681,14 +2692,102 @@ class SynchroReplica extends DBObject implements iDisplay
public function DisplayDetails(WebPage $oPage, $bEditMode = false)
{
// Object's details
- //$this->DisplayBareHeader($oPage, $bEditMode);
+ $this->DisplayBareHeader($oPage, $bEditMode);
+
$oPage->AddTabContainer(OBJECT_PROPERTIES_TAB);
$oPage->SetCurrentTabContainer(OBJECT_PROPERTIES_TAB);
$oPage->SetCurrentTab('UI:PropertiesTab');
$this->DisplayBareProperties($oPage, $bEditMode);
}
+ public function DisplayBareHeader(WebPage $oPage, $bEditMode = false)
+ {
+ $oBlock = UIContentBlockUIBlockFactory::MakeStandard('title-for-replica', ['ibo-page-header--replica-title']);
+ $oPage->AddSubBlock($oBlock);
+ $oPage->add_style('.ibo-page-header--replica-title{ display: table; width: 100%;}');
+ $oPage->add_style('.ibo-page-header--replica-title>.ibo-toolbar--button{ display: table-cell; vertical-align:middle;}');
- public function DisplayBareProperties(WebPage $oPage, $bEditMode = false, $sPrefix = '', $aExtraParams = [])
+ $sId = $this->GetKey();
+ $oTitle = TitleUIBlockFactory::MakeNeutral(Dict::S('Class:SynchroReplica'));
+ $oBlock->AddSubBlock($oTitle);
+ $oActionsToolbar = ToolbarUIBlockFactory::MakeForButton(MenuBlock::ACTIONS_TOOLBAR_ID_PREFIX.$sId);
+ $oActionsToolbar->AddCSSClass('ibo-panel--toolbar');
+ $oBlock->AddSubBlock($oActionsToolbar);
+
+ $sClass = get_class($this);
+ $sRootUrl = utils::GetAbsoluteUrlAppRoot();
+ $sUIPage = cmdbAbstractObject::ComputeStandardUIPage($sClass);
+ $oAppContext = new ApplicationContext();
+ $sContext = $oAppContext->GetForLink();
+ if (utils::IsNotNullOrEmptyString($sContext)) {
+ $sContext = '&'.$sContext;
+ }
+
+ $aActions = [];
+ //Delete
+ if (UserRights::IsActionAllowed($sClass, UR_ACTION_DELETE)) {
+ $aActions['UI:Menu:Delete'] = array(
+ 'label' => Dict::S('UI:Menu:Delete'),
+ 'url' => "{$sRootUrl}pages/$sUIPage?operation=delete&class=$sClass&id=$sId{$sContext}",
+ );
+ }
+
+ if (UserRights::IsActionAllowed($sClass, UR_ACTION_MODIFY)) {
+ if (count($aActions) > 0) {
+ $sSeparator = '