HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
Public Member Functions | Public Attributes | Static Public Attributes | List of all members
ftests.ftest_DBTask.Test Class Reference
Inheritance diagram for ftests.ftest_DBTask.Test:
Inheritance graph
[legend]
Collaboration diagram for ftests.ftest_DBTask.Test:
Collaboration graph
[legend]

Public Member Functions

def setUp (self)
 
def tearDown (self)
 
def execCommand (self, command, step)
 
def checkSStep1 (self, obj, step)
 
def checkSStep2 (self, obj, step)
 
def checkSStep3 (self, obj, step)
 
def checkSStep4 (self, obj, step)
 
def checkSStep5 (self, obj, step)
 
def checkSStep6 (self, obj, step)
 
def checkSStep7 (self, obj, step)
 
def checkSStep8 (self, obj, step)
 
def checkSStep9 (self, obj, step)
 
def checkSStep10 (self, obj, step)
 
def checkUStep1 (self, obj, step)
 
def checkUStep2 (self, obj, step)
 
def checkUStep3 (self, obj, step)
 
def checkUStep4 (self, obj, step)
 
def checkUStep5 (self, obj, step)
 
def checkUStep6 (self, obj, step)
 
def checkUStep7 (self, obj, step)
 
def checkUStep8 (self, obj, step)
 
def checkUStep9 (self, obj, step)
 
def checkUStep10 (self, obj, step)
 
def checkUStep11 (self, obj, step)
 
def checkUStep12 (self, obj, step)
 
def checkUStep13 (self, obj, step)
 
def checkUStep14 (self, obj, step)
 
def checkUStep15 (self, obj, step)
 
def checkUStep16 (self, obj, step)
 
def checkUStep17 (self, obj, step)
 
def checkCStep1 (self, obj, step)
 
def checkCStep2 (self, obj, step)
 
def checkCStep3 (self, obj, step)
 
def checkIntelStep0 (self, obj, step)
 
def checkIntelStep3 (self, obj, step)
 
def checkCriterions2 (self, obj, step)
 
def checkDeleteBad (self, obj, step)
 
def checkSiteCriterions1 (self, obj, step)
 
def checkSiteCriterions2 (self, obj, step)
 
def checkURLContentBDFields (self, obj, step)
 
def checkSQLCustom1 (self, obj, step)
 
def checkSQLCustom2 (self, obj, step)
 
def checkSQLCustom3 (self, obj, step)
 
def checkSStatusUrls (self, obj, step)
 
def checkSiteFind (self, obj, step)
 
def checkFieldRecalculator (self, obj, step)
 
def checkVerify (self, obj, step)
 
def checkMySQLContent (self, obj, step)
 
def fileCreate (self, directory, fName, data)
 
def makeContent (self)
 
def test_22_UrlPutTest (self)
 

Public Attributes

 url
 
 siteId
 
 urlMd5
 

Static Public Attributes

string CD_PATH = "../../bin"
 
string CLASS_NAME = "TasksManager"
 
string KEY_VALUE_STORAGE_DIR = "key_value_storage_dir"
 
string RAW_DATA_DIR = "raw_data_dir"
 
 mutex = threading.Lock()
 
 contentType = dc_db.Constants.DB_DATA_MYSQL
 

Detailed Description

Definition at line 263 of file ftest_DBTask.py.

Member Function Documentation

◆ checkCriterions2()

def ftests.ftest_DBTask.Test.checkCriterions2 (   self,
  obj,
  step 
)

Definition at line 929 of file ftest_DBTask.py.

