def test_build_statistic_lines_uncovered():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.buildStatisticLinesUncovered(5)
    assert stream.observed_output.strip() == textwrap.dedent("""\
            ##teamcity[buildStatisticValue timestamp='2000-11-02T10:23:01.556' key='CodeCoverageAbsLUncovered' value='5']
        """).strip().encode('utf-8')

def test_import_data():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.importData('junit', '/path/to/junit.xml')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[importData timestamp='2000-11-02T10:23:01.556' path='/path/to/junit.xml' type='junit']
        """).strip().encode('utf-8')

def test_set_parameter():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.setParameter(name='env', value='mt3')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[setParameter timestamp='2000-11-02T10:23:01.556' name='env' value='mt3']
        """).strip().encode('utf-8')

def test_block_closed():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.blockClosed('dummyMessage')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[blockClosed timestamp='2000-11-02T10:23:01.556' name='dummyMessage']
        """).strip().encode('utf-8')

def test_build_problem():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.buildProblem(description='something is wrong', identity='me')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[buildProblem timestamp='2000-11-02T10:23:01.556' description='something is wrong' identity='me']
        """).strip().encode('utf-8')

def test_build_status():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.buildStatus(status='failure', text='compile error')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[buildStatus timestamp='2000-11-02T10:23:01.556' status='failure' text='compile error']
        """).strip().encode('utf-8')

def test_test_stderr():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.testStdErr(testName='only a test', out='out')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[testStdErr timestamp='2000-11-02T10:23:01.556' name='only a test' out='out']
        """).strip().encode('utf-8')

def test_test_failed():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.testFailed(testName='only a test', message='some message', details='details')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[testFailed timestamp='2000-11-02T10:23:01.556' details='details' message='some message' name='only a test']
        """).strip().encode('utf-8')

def test_test_suite_finished():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.testSuiteFinished('suite emotion')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[testSuiteFinished timestamp='2000-11-02T10:23:01.556' name='suite emotion']
        """).strip().encode('utf-8')

def test_compilation_finished():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.compilationFinished('gcc')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[compilationFinished timestamp='2000-11-02T10:23:01.556' compiler='gcc']
        """).strip().encode('utf-8')

def test_build_statistic_value():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.buildStatisticValue('CustomKey', '1234')
    assert stream.observed_output.strip() == textwrap.dedent("""\
            ##teamcity[buildStatisticValue timestamp='2000-11-02T10:23:01.556' key='CustomKey' value='1234']
        """).strip().encode('utf-8')

def test_disable_service_messages():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.disableServiceMessages()
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[disableServiceMessages timestamp='2000-11-02T10:23:01.556']
        """).strip().encode('utf-8')

def test_publish_artifacts():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.publishArtifacts('/path/to/file')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[publishArtifacts '/path/to/file']
        """).strip().encode('utf-8')

def test_progress_message():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.progressMessage('doing stuff')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[progressMessage 'doing stuff']
        """).strip().encode('utf-8')

def test_custom_message():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    messages.customMessage('blah blah blah', status='all good')
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[message timestamp='2000-11-02T10:23:01.556' errorDetails='' status='all good' text='blah blah blah']
        """).strip().encode('utf-8')

 def test_one_property(self):
     stream = MessagesTest.StreamStub()
     messages = TeamcityServiceMessages(output=stream, now=lambda: datetime.min)
     messages.message("dummyMessage", fruit="apple")
     self.assertEqual(
         stream.observed_output, "\n##teamcity[dummyMessage timestamp='0001-01-01T00:00' fruit='apple']\n"
     )

 def test_three_properties(self):
     stream = MessagesTest.StreamStub()
     messages = TeamcityServiceMessages(output=stream, now=lambda: datetime.min)
     messages.message("dummyMessage", fruit="apple", meat="steak", pie="raspberry")
     self.assertEqual(
         stream.observed_output,
         "\n##teamcity[dummyMessage timestamp='0001-01-01T00:00' " "fruit='apple' meat='steak' pie='raspberry']\n",
     )

def test_unicode():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    if sys.version_info < (3, ):
        bjork = 'Bj\xc3\xb6rk Gu\xc3\xb0mundsd\xc3\xb3ttir'.decode('utf-8')
    else:
        bjork = b('Bj\xc3\xb6rk Gu\xc3\xb0mundsd\xc3\xb3ttir').decode('utf-8')
    messages.message(bjork)
    assert stream.observed_output == ("\n##teamcity[%s timestamp='2000-11-02T10:23:01.556']\n" % bjork).encode('utf-8')

def test_test():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    with messages.test('only a test'):
        pass
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[testStarted timestamp='2000-11-02T10:23:01.556' name='only a test']
        ##teamcity[testFinished timestamp='2000-11-02T10:23:01.556' name='only a test']
        """).strip().encode('utf-8')

def test_progress():
    stream = StreamStub()
    messages = TeamcityServiceMessages(output=stream, now=lambda: fixed_date)
    with messages.progress('only a test'):
        pass
    assert stream.observed_output.strip() == textwrap.dedent("""\
        ##teamcity[progressStart 'only a test']
        ##teamcity[progressFinish 'only a test']
        """).strip().encode('utf-8')