init

Author: asd

CONTRIBUTING.md

@@ -0,0 +1,61 @@
+# Contribution guidelines
+
+Contributing to this project should be as easy and transparent as possible, whether it's:
+
+- Reporting a bug
+- Discussing the current state of the code
+- Submitting a fix
+- Proposing new features
+
+## Github is used for everything
+
+Github is used to host code, to track issues and feature requests, as well as accept pull requests.
+
+Pull requests are the best way to propose changes to the codebase.
+
+1. Fork the repo and create your branch from `main`.
+2. If you've changed something, update the documentation.
+3. Make sure your code lints (using `scripts/lint`).
+4. Test you contribution.
+5. Issue that pull request!
+
+## Any contributions you make will be under the MIT Software License
+
+In short, when you submit code changes, your submissions are understood to be under the same [MIT License](http://choosealicense.com/licenses/mit/) that covers the project. Feel free to contact the maintainers if that's a concern.
+
+## Report bugs using Github's [issues](../../issues)
+
+GitHub issues are used to track public bugs.
+Report a bug by [opening a new issue](../../issues/new/choose); it's that easy!
+
+## Write bug reports with detail, background, and sample code
+
+**Great Bug Reports** tend to have:
+
+- A quick summary and/or background
+- Steps to reproduce
+  - Be specific!
+  - Give sample code if you can.
+- What you expected would happen
+- What actually happens
+- Notes (possibly including why you think this might be happening, or stuff you tried that didn't work)
+
+People *love* thorough bug reports. I'm not even kidding.
+
+## Use a Consistent Coding Style
+
+Use [black](https://github.com/ambv/black) to make sure the code follows the style.
+
+## Test your code modification
+
+This custom component is based on [integration_blueprint template](https://github.com/ludeeus/integration_blueprint).
+
+It comes with development environment in a container, easy to launch
+if you use Visual Studio Code. With this container you will have a stand alone
+Home Assistant instance running and already configured with the included
+[`configuration.yaml`](./config/configuration.yaml)
+file.
+
+## License
+
+By contributing, you agree that your contributions will be licensed under its MIT License.

LICENSE.txt

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2019 - 2024  Joakim Sørensen @ludeeus
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,32 @@
+
+[![License][license-shield]](LICENSE)
+![Project Maintenance][maintenance-shield]
+
+# Instagram followers Integration for Home Assistant
+
+
+_Integration to integrate with [integration_blueprint][integration_blueprint]._
+
+**This integration will set up the following platforms.**
+
+Platform | Description
+-- | --
+`sensor` | Show how many subscribers given instagram user has.
+
+## Installation
+
+1. Add this repository URL as a custom repository in HACS
+2. Restart Home Assistant
+3. In the HA UI go to "Settings" -> "Devices & services" click "+ ADD INTEGRATION" and search for "Insta Follower"*
+
+## Configuration is done in the UI
+
+<!---->
+
+
+
+***
+
+[integration_blueprint]: https://github.com/ludeeus/integration_blueprint
+[license-shield]: https://img.shields.io/github/license/ludeeus/integration_blueprint.svg?style=for-the-badge
+[maintenance-shield]: https://img.shields.io/badge/maintainer-xamrex-blue.svg?style=for-the-badge

custom_components/insta_follower/__init__.py

@@ -0,0 +1,65 @@
+from __future__ import annotations
+
+from typing import TYPE_CHECKING
+
+from homeassistant.const import CONF_PASSWORD, CONF_USERNAME, Platform
+from homeassistant.helpers.aiohttp_client import async_get_clientsession
+from homeassistant.loader import async_get_loaded_integration
+
+from .api import IntegrationInstaApiClient
+from .coordinator import InstaDataUpdateCoordinator
+from .data import IntegrationInstaData
+
+if TYPE_CHECKING:
+    from homeassistant.core import HomeAssistant
+
+    from .data import IntegrationInstaConfigEntry
+
+PLATFORMS: list[Platform] = [
+    Platform.SENSOR,
+]
+
+
+# https://developers.home-assistant.io/docs/config_entries_index/#setting-up-an-entry
+async def async_setup_entry(
+    hass: HomeAssistant,
+    entry: IntegrationInstaConfigEntry,
+) -> bool:
+    """Set up this integration using UI."""
+    coordinator = InstaDataUpdateCoordinator(
+        hass=hass,
+    )
+    entry.runtime_data = IntegrationInstaData(
+        client=IntegrationInstaApiClient(
+            username=entry.data[CONF_USERNAME],
+            password=entry.data[CONF_PASSWORD],
+            session=async_get_clientsession(hass),
+        ),
+        integration=async_get_loaded_integration(hass, entry.domain),
+        coordinator=coordinator,
+    )
+
+    # https://developers.home-assistant.io/docs/integration_fetching_data#coordinated-single-api-poll-for-data-for-all-entities
+    await coordinator.async_config_entry_first_refresh()
+
+    await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)
+    entry.async_on_unload(entry.add_update_listener(async_reload_entry))
+
+    return True
+
+
+async def async_unload_entry(
+    hass: HomeAssistant,
+    entry: IntegrationInstaConfigEntry,
+) -> bool:
+    """Handle removal of an entry."""
+    return await hass.config_entries.async_unload_platforms(entry, PLATFORMS)
+
+
+async def async_reload_entry(
+    hass: HomeAssistant,
+    entry: IntegrationInstaConfigEntry,
+) -> None:
+    """Reload config entry."""
+    await async_unload_entry(hass, entry)
+    await async_setup_entry(hass, entry)

custom_components/insta_follower/api.py

@@ -0,0 +1,133 @@
+import logging
+import socket
+from typing import Any
+
+import aiohttp
+import async_timeout
+
+# Konfiguracja logowania
+_LOGGER = logging.getLogger(__name__)
+
+class IntegrationInstaApiClientError(Exception):
+    """Exception to indicate a general API error."""
+
+
+class IntegrationInstaApiClientCommunicationError(
+    IntegrationInstaApiClientError,
+):
+    """Exception to indicate a communication error."""
+
+
+class IntegrationInstaApiClientAuthenticationError(
+    IntegrationInstaApiClientError,
+):
+    """Exception to indicate an authentication error."""
+
+
+def _verify_response_or_raise(response: aiohttp.ClientResponse) -> None:
+    """Verify that the response is valid."""
+    if response.status in (401, 403):
+        msg = "Invalid credentials"
+        _LOGGER.error("Authentication failed: %s", msg)  # Log error
+        raise IntegrationInstaApiClientAuthenticationError(
+            msg,
+        )
+    response.raise_for_status()
+
+
+class IntegrationInstaApiClient:
+    """Sample API Client."""
+
+    def __init__(
+        self,
+        username: str,
+        password: str,
+        session: aiohttp.ClientSession,
+    ) -> None:
+        """Sample API Client."""
+        self._username = username
+        self._password = password
+        self._session = session
+        _LOGGER.info("API Client initialized for user: %s", username)  # Log
+
+    async def async_get_data(self) -> Any:
+        """Get data from the API."""
+        _LOGGER.info("Fetching data from the API...")  # Logowanie try get data
+        return await self._api_wrapper(
+            method="get",
+            url="https://jsonplaceholder.typicode.com/posts/1",
+        )
+
+    async def async_set_title(self, value: str) -> Any: # NOT USED
+        """Set title in the API."""
+        _LOGGER.info("Setting new title: %s", value)  
+        return await self._api_wrapper(
+            method="patch",
+            url="https://jsonplaceholder.typicode.com/posts/1",
+            data={"title": value},
+            headers={"Content-type": "application/json; charset=UTF-8"},
+        )
+        
+    async def async_get_followers(self) -> Any:
+        """Get number of followers from Instagram."""
+        _LOGGER.info("Fetching followers for user: %s", self._username)
+        url = f"https://instagram-scraper-api2.p.rapidapi.com/v1/info?username_or_id_or_url={self._username}"
+
+        headers = {
+            'x-rapidapi-key': self._password,
+            'x-rapidapi-host': "instagram-scraper-api2.p.rapidapi.com"
+        }
+
+        # Call API method
+        response_data = await self._api_wrapper(
+            method="get",
+            url=url,
+            headers=headers,
+        )
+
+        # Get numbers
+        follower_count = response_data["data"]["follower_count"]
+        _LOGGER.info("User %s has %d followers", self._username, follower_count)
+        return response_data        
+
+    async def _api_wrapper(
+        self,
+        method: str,
+        url: str,
+        data: dict | None = None,
+        headers: dict | None = None,
+    ) -> Any:
+        """Get information from the API."""
+        try:
+            _LOGGER.info("Making %s request to %s", method.upper(), url)  # Log request
+            async with async_timeout.timeout(10):
+                response = await self._session.request(
+                    method=method,
+                    url=url,
+                    headers=headers,
+                    json=data,
+                )
+                _verify_response_or_raise(response)
+                _LOGGER.info("Received response: %s", response.status)  # Log answer
+                response_data = await response.json()
+                _LOGGER.info("Received response: %s", response_data)  # Log whole answer
+                return response_data
+
+        except TimeoutError as exception:
+            msg = f"Timeout error fetching information - {exception}"
+            _LOGGER.error(msg)  
+            raise IntegrationInstaApiClientCommunicationError(
+                msg,
+            ) from exception
+        except (aiohttp.ClientError, socket.gaierror) as exception:
+            msg = f"Error fetching information - {exception}"
+            _LOGGER.error(msg)  
+            raise IntegrationInstaApiClientCommunicationError(
+                msg,
+            ) from exception
+        except Exception as exception:  # pylint: disable=broad-except
+            msg = f"Something really wrong happened! - {exception}"
+            _LOGGER.error(msg)  
+            raise IntegrationInstaApiClientError(
+                msg,
+            ) from exception