summaryrefslogtreecommitdiffstats
path: root/arts/kde/kaudioconverter.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'arts/kde/kaudioconverter.cpp')
-rw-r--r--arts/kde/kaudioconverter.cpp198
1 files changed, 198 insertions, 0 deletions
diff --git a/arts/kde/kaudioconverter.cpp b/arts/kde/kaudioconverter.cpp
new file mode 100644
index 000000000..1eb8c20e5
--- /dev/null
+++ b/arts/kde/kaudioconverter.cpp
@@ -0,0 +1,198 @@
+ /*
+
+ Copyright (C) 2002 Nikolas Zimmermann <wildfox@kde.org>
+
+ This library is free software; you can redistribute it and/or
+ modify it under the terms of the GNU Library 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 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
+ Library General Public License for more details.
+
+ You should have received a copy of the GNU Library General Public License
+ along with this library; see the file COPYING.LIB. If not, write to
+ the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+ Boston, MA 02110-1301, USA.
+
+ */
+
+#include "config.h"
+#include "artskde.h"
+#include "connect.h"
+#include "flowsystem.h"
+#include "audiosubsys.h"
+#include "dynamicrequest.h"
+#include "kdatarequest_impl.h"
+#include "kioinputstream_impl.h"
+#include "kaudioconverter.moc"
+
+#include <iostream>
+
+#include <tqfile.h>
+#include <tqtimer.h>
+
+#include <kurl.h>
+#include <kdebug.h>
+#include <kmimetype.h>
+#include <tdeapplication.h>
+
+using namespace std;
+
+KAudioConverter::KAudioConverter()
+{
+ m_incoming = 0;
+ m_started = false;
+}
+
+KAudioConverter::~KAudioConverter()
+{
+ delete m_incoming;
+}
+
+bool KAudioConverter::setup(int samplingRate)
+{
+ string backupAudioIO = Arts::AudioSubSystem::the()->audioIO();
+ int backupSamplingRate = Arts::AudioSubSystem::the()->samplingRate();
+
+ Arts::AudioSubSystem::the()->audioIO("null");
+ Arts::AudioSubSystem::the()->samplingRate(samplingRate);
+
+ if(!Arts::AudioSubSystem::the()->open())
+ {
+ Arts::AudioSubSystem::the()->audioIO(backupAudioIO);
+ Arts::AudioSubSystem::the()->samplingRate(backupSamplingRate);
+
+ return false;
+ }
+
+ return true;
+}
+
+void KAudioConverter::slotMimeType(const TQString &mimeType)
+{
+ m_mimeType = mimeType;
+ kapp->exit_loop();
+}
+
+void KAudioConverter::requestPlayObject(const KURL &url)
+{
+ string queryInterface = "Arts::PlayObject";
+
+ Arts::TDEIOInputStream inputStream;
+
+ if(!url.isLocalFile())
+ {
+ Arts::TDEIOInputStream_impl *inputStreamImpl = new Arts::TDEIOInputStream_impl();
+ inputStream = Arts::TDEIOInputStream::_from_base(inputStreamImpl);
+
+ TQObject::connect(inputStreamImpl, TQT_SIGNAL(mimeTypeFound(const TQString &)), TQT_SLOT(slotMimeType(const TQString &)));
+
+ inputStream.openURL(url.url().latin1());
+ inputStream.streamStart();
+
+ // ugly hacks.. :/
+ kapp->enter_loop();
+
+ queryInterface = "Arts::StreamPlayObject";
+ }
+ else
+ {
+ KMimeType::Ptr mimetype = KMimeType::findByURL(url);
+ m_mimeType = mimetype->name();
+ }
+
+ Arts::TraderQuery query;
+ query.supports("Interface", queryInterface);
+ query.supports("MimeType", string(m_mimeType.latin1()));
+
+ string objectType;
+
+ vector<Arts::TraderOffer> *offers = query.query();
+ if(!offers->empty())
+ objectType = offers->front().interfaceName(); // first offer
+
+ delete offers;
+
+ if(objectType.empty())
+ {
+ m_incoming = 0;
+ return;
+ }
+
+ if(!url.isLocalFile())
+ {
+ Arts::StreamPlayObject result = Arts::SubClass(objectType);
+ result.streamMedia(inputStream);
+ result._node()->start();
+
+ m_incoming = new KPlayObject(result, true);
+ }
+ else
+ {
+ Arts::PlayObject result = Arts::SubClass(objectType);
+
+ if(result.loadMedia(string(TQFile::encodeName(url.path()))))
+ {
+ result._node()->start();
+ m_incoming = new KPlayObject(result, false);
+ }
+ else
+ m_incoming = 0;
+ }
+}
+
+void KAudioConverter::start()
+{
+ if(m_started || !m_incoming)
+ return;
+
+ m_started = true;
+
+ emit rawStreamStart();
+
+ m_incoming->play();
+
+ Arts::KDataRequest_impl *requestImpl = new Arts::KDataRequest_impl();
+ m_request = Arts::KDataRequest::_from_base(requestImpl);
+
+ Arts::connect(m_incoming->object(), "left", m_request, "left");
+ Arts::connect(m_incoming->object(), "right", m_request, "right");
+
+ TQObject::connect(requestImpl, TQT_SIGNAL(newBlockSize(long)), TQT_SIGNAL(newBlockSize(long)));
+ TQObject::connect(requestImpl, TQT_SIGNAL(newBlockPointer(long)), TQT_SIGNAL(newBlockPointer(long)));
+ TQObject::connect(requestImpl, TQT_SIGNAL(newData()), TQT_SIGNAL(newData()));
+
+ // Special mpeglib case
+ // TODO: needed at all??
+ usleep(100000);
+ if(m_incoming->object()._base()->_isCompatibleWith("DecoderBaseObject"))
+ if(!Arts::DynamicRequest(m_incoming->object()).method("_set_blocking").param(true).invoke())
+ cerr << "mpeglib, and blocking attribute can't be changed?" << endl;
+
+ m_request.start();
+
+ // TODO: Maybe do this async, using TQTimer::singleShot
+ // But jowenn i think jowenn is right -> this would
+ // lead to problems in slotNewData() when accessing the data
+ // (could already be overwritten...)
+ while(m_incoming->state() != Arts::posIdle)
+ m_request.goOn();
+
+ stop();
+}
+
+void KAudioConverter::stop()
+{
+ if(!m_started || !m_incoming)
+ return;
+
+ m_incoming->halt();
+ m_request.streamEnd();
+
+ m_started = false;
+
+ emit rawStreamFinished();
+}