}

    URI getUri() {
        return new URI("${server.uri}${pathOnServer}")
    }

    void expectLstat() {
        server.expectLstat(pathOnServer)
    }

    void expectLstatMissing() {
        server.expectLstatMissing(pathOnServer)
    }

    void expectStat() {
        server.expectStat(pathOnServer)
    }

    void expectOpen() {
        server.expectOpen(pathOnServer)
    }

            }
        """
        sftpServer.expectLstat("/")
        def sync = coordinator.expectAndBlock('sync')

        when:
        def gradle = executer.withTasks('reuseClient').withArgument("--info").start()
        sync.waitForAllPendingCalls()

        then:
        sftpServer.clearSessions()
        sftpServer.expectLstat("/")
        sleep(1000)

        when:
        sync.releaseAll()

        when:
        def directory = '/repo/org.group.name/publish/2'
        directory.tokenize('/').findAll().inject('') { path, token ->
            def currentPath = "$path/$token"
            server.expectLstat(currentPath)
            currentPath
        }
        server.expectMkdirBroken('/repo')

        then:
        fails 'publish'

    }

    void allowInit() {
        expectations << new SftpAllow(SftpConstants.SSH_FXP_INIT)
    }

    void expectLstat(String path) {
        expectations << new SftpExpectOnePath(SftpConstants.SSH_FXP_LSTAT, "LSTAT", path)
    }

    void expectMetadataRetrieve(String path) {
        expectLstat(path)
    }

    void expectOpen(String path) {

        projectB1.publish()

        and:
        server.expectStat('/repo/group/projectA/')
        server.expectDirectoryList('/repo/group/projectA/')

        projectA1.ivy.expectMetadataRetrieve()
        projectA1.ivy.expectFileDownload()

        server.expectStat('/repo/group/projectB/')
        server.expectDirectoryList('/repo/group/projectB/')

        throw new UnsupportedOperationException()
    }

    void expectMetadataRetrieveMissing() {
        throw new UnsupportedOperationException()
    }

    void expectDownload() {
        server.expectStat(pathOnServer)
        server.expectDirectoryList(pathOnServer)
    }

    void expectDownloadMissing() {
        throw new UnsupportedOperationException()
    }

    void expectMetadataRetrieve() {

            task retrieve(type: Sync) {
                from configurations.compile
                into 'libs'
            }
        """

        when:
        server.expectStat('/repo/org.group.name/projectA/')

        then:
        fails 'retrieve'
        assertTaskFailureDescription(":retrieve")
        failure.assertHasCause("Could not resolve all files for configuration ':compile'.")