from common import *

def testFlushall(env):
    env.expect('FT.CREATE', 'idx', 'ON', 'HASH', 'SCHEMA', 't', 'TEXT').ok()
    con = env.getClusterConnectionIfNeeded()
    env.assertOk(con.execute_command('FT.ADD', 'idx', 'doc1', 1, 'FIELDS', 't', 'RediSearch'))
    env.expect('FT.SEARCH', 'idx', '*').equal([1, 'doc1', ['t', 'RediSearch']])
    env.assertEqual(collectKeys(env), ['doc1'])

    env.flush()

    env.expect('FT.SEARCH', 'idx', '*').error().contains('SEARCH_INDEX_NOT_FOUND Index not found: idx')
    env.expect('KEYS', '*').equal([])

    env.expect('FT.CREATE', 'idx', 'ON', 'HASH', 'SCHEMA', 't', 'TEXT').ok()
    env.assertOk(con.execute_command('FT.ADD', 'idx', 'doc1', '1', 'FIELDS', 't', 'RediSearch'))
    env.expect('FT.SEARCH', 'idx', '*').equal([1, 'doc1', ['t', 'RediSearch']])
    env.assertEqual(collectKeys(env), ['doc1'])