// Hidden vars (os, actorsym, init, core_path, shop_path, json, args) come from env
// Engine is self-sufficient: defines its own compilation pipeline
var ACTORDATA = actorsym
var native_mode = false
var _no_warn = (init != null && init.no_warn) ? true : false
var SYSYM = '__SYSTEM__'

var _cell = {}
var need_stop = false

var cases = {
  Windows: '.dll',
  macOS: '.dylib',
  Linux: '.so'
}

var dylib_ext = cases[os.platform()]

var MOD_EXT = '.cm'
var ACTOR_EXT = '.ce'

var load_internal = os.load_internal
function use_embed(name) {
  return load_internal("js_core_" + name + "_use")
}

var fd = use_embed('internal_fd')
var js = use_embed('js')
var crypto = use_embed('internal_crypto')

// core_path and shop_path come from env (C runtime passes them through)
// shop_path may be null if --core was used without --shop
var packages_path = shop_path ? shop_path + '/packages' : null

// Self-sufficient initialization: content-addressed cache
var use_cache = {}

// Save blob intrinsic before var blob = use_core('blob') shadows it.
var _make_blob = (function() { return blob })()

function content_hash(content) {
  var data = content
  if (!is_blob(data)) data = stone(_make_blob(text(data)))
  return text(crypto.blake2(data), 'h')
}

function pipeline_cache_path(hash) {
  if (!shop_path) return null
  return shop_path + '/build/' + hash
}

function ensure_build_dir() {
  if (!shop_path) return null
  var dir = shop_path + '/build'
  if (!fd.is_dir(dir)) fd.mkdir(dir)
  return dir
}

function warn_marker_path(hash) {
  if (!shop_path) return null
  return shop_path + '/build/' + hash + '.w'
}

// --- Native compilation support ---

function detect_host_target() {
  var platform = os.platform()
  var arch = os.arch ? os.arch() : 'arm64'
  if (platform == 'macOS' || platform == 'darwin')
    return arch == 'x86_64' ? 'macos_x86_64' : 'macos_arm64'
  if (platform == 'Linux' || platform == 'linux')
    return arch == 'x86_64' ? 'linux' : 'linux_arm64'
  if (platform == 'Windows' || platform == 'windows')
    return 'windows'
  return null
}

function detect_cc() {
  var platform = os.platform()
  if (platform == 'macOS') return 'clang'
  return 'cc'
}

function native_dylib_cache_path(src, target) {
  var native_key = src + '\n' + target + '\nnative\n'
  var full_key = native_key + '\nnative'
  return pipeline_cache_path(content_hash(full_key))
}

var _engine_host_target = null
var _engine_cc = null
var _engine_is_darwin = false
var _qbe_mod = null
var _qbe_emit_mod = null

// Load a boot seed module (for compiling pipeline modules on cache miss)
function boot_load(name) {
  var mcode_path = core_path + '/boot/' + name + '.cm.mcode'
  var mcode_blob = null
  var mach_blob = null
  if (!fd.is_file(mcode_path)) {
    os.print("error: missing boot seed: " + name + "\n")
    disrupt
  }
  mcode_blob = fd.slurp(mcode_path)
  mach_blob = mach_compile_mcode_bin(name, text(mcode_blob))
  return mach_load(mach_blob, stone({use: use_embed}))
}

// Load a pipeline module from cache; on miss compile from source via boot chain
function load_pipeline_module(name, env) {
  var source_path = core_path + '/' + name + '.cm'
  var source_blob = null
  var hash = null
  var cached = null
  var mcode_path = null
  var mcode_blob = null
  var mach_blob = null
  var src = null
  var boot_tok = null
  var boot_par = null
  var boot_fld = null
  var boot_mc = null
  var boot_sl = null
  var tok_result = null
  var ast = null
  var compiled = null
  var mcode_json = null
  var native_path = null
  var native_handle = null

  // Native mode: check native cache first
  if (native_mode && _engine_host_target && fd.is_file(source_path)) {
    source_blob = fd.slurp(source_path)
    src = text(source_blob)
    native_path = native_dylib_cache_path(src, _engine_host_target)
    if (native_path && fd.is_file(native_path)) {
      native_handle = os.dylib_open(native_path)
      return os.native_module_load_named(native_handle, 'cell_main', env)
    }
  }

  if (fd.is_file(source_path)) {
    if (!source_blob) source_blob = fd.slurp(source_path)
    hash = content_hash(source_blob)
    cached = pipeline_cache_path(hash)
    if (cached && fd.is_file(cached)) {
      // log.system('engine: pipeline ' + name + ' (cached)')
      return mach_load(fd.slurp(cached), env)
    }

    // Cache miss: compile from source using boot seed pipeline
    mcode_path = core_path + '/boot/' + name + '.cm.mcode'
    if (fd.is_file(mcode_path)) {
      boot_tok = boot_load("tokenize")
      boot_par = boot_load("parse")
      boot_fld = boot_load("fold")
      boot_mc = boot_load("mcode")
      if (!src) src = text(source_blob)
      tok_result = boot_tok(src, source_path)
      ast = boot_par(tok_result.tokens, src, source_path, boot_tok)
      if (ast.errors != null && length(ast.errors) > 0) {
        os.print("error: failed to compile pipeline module: " + name + "\n")
        disrupt
      }
      ast = boot_fld(ast)
      compiled = boot_mc(ast)
      boot_sl = boot_load("streamline")
      compiled = boot_sl(compiled)
      mcode_json = json.encode(compiled)
      mach_blob = mach_compile_mcode_bin(name, mcode_json)
      // log.system('engine: pipeline ' + name + ' (compiled)')
      if (!native_mode && cached) {
        ensure_build_dir()
        fd.slurpwrite(cached, mach_blob)
      }
      return mach_load(mach_blob, env)
    }
  }
  // Last resort: boot seed as runtime (no source file found)
  mcode_path = core_path + '/boot/' + name + '.cm.mcode'
  if (fd.is_file(mcode_path)) {
    mcode_blob = fd.slurp(mcode_path)
    mach_blob = mach_compile_mcode_bin(name, text(mcode_blob))
    return mach_load(mach_blob, env)
  }
  os.print("error: cannot load pipeline module: " + name + "\n")
  disrupt
}

// Initialize native compilation state before pipeline loading
if (native_mode) {
  _engine_host_target = detect_host_target()
  _engine_cc = detect_cc()
  _engine_is_darwin = os.platform() == 'macOS'
}

// Load compilation pipeline
var pipeline_env = stone({use: use_embed})
var tokenize_mod = load_pipeline_module('tokenize', pipeline_env)
var parse_mod = load_pipeline_module('parse', pipeline_env)
var fold_mod = load_pipeline_module('fold', pipeline_env)
var mcode_mod = load_pipeline_module('mcode', pipeline_env)
var streamline_mod = load_pipeline_module('streamline', pipeline_env)

use_cache['tokenize'] = tokenize_mod
use_cache['parse'] = parse_mod
use_cache['fold'] = fold_mod
use_cache['mcode'] = mcode_mod
use_cache['core/mcode'] = mcode_mod
use_cache['streamline'] = streamline_mod
use_cache['core/streamline'] = streamline_mod

