aboutsummaryrefslogtreecommitdiff
path: root/stage2/Stage2.scala
blob: 4ae149cf0cb22030b6afb5c87f4e877c1efd7cbc (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
package cbt

import java.io._

import scala.collection.immutable.Seq

import cbt.paths._

object Stage2 extends Stage2Base{
  def run( args: Stage2Args ): Unit = {
    import args.logger

    val lib = new Lib(args.logger)

    logger.stage2(s"Stage2 start")
    val loop = args.args.lift(0) == Some("loop")
    val direct = args.args.lift(0) == Some("direct")

    val taskIndex = if (loop || direct) {
      1
    } else {
      0
    }
    val task = args.args.lift( taskIndex )

    val context = Context( args.cwd, args.args.drop( taskIndex ), logger, args.cbtHasChanged, new ClassLoaderCache(logger) )
    val first = lib.loadRoot( context )
    val build = first.finalBuild

    val res =
      if (loop) {
        // TODO: this should allow looping over task specific files, like test files as well
        val triggerFiles = first.triggerLoopFiles.map(lib.realpath)
        val triggerCbtFiles = Seq( nailgun, stage1, stage2 ).map(lib.realpath _)
        val allTriggerFiles = triggerFiles ++ triggerCbtFiles

        logger.loop("Looping change detection over:\n - "++allTriggerFiles.mkString("\n - "))

        lib.watch(allTriggerFiles){
          case file if triggerCbtFiles.exists(file.toString startsWith _.toString) =>
            logger.loop("Change is in CBT's own source code.")
            logger.loop("Restarting CBT.")
            scala.util.control.Breaks.break

          case file if triggerFiles.exists(file.toString startsWith _.toString) =>
            val build = lib.loadDynamic(context)
            val reflectBuild = new lib.ReflectBuild( build )
            logger.loop(s"Re-running $task for " ++ build.projectDirectory.toString)
            reflectBuild.callNullary(task)
        }
      } else {
        new lib.ReflectBuild(build).callNullary(task)
      }

    logger.stage2(s"Stage2 end")
  }
}