diff --git a/custom_components/webastoconnect/__init__.py b/custom_components/webastoconnect/__init__.py
index a12c9e4..a0172d6 100644
--- a/custom_components/webastoconnect/__init__.py
+++ b/custom_components/webastoconnect/__init__.py
@@ -6,10 +6,10 @@
 from homeassistant.const import CONF_EMAIL, CONF_PASSWORD
 from homeassistant.core import HomeAssistant
 from homeassistant.loader import async_get_integration
+from pywebasto.exceptions import UnauthorizedException
 
 from .api import WebastoConnector, WebastoConnectUpdateCoordinator
 from .const import ATTR_COORDINATOR, DOMAIN, PLATFORMS, STARTUP
-from .pywebasto.exceptions import UnauthorizedException
 
 LOGGER = logging.getLogger(__name__)
 
diff --git a/custom_components/webastoconnect/api.py b/custom_components/webastoconnect/api.py
index fd9a38d..29dd225 100644
--- a/custom_components/webastoconnect/api.py
+++ b/custom_components/webastoconnect/api.py
@@ -7,9 +7,9 @@
 from homeassistant.const import CONF_EMAIL, CONF_PASSWORD
 from homeassistant.core import HomeAssistant
 from homeassistant.helpers.update_coordinator import DataUpdateCoordinator
+from pywebasto import WebastoConnect
 
 from .const import DOMAIN
-from .pywebasto import WebastoConnect
 
 SCAN_INTERVAL = timedelta(seconds=30)
 LOGGER = logging.getLogger(__name__)
diff --git a/custom_components/webastoconnect/base.py b/custom_components/webastoconnect/base.py
index f39f5b6..17dabb6 100644
--- a/custom_components/webastoconnect/base.py
+++ b/custom_components/webastoconnect/base.py
@@ -7,8 +7,7 @@
 from homeassistant.components.number import NumberEntityDescription
 from homeassistant.components.sensor import SensorEntityDescription
 from homeassistant.components.switch import SwitchEntityDescription
-
-from .pywebasto import WebastoConnect
+from pywebasto import WebastoConnect
 
 
 @dataclass
diff --git a/custom_components/webastoconnect/config_flow.py b/custom_components/webastoconnect/config_flow.py
index 0ad88d5..19260ee 100644
--- a/custom_components/webastoconnect/config_flow.py
+++ b/custom_components/webastoconnect/config_flow.py
@@ -2,12 +2,12 @@
 
 import logging
 from typing import Any
+
 import voluptuous as vol
 from homeassistant import config_entries
 from homeassistant.const import CONF_EMAIL, CONF_PASSWORD
-
-from .pywebasto.exceptions import UnauthorizedException
-from .pywebasto import WebastoConnect
+from pywebasto import WebastoConnect
+from pywebasto.exceptions import UnauthorizedException
 
 from .const import DOMAIN
 
diff --git a/custom_components/webastoconnect/manifest.json b/custom_components/webastoconnect/manifest.json
index 25c7e5e..b347d92 100644
--- a/custom_components/webastoconnect/manifest.json
+++ b/custom_components/webastoconnect/manifest.json
@@ -11,6 +11,8 @@
     "documentation": "https://github.com/MTrab/webastoconnect/blob/master/README.md",
     "iot_class": "cloud_polling",
     "issue_tracker": "https://github.com/MTrab/webastoconnect/issues",
-    "requirements": [],
+    "requirements": [
+        "pywebasto==0.1.0"
+    ],
     "version": "0.0.1b3"
 }
