2 * Copyright (C) 2008 by INdT
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Lesser General Public License
6 * as published by the Free Software Foundation; either version 2
7 * of the License, or (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU Lesser General Public License
15 * along with this program; if not, write to the Free Software
16 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
18 * @author Andre Moreira Magalhaes <andre.magalhaes@openbossa.org>
24 * real media file parser.
31 #include <lightmediascanner_plugin.h>
32 #include <lightmediascanner_db.h>
33 #include <sys/types.h>
43 STREAM_TYPE_UNKNOWN = 0,
49 struct lms_string_size title;
50 struct lms_string_size artist;
53 struct rm_file_header {
57 } __attribute__((packed));
60 struct lms_plugin plugin;
61 lms_db_audio_t *audio_db;
62 lms_db_video_t *video_db;
65 static const char _name[] = "rm";
66 static const struct lms_string_size _exts[] = {
67 LMS_STATIC_STRING_SIZE(".ra"),
68 LMS_STATIC_STRING_SIZE(".rv"),
69 LMS_STATIC_STRING_SIZE(".rm"),
70 LMS_STATIC_STRING_SIZE(".rmj"),
71 LMS_STATIC_STRING_SIZE(".rmvb")
75 * A real media file header has the following format:
76 * dword chunk type ('.RMF')
77 * dword chunk size (typically 0x12)
80 * dword number of headers
83 _parse_file_header(int fd, struct rm_file_header *file_header)
85 if (read(fd, file_header, sizeof(struct rm_file_header)) == -1) {
86 fprintf(stderr, "ERROR: could not read file header\n");
90 if (memcmp(file_header->type, ".RMF", 4) != 0) {
91 fprintf(stderr, "ERROR: invalid header type\n");
95 /* convert to host byte order */
96 file_header->size = ntohl(file_header->size);
99 fprintf(stderr, "file_header type=%.*s\n", 4, file_header->type);
100 fprintf(stderr, "file_header size=%d\n", file_header->size);
101 fprintf(stderr, "file_header version=%d\n", file_header->version);
104 /* TODO we should ignore these fields just when version is 0 or 1,
105 * but using the test files, if we don't ignore them for version 256
107 /* ignore file header extra fields
108 * file version and number of headers */
109 lseek(fd, 8, SEEK_CUR);
115 _read_header_type_and_size(int fd, char *type, uint32_t *size)
117 if (read(fd, type, 4) != 4)
120 if (read(fd, size, 4) != 4)
123 *size = ntohl(*size);
126 fprintf(stderr, "header type=%.*s\n", 4, type);
127 fprintf(stderr, "header size=%d\n", *size);
134 _read_string(int fd, char **out, int *out_len)
139 if (read(fd, &len, 2) == -1)
146 s = malloc(sizeof(char) * len + 1);
147 if (read(fd, s, len) == -1) {
161 lseek(fd, len, SEEK_CUR);
166 * A CONT header has the following format
167 * dword Chunk type ('CONT')
169 * word Chunk version (always 0, for every known file)
170 * word Title string length
171 * byte[] Title string
172 * word Author string length
173 * byte[] Author string
174 * word Copyright string length
175 * byte[] Copyright string
176 * word Comment string length
177 * byte[] Comment string
180 _parse_cont_header(int fd, struct rm_info *info)
186 /* Ps.: type and size were already read */
189 lseek(fd, 2, SEEK_CUR);
191 _read_string(fd, &info->title.str, &info->title.len);
192 _read_string(fd, &info->artist.str, &info->artist.len);
193 _read_string(fd, NULL, NULL); /* copyright */
194 _read_string(fd, NULL, NULL); /* comment */
198 _strstrip(char **str, unsigned int *p_len)
201 lms_strstrip(*str, p_len);
203 if (*p_len == 0 && *str) {
210 _match(struct plugin *p, const char *path, int len, int base)
214 i = lms_which_extension(path, len, _exts, LMS_ARRAY_SIZE(_exts));
218 return (void*)(i + 1);
222 _parse(struct plugin *plugin, struct lms_context *ctxt, const struct lms_file_info *finfo, void *match)
224 struct rm_info info = {{0}, {0}};
225 struct lms_audio_info audio_info = {0, {0}, {0}, {0}, {0}, 0, 0, 0};
226 struct lms_video_info video_info = {0, {0}, {0}};
227 int r, fd, stream_type = STREAM_TYPE_UNKNOWN;
228 struct rm_file_header file_header;
232 fd = open(finfo->path, O_RDONLY);
238 if (_parse_file_header(fd, &file_header) != 0) {
243 if (_read_header_type_and_size(fd, type, &size) != 0) {
247 while (memcmp(type, "DATA", 4) != 0) {
248 if (memcmp(type, "CONT", 4) == 0) {
249 _parse_cont_header(fd, &info);
252 /* TODO check for mimetype
253 else if (memcmp(type, "MDPR", 4) == 0) {
256 /* ignore other headers */
258 lseek(fd, size - 8, SEEK_CUR);
260 if (_read_header_type_and_size(fd, type, &size) != 0) {
266 /* try to define stream type by extension */
267 if (stream_type == STREAM_TYPE_UNKNOWN) {
268 int ext_idx = ((int)match) - 1;
269 if (strcmp(_exts[ext_idx].str, ".ra") == 0)
270 stream_type = STREAM_TYPE_AUDIO;
271 /* consider rv, rm, rmj and rmvb as video */
273 stream_type = STREAM_TYPE_VIDEO;
276 _strstrip(&info.title.str, &info.title.len);
277 _strstrip(&info.artist.str, &info.artist.len);
279 if (!info.title.str) {
281 ext_idx = ((int)match) - 1;
282 info.title.len = finfo->path_len - finfo->base - _exts[ext_idx].len;
283 info.title.str = malloc((info.title.len + 1) * sizeof(char));
284 memcpy(info.title.str, finfo->path + finfo->base, info.title.len);
285 info.title.str[info.title.len] = '\0';
286 lms_charset_conv(ctxt->cs_conv, &info.title.str, &info.title.len);
290 fprintf(stderr, "file %s info\n", finfo->path);
291 fprintf(stderr, "\ttitle=%s\n", info.title);
292 fprintf(stderr, "\tartist=%s\n", info.artist);
295 if (stream_type == STREAM_TYPE_AUDIO) {
296 audio_info.id = finfo->id;
297 audio_info.title = info.title;
298 audio_info.artist = info.artist;
299 r = lms_db_audio_add(plugin->audio_db, &audio_info);
302 video_info.id = finfo->id;
303 video_info.title = info.title;
304 video_info.artist = info.artist;
305 r = lms_db_video_add(plugin->video_db, &video_info);
310 free(info.title.str);
312 free(info.artist.str);
314 posix_fadvise(fd, 0, 0, POSIX_FADV_DONTNEED);
321 _setup(struct plugin *plugin, struct lms_context *ctxt)
323 plugin->audio_db = lms_db_audio_new(ctxt->db);
324 if (!plugin->audio_db)
326 plugin->video_db = lms_db_video_new(ctxt->db);
327 if (!plugin->video_db)
334 _start(struct plugin *plugin, struct lms_context *ctxt)
337 r = lms_db_audio_start(plugin->audio_db);
338 r |= lms_db_video_start(plugin->video_db);
343 _finish(struct plugin *plugin, struct lms_context *ctxt)
345 if (plugin->audio_db)
346 lms_db_audio_free(plugin->audio_db);
347 if (plugin->video_db)
348 lms_db_video_free(plugin->video_db);
354 _close(struct plugin *plugin)
360 API struct lms_plugin *
361 lms_plugin_open(void)
363 struct plugin *plugin;
365 plugin = (struct plugin *)malloc(sizeof(*plugin));
366 plugin->plugin.name = _name;
367 plugin->plugin.match = (lms_plugin_match_fn_t)_match;
368 plugin->plugin.parse = (lms_plugin_parse_fn_t)_parse;
369 plugin->plugin.close = (lms_plugin_close_fn_t)_close;
370 plugin->plugin.setup = (lms_plugin_setup_fn_t)_setup;
371 plugin->plugin.start = (lms_plugin_start_fn_t)_start;
372 plugin->plugin.finish = (lms_plugin_finish_fn_t)_finish;
374 return (struct lms_plugin *)plugin;