// Load QBE modules when native mode
if (native_mode) {
  _qbe_mod = load_pipeline_module('qbe', pipeline_env)
  _qbe_emit_mod = load_pipeline_module('qbe_emit', pipeline_env)
  use_cache['qbe'] = _qbe_mod
  use_cache['core/qbe'] = _qbe_mod
  use_cache['qbe_emit'] = _qbe_emit_mod
  use_cache['core/qbe_emit'] = _qbe_emit_mod
}

var compiler_fingerprint = (function() {
  var files = [
    "tokenize", "parse", "fold", "mcode", "streamline",
    "qbe", "qbe_emit", "ir_stats"
  ]
  var combined = ""
  var i = 0
  var path = null
  while (i < length(files)) {
    path = core_path + '/' + files[i] + '.cm'
    if (fd.is_file(path))
      combined = combined + text(fd.slurp(path))
    i = i + 1
  }
  return content_hash(stone(blob(combined)))
})()

function module_cache_path(content, salt) {
  if (!shop_path) return null
  var s = salt || 'mach'
  return shop_path + '/build/' + content_hash(
    stone(_make_blob(text(content) + '\n' + s + '\n' + compiler_fingerprint))
  )
}

// analyze: tokenize + parse + fold, check for errors
function analyze(src, filename) {
  var tok_result = tokenize_mod(src, filename)
  var _ast = parse_mod(tok_result.tokens, src, filename, tokenize_mod)
  var _i = 0
  var prev_line = -1
  var prev_msg = null
  var e = null
  var msg = null
  var line = null
  var col = null
  var has_errors = _ast.errors != null && length(_ast.errors) > 0
  var folded = null
  var _wm = null
  if (has_errors) {
    while (_i < length(_ast.errors)) {
      e = _ast.errors[_i]
      msg = e.message
      line = e.line
      col = e.column
      if (msg != prev_msg || line != prev_line) {
        if (line != null && col != null)
          os.print(`${filename}:${text(line)}:${text(col)}: error: ${msg}\n`)
        else
          os.print(`${filename}: error: ${msg}\n`)
      }
      prev_line = line
      prev_msg = msg
      _i = _i + 1
    }
    disrupt
  }
  folded = fold_mod(_ast)
  if (!_no_warn && folded._diagnostics != null && length(folded._diagnostics) > 0) {
    _wm = warn_marker_path(content_hash(stone(blob(src))))
    if (!_wm || !fd.is_file(_wm)) {
      _i = 0
      while (_i < length(folded._diagnostics)) {
        e = folded._diagnostics[_i]
        log.warn(`${filename}:${text(e.line)}:${text(e.col)}: ${e.severity}: ${e.message}`)
        _i = _i + 1
      }
      if (_wm) {
        ensure_build_dir()
        fd.slurpwrite(_wm, stone(blob("1")))
      }
    }
  }
  folded._diagnostics = null
  return folded
}

// Lazy-loaded verify_ir module (loaded on first use)
var _verify_ir_mod = null

// Module summary extraction for cross-program analysis.
// Scans mcode IR for use() call patterns and attaches summaries.
// _summary_resolver is set after shop loads (null during bootstrap).
var _summary_resolver = null

function extract_module_summaries(compiled, ctx) {
  if (_summary_resolver == null) return null
  var instrs = null
  var summaries = []
  var unresolved = []
  var i = 0
  var j = 0
  var n = 0
  var instr = null
  var prev = null
  var op = null
  var use_slots = {}
  var frame_map = {}
  var arg_map = {}
  var val_slot = 0
  var f_slot = 0
  var path = null
  var result_slot = 0
  var summary = null
  var inv_n = 0

  if (compiled.main == null) return null
  instrs = compiled.main.instructions
  if (instrs == null) return null
  n = length(instrs)

  // Pass 1: find access(slot, {make:"intrinsic", name:"use"})
  i = 0
  while (i < n) {
    instr = instrs[i]
    if (is_array(instr) && instr[0] == "access") {
      if (is_object(instr[2]) && instr[2].make == "intrinsic" && instr[2].name == "use") {
        use_slots[text(instr[1])] = true
      }
    }
    i = i + 1
  }

  // Pass 2: find frame(frame_slot, use_slot), setarg with string, invoke
  i = 0
  while (i < n) {
    instr = instrs[i]
    if (is_array(instr)) {
      op = instr[0]
      if (op == "frame" || op == "goframe") {
        if (use_slots[text(instr[2])] == true) {
          frame_map[text(instr[1])] = true
        }
      } else if (op == "setarg") {
        if (frame_map[text(instr[1])] == true) {
          val_slot = instr[3]
          j = i - 1
          while (j >= 0) {
            prev = instrs[j]
            if (is_array(prev) && prev[0] == "access" && prev[1] == val_slot && is_text(prev[2])) {
              arg_map[text(instr[1])] = prev[2]
              break
            }
            j = j - 1
          }
        }
      } else if (op == "invoke" || op == "tail_invoke") {
        f_slot = instr[1]
        path = arg_map[text(f_slot)]
        if (path != null) {
          result_slot = instr[2]
          summary = _summary_resolver(path, ctx)
          if (summary != null) {
            if (summary._native != true) {
              summaries[] = {slot: result_slot, summary: summary}
            }
          } else {
            inv_n = length(instr)
            unresolved[] = {path: path, line: instr[inv_n - 2], col: instr[inv_n - 1]}
          }
        }
      }
    }
    i = i + 1
  }

  if (length(summaries) > 0 || length(unresolved) > 0) {
    return {summaries: summaries, unresolved: unresolved}
  }
  return null
}

// Run AST through mcode pipeline -> register VM
function run_ast_fn(name, ast, env, pkg) {
  var compiled = mcode_mod(ast)
  var ms = null
  var _ui = 0
  var _ur = null
  var optimized = null
  var _di = 0
  var _diag = null
  var _has_errors = false
  var mcode_json = null
  var mach_blob = null
  if (os._verify_ir) {
    if (_verify_ir_mod == null) {
      _verify_ir_mod = load_pipeline_module('verify_ir', pipeline_env)
    }
    compiled._verify = true
    compiled._verify_mod = _verify_ir_mod
  }
  if (!_no_warn) {
    compiled._warn = true
    ms = extract_module_summaries(compiled, pkg)
    if (ms != null) {
      if (length(ms.summaries) > 0) {
        compiled._module_summaries = ms.summaries
      }
      if (length(ms.unresolved) > 0) {
        compiled._unresolved_imports = ms.unresolved
      }
    }
  }
  if (compiled._unresolved_imports != null) {
    _ui = 0
    while (_ui < length(compiled._unresolved_imports)) {
      _ur = compiled._unresolved_imports[_ui]
      os.print(`${name}:${text(_ur.line)}:${text(_ur.col)}: error: cannot resolve module '${_ur.path}'\n`)
      _ui = _ui + 1
    }
    disrupt
  }
  optimized = streamline_mod(compiled)
  if (optimized._verify) {
    delete optimized._verify
    delete optimized._verify_mod
  }
  if (optimized._diagnostics != null && length(optimized._diagnostics) > 0) {
    _di = 0
    _has_errors = false
    while (_di < length(optimized._diagnostics)) {
      _diag = optimized._diagnostics[_di]
      if (_diag.severity == "error") {
        log.error(`${_diag.file}:${text(_diag.line)}:${text(_diag.col)}: ${_diag.severity}: ${_diag.message}`)
        _has_errors = true
      } else {
        log.warn(`${_diag.file}:${text(_diag.line)}:${text(_diag.col)}: ${_diag.severity}: ${_diag.message}`)
      }
      _di = _di + 1
    }
    if (_has_errors) disrupt
  }
  mcode_json = json.encode(optimized)
  mach_blob = mach_compile_mcode_bin(name, mcode_json)
  return mach_load(mach_blob, env)
}