929  def checkCriterions2(self, obj, step):
930  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
931  self.assertTrue(obj.eventType == EVENT_TYPES.URL_FETCH_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
932  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
933  self.assertTrue(len(obj.eventObject) == 3, "Step%s >>> Bad return object len" % str(step))
934  self.assertTrue(obj.eventObject[0].siteId == "z2", "Step%s >>> Bad return object[0].siteId value" % str(step))
935  self.assertTrue(obj.eventObject[1].siteId == "intel1", "Step%s >>> Bad return object[1].siteId value" % str(step))
936  self.assertTrue(obj.eventObject[1].url ==
937  "http://intel.com/path1/path2", "Step%s >>> Bad return object[1].url value" % str(step))
938  self.assertTrue(obj.eventObject[1].state == 77, "Step%s >>> Bad return object[1].state value" % str(step))
939  self.assertTrue(obj.eventObject[1].status == 77, "Step%s >>> Bad return object[1].status value" % str(step))
940  self.assertTrue(obj.eventObject[2].siteId == "intel1", "Step%s >>> Bad return object[2].siteId value" % str(step))
941  self.assertTrue(obj.eventObject[2].url ==
942  "http://intel.com/path1/", "Step%s >>> Bad return object[2].url value" % str(step))
943 
944 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkCStep1()

def ftests.ftest_DBTask.Test.checkCStep1 (   self,
  obj,
  step 
)

Definition at line 623 of file ftest_DBTask.py.

623  def checkCStep1(self, obj, step):
624  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
625  self.assertTrue(obj.eventType == EVENT_TYPES.URL_CONTENT_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
626  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
627  self.assertTrue(len(obj.eventObject) == 3, "Step%s >>> Bad return object len" % str(step))
628  self.assertTrue(obj.eventObject[0].url ==
629  "http://url1.com/", "Step%s >>> Bad return object[0].url value" % str(step))
630  self.assertTrue(type(obj.eventObject[0].rawContents) == type([]),
631  "Step%s >>> Bad return object[0].rawContent type" % str(step))
632  self.assertTrue(len(obj.eventObject[0].rawContents) == 0,
633  "Step%s >>> Bad return object[0].rawContent len" % str(step))
634 
635  self.assertTrue(type(obj.eventObject[0].processedContents) == type([]),
636  "Step%s >>> Bad return object[0].processedContents type" % str(step))
637  self.assertTrue(len(obj.eventObject[0].processedContents) == 0,
638  "Step%s >>> Bad return object[0].processedContents len" % str(step))
639  self.assertTrue(obj.eventObject[1].url ==
640  "http://url5.com/", "Step%s >>> Bad return object[1].url value" % str(step))
641  self.assertTrue(type(obj.eventObject[1].rawContents) == type([]),
642  "Step%s >>> Bad return object[1].rawContent type" % str(step))
643 
644  self.assertTrue(len(obj.eventObject[1].rawContents) == 2,
645  "Step%s >>> Bad return object[1].rawContent len" % str(step))
646  baseStr = base64.b64decode(obj.eventObject[1].rawContents[0].buffer)
647  self.assertTrue(baseStr == "EEEEE",
648  "Step%s >>> Bad return obj.eventObject[1].rawContents[1].buffer value" % str(step))
649  print(obj.eventObject[1].rawContents[0].cDate)
650  self.assertTrue(len(obj.eventObject[1].processedContents) == 1,
651  "Step%s >>> Bad return object[1].processedContents len" % str(step))
652  self.assertTrue(obj.eventObject[1].processedContents[0].buffer == "EEEEE",
653  "Step%s >>> Bad return obj.processedContents[1].rawContents[0].buffer value" % str(step))
654  print(obj.eventObject[1].rawContents[0].cDate)
655  baseStr = base64.b64decode(obj.eventObject[1].rawContents[1].buffer)
656  self.assertTrue(baseStr == "ArashTIDY",
657  "Step%s >>> Bad return obj.eventObject[1].rawContents[1].buffer value" % str(step))
658  self.assertTrue(obj.eventObject[1].rawContents[1].typeId == dc.EventObjects.Content.CONTENT_TIDY_CONTENT,
659  "Step%s >>> Bad return obj.eventObject[1].rawContents[1].typeId value" % str(step))
660  print(obj.eventObject[1].rawContents[1].cDate)
661 
662  self.assertTrue(obj.eventObject[2].url ==
663  "http://url5.com/", "Step%s >>> Bad return object[1].url value" % str(step))
664  self.assertTrue(type(obj.eventObject[2].rawContents) == type([]),
665  "Step%s >>> Bad return object[1].rawContent type" % str(step))
666  self.assertTrue(len(obj.eventObject[2].rawContents) == 10,
667  "Step%s >>> Bad return object[2].rawContent len" % str(step))
668  baseStr = base64.b64decode(obj.eventObject[2].rawContents[0].buffer)
669  self.assertTrue(baseStr == "EEEEE",
670  "Step%s >>> Bad return obj.eventObject[2].rawContents[0].buffer value" % str(step))
671  print(obj.eventObject[2].rawContents[0].cDate)
672  baseStr = base64.b64decode(obj.eventObject[2].rawContents[1].buffer)
673  self.assertTrue(baseStr == "AAAAA",
674  "Step%s >>> Bad return obj.eventObject[2].rawContents[1].buffer value" % str(step))
675  print(obj.eventObject[2].rawContents[1].cDate)
676  baseStr = base64.b64decode(obj.eventObject[2].rawContents[2].buffer)
677  self.assertTrue(baseStr == "AAAAA",
678  "Step%s >>> Bad return obj.eventObject[2].rawContents[2].buffer value" % str(step))
679  print(obj.eventObject[2].rawContents[2].cDate)
680  baseStr = base64.b64decode(obj.eventObject[2].rawContents[3].buffer)
681  self.assertTrue(baseStr == "BBBBB",
682  "Step%s >>> Bad return obj.eventObject[2].rawContents[3].buffer value" % str(step))
683  print(obj.eventObject[2].rawContents[3].cDate)
684  baseStr = base64.b64decode(obj.eventObject[2].rawContents[4].buffer)
685  self.assertTrue(baseStr == "CCCCC",
686  "Step%s >>> Bad return obj.eventObject[2].rawContents[4].buffer value" % str(step))
687  print(obj.eventObject[2].rawContents[4].cDate)
688  baseStr = base64.b64decode(obj.eventObject[2].rawContents[5].buffer)
689  self.assertTrue(baseStr == "EEEEE",
690  "Step%s >>> Bad return obj.eventObject[2].rawContents[5].buffer value" % str(step))
691  print(obj.eventObject[2].rawContents[5].cDate)
692  baseStr = base64.b64decode(obj.eventObject[2].rawContents[6].buffer)
693  self.assertTrue(baseStr == "ArashTIDY",
694  "Step%s >>> Bad return obj.eventObject[2].rawContents[6].buffer value" % str(step))
695  self.assertTrue(obj.eventObject[2].rawContents[6].typeId == dc.EventObjects.Content.CONTENT_TIDY_CONTENT,
696  "Step%s >>> Bad return obj.eventObject[2].rawContents[6].typeId value" % str(step))
697  print(obj.eventObject[2].rawContents[6].cDate)
698 
699  baseStr = base64.b64decode(obj.eventObject[2].rawContents[7].buffer)
700  self.assertTrue(baseStr == "AAATIDY",
701  "Step%s >>> Bad return obj.eventObject[1].rawContents[7].buffer value" % str(step))
702  self.assertTrue(obj.eventObject[2].rawContents[7].typeId == dc.EventObjects.Content.CONTENT_TIDY_CONTENT,
703  "Step%s >>> Bad return obj.eventObject[1].rawContents[7].typeId value" % str(step))
704  print(obj.eventObject[2].rawContents[7].cDate)
705  baseStr = base64.b64decode(obj.eventObject[2].rawContents[8].buffer)
706  self.assertTrue(baseStr == "AAATIDY",
707  "Step%s >>> Bad return obj.eventObject[2].rawContents[8].buffer value" % str(step))
708  self.assertTrue(obj.eventObject[2].rawContents[8].typeId == dc.EventObjects.Content.CONTENT_TIDY_CONTENT,
709  "Step%s >>> Bad return obj.eventObject[2].rawContents[8].typeId value" % str(step))
710  print(obj.eventObject[2].rawContents[8].cDate)
711  baseStr = base64.b64decode(obj.eventObject[2].rawContents[9].buffer)
712  self.assertTrue(baseStr == "ArashTIDY",
713  "Step%s >>> Bad return obj.eventObject[2].rawContents[9].buffer value" % str(step))
714  self.assertTrue(obj.eventObject[2].rawContents[9].typeId == dc.EventObjects.Content.CONTENT_TIDY_CONTENT,
715  "Step%s >>> Bad return obj.eventObject[2].rawContents[9].typeId value" % str(step))
716  print(obj.eventObject[2].rawContents[9].cDate)
717  self.assertTrue(len(obj.eventObject[1].processedContents) == 1,
718  "Step%s >>> Bad return object[1].processedContents len" % str(step))
719  self.assertTrue(obj.eventObject[1].processedContents[0].buffer == "EEEEE",
720  "Step%s >>> Bad return obj.processedContents[1].rawContents[0].buffer value" % str(step))
721  print(obj.eventObject[1].processedContents[0].cDate)
722 
723 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkCStep2()

def ftests.ftest_DBTask.Test.checkCStep2 (   self,
  obj,
  step 
)

Definition at line 724 of file ftest_DBTask.py.

724  def checkCStep2(self, obj, step):
725  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
726  self.assertTrue(obj.eventType == EVENT_TYPES.URL_CONTENT_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
727  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
728  self.assertTrue(len(obj.eventObject) == 3, "Step%s >>> Bad return object len" % str(step))
729  self.assertTrue(obj.eventObject[0].url ==
730  "http://url1.com/", "Step%s >>> Bad return object[0].url value" % str(step))
731  self.assertTrue(type(obj.eventObject[0].rawContents) == type([]),
732  "Step%s >>> Bad return object[0].rawContent type" % str(step))
733  self.assertTrue(len(obj.eventObject[0].rawContents) == 0,
734  "Step%s >>> Bad return object[0].rawContent len" % str(step))
735 
736  self.assertTrue(type(obj.eventObject[0].processedContents) == type([]),
737  "Step%s >>> Bad return object[0].processedContents type" % str(step))
738  self.assertTrue(len(obj.eventObject[0].processedContents) == 0,
739  "Step%s >>> Bad return object[0].processedContents len" % str(step))
740  self.assertTrue(type(obj.eventObject[0].headers) == type([]),
741  "Step%s >>> Bad return object[0].headers type" % str(step))
742  self.assertTrue(len(obj.eventObject[0].headers) == 0,
743  "Step%s >>> Bad return object[0].headers len" % str(step))
744  self.assertTrue(type(obj.eventObject[0].requests) == type([]),
745  "Step%s >>> Bad return object[0].requests type" % str(step))
746  self.assertTrue(len(obj.eventObject[0].requests) == 0,
747  "Step%s >>> Bad return object[0].requests len" % str(step))
748  self.assertTrue(type(obj.eventObject[0].meta) == type([]),
749  "Step%s >>> Bad return object[0].meta type" % str(step))
750  self.assertTrue(len(obj.eventObject[0].meta) == 0,
751  "Step%s >>> Bad return object[0].meta len" % str(step))
752  self.assertTrue(type(obj.eventObject[0].cookies) == type([]),
753  "Step%s >>> Bad return object[0].cookies type" % str(step))
754  self.assertTrue(len(obj.eventObject[0].cookies) == 0,
755  "Step%s >>> Bad return object[0].cookies len" % str(step))
756 
757  self.assertTrue(obj.eventObject[1].url ==
758  "http://url5.com/", "Step%s >>> Bad return object[0].url value" % str(step))
759  self.assertTrue(type(obj.eventObject[1].rawContents) == type([]),
760  "Step%s >>> Bad return object[1].rawContent type" % str(step))
761  self.assertTrue(len(obj.eventObject[1].rawContents) == 8,
762  "Step%s >>> Bad return object[1].rawContent len" % str(step))
763  self.assertTrue(len(obj.eventObject[1].headers) == 5,
764  "Step%s >>> Bad return object[1].headers len" % str(step))
765  baseStr = base64.b64decode(obj.eventObject[1].headers[0].buffer)
766  self.assertTrue(baseStr == "AAAAAheaders",
767  "Step%s >>> Bad return obj.eventObject[1].headers[0].buffer value" % str(step))
768  baseStr = base64.b64decode(obj.eventObject[1].headers[1].buffer)
769  self.assertTrue(baseStr == "AAAAAheaders",
770  "Step%s >>> Bad return obj.eventObject[1].headers[1].buffer value" % str(step))
771  baseStr = base64.b64decode(obj.eventObject[1].headers[2].buffer)
772  self.assertTrue(baseStr == "BBBBBheaders",
773  "Step%s >>> Bad return obj.eventObject[1].headers[2].buffer value" % str(step))
774  baseStr = base64.b64decode(obj.eventObject[1].headers[3].buffer)
775  self.assertTrue(baseStr == "CCCCCheaders",
776  "Step%s >>> Bad return obj.eventObject[1].headers[3].buffer value" % str(step))
777  self.assertTrue(len(obj.eventObject[1].requests) == 5,
778  "Step%s >>> Bad return object[1].requests len" % str(step))
779  baseStr = base64.b64decode(obj.eventObject[1].requests[0].buffer)
780  self.assertTrue(baseStr == "AAAAArequests",
781  "Step%s >>> Bad return obj.eventObject[1].requests[0].buffer value" % str(step))
782  baseStr = base64.b64decode(obj.eventObject[1].requests[1].buffer)
783  self.assertTrue(baseStr == "AAAAArequests",
784  "Step%s >>> Bad return obj.eventObject[1].requests[1].buffer value" % str(step))
785  self.assertTrue(obj.eventObject[1].requests[2] == None,
786  "Step%s >>> Bad return obj.eventObject[1].requests[2].buffer value" % str(step))
787  baseStr = base64.b64decode(obj.eventObject[1].requests[3].buffer)
788  self.assertTrue(baseStr == "CCCCCrequests",
789  "Step%s >>> Bad return obj.eventObject[1].requests[3].buffer value" % str(step))
790  self.assertTrue(len(obj.eventObject[1].meta) == 5,
791  "Step%s >>> Bad return object[1].meta len" % str(step))
792  baseStr = base64.b64decode(obj.eventObject[1].meta[0].buffer)
793  self.assertTrue(baseStr == "AAAAAmeta",
794  "Step%s >>> Bad return obj.eventObject[1].meta[0].buffer value" % str(step))
795  baseStr = base64.b64decode(obj.eventObject[1].meta[1].buffer)
796  self.assertTrue(baseStr == "AAAAAmeta",
797  "Step%s >>> Bad return obj.eventObject[1].meta[1].buffer value" % str(step))
798  self.assertTrue(obj.eventObject[1].meta[2] == None,
799  "Step%s >>> Bad return obj.eventObject[1].meta[2].buffer value" % str(step))
800  baseStr = base64.b64decode(obj.eventObject[1].meta[3].buffer)
801  self.assertTrue(baseStr == "CCCCCmeta",
802  "Step%s >>> Bad return obj.eventObject[1].meta[3].buffer value" % str(step))
803  self.assertTrue(len(obj.eventObject[1].cookies) == 5,
804  "Step%s >>> Bad return object[1].cookies len" % str(step))
805  baseStr = base64.b64decode(obj.eventObject[1].cookies[0].buffer)
806  self.assertTrue(baseStr == "AAAAAcookies",
807  "Step%s >>> Bad return obj.eventObject[1].cookies[0].buffer value" % str(step))
808  baseStr = base64.b64decode(obj.eventObject[1].cookies[1].buffer)
809  self.assertTrue(baseStr == "AAAAAcookies",
810  "Step%s >>> Bad return obj.eventObject[1].cookies[1].buffer value" % str(step))
811  baseStr = base64.b64decode(obj.eventObject[1].cookies[2].buffer)
812  self.assertTrue(baseStr == "BBBBBcookies",
813  "Step%s >>> Bad return obj.eventObject[1].cookies[2].buffer value" % str(step))
814  baseStr = base64.b64decode(obj.eventObject[1].cookies[3].buffer)
815  self.assertTrue(baseStr == "CCCCCcookies",
816  "Step%s >>> Bad return obj.eventObject[1].cookies[3].buffer value" % str(step))
817 
818  self.assertTrue(obj.eventObject[2].url ==
819  "http://url5.com/", "Step%s >>> Bad return object[0].url value" % str(step))
820  self.assertTrue(type(obj.eventObject[2].rawContents) == type([]),
821  "Step%s >>> Bad return object[2].rawContent type" % str(step))
822  self.assertTrue(len(obj.eventObject[2].rawContents) == 8,
823  "Step%s >>> Bad return object[2].rawContent len" % str(step))
824  self.assertTrue(len(obj.eventObject[2].headers) == 5,
825  "Step%s >>> Bad return object[2].headers len" % str(step))
826  baseStr = base64.b64decode(obj.eventObject[2].headers[0].buffer)
827  self.assertTrue(baseStr == "AAAAAheaders",
828  "Step%s >>> Bad return obj.eventObject[2].headers[0].buffer value" % str(step))
829  baseStr = base64.b64decode(obj.eventObject[2].headers[1].buffer)
830  self.assertTrue(baseStr == "AAAAAheaders",
831  "Step%s >>> Bad return obj.eventObject[2].headers[1].buffer value" % str(step))
832  baseStr = base64.b64decode(obj.eventObject[2].headers[2].buffer)
833  self.assertTrue(baseStr == "BBBBBheaders",
834  "Step%s >>> Bad return obj.eventObject[2].headers[2].buffer value" % str(step))
835  baseStr = base64.b64decode(obj.eventObject[2].headers[3].buffer)
836  self.assertTrue(baseStr == "CCCCCheaders",
837  "Step%s >>> Bad return obj.eventObject[2].headers[3].buffer value" % str(step))
838  self.assertTrue(len(obj.eventObject[2].requests) == 5,
839  "Step%s >>> Bad return object[2].requests len" % str(step))
840  baseStr = base64.b64decode(obj.eventObject[2].requests[0].buffer)
841  self.assertTrue(baseStr == "AAAAArequests",
842  "Step%s >>> Bad return obj.eventObject[2].requests[0].buffer value" % str(step))
843  baseStr = base64.b64decode(obj.eventObject[2].requests[1].buffer)
844  self.assertTrue(baseStr == "AAAAArequests",
845  "Step%s >>> Bad return obj.eventObject[2].requests[1].buffer value" % str(step))
846  self.assertTrue(obj.eventObject[2].requests[2] == None,
847  "Step%s >>> Bad return obj.eventObject[2].requests[2].buffer value" % str(step))
848  baseStr = base64.b64decode(obj.eventObject[2].requests[3].buffer)
849  self.assertTrue(baseStr == "CCCCCrequests",
850  "Step%s >>> Bad return obj.eventObject[2].requests[3].buffer value" % str(step))
851  self.assertTrue(len(obj.eventObject[2].meta) == 5,
852  "Step%s >>> Bad return object[2].meta len" % str(step))
853  baseStr = base64.b64decode(obj.eventObject[2].meta[0].buffer)
854  self.assertTrue(baseStr == "AAAAAmeta",
855  "Step%s >>> Bad return obj.eventObject[2].meta[0].buffer value" % str(step))
856  baseStr = base64.b64decode(obj.eventObject[2].meta[1].buffer)
857  self.assertTrue(baseStr == "AAAAAmeta",
858  "Step%s >>> Bad return obj.eventObject[2].meta[1].buffer value" % str(step))
859  self.assertTrue(obj.eventObject[2].meta[2] == None,
860  "Step%s >>> Bad return obj.eventObject[2].meta[2].buffer value" % str(step))
861  baseStr = base64.b64decode(obj.eventObject[2].meta[3].buffer)
862  self.assertTrue(baseStr == "CCCCCmeta",
863  "Step%s >>> Bad return obj.eventObject[2].meta[3].buffer value" % str(step))
864  self.assertTrue(len(obj.eventObject[2].cookies) == 0,
865  "Step%s >>> Bad return object[2].cookies len" % str(step))
866 
867 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkCStep3()

def ftests.ftest_DBTask.Test.checkCStep3 (   self,
  obj,
  step 
)

Definition at line 868 of file ftest_DBTask.py.

868  def checkCStep3(self, obj, step):
869  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
870  self.assertTrue(obj.eventType == EVENT_TYPES.URL_CONTENT_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
871  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
872  self.assertTrue(len(obj.eventObject) == 3, "Step%s >>> Bad return object len" % str(step))
873 
874  self.assertTrue(obj.eventObject[1].url ==
875  "http://url5.com/", "Step%s >>> Bad return object[0].url value" % str(step))
876  self.assertTrue(type(obj.eventObject[1].rawContents) == type([]),
877  "Step%s >>> Bad return object[1].rawContent type" % str(step))
878  self.assertTrue(len(obj.eventObject[1].rawContents) == 7,
879  "Step%s >>> Bad return object[1].rawContent len" % str(step))
880  self.assertTrue(len(obj.eventObject[1].headers) == 5,
881  "Step%s >>> Bad return object[1].headers len" % str(step))
882  baseStr = base64.b64decode(obj.eventObject[1].rawContents[6].buffer)
883  self.assertTrue(baseStr == "AAADYN",
884  "Step%s >>> Bad return obj.eventObject[1].rawContents[6].buffer value" % str(step))
885  self.assertTrue(obj.eventObject[1].rawContents[6].typeId == dc.EventObjects.Content.CONTENT_DYNAMIC_CONTENT,
886  "Step%s >>> Bad return obj.eventObject[1].rawContents[6].typeId value" % str(step))
887  print(obj.eventObject[1].rawContents[6].cDate)
888 
889  self.assertTrue(obj.eventObject[2].url ==
890  "http://url5.com/", "Step%s >>> Bad return object[0].url value" % str(step))
891  self.assertTrue(type(obj.eventObject[2].rawContents) == type([]),
892  "Step%s >>> Bad return object[2].rawContent type" % str(step))
893  self.assertTrue(len(obj.eventObject[2].rawContents) == 7,
894  "Step%s >>> Bad return object[2].rawContent len" % str(step))
895  self.assertTrue(len(obj.eventObject[2].headers) == 5,
896  "Step%s >>> Bad return object[2].headers len" % str(step))
897  baseStr = base64.b64decode(obj.eventObject[2].rawContents[6].buffer)
898  self.assertTrue(baseStr == "AAADYN",
899  "Step%s >>> Bad return obj.eventObject[2].rawContents[6].buffer value" % str(step))
900  self.assertTrue(obj.eventObject[2].rawContents[6].typeId == dc.EventObjects.Content.CONTENT_DYNAMIC_CONTENT,
901  "Step%s >>> Bad return obj.eventObject[2].rawContents[6].typeId value" % str(step))
902  print(obj.eventObject[2].rawContents[6].cDate)
903 
904 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkDeleteBad()

def ftests.ftest_DBTask.Test.checkDeleteBad (   self,
  obj,
  step 
)

Definition at line 945 of file ftest_DBTask.py.

945  def checkDeleteBad(self, obj, step):
946  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
947  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_DELETE_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
948  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
949  "Step%s >>> Bad return object type" % str(step))
950  self.assertTrue(obj.eventObject.errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK,
951  "Step%s >>> Wrong obj.eventObject.errorCode value" % str(step))
952  self.assertTrue(obj.eventObject.errorMessage == "",
953  "Step%s >>> Wrong obj.eventObject.errorMessage value" % str(step))
954 
955 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkFieldRecalculator()

def ftests.ftest_DBTask.Test.checkFieldRecalculator (   self,
  obj,
  step 
)

Definition at line 1054 of file ftest_DBTask.py.

1054  def checkFieldRecalculator(self, obj, step):
1055  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
1056  self.assertTrue(obj.eventType == EVENT_TYPES.FIELD_RECALCULATE_RESPONSE,
1057  "Step%s >>> Bad return Event type" % str(step))
1058  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
1059  "Step%s >>> Bad return object type" % str(step))
1060  self.assertTrue(len(obj.eventObject.statuses) == 12, "Step%s >>> Bad return object len" % str(step))
1061 
1062 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkIntelStep0()

def ftests.ftest_DBTask.Test.checkIntelStep0 (   self,
  obj,
  step 
)

Definition at line 905 of file ftest_DBTask.py.

905  def checkIntelStep0(self, obj, step):
906  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
907  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_NEW_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
908  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
909  "Step%s >>> Bad return object type" % str(step))
910  self.assertTrue(obj.eventObject.errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK,
911  "Step%s >>> Some Error in Return object" % str(step))
912  self.assertTrue(len(obj.eventObject.statuses) == 1, "Step%s >>> obj.eventObject.statuses len != 1" % str(step))
913  self.assertTrue(obj.eventObject.statuses[0] == "intel1", "Step%s >>> obj.eventObject.statuses[0] != \"intel1\""
914  % str(step))
915 
916 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkIntelStep3()

def ftests.ftest_DBTask.Test.checkIntelStep3 (   self,
  obj,
  step 
)

Definition at line 917 of file ftest_DBTask.py.

917  def checkIntelStep3(self, obj, step):
918  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
919  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_NEW_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
920  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
921  "Step%s >>> Bad return object type" % str(step))
922  self.assertTrue(obj.eventObject.errorCode == dc_db.Constants.TASK_DUPLICATE_ERR,
923  "Step%s >>> Some Error in Return object" % str(step))
924  self.assertTrue(len(obj.eventObject.statuses) == 1, "Step%s >>> obj.eventObject.statuses len != 1" % str(step))
925  self.assertTrue(obj.eventObject.statuses[0] == None, "Step%s >>> obj.eventObject.statuses[3] != None"
926  % str(step))
927 
928 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkMySQLContent()

