Compare commits

...

2 Commits

Author SHA1 Message Date
zacharyhampton
fefacdd264 Version bump to 0.8.8
🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
2025-12-14 17:32:06 -08:00
Zachary Hampton
3579c10196 Merge pull request #147 from ZacharyHampton/feature/ios-mobile-headers
Improve API stability and reliability
2025-12-05 19:30:25 -08:00
4 changed files with 261 additions and 36 deletions

View File

@@ -91,6 +91,8 @@ class Scraper:
'X-APOLLO-OPERATION-TYPE': 'query', 'X-APOLLO-OPERATION-TYPE': 'query',
'rdc-client-name': 'RDC_NATIVE_MOBILE-iPhone-com.move.Realtor', 'rdc-client-name': 'RDC_NATIVE_MOBILE-iPhone-com.move.Realtor',
'apollographql-client-name': 'com.move.Realtor-apollo-ios', 'apollographql-client-name': 'com.move.Realtor-apollo-ios',
'newrelic': '',
'transparent': '',
'User-Agent': 'Realtor.com/26.9.25.0774600 CFNetwork/3860.200.71 Darwin/25.1.0', 'User-Agent': 'Realtor.com/26.9.25.0774600 CFNetwork/3860.200.71 Darwin/25.1.0',
} }
) )

View File