// Run AST through mcode pipeline WITHOUT optimization -> register VM
function run_ast_noopt_fn(name, ast, env) {
  var compiled = mcode_mod(ast)
  var mcode_json = json.encode(compiled)
  var mach_blob = mach_compile_mcode_bin(name, mcode_json)
  return mach_load(mach_blob, env)
}

// Compile AST to blob without loading (for caching)
function compile_to_blob(name, ast) {
  var compiled = mcode_mod(ast)
  var optimized = streamline_mod(compiled)
  return mach_compile_mcode_bin(name, json.encode(optimized))
}

// Compile user program AST to blob with diagnostics
function compile_user_blob(name, ast, pkg) {
  var compiled = mcode_mod(ast)
  var ms = null
  var _ui = 0
  var _ur = null
  var optimized = null
  var _di = 0
  var _diag = null
  var _has_errors = false
  if (!_no_warn) {
    compiled._warn = true
    ms = extract_module_summaries(compiled, pkg)
    if (ms != null) {
      if (length(ms.summaries) > 0) {
        compiled._module_summaries = ms.summaries
      }
      if (length(ms.unresolved) > 0) {
        compiled._unresolved_imports = ms.unresolved
      }
    }
  }
  if (compiled._unresolved_imports != null) {
    _ui = 0
    while (_ui < length(compiled._unresolved_imports)) {
      _ur = compiled._unresolved_imports[_ui]
      os.print(`${name}:${text(_ur.line)}:${text(_ur.col)}: error: cannot resolve module '${_ur.path}'\n`)
      _ui = _ui + 1
    }
    disrupt
  }
  optimized = streamline_mod(compiled)
  if (optimized._diagnostics != null && length(optimized._diagnostics) > 0) {
    _di = 0
    _has_errors = false
    while (_di < length(optimized._diagnostics)) {
      _diag = optimized._diagnostics[_di]
      if (_diag.severity == "error") {
        log.error(`${_diag.file}:${text(_diag.line)}:${text(_diag.col)}: ${_diag.severity}: ${_diag.message}`)
        _has_errors = true
      } else {
        log.warn(`${_diag.file}:${text(_diag.line)}:${text(_diag.col)}: ${_diag.severity}: ${_diag.message}`)
      }
      _di = _di + 1
    }
    if (_has_errors) disrupt
  }
  return mach_compile_mcode_bin(name, json.encode(optimized))
}

// If loaded directly by C runtime (not via bootstrap), convert args -> init
var _program = null
var _user_args = []
var _j = 1
var _init = init

// Inherit native_mode from init (set by C for --native, or by parent actor)
if (_init != null && _init.native_mode)
  native_mode = true

// _no_warn already set from init at top of file

// CLI path: convert args to init record
if (args != null && (_init == null || !_init.program)) {
  _program = args[0]
  while (_j < length(args)) {
    push(_user_args, args[_j])
    _j = _j + 1
  }
  if (_init == null) {
    _init = {program: _program, arg: _user_args}
  } else {
    _init.program = _program
    _init.arg = _user_args
  }
}

// -e flag: eval script string directly
var _eval_script = (_init != null && _init.eval_script) ? _init.eval_script : null
if (_eval_script && !_init.program) {
  _init.program = "-e"
}

use_cache['core/internal/os'] = os

// Extra env properties added as engine initializes (log, runtime fns, etc.)
var core_extras = {}

// Compile a core module to a native dylib, return the dylib path
function compile_core_native(name, source_path) {
  var source_blob = fd.slurp(source_path)
  var src = text(source_blob)
  var dylib_path = native_dylib_cache_path(src, _engine_host_target)
  var ast = null
  var compiled = null
  var il_parts = null
  var helpers_il = null
  var all_fns = null
  var full_il = null
  var asm_text = null
  var tmp = null
  var rc = null
  var rt_o = null
  var qbe_rt_path = null
  var link_cmd = null

  if (dylib_path && fd.is_file(dylib_path))
    return dylib_path

  ast = analyze(src, source_path)
  compiled = streamline_mod(mcode_mod(ast))
  il_parts = _qbe_emit_mod(compiled, _qbe_mod, null)

  helpers_il = (il_parts.helpers && length(il_parts.helpers) > 0)
    ? text(il_parts.helpers, "\n") : ""
  all_fns = text(il_parts.functions, "\n")
  full_il = il_parts.data + "\n\n" + helpers_il + "\n\n" + all_fns

  asm_text = os.qbe(full_il)
  tmp = '/tmp/cell_engine_' + replace(name, '/', '_')
  fd.slurpwrite(tmp + '.s', stone(blob(asm_text)))

  rc = os.system(_engine_cc + ' -c ' + tmp + '.s -o ' + tmp + '.o')
  if (rc != 0) {
    os.print("error: assembly failed for " + name + "\n")
    disrupt
  }

  rt_o = '/tmp/cell_qbe_rt.o'
  if (!fd.is_file(rt_o)) {
    qbe_rt_path = core_path + '/src/qbe_rt.c'
    rc = os.system(_engine_cc + ' -c ' + qbe_rt_path + ' -o ' + rt_o + ' -fPIC')
    if (rc != 0) {
      os.print("error: qbe_rt compilation failed\n")
      disrupt
    }
  }

  ensure_build_dir()
  link_cmd = _engine_cc + ' -shared -fPIC'
  if (_engine_is_darwin)
    link_cmd = link_cmd + ' -undefined dynamic_lookup'
  link_cmd = link_cmd + ' ' + tmp + '.o ' + rt_o + ' -o ' + dylib_path

  rc = os.system(link_cmd)
  if (rc != 0) {
    os.print("error: linking failed for " + name + "\n")
    disrupt
  }
  return dylib_path
}

