Inheritance diagram for dc_db.ProcessedContentInternalStruct.ProcessedContentInternalStruct:

Collaboration diagram for dc_db.ProcessedContentInternalStruct.ProcessedContentInternalStruct:

Static Public Member Functions
def	processDictProcessedContent (cDateValue, contentMask, processedContent)

def	parseProcessedBuf (buf, cDateValue, contentMask)

Static Public Attributes
string	DATA_FIELD = "data"

string	CDATE_FIELD = "CDate"

Detailed Description

Definition at line 21 of file ProcessedContentInternalStruct.py.

Member Function Documentation

◆ parseProcessedBuf()

def dc_db.ProcessedContentInternalStruct.ProcessedContentInternalStruct.parseProcessedBuf	(	buf,
		cDateValue,
		contentMask
	)

static

Definition at line 98 of file ProcessedContentInternalStruct.py.

   def parseProcessedBuf(buf, cDateValue, contentMask):
     ret = []
     try:
       processedContent = json.loads(base64.b64decode(buf))
     except Exception as excp:
       processedContent = None
       logger.debug(">>> Wrong something bad with processedContent decode, =" + str(excp))
     if processedContent is not None:
       if isinstance(processedContent, types.DictType):
         if "custom" in processedContent and "internal" in processedContent:
           ret = ProcessedContentInternalStruct.processDictProcessedContent(cDateValue, contentMask, processedContent)
         else:
           logger.debug(">>> Wrong custom or internal not present in processedContent DICT")
       elif isinstance(processedContent, types.ListType):
         if contentMask & dc.EventObjects.URLContentRequest.CONTENT_TYPE_PROCESSED:
           resultElem = json.dumps(processedContent, ensure_ascii=False, encoding='utf-8')
           resultElem = base64.b64encode(resultElem)
           content = dc.EventObjects.Content(resultElem, cDateValue, dc.EventObjects.Content.CONTENT_PROCESSOR_CONTENT)
           ret.append(content)
     return ret

◆ processDictProcessedContent()

def dc_db.ProcessedContentInternalStruct.ProcessedContentInternalStruct.processDictProcessedContent	(	cDateValue,
		contentMask,
		processedContent
	)

static

Definition at line 34 of file ProcessedContentInternalStruct.py.

   def processDictProcessedContent(cDateValue, contentMask, processedContent):
     ret = []
 
     logger.debug("contentMask: %s, len(processedContent): %s", str(contentMask), str(len(processedContent)))
     if contentMask & dc.EventObjects.URLContentRequest.CONTENT_TYPE_PROCESSED:
       if len(processedContent["custom"]) > 0:
         logger.debug("return item processedContent['custom'][0]")
         resultElem = base64.b64encode(processedContent["custom"][0])
       else:
         logger.debug("return deep copy of processedContent, `internal` and `custom` removed")
         localProcessedContent = copy.deepcopy(processedContent)
         del localProcessedContent["internal"]
         del localProcessedContent["custom"]
         resultElem = json.dumps(localProcessedContent, ensure_ascii=False, encoding='utf-8')
         resultElem = base64.b64encode(resultElem)
       content = dc.EventObjects.Content(resultElem, cDateValue, dc.EventObjects.Content.CONTENT_PROCESSOR_CONTENT)
       ret.append(content)
     if contentMask & dc.EventObjects.URLContentRequest.CONTENT_TYPE_PROCESSED_INTERNAL and \
       contentMask & dc.EventObjects.URLContentRequest.CONTENT_TYPE_PROCESSED_CUSTOM:
       i = 0
       for elem in processedContent["internal"]:
         resultElem = json.dumps(elem, ensure_ascii=False, encoding='utf-8')
         resultElem = base64.b64encode(resultElem)
         contentInternal = dc.EventObjects.Content(resultElem, cDateValue,
                                                   dc.EventObjects.Content.CONTENT_PROCESSOR_CONTENT)
         if i < len(processedContent["custom"]):
           elemCustom = processedContent["custom"][i]
           resultElem = base64.b64encode(elemCustom)
           contentCustom = dc.EventObjects.Content(resultElem, cDateValue,
                                                   dc.EventObjects.Content.CONTENT_PROCESSOR_CONTENT)
         else:
           contentCustom = None
         insertTuple = (contentInternal, contentCustom)
         ret.append(insertTuple)
         i += 1
     elif contentMask & dc.EventObjects.URLContentRequest.CONTENT_TYPE_PROCESSED_INTERNAL:
       for elem in processedContent["internal"]:
         resultElem = json.dumps(elem, ensure_ascii=False, encoding='utf-8')
         resultElem = base64.b64encode(resultElem)
         content = dc.EventObjects.Content(resultElem, cDateValue, dc.EventObjects.Content.CONTENT_PROCESSOR_CONTENT)
         ret.append(content)
         if (contentMask & dc.EventObjects.URLContentRequest.CONTENT_TYPE_PROCESSED_ALL) == 0:
           break
     elif contentMask & dc.EventObjects.URLContentRequest.CONTENT_TYPE_PROCESSED_CUSTOM:
       for elem in processedContent["custom"]:
         resultElem = base64.b64encode(elem)
         content = dc.EventObjects.Content(resultElem, cDateValue, dc.EventObjects.Content.CONTENT_PROCESSOR_CONTENT)
         ret.append(content)
         if (contentMask & dc.EventObjects.URLContentRequest.CONTENT_TYPE_PROCESSED_ALL) == 0:
           break
 
     logger.debug("Return Content instance list: %s", str(len(ret)))
 
     return ret
 
 