X-Git-Url: http://research.m1stereo.tv/gitweb?a=blobdiff_plain;f=src%2Fmodules%2Fwestley%2Fproducer_westley.c;h=0a6654035adc69c7c034fb3e5f3973040fef27c0;hb=4fc3fa1bf4116848c423837437d75f103cdd0154;hp=8873ca936a9cb45b82fde012728ab04f51784f2c;hpb=abc466844ef298c20f1530c1f287de40445762a4;p=melted diff --git a/src/modules/westley/producer_westley.c b/src/modules/westley/producer_westley.c index 8873ca9..0a66540 100644 --- a/src/modules/westley/producer_westley.c +++ b/src/modules/westley/producer_westley.c @@ -3,67 +3,162 @@ * Copyright (C) 2003-2004 Ushodaya Enterprises Limited * Author: Dan Dennedy * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. * - * This program is distributed in the hope that it will be useful, + * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software Foundation, - * Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ -// TODO: destroy unreferenced producers - -#include "producer_westley.h" +// TODO: destroy unreferenced producers (they are currently destroyed +// when the returned producer is closed). + #include #include #include #include +#include +#include #include +#include // for xmlCreateFileParserCtxt +#include #define STACK_SIZE 1000 +#define BRANCH_SIG_LEN 4000 + +#define _x (const xmlChar*) +#define _s (const char*) + +#undef DEBUG +#ifdef DEBUG +extern xmlDocPtr westley_make_doc( mlt_service service ); +#endif + +enum service_type +{ + mlt_invalid_type, + mlt_unknown_type, + mlt_producer_type, + mlt_playlist_type, + mlt_entry_type, + mlt_tractor_type, + mlt_multitrack_type, + mlt_filter_type, + mlt_transition_type, + mlt_consumer_type, + mlt_field_type, + mlt_services_type, + mlt_dummy_filter_type, + mlt_dummy_transition_type, + mlt_dummy_producer_type, +}; struct deserialise_context_s { + enum service_type stack_types[ STACK_SIZE ]; mlt_service stack_service[ STACK_SIZE ]; int stack_service_size; mlt_properties producer_map; mlt_properties destructors; char *property; - mlt_properties producer_properties; + int is_value; + xmlDocPtr value_doc; + xmlNodePtr stack_node[ STACK_SIZE ]; + int stack_node_size; + xmlDocPtr entity_doc; + int entity_is_replace; + int depth; + int branch[ STACK_SIZE ]; + const xmlChar *publicId; + const xmlChar *systemId; + mlt_properties params; + mlt_profile profile; }; typedef struct deserialise_context_s *deserialise_context; +/** Convert the numerical current branch address to a dot-delimited string. +*/ +static char *serialise_branch( deserialise_context this, char *s ) +{ + int i; + + s[0] = 0; + for ( i = 0; i < this->depth; i++ ) + { + int len = strlen( s ); + snprintf( s + len, BRANCH_SIG_LEN - len, "%d.", this->branch[ i ] ); + } + return s; +} /** Push a service. */ -static int context_push_service( deserialise_context this, mlt_service that ) +static int context_push_service( deserialise_context this, mlt_service that, enum service_type type ) { - int ret = this->stack_service_size >= STACK_SIZE; + int ret = this->stack_service_size >= STACK_SIZE - 1; if ( ret == 0 ) - this->stack_service[ this->stack_service_size ++ ] = that; + { + this->stack_service[ this->stack_service_size ] = that; + this->stack_types[ this->stack_service_size++ ] = type; + + // Record the tree branch on which this service lives + if ( that != NULL && mlt_properties_get( MLT_SERVICE_PROPERTIES( that ), "_westley_branch" ) == NULL ) + { + char s[ BRANCH_SIG_LEN ]; + mlt_properties_set( MLT_SERVICE_PROPERTIES( that ), "_westley_branch", serialise_branch( this, s ) ); + } + } return ret; } /** Pop a service. */ -static mlt_service context_pop_service( deserialise_context this ) +static mlt_service context_pop_service( deserialise_context this, enum service_type *type ) { mlt_service result = NULL; if ( this->stack_service_size > 0 ) + { result = this->stack_service[ -- this->stack_service_size ]; + if ( type != NULL ) + *type = this->stack_types[ this->stack_service_size ]; + } + return result; +} + +/** Push a node. +*/ + +static int context_push_node( deserialise_context this, xmlNodePtr node ) +{ + int ret = this->stack_node_size >= STACK_SIZE - 1; + if ( ret == 0 ) + this->stack_node[ this->stack_node_size ++ ] = node; + return ret; +} + +/** Pop a node. +*/ + +static xmlNodePtr context_pop_node( deserialise_context this ) +{ + xmlNodePtr result = NULL; + if ( this->stack_node_size > 0 ) + result = this->stack_node[ -- this->stack_node_size ]; return result; } + // Set the destructor on a new service static void track_service( mlt_properties properties, void *service, mlt_destructor destructor ) { @@ -73,509 +168,1297 @@ static void track_service( mlt_properties properties, void *service, mlt_destruc mlt_properties_set_int( properties, "registered", ++ registered ); } -static void on_start_tractor( deserialise_context context, const xmlChar *name, const xmlChar **atts) + +// Prepend the property value with the document root +static inline void qualify_property( deserialise_context context, mlt_properties properties, const char *name ) { - mlt_service service = mlt_tractor_service( mlt_tractor_init() ); - mlt_properties properties = mlt_service_properties( service ); + char *resource = mlt_properties_get( properties, name ); + if ( resource != NULL ) + { + // Qualify file name properties + char *root = mlt_properties_get( context->producer_map, "root" ); + if ( root != NULL && strcmp( root, "" ) ) + { + char *full_resource = malloc( strlen( root ) + strlen( resource ) + 2 ); + if ( resource[ 0 ] != '/' && strchr( resource, ':' ) == NULL ) + { + strcpy( full_resource, root ); + strcat( full_resource, "/" ); + strcat( full_resource, resource ); + } + else + { + strcpy( full_resource, resource ); + } + mlt_properties_set( properties, name, full_resource ); + free( full_resource ); + } + } +} - track_service( context->destructors, service, (mlt_destructor) mlt_tractor_close ); - mlt_properties_set_position( properties, "length", 0 ); +/** This function adds a producer to a playlist or multitrack when + there is no entry or track element. +*/ - for ( ; atts != NULL && *atts != NULL; atts += 2 ) - mlt_properties_set( mlt_service_properties( service ), (char*) atts[0], (char*) atts[1] ); +static int add_producer( deserialise_context context, mlt_service service, mlt_position in, mlt_position out ) +{ + // Return value (0 = service remains top of stack, 1 means it can be removed) + int result = 0; - if ( mlt_properties_get_position( properties, "length" ) < mlt_properties_get_position( properties, "out" ) ) + // Get the parent producer + enum service_type type = mlt_invalid_type; + mlt_service container = context_pop_service( context, &type ); + int contained = 0; + + if ( service != NULL && container != NULL ) { - mlt_position length = mlt_properties_get_position( properties, "out" ) + 1; - mlt_properties_set_position( properties, "length", length ); + char *container_branch = mlt_properties_get( MLT_SERVICE_PROPERTIES( container ), "_westley_branch" ); + char *service_branch = mlt_properties_get( MLT_SERVICE_PROPERTIES( service ), "_westley_branch" ); + contained = !strncmp( container_branch, service_branch, strlen( container_branch ) ); } - context_push_service( context, service ); -} + if ( contained ) + { + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); + char *hide_s = mlt_properties_get( properties, "hide" ); -static void on_start_multitrack( deserialise_context context, const xmlChar *name, const xmlChar **atts) -{ - mlt_service service = mlt_multitrack_service( mlt_multitrack_init() ); - mlt_properties properties = mlt_service_properties( service ); + // Indicate that this service is no longer top of stack + result = 1; - track_service( context->destructors, service, (mlt_destructor) mlt_multitrack_close ); + switch( type ) + { + case mlt_tractor_type: + { + mlt_multitrack multitrack = mlt_tractor_multitrack( MLT_TRACTOR( container ) ); + mlt_multitrack_connect( multitrack, MLT_PRODUCER( service ), mlt_multitrack_count( multitrack ) ); + } + break; + case mlt_multitrack_type: + { + mlt_multitrack_connect( MLT_MULTITRACK( container ), + MLT_PRODUCER( service ), + mlt_multitrack_count( MLT_MULTITRACK( container ) ) ); + } + break; + case mlt_playlist_type: + { + mlt_playlist_append_io( MLT_PLAYLIST( container ), MLT_PRODUCER( service ), in, out ); + } + break; + default: + result = 0; + fprintf( stderr, "Producer defined inside something that isn't a container\n" ); + break; + }; - mlt_properties_set_position( properties, "length", 0 ); + // Set the hide state of the track producer + if ( hide_s != NULL ) + { + if ( strcmp( hide_s, "video" ) == 0 ) + mlt_properties_set_int( properties, "hide", 1 ); + else if ( strcmp( hide_s, "audio" ) == 0 ) + mlt_properties_set_int( properties, "hide", 2 ); + else if ( strcmp( hide_s, "both" ) == 0 ) + mlt_properties_set_int( properties, "hide", 3 ); + } + } - for ( ; atts != NULL && *atts != NULL; atts += 2 ) - mlt_properties_set( properties, (char*) atts[0], (char*) atts[1] ); + // Put the parent producer back + if ( container != NULL ) + context_push_service( context, container, type ); - context_push_service( context, service ); + return result; } -static void on_start_playlist( deserialise_context context, const xmlChar *name, const xmlChar **atts) +/** Attach filters defined on that to this. +*/ + +static void attach_filters( mlt_service this, mlt_service that ) { - mlt_service service = mlt_playlist_service( mlt_playlist_init() ); - mlt_properties properties = mlt_service_properties( service ); + if ( that != NULL ) + { + int i = 0; + mlt_filter filter = NULL; + for ( i = 0; ( filter = mlt_service_filter( that, i ) ) != NULL; i ++ ) + { + mlt_service_attach( this, filter ); + attach_filters( MLT_FILTER_SERVICE( filter ), MLT_FILTER_SERVICE( filter ) ); + } + } +} - track_service( context->destructors, service, (mlt_destructor) mlt_playlist_close ); +static void on_start_tractor( deserialise_context context, const xmlChar *name, const xmlChar **atts) +{ + mlt_tractor tractor = mlt_tractor_new( ); + mlt_service service = MLT_TRACTOR_SERVICE( tractor ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); - mlt_properties_set_position( properties, "length", 0 ); + track_service( context->destructors, service, (mlt_destructor) mlt_tractor_close ); for ( ; atts != NULL && *atts != NULL; atts += 2 ) - { - mlt_properties_set( properties, ( char* )atts[0], ( char* )atts[1] ); - if ( strcmp( atts[ 0 ], "out" ) == 0 ) - mlt_properties_set( properties, "_westley.out", ( char* )atts[ 1 ] ); - } + mlt_properties_set( MLT_SERVICE_PROPERTIES( service ), (const char*) atts[0], atts[1] == NULL ? "" : (const char*) atts[1] ); + + mlt_properties_set_int( MLT_TRACTOR_PROPERTIES( tractor ), "global_feed", 1 ); if ( mlt_properties_get( properties, "id" ) != NULL ) mlt_properties_set_data( context->producer_map, mlt_properties_get( properties, "id" ), service, 0, NULL, NULL ); - - context_push_service( context, service ); + + context_push_service( context, service, mlt_tractor_type ); } -static void on_start_producer( deserialise_context context, const xmlChar *name, const xmlChar **atts) +static void on_end_tractor( deserialise_context context, const xmlChar *name ) { - mlt_properties properties = context->producer_properties = mlt_properties_new(); + // Get the tractor + enum service_type type; + mlt_service tractor = context_pop_service( context, &type ); - for ( ; atts != NULL && *atts != NULL; atts += 2 ) + if ( tractor != NULL && type == mlt_tractor_type ) { - mlt_properties_set( properties, (char*) atts[0], (char*) atts[1] ); + // See if the tractor should be added to a playlist or multitrack + if ( add_producer( context, tractor, 0, mlt_producer_get_out( MLT_PRODUCER( tractor ) ) ) == 0 ) + context_push_service( context, tractor, type ); + } + else + { + fprintf( stderr, "Invalid state for tractor\n" ); } } -static void on_start_blank( deserialise_context context, const xmlChar *name, const xmlChar **atts) +static void on_start_multitrack( deserialise_context context, const xmlChar *name, const xmlChar **atts) { - // Get the playlist from the stack - mlt_service service = context_pop_service( context ); - mlt_position length = 0; + enum service_type type; + mlt_service parent = context_pop_service( context, &type ); - // Look for the length attribute - for ( ; atts != NULL && *atts != NULL; atts += 2 ) + // If we don't have a parent, then create one now, providing we're in a state where we can + if ( parent == NULL || ( type == mlt_playlist_type || type == mlt_multitrack_type ) ) { - if ( strcmp( atts[0], "length" ) == 0 ) - { - length = atoll( atts[1] ); - break; - } + mlt_tractor tractor = NULL; + // Push the parent back + if ( parent != NULL ) + context_push_service( context, parent, type ); + + // Create a tractor to contain the multitrack + tractor = mlt_tractor_new( ); + parent = MLT_TRACTOR_SERVICE( tractor ); + track_service( context->destructors, parent, (mlt_destructor) mlt_tractor_close ); + type = mlt_tractor_type; + + // Flag it as a synthesised tractor for clean up later + mlt_properties_set_int( MLT_SERVICE_PROPERTIES( parent ), "fezzik_synth", 1 ); } - // Append a blank to the playlist - mlt_playlist_blank( MLT_PLAYLIST( service ), length - 1 ); + if ( type == mlt_tractor_type ) + { + mlt_service service = MLT_SERVICE( mlt_tractor_multitrack( MLT_TRACTOR( parent ) ) ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); + for ( ; atts != NULL && *atts != NULL; atts += 2 ) + mlt_properties_set( properties, (const char*) atts[0], atts[1] == NULL ? "" : (const char*) atts[1] ); - // Push the playlist back onto the stack - context_push_service( context, service ); + if ( mlt_properties_get( properties, "id" ) != NULL ) + mlt_properties_set_data( context->producer_map, mlt_properties_get( properties,"id" ), service, 0, NULL, NULL ); + + context_push_service( context, parent, type ); + context_push_service( context, service, mlt_multitrack_type ); + } + else + { + fprintf( stderr, "Invalid multitrack position\n" ); + } } -static void on_start_entry_track( deserialise_context context, const xmlChar *name, const xmlChar **atts) +static void on_end_multitrack( deserialise_context context, const xmlChar *name ) { - // Look for the producer attribute + // Get the multitrack from the stack + enum service_type type; + mlt_service service = context_pop_service( context, &type ); + + if ( service == NULL || type != mlt_multitrack_type ) + fprintf( stderr, "End multitrack in the wrong state...\n" ); +} + +static void on_start_playlist( deserialise_context context, const xmlChar *name, const xmlChar **atts) +{ + mlt_playlist playlist = mlt_playlist_init( ); + mlt_service service = MLT_PLAYLIST_SERVICE( playlist ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); + + track_service( context->destructors, service, (mlt_destructor) mlt_playlist_close ); + for ( ; atts != NULL && *atts != NULL; atts += 2 ) { - if ( strcmp( atts[0], "producer" ) == 0 ) - { - if ( mlt_properties_get_data( context->producer_map, (char*) atts[1], NULL ) != NULL ) - // Push the referenced producer onto the stack - context_push_service( context, MLT_SERVICE( mlt_properties_get_data( context->producer_map, (char*) atts[1], NULL ) ) ); - break; - } + mlt_properties_set( properties, (const char*) atts[0], atts[1] == NULL ? "" : (const char*) atts[1] ); + + // Out will be overwritten later as we append, so we need to save it + if ( xmlStrcmp( atts[ 0 ], _x("out") ) == 0 ) + mlt_properties_set( properties, "_westley.out", ( const char* )atts[ 1 ] ); } + + if ( mlt_properties_get( properties, "id" ) != NULL ) + mlt_properties_set_data( context->producer_map, mlt_properties_get( properties, "id" ), service, 0, NULL, NULL ); + + context_push_service( context, service, mlt_playlist_type ); } -static void on_start_filter( deserialise_context context, const xmlChar *name, const xmlChar **atts) +static void on_end_playlist( deserialise_context context, const xmlChar *name ) { - mlt_properties properties = context->producer_properties = mlt_properties_new(); + // Get the playlist from the stack + enum service_type type; + mlt_service service = context_pop_service( context, &type ); - // Set the properties - for ( ; atts != NULL && *atts != NULL; atts += 2 ) - mlt_properties_set( properties, (char*) atts[0], (char*) atts[1] ); + if ( service != NULL && type == mlt_playlist_type ) + { + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); + mlt_position in = mlt_properties_get_position( properties, "in" ); + mlt_position out = mlt_properties_get_position( properties, "out" ); + + // See if the playlist should be added to a playlist or multitrack + if ( add_producer( context, service, in, out ) == 0 ) + context_push_service( context, service, type ); + } + else + { + fprintf( stderr, "Invalid state of playlist end\n" ); + } } -static void on_start_transition( deserialise_context context, const xmlChar *name, const xmlChar **atts) +static void on_start_producer( deserialise_context context, const xmlChar *name, const xmlChar **atts) { - mlt_properties properties = context->producer_properties = mlt_properties_new(); + // use a dummy service to hold properties to allow arbitrary nesting + mlt_service service = calloc( 1, sizeof( struct mlt_service_s ) ); + mlt_service_init( service, NULL ); + + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); + + context_push_service( context, service, mlt_dummy_producer_type ); - // Set the properties for ( ; atts != NULL && *atts != NULL; atts += 2 ) - mlt_properties_set( properties, (char*) atts[0], (char*) atts[1] ); + mlt_properties_set( properties, (const char*) atts[0], atts[1] == NULL ? "" : (const char*) atts[1] ); } -static void on_start_property( deserialise_context context, const xmlChar *name, const xmlChar **atts) +// Parse a SMIL clock value (as produced by Kino 0.9.1) and return position in frames +static mlt_position parse_clock_value( char *value, double fps ) { - mlt_properties properties = context->producer_properties; - char *value = NULL; - - if ( properties == NULL ) - return; + // This implementation expects a fully specified clock value - no optional + // parts (e.g. 1:05) + char *pos, *copy = strdup( value ); + int hh, mm, ss, ms; + mlt_position result = -1; + + value = copy; + pos = strchr( value, ':' ); + if ( !pos ) + return result; + *pos = '\0'; + hh = atoi( value ); + value = pos + 1; + + pos = strchr( value, ':' ); + if ( !pos ) + return result; + *pos = '\0'; + mm = atoi( value ); + value = pos + 1; - // Set the properties - for ( ; atts != NULL && *atts != NULL; atts += 2 ) + pos = strchr( value, '.' ); + if ( !pos ) + return result; + *pos = '\0'; + ss = atoi( value ); + value = pos + 1; + + ms = atoi( value ); + free( copy ); + result = ( fps * ( ( (hh * 3600) + (mm * 60) + ss ) * 1000 + ms ) / 1000 + 0.5 ); + + return result; +} + +static void on_end_producer( deserialise_context context, const xmlChar *name ) +{ + enum service_type type; + mlt_service service = context_pop_service( context, &type ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); + + if ( service != NULL && type == mlt_dummy_producer_type ) { - if ( strcmp( atts[ 0 ], "name" ) == 0 ) + mlt_service producer = NULL; + + qualify_property( context, properties, "resource" ); + char *resource = mlt_properties_get( properties, "resource" ); + + // Let Kino-SMIL src be a synonym for resource + if ( resource == NULL ) { - context->property = strdup( atts[ 1 ] ); + qualify_property( context, properties, "src" ); + resource = mlt_properties_get( properties, "src" ); } - else if ( strcmp( atts[ 0 ], "value" ) == 0 ) + + // Instantiate the producer + if ( mlt_properties_get( properties, "mlt_service" ) != NULL ) { - value = (char*) atts[ 1 ]; + char temp[ 1024 ]; + strncpy( temp, mlt_properties_get( properties, "mlt_service" ), 1024 ); + if ( resource != NULL ) + { + strcat( temp, ":" ); + strncat( temp, resource, 1023 - strlen( temp ) ); + } + producer = MLT_SERVICE( mlt_factory_producer( context->profile, "fezzik", temp ) ); } - } - if ( context->property != NULL && value != NULL ) - mlt_properties_set( properties, context->property, value ); -} - -static void on_end_multitrack( deserialise_context context, const xmlChar *name ) -{ - // Get the producer (multitrack) from the stack - mlt_service producer = context_pop_service( context ); + // Just in case the plugin requested doesn't exist... + if ( producer == NULL && resource != NULL ) + producer = MLT_SERVICE( mlt_factory_producer( context->profile, "fezzik", resource ) ); + + if ( producer == NULL ) + producer = MLT_SERVICE( mlt_factory_producer( context->profile, "fezzik", "+INVALID.txt" ) ); - // Get the tractor from the stack - mlt_service service = context_pop_service( context ); + if ( producer == NULL ) + producer = MLT_SERVICE( mlt_factory_producer( context->profile, "fezzik", "colour:red" ) ); - // Connect the tractor to the producer - mlt_tractor_connect( MLT_TRACTOR( service ), producer ); - mlt_properties_set_data( mlt_service_properties( service ), "multitrack", - MLT_MULTITRACK( producer ), 0, NULL, NULL ); + // Track this producer + track_service( context->destructors, producer, (mlt_destructor) mlt_producer_close ); - // Push the tractor back onto the stack - context_push_service( context, service ); + // Propogate the properties + qualify_property( context, properties, "resource" ); + qualify_property( context, properties, "luma" ); + qualify_property( context, properties, "luma.resource" ); + qualify_property( context, properties, "composite.luma" ); + qualify_property( context, properties, "producer.resource" ); - // Push the producer back onto the stack - context_push_service( context, producer ); -} + // Handle in/out properties separately + mlt_position in = -1; + mlt_position out = -1; + + // Get in + if ( mlt_properties_get( properties, "in" ) != NULL ) + in = mlt_properties_get_position( properties, "in" ); + // Let Kino-SMIL clipBegin be a synonym for in + if ( mlt_properties_get( properties, "clipBegin" ) != NULL ) + { + if ( strchr( mlt_properties_get( properties, "clipBegin" ), ':' ) ) + // Parse clock value + in = parse_clock_value( mlt_properties_get( properties, "clipBegin" ), + mlt_producer_get_fps( MLT_PRODUCER( producer ) ) ); + else + // Parse frames value + in = mlt_properties_get_position( properties, "clipBegin" ); + } + // Get out + if ( mlt_properties_get( properties, "out" ) != NULL ) + out = mlt_properties_get_position( properties, "out" ); + // Let Kino-SMIL clipEnd be a synonym for out + if ( mlt_properties_get( properties, "clipEnd" ) != NULL ) + { + if ( strchr( mlt_properties_get( properties, "clipEnd" ), ':' ) ) + // Parse clock value + out = parse_clock_value( mlt_properties_get( properties, "clipEnd" ), + mlt_producer_get_fps( MLT_PRODUCER( producer ) ) ); + else + // Parse frames value + out = mlt_properties_get_position( properties, "clipEnd" ); + } + // Remove in and out + mlt_properties_set( properties, "in", NULL ); + mlt_properties_set( properties, "out", NULL ); -static void on_end_playlist( deserialise_context context, const xmlChar *name ) -{ - // Get the playlist from the stack - mlt_service service = context_pop_service( context ); - mlt_properties properties = mlt_service_properties( service ); + // Inherit the properties + mlt_properties_inherit( MLT_SERVICE_PROPERTIES( producer ), properties ); - mlt_position in = mlt_properties_get_position( properties, "in" ); - mlt_position out; + // Attach all filters from service onto producer + attach_filters( producer, service ); - if ( mlt_properties_get( properties, "_westley.out" ) != NULL ) - out = mlt_properties_get_position( properties, "_westley.out" ); - else - out = mlt_properties_get_position( properties, "length" ) - 1; + // Add the producer to the producer map + if ( mlt_properties_get( properties, "id" ) != NULL ) + mlt_properties_set_data( context->producer_map, mlt_properties_get(properties, "id"), producer, 0, NULL, NULL ); - if ( mlt_properties_get_position( properties, "length" ) < out ) - mlt_properties_set_position( properties, "length", out + 1 ); + // See if the producer should be added to a playlist or multitrack + if ( add_producer( context, producer, in, out ) == 0 ) + { + // Otherwise, set in and out on... + if ( in != -1 || out != -1 ) + { + // Get the parent service + enum service_type type; + mlt_service parent = context_pop_service( context, &type ); + if ( parent != NULL ) + { + // Get the parent properties + properties = MLT_SERVICE_PROPERTIES( parent ); + + char *resource = mlt_properties_get( properties, "resource" ); + + // Put the parent producer back + context_push_service( context, parent, type ); + + // If the parent is a track or entry + if ( resource && ( strcmp( resource, "" ) == 0 ) ) + { + mlt_properties_set_position( properties, "in", in ); + mlt_properties_set_position( properties, "out", out ); + } + else + { + // Otherwise, set in and out on producer directly + mlt_producer_set_in_and_out( MLT_PRODUCER( producer ), in, out ); + } + } + else + { + // Otherwise, set in and out on producer directly + mlt_producer_set_in_and_out( MLT_PRODUCER( producer ), in, out ); + } + } - mlt_producer_set_in_and_out( MLT_PRODUCER( service ), in, out ); + // Push the producer onto the stack + context_push_service( context, producer, mlt_producer_type ); + } - // Push the playlist back onto the stack - context_push_service( context, service ); + mlt_service_close( service ); + } } -static void on_end_track( deserialise_context context, const xmlChar *name ) +static void on_start_blank( deserialise_context context, const xmlChar *name, const xmlChar **atts) { - // Get the producer from the stack - mlt_service producer = context_pop_service( context ); - - // Get the multitrack from the stack - mlt_service service = context_pop_service( context ); + // Get the playlist from the stack + enum service_type type; + mlt_service service = context_pop_service( context, &type ); + mlt_position length = 0; + + if ( type == mlt_playlist_type && service != NULL ) + { + // Look for the length attribute + for ( ; atts != NULL && *atts != NULL; atts += 2 ) + { + if ( xmlStrcmp( atts[0], _x("length") ) == 0 ) + { + length = atoll( _s(atts[1]) ); + break; + } + } - // Set the track on the multitrack - mlt_multitrack_connect( MLT_MULTITRACK( service ), - MLT_PRODUCER( producer ), - mlt_multitrack_count( MLT_MULTITRACK( service ) ) ); + // Append a blank to the playlist + mlt_playlist_blank( MLT_PLAYLIST( service ), length - 1 ); - // Push the multitrack back onto the stack - context_push_service( context, service ); + // Push the playlist back onto the stack + context_push_service( context, service, type ); + } + else + { + fprintf( stderr, "blank without a playlist - a definite no no\n" ); + } } -static void on_end_entry( deserialise_context context, const xmlChar *name ) +static void on_start_entry( deserialise_context context, const xmlChar *name, const xmlChar **atts) { - // Get the producer from the stack - mlt_service producer = context_pop_service( context ); + mlt_producer entry = NULL; + mlt_properties temp = mlt_properties_new( ); - // Get the playlist from the stack - mlt_service service = context_pop_service( context ); + for ( ; atts != NULL && *atts != NULL; atts += 2 ) + { + mlt_properties_set( temp, (const char*) atts[0], atts[1] == NULL ? "" : (const char*) atts[1] ); + + // Look for the producer attribute + if ( xmlStrcmp( atts[ 0 ], _x("producer") ) == 0 ) + { + mlt_producer producer = mlt_properties_get_data( context->producer_map, (const char*) atts[1], NULL ); + if ( producer != NULL ) + mlt_properties_set_data( temp, "producer", producer, 0, NULL, NULL ); + } + } - // Append the producer to the playlist - // TODO: THIS IS NOT CORRECT - an entry SHOULD have in/out points of its own - mlt_playlist_append_io( MLT_PLAYLIST( service ), - MLT_PRODUCER( producer ), 0, - mlt_properties_get_position( mlt_service_properties( producer ), "out" ) - mlt_properties_get_position( mlt_service_properties( producer ), "in" ) + 1 ); + // If we have a valid entry + if ( mlt_properties_get_data( temp, "producer", NULL ) != NULL ) + { + mlt_playlist_clip_info info; + enum service_type parent_type = invalid_type; + mlt_service parent = context_pop_service( context, &parent_type ); + mlt_producer producer = mlt_properties_get_data( temp, "producer", NULL ); - // Push the playlist back onto the stack - context_push_service( context, service ); -} + if ( parent_type == mlt_playlist_type ) + { + // Append the producer to the playlist + if ( mlt_properties_get( temp, "in" ) != NULL || mlt_properties_get( temp, "out" ) != NULL ) + { + mlt_playlist_append_io( MLT_PLAYLIST( parent ), producer, + mlt_properties_get_position( temp, "in" ), + mlt_properties_get_position( temp, "out" ) ); + } + else + { + mlt_playlist_append( MLT_PLAYLIST( parent ), producer ); + } -static void on_end_tractor( deserialise_context context, const xmlChar *name ) -{ - // Get and discard the last producer - mlt_producer multitrack = MLT_PRODUCER( context_pop_service( context ) ); + // Handle the repeat property + if ( mlt_properties_get_int( temp, "repeat" ) > 0 ) + { + mlt_playlist_repeat_clip( MLT_PLAYLIST( parent ), + mlt_playlist_count( MLT_PLAYLIST( parent ) ) - 1, + mlt_properties_get_int( temp, "repeat" ) ); + } - // Get the tractor - mlt_service tractor = context_pop_service( context ); - multitrack = mlt_properties_get_data( mlt_service_properties( tractor ), "multitrack", NULL ); + mlt_playlist_get_clip_info( MLT_PLAYLIST( parent ), &info, mlt_playlist_count( MLT_PLAYLIST( parent ) ) - 1 ); + entry = info.cut; + } + else + { + fprintf( stderr, "Entry not part of a playlist...\n" ); + } + + context_push_service( context, parent, parent_type ); + } - // Inherit the producer's properties - mlt_properties properties = mlt_producer_properties( multitrack ); - mlt_properties_set_position( properties, "length", mlt_producer_get_out( multitrack ) + 1 ); - mlt_producer_set_in_and_out( multitrack, 0, mlt_producer_get_out( multitrack ) ); - mlt_properties_set_double( properties, "fps", mlt_producer_get_fps( multitrack ) ); + // Push the cut onto the stack + context_push_service( context, MLT_PRODUCER_SERVICE( entry ), mlt_entry_type ); - // Push the playlist back onto the stack - context_push_service( context, tractor ); + mlt_properties_close( temp ); } -static void on_end_property( deserialise_context context, const xmlChar *name ) +static void on_end_entry( deserialise_context context, const xmlChar *name ) { - // Close this property handling - free( context->property ); - context->property = NULL; + // Get the entry from the stack + enum service_type entry_type = invalid_type; + mlt_service entry = context_pop_service( context, &entry_type ); + + if ( entry == NULL && entry_type != mlt_entry_type ) + { + fprintf( stderr, "Invalid state at end of entry\n" ); + } } -static void on_end_producer( deserialise_context context, const xmlChar *name ) +static void on_start_track( deserialise_context context, const xmlChar *name, const xmlChar **atts) { - mlt_properties properties = context->producer_properties; - mlt_service service = NULL; + // use a dummy service to hold properties to allow arbitrary nesting + mlt_service service = calloc( 1, sizeof( struct mlt_service_s ) ); + mlt_service_init( service, NULL ); + + // Push the dummy service onto the stack + context_push_service( context, service, mlt_entry_type ); - if ( properties == NULL ) - return; - - // Instatiate the producer - service = MLT_SERVICE( mlt_factory_producer( "fezzik", mlt_properties_get( properties, "resource" ) ) ); + mlt_properties_set( MLT_SERVICE_PROPERTIES( service ), "resource", "" ); - if ( service == NULL && mlt_properties_get( properties, "mlt_service" ) != NULL ) + for ( ; atts != NULL && *atts != NULL; atts += 2 ) { - service = MLT_SERVICE( mlt_factory_producer( mlt_properties_get( properties, "mlt_service" ), - mlt_properties_get( properties, "resource" ) ) ); + mlt_properties_set( MLT_SERVICE_PROPERTIES( service ), (const char*) atts[0], atts[1] == NULL ? "" : (const char*) atts[1] ); + + // Look for the producer attribute + if ( xmlStrcmp( atts[ 0 ], _x("producer") ) == 0 ) + { + mlt_producer producer = mlt_properties_get_data( context->producer_map, (const char*) atts[1], NULL ); + if ( producer != NULL ) + mlt_properties_set_data( MLT_SERVICE_PROPERTIES( service ), "producer", producer, 0, NULL, NULL ); + } } +} - track_service( context->destructors, service, (mlt_destructor) mlt_producer_close ); +static void on_end_track( deserialise_context context, const xmlChar *name ) +{ + // Get the track from the stack + enum service_type track_type; + mlt_service track = context_pop_service( context, &track_type ); - // Add the producer to the producer map - if ( mlt_properties_get( properties, "id" ) != NULL ) - mlt_properties_set_data( context->producer_map, mlt_properties_get( properties, "id" ), service, 0, NULL, NULL ); + if ( track != NULL && track_type == mlt_entry_type ) + { + mlt_properties track_props = MLT_SERVICE_PROPERTIES( track ); + enum service_type parent_type = invalid_type; + mlt_service parent = context_pop_service( context, &parent_type ); + mlt_multitrack multitrack = NULL; + + mlt_producer producer = mlt_properties_get_data( track_props, "producer", NULL ); + mlt_properties producer_props = MLT_PRODUCER_PROPERTIES( producer ); + + if ( parent_type == mlt_tractor_type ) + multitrack = mlt_tractor_multitrack( MLT_TRACTOR( parent ) ); + else if ( parent_type == mlt_multitrack_type ) + multitrack = MLT_MULTITRACK( parent ); + else + fprintf( stderr, "track contained in an invalid container\n" ); + + if ( multitrack != NULL ) + { + // Set producer i/o if specified + if ( mlt_properties_get( track_props, "in" ) != NULL || + mlt_properties_get( track_props, "out" ) != NULL ) + { + mlt_producer cut = mlt_producer_cut( MLT_PRODUCER( producer ), + mlt_properties_get_position( track_props, "in" ), + mlt_properties_get_position( track_props, "out" ) ); + mlt_multitrack_connect( multitrack, cut, mlt_multitrack_count( multitrack ) ); + mlt_properties_inherit( MLT_PRODUCER_PROPERTIES( cut ), track_props ); + track_props = MLT_PRODUCER_PROPERTIES( cut ); + mlt_producer_close( cut ); + } + else + { + mlt_multitrack_connect( multitrack, producer, mlt_multitrack_count( multitrack ) ); + } - mlt_properties_inherit( mlt_service_properties( service ), properties ); - mlt_properties_close( properties ); - context->producer_properties = NULL; - properties = mlt_service_properties( service ); + // Set the hide state of the track producer + char *hide_s = mlt_properties_get( track_props, "hide" ); + if ( hide_s != NULL ) + { + if ( strcmp( hide_s, "video" ) == 0 ) + mlt_properties_set_int( producer_props, "hide", 1 ); + else if ( strcmp( hide_s, "audio" ) == 0 ) + mlt_properties_set_int( producer_props, "hide", 2 ); + else if ( strcmp( hide_s, "both" ) == 0 ) + mlt_properties_set_int( producer_props, "hide", 3 ); + } + } - // Set in and out - mlt_producer_set_in_and_out( MLT_PRODUCER( service ), - mlt_properties_get_position( properties, "in" ), - mlt_properties_get_position( properties, "out" ) ); + if ( parent != NULL ) + context_push_service( context, parent, parent_type ); - // Push the new producer onto the stack - context_push_service( context, service ); + mlt_service_close( track ); + } + else + { + fprintf( stderr, "Invalid state at end of track\n" ); + } } -static void on_end_filter( deserialise_context context, const xmlChar *name ) +static void on_start_filter( deserialise_context context, const xmlChar *name, const xmlChar **atts) { - mlt_properties properties = context->producer_properties; - if ( properties == NULL ) - return; + // use a dummy service to hold properties to allow arbitrary nesting + mlt_service service = calloc( 1, sizeof( struct mlt_service_s ) ); + mlt_service_init( service, NULL ); - char *id; - char key[11]; - key[ 10 ] = '\0'; + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); - // Get the producer from the stack - mlt_service producer = context_pop_service( context ); -//fprintf( stderr, "connecting filter to %s\n", mlt_properties_get( mlt_service_properties( producer ), "resource" ) ); + context_push_service( context, service, mlt_dummy_filter_type ); - // Create the filter - mlt_service service = MLT_SERVICE( mlt_factory_filter( mlt_properties_get( properties, "mlt_service" ), NULL ) ); + // Set the properties + for ( ; atts != NULL && *atts != NULL; atts += 2 ) + mlt_properties_set( properties, (const char*) atts[0], (const char*) atts[1] ); +} - track_service( context->destructors, service, (mlt_destructor) mlt_filter_close ); +static void on_end_filter( deserialise_context context, const xmlChar *name ) +{ + enum service_type type; + mlt_service service = context_pop_service( context, &type ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); - // Connect the filter to the producer - mlt_filter_connect( MLT_FILTER( service ), producer, - mlt_properties_get_int( properties, "track" ) ); + enum service_type parent_type = invalid_type; + mlt_service parent = context_pop_service( context, &parent_type ); - // Set in and out from producer if non existant - if ( mlt_properties_get( properties, "in" ) == NULL ) - mlt_properties_set_position( properties, "in", mlt_producer_get_in( MLT_PRODUCER( producer ) ) ); - if ( mlt_properties_get( properties, "out" ) == NULL ) - mlt_properties_set_position( properties, "out", mlt_producer_get_out( MLT_PRODUCER( producer ) ) ); + if ( service != NULL && type == mlt_dummy_filter_type ) + { + mlt_service filter = MLT_SERVICE( mlt_factory_filter( context->profile, mlt_properties_get( properties, "mlt_service" ), NULL ) ); + mlt_properties filter_props = MLT_SERVICE_PROPERTIES( filter ); - // Propogate the properties - mlt_properties_inherit( mlt_service_properties( service ), properties ); - mlt_properties_close( properties ); - context->producer_properties = NULL; - properties = mlt_service_properties( service ); + track_service( context->destructors, filter, (mlt_destructor) mlt_filter_close ); - // Set in and out -//fprintf( stderr, "setting filter in %lld out %lld\n", mlt_properties_get_position( properties, "in" ), mlt_properties_get_position( properties, "out" ) ); - mlt_filter_set_in_and_out( MLT_FILTER( service ), - mlt_properties_get_position( properties, "in" ), - mlt_properties_get_position( properties, "out" ) ); + // Propogate the properties + qualify_property( context, properties, "resource" ); + qualify_property( context, properties, "luma" ); + qualify_property( context, properties, "luma.resource" ); + qualify_property( context, properties, "composite.luma" ); + qualify_property( context, properties, "producer.resource" ); + mlt_properties_inherit( filter_props, properties ); - // Get the parent producer from the stack - mlt_service tractor = context_pop_service( context ); + // Attach all filters from service onto filter + attach_filters( filter, service ); - if ( tractor != NULL ) - { -//fprintf( stderr, "connecting tractor %s to filter\n", mlt_properties_get( mlt_service_properties( tractor ), "resource" ) ); - // Connect the tractor to the filter - if ( strcmp( mlt_properties_get( mlt_service_properties( tractor ), "resource" ), "" ) == 0 ) - mlt_tractor_connect( MLT_TRACTOR( tractor ), service ); + // Associate the filter with the parent + if ( parent != NULL ) + { + if ( parent_type == mlt_tractor_type ) + { + mlt_field field = mlt_tractor_field( MLT_TRACTOR( parent ) ); + mlt_field_plant_filter( field, MLT_FILTER( filter ), mlt_properties_get_int( properties, "track" ) ); + mlt_filter_set_in_and_out( MLT_FILTER( filter ), + mlt_properties_get_int( properties, "in" ), + mlt_properties_get_int( properties, "out" ) ); + } + else + { + mlt_service_attach( parent, MLT_FILTER( filter ) ); + } - // Push the parent producer back onto the stack - context_push_service( context, tractor ); - } + // Put the parent back on the stack + context_push_service( context, parent, parent_type ); + } + else + { + fprintf( stderr, "filter closed with invalid parent...\n" ); + } -//fprintf( stderr, "setting filter in %lld out %lld\n", mlt_properties_get_position( properties, "in" ), mlt_properties_get_position( properties, "out" ) ); - // If a producer alias is in the producer_map, get it - snprintf( key, 10, "%p", producer ); - if ( mlt_properties_get_data( context->producer_map, key, NULL ) != NULL ) - producer = mlt_properties_get_data( context->producer_map, key, NULL ); + // Close the dummy filter service + mlt_service_close( service ); + } + else + { + fprintf( stderr, "Invalid top of stack on filter close\n" ); + } +} - // Put the producer in the producer map - id = mlt_properties_get( mlt_service_properties( producer ), "id" ); - if ( id != NULL ) - mlt_properties_set_data( context->producer_map, id, service, 0, NULL, NULL ); +static void on_start_transition( deserialise_context context, const xmlChar *name, const xmlChar **atts) +{ + // use a dummy service to hold properties to allow arbitrary nesting + mlt_service service = calloc( 1, sizeof( struct mlt_service_s ) ); + mlt_service_init( service, NULL ); - // For filter chain support, add an alias to the producer map - snprintf( key, 10, "%p", service ); - mlt_properties_set_data( context->producer_map, key, producer, 0, NULL, NULL ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); - // Push the filter onto the stack - context_push_service( context, service ); + context_push_service( context, service, mlt_dummy_transition_type ); + // Set the properties + for ( ; atts != NULL && *atts != NULL; atts += 2 ) + mlt_properties_set( properties, (const char*) atts[0], (const char*) atts[1] ); } static void on_end_transition( deserialise_context context, const xmlChar *name ) { - mlt_properties properties = context->producer_properties; - if ( properties == NULL ) - return; + enum service_type type; + mlt_service service = context_pop_service( context, &type ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); + + enum service_type parent_type = invalid_type; + mlt_service parent = context_pop_service( context, &parent_type ); + + if ( service != NULL && type == mlt_dummy_transition_type ) + { + char *id = mlt_properties_get( properties, "mlt_service" ); + mlt_service effect = MLT_SERVICE( mlt_factory_transition( context->profile, id, NULL ) ); + mlt_properties effect_props = MLT_SERVICE_PROPERTIES( effect ); - // Get the producer from the stack - mlt_service producer = context_pop_service( context ); + track_service( context->destructors, effect, (mlt_destructor) mlt_transition_close ); - // Create the transition - mlt_service service = MLT_SERVICE( mlt_factory_transition( mlt_properties_get( properties, "mlt_service" ), NULL ) ); + // Propogate the properties + qualify_property( context, properties, "resource" ); + qualify_property( context, properties, "luma" ); + qualify_property( context, properties, "luma.resource" ); + qualify_property( context, properties, "composite.luma" ); + qualify_property( context, properties, "producer.resource" ); + mlt_properties_inherit( effect_props, properties ); + + // Attach all filters from service onto effect + attach_filters( effect, service ); + + // Associate the filter with the parent + if ( parent != NULL ) + { + if ( parent_type == mlt_tractor_type ) + { + mlt_field field = mlt_tractor_field( MLT_TRACTOR( parent ) ); + if ( mlt_properties_get_int( properties, "a_track" ) == mlt_properties_get_int( properties, "b_track" ) ) + mlt_properties_set_int( properties, "b_track", mlt_properties_get_int( properties, "a_track" ) + 1 ); + mlt_field_plant_transition( field, MLT_TRANSITION( effect ), + mlt_properties_get_int( properties, "a_track" ), + mlt_properties_get_int( properties, "b_track" ) ); + mlt_transition_set_in_and_out( MLT_TRANSITION( effect ), + mlt_properties_get_int( properties, "in" ), + mlt_properties_get_int( properties, "out" ) ); + } + else + { + fprintf( stderr, "Misplaced transition - ignoring\n" ); + } - track_service( context->destructors, service, (mlt_destructor) mlt_transition_close ); + // Put the parent back on the stack + context_push_service( context, parent, parent_type ); + } + else + { + fprintf( stderr, "transition closed with invalid parent...\n" ); + } + + // Close the dummy filter service + mlt_service_close( service ); + } + else + { + fprintf( stderr, "Invalid top of stack on transition close\n" ); + } +} + +static void on_start_property( deserialise_context context, const xmlChar *name, const xmlChar **atts) +{ + enum service_type type; + mlt_service service = context_pop_service( context, &type ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); + char *value = NULL; + + if ( service != NULL ) + { + // Set the properties + for ( ; atts != NULL && *atts != NULL; atts += 2 ) + { + if ( xmlStrcmp( atts[ 0 ], _x("name") ) == 0 ) + context->property = strdup( _s(atts[ 1 ]) ); + else if ( xmlStrcmp( atts[ 0 ], _x("value") ) == 0 ) + value = _s(atts[ 1 ]); + } - // Propogate the properties - mlt_properties_inherit( mlt_service_properties( service ), properties ); - mlt_properties_close( properties ); - context->producer_properties = NULL; - properties = mlt_service_properties( service ); + if ( context->property != NULL ) + mlt_properties_set( properties, context->property, value == NULL ? "" : value ); - // Set in and out - mlt_transition_set_in_and_out( MLT_TRANSITION( service ), - mlt_properties_get_position( properties, "in" ), - mlt_properties_get_position( properties, "out" ) ); + // Tell parser to collect any further nodes for serialisation + context->is_value = 1; - // Connect the filter to the producer - mlt_transition_connect( MLT_TRANSITION( service ), producer, - mlt_properties_get_int( properties, "a_track" ), - mlt_properties_get_int( properties, "b_track" ) ); + context_push_service( context, service, type ); + } + else + { + fprintf( stderr, "Property without a service '%s'?\n", ( const char * )name ); + } +} - // Get the tractor from the stack - mlt_service tractor = context_pop_service( context ); +static void on_end_property( deserialise_context context, const xmlChar *name ) +{ + enum service_type type; + mlt_service service = context_pop_service( context, &type ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); - // Connect the tractor to the transition - mlt_tractor_connect( MLT_TRACTOR( tractor ), service ); + if ( service != NULL ) + { + // Tell parser to stop building a tree + context->is_value = 0; + + // See if there is a xml tree for the value + if ( context->property != NULL && context->value_doc != NULL ) + { + xmlChar *value; + int size; + + // Serialise the tree to get value + xmlDocDumpMemory( context->value_doc, &value, &size ); + mlt_properties_set( properties, context->property, _s(value) ); + xmlFree( value ); + xmlFreeDoc( context->value_doc ); + context->value_doc = NULL; + } - // Push the tractor back onto the stack - context_push_service( context, tractor ); + // Close this property handling + free( context->property ); + context->property = NULL; - // Push the transition onto the stack - context_push_service( context, service ); + context_push_service( context, service, type ); + } + else + { + fprintf( stderr, "Property without a service '%s'??\n", (const char *)name ); + } } static void on_start_element( void *ctx, const xmlChar *name, const xmlChar **atts) { - deserialise_context context = ( deserialise_context ) ctx; + struct _xmlParserCtxt *xmlcontext = ( struct _xmlParserCtxt* )ctx; + deserialise_context context = ( deserialise_context )( xmlcontext->_private ); + +//printf("on_start_element: %s\n", name ); + context->branch[ context->depth ] ++; + context->depth ++; - if ( strcmp( name, "tractor" ) == 0 ) + // Build a tree from nodes within a property value + if ( context->is_value == 1 ) + { + xmlNodePtr node = xmlNewNode( NULL, name ); + + if ( context->value_doc == NULL ) + { + // Start a new tree + context->value_doc = xmlNewDoc( _x("1.0") ); + xmlDocSetRootElement( context->value_doc, node ); + } + else + { + // Append child to tree + xmlAddChild( context->stack_node[ context->stack_node_size - 1 ], node ); + } + context_push_node( context, node ); + + // Set the attributes + for ( ; atts != NULL && *atts != NULL; atts += 2 ) + xmlSetProp( node, atts[ 0 ], atts[ 1 ] ); + } + else if ( xmlStrcmp( name, _x("tractor") ) == 0 ) on_start_tractor( context, name, atts ); - else if ( strcmp( name, "multitrack" ) == 0 ) + else if ( xmlStrcmp( name, _x("multitrack") ) == 0 ) on_start_multitrack( context, name, atts ); - else if ( strcmp( name, "playlist" ) == 0 ) + else if ( xmlStrcmp( name, _x("playlist") ) == 0 || xmlStrcmp( name, _x("seq") ) == 0 || xmlStrcmp( name, _x("smil") ) == 0 ) on_start_playlist( context, name, atts ); - else if ( strcmp( name, "producer" ) == 0 ) + else if ( xmlStrcmp( name, _x("producer") ) == 0 || xmlStrcmp( name, _x("video") ) == 0 ) on_start_producer( context, name, atts ); - else if ( strcmp( name, "blank" ) == 0 ) + else if ( xmlStrcmp( name, _x("blank") ) == 0 ) on_start_blank( context, name, atts ); - else if ( strcmp( name, "entry" ) == 0 || strcmp( name, "track" ) == 0 ) - on_start_entry_track( context, name, atts ); - else if ( strcmp( name, "filter" ) == 0 ) + else if ( xmlStrcmp( name, _x("entry") ) == 0 ) + on_start_entry( context, name, atts ); + else if ( xmlStrcmp( name, _x("track") ) == 0 ) + on_start_track( context, name, atts ); + else if ( xmlStrcmp( name, _x("filter") ) == 0 ) on_start_filter( context, name, atts ); - else if ( strcmp( name, "transition" ) == 0 ) + else if ( xmlStrcmp( name, _x("transition") ) == 0 ) on_start_transition( context, name, atts ); - else if ( strcmp( name, "property" ) == 0 ) + else if ( xmlStrcmp( name, _x("property") ) == 0 ) on_start_property( context, name, atts ); + else if ( xmlStrcmp( name, _x("westley") ) == 0 ) + for ( ; atts != NULL && *atts != NULL; atts += 2 ) + mlt_properties_set( context->producer_map, ( const char * )atts[ 0 ], ( const char * )atts[ 1 ] ); } static void on_end_element( void *ctx, const xmlChar *name ) { - deserialise_context context = ( deserialise_context ) ctx; + struct _xmlParserCtxt *xmlcontext = ( struct _xmlParserCtxt* )ctx; + deserialise_context context = ( deserialise_context )( xmlcontext->_private ); - if ( strcmp( name, "multitrack" ) == 0 ) +//printf("on_end_element: %s\n", name ); + if ( context->is_value == 1 && xmlStrcmp( name, _x("property") ) != 0 ) + context_pop_node( context ); + else if ( xmlStrcmp( name, _x("multitrack") ) == 0 ) on_end_multitrack( context, name ); - else if ( strcmp( name, "playlist" ) == 0 ) + else if ( xmlStrcmp( name, _x("playlist") ) == 0 || xmlStrcmp( name, _x("seq") ) == 0 || xmlStrcmp( name, _x("smil") ) == 0 ) on_end_playlist( context, name ); - else if ( strcmp( name, "track" ) == 0 ) + else if ( xmlStrcmp( name, _x("track") ) == 0 ) on_end_track( context, name ); - else if ( strcmp( name, "entry" ) == 0 ) + else if ( xmlStrcmp( name, _x("entry") ) == 0 ) on_end_entry( context, name ); - else if ( strcmp( name, "tractor" ) == 0 ) + else if ( xmlStrcmp( name, _x("tractor") ) == 0 ) on_end_tractor( context, name ); - else if ( strcmp( name, "property" ) == 0 ) + else if ( xmlStrcmp( name, _x("property") ) == 0 ) on_end_property( context, name ); - else if ( strcmp( name, "producer" ) == 0 ) + else if ( xmlStrcmp( name, _x("producer") ) == 0 || xmlStrcmp( name, _x("video") ) == 0 ) on_end_producer( context, name ); - else if ( strcmp( name, "filter" ) == 0 ) + else if ( xmlStrcmp( name, _x("filter") ) == 0 ) on_end_filter( context, name ); - else if ( strcmp( name, "transition" ) == 0 ) + else if ( xmlStrcmp( name, _x("transition") ) == 0 ) on_end_transition( context, name ); + + context->branch[ context->depth ] = 0; + context->depth --; } static void on_characters( void *ctx, const xmlChar *ch, int len ) { - deserialise_context context = ( deserialise_context ) ctx; + struct _xmlParserCtxt *xmlcontext = ( struct _xmlParserCtxt* )ctx; + deserialise_context context = ( deserialise_context )( xmlcontext->_private ); char *value = calloc( len + 1, 1 ); + enum service_type type; + mlt_service service = context_pop_service( context, &type ); + mlt_properties properties = MLT_SERVICE_PROPERTIES( service ); + + if ( service != NULL ) + context_push_service( context, service, type ); value[ len ] = 0; strncpy( value, (const char*) ch, len ); - if ( context->property != NULL && context->producer_properties != NULL ) - mlt_properties_set( context->producer_properties, context->property, value ); - + if ( context->stack_node_size > 0 ) + xmlNodeAddContent( context->stack_node[ context->stack_node_size - 1 ], ( xmlChar* )value ); + + // libxml2 generates an on_characters immediately after a get_entity within + // an element value, and we ignore it because it is called again during + // actual substitution. + else if ( context->property != NULL && context->entity_is_replace == 0 ) + { + char *s = mlt_properties_get( properties, context->property ); + if ( s != NULL ) + { + // Append new text to existing content + char *new = calloc( strlen( s ) + len + 1, 1 ); + strcat( new, s ); + strcat( new, value ); + mlt_properties_set( properties, context->property, new ); + free( new ); + } + else + mlt_properties_set( properties, context->property, value ); + } + context->entity_is_replace = 0; + free( value); } -mlt_producer producer_westley_init( char *filename ) +/** Convert parameters parsed from resource into entity declarations. +*/ +static void params_to_entities( deserialise_context context ) +{ + if ( context->params != NULL ) + { + int i; + + // Add our params as entitiy declarations + for ( i = 0; i < mlt_properties_count( context->params ); i++ ) + { + xmlChar *name = ( xmlChar* )mlt_properties_get_name( context->params, i ); + xmlAddDocEntity( context->entity_doc, name, XML_INTERNAL_GENERAL_ENTITY, + context->publicId, context->systemId, ( xmlChar* )mlt_properties_get( context->params, _s(name) ) ); + } + + // Flag completion + mlt_properties_close( context->params ); + context->params = NULL; + } +} + +// The following 3 facilitate entity substitution in the SAX parser +static void on_internal_subset( void *ctx, const xmlChar* name, + const xmlChar* publicId, const xmlChar* systemId ) +{ + struct _xmlParserCtxt *xmlcontext = ( struct _xmlParserCtxt* )ctx; + deserialise_context context = ( deserialise_context )( xmlcontext->_private ); + + context->publicId = publicId; + context->systemId = systemId; + xmlCreateIntSubset( context->entity_doc, name, publicId, systemId ); + + // Override default entities with our parameters + params_to_entities( context ); +} + +// TODO: Check this with Dan... I think this is for westley parameterisation +// but it's breaking standard escaped entities (like < etc). +static void on_entity_declaration( void *ctx, const xmlChar* name, int type, + const xmlChar* publicId, const xmlChar* systemId, xmlChar* content) +{ + struct _xmlParserCtxt *xmlcontext = ( struct _xmlParserCtxt* )ctx; + deserialise_context context = ( deserialise_context )( xmlcontext->_private ); + + xmlAddDocEntity( context->entity_doc, name, type, publicId, systemId, content ); +} + +// TODO: Check this functionality (see on_entity_declaration) +static xmlEntityPtr on_get_entity( void *ctx, const xmlChar* name ) +{ + struct _xmlParserCtxt *xmlcontext = ( struct _xmlParserCtxt* )ctx; + deserialise_context context = ( deserialise_context )( xmlcontext->_private ); + xmlEntityPtr e = NULL; + + // Setup for entity declarations if not ready + if ( xmlGetIntSubset( context->entity_doc ) == NULL ) + { + xmlCreateIntSubset( context->entity_doc, _x("westley"), _x(""), _x("") ); + context->publicId = _x(""); + context->systemId = _x(""); + } + + // Add our parameters if not already + params_to_entities( context ); + + e = xmlGetPredefinedEntity( name ); + + // Send signal to on_characters that an entity substitutin is pending + if ( e == NULL ) + { + e = xmlGetDocEntity( context->entity_doc, name ); + if ( e != NULL ) + context->entity_is_replace = 1; + } + + return e; +} + +/** Convert a hexadecimal character to its value. +*/ +static int tohex( char p ) +{ + return isdigit( p ) ? p - '0' : tolower( p ) - 'a' + 10; +} + +/** Decode a url-encoded string containing hexadecimal character sequences. +*/ +static char *url_decode( char *dest, char *src ) +{ + char *p = dest; + + while ( *src ) + { + if ( *src == '%' ) + { + *p ++ = ( tohex( *( src + 1 ) ) << 4 ) | tohex( *( src + 2 ) ); + src += 3; + } + else + { + *p ++ = *src ++; + } + } + + *p = *src; + return dest; +} + +/** Extract the filename from a URL attaching parameters to a properties list. +*/ +static void parse_url( mlt_properties properties, char *url ) +{ + int i; + int n = strlen( url ); + char *name = NULL; + char *value = NULL; + + for ( i = 0; i < n; i++ ) + { + switch ( url[ i ] ) + { + case '?': + url[ i++ ] = '\0'; + name = &url[ i ]; + break; + + case ':': + case '=': + url[ i++ ] = '\0'; + value = &url[ i ]; + break; + + case '&': + url[ i++ ] = '\0'; + if ( name != NULL && value != NULL ) + mlt_properties_set( properties, name, value ); + name = &url[ i ]; + value = NULL; + break; + } + } + if ( name != NULL && value != NULL ) + mlt_properties_set( properties, name, value ); +} + +// Quick workaround to avoid unecessary libxml2 warnings +static int file_exists( char *file ) +{ + char *name = strdup( file ); + int exists = 0; + if ( name != NULL && strchr( name, '?' ) ) + *( strchr( name, '?' ) ) = '\0'; + if ( name != NULL ) + { + FILE *f = fopen( name, "r" ); + exists = f != NULL; + if ( exists ) fclose( f ); + } + free( name ); + return exists; +} + +mlt_producer producer_westley_init( mlt_profile profile, mlt_service_type servtype, const char *id, char *data ) { - static int init = 0; xmlSAXHandler *sax = calloc( 1, sizeof( xmlSAXHandler ) ); struct deserialise_context_s *context = calloc( 1, sizeof( struct deserialise_context_s ) ); mlt_properties properties = NULL; int i = 0; + struct _xmlParserCtxt *xmlcontext; + int well_formed = 0; + char *filename = NULL; + int info = strcmp( id, "westley-xml" ) ? 0 : 1; + + if ( data == NULL || !strcmp( data, "" ) || ( info == 0 && !file_exists( data ) ) ) + return NULL; + + context = calloc( 1, sizeof( struct deserialise_context_s ) ); + if ( context == NULL ) + return NULL; context->producer_map = mlt_properties_new(); context->destructors = mlt_properties_new(); + context->params = mlt_properties_new(); + context->profile = profile; + + // Decode URL and parse parameters + mlt_properties_set( context->producer_map, "root", "" ); + if ( info == 0 ) + { + filename = strdup( data ); + parse_url( context->params, url_decode( filename, data ) ); + + // We need the directory prefix which was used for the westley + if ( strchr( filename, '/' ) ) + { + char *root = NULL; + mlt_properties_set( context->producer_map, "root", filename ); + root = mlt_properties_get( context->producer_map, "root" ); + *( strrchr( root, '/' ) ) = '\0'; + + // If we don't have an absolute path here, we're heading for disaster... + if ( root[ 0 ] != '/' ) + { + char *cwd = getcwd( NULL, 0 ); + char *real = malloc( strlen( cwd ) + strlen( root ) + 2 ); + sprintf( real, "%s/%s", cwd, root ); + mlt_properties_set( context->producer_map, "root", real ); + free( real ); + free( cwd ); + } + } + } + // We need to track the number of registered filters mlt_properties_set_int( context->destructors, "registered", 0 ); + + // Setup SAX callbacks sax->startElement = on_start_element; sax->endElement = on_end_element; sax->characters = on_characters; + sax->cdataBlock = on_characters; + sax->internalSubset = on_internal_subset; + sax->entityDecl = on_entity_declaration; + sax->getEntity = on_get_entity; + + // Setup libxml2 SAX parsing + xmlInitParser(); + xmlSubstituteEntitiesDefault( 1 ); + // This is used to facilitate entity substitution in the SAX parser + context->entity_doc = xmlNewDoc( _x("1.0") ); + if ( info == 0 ) + xmlcontext = xmlCreateFileParserCtxt( filename ); + else + xmlcontext = xmlCreateMemoryParserCtxt( data, strlen( data ) ); - if ( !init ) + // Invalid context - clean up and return NULL + if ( xmlcontext == NULL ) { - xmlInitParser(); - //init = 1; + mlt_properties_close( context->producer_map ); + mlt_properties_close( context->destructors ); + mlt_properties_close( context->params ); + free( context ); + free( sax ); + free( filename ); + return NULL; } - xmlSAXUserParseFile( sax, context, filename ); - - // Need the complete producer list for various reasons - properties = context->destructors; + xmlcontext->sax = sax; + xmlcontext->_private = ( void* )context; + + // Parse + xmlParseDocument( xmlcontext ); + well_formed = xmlcontext->wellFormed; + + // Cleanup after parsing + xmlFreeDoc( context->entity_doc ); + free( sax ); + xmlcontext->sax = NULL; + xmlcontext->_private = NULL; + xmlFreeParserCtxt( xmlcontext ); + xmlMemoryDump( ); // for debugging // Get the last producer on the stack - mlt_service service = context_pop_service( context ); + enum service_type type; + mlt_service service = context_pop_service( context, &type ); + if ( well_formed && service != NULL ) + { + // Verify it is a producer service (mlt_type="mlt_producer") + // (producer, playlist, multitrack) + char *type = mlt_properties_get( MLT_SERVICE_PROPERTIES( service ), "mlt_type" ); + if ( type == NULL || ( strcmp( type, "mlt_producer" ) != 0 && strcmp( type, "producer" ) != 0 ) ) + service = NULL; + } - // Do we actually have a producer here? - if ( service != NULL ) +#ifdef DEBUG + xmlDocPtr doc = westley_make_doc( service ); + xmlDocFormatDump( stdout, doc, 1 ); + xmlFreeDoc( doc ); + service = NULL; +#endif + + if ( well_formed && service != NULL ) { + char *title = mlt_properties_get( context->producer_map, "title" ); + + // Need the complete producer list for various reasons + properties = context->destructors; + // Now make sure we don't have a reference to the service in the properties for ( i = mlt_properties_count( properties ) - 1; i >= 1; i -- ) { @@ -589,31 +1472,44 @@ mlt_producer producer_westley_init( char *filename ) // We are done referencing destructor property list // Set this var to service properties for convenience - properties = mlt_service_properties( service ); + properties = MLT_SERVICE_PROPERTIES( service ); - // make the returned service destroy the connected services - mlt_properties_set_data( properties, "__destructors__", context->destructors, 0, (mlt_destructor) mlt_properties_close, NULL ); + // Assign the title + mlt_properties_set( properties, "title", title ); + + // Optimise for overlapping producers + mlt_producer_optimise( MLT_PRODUCER( service ) ); - // Now assign additional properties - mlt_properties_set( properties, "resource", filename ); + // Handle deep copies + if ( getenv( "MLT_WESTLEY_DEEP" ) == NULL ) + { + // Now assign additional properties + if ( info == 0 ) + mlt_properties_set( properties, "resource", data ); - // This tells consumer_westley not to deep copy - mlt_properties_set( properties, "westley", "was here" ); + // This tells consumer_westley not to deep copy + mlt_properties_set( properties, "westley", "was here" ); + } + else + { + // Allow the project to be edited + mlt_properties_set( properties, "_westley", "was here" ); + mlt_properties_set_int( properties, "_mlt_service_hidden", 1 ); + } } else { - // Clean up - mlt_properties_close( properties ); + // Return null if not well formed + service = NULL; } - free( context->stack_service ); + // Clean up mlt_properties_close( context->producer_map ); - //free( context ); - free( sax ); - xmlCleanupParser(); - xmlMemoryDump( ); - + if ( context->params != NULL ) + mlt_properties_close( context->params ); + mlt_properties_close( context->destructors ); + free( context ); + free( filename ); return MLT_PRODUCER( service ); } -