// Load a core module from the file system
function use_core(path) {
  var cache_key = 'core/' + path
  var env = null
  if (use_cache[cache_key])
    return use_cache[cache_key]

  var sym = use_embed(replace(path, '/', '_'))
  var result = null
  var script = null
  var ast = null
  var _load_mod = null
  var _try_native = null

  // Build env: merge core_extras
  env = {use: use_core}
  arrfor(array(core_extras), function(k) { env[k] = core_extras[k] })
  env = stone(env)

  var cached_path = null
  var mach_blob = null
  var source_blob = null
  var file_path = null

  // Compile from source .cm file
  file_path = core_path + '/' + path + MOD_EXT
  if (fd.is_file(file_path)) {
    // Native path: try native cache or compile natively
    if (native_mode && _qbe_mod && _qbe_emit_mod) {
      _try_native = function() {
        var src = null
        var native_path = null
        var native_handle = null
        source_blob = fd.slurp(file_path)
        src = text(source_blob)
        native_path = native_dylib_cache_path(src, _engine_host_target)
        if (native_path && fd.is_file(native_path)) {
          native_handle = os.dylib_open(native_path)
          result = os.native_module_load_named(native_handle, 'cell_main', env)
          return
        }
        native_path = compile_core_native('core:' + path, file_path)
        native_handle = os.dylib_open(native_path)
        result = os.native_module_load_named(native_handle, 'cell_main', env)
      } disruption {
        os.print(`[engine] native compilation failed for '${path}'; falling back to bytecode\n`)
      }
      _try_native()
      if (result != null) {
        use_cache[cache_key] = result
        return result
      }
    }

    // Bytecode path (fallback or non-native mode)
    _load_mod = function() {
      if (!source_blob) source_blob = fd.slurp(file_path)
      cached_path = module_cache_path(source_blob, 'mach')
      if (cached_path && fd.is_file(cached_path)) {
        // log.system('engine: cache hit for core/' + path)
        result = mach_load(fd.slurp(cached_path), env)
      } else {
        script = text(source_blob)
        ast = analyze(script, file_path)
        mach_blob = compile_to_blob('core:' + path, ast)
        // log.system('engine: compiled core/' + path)
        if (!native_mode && cached_path) {
          ensure_build_dir()
          fd.slurpwrite(cached_path, mach_blob)
        }
        result = mach_load(mach_blob, env)
      }
    } disruption {
      log.error("use('" + path + "'): failed to compile or load " + file_path)
      disrupt
    }
    _load_mod()
    use_cache[cache_key] = result
    return result
  }

  // Embedded C module only
  use_cache[cache_key] = sym
  return sym
}

// Load full modules via use_core (extends C embeds with .cm additions, and caches)
fd = use_core('fd')
use_core('js')
var blob = use_core('blob')

function actor() {

}

var actor_mod = use_core('actor')
var wota = use_core('internal/wota')
var nota = use_core('internal/nota')


var ENETSERVICE = 0.1
var REPLYTIMEOUT = 60 // seconds before replies are ignored

// --- Logging system (bootstrap phase) ---
// Early log: prints to console before toml/time/json are loaded.
// Upgraded to full sink-based system after config loads (see load_log_config below).
// The bootstrap log forwards to _log_full once the full system is ready, so that
// modules loaded early (like shop.cm) get full logging even though they captured
// the bootstrap function reference.

var log_config = null
var channel_sinks = {}
var wildcard_sinks = []
var warned_channels = {}
var stack_channels = {}
var _log_full = null

var log_quiet_channels = { shop: true }

function log(name, args) {
  if (_log_full) return _log_full(name, args)
  if (log_quiet_channels[name]) return
  var msg = args[0]
  var stk = null
  var i = 0
  var fr = null
  if (msg == null) msg = ""
  os.print(`[${text(_cell.id, 0, 5)}] [${name}]: ${msg}\n`)
  if (name == "error") {
    stk = os.stack(2)
    if (stk && length(stk) > 0) {
      for (i = 0; i < length(stk); i = i + 1) {
        fr = stk[i]
        os.print(`    at ${fr.fn} (${fr.file}:${text(fr.line)}:${text(fr.col)})\n`)
      }
    }
  }
}

function actor_die(err)
{
  var reason = null
  var unders = null

  if (err && is_function(err.toString)) {
    os.print(err.toString())
    os.print("\n")
    if (err.stack) os.print(err.stack)
  }

  if (overling) {
    if (err) {
      // with an err, this is a forceful disrupt
      reason = err
      report_to_overling({type:'disrupt', reason})
    } else
      report_to_overling({type:'stop'})
  }

  if (underlings) {
    unders = array(underlings)
    arrfor(unders, function(id, index) {
      if (!is_null(underlings[id])) {
        log.system(`stopping underling ${id}`)
        $_.stop(create_actor({id}))
      }
    })
  }

  if (err) {
    if (err.message)
      log.console(err.message)
    if (err.stack)
      log.console(err.stack)
  }

  actor_mod["disrupt"]()
}



actor_mod.on_exception(actor_die)

_cell.args = _init != null ? _init : {}

function create_actor(desc) {
  var _desc = desc == null ? {id:guid()} : desc
  var actor = {}
  actor[ACTORDATA] = _desc
  stone(actor)
  return actor
}

var $_ = {}

use_cache['core/json'] = json

// Create runtime_env early (empty) -- filled after pronto loads.
// Shop accesses it lazily (in inject_env, called at module-use time, not load time)
// so it sees the filled version.
var runtime_env = {}

// Populate core_extras with everything shop (and other core modules) need
core_extras.use_cache = use_cache
core_extras.core_path = core_path
core_extras.shop_path = shop_path
core_extras.analyze = analyze
core_extras.run_ast_fn = run_ast_fn
core_extras.run_ast_noopt_fn = run_ast_noopt_fn
os.analyze = analyze
os.run_ast_fn = run_ast_fn
os.run_ast_noopt_fn = run_ast_noopt_fn
core_extras.core_json = json
core_extras.actor_api = $_
core_extras.log = log
core_extras.runtime_env = runtime_env
core_extras.content_hash = content_hash
core_extras.cache_path = module_cache_path
core_extras.compiler_fingerprint = compiler_fingerprint
core_extras.ensure_build_dir = ensure_build_dir
core_extras.compile_to_blob = compile_to_blob
core_extras.native_mode = native_mode

// NOW load shop -- it receives all of the above via env
var shop = use_core('internal/shop')
use_core('build')

// Wire up module summary resolver now that shop is available
_summary_resolver = function(path, ctx) {
  var info = shop.resolve_import_info(path, ctx)
  if (info == null) return null
  if (info.type == 'native') return {_native: true}
  var resolved = info.resolved_path
  if (resolved == null) return null
  var summary_fn = function() {
    return shop.summary_file(resolved)
  } disruption {
    return null
  }
  return summary_fn()
}

var time = use_core('time')
var toml = use_core('toml')

// --- Logging system (full version) ---
// Now that toml, time, fd, and json are available, upgrade the log function
// from the bootstrap version to a configurable sink-based system.

function ensure_log_dir(path) {
  var parts = array(path, '/')
  var current = starts_with(path, '/') ? '/' : ''
  var i = 0
  // ensure parent dir (skip last element which is the filename)
  for (i = 0; i < length(parts) - 1; i++) {
    if (parts[i] == '') continue
    current = current + parts[i] + '/'
    if (!fd.is_dir(current)) fd.mkdir(current)
  }
}

function build_sink_routing() {
  channel_sinks = {}
  wildcard_sinks = []
  stack_channels = {}
  var names = array(log_config.sink)
  arrfor(names, function(name) {
    var sink = log_config.sink[name]
    if (!sink || !is_object(sink)) return
    sink._name = name
    if (!is_array(sink.channels)) sink.channels = []
    if (is_text(sink.exclude)) sink.exclude = [sink.exclude]
    if (!is_array(sink.exclude)) sink.exclude = []
    if (is_text(sink.stack)) sink.stack = [sink.stack]
    if (!is_array(sink.stack)) sink.stack = []
    if (sink.type == "file" && sink.path) ensure_log_dir(sink.path)
    arrfor(sink.stack, function(ch) {
      stack_channels[ch] = true
    })
    arrfor(sink.channels, function(ch) {
      if (ch == "*") {
        wildcard_sinks[] = sink
        return
      }
      if (!channel_sinks[ch]) channel_sinks[ch] = []
      channel_sinks[ch][] = sink
    })
  })
}

