Title:
+ *Description:
+ *Copyright: Copyright (c) 2003
+ *Company:
+ * @author the mir coders + * @version 1.0 */ -public abstract class ServletModuleUploadedMedia - extends mir.servlet.ServletModule { - - //private static DatabaseRights dbRights; +public abstract class ServletModuleUploadedMedia extends ServletModule { + protected String moduleName = "UploadedMedia"; public static ServletModule getInstance() { return null; } - public void insert(HttpServletRequest req, HttpServletResponse res) - throws ServletModuleException, ServletModuleUserException { + public ServletModuleUploadedMedia() { + super(); + + definition = "uploadedMedia"; + logger = new LoggerWrapper("ServletModule.UploadedMedia"); try { - WebdbMultipartRequest mp = new WebdbMultipartRequest(req); - HashMap parameters = mp.getParameters(); - EntityUsers user = _getUser(req); - String mediaId = null; - MpRequest mpReq = (MpRequest) mp.requestList.get(0); - String mediaTypeId; //= null; - MirMedia mediaHandler; - Database mediaStorage; - - // get the content-type from what the client browser - // sends us. (the "Oreilly method") - String contentType = mpReq.getContentType(); - String fileName = mpReq.getFilename(); - theLog.printInfo("CONTENT-TYPE FROM BROWSER: " + contentType); - - // if the client browser sent us unknown (text/plain is default) - // or if we got application/octet-stream, it's possible that - // the browser is in error, better check against the file extension - if (contentType.equals("text/plain") || - contentType.equals("application/octet-stream")) { - /** - * This is just a temporary way to get the content-type via - * the .extension , we could maybe use a magic method, by looking - * at the header (first few bytes) of the file. (like the file(1) - * command). - * The Oreilly method relies on the content-type that the client - * browser sends and that sometimes is application-octet stream with - * broken/mis-configured browsers. - * - * The map file should be Mir/content-types.properties, it's the - * default Sun Java file with some additional entries that it did - * not have. So if you support a new media type you have to make - * sure that it is in this file -mh - */ - contentType = FileUtil.guessContentTypeFromName(fileName); - if (contentType == null) - contentType = "text/plain"; // rfc1867 says this is the default - } - theLog.printInfo("CONTENT TYPE IS: " + contentType); + model = MirGlobal.localizer().dataModel().adapterModel(); + } + catch (Throwable t) { + throw new ServletModuleFailure(t); + } + } - if (contentType.equals("text/plain") || - contentType.equals("application/octet-stream")) { - throw new ServletModuleUserException( - "One or more files of unrecognized types"); - } + public void insert(HttpServletRequest aRequest, HttpServletResponse aResponse) + throws ServletModuleExc, ServletModuleUserExc { + try { + HTTPParsedRequest parsedRequest = new HTTPParsedRequest(aRequest, + configuration.getString("Mir.DefaultEncoding"), + configuration.getInt("MaxMediaUploadSize")*1024, + configuration.getString("TempDir")); - parameters.put("date", StringUtil.date2webdbDate(new GregorianCalendar())); - parameters.put("to_publisher", user.getId()); - - //the where clause to find the media_type entry from the content-type. - //we use the media type entry to lookup the media Handler/Storage classes - // @todo this should probably be moved to DatabaseMediaType or - // somewhere else appropriate -mh - String[] contentTypeSplit = StringUtil.split(contentType, "/"); - String wc = " mime_type LIKE '" + contentTypeSplit[0] + "%'"; - DatabaseMediaType mediaTypeStor = DatabaseMediaType.getInstance(); - EntityList mediaTypesList = mediaTypeStor.selectByWhereClause(wc); - - // if we didn't find an entry matching the - // content-type in the table. - if (mediaTypesList.size() == 0) { - theLog.printDebugInfo("Wrong file type uploaded!: " + fileName); - throw new MirMediaUserException("One or more files of unrecognized type"); - } - Entity mediaType = null; - - // find out if we an exact content-type match if so take it. - // otherwise just use the first one. - // @todo this should probably be moved to DatabaseMediaType -mh - for (int j = 0; j < mediaTypesList.size(); j++) { - if (contentType.equals( - mediaTypesList.elementAt(j).getValue("mime_type"))) - mediaType = mediaTypesList.elementAt(j); - } + Map mediaValues = new HashMap(); - // if no exact match, whatever foo/* might match - if (mediaType == null) - mediaType = mediaTypesList.elementAt(0); + mediaValues.put("to_publisher", ServletHelper.getUser(aRequest).getId()); - // get the class names from the media_type table. - mediaTypeId = mediaType.getId(); - try { - // ############### @todo: merge these and the getURL call into one - // getURL helper call that just takes the Entity as a parameter - // along with media_type - mediaHandler = MediaHelper.getHandler(mediaType); - mediaStorage = MediaHelper.getStorage(mediaType, - "mircoders.storage.Database"); - } - catch (Exception e) { - theLog.printError("getting media handler failed: " + e.toString()); - throw new MirMediaException("getting media handler failed: " - + e.toString()); + Iterator i = mainModule.getStorageObject().getFields().iterator(); + while (i.hasNext()) { + String field = (String) i.next(); + String value = parsedRequest.getParameter(field); + if (value!=null) + mediaValues.put(field, value); } - parameters.put("to_media_type", mediaTypeId); - //load the classes via reflection - Entity mediaEnt = null; - try { - mediaEnt = (Entity) mediaStorage.getEntityClass().newInstance(); - mediaEnt.setStorage(mediaStorage); - mediaEnt.setValues(parameters); - // unfortunatly we have to insert it first because of the way - // Image setting works right now. that should change soon. -mh - mediaId = mediaEnt.insert(); - //save and store the media data/metadata - mediaHandler.set(mpReq.getMedia(), mediaEnt, mediaType); - - //were done with mpReq at this point, dereference it. - //as it contains mucho mem. -mh 01.10.2001 - mpReq = null; - - //we got this far, associate the media to the article - mediaEnt.setValueForProperty("is_published", "1"); - mediaEnt.update(); + List mediaList = new Vector(); + + i = parsedRequest.getFiles().iterator(); + while (i.hasNext()) { + UploadedFile file = new mir.session.CommonsUploadedFileAdapter((FileItem) i.next()); + + String suffix = file.getFieldName().substring(5); + mediaValues.put("title", parsedRequest.getParameter("media_title" + suffix)); + + mediaList.add(MediaUploadProcessor.processMediaUpload(file, mediaValues)); } - catch (Exception e) { - try { - mediaStorage.delete(mediaId); + + String articleid = parsedRequest.getParameter("articleid"); + String commentid = parsedRequest.getParameter("commentid"); + + if (articleid!=null) { + EntityContent entContent = (EntityContent) DatabaseContent.getInstance().selectById(articleid); + + i=mediaList.iterator(); + + while (i.hasNext()) { + String id = ((EntityUploadedMedia) i.next()).getId(); + + entContent.attach(id); + logAdminUsage(aRequest, id, "object attached to article " + articleid); } - catch (Exception e2) { - // dont't do anything here as the error was setting the media, - // this just means that the entity may not have been inserted yet + + ((ServletModuleContent) ServletModuleContent.getInstance()).editObject(aRequest, aResponse, articleid); + + + return; + } + + if (commentid!=null) { + EntityComment comment = (EntityComment) DatabaseComment.getInstance().selectById(commentid); + + i=mediaList.iterator(); + + while (i.hasNext()) { + String id = ((EntityUploadedMedia) i.next()).getId(); + + comment.attach(id); + + logAdminUsage(aRequest, id, "object attached to comment " + commentid); } - theLog.printError("setting media failed: " + e.toString()); - throw new MirMediaException("setting media failed: " + e.toString()); + + ((ServletModuleComment) ServletModuleComment.getInstance()).editObject(aRequest, aResponse, commentid); + + return; } - _edit(mediaId, req, res); - } - catch (MirMediaException e) { - throw new ServletModuleException( - "upload -- media handling exception " + e.toString()); - } - catch (MirMediaUserException e) { - throw new ServletModuleUserException( - e.getMsg()); - } - catch (IOException e) { - throw new ServletModuleException("upload -- ioexception " + e.toString()); - } - catch (StorageObjectException e) { - throw new ServletModuleException("StorageObjectException" + e.toString()); + logAdminUsage(aRequest, "", mediaList.size() + " objects added"); + + returnUploadedMediaList(aRequest, aResponse, mediaList, 1, mediaList.size(), mediaList.size(), "", null, null); } + catch (Throwable t) { + Throwable cause = ExceptionFunctions.traceCauseException(t); + if (cause instanceof ModuleMediaType.UnsupportedMimeTypeExc) { + throw new ServletModuleUserExc("media.error.unsupportedformat", new String[] {}); + } + throw new ServletModuleFailure("ServletModuleUploadedMedia.insert: " + t.toString(), t); + } } - public void update(HttpServletRequest req, HttpServletResponse res) throws ServletModuleException { + public void update(HttpServletRequest aRequest, HttpServletResponse aResponse) throws ServletModuleExc { try { - WebdbMultipartRequest mp = new WebdbMultipartRequest(req); - HashMap parameters = mp.getParameters(); - - EntityUsers user = _getUser(req); - parameters.put("to_publisher", user.getId()); - parameters.put("is_produced", "0"); - if (!parameters.containsKey("is_published")) - parameters.put("is_published", "0"); - - String id = mainModule.set(parameters); - theLog.printError("media ID" + id); - _edit(id, req, res); - } - catch (IOException e) { - throw new ServletModuleException("upload -- ioexception " + e.toString()); + HTTPParsedRequest parsedRequest = new HTTPParsedRequest(aRequest, + configuration.getString("Mir.DefaultEncoding"), + configuration.getInt("MaxMediaUploadSize")*1024, + configuration.getString("TempDir")); + Map mediaValues = new HashMap(); + + Iterator i = mainModule.getStorageObject().getFields().iterator(); + while (i.hasNext()) { + String field = (String) i.next(); + String value = parsedRequest.getParameter(field); + if (value!=null) + mediaValues.put(field, value); + } + + mediaValues.put("to_publisher", ServletHelper.getUser(aRequest).getId()); + mediaValues.put("is_produced", "0"); + if (!mediaValues.containsKey("is_published")) + mediaValues.put("is_published", "0"); + + String id = mainModule.set(mediaValues); + logger.debug("update: media ID = " + id); + logAdminUsage(aRequest, id, "object modified"); + + editUploadedMediaObject(id, aRequest, aResponse); } - catch (ModuleException e) { - throw new ServletModuleException("upload -- moduleexception " + e.toString()); + catch (Throwable e) { + throw new ServletModuleFailure("upload -- exception " + e.toString(), e); } } + public void returnUploadedMediaList(HttpServletRequest aRequest, HttpServletResponse aResponse, + Object aList, int aFrom, int aTo, int aCount, + String aThisUrl, String aNextUrl, String aPreviousUrl) throws ServletModuleExc { - public void list(HttpServletRequest req, HttpServletResponse res) - throws ServletModuleException { - // Parameter auswerten - SimpleHash mergeData = new SimpleHash(); - SimpleHash popups = new SimpleHash(); - - String query_text = req.getParameter("query_text"); - mergeData.put("query_text", query_text); - if (query_text != null) mergeData.put("query_text_encoded", URLEncoder.encode(query_text)); - String query_field = req.getParameter("query_field"); - mergeData.put("query_field", query_field); - String query_is_published = req.getParameter("query_is_published"); - mergeData.put("query_is_published", query_is_published); - String query_media_folder = req.getParameter("query_media_folder"); - mergeData.put("query_media_folder", query_media_folder); - String offset = req.getParameter("offset"); - if (offset == null || offset.equals("")) offset = "0"; - mergeData.put("offset", offset); - - String order = req.getParameter("order"); - if (order == null) order = "webdb_lastchange desc"; - - // if in connection mode to content - String cid = req.getParameter("cid"); - mergeData.put("cid", cid); - - - // sql basteln - String whereClause = ""; - boolean isFirst = true; - if (query_text != null && !query_text.equalsIgnoreCase("")) { - whereClause += "lower(" + query_field + ") like lower('%" + query_text + "%')"; - isFirst = false; - } - if (query_is_published != null && !query_is_published.equals("")) { - if (isFirst == false) whereClause += " and "; - whereClause += "is_published='" + query_is_published + "'"; - isFirst = false; + try { + HTTPRequestParser requestParser = new HTTPRequestParser(aRequest); + Map responseData = ServletHelper.makeGenerationData(aRequest, aResponse, new Locale[] {getLocale(aRequest), getFallbackLocale(aRequest)}); + + responseData.put("searchfield", requestParser.getParameterWithDefault("searchfield", "")); + responseData.put("searchtext", requestParser.getParameterWithDefault("searchtext", "")); + responseData.put("searchispublished", requestParser.getParameterWithDefault("searchispublished", "")); + responseData.put("searchmediafolder", requestParser.getParameterWithDefault("searchmediafolder", "")); + responseData.put("articleid", requestParser.getParameter("articleid")); + responseData.put("commentid", requestParser.getParameter("commentid")); + + responseData.put("thisurl", aThisUrl); + responseData.put("nexturl", aNextUrl); + responseData.put("prevurl", aPreviousUrl); + + responseData.put("from", Integer.toString(aFrom)); + responseData.put("count", Integer.toString(aCount)); + responseData.put("to", Integer.toString(aTo)); + + responseData.put("medialist", aList); + + addExtraData(responseData); + ServletHelper.generateResponse(aResponse.getWriter(), responseData, listGenerator); } - if (query_media_folder != null && !query_media_folder.equals("")) { - if (isFirst == false) whereClause += " and "; - whereClause += "to_media_folder='" + query_media_folder + "'"; + catch (Throwable t) { + throw new ServletModuleFailure(t); } - //theLog.printDebugInfo("sql-whereclause: " + whereClause + " order: " + order + " offset: " + offset); + } + + public void returnUploadedMediaList(HttpServletRequest aRequest, HttpServletResponse aResponse, + String aWhereClause, String anOrderByClause, int anOffset) throws ServletModuleExc { + + HTTPRequestParser requestParser = new HTTPRequestParser(aRequest); + URLBuilder urlBuilder = new URLBuilder(); + EntityAdapterModel model; + String nextPageUrl = null; + String previousPageUrl = null; + String thisUrl = null; + + int count; - // fetch und ausliefern try { - if (query_text != null || query_is_published != null || query_media_folder != null) { - EntityList theList = mainModule.getByWhereClause(whereClause, order, (new Integer(offset)).intValue(), 10); - if (theList != null) { - mergeData.put("contentlist", theList); - if (theList.getOrder() != null) { - mergeData.put("order", theList.getOrder()); - mergeData.put("order_encoded", URLEncoder.encode(theList.getOrder())); - } - mergeData.put("count", (new Integer(theList.getCount())).toString()); - mergeData.put("from", (new Integer(theList.getFrom())).toString()); - mergeData.put("to", (new Integer(theList.getTo())).toString()); - if (theList.hasNextBatch()) - mergeData.put("next", (new Integer(theList.getNextBatch())).toString()); - if (theList.hasPrevBatch()) - mergeData.put("prev", (new Integer(theList.getPrevBatch())).toString()); - } - //fetch the popups - popups.put("mediafolderPopupData", DatabaseMediafolder.getInstance().getPopupData()); + model = MirGlobal.localizer().dataModel().adapterModel(); + + Object mediaList = + new CachingRewindableIterator( + new EntityIteratorAdapter(aWhereClause, anOrderByClause, nrEntitiesPerListPage, + model, definition, nrEntitiesPerListPage, anOffset) + ); + + count = mainModule.getSize(aWhereClause); + + urlBuilder.setValue("module", moduleName); + urlBuilder.setValue("do", "list"); + urlBuilder.setValue("where", aWhereClause); + urlBuilder.setValue("order", anOrderByClause); + + urlBuilder.setValue("articleid", requestParser.getParameter("articleid")); + urlBuilder.setValue("commentid", requestParser.getParameter("commentid")); + urlBuilder.setValue("searchfield", requestParser.getParameter("searchfield")); + urlBuilder.setValue("searchtext", requestParser.getParameter("searchtext")); + urlBuilder.setValue("searchispublished", requestParser.getParameter("searchispublished")); + urlBuilder.setValue("searchmediafolder", requestParser.getParameter("searchmediafolder")); + urlBuilder.setValue("where", aWhereClause); + urlBuilder.setValue("order", anOrderByClause); + + urlBuilder.setValue("offset", anOffset); + thisUrl = urlBuilder.getQuery(); + + if (count >= anOffset + nrEntitiesPerListPage) { + urlBuilder.setValue("offset", anOffset + nrEntitiesPerListPage); + nextPageUrl = urlBuilder.getQuery(); + } + + if (anOffset > 0) { + urlBuilder.setValue("offset", Math.max(anOffset - nrEntitiesPerListPage, 0)); + previousPageUrl = urlBuilder.getQuery(); } - // raus damit - deliver(req, res, mergeData, popups, templateListString); + + returnUploadedMediaList(aRequest, aResponse, mediaList, + anOffset+1, anOffset+nrEntitiesPerListPage, count, thisUrl, + nextPageUrl, previousPageUrl); } - catch (ModuleException e) { - throw new ServletModuleException(e.toString()); + catch (Throwable e) { + throw new ServletModuleFailure(e); } - catch (Exception e) { - throw new ServletModuleException(e.toString()); + } + + public void search(HttpServletRequest aRequest, HttpServletResponse aResponse) throws ServletModuleExc { + HTTPRequestParser requestParser = new HTTPRequestParser(aRequest); + + SQLQueryBuilder queryBuilder = new SQLQueryBuilder(); + + String queryField = ""; + String searchField = requestParser.getParameter("searchfield"); + String searchText = requestParser.getParameter("searchtext"); + String searchIsPublished = requestParser.getParameter("searchispublished"); + String searchMediaFolder = requestParser.getParameter("searchmediafolder"); + + queryBuilder.appendDescendingOrder("webdb_create"); + + if (searchIsPublished!=null) + if (searchIsPublished.equals("0")) { + queryBuilder.appendAndCondition("is_published='f'"); + } + else if (searchIsPublished.equals("1")) { + queryBuilder.appendAndCondition("is_published='t'"); + } + + if (searchField!=null && searchText!=null && searchText.length()>0) { + queryBuilder.appendAndCondition( + "lower(" + searchField + ") like " + + "'%" + JDBCStringRoutines.escapeStringLiteral(searchText.toLowerCase()) + "%'"); } + + if (searchMediaFolder!=null && searchMediaFolder.length()>0) { + queryBuilder.appendAndCondition("to_media_folder="+Integer.parseInt(searchMediaFolder)); + } + + returnUploadedMediaList(aRequest, aResponse, + queryBuilder.getWhereClause(), queryBuilder.getOrderByClause(), requestParser.getIntegerWithDefault("offset", 0)); } + public void list(HttpServletRequest aRequest, HttpServletResponse aResponse) throws ServletModuleExc { + HTTPRequestParser requestParser = new HTTPRequestParser(aRequest); + + returnUploadedMediaList(aRequest, aResponse, + requestParser.getParameterWithDefault("where", ""), + requestParser.getParameterWithDefault("order", "webdb_create desc"), + requestParser.getIntegerWithDefault("offset", 0)); + } - public void add(HttpServletRequest req, HttpServletResponse res) - throws ServletModuleException { + + public void add(HttpServletRequest aRequest, HttpServletResponse aResponse) throws ServletModuleExc { try { - SimpleHash mergeData = new SimpleHash(); - mergeData.put("new", "1"); - SimpleHash popups = new SimpleHash(); - popups.put("mediafolderPopupData", DatabaseMediafolder.getInstance().getPopupData()); - deliver(req, res, mergeData, popups, templateObjektString); + HTTPRequestParser requestParser = new HTTPRequestParser(aRequest); + Map responseData = ServletHelper.makeGenerationData(aRequest, aResponse, new Locale[] {getLocale(aRequest), getFallbackLocale(aRequest)}); + + int nrMedia = requestParser.getIntegerWithDefault("nrmedia", 1); + int maxNrMedia=configuration.getInt("ServletModule.OpenIndy.MaxMediaUploadItems", 20); + + List fields = mainModule.getStorageObject().getFields(); + Map media = new HashMap(); + Iterator i = fields.iterator(); + while (i.hasNext()) { + media.put(i.next(), null); + } + media.put("to_media_folder", new Integer(7)); + responseData.put("uploadedmedia", media); + + responseData.put("new", Boolean.TRUE); + responseData.put("articleid", requestParser.getParameter("articleid")); + responseData.put("commentid", requestParser.getParameter("commentid")); + responseData.put("returnurl", null); + + if (nrMedia<=0) + nrMedia=1; + if (nrMedia>maxNrMedia) + nrMedia=maxNrMedia; + + List mediaFields = new Vector(); + for (int j=0; j