원문 수집과 제공 자료를 나누는 상품 후보 모듈

"""Independent synthetic intake decision. No fetch, parser, storage or publishing."""
FIELDS=('title','price_minor','shipping_minor','stock')
STATES=('retrieved','unavailable','blocked')

def _fields(value):
 if not isinstance(value,dict) or set(value)-set(FIELDS):raise ValueError('FIELD_CONTRACT')
 out={}
 for key,item in value.items():
  if item is None:continue
  if key=='title':
   if not isinstance(item,str) or len(item)>120:raise ValueError('TITLE_CONTRACT')
   if item.strip():out[key]=item.strip()
  elif type(item) is not int or not 0<=item<=1_000_000_000:raise ValueError('INTEGER_CONTRACT')
  else:out[key]=item
 return out

def decide_intake(fetch_status,fetched,provided):
 """Caller must supply trustworthy classified observations, not raw error text.

 Integers share an externally declared minor-money/count unit; no conversion.
 Retrieved means a transport classification, never verification of product truth.
 """
 if fetch_status not in STATES or type(fetch_status) is not str:raise ValueError('FETCH_STATE')
 a,b=_fields(fetched),_fields(provided)
 if fetch_status!='retrieved' and a:raise ValueError('CONTRADICTORY_FETCH_FIELDS')
 base={'fetch_status':fetch_status,'candidate':None,'field_origins':{},'missing_fields':list(FIELDS),'review_required':True,'publish_ready':False,'performs_action':False,'authenticates_sources':False}
 if fetch_status=='blocked':return {**base,'decision':'blocked'}
 selected={};origins={}
 for key in FIELDS:
  if key in a:selected[key]=a[key];origins[key]='fetched'
  elif key in b:selected[key]=b[key];origins[key]='provided'
 if 'title' not in selected:return {**base,'decision':'insufficient'}
 return {**base,'decision':'fetched_candidate' if origins['title']=='fetched' else 'provided_candidate','candidate':selected,'field_origins':origins,'missing_fields':[key for key in FIELDS if key not in selected]}