@@ -26,7 +26,7 @@ from ..models import (
ListingType, ListingType,
ReturnType ReturnType
) )
from .queries import GENERAL_RESULTS_QUERY, SEARCH_HOMES_DATA, HOMES_DATA, HOME_FRAGMENT from .queries import GENERAL_RESULTS_QUERY, SEARCH_HOMES_DATA, HOMES_DATA, HOME_FRAGMENT, SEARCH_RESULTS_FRAGMENT
from .processors import ( from .processors import (
process_property, process_property,
process_extra_property_details, process_extra_property_details,
@@ -72,9 +72,8 @@ class RealtorScraper(Scraper):
stop=stop_after_attempt(3), stop=stop_after_attempt(3),
) )
def handle_location(self): def handle_location(self):
query = """query SearchSuggestions($searchInput: SearchSuggestionsInput!) { query = """
search_suggestions(search_input: $searchInput) { fragment SuggestionFragment on SearchSuggestionGeoResult {
geo_results {
type type
text text
geo { geo {
@@ -89,6 +88,11 @@ class RealtorScraper(Scraper):
geo_id geo_id
} }
} }
query SearchSuggestions($searchInput: SearchSuggestionsInput!) {
search_suggestions(search_input: $searchInput) {
geo_results {
...SuggestionFragment
}
} }
}""" }"""
@@ -137,12 +141,16 @@ class RealtorScraper(Scraper):
return result return result
def get_latest_listing_id(self, property_id: str) -> str | None: def get_latest_listing_id(self, property_id: str) -> str | None:
query = """query GetPropertyListingId($property_id: ID!) { query = """
property(id: $property_id) { fragment ListingFragment on Listing {
listings {
listing_id listing_id
primary primary
} }
query GetPropertyListingId($property_id: ID!) {
property(id: $property_id) {
listings {
...ListingFragment
}
} }
} }
""" """
@@ -166,10 +174,13 @@ class RealtorScraper(Scraper):
def handle_home(self, property_id: str) -> list[Property]: def handle_home(self, property_id: str) -> list[Property]:
"""Fetch single home with proper error handling.""" """Fetch single home with proper error handling."""
query = ( query = (
"""query GetHomeDetails($property_id: ID!) { """%s
home(property_id: $property_id) %s query GetHomeDetails($property_id: ID!) {
home(property_id: $property_id) {
...HomeDetailsFragment
}
}""" }"""
% HOMES_DATA % HOME_FRAGMENT
) )
variables = {"property_id": property_id} variables = {"property_id": property_id}
@@ -394,12 +405,13 @@ class RealtorScraper(Scraper):
is_foreclosure = "foreclosure: false" is_foreclosure = "foreclosure: false"
if search_type == "comps": #: comps search, came from an address if search_type == "comps": #: comps search, came from an address
query = """query GetHomeSearch( query = """%s
query GetHomeSearch(
$coordinates: [Float]! $coordinates: [Float]!
$radius: String! $radius: String!
$offset: Int!, $offset: Int!,
) { ) {
home_search( homeSearch: home_search(
query: { query: {
%s %s
nearby: { nearby: {
@@ -417,6 +429,7 @@ class RealtorScraper(Scraper):
offset: $offset offset: $offset
) %s ) %s
}""" % ( }""" % (
SEARCH_RESULTS_FRAGMENT,
is_foreclosure, is_foreclosure,
status_param, status_param,
date_param, date_param,
@@ -427,11 +440,12 @@ class RealtorScraper(Scraper):
GENERAL_RESULTS_QUERY, GENERAL_RESULTS_QUERY,
) )
elif search_type == "area": #: general search, came from a general location elif search_type == "area": #: general search, came from a general location
query = """query GetHomeSearch( query = """%s
query GetHomeSearch(
$search_location: SearchLocation, $search_location: SearchLocation,
$offset: Int, $offset: Int,
) { ) {
home_search( homeSearch: home_search(
query: { query: {
%s %s
search_location: $search_location search_location: $search_location
@@ -447,6 +461,7 @@ class RealtorScraper(Scraper):
offset: $offset offset: $offset
) %s ) %s
}""" % ( }""" % (
SEARCH_RESULTS_FRAGMENT,
is_foreclosure, is_foreclosure,
status_param, status_param,
date_param, date_param,
@@ -459,11 +474,12 @@ class RealtorScraper(Scraper):
) )
else: #: general search, came from an address else: #: general search, came from an address
query = ( query = (
"""query GetHomeSearch( """%s
query GetHomeSearch(
$property_id: [ID]! $property_id: [ID]!
$offset: Int!, $offset: Int!,
) { ) {
home_search( homeSearch: home_search(
query: { query: {
property_id: $property_id property_id: $property_id
} }
@@ -471,11 +487,11 @@ class RealtorScraper(Scraper):
offset: $offset offset: $offset
) %s ) %s
}""" }"""
% GENERAL_RESULTS_QUERY % (SEARCH_RESULTS_FRAGMENT, GENERAL_RESULTS_QUERY)
) )
response_json = self._graphql_post(query, variables, "GetHomeSearch") response_json = self._graphql_post(query, variables, "GetHomeSearch")
search_key = "home_search" if "home_search" in query else "property_search" search_key = "homeSearch"
properties: list[Union[Property, dict]] = [] properties: list[Union[Property, dict]] = []
@@ -1109,18 +1125,17 @@ class RealtorScraper(Scraper):
property_ids = list(set(property_ids)) property_ids = list(set(property_ids))
# Construct the bulk query
fragments = "\n".join( fragments = "\n".join(
f'home_{property_id}: home(property_id: {property_id}) {{ ...HomeData }}' f'home_{property_id}: home(property_id: {property_id}) {{ ...HomeDetailsFragment }}'
for property_id in property_ids for property_id in property_ids
) )
query = f"""{HOME_FRAGMENT} query = f"""{HOME_FRAGMENT}
query GetBulkPropertyDetails {{ query GetHomeDetails {{
{fragments} {fragments}
}}""" }}"""
data = self._graphql_post(query, {}, "GetBulkPropertyDetails") data = self._graphql_post(query, {}, "GetHomeDetails")
if "data" not in data: if "data" not in data:
# If we got a 400 error with "Required parameter is missing", raise to trigger retry # If we got a 400 error with "Required parameter is missing", raise to trigger retry

View File

@@ -1,3 +1,200 @@
SEARCH_RESULTS_FRAGMENT = """
fragment SearchFragment on SearchHome {
__typename
pending_date
listing_id
property_id
href
permalink
list_date
status
mls_status
last_sold_price
last_sold_date
last_status_change_date
last_update_date
list_price
list_price_max
list_price_min
price_per_sqft
tags
open_houses {
start_date
end_date
description
time_zone
dst
href
methods
}
details {
category
text
parent_category
}
pet_policy {
cats
dogs
dogs_small
dogs_large
__typename
}
units {
availability {
date
__typename
}
description {
baths_consolidated
baths
beds
sqft
__typename
}
photos(https: true) {
title
href
tags {
label
}
}
list_price
__typename
}
flags {
is_contingent
is_pending
is_new_construction
}
description {
type
sqft
beds
baths_full
baths_half
lot_sqft
year_built
garage
type
name
stories
text
}
source {
id
listing_id
}
hoa {
fee
}
location {
address {
street_direction
street_number
street_name
street_suffix
line
unit
city
state_code
postal_code
coordinate {
lon
lat
}
}
county {
name
fips_code
}
neighborhoods {
name
}
}
tax_record {
cl_id
public_record_id
last_update_date
apn
tax_parcel_id
}
primary_photo(https: true) {
href
}
photos(https: true) {
title
href
tags {
label
}
}
advertisers {
email
broker {
name
fulfillment_id
}
type
name
fulfillment_id
builder {
name
fulfillment_id
}
phones {
ext
primary
type
number
}
office {
name
email
fulfillment_id
href
phones {
number
type
primary
ext
}
mls_set
}
corporation {
specialties
name
bio
href
fulfillment_id
}
mls_set
nrds_id
state_license
rental_corporation {
fulfillment_id
}
rental_management {
name
href
fulfillment_id
}
}
current_estimates {
__typename
source {
__typename
type
name
}
estimate
estimateHigh: estimate_high
estimateLow: estimate_low
date
isBestHomeValue: isbest_homevalue
}
}
"""
_SEARCH_HOMES_DATA_BASE = """{ _SEARCH_HOMES_DATA_BASE = """{
pending_date pending_date
listing_id listing_id
@@ -181,7 +378,7 @@ _SEARCH_HOMES_DATA_BASE = """{
HOME_FRAGMENT = """ HOME_FRAGMENT = """
fragment HomeData on Home { fragment HomeDetailsFragment on Home {
property_id property_id
nearbySchools: nearby_schools(radius: 5.0, limit_per_level: 3) { nearbySchools: nearby_schools(radius: 5.0, limit_per_level: 3) {
__typename schools { district { __typename id name } } __typename schools { district { __typename id name } }
@@ -300,8 +497,19 @@ current_estimates {
} }
}""" % _SEARCH_HOMES_DATA_BASE }""" % _SEARCH_HOMES_DATA_BASE
GENERAL_RESULTS_QUERY = """{ # Query body using inline fields (kept for backward compatibility)
GENERAL_RESULTS_QUERY_BODY = """{
count count
total total
results %s results %s
}""" % SEARCH_HOMES_DATA }""" % SEARCH_HOMES_DATA
GENERAL_RESULTS_QUERY = """{
__typename
count
total
results {
__typename
...SearchFragment
}
}"""

View File

@@ -1,6 +1,6 @@
[tool.poetry] [tool.poetry]
name = "homeharvest" name = "homeharvest"
version = "0.8.7" version = "0.8.8"
description = "Real estate scraping library" description = "Real estate scraping library"
authors = ["Zachary Hampton <zachary@bunsly.com>", "Cullen Watson <cullen@bunsly.com>"] authors = ["Zachary Hampton <zachary@bunsly.com>", "Cullen Watson <cullen@bunsly.com>"]
homepage = "https://github.com/ZacharyHampton/HomeHarvest" homepage = "https://github.com/ZacharyHampton/HomeHarvest"