def ftests.ftest_DBTask.Test.checkMySQLContent (   self,
  obj,
  step 
)

Definition at line 1077 of file ftest_DBTask.py.

1077  def checkMySQLContent(self, obj, step):
1078  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
1079  self.assertTrue(obj.eventType == EVENT_TYPES.URL_CONTENT_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
1080  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
1081  self.assertTrue(len(obj.eventObject) == 1, "Step%s >>> Bad return object len" % str(step))
1082  self.assertTrue(type(obj.eventObject[0].processedContents) == type([]),
1083  "Step%s >>> Bad return object[0].processedContents type" % str(step))
1084  self.assertTrue(len(obj.eventObject[0].processedContents) == 1,
1085  "Step%s >>> Bad return object[0].processedContents len" % str(step))
1086  self.assertTrue(len(obj.eventObject[0].processedContents) == 1,
1087  "Step%s >>> Bad return object[0].processedContents len" % str(step))
1088  self.assertTrue(obj.eventObject[0].processedContents[0].buffer == "blob data",
1089  "Step%s >>> Bad return object[0].processedContents.buffer value" % str(step))
1090  self.assertTrue(obj.eventObject[0].processedContents[0].cDate == "2010-10-10 10:10:10",
1091  "Step%s >>> Bad return object[0].processedContents.cDate value" % str(step))
1092 
1093 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSiteCriterions1()

def ftests.ftest_DBTask.Test.checkSiteCriterions1 (   self,
  obj,
  step 
)

Definition at line 956 of file ftest_DBTask.py.

956  def checkSiteCriterions1(self, obj, step):
957  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
958  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_UPDATE_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
959  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
960  "Step%s >>> Bad return object type" % str(step))
961  self.assertTrue(len(obj.eventObject.statuses) == 1, "Step%s >>> Bad return object statuses len" % str(step))
962  for status in obj.eventObject.statuses:
963  self.assertTrue(status == dtm.EventObjects.GeneralResponse.ERROR_OK,
964  "Step%s >>> Bad return object statuses value" % str(step))
965 
966 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSiteCriterions2()

