from __future__ import absolute_import
import sys

from conda.cli import common
from conda import plan


def install(prefix, specs, args, data):
    # TODO: do we need this?
    common.check_specs(prefix, specs, json=args.json)

    # TODO: support all various ways this happens
    index = common.get_index_trap(
        channel_urls=data.get('channels', ())
    )
    actions = plan.install_actions(prefix, index, specs)
    if plan.nothing_to_do(actions):
        sys.stderr.write('# TODO handle more gracefully')
        sys.exit(-1)

    with common.json_progress_bars(json=args.json and not args.quiet):
        try:
            plan.execute_actions(actions, index, verbose=not args.quiet)
        except RuntimeError as e:
            if len(e.args) > 0 and "LOCKERROR" in e.args[0]:
                error_type = "AlreadyLocked"
            else:
                error_type = "RuntimeError"
            common.exception_and_exit(e, error_type=error_type, json=args.json)
        except SystemExit as e:
            common.exception_and_exit(e, json=args.json)


from __future__ import absolute_import
import sys

from conda.cli import common
from conda import plan


def install(prefix, specs, args, data):
    # TODO: do we need this?
    common.check_specs(prefix, specs, json=args.json)

    # TODO: support all various ways this happens
    index = common.get_index_trap()
    actions = plan.install_actions(prefix, index, specs)
    if plan.nothing_to_do(actions):
        sys.stderr.write('# TODO handle more gracefully')
        sys.exit(-1)

    with common.json_progress_bars(json=args.json and not args.quiet):
        try:
            plan.execute_actions(actions, index, verbose=not args.quiet)
        except RuntimeError as e:
            if len(e.args) > 0 and "LOCKERROR" in e.args[0]:
                error_type = "AlreadyLocked"
            else:
                error_type = "RuntimeError"
            common.exception_and_exit(e, error_type=error_type, json=args.json)
        except SystemExit as e:
            common.exception_and_exit(e, json=args.json)


--- 
+++ 
@@ -10,7 +10,9 @@
     common.check_specs(prefix, specs, json=args.json)
 
     # TODO: support all various ways this happens
-    index = common.get_index_trap()
+    index = common.get_index_trap(
+        channel_urls=data.get('channels', ())
+    )
     actions = plan.install_actions(prefix, index, specs)
     if plan.nothing_to_do(actions):
         sys.stderr.write('# TODO handle more gracefully')
Add support for channels in the spec
