Method start

src/wechaty/plugin.py:828–888

set wechaty to plugins

(self)

        return url

    async def start(self) -> None:
        """
        set wechaty to plugins
        """
        log.info('start the plugins ...')

        # 1. init the plugins
        for name, plugin in self._plugins.items():
            log.info('init %s-plugin ...', name)
            assert isinstance(plugin, WechatyPlugin)
            # set wechaty instance to all of the plugin bot attribute

            plugin.set_bot(self._wechaty)
            await plugin.init_plugin(self._wechaty)
            await plugin.blueprint(self.app)
        self.scheduler.start()
        # check the host & port configuration

        # pylint: disable=W0212
        host, port = self.endpoint[0], self.endpoint[1]
        if _check_local_port(port):
            raise WechatyPluginError(
                f'local port<{port}> is in use, can"t start plugin server. '
                'So please use the another valid port'
            )
        # 3. list all valid endpoints in web service
        # checking the number of registered blueprints
        routes_txt = _list_routes_txt(self.app)
        if len(routes_txt) == 0:
            log.warning(
                'there is not registed blueprint in the plugins, '
                'so bot will not start the web service'
            )
            return

        await self.register_ui_view(self.app)
        # re-fetch the routes info
        routes_txt = _list_routes_txt(self.app)

        log.info(
            '============================starting web service========================')
        log.info('starting web service at endpoint: <{%s}:{%d}>', host, port)

        shutdown_trigger = await get_shutdown_trigger()
        task = self.app.run_task(
            host=host,
            port=port,
            shutdown_trigger=shutdown_trigger
        )
        loop = asyncio.get_event_loop()
        loop.create_task(task)

        loop.create_task(
            shutdown(shutdown_trigger)
        )

        for route_txt in routes_txt:
            log.info(route_txt)