<filename>tests/integration/test_es_indexer.py
from nboost.indexers.cli import main
import subprocess
import unittest
import requests
import time

class TestESIndexer(unittest.TestCase):
    def test_travel_tutorial(self):
        subprocess.call('docker pull elasticsearch:7.4.2', shell=True)
        subprocess.call("docker rm -f es_integration", shell=True)

        subprocess.call('docker run -d -p 9200:9200 -p 9300:9300 --name es_integration '
                        '-e "discovery.type=single-node" elasticsearch:7.4.2',
                        shell=True)

        #TODO: check if the core is ready by the api
        time.sleep(20.0)

        # dump es index
        main([
            '--verbose', 'True',
            '--port', '9200',
            '--file', 'travel.csv',
            '--index_name', 'travel',
            '--id_col',
            '--delim', ','
        ])

        # search
        params = dict(size=2, q='passage:hotels in vegas, baby')

        proxy_res = requests.get('http://localhost:9200/travel/_search', params=params)
        self.assertTrue(proxy_res.ok)
        
        subprocess.call("docker rm -f es_integration", shell=True)

<filename>tests/integration/test_es_indexer.py
from nboost.indexers.cli import main
import subprocess
import unittest
import requests
import time

class TestESIndexer(unittest.TestCase):
    def test_travel_tutorial(self):
        subprocess.call('docker pull elasticsearch:7.4.2', shell=True)
        subprocess.call("docker rm -f es_integration", shell=True)

        subprocess.call('docker run -d -p 9200:9200 -p 9300:9300 --name es_integration '
                        '-e "discovery.type=single-node" elasticsearch:7.4.2',
                        shell=True)

        #TODO: check if the core is ready by the api
        time.sleep(20.0)

        # dump es index
        main([
            '--verbose', 'True',
            '--port', '9200',
            '--file', 'travel.csv',
            '--index_name', 'travel',
            '--id_col',
            '--delim', ','
        ])

        # search
        params = dict(size=2, q='passage:hotels in vegas, baby')

        proxy_res = requests.get('http://localhost:9200/travel/_search', params=params)
        self.assertTrue(proxy_res.ok)
        
        subprocess.call("docker rm -f es_integration", shell=True)

#TODO: check if the core is ready by the api # dump es index # search