mirror of
https://github.com/qTox/qTox.git
synced 2024-03-22 14:00:36 +08:00
327 lines
15 KiB
C++
327 lines
15 KiB
C++
/*
|
|
Copyright (C) 2013 by Maxim Biro <nurupo.contributions@gmail.com>
|
|
|
|
This file is part of Tox Qt GUI.
|
|
|
|
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 3 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 COPYING file for more details.
|
|
*/
|
|
|
|
#ifndef CORE_HPP
|
|
#define CORE_HPP
|
|
|
|
#include <cstdint>
|
|
#include <QObject>
|
|
#include <QMutex>
|
|
|
|
#include <tox/tox.h>
|
|
|
|
#include "corestructs.h"
|
|
#include "coreav.h"
|
|
#include "coredefines.h"
|
|
|
|
template <typename T> class QList;
|
|
class Camera;
|
|
class QTimer;
|
|
class QString;
|
|
class CString;
|
|
class VideoSource;
|
|
#ifdef QTOX_FILTER_AUDIO
|
|
class AudioFilterer;
|
|
#endif
|
|
|
|
class Core : public QObject
|
|
{
|
|
Q_OBJECT
|
|
public:
|
|
enum PasswordType {ptMain = 0, ptHistory, ptCounter};
|
|
|
|
explicit Core(Camera* cam, QThread* coreThread, QString initialLoadPath);
|
|
static Core* getInstance(); ///< Returns the global widget's Core instance
|
|
~Core();
|
|
|
|
static const QString TOX_EXT;
|
|
static const QString CONFIG_FILE_NAME;
|
|
static QString sanitize(QString name);
|
|
static QList<CString> splitMessage(const QString &message, int maxLen);
|
|
|
|
static QByteArray getSaltFromFile(QString filename);
|
|
|
|
QString getPeerName(const ToxID& id) const;
|
|
|
|
int getGroupNumberPeers(int groupId) const; ///< Return the number of peers in the group chat on success, or -1 on failure
|
|
QString getGroupPeerName(int groupId, int peerId) const; ///< Get the name of a peer of a group
|
|
ToxID getGroupPeerToxID(int groupId, int peerId) const; ///< Get the ToxID of a peer of a group
|
|
QList<QString> getGroupPeerNames(int groupId) const; ///< Get the names of the peers of a group
|
|
QString getFriendAddress(int friendNumber) const; ///< Get the full address if known, or Tox ID of a friend
|
|
QString getFriendUsername(int friendNumber) const; ///< Get the username of a friend
|
|
bool hasFriendWithAddress(const QString &addr) const; ///< Check if we have a friend by address
|
|
bool hasFriendWithPublicKey(const QString &pubkey) const; ///< Check if we have a friend by public key
|
|
int joinGroupchat(int32_t friendNumber, uint8_t type, const uint8_t* pubkey,uint16_t length) const; ///< Accept a groupchat invite
|
|
void quitGroupChat(int groupId) const; ///< Quit a groupchat
|
|
|
|
QString getIDString() const; ///< Get the 12 first characters of our Tox ID
|
|
|
|
QString getUsername() const; ///< Returns our username, or an empty string on failure
|
|
QString getStatusMessage() const; ///< Returns our status message, or an empty string on failure
|
|
ToxID getSelfId() const; ///< Returns our Tox ID
|
|
QPair<QByteArray, QByteArray> getKeypair() const; ///< Returns our public and private keys
|
|
|
|
VideoSource* getVideoSourceFromCall(int callNumber); ///< Get a call's video source
|
|
|
|
bool anyActiveCalls(); ///< true is any calls are currently active (note: a call about to start is not yet active)
|
|
bool isPasswordSet(PasswordType passtype);
|
|
bool isReady(); ///< Most of the API shouldn't be used until Core is ready, call start() first
|
|
|
|
void resetCallSources(); ///< Forces to regenerate each call's audio sources
|
|
|
|
public slots:
|
|
void start(); ///< Initializes the core, must be called before anything else
|
|
void process(); ///< Processes toxcore events and ensure we stay connected, called by its own timer
|
|
void bootstrapDht(); ///< Connects us to the Tox network
|
|
|
|
void saveConfiguration();
|
|
void saveConfiguration(const QString& path);
|
|
void switchConfiguration(const QString& profile); ///< Load a different profile and restart the core
|
|
|
|
void acceptFriendRequest(const QString& userId);
|
|
void requestFriendship(const QString& friendAddress, const QString& message);
|
|
void groupInviteFriend(int friendId, int groupId);
|
|
void createGroup(uint8_t type = TOX_GROUPCHAT_TYPE_AV);
|
|
|
|
void removeFriend(int friendId, bool fake = false);
|
|
void removeGroup(int groupId, bool fake = false);
|
|
|
|
void setStatus(Status status);
|
|
void setUsername(const QString& username);
|
|
void setStatusMessage(const QString& message);
|
|
void setAvatar(uint8_t format, const QByteArray& data);
|
|
|
|
int sendMessage(int friendId, const QString& message);
|
|
void sendGroupMessage(int groupId, const QString& message);
|
|
void sendGroupAction(int groupId, const QString& message);
|
|
void changeGroupTitle(int groupId, const QString& title);
|
|
int sendAction(int friendId, const QString& action);
|
|
void sendTyping(int friendId, bool typing);
|
|
|
|
void sendFile(int32_t friendId, QString Filename, QString FilePath, long long filesize);
|
|
void cancelFileSend(int friendId, int fileNum);
|
|
void cancelFileRecv(int friendId, int fileNum);
|
|
void rejectFileRecvRequest(int friendId, int fileNum);
|
|
void acceptFileRecvRequest(int friendId, int fileNum, QString path);
|
|
void pauseResumeFileSend(int friendId, int fileNum);
|
|
void pauseResumeFileRecv(int friendId, int fileNum);
|
|
|
|
void answerCall(int callId);
|
|
void rejectCall(int callId);
|
|
void hangupCall(int callId);
|
|
void startCall(int friendId, bool video=false);
|
|
void cancelCall(int callId, int friendId);
|
|
|
|
void micMuteToggle(int callId);
|
|
void volMuteToggle(int callId);
|
|
|
|
void setNospam(uint32_t nospam);
|
|
|
|
static void joinGroupCall(int groupId); ///< Starts a call in an existing AV groupchat. Call from the GUI thread.
|
|
static void leaveGroupCall(int groupId); ///< Will not leave the group, just stop the call. Call from the GUI thread.
|
|
static void disableGroupCallMic(int groupId);
|
|
static void disableGroupCallVol(int groupId);
|
|
static void enableGroupCallMic(int groupId);
|
|
static void enableGroupCallVol(int groupId);
|
|
static bool isGroupCallMicEnabled(int groupId);
|
|
static bool isGroupCallVolEnabled(int groupId);
|
|
|
|
void setPassword(QString& password, PasswordType passtype, uint8_t* salt = nullptr);
|
|
void useOtherPassword(PasswordType type);
|
|
void clearPassword(PasswordType passtype);
|
|
QByteArray encryptData(const QByteArray& data, PasswordType passtype);
|
|
QByteArray decryptData(const QByteArray& data, PasswordType passtype);
|
|
|
|
signals:
|
|
void connected();
|
|
void disconnected();
|
|
void blockingClearContacts();
|
|
|
|
void friendRequestReceived(const QString& userId, const QString& message);
|
|
void friendMessageReceived(int friendId, const QString& message, bool isAction);
|
|
|
|
void friendAdded(int friendId, const QString& userId);
|
|
|
|
void friendStatusChanged(int friendId, Status status);
|
|
void friendStatusMessageChanged(int friendId, const QString& message);
|
|
void friendUsernameChanged(int friendId, const QString& username);
|
|
void friendTypingChanged(int friendId, bool isTyping);
|
|
void friendAvatarChanged(int friendId, const QPixmap& pic);
|
|
void friendAvatarRemoved(int friendId);
|
|
|
|
void friendRemoved(int friendId);
|
|
|
|
void friendLastSeenChanged(int friendId, const QDateTime& dateTime);
|
|
|
|
void emptyGroupCreated(int groupnumber);
|
|
void groupInviteReceived(int friendnumber, uint8_t type, QByteArray publicKey);
|
|
void groupMessageReceived(int groupnumber, int peernumber, const QString& message, bool isAction);
|
|
void groupNamelistChanged(int groupnumber, int peernumber, uint8_t change);
|
|
void groupTitleChanged(int groupnumber, const QString& author, const QString& title);
|
|
void groupPeerAudioPlaying(int groupnumber, int peernumber);
|
|
|
|
void usernameSet(const QString& username);
|
|
void statusMessageSet(const QString& message);
|
|
void statusSet(Status status);
|
|
void idSet(const QString& id);
|
|
void selfAvatarChanged(const QPixmap& pic);
|
|
|
|
void messageSentResult(int friendId, const QString& message, int messageId);
|
|
void groupSentResult(int groupId, const QString& message, int result);
|
|
void actionSentResult(int friendId, const QString& action, int success);
|
|
|
|
void receiptRecieved(int friedId, int receipt);
|
|
|
|
void failedToAddFriend(const QString& userId, const QString& errorInfo = QString());
|
|
void failedToRemoveFriend(int friendId);
|
|
void failedToSetUsername(const QString& username);
|
|
void failedToSetStatusMessage(const QString& message);
|
|
void failedToSetStatus(Status status);
|
|
void failedToSetTyping(bool typing);
|
|
|
|
void failedToStart();
|
|
void badProxy();
|
|
|
|
void fileSendStarted(ToxFile file);
|
|
void fileReceiveRequested(ToxFile file);
|
|
void fileTransferAccepted(ToxFile file);
|
|
void fileTransferCancelled(ToxFile file);
|
|
void fileTransferFinished(ToxFile file);
|
|
void fileUploadFinished(const QString& path);
|
|
void fileDownloadFinished(const QString& path);
|
|
void fileTransferPaused(ToxFile file);
|
|
void fileTransferInfo(ToxFile file);
|
|
void fileTransferRemotePausedUnpaused(ToxFile file, bool paused);
|
|
void fileTransferBrokenUnbroken(ToxFile file, bool broken);
|
|
|
|
void fileSendFailed(int FriendId, const QString& fname);
|
|
|
|
void avInvite(int friendId, int callIndex, bool video);
|
|
void avStart(int friendId, int callIndex, bool video);
|
|
void avCancel(int friendId, int callIndex);
|
|
void avEnd(int friendId, int callIndex);
|
|
void avRinging(int friendId, int callIndex, bool video);
|
|
void avStarting(int friendId, int callIndex, bool video);
|
|
void avEnding(int friendId, int callIndex);
|
|
void avRequestTimeout(int friendId, int callIndex);
|
|
void avPeerTimeout(int friendId, int callIndex);
|
|
void avMediaChange(int friendId, int callIndex, bool videoEnabled);
|
|
void avCallFailed(int friendId);
|
|
void avRejected(int friendId, int callIndex);
|
|
|
|
void videoFrameReceived(vpx_image* frame);
|
|
|
|
private:
|
|
static void onFriendRequest(Tox* tox, const uint8_t* cUserId, const uint8_t* cMessage, uint16_t cMessageSize, void* core);
|
|
static void onFriendMessage(Tox* tox, int friendId, const uint8_t* cMessage, uint16_t cMessageSize, void* core);
|
|
static void onFriendNameChange(Tox* tox, int friendId, const uint8_t* cName, uint16_t cNameSize, void* core);
|
|
static void onFriendTypingChange(Tox* tox, int friendId, uint8_t isTyping, void* core);
|
|
static void onStatusMessageChanged(Tox* tox, int friendId, const uint8_t* cMessage, uint16_t cMessageSize, void* core);
|
|
static void onUserStatusChanged(Tox* tox, int friendId, uint8_t userstatus, void* core);
|
|
static void onConnectionStatusChanged(Tox* tox, int friendId, uint8_t status, void* core);
|
|
static void onAction(Tox* tox, int friendId, const uint8_t* cMessage, uint16_t cMessageSize, void* core);
|
|
static void onGroupAction(Tox* tox, int groupnumber, int peernumber, const uint8_t * action, uint16_t length, void* core);
|
|
static void onGroupInvite(Tox *tox, int friendnumber, uint8_t type, const uint8_t *data, uint16_t length,void *userdata);
|
|
static void onGroupMessage(Tox *tox, int groupnumber, int friendgroupnumber, const uint8_t * message, uint16_t length, void *userdata);
|
|
static void onGroupNamelistChange(Tox *tox, int groupnumber, int peernumber, uint8_t change, void *userdata);
|
|
static void onGroupTitleChange(Tox*, int groupnumber, int peernumber, const uint8_t* title, uint8_t len, void* _core);
|
|
static void onFileSendRequestCallback(Tox *tox, int32_t friendnumber, uint8_t filenumber, uint64_t filesize,
|
|
const uint8_t *filename, uint16_t filename_length, void *userdata);
|
|
static void onFileControlCallback(Tox *tox, int32_t friendnumber, uint8_t receive_send, uint8_t filenumber,
|
|
uint8_t control_type, const uint8_t *data, uint16_t length, void *core);
|
|
static void onFileDataCallback(Tox *tox, int32_t friendnumber, uint8_t filenumber, const uint8_t *data, uint16_t length, void *userdata);
|
|
static void onAvatarInfoCallback(Tox* tox, int32_t friendnumber, uint8_t format, uint8_t *hash, void *userdata);
|
|
static void onAvatarDataCallback(Tox* tox, int32_t friendnumber, uint8_t format, uint8_t *hash, uint8_t *data, uint32_t datalen, void *userdata);
|
|
static void onReadReceiptCallback(Tox *tox, int32_t friendnumber, uint32_t receipt, void *core);
|
|
|
|
static void onAvInvite(void* toxav, int32_t call_index, void* core);
|
|
static void onAvStart(void* toxav, int32_t call_index, void* core);
|
|
static void onAvCancel(void* toxav, int32_t call_index, void* core);
|
|
static void onAvReject(void* toxav, int32_t call_index, void* core);
|
|
static void onAvEnd(void* toxav, int32_t call_index, void* core);
|
|
static void onAvRinging(void* toxav, int32_t call_index, void* core);
|
|
static void onAvRequestTimeout(void* toxav, int32_t call_index, void* core);
|
|
static void onAvPeerTimeout(void* toxav, int32_t call_index, void* core);
|
|
static void onAvMediaChange(void *toxav, int32_t call_index, void* core);
|
|
|
|
static void sendGroupCallAudio(int groupId, ToxAv* toxav);
|
|
|
|
static void prepareCall(int friendId, int callId, ToxAv *toxav, bool videoEnabled);
|
|
static void cleanupCall(int callId);
|
|
static void playCallAudio(void *toxav, int32_t callId, const int16_t *data, uint16_t samples, void *user_data); // Callback
|
|
static void sendCallAudio(int callId, ToxAv* toxav);
|
|
static void playAudioBuffer(ALuint alSource, const int16_t *data, int samples, unsigned channels, int sampleRate);
|
|
static void playCallVideo(void *toxav, int32_t callId, const vpx_image_t* img, void *user_data);
|
|
void sendCallVideo(int callId);
|
|
|
|
bool checkConnection();
|
|
|
|
bool loadConfiguration(QString path); // Returns false for a critical error, true otherwise
|
|
bool loadEncryptedSave(QByteArray& data);
|
|
void checkEncryptedHistory();
|
|
void make_tox();
|
|
void loadFriends();
|
|
|
|
static void sendAllFileData(Core* core, ToxFile* file);
|
|
static void removeFileFromQueue(bool sendQueue, int friendId, int fileId);
|
|
|
|
void checkLastOnline(int friendId);
|
|
|
|
void deadifyTox();
|
|
|
|
private slots:
|
|
void onFileTransferFinished(ToxFile file);
|
|
|
|
private:
|
|
Tox* tox;
|
|
ToxAv* toxav;
|
|
QTimer *toxTimer, *fileTimer; //, *saveTimer;
|
|
Camera* camera;
|
|
QString loadPath; // meaningless after start() is called
|
|
QList<DhtServer> dhtServerList;
|
|
int dhtServerId;
|
|
static QList<ToxFile> fileSendQueue, fileRecvQueue;
|
|
static ToxCall calls[TOXAV_MAX_CALLS];
|
|
#ifdef QTOX_FILTER_AUDIO
|
|
static AudioFilterer * filterer[TOXAV_MAX_CALLS];
|
|
#endif
|
|
static QHash<int, ToxGroupCall> groupCalls; // Maps group IDs to ToxGroupCalls
|
|
QMutex fileSendMutex, messageSendMutex;
|
|
bool ready;
|
|
|
|
uint8_t* pwsaltedkeys[PasswordType::ptCounter] = {nullptr}; // use the pw's hash as the "pw"
|
|
|
|
// Hack for reloading current profile if switching to an encrypted one fails.
|
|
// Testing the passwords before killing the current profile is perfectly doable,
|
|
// however it would require major refactoring;
|
|
// the Core class as a whole also requires major refactoring (especially to support multiple IDs at once),
|
|
// so I'm punting on this until then, when it would get fixed anyways
|
|
uint8_t* backupkeys[PasswordType::ptCounter] = {nullptr};
|
|
QString* backupProfile = nullptr;
|
|
void saveCurrentInformation();
|
|
QString loadOldInformation();
|
|
|
|
static const int videobufsize;
|
|
static uint8_t* videobuf;
|
|
|
|
static QThread *coreThread;
|
|
|
|
friend class Audio; ///< Audio can access our calls directly to reduce latency
|
|
};
|
|
|
|
#endif // CORE_HPP
|
|
|