/*************************************************************************** * Copyright (C) 2009 * * * * 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 of the License, 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. * * * * You should have received a copy of the GNU General Public License * * along with this program; if not, write to the * * Free Software Foundation, Inc., * * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * ***************************************************************************/ #include #include #include #include #include #include #include #include #include #include #include "RetroShareLink.h" #include "MainWindow.h" #include "ForumsDialog.h" #include "ChannelFeed.h" #include "SearchDialog.h" #include "msgs/MessageComposer.h" #include "util/misc.h" #include "common/PeerDefs.h" #include "common/RsCollectionFile.h" #include "gui/connect/ConnectFriendWizard.h" #include "gui/connect/ConfCertDialog.h" #include "gui/chat/ChatDialog.h" #include #include #include #include #include //#define DEBUG_RSLINK 1 #define HOST_FILE "file" #define HOST_EXTRAFILE "extra" #define HOST_PERSON "person" #define HOST_FORUM "forum" #define HOST_CHANNEL "channel" #define HOST_MESSAGE "message" #define HOST_SEARCH "search" #define HOST_CERTIFICATE "certificate" #define HOST_PUBLIC_MSG "public_msg" #define HOST_PRIVATE_CHAT "private_chat" #define HOST_REGEXP "file|person|forum|channel|search|message|certificate|private_chat|public_msg" #define FILE_NAME "name" #define FILE_SIZE "size" #define FILE_HASH "hash" #define FILE_SOURCE "src" #define PERSON_NAME "name" #define PERSON_HASH "hash" #define FORUM_NAME "name" #define FORUM_ID "id" #define FORUM_MSGID "msgid" #define CHANNEL_NAME "name" #define CHANNEL_ID "id" #define CHANNEL_MSGID "msgid" #define MESSAGE_ID "id" #define MESSAGE_SUBJECT "subject" #define SEARCH_KEYWORDS "keywords" #define CERTIFICATE_SSLID "sslid" #define CERTIFICATE_GPG_ID "gpgid" #define CERTIFICATE_GPG_BASE64 "gpgbase64" #define CERTIFICATE_GPG_CHECKSUM "gpgchecksum" #define CERTIFICATE_LOCATION "location" #define CERTIFICATE_NAME "name" #define CERTIFICATE_EXT_IPPORT "extipp" #define CERTIFICATE_LOC_IPPORT "locipp" #define PRIVATE_CHAT_TIME_STAMP "time_stamp" #define PRIVATE_CHAT_STRING "encrypted_data" #define PRIVATE_CHAT_GPG_ID "gpgid" #define PUBLIC_MSG_TIME_STAMP "time_stamp" #define PUBLIC_MSG_SRC_PGP_ID "gpgid" #define PUBLIC_MSG_HASH "hash" RetroShareLink::RetroShareLink(const QUrl& url) { fromUrl(url); } RetroShareLink::RetroShareLink(const QString& url) { fromString(url); } void RetroShareLink::fromString(const QString& url) { clear(); // parse #ifdef DEBUG_RSLINK std::cerr << "got new RS link \"" << url.toStdString() << "\"" << std::endl ; #endif if ((url.startsWith(QString(RSLINK_SCHEME) + "://" + QString(HOST_FILE)) && url.count("|") == 3) || (url.startsWith(QString(RSLINK_SCHEME) + "://" + QString(HOST_PERSON)) && url.count("|") == 2)) { /* Old link, we try it */ QStringList list = url.split ("|"); if (list.size() >= 1) { if (list.size() == 4 && list[0] == QString(RSLINK_SCHEME) + "://" + QString(HOST_FILE)) { bool ok ; _type = TYPE_FILE; _name = list[1] ; _size = list[2].toULongLong(&ok) ; _hash = list[3].left(40) ; // normally not necessary, but it's a security. if (ok) { #ifdef DEBUG_RSLINK std::cerr << "New RetroShareLink forged:" << std::endl ; std::cerr << " name = \"" << _name.toStdString() << "\"" << std::endl ; std::cerr << " hash = \"" << _hash.toStdString() << "\"" << std::endl ; std::cerr << " size = " << _size << std::endl ; #endif check(); return; } } else if (list.size() == 3 && list[0] == QString(RSLINK_SCHEME) + "://" + QString(HOST_PERSON)) { _type = TYPE_PERSON; _name = list[1] ; _hash = list[2].left(40) ; // normally not necessary, but it's a security. _size = 0; check(); return; } // bad link } } /* Now try QUrl */ fromUrl(QUrl::fromEncoded(url.toUtf8().constData())); } void RetroShareLink::fromUrl(const QUrl& url) { clear(); // parse #ifdef DEBUG_RSLINK std::cerr << "got new RS link \"" << url.toString().toStdString() << "\"" << std::endl ; #endif if (url.scheme() != RSLINK_SCHEME) { /* No RetroShare-Link */ std::cerr << "Not a RS link: scheme=" << url.scheme().toStdString() << std::endl; return; } if (url.host() == HOST_FILE) { bool ok ; _type = TYPE_FILE; _name = url.queryItemValue(FILE_NAME); _size = url.queryItemValue(FILE_SIZE).toULongLong(&ok); _hash = url.queryItemValue(FILE_HASH).left(40); // normally not necessary, but it's a security. if (ok) { #ifdef DEBUG_RSLINK std::cerr << "New RetroShareLink forged:" << std::endl ; std::cerr << " name = \"" << _name.toStdString() << "\"" << std::endl ; std::cerr << " hash = \"" << _hash.toStdString() << "\"" << std::endl ; std::cerr << " size = " << _size << std::endl ; #endif check(); return; } } if(url.host() == HOST_PRIVATE_CHAT) { bool ok ; _type = TYPE_PRIVATE_CHAT ; _time_stamp = url.queryItemValue(PRIVATE_CHAT_TIME_STAMP).toUInt(&ok) ; _encrypted_chat_info = url.queryItemValue(PRIVATE_CHAT_STRING) ; _GPGid = url.queryItemValue(PRIVATE_CHAT_GPG_ID) ; check() ; return; } if(url.host() == HOST_PUBLIC_MSG) { bool ok ; _type = TYPE_PUBLIC_MSG ; _hash = url.queryItemValue(PUBLIC_MSG_HASH) ; _time_stamp = url.queryItemValue(PUBLIC_MSG_TIME_STAMP).toUInt(&ok) ; _GPGid = url.queryItemValue(PUBLIC_MSG_SRC_PGP_ID) ; check() ; return; } if (url.host() == HOST_EXTRAFILE) { bool ok ; _type = TYPE_EXTRAFILE; _name = url.queryItemValue(FILE_NAME); _size = url.queryItemValue(FILE_SIZE).toULongLong(&ok); _hash = url.queryItemValue(FILE_HASH).left(40); // normally not necessary, but it's a security. _SSLid = url.queryItemValue(FILE_SOURCE); if (ok) { #ifdef DEBUG_RSLINK std::cerr << "New RetroShareLink forged:" << std::endl ; std::cerr << " name = \"" << _name.toStdString() << "\"" << std::endl ; std::cerr << " hash = \"" << _hash.toStdString() << "\"" << std::endl ; std::cerr << " size = " << _size << std::endl ; std::cerr << " src = " << _SSLid.toStdString() << std::endl ; #endif check(); return; } } if (url.host() == HOST_PERSON) { _type = TYPE_PERSON; _name = url.queryItemValue(PERSON_NAME); _hash = url.queryItemValue(PERSON_HASH).left(40); // normally not necessary, but it's a security. check(); return; } if (url.host() == HOST_FORUM) { _type = TYPE_FORUM; _name = url.queryItemValue(FORUM_NAME); _hash = url.queryItemValue(FORUM_ID); _msgId = url.queryItemValue(FORUM_MSGID); check(); return; } if (url.host() == HOST_CHANNEL) { _type = TYPE_CHANNEL; _name = url.queryItemValue(CHANNEL_NAME); _hash = url.queryItemValue(CHANNEL_ID); _msgId = url.queryItemValue(CHANNEL_MSGID); check(); return; } if (url.host() == HOST_SEARCH) { _type = TYPE_SEARCH; _name = url.queryItemValue(SEARCH_KEYWORDS); check(); return; } if (url.host() == HOST_MESSAGE) { _type = TYPE_MESSAGE; std::string id = url.queryItemValue(MESSAGE_ID).toStdString(); createMessage(id, url.queryItemValue(MESSAGE_SUBJECT)); return; } if (url.host() == HOST_CERTIFICATE) { _type = TYPE_CERTIFICATE; _SSLid = url.queryItemValue(CERTIFICATE_SSLID); _name = url.queryItemValue(CERTIFICATE_NAME); _location = url.queryItemValue(CERTIFICATE_LOCATION); _GPGBase64String = url.queryItemValue(CERTIFICATE_GPG_BASE64); _GPGid = url.queryItemValue(CERTIFICATE_GPG_ID); _GPGBase64CheckSum = url.queryItemValue(CERTIFICATE_GPG_CHECKSUM); _ext_ip_port = url.queryItemValue(CERTIFICATE_EXT_IPPORT); _loc_ip_port = url.queryItemValue(CERTIFICATE_LOC_IPPORT); std::cerr << "Got a certificate link!!" << std::endl; check() ; return; } // bad link #ifdef DEBUG_RSLINK std::cerr << "Wrongly formed RS link. Can't process." << std::endl ; #endif clear(); } RetroShareLink::RetroShareLink() { clear(); } bool RetroShareLink::createExtraFile(const QString& name, uint64_t size, const QString& hash,const QString& ssl_id) { clear(); _name = name; _size = size; _hash = hash; _SSLid = ssl_id; _type = TYPE_EXTRAFILE; check(); return valid(); } bool RetroShareLink::createFile(const QString& name, uint64_t size, const QString& hash) { clear(); _name = name; _size = size; _hash = hash; _type = TYPE_FILE; check(); return valid(); } bool RetroShareLink::createPrivateChatInvite(time_t time_stamp,const QString& gpg_id,const QString& encrypted_chat_info) { clear() ; _type = TYPE_PRIVATE_CHAT ; _time_stamp = time_stamp ; _encrypted_chat_info = encrypted_chat_info ; _GPGid = gpg_id ; check() ; return valid() ; } bool RetroShareLink::createPublicMsgInvite(time_t time_stamp,const QString& issuer_pgp_id,const QString& hash) { clear() ; _type = TYPE_PUBLIC_MSG ; _time_stamp = time_stamp ; _hash = hash ; _GPGid = issuer_pgp_id ; check() ; return valid() ; } bool RetroShareLink::createPerson(const std::string& id) { clear(); RsPeerDetails detail; if (rsPeers->getPeerDetails(id, detail) == false) { std::cerr << "RetroShareLink::createPerson() Couldn't find peer id " << id << std::endl; return false; } _hash = QString::fromStdString(id); _name = QString::fromUtf8(detail.name.c_str()); _type = TYPE_PERSON; check(); return valid(); } bool RetroShareLink::createCertificate(const std::string& ssl_or_gpg_id) { // This is baaaaaad code: // - we should not need to parse and re-read a cert in old format. // RsPeerDetails detail; if (rsPeers->getPeerDetails(ssl_or_gpg_id, detail) == false) { std::cerr << "RetroShareLink::createPerson() Couldn't find peer id " << ssl_or_gpg_id << std::endl; return false; } std::string gpg_base_64_str = "" ; std::string gpg_base_64_checksum_str = "" ; if(!rsPeers->GetPGPBase64StringAndCheckSum(detail.gpg_id,gpg_base_64_str,gpg_base_64_checksum_str)) return false ; _GPGBase64String = QString::fromStdString(gpg_base_64_str) ; _GPGBase64CheckSum = QString::fromStdString(gpg_base_64_checksum_str) ; _type = TYPE_CERTIFICATE; _GPGid = QString::fromStdString(detail.gpg_id).right(8); if(detail.isOnlyGPGdetail) { _SSLid.clear(); _location.clear(); _ext_ip_port.clear(); _loc_ip_port.clear(); } else { _SSLid = QString::fromStdString(ssl_or_gpg_id) ; _location = QString::fromUtf8(detail.location.c_str()) ; _ext_ip_port = QString::fromStdString(detail.extAddr) + ":" + QString::number(detail.extPort) + ";" ; _loc_ip_port = QString::fromStdString(detail.localAddr) + ":" + QString::number(detail.localPort) + ";" ; } _name = QString::fromUtf8(detail.name.c_str()) ; std::cerr << "Found gpg base 64 string = " << _GPGBase64String.toStdString() << std::endl; std::cerr << "Found gpg base 64 checksum = " << _GPGBase64CheckSum.toStdString() << std::endl; std::cerr << "Found SSLId = " << _SSLid.toStdString() << std::endl; std::cerr << "Found GPGId = " << _GPGid.toStdString() << std::endl; std::cerr << "Found Local IP+Port = " << _loc_ip_port.toStdString() << std::endl; std::cerr << "Found External IP+Port = " << _ext_ip_port.toStdString() << std::endl; std::cerr << "Found Location = " << _location.toStdString() << std::endl; return true; } bool RetroShareLink::createUnknwonSslCertificate(const std::string& sslId, const std::string& gpgId) { // first try ssl id if (createCertificate(sslId)) { if (gpgId.empty() || _GPGid.toStdString() == gpgId) { return true; } // wrong gpg id return false; } // then gpg id if (createCertificate(gpgId)) { if (!_SSLid.isEmpty()) { return false; } if (sslId.empty()) { return true; } _SSLid = QString::fromStdString(sslId); if (_location.isEmpty()) { _location = _name; } return true; } return false; } bool RetroShareLink::createForum(const std::string& id, const std::string& msgId) { clear(); if (!id.empty()) { _hash = QString::fromStdString(id); _msgId = QString::fromStdString(msgId); _type = TYPE_FORUM; if (msgId.empty()) { ForumInfo fi; if (rsForums->getForumInfo(id, fi)) { _name = QString::fromStdWString(fi.forumName); } } else { ForumMsgInfo mi; if (rsForums->getForumMessage(id, msgId, mi)) { _name = ForumsDialog::titleFromInfo(mi); } } } check(); return valid(); } bool RetroShareLink::createChannel(const std::string& id, const std::string& msgId) { clear(); if (!id.empty()) { _hash = QString::fromStdString(id); _msgId = QString::fromStdString(msgId); _type = TYPE_CHANNEL; if (msgId.empty()) { ChannelInfo ci; if (rsChannels->getChannelInfo(id, ci)) { _name = QString::fromStdWString(ci.channelName); } } else { ChannelMsgInfo mi; if (rsChannels->getChannelMessage(id, msgId, mi)) { _name = QString::fromStdWString(mi.subject); } } } check(); return valid(); } bool RetroShareLink::createSearch(const QString& keywords) { clear(); _name = keywords; _type = TYPE_SEARCH; check(); return valid(); } bool RetroShareLink::createMessage(const std::string& peerId, const QString& subject) { clear(); _hash = QString::fromStdString(peerId); PeerDefs::rsidFromId(peerId, &_name); _subject = subject; _type = TYPE_MESSAGE; check(); return valid(); } void RetroShareLink::clear() { _valid = false; _type = TYPE_UNKNOWN; _subType = 0; _hash = "" ; _size = 0 ; _name = "" ; _GPGid = "" ; _time_stamp = 0 ; _encrypted_chat_info = "" ; } void RetroShareLink::check() { _valid = true; switch (_type) { case TYPE_UNKNOWN: _valid = false; break; case TYPE_EXTRAFILE: if(!checkSSLId(_SSLid)) _valid = false; // no break! We also test file stuff below. case TYPE_FILE: if(_size > (((uint64_t)1)<<40)) // 1TB. Who has such large files? _valid = false; if(!checkName(_name)) _valid = false; if(!checkHash(_hash)) _valid = false; break; case TYPE_PRIVATE_CHAT: if(!checkRadix64(_encrypted_chat_info)) _valid = false ; if(!checkPGPId(_GPGid)) _valid = false ; break ; case TYPE_PUBLIC_MSG: if(!checkHash(_hash)) _valid = false ; if(!checkPGPId(_GPGid)) _valid = false ; break ; case TYPE_PERSON: if(_size != 0) _valid = false; if(_name.isEmpty()) _valid = false; if(_hash.isEmpty()) _valid = false; break; case TYPE_FORUM: if(_size != 0) _valid = false; if(_name.isEmpty()) _valid = false; if(_hash.isEmpty()) _valid = false; break; case TYPE_CHANNEL: if(_size != 0) _valid = false; if(_name.isEmpty()) _valid = false; if(_hash.isEmpty()) _valid = false; break; case TYPE_SEARCH: if(_size != 0) _valid = false; if(_name.isEmpty()) _valid = false; if(!_hash.isEmpty()) _valid = false; break; case TYPE_MESSAGE: if(_size != 0) _valid = false; if(_hash.isEmpty()) _valid = false; break; case TYPE_CERTIFICATE: break; } if (!_valid) { clear(); } } QString RetroShareLink::title() const { if (!valid()) { return ""; } switch (_type) { case TYPE_UNKNOWN: break; case TYPE_PUBLIC_MSG: { RsPeerDetails detail; rsPeers->getPeerDetails(_GPGid.toStdString(), detail) ; return QString("Click to send a private message to %1 (%2).").arg(QString::fromStdString(detail.name)).arg(_GPGid) ; } case TYPE_PRIVATE_CHAT: { RsPeerDetails detail; rsPeers->getPeerDetails(_GPGid.toStdString(), detail) ; if (_GPGid.toStdString() == rsPeers->getGPGOwnId()) return QString("Click to open a private chat canal to %1 (%2).").arg(QString::fromStdString(detail.name)).arg(_GPGid) ; else return QString("This is a private chat invite for %1 (%2). You can't use it.").arg(QString::fromStdString(detail.name)).arg(_GPGid) ; } case TYPE_EXTRAFILE: return QString("%1 (%2, Extra - Source included)").arg(hash()).arg(misc::friendlyUnit(size())); case TYPE_FILE: return QString("%1 (%2)").arg(hash()).arg(misc::friendlyUnit(size())); case TYPE_PERSON: return PeerDefs::rsidFromId(hash().toStdString()); case TYPE_FORUM: case TYPE_CHANNEL: case TYPE_SEARCH: break; case TYPE_MESSAGE: return PeerDefs::rsidFromId(hash().toStdString()); case TYPE_CERTIFICATE: return QObject::tr("Click to add this RetroShare cert to your PGP keyring\nand open the Make Friend Wizard.\n") + QString("GPG Id = ") + GPGId() + QString("\nSSLId = ")+SSLId(); } return ""; } static QString encodeItem(QString item) { return item.replace(" ", "%20").replace("&", "%26").replace("#", "%23").replace("\"", "%22"); } QString RetroShareLink::toString() const { switch (_type) { case TYPE_UNKNOWN: break; case TYPE_FILE: { QUrl url; url.setScheme(RSLINK_SCHEME); url.setHost(HOST_FILE); url.addQueryItem(FILE_NAME, encodeItem(_name)); url.addQueryItem(FILE_SIZE, QString::number(_size)); url.addQueryItem(FILE_HASH, _hash); return url.toString(); } case TYPE_PRIVATE_CHAT: { QUrl url; url.setScheme(RSLINK_SCHEME) ; url.setHost(HOST_PRIVATE_CHAT) ; url.addQueryItem(PRIVATE_CHAT_TIME_STAMP,QString::number(_time_stamp)) ; url.addQueryItem(PRIVATE_CHAT_GPG_ID,_GPGid) ; url.addQueryItem(PRIVATE_CHAT_STRING,_encrypted_chat_info) ; return url.toString() ; } case TYPE_PUBLIC_MSG: { QUrl url; url.setScheme(RSLINK_SCHEME) ; url.setHost(HOST_PUBLIC_MSG) ; url.addQueryItem(PUBLIC_MSG_TIME_STAMP,QString::number(_time_stamp)) ; url.addQueryItem(PUBLIC_MSG_HASH,_hash) ; url.addQueryItem(PUBLIC_MSG_SRC_PGP_ID,_GPGid) ; return url.toString() ; } case TYPE_EXTRAFILE: { QUrl url; url.setScheme(RSLINK_SCHEME); url.setHost(HOST_EXTRAFILE); url.addQueryItem(FILE_NAME, encodeItem(_name)); url.addQueryItem(FILE_SIZE, QString::number(_size)); url.addQueryItem(FILE_HASH, _hash); url.addQueryItem(FILE_SOURCE, _SSLid); return url.toString(); } case TYPE_PERSON: { QUrl url; url.setScheme(RSLINK_SCHEME); url.setHost(HOST_PERSON); url.addQueryItem(PERSON_NAME, encodeItem(_name)); url.addQueryItem(PERSON_HASH, _hash); return url.toString(); } case TYPE_FORUM: { QUrl url; url.setScheme(RSLINK_SCHEME); url.setHost(HOST_FORUM); url.addQueryItem(FORUM_NAME, encodeItem(_name)); url.addQueryItem(FORUM_ID, _hash); if (!_msgId.isEmpty()) { url.addQueryItem(FORUM_MSGID, _msgId); } return url.toString(); } case TYPE_CHANNEL: { QUrl url; url.setScheme(RSLINK_SCHEME); url.setHost(HOST_CHANNEL); url.addQueryItem(CHANNEL_NAME, encodeItem(_name)); url.addQueryItem(CHANNEL_ID, _hash); if (!_msgId.isEmpty()) { url.addQueryItem(CHANNEL_MSGID, _msgId); } return url.toString(); } case TYPE_SEARCH: { QUrl url; url.setScheme(RSLINK_SCHEME); url.setHost(HOST_SEARCH); url.addQueryItem(SEARCH_KEYWORDS, encodeItem(_name)); return url.toString(); } case TYPE_MESSAGE: { QUrl url; url.setScheme(RSLINK_SCHEME); url.setHost(HOST_MESSAGE); url.addQueryItem(MESSAGE_ID, _hash); if (_subject.isEmpty() == false) { url.addQueryItem(MESSAGE_SUBJECT, encodeItem(_subject)); } return url.toString(); } case TYPE_CERTIFICATE: { QUrl url ; url.setScheme(RSLINK_SCHEME); url.setHost(HOST_CERTIFICATE) ; if (!_SSLid.isEmpty()) { url.addQueryItem(CERTIFICATE_SSLID, _SSLid); } url.addQueryItem(CERTIFICATE_GPG_ID, _GPGid); url.addQueryItem(CERTIFICATE_GPG_BASE64, _GPGBase64String); url.addQueryItem(CERTIFICATE_GPG_CHECKSUM, _GPGBase64CheckSum); if (!_location.isEmpty()) { url.addQueryItem(CERTIFICATE_LOCATION, encodeItem(_location)); } url.addQueryItem(CERTIFICATE_NAME, encodeItem(_name)); if (!_loc_ip_port.isEmpty()) { url.addQueryItem(CERTIFICATE_LOC_IPPORT, encodeItem(_loc_ip_port)); } if (!_ext_ip_port.isEmpty()) { url.addQueryItem(CERTIFICATE_EXT_IPPORT, encodeItem(_ext_ip_port)); } return url.toString(); } } return ""; } QString RetroShareLink::niceName() const { if (type() == TYPE_PERSON) { return PeerDefs::rsid(name().toUtf8().constData(), hash().toStdString()); } if(type() == TYPE_PRIVATE_CHAT) { return QString("Private chat invite (Valid only for key %1)").arg(_GPGid); } if(type() == TYPE_PUBLIC_MSG) { RsPeerDetails detail; rsPeers->getPeerDetails(_GPGid.toStdString(), detail) ; return QString("Click this link to send a private message to %1 (%2)").arg(QString::fromStdString(detail.name)).arg(_GPGid) ; } if(type() == TYPE_CERTIFICATE) { if (_location.isEmpty()) { return QString("RetroShare Certificate (%1)").arg(_name); } return QString("RetroShare Certificate (%1, @%2)").arg(_name, _location); // should add SSL id there } return name(); } QString RetroShareLink::toHtml() const { QString html = "" ; return html; } QString RetroShareLink::toHtmlFull() const { return QString("" + toString() + "" ; } QString RetroShareLink::toHtmlSize() const { QString size = QString("(%1)").arg(misc::friendlyUnit(_size)); if (type() == TYPE_FILE && RsCollectionFile::isCollectionFile(name())) { FileInfo finfo; if (rsFiles->FileDetails(hash().toStdString(), RS_FILE_HINTS_EXTRA | RS_FILE_HINTS_LOCAL, finfo)) { RsCollectionFile collection; if (collection.load(QString::fromUtf8(finfo.path.c_str()), false)) { size += QString(" [%1]").arg(misc::friendlyUnit(collection.size())); } } } QString link = QString("%2 %3").arg(toString()).arg(name()).arg(size); return link; } bool RetroShareLink::checkName(const QString& name) { if(name == "") return false ; for(int i=0;i47 && b<58) || (b>96 && b<103))) return false ; } return true ; } bool RetroShareLink::checkPGPId(const QString& pgp_id) { if(pgp_id.length() != 16) return false ; QByteArray qb(pgp_id.toAscii()) ; for(int i=0;i47 && b<58) || (b>64 && b<71))) return false ; } return true ; } bool RetroShareLink::checkRadix64(const QString& s) { QByteArray qb(s.toAscii()) ; for(int i=0;i 46 && b < 58) || (b > 64 && b < 91) || (b > 96 && b < 123) || b=='+' || b=='=')) { std::cerr << "Character not allowed in radix: " << b << std::endl; return false; } } std::cerr << "Radix check: passed" << std::endl; return true ; } bool RetroShareLink::checkHash(const QString& hash) { if(hash.length() != 40) return false ; QByteArray qb(hash.toAscii()) ; for(int i=0;i47 && b<58) || (b>96 && b<103))) return false ; } return true ; } static void processList(const QStringList &list, const QString &textSingular, const QString &textPlural, QString &result) { if (list.size() == 0) { return; } if (list.size() == 1) { result += "" + textSingular + ":"; } else { result += "" + textPlural + ":"; } result += "