function load_log_config() {
  var log_path = null
  if (shop_path) {
    log_path = shop_path + '/log.toml'
    if (fd.is_file(log_path)) {
      log_config = toml.decode(text(fd.slurp(log_path)))
    }
  }
  if (!log_config || !log_config.sink || length(array(log_config.sink)) == 0) {
    log_config = {
      sink: {
        terminal: {
          type: "console",
          format: "clean",
          channels: ["console", "error"],
          stack: ["error"]
        }
      }
    }
  }
  build_sink_routing()
}

function pretty_format(rec) {
  var aid = text(rec.actor_id, 0, 5)
  var src = ""
  var ev = null
  var out = null
  var i = 0
  var fr = null
  ev = is_text(rec.event) ? rec.event : json.encode(rec.event, false)
  out = `[${aid}] [${rec.channel}] ${ev}\n`
  if (rec.stack && length(rec.stack) > 0) {
    for (i = 0; i < length(rec.stack); i = i + 1) {
      fr = rec.stack[i]
      out = out + `    at ${fr.fn} (${fr.file}:${text(fr.line)}:${text(fr.col)})\n`
    }
  }
  return out
}

function bare_format(rec) {
  var aid = text(rec.actor_id, 0, 5)
  var ev = is_text(rec.event) ? rec.event : json.encode(rec.event, false)
  var out = `[${aid}] ${ev}\n`
  var i = 0
  var fr = null
  if (rec.stack && length(rec.stack) > 0) {
    for (i = 0; i < length(rec.stack); i = i + 1) {
      fr = rec.stack[i]
      out = out + `    at ${fr.fn} (${fr.file}:${text(fr.line)}:${text(fr.col)})\n`
    }
  }
  return out
}

function clean_format(rec) {
  var ev = is_text(rec.event) ? rec.event : json.encode(rec.event, false)
  var out = null
  var i = 0
  var fr = null
  if (rec.channel == "error") {
    out = `error: ${ev}\n`
  } else {
    out = `${ev}\n`
  }
  if (rec.stack && length(rec.stack) > 0) {
    for (i = 0; i < length(rec.stack); i = i + 1) {
      fr = rec.stack[i]
      out = out + `    at ${fr.fn} (${fr.file}:${text(fr.line)}:${text(fr.col)})\n`
    }
  }
  return out
}

function sink_excluded(sink, channel) {
  var excluded = false
  if (!sink.exclude || length(sink.exclude) == 0) return false
  arrfor(sink.exclude, function(ex) {
    if (ex == channel) excluded = true
  })
  return excluded
}

function dispatch_to_sink(sink, rec) {
  var line = null
  if (sink_excluded(sink, rec.channel)) return
  if (sink.type == "console") {
    if (sink.format == "json")
      os.print(json.encode(rec, false) + "\n")
    else if (sink.format == "bare")
      os.print(bare_format(rec))
    else if (sink.format == "clean")
      os.print(clean_format(rec))
    else
      os.print(pretty_format(rec))
  } else if (sink.type == "file") {
    line = json.encode(rec, false) + "\n"
    fd.slurpappend(sink.path, stone(blob(line)))
  }
}

load_log_config()

log = function(name, args) {
  var sinks = channel_sinks[name]
  var event = args[0]
  var c_stack = args[1]
  var caller = null
  var stack = null
  var rec = null

  if (!sinks && length(wildcard_sinks) == 0) return

  // C-provided stack (from JS_Log callback) overrides caller_info/os.stack
  if (c_stack && length(c_stack) > 0) {
    caller = {file: c_stack[0].file, line: c_stack[0].line}
    if (stack_channels[name]) stack = c_stack
  } else {
    caller = caller_info(0)
    if (stack_channels[name]) stack = os.stack(1)
  }

  rec = {
    actor_id: _cell.id,
    timestamp: time.number(),
    channel: name,
    event: event,
    source: caller
  }
  if (stack) rec.stack = stack

  if (sinks) arrfor(sinks, function(sink) { dispatch_to_sink(sink, rec) })
  arrfor(wildcard_sinks, function(sink) { dispatch_to_sink(sink, rec) })
}

// Wire C-level JS_Log through the ƿit log system
actor_mod.set_log(log)

// Let the bootstrap log forward to the full system — modules loaded early
// (before the full log was ready) captured the bootstrap function reference.
_log_full = log

var pronto = use_core('pronto')
var fallback = pronto.fallback
var parallel = pronto.parallel
var race = pronto.race
var sequence = pronto.sequence

runtime_env.actor = actor
runtime_env.log = log
runtime_env.send = send
runtime_env.shop_path = shop_path
runtime_env.fallback = fallback
runtime_env.parallel = parallel
runtime_env.race = race
runtime_env.sequence = sequence

// Make runtime functions available to modules loaded via use_core
arrfor(array(runtime_env), function(k) { core_extras[k] = runtime_env[k] })

$_.time_limit = function(requestor, seconds)
{
  if (!pronto.is_requestor(requestor)) {
    log.error('time_limit: first argument must be a requestor')
    disrupt
  }
  if (!is_number(seconds) || seconds <= 0) {
    log.error('time_limit: seconds must be a positive number')
    disrupt
  }

  return function time_limit_requestor(callback, value) {
    pronto.check_callback(callback, 'time_limit')
    var finished = false
    var requestor_cancel = null
    var timer_cancel = null

    function cancel(reason) {
      if (finished) return
      finished = true
      if (timer_cancel) {
        timer_cancel()
        timer_cancel = null
      }
      if (requestor_cancel) {
        requestor_cancel(reason)
        requestor_cancel = null
      }
    }

    function safe_cancel_requestor(reason) {
      if (requestor_cancel) {
        requestor_cancel(reason)
        requestor_cancel = null
      }
    }

    timer_cancel = $_.delay(function() {
      if (finished) return
      def reason = make_reason(factory, 'Timeout.', seconds)
      safe_cancel_requestor(reason)
      finished = true
      callback(null, reason)
    }, seconds)

    function do_request() {
      requestor_cancel = requestor(function(val, reason) {
        if (finished) return
        finished = true
        if (timer_cancel) {
          timer_cancel()
          timer_cancel = null
        }
        callback(val, reason)
      }, value)
    } disruption {
      cancel('requestor failed')
      callback(null, 'requestor failed')
    }
    do_request()

    return function(reason) {
      safe_cancel_requestor(reason)
    }
  }
}

var config = {
  ar_timer: 60,
  actor_memory:0,
  net_service:0.1,
  reply_timeout:60,
  main: true
}

_cell.config = config

ENETSERVICE = config.net_service
REPLYTIMEOUT = config.reply_timeout



