class TransactionsStream(JoryStream):
    """Transactions stream representing Jory Transactions."""

    name = "transactions"
    path = "/transactions"
    primary_keys = ["mid", "txn_id"]
    replication_key = "transaction_time"
    schema = PropertiesList(*TRANSACTION).to_dict()

    @property
    def partitions(self) -> List[Dict[str, int]]:
        """Return a list of partitions to be used by the stream.
        Each stream partition will correspond to a single Merchant ID (MID).
        """
        return [{"mid": mid} for mid in self.config["mids"]]

    def _request_date_range(self, start: datetime) -> Iterable[Tuple[datetime, datetime]]:
        """Return a generator of dates as determined by the start_date config value and current datetime."""
        now = pendulum.now("UTC")
        while start < now:
            end = min(start + timedelta(days=30), now)
            yield start, end
            start = end + timedelta(days=1)

    def get_records(self, context: Optional[dict]) -> Iterable[Dict[str, Any]]:
        """Return a generator of row-type dictionary objects.
        Each row emitted should be a dictionary of property names to their values.
        """
        context = context or {}
        starting_ts = self.get_starting_timestamp(context)
        if starting_ts is not None:
            for start, end in self._request_date_range(starting_ts):
                context.update({"start": start.strftime("%Y-%m-%d"), "end": end.strftime("%Y-%m-%d")})
                for row in self.request_records(context):
                    row = self.post_process(row, context)
                    yield row

    def get_url_params(self, context: Optional[dict], next_page_token: Optional[int]) -> Dict[str, Any]:
        """Override the RESTStream get_url_params method."""
        params = {}
        if context is not None:
            params["mid"] = context["mid"]
            params["startDate"] = context["start"]
            params["endDate"] = context["end"]
        return params

    def post_process(self, row: dict, context: Optional[dict] = None) -> dict:
        """Post-process each transaction record by enriching it with the corresponding Merchant ID."""
        if context is not None:
            row["mid"] = context["mid"]
        return row

JoryStream

get_starting_timestamp