2013-07-07 10:28:15 +08:00
|
|
|
/* Messenger.h
|
2013-07-26 09:45:56 +08:00
|
|
|
*
|
|
|
|
* An implementation of a simple text chat only messenger on the tox network core.
|
|
|
|
*
|
|
|
|
* NOTE: All the text in the messages must be encoded using UTF-8
|
2013-07-27 20:43:36 +08:00
|
|
|
*
|
2013-07-26 09:45:56 +08:00
|
|
|
* Copyright (C) 2013 Tox project All Rights Reserved.
|
|
|
|
*
|
|
|
|
* This file is part of Tox.
|
|
|
|
*
|
|
|
|
* Tox 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.
|
|
|
|
*
|
|
|
|
* Tox 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 Tox. If not, see <http://www.gnu.org/licenses/>.
|
2013-07-27 20:43:36 +08:00
|
|
|
*
|
|
|
|
*/
|
2013-07-26 16:02:17 +08:00
|
|
|
|
2013-07-19 01:56:50 +08:00
|
|
|
#ifndef MESSENGER_H
|
|
|
|
#define MESSENGER_H
|
2013-07-07 10:28:15 +08:00
|
|
|
|
|
|
|
#include "net_crypto.h"
|
|
|
|
#include "DHT.h"
|
2013-07-23 02:52:42 +08:00
|
|
|
#include "friend_requests.h"
|
2013-07-26 22:24:56 +08:00
|
|
|
#include "LAN_discovery.h"
|
2013-07-07 10:28:15 +08:00
|
|
|
|
2013-07-23 06:06:24 +08:00
|
|
|
#ifdef __cplusplus
|
|
|
|
extern "C" {
|
|
|
|
#endif
|
|
|
|
|
2013-07-19 01:56:50 +08:00
|
|
|
#define MAX_NAME_LENGTH 128
|
2013-08-08 05:01:31 +08:00
|
|
|
#define MAX_STATUSMESSAGE_LENGTH 128
|
2013-07-19 04:58:03 +08:00
|
|
|
|
|
|
|
#define PACKET_ID_NICKNAME 48
|
2013-08-08 05:01:31 +08:00
|
|
|
#define PACKET_ID_STATUSMESSAGE 49
|
|
|
|
#define PACKET_ID_USERSTATUS 50
|
2013-08-08 00:53:52 +08:00
|
|
|
#define PACKET_ID_RECEIPT 65
|
2013-07-19 04:58:03 +08:00
|
|
|
#define PACKET_ID_MESSAGE 64
|
2013-08-09 03:00:30 +08:00
|
|
|
#define PACKET_ID_ACTION 63
|
2013-07-19 04:58:03 +08:00
|
|
|
|
2013-08-03 00:33:11 +08:00
|
|
|
/* status definitions */
|
|
|
|
#define FRIEND_ONLINE 4
|
|
|
|
#define FRIEND_CONFIRMED 3
|
|
|
|
#define FRIEND_REQUESTED 2
|
|
|
|
#define FRIEND_ADDED 1
|
|
|
|
#define NOFRIEND 0
|
|
|
|
|
|
|
|
/* errors for m_addfriend
|
|
|
|
* FAERR - Friend Add Error */
|
|
|
|
#define FAERR_TOOLONG -1
|
|
|
|
#define FAERR_NOMESSAGE -2
|
|
|
|
#define FAERR_OWNKEY -3
|
|
|
|
#define FAERR_ALREADYSENT -4
|
2013-08-03 00:35:34 +08:00
|
|
|
#define FAERR_UNKNOWN -5
|
2013-08-03 00:33:11 +08:00
|
|
|
|
2013-08-08 05:01:31 +08:00
|
|
|
/* don't assume MAX_STATUSMESSAGE_LENGTH will stay at 128, it may be increased
|
2013-07-27 20:48:50 +08:00
|
|
|
to an absurdly large number later */
|
|
|
|
|
2013-08-08 05:01:31 +08:00
|
|
|
/* USERSTATUS
|
|
|
|
* Represents userstatuses someone can have. */
|
2013-08-06 03:30:07 +08:00
|
|
|
|
|
|
|
typedef enum {
|
2013-08-08 05:01:31 +08:00
|
|
|
USERSTATUS_NONE,
|
|
|
|
USERSTATUS_AWAY,
|
|
|
|
USERSTATUS_BUSY,
|
|
|
|
USERSTATUS_INVALID
|
|
|
|
} USERSTATUS;
|
2013-08-06 03:30:07 +08:00
|
|
|
|
2013-08-11 11:24:11 +08:00
|
|
|
typedef struct {
|
|
|
|
uint8_t client_id[CLIENT_ID_SIZE];
|
|
|
|
int crypt_connection_id;
|
|
|
|
uint64_t friend_request_id; /* id of the friend request corresponding to the current friend request to the current friend. */
|
|
|
|
uint8_t status; /* 0 if no friend, 1 if added, 2 if friend request sent, 3 if confirmed friend, 4 if online. */
|
|
|
|
uint8_t info[MAX_DATA_SIZE]; /* the data that is sent during the friend requests we do */
|
|
|
|
uint8_t name[MAX_NAME_LENGTH];
|
|
|
|
uint8_t name_sent; /* 0 if we didn't send our name to this friend 1 if we have. */
|
|
|
|
uint8_t *statusmessage;
|
|
|
|
uint16_t statusmessage_length;
|
|
|
|
uint8_t statusmessage_sent;
|
|
|
|
USERSTATUS userstatus;
|
|
|
|
uint8_t userstatus_sent;
|
|
|
|
uint16_t info_size; /* length of the info */
|
|
|
|
uint32_t message_id; /* a semi-unique id used in read receipts */
|
|
|
|
uint8_t receives_read_receipts; /* shall we send read receipts to this person? */
|
|
|
|
} Friend;
|
|
|
|
|
|
|
|
typedef struct Messenger {
|
|
|
|
uint8_t public_key[crypto_box_PUBLICKEYBYTES];
|
|
|
|
|
|
|
|
uint8_t name[MAX_NAME_LENGTH];
|
|
|
|
uint16_t name_length;
|
|
|
|
|
|
|
|
uint8_t statusmessage[MAX_STATUSMESSAGE_LENGTH];
|
|
|
|
uint16_t statusmessage_length;
|
|
|
|
|
|
|
|
USERSTATUS userstatus;
|
|
|
|
|
|
|
|
Friend *friendlist;
|
|
|
|
uint32_t numfriends;
|
|
|
|
|
2013-08-12 20:23:46 +08:00
|
|
|
void (*friend_message)(struct Messenger *m, int, uint8_t *, uint16_t, void*);
|
2013-08-11 11:24:11 +08:00
|
|
|
uint8_t friend_message_isset;
|
2013-08-12 20:23:46 +08:00
|
|
|
void* friend_message_userdata;
|
|
|
|
void (*friend_action)(struct Messenger *m, int, uint8_t *, uint16_t, void*);
|
2013-08-11 11:24:11 +08:00
|
|
|
uint8_t friend_action_isset;
|
2013-08-12 20:23:46 +08:00
|
|
|
void* friend_action_userdata;
|
|
|
|
void (*friend_namechange)(struct Messenger *m, int, uint8_t *, uint16_t, void*);
|
2013-08-11 11:24:11 +08:00
|
|
|
uint8_t friend_namechange_isset;
|
2013-08-12 20:23:46 +08:00
|
|
|
void* friend_namechange_userdata;
|
|
|
|
void (*friend_statusmessagechange)(struct Messenger *m, int, uint8_t *, uint16_t, void*);
|
2013-08-11 11:24:11 +08:00
|
|
|
uint8_t friend_statusmessagechange_isset;
|
2013-08-12 20:23:46 +08:00
|
|
|
void* friend_statusmessagechange_userdata;
|
|
|
|
void (*friend_userstatuschange)(struct Messenger *m, int, USERSTATUS, void*);
|
2013-08-11 11:24:11 +08:00
|
|
|
uint8_t friend_userstatuschange_isset;
|
2013-08-12 20:23:46 +08:00
|
|
|
void* friend_userstatuschange_userdata;
|
|
|
|
void (*read_receipt)(struct Messenger *m, int, uint32_t, void*);
|
2013-08-11 11:24:11 +08:00
|
|
|
uint8_t read_receipt_isset;
|
2013-08-12 20:23:46 +08:00
|
|
|
void* read_receipt_userdata;
|
|
|
|
void (*friend_statuschange)(struct Messenger *m, int, uint8_t, void*);
|
2013-08-11 11:24:11 +08:00
|
|
|
uint8_t friend_statuschange_isset;
|
2013-08-12 20:23:46 +08:00
|
|
|
void* friend_statuschange_userdata;
|
|
|
|
void (*friend_connectionstatuschange)(struct Messenger *m, int, uint8_t, void*);
|
2013-08-11 11:24:11 +08:00
|
|
|
uint8_t friend_connectionstatuschange_isset;
|
2013-08-12 20:23:46 +08:00
|
|
|
void* friend_connectionstatuschange_userdata;
|
2013-08-11 11:24:11 +08:00
|
|
|
|
|
|
|
|
|
|
|
} Messenger;
|
|
|
|
|
2013-08-02 08:40:58 +08:00
|
|
|
/*
|
|
|
|
* add a friend
|
|
|
|
* set the data that will be sent along with friend request
|
|
|
|
* client_id is the client id of the friend
|
|
|
|
* data is the data and length is the length
|
|
|
|
* returns the friend number if success
|
|
|
|
* return -1 if message length is too long
|
|
|
|
* return -2 if no message (message length must be >= 1 byte)
|
|
|
|
* return -3 if user's own key
|
|
|
|
* return -4 if friend request already sent or already a friend
|
2013-08-06 03:30:07 +08:00
|
|
|
* return -5 for unknown error
|
2013-08-02 08:40:58 +08:00
|
|
|
*/
|
2013-08-11 11:24:11 +08:00
|
|
|
int m_addfriend(Messenger *m, uint8_t *client_id, uint8_t *data, uint16_t length);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
|
|
|
|
/* add a friend without sending a friendrequest.
|
|
|
|
returns the friend number if success
|
|
|
|
return -1 if failure. */
|
2013-08-11 11:24:11 +08:00
|
|
|
int m_addfriend_norequest(Messenger *m, uint8_t *client_id);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* return the friend id associated to that client id.
|
|
|
|
return -1 if no such friend */
|
2013-08-11 11:24:11 +08:00
|
|
|
int getfriend_id(Messenger *m, uint8_t *client_id);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* copies the public key associated to that friend id into client_id buffer.
|
|
|
|
make sure that client_id is of size CLIENT_ID_SIZE.
|
|
|
|
return 0 if success
|
|
|
|
return -1 if failure */
|
2013-08-11 11:24:11 +08:00
|
|
|
int getclient_id(Messenger *m, int friend_id, uint8_t *client_id);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* remove a friend */
|
2013-08-11 11:24:11 +08:00
|
|
|
int m_delfriend(Messenger *m, int friendnumber);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* return 4 if friend is online
|
|
|
|
return 3 if friend is confirmed
|
|
|
|
return 2 if the friend request was sent
|
|
|
|
return 1 if the friend was added
|
|
|
|
return 0 if there is no friend with that number */
|
2013-08-11 11:24:11 +08:00
|
|
|
int m_friendstatus(Messenger *m, int friendnumber);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* send a text chat message to an online friend
|
2013-08-08 00:53:52 +08:00
|
|
|
returns the message id if packet was successfully put into the send queue
|
|
|
|
return 0 if it was not
|
|
|
|
you will want to retain the return value, it will be passed to your read receipt callback
|
|
|
|
if one is received.
|
|
|
|
m_sendmessage_withid will send a message with the id of your choosing,
|
|
|
|
however we can generate an id for you by calling plain m_sendmessage. */
|
2013-08-11 11:24:11 +08:00
|
|
|
uint32_t m_sendmessage(Messenger *m, int friendnumber, uint8_t *message, uint32_t length);
|
|
|
|
uint32_t m_sendmessage_withid(Messenger *m, int friendnumber, uint32_t theid, uint8_t *message, uint32_t length);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
2013-08-09 03:00:30 +08:00
|
|
|
/* send an action to an online friend
|
|
|
|
returns 1 if packet was successfully put into the send queue
|
|
|
|
return 0 if it was not */
|
2013-08-11 11:24:11 +08:00
|
|
|
int m_sendaction(Messenger *m, int friendnumber, uint8_t *action, uint32_t length);
|
2013-08-09 03:00:30 +08:00
|
|
|
|
2013-07-27 20:48:50 +08:00
|
|
|
/* Set our nickname
|
2013-07-28 09:08:06 +08:00
|
|
|
name must be a string of maximum MAX_NAME_LENGTH length.
|
|
|
|
length must be at least 1 byte
|
|
|
|
length is the length of name with the NULL terminator
|
|
|
|
return 0 if success
|
|
|
|
return -1 if failure */
|
2013-08-11 11:24:11 +08:00
|
|
|
int setname(Messenger *m, uint8_t *name, uint16_t length);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
2013-07-31 02:30:33 +08:00
|
|
|
/* get our nickname
|
2013-08-06 03:30:07 +08:00
|
|
|
put it in name
|
2013-07-31 02:30:33 +08:00
|
|
|
return the length of the name*/
|
2013-08-11 11:24:11 +08:00
|
|
|
uint16_t getself_name(Messenger *m, uint8_t *name);
|
2013-07-30 23:09:09 +08:00
|
|
|
|
2013-07-27 20:48:50 +08:00
|
|
|
/* get name of friendnumber
|
|
|
|
put it in name
|
|
|
|
name needs to be a valid memory location with a size of at least MAX_NAME_LENGTH (128) bytes.
|
|
|
|
return 0 if success
|
|
|
|
return -1 if failure */
|
2013-08-11 11:24:11 +08:00
|
|
|
int getname(Messenger *m, int friendnumber, uint8_t *name);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* set our user status
|
|
|
|
you are responsible for freeing status after
|
|
|
|
returns 0 on success, -1 on failure */
|
2013-08-11 11:24:11 +08:00
|
|
|
int m_set_statusmessage(Messenger *m, uint8_t *status, uint16_t length);
|
|
|
|
int m_set_userstatus(Messenger *m, USERSTATUS status);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
2013-08-08 05:01:31 +08:00
|
|
|
/* return the length of friendnumber's status message,
|
2013-07-27 20:48:50 +08:00
|
|
|
including null
|
|
|
|
pass it into malloc */
|
2013-08-11 11:24:11 +08:00
|
|
|
int m_get_statusmessage_size(Messenger *m, int friendnumber);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
2013-08-08 05:01:31 +08:00
|
|
|
/* copy friendnumber's status message into buf, truncating if size is over maxlen
|
|
|
|
get the size you need to allocate from m_get_statusmessage_size
|
|
|
|
The self variant will copy our own status message. */
|
2013-08-11 11:24:11 +08:00
|
|
|
int m_copy_statusmessage(Messenger *m, int friendnumber, uint8_t *buf, uint32_t maxlen);
|
|
|
|
int m_copy_self_statusmessage(Messenger *m, uint8_t *buf, uint32_t maxlen);
|
2013-08-06 03:30:07 +08:00
|
|
|
|
2013-08-08 05:01:31 +08:00
|
|
|
/* Return one of USERSTATUS values.
|
|
|
|
* Values unknown to your application should be represented as USERSTATUS_NONE.
|
|
|
|
* As above, the self variant will return our own USERSTATUS.
|
|
|
|
* If friendnumber is invalid, this shall return USERSTATUS_INVALID. */
|
2013-08-11 11:24:11 +08:00
|
|
|
USERSTATUS m_get_userstatus(Messenger *m, int friendnumber);
|
|
|
|
USERSTATUS m_get_self_userstatus(Messenger *m);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
2013-08-08 01:06:07 +08:00
|
|
|
/* Sets whether we send read receipts for friendnumber.
|
|
|
|
* This function is not lazy, and it will fail if yesno is not (0 or 1).*/
|
2013-08-11 11:24:11 +08:00
|
|
|
void m_set_sends_receipts(Messenger *m, int friendnumber, int yesno);
|
2013-08-08 01:06:07 +08:00
|
|
|
|
2013-07-27 20:48:50 +08:00
|
|
|
/* set the function that will be executed when a friend request is received.
|
|
|
|
function format is function(uint8_t * public_key, uint8_t * data, uint16_t length) */
|
2013-08-12 20:23:46 +08:00
|
|
|
void m_callback_friendrequest(Messenger *m, void (*function)(uint8_t *, uint8_t *, uint16_t, void*), void* userdata);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* set the function that will be executed when a message from a friend is received.
|
|
|
|
function format is: function(int friendnumber, uint8_t * message, uint32_t length) */
|
2013-08-12 20:23:46 +08:00
|
|
|
void m_callback_friendmessage(Messenger *m, void (*function)(Messenger *m, int, uint8_t *, uint16_t, void*), void* userdata);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
2013-08-09 03:00:30 +08:00
|
|
|
/* set the function that will be executed when an action from a friend is received.
|
|
|
|
function format is: function(int friendnumber, uint8_t * action, uint32_t length) */
|
2013-08-12 20:23:46 +08:00
|
|
|
void m_callback_action(Messenger *m, void (*function)(Messenger *m, int, uint8_t *, uint16_t, void*), void* userdata);
|
2013-08-09 03:00:30 +08:00
|
|
|
|
2013-07-27 20:48:50 +08:00
|
|
|
/* set the callback for name changes
|
|
|
|
function(int friendnumber, uint8_t *newname, uint16_t length)
|
|
|
|
you are not responsible for freeing newname */
|
2013-08-12 20:23:46 +08:00
|
|
|
void m_callback_namechange(Messenger *m, void (*function)(Messenger *m, int, uint8_t *, uint16_t, void*), void* userdata);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
2013-08-08 05:01:31 +08:00
|
|
|
/* set the callback for status message changes
|
|
|
|
function(int friendnumber, uint8_t *newstatus, uint16_t length)
|
2013-07-27 20:48:50 +08:00
|
|
|
you are not responsible for freeing newstatus */
|
2013-08-12 20:23:46 +08:00
|
|
|
void m_callback_statusmessage(Messenger *m, void (*function)(Messenger *m, int, uint8_t *, uint16_t, void*), void* userdata);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
2013-08-08 13:05:23 +08:00
|
|
|
/* set the callback for status type changes
|
|
|
|
function(int friendnumber, USERSTATUS kind) */
|
2013-08-12 20:23:46 +08:00
|
|
|
void m_callback_userstatus(Messenger *m, void (*function)(Messenger *m, int, USERSTATUS, void*), void* userdata);
|
2013-08-08 13:05:23 +08:00
|
|
|
|
2013-08-08 01:06:07 +08:00
|
|
|
/* set the callback for read receipts
|
|
|
|
function(int friendnumber, uint32_t receipt)
|
|
|
|
if you are keeping a record of returns from m_sendmessage,
|
|
|
|
receipt might be one of those values, and that means the message
|
|
|
|
has been received on the other side. since core doesn't
|
|
|
|
track ids for you, receipt may not correspond to any message
|
|
|
|
in that case, you should discard it. */
|
2013-08-12 20:23:46 +08:00
|
|
|
void m_callback_read_receipt(Messenger *m, void (*function)(Messenger *m, int, uint32_t, void*), void* userdata);
|
2013-08-08 00:53:52 +08:00
|
|
|
|
2013-08-12 04:52:43 +08:00
|
|
|
/* set the callback for connection status changes
|
2013-08-12 02:57:47 +08:00
|
|
|
function(int friendnumber, uint8_t status)
|
|
|
|
status:
|
|
|
|
0 -- friend went offline after being previously online
|
|
|
|
1 -- friend went online
|
|
|
|
note that this callback is not called when adding friends, thus the "after
|
|
|
|
being previously online" part. it's assumed that when adding friends,
|
|
|
|
their connection status is offline. */
|
2013-08-12 20:23:46 +08:00
|
|
|
void m_callback_connectionstatus(Messenger *m, void (*function)(Messenger *m, int, uint8_t, void*), void* userdata);
|
2013-08-08 13:46:27 +08:00
|
|
|
|
2013-07-27 20:48:50 +08:00
|
|
|
/* run this at startup
|
2013-08-11 11:24:11 +08:00
|
|
|
* returns allocated instance of Messenger on success
|
|
|
|
* returns 0 if there are problems */
|
|
|
|
Messenger * initMessenger(void);
|
|
|
|
|
|
|
|
/* run this before closing shop
|
|
|
|
* free all datastructures */
|
|
|
|
void cleanupMessenger(Messenger *M);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* the main loop that needs to be run at least 200 times per second */
|
2013-08-11 11:24:11 +08:00
|
|
|
void doMessenger(Messenger *m);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* SAVING AND LOADING FUNCTIONS: */
|
|
|
|
|
|
|
|
/* returns the size of the messenger data (for saving) */
|
2013-08-11 11:24:11 +08:00
|
|
|
uint32_t Messenger_size(Messenger *m);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* save the messenger in data (must be allocated memory of size Messenger_size()) */
|
2013-08-11 11:24:11 +08:00
|
|
|
void Messenger_save(Messenger *m, uint8_t *data);
|
2013-07-27 20:48:50 +08:00
|
|
|
|
|
|
|
/* load the messenger from data of size length */
|
2013-08-11 11:24:11 +08:00
|
|
|
int Messenger_load(Messenger *m, uint8_t *data, uint32_t length);
|
2013-07-18 00:07:19 +08:00
|
|
|
|
2013-07-23 06:06:24 +08:00
|
|
|
#ifdef __cplusplus
|
|
|
|
}
|
|
|
|
#endif
|
|
|
|
|
2013-07-07 10:28:15 +08:00
|
|
|
#endif
|