import unittest

from ravendb.documents.commands.query import QueryCommand
from ravendb.exceptions import exceptions
from ravendb.documents.commands.crud import PutDocumentCommand
from ravendb.documents.indexes.definitions import IndexDefinition
from ravendb.documents.operations.indexes import PutIndexesOperation
from ravendb.documents.operations.misc import QueryOperationOptions, DeleteByQueryOperation
from ravendb.documents.operations.operation import Operation
from ravendb.documents.operations.patch import PatchByQueryOperation
from ravendb.documents.queries.index_query import IndexQuery
from ravendb.tests.test_base import TestBase


class TestByIndexActions(TestBase):
    def setUp(self):
        super(TestByIndexActions, self).setUp()
        index_map = "from doc in docs.Testings " "select new{" "Name = doc.Name," "DocNumber = doc.DocNumber} "

        self.index_sort = IndexDefinition()

        self.index_sort.name = "Testing_Sort"
        self.index_sort.maps = index_map

        self.patch = "this.Name = 'Patched';"
        self.store.maintenance.send(PutIndexesOperation(self.index_sort))
        self.requests_executor = self.store.get_request_executor()
        for i in range(100):
            put_command = PutDocumentCommand(
                "testing/" + str(i),
                None,
                {
                    "Name": "test" + str(i),
                    "DocNumber": i,
                    "@metadata": {"@collection": "Testings"},
                },
            )
            self.requests_executor.execute_command(put_command)

    def tearDown(self):
        super(TestByIndexActions, self).tearDown()
        self.delete_all_topology_files()

    def test_update_by_index_success(self):
        index_query = IndexQuery("from index 'Testing_Sort'")
        index_query.wait_for_non_stale_results = True
        with self.store.open_session() as session:
            query_command = QueryCommand(session, index_query, False, False)
            self.requests_executor.execute_command(query_command)

        patch_command = PatchByQueryOperation(
            "From INDEX 'Testing_Sort' Update {{{0}}}".format(self.patch),
            options=QueryOperationOptions(allow_stale=False),
        ).get_command(self.store, self.store.conventions)
        self.requests_executor.execute_command(patch_command)
        Operation(
            self.requests_executor,
            lambda: None,
            self.store.conventions,
            patch_command.result.operation_id,
            patch_command.result.operation_node_tag,
        ).wait_for_completion()

    @unittest.skip("Exception dispatcher")
    def test_update_by_index_fail(self):
        index_query = IndexQuery("from index 'TeSort' update {{{0}}}".format(self.patch))
        patch_command = PatchByQueryOperation(
            index_query,
            options=QueryOperationOptions(allow_stale=False),
        ).get_command(self.store, self.store.conventions)
        with self.assertRaises(exceptions.InvalidOperationException):
            self.requests_executor.execute_command(patch_command)
            Operation(
                self.requests_executor,
                lambda: None,
                self.store.conventions,
                patch_command.result.operation_id,
                patch_command.result.operation_node_tag,
            ).wait_for_completion()

    @unittest.skip("Exception dispatcher")
    def test_delete_by_index_fail(self):
        delete_by_index_command = DeleteByQueryOperation("From Index 'region_2' WHERE Name = 'Western'").get_command(
            self.store, self.store.conventions
        )
        with self.assertRaises(exceptions.InvalidOperationException):
            self.requests_executor.execute_command(delete_by_index_command)
            self.assertIsNotNone(delete_by_index_command.result)
            Operation(
                self.requests_executor,
                lambda: None,
                self.store.conventions,
                delete_by_index_command.result.operation_id,
                delete_by_index_command.result.operation_node_tag,
            ).wait_for_completion()

    def test_delete_by_index_success(self):
        with self.store.open_session() as session:
            index_query = IndexQuery("from index 'Testing_Sort' where DocNumber between '0' and '49'")
            index_query.wait_for_non_stale_results = True
            query_command = QueryCommand(session, index_query, False, False)
            self.requests_executor.execute_command(query_command)
            delete_by_index_command = DeleteByQueryOperation(
                "FROM INDEX 'Testing_Sort' WHERE DocNumber BETWEEN '0' AND '49'",
                options=QueryOperationOptions(allow_stale=False),
            ).get_command(self.store, self.store.conventions)
            self.requests_executor.execute_command(delete_by_index_command)
            response = delete_by_index_command.result
            x = Operation(
                self.requests_executor,
                lambda: None,
                self.store.conventions,
                response.operation_id,
                response.operation_node_tag,
            )
            # wait_for_completion doesnt return anything (None) when operation state is 'Completed'
            self.assertIsNone(x.wait_for_completion())


if __name__ == "__main__":
    unittest.main()

import unittest

