MigrateUserHandlerTrait::migratePersonalItemsStep40()

Complexity

Conditions	4
Paths	3

Size

Total Lines	68
Code Lines	36

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

<?php
    private function migratePersonalItemsStep40($taskData, $arguments) {
        // get user private key
        $userInfo = $this->getOwnerInfos(
            $arguments['user_id'],
            $arguments['user_pwd'],
            1,
            $arguments['user_private_key'] ?? ''
        );

        // get TP_USER private key
        $userTP = DB::queryFirstRow(
            'SELECT pw, public_key, private_key
            FROM ' . prefixTable('users') . '
            WHERE id = %i',
            TP_USER_ID
        );

        // Start transaction for better performance
        DB::startTransaction();

        // Loop on suggestions
        $rows = DB::query(
            'SELECT id
            FROM ' . prefixTable('suggestion') . '
            ORDER BY id ASC
            LIMIT %i, %i',
            $taskData['index'],
            $taskData['nb']
        );
        foreach ($rows as $record) {
            // Get itemKey from current user
            $currentUserKey = DB::queryFirstRow(
                'SELECT share_key
                FROM ' . prefixTable('sharekeys_suggestions') . '
                WHERE object_id = %i AND user_id = %i',
                $record['id'],
                $arguments['user_id']
            );

            // do we have any input? (#3481)
            if ($currentUserKey === null || count($currentUserKey) === 0) {
                continue;
            }

            // Decrypt itemkey with user key
            $itemKey = decryptUserObjectKey($currentUserKey['share_key'], $userInfo['private_key']);

            // Now create sharekey for user
            $this->createUserShareKey(
                'sharekeys_suggestions',
                (string) $itemKey,
                (string) $userInfo['public_key'],
                (int) $record['id'],
                (int) $arguments['user_id'],
            );

            // Now create sharekey for TP_USER
            $this->createUserShareKey(
                'sharekeys_fields',
                (string) $itemKey,
                (string) $userTP['public_key'],
                (int) $record['id'],
                (int) TP_USER_ID,
            );
        }

        // Commit transaction
        DB::commit();
    }