#!/bin/bash -e

# Imports all inputs at once

. "$(dirname "${BASH_SOURCE[0]}")"/../lib/runscripts/util.run "$@"

hidden_srcs()

{

    local hidden_srcs=1 inputs=() # with_all adds the hidden srcs to @inputs

    . "$selfDir/with_all" import "$@"

}

delete_logs()

{

	if test "$delete_logs"; then

		(set -x; find . -name "${n:+n=$n.}$version.log.sql" -delete)

	fi

}

main()

{

    local self="${BASH_SOURCE[0]}"

    local selfDir="$(dirname -- "$self")"

    pushd "$selfDir/.."

    if ! test "$SHLVL" -ge 2; then # was run without subshell

        # needs subshell so errexits don't close the terminal window

        echo 'usage: must be run in a subshell, obtained by running `$0`' >&2

        return 0 # not nonzero because this will close the terminal window

    fi

    if test "${BASH_LINENO[1]}" = 0; then # was run without initial "."

        echo "usage: (*in subshell*) [version=...] [inputs=(inputs/src/ ...)]; \

. $self [vars...] (note initial \".\")"|fold -s >&2

        return 0 # not nonzero because this will close the subshell

    fi

    : ${version=$(make -s version)}

    local by_col=${by_col-1} full_import=1

    export version by_col full_import

    if test ! "${log-1}"; then local delete_logs=1; fi #log==''

    trap delete_logs SIGINT SIGTERM #not EXIT b/c doesn't run until *shell* exit

    local log=1 # always use log files for background processes

    # remove any leftover TNRS lockfile. usually, the PID in it would not exist,

    # but sometimes it now refers to an active process which blocks tnrs.make.

    "rm" -f inputs/.TNRS/tnrs/tnrs.make.lock

    make schemas/$version/reinstall

    local hidden_srcs=1; . "$selfDir/with_all" Source/import "$@"

        # note that this isn't affected by $import_source

    wait # wait for asynchronous commands

    unset hidden_srcs

    local import_source= # Source tables have already been imported

    export import_source # must come after local

    hidden_srcs "$@" # separate function to avoid overwriting @inputs

    wait # wait for asynchronous commands

    . "$selfDir/with_all" import_scrub "$@" # uses $by_col

    local jobs="$(jobs -p)"

    echo "import_scrub PIDs: $jobs" >&2

    bin/after_import $jobs &

    echo "after_import PID: $!" >&2

    popd

    delete_logs # manually run b/c `trap EXIT` doesn't run until *shell* exit

}

on_exit