<?php

/**
 * Helper: execute migration API request.
 *
 * @param $format
 * @param int $limit
 * @param int $offset
 *
 * @return object
 */
function _mkbh_migration_api_request($format, $limit = 0, $offset = 0)
{
    $queryParameters = [
        'client_id' => MKBH_D6_MIGRATION_API_CLIENT_ID,
        'client_secret' => MKBH_D6_MIGRATION_API_CLIENT_SECRET,
        'format' => $format,
        'limit' => (int)$limit,
        'offset' => (int)$offset,
    ];

    $response = drupal_http_request(MKBH_D6_MIGRATION_API_ENDPOINT . '?' . drupal_http_build_query($queryParameters));

    if (!empty($response) && $response->code == 200 && !empty($response->data)) {
        return json_decode($response->data, FALSE, 2048);
    }

    return FALSE;
}

function _mkbh_migration_get_changed_nodes($remoteNodes, $mode)
{
    $nodesMap = db_query("SELECT * FROM {mkbh_migration_imported_map} map")->fetchAll();
    $changedNodes = [];

    if (!empty($nodesMap)) {
        switch ($mode) {
            case 'remote':
                foreach ($remoteNodes as $remoteNode) {
                    $nodeChanged = FALSE;

                    foreach ($nodesMap as $map) {
                        if ($remoteNode->nid == $map->remote_node_id) {
                            if ($remoteNode->changed != $map->remote_node_changed) {
                                $nodeChanged = TRUE;
                            }
                        }
                    }

                    if ($nodeChanged) {
                        $changedNodes[$remoteNode->nid] = $remoteNode;
                    }
                }

                return $changedNodes;

            case 'local':
                $localNodes = db_query("SELECT n.nid, n.title, n.vid, n.type, n.changed, n.created FROM {node} n WHERE n.nid IN(:nids)", [
                    ':nids' => array_map(function ($e) {
                        return $e->imported_node_id;
                    }, $nodesMap),
                ])->fetchAll();

                foreach ($localNodes as $localNode) {
                    $nodeChanged = FALSE;

                    foreach ($nodesMap as $map) {
                        if ($localNode->nid == $map->imported_node_id) {
                            if ($localNode->changed != $map->imported_node_changed) {
                                $nodeChanged = TRUE;
                            }
                        }
                    }

                    if ($nodeChanged) {
                        $changedNodes[$localNode->nid] = $localNode;
                    }
                }

                return $changedNodes;
        }
    }

    return [];
}