2 * valerie.c -- High Level Client API for miracle
3 * Copyright (C) 2002-2003 Ushodaya Enterprises Limited
4 * Author: Charles Yates <charles.yates@pandora.be>
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
21 /* System header files */
27 /* Application header files */
29 #include "valerie_tokeniser.h"
30 #include "valerie_util.h"
32 /** Initialise the valerie structure.
35 valerie
valerie_init( valerie_parser parser
)
37 valerie
this = malloc( sizeof( valerie_t
) );
40 memset( this, 0, sizeof( valerie_t
) );
41 this->parser
= parser
;
46 /** Set the response structure associated to the last command.
49 static void valerie_set_last_response( valerie
this, valerie_response response
)
53 if ( this->last_response
!= NULL
)
54 valerie_response_close( this->last_response
);
55 this->last_response
= response
;
59 /** Connect to the parser.
62 valerie_error_code
valerie_connect( valerie
this )
64 valerie_error_code error
= valerie_server_unavailable
;
65 valerie_response response
= valerie_parser_connect( this->parser
);
66 if ( response
!= NULL
)
68 valerie_set_last_response( this, response
);
69 if ( valerie_response_get_error_code( response
) == 100 )
75 /** Interpret a non-context sensitive error code.
78 static valerie_error_code
valerie_get_error_code( valerie
this, valerie_response response
)
80 valerie_error_code error
= valerie_server_unavailable
;
81 switch( valerie_response_get_error_code( response
) )
84 error
= valerie_server_unavailable
;
87 error
= valerie_no_response
;
95 error
= valerie_invalid_command
;
98 error
= valerie_server_timeout
;
101 error
= valerie_missing_argument
;
104 error
= valerie_unit_unavailable
;
107 error
= valerie_invalid_file
;
111 error
= valerie_unknown_error
;
117 /** Execute a command.
120 valerie_error_code
valerie_execute( valerie
this, size_t size
, char *format
, ... )
122 valerie_error_code error
= valerie_server_unavailable
;
123 char *command
= malloc( size
);
124 if ( this != NULL
&& command
!= NULL
)
127 va_start( list
, format
);
128 if ( vsnprintf( command
, size
, format
, list
) != 0 )
130 valerie_response response
= valerie_parser_execute( this->parser
, command
);
131 valerie_set_last_response( this, response
);
132 error
= valerie_get_error_code( this, response
);
136 error
= valerie_invalid_command
;
142 error
= valerie_malloc_failed
;
148 /** Set a global property.
151 valerie_error_code
valerie_set( valerie
this, char *property
, char *value
)
153 return valerie_execute( this, 1024, "SET %s=%s", property
, value
);
156 /** Get a global property.
159 valerie_error_code
valerie_get( valerie
this, char *property
, char *value
, int length
)
161 valerie_error_code error
= valerie_execute( this, 1024, "GET %s", property
);
162 if ( error
== valerie_ok
)
164 valerie_response response
= valerie_get_last_response( this );
165 strncpy( value
, valerie_response_get_line( response
, 1 ), length
);
173 valerie_error_code
valerie_run( valerie
this, char *file
)
175 return valerie_execute( this, 10240, "RUN \"%s\"", file
);
181 valerie_error_code
valerie_unit_add( valerie
this, char *guid
, int *unit
)
183 valerie_error_code error
= valerie_execute( this, 1024, "UADD %s", guid
);
184 if ( error
== valerie_ok
)
186 int length
= valerie_response_count( this->last_response
);
187 char *line
= valerie_response_get_line( this->last_response
, length
- 1 );
188 if ( line
== NULL
|| sscanf( line
, "U%d", unit
) != 1 )
189 error
= valerie_unit_creation_failed
;
193 if ( error
== valerie_unknown_error
)
194 error
= valerie_unit_creation_failed
;
199 /** Load a file on the specified unit.
202 valerie_error_code
valerie_unit_load( valerie
this, int unit
, char *file
)
204 return valerie_execute( this, 10240, "LOAD U%d \"%s\"", unit
, file
);
207 static void valerie_interpret_clip_offset( char *output
, valerie_clip_offset offset
, int clip
)
211 case valerie_absolute
:
212 sprintf( output
, "%d", clip
);
214 case valerie_relative
:
216 sprintf( output
, "%d", clip
);
218 sprintf( output
, "+%d", clip
);
223 /** Load a file on the specified unit with the specified in/out points.
226 valerie_error_code
valerie_unit_load_clipped( valerie
this, int unit
, char *file
, int32_t in
, int32_t out
)
228 return valerie_execute( this, 10240, "LOAD U%d \"%s\" %d %d", unit
, file
, in
, out
);
231 /** Load a file on the specified unit at the end of the current pump.
234 valerie_error_code
valerie_unit_load_back( valerie
this, int unit
, char *file
)
236 return valerie_execute( this, 10240, "LOAD U%d \"!%s\"", unit
, file
);
239 /** Load a file on the specified unit at the end of the pump with the specified in/out points.
242 valerie_error_code
valerie_unit_load_back_clipped( valerie
this, int unit
, char *file
, int32_t in
, int32_t out
)
244 return valerie_execute( this, 10240, "LOAD U%d \"!%s\" %d %d", unit
, file
, in
, out
);
247 /** Append a file on the specified unit.
250 valerie_error_code
valerie_unit_append( valerie
this, int unit
, char *file
, int32_t in
, int32_t out
)
252 return valerie_execute( this, 10240, "APND U%d \"%s\" %d %d", unit
, file
, in
, out
);
255 /** Clean the unit - this function removes all but the currently playing clip.
258 valerie_error_code
valerie_unit_clean( valerie
this, int unit
)
260 return valerie_execute( this, 1024, "CLEAN U%d", unit
);
263 /** Clear the unit - this function removes all clips.
266 valerie_error_code
valerie_unit_clear( valerie
this, int unit
)
268 return valerie_execute( this, 1024, "CLEAR U%d", unit
);
271 /** Move clips on the units playlist.
274 valerie_error_code
valerie_unit_clip_move( valerie
this, int unit
, valerie_clip_offset src_offset
, int src
, valerie_clip_offset dest_offset
, int dest
)
278 valerie_interpret_clip_offset( temp1
, src_offset
, src
);
279 valerie_interpret_clip_offset( temp2
, dest_offset
, dest
);
280 return valerie_execute( this, 1024, "MOVE U%d %s %s", unit
, temp1
, temp2
);
283 /** Remove clip at the specified position.
286 valerie_error_code
valerie_unit_clip_remove( valerie
this, int unit
, valerie_clip_offset offset
, int clip
)
289 valerie_interpret_clip_offset( temp
, offset
, clip
);
290 return valerie_execute( this, 1024, "REMOVE U%d %s", unit
, temp
);
293 /** Remove the currently playing clip.
296 valerie_error_code
valerie_unit_remove_current_clip( valerie
this, int unit
)
298 return valerie_execute( this, 1024, "REMOVE U%d", unit
);
301 /** Insert clip at the specified position.
304 valerie_error_code
valerie_unit_clip_insert( valerie
this, int unit
, valerie_clip_offset offset
, int clip
, char *file
, int32_t in
, int32_t out
)
307 valerie_interpret_clip_offset( temp
, offset
, clip
);
308 return valerie_execute( this, 1024, "INSERT U%d %s %s %d %d", unit
, file
, temp
, in
, out
);
311 /** Play the unit at normal speed.
314 valerie_error_code
valerie_unit_play( valerie
this, int unit
)
316 return valerie_execute( this, 1024, "PLAY U%d 1000", unit
);
319 /** Play the unit at specified speed.
322 valerie_error_code
valerie_unit_play_at_speed( valerie
this, int unit
, int speed
)
324 return valerie_execute( this, 10240, "PLAY U%d %d", unit
, speed
);
327 /** Stop playback on the specified unit.
330 valerie_error_code
valerie_unit_stop( valerie
this, int unit
)
332 return valerie_execute( this, 1024, "STOP U%d", unit
);
335 /** Pause playback on the specified unit.
338 valerie_error_code
valerie_unit_pause( valerie
this, int unit
)
340 return valerie_execute( this, 1024, "PAUSE U%d", unit
);
343 /** Rewind the specified unit.
346 valerie_error_code
valerie_unit_rewind( valerie
this, int unit
)
348 return valerie_execute( this, 1024, "REW U%d", unit
);
351 /** Fast forward the specified unit.
354 valerie_error_code
valerie_unit_fast_forward( valerie
this, int unit
)
356 return valerie_execute( this, 1024, "FF U%d", unit
);
359 /** Step by the number of frames on the specified unit.
362 valerie_error_code
valerie_unit_step( valerie
this, int unit
, int32_t step
)
364 return valerie_execute( this, 1024, "STEP U%d %d", unit
, step
);
367 /** Goto the specified frame on the specified unit.
370 valerie_error_code
valerie_unit_goto( valerie
this, int unit
, int32_t position
)
372 return valerie_execute( this, 1024, "GOTO U%d %d", unit
, position
);
375 /** Goto the specified frame in the clip on the specified unit.
378 valerie_error_code
valerie_unit_clip_goto( valerie
this, int unit
, valerie_clip_offset offset
, int clip
, int32_t position
)
381 valerie_interpret_clip_offset( temp
, offset
, clip
);
382 return valerie_execute( this, 1024, "GOTO U%d %d %s", unit
, position
, temp
);
385 /** Set the in point of the loaded file on the specified unit.
388 valerie_error_code
valerie_unit_set_in( valerie
this, int unit
, int32_t in
)
390 return valerie_execute( this, 1024, "SIN U%d %d", unit
, in
);
393 /** Set the in point of the clip on the specified unit.
396 valerie_error_code
valerie_unit_clip_set_in( valerie
this, int unit
, valerie_clip_offset offset
, int clip
, int32_t in
)
399 valerie_interpret_clip_offset( temp
, offset
, clip
);
400 return valerie_execute( this, 1024, "SIN U%d %d %s", unit
, in
, temp
);
403 /** Set the out point of the loaded file on the specified unit.
406 valerie_error_code
valerie_unit_set_out( valerie
this, int unit
, int32_t out
)
408 return valerie_execute( this, 1024, "SOUT U%d %d", unit
, out
);
411 /** Set the out point of the clip on the specified unit.
414 valerie_error_code
valerie_unit_clip_set_out( valerie
this, int unit
, valerie_clip_offset offset
, int clip
, int32_t in
)
417 valerie_interpret_clip_offset( temp
, offset
, clip
);
418 return valerie_execute( this, 1024, "SOUT U%d %d %s", unit
, in
, temp
);
421 /** Clear the in point of the loaded file on the specified unit.
424 valerie_error_code
valerie_unit_clear_in( valerie
this, int unit
)
426 return valerie_execute( this, 1024, "SIN U%d -1", unit
);
429 /** Clear the out point of the loaded file on the specified unit.
432 valerie_error_code
valerie_unit_clear_out( valerie
this, int unit
)
434 return valerie_execute( this, 1024, "SOUT U%d -1", unit
);
437 /** Clear the in and out points on the loaded file on the specified unit.
440 valerie_error_code
valerie_unit_clear_in_out( valerie
this, int unit
)
442 valerie_error_code error
= valerie_unit_clear_out( this, unit
);
443 if ( error
== valerie_ok
)
444 error
= valerie_unit_clear_in( this, unit
);
448 /** Set a unit configuration property.
451 valerie_error_code
valerie_unit_set( valerie
this, int unit
, char *name
, char *value
)
453 return valerie_execute( this, 1024, "USET U%d %s=%s", unit
, name
, value
);
456 /** Get a unit configuration property.
459 valerie_error_code
valerie_unit_get( valerie
this, int unit
, char *name
)
461 return valerie_execute( this, 1024, "UGET U%d %s", unit
, name
);
464 /** Get a units status.
467 valerie_error_code
valerie_unit_status( valerie
this, int unit
, valerie_status status
)
469 valerie_error_code error
= valerie_execute( this, 1024, "USTA U%d", unit
);
470 int error_code
= valerie_response_get_error_code( this->last_response
);
472 memset( status
, 0, sizeof( valerie_status_t
) );
474 if ( error_code
== 202 && valerie_response_count( this->last_response
) == 2 )
475 valerie_status_parse( status
, valerie_response_get_line( this->last_response
, 1 ) );
476 else if ( error_code
== 403 )
477 status
->status
= unit_undefined
;
482 /** Transfer the current settings of unit src to unit dest.
485 valerie_error_code
valerie_unit_transfer( valerie
this, int src
, int dest
)
487 return valerie_execute( this, 1024, "XFER U%d U%d", src
, dest
);
490 /** Obtain the parsers notifier.
493 valerie_notifier
valerie_get_notifier( valerie
this )
496 return valerie_parser_get_notifier( this->parser
);
501 /** List the contents of the specified directory.
504 valerie_dir
valerie_dir_init( valerie
this, char *directory
)
506 valerie_dir dir
= malloc( sizeof( valerie_dir_t
) );
509 memset( dir
, 0, sizeof( valerie_dir_t
) );
510 dir
->directory
= strdup( directory
);
511 dir
->response
= valerie_parser_executef( this->parser
, "CLS \"%s\"", directory
);
516 /** Return the error code associated to the dir.
519 valerie_error_code
valerie_dir_get_error_code( valerie_dir dir
)
522 return valerie_get_error_code( NULL
, dir
->response
);
524 return valerie_malloc_failed
;
527 /** Get a particular file entry in the directory.
530 valerie_error_code
valerie_dir_get( valerie_dir dir
, int index
, valerie_dir_entry entry
)
532 valerie_error_code error
= valerie_ok
;
533 memset( entry
, 0, sizeof( valerie_dir_entry_t
) );
534 if ( index
< valerie_dir_count( dir
) )
536 char *line
= valerie_response_get_line( dir
->response
, index
+ 1 );
537 valerie_tokeniser tokeniser
= valerie_tokeniser_init( );
538 valerie_tokeniser_parse_new( tokeniser
, line
, " " );
540 if ( valerie_tokeniser_count( tokeniser
) > 0 )
542 valerie_util_strip( valerie_tokeniser_get_string( tokeniser
, 0 ), '\"' );
543 strcpy( entry
->full
, dir
->directory
);
544 if ( entry
->full
[ strlen( entry
->full
) - 1 ] != '/' )
545 strcat( entry
->full
, "/" );
546 strcpy( entry
->name
, valerie_tokeniser_get_string( tokeniser
, 0 ) );
547 strcat( entry
->full
, entry
->name
);
549 switch ( valerie_tokeniser_count( tokeniser
) )
555 entry
->size
= strtoull( valerie_tokeniser_get_string( tokeniser
, 1 ), NULL
, 10 );
558 error
= valerie_invalid_file
;
562 valerie_tokeniser_close( tokeniser
);
567 /** Get the number of entries in the directory
570 int valerie_dir_count( valerie_dir dir
)
572 if ( dir
!= NULL
&& valerie_response_count( dir
->response
) >= 2 )
573 return valerie_response_count( dir
->response
) - 2;
578 /** Close the directory structure.
581 void valerie_dir_close( valerie_dir dir
)
585 free( dir
->directory
);
586 valerie_response_close( dir
->response
);
591 /** List the playlist of the specified unit.
594 valerie_list
valerie_list_init( valerie
this, int unit
)
596 valerie_list list
= calloc( 1, sizeof( valerie_list_t
) );
599 list
->response
= valerie_parser_executef( this->parser
, "LIST U%d", unit
);
600 if ( valerie_response_count( list
->response
) >= 2 )
601 list
->generation
= atoi( valerie_response_get_line( list
->response
, 1 ) );
606 /** Return the error code associated to the list.
609 valerie_error_code
valerie_list_get_error_code( valerie_list list
)
612 return valerie_get_error_code( NULL
, list
->response
);
614 return valerie_malloc_failed
;
617 /** Get a particular file entry in the list.
620 valerie_error_code
valerie_list_get( valerie_list list
, int index
, valerie_list_entry entry
)
622 valerie_error_code error
= valerie_ok
;
623 memset( entry
, 0, sizeof( valerie_list_entry_t
) );
624 if ( index
< valerie_list_count( list
) )
626 char *line
= valerie_response_get_line( list
->response
, index
+ 2 );
627 valerie_tokeniser tokeniser
= valerie_tokeniser_init( );
628 valerie_tokeniser_parse_new( tokeniser
, line
, " " );
630 if ( valerie_tokeniser_count( tokeniser
) > 0 )
632 entry
->clip
= atoi( valerie_tokeniser_get_string( tokeniser
, 0 ) );
633 valerie_util_strip( valerie_tokeniser_get_string( tokeniser
, 1 ), '\"' );
634 strcpy( entry
->full
, valerie_tokeniser_get_string( tokeniser
, 1 ) );
635 entry
->in
= atol( valerie_tokeniser_get_string( tokeniser
, 2 ) );
636 entry
->out
= atol( valerie_tokeniser_get_string( tokeniser
, 3 ) );
637 entry
->max
= atol( valerie_tokeniser_get_string( tokeniser
, 4 ) );
638 entry
->size
= atol( valerie_tokeniser_get_string( tokeniser
, 5 ) );
639 entry
->fps
= atof( valerie_tokeniser_get_string( tokeniser
, 6 ) );
641 valerie_tokeniser_close( tokeniser
);
646 /** Get the number of entries in the list
649 int valerie_list_count( valerie_list list
)
651 if ( list
!= NULL
&& valerie_response_count( list
->response
) >= 3 )
652 return valerie_response_count( list
->response
) - 3;
657 /** Close the list structure.
660 void valerie_list_close( valerie_list list
)
664 valerie_response_close( list
->response
);
669 /** List the currently connected nodes.
672 valerie_nodes
valerie_nodes_init( valerie
this )
674 valerie_nodes nodes
= malloc( sizeof( valerie_nodes_t
) );
677 memset( nodes
, 0, sizeof( valerie_nodes_t
) );
678 nodes
->response
= valerie_parser_executef( this->parser
, "NLS" );
683 /** Return the error code associated to the nodes list.
686 valerie_error_code
valerie_nodes_get_error_code( valerie_nodes nodes
)
689 return valerie_get_error_code( NULL
, nodes
->response
);
691 return valerie_malloc_failed
;
694 /** Get a particular node entry.
697 valerie_error_code
valerie_nodes_get( valerie_nodes nodes
, int index
, valerie_node_entry entry
)
699 valerie_error_code error
= valerie_ok
;
700 memset( entry
, 0, sizeof( valerie_node_entry_t
) );
701 if ( index
< valerie_nodes_count( nodes
) )
703 char *line
= valerie_response_get_line( nodes
->response
, index
+ 1 );
704 valerie_tokeniser tokeniser
= valerie_tokeniser_init( );
705 valerie_tokeniser_parse_new( tokeniser
, line
, " " );
707 if ( valerie_tokeniser_count( tokeniser
) == 3 )
709 entry
->node
= atoi( valerie_tokeniser_get_string( tokeniser
, 0 ) );
710 strncpy( entry
->guid
, valerie_tokeniser_get_string( tokeniser
, 1 ), sizeof( entry
->guid
) );
711 valerie_util_strip( valerie_tokeniser_get_string( tokeniser
, 2 ), '\"' );
712 strncpy( entry
->name
, valerie_tokeniser_get_string( tokeniser
, 2 ), sizeof( entry
->name
) );
715 valerie_tokeniser_close( tokeniser
);
720 /** Get the number of nodes
723 int valerie_nodes_count( valerie_nodes nodes
)
725 if ( nodes
!= NULL
&& valerie_response_count( nodes
->response
) >= 2 )
726 return valerie_response_count( nodes
->response
) - 2;
731 /** Close the nodes structure.
734 void valerie_nodes_close( valerie_nodes nodes
)
738 valerie_response_close( nodes
->response
);
743 /** List the currently defined units.
746 valerie_units
valerie_units_init( valerie
this )
748 valerie_units units
= malloc( sizeof( valerie_units_t
) );
751 memset( units
, 0, sizeof( valerie_units_t
) );
752 units
->response
= valerie_parser_executef( this->parser
, "ULS" );
757 /** Return the error code associated to the nodes list.
760 valerie_error_code
valerie_units_get_error_code( valerie_units units
)
763 return valerie_get_error_code( NULL
, units
->response
);
765 return valerie_malloc_failed
;
768 /** Get a particular unit entry.
771 valerie_error_code
valerie_units_get( valerie_units units
, int index
, valerie_unit_entry entry
)
773 valerie_error_code error
= valerie_ok
;
774 memset( entry
, 0, sizeof( valerie_unit_entry_t
) );
775 if ( index
< valerie_units_count( units
) )
777 char *line
= valerie_response_get_line( units
->response
, index
+ 1 );
778 valerie_tokeniser tokeniser
= valerie_tokeniser_init( );
779 valerie_tokeniser_parse_new( tokeniser
, line
, " " );
781 if ( valerie_tokeniser_count( tokeniser
) == 4 )
783 entry
->unit
= atoi( valerie_tokeniser_get_string( tokeniser
, 0 ) + 1 );
784 entry
->node
= atoi( valerie_tokeniser_get_string( tokeniser
, 1 ) );
785 strncpy( entry
->guid
, valerie_tokeniser_get_string( tokeniser
, 2 ), sizeof( entry
->guid
) );
786 entry
->online
= atoi( valerie_tokeniser_get_string( tokeniser
, 3 ) );
789 valerie_tokeniser_close( tokeniser
);
794 /** Get the number of units
797 int valerie_units_count( valerie_units units
)
799 if ( units
!= NULL
&& valerie_response_count( units
->response
) >= 2 )
800 return valerie_response_count( units
->response
) - 2;
805 /** Close the units structure.
808 void valerie_units_close( valerie_units units
)
812 valerie_response_close( units
->response
);
817 /** Get the response of the last command executed.
820 valerie_response
valerie_get_last_response( valerie
this )
822 return this->last_response
;
825 /** Obtain a printable message associated to the error code provided.
828 char *valerie_error_description( valerie_error_code error
)
830 char *msg
= "Unrecognised error";
836 case valerie_malloc_failed
:
837 msg
= "Memory allocation error";
839 case valerie_unknown_error
:
840 msg
= "Unknown error";
842 case valerie_no_response
:
843 msg
= "No response obtained";
845 case valerie_invalid_command
:
846 msg
= "Invalid command";
848 case valerie_server_timeout
:
849 msg
= "Communications with server timed out";
851 case valerie_missing_argument
:
852 msg
= "Missing argument";
854 case valerie_server_unavailable
:
855 msg
= "Unable to communicate with server";
857 case valerie_unit_creation_failed
:
858 msg
= "Unit creation failed";
860 case valerie_unit_unavailable
:
861 msg
= "Unit unavailable";
863 case valerie_invalid_file
:
864 msg
= "Invalid file";
866 case valerie_invalid_position
:
867 msg
= "Invalid position";
873 /** Close the valerie structure.
876 void valerie_close( valerie
this )
880 valerie_set_last_response( this, NULL
);