/*
  When handling a message, the message appears like this:
  {
    type: type of message
      - contact: used for contact messages
      - stop: used to issue stop command
      - etc
    reply: ID this message will respond to (callback saved on the actor)
    replycc: the actor that is waiting for the reply
    target: ID of the actor that's supposed to receive the message. Only added to non direct sends (out of portals)
    return: reply ID so the replycc actor can know what callback to send the message to

    data: the actual content of the message
  }

  actors look like
  {
    id: the GUID of this actor
    address: the IP this actor can be found at
    port: the port of the IP the actor can be found at
  }
*/

function guid(bits)
{
  var _bits = bits == null ? 256 : bits
  var guid = blob(_bits, os.random)
  stone(guid)
  return text(guid,'h')
}

var HEADER = {}

// takes a function input value that will eventually be called with the current time in number form.
$_.clock = function(fn) {
  actor_mod.clock(_ => {
    fn(time.number())
    send_messages()
  })
}

var underlings = {} // this is more like "all actors that are notified when we die"
var overling = null
var root = null

var receive_fn = null
var greeters = {} // Router functions for when messages are received for a specific actor

var enet = use_core('internal/enet')

var peers = {}
var id_address = {}
var peer_queue = {}
var portal = null
var portal_fn = null
var enet = use_core('enet')

function peer_connection(peer) {
  return {
    latency: peer.rtt(),
    bandwidth: {
      incoming: peer.incoming_bandwidth(),
      outgoing: peer.outgoing_bandwidth()
    },
    activity: {
      last_sent: peer.last_send_time(),
      last_received: peer.last_receive_time()
    },
    mtu: peer.mtu(),
    data: {
      incoming_total: peer.incoming_data_total(),
      outgoing_total: peer.outgoing_data_total(),
      reliable_in_transit: peer.reliable_data_in_transit()
    },
    latency_variance: peer.rtt_variance(),
    packet_loss: peer.packet_loss(),
    state: peer.state()
  }
}

// takes a callback function, an actor object, and a configuration record for getting information about the status of a connection to the actor. The configuration record is used to request the sort of information that needs to be communicated. This can include latency, bandwidth, activity, congestion, cost, partitions. The callback is given a record containing the requested information.
$_.connection = function(callback, actor, config) {
  var peer = peers[actor[ACTORDATA].id]
  if (peer) {
    callback(peer_connection(peer))
    return
  }
  if (actor_mod.mailbox_exist(actor[ACTORDATA].id)) {
    callback({type:"local"})
    return
  }

  callback()
}

// takes a function input value that will eventually be called with the current time in number form.
$_.portal = function(fn, port) {
  if (portal) {
    log.error(`Already started a portal listening on ${portal.port()}`)
    disrupt
  }
  if (!port) {
    log.error("Requires a valid port.")
    disrupt
  }
  log.system(`starting a portal on port ${port}`)
  portal = enet.create_host({address: "any", port})
  portal_fn = fn
  enet_check()
}

function handle_host(e) {
  var queue = null
  var data = null
  var addr = null
  var port = null

  if (e.type == "connect") {
    addr = e.peer.address()
    port = e.peer.port()
    log.system(`connected a new peer: ${addr}:${port}`)
    peers[`${addr}:${port}`] = e.peer
    queue = peer_queue[e.peer]
    if (queue) {
      arrfor(queue, (msg, index) => e.peer.send(nota.encode(msg)))
      log.system(`sent queue out of queue`)
      delete peer_queue[e.peer]
    }
  } else if (e.type == "disconnect") {
    delete peer_queue[e.peer]
    arrfor(array(peers), function(id, index) {
      if (peers[id] == e.peer) delete peers[id]
    })
    log.system('portal got disconnect from ' + e.peer.address() + ":" + e.peer.port())
  } else if (e.type == "receive") {
    data = nota.decode(e.data)
    if (data.replycc && !data.replycc.address) {
      data.replycc[ACTORDATA].address = e.peer.address()
      data.replycc[ACTORDATA].port = e.peer.port()
    }
    if (data.data) populate_actor_addresses(data.data, e)
    handle_message(data)
    send_messages()
  }
}

function populate_actor_addresses(obj, e) {
  if (!is_object(obj)) return
  if (obj[ACTORDATA] && !obj[ACTORDATA].address) {
    obj[ACTORDATA].address = e.peer.address()
    obj[ACTORDATA].port = e.peer.port()
  }
  arrfor(array(obj), function(key, index) {
    if (key in obj)
      populate_actor_addresses(obj[key], e)
  })
}

// takes a callback function, an actor object, and a configuration record for getting information about the status of a connection to the actor. The configuration record is used to request the sort of information that needs to be communicated. This can include latency, bandwidth, activity, congestion, cost, partitions. The callback is given a record containing the requested information.
$_.contact = function(callback, record) {
  send(create_actor(record), record, callback)
}

// registers a function that will receive all messages...
$_.receiver = function receiver(fn) {
  receive_fn = fn
}

// Holds all messages queued during the current turn.
var message_queue = []

$_.start = function start(cb, program) {
    if (!program) return

    var id = guid()
    var oid = $_.self[ACTORDATA].id
    var startup = {
      id,
      overling_id: oid,
      root_id: root ? root[ACTORDATA].id : null,
      program,
      native_mode: native_mode,
      no_warn: _no_warn,
    }
    greeters[id] = cb
    push(message_queue, { startup })
}

// stops an underling or self.
$_.stop = function stop(actor) {
  if (!actor) {
    need_stop = true
    return
  }
  if (!is_actor(actor)) {
    log.error('Can only call stop on an actor.')
    disrupt
  }
  if (is_null(underlings[actor[ACTORDATA].id])) {
    log.error('Can only call stop on an underling or self.')
    disrupt
  }

  sys_msg(actor, {kind:"stop"})
}

// schedules the removal of an actor after a specified amount of time.
$_.unneeded = function unneeded(fn, seconds) {
  actor_mod.unneeded(fn, seconds)
}

// schedules the invocation of a function after a specified amount of time.
$_.delay = function delay(fn, seconds) {
  var _seconds = seconds == null ? 0 : seconds
  function delay_turn() {
    fn()
    send_messages()
  }
  var id = actor_mod.delay(delay_turn, _seconds)
  return function() { actor_mod.removetimer(id) }
}

// causes this actor to stop when another actor stops.
var couplings = {}
$_.couple = function couple(actor) {
  if (actor == $_.self) return // can't couple to self
  couplings[actor[ACTORDATA].id] = true
  sys_msg(actor, {kind:'couple', from_id: _cell.id})
  log.system(`coupled to ${actor[ACTORDATA].id}`)
}

function actor_prep(actor, send) {
  push(message_queue, {actor,send});
}

// Send a message immediately without queuing
function actor_send_immediate(actor, send) {
  actor_send(actor, send)
}

