Mercurial > audlegacy-plugins
view src/mtp_up/mtp.c @ 2014:1ad002ce1bd0
Just a tiny cleanup.
author | Eugene Paskevich <eugene@raptor.kiev.ua> |
---|---|
date | Wed, 10 Oct 2007 11:11:26 +0300 |
parents | fa9f85cebade |
children | cf4fa45ffd80 |
line wrap: on
line source
/* * Audacious MTP upload plugin * * Copyright (c) 2007 Cristian Magherusan <majeru@atheme.org> * * 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; under version 3 of the License. * * This program 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. * * You should have received a copy of the GNU General Public License * along with this program. If not, see <http://www.gnu.org/licenses>. */ #include <glib.h> #include <sys/types.h> #include <libmtp.h> #include <audacious/plugin.h> #include <audacious/playlist.h> #include <audacious/ui_plugin_menu.h> #include <gtk/gtk.h> #include <audacious/util.h> #include "filetype.h" #define DEBUG 1 #define ROOT_LABEL "MTP device handler" #define UP_DEFAULT_LABEL "Upload selected track(s)" #define UP_BUSY_LABEL "Upload in progress..." #define FREE_LABEL "Disconnect the device" GMutex * mutex = NULL; gboolean mtp_initialised = FALSE; LIBMTP_mtpdevice_t *mtp_device = NULL; LIBMTP_progressfunc_t *callback; LIBMTP_file_t *filelist; Playlist *active_playlist; static gboolean plugin_active = FALSE,exiting=FALSE; void mtp_init ( void ); void mtp_cleanup ( void ); void mtp_prefs ( void ); void mtp_about ( void ); GeneralPlugin mtp_gp = { NULL, /* handle */ NULL, /* filename */ "MTP Upload " , /* description */ mtp_init, /* init */ mtp_about, /* about */ mtp_prefs, /* configure */ mtp_cleanup /* cleanup */ }; GtkWidget *mtp_root_menuitem,*mtp_submenu_item_up,*mtp_submenu_item_free,*mtp_submenu; GeneralPlugin *mtp_gplist[] = { &mtp_gp, NULL }; DECLARE_PLUGIN(mtp_gp, NULL, NULL, NULL, NULL, NULL, mtp_gplist, NULL, NULL) void show_dialog(const gchar* message) { GDK_THREADS_ENTER(); GtkWidget *dialog = gtk_message_dialog_new (NULL, GTK_DIALOG_MODAL, GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, message); gtk_dialog_run (GTK_DIALOG (dialog)); gtk_widget_show(dialog); /* gtk_widget_destroy(dialog); */ GDK_THREADS_LEAVE(); } gboolean free_device(void) { #if DEBUG if(mtp_initialised) g_print("\n\n !!!CAUTION!!! \n\n" "Cleaning up MTP upload plugin, please wait!!!...\n" "This will block until the pending tracks are uploaded,\n" "then it will gracefully close your device\n\n" "!!! FORCING SHUTDOWN NOW MAY CAUSE DAMAGE TO YOUR DEVICE !!!\n\n\n" "Waiting for the MTP mutex to unlock...\n"); #endif if(!mutex) return TRUE; g_mutex_lock(mutex); if(mtp_device!= NULL) { LIBMTP_Release_Device(mtp_device); mtp_device = NULL; mtp_initialised = FALSE; gtk_widget_hide(mtp_submenu_item_free); } g_mutex_unlock(mutex); return TRUE; } GList * get_upload_list() { Tuple *tuple; GList *node=NULL,*up_list=NULL; PlaylistEntry *entry; Playlist *current_play = playlist_get_active(); node = current_play->entries; PLAYLIST_LOCK(current_play); /*needed so that the user doesn't modify the selection*/ while (node) /*while creating the list of files to be uploaded*/ { entry = PLAYLIST_ENTRY(node->data); if (entry->selected) { tuple = entry->tuple; up_list=g_list_prepend(up_list,tuple); entry->selected = FALSE; } node = g_list_next(node); } PLAYLIST_UNLOCK(current_play); return g_list_reverse(up_list); } LIBMTP_track_t *track_metadata(Tuple *from_tuple) { LIBMTP_track_t *tr; gchar *filename, *from_path; VFSFile *f; uint64_t filesize; uint32_t parent_id = 0; struct stat sb; from_path = g_strdup_printf("%s/%s", aud_tuple_get_string(from_tuple, FIELD_FILE_PATH, NULL), aud_tuple_get_string(from_tuple, FIELD_FILE_NAME, NULL)); gchar *tmp; tmp = g_strescape(from_path,NULL); filename=g_filename_from_uri(tmp,NULL,NULL); /* dealing the stream upload (invalidating)*/ if(filename) { f = aud_vfs_fopen(from_path,"r"); if(aud_vfs_is_streaming(f)) { aud_vfs_fclose(f); return NULL; } } if ( stat(from_path, &sb) == -1 ) { #if DEBUG g_print("ERROR! encountered while stat()'ing \"%s\"\n",from_path); #endif return NULL; } filesize = (uint64_t) sb.st_size; parent_id = mtp_device->default_music_folder; /* track metadata*/ tr = LIBMTP_new_track_t(); tr->title = g_strdup((gchar*) aud_tuple_get_string(from_tuple, FIELD_TITLE, NULL)); tr->artist = g_strdup((gchar*) aud_tuple_get_string(from_tuple, FIELD_ARTIST, NULL)); tr->album = g_strdup((gchar*)aud_tuple_get_string(from_tuple, FIELD_ALBUM, NULL)); tr->filesize = filesize; tr->filename = g_strdup(aud_tuple_get_string(from_tuple, FIELD_FILE_NAME, NULL)); tr->duration = (uint32_t)aud_tuple_get_int(from_tuple, FIELD_LENGTH, NULL); tr->filetype = find_filetype (from_path); tr->genre = g_strdup((gchar*)aud_tuple_get_string(from_tuple, FIELD_GENRE, NULL)); tr->date = g_strdup_printf("%d",aud_tuple_get_int(from_tuple, FIELD_YEAR, NULL)); g_free(filename); g_free(from_path); g_free(tmp); return tr; } gint upload_file(Tuple *from_tuple) { int ret; gchar *comp, *from_path = NULL; uint32_t parent_id = 0; LIBMTP_track_t *gentrack; gentrack = track_metadata(from_tuple); from_path = g_strdup_printf("%s/%s", aud_tuple_get_string(from_tuple, FIELD_FILE_PATH, NULL), aud_tuple_get_string(from_tuple, FIELD_FILE_NAME, NULL)); if(gentrack == NULL) return 1; comp = g_strescape(from_path,NULL); g_free(from_path); parent_id = mtp_device->default_music_folder; #if DEBUG g_print("Uploading track '%s'\n",comp); #endif ret = LIBMTP_Send_Track_From_File(mtp_device, comp , gentrack, NULL , NULL, parent_id); LIBMTP_destroy_track_t(gentrack); g_free(comp); if (ret == 0) g_print("Track upload finished!\n"); else { g_print("An error has occured while uploading '%s'...\nUpload failed!!!\n\n",comp); mtp_initialised = FALSE; return 1; } return 0; } gpointer upload(gpointer arg) { gtk_widget_hide(mtp_submenu_item_free); if(!mutex) { gtk_label_set_text(GTK_LABEL(gtk_bin_get_child(GTK_BIN(mtp_submenu_item_up))),UP_DEFAULT_LABEL); gtk_widget_set_sensitive(mtp_submenu_item_up, TRUE); return NULL; } g_mutex_lock(mutex); if(!mtp_device) { gtk_label_set_text(GTK_LABEL(gtk_bin_get_child(GTK_BIN(mtp_submenu_item_up))),UP_DEFAULT_LABEL); gtk_widget_set_sensitive(mtp_submenu_item_up, TRUE); g_mutex_unlock(mutex); return NULL; } Tuple* tuple; GList *up_list=NULL,*node; node=up_list=get_upload_list(); gint up_err=0; while(node) { tuple=(Tuple*)(node->data); up_err = upload_file(tuple); if(up_err ) { /*show_dialog("An error has occured while uploading...\nUpload failed!");*/ break; } if(exiting) { /*show_dialog("Shutting down MTP while uploading.\nPending uploads were cancelled");*/ break; } node = g_list_next(node); } g_list_free(up_list); gtk_label_set_text(GTK_LABEL(gtk_bin_get_child(GTK_BIN(mtp_submenu_item_up))),UP_DEFAULT_LABEL); gtk_widget_set_sensitive(mtp_submenu_item_up, TRUE); g_mutex_unlock(mutex); #if DEBUG g_print("MTP upload process finished\n"); #endif gtk_widget_show(mtp_submenu_item_free); g_thread_exit(NULL); return NULL; } void mtp_prefs ( void ) { /*pref stub*/ } void mtp_about ( void ) { /*about stub*/ } gboolean mtp_press() { if(!mutex) return TRUE; g_mutex_lock(mutex); if(!mtp_initialised) { #if DEBUG g_print("Initializing the MTP device...\n"); #endif LIBMTP_Init(); mtp_device = LIBMTP_Get_First_Device(); mtp_initialised = TRUE; gtk_widget_show(mtp_submenu_item_free); } g_mutex_unlock(mutex); if(mtp_device == NULL) { #if DEBUG g_print("No MTP devices have been found !!!\n"); #endif /* show_dialog("No MTP devices have been found !!!"); */ mtp_initialised = FALSE; return TRUE; } gtk_label_set_text(GTK_LABEL(gtk_bin_get_child(GTK_BIN(mtp_submenu_item_up))),UP_BUSY_LABEL); gtk_widget_set_sensitive(mtp_submenu_item_up, FALSE); g_thread_create(upload,NULL,FALSE,NULL); return TRUE; } void mtp_init(void) { mtp_root_menuitem=gtk_menu_item_new_with_label(ROOT_LABEL); mtp_submenu=gtk_menu_new(); mtp_submenu_item_up=gtk_menu_item_new_with_label(UP_DEFAULT_LABEL); mtp_submenu_item_free=gtk_menu_item_new_with_label(FREE_LABEL); gtk_menu_shell_append (GTK_MENU_SHELL (mtp_submenu), mtp_submenu_item_up); gtk_widget_show (mtp_submenu_item_up); gtk_menu_shell_append (GTK_MENU_SHELL (mtp_submenu), mtp_submenu_item_free); gtk_menu_item_set_submenu(GTK_MENU_ITEM(mtp_root_menuitem),mtp_submenu); gtk_widget_show (mtp_submenu); gtk_widget_show (mtp_root_menuitem); audacious_menu_plugin_item_add(AUDACIOUS_MENU_PLAYLIST_RCLICK, mtp_root_menuitem); g_signal_connect (G_OBJECT (mtp_submenu_item_up), "button_press_event",G_CALLBACK (mtp_press), NULL); g_signal_connect (G_OBJECT (mtp_submenu_item_free), "button_press_event",G_CALLBACK (free_device), NULL); mutex = g_mutex_new(); plugin_active = TRUE; exiting=FALSE; } void mtp_cleanup(void) { if (plugin_active) { #if DEBUG if(mtp_initialised) { g_print("\n\n !!!CAUTION!!! \n\n" "Cleaning up MTP upload plugin, please wait!!!...\n" "This will block until the pending tracks are uploaded,\n" "then it will gracefully close your device\n\n" "!!! FORCING SHUTDOWN NOW MAY CAUSE DAMAGE TO YOUR DEVICE !!!\n\n\n" "Waiting for the MTP mutex to unlock...\n"); exiting=TRUE; } #endif if(mutex) g_mutex_lock(mutex); if(mtp_device!= NULL) { LIBMTP_Release_Device(mtp_device); mtp_device = NULL; } g_mutex_unlock(mutex); #if DEBUG if(mtp_initialised) g_print("The MTP mutex has been unlocked\n"); #endif audacious_menu_plugin_item_remove(AUDACIOUS_MENU_PLAYLIST_RCLICK, mtp_root_menuitem); gtk_widget_destroy(mtp_submenu_item_up); gtk_widget_destroy(mtp_submenu_item_up); gtk_widget_destroy(mtp_submenu_item_free); gtk_widget_destroy(mtp_submenu); gtk_widget_destroy(mtp_root_menuitem); g_mutex_free (mutex); mutex = NULL; plugin_active = FALSE; #if DEBUG if(mtp_initialised) g_print("MTP upload plugin has been cleaned up successfully\n"); #endif } }