import org.gradle.launcher.daemon.server.stats.DaemonRunningStats
import spock.lang.Specification

class DaemonHealthStatsTest extends Specification {

    def gcInfo = Stub(GarbageCollectionInfo)
    def gcMonitor = Stub(DefaultGarbageCollectionMonitor)
    def runningStats = Stub(DaemonRunningStats)
    def healthStats = new DaemonHealthStats(runningStats, gcInfo, gcMonitor)

    def "includes garbage collection data when present"() {
        when:

        0 * _
    }

    def "requests status report from all daemons"() {
        given:
        def daemon1 = Stub(DaemonInfo)
        def daemon2 = Stub(DaemonInfo)

        when:
        client.listAll()

        then:
        1 * registry.getAll() >> { [daemon1, daemon2] as List<DaemonInfo> }

    }

    def "returns cached output when exists"() {
        def cachedResult = Try.successful(Mock(Object))
        def returnedOriginMetadata = Stub(OriginMetadata) {
            buildInvocationId >> "12345"
        }
        def identityCacheResult = Stub(ExecutionEngine.IdentityCacheResult) {
            result >> cachedResult
            originMetadata >> Optional.of(returnedOriginMetadata)
        }

    def "knows task status"() {
        def skipped = Stub(TaskState) {
            getSkipped() >> true
            getSkipMessage() >> "Skipped for a good reason."
        }
        def busy = Stub(TaskState) {
            getSkipped() >> false
            getDidWork() >> true
        }
        def noWork = Stub(TaskState) {
            getSkipped() >> false
            getDidWork() >> false
        }

        0 * phasedActionResultListener.onResult(_)
    }

    def "deserialize and correctly map results"() {
        def result1 = 'result1'
        def serializedResult1 = Stub(SerializedPayload)
        def result2 = 'result2'
        def serializedResult2 = Stub(SerializedPayload)

        given:
        payloadSerializer.deserialize(serializedResult1) >> result1
        payloadSerializer.deserialize(serializedResult2) >> result2

        def selector = new DefaultProjectComponentSelector(Stub(BuildIdentifier), Path.path(":id:path"), Path.path(":project:path"), "projectName", ImmutableAttributes.EMPTY, [])
        def sameIdPath = new DefaultProjectComponentIdentifier(Stub(BuildIdentifier), Path.path(":id:path"), Path.path(":project:path"), "projectName")

        Task task1 = task(':task1')
        Task task2 = task(':task2')
        ResultHandlerVersion1<Void> adaptedHandler
        ResultHandler<Void> handler = Mock()
        OutputStream stdout = Stub()
        OutputStream stderr = Stub()

        when:
        launcher.standardOutput = stdout
        launcher.standardError = stderr
        launcher.forTasks(task1, task2)
        launcher.run(handler)

        then:

    def "types subscribed when actions registered"() {
        given:
        r.registerEagerAddAction(String, Stub(Action))

        expect:
        r.isSubscribed(null)
        r.isSubscribed(String)
        !r.isSubscribed(CharSequence)
        !r.isSubscribed(StringBuilder)

        r.registerEagerAddAction(CharSequence, Stub(Action))

        r.isSubscribed(null)
        r.isSubscribed(String)
        r.isSubscribed(CharSequence)

    final DefaultArtifactIdentifierFileStore artifactIdentifierFileStore = Stub()
    final MetaDataParser<MutableMavenModuleResolveMetadata> pomParser = Stub()
    final GradleModuleMetadataParser metadataParser = Stub()
    final AuthenticationContainer authenticationContainer = Stub()
    final FileResourceRepository fileResourceRepository = Mock()

    def artifactCacheMetadata = Stub(ArtifactCacheMetadata) {
        getCacheDir() >> cacheDir
        getExternalResourcesStoreDirectory() >> resourcesDir
        getFileStoreDirectory() >> filesDir
        getMetaDataStoreDirectory() >> metaDataDir.file("descriptors")
    }
    def fileAccessTimeJournal = new ModificationTimeFileAccessTimeJournal()
    def usedGradleVersions = Stub(UsedGradleVersions)