function actor_send(actor, message) {
  var wota_blob = null
  var peer = null

  if (actor[HEADER] && !actor[HEADER].replycc) // attempting to respond to a message but sender is not expecting; silently drop
    return

  if (!is_actor(actor) && !is_actor(actor.replycc)) {
    log.error(`Must send to an actor object. Attempted send to ${actor}`)
    disrupt
  }

  if (!is_object(message)) {
    log.error('Must send an object record.')
    disrupt
  }

  // message to self
  if (actor[ACTORDATA].id == _cell.id) {
    if (receive_fn) receive_fn(message.data)
    return
  }

  // message to actor in same flock
  if (actor[ACTORDATA].id && actor_mod.mailbox_exist(actor[ACTORDATA].id)) {
    wota_blob = wota.encode(message)
    actor_mod.mailbox_push(actor[ACTORDATA].id, wota_blob)
    return
  }

  if (actor[ACTORDATA].address) {
    if (actor[ACTORDATA].id)
      message.target = actor[ACTORDATA].id
    else
      message.type = "contact"

    peer = peers[actor[ACTORDATA].address + ":" + actor[ACTORDATA].port]
    if (!peer) {
      if (!portal) {
        log.system(`creating a contactor ...`)
        portal = enet.create_host({address:"any"})
        log.system(`allowing contact to port ${portal.port()}`)
        enet_check()
      }
      log.system(`no peer! connecting to ${actor[ACTORDATA].address}:${actor[ACTORDATA].port}`)
      peer = portal.connect(actor[ACTORDATA].address, actor[ACTORDATA].port)
      peer_queue.set(peer, [message])
    } else {
      peer.send(nota.encode(message))
    }
    return
  }
  log.system(`Unable to send message to actor ${actor[ACTORDATA].id}`)
}

function send_messages() {
   // if we've been flagged to stop, bail out before doing anything
   if (need_stop) {
     actor_die()
     message_queue = []
     return
   }

   var _qi = 0
   var _qm = null
   while (_qi < length(message_queue)) {
     _qm = message_queue[_qi]
     if (_qm.startup) {
       actor_mod.createactor(_qm.startup)
     } else {
       actor_send(_qm.actor, _qm.send)
     }
     _qi = _qi + 1
   }

   message_queue = []
 }

var replies = {}

function send(actor, message, reply) {
  var send_msg = null
  var target = null
  var header = null
  var id = null

  if (!is_object(actor)) {
    log.error(`Must send to an actor object. Provided: ${actor}`)
    disrupt
  }

  if (!is_object(message)) {
    log.error('Message must be an object')
    disrupt
  }
  send_msg = {type:"user", data: message}
  target = actor

  if (actor[HEADER] && actor[HEADER].replycc) {
    header = actor[HEADER]
    if (!header.replycc || !is_actor(header.replycc)) {
      log.error(`Supplied actor had a return, but it's not a valid actor! ${actor[HEADER]}`)
      disrupt
    }

    target = header.replycc
    send_msg.return = header.reply
  }

  if (reply) {
    id = guid()
    replies[id] = reply
    $_.delay(_ => {
      if (replies[id]) {
        replies[id](null, "timeout")
        delete replies[id]
      }
    }, REPLYTIMEOUT)
    send_msg.reply = id
    send_msg.replycc_id = _cell.id
  }

  // Instead of sending immediately, queue it
  actor_prep(target, send_msg);
}

stone(send)

if (!_cell.args.id) _cell.id = guid()
else _cell.id = _cell.args.id

$_.self = create_actor({id: _cell.id})

// Actor's timeslice for processing a single message
function turn(msg)
{
  var mes = wota.decode(msg)
  handle_message(mes)
  send_messages()
}

//log.console(`FIXME: need to get main from config, not just set to true`)
actor_mod.register_actor(_cell.id, turn, true, config.ar_timer)

if (config.actor_memory)
  js.mem_limit(config.actor_memory)

if (config.stack_max)
  js.max_stacksize(config.system.stack_max);

overling = _cell.args.overling_id ? create_actor({id: _cell.args.overling_id}) : null
$_.overling = overling

root = _cell.args.root_id ? create_actor({id: _cell.args.root_id}) : null
if (root == null) root = $_.self

if (overling) {
  $_.couple(overling)
  report_to_overling({type:'greet', actor_id: _cell.id})
}

// sys messages are always dispatched immediately
function sys_msg(actor, msg)
{
  var envelope = {}
  envelope[SYSYM] = msg
  actor_send(actor, envelope)
}

// messages sent to here get put into the cb provided to start
function report_to_overling(msg)
{
  if (!overling) return
  sys_msg(overling, {kind:'underling', message:msg, from_id: _cell.id})
}

// Determine the program to run from command line
var program = _cell.args.program

if (!program) {
  log.error('No program specified. Usage: cell <program> [args...]')
  os.exit(1)
}

function handle_actor_disconnect(id) {
  var greeter = greeters[id]
  if (greeter) {
    greeter({type: "stopped", id})
    delete greeters[id]
  }
  log.system(`actor ${id} disconnected`)
  if (!is_null(couplings[id])) actor_die("coupled actor died") // couplings now disrupts instead of stop
}

function handle_sysym(msg)
{
  var from_id = null
  var from_actor = null
  var greeter = null
  var letter2 = null
  var greet_msg = null

  if (msg.kind == 'stop') {
    actor_die("got stop message")
  } else if (msg.kind == 'underling') {
    from_id = msg.from_id
    greeter = greeters[from_id]
    if (greeter) {
      greet_msg = msg.message
      if (greet_msg.actor_id) {
        greet_msg.actor = create_actor({id: greet_msg.actor_id})
      }
      greeter(greet_msg)
    }
    if (msg.message.type == 'disrupt' || msg.message.type == 'stop')
      delete underlings[from_id]
  } else if (msg.kind == 'contact') {
    if (portal_fn) {
      letter2 = msg.data
      letter2[HEADER] = msg
      delete msg.data
      portal_fn(letter2)
    } else {
      log.error('Got a contact message, but no portal is established.')
      disrupt
    }
  } else if (msg.kind == 'couple') {
    from_id = msg.from_id
    underlings[from_id] = true
    log.system(`actor ${from_id} is coupled to me`)
  }
}

function handle_message(msg) {
  var letter = null
  var fn = null

  if (msg[SYSYM]) {
    handle_sysym(msg[SYSYM])
    return
  }

  if (msg.type == "user") {
    letter = msg.data // what the sender really sent
    if (msg.replycc_id) {
      msg.replycc = create_actor({id: msg.replycc_id})
    }
    letter[HEADER] = msg
    letter[ACTORDATA] = { reply: msg.reply }

    if (msg.return) {
      fn = replies[msg.return]
      if (fn) fn(letter)
      delete replies[msg.return]
      return
    }

    if (receive_fn) receive_fn(letter)
  } else if (msg.type == "stopped") {
    handle_actor_disconnect(msg.id)
  }
}

function enet_check()
{
  if (portal) portal.service(handle_host)

  $_.delay(enet_check, ENETSERVICE);
}

// enet_check started on demand when $portal() is called

// Finally, run the program
actor_mod.setname(_cell.args.program)

if (_eval_script) {
  // -e flag: compile and run inline script
  $_.clock(_ => {
    var env = {}
    arrfor(array(runtime_env), function(k) { env[k] = runtime_env[k] })
    env.use = function(path) {
      var ck = 'core/' + path
      var _use_core_result = null
      var _use_core_ok = false
      if (use_cache[ck]) return use_cache[ck]
      var _try_core = function() {
        _use_core_result = use_core(path)
        _use_core_ok = true
      } disruption {}
      _try_core()
      if (_use_core_ok && _use_core_result) return _use_core_result
      var _shop_use = function() {
        return shop.use(path, null)
      } disruption {
        log.error(`use('${path}') failed`)
        disrupt
      }
      return _shop_use()
    }
    env.args = _cell.args.arg
    env.log = log
    env = stone(env)

    var ast = analyze(_eval_script, "-e")
    var val = null
    var _compile = function() {
      var mach_blob = compile_user_blob("-e", ast, null)
      val = mach_load(mach_blob, env)
    } disruption {
      os.exit(1)
    }
    _compile()
  })
  return null
}

