git.useribm.hu - mediacube.git/blob

   1 package hu.user.mediacube.executors.tests;\r
   2 \r
   3 import static org.junit.Assert.assertNotNull;\r
   4 import static org.junit.Assert.assertNull;\r
   5 \r
   6 import java.nio.file.Files;\r
   7 import java.nio.file.Paths;\r
   8 import java.util.LinkedHashSet;\r
   9 import java.util.List;\r
  10 \r
  11 import org.junit.BeforeClass;\r
  12 import org.junit.Test;\r
  13 \r
  14 import com.ibm.nosql.json.api.BasicDBObject;\r
  15 \r
  16 import user.jobengine.server.steps.HSMMigrateStep;\r
  17 import user.mediacube.metadata.MetadataProviderFactory;\r
  18 import user.mediacube.metadata.interfaces.IMetadataProvider;\r
  19 import user.mediacube.metadata.interfaces.IMetadataProviderFactory;\r
  20 import user.mediacube.metadata.interfaces.MetadataProviderType;\r
  21 \r
  22 public class HSMMigrateStepTest {\r
  23 \r
  24         @BeforeClass\r
  25         static public void setUpConnection() {\r
  26                 System.setProperty("jobengine.nosql.db.url", "jdbc:db2://10.11.1.90:50000/mc:retrieveMessagesFromServerOnGetMessage=true;");\r
  27                 System.setProperty("jobengine.nosql.db.user", "db2admin");\r
  28                 System.setProperty("jobengine.nosql.db.password", "password");\r
  29         }\r
  30 \r
  31         @Test\r
  32         public void createMigrateReport() throws Exception {\r
  33                 LinkedHashSet<Object> success = new LinkedHashSet<>();\r
  34                 List<String> migrated = Files.readAllLines(Paths.get("/opt/MV-migrate-status/migrated.txt"));\r
  35                 System.out.println("Starting");\r
  36                 for (String m : migrated) {\r
  37                         String name = m.trim();\r
  38                         int indexOf = name.indexOf("-");\r
  39                         if (indexOf > -1) {\r
  40                                 name = name.substring(9);\r
  41                                 if (success.contains(name))\r
  42                                         System.out.println("Error " + m.trim());\r
  43                                 else\r
  44                                         success.add(name);\r
  45                         }\r
  46                         //                      System.out.println(name);\r
  47                 }\r
  48 \r
  49                 List<String> tomigrate = Files.readAllLines(Paths.get("/opt/MV-migrate-status/to-migrate.txt"));\r
  50                 int nosuccesscount = 0;\r
  51                 for (String t : tomigrate) {\r
  52                         String name = t.trim();\r
  53                         name = name.substring(2);\r
  54                         int indexOf = name.indexOf(".");\r
  55                         if (indexOf > -1) {\r
  56                                 indexOf = name.lastIndexOf("/");\r
  57                                 name = name.substring(indexOf + 1);\r
  58                                 if (!success.contains(name)) {\r
  59                                         System.out.println(name);\r
  60                                         nosuccesscount++;\r
  61                                 }\r
  62                         }\r
  63                 }\r
  64 \r
  65                 System.out.println("Success " + migrated.size());\r
  66                 System.out.println("No success " + nosuccesscount);\r
  67                 System.out.println(100 - (nosuccesscount * 100 / migrated.size()));\r
  68 \r
  69         }\r
  70 \r
  71         private HSMMigrateStep createSUT() {\r
  72                 HSMMigrateStep sut = new HSMMigrateStep() {\r
  73                         @Override\r
  74                         protected IMetadataProvider getMetadataProvider(MetadataProviderType type) {\r
  75                                 IMetadataProviderFactory factory = new MetadataProviderFactory();\r
  76                                 return factory.getProvider(type);\r
  77                         }\r
  78                 };\r
  79                 return sut;\r
  80         }\r
  81 \r
  82         @Test\r
  83         public void testExecute() throws Exception {\r
  84                 HSMMigrateStep sut = createSUT();\r
  85                 sut.execute("//10.11.1.89", "/_video/migrate");\r
  86                 //              System.out.println(Arrays.toString(sut));\r
  87         }\r
  88 \r
  89         @Test\r
  90         public void testQueryException_FileNameExclude() throws Exception {\r
  91                 HSMMigrateStep sut = new HSMMigrateStep();\r
  92                 BasicDBObject actual = sut.queryExclude("12-90670-0012");\r
  93                 assertNotNull(actual);\r
  94         }\r
  95 \r
  96         @Test\r
  97         public void testQueryException_FullPathExclude() throws Exception {\r
  98                 HSMMigrateStep sut = new HSMMigrateStep();\r
  99                 BasicDBObject actual = sut.queryExclude("/gpfs/OMARCHIVE/2011-mxf/11-01771-0002-2.mxf");\r
 100                 assertNotNull(actual);\r
 101         }\r
 102 \r
 103         @Test\r
 104         public void testQueryException_NoException() throws Exception {\r
 105                 HSMMigrateStep sut = new HSMMigrateStep();\r
 106                 BasicDBObject actual = sut.queryExclude("test.mxf");\r
 107                 assertNull(actual);\r
 108         }\r
 109 \r
 110         @Test\r
 111         public void testQueryHistory() throws Exception {\r
 112                 HSMMigrateStep sut = new HSMMigrateStep();\r
 113                 BasicDBObject actual = sut.queryFileHistory("/OMARCHIVE/6.3.4.200-TIV-TSMALL-Linuxx86_64.bin");\r
 114                 assertNotNull(actual);\r
 115         }\r
 116 \r
 117         @Test\r
 118         public void testResumableCopy() throws Exception {\r
 119                 HSMMigrateStep sut = new HSMMigrateStep();\r
 120                 Paths.get("c:/_video/03c.mp4").toFile().delete();\r
 121                 //sut.copyChunk(Paths.get("c:/_video/1.txt"), Paths.get("c:/_video/2.txt"), 5);\r
 122                 sut.resumeableCopy(Paths.get("c:/_video/1.txt"), Paths.get("c:/_video/2.txt"));\r
 123         }\r
 124 }\r