diff options
Diffstat (limited to 'Src/Plugins/Library/ml_wire/Main.cpp')
| -rw-r--r-- | Src/Plugins/Library/ml_wire/Main.cpp | 469 |
1 files changed, 469 insertions, 0 deletions
diff --git a/Src/Plugins/Library/ml_wire/Main.cpp b/Src/Plugins/Library/ml_wire/Main.cpp new file mode 100644 index 00000000..37e0ff6b --- /dev/null +++ b/Src/Plugins/Library/ml_wire/Main.cpp @@ -0,0 +1,469 @@ +#include "main.h" +#include "Cloud.h" +#include "DownloadThread.h" +#include "OPMLParse.h" +#include "FeedsDialog.h" +#include "DownloadsParse.h" +#include "XMLWriter.h" +#include "FeedParse.h" +#include "DownloadsDialog.h" +#include "Preferences.h" +#include "..\..\General\gen_ml/ml.h" +#include "Defaults.h" +#include "Wire.h" +#include "..\..\General\gen_ml/ml_ipc_0313.h" +#include "RSSCOM.h" + +#include "api__ml_wire.h" +#include "Downloaded.h" +#include "DownloadStatus.h" +#include "Factory.h" +#include "JSAPI2_Creator.h" +#include "./navigation.h" + +#include <strsafe.h> + +#include "PCastFactory.h" + +Cloud cloud; +WireManager channelMgr; + +int treeId = 0, allId = 0 +#if 0 + , discoverId = 0 +#endif + ; +MLTREEITEMW downloadsTree; +wchar_t downloadsStr[64] = {0}, *ml_cfg = 0, + feedsXmlFileName[1024] = {0}, + feedsXmlFileNameBackup[1024] = {0}, + rssXmlFileName[1024] = {0}, + rssXmlFileNameBackup[1024] = {0}; + +ATOM VIEWPROP = 0; + +api_downloadManager *WAC_API_DOWNLOADMANAGER = 0; + +static int Init(); +static void Quit(); +static INT_PTR MessageProc(int message_type, INT_PTR param1, INT_PTR param2, INT_PTR param3); + +DWORD threadStorage=TLS_OUT_OF_INDEXES; +extern "C" winampMediaLibraryPlugin plugin = + { + MLHDR_VER, + "nullsoft(ml_wire.dll)", + Init, + Quit, + MessageProc, + 0, + 0, + 0, + }; + +static prefsDlgRecW preferences; + +static wchar_t preferencesName[64] = {0}; +void SaveChannels(ChannelList &channels) +{ + // generate a backup of the feeds.xml to cope with it being wiped randomly for some + // people or it not being able to be saved in time e.g. during a forced OS shutdown + CopyFile(feedsXmlFileName, feedsXmlFileNameBackup, FALSE); + SaveChannels(feedsXmlFileName, channels); +} + +void SaveAll(bool rss_only) +{ + if (AGAVE_API_STATS) + AGAVE_API_STATS->SetStat(api_stats::PODCAST_COUNT, (int)channels.size()); + + if(!rss_only) + SaveChannels(channels); + + // generate a backup of the rss.xml to cope with it being wiped randomly for some + // people or it not being able to be saved in time e.g. during a forced OS shutdown + CopyFile(rssXmlFileName, rssXmlFileNameBackup, FALSE); + SaveSettings(rssXmlFileName, downloadedFiles); +} + +static PodcastsFactory podcastsFactory; + +HANDLE hMainThread = NULL; + +HCURSOR hDragNDropCursor = NULL; +int winampVersion = 0; + +JSAPI2::api_security *AGAVE_API_JSAPI2_SECURITY = 0; +JSAPI2Factory jsapi2Creator; + +obj_ombrowser *browserManager = NULL; +api_application *applicationApi = NULL; +api_stats *AGAVE_API_STATS = 0; +api_threadpool *WASABI_API_THREADPOOL = 0; +api_explorerfindfile *WASABI_API_EXPLORERFINDFILE = 0; + +// wasabi based services for localisation support +api_language *WASABI_API_LNG = 0; +HINSTANCE WASABI_API_LNG_HINST = 0; +HINSTANCE WASABI_API_ORIG_HINST = 0; + +static PCastFactory pcastFactory; + +static void CALLBACK InitTimer(HWND hwnd, UINT uMsg, UINT_PTR eventId, ULONG elapsed) +{ + KillTimer(hwnd, eventId); + + { + Nullsoft::Utility::AutoLock lock (channels LOCKNAME("feeds.xml load!")); + + FeedParse downloader(&channelMgr, true); + downloader.DownloadFile(feedsXmlFileName); + if (AGAVE_API_STATS) + AGAVE_API_STATS->SetStat(api_stats::PODCAST_COUNT, (int)channels.size()); + } + + if (updateOnLaunch) + { + cloud.RefreshAll(); + } + + cloud.Init(); + cloud.Pulse(); +} + +int Init() +{ + hMainThread = GetCurrentThread(); + hDragNDropCursor = LoadCursor( GetModuleHandle( L"gen_ml.dll" ), MAKEINTRESOURCE( ML_IDC_DRAGDROP ) ); + threadStorage = TlsAlloc(); + + if ( 0 == VIEWPROP ) + { + VIEWPROP = GlobalAddAtom( L"Nullsoft_PodcastView" ); + if ( VIEWPROP == 0 ) + return 1; + } + + winampVersion = SendMessage( plugin.hwndWinampParent, WM_WA_IPC, 0, IPC_GETVERSION ); + ml_cfg = (wchar_t*)SendMessage(plugin.hwndWinampParent, WM_WA_IPC, 0, IPC_GETMLINIFILEW); + + plugin.service->service_register( &podcastsFactory ); + plugin.service->service_register( &jsapi2Creator ); + plugin.service->service_register( &pcastFactory ); + + // loader so that we can get the localisation service api for use + waServiceFactory *sf = plugin.service->service_getServiceByGuid( languageApiGUID ); + if ( sf ) + WASABI_API_LNG = reinterpret_cast<api_language*>( sf->getInterface() ); + + sf = plugin.service->service_getServiceByGuid( JSAPI2::api_securityGUID ); + if ( sf ) + AGAVE_API_JSAPI2_SECURITY = reinterpret_cast<JSAPI2::api_security*>( sf->getInterface() ); + + sf = plugin.service->service_getServiceByGuid( applicationApiServiceGuid ); + if ( sf ) + WASABI_API_APP = reinterpret_cast<api_application*>( sf->getInterface() ); + + sf = plugin.service->service_getServiceByGuid( OBJ_OmBrowser ); + if ( sf ) + OMBROWSERMNGR = reinterpret_cast<obj_ombrowser*>( sf->getInterface() ); + + sf = plugin.service->service_getServiceByGuid( AnonymousStatsGUID ); + if ( sf ) + AGAVE_API_STATS = reinterpret_cast<api_stats*>( sf->getInterface() ); + + sf = plugin.service->service_getServiceByGuid( ThreadPoolGUID ); + if ( sf ) + WASABI_API_THREADPOOL = reinterpret_cast<api_threadpool*>( sf->getInterface() ); + + sf = plugin.service->service_getServiceByGuid( DownloadManagerGUID ); + if ( sf ) + WAC_API_DOWNLOADMANAGER = reinterpret_cast<api_downloadManager*>( sf->getInterface() ); + + sf = plugin.service->service_getServiceByGuid( ExplorerFindFileApiGUID ); + if ( sf ) + WASABI_API_EXPLORERFINDFILE = reinterpret_cast<api_explorerfindfile*>( sf->getInterface() ); + + // need to have this initialised before we try to do anything with localisation features + WASABI_API_START_LANG( plugin.hDllInstance, MlWireLangGUID ); + + static wchar_t szDescription[ 256 ]; + StringCchPrintfW( szDescription, ARRAYSIZE( szDescription ), WASABI_API_LNGSTRINGW( IDS_PLUGIN_NAME ), PLUGIN_VERSION_MAJOR, PLUGIN_VERSION_MINOR ); + plugin.description = (char*)szDescription; + + mediaLibrary.library = plugin.hwndLibraryParent; + mediaLibrary.winamp = plugin.hwndWinampParent; + mediaLibrary.instance = plugin.hDllInstance; + + RssCOM *rss; + if (SUCCEEDED(RssCOM::CreateInstance(&rss))) + { + DispatchInfo dispatchInfo; + dispatchInfo.name = (LPWSTR)rss->GetName(); + dispatchInfo.dispatch = rss; + + SENDWAIPC(plugin.hwndWinampParent, IPC_ADD_DISPATCH_OBJECT, (WPARAM)&dispatchInfo); + rss->Release(); + } + + BuildDefaultDownloadPath( plugin.hwndWinampParent ); + + preferences.hInst = WASABI_API_LNG_HINST; + preferences.dlgID = IDD_PREFERENCES; + preferences.proc = (void *)PreferencesDialogProc; + preferences.name = WASABI_API_LNGSTRINGW_BUF( IDS_PODCAST_DIRECTORY, preferencesName, 64 ); + preferences.where = 6; + + mediaLibrary.AddPreferences( preferences ); + + wchar_t g_path[MAX_PATH] = {0}; + mediaLibrary.BuildPath( L"Plugins\\ml\\feeds", g_path, MAX_PATH ); + CreateDirectoryW( g_path, NULL ); + + wchar_t oldxmlFileName[1024] = {0}, oldxmlFileNameBackup[ 1024 ] = { 0 }; + mediaLibrary.BuildPath( L"Plugins\\ml\\rss.xml", oldxmlFileName, 1024 ); + mediaLibrary.BuildPath( L"Plugins\\ml\\feeds\\rss.xml", rssXmlFileName, 1024 ); + mediaLibrary.BuildPath( L"Plugins\\ml\\rss.xml.backup", oldxmlFileNameBackup, 1024 ); + mediaLibrary.BuildPath( L"Plugins\\ml\\feeds\\rss.xml.backup", rssXmlFileNameBackup, 1024 ); + + if ( PathFileExists( oldxmlFileName ) && !PathFileExists(rssXmlFileName)) + { + MoveFile( oldxmlFileName, rssXmlFileName ); + MoveFile( oldxmlFileNameBackup, rssXmlFileNameBackup ); + } + + { + DownloadsParse downloader; + downloader.DownloadFile(rssXmlFileName); + } + + mediaLibrary.BuildPath( L"Plugins\\ml\\feeds.xml", oldxmlFileName, 1024 ); + mediaLibrary.BuildPath( L"Plugins\\ml\\feeds\\feeds.xml", feedsXmlFileName, 1024 ); + mediaLibrary.BuildPath( L"Plugins\\ml\\feeds.xml.backup", oldxmlFileNameBackup, 1024 ); + mediaLibrary.BuildPath( L"Plugins\\ml\\feeds\\feeds.xml.backup", feedsXmlFileNameBackup, 1024 ); + + if ( PathFileExists( oldxmlFileName ) && !PathFileExists( feedsXmlFileName ) ) + { + MoveFile( oldxmlFileName, feedsXmlFileName ); + MoveFile( oldxmlFileNameBackup, feedsXmlFileNameBackup ); + } + + Navigation_Initialize(); + SetTimer( plugin.hwndLibraryParent, 0x498, 10, InitTimer ); + + return 0; +} + +void Quit() +{ + // If there are still files downloading, cancel download to remove incomplete downloaded files + while ( downloadStatus.CurrentlyDownloading() ) + { + Nullsoft::Utility::AutoLock lock( downloadStatus.statusLock ); + DownloadToken dltoken = downloadStatus.downloads.begin()->first; + WAC_API_DOWNLOADMANAGER->CancelDownload( dltoken ); + } + + cloud.Quit(); + CloseDatabase(); + + plugin.service->service_deregister( &podcastsFactory ); + plugin.service->service_deregister( &jsapi2Creator ); + + waServiceFactory *sf = plugin.service->service_getServiceByGuid( OBJ_OmBrowser ); + if ( sf != NULL ) + sf->releaseInterface( OMBROWSERMNGR ); + + sf = plugin.service->service_getServiceByGuid( applicationApiServiceGuid ); + if ( sf != NULL ) + sf->releaseInterface(WASABI_API_APP); + + sf = plugin.service->service_getServiceByGuid(AnonymousStatsGUID); + if ( sf != NULL ) + sf->releaseInterface(AGAVE_API_STATS); + + sf = plugin.service->service_getServiceByGuid(ThreadPoolGUID); + if ( sf != NULL ) + sf->releaseInterface(WASABI_API_THREADPOOL); + + sf = plugin.service->service_getServiceByGuid(ExplorerFindFileApiGUID); + if ( sf != NULL ) + sf->releaseInterface(WASABI_API_EXPLORERFINDFILE); + + sf = plugin.service->service_getServiceByGuid(DownloadManagerGUID); + if ( sf != NULL ) + sf->releaseInterface(WAC_API_DOWNLOADMANAGER); + + if ( VIEWPROP != 0 ) + { + GlobalDeleteAtom(VIEWPROP); + VIEWPROP = 0; + } +} + +static INT_PTR Podcast_OnContextMenu( INT_PTR param1, HWND hHost, POINTS pts) +{ + HNAVITEM hItem = (HNAVITEM)param1; + HNAVITEM myItem = Navigation_FindService( SERVICE_PODCAST, NULL, NULL); + + HNAVITEM podcastItem = MLNavItem_GetChild( plugin.hwndLibraryParent, myItem); + HNAVITEM subscriptionItem = Navigation_FindService( SERVICE_SUBSCRIPTION, podcastItem, NULL); + + if ( hItem != myItem && hItem != subscriptionItem ) + return FALSE; + + POINT pt; + POINTSTOPOINT( pt, pts ); + if ( pt.x == -1 || pt.y == -1 ) + { + NAVITEMGETRECT itemRect; + itemRect.fItem = FALSE; + itemRect.hItem = hItem; + if ( MLNavItem_GetRect( plugin.hwndLibraryParent, &itemRect ) ) + { + MapWindowPoints( hHost, HWND_DESKTOP, (POINT*)&itemRect.rc, 2 ); + pt.x = itemRect.rc.left + 2; + pt.y = itemRect.rc.top + 2; + } + } + + HMENU hMenu = WASABI_API_LOADMENU( IDR_MENU1 ); + int subMenuId = ( hItem == subscriptionItem )? 4 : 3; + + HMENU subMenu = ( NULL != hMenu ) ? GetSubMenu( hMenu, subMenuId ) : NULL; + if ( subMenu != NULL ) + { + INT r = Menu_TrackPopup( plugin.hwndLibraryParent, subMenu, TPM_LEFTALIGN | TPM_TOPALIGN | TPM_NONOTIFY | TPM_RETURNCMD | TPM_RIGHTBUTTON | TPM_LEFTBUTTON, pt.x, pt.y, hHost, NULL ); + + switch(r) + { + case ID_NAVIGATION_DIRECTORY: + MLNavItem_Select( plugin.hwndLibraryParent, myItem ); + break; + case ID_NAVIGATION_PREFERENCES: + SENDWAIPC( plugin.hwndWinampParent, IPC_OPENPREFSTOPAGE, &preferences ); + break; + case ID_NAVIGATION_HELP: + SENDWAIPC( plugin.hwndWinampParent, IPC_OPEN_URL, L"https://help.winamp.com/hc/articles/8112346487060-Podcast-Directory" ); + break; + case ID_NAVIGATION_REFRESHALL: + cloud.RefreshAll(); + cloud.Pulse(); + break; + } + } + + if ( hMenu != NULL ) + DestroyMenu( hMenu ); + + return TRUE; +} + +INT_PTR MessageProc( int msg, INT_PTR param1, INT_PTR param2, INT_PTR param3 ) +{ + INT_PTR result = 0; + if ( Navigation_ProcessMessage( msg, param1, param2, param3, &result ) != FALSE ) + return result; + + switch ( msg ) + { + case ML_MSG_NOTOKTOQUIT: + { + if (downloadStatus.CurrentlyDownloading()) + { + wchar_t titleStr[32] = {0}; + if ( MessageBox( plugin.hwndLibraryParent, WASABI_API_LNGSTRINGW( IDS_CANCEL_DOWNLOADS_AND_QUIT ), WASABI_API_LNGSTRINGW_BUF( IDS_CONFIRM_QUIT, titleStr, 32 ), MB_YESNO | MB_ICONQUESTION ) == IDNO ) + return TRUE; + } + + return 0; + } + case ML_MSG_CONFIG: + mediaLibrary.GoToPreferences(preferences._id); + return TRUE; + case ML_MSG_NAVIGATION_CONTEXTMENU: + return Podcast_OnContextMenu( param1, (HWND)param2, MAKEPOINTS( param3 ) ); + case ML_MSG_VIEW_PLAY_ENQUEUE_CHANGE: + enqueuedef = param1; + groupBtn = param2; + PostMessage( current_window, WM_APP + 104, param1, param2 ); + return 0; + } + + return FALSE; +} + + +#define TREE_IMAGE_LOCAL_PODCASTS 108 + +void addToLibrary(const DownloadedFile& d) +{ + itemRecordW item = { 0 }; + + item.year = -1; + item.track = -1; + item.tracks = -1; + item.length = -1; + item.rating = -1; + item.lastplay = -1; + item.lastupd = -1; + item.filetime = -1; + item.filesize = -1; + item.bitrate = -1; + item.type = -1; + item.disc = -1; + item.discs = -1; + item.bpm = -1; + item.playcount = -1; + item.filename = _wcsdup( d.path ); + + setRecordExtendedItem(&item,L"ispodcast",L"1"); + setRecordExtendedItem(&item,L"podcastchannel",d.channel); + + wchar_t buf[40] = {0}; + _i64tow(d.publishDate,buf,10); + if(d.publishDate) + setRecordExtendedItem(&item,L"podcastpubdate",buf); + + LMDB_FILE_ADD_INFOW fai = {item.filename,-1,-1}; + SendMessage(plugin.hwndLibraryParent, WM_ML_IPC, (WPARAM)&fai, ML_IPC_DB_ADDORUPDATEFILEW); + SendMessage(plugin.hwndLibraryParent, WM_ML_IPC, (WPARAM)&item, ML_IPC_DB_UPDATEITEMW); + PostMessage(plugin.hwndLibraryParent, WM_ML_IPC, 0, ML_IPC_DB_SYNCDB); + freeRecord(&item); + + if(needToMakePodcastsView) { + mlSmartViewInfo m = { sizeof( mlSmartViewInfo ),2,L"Podcasts", L"ispodcast = 1",461315,TREE_IMAGE_LOCAL_PODCASTS,0 }; + WASABI_API_LNGSTRINGW_BUF( IDS_PODCASTS, m.smartViewName, 128 ); + SendMessage( plugin.hwndLibraryParent, WM_ML_IPC, (WPARAM)&m, ML_IPC_SMARTVIEW_ADD ); + needToMakePodcastsView = false; + } +} + +typedef struct +{ + const DownloadedFile *d; + volatile UINT done; +} apc_addtolib_waiter; + +static VOID CALLBACK apc_addtolib(ULONG_PTR dwParam) +{ + apc_addtolib_waiter *w = (apc_addtolib_waiter *)dwParam; + addToLibrary(*w->d); + w->done=1; +} + +void addToLibrary_thread(const DownloadedFile& d) +{ + apc_addtolib_waiter w = { &d, 0 }; + if ( !QueueUserAPC( apc_addtolib, hMainThread, (ULONG_PTR)&w ) ) + return; + + while ( !w.done ) + SleepEx( 5, true ); +} + + +extern "C" __declspec(dllexport) winampMediaLibraryPlugin *winampGetMediaLibraryPlugin() +{ + return &plugin; +}
\ No newline at end of file |