Initial community commit

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