\ No newline at end of file
diff --git a/custom_components/webastoconnect/pywebasto/__init__.py b/custom_components/webastoconnect/pywebasto/__init__.py
deleted file mode 100644
index 8523c83..0000000
--- a/custom_components/webastoconnect/pywebasto/__init__.py
+++ /dev/null
@@ -1,330 +0,0 @@
-"""Module for interfacing with Webasto Connect."""
-
-from datetime import datetime
-import json
-import threading
-from typing import Any
-
-import requests
-
-from .consts import (
-    API_URL,
-    CMD_HEATER_OFF,
-    CMD_HEATER_ON,
-    CMD_VENTILATION_OFF,
-    CMD_VENTILATION_ON,
-)
-from .enums import Outputs, Request
-from .exceptions import InvalidRequestException, UnauthorizedException
-
-
-class WebastoConnect:
-    """Webasto Connect implementation."""
-
-    def __init__(self, username: str, password: str) -> None:
-        """Initialize the component."""
-        self.__initialized: bool = False
-
-        self._usn: str = username
-        self._pwd: str = password
-        self._hssess: str = None
-        self._authorized: bool = False
-        self._last_data = {}
-        self._dev_data = {}
-        self._settings = {}
-        self._mainOutput = {}
-        self._aux = {}
-
-        self._timeout_vent: int = 3600
-        self._timeout_heat: int = 3600
-
-        self._ventilation: bool = False
-        self._isCelcius: bool = False
-
-    def connect(self) -> None:
-        """Connect to the API."""
-        self._call(Request.LOGIN, {"username": self._usn, "password": self._pwd})
-        if self._authorized:
-            self.__initialized = True
-            self.update()
-        else:
-            raise UnauthorizedException("Username or password incorrect")
-
-    def assemble_headers(self) -> dict:
-        """Generate headers."""
-        _headers: dict = {"origin": "https://my.webastoconnect.com"}
-
-        if isinstance(self._hssess, type(None)):
-            # _headers.update(
-            #     {"Cookie": "__stripe_mid=70011fb4-8351-41c7-baad-047402d8cafed894b1;"}
-            # )
-            pass
-        else:
-            _headers.update({"Cookie": f"hssess={self._hssess};"})
-
-        return _headers
-
-    def _call(
-        self, api_type: Request, payload: dict | str | None = None
-    ) -> dict | None:
-        """Make an API request."""
-
-        if isinstance(payload, type(None)):
-            payload = {}
-
-        response = requests.request(
-            "POST",
-            f"{API_URL}{api_type.value}",
-            headers=self.assemble_headers(),
-            data=payload,
-            timeout=60,
-        )
-        # self._cookies = response.cookies
-        if isinstance(self._hssess, type(None)):
-            self._hssess = response.cookies["hssess"]
-
-        if response.status_code != 200:
-            if response.status_code == 401:
-                self._authorized = False
-                if self.__initialized:
-                    self.__initialized = False
-                    self._call(
-                        Request.LOGIN, {"username": self._usn, "password": self._pwd}
-                    )
-                    if self._authorized:
-                        self.__initialized = True
-                        self._call(api_type, payload)
-                    else:
-                        raise UnauthorizedException("Username or password incorrect")
-            elif response.status_code == 403:
-                retry = threading.Timer(30, self._call, [api_type, payload])
-                retry.start()
-            else:
-                raise InvalidRequestException(
-                    f"API reported {response.status_code}: {response.text}"
-                )
-        else:
-            self._authorized = True
-
-        if "GET" in api_type.name:
-            return response.json()
-
-    def update(self) -> None:
-        """Get current data from Webasto API."""
-        self._settings = self._call(Request.GET_SETTINGS)
-        self.__get_timeouts()
-        self._last_data = self._call(Request.GET_DATA)
-        self._dev_data = self._call(Request.GET_DATA_NOPOLL)
-
-        if self._last_data["temperature"][-1] == "C":
-            self._isCelcius = True
-
-        for output in self._last_data["outputs"]:
-            if output["line"] == "OUTH" or output["line"] == "OUTV":
-                self._mainOutput = output
-                if output["line"] == "OUTH":
-                    self._ventilation = False
-                else:
-                    self._ventilation = True
-            elif output["line"] == "OUTA":
-                self._aux = output
-
-    def set_output(self, state: bool) -> None:
-        """Turn on or off the heater or ventilation."""
-        if state:
-            if self._ventilation:
-                self._call(Request.COMMAND, CMD_VENTILATION_ON)
-            else:
-                self._call(Request.COMMAND, CMD_HEATER_ON)
-        else:
-            if self._ventilation:
-                self._call(Request.COMMAND, CMD_VENTILATION_OFF)
-            else:
-                self._call(Request.COMMAND, CMD_HEATER_OFF)
-        self.update()
-
-    def ventilation_mode(self, state: bool) -> None:
-        """Turn ventilation mode on or off."""
-        vent_sec = self._timeout_vent % (24 * 3600)
-        vent_h = vent_sec // 3600
-        vent_sec = vent_sec % 3600
-        vent_m = vent_sec // 60
-
-        heat_sec = self._timeout_heat % (24 * 3600)
-        heat_h = heat_sec // 3600
-        heat_sec = heat_sec % 3600
-        heat_m = heat_sec // 60
-
-        ventmode = {
-            "device_settings": {
-                "webasto_emul_mode": "thermoconnect",
-                "OUTV_timeout_on": True,
-                "OUTV_timeout_h": vent_h,
-                "OUTV_timeout_min": vent_m,
-                "OUTH_timeout_on": True,
-                "OUTH_timeout_h": heat_h,
-                "OUTH_timeout_min": heat_m,
-            },
-            "service_settings": {
-                "OUTH_on": True if not state else False,
-                "OUTV_on": False if not state else True,
-                "heater_mode": 0 if not state else 1,
-                "OUTV_name": "Ventilation",
-                "OUTV_icon": "car_vent",
-                "OUTH_name": "Heater",
-                "OUTH_icon": "car_heat",
-            },
-            "location_events": None,
-            "air_heater": {},
-        }
-
-        self._call(Request.POST_SETTING, json.dumps(ventmode))
-        self.update()
-
-    def set_timeout(
-        self,
-        heater: int | None = None,
-        ventilation: int | None = None,
-        aux: int | None = None,
-    ) -> None:
-        """Sets timeout of an output port in seconds."""
-        if not isinstance(heater, type(None)):
-            self._timeout_heat = heater
-
-        if not isinstance(ventilation, type(None)):
-            self._timeout_vent = ventilation
-
-        self.ventilation_mode(self._ventilation)
-
-    def set_low_voltage_cutoff(self, value: float) -> None:
-        """Set the low voltage cutoff value."""
-
-        payload = {
-            "device_settings": {"low_voltage_cutoff": value},
-            "service_settings": {},
-            "location_events": None,
-            "air_heater": {},
-        }
-        self._call(Request.POST_SETTING, json.dumps(payload))
-        self.update()
-
-    def set_temperature_compensation(self, value: float) -> None:
-        """Set the temperature compensation value."""
-
-        payload = {
-            "device_settings": {"ext_temp_comp": value},
-            "service_settings": {},
-            "location_events": None,
-            "air_heater": {},
-        }
-        self._call(Request.POST_SETTING, json.dumps(payload, indent=4))
-        self.update()
-
-    @property
-    def temperature(self) -> int:
-        """Returns the current temperature."""
-        return self._last_data["temperature"][: len(self._last_data["temperature"]) - 1]
-
-    @property
-    def voltage(self) -> float:
-        """Returns the current voltage."""
-        return self._last_data["voltage"][: len(self._last_data["voltage"]) - 1]
-
-    @property
-    def location(self) -> dict:
-        """Returns the current location."""
-        return (
-            self._last_data["location"]
-            if self._last_data["location"]["state"] == "ON"
-            else None
-        )
-
-    @property
-    def output(self) -> bool:
-        """Get the main output state."""
-        if self._mainOutput["state"] == "OFF":
-            return False
-        else:
-            return True
-
-    @property
-    def isVentilation(self) -> bool:
-        """Get the mode of the output channel."""
-        return self._ventilation
-
-    @property
-    def temperature_unit(self) -> bool:
-        """Get the temperature unit."""
-        return "°C" if self._isCelcius else "°F"
-
-    @property
-    def hardware_version(self) -> str:
-        """Get the hardware version."""
-        return self._settings["hw_version"]
-
-    @property
-    def software_version(self) -> str:
-        """Get the software version."""
-        return self._settings["sw_version"]
-
-    @property
-    def software_variant(self) -> str:
-        """Get the software variant."""
-        return self._settings["sw_variant"]
-
-    @property
-    def allow_location(self) -> str:
-        """Get the location setting."""
-        return self.__get_value("general", "allow_GPS")
-
-    @property
-    def low_voltage_cutoff(self) -> str:
-        """Get the low_voltage_cutoff setting."""
-        return self.__get_value("general", "low_voltage_cutoff")
-
-    @property
-    def temperature_compensation(self) -> str:
-        """Get the ext_temp_comp setting."""
-        return self.__get_value("general", "ext_temp_comp")
-
-    @property
-    def device_id(self) -> str:
-        """Get the ID of the device (QR code ID)"""
-        return self._dev_data["id"]
-
-    @property
-    def name(self) -> str:
-        """Get the name of the device."""
-        return self._dev_data["alias"]
-
-    @property
-    def output_name(self) -> str:
-        """Get the main output name."""
-        return self._mainOutput["name"]
-
-    @property
-    def subscription_expiration(self) -> datetime:
-        """Get subscription expiration."""
-        expiration = self._dev_data["subscription"]["expiration"]
-        return datetime.fromtimestamp(expiration)
-
-    def __get_value(self, group: str, key: str) -> Any:
-        """Get a value from the settings dict."""
-        for g in self._settings["settings_tab"]:
-            if g["group"] != group:
-                continue
-
-            for o in g["options"]:
-                if o["key"] == key:
-                    return o["value"]
-
-    def __get_timeouts(self) -> None:
-        for g in self._settings["settings_tab"]:
-            if g["group"] != "webasto":
-                continue
-
-            for o in g["options"]:
-                if o["key"] == "OUTH":
-                    self._timeout_heat = o["timeout"]
-                elif o["key"] == "OUTV":
-                    self._timeout_vent = o["timeout"]
diff --git a/custom_components/webastoconnect/pywebasto/consts.py b/custom_components/webastoconnect/pywebasto/consts.py
deleted file mode 100644
index 5babf5a..0000000
--- a/custom_components/webastoconnect/pywebasto/consts.py
+++ /dev/null
@@ -1,12 +0,0 @@
-"""Constants used for Webasto."""
-
-API_URL = "https://my.webastoconnect.com/webapi"
-
-CMD_HEATER_ON = "OUT H ON"
-CMD_HEATER_OFF = "OUT H OFF"
-
-CMD_VENTILATION_ON = "OUT V ON"
-CMD_VENTILATION_OFF = "OUT V OFF"
-
-CMD_AUX_ON = "OUT A ON"
-CMD_AUX_OFF = "OUT A OFF"
diff --git a/custom_components/webastoconnect/pywebasto/enums.py b/custom_components/webastoconnect/pywebasto/enums.py
deleted file mode 100644
index 7c857ae..0000000
--- a/custom_components/webastoconnect/pywebasto/enums.py
+++ /dev/null
@@ -1,21 +0,0 @@
-"""Enum classes."""
-from enum import Enum
-
-
-class Request(Enum):
-    """Requests options."""
-
-    LOGIN = "/login"
-    COMMAND = "/command"
-    GET_DATA = "/get_service_data?poll=true"
-    GET_DATA_NOPOLL = "/get_service_data?poll=false"
-    POST_SETTING = "/post_settings"
-    GET_SETTINGS = "/get_settings"
-
-
-class Outputs(Enum):
-    """Valid Webasto outputs."""
-
-    HEATER = "OUTH"
-    VENTILATION = "OUTV"
-    AUX = "OUTA"
diff --git a/custom_components/webastoconnect/pywebasto/exceptions.py b/custom_components/webastoconnect/pywebasto/exceptions.py
deleted file mode 100644
index b74abe7..0000000
--- a/custom_components/webastoconnect/pywebasto/exceptions.py
+++ /dev/null
@@ -1,9 +0,0 @@
-"""Exceptions used in this module."""
-
-
-class UnauthorizedException(Exception):
-    """User is unauthorized."""
-
-
-class InvalidRequestException(Exception):
-    """Something went wrong with the request."""