import pytest

from mitmproxy import options
from mitmproxy.tools.web import master

from ... import tservers


class TestWebMaster(tservers.MasterTest):

            

Reported by Pylint.

              from mitmproxy import options
from mitmproxy.tools.web import master

from ... import tservers


class TestWebMaster(tservers.MasterTest):
    def mkmaster(self, **opts):
        o = options.Options(**opts)

            

Reported by Pylint.

              import pytest

from mitmproxy import options
from mitmproxy.tools.web import master

from ... import tservers


class TestWebMaster(tservers.MasterTest):

            

Reported by Pylint.

              from ... import tservers


class TestWebMaster(tservers.MasterTest):
    def mkmaster(self, **opts):
        o = options.Options(**opts)
        return master.WebMaster(o)

    @pytest.mark.asyncio

            

Reported by Pylint.

              

class TestWebMaster(tservers.MasterTest):
    def mkmaster(self, **opts):
        o = options.Options(**opts)
        return master.WebMaster(o)

    @pytest.mark.asyncio
    async def test_basic(self):

            

Reported by Pylint.

              

class TestWebMaster(tservers.MasterTest):
    def mkmaster(self, **opts):
        o = options.Options(**opts)
        return master.WebMaster(o)

    @pytest.mark.asyncio
    async def test_basic(self):

            

Reported by Pylint.

              
class TestWebMaster(tservers.MasterTest):
    def mkmaster(self, **opts):
        o = options.Options(**opts)
        return master.WebMaster(o)

    @pytest.mark.asyncio
    async def test_basic(self):
        m = self.mkmaster()

            

Reported by Pylint.

                      return master.WebMaster(o)

    @pytest.mark.asyncio
    async def test_basic(self):
        m = self.mkmaster()
        for i in (1, 2, 3):
            await self.dummy_cycle(m, 1, b"")
            assert len(m.view) == i

            

Reported by Pylint.

              
    @pytest.mark.asyncio
    async def test_basic(self):
        m = self.mkmaster()
        for i in (1, 2, 3):
            await self.dummy_cycle(m, 1, b"")
            assert len(m.view) == i

            

Reported by Pylint.

                      m = self.mkmaster()
        for i in (1, 2, 3):
            await self.dummy_cycle(m, 1, b"")
            assert len(m.view) == i

            

Reported by Bandit.

              """Handle flows as command arguments."""
import typing

from mitmproxy import command
from mitmproxy import ctx
from mitmproxy import flow
from mitmproxy import http



            

Reported by Pylint.

              import typing

from mitmproxy import command
from mitmproxy import ctx
from mitmproxy import flow
from mitmproxy import http


class MyAddon:

            

Reported by Pylint.

              
from mitmproxy import command
from mitmproxy import ctx
from mitmproxy import flow
from mitmproxy import http


class MyAddon:
    @command.command("myaddon.addheader")

            

Reported by Pylint.

              from mitmproxy import command
from mitmproxy import ctx
from mitmproxy import flow
from mitmproxy import http


class MyAddon:
    @command.command("myaddon.addheader")
    def addheader(self, flows: typing.Sequence[flow.Flow]) -> None:

            

Reported by Pylint.

              """Handle flows as command arguments."""
import typing

from mitmproxy import command
from mitmproxy import ctx
from mitmproxy import flow
from mitmproxy import http



            

Reported by Pylint.

              from mitmproxy import http


class MyAddon:
    @command.command("myaddon.addheader")
    def addheader(self, flows: typing.Sequence[flow.Flow]) -> None:
        for f in flows:
            if isinstance(f, http.HTTPFlow):
                f.request.headers["myheader"] = "value"

            

Reported by Pylint.

              from mitmproxy import http


class MyAddon:
    @command.command("myaddon.addheader")
    def addheader(self, flows: typing.Sequence[flow.Flow]) -> None:
        for f in flows:
            if isinstance(f, http.HTTPFlow):
                f.request.headers["myheader"] = "value"

            

Reported by Pylint.

              
class MyAddon:
    @command.command("myaddon.addheader")
    def addheader(self, flows: typing.Sequence[flow.Flow]) -> None:
        for f in flows:
            if isinstance(f, http.HTTPFlow):
                f.request.headers["myheader"] = "value"
        ctx.log.alert("done")


            