def ftests.ftest_DBTask.Test.checkSiteCriterions2 (   self,
  obj,
  step 
)

Definition at line 967 of file ftest_DBTask.py.

967  def checkSiteCriterions2(self, obj, step):
968  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
969  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
970  self.assertTrue(type(obj.eventObject) == dc.EventObjects.Site, "Step%s >>> Bad return object type" % str(step))
971  self.assertTrue(obj.eventObject.maxResources == 6688,
972  "Step%s >>> Bad return eventObject.maxResources value" % str(step))
973 
974 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSiteFind()

def ftests.ftest_DBTask.Test.checkSiteFind (   self,
  obj,
  step 
)

Definition at line 1040 of file ftest_DBTask.py.

1040  def checkSiteFind(self, obj, step):
1041  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
1042  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_FIND_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
1043  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
1044  self.assertTrue(len(obj.eventObject) == 1, "Step%s >>> Bad return object len" % str(step))
1045  self.assertTrue(type(obj.eventObject[0].properties) == type([]),
1046  "Step%s >>> Bad return object.properties type" % str(step))
1047  self.assertTrue(len(obj.eventObject[0].properties) == 2,
1048  "Step%s >>> Bad return object.properties len" % str(step))
1049  self.assertTrue(type(obj.eventObject[0].filters) == type([]),
1050  "Step%s >>> Bad return object.filters type" % str(step))
1051  self.assertTrue(len(obj.eventObject[0].filters) == 1, "Step%s >>> Bad return object.filters len" % str(step))
1052 
1053 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSQLCustom1()

def ftests.ftest_DBTask.Test.checkSQLCustom1 (   self,
  obj,
  step 
)

Definition at line 1001 of file ftest_DBTask.py.

