b974797f27b534a1fb7132664707fad585054046
[mediacube.git] /
1 package user.jobengine.server.steps;\r
2 \r
3 import java.io.OutputStream;\r
4 import java.net.InetAddress;\r
5 import java.net.URI;\r
6 import java.util.ArrayList;\r
7 import java.util.Arrays;\r
8 import java.util.Calendar;\r
9 import java.util.Date;\r
10 import java.util.List;\r
11 \r
12 import org.apache.commons.lang.StringUtils;\r
13 import org.apache.commons.net.ftp.FTP;\r
14 import org.apache.commons.net.ftp.FTPClient;\r
15 import org.apache.commons.net.ftp.FTPReply;\r
16 import org.apache.logging.log4j.LogManager;\r
17 import org.apache.logging.log4j.Logger;\r
18 import org.apache.logging.log4j.Marker;\r
19 \r
20 import com.ibm.nosql.json.api.BasicDBObject;\r
21 import com.ibm.nosql.json.api.DB;\r
22 import com.ibm.nosql.json.api.DBCollection;\r
23 import com.ibm.nosql.json.api.DBCursor;\r
24 import com.ibm.nosql.json.api.DBObject;\r
25 \r
26 import user.commons.CalendarUtils;\r
27 import user.commons.ListUtils;\r
28 import user.commons.StoreUri;\r
29 import user.commons.configuration.SystemConfiguration;\r
30 import user.commons.nosql.NoSQLUtils;\r
31 import user.commons.octopus.IOctopusAPI;\r
32 import user.commons.octopus.OctopusAPI;\r
33 import user.commons.remotestore.FtpDirectoryLister;\r
34 import user.commons.remotestore.RemoteStoreProtocol;\r
35 import user.jobengine.db.IItemManager;\r
36 import user.jobengine.server.IJobEngine;\r
37 import user.jobengine.server.IJobRuntime;\r
38 import user.jobengine.server.steps.shared.EscortFiles;\r
39 import user.jobengine.server.steps.shared.ItemManagerExtensions;\r
40 import user.jobengine.server.steps.shared.MetadataType;\r
41 import user.jobengine.server.steps.shared.MetadataTypeDetector;\r
42 \r
43 public class CopyForArchiveNEXIOMaterialsStep extends JobStep {\r
44         private static final String SCHEDULED_FORMAT = "yyyy.MM.dd HH:mm";\r
45         private static final Logger logger = LogManager.getLogger();\r
46         private static final String UTF_8 = "utf-8";\r
47         private static final String JSON_EXT = ".json";\r
48         private static final String XML_EXT = ".xml";\r
49         private static final String DURATION = "duration";\r
50         private static final String MXFEXT = ".MXF";\r
51         private static final String NEXIOCLIPS = "nexioclips";\r
52         private static final String LONGNAMEID = "longnameid";\r
53         private static final String ARCHIVEDRUNDOWNS = "archivedrundowns";\r
54         private static final String ID = "id";\r
55         private static final String MEDIATYPE = "Hír bejátszó";\r
56         private static String NEXIO_HOST = SystemConfiguration.getInstance().value("services.nexio.host");\r
57         private OctopusAPI octopusAPI;\r
58         private IItemManager manager;\r
59 \r
60         private DB db;\r
61         private FTPClient sourceFtp;\r
62         private FTPClient targetFtp;\r
63         private StoreUri sourceUri;\r
64         private StoreUri targetUri;\r
65         private int nexioKillDateDays;\r
66         private String nexioAgency;\r
67         private Marker systemMarker;\r
68         private List<String> transferredFileNames = null;\r
69         private boolean demo = false;\r
70 \r
71         private int check(int value, String name) {\r
72                 if (value == 0) {\r
73                         logger.error(systemMarker, "A folyamat '{}' bemeneti paramétere 0.", name);\r
74                         throw new NullPointerException(String.format("System is not configured properly, missing '%s' input parameter.", name));\r
75                 }\r
76                 return value;\r
77         }\r
78 \r
79         private String check(String value, String name) {\r
80                 if (value == null) {\r
81                         logger.error(systemMarker, "A folyamat '{}' bemeneti paramétere üres.", name);\r
82                         throw new NullPointerException(String.format("System is not configured properly, missing '%s' input parameter.", name));\r
83                 }\r
84                 return value;\r
85         }\r
86 \r
87         private void copy(RundownArchive rundownArchive) throws Exception {\r
88                 for (StoryArchive storyArchive : rundownArchive.getStoryArchives()) {\r
89                         for (FileArchive fileArchive : storyArchive.getFileArchives()) {\r
90                                 try {\r
91                                         copyFile(fileArchive, rundownArchive, storyArchive);\r
92                                 } catch (Exception e) {\r
93                                         logger.error(systemMarker, "A '{}' clip archiválása sikertelen. A rendszer üzenete: {}", fileArchive.getFileName(), e.getMessage());\r
94                                         throw e;\r
95                                 }\r
96                         }\r
97                 }\r
98         }\r
99 \r
100         private void copyFile(FileArchive fileArchive, RundownArchive rundownArchive, StoryArchive storyArchive) throws Exception {\r
101                 String origFileName = fileArchive.getFileName();\r
102                 String fileName = String.format("%s-%s", origFileName, rundownArchive.getItemHouseId());\r
103                 String videoFileName = fileName + MXFEXT;\r
104 \r
105                 if (transferredFileNames == null)\r
106                         transferredFileNames = new ArrayList<>();\r
107 \r
108                 //A mar letezo mozikat nem archivaljuk le ujra, csak a metaadatot\r
109                 long existingMediaId = 0;\r
110                 boolean transferDone = false;\r
111                 if (transferredFileNames.contains(origFileName)) {\r
112                         logger.info(systemMarker, "A '{}' file archiválásra felkészítése egy másik story kapcsán már megtörtént, ezért csak metaadat archiválás szükséges.",\r
113                                         origFileName);\r
114                         if (!demo)\r
115                                 transferDone = transferChunk(videoFileName);\r
116                 } else {\r
117                         existingMediaId = ItemManagerExtensions.getExistingRundownMedia(manager, origFileName);\r
118                         if (existingMediaId == 0) {\r
119                                 transferredFileNames.add(origFileName);\r
120                                 if (!demo)\r
121                                         transferDone = transferFile(origFileName + MXFEXT, videoFileName);\r
122                                 logger.info(systemMarker, "A '{}' file archiválásra felkészítése sikeres volt.", origFileName);\r
123                         } else {\r
124 \r
125                                 logger.info(systemMarker, "A '{}' file archiválása már megtörtént, ezért csak metaadat archiválás szükséges.", origFileName);\r
126                                 if (!demo)\r
127                                         transferDone = transferChunk(videoFileName);\r
128                         }\r
129                 }\r
130 \r
131                 if (!demo && transferDone) {\r
132                         BasicDBObject metadata = createMetadata(rundownArchive, storyArchive, fileArchive, existingMediaId);\r
133                         transferMetadata(videoFileName, metadata);\r
134                         createSourceKillDateFile(rundownArchive, origFileName);\r
135                 }\r
136         }\r
137 \r
138         private BasicDBObject createMetadata(RundownArchive rundownArchive, StoryArchive storyArchive, FileArchive fileArchive, long existingMediaId) {\r
139                 BasicDBObject result = new BasicDBObject();\r
140                 result.put("itemHouseId", rundownArchive.getItemHouseId());\r
141                 result.put("itemTitle", rundownArchive.getItemTitle());\r
142                 result.put("itemDescription", rundownArchive.getItemDesc());\r
143                 result.put("userName", "mediacube");\r
144                 result.put("mediaHouseId", storyArchive.getMediaHouseId());\r
145                 result.put("mediaTitle", storyArchive.getMediaTitle());\r
146                 result.put("mediaDescription", storyArchive.getMediaDesc());\r
147                 result.put("mediaType", MEDIATYPE);\r
148                 result.put("duration", fileArchive.getDuration());\r
149                 result.put("existingMediaId", existingMediaId);\r
150                 return result;\r
151         }\r
152 \r
153         private void createSourceKillDateFile(RundownArchive rundownArchive, String fileName) throws Exception {\r
154                 logger.info("Create killdate/agency for {}", fileName);\r
155                 OutputStream outStream = null;\r
156                 try {\r
157                         sourceFtp = ((FtpDirectoryLister) sourceUri.getLister()).connect();\r
158                         Calendar killDate = CalendarUtils.createCalendar(rundownArchive.getScheduleDate());\r
159                         killDate.add(Calendar.DAY_OF_YEAR, nexioKillDateDays);\r
160                         byte[] killDateFile = EscortFiles.createNEXIOKillDateFile(fileName, killDate.getTime(), null, nexioAgency);\r
161                         outStream = sourceFtp.storeFileStream(fileName + XML_EXT);\r
162                         if (outStream == null) {\r
163                                 throw new NullPointerException("Can not open: " + fileName + XML_EXT + " Reply:" + sourceFtp.getReplyString());\r
164                         }\r
165                         outStream.write(killDateFile);\r
166                         outStream.flush();\r
167                 } catch (Exception e) {\r
168                         logger.catching(e);\r
169                         throw e;\r
170                 } finally {\r
171                         if (outStream != null)\r
172                                 outStream.close();\r
173                         sourceUri.cleanUp();\r
174                 }\r
175         }\r
176 \r
177         @StepEntry\r
178         public Object[] execute(int nexioPort, String nexioUserName, String nexioPassword, String archiveFtp, String archiveUserName, String archivePassword,\r
179                         int daysBeforeNow, int nexioKillDateDays, String nexioAgency, IJobEngine jobEngine, IJobRuntime jobRuntime) throws Exception {\r
180                 systemMarker = getMarker();\r
181                 logger.info(systemMarker, "test");\r
182                 setAndCheck(nexioPort, nexioUserName, nexioPassword, archiveFtp, archiveUserName, archivePassword, nexioKillDateDays, nexioAgency, jobEngine);\r
183                 octopusAPI = new OctopusAPI();\r
184                 Calendar scheduledDate = Calendar.getInstance();\r
185                 scheduledDate.add(Calendar.DAY_OF_YEAR, -1 * daysBeforeNow);\r
186                 List<DBObject> rundowns = octopusAPI.getRundowns(scheduledDate.getTime());\r
187                 if (rundowns == null) {\r
188                         logger.warn(systemMarker, "Nem található adástükör a {} napra.", CalendarUtils.toDateString(scheduledDate));\r
189                         return null;\r
190                 }\r
191 \r
192                 processRundowns(rundowns);\r
193                 return null;\r
194         }\r
195 \r
196         //      private String getVersionedFileName(String fileName, String extension) throws Exception {\r
197         //              String result = fileName;\r
198         //              try {\r
199         //                      targetFtp = ((FtpDirectoryLister) targetUri.getLister()).connect();\r
200         //                      FTPFile[] listFiles = targetFtp.listFiles();\r
201         //                      List<String> fileNames = new ArrayList<>();\r
202         //                      for (FTPFile ftpFile : listFiles) {\r
203         //                              fileNames.add(ftpFile.getName());\r
204         //                      }\r
205         //                      while (fileNames.contains(result + extension)) {\r
206         //\r
207         //                      }\r
208         //\r
209         //              } catch (Exception e) {\r
210         //                      logger.catching(e);\r
211         //                      throw e;\r
212         //              } finally {\r
213         //                      targetUri.cleanUp();\r
214         //              }\r
215         //              return result;\r
216         //      }\r
217 \r
218         private FileArchive processMosObject(BasicDBObject rundown, BasicDBObject story, BasicDBObject mosObject) throws Exception {\r
219                 String mosID = mosObject.getString(IOctopusAPI.OBJ_ID);\r
220                 if (MetadataTypeDetector.GuessMetadataType(mosID) != MetadataType.OctopusPlaceholder) {\r
221                         logger.trace(systemMarker, "Skipping MOS object {}", mosID);\r
222                         return null;\r
223                 }\r
224                 DBCollection clips = db.getCollection(NEXIOCLIPS);\r
225                 BasicDBObject clip = (BasicDBObject) clips.findOne(new BasicDBObject(LONGNAMEID, mosID));\r
226                 if (clip == null) {\r
227                         logger.debug(systemMarker, "File {} NOT exists", mosID);\r
228                         return null;\r
229                         //throw new Exception(String.format("File NOT exists %s", mosID));\r
230                 } else {\r
231                         logger.debug(systemMarker, "File {} exists", mosID);\r
232                 }\r
233                 long duration = NoSQLUtils.asLong(clip, DURATION);\r
234 \r
235                 if (duration == 0) {\r
236                         logger.debug(systemMarker, "File {} exists with 0 frame length", mosID);\r
237                         return null;\r
238                 }\r
239                 if (duration == 1) {\r
240                         logger.debug(systemMarker, "File {} exists with 1 frame length", mosID);\r
241                         return null;\r
242                 }\r
243                 return new FileArchive(mosID, duration);\r
244         }\r
245 \r
246         private RundownArchive processRundow(DBObject r) throws Exception {\r
247                 BasicDBObject rundown = (BasicDBObject) r;\r
248                 long rundownID = rundown.getLong(ID);\r
249                 if (!demo)\r
250                         logger.info(systemMarker, "Processing rundown {} {}", rundownID, rundown.getString(IOctopusAPI.NAME));\r
251                 List<DBObject> stories = octopusAPI.getRundownFullStories(rundownID);\r
252                 if (stories == null)\r
253                         return null;\r
254                 RundownArchive result = new RundownArchive();\r
255 \r
256                 long id = NoSQLUtils.asLong(rundown, IOctopusAPI.ID);\r
257                 if (id == 0)\r
258                         return null;\r
259                 String name = NoSQLUtils.asString(NoSQLUtils.asDBObject(rundown, IOctopusAPI.RUNDOWN_TYPE), IOctopusAPI.NAME);\r
260                 if (StringUtils.isBlank(name))\r
261                         return null;\r
262                 String channel = NoSQLUtils.asString(NoSQLUtils.asDBObject(rundown, IOctopusAPI.CHANNEL), IOctopusAPI.NAME);\r
263                 Date scheduledStart = rundown.getDate(IOctopusAPI.SCHEDULED_START);\r
264                 if (scheduledStart == null)\r
265                         return null;\r
266                 String start = CalendarUtils.toString(CalendarUtils.createCalendar(scheduledStart), SCHEDULED_FORMAT);\r
267                 result.setScheduleDate(scheduledStart);\r
268                 result.setItemHouseId(String.valueOf(id));\r
269                 result.setItemTitle(String.format("%s %s %s", start, name, channel));\r
270 \r
271                 for (DBObject s : stories) {\r
272                         StoryArchive storyArchive = processStory(rundown, s);\r
273                         if (storyArchive == null)\r
274                                 continue;\r
275                         result.addStoryArchive(storyArchive);\r
276                 }\r
277                 return result;\r
278         }\r
279 \r
280         private void processRundowns(List<DBObject> rundowns) {\r
281 \r
282                 //TODO kiveni publikálás előtt\r
283                 //db.getCollection(ARCHIVEDRUNDOWNS).drop();\r
284                 List<BasicDBObject> archivedRundowns = queryArchivedRundowns();\r
285 \r
286                 logger.info(systemMarker, "Found {} rundowns to archive", archivedRundowns.size());\r
287                 int index = 1;\r
288 \r
289                 for (DBObject r : rundowns) {\r
290                         BasicDBObject rundown = (BasicDBObject) r;\r
291                         int progress = index * 100 / rundowns.size();\r
292                         setProgress(progress);\r
293                         long rundownID = NoSQLUtils.asLong(rundown, IOctopusAPI.ID);\r
294                         String rundownName = NoSQLUtils.asString(rundown, IOctopusAPI.NAME);\r
295                         try {\r
296                                 BasicDBObject currentRundownID = new BasicDBObject(IOctopusAPI.ID, rundownID);\r
297                                 if (!demo && archivedRundowns != null && archivedRundowns.contains(currentRundownID)) {\r
298                                         logger.info(systemMarker, "Skipping archived rundown {} {}", rundownID, rundownName);\r
299                                         continue;\r
300                                 }\r
301 \r
302                                 RundownArchive rundownArchive = processRundow(r);\r
303                                 if (rundownArchive == null || rundownArchive.isEmpty()) {\r
304                                         if (!demo)\r
305                                                 logger.info(systemMarker, "Skipping rundown {} {}", rundownID, rundownName);\r
306                                         continue;\r
307                                 }\r
308 \r
309                                 if (!demo)\r
310                                         logger.info(systemMarker, "Saving rundown {} {}", rundownID, rundownName);\r
311                                 copy(rundownArchive);\r
312                                 if (!demo)\r
313                                         logger.info(systemMarker, "A '{}' tükör {}db bejátszójának archiválása sikeres volt", rundownArchive.getItemTitle(),\r
314                                                         rundownArchive.getStoryArchives().size());\r
315 \r
316                                 if (!demo)\r
317                                         db.getCollection(ARCHIVEDRUNDOWNS).save(currentRundownID);\r
318                         } catch (Exception e) {\r
319                                 logger.catching(e);\r
320                                 logger.error(systemMarker,\r
321                                                 String.format("A %s %s tükör archiválása nem lehetséges, mert a annak ellenőrzése hibát jelzett. A rendszer üzenete: %s", rundownID,\r
322                                                                 rundownName, e.getMessage()));\r
323                         }\r
324                         index++;\r
325                 }\r
326 \r
327         }\r
328 \r
329         private StoryArchive processStory(BasicDBObject rundown, DBObject s) throws Exception {\r
330                 BasicDBObject story = (BasicDBObject) s;\r
331                 String parentStoryID = story.getString(IOctopusAPI.PARENT_STORY_ID);\r
332                 if (StringUtils.isBlank(parentStoryID)) {\r
333                         logger.warn(systemMarker, "Story parentStoryID is null: {}", story.toPrettyString(null));\r
334                         return null;\r
335                 } else\r
336                         logger.info(systemMarker, "Processing story {}", parentStoryID);\r
337                 List<BasicDBObject> mosObjects = NoSQLUtils.asList(story, IOctopusAPI.MOS_OBJECTS);\r
338                 if (mosObjects == null) {\r
339                         logger.info(systemMarker, "No MOS in story {}: {}", parentStoryID, story.toPrettyString(null));\r
340                         \r
341                         return null;\r
342                 }\r
343                 StoryArchive storyArchive = null;\r
344                 for (BasicDBObject mosObject : mosObjects) {\r
345                         FileArchive fileArchive = processMosObject(rundown, story, mosObject);\r
346                         if (fileArchive == null)\r
347                                 continue;\r
348                         if (storyArchive == null) {\r
349                                 storyArchive = new StoryArchive();\r
350                                 storyArchive.setMediaHouseId(parentStoryID);\r
351                                 storyArchive.setMediaTitle(story.getString(IOctopusAPI.NAME));\r
352                                 storyArchive.setMediaDesc(story.getString(IOctopusAPI.SCRIPT_CONTENT));\r
353 \r
354                         }\r
355                         storyArchive.addFileArchive(fileArchive);\r
356                 }\r
357                 return storyArchive;\r
358 \r
359         }\r
360 \r
361         private List<BasicDBObject> queryArchivedRundowns() {\r
362                 List<BasicDBObject> result = null;\r
363                 DBCollection collection = db.getCollection(ARCHIVEDRUNDOWNS);\r
364                 DBCursor find = collection.find(new BasicDBObject(), new BasicDBObject(IOctopusAPI._ID, 0).append(IOctopusAPI.ID, 1));\r
365                 if (find.hasNext())\r
366                         result = ListUtils.cast(find.toArray());\r
367                 return result;\r
368         }\r
369 \r
370         private void setAndCheck(int nexioPort, String nexioUserName, String nexioPassword, String archiveFtp, String archiveUserName, String archivePassword,\r
371                         int nexioKillDateDays, String nexioAgency, IJobEngine jobEngine) throws Exception {\r
372                 db = NoSQLUtils.getNoSQLDB();\r
373                 if (db == null) {\r
374                         logger.error(systemMarker, "Az NoSQL adatkezelő réteg nem elérhető.");\r
375                         throw new NullPointerException("Internal error, missing NoSQL DB reference.");\r
376                 }\r
377 \r
378                 if (jobEngine == null) {\r
379                         logger.error(systemMarker, "Az folyamatkezelő réteg nem elérhető.");\r
380                         throw new NullPointerException("Internal error, missing JobEngine reference.");\r
381                 }\r
382                 manager = jobEngine.getItemManager();\r
383                 if (manager == null) {\r
384                         logger.error(systemMarker, "Az adatbáziskezelő réteg nem elérhető.");\r
385                         throw new NullPointerException("Internal error, missing ItemManager reference.");\r
386                 }\r
387 \r
388                 if (StringUtils.isBlank(NEXIO_HOST)) {\r
389                         logger.error(systemMarker, "A 'nexio.host' rendszer paraméter nem található.");\r
390                         throw new NullPointerException("System is not configured properly, 'jobengine.selenio.address' startup parameter missing.");\r
391                 }\r
392                 check(nexioPort, "nexioPort");\r
393                 check(nexioUserName, "nexioUserName");\r
394                 check(nexioPassword, "nexioPassword");\r
395 \r
396                 check(nexioKillDateDays, "nexioKillDateDays");\r
397                 this.nexioKillDateDays = nexioKillDateDays;\r
398                 check(nexioAgency, "nexioAgency");\r
399                 this.nexioAgency = nexioAgency;\r
400 \r
401                 sourceUri = manager.createStoreUri(RemoteStoreProtocol.FTP, NEXIO_HOST);\r
402                 sourceUri.setPortNumber(nexioPort);\r
403                 sourceUri.setUserName(nexioUserName);\r
404                 sourceUri.setPassword(nexioPassword);\r
405                 if (sourceUri == null) {\r
406                         logger.error(systemMarker, "A forrás nem elérhető.");\r
407                         throw new NullPointerException("Internal error, missing 'sourceUri'.");\r
408                 }\r
409 \r
410                 check(archiveFtp, "archiveFtp");\r
411                 check(archiveUserName, "archiveUserName");\r
412                 check(archivePassword, "archivePassword");\r
413 \r
414                 targetUri = manager.createStoreUri(new URI(archiveFtp));\r
415                 targetUri.setUserName(archiveUserName);\r
416                 targetUri.setPassword(archivePassword);\r
417                 if (targetUri == null) {\r
418                         logger.error(systemMarker, "A cél nem elérhető.");\r
419                         throw new NullPointerException("Internal error, missing 'targetUri'.");\r
420                 }\r
421 \r
422         }\r
423 \r
424         private boolean transferChunk(String fileName) throws Exception {\r
425                 logger.info("Transfer chunk {}", fileName);\r
426                 OutputStream outStream = null;\r
427                 try {\r
428                         targetFtp = ((FtpDirectoryLister) targetUri.getLister()).connect();\r
429 \r
430                         //ha ugyan abban a tukorben szerepel meg 1x a mozi, akkor a chunk felulirja a tenyleges file-t, es az sosem archivalodik\r
431                         String[] names = targetFtp.listNames();\r
432                         if (names != null) {\r
433                                 if (Arrays.asList(names).contains(fileName))\r
434                                         return false;\r
435                         }\r
436 \r
437                         outStream = targetFtp.storeFileStream(fileName);\r
438                         if (outStream == null) {\r
439                                 throw new NullPointerException("Can not open: " + fileName + " Reply:" + targetFtp.getReplyString());\r
440                         }\r
441                 } catch (Exception e) {\r
442                         logger.catching(e);\r
443                         throw e;\r
444                 } finally {\r
445                         if (outStream != null)\r
446                                 outStream.close();\r
447                         targetUri.cleanUp();\r
448                 }\r
449                 return true;\r
450         }\r
451 \r
452         private boolean transferFile(String sourceFileName, String targetFileName) throws Exception {\r
453                 boolean result = true;\r
454                 int reply = 0;\r
455                 logger.info("Transfer clip {}", sourceFileName);\r
456                 try {\r
457                         sourceFtp = ((FtpDirectoryLister) sourceUri.getLister()).connect();\r
458                         targetFtp = ((FtpDirectoryLister) targetUri.getLister()).connect();\r
459                         if (!targetFtp.enterRemotePassiveMode())\r
460                                 throw new Exception("!PASV");\r
461 \r
462                         reply = sourceFtp.port(InetAddress.getByName(targetFtp.getPassiveHost()), targetFtp.getPassivePort());\r
463                         if (!FTPReply.isPositiveCompletion(reply))\r
464                                 throw new Exception("PORT parancs válasza: " + sourceFtp.getReplyString());\r
465 \r
466                         if (!sourceFtp.setFileType(FTP.BINARY_FILE_TYPE))\r
467                                 throw new Exception("!SOURCE TYPE");\r
468 \r
469                         reply = sourceFtp.retr(sourceFileName);\r
470                         if (!FTPReply.isPositivePreliminary(reply))\r
471                                 throw new Exception("RETR parancs válasza: " + sourceFtp.getReplyString());\r
472 \r
473                         if (!targetFtp.setFileType(FTP.BINARY_FILE_TYPE))\r
474                                 throw new Exception("!TARGET TYPE");\r
475 \r
476                         reply = targetFtp.stor(targetFileName);\r
477                         if (!FTPReply.isPositivePreliminary(reply))\r
478                                 throw new Exception("STOR parancs válasza: " + sourceFtp.getReplyString());\r
479 \r
480                         while (true) {\r
481                                 reply = sourceFtp.stat();\r
482                                 if (!FTPReply.isPositiveCompletion(reply))\r
483                                         throw new Exception("STAT parancs válasza: " + sourceFtp.getReplyString());\r
484 \r
485                                 logger.info("Status: {}", sourceFtp.getReplyString());\r
486                                 if (reply == 226) {\r
487                                         break;\r
488                                 }\r
489                                 Thread.sleep(1000);\r
490                         }\r
491                 } catch (Exception e) {\r
492                         logger.catching(e);\r
493                         result = false;\r
494                 } finally {\r
495                         sourceUri.cleanUp();\r
496                         targetUri.cleanUp();\r
497                 }\r
498 \r
499                 return result;\r
500         }\r
501 \r
502         private void transferMetadata(String fileName, BasicDBObject metadata) throws Exception {\r
503                 logger.info("Transfer metadata {}", fileName);\r
504                 OutputStream outStream = null;\r
505                 try {\r
506                         targetFtp = ((FtpDirectoryLister) targetUri.getLister()).connect();\r
507                         if (!targetFtp.changeWorkingDirectory(EscortFiles.STATUSFOLDER)) {\r
508                                 targetFtp.makeDirectory(EscortFiles.STATUSFOLDER);\r
509                                 if (!targetFtp.changeWorkingDirectory(EscortFiles.STATUSFOLDER))\r
510                                         throw new Exception("!STATUSFOLDER");\r
511                         }\r
512 \r
513                         outStream = targetFtp.storeFileStream(fileName + JSON_EXT);\r
514                         if (outStream == null) {\r
515                                 throw new NullPointerException("Can not open: " + fileName + JSON_EXT + " Reply:" + targetFtp.getReplyString());\r
516                         }\r
517                         outStream.write(metadata.toString().getBytes(UTF_8));\r
518                         outStream.flush();\r
519                         //targetFtp.changeToParentDirectory();\r
520                 } catch (Exception e) {\r
521                         logger.catching(e);\r
522                         throw e;\r
523                 } finally {\r
524                         if (outStream != null)\r
525                                 outStream.close();\r
526                         targetUri.cleanUp();\r
527                 }\r
528         }\r
529 \r
530 }\r