"; QStringList::const_iterator it; for (it = list.begin(); it != list.end(); ++it) { if (it != list.begin()) { result += ", "; } result += *it; } result += "

"; } /*static*/ int RetroShareLink::process(const QList &linksIn, uint flag /* = RSLINK_PROCESS_NOTIFY_ALL*/) { QList::const_iterator linkIt; flag &= ~RSLINK_PROCESS_NOTIFY_BAD_CHARS ; // this will be set below when needed /* filter dublicate links */ QList links; for (linkIt = linksIn.begin(); linkIt != linksIn.end(); linkIt++) { if (links.contains(*linkIt)) { continue; } links.append(*linkIt); } if (flag & RSLINK_PROCESS_NOTIFY_ASK) { /* ask for some types of link */ QStringList fileAdd; QStringList personAdd; for (linkIt = links.begin(); linkIt != links.end(); linkIt++) { const RetroShareLink &link = *linkIt; if (link.valid() == false) { continue; } switch (link.type()) { case TYPE_UNKNOWN: case TYPE_FORUM: case TYPE_CHANNEL: case TYPE_SEARCH: case TYPE_MESSAGE: case TYPE_CERTIFICATE: case TYPE_PRIVATE_CHAT: case TYPE_PUBLIC_MSG: // no need to ask break; case TYPE_FILE: case TYPE_EXTRAFILE: fileAdd.append(link.name()); break; case TYPE_PERSON: personAdd.append(PeerDefs::rsid(link.name().toUtf8().constData(), link.hash().toStdString())); break; } } QString content; if (fileAdd.size()) { processList(fileAdd, QObject::tr("Add file"), QObject::tr("Add files"), content); } if (personAdd.size()) { processList(personAdd, QObject::tr("Add friend"), QObject::tr("Add friends"), content); } if (content.isEmpty() == false) { QString question = ""; if (links.size() == 1) { question += QObject::tr("Do you want to process the link ?"); } else { question += QObject::tr("Do you want to process %1 links ?").arg(links.size()); } question += "