1001  def checkSQLCustom1(self, obj, step):
1002  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
1003  self.assertTrue(obj.eventType == EVENT_TYPES.SQL_CUSTOM_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
1004  self.assertTrue(type(obj.eventObject) == dbi.EventObjects.CustomResponse,
1005  "Step%s >>> Bad return object type" % str(step))
1006  self.assertTrue(obj.eventObject.errString == "Error: wrong SQL request or DBName")
1007  self.assertTrue(type(obj.eventObject.result) == tuple)
1008  self.assertTrue(len(obj.eventObject.result) == 0)
1009 
1010 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSQLCustom2()

def ftests.ftest_DBTask.Test.checkSQLCustom2 (   self,
  obj,
  step 
)

Definition at line 1011 of file ftest_DBTask.py.

1011  def checkSQLCustom2(self, obj, step):
1012  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
1013  self.assertTrue(obj.eventType == EVENT_TYPES.SQL_CUSTOM_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
1014  self.assertTrue(type(obj.eventObject) == dbi.EventObjects.CustomResponse,
1015  "Step%s >>> Bad return object type" % str(step))
1016  self.assertTrue(obj.eventObject.errString == "Error: wrong SQL request or DBName")
1017  self.assertTrue(type(obj.eventObject.result) == tuple)
1018  self.assertTrue(len(obj.eventObject.result) == 0)
1019 
1020 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSQLCustom3()

def ftests.ftest_DBTask.Test.checkSQLCustom3 (   self,
  obj,
  step 
)

Definition at line 1021 of file ftest_DBTask.py.

1021  def checkSQLCustom3(self, obj, step):
1022  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
1023  self.assertTrue(obj.eventType == EVENT_TYPES.SQL_CUSTOM_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
1024  self.assertTrue(type(obj.eventObject) == dbi.EventObjects.CustomResponse,
1025  "Step%s >>> Bad return object type" % str(step))
1026  self.assertTrue(obj.eventObject.errString is None)
1027  self.assertTrue(type(obj.eventObject.result) == tuple)
1028  self.assertTrue(len(obj.eventObject.result) > 0)
1029 
1030 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStatusUrls()

def ftests.ftest_DBTask.Test.checkSStatusUrls (   self,
  obj,
  step 
)

Definition at line 1031 of file ftest_DBTask.py.

1031  def checkSStatusUrls(self, obj, step):
1032  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
1033  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
1034  print obj.eventObject.id
1035  print obj.eventObject.contents
1036  print obj.eventObject.urls
1037  print obj.eventObject.urls[0].__dict__
1038 
1039 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep1()

def ftests.ftest_DBTask.Test.checkSStep1 (   self,
  obj,
  step 
)

Definition at line 300 of file ftest_DBTask.py.

300  def checkSStep1(self, obj, step):
301  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
302  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_NEW_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
303  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
304  "Step%s >>> Bad return object type" % str(step))
305  self.assertTrue(obj.eventObject.errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK,
306  "Step%s >>> Some Error in Return object" % str(step))
307 
308 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep10()

def ftests.ftest_DBTask.Test.checkSStep10 (   self,
  obj,
  step 
)

Definition at line 385 of file ftest_DBTask.py.

385  def checkSStep10(self, obj, step):
386  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
387  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
388  self.assertTrue(type(obj.eventObject) == dc.EventObjects.Site, "Step%s >>> Bad return object type" % str(step))
389  self.assertTrue(obj.eventObject.state != dc.EventObjects.Site.STATE_NOT_FOUND,
390  "Step%s >>> Wrong 'state' field value" % str(step))
391  self.assertTrue(obj.eventObject.id == "z2", "Step%s >>> Wrong 'id' field value" % str(step))
392  self.assertTrue(obj.eventObject.state == dc.EventObjects.Site.STATE_ACTIVE,
393  "Step%s >>> Wrong 'state' field value" % str(step))
394  self.assertTrue(type(obj.eventObject.properties) == type([]),
395  "Step%s >>> Wrong 'properties' field type" % str(step))
396  self.assertTrue(type(obj.eventObject.filters) == type([]),
397  "Step%s >>> Wrong 'filters' field type" % str(step))
398  self.assertTrue(len(obj.eventObject.properties) == 2, "Step%s >>> Wrong 'properties' field size" % str(step))
399  self.assertTrue(type(obj.eventObject.properties[0]["cDate"]) == str,
400  "Step%s >>> Wrong 'properties[0][cDate]' field value" % str(step))
401  self.assertTrue(obj.eventObject.properties[0]["uDate"] == None,
402  "Step%s >>> Wrong 'properties[0][uDate]' field value" % str(step))
403  self.assertTrue(len(obj.eventObject.properties) == 2, "Step%s >>> Wrong 'properties' field size" % str(step))
404  self.assertTrue(len(obj.eventObject.filters) == 1, "Step%s >>> Wrong 'filters' field size" % str(step))
405 
406 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep2()

def ftests.ftest_DBTask.Test.checkSStep2 (   self,
  obj,
  step 
)

Definition at line 309 of file ftest_DBTask.py.

309  def checkSStep2(self, obj, step):
310  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
311  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
312  self.assertTrue(type(obj.eventObject) == dc.EventObjects.Site, "Step%s >>> Bad return objsct type" % str(step))
313  self.assertTrue(obj.eventObject.state == dc.EventObjects.Site.STATE_NOT_FOUND,
314  "Step%s >>> Wrong 'state' field value" % str(step))
315 
316 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep3()

def ftests.ftest_DBTask.Test.checkSStep3 (   self,
  obj,
  step 
)

Definition at line 317 of file ftest_DBTask.py.

317  def checkSStep3(self, obj, step):
318  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
319  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_NEW_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
320  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
321  "Step%s >>> Bad return object type" % str(step))
322  self.assertTrue(obj.eventObject.errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK,
323  "Step%s >>> Some Error in Return object" % str(step))
324 
325 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep4()

def ftests.ftest_DBTask.Test.checkSStep4 (   self,
  obj,
  step 
)

Definition at line 326 of file ftest_DBTask.py.

326  def checkSStep4(self, obj, step):
327  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
328  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
329  self.assertTrue(type(obj.eventObject) == dc.EventObjects.Site, "Step%s >>> Bad return object type" % str(step))
330  self.assertTrue(obj.eventObject.state != dc.EventObjects.Site.STATE_NOT_FOUND,
331  "Step%s >>> Wrong 'state' field value" % str(step))
332  self.assertTrue(obj.eventObject.id == "z2", "Step%s >>> Wrong 'id' field value" % str(step))
333  self.assertTrue(obj.eventObject.state == 1, "Step%s >>> Wrong 'state' field value" % str(step))
334 
335 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep5()

def ftests.ftest_DBTask.Test.checkSStep5 (   self,
  obj,
  step 
)

Definition at line 336 of file ftest_DBTask.py.

336  def checkSStep5(self, obj, step):
337  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
338  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_UPDATE_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
339  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
340  "Step%s >>> Bad return object type" % str(step))
341  self.assertTrue(obj.eventObject.errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK,
342  "Step%s >>> Wrong 'errorCode' field value" % str(step))
343 
344 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep6()

def ftests.ftest_DBTask.Test.checkSStep6 (   self,
  obj,
  step 
)

Definition at line 345 of file ftest_DBTask.py.

345  def checkSStep6(self, obj, step):
346  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
347  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_DELETE_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
348  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
349  "Step%s >>> Bad return object type" % str(step))
350 
351 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep7()

def ftests.ftest_DBTask.Test.checkSStep7 (   self,
  obj,
  step 
)

Definition at line 352 of file ftest_DBTask.py.

352  def checkSStep7(self, obj, step):
353  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
354  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
355  self.assertTrue(type(obj.eventObject) == dc.EventObjects.Site, "Step%s >>> Bad return object type" % str(step))
356  self.assertTrue(obj.eventObject.state == dc.EventObjects.Site.STATE_NOT_FOUND,
357  "Step%s >>> Wrong 'state' field value" % str(step))
358 
359 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep8()

def ftests.ftest_DBTask.Test.checkSStep8 (   self,
  obj,
  step 
)

Definition at line 360 of file ftest_DBTask.py.

360  def checkSStep8(self, obj, step):
361  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
362  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
363  self.assertTrue(type(obj.eventObject) == dc.EventObjects.Site, "Step%s >>> Bad return object type" % str(step))
364  self.assertTrue(obj.eventObject.state != dc.EventObjects.Site.STATE_NOT_FOUND,
365  "Step%s >>> Wrong 'state' field value" % str(step))
366  self.assertTrue(obj.eventObject.id == "z2", "Step%s >>> Wrong 'id' field value" % str(step))
367  self.assertTrue(obj.eventObject.state == 55, "Step%s >>> Wrong 'state' field value" % str(step))
368  self.assertTrue(type(obj.eventObject.uDate) == str, "Step%s >>> Wrong 'uDate' field type" % str(step))
369  self.assertTrue(type(obj.eventObject.tcDate) == str, "Step%s >>> Wrong 'tcDate' field type" % str(step))
370  self.assertTrue(type(obj.eventObject.cDate) == str, "Step%s >>> Wrong 'cDate' field type" % str(step))
371  self.assertTrue(type(obj.eventObject.recrawlDate) == str, "Step%s >>> Wrong 'recrawlDate' field type" % str(step))
372  self.assertTrue(type(obj.eventObject.description) == str, "Step%s >>> Wrong 'description' field type" % str(step))
373  self.assertTrue(obj.eventObject.description == '33', "Step%s >>> Wrong 'description' value" % str(step))
374 
375 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkSStep9()

def ftests.ftest_DBTask.Test.checkSStep9 (   self,
  obj,
  step 
)

Definition at line 376 of file ftest_DBTask.py.

376  def checkSStep9(self, obj, step):
377  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
378  self.assertTrue(obj.eventType == EVENT_TYPES.SITE_CLEANUP_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
379  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
380  "Step%s >>> Bad return object type" % str(step))
381  self.assertTrue(obj.eventObject.errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK,
382  "Step%s >>> errorCode badvalue" % str(step))
383 
384 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkURLContentBDFields()

def ftests.ftest_DBTask.Test.checkURLContentBDFields (   self,
  obj,
  step 
)

Definition at line 975 of file ftest_DBTask.py.

