e76831bda2199ead4c256977fb3ed08104b099b9
[mir.git] / source / mircoders / producer / MediaGeneratingProducerNode.java
1 /*
2  * Copyright (C) 2001, 2002  The Mir-coders group
3  *
4  * This file is part of Mir.
5  *
6  * Mir is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation; either version 2 of the License, or
9  * (at your option) any later version.
10  *
11  * Mir is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with Mir; if not, write to the Free Software
18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
19  *
20  * In addition, as a special exception, The Mir-coders gives permission to link
21  * the code of this program with the com.oreilly.servlet library, any library
22  * licensed under the Apache Software License, The Sun (tm) Java Advanced
23  * Imaging library (JAI), The Sun JIMI library (or with modified versions of
24  * the above that use the same license as the above), and distribute linked
25  * combinations including the two.  You must obey the GNU General Public
26  * License in all respects for all of the code used other than the above
27  * mentioned libraries.  If you modify this file, you may extend this exception
28  * to your version of the file, but you are not obligated to do so.  If you do
29  * not wish to do so, delete this exception statement from your version.
30  */
31
32 package mircoders.producer;
33
34 import java.util.*;
35 import java.io.*;
36 import mir.util.*;
37 import mir.misc.*;
38 import mir.media.*;
39 import mir.producer.*;
40 import mir.generator.*;
41 import mir.entity.*;
42 import mir.entity.adapter.*;
43 //import mircoders.global.*;
44 //import mircoders.localizer.*;
45 import mircoders.entity.*;
46 import mircoders.storage.*;
47
48 public class MediaGeneratingProducerNode implements ProducerNode {
49   private String mediaEntityKey;
50
51   public MediaGeneratingProducerNode(String aMediaEntityKey) {
52     mediaEntityKey = aMediaEntityKey;
53   }
54
55   public void produce(Map aValueMap, String aVerb, PrintWriter aLogger) throws ProducerFailure {
56     Object data;
57     Entity entity;
58     Entity currentMediaType;
59     MirMedia currentMediaHandler;
60
61     try {
62       data = ParameterExpander.findValueForKey( aValueMap, mediaEntityKey );
63
64       if (!(data instanceof EntityAdapter)) {
65         throw new ProducerFailure("MediaGeneratingProducerNode: value of '"+mediaEntityKey+"' is not an EntityAdapter, but an " + data.getClass().getName(), null);
66       }
67
68       entity = ((EntityAdapter) data).getEntity();
69       if (! (entity instanceof EntityUploadedMedia)) {
70         throw new ProducerFailure("MediaGeneratingProducerNode: value of '"+mediaEntityKey+"' is not an uploaded media EntityAdapter, but a " + entity.getClass().getName() + " adapter", null);
71       }
72
73       currentMediaType = DatabaseUploadedMedia.getInstance().getMediaType(entity);
74
75       currentMediaHandler = MediaHelper.getHandler( currentMediaType );
76       currentMediaHandler.produce(entity,currentMediaType);
77       entity.setValueForProperty("publish_server", currentMediaHandler.getPublishHost());
78       entity.setValueForProperty("icon_is_produced", "1");
79       entity.setValueForProperty("is_produced", "1");
80       entity.update();
81     }
82     catch (Throwable t) {
83       aLogger.println("Error while generating media: " + t.getMessage());
84       t.printStackTrace(aLogger);
85
86       throw new ProducerFailure(t.getMessage(), t);
87     }
88   }
89 }
90
91
92 /*
93
94
95   abstract Database getStorage() throws StorageObjectException;
96
97   public void handle(PrintWriter htmlout, EntityUsers user, boolean force,
98     boolean sync) throws StorageObjectException, ModuleException {
99     handle(htmlout,user,force,sync,null);
100   }
101
102   public void handle(PrintWriter htmlout,EntityUsers user,boolean force,
103     boolean sync, String id) throws StorageObjectException, ModuleException
104   {
105     long                sessionConnectTime = 0;
106     long                startTime = (new java.util.Date()).getTime();
107     String              whereClause;
108     String              orderBy;
109     Entity              currentMedia;
110     MirMedia            currentMediaHandler;
111     EntityList          batchEntityList;
112
113     int contentBatchsize =
114             Integer.parseInt(MirConfig.getProp("Producer.Content.Batchsize"));
115     orderBy = "date desc, webdb_lastchange desc";
116
117     // get batch of non-produced medias, that are to be published
118     whereClause="is_published='1'";
119     if (id!= null) {
120       whereClause += " and id="+id;
121       // optimization to avoid select count(*)..
122       contentBatchsize = -1;
123     }
124     if (force==false) whereClause += " and is_produced='0'";
125
126     batchEntityList = getStorage().selectByWhereClause(whereClause,
127                                                 orderBy, 0, contentBatchsize);
128
129     while (batchEntityList != null) {
130       for(int i=0;i<batchEntityList.size();i++) {
131         currentMedia = (Entity)batchEntityList.elementAt(i);
132         try {
133           Entity currentMediaType =
134                 DatabaseUploadedMedia.getInstance().getMediaType(currentMedia);
135           currentMediaHandler = MediaHelper.getHandler( currentMediaType );
136
137           // now produce
138           currentMediaHandler.produce(currentMedia,currentMediaType);
139           currentMedia.setValueForProperty("publish_server",
140                                         currentMediaHandler.getPublishHost());
141           currentMedia.setValueForProperty("icon_is_produced", "1");
142           currentMedia.setValueForProperty("is_produced", "1");
143           currentMedia.update();
144           logHTML(htmlout,"produced media id "+currentMedia.getId()
145                   +": "+currentMediaType.getValue("mime_type")+" success");
146         } catch (Exception e) {
147           // don't throw and exception here, just log.
148           // we don't want to make the admin interface unuseable
149           theLog.printError("media exception: "+currentMedia.getId()+
150                             e.toString());
151           logHTML(htmlout, "problem with media id: "+currentMedia.getId()+
152                   " <font color=\"Red\"> failed!</font>: "+e.toString());
153           e.printStackTrace(htmlout);
154         }
155       }
156
157       // if next batch get it...
158       if (batchEntityList.hasNextBatch()){
159         batchEntityList = uploadedMediaModule.getByWhereClause(whereClause,
160           orderBy, batchEntityList.getNextBatch(),contentBatchsize);
161       } else {
162         batchEntityList=null;
163       }
164     }
165     // Finish
166     sessionConnectTime = new java.util.Date().getTime() - startTime;
167     logHTML(htmlout, "Producer.Media finished: " + sessionConnectTime + " ms.");
168   }
169 */