2020-11-13 03:30:48 +01:00
|
|
|
/* groupchats.c
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* Copyright (C) 2020 Toxic All Rights Reserved.
|
|
|
|
*
|
|
|
|
* This file is part of Toxic.
|
|
|
|
*
|
|
|
|
* Toxic 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.
|
|
|
|
*
|
|
|
|
* Toxic 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 Toxic. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
*
|
|
|
|
*/
|
|
|
|
|
|
|
|
#ifndef _GNU_SOURCE
|
|
|
|
#define _GNU_SOURCE /* needed for strcasestr() and wcswidth() */
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#include <stdlib.h>
|
|
|
|
#include <string.h>
|
|
|
|
#include <assert.h>
|
|
|
|
#include <time.h>
|
|
|
|
#include <wchar.h>
|
|
|
|
#include <unistd.h>
|
|
|
|
#include <inttypes.h>
|
|
|
|
|
|
|
|
#ifdef AUDIO
|
|
|
|
#ifdef __APPLE__
|
|
|
|
#include <OpenAL/al.h>
|
|
|
|
#include <OpenAL/alc.h>
|
|
|
|
#else
|
|
|
|
#include <AL/al.h>
|
|
|
|
#include <AL/alc.h>
|
|
|
|
/* compatibility with older versions of OpenAL */
|
|
|
|
#ifndef ALC_ALL_DEVICES_SPECIFIER
|
|
|
|
#include <AL/alext.h>
|
|
|
|
#endif /* ALC_ALL_DEVICES_SPECIFIER */
|
|
|
|
#endif /* __APPLE__ */
|
|
|
|
#endif /* AUDIO */
|
|
|
|
|
|
|
|
#include "windows.h"
|
|
|
|
#include "toxic.h"
|
|
|
|
#include "execute.h"
|
|
|
|
#include "misc_tools.h"
|
|
|
|
#include "groupchats.h"
|
|
|
|
#include "prompt.h"
|
|
|
|
#include "toxic_strings.h"
|
|
|
|
#include "log.h"
|
|
|
|
#include "line_info.h"
|
|
|
|
#include "settings.h"
|
|
|
|
#include "input.h"
|
|
|
|
#include "help.h"
|
|
|
|
#include "notify.h"
|
|
|
|
#include "autocomplete.h"
|
|
|
|
#include "audio_device.h"
|
|
|
|
|
|
|
|
extern char *DATA_FILE;
|
|
|
|
static int max_groupchat_index = 0;
|
|
|
|
|
|
|
|
extern struct user_settings *user_settings;
|
|
|
|
extern struct Winthread Winthread;
|
|
|
|
|
|
|
|
#define GROUP_SIDEBAR_OFFSET 2 /* Offset for the peer number box at the top of the statusbar */
|
|
|
|
|
|
|
|
/* groupchat command names used for tab completion. */
|
|
|
|
static const char *group_cmd_list[] = {
|
|
|
|
"/accept",
|
|
|
|
"/add",
|
|
|
|
"/avatar",
|
|
|
|
"/chatid",
|
|
|
|
"/clear",
|
|
|
|
"/close",
|
|
|
|
"/conference",
|
|
|
|
"/connect",
|
|
|
|
"/disconnect",
|
|
|
|
"/decline",
|
|
|
|
"/exit",
|
|
|
|
"/group",
|
|
|
|
"/help",
|
|
|
|
"/ignore",
|
|
|
|
"/join",
|
|
|
|
"/kick",
|
|
|
|
"/log",
|
|
|
|
"/mod",
|
|
|
|
"/myid",
|
|
|
|
"/mykey",
|
|
|
|
#ifdef QRCODE
|
|
|
|
"/myqr",
|
|
|
|
#endif /* QRCODE */
|
|
|
|
"/nick",
|
|
|
|
"/note",
|
|
|
|
"/passwd",
|
|
|
|
"/nospam",
|
|
|
|
"/peerlimit",
|
|
|
|
"/privacy",
|
|
|
|
"/quit",
|
|
|
|
"/rejoin",
|
|
|
|
"/requests",
|
|
|
|
#ifdef PYTHON
|
|
|
|
"/run",
|
|
|
|
#endif /* PYTHON */
|
|
|
|
"/silence",
|
|
|
|
"/status",
|
|
|
|
"/topic",
|
|
|
|
"/unignore",
|
|
|
|
"/unmod",
|
|
|
|
"/unsilence",
|
|
|
|
"/whisper",
|
|
|
|
"/whois",
|
|
|
|
#ifdef AUDIO
|
|
|
|
"/lsdev",
|
|
|
|
"/sdev",
|
|
|
|
"/mute",
|
|
|
|
"/sense",
|
|
|
|
#endif /* AUDIO */
|
|
|
|
};
|
|
|
|
|
|
|
|
GroupChat groupchats[MAX_GROUPCHAT_NUM];
|
|
|
|
|
|
|
|
static ToxWindow *new_group_chat(Tox *m, uint32_t groupnumber, const char *groupname, int length);
|
|
|
|
static void groupchat_set_group_name(ToxWindow *self, Tox *m, uint32_t groupnumber);
|
|
|
|
static void group_update_name_list(uint32_t groupnumber);
|
|
|
|
static void groupchat_onGroupPeerJoin(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id);
|
|
|
|
static int realloc_peer_list(uint32_t groupnumber, uint32_t n);
|
|
|
|
static void groupchat_onGroupNickChange(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id,
|
|
|
|
const char *new_nick, size_t len);
|
|
|
|
static void groupchat_onGroupStatusChange(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id,
|
|
|
|
TOX_USER_STATUS status);
|
|
|
|
static void groupchat_onGroupSelfNickChange(ToxWindow *self, Tox *m, uint32_t groupnumber, const char *old_nick,
|
|
|
|
size_t old_length, const char *new_nick, size_t length);
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Return a GroupChat pointer associated with groupnumber.
|
|
|
|
* Return NULL if groupnumber is invalid.
|
|
|
|
*/
|
|
|
|
GroupChat *get_groupchat(uint32_t groupnumber)
|
|
|
|
{
|
|
|
|
for (size_t i = 0; i < max_groupchat_index; ++i) {
|
|
|
|
if (!groupchats[i].active) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (groupchats[i].groupnumber == groupnumber) {
|
|
|
|
return &groupchats[i];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
static const char *get_group_exit_string(Tox_Group_Exit_Type exit_type)
|
|
|
|
{
|
|
|
|
switch (exit_type) {
|
|
|
|
case TOX_GROUP_EXIT_TYPE_QUIT:
|
|
|
|
return "Quit";
|
|
|
|
|
|
|
|
case TOX_GROUP_EXIT_TYPE_TIMEOUT:
|
|
|
|
return "Connection timed out";
|
|
|
|
|
|
|
|
case TOX_GROUP_EXIT_TYPE_DISCONNECTED:
|
|
|
|
return "Disconnected";
|
|
|
|
|
|
|
|
case TOX_GROUP_EXIT_TYPE_KICK:
|
|
|
|
return "Kicked";
|
|
|
|
|
|
|
|
case TOX_GROUP_EXIT_TYPE_SYNC_ERROR:
|
|
|
|
return "Sync error";
|
|
|
|
|
|
|
|
default:
|
|
|
|
return "Unknown error";
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void clear_peer(GroupPeer *peer)
|
|
|
|
{
|
|
|
|
*peer = (GroupPeer) {
|
|
|
|
0
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
|
|
|
void groupchat_rejoin(ToxWindow *self, Tox *m)
|
|
|
|
{
|
|
|
|
GroupChat *chat = get_groupchat(self->num);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to fetch GroupChat object.");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
TOX_ERR_GROUP_SELF_QUERY s_err;
|
|
|
|
uint32_t self_peer_id = tox_group_self_get_peer_id(m, self->num, &s_err);
|
|
|
|
|
|
|
|
if (s_err != TOX_ERR_GROUP_SELF_QUERY_OK) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to fetch self peer_id in groupchat_rejoin()");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
for (size_t i = 0; i < chat->max_idx; ++i) {
|
|
|
|
clear_peer(&chat->peer_list[i]);
|
|
|
|
}
|
|
|
|
|
|
|
|
chat->num_peers = 0;
|
|
|
|
chat->max_idx = 0;
|
|
|
|
realloc_peer_list(self->num, 0);
|
|
|
|
|
|
|
|
groupchat_onGroupPeerJoin(self, m, self->num, self_peer_id);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void kill_groupchat_window(ToxWindow *self)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
log_disable(ctx->log);
|
|
|
|
line_info_cleanup(ctx->hst);
|
|
|
|
delwin(ctx->linewin);
|
|
|
|
delwin(ctx->history);
|
|
|
|
delwin(ctx->sidebar);
|
|
|
|
free(ctx->log);
|
|
|
|
free(ctx);
|
|
|
|
free(self->help);
|
|
|
|
del_window(self);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Closes groupchat window and cleans up. */
|
|
|
|
static void close_groupchat(ToxWindow *self, Tox *m, uint32_t groupnumber)
|
|
|
|
{
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
realloc_peer_list(groupnumber, 0);
|
|
|
|
|
|
|
|
free_ptr_array((void **) chat->name_list);
|
|
|
|
|
|
|
|
*chat = (GroupChat) {
|
|
|
|
0
|
|
|
|
};
|
|
|
|
|
|
|
|
int i;
|
|
|
|
|
|
|
|
for (i = max_groupchat_index; i > 0; --i) {
|
|
|
|
if (groupchats[i - 1].active) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
max_groupchat_index = i;
|
|
|
|
kill_groupchat_window(self);
|
|
|
|
}
|
|
|
|
|
|
|
|
void exit_groupchat(ToxWindow *self, Tox *m, uint32_t groupnumber, const char *partmessage, size_t length)
|
|
|
|
{
|
|
|
|
if (length > TOX_GROUP_MAX_PART_LENGTH) {
|
|
|
|
length = TOX_GROUP_MAX_PART_LENGTH;
|
|
|
|
}
|
|
|
|
|
|
|
|
tox_group_leave(m, groupnumber, (uint8_t *) partmessage, length, NULL);
|
2020-11-19 07:31:47 +01:00
|
|
|
|
|
|
|
if (self != NULL) {
|
|
|
|
close_groupchat(self, m, groupnumber);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Initializes groupchat log. This should only be called after we have the group name.
|
|
|
|
*/
|
|
|
|
static void init_groupchat_log(ToxWindow *self, Tox *m, uint32_t groupnumber)
|
|
|
|
{
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
char my_id[TOX_ADDRESS_SIZE];
|
|
|
|
tox_self_get_address(m, (uint8_t *) my_id);
|
|
|
|
|
|
|
|
char chat_id[TOX_GROUP_CHAT_ID_SIZE];
|
|
|
|
|
|
|
|
TOX_ERR_GROUP_STATE_QUERIES err;
|
|
|
|
|
|
|
|
if (!tox_group_get_chat_id(m, groupnumber, (uint8_t *)chat_id, &err)) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to fetch chat id. Logging disabled. (error: %d)", err);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (log_init(ctx->log, chat->group_name, my_id, chat_id, LOG_TYPE_CHAT) != 0) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Warning: Log failed to initialize.");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (load_chat_history(self, ctx->log) != 0) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to load chat history.");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (user_settings->autolog == AUTOLOG_ON) {
|
|
|
|
if (log_enable(ctx->log) != 0) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to enable chat log.");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
execute(ctx->history, self, m, "/log", GLOBAL_COMMAND_MODE); // print log state to screen
|
2020-11-13 03:30:48 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
/* Creates a new toxic groupchat window associated with groupnumber.
|
|
|
|
*
|
|
|
|
* Returns 0 on success.
|
|
|
|
* Returns -1 on general failure.
|
|
|
|
* Returns -2 if the groupnumber is already in use. This usually means that the client has
|
2020-11-19 07:31:47 +01:00
|
|
|
* been kicked and needs to close the chat window before opening a new one.
|
2020-11-13 03:30:48 +01:00
|
|
|
*/
|
2020-11-19 07:31:47 +01:00
|
|
|
int init_groupchat_win(Tox *m, uint32_t groupnumber, const char *groupname, size_t length, Group_Join_Type join_type)
|
2020-11-13 03:30:48 +01:00
|
|
|
{
|
|
|
|
ToxWindow *self = new_group_chat(m, groupnumber, groupname, length);
|
|
|
|
|
|
|
|
for (int i = 0; i <= max_groupchat_index; ++i) {
|
|
|
|
if (!groupchats[i].active) {
|
|
|
|
groupchats[i].chatwin = add_window(m, self);
|
|
|
|
groupchats[i].active = true;
|
|
|
|
groupchats[i].groupnumber = groupnumber;
|
|
|
|
groupchats[i].num_peers = 0;
|
|
|
|
groupchats[i].time_connected = 0;
|
|
|
|
|
|
|
|
if (i == max_groupchat_index) {
|
|
|
|
++max_groupchat_index;
|
|
|
|
}
|
|
|
|
|
|
|
|
set_active_window_index(groupchats[i].chatwin);
|
|
|
|
store_data(m, DATA_FILE);
|
|
|
|
|
|
|
|
TOX_ERR_GROUP_SELF_QUERY err;
|
|
|
|
uint32_t peer_id = tox_group_self_get_peer_id(m, groupnumber, &err);
|
|
|
|
|
|
|
|
if (err != TOX_ERR_GROUP_SELF_QUERY_OK) {
|
|
|
|
close_groupchat(self, m, groupnumber);
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
2020-11-19 07:31:47 +01:00
|
|
|
if (join_type == Group_Join_Type_Create || join_type == Group_Join_Type_Load) {
|
|
|
|
groupchat_set_group_name(self, m, groupnumber);
|
|
|
|
}
|
|
|
|
|
2020-11-13 03:30:48 +01:00
|
|
|
groupchat_onGroupPeerJoin(self, m, groupnumber, peer_id);
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
void set_nick_all_groups(Tox *m, const char *new_nick, size_t length)
|
|
|
|
{
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
for (int i = 0; i < max_groupchat_index; ++i) {
|
|
|
|
if (groupchats[i].active) {
|
|
|
|
ToxWindow *self = get_window_ptr(groupchats[i].chatwin);
|
|
|
|
|
|
|
|
if (!self) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
char old_nick[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
size_t old_length = get_group_self_nick_truncate(m, old_nick, self->num);
|
|
|
|
|
|
|
|
TOX_ERR_GROUP_SELF_NAME_SET err;
|
|
|
|
tox_group_self_set_name(m, groupchats[i].groupnumber, (uint8_t *) new_nick, length, &err);
|
|
|
|
|
|
|
|
switch (err) {
|
|
|
|
case TOX_ERR_GROUP_SELF_NAME_SET_OK: {
|
|
|
|
groupchat_onGroupSelfNickChange(self, m, self->num, old_nick, old_length, new_nick, length);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
case TOX_ERR_GROUP_SELF_NAME_SET_TAKEN: {
|
|
|
|
line_info_add(self, NULL, NULL, 0, SYS_MSG, 0, RED, "-!- That nick is already in use.");
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
default: {
|
|
|
|
if (groupchats[i].time_connected > 0) {
|
|
|
|
line_info_add(self, NULL, NULL, 0, SYS_MSG, 0, RED, "-!- Failed to set nick (error %d).", err);
|
|
|
|
}
|
|
|
|
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void set_status_all_groups(Tox *m, uint8_t status)
|
|
|
|
{
|
|
|
|
for (int i = 0; i < max_groupchat_index; ++i) {
|
|
|
|
if (groupchats[i].active) {
|
|
|
|
ToxWindow *self = get_window_ptr(groupchats[i].chatwin);
|
|
|
|
|
|
|
|
if (!self) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
TOX_ERR_GROUP_SELF_QUERY s_err;
|
|
|
|
uint32_t self_peer_id = tox_group_self_get_peer_id(m, self->num, &s_err);
|
|
|
|
|
|
|
|
if (s_err != TOX_ERR_GROUP_SELF_QUERY_OK) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to fetch self peer_id.");
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (tox_group_self_set_status(m, self->num, (TOX_USER_STATUS) status, NULL)) {
|
|
|
|
groupchat_onGroupStatusChange(self, m, self->num, self_peer_id, (TOX_USER_STATUS) status);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Returns a weight for peer_sort_cmp based on the peer's role. */
|
|
|
|
#define PEER_CMP_BASE_WEIGHT 100000
|
|
|
|
static int peer_sort_cmp_weight(struct GroupPeer *peer)
|
|
|
|
{
|
|
|
|
int w = PEER_CMP_BASE_WEIGHT;
|
|
|
|
|
|
|
|
if (peer->role == TOX_GROUP_ROLE_FOUNDER) {
|
|
|
|
w <<= 2;
|
|
|
|
} else if (peer->role == TOX_GROUP_ROLE_MODERATOR) {
|
|
|
|
w <<= 1;
|
|
|
|
} else if (peer->role == TOX_GROUP_ROLE_OBSERVER) {
|
|
|
|
w >>= 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
return w;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int peer_sort_cmp(const void *n1, const void *n2)
|
|
|
|
{
|
|
|
|
struct GroupPeer *peer1 = (struct GroupPeer *) n1;
|
|
|
|
struct GroupPeer *peer2 = (struct GroupPeer *) n2;
|
|
|
|
|
|
|
|
int res = qsort_strcasecmp_hlpr(peer1->name, peer2->name);
|
|
|
|
return res - peer_sort_cmp_weight(peer1) + peer_sort_cmp_weight(peer2);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Sorts the peer list, first by role, then by name. */
|
|
|
|
static void sort_peerlist(uint32_t groupnumber)
|
|
|
|
{
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
qsort(chat->peer_list, chat->max_idx, sizeof(struct GroupPeer), peer_sort_cmp);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Gets the peer_id associated with nick.
|
|
|
|
* Returns -1 on failure or if nick is not assigned to anyone in the group.
|
|
|
|
*/
|
|
|
|
int group_get_nick_peer_id(uint32_t groupnumber, const char *nick, uint32_t *peer_id)
|
|
|
|
{
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
for (size_t i = 0; i < chat->max_idx; ++i) {
|
|
|
|
if (chat->peer_list[i].active) {
|
|
|
|
if (strcmp(nick, chat->peer_list[i].name) == 0) {
|
|
|
|
*peer_id = chat->peer_list[i].peer_id;
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_update_last_seen(uint32_t groupnumber, uint32_t peer_id)
|
|
|
|
{
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
int peer_index = get_peer_index(groupnumber, peer_id);
|
|
|
|
|
|
|
|
if (peer_index >= 0) {
|
|
|
|
chat->peer_list[peer_index].last_active = get_unix_time();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Returns the peerlist index of peer_id for groupnumber's group chat.
|
|
|
|
* Returns -1 on failure.
|
|
|
|
*/
|
|
|
|
int get_peer_index(uint32_t groupnumber, uint32_t peer_id)
|
|
|
|
{
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
for (uint32_t i = 0; i < chat->max_idx; ++i) {
|
|
|
|
if (!chat->peer_list[i].active) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (chat->peer_list[i].peer_id == peer_id) {
|
|
|
|
return i;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void group_update_name_list(uint32_t groupnumber)
|
|
|
|
{
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
free_ptr_array((void **) chat->name_list);
|
|
|
|
|
|
|
|
chat->name_list = (char **) malloc_ptr_array(chat->num_peers, TOX_MAX_NAME_LENGTH + 1);
|
|
|
|
|
|
|
|
if (!chat->name_list) {
|
|
|
|
fprintf(stderr, "WARNING: Out of memory in group_update_name_list()\n");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
uint32_t count = 0;
|
|
|
|
|
|
|
|
for (uint32_t i = 0; i < chat->max_idx; ++i) {
|
|
|
|
if (chat->peer_list[i].active) {
|
|
|
|
size_t length = chat->peer_list[i].name_length;
|
|
|
|
memcpy(chat->name_list[count], chat->peer_list[i].name, length);
|
|
|
|
chat->name_list[count][length] = 0;
|
|
|
|
++count;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
sort_peerlist(groupnumber);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* destroys and re-creates groupchat window */
|
|
|
|
void redraw_groupchat_win(ToxWindow *self)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
endwin();
|
|
|
|
refresh();
|
|
|
|
clear();
|
|
|
|
|
|
|
|
int x2, y2;
|
|
|
|
getmaxyx(stdscr, y2, x2);
|
|
|
|
y2 -= 2;
|
|
|
|
|
|
|
|
if (y2 <= 0 || x2 <= 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (ctx->sidebar) {
|
|
|
|
delwin(ctx->sidebar);
|
|
|
|
ctx->sidebar = NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
delwin(ctx->linewin);
|
|
|
|
delwin(ctx->history);
|
|
|
|
delwin(self->window);
|
|
|
|
|
|
|
|
self->window = newwin(y2, x2, 0, 0);
|
|
|
|
ctx->linewin = subwin(self->window, CHATBOX_HEIGHT, x2, y2 - CHATBOX_HEIGHT, 0);
|
|
|
|
|
|
|
|
if (self->show_peerlist) {
|
|
|
|
ctx->history = subwin(self->window, y2 - CHATBOX_HEIGHT + 1, x2 - SIDEBAR_WIDTH - 1, 0, 0);
|
|
|
|
ctx->sidebar = subwin(self->window, y2 - CHATBOX_HEIGHT + 1, SIDEBAR_WIDTH, 0, x2 - SIDEBAR_WIDTH);
|
|
|
|
} else {
|
|
|
|
ctx->history = subwin(self->window, y2 - CHATBOX_HEIGHT + 1, x2, 0, 0);
|
|
|
|
}
|
|
|
|
|
|
|
|
scrollok(ctx->history, 0);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
static void group_onAction(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id, const char *action,
|
|
|
|
size_t len)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
char nick[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
get_group_nick_truncate(m, nick, peer_id, groupnumber);
|
|
|
|
|
|
|
|
char self_nick[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
get_group_self_nick_truncate(m, self_nick, groupnumber);
|
|
|
|
|
|
|
|
if (strcasestr(action, self_nick)) {
|
|
|
|
sound_notify(self, generic_message, NT_WNDALERT_0, NULL);
|
|
|
|
|
|
|
|
if (self->active_box != -1) {
|
|
|
|
box_silent_notify2(self, NT_NOFOCUS, self->active_box, "* %s %s", nick, action);
|
|
|
|
} else {
|
|
|
|
box_silent_notify(self, NT_NOFOCUS, &self->active_box, self->name, "* %s %s", nick, action);
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
sound_notify(self, silent, NT_WNDALERT_1, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
line_info_add(self, timefrmt, nick, NULL, IN_ACTION, 0, 0, "%s", action);
|
|
|
|
write_to_log(action, nick, ctx->log, true);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupMessage(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id,
|
|
|
|
TOX_MESSAGE_TYPE type, const char *msg, size_t len)
|
|
|
|
{
|
|
|
|
if (self->num != groupnumber || !get_groupchat(groupnumber)) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
groupchat_update_last_seen(groupnumber, peer_id);
|
|
|
|
|
|
|
|
if (type == TOX_MESSAGE_TYPE_ACTION) {
|
|
|
|
group_onAction(self, m, groupnumber, peer_id, msg, len);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
char nick[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
get_group_nick_truncate(m, nick, peer_id, groupnumber);
|
|
|
|
|
|
|
|
char self_nick[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
get_group_self_nick_truncate(m, self_nick, groupnumber);
|
|
|
|
|
|
|
|
int nick_clr = CYAN;
|
|
|
|
|
|
|
|
/* Only play sound if mentioned by someone else */
|
|
|
|
if (strcasestr(msg, self_nick) && strcmp(self_nick, nick)) {
|
|
|
|
sound_notify(self, generic_message, NT_WNDALERT_0 | user_settings->bell_on_message, NULL);
|
|
|
|
|
|
|
|
if (self->active_box != -1) {
|
|
|
|
box_silent_notify2(self, NT_NOFOCUS, self->active_box, "%s %s", nick, msg);
|
|
|
|
} else {
|
|
|
|
box_silent_notify(self, NT_NOFOCUS, &self->active_box, self->name, "%s %s", nick, msg);
|
|
|
|
}
|
|
|
|
|
|
|
|
nick_clr = RED;
|
|
|
|
} else {
|
|
|
|
sound_notify(self, silent, NT_WNDALERT_1, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
line_info_add(self, timefrmt, nick, NULL, IN_MSG, 0, nick_clr, "%s", msg);
|
|
|
|
write_to_log(msg, nick, ctx->log, false);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupPrivateMessage(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id,
|
|
|
|
const char *msg, size_t len)
|
|
|
|
{
|
|
|
|
if (self->num != groupnumber || !get_groupchat(groupnumber)) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
groupchat_update_last_seen(groupnumber, peer_id);
|
|
|
|
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
char nick[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
get_group_nick_truncate(m, nick, peer_id, groupnumber);
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
line_info_add(self, timefrmt, nick, NULL, IN_PRVT_MSG, 0, MAGENTA, "%s", msg);
|
|
|
|
write_to_log(msg, nick, ctx->log, false);
|
|
|
|
|
|
|
|
sound_notify(self, generic_message, NT_WNDALERT_0, NULL);
|
|
|
|
|
|
|
|
if (self->active_box != -1) {
|
|
|
|
box_silent_notify2(self, NT_NOFOCUS, self->active_box, "%s %s", nick, msg);
|
|
|
|
} else {
|
|
|
|
box_silent_notify(self, NT_NOFOCUS, &self->active_box, self->name, "%s %s", nick, msg);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupTopicChange(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id,
|
|
|
|
const char *topic, size_t length)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
if (self->num != groupnumber || !get_groupchat(groupnumber)) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
groupchat_update_last_seen(groupnumber, peer_id);
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
char nick[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
get_group_nick_truncate(m, nick, peer_id, groupnumber);
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, MAGENTA, "-!- %s set the topic to: %s", nick, topic);
|
|
|
|
|
|
|
|
char tmp_event[MAX_STR_SIZE];
|
|
|
|
snprintf(tmp_event, sizeof(tmp_event), " set the topic to %s", topic);
|
|
|
|
write_to_log(tmp_event, nick, ctx->log, true);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupPeerLimit(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_limit)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
if (self->num != groupnumber || !get_groupchat(groupnumber)) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, BLUE, "-!- The group founder has set the peer limit to %d",
|
|
|
|
peer_limit);
|
|
|
|
|
|
|
|
char tmp_event[MAX_STR_SIZE];
|
|
|
|
snprintf(tmp_event, sizeof(tmp_event), " set the peer limit to %u", peer_limit);
|
|
|
|
write_to_log(tmp_event, "The founder", ctx->log, true);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupPrivacyState(ToxWindow *self, Tox *m, uint32_t groupnumber, TOX_GROUP_PRIVACY_STATE state)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
if (self->num != groupnumber || !get_groupchat(groupnumber)) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
const char *state_str = state == TOX_GROUP_PRIVACY_STATE_PUBLIC ? "public" : "private";
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, BLUE, "-!- The group founder has set the group to %s.",
|
|
|
|
state_str);
|
|
|
|
|
|
|
|
char tmp_event[MAX_STR_SIZE];
|
|
|
|
snprintf(tmp_event, sizeof(tmp_event), " set the group to %s.", state_str);
|
|
|
|
write_to_log(tmp_event, "The founder", ctx->log, true);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupPassword(ToxWindow *self, Tox *m, uint32_t groupnumber, const char *password,
|
|
|
|
size_t length)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
if (self->num != groupnumber || !get_groupchat(groupnumber)) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
if (length > 0) {
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, BLUE, "-!- The group founder has password protected the group.");
|
|
|
|
|
|
|
|
char tmp_event[MAX_STR_SIZE];
|
|
|
|
snprintf(tmp_event, sizeof(tmp_event), " set a new password.");
|
|
|
|
write_to_log(tmp_event, "The founder", ctx->log, true);
|
|
|
|
} else {
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, BLUE, "-!- The group founder has removed password protection.");
|
|
|
|
|
|
|
|
char tmp_event[MAX_STR_SIZE];
|
|
|
|
snprintf(tmp_event, sizeof(tmp_event), " removed password protection.");
|
|
|
|
write_to_log(tmp_event, "The founder", ctx->log, true);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Reallocates groupnumber's peer list to size n.
|
|
|
|
*
|
|
|
|
* Returns 0 on success.
|
|
|
|
* Returns -1 on failure.
|
|
|
|
*/
|
|
|
|
static int realloc_peer_list(uint32_t groupnumber, uint32_t n)
|
|
|
|
{
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (n == 0) {
|
|
|
|
free(chat->peer_list);
|
|
|
|
chat->peer_list = NULL;
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
struct GroupPeer *tmp_list = realloc(chat->peer_list, n * sizeof(struct GroupPeer));
|
|
|
|
|
|
|
|
if (!tmp_list) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
chat->peer_list = tmp_list;
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupPeerJoin(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id)
|
|
|
|
{
|
|
|
|
if (self->num != groupnumber) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (realloc_peer_list(groupnumber, chat->max_idx + 1) == -1) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
clear_peer(&chat->peer_list[chat->max_idx]);
|
|
|
|
|
|
|
|
for (uint32_t i = 0; i <= chat->max_idx; ++i) {
|
|
|
|
if (chat->peer_list[i].active) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
++chat->num_peers;
|
|
|
|
|
|
|
|
chat->peer_list[i].active = true;
|
|
|
|
chat->peer_list[i].peer_id = peer_id;
|
|
|
|
get_group_nick_truncate(m, chat->peer_list[i].name, peer_id, groupnumber);
|
|
|
|
chat->peer_list[i].name_length = strlen(chat->peer_list[i].name);
|
|
|
|
chat->peer_list[i].status = tox_group_peer_get_status(m, groupnumber, peer_id, NULL);
|
|
|
|
chat->peer_list[i].role = tox_group_peer_get_role(m, groupnumber, peer_id, NULL);
|
|
|
|
chat->peer_list[i].last_active = get_unix_time();
|
|
|
|
tox_group_peer_get_public_key(m, groupnumber, peer_id, (uint8_t *) chat->peer_list[i].public_key, NULL);
|
|
|
|
|
|
|
|
if (i == chat->max_idx) {
|
|
|
|
++chat->max_idx;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (timed_out(chat->time_connected, 7)) { /* ignore join messages when we first connect to the group */
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
line_info_add(self, timefrmt, chat->peer_list[i].name, NULL, CONNECTION, 0, GREEN, "has joined the room.");
|
|
|
|
|
|
|
|
char log_str[TOX_MAX_NAME_LENGTH + 32];
|
|
|
|
snprintf(log_str, sizeof(log_str), "%s has joined the room", chat->peer_list[i].name);
|
|
|
|
|
|
|
|
write_to_log(log_str, chat->peer_list[i].name, self->chatwin->log, true);
|
|
|
|
sound_notify(self, silent, NT_WNDALERT_2, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
group_update_name_list(groupnumber);
|
|
|
|
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void groupchat_onGroupPeerExit(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id,
|
|
|
|
Tox_Group_Exit_Type exit_type,
|
|
|
|
const char *name, size_t name_len, const char *part_message, size_t length)
|
|
|
|
{
|
|
|
|
UNUSED_VAR(name_len);
|
|
|
|
UNUSED_VAR(length);
|
|
|
|
|
|
|
|
if (self->num != groupnumber) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
if (exit_type != TOX_GROUP_EXIT_TYPE_SELF_DISCONNECTED) {
|
|
|
|
char log_str[TOX_MAX_NAME_LENGTH + MAX_STR_SIZE];
|
|
|
|
|
|
|
|
if (length > 0) {
|
|
|
|
line_info_add(self, timefrmt, name, NULL, DISCONNECTION, 0, RED, "[Quit]: %s", part_message);
|
|
|
|
snprintf(log_str, sizeof(log_str), "%s has left the room (%s)", name, part_message);
|
|
|
|
} else {
|
|
|
|
const char *exit_string = get_group_exit_string(exit_type);
|
|
|
|
line_info_add(self, timefrmt, name, NULL, DISCONNECTION, 0, RED, "[%s]", exit_string);
|
|
|
|
snprintf(log_str, sizeof(log_str), "%s [%s]", name, exit_string);
|
|
|
|
}
|
|
|
|
|
|
|
|
write_to_log(log_str, name, self->chatwin->log, true);
|
|
|
|
sound_notify(self, silent, NT_WNDALERT_2, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
int peer_index = get_peer_index(groupnumber, peer_id);
|
|
|
|
|
|
|
|
if (peer_index < 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
clear_peer(&chat->peer_list[peer_index]);
|
|
|
|
|
|
|
|
uint32_t i;
|
|
|
|
|
|
|
|
for (i = chat->max_idx; i > 0; --i) {
|
|
|
|
if (chat->peer_list[i - 1].active) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (realloc_peer_list(groupnumber, i) == -1) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
--chat->num_peers;
|
|
|
|
chat->max_idx = i;
|
|
|
|
|
|
|
|
group_update_name_list(groupnumber);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_set_group_name(ToxWindow *self, Tox *m, uint32_t groupnumber)
|
|
|
|
{
|
2020-11-19 07:31:47 +01:00
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2020-11-13 03:30:48 +01:00
|
|
|
TOX_ERR_GROUP_STATE_QUERIES err;
|
|
|
|
size_t len = tox_group_get_name_size(m, groupnumber, &err);
|
|
|
|
|
|
|
|
if (err != TOX_ERR_GROUP_STATE_QUERIES_OK) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to retrieve group name length (error %d)", err);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char tmp_groupname[TOX_GROUP_MAX_GROUP_NAME_LENGTH + 1];
|
|
|
|
|
|
|
|
if (!tox_group_get_name(m, groupnumber, (uint8_t *) tmp_groupname, &err)) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to retrieve group name (error %d)", err);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2020-11-19 07:31:47 +01:00
|
|
|
len = copy_tox_str(chat->group_name, sizeof(chat->group_name), tmp_groupname, len);
|
|
|
|
chat->group_name_length = len;
|
2020-11-13 03:30:48 +01:00
|
|
|
|
|
|
|
if (len > 0) {
|
2020-11-19 07:31:47 +01:00
|
|
|
set_window_title(self, chat->group_name, len);
|
|
|
|
init_groupchat_log(self, m, groupnumber);
|
2020-11-13 03:30:48 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupSelfJoin(ToxWindow *self, Tox *m, uint32_t groupnumber)
|
|
|
|
{
|
|
|
|
if (self->num != groupnumber) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
chat->time_connected = get_unix_time();
|
|
|
|
|
|
|
|
char topic[TOX_GROUP_MAX_TOPIC_LENGTH + 1];
|
|
|
|
|
|
|
|
TOX_ERR_GROUP_STATE_QUERIES err;
|
|
|
|
size_t topic_length = tox_group_get_topic_size(m, groupnumber, &err);
|
|
|
|
|
|
|
|
if (err != TOX_ERR_GROUP_STATE_QUERIES_OK) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to retrieve group topic length (error %d)", err);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
tox_group_get_topic(m, groupnumber, (uint8_t *) topic, &err);
|
|
|
|
topic[topic_length] = 0;
|
|
|
|
|
|
|
|
if (err != TOX_ERR_GROUP_STATE_QUERIES_OK) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Failed to retrieve group topic (error %d)", err);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, MAGENTA, "-!- Topic set to: %s", topic);
|
|
|
|
|
2020-11-19 07:31:47 +01:00
|
|
|
if (chat->group_name_length == 0) {
|
|
|
|
groupchat_set_group_name(self, m, groupnumber);
|
|
|
|
}
|
|
|
|
|
2020-11-13 03:30:48 +01:00
|
|
|
/* Update own role since it may have changed while we were offline */
|
|
|
|
TOX_ERR_GROUP_SELF_QUERY s_err;
|
|
|
|
TOX_GROUP_ROLE role = tox_group_self_get_role(m, groupnumber, &s_err);
|
|
|
|
|
|
|
|
if (s_err != TOX_ERR_GROUP_SELF_QUERY_OK) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
uint32_t self_peer_id = tox_group_self_get_peer_id(m, groupnumber, &s_err);
|
|
|
|
|
|
|
|
if (s_err != TOX_ERR_GROUP_SELF_QUERY_OK) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
int idx = get_peer_index(groupnumber, self_peer_id);
|
|
|
|
|
|
|
|
if (idx < 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
chat->peer_list[idx].role = role;
|
|
|
|
|
|
|
|
sort_peerlist(groupnumber);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupRejected(ToxWindow *self, Tox *m, uint32_t groupnumber, TOX_GROUP_JOIN_FAIL type)
|
|
|
|
{
|
|
|
|
if (self->num != groupnumber || !get_groupchat(groupnumber)) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
const char *msg = NULL;
|
|
|
|
|
|
|
|
switch (type) {
|
|
|
|
case TOX_GROUP_JOIN_FAIL_NAME_TAKEN:
|
|
|
|
msg = "Nick already in use. Change your nick and use the '/rejoin' command.";
|
|
|
|
break;
|
|
|
|
|
|
|
|
case TOX_GROUP_JOIN_FAIL_PEER_LIMIT:
|
|
|
|
msg = "Group is full. Try again with the '/rejoin' command.";
|
|
|
|
break;
|
|
|
|
|
|
|
|
case TOX_GROUP_JOIN_FAIL_INVALID_PASSWORD:
|
|
|
|
msg = "Invalid password.";
|
|
|
|
break;
|
|
|
|
|
|
|
|
case TOX_GROUP_JOIN_FAIL_UNKNOWN:
|
|
|
|
msg = "Failed to join group. Try again with the '/rejoin' command.";
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 0, RED, "-!- %s", msg);
|
|
|
|
}
|
|
|
|
|
|
|
|
void groupchat_onGroupModeration(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t src_peer_id,
|
|
|
|
uint32_t tgt_peer_id, TOX_GROUP_MOD_EVENT type)
|
|
|
|
{
|
|
|
|
if (self->num != groupnumber) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char src_name[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
char tgt_name[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
|
|
|
|
get_group_nick_truncate(m, src_name, src_peer_id, groupnumber);
|
|
|
|
get_group_nick_truncate(m, tgt_name, tgt_peer_id, groupnumber);
|
|
|
|
|
|
|
|
int tgt_index = get_peer_index(groupnumber, tgt_peer_id);
|
|
|
|
|
|
|
|
if (tgt_index < 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
groupchat_update_last_seen(groupnumber, src_peer_id);
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
switch (type) {
|
|
|
|
case TOX_GROUP_MOD_EVENT_KICK:
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, RED, "-!- %s has been kicked by %s", tgt_name, src_name);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case TOX_GROUP_MOD_EVENT_OBSERVER:
|
|
|
|
chat->peer_list[tgt_index].role = TOX_GROUP_ROLE_OBSERVER;
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, BLUE, "-!- %s has set %s's role to observer", src_name, tgt_name);
|
|
|
|
sort_peerlist(groupnumber);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case TOX_GROUP_MOD_EVENT_USER:
|
|
|
|
chat->peer_list[tgt_index].role = TOX_GROUP_ROLE_USER;
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, BLUE, "-!- %s has set %s's role to user", src_name, tgt_name);
|
|
|
|
sort_peerlist(groupnumber);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case TOX_GROUP_MOD_EVENT_MODERATOR:
|
|
|
|
chat->peer_list[tgt_index].role = TOX_GROUP_ROLE_MODERATOR;
|
|
|
|
line_info_add(self, timefrmt, NULL, NULL, SYS_MSG, 1, BLUE, "-!- %s has set %s's role to moderator", src_name,
|
|
|
|
tgt_name);
|
|
|
|
sort_peerlist(groupnumber);
|
|
|
|
break;
|
|
|
|
|
|
|
|
default:
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupSelfNickChange(ToxWindow *self, Tox *m, uint32_t groupnumber, const char *old_nick,
|
|
|
|
size_t old_length, const char *new_nick, size_t length)
|
|
|
|
{
|
|
|
|
UNUSED_VAR(old_length);
|
|
|
|
|
|
|
|
if (self->num != groupnumber) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
TOX_ERR_GROUP_SELF_QUERY s_err;
|
|
|
|
uint32_t peer_id = tox_group_self_get_peer_id(m, self->num, &s_err);
|
|
|
|
|
|
|
|
if (s_err != TOX_ERR_GROUP_SELF_QUERY_OK) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
int peer_index = get_peer_index(groupnumber, peer_id);
|
|
|
|
|
|
|
|
if (peer_index < 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
length = MIN(length, TOX_MAX_NAME_LENGTH - 1);
|
|
|
|
memcpy(chat->peer_list[peer_index].name, new_nick, length);
|
|
|
|
chat->peer_list[peer_index].name[length] = 0;
|
|
|
|
chat->peer_list[peer_index].name_length = length;
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
line_info_add(self, timefrmt, old_nick, chat->peer_list[peer_index].name, NAME_CHANGE, 0, MAGENTA, " is now known as ");
|
|
|
|
|
|
|
|
groupchat_update_last_seen(groupnumber, peer_id);
|
|
|
|
group_update_name_list(groupnumber);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupNickChange(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id,
|
|
|
|
const char *new_nick, size_t length)
|
|
|
|
{
|
|
|
|
if (self->num != groupnumber) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
int peer_index = get_peer_index(groupnumber, peer_id);
|
|
|
|
|
|
|
|
if (peer_index < 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
groupchat_update_last_seen(groupnumber, peer_id);
|
|
|
|
|
|
|
|
char oldnick[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
get_group_nick_truncate(m, oldnick, peer_id, groupnumber);
|
|
|
|
|
|
|
|
length = MIN(length, TOX_MAX_NAME_LENGTH - 1);
|
|
|
|
memcpy(chat->peer_list[peer_index].name, new_nick, length);
|
|
|
|
chat->peer_list[peer_index].name[length] = 0;
|
|
|
|
chat->peer_list[peer_index].name_length = length;
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
line_info_add(self, timefrmt, oldnick, chat->peer_list[peer_index].name, NAME_CHANGE, 0, MAGENTA, " is now known as ");
|
|
|
|
|
|
|
|
group_update_name_list(groupnumber);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onGroupStatusChange(ToxWindow *self, Tox *m, uint32_t groupnumber, uint32_t peer_id,
|
|
|
|
TOX_USER_STATUS status)
|
|
|
|
{
|
|
|
|
if (self->num != groupnumber) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
int peer_index = get_peer_index(groupnumber, peer_id);
|
|
|
|
|
|
|
|
if (peer_index < 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
groupchat_update_last_seen(groupnumber, peer_id);
|
|
|
|
chat->peer_list[peer_index].status = status;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void send_group_message(ToxWindow *self, Tox *m, uint32_t groupnumber, const char *msg, TOX_MESSAGE_TYPE type)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
if (msg == NULL) {
|
|
|
|
wprintw(ctx->history, "Message is empty.\n");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
TOX_ERR_GROUP_SEND_MESSAGE err;
|
|
|
|
|
|
|
|
if (!tox_group_send_message(m, groupnumber, type, (uint8_t *) msg, strlen(msg), &err)) {
|
|
|
|
if (err == TOX_ERR_GROUP_SEND_MESSAGE_PERMISSIONS) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, RED, " * You are silenced.");
|
|
|
|
} else {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, RED, " * Failed to send message (Error %d).", err);
|
|
|
|
}
|
|
|
|
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char self_nick[TOX_MAX_NAME_LENGTH + 1];
|
|
|
|
get_group_self_nick_truncate(m, self_nick, groupnumber);
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
|
|
|
|
if (type == TOX_MESSAGE_TYPE_NORMAL) {
|
|
|
|
line_info_add(self, timefrmt, self_nick, NULL, OUT_MSG_READ, 0, 0, "%s", msg);
|
|
|
|
write_to_log(msg, self_nick, ctx->log, false);
|
|
|
|
} else if (type == TOX_MESSAGE_TYPE_ACTION) {
|
|
|
|
line_info_add(self, timefrmt, self_nick, NULL, OUT_ACTION_READ, 0, 0, "%s", msg);
|
|
|
|
write_to_log(msg, self_nick, ctx->log, true);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void send_group_prvt_message(ToxWindow *self, Tox *m, uint32_t groupnumber, const char *data, size_t data_len)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(groupnumber);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, RED, "Failed to fetch GroupChat object.");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (data == NULL) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, RED, "Invalid comand.");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
uint32_t peer_id = 0;
|
|
|
|
uint32_t name_length = 0;
|
|
|
|
const char *nick = NULL;
|
|
|
|
|
|
|
|
/* need to match the longest nick in case of nicks that are smaller sub-strings */
|
|
|
|
for (uint32_t i = 0; i < chat->max_idx; ++i) {
|
|
|
|
if (!chat->peer_list[i].active) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (data_len < chat->peer_list[i].name_length) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (memcmp(chat->peer_list[i].name, data, chat->peer_list[i].name_length) == 0) {
|
|
|
|
if (chat->peer_list[i].name_length > name_length) {
|
|
|
|
name_length = chat->peer_list[i].name_length;
|
|
|
|
nick = chat->peer_list[i].name;
|
|
|
|
peer_id = chat->peer_list[i].peer_id;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (nick == NULL) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Invalid peer name.");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
int msg_len = ((int) data_len) - ((int) name_length) - 1;
|
|
|
|
|
|
|
|
if (msg_len <= 0) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, 0, "Message is empty.");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
const char *msg = data + name_length + 1;
|
|
|
|
|
|
|
|
TOX_ERR_GROUP_SEND_PRIVATE_MESSAGE err;
|
|
|
|
|
|
|
|
if (!tox_group_send_private_message(m, groupnumber, peer_id, TOX_MESSAGE_TYPE_NORMAL, (uint8_t *) msg, msg_len, &err)) {
|
|
|
|
if (err == TOX_ERR_GROUP_SEND_PRIVATE_MESSAGE_PERMISSIONS) {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, RED, " * You are silenced.");
|
|
|
|
} else {
|
|
|
|
line_info_add(self, NULL, NULL, NULL, SYS_MSG, 0, RED, " * Failed to send private message.");
|
|
|
|
}
|
|
|
|
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char pm_nick[TOX_MAX_NAME_LENGTH + 3];
|
|
|
|
snprintf(pm_nick, sizeof(pm_nick), ">%s<", nick);
|
|
|
|
|
|
|
|
char timefrmt[TIME_STR_SIZE];
|
|
|
|
get_time_str(timefrmt, sizeof(timefrmt));
|
|
|
|
|
|
|
|
line_info_add(self, timefrmt, pm_nick, NULL, OUT_PRVT_MSG, 0, 0, "%s", msg);
|
|
|
|
write_to_log(msg, pm_nick, ctx->log, false);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Return true if input is recognized by handler
|
|
|
|
*/
|
|
|
|
static bool groupchat_onKey(ToxWindow *self, Tox *m, wint_t key, bool ltr)
|
|
|
|
{
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(self->num);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
int x, y, y2, x2;
|
|
|
|
getyx(self->window, y, x);
|
|
|
|
getmaxyx(self->window, y2, x2);
|
|
|
|
|
|
|
|
UNUSED_VAR(y);
|
|
|
|
|
|
|
|
if (x2 <= 0 || y2 <= 0) {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (self->help->active) {
|
|
|
|
help_onKey(self, key);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (ctx->pastemode && key == L'\r') {
|
|
|
|
key = L'\n';
|
|
|
|
}
|
|
|
|
|
|
|
|
if (ltr || key == L'\n') { /* char is printable */
|
|
|
|
input_new_char(self, key, x, x2);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (line_info_onKey(self, key)) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (input_handle(self, key, x, x2)) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool input_ret = false;
|
|
|
|
|
|
|
|
if (key == L'\t') { /* TAB key: auto-completes peer name or command */
|
|
|
|
input_ret = true;
|
|
|
|
|
|
|
|
if (ctx->len > 0) {
|
|
|
|
int diff = -1;
|
|
|
|
|
|
|
|
/* TODO: make this not suck */
|
|
|
|
if (ctx->line[0] != L'/' || wcschr(ctx->line, L' ') != NULL) {
|
|
|
|
diff = complete_line(self, (const char **) chat->name_list, chat->num_peers);
|
|
|
|
} else if (wcsncmp(ctx->line, L"/avatar \"", wcslen(L"/avatar \"")) == 0) {
|
|
|
|
diff = dir_match(self, m, ctx->line, L"/avatar");
|
|
|
|
} else {
|
|
|
|
diff = complete_line(self, group_cmd_list, sizeof(group_cmd_list) / sizeof(char *));
|
|
|
|
}
|
|
|
|
|
|
|
|
if (diff != -1) {
|
|
|
|
if (x + diff > x2 - 1) {
|
|
|
|
int wlen = MAX(0, wcswidth(ctx->line, sizeof(ctx->line) / sizeof(wchar_t)));
|
|
|
|
ctx->start = wlen < x2 ? 0 : wlen - x2 + 1;
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
sound_notify(self, notif_error, 0, NULL);
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
sound_notify(self, notif_error, 0, NULL);
|
|
|
|
}
|
|
|
|
} else if (key == T_KEY_C_DOWN) { /* Scroll peerlist up and down one position */
|
|
|
|
input_ret = true;
|
|
|
|
int L = y2 - CHATBOX_HEIGHT - GROUP_SIDEBAR_OFFSET;
|
|
|
|
|
|
|
|
if (chat->side_pos < (int) chat->num_peers - L) {
|
|
|
|
++chat->side_pos;
|
|
|
|
}
|
|
|
|
} else if (key == T_KEY_C_UP) {
|
|
|
|
input_ret = true;
|
|
|
|
|
|
|
|
if (chat->side_pos > 0) {
|
|
|
|
--chat->side_pos;
|
|
|
|
}
|
|
|
|
} else if (key == L'\r') {
|
|
|
|
input_ret = true;
|
|
|
|
rm_trailing_spaces_buf(ctx);
|
|
|
|
|
|
|
|
if (!wstring_is_empty(ctx->line)) {
|
|
|
|
add_line_to_hist(ctx);
|
|
|
|
|
|
|
|
wstrsubst(ctx->line, L'¶', L'\n');
|
|
|
|
|
|
|
|
char line[MAX_STR_SIZE];
|
|
|
|
|
|
|
|
if (wcs_to_mbs_buf(line, ctx->line, MAX_STR_SIZE) == -1) {
|
|
|
|
memset(line, 0, sizeof(line));
|
|
|
|
}
|
|
|
|
|
|
|
|
if (line[0] == '/') {
|
|
|
|
if (strncmp(line, "/close", strlen("/close")) == 0) {
|
|
|
|
int offset = 6;
|
|
|
|
|
|
|
|
if (line[offset] != '\0') {
|
|
|
|
++offset;
|
|
|
|
}
|
|
|
|
|
|
|
|
const char *part_message = line + offset;
|
|
|
|
size_t part_length = ctx->len - offset;
|
|
|
|
|
|
|
|
if (part_length > 0) {
|
|
|
|
exit_groupchat(self, m, self->num, part_message, part_length);
|
|
|
|
} else {
|
|
|
|
exit_groupchat(self, m, self->num, user_settings->group_part_message, strlen(user_settings->group_part_message));
|
|
|
|
}
|
|
|
|
|
|
|
|
return true;
|
|
|
|
} else if (strncmp(line, "/me ", strlen("/me ")) == 0) {
|
|
|
|
send_group_message(self, m, self->num, line + 4, TOX_MESSAGE_TYPE_ACTION);
|
|
|
|
} else if (strncmp(line, "/whisper ", strlen("/whisper ")) == 0) {
|
|
|
|
send_group_prvt_message(self, m, self->num, line + 9, ctx->len - 9);
|
|
|
|
} else {
|
|
|
|
execute(ctx->history, self, m, line, GROUPCHAT_COMMAND_MODE);
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
send_group_message(self, m, self->num, line, TOX_MESSAGE_TYPE_NORMAL);
|
|
|
|
}
|
|
|
|
|
|
|
|
wclear(ctx->linewin);
|
|
|
|
wmove(self->window, y2 - CURS_Y_OFFSET, 0);
|
|
|
|
reset_buf(ctx);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return input_ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onDraw(ToxWindow *self, Tox *m)
|
|
|
|
{
|
|
|
|
|
|
|
|
int x2, y2;
|
|
|
|
getmaxyx(self->window, y2, x2);
|
|
|
|
|
|
|
|
if (x2 <= 0 || y2 <= 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
pthread_mutex_lock(&Winthread.lock);
|
|
|
|
|
|
|
|
GroupChat *chat = get_groupchat(self->num);
|
|
|
|
|
|
|
|
if (!chat) {
|
|
|
|
pthread_mutex_unlock(&Winthread.lock);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
line_info_print(self);
|
|
|
|
|
|
|
|
pthread_mutex_unlock(&Winthread.lock);
|
|
|
|
|
|
|
|
wclear(ctx->linewin);
|
|
|
|
|
|
|
|
curs_set(1);
|
|
|
|
|
|
|
|
if (ctx->len > 0) {
|
|
|
|
mvwprintw(ctx->linewin, 1, 0, "%ls", &ctx->line[ctx->start]);
|
|
|
|
}
|
|
|
|
|
|
|
|
wclear(ctx->sidebar);
|
|
|
|
mvwhline(self->window, y2 - CHATBOX_HEIGHT, 0, ACS_HLINE, x2);
|
|
|
|
|
|
|
|
if (self->show_peerlist) {
|
|
|
|
mvwvline(ctx->sidebar, 0, 0, ACS_VLINE, y2 - CHATBOX_HEIGHT);
|
|
|
|
mvwaddch(ctx->sidebar, y2 - CHATBOX_HEIGHT, 0, ACS_BTEE);
|
|
|
|
|
|
|
|
wmove(ctx->sidebar, 0, 1);
|
|
|
|
wattron(ctx->sidebar, A_BOLD);
|
|
|
|
|
|
|
|
pthread_mutex_lock(&Winthread.lock);
|
|
|
|
wprintw(ctx->sidebar, "Peers: %d\n", chat->num_peers);
|
|
|
|
pthread_mutex_unlock(&Winthread.lock);
|
|
|
|
|
|
|
|
wattroff(ctx->sidebar, A_BOLD);
|
|
|
|
|
|
|
|
mvwaddch(ctx->sidebar, 1, 0, ACS_LTEE);
|
|
|
|
mvwhline(ctx->sidebar, 1, 1, ACS_HLINE, SIDEBAR_WIDTH - 1);
|
|
|
|
|
|
|
|
int maxlines = y2 - GROUP_SIDEBAR_OFFSET - CHATBOX_HEIGHT;
|
|
|
|
uint32_t i, offset = 0;
|
|
|
|
|
|
|
|
pthread_mutex_lock(&Winthread.lock);
|
|
|
|
uint32_t max_idx = chat->max_idx;
|
|
|
|
pthread_mutex_unlock(&Winthread.lock);
|
|
|
|
|
|
|
|
for (i = 0; i < max_idx && i < maxlines; ++i) {
|
|
|
|
pthread_mutex_lock(&Winthread.lock);
|
|
|
|
|
|
|
|
if (!chat->peer_list[i].active) {
|
|
|
|
pthread_mutex_unlock(&Winthread.lock);
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
wmove(ctx->sidebar, offset + 2, 1);
|
|
|
|
|
|
|
|
int p = i + chat->side_pos;
|
|
|
|
int maxlen_offset = chat->peer_list[p].role == TOX_GROUP_ROLE_USER ? 2 : 3;
|
|
|
|
|
|
|
|
/* truncate nick to fit in side panel without modifying list */
|
|
|
|
char tmpnck[TOX_MAX_NAME_LENGTH];
|
|
|
|
int maxlen = SIDEBAR_WIDTH - maxlen_offset;
|
|
|
|
|
|
|
|
memcpy(tmpnck, chat->peer_list[p].name, maxlen);
|
|
|
|
|
|
|
|
tmpnck[maxlen] = '\0';
|
|
|
|
|
|
|
|
int namecolour = WHITE;
|
|
|
|
|
|
|
|
if (chat->peer_list[p].status == TOX_USER_STATUS_AWAY) {
|
|
|
|
namecolour = YELLOW;
|
|
|
|
} else if (chat->peer_list[p].status == TOX_USER_STATUS_BUSY) {
|
|
|
|
namecolour = RED;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Signify roles (e.g. founder, moderator) */
|
|
|
|
const char *rolesig = "";
|
|
|
|
int rolecolour = WHITE;
|
|
|
|
|
|
|
|
if (chat->peer_list[p].role == TOX_GROUP_ROLE_FOUNDER) {
|
|
|
|
rolesig = "&";
|
|
|
|
rolecolour = BLUE;
|
|
|
|
} else if (chat->peer_list[p].role == TOX_GROUP_ROLE_MODERATOR) {
|
|
|
|
rolesig = "+";
|
|
|
|
rolecolour = GREEN;
|
|
|
|
} else if (chat->peer_list[p].role == TOX_GROUP_ROLE_OBSERVER) {
|
|
|
|
rolesig = "-";
|
|
|
|
rolecolour = MAGENTA;
|
|
|
|
}
|
|
|
|
|
|
|
|
pthread_mutex_unlock(&Winthread.lock);
|
|
|
|
|
|
|
|
wattron(ctx->sidebar, COLOR_PAIR(rolecolour) | A_BOLD);
|
|
|
|
wprintw(ctx->sidebar, "%s", rolesig);
|
|
|
|
wattroff(ctx->sidebar, COLOR_PAIR(rolecolour) | A_BOLD);
|
|
|
|
|
|
|
|
wattron(ctx->sidebar, COLOR_PAIR(namecolour));
|
|
|
|
wprintw(ctx->sidebar, "%s\n", tmpnck);
|
|
|
|
wattroff(ctx->sidebar, COLOR_PAIR(namecolour));
|
|
|
|
|
|
|
|
++offset;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
int y, x;
|
|
|
|
getyx(self->window, y, x);
|
|
|
|
(void) x;
|
|
|
|
int new_x = ctx->start ? x2 - 1 : MAX(0, wcswidth(ctx->line, ctx->pos));
|
|
|
|
wmove(self->window, y + 1, new_x);
|
|
|
|
|
|
|
|
wrefresh(self->window);
|
|
|
|
|
|
|
|
if (self->help->active) {
|
|
|
|
help_onDraw(self);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void groupchat_onInit(ToxWindow *self, Tox *m)
|
|
|
|
{
|
|
|
|
int x2, y2;
|
|
|
|
getmaxyx(self->window, y2, x2);
|
|
|
|
|
|
|
|
if (x2 <= 0 || y2 <= 0) {
|
|
|
|
exit_toxic_err("failed in groupchat_onInit", FATALERR_CURSES);
|
|
|
|
}
|
|
|
|
|
|
|
|
ChatContext *ctx = self->chatwin;
|
|
|
|
|
|
|
|
ctx->history = subwin(self->window, y2 - CHATBOX_HEIGHT + 1, x2 - SIDEBAR_WIDTH - 1, 0, 0);
|
|
|
|
ctx->linewin = subwin(self->window, CHATBOX_HEIGHT, x2, y2 - CHATBOX_HEIGHT, 0);
|
|
|
|
ctx->sidebar = subwin(self->window, y2 - CHATBOX_HEIGHT + 1, SIDEBAR_WIDTH, 0, x2 - SIDEBAR_WIDTH);
|
|
|
|
|
|
|
|
ctx->hst = calloc(1, sizeof(struct history));
|
|
|
|
ctx->log = calloc(1, sizeof(struct chatlog));
|
|
|
|
|
|
|
|
if (ctx->log == NULL || ctx->hst == NULL) {
|
|
|
|
exit_toxic_err("failed in groupchat_onInit", FATALERR_MEMORY);
|
|
|
|
}
|
|
|
|
|
|
|
|
line_info_init(ctx->hst);
|
|
|
|
|
|
|
|
scrollok(ctx->history, 0);
|
|
|
|
wmove(self->window, y2 - CURS_Y_OFFSET, 0);
|
|
|
|
}
|
|
|
|
|
|
|
|
static ToxWindow *new_group_chat(Tox *m, uint32_t groupnumber, const char *groupname, int length)
|
|
|
|
{
|
|
|
|
ToxWindow *ret = calloc(1, sizeof(ToxWindow));
|
|
|
|
|
|
|
|
if (ret == NULL) {
|
|
|
|
exit_toxic_err("failed in new_group_chat", FATALERR_MEMORY);
|
|
|
|
}
|
|
|
|
|
|
|
|
ret->type = WINDOW_TYPE_GROUPCHAT;
|
|
|
|
|
|
|
|
ret->onKey = &groupchat_onKey;
|
|
|
|
ret->onDraw = &groupchat_onDraw;
|
|
|
|
ret->onInit = &groupchat_onInit;
|
|
|
|
ret->onGroupMessage = &groupchat_onGroupMessage;
|
|
|
|
ret->onGroupPrivateMessage = &groupchat_onGroupPrivateMessage;
|
|
|
|
ret->onGroupPeerJoin = &groupchat_onGroupPeerJoin;
|
|
|
|
ret->onGroupPeerExit = &groupchat_onGroupPeerExit;
|
|
|
|
ret->onGroupTopicChange = &groupchat_onGroupTopicChange;
|
|
|
|
ret->onGroupPeerLimit = &groupchat_onGroupPeerLimit;
|
|
|
|
ret->onGroupPrivacyState = &groupchat_onGroupPrivacyState;
|
|
|
|
ret->onGroupPassword = &groupchat_onGroupPassword;
|
|
|
|
ret->onGroupNickChange = &groupchat_onGroupNickChange;
|
|
|
|
ret->onGroupStatusChange = &groupchat_onGroupStatusChange;
|
|
|
|
ret->onGroupSelfJoin = &groupchat_onGroupSelfJoin;
|
|
|
|
ret->onGroupRejected = &groupchat_onGroupRejected;
|
|
|
|
ret->onGroupModeration = &groupchat_onGroupModeration;
|
|
|
|
|
|
|
|
ChatContext *chatwin = calloc(1, sizeof(ChatContext));
|
|
|
|
Help *help = calloc(1, sizeof(Help));
|
|
|
|
|
|
|
|
if (chatwin == NULL || help == NULL) {
|
|
|
|
exit_toxic_err("failed in new_group_chat", FATALERR_MEMORY);
|
|
|
|
}
|
|
|
|
|
|
|
|
ret->chatwin = chatwin;
|
|
|
|
ret->help = help;
|
|
|
|
|
|
|
|
ret->num = groupnumber;
|
|
|
|
ret->show_peerlist = true;
|
|
|
|
ret->active_box = -1;
|
|
|
|
|
|
|
|
if (groupname && length > 0) {
|
|
|
|
set_window_title(ret, groupname, length);
|
|
|
|
} else {
|
|
|
|
snprintf(ret->name, sizeof(ret->name), "Group %u", groupnumber);
|
|
|
|
}
|
|
|
|
|
|
|
|
return ret;
|
|
|
|
}
|