var prog = _cell.args.program
if (ends_with(prog, '.cm')) {
  os.print(`error: ${prog} is a module (.cm), not a program (.ce)\n`)
  os.exit(1)
}
if (ends_with(prog, '.ce')) prog = text(prog, 0, -3)

var package = use_core('package')

// Find the .ce file using unified resolver
var cwd_package = package.find_package_dir(".")
var prog_info = shop.resolve_program ? shop.resolve_program(prog, cwd_package) : null
var prog_path = null
if (prog_info) {
  prog_path = prog_info.path
} else {
  // Fallback: check CWD, package dir, and core
  prog_path = prog + ".ce"
  if (!fd.is_file(prog_path) && cwd_package)
    prog_path = cwd_package + '/' + prog + '.ce'
  if (!fd.is_file(prog_path))
    prog_path = core_path + '/' + prog + '.ce'
  if (!fd.is_file(prog_path)) {
    os.print(`Main program ${prog} could not be found\n`)
    os.exit(1)
  }
}

$_.clock(_ => {
  var _file_info_ok = false
  var file_info = null
  var _try_fi = function() {
    file_info = shop.file_info ? shop.file_info(prog_path) : null
    _file_info_ok = true
  } disruption {}
  _try_fi()
  if (!_file_info_ok || !file_info)
    file_info = {path: prog_path, is_module: false, is_actor: true, package: null, name: prog}
  // If the unified resolver found the package, use that as the authoritative source
  if (prog_info && prog_info.pkg)
    file_info.package = prog_info.pkg
  var inject = shop.script_inject_for ? shop.script_inject_for(file_info) : []

  // Build env with runtime functions + capability injections
  var env = {}
  arrfor(array(runtime_env), function(k) { env[k] = runtime_env[k] })
  var _ki = 0
  var inj = null
  var key = null
  while (_ki < length(inject)) {
    inj = inject[_ki]
    key = inj
    if (key && key[0] == '$') key = text(key, 1)
    if (key == 'fd') env['$fd'] = fd
    else env['$' + key] = $_[key]
    _ki = _ki + 1
  }

  var pkg = file_info ? file_info.package : null

  // Verify all transitive dependency packages are present, auto-install if missing
  var _deps = null
  var _di = 0
  var _dep_dir = null
  var _auto_install = null
  if (pkg) {
    _deps = package.gather_dependencies(pkg)
    _di = 0
    while (_di < length(_deps)) {
      _dep_dir = package.get_dir(_deps[_di])
      if (!fd.is_dir(_dep_dir)) {
        log.console('installing missing dependency: ' + _deps[_di])
        _auto_install = function() {
          shop.sync(_deps[_di])
        } disruption {
          log.error('failed to install dependency: ' + _deps[_di])
          disrupt
        }
        _auto_install()
      }
      _di = _di + 1
    }
  }

  env.use = function(path) {
    var ck = 'core/' + path
    var _use_core_result = null
    var _use_core_ok = false
    if (use_cache[ck]) return use_cache[ck]
    var _try_core = function() {
      _use_core_result = use_core(path)
      _use_core_ok = true
    } disruption {}
    _try_core()
    if (_use_core_ok && _use_core_result) return _use_core_result
    var _shop_use = function() {
      return shop.use(path, pkg)
    } disruption {
      log.error(`use('${path}') failed (package: ${pkg})`)
      disrupt
    }
    return _shop_use()
  }
  env.args = _cell.args.arg
  env.log  = log
  env = stone(env)

  // --- run_program: execute the resolved program ---
  function run_program() {
    var native_build = null
    var native_dylib_path = null
    var native_handle = null
    var native_basename = null
    var native_sym = null

    // Native execution path: compile to dylib and run
    if (native_mode) {
      native_build = use_core('build')
      native_dylib_path = native_build.compile_native(prog_path, null, null, pkg)
      native_handle = os.dylib_open(native_dylib_path)
      native_basename = file_info.name ? file_info.name + (file_info.is_actor ? '.ce' : '.cm') : fd.basename(prog_path)
      native_sym = pkg ? shop.c_symbol_for_file(pkg, native_basename) : null
      if (native_sym)
        os.native_module_load_named(native_handle, native_sym, env)
      else
        os.native_module_load(native_handle, env)
      return
    }

    var source_blob = fd.slurp(prog_path)
    var _cached_path = module_cache_path(source_blob, 'mach')
    var val = null
    var script = null
    var ast = null
    var mach_blob = null
    var _compile = function() {
      if (_cached_path && fd.is_file(_cached_path)) {
        val = mach_load(fd.slurp(_cached_path), env)
      } else {
        script = text(source_blob)
        ast = analyze(script, prog_path)
        mach_blob = compile_user_blob(prog, ast, pkg)
        if (_cached_path) {
          ensure_build_dir()
          fd.slurpwrite(_cached_path, mach_blob)
        }
        val = mach_load(mach_blob, env)
      }
    } disruption {
      os.exit(1)
    }
    _compile()
    if (val) {
      log.error('Program must not return anything')
      disrupt
    }
  }

  // --- Auto-boot: pre-compile uncached deps before running ---
  // Only auto-boot for the root program (not child actors, not boot itself).
  // Quick-check deps inline; only spawn boot actor if something needs compiling.
  var _is_root_actor = !_cell.args.overling_id
  var _skip_boot = !_is_root_actor || prog == 'boot' || prog == 'compile_worker'

  var _needs_boot = false
  var _boot_check = function() {
    var _deps = shop.trace_deps(prog_path)
    var _bi = 0
    var _bs = null
    while (_bi < length(_deps.scripts)) {
      _bs = _deps.scripts[_bi]
      if (native_mode) {
        if (!shop.is_native_cached(_bs.path, _bs.package)) {
          _needs_boot = true
          return
        }
      } else {
        if (!shop.is_cached(_bs.path)) {
          _needs_boot = true
          return
        }
      }
      _bi = _bi + 1
    }
    _bi = 0
    while (_bi < length(_deps.c_packages)) {
      if (_deps.c_packages[_bi] != 'core' && !shop.has_c_manifest(_deps.c_packages[_bi])) {
        _needs_boot = true
        return
      }
      _bi = _bi + 1
    }
  } disruption {
    _needs_boot = true
  }
  if (!_skip_boot) _boot_check()

  if (_skip_boot || !_needs_boot) {
    run_program()
  } else {
    $_.start(function(event) {
      if (event.type == 'greet') {
        send(event.actor, {
          program: prog,
          package: pkg,
          native: native_mode
        })
      }
      if (event.type == 'stop') {
        run_program()
      }
      if (event.type == 'disrupt') {
        // Boot failed, run program anyway
        run_program()
      }
    }, 'boot')
  }
})