from ravendb.documents.commands.query import QueryCommand
from ravendb.exceptions import exceptions
from ravendb.documents.commands.crud import PutDocumentCommand
from ravendb.documents.indexes.definitions import IndexDefinition
from ravendb.documents.operations.indexes import PutIndexesOperation
from ravendb.documents.operations.misc import QueryOperationOptions, DeleteByQueryOperation
from ravendb.documents.operations.operation import Operation
from ravendb.documents.operations.patch import PatchByQueryOperation
from ravendb.documents.queries.index_query import IndexQuery
from ravendb.tests.test_base import TestBase


class TestByIndexActions(TestBase):
    def setUp(self):
        super(TestByIndexActions, self).setUp()
        index_map = "from doc in docs.Testings " "select new{" "Name = doc.Name," "DocNumber = doc.DocNumber} "

        self.index_sort = IndexDefinition()

        self.index_sort.name = "Testing_Sort"
        self.index_sort.maps = index_map

        self.patch = "this.Name = 'Patched';"
        self.store.maintenance.send(PutIndexesOperation(self.index_sort))
        self.requests_executor = self.store.get_request_executor()
        for i in range(100):
            put_command = PutDocumentCommand(
                "testing/" + str(i),
                None,
                {
                    "Name": "test" + str(i),
                    "DocNumber": i,
                    "@metadata": {"@collection": "Testings"},
                },
            )
            self.requests_executor.execute_command(put_command)

    def tearDown(self):
        super(TestByIndexActions, self).tearDown()
        self.delete_all_topology_files()

    def test_update_by_index_success(self):
        index_query = IndexQuery("from index 'Testing_Sort'")
        index_query.wait_for_non_stale_results = True
        with self.store.open_session() as session:
            query_command = QueryCommand(session, index_query, False, False)
            self.requests_executor.execute_command(query_command)

        patch_command = PatchByQueryOperation(
            "From INDEX 'Testing_Sort' Update {{{0}}}".format(self.patch),
            options=QueryOperationOptions(allow_stale=False),
        ).get_command(self.store, self.store.conventions)
        self.requests_executor.execute_command(patch_command)
        Operation(
            self.requests_executor,
            lambda: None,
            self.store.conventions,
            patch_command.result.operation_id,
            patch_command.result.operation_node_tag,
        ).wait_for_completion()

    @unittest.skip("Exception dispatcher")
    def test_update_by_index_fail(self):
        index_query = IndexQuery("from index 'TeSort' update {{{0}}}".format(self.patch))
        patch_command = PatchByQueryOperation(
            index_query,
            options=QueryOperationOptions(allow_stale=False),
        ).get_command(self.store, self.store.conventions)
        with self.assertRaises(exceptions.InvalidOperationException):
            self.requests_executor.execute_command(patch_command)
            Operation(
                self.requests_executor,
                lambda: None,
                self.store.conventions,
                patch_command.result.operation_id,
                patch_command.result.operation_node_tag,
            ).wait_for_completion()

    @unittest.skip("Exception dispatcher")
    def test_delete_by_index_fail(self):
        delete_by_index_command = DeleteByQueryOperation("From Index 'region_2' WHERE Name = 'Western'").get_command(
            self.store, self.store.conventions
        )
        with self.assertRaises(exceptions.InvalidOperationException):
            self.requests_executor.execute_command(delete_by_index_command)
            self.assertIsNotNone(delete_by_index_command.result)
            Operation(
                self.requests_executor,
                lambda: None,
                self.store.conventions,
                delete_by_index_command.result.operation_id,
                delete_by_index_command.result.operation_node_tag,
            ).wait_for_completion()

    def test_delete_by_index_success(self):
        with self.store.open_session() as session:
            index_query = IndexQuery("from index 'Testing_Sort' where DocNumber between '0' and '49'")
            index_query.wait_for_non_stale_results = True
            query_command = QueryCommand(session, index_query, False, False)
            self.requests_executor.execute_command(query_command)
            delete_by_index_command = DeleteByQueryOperation(
                "FROM INDEX 'Testing_Sort' WHERE DocNumber BETWEEN '0' AND '49'",
                options=QueryOperationOptions(allow_stale=False),
            ).get_command(self.store, self.store.conventions)
            self.requests_executor.execute_command(delete_by_index_command)
            response = delete_by_index_command.result
            x = Operation(
                self.requests_executor,
                lambda: None,
                self.store.conventions,
                response.operation_id,
                response.operation_node_tag,
            )
            # wait_for_completion doesnt return anything (None) when operation state is 'Completed'
            self.assertIsNone(x.wait_for_completion())


if __name__ == "__main__":
    unittest.main()

# wait_for_completion doesnt return anything (None) when operation state is 'Completed'