diff options
| author | Anton <anton@picapica> | 2017-12-01 22:16:24 +0400 |
|---|---|---|
| committer | Anton <anton@picapica> | 2017-12-01 22:16:24 +0400 |
| commit | 0f726c30f5f11990d325bc5e55015c42c80cd9d2 (patch) | |
| tree | f8c9b83cc440dd3a2f43285dc35199435f6e2701 /pica-client/skynet.h | |
| parent | ac041927bc0c82e33acaa9e15fd46ecca0b77172 (diff) | |
| download | pica-pica-0f726c30f5f11990d325bc5e55015c42c80cd9d2.tar.gz pica-pica-0f726c30f5f11990d325bc5e55015c42c80cd9d2.zip | |
fixed code style on all source files (*.c *.cpp *.h) using astyle --style=allman --lineend=linux --indent=tab --pad-oper
Diffstat (limited to 'pica-client/skynet.h')
| -rw-r--r-- | pica-client/skynet.h | 189 |
1 files changed, 96 insertions, 93 deletions
diff --git a/pica-client/skynet.h b/pica-client/skynet.h index bea1a21..15c4359 100644 --- a/pica-client/skynet.h +++ b/pica-client/skynet.h @@ -13,125 +13,128 @@ class SkyNet : public QObject { - Q_OBJECT + Q_OBJECT public: - SkyNet(); - void Join(Accounts::AccountRecord &accrec); - bool isSelfAware(); - void Exit(); - - void SendMessage(QByteArray to, QString msg); - void SendFile(QByteArray to, QString filepath); - void AcceptFile(QByteArray from, QString filepath); - void DenyFile(QByteArray from); - void PauseFile(QByteArray peer_id, bool pause_sending); - void ResumeFile(QByteArray peer_id, bool resume_sending); - void CancelFile(QByteArray peer_id, bool cancel_sending); - - Accounts::AccountRecord CurrentAccount() {return skynet_account;}; + SkyNet(); + void Join(Accounts::AccountRecord &accrec); + bool isSelfAware(); + void Exit(); + + void SendMessage(QByteArray to, QString msg); + void SendFile(QByteArray to, QString filepath); + void AcceptFile(QByteArray from, QString filepath); + void DenyFile(QByteArray from); + void PauseFile(QByteArray peer_id, bool pause_sending); + void ResumeFile(QByteArray peer_id, bool resume_sending); + void CancelFile(QByteArray peer_id, bool cancel_sending); + + Accounts::AccountRecord CurrentAccount() + { + return skynet_account; + }; signals: - void MessageReceived(QByteArray from, QString msg); - void UnableToDeliver(QByteArray to, QString msg); - void Delivered(QByteArray to); - void BecameSelfAware(); - void LostSelfAwareness(); - void PeerCertificateReceived(QByteArray peer_id, QString cert_pem, bool *verified); - void CertificateForged(QByteArray peer_id, QString received_cert, QString stored_cert); + void MessageReceived(QByteArray from, QString msg); + void UnableToDeliver(QByteArray to, QString msg); + void Delivered(QByteArray to); + void BecameSelfAware(); + void LostSelfAwareness(); + void PeerCertificateReceived(QByteArray peer_id, QString cert_pem, bool *verified); + void CertificateForged(QByteArray peer_id, QString received_cert, QString stored_cert); void StatusMsg(QString msg, bool is_critical); - void ContactsUpdated(); - void IncomingFileRequestReceived(QByteArray peer_id, quint64 file_size, QString filename); - void OutgoingFileRequestAccepted(QByteArray peer_id); - void OutgoingFileRequestDenied(QByteArray peer_id); - void FileProgress(QByteArray peer_id, quint64 bytes_sent, quint64 bytes_received); - void IncomingFilePaused(QByteArray peer_id); - void IncomingFileCancelled(QByteArray peer_id); - void IncomingFileIoError(QByteArray peer_id); - void IncomingFileResumed(QByteArray peer_id); - void OutgoingFilePaused(QByteArray peer_id); - void OutgoingFileCancelled(QByteArray peer_id); - void OutgoingFileIoError(QByteArray peer_id); - void OutgoingFileResumed(QByteArray peer_id); - void OutgoingFileFinished(QByteArray peer_id); - void IncomingFileFinished(QByteArray peer_id); - - void c2cClosed(QByteArray peer_id); + void ContactsUpdated(); + void IncomingFileRequestReceived(QByteArray peer_id, quint64 file_size, QString filename); + void OutgoingFileRequestAccepted(QByteArray peer_id); + void OutgoingFileRequestDenied(QByteArray peer_id); + void FileProgress(QByteArray peer_id, quint64 bytes_sent, quint64 bytes_received); + void IncomingFilePaused(QByteArray peer_id); + void IncomingFileCancelled(QByteArray peer_id); + void IncomingFileIoError(QByteArray peer_id); + void IncomingFileResumed(QByteArray peer_id); + void OutgoingFilePaused(QByteArray peer_id); + void OutgoingFileCancelled(QByteArray peer_id); + void OutgoingFileIoError(QByteArray peer_id); + void OutgoingFileResumed(QByteArray peer_id); + void OutgoingFileFinished(QByteArray peer_id); + void IncomingFileFinished(QByteArray peer_id); + + void c2cClosed(QByteArray peer_id); private: - Nodes nodes; + Nodes nodes; QList<QPair<struct PICA_c2n *, Nodes::NodeRecord> > connecting_nodes; - bool self_aware; - QString status; + bool self_aware; + QString status; struct PICA_c2n *active_nodelink; - struct PICA_acc *acc; + struct PICA_acc *acc; struct PICA_listener *listener; - Accounts::AccountRecord skynet_account; + Accounts::AccountRecord skynet_account; - QMap<QByteArray, QList<QString> > msgqueues; - QMap<QByteArray, QList<QString> > sndfilequeues; + QMap<QByteArray, QList<QString> > msgqueues; + QMap<QByteArray, QList<QString> > sndfilequeues; int retry_timer_id; int event_loop_timer_id; - void timerEvent(QTimerEvent * e); + void timerEvent(QTimerEvent * e); - void flush_queues(QByteArray to); - struct PICA_c2c *find_active_chan(QByteArray peer_id); - QList<QByteArray> filter_existing_chans(QList<QByteArray> peer_ids); - bool open_account(); + void flush_queues(QByteArray to); + struct PICA_c2c *find_active_chan(QByteArray peer_id); + QList<QByteArray> filter_existing_chans(QList<QByteArray> peer_ids); + bool open_account(); - void emit_MessageReceived(QByteArray from, QString msg); - void emit_UnableToDeliver(QByteArray to, QString msg); - void emit_Delivered(QByteArray to); - void emit_PeerCertificateReceived(QByteArray peer_id, QString cert_pem, bool *verified); - void emit_IncomingFileRequestReceived(QByteArray peer_id, quint64 file_size, QString filename); - void emit_OutgoingFileRequestAccepted(QByteArray peer_id); - void emit_OutgoingFileRequestDenied(QByteArray peer_id); - void emit_FileProgress(QByteArray peer_id, quint64 bytes_sent, quint64 bytes_received); + void emit_MessageReceived(QByteArray from, QString msg); + void emit_UnableToDeliver(QByteArray to, QString msg); + void emit_Delivered(QByteArray to); + void emit_PeerCertificateReceived(QByteArray peer_id, QString cert_pem, bool *verified); + void emit_IncomingFileRequestReceived(QByteArray peer_id, quint64 file_size, QString filename); + void emit_OutgoingFileRequestAccepted(QByteArray peer_id); + void emit_OutgoingFileRequestDenied(QByteArray peer_id); + void emit_FileProgress(QByteArray peer_id, quint64 bytes_sent, quint64 bytes_received); - void emit_IncomingFilePaused(QByteArray peer_id); - void emit_IncomingFileCancelled(QByteArray peer_id); - void emit_IncomingFileIoError(QByteArray peer_id); - void emit_IncomingFileResumed(QByteArray peer_id); - void emit_OutgoingFilePaused(QByteArray peer_id); - void emit_OutgoingFileCancelled(QByteArray peer_id); - void emit_OutgoingFileIoError(QByteArray peer_id); - void emit_OutgoingFileResumed(QByteArray peer_id); + void emit_IncomingFilePaused(QByteArray peer_id); + void emit_IncomingFileCancelled(QByteArray peer_id); + void emit_IncomingFileIoError(QByteArray peer_id); + void emit_IncomingFileResumed(QByteArray peer_id); + void emit_OutgoingFilePaused(QByteArray peer_id); + void emit_OutgoingFileCancelled(QByteArray peer_id); + void emit_OutgoingFileIoError(QByteArray peer_id); + void emit_OutgoingFileResumed(QByteArray peer_id); - void emit_OutgoingFileFinished(QByteArray peer_id); - void emit_IncomingFileFinished(QByteArray peer_id); + void emit_OutgoingFileFinished(QByteArray peer_id); + void emit_IncomingFileFinished(QByteArray peer_id); - void emit_c2cClosed(QByteArray peer_id); + void emit_c2cClosed(QByteArray peer_id); - //получение сообщения. - static void newmsg_cb(const unsigned char *peer_id,const char* msgbuf,unsigned int nb,int type); - //получение подтверждения о доставке сообщения - static void msgok_cb(const unsigned char *peer_id); - //создание канала с собеседником - static void c2c_established_cb(const unsigned char *peer_id); - //создать канал не удалось - static void c2c_failed(const unsigned char *peer_id); - //входящий запрос на создание канала от пользователя с номером caller_id - static int accept_cb(const unsigned char *caller_id); - //запрошенный пользователь не найден, в оффлайне или отказался от общения - static void notfound_cb(const unsigned char *callee_id); + //получение сообщения. + static void newmsg_cb(const unsigned char *peer_id, const char* msgbuf, unsigned int nb, int type); + //получение подтверждения о доставке сообщения + static void msgok_cb(const unsigned char *peer_id); + //создание канала с собеседником + static void c2c_established_cb(const unsigned char *peer_id); + //создать канал не удалось + static void c2c_failed(const unsigned char *peer_id); + //входящий запрос на создание канала от пользователя с номером caller_id + static int accept_cb(const unsigned char *caller_id); + //запрошенный пользователь не найден, в оффлайне или отказался от общения + static void notfound_cb(const unsigned char *callee_id); - static void c2c_closed_cb(const unsigned char *peer_id, int reason); + static void c2c_closed_cb(const unsigned char *peer_id, int reason); - static void nodelist_cb(int type, void *addr_bin, const char *addr_str, unsigned int port); + static void nodelist_cb(int type, void *addr_bin, const char *addr_str, unsigned int port); - static int peer_cert_verify_cb(const unsigned char *peer_id, const char *cert_pem, unsigned int nb); + static int peer_cert_verify_cb(const unsigned char *peer_id, const char *cert_pem, unsigned int nb); - static int accept_file_cb(const unsigned char *peer_id, uint64_t file_size, const char *filename, unsigned int filename_size); + static int accept_file_cb(const unsigned char *peer_id, uint64_t file_size, const char *filename, unsigned int filename_size); - static void accepted_file_cb(const unsigned char *peer_id); + static void accepted_file_cb(const unsigned char *peer_id); - static void denied_file_cb(const unsigned char *peer_id); + static void denied_file_cb(const unsigned char *peer_id); - static void file_progress(const unsigned char *peer_id, uint64_t sent, uint64_t received); + static void file_progress(const unsigned char *peer_id, uint64_t sent, uint64_t received); - static void file_control(const unsigned char *peer_id, unsigned int sender_cmd, unsigned int receiver_cmd); + static void file_control(const unsigned char *peer_id, unsigned int sender_cmd, unsigned int receiver_cmd); - static void file_finished(const unsigned char *peer_id, int sending); + static void file_finished(const unsigned char *peer_id, int sending); static void c2n_established_cb(struct PICA_c2n *c2n); @@ -146,8 +149,8 @@ private slots: void nodelink_closed(PICA_c2n *c2n, int error); void nodelink_failed(PICA_c2n *c2n, int error); - void node_status_changed(Nodes::NodeRecord nr,bool alive); - void verify_peer_cert(QByteArray peer_id, QString cert_pem, bool *verified); + void node_status_changed(Nodes::NodeRecord nr, bool alive); + void verify_peer_cert(QByteArray peer_id, QString cert_pem, bool *verified); }; |
