|
1 |
| -from typing import List, Optional, Literal |
| 1 | +from typing import List, Literal, Optional |
2 | 2 |
|
3 |
| -from .base import BaseAPI |
4 | 3 | from ..models.property import Property, PropertyValuesData
|
5 | 4 | from ..models.search_query import SearchQuery
|
6 | 5 | from ..models.transaction import Transaction
|
| 6 | +from .base import BaseAPI |
7 | 7 |
|
8 | 8 |
|
9 | 9 | class PropertiesAPI(BaseAPI):
|
10 | 10 | """API for managing properties in RushDB."""
|
11 |
| - def find(self, query: Optional[SearchQuery] = None, transaction: Optional[Transaction] = None) -> List[Property]: |
| 11 | + |
| 12 | + def find( |
| 13 | + self, |
| 14 | + query: Optional[SearchQuery] = None, |
| 15 | + transaction: Optional[Transaction] = None, |
| 16 | + ) -> List[Property]: |
12 | 17 | """List all properties."""
|
13 |
| - headers = Transaction._build_transaction_header(transaction.id if transaction else None) |
| 18 | + headers = Transaction._build_transaction_header( |
| 19 | + transaction.id if transaction else None |
| 20 | + ) |
14 | 21 |
|
15 |
| - return self.client._make_request('POST', '/api/v1/properties', query or {}, headers) |
| 22 | + return self.client._make_request( |
| 23 | + "POST", "/api/v1/properties", query or {}, headers |
| 24 | + ) |
16 | 25 |
|
17 |
| - def find_by_id(self, property_id: str, transaction: Optional[Transaction] = None) -> Property: |
| 26 | + def find_by_id( |
| 27 | + self, property_id: str, transaction: Optional[Transaction] = None |
| 28 | + ) -> Property: |
18 | 29 | """Get a property by ID."""
|
19 |
| - headers = Transaction._build_transaction_header(transaction.id if transaction else None) |
| 30 | + headers = Transaction._build_transaction_header( |
| 31 | + transaction.id if transaction else None |
| 32 | + ) |
20 | 33 |
|
21 |
| - return self.client._make_request('GET', f'/api/v1/properties/{property_id}', headers=headers) |
| 34 | + return self.client._make_request( |
| 35 | + "GET", f"/api/v1/properties/{property_id}", headers=headers |
| 36 | + ) |
22 | 37 |
|
23 |
| - def delete(self, property_id: str, transaction: Optional[Transaction] = None) -> None: |
| 38 | + def delete( |
| 39 | + self, property_id: str, transaction: Optional[Transaction] = None |
| 40 | + ) -> None: |
24 | 41 | """Delete a property."""
|
25 |
| - headers = Transaction._build_transaction_header(transaction.id if transaction else None) |
| 42 | + headers = Transaction._build_transaction_header( |
| 43 | + transaction.id if transaction else None |
| 44 | + ) |
26 | 45 |
|
27 |
| - return self.client._make_request('DELETE', f'/api/v1/properties/{property_id}', headers=headers) |
| 46 | + return self.client._make_request( |
| 47 | + "DELETE", f"/api/v1/properties/{property_id}", headers=headers |
| 48 | + ) |
28 | 49 |
|
29 |
| - def values(self, property_id: str, sort: Optional[Literal['asc', 'desc']], skip: Optional[int], limit: Optional[int], transaction: Optional[Transaction] = None) -> PropertyValuesData: |
| 50 | + def values( |
| 51 | + self, |
| 52 | + property_id: str, |
| 53 | + sort: Optional[Literal["asc", "desc"]], |
| 54 | + skip: Optional[int], |
| 55 | + limit: Optional[int], |
| 56 | + transaction: Optional[Transaction] = None, |
| 57 | + ) -> PropertyValuesData: |
30 | 58 | """Get values data for a property."""
|
31 |
| - headers = Transaction._build_transaction_header(transaction.id if transaction else None) |
| 59 | + headers = Transaction._build_transaction_header( |
| 60 | + transaction.id if transaction else None |
| 61 | + ) |
32 | 62 |
|
33 |
| - return self.client._make_request('GET', f'/api/v1/properties/{property_id}/values', headers=headers, params={ "sort": sort, "skip": skip, "limit": limit }) |
| 63 | + return self.client._make_request( |
| 64 | + "GET", |
| 65 | + f"/api/v1/properties/{property_id}/values", |
| 66 | + headers=headers, |
| 67 | + params={"sort": sort, "skip": skip, "limit": limit}, |
| 68 | + ) |
0 commit comments