975  def checkURLContentBDFields(self, obj, step):
976  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
977  self.assertTrue(obj.eventType == EVENT_TYPES.URL_CONTENT_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
978  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
979  self.assertTrue(len(obj.eventObject) == 2, "Step%s >>> Bad return object len" % str(step))
980  self.assertTrue(obj.eventObject[0].url ==
981  "http://url1.com/", "Step%s >>> Bad return object[0].url value" % str(step))
982  self.assertTrue(type(obj.eventObject[0].dbFields) == type({}),
983  "Step%s >>> Wrong object[0].dbFields type" % str(step))
984  self.assertTrue(len(obj.eventObject[0].dbFields) == 0, "Step%s >>> Wrong object[0].dbFields len" % str(step))
985  self.assertTrue(obj.eventObject[1].url ==
986  "http://url1.com/", "Step%s >>> Bad return object[1].url value" % str(step))
987  self.assertTrue(type(obj.eventObject[1].dbFields) == type({}),
988  "Step%s >>> Wrong object[1].dbFields type" % str(step))
989  self.assertTrue(len(obj.eventObject[1].dbFields) == 4,
990  "Step%s >>> Wrong object[1].dbFields len" % str(step))
991  self.assertTrue(obj.eventObject[1].dbFields["CDate"] != None,
992  "Step%s >>> Wrong object[1].dbFields[CDate] value" % str(step))
993  self.assertTrue(obj.eventObject[1].dbFields["RawContentMd5"] != None,
994  "Step%s >>> Wrong object[1].dbFields[RawContentMd5] value" % str(step))
995  self.assertTrue(obj.eventObject[1].dbFields["MRate"] != None,
996  "Step%s >>> Wrong object[1].dbFields[MRate] value" % str(step))
997  self.assertTrue(obj.eventObject[1].dbFields["emptyF"] == None,
998  "Step%s >>> Wrong object[1].dbFields[emptyF] value" % str(step))
999 
1000 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep1()

def ftests.ftest_DBTask.Test.checkUStep1 (   self,
  obj,
  step 
)

Definition at line 407 of file ftest_DBTask.py.

407  def checkUStep1(self, obj, step):
408  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
409  self.assertTrue(obj.eventType == EVENT_TYPES.URL_NEW_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
410  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
411  "Step%s >>> Bad return object type" % str(step))
412  self.assertTrue(obj.eventObject.errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK,
413  "Step%s >>> GeneralResponse come error" % str(step))
414 
415 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep10()

def ftests.ftest_DBTask.Test.checkUStep10 (   self,
  obj,
  step 
)

Definition at line 521 of file ftest_DBTask.py.

521  def checkUStep10(self, obj, step):
522  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
523  self.assertTrue(obj.eventType == EVENT_TYPES.URL_UPDATE_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
524  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
525  "Step%s >>> Bad return object type" % str(step))
526  self.assertTrue(len(obj.eventObject.statuses) == 4, "Step%s >>> Wrong GeneralResponse.statuses len" % str(step))
527  self.assertTrue(obj.eventObject.statuses[0] == True,
528  "Step%s >>> Wrong GeneralResponse.statuses[0] value" % str(step))
529  self.assertTrue(obj.eventObject.statuses[1] == True,
530  "Step%s >>> Wrong GeneralResponse.statuses[1] value" % str(step))
531  self.assertTrue(obj.eventObject.statuses[2] == False,
532  "Step%s >>> Wrong GeneralResponse.statuses[2] value" % str(step))
533  self.assertTrue(obj.eventObject.statuses[3] == True,
534  "Step%s >>> Wrong GeneralResponse.statuses[3] value" % str(step))
535 
536 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep11()

def ftests.ftest_DBTask.Test.checkUStep11 (   self,
  obj,
  step 
)

Definition at line 537 of file ftest_DBTask.py.

537  def checkUStep11(self, obj, step):
538  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
539  self.assertTrue(obj.eventType == EVENT_TYPES.URL_CONTENT_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
540  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
541  self.assertTrue(len(obj.eventObject) == 2, "Step%s >>> Bad return object len" % str(step))
542  self.assertTrue(obj.eventObject[0].url ==
543  "http://url1.com/", "Step%s >>> Bad return object[0].url value" % str(step))
544  self.assertTrue(type(obj.eventObject[0].rawContents) == type([]),
545  "Step%s >>> Bad return object[0].rawContent type" % str(step))
546  self.assertTrue(len(obj.eventObject[0].rawContents) == 0,
547  "Step%s >>> Bad return object[0].rawContent len" % str(step))
548  self.assertTrue(obj.eventObject[1].url ==
549  "http://url4.com/", "Step%s >>> Bad return object[1].url value" % str(step))
550  self.assertTrue(type(obj.eventObject[1].rawContents) == type([]),
551  "Step%s >>> Bad return object[1].rawContent type" % str(step))
552  self.assertTrue(len(obj.eventObject[1].rawContents) == 0,
553  "Step%s >>> Bad return object[1].rawContent len" % str(step))
554 
555 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep12()

def ftests.ftest_DBTask.Test.checkUStep12 (   self,
  obj,
  step 
)

Definition at line 556 of file ftest_DBTask.py.

556  def checkUStep12(self, obj, step):
557  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
558  self.assertTrue(obj.eventType == EVENT_TYPES.URL_DELETE_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
559  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
560  "Step%s >>> Bad return object type" % str(step))
561  self.assertTrue(type(obj.eventObject.statuses) == type([]),
562  "Step%s >>> Bad return object.statuses type" % str(step))
563  self.assertTrue(len(obj.eventObject.statuses) == 1, "Step%s >>> Bad return object.statuses len" % str(step))
564  self.assertTrue(obj.eventObject.statuses[0] == True, "Step%s >>> Bad return object.statuses[0] value" % str(step))
565 
566 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep13()

def ftests.ftest_DBTask.Test.checkUStep13 (   self,
  obj,
  step 
)

Definition at line 567 of file ftest_DBTask.py.

567  def checkUStep13(self, obj, step):
568  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
569  self.assertTrue(obj.eventType == EVENT_TYPES.URL_DELETE_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
570  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
571  "Step%s >>> Bad return object type" % str(step))
572  self.assertTrue(type(obj.eventObject.statuses) == type([]),
573  "Step%s >>> Bad return object.statuses type" % str(step))
574  self.assertTrue(len(obj.eventObject.statuses) == 1, "Step%s >>> Bad return object.statuses len" % str(step))
575  self.assertTrue(obj.eventObject.statuses[0] == False, "Step%s >>> Bad return object.statuses[0] value" % str(step))
576 
577 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep14()

def ftests.ftest_DBTask.Test.checkUStep14 (   self,
  obj,
  step 
)

Definition at line 578 of file ftest_DBTask.py.

578  def checkUStep14(self, obj, step):
579  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
580  self.assertTrue(obj.eventType == EVENT_TYPES.URL_CLEANUP_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
581  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
582  "Step%s >>> Bad return object type" % str(step))
583  self.assertTrue(type(obj.eventObject.statuses) == type([]),
584  "Step%s >>> Bad return object.statuses type" % str(step))
585  self.assertTrue(len(obj.eventObject.statuses) == 1, "Step%s >>> Bad return object.statuses len" % str(step))
586  self.assertTrue(obj.eventObject.statuses[0] == False, "Step%s >>> Bad return object.statuses[0] value" % str(step))
587 
588 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep15()

def ftests.ftest_DBTask.Test.checkUStep15 (   self,
  obj,
  step 
)

Definition at line 589 of file ftest_DBTask.py.

589  def checkUStep15(self, obj, step):
590  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
591  self.assertTrue(obj.eventType == EVENT_TYPES.URL_CLEANUP_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
592  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
593  "Step%s >>> Bad return object type" % str(step))
594  self.assertTrue(type(obj.eventObject.statuses) == type([]),
595  "Step%s >>> Bad return object.statuses type" % str(step))
596  self.assertTrue(len(obj.eventObject.statuses) == 1, "Step%s >>> Bad return object.statuses len" % str(step))
597  self.assertTrue(obj.eventObject.statuses[0] == False, "Step%s >>> Bad return object.statuses[0] value" % str(step))
598 
599 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep16()

def ftests.ftest_DBTask.Test.checkUStep16 (   self,
  obj,
  step 
)

Definition at line 600 of file ftest_DBTask.py.

600  def checkUStep16(self, obj, step):
601  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
602  self.assertTrue(obj.eventType == EVENT_TYPES.URL_FETCH_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
603  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
604  self.assertTrue(len(obj.eventObject) == 1, "Step%s >>> Bad return object len" % str(step))
605  self.assertTrue(obj.eventObject[0].siteId == "z2", "Step%s >>> Bad return object[0].siteId value" % str(step))
606  self.assertTrue(obj.eventObject[0].url ==
607  "http://url3.com/", "Step%s >>> Bad return object[0].url value" % str(step))
608 
609 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep17()

def ftests.ftest_DBTask.Test.checkUStep17 (   self,
  obj,
  step 
)

Definition at line 610 of file ftest_DBTask.py.

610  def checkUStep17(self, obj, step):
611  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
612  self.assertTrue(obj.eventType == EVENT_TYPES.URL_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
613  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
614  self.assertTrue(len(obj.eventObject) == 2, "Step%s >>> Bad return object len" % str(step))
615  self.assertTrue(obj.eventObject[0].siteId == "z1", "Step%s >>> Bad return object[0].siteId value" % str(step))
616  self.assertTrue(obj.eventObject[0].url ==
617  "http://url2.com/", "Step%s >>> Bad return object[0].url value" % str(step))
618  self.assertTrue(obj.eventObject[1].siteId == "z2", "Step%s >>> Bad return object[1].siteId value" % str(step))
619  self.assertTrue(obj.eventObject[1].url ==
620  "http://url3.com/", "Step%s >>> Bad return object[0].url value" % str(step))
621 
622 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep2()

def ftests.ftest_DBTask.Test.checkUStep2 (   self,
  obj,
  step 
)

Definition at line 416 of file ftest_DBTask.py.

416  def checkUStep2(self, obj, step):
417  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
418  self.assertTrue(obj.eventType == EVENT_TYPES.URL_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
419  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
420  self.assertTrue(len(obj.eventObject) == 1, "Step%s >>> Bad return object len" % str(step))
421  self.assertTrue(obj.eventObject[0].siteId == "z1", "Step%s >>> Bad return object [0].siteId value" % str(step))
422 
423 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep3()

def ftests.ftest_DBTask.Test.checkUStep3 (   self,
  obj,
  step 
)

Definition at line 424 of file ftest_DBTask.py.

424  def checkUStep3(self, obj, step):
425  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
426  self.assertTrue(obj.eventType == EVENT_TYPES.URL_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
427  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
428  self.assertTrue(len(obj.eventObject) == 0, "Step%s >>> Bad return object len" % str(step))
429 
430 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep4()

def ftests.ftest_DBTask.Test.checkUStep4 (   self,
  obj,
  step 
)

Definition at line 431 of file ftest_DBTask.py.

431  def checkUStep4(self, obj, step):
432  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
433  self.assertTrue(obj.eventType == EVENT_TYPES.URL_FETCH_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
434  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
435  self.assertTrue(len(obj.eventObject) == 1, "Step%s >>> Bad return object len" % str(step))
436  self.assertTrue(obj.eventObject[0].siteId == "z1", "Step%s >>> Bad return object [0].siteId value" % str(step))
437 
438 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep5()

def ftests.ftest_DBTask.Test.checkUStep5 (   self,
  obj,
  step 
)

Definition at line 439 of file ftest_DBTask.py.

439  def checkUStep5(self, obj, step):
440  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
441  self.assertTrue(obj.eventType == EVENT_TYPES.URL_FETCH_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
442  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
443  self.assertTrue(len(obj.eventObject) == 0, "Step%s >>> Bad return object len" % str(step))
444 
445 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep6()

def ftests.ftest_DBTask.Test.checkUStep6 (   self,
  obj,
  step 
)

Definition at line 446 of file ftest_DBTask.py.

446  def checkUStep6(self, obj, step):
447  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
448  self.assertTrue(obj.eventType == EVENT_TYPES.URL_NEW_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
449  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
450  "Step%s >>> Bad return object type" % str(step))
451  self.assertTrue(obj.eventObject.errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK,
452  "Step%s >>> GeneralResponse come error" % str(step))
453 
454 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep7()

def ftests.ftest_DBTask.Test.checkUStep7 (   self,
  obj,
  step 
)

Definition at line 455 of file ftest_DBTask.py.

455  def checkUStep7(self, obj, step):
456  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
457  self.assertTrue(obj.eventType == EVENT_TYPES.URL_NEW_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
458  self.assertTrue(type(obj.eventObject) == dtm.EventObjects.GeneralResponse,
459  "Step%s >>> Bad return object type" % str(step))
460  self.assertTrue(obj.eventObject.errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK,
461  "Step%s >>> GeneralResponse come error" % str(step))
462 
463 
dtm.EventObjects.GeneralResponse
GeneralResponse event object, represents general state response for multipurpose usage.
Definition: EventObjects.py:561
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep8()

def ftests.ftest_DBTask.Test.checkUStep8 (   self,
  obj,
  step 
)

Definition at line 464 of file ftest_DBTask.py.

464  def checkUStep8(self, obj, step):
465  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
466  self.assertTrue(obj.eventType == EVENT_TYPES.URL_STATUS_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
467  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
468  self.assertTrue(len(obj.eventObject) == 2, "Step%s >>> Bad return object len" % str(step))
469  self.assertTrue(obj.eventObject[0].siteId == "z1", "Step%s >>> Bad return object[0].siteId value" % str(step))
470  self.assertTrue(obj.eventObject[0].url ==
471  "http://url2.com/", "Step%s >>> Bad return object[0].url value" % str(step))
472 
473  self.assertTrue(type(obj.eventObject[0].UDate) == str, "Step%s >>> Wrong 'UDate' field type" % str(step))
474  self.assertTrue(type(obj.eventObject[0].CDate) == str, "Step%s >>> Wrong 'CDate' field type" % str(step))
475  self.assertTrue(type(obj.eventObject[0].lastModified) == str,
476  "Step%s >>> Wrong 'lastModified' field type" % str(step))
477  self.assertTrue(obj.eventObject[0].tcDate == None, "Step%s >>> Wrong 'tcDate' field type" % str(step))
478 
479  self.assertTrue(obj.eventObject[1].siteId == "z2", "Step%s >>> Bad return object[1].siteId value" % str(step))
480  self.assertTrue(obj.eventObject[1].url ==
481  "http://url3.com/", "Step%s >>> Bad return object10].url value" % str(step))
482 
483  self.assertTrue(type(obj.eventObject[1].UDate) == str, "Step%s >>> Wrong 'UDate' field type" % str(step))
484  self.assertTrue(type(obj.eventObject[1].CDate) == str, "Step%s >>> Wrong 'CDate' field type" % str(step))
485  self.assertTrue(type(obj.eventObject[1].lastModified) == str,
486  "Step%s >>> Wrong 'lastModified' field type" % str(step))
487  self.assertTrue(obj.eventObject[1].tcDate == None, "Step%s >>> Wrong 'tcDate' field type" % str(step))
488 
489 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkUStep9()

def ftests.ftest_DBTask.Test.checkUStep9 (   self,
  obj,
  step 
)

Definition at line 490 of file ftest_DBTask.py.

490  def checkUStep9(self, obj, step):
491  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
492  self.assertTrue(obj.eventType == EVENT_TYPES.URL_FETCH_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
493  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
494  self.assertTrue(len(obj.eventObject) == 3, "Step%s >>> Bad return object len" % str(step))
495  self.assertTrue(obj.eventObject[0].siteId == "z1", "Step%s >>> Bad return object[0].siteId value" % str(step))
496  self.assertTrue(obj.eventObject[0].url ==
497  "http://url1.com/", "Step%s >>> Bad return object[0].url value" % str(step))
498  self.assertTrue(obj.eventObject[0].UDate == None, "Step%s >>> Wrong 'UDate' field type" % str(step))
499  self.assertTrue(type(obj.eventObject[0].CDate) == str, "Step%s >>> Wrong 'CDate' field type" % str(step))
500  self.assertTrue(obj.eventObject[0].lastModified == None,
501  "Step%s >>> Wrong 'lastModified' field type" % str(step))
502  self.assertTrue(obj.eventObject[0].tcDate == None, "Step%s >>> Wrong 'tcDate' field type" % str(step))
503  self.assertTrue(obj.eventObject[1].siteId == "z1", "Step%s >>> Bad return object[1].siteId value" % str(step))
504  self.assertTrue(obj.eventObject[1].url ==
505  "http://url2.com/", "Step%s >>> Bad return object[1].url value" % str(step))
506  self.assertTrue(type(obj.eventObject[1].UDate) == str, "Step%s >>> Wrong 'UDate' field type" % str(step))
507  self.assertTrue(type(obj.eventObject[1].CDate) == str, "Step%s >>> Wrong 'CDate' field type" % str(step))
508  self.assertTrue(type(obj.eventObject[1].lastModified) == str,
509  "Step%s >>> Wrong 'lastModified' field type" % str(step))
510  self.assertTrue(obj.eventObject[1].tcDate == None, "Step%s >>> Wrong 'tcDate' field type" % str(step))
511  self.assertTrue(obj.eventObject[2].siteId == "z2", "Step%s >>> Bad return object[2].siteId value" % str(step))
512  self.assertTrue(obj.eventObject[2].url ==
513  "http://url3.com/", "Step%s >>> Bad return object[2].url value" % str(step))
514  self.assertTrue(type(obj.eventObject[2].UDate) == str, "Step%s >>> Wrong 'UDate' field type" % str(step))
515  self.assertTrue(type(obj.eventObject[2].CDate) == str, "Step%s >>> Wrong 'CDate' field type" % str(step))
516  self.assertTrue(type(obj.eventObject[2].lastModified) == str,
517  "Step%s >>> Wrong 'lastModified' field type" % str(step))
518  self.assertTrue(obj.eventObject[2].tcDate == None, "Step%s >>> Wrong 'tcDate' field type" % str(step))
519 
520 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ checkVerify()

def ftests.ftest_DBTask.Test.checkVerify (   self,
  obj,
  step 
)

Definition at line 1063 of file ftest_DBTask.py.

1063  def checkVerify(self, obj, step):
1064  self.assertTrue(type(obj) == dc.Constants.DRCESyncTasksCover, "Step%s >>> Bad return type" % str(step))
1065  self.assertTrue(obj.eventType == EVENT_TYPES.URL_VERIFY_RESPONSE, "Step%s >>> Bad return Event type" % str(step))
1066  self.assertTrue(type(obj.eventObject) == type([]), "Step%s >>> Bad return object type" % str(step))
1067  self.assertTrue(len(obj.eventObject) == 7, "Step%s >>> Bad return object len" % str(step))
1068  self.assertTrue(obj.eventObject[0] is not None, "Step%s >>> Bad return object eventObject[0]" % str(step))
1069  self.assertTrue(obj.eventObject[1] is not None, "Step%s >>> Bad return object eventObject[1]" % str(step))
1070  self.assertTrue(obj.eventObject[2] is None, "Step%s >>> Bad return object eventObject[2]" % str(step))
1071  self.assertTrue(obj.eventObject[3] is None, "Step%s >>> Bad return object eventObject[3]" % str(step))
1072  self.assertTrue(obj.eventObject[4] is not None, "Step%s >>> Bad return object eventObject[4]" % str(step))
1073  self.assertTrue(obj.eventObject[5] is not None, "Step%s >>> Bad return object eventObject[5]" % str(step))
1074  self.assertTrue(obj.eventObject[6] is None, "Step%s >>> Bad return object eventObject[6]" % str(step))
1075 
1076 
integrity-urlContent.type
type
Definition: integrity-urlContent.py:27

◆ execCommand()

def ftests.ftest_DBTask.Test.execCommand (   self,
  command,
  step 
)

Definition at line 283 of file ftest_DBTask.py.

283  def execCommand(self, command, step):
284  obj = None
285  print ">>> Start = " + str(command)
286  fd = os.popen(command)
287  if fd:
288  localStr = fd.read()
289  fd.close()
290  print ">>> Finish = " + str(command)
291  try:
292  obj = pickle.loads(localStr)
293  except EOFError:
294  self.assertTrue(False, "Step%s >>> Invalid return data" % str(step))
295  else:
296  print ">>> Bad FD " + + str(command)
297  return obj
298 
299 
Here is the caller graph for this function:

◆ fileCreate()

def ftests.ftest_DBTask.Test.fileCreate (   self,
  directory,
  fName,
  data 
)

Definition at line 1094 of file ftest_DBTask.py.

1094  def fileCreate(self, directory, fName, data):
1095  time.sleep(0.3)
1096  fd = open(directory + "/" + fName, "w")
1097  fd.write(data)
1098  fd.close()
1099 
1100 
Here is the caller graph for this function:

◆ makeContent()

def ftests.ftest_DBTask.Test.makeContent (   self)

Definition at line 1101 of file ftest_DBTask.py.

1101  def makeContent(self):
1102  savePath = os.getcwd()
1103  os.chdir(self.CD_PATH)
1104  configParser = ConfigParser.ConfigParser()
1105  configParser.read("../ini/db-task.ini")
1106  keyValueStorageDir = configParser.get(self.CLASS_NAME, self.KEY_VALUE_STORAGE_DIR)
1107  rawDataDir = configParser.get(self.CLASS_NAME, self.RAW_DATA_DIR)
1108  print(keyValueStorageDir + "\n" + rawDataDir)
1109 # Files creating
1110  dataDir = rawDataDir + "/" + self.siteId +"/"+ PathMaker(self.urlMd5).getDir()
1111  try:
1112  os.makedirs(dataDir)
1113  except Exception:
1114  print ">>>---- "+ str(dataDir) + " path already exist !!!"
1115  self.fileCreate(dataDir, "A1.bin", "AAAAA")
1116  self.fileCreate(dataDir, "A1.headers.txt", "AAAAAheaders")
1117  self.fileCreate(dataDir, "A1.requests.txt", "AAAAArequests")
1118  self.fileCreate(dataDir, "A1.meta.txt", "AAAAAmeta")
1119  self.fileCreate(dataDir, "A1.cookies.txt", "AAAAAcookies")
1120  self.fileCreate(dataDir, "A1.tidy", "AAATIDY")
1121  self.fileCreate(dataDir, "B1.bin", "BBBBB")
1122  self.fileCreate(dataDir, "B1.headers.txt", "BBBBBheaders")
1123  self.fileCreate(dataDir, "B1.cookies.txt", "BBBBBcookies")
1124  self.fileCreate(dataDir, "C1.bin", "CCCCC")
1125  self.fileCreate(dataDir, "C1.headers.txt", "CCCCCheaders")
1126  self.fileCreate(dataDir, "C1.requests.txt", "CCCCCrequests")
1127  self.fileCreate(dataDir, "C1.meta.txt", "CCCCCmeta")
1128  self.fileCreate(dataDir, "C1.cookies.txt", "CCCCCcookies")
1129  self.fileCreate(dataDir, "D1.meta.txt", "DDDDDmeta")
1130  self.fileCreate(dataDir, "E1.bin", "EEEEE")
1131  self.fileCreate(dataDir, "arash.tidy", "ArashTIDY")
1132  self.fileCreate(dataDir, "arash.dyn", "AAADYN")
1133 # KV_DB creating
1134  localUrlContent = dc.EventObjects.URLContentRequest(0, "http")
1135  localUrlMD5 = localUrlContent.fillMD5(self.url)
1136  if self.contentType == dc_db.Constants.DB_DATA_KVDB:
1137  dbName = dc_db.Constants.KEY_VALUE_FILE_NAME_TEMPLATE % self.siteId
1138  dbFileName = keyValueStorageDir + "/" + dbName
1139  INSERT_SQL = "INSERT INTO `articles` (Id, Data, CDate) VALUES('%s', '%s', %s)"
1140  query = INSERT_SQL % (localUrlMD5, "EEEEE", str(int(time.time())))
1141  if os.path.exists(dbFileName):
1142  dbConnect = sqlite3.connect(dbFileName)
1143  dbConnect.text_factory = str
1144  cursor = dbConnect.cursor()
1145  cursor.execute(query)
1146  dbConnect.commit()
1147  elif self.contentType == dc_db.Constants.DB_DATA_MYSQL:
1148  print ">>>> CREATE MYSQL !!!"
1149  mysqlConnUrl = mdb.connect("192.168.253.113", "hce", "hce12345", "dc_contents", 3306)
1150  bdName = "contents_%s" % self.siteId
1151  CREATE_SQL = "CREATE TABLE IF NOT EXISTS `%s` (`id` varchar(32) NOT NULL DEFAULT '\"\"', \
1152  `data` BLOB NOT NULL, `CDate` datetime DEFAULT NULL, KEY `id` (`id`), KEY `CDate` (`CDate`)) \
1153  ENGINE=MyISAM DEFAULT CHARSET=utf8"
1154  query = CREATE_SQL % bdName
1155  INSERT_SQL = "INSERT INTO `%s` (Id, Data, CDate) VALUES('%s', '%s', %s)"
1156  query1 = INSERT_SQL % (bdName, localUrlMD5, "EEEEE", "NOW()")
1157  if mysqlConnUrl is not None:
1158  with closing(mysqlConnUrl.cursor()) as cursor:
1159  cursor.execute(query)
1160  mysqlConnUrl.commit()
1161  cursor.execute(query1)
1162  mysqlConnUrl.commit()
1163  else:
1164  print ">>>> WRONG DB_CONTENT CONNECTION !!!"
1165  os.chdir(savePath)
1166 
dc.EventObjects.URLContentRequest
Definition: EventObjects.py:890
Here is the call graph for this function:

◆ setUp()

def ftests.ftest_DBTask.Test.setUp (   self)

Definition at line 273 of file ftest_DBTask.py.

273  def setUp(self):
274  self.url = None
275  self.siteId = None
276  self.urlMd5 = None
277 
278 

◆ tearDown()

def ftests.ftest_DBTask.Test.tearDown (   self)

Definition at line 279 of file ftest_DBTask.py.

279  def tearDown(self):
280  pass
281 
282 

◆ test_22_UrlPutTest()

def ftests.ftest_DBTask.Test.test_22_UrlPutTest (   self)

Definition at line 1602 of file ftest_DBTask.py.

1602  def test_22_UrlPutTest(self):
1603  self.mutex.acquire()
1604  print "test_22_UrlPutTest"
1605  self.execCommand(CMD_UNEW_PUT, 0)
1606  self.execCommand(CMD_UPUT, 1)
1607  self.execCommand(CMD_UPUT1, 2)
1608  print "test_22_UrlPutTest FN"
1609  self.mutex.release()
1610 
1611 
Here is the call graph for this function:

Member Data Documentation

◆ CD_PATH

string ftests.ftest_DBTask.Test.CD_PATH = "../../bin"
static

Definition at line 265 of file ftest_DBTask.py.

◆ CLASS_NAME

string ftests.ftest_DBTask.Test.CLASS_NAME = "TasksManager"
static

Definition at line 266 of file ftest_DBTask.py.

◆ contentType

ftests.ftest_DBTask.Test.contentType = dc_db.Constants.DB_DATA_MYSQL
static

Definition at line 270 of file ftest_DBTask.py.

◆ KEY_VALUE_STORAGE_DIR

string ftests.ftest_DBTask.Test.KEY_VALUE_STORAGE_DIR = "key_value_storage_dir"
static

Definition at line 267 of file ftest_DBTask.py.

◆ mutex

ftests.ftest_DBTask.Test.mutex = threading.Lock()
static

Definition at line 269 of file ftest_DBTask.py.

◆ RAW_DATA_DIR

string ftests.ftest_DBTask.Test.RAW_DATA_DIR = "raw_data_dir"
static

Definition at line 268 of file ftest_DBTask.py.

◆ siteId

ftests.ftest_DBTask.Test.siteId

Definition at line 275 of file ftest_DBTask.py.

◆ url

ftests.ftest_DBTask.Test.url

Definition at line 274 of file ftest_DBTask.py.

◆ urlMd5

ftests.ftest_DBTask.Test.urlMd5

Definition at line 276 of file ftest_DBTask.py.

The documentation for this class was generated from the following file: