You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
kipi-plugins/kipi-plugins/kameraklient/gpcontroller.cpp

458 lines
15 KiB

/* ============================================================
* File : gpcontroller.cpp
* Author: Renchi Raju <renchi@pooh.tam.uiuc.edu>
* Date : 2003-01-22
* Description :
*
* Copyright 2003 by Renchi Raju <renchi@pooh.tam.uiuc.edu>
* Update : 09/23/2003 - Gilles Caulier <caulier.gilles@free.fr>
* Improve i18n messages.
* 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;
* either version 2, or (at your option)
* any later version.
*
* 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.
*
* ============================================================ */
// Standard
#include <iostream>
// TQt
#include <tqapplication.h>
#include <tqstring.h>
#include <tqimage.h>
#include <tqcolor.h>
// KDE
#include <kdebug.h>
#include <tdelocale.h>
// Local
#include "gpfileiteminfo.h"
#include "mtlist.h"
#include "gpcamera.h"
#include "gpevents.h"
#include "gpmessages.h"
#include "gpcontroller.h"
namespace KIPIKameraKlientPlugin
{
GPController::GPController(TQObject *parent, const CameraType& ctype) : TQObject(parent) {
parent_ = parent;
camera_ = new GPCamera(TQString(ctype.model().latin1()), TQString(ctype.port().latin1()));
close_ = false;
connect(GPMessages::gpMessagesWrapper(), TQ_SIGNAL(statusChanged(const TQString&)),
this, TQ_SLOT(slotStatusMsg(const TQString&)) );
connect(GPMessages::gpMessagesWrapper(), TQ_SIGNAL(progressChanged(int)),
this, TQ_SLOT(slotProgressVal(int)) );
connect(GPMessages::gpMessagesWrapper(), TQ_SIGNAL(errorMessage(const TQString&)),
this, TQ_SLOT(slotErrorMsg(const TQString&)));
}
GPController::~GPController() {
close_ = true;
wait();
cmdQueue_.flush();
GPMessages::deleteMessagesWrapper();
delete camera_;
}
void GPController::requestInitialize() {
cmdQueue_.enqueue(new GPCommand(GPCommand::Init));
}
void GPController::requestGetSubFolders(const TQString& folder) {
cmdQueue_.enqueue(new GPCommandGetSubFolders(folder));
}
void GPController::requestMakeFolder(const TQString& folder, const TQString& newFolder) {
cmdQueue_.enqueue(new GPCommandMakeFolder(folder, newFolder));
}
void GPController::requestDeleteFolder(const TQString& folder) {
cmdQueue_.enqueue(new GPCommandDeleteFolder(folder));
}
void GPController::requestGetItemsInfo(const TQString& folder) {
cmdQueue_.enqueue(new GPCommandGetItemsInfo(folder));
}
void GPController::requestGetAllItemsInfo(const TQString& folder) {
cmdQueue_.enqueue(new GPCommandGetAllItemsInfo(folder));
}
void GPController::requestGetThumbnail(const TQString& folder, const TQString& imageName) {
cmdQueue_.enqueue(new GPCommandGetThumbnail(folder, imageName));
}
void GPController::requestDownloadItem(const TQString& folder, const TQString& itemName, const TQString& saveFile) {
cmdQueue_.enqueue(new GPCommandDownloadItem(folder, itemName, saveFile));
}
void GPController::requestDeleteItem(const TQString& folder, const TQString& itemName) {
cmdQueue_.enqueue(new GPCommandDeleteItem(folder, itemName));
}
void GPController::requestUploadItem(const TQString& folder, const TQString& localFile, const TQString& uploadName) {
cmdQueue_.enqueue(new GPCommandUploadItem(folder, localFile, uploadName));
}
void GPController::requestOpenItem(const TQString& folder, const TQString& itemName, const TQString& saveFile) {
cmdQueue_.enqueue(new GPCommandOpenItem(folder, itemName, saveFile));
}
void GPController::requestOpenItemWithService(const TQString& folder, const TQString& itemName, const TQString& saveFile, const TQString& serviceName) {
cmdQueue_.enqueue(new GPCommandOpenItemWithService(folder, itemName, saveFile, serviceName));
}
void GPController::cancel() {
cmdQueue_.flush();
mutex_.lock();
camera_->cancel();
mutex_.unlock();
}
void GPController::run() {
while(true) {
if(cmdQueue_.isEmpty())
showBusy(false);
if(close_) return;
while(cmdQueue_.isEmpty()) {
if (close_) return;
msleep(200);
}
GPCommand *cmd = cmdQueue_.dequeue();
if(!cmd) {
continue;
}
showBusy(true);
switch(cmd->type()) {
case(GPCommand::Init): {
initialize();
break;
}
case(GPCommand::GetSubFolders): {
GPCommandGetSubFolders *command = static_cast<GPCommandGetSubFolders *>(cmd);
getSubFolders(command->folder());
delete command;
cmd = 0;
break;
}
case(GPCommand::GetItemsInfo): {
GPCommandGetItemsInfo *command = static_cast<GPCommandGetItemsInfo *>(cmd);
getItemsInfo(command->folder());
delete command;
cmd = 0;
break;
}
case(GPCommand::GetAllItemsInfo): {
GPCommandGetAllItemsInfo *command = static_cast<GPCommandGetAllItemsInfo *>(cmd);
getAllItemsInfo(command->folder());
delete command;
cmd = 0;
break;
}
case(GPCommand::GetThumbnail): {
GPCommandGetThumbnail *command = static_cast<GPCommandGetThumbnail *>(cmd);
getThumbnail(command->folder(), command->imageName());
delete command;
cmd = 0;
break;
}
case(GPCommand::DownloadItem): {
GPCommandDownloadItem *command = static_cast<GPCommandDownloadItem *>(cmd);
downloadItem(command->folder(), command->itemName(), command->saveFile());
delete command;
cmd = 0;
break;
}
case(GPCommand::DeleteItem): {
GPCommandDeleteItem *command = static_cast<GPCommandDeleteItem *>(cmd);
deleteItem(command->folder(), command->itemName());
delete command;
cmd = 0;
break;
}
case(GPCommand::UploadItem): {
GPCommandUploadItem *command = static_cast<GPCommandUploadItem *>(cmd);
uploadItem(command->folder(), command->uploadName(), command->localFile());
delete command;
cmd = 0;
break;
}
case(GPCommand::OpenItem): {
GPCommandOpenItem *command = static_cast<GPCommandOpenItem *>(cmd);
openItem(command->folder(), command->itemName(),
command->saveFile());
delete command;
cmd = 0;
break;
}
case(GPCommand::OpenItemWithService): {
GPCommandOpenItemWithService *command = static_cast<GPCommandOpenItemWithService *>(cmd);
openItemWithService(command->folder(),
command->itemName(),
command->saveFile(),
command->serviceName());
delete command;
cmd = 0;
break;
}
default:
tqWarning("GPController: Unknown Command");
break;
}
if (cmd) {
delete cmd;
}
}
}
void GPController::initialize() {
mutex_.lock();
int result = camera_->initialize();
mutex_.unlock();
if (result == GPCamera::GPSuccess) {
TQApplication::postEvent(parent_, new GPEvent(GPEvent::Init));
}
else if (result == GPCamera::GPSetup) {
TQString msg(i18n("Camera Model or Port not specified correctly.\n" "Please run Setup"));
error(msg);
} else {
TQString msg(i18n("Failed to initialize camera.\n" "Please ensure camera is connected properly and turned on"));
error(msg);
}
}
void GPController::getSubFolders(const TQString& folder) {
TQValueList<TQString> subFolderList;
subFolderList.clear();
mutex_.lock();
int result = camera_->getSubFolders(folder, subFolderList);
mutex_.unlock();
if (result == GPCamera::GPSuccess) {
TQApplication::postEvent(parent_, new GPEventGetSubFolders(folder, subFolderList));
if (subFolderList.count() > 0) {
for (unsigned int i=0; i<subFolderList.count(); i++) {
TQString subFolder(folder);
if (subFolder.endsWith("/"))
subFolder += subFolderList[i];
else
subFolder += "/" + subFolderList[i];
getSubFolders(subFolder);
}
}
return;
} else {
TQString msg(i18n("Failed to get subfolder names from '%1'\n").arg(folder));
error(msg);
return;
}
}
void GPController::makeFolder(const TQString&, const TQString&) {
}
void GPController::deleteFolder(const TQString&) {
}
void GPController::getItemsInfo(const TQString& folder) {
GPFileItemInfoList infoList;
infoList.clear();
mutex_.lock();
int result = camera_->getItemsInfo(folder, infoList);
mutex_.unlock();
if (result == GPCamera::GPSuccess) {
TQApplication::postEvent(parent_, new GPEventGetItemsInfo(folder, infoList));
} else {
TQString msg(i18n("Failed to get images information from '%1'\n").arg(folder));
error(msg);
}
}
void GPController::getAllItemsInfo(const TQString& folder) {
GPFileItemInfoList infoList;
infoList.clear();
mutex_.lock();
camera_->getAllItemsInfo(folder, infoList);
mutex_.unlock();
TQApplication::postEvent(parent_, new GPEventGetAllItemsInfo(infoList));
}
void GPController::getThumbnail(const TQString& folder, const TQString& imageName) {
TQImage thumbnail;
mutex_.lock();
int result = camera_->getThumbnail(folder, imageName, thumbnail);
mutex_.unlock();
if (result == GPCamera::GPSuccess) {
scaleHighlightThumbnail(thumbnail);
TQApplication::postEvent(parent_, new GPEventGetThumbnail(folder, imageName, thumbnail));
} else {
kdWarning() << i18n("Failed to get preview for '%1/%2'").arg(folder).arg(imageName) << endl;
}
}
void GPController::downloadItem(const TQString& folder, const TQString& itemName, const TQString& saveFile) {
mutex_.lock();
int result = camera_->downloadItem(folder, itemName, saveFile);
mutex_.unlock();
if (result != GPCamera::GPSuccess) {
TQString msg(i18n("Failed to download '%1' from '%2'").arg(itemName).arg(folder));
error(msg);
} else {
TQApplication::postEvent(parent_, new GPEventDownloadItem(folder, itemName));
}
}
void GPController::openItem(const TQString& folder, const TQString& itemName, const TQString& saveFile) {
mutex_.lock();
int result = camera_->downloadItem(folder, itemName, saveFile);
mutex_.unlock();
if (result != GPCamera::GPSuccess) {
TQString msg(i18n("Failed to open '%1'").arg(itemName));
error(msg);
} else {
TQApplication::postEvent(parent_, new GPEventOpenItem(saveFile));
}
}
void GPController::openItemWithService(const TQString& folder, const TQString& itemName, const TQString& saveFile, const TQString& serviceName) {
mutex_.lock();
int result = camera_->downloadItem(folder, itemName, saveFile);
mutex_.unlock();
if (result != GPCamera::GPSuccess) {
TQString msg(i18n("Failed to open '%1'").arg(itemName));
error(msg);
} else {
TQApplication::postEvent(parent_, new GPEventOpenItemWithService(saveFile, serviceName));
}
}
void GPController::deleteItem(const TQString& folder, const TQString& itemName) {
mutex_.lock();
int result = camera_->deleteItem(folder, itemName);
mutex_.unlock();
if (result != GPCamera::GPSuccess) {
TQString msg(i18n("Failed to delete '%1'").arg(itemName));
error(msg);
} else {
TQApplication::postEvent(parent_, new GPEventDeleteItem(folder, itemName));
}
}
void GPController::uploadItem(const TQString& folder, const TQString& uploadName, const TQString& localFile) {
mutex_.lock();
int result = camera_->uploadItem(folder, uploadName, localFile);
mutex_.unlock();
if (result != GPCamera::GPSuccess) {
TQString msg(i18n("Failed to upload '%1'").arg(localFile));
error(msg);
} else {
GPFileItemInfoList infoList;
GPFileItemInfoList infoList2;
infoList.clear();
infoList2.clear();
mutex_.lock();
int result = camera_->getItemsInfo(folder, infoList);
mutex_.unlock();
if (result == GPCamera::GPSuccess) {
while ( !(infoList.isEmpty()) ) {
GPFileItemInfo info( infoList.first() );
infoList.pop_front();
if (info.name == uploadName) {
infoList2.push_back(info);
break;
}
}
if (!infoList2.isEmpty()) {
TQApplication::postEvent(parent_, new GPEventGetItemsInfo(folder, infoList2));
}
}
}
}
void GPController::error(const TQString& errorMsg) {
kdWarning() << errorMsg;
TQApplication::postEvent(parent_, new GPEventError(errorMsg));
}
void GPController::scaleHighlightThumbnail(TQImage& thumbnail) {
thumbnail = thumbnail.smoothScale(100, 100, TQImage::ScaleMin);
TQColor darkColor(48, 48, 48);
TQColor lightColor(215, 215, 215);
int w = thumbnail.width();
int h = thumbnail.height();
// Right
for (int y=0; y<h; y++) {
if (y > 1 && y < h-2) {
thumbnail.setPixel(w-3, y, lightColor.rgb());
}
thumbnail.setPixel(w-1, y, darkColor.rgb());
thumbnail.setPixel(w-2, y, darkColor.rgb());
}
// Bottom
for (int x=0; x<w; x++) {
if (x > 1 && x < w-2) {
thumbnail.setPixel(x, h-3, lightColor.rgb());
}
thumbnail.setPixel(x, h-1, darkColor.rgb());
thumbnail.setPixel(x, h-2, darkColor.rgb());
}
// Top
for (int x=0; x<w; x++) {
if (x > 1 && x < w-2) {
thumbnail.setPixel(x, 2, lightColor.rgb());
}
thumbnail.setPixel(x, 0, darkColor.rgb());
thumbnail.setPixel(x, 1, darkColor.rgb());
}
// Left
for (int y=0; y<h; y++) {
if (y > 1 && y < h-2) {
thumbnail.setPixel(2, y, lightColor.rgb());
}
thumbnail.setPixel(0, y, darkColor.rgb());
thumbnail.setPixel(1, y, darkColor.rgb());
}
}
void GPController::slotStatusMsg(const TQString& msg) {
if (!msg.isEmpty()) {
TQApplication::postEvent(parent_, new GPEventStatusMsg(msg));
}
}
void GPController::slotProgressVal(int val) {
TQApplication::postEvent(parent_, new GPEventProgress(val));
}
void GPController::slotErrorMsg(const TQString& msg) {
error(msg);
}
void GPController::showBusy(bool val) {
TQApplication::postEvent(parent_, new GPEventBusy(val));
}
void GPController::getInformation(TQString& summary, TQString& manual, TQString& about) {
mutex_.lock();
camera_->cameraSummary(summary);
camera_->cameraManual(manual);
camera_->cameraAbout(about);
mutex_.unlock();
}
} // NameSpace KIPIKameraKlientPlugin
#include "gpcontroller.moc"