# local_instance.py
import subprocess, os, threading
from time import sleep
from logging import getLogger
from .internal import data_dir, cache_dir


logger = getLogger(__name__)

instance = None
port = 11435
overrides = {}

def start():
    if not os.path.isdir(os.path.join(cache_dir, 'tmp/ollama')):
        os.mkdir(os.path.join(cache_dir, 'tmp/ollama'))
    global instance, overrides
    params = overrides.copy()
    params["OLLAMA_HOST"] = f"127.0.0.1:{port}" # You can't change this directly sorry :3
    params["HOME"] = data_dir
    params["TMPDIR"] = os.path.join(cache_dir, 'tmp/ollama')
    instance = subprocess.Popen(["ollama", "serve"], env={**os.environ, **params}, stderr=subprocess.PIPE, text=True)
    logger.info("Starting Alpaca's Ollama instance...")
    logger.debug(params)
    sleep(1)
    logger.info("Started Alpaca's Ollama instance")

def stop():
    logger.info("Stopping Alpaca's Ollama instance")
    global instance
    if instance:
        instance.terminate()
        instance.wait()
        instance = None
        logger.info("Stopped Alpaca's Ollama instance")

def reset():
    logger.info("Resetting Alpaca's Ollama instance")
    stop()
    sleep(1)
    start()