1
0
mirror of https://github.com/qTox/qTox.git synced 2024-03-22 14:00:36 +08:00
qTox/core.h

288 lines
10 KiB
C
Raw Normal View History

2014-06-25 04:11:11 +08:00
/*
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 "audiobuffer.h"
2014-06-25 04:11:11 +08:00
#include <tox/tox.h>
#include <tox/toxav.h>
2014-06-25 04:11:11 +08:00
2014-06-26 04:43:28 +08:00
#include <cstdint>
2014-06-25 04:11:11 +08:00
#include <QDateTime>
#include <QObject>
#include <QTimer>
#include <QString>
#include <QList>
2014-06-26 04:43:28 +08:00
#include <QByteArray>
#include <QFuture>
#include <QBuffer>
#include <QAudioOutput>
2014-06-28 03:59:25 +08:00
#include <QAudioInput>
#define TOXAV_MAX_CALLS 16
#define GROUPCHAT_MAX_SIZE 32
#define TOX_SAVE_INTERVAL 30*1000
#define TOX_FILE_INTERVAL 20
#define TOX_BOOTSTRAP_INTERVAL 10*1000
#define TOXAV_RINGING_TIME 15
2014-06-25 04:11:11 +08:00
2014-06-30 05:38:48 +08:00
// TODO: Put that in the settings
#define TOXAV_MAX_VIDEO_WIDTH 1600
#define TOXAV_MAX_VIDEO_HEIGHT 1200
2014-06-30 05:38:48 +08:00
#define TOXAV_VIDEO_WIDTH 640
#define TOXAV_VIDEO_HEIGHT 480
2014-06-30 20:49:42 +08:00
class Camera;
2014-07-01 06:36:48 +08:00
enum class Status : int {Online = 0, Away, Busy, Offline};
2014-06-25 04:11:11 +08:00
struct DhtServer
{
QString name;
QString userId;
QString address;
int port;
};
2014-06-26 04:43:28 +08:00
struct ToxFile
{
enum FileStatus
{
STOPPED,
PAUSED,
TRANSMITTING
};
2014-06-26 06:30:24 +08:00
enum FileDirection : bool
{
SENDING,
RECEIVING
};
ToxFile()=default;
ToxFile(int FileNum, int FriendId, QByteArray FileData, long long Filesize, QByteArray FileName, FileDirection Direction)
: fileNum(FileNum), friendId(FriendId), fileData{FileData}, fileName{FileName},
bytesSent{0}, filesize(Filesize), status{STOPPED}, direction{Direction} {}
2014-06-26 04:43:28 +08:00
int fileNum;
int friendId;
QByteArray fileData;
QByteArray fileName;
long long bytesSent;
long long filesize;
2014-06-26 04:43:28 +08:00
FileStatus status;
2014-06-26 06:30:24 +08:00
FileDirection direction;
QFuture<void> sendFuture;
2014-06-26 04:43:28 +08:00
};
struct ToxCall
{
public:
AudioBuffer audioBuffer;
QAudioOutput* audioOutput;
2014-06-28 03:59:25 +08:00
QAudioInput* audioInput;
QIODevice* audioInputDevice;
ToxAvCodecSettings codecSettings;
QTimer *playAudioTimer, *sendAudioTimer, *playVideoTimer, *sendVideoTimer;
int callId;
int friendId;
2014-06-30 05:38:48 +08:00
bool videoEnabled;
bool active;
};
2014-06-25 04:11:11 +08:00
class Core : public QObject
{
Q_OBJECT
public:
explicit Core(Camera* cam, QThread* coreThread);
2014-06-25 04:11:11 +08:00
~Core();
int getGroupNumberPeers(int groupId) const;
QString getGroupPeerName(int groupId, int peerId) const;
QList<QString> getGroupPeerNames(int groupId) const;
2014-07-03 15:22:12 +08:00
int joinGroupchat(int32_t friendnumber, const uint8_t* friend_group_public_key) const;
2014-06-25 04:11:11 +08:00
void quitGroupChat(int groupId) const;
2014-06-30 05:38:48 +08:00
void dispatchVideoFrame(vpx_image img) const;
2014-06-25 04:11:11 +08:00
2014-07-04 01:38:30 +08:00
void saveConfiguration();
2014-06-25 04:11:11 +08:00
public slots:
void start();
void process();
void bootstrapDht();
2014-06-25 04:11:11 +08:00
void acceptFriendRequest(const QString& userId);
void requestFriendship(const QString& friendAddress, const QString& message);
void groupInviteFriend(int friendId, int groupId);
2014-06-30 05:38:48 +08:00
void createGroup();
2014-06-25 04:11:11 +08:00
void removeFriend(int friendId);
void removeGroup(int groupId);
2014-07-01 06:36:48 +08:00
void setStatus(Status status);
void setUsername(const QString& username);
void setStatusMessage(const QString& message);
2014-06-25 04:11:11 +08:00
void sendMessage(int friendId, const QString& message);
2014-06-26 04:43:28 +08:00
void sendGroupMessage(int groupId, const QString& message);
2014-06-25 04:11:11 +08:00
void sendAction(int friendId, const QString& action);
void sendTyping(int friendId, bool typing);
2014-06-26 04:43:28 +08:00
void sendFile(int32_t friendId, QString Filename, QByteArray data);
void cancelFileSend(int friendId, int fileNum);
void cancelFileRecv(int friendId, int fileNum);
void rejectFileRecvRequest(int friendId, int fileNum);
void acceptFileRecvRequest(int friendId, int fileNum);
void pauseResumeFileSend(int friendId, int fileNum);
void pauseResumeFileRecv(int friendId, int fileNum);
2014-06-25 04:11:11 +08:00
void answerCall(int callId);
void hangupCall(int callId);
2014-06-30 05:38:48 +08:00
void startCall(int friendId, bool video=false);
2014-06-27 09:06:56 +08:00
void cancelCall(int callId, int friendId);
2014-06-25 04:11:11 +08:00
signals:
void connected();
void disconnected();
void friendRequestReceived(const QString& userId, const QString& message);
void friendMessageReceived(int friendId, const QString& message);
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 friendStatusMessageLoaded(int friendId, const QString& message);
void friendUsernameLoaded(int friendId, const QString& username);
void friendAddressGenerated(const QString& friendAddress);
void friendRemoved(int friendId);
void friendLastSeenChanged(int friendId, const QDateTime& dateTime);
2014-06-30 05:38:48 +08:00
void emptyGroupCreated(int groupnumber);
2014-07-03 15:22:12 +08:00
void groupInviteReceived(int friendnumber, const uint8_t *group_public_key);
2014-06-25 04:11:11 +08:00
void groupMessageReceived(int groupnumber, int friendgroupnumber, const QString& message);
void groupNamelistChanged(int groupnumber, int peernumber, uint8_t change);
void usernameSet(const QString& username);
void statusMessageSet(const QString& message);
void statusSet(Status status);
void messageSentResult(int friendId, const QString& message, int messageId);
void actionSentResult(int friendId, const QString& action, int success);
void failedToAddFriend(const QString& userId);
void failedToRemoveFriend(int friendId);
void failedToSetUsername(const QString& username);
void failedToSetStatusMessage(const QString& message);
void failedToSetStatus(Status status);
void failedToSetTyping(bool typing);
void actionReceived(int friendId, const QString& acionMessage);
void failedToStart();
void fileSendStarted(ToxFile file);
void fileReceiveRequested(ToxFile file);
void fileTransferAccepted(ToxFile file);
void fileTransferCancelled(int FriendId, int FileNum, ToxFile::FileDirection direction);
void fileTransferFinished(ToxFile file);
void fileTransferPaused(int FriendId, int FileNum, ToxFile::FileDirection direction);
void fileTransferInfo(int FriendId, int FileNum, int Filesize, int BytesSent, ToxFile::FileDirection direction);
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);
2014-06-27 09:06:56 +08:00
void avRequestTimeout(int friendId, int callIndex);
2014-06-28 03:59:25 +08:00
void avPeerTimeout(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);
2014-07-03 15:22:12 +08:00
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);
2014-07-03 15:22:12 +08:00
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);
2014-07-03 15:22:12 +08:00
static void onAction(Tox* tox, int friendId, const uint8_t* cMessage, uint16_t cMessageSize, void* core);
static void onGroupInvite(Tox *tox, int friendnumber, const uint8_t *group_public_key, 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 onFileSendRequestCallback(Tox *tox, int32_t friendnumber, uint8_t filenumber, uint64_t filesize,
2014-07-03 15:22:12 +08:00
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,
2014-07-03 15:22:12 +08:00
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);
2014-06-27 07:17:10 +08:00
static void onAvInvite(int32_t call_index, void* toxav);
static void onAvStart(int32_t call_index, void* toxav);
static void onAvCancel(int32_t call_index, void* toxav);
static void onAvReject(int32_t call_index, void* toxav);
static void onAvEnd(int32_t call_index, void* toxav);
static void onAvRinging(int32_t call_index, void* toxav);
static void onAvStarting(int32_t call_index, void* toxav);
static void onAvEnding(int32_t call_index, void* toxav);
static void onAvError(int32_t call_index, void* toxav);
static void onAvRequestTimeout(int32_t call_index, void* toxav);
static void onAvPeerTimeout(int32_t call_index, void* toxav);
2014-06-30 05:38:48 +08:00
static void prepareCall(int friendId, int callId, ToxAv *toxav, bool videoEnabled);
static void cleanupCall(int callId);
static void playCallAudio(int callId, ToxAv* toxav);
static void sendCallAudio(int callId, ToxAv* toxav); // Blocking, start in a thread
void playCallVideo(int callId);
2014-06-30 20:49:42 +08:00
void sendCallVideo(int callId);
void checkConnection();
void onBootstrapTimer();
void loadConfiguration();
void loadFriends();
static void sendAllFileData(Core* core, ToxFile* file);
static void removeFileFromQueue(bool sendQueue, int friendId, int fileId);
void checkLastOnline(int friendId);
private:
Tox* tox;
ToxAv* toxav;
2014-07-04 22:41:29 +08:00
QTimer *toxTimer, *fileTimer, *bootstrapTimer; //, *saveTimer;
2014-06-30 20:49:42 +08:00
Camera* camera;
QList<DhtServer> dhtServerList;
int dhtServerId;
static QList<ToxFile> fileSendQueue, fileRecvQueue;
static ToxCall calls[TOXAV_MAX_CALLS];
static const QString CONFIG_FILE_NAME;
2014-06-25 04:11:11 +08:00
};
#endif // CORE_HPP