path: root/Zotlabs/Update/_1236.php

<?php

namespace Zotlabs\Update;

use Zotlabs\Lib\Config;
use Zotlabs\Lib\Libzot;

class _1236 {

	function run() {

		$r = q("SELECT channel.channel_address, channel.channel_hash, xchan.xchan_guid, channel.channel_pubkey, channel.channel_portable_id FROM channel
			LEFT JOIN xchan ON channel_hash = xchan_hash
			WHERE xchan.xchan_network = 'zot'
			AND channel.channel_removed = 0"
		);

		$i = 0;

		foreach($r as $rr) {

			$zot_xchan = $rr['channel_hash'];
			$guid = $rr['xchan_guid'];

			$xchan = q("SELECT xchan_hash, xchan_guid_sig FROM xchan WHERE xchan_guid = '%s' AND xchan_network = 'zot6'",
				dbesc($guid)
			);

			if(!$xchan) {
				// This should not actually happen.
				// A zot6 xchan for every channel should have been
				// created in update _1226.

				// In case this failed, we will try to fix it here.
				logger('No zot6 xchan found for: ' . $rr['channel_hash']);

				$zhash = $rr['channel_portable_id'];

				if(!$zhash) {
					$zhash = Libzot::make_xchan_hash($rr['xchan_guid'], $rr['channel_pubkey']);

					q("UPDATE channel SET channel_portable_id = '%s' WHERE channel_hash = '%s'",
						dbesc($zhash),
						dbesc($zot_xchan)
					);
				}

				if(!$zhash) {
					logger('Could not create zot6 xchan_hash for: ' . $rr['channel_hash']);
					continue;
				}

				$x = q("SELECT * FROM xchan WHERE xchan_hash = '%s' LIMIT 1",
					dbesc($rr['channel_hash'])
				);

				if($x) {
					$rec = $x[0];
					$rec['xchan_hash'] = $zhash;
					$rec['xchan_guid_sig'] = 'sha256.' . $rec['xchan_guid_sig'];
					$rec['xchan_network'] = 'zot6';
					xchan_store_lowlevel($rec);
				}

				// Now try again
				$xchan = q("SELECT xchan_hash, xchan_guid_sig FROM xchan WHERE xchan_guid = '%s' AND xchan_network = 'zot6'",
					dbesc($guid)
				);

				if(! $xchan) {
					logger('Could not create zot6 xchan record for: ' . $zot_xchan);
					continue;
				}

			}

			$zot6_xchan = $xchan[0]['xchan_hash'];
			$zot6_xchan_guid_sig = $xchan[0]['xchan_guid_sig'];

			$hubloc = q("SELECT hubloc_hash FROM hubloc WHERE hubloc_guid = '%s' AND hubloc_url = '%s' AND hubloc_network = 'zot6'",
				dbesc($guid),
				dbesc(z_root())
			);

			if(! $hubloc) {
				// This should not actually happen.
				// A local zot6 hubloc for every channel should have been
				// created in update _1226.

				// In case this failed, we will try to fix it here.
				logger('No local zot6 hubloc found for: ' . $rr['channel_hash']);

				$h = q("SELECT * FROM hubloc WHERE hubloc_hash = '%s' AND hubloc_url = '%s' LIMIT 1",
					dbesc($zot_xchan),
					dbesc(z_root())
				);

				if($h) {
					$rec = $h[0];
					$rec['hubloc_hash'] = $zot6_xchan;
					$rec['hubloc_guid_sig'] = 'sha256.' . $rec['hubloc_guid_sig'];
					$rec['hubloc_network'] = 'zot6';
					$rec['hubloc_url_sig'] = 'sha256.' . $rec['hubloc_url_sig'];
					$rec['hubloc_callback'] = z_root() . '/zot';
					$rec['hubloc_id_url'] = channel_url($rr);
					$rec['hubloc_site_id'] = Libzot::make_xchan_hash(z_root(),Config::Get('system','pubkey'));

					$hubloc = hubloc_store_lowlevel($rec);
				}

				if(! $hubloc) {
					logger('Could not create local zot6 hubloc record for: ' . $zot_xchan);
					continue;
				}
			}

			logger('Transforming channel: ' . $zot_xchan);
			q("UPDATE channel SET channel_hash = '%s', channel_portable_id = '%s', channel_guid_sig = '%s' WHERE channel_hash = '%s'",
				dbesc($zot6_xchan),
				dbesc($zot_xchan),
				dbesc($zot6_xchan_guid_sig),
				dbesc($zot_xchan)
			);

			$i++;

		}

		if(count($r) == $i) {
			z6trans_connections();
			return UPDATE_SUCCESS;
		}

		return UPDATE_FAILED;

	}

}