" + content + ""; QMessageBox mb(QObject::tr("Confirmation"), question, QMessageBox::Question, QMessageBox::Yes,QMessageBox::No, 0); mb.setWindowIcon(QIcon(QString::fromUtf8(":/images/rstray3.png"))); if (mb.exec() == QMessageBox::No) { return 0; } } } int countInvalid = 0; int countUnknown = 0; bool needNotifySuccess = false; // file QStringList fileAdded; QStringList fileExist; // person QStringList personAdded; QStringList personExist; QStringList personFailed; QStringList personNotFound; // forum QStringList forumFound; QStringList forumMsgFound; QStringList forumUnknown; QStringList forumMsgUnknown; // forum QStringList channelFound; QStringList channelMsgFound; QStringList channelUnknown; QStringList channelMsgUnknown; // search QStringList searchStarted; // message QStringList messageStarted; QStringList messageReceipientNotAccepted; QStringList messageReceipientUnknown; // Certificate QStringList GPGBase64Strings ; QStringList SSLIds ; // summary QList processedList; QList errorList; processedList << &fileAdded << &personAdded << &forumFound << &channelFound << &searchStarted << &messageStarted; errorList << &fileExist << &personExist << &personFailed << &personNotFound << &forumUnknown << &forumMsgUnknown << &channelUnknown << &channelMsgUnknown << &messageReceipientNotAccepted << &messageReceipientUnknown; // not needed: forumFound, channelFound, messageStarted for (linkIt = links.begin(); linkIt != links.end(); linkIt++) { const RetroShareLink &link = *linkIt; if (link.valid() == false) { std::cerr << " RetroShareLink::process invalid request" << std::endl; countInvalid++; continue; } switch (link.type()) { case TYPE_UNKNOWN: countUnknown++; break; case TYPE_CERTIFICATE: { #ifdef DEBUG_RSLINK std::cerr << " RetroShareLink::process certificate." << std::endl; #endif needNotifySuccess = true; QString RS_Certificate ; RS_Certificate += "-----BEGIN PGP PUBLIC KEY BLOCK-----\n" ; RS_Certificate += "Version: Retroshare Generated cert.\n" ; RS_Certificate += "\n" ; QString radix = link.GPGRadix64Key() ; while(radix.size() > 64) { RS_Certificate += radix.left(64) + "\n" ; radix = radix.right(radix.size() - 64) ; } RS_Certificate += radix.left(64) + "\n" ; RS_Certificate += "=" + link.GPGBase64CheckSum() + "\n" ; RS_Certificate += "-----END PGP PUBLIC KEY BLOCK-----\n" ; RS_Certificate += "--SSLID--" + link.SSLId() + ";--LOCATION--" + link.location() + ";\n" ; if(!link.externalIPAndPort().isNull()) RS_Certificate += "--EXT--" + link.externalIPAndPort() + ";" ; if(!link.localIPAndPort().isNull()) RS_Certificate += "--LOCAL--" + link.localIPAndPort() + ";" ; RS_Certificate += "\n" ; std::cerr << "Usign this certificate:" << std::endl; std::cerr << RS_Certificate.toStdString() << std::endl; ConnectFriendWizard connectFriendWizard; connectFriendWizard.setCertificate(RS_Certificate, (link.subType() == RSLINK_SUBTYPE_CERTIFICATE_USER_REQUEST) ? true : false); connectFriendWizard.exec(); needNotifySuccess = false; } break ; case TYPE_PUBLIC_MSG: { std::cerr << "Opening a public msg window " << std::endl; std::cerr << " time_stamp = " << link._time_stamp << std::endl; std::cerr << " hash = " << link._hash.toStdString() << std::endl; std::cerr << " Issuer Id = " << link._GPGid.toStdString() << std::endl; if(link._time_stamp < time(NULL)) { QMessageBox::information(NULL,QObject::tr("Messenging link is expired"),QObject::tr("This Messenging link is expired. The destination peer will not receive it.")) ; break ; } MessageComposer::msgDistantPeer(link._hash.toStdString(),link._GPGid.toStdString()) ; } break ; case TYPE_PRIVATE_CHAT: { std::cerr << "Opening a private chat window " << std::endl; std::cerr << " time_stamp = " << link._time_stamp << std::endl; std::cerr << " enc-string = " << link._encrypted_chat_info.toStdString() << std::endl; std::cerr << " PGP Id = " << link._GPGid.toStdString() << std::endl; if(link._time_stamp < time(NULL)) { QMessageBox::information(NULL,QObject::tr("Chat link is expired"),QObject::tr("This chat link is expired. The destination peer will not answer.")) ; break ; } if(link._GPGid.toStdString() != rsPeers->getGPGOwnId()) { QMessageBox::information(NULL,QObject::tr("Chat link cannot be decrypted"),QObject::tr("This chat link is encrypted with a key that is not yours. You can't used it. Key ID = ")+link._GPGid) ; break ; } std::string hash ; uint32_t error_code ; if(!rsMsgs->initiateDistantChatConnexion(link._encrypted_chat_info.toStdString(),link._time_stamp,hash,error_code)) { QString error_msg ; switch(error_code) { default: case RS_DISTANT_CHAT_ERROR_DECRYPTION_FAILED: error_msg = QObject::tr("The link could not be decrypted.") ; break ; case RS_DISTANT_CHAT_ERROR_SIGNATURE_MISMATCH: error_msg = QObject::tr("The link signature cannot be checked.") ; break ; case RS_DISTANT_CHAT_ERROR_UNKNOWN_KEY: error_msg = QObject::tr("The link is signed by an unknown key.") ; break ; } QMessageBox::information(NULL,QObject::tr("Chat connexion is not possible"),error_msg) ; } else ChatDialog::chatFriend(hash); } break ; case TYPE_FILE: case TYPE_EXTRAFILE: { #ifdef DEBUG_RSLINK std::cerr << " RetroShareLink::process FileRequest : fileName : " << link.name().toUtf8().constData() << ". fileHash : " << link.hash().toStdString() << ". fileSize : " << link.size() << std::endl; #endif needNotifySuccess = true; std::list srcIds; // Add the link built-in source. This is needed for EXTRA files, where the source is specified in the link. if(link.type() == TYPE_EXTRAFILE) { #ifdef DEBUG_RSLINK std::cerr << " RetroShareLink::process Adding built-in source " << link.SSLId().toStdString() << std::endl; #endif srcIds.push_back(link.SSLId().toStdString()) ; } // Get a list of available direct sources, in case the file is browsable only. // FileInfo finfo ; rsFiles->FileDetails(link.hash().toStdString(), RS_FILE_HINTS_REMOTE, finfo) ; for(std::list::const_iterator it(finfo.peers.begin());it!=finfo.peers.end();++it) { #ifdef DEBUG_RSLINK std::cerr << " adding peerid " << (*it).peerId << std::endl ; #endif srcIds.push_back((*it).peerId) ; } QString cleanname = link.name() ; static const QString bad_chars_str = "/\\\"*:?<>|" ; for(int i=0;iFileRequest(cleanname.toUtf8().constData(), link.hash().toStdString(), link.size(), "", RS_FILE_REQ_ANONYMOUS_ROUTING, srcIds)) { fileAdded.append(link.name()); } else { fileExist.append(link.name()); } break; } case TYPE_PERSON: { #ifdef DEBUG_RSLINK std::cerr << " RetroShareLink::process FriendRequest : name : " << link.name().toStdString() << ". id : " << link.hash().toStdString() << std::endl; #endif needNotifySuccess = true; RsPeerDetails detail; if (rsPeers->getPeerDetails(link.hash().toStdString(), detail)) { if (detail.gpg_id == rsPeers->getGPGOwnId()) { // it's me, do nothing break; } if (detail.accept_connection) { // peer connection is already accepted personExist.append(PeerDefs::rsid(detail)); break; } if (rsPeers->addFriend("", link.hash().toStdString())) { ConfCertDialog::loadAll(); personAdded.append(PeerDefs::rsid(detail)); break; } personFailed.append(PeerDefs::rsid(link.name().toUtf8().constData(), link.hash().toStdString())); break; } personNotFound.append(PeerDefs::rsid(link.name().toUtf8().constData(), link.hash().toStdString())); break; } case TYPE_FORUM: { #ifdef DEBUG_RSLINK std::cerr << " RetroShareLink::process ForumRequest : name : " << link.name().toStdString() << ". id : " << link.hash().toStdString() << ". msgId : " << link.msgId().toStdString() << std::endl; #endif ForumInfo fi; if (!rsForums->getForumInfo(link.id().toStdString(), fi)) { if (link.msgId().isEmpty()) { forumUnknown.append(link.name()); } else { forumMsgUnknown.append(link.name()); } break; } ForumMsgInfo msg; if (!link.msgId().isEmpty()) { if (!rsForums->getForumMessage(fi.forumId, link.msgId().toStdString(), msg)) { forumMsgUnknown.append(link.name()); break; } } MainWindow::showWindow(MainWindow::Forums); ForumsDialog *forumsDialog = dynamic_cast(MainWindow::getPage(MainWindow::Forums)); if (!forumsDialog) { return false; } if (forumsDialog->navigate(fi.forumId, msg.msgId)) { if (link.msgId().isEmpty()) { forumFound.append(link.name()); } else { forumMsgFound.append(link.name()); } } else { if (link.msgId().isEmpty()) { forumUnknown.append(link.name()); } else { forumMsgUnknown.append(link.name()); } } break; } case TYPE_CHANNEL: { #ifdef DEBUG_RSLINK std::cerr << " RetroShareLink::process ChannelRequest : name : " << link.name().toStdString() << ". id : " << link.hash().toStdString() << ". msgId : " << link.msgId().toStdString() << std::endl; #endif ChannelInfo ci; if (!rsChannels->getChannelInfo(link.id().toStdString(), ci)) { if (link.msgId().isEmpty()) { channelUnknown.append(link.name()); } else { channelMsgUnknown.append(link.name()); } break; } ChannelMsgInfo msg; if (!link.msgId().isEmpty()) { if (!rsChannels->getChannelMessage(ci.channelId, link.msgId().toStdString(), msg)) { channelMsgUnknown.append(link.name()); break; } } MainWindow::showWindow(MainWindow::Channels); ChannelFeed *channelFeed = dynamic_cast(MainWindow::getPage(MainWindow::Channels)); if (!channelFeed) { return false; } if (channelFeed->navigate(ci.channelId, msg.msgId)) { if (link.msgId().isEmpty()) { channelFound.append(link.name()); } else { channelMsgFound.append(link.name()); } } else { if (link.msgId().isEmpty()) { channelUnknown.append(link.name()); } else { channelMsgUnknown.append(link.name()); } } break; } case TYPE_SEARCH: { #ifdef DEBUG_RSLINK std::cerr << " RetroShareLink::process SearchRequest : string : " << link.name().toStdString() << std::endl; #endif SearchDialog *searchDialog = dynamic_cast(MainWindow::getPage(MainWindow::Search)); if (!searchDialog) { std::cerr << "Retrieve of search dialog failed. Please debug!" << std::endl; break; } MainWindow::showWindow(MainWindow::Search); searchDialog->searchKeywords(link.name()); searchStarted.append(link.name()); break; } case TYPE_MESSAGE: { #ifdef DEBUG_RSLINK std::cerr << " RetroShareLink::process MessageRequest : id : " << link.hash().toStdString() << ", subject : " << link.name().toStdString() << std::endl; #endif RsPeerDetails detail; if (rsPeers->getPeerDetails(link.hash().toStdString(), detail)) { if (detail.accept_connection || detail.id == rsPeers->getOwnId() || detail.id == rsPeers->getGPGOwnId()) { MessageComposer *msg = MessageComposer::newMsg(); msg->addRecipient(MessageComposer::TO, detail.id, false); if (link.subject().isEmpty() == false) { msg->setTitleText(link.subject()); } msg->show(); messageStarted.append(PeerDefs::nameWithLocation(detail)); } else { messageReceipientNotAccepted.append(PeerDefs::nameWithLocation(detail)); } } else { messageReceipientUnknown.append(PeerDefs::rsidFromId(link.hash().toStdString())); } break; } default: std::cerr << " RetroShareLink::process unknown type: " << link.type() << std::endl; countUnknown++; } } int countProcessed = 0; int countError = 0; QList::iterator listIt; for (listIt = processedList.begin(); listIt != processedList.end(); ++listIt) { countProcessed += (*listIt)->size(); } for (listIt = errorList.begin(); listIt != errorList.end(); ++listIt) { countError += (*listIt)->size(); } // success notify needed ? if (needNotifySuccess == false) { flag &= ~RSLINK_PROCESS_NOTIFY_SUCCESS; } // error notify needed ? if (countError == 0) { flag &= ~RSLINK_PROCESS_NOTIFY_ERROR; } QString result; if (flag & (RSLINK_PROCESS_NOTIFY_SUCCESS | RSLINK_PROCESS_NOTIFY_ERROR)) { result += (links.count() == 1 ? QObject::tr("%1 of %2 RetroShare link processed.") : QObject::tr("%1 of %2 RetroShare links processed.")).arg(countProcessed).arg(links.count()) + "

"; } // file if (flag & RSLINK_PROCESS_NOTIFY_SUCCESS) { if (fileAdded.size()) { processList(fileAdded, QObject::tr("File added"), QObject::tr("Files added"), result); } } if (flag & RSLINK_PROCESS_NOTIFY_ERROR) { if (fileExist.size()) { processList(fileExist, QObject::tr("File exist"), QObject::tr("Files exist"), result); } } // person if (flag & RSLINK_PROCESS_NOTIFY_SUCCESS) { if (personAdded.size()) { processList(personAdded, QObject::tr("Friend added"), QObject::tr("Friends added"), result); } } if (flag & RSLINK_PROCESS_NOTIFY_ERROR) { if (personExist.size()) { processList(personExist, QObject::tr("Friend exist"), QObject::tr("Friends exist"), result); } if (personFailed.size()) { processList(personFailed, QObject::tr("Friend not added"), QObject::tr("Friends not added"), result); } if (personNotFound.size()) { processList(personNotFound, QObject::tr("Friend not found"), QObject::tr("Friends not found"), result); } } // forum if (flag & RSLINK_PROCESS_NOTIFY_ERROR) { if (forumUnknown.size()) { processList(forumUnknown, QObject::tr("Forum not found"), QObject::tr("Forums not found"), result); } if (forumMsgUnknown.size()) { processList(forumMsgUnknown, QObject::tr("Forum message not found"), QObject::tr("Forum messages not found"), result); } } // channel if (flag & RSLINK_PROCESS_NOTIFY_ERROR) { if (channelUnknown.size()) { processList(channelUnknown, QObject::tr("Channel not found"), QObject::tr("Channels not found"), result); } if (channelMsgUnknown.size()) { processList(channelMsgUnknown, QObject::tr("Channel message not found"), QObject::tr("Channel messages not found"), result); } } // message if (flag & RSLINK_PROCESS_NOTIFY_ERROR) { if (messageReceipientNotAccepted.size()) { processList(messageReceipientNotAccepted, QObject::tr("Recipient not accepted"), QObject::tr("Recipients not accepted"), result); } if (messageReceipientUnknown.size()) { processList(messageReceipientUnknown, QObject::tr("Unkown recipient"), QObject::tr("Unkown recipients"), result); } } if (flag & RSLINK_PROCESS_NOTIFY_ERROR) { if (countUnknown) { result += QString("
%1: %2").arg(QObject::tr("Malformed links")).arg(countUnknown); } if (countInvalid) { result += QString("
%1: %2").arg(QObject::tr("Invalid links")).arg(countInvalid); } } if(flag & RSLINK_PROCESS_NOTIFY_BAD_CHARS) result += QString("
%1").arg(QObject::tr("Warning: forbidden characters found in filenames. \nCharacters \",|,/,\\,<,>,*,? will be replaced by '_'.")) ; if (result.isEmpty() == false) { QMessageBox mb(QObject::tr("Result"), "" + result + "", QMessageBox::Information, QMessageBox::Ok, 0, 0); mb.setWindowIcon(QIcon(QString::fromUtf8(":/images/rstray3.png"))); mb.exec(); } return 0; } /*static*/ int RetroShareLink::process(const QStringList &urls, RetroShareLink::enumType type /* = RetroShareLink::TYPE_UNKNOWN*/, uint flag /* = RSLINK_PROCESS_NOTIFY_ALL*/) { QList links; for (QStringList::const_iterator it = urls.begin(); it != urls.end(); it++) { RetroShareLink link(*it); if (link.valid() && (type == RetroShareLink::TYPE_UNKNOWN || link.type() == type)) { links.append(link); } } return process(links, flag); } void RSLinkClipboard::copyLinks(const QList& links) { QString res ; for (int i = 0; i < links.size(); ++i) res += links[i].toString() + "\n" ; QApplication::clipboard()->setText(res) ; } void RSLinkClipboard::pasteLinks(QList &links) { return parseClipboard(links); } void RSLinkClipboard::parseClipboard(QList &links) { // parse clipboard for links. // links.clear(); QString text = QApplication::clipboard()->text() ; std::cerr << "Parsing clipboard:" << text.toStdString() << std::endl ; QRegExp rx(QString("retroshare://(%1)[^\r\n]+").arg(HOST_REGEXP)); int pos = 0; while((pos = rx.indexIn(text, pos)) != -1) { QString url(text.mid(pos, rx.matchedLength())); RetroShareLink link(url); if(link.valid()) { // check that the link is not already in the list: bool already = false ; for (int i = 0; i links; parseClipboard(links); QString res ; for(int i = 0; i < links.size(); ++i) res += links[i].toString() + "\n" ; return res ; } QString RSLinkClipboard::toHtml() { QList links; parseClipboard(links); QString res ; for(int i = 0; i < links.size(); ++i) res += links[i].toHtml() + "
" ; return res ; } QString RSLinkClipboard::toHtmlFull() { QList links; parseClipboard(links); QString res ; for(int i = 0; i < links.size(); ++i) res += links[i].toHtmlFull() + "
" ; return res ; } bool RSLinkClipboard::empty(RetroShareLink::enumType type /* = RetroShareLink::TYPE_UNKNOWN*/) { QList links; parseClipboard(links); if (type == RetroShareLink::TYPE_UNKNOWN) { return links.empty(); } for (QList::iterator link = links.begin(); link != links.end(); link++) { if (link->type() == type) { return false; } } return true; } /*static*/ int RSLinkClipboard::process(RetroShareLink::enumType type /* = RetroShareLink::TYPE_UNKNOWN*/, uint flag /* = RSLINK_PROCESS_NOTIFY_ALL*/) { QList links; pasteLinks(links); QList linksToProcess; for (int i = 0; i < links.size(); i++) { if (links[i].valid() && (type == RetroShareLink::TYPE_UNKNOWN || links[i].type() == type)) { linksToProcess.append(links[i]); } } if (linksToProcess.size() == 0) { return 0; } return RetroShareLink::process(linksToProcess, flag); }