/*
 * Copyright (c) "Neo4j"
 * Neo4j Sweden AB [http://neo4j.com]
 *
 * This file is part of Neo4j.
 *
 * Neo4j is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
package org.neo4j.kernel.impl.newapi;

import static org.neo4j.internal.kernel.api.IndexQueryConstraints.unordered;

import java.util.Set;
import java.util.concurrent.TimeUnit;
import org.eclipse.collections.api.map.primitive.MutableIntObjectMap;
import org.eclipse.collections.impl.factory.primitive.IntObjectMaps;
import org.neo4j.exceptions.KernelException;
import org.neo4j.graphdb.RelationshipType;
import org.neo4j.graphdb.Transaction;
import org.neo4j.graphdb.schema.IndexType;
import org.neo4j.internal.kernel.api.IndexReadSession;
import org.neo4j.internal.kernel.api.RelationshipValueIndexCursor;
import org.neo4j.internal.kernel.api.Write;
import org.neo4j.internal.schema.IndexDescriptor;
import org.neo4j.kernel.api.KernelTransaction;
import org.neo4j.values.storable.Value;
import org.neo4j.values.storable.Values;

public class RelationshipIndexTransactionStateWithApplyChangesTest
        extends IndexTransactionStateWithApplyChangesTestBase {
    private static final String DEFAULT_TYPE = "type";

    @Override
    EntityWithProps entityWithProps(KernelTransaction tx, Object val, Object val2) throws Exception {
        Write write = tx.dataWrite();
        long node = write.nodeCreate();
        int relType = tx.tokenWrite().relationshipTypeGetOrCreateForName(DEFAULT_TYPE);
        long rel = write.relationshipCreate(node, relType, node);
        return setPropsOnEntity(tx, rel, val, val2);
    }

    @Override
    void createIndex(IndexType indexType) {
        try (Transaction tx = graphDb.beginTx()) {
            tx.schema()
                    .indexFor(RelationshipType.withName(DEFAULT_TYPE))
                    .on(PROP1)
                    .on(PROP2)
                    .withIndexType(indexType)
                    .withName(INDEX_NAME)
                    .create();
            tx.commit();
        }

        try (Transaction tx = graphDb.beginTx()) {
            tx.schema().awaitIndexesOnline(2, TimeUnit.MINUTES);
        }
    }

    @Override
    void deleteEntity(KernelTransaction tx, long entity) throws Exception {
        tx.dataWrite().relationshipDelete(entity);
    }

    @Override
    void removeProperties(KernelTransaction tx, long entity) throws Exception {
        int prop1Key = tx.tokenWrite().propertyKeyGetOrCreateForName(PROP1);
        int prop2Key = tx.tokenWrite().propertyKeyGetOrCreateForName(PROP2);
        MutableIntObjectMap<Value> propertiesToSet = IntObjectMaps.mutable.empty();
        propertiesToSet.put(prop1Key, Values.NO_VALUE);
        propertiesToSet.put(prop2Key, Values.NO_VALUE);
        tx.dataWrite().relationshipApplyChanges(entity, propertiesToSet);
    }

    @Override
    EntityWithProps setProperties(KernelTransaction tx, long entity, Object val, Object val2) throws Exception {
        return setPropsOnEntity(tx, entity, val, val2);
    }

    private EntityWithProps setPropsOnEntity(KernelTransaction tx, long entity, Object val, Object val2)
            throws KernelException {
        int prop1Key = tx.tokenWrite().propertyKeyGetOrCreateForName(PROP1);
        int prop2Key = tx.tokenWrite().propertyKeyGetOrCreateForName(PROP2);
        MutableIntObjectMap<Value> propertiesToSet = IntObjectMaps.mutable.empty();
        Value value1 = Values.of(val);
        propertiesToSet.put(prop1Key, value1);
        Value value2 = Values.of(val2);
        propertiesToSet.put(prop2Key, value2);
        tx.dataWrite().relationshipApplyChanges(entity, propertiesToSet);
        return new EntityWithProps(entity, value1, value2);
    }

    @Override
    void assertEntityAndValueForScan(
            Set<EntityWithProps> expected,
            KernelTransaction tx,
            IndexDescriptor index,
            boolean needsValues,
            Object anotherValueFoundByQuery,
            Object anotherValueFoundByQuery2)
            throws Exception {
        IndexReadSession indexSession = tx.dataRead().indexReadSession(index);
        try (RelationshipValueIndexCursor rels =
                tx.cursors().allocateRelationshipValueIndexCursor(tx.cursorContext(), tx.memoryTracker())) {
            tx.dataRead().relationshipIndexScan(indexSession, rels, unordered(needsValues));
            assertEntityAndValue(
                    expected,
                    tx,
                    needsValues,
                    anotherValueFoundByQuery,
                    anotherValueFoundByQuery2,
                    new RelationshipCursorAdapter(rels));
        }
    }

    private static class RelationshipCursorAdapter implements EntityValueIndexCursor {

        private final RelationshipValueIndexCursor relationships;

        private RelationshipCursorAdapter(RelationshipValueIndexCursor relationships) {
            this.relationships = relationships;
        }

        @Override
        public boolean next() {
            return relationships.next();
        }

        @Override
        public Value propertyValue(int offset) {
            return relationships.propertyValue(offset);
        }

        @Override
        public long entityReference() {
            return relationships.relationshipReference();
        }
    }
}