Reported by Pylint.

              
class MyAddon:
    @command.command("myaddon.addheader")
    def addheader(self, flows: typing.Sequence[flow.Flow]) -> None:
        for f in flows:
            if isinstance(f, http.HTTPFlow):
                f.request.headers["myheader"] = "value"
        ctx.log.alert("done")


            

Reported by Pylint.

              class MyAddon:
    @command.command("myaddon.addheader")
    def addheader(self, flows: typing.Sequence[flow.Flow]) -> None:
        for f in flows:
            if isinstance(f, http.HTTPFlow):
                f.request.headers["myheader"] = "value"
        ctx.log.alert("done")



            

Reported by Pylint.

              from typing import Optional

from mitmproxy.contrib.wbxml import ASCommandResponse
from . import base


class ViewWBXML(base.View):
    name = "WBXML"
    __content_types = (

            

Reported by Pylint.

                          parsedContent = parser.xmlString
            if parsedContent:
                return "WBXML", base.format_text(parsedContent)
        except:
            return None

    def render_priority(self, data: bytes, *, content_type: Optional[str] = None, **metadata) -> float:
        return float(content_type in self.__content_types)

            

Reported by Pylint.

                      except:
            return None

    def render_priority(self, data: bytes, *, content_type: Optional[str] = None, **metadata) -> float:
        return float(content_type in self.__content_types)

            

Reported by Pylint.

                      except:
            return None

    def render_priority(self, data: bytes, *, content_type: Optional[str] = None, **metadata) -> float:
        return float(content_type in self.__content_types)

            

Reported by Pylint.

              from typing import Optional

from mitmproxy.contrib.wbxml import ASCommandResponse
from . import base


class ViewWBXML(base.View):
    name = "WBXML"
    __content_types = (

            

Reported by Pylint.

              from . import base


class ViewWBXML(base.View):
    name = "WBXML"
    __content_types = (
        "application/vnd.wap.wbxml",
        "application/vnd.ms-sync.wbxml"
    )

            

Reported by Pylint.

                      "application/vnd.ms-sync.wbxml"
    )

    def __call__(self, data, **metadata):
        try:
            parser = ASCommandResponse.ASCommandResponse(data)
            parsedContent = parser.xmlString
            if parsedContent:
                return "WBXML", base.format_text(parsedContent)

            

Reported by Pylint.

                  def __call__(self, data, **metadata):
        try:
            parser = ASCommandResponse.ASCommandResponse(data)
            parsedContent = parser.xmlString
            if parsedContent:
                return "WBXML", base.format_text(parsedContent)
        except:
            return None


            

Reported by Pylint.

                      except:
            return None

    def render_priority(self, data: bytes, *, content_type: Optional[str] = None, **metadata) -> float:
        return float(content_type in self.__content_types)

            

Reported by Pylint.

                      except:
            return None

    def render_priority(self, data: bytes, *, content_type: Optional[str] = None, **metadata) -> float:
        return float(content_type in self.__content_types)

            

Reported by Pylint.

              """
Use mitmproxy's filter pattern in scripts.
"""
from mitmproxy import flowfilter
from mitmproxy import ctx, http


class Filter:
    def __init__(self):

            

Reported by Pylint.

              Use mitmproxy's filter pattern in scripts.
"""
from mitmproxy import flowfilter
from mitmproxy import ctx, http


class Filter:
    def __init__(self):
        self.filter: flowfilter.TFilter = None

            

Reported by Pylint.

                  def __init__(self):
        self.filter: flowfilter.TFilter = None

    def configure(self, updated):
        self.filter = flowfilter.parse(ctx.options.flowfilter)

    def load(self, l):
        l.add_option(
            "flowfilter", str, "", "Check that flow matches filter."

            

Reported by Pylint.

              """
Use mitmproxy's filter pattern in scripts.
"""
from mitmproxy import flowfilter
from mitmproxy import ctx, http


class Filter:
    def __init__(self):

            

Reported by Pylint.

              from mitmproxy import ctx, http


class Filter:
    def __init__(self):
        self.filter: flowfilter.TFilter = None

    def configure(self, updated):
        self.filter = flowfilter.parse(ctx.options.flowfilter)

            

Reported by Pylint.

                  def __init__(self):
        self.filter: flowfilter.TFilter = None

    def configure(self, updated):
        self.filter = flowfilter.parse(ctx.options.flowfilter)

    def load(self, l):
        l.add_option(
            "flowfilter", str, "", "Check that flow matches filter."

            

Reported by Pylint.

                  def configure(self, updated):
        self.filter = flowfilter.parse(ctx.options.flowfilter)

    def load(self, l):
        l.add_option(
            "flowfilter", str, "", "Check that flow matches filter."
        )

    def response(self, flow: http.HTTPFlow) -> None:

            

Reported by Pylint.

                  def configure(self, updated):
        self.filter = flowfilter.parse(ctx.options.flowfilter)

    def load(self, l):
        l.add_option(
            "flowfilter", str, "", "Check that flow matches filter."
        )

    def response(self, flow: http.HTTPFlow) -> None:

            

Reported by Pylint.

                  def configure(self, updated):
        self.filter = flowfilter.parse(ctx.options.flowfilter)

    def load(self, l):
        l.add_option(
            "flowfilter", str, "", "Check that flow matches filter."
        )

    def response(self, flow: http.HTTPFlow) -> None:

            

Reported by Pylint.

                          "flowfilter", str, "", "Check that flow matches filter."
        )

    def response(self, flow: http.HTTPFlow) -> None:
        if flowfilter.match(self.filter, flow):
            ctx.log.info("Flow matches filter:")
            ctx.log.info(flow)



            

Reported by Pylint.

              """React to configuration changes."""
import typing

from mitmproxy import ctx
from mitmproxy import exceptions


class AddHeader:
    def load(self, loader):

            

Reported by Pylint.

              import typing

from mitmproxy import ctx
from mitmproxy import exceptions


class AddHeader:
    def load(self, loader):
        loader.add_option(

            

Reported by Pylint.

              """React to configuration changes."""
import typing

from mitmproxy import ctx
from mitmproxy import exceptions


class AddHeader:
    def load(self, loader):

            

Reported by Pylint.

              from mitmproxy import exceptions


class AddHeader:
    def load(self, loader):
        loader.add_option(
            name = "addheader",
            typespec = typing.Optional[int],
            default = None,

            

Reported by Pylint.

              

class AddHeader:
    def load(self, loader):
        loader.add_option(
            name = "addheader",
            typespec = typing.Optional[int],
            default = None,
            help = "Add a header to responses",

            

Reported by Pylint.

              

class AddHeader:
    def load(self, loader):
        loader.add_option(
            name = "addheader",
            typespec = typing.Optional[int],
            default = None,
            help = "Add a header to responses",

            

Reported by Pylint.

                          help = "Add a header to responses",
        )

    def configure(self, updates):
        if "addheader" in updates:
            if ctx.options.addheader is not None and ctx.options.addheader > 100:
                raise exceptions.OptionsError("addheader must be <= 100")

    def response(self, flow):

            

Reported by Pylint.

                          help = "Add a header to responses",
        )

    def configure(self, updates):
        if "addheader" in updates:
            if ctx.options.addheader is not None and ctx.options.addheader > 100:
                raise exceptions.OptionsError("addheader must be <= 100")

    def response(self, flow):

            

Reported by Pylint.

                          if ctx.options.addheader is not None and ctx.options.addheader > 100:
                raise exceptions.OptionsError("addheader must be <= 100")

    def response(self, flow):
        if ctx.options.addheader is not None:
            flow.response.headers["addheader"] = str(ctx.options.addheader)


addons = [

            

Reported by Pylint.

                          if ctx.options.addheader is not None and ctx.options.addheader > 100:
                raise exceptions.OptionsError("addheader must be <= 100")

    def response(self, flow):
        if ctx.options.addheader is not None:
            flow.response.headers["addheader"] = str(ctx.options.addheader)


addons = [

            

Reported by Pylint.

              import urwid

from mitmproxy.test import tflow
from mitmproxy.tools.console import common


def test_format_flow():
    flows = [
        tflow.tflow(resp=True),

            

Reported by Pylint.

              import urwid

from mitmproxy.test import tflow
from mitmproxy.tools.console import common


def test_format_flow():
    flows = [
        tflow.tflow(resp=True),

            

Reported by Pylint.

              from mitmproxy.tools.console import common


def test_format_flow():
    flows = [
        tflow.tflow(resp=True),
        tflow.tflow(err=True),
        tflow.ttcpflow(),
        tflow.ttcpflow(err=True),

            

Reported by Pylint.

                      tflow.ttcpflow(),
        tflow.ttcpflow(err=True),
    ]
    for f in flows:
        for render_mode in common.RenderMode:
            assert common.format_flow(f, render_mode=render_mode)
            assert common.format_flow(f, render_mode=render_mode, hostheader=True, focused=False)



            

Reported by Pylint.

                  ]
    for f in flows:
        for render_mode in common.RenderMode:
            assert common.format_flow(f, render_mode=render_mode)
            assert common.format_flow(f, render_mode=render_mode, hostheader=True, focused=False)


def test_format_keyvals():
    assert common.format_keyvals(

            

Reported by Bandit.

                  for f in flows:
        for render_mode in common.RenderMode:
            assert common.format_flow(f, render_mode=render_mode)
            assert common.format_flow(f, render_mode=render_mode, hostheader=True, focused=False)


def test_format_keyvals():
    assert common.format_keyvals(
        [

            

Reported by Bandit.

                          assert common.format_flow(f, render_mode=render_mode, hostheader=True, focused=False)


def test_format_keyvals():
    assert common.format_keyvals(
        [
            ("aa", "bb"),
            ("cc", "dd"),
            ("ee", None),

            

Reported by Pylint.

              

def test_format_keyvals():
    assert common.format_keyvals(
        [
            ("aa", "bb"),
            ("cc", "dd"),
            ("ee", None),
        ]

            

Reported by Bandit.

                          common.format_keyvals([("foo", "bar")])
        )
    )
    assert wrapped.render((30,))
    assert common.format_keyvals(
        [
            ("aa", wrapped)
        ]
    )

            

Reported by Bandit.

                      )
    )
    assert wrapped.render((30,))
    assert common.format_keyvals(
        [
            ("aa", wrapped)
        ]
    )

            

Reported by Bandit.

              
from mitmproxy.contentviews import base
from mitmproxy.coretypes import multidict
from . import image_parser


def test_ico(h, f):
    if h.startswith(b"\x00\x00\x01\x00"):
        return "ico"

            

Reported by Pylint.

              from . import image_parser


def test_ico(h, f):
    if h.startswith(b"\x00\x00\x01\x00"):
        return "ico"


imghdr.tests.append(test_ico)

            

Reported by Pylint.

                          view_name = "Unknown Image"
        return view_name, base.format_dict(multidict.MultiDict(image_metadata))

    def render_priority(self, data: bytes, *, content_type: Optional[str] = None, **metadata) -> float:
        return float(bool(
            content_type
            and content_type.startswith("image/")
            and content_type != "image/svg+xml"
        ))

            

Reported by Pylint.

              import imghdr
from typing import Optional

from mitmproxy.contentviews import base
from mitmproxy.coretypes import multidict
from . import image_parser


def test_ico(h, f):

            

Reported by Pylint.

              from . import image_parser


def test_ico(h, f):
    if h.startswith(b"\x00\x00\x01\x00"):
        return "ico"


imghdr.tests.append(test_ico)

            

Reported by Pylint.

              from . import image_parser


def test_ico(h, f):
    if h.startswith(b"\x00\x00\x01\x00"):
        return "ico"


imghdr.tests.append(test_ico)

            

Reported by Pylint.

              from . import image_parser


def test_ico(h, f):
    if h.startswith(b"\x00\x00\x01\x00"):
        return "ico"


imghdr.tests.append(test_ico)

            

Reported by Pylint.

              from . import image_parser


def test_ico(h, f):
    if h.startswith(b"\x00\x00\x01\x00"):
        return "ico"


imghdr.tests.append(test_ico)

            

Reported by Pylint.

              imghdr.tests.append(test_ico)


class ViewImage(base.View):
    name = "Image"

    def __call__(self, data, **metadata):
        image_type = imghdr.what('', h=data)
        if image_type == 'png':

            

Reported by Pylint.

                          view_name = "Unknown Image"
        return view_name, base.format_dict(multidict.MultiDict(image_metadata))

    def render_priority(self, data: bytes, *, content_type: Optional[str] = None, **metadata) -> float:
        return float(bool(
            content_type
            and content_type.startswith("image/")
            and content_type != "image/svg+xml"
        ))

            

Reported by Pylint.

              import pytest

from mitmproxy import io
from mitmproxy import exceptions


@pytest.mark.parametrize("dumpfile, url, count", [
    ["dumpfile-011.mitm", "https://example.com/", 1],
    ["dumpfile-018.mitm", "https://www.example.com/", 1],

            

Reported by Pylint.

              import pytest

from mitmproxy import io
from mitmproxy import exceptions


@pytest.mark.parametrize("dumpfile, url, count", [
    ["dumpfile-011.mitm", "https://example.com/", 1],
    ["dumpfile-018.mitm", "https://www.example.com/", 1],

            

Reported by Pylint.

              import pytest

from mitmproxy import io
from mitmproxy import exceptions


@pytest.mark.parametrize("dumpfile, url, count", [
    ["dumpfile-011.mitm", "https://example.com/", 1],
    ["dumpfile-018.mitm", "https://www.example.com/", 1],

            

Reported by Pylint.

              import pytest

from mitmproxy import io
from mitmproxy import exceptions


@pytest.mark.parametrize("dumpfile, url, count", [
    ["dumpfile-011.mitm", "https://example.com/", 1],
    ["dumpfile-018.mitm", "https://www.example.com/", 1],

            

Reported by Pylint.

                  ["dumpfile-019.mitm", "https://webrv.rtb-seller.com/", 1],
    ["dumpfile-7-websocket.mitm", "https://echo.websocket.org/", 6],
    ["dumpfile-10.mitm", "https://example.com/", 1]
])
def test_load(tdata, dumpfile, url, count):
    with open(tdata.path("mitmproxy/data/" + dumpfile), "rb") as f:
        flow_reader = io.FlowReader(f)
        flows = list(flow_reader.stream())
        assert len(flows) == count

            

Reported by Pylint.

                  ["dumpfile-10.mitm", "https://example.com/", 1]
])
def test_load(tdata, dumpfile, url, count):
    with open(tdata.path("mitmproxy/data/" + dumpfile), "rb") as f:
        flow_reader = io.FlowReader(f)
        flows = list(flow_reader.stream())
        assert len(flows) == count
        assert flows[-1].request.url.startswith(url)


            

Reported by Pylint.

                  with open(tdata.path("mitmproxy/data/" + dumpfile), "rb") as f:
        flow_reader = io.FlowReader(f)
        flows = list(flow_reader.stream())
        assert len(flows) == count
        assert flows[-1].request.url.startswith(url)


def test_cannot_convert(tdata):
    with open(tdata.path("mitmproxy/data/dumpfile-010.mitm"), "rb") as f:

            

Reported by Bandit.

                      flow_reader = io.FlowReader(f)
        flows = list(flow_reader.stream())
        assert len(flows) == count
        assert flows[-1].request.url.startswith(url)


def test_cannot_convert(tdata):
    with open(tdata.path("mitmproxy/data/dumpfile-010.mitm"), "rb") as f:
        flow_reader = io.FlowReader(f)

            

Reported by Bandit.

                      assert flows[-1].request.url.startswith(url)


def test_cannot_convert(tdata):
    with open(tdata.path("mitmproxy/data/dumpfile-010.mitm"), "rb") as f:
        flow_reader = io.FlowReader(f)
        with pytest.raises(exceptions.FlowReadException):
            list(flow_reader.stream())

            

Reported by Pylint.

              

def test_cannot_convert(tdata):
    with open(tdata.path("mitmproxy/data/dumpfile-010.mitm"), "rb") as f:
        flow_reader = io.FlowReader(f)
        with pytest.raises(exceptions.FlowReadException):
            list(flow_reader.stream())

            

Reported by Pylint.

              import asyncio

import pytest

from mitmproxy.utils import asyncio_utils


async def ttask():
    asyncio_utils.set_task_debug_info(

            

Reported by Pylint.

              import asyncio

import pytest

from mitmproxy.utils import asyncio_utils


async def ttask():
    asyncio_utils.set_task_debug_info(

            

Reported by Pylint.

              from mitmproxy.utils import asyncio_utils


async def ttask():
    asyncio_utils.set_task_debug_info(
        asyncio.current_task(),
        name="newname",
    )
    await asyncio.sleep(999)

            

Reported by Pylint.

              

@pytest.mark.asyncio
async def test_simple():
    task = asyncio_utils.create_task(
        ttask(),
        name="ttask",
        client=("127.0.0.1", 42313)
    )

            

Reported by Pylint.

                      name="ttask",
        client=("127.0.0.1", 42313)
    )
    assert asyncio_utils.task_repr(task) == "127.0.0.1:42313: ttask (age: 0s)"
    await asyncio.sleep(0)
    assert "newname" in asyncio_utils.task_repr(task)
    asyncio_utils.cancel_task(task, "bye")
    await asyncio.sleep(0)
    assert task.cancelled()

            

Reported by Bandit.

                  )
    assert asyncio_utils.task_repr(task) == "127.0.0.1:42313: ttask (age: 0s)"
    await asyncio.sleep(0)
    assert "newname" in asyncio_utils.task_repr(task)
    asyncio_utils.cancel_task(task, "bye")
    await asyncio.sleep(0)
    assert task.cancelled()



            

Reported by Bandit.

                  assert "newname" in asyncio_utils.task_repr(task)
    asyncio_utils.cancel_task(task, "bye")
    await asyncio.sleep(0)
    assert task.cancelled()


def test_closed_loop():
    # Crude test for line coverage.
    # This should eventually go, see the description in asyncio_utils.create_task for details.

            

Reported by Bandit.

                  assert task.cancelled()


def test_closed_loop():
    # Crude test for line coverage.
    # This should eventually go, see the description in asyncio_utils.create_task for details.
    asyncio_utils.create_task(
        ttask(),
        name="ttask",

            

Reported by Pylint.

                      ttask(),
        name="ttask",
    )
    t = ttask()
    with pytest.raises(RuntimeError):
        asyncio_utils.create_task(
            t,
            name="ttask",
            ignore_closed_loop=False,

            

Reported by Pylint.

                          name="ttask",
            ignore_closed_loop=False,
        )
    t.close()  # suppress "not awaited" warning
            

Reported by Pylint.

              from unittest import mock
import pytest

from mitmproxy.addons import browser
from mitmproxy.test import taddons


@pytest.mark.asyncio
async def test_browser():

            

Reported by Pylint.

              from unittest import mock
import pytest

from mitmproxy.addons import browser
from mitmproxy.test import taddons


@pytest.mark.asyncio
async def test_browser():

            

Reported by Pylint.

              

@pytest.mark.asyncio
async def test_browser():
    with mock.patch("subprocess.Popen") as po, mock.patch("shutil.which") as which:
        which.return_value = "chrome"
        b = browser.Browser()
        with taddons.context() as tctx:
            b.start()

            

Reported by Pylint.

              
@pytest.mark.asyncio
async def test_browser():
    with mock.patch("subprocess.Popen") as po, mock.patch("shutil.which") as which:
        which.return_value = "chrome"
        b = browser.Browser()
        with taddons.context() as tctx:
            b.start()
            assert po.called

            

Reported by Pylint.

              async def test_browser():
    with mock.patch("subprocess.Popen") as po, mock.patch("shutil.which") as which:
        which.return_value = "chrome"
        b = browser.Browser()
        with taddons.context() as tctx:
            b.start()
            assert po.called

            b.start()

            

Reported by Pylint.

                      b = browser.Browser()
        with taddons.context() as tctx:
            b.start()
            assert po.called

            b.start()
            await tctx.master.await_log("Starting additional browser")
            assert len(b.browser) == 2
            b.done()

            

Reported by Bandit.

              
            b.start()
            await tctx.master.await_log("Starting additional browser")
            assert len(b.browser) == 2
            b.done()
            assert not b.browser


@pytest.mark.asyncio

            

Reported by Bandit.

                          await tctx.master.await_log("Starting additional browser")
            assert len(b.browser) == 2
            b.done()
            assert not b.browser


@pytest.mark.asyncio
async def test_no_browser():
    with mock.patch("shutil.which") as which:

            

Reported by Bandit.

              

@pytest.mark.asyncio
async def test_no_browser():
    with mock.patch("shutil.which") as which:
        which.return_value = False

        b = browser.Browser()
        with taddons.context() as tctx:

            

Reported by Pylint.

                  with mock.patch("shutil.which") as which:
        which.return_value = False

        b = browser.Browser()
        with taddons.context() as tctx:
            b.start()
            await tctx.master.await_log("platform is not supported")

            

Reported by Pylint.