[FEATURE] Implement Open Telemetry

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "currency-quote"
-version = "4.0.2"
+version = "5.0.0"
 description = "Complete solution for extracting currency pair quotes data. With comprehensive testing, parameter validation, flexible configuration management, Hexagonal Architecture, CI/CD pipelines, code quality tools, and detailed documentation."
 authors = ["IvanildoBarauna <[email protected]>"]
 readme = "README.md"
@@ -29,8 +29,9 @@ include = ["currency_quote*"]
 
 [tool.poetry.dependencies]
 python = "^3.9"
-api-to-dataframe = "^1.3.12"
 pytest = "^8.3.4"
+api-to-dataframe = "^1.4.0"
+otel-wrapper = "^0.0.1"
 
 [tool.poetry.group.dev.dependencies]
 coverage = "^7.5.4"

src/currency_quote/domain/services/get_currency_quote.py

@@ -6,6 +6,7 @@
     ValidateCurrencyUseCase,
 )
 from currency_quote.domain.entities.currency import CurrencyQuote, CurrencyObject
+from currency_quote.utils.open_observability import increment_metric
 
 
 class GetCurrencyQuoteService:
@@ -15,16 +16,19 @@ def __init__(
         self.currency = currency
         self.currency_repository = currency_repository
 
+    @increment_metric
     def last(self) -> List[CurrencyQuote]:
         valid_currency = self.validate_currency_code()
         last_quote = self.currency_repository(valid_currency).get_last_quote()
         return last_quote
 
+    @increment_metric
     def history(self, reference_date: int) -> List[CurrencyQuote]:
         return self.currency_repository(
             self.validate_currency_code()
         ).get_history_quote(reference_date=reference_date)
 
+    @increment_metric
     def validate_currency_code(self) -> CurrencyObject:
         currency_valid_obj = ValidateCurrencyUseCase.execute(self.currency)
         return currency_valid_obj

src/currency_quote/utils/open_observability.py

@@ -0,0 +1,10 @@
+from otel_wrapper import OpenObservability
+
+metrics_wrapper = OpenObservability(application_name="currency-quote").get_wrapper().metrics()
+
+
+def increment_metric(func):
+    def inner(*args, **kwargs):
+        metrics_wrapper.metric_increment(func.__qualname__, value=1, tags=kwargs)
+        return func(*args, **kwargs)
+    return inner