mirror of
https://github.com/Tha14/toxic.git
synced 2025-06-26 22:56:46 +02:00
Compare commits
42 Commits
Author | SHA1 | Date | |
---|---|---|---|
fd263e3e0a | |||
15ab58aa13 | |||
b91f5a8758 | |||
cec96e1ea3 | |||
eb7e6151a2 | |||
22ca3704d2 | |||
fdfaaf953f | |||
310cf464d0 | |||
0c11b3121a | |||
1bdf0041bc | |||
6a203fd7bf | |||
93b3bbd5f6 | |||
e122c5dbca | |||
f6f41a510b | |||
05dbc626e2 | |||
ceb175e3f1 | |||
4bd1d9bfee | |||
55944aa5a9 | |||
b71c6a3792 | |||
0239509439 | |||
602d9d97c1 | |||
6f8f6f0ac5 | |||
8d58e8f4d6 | |||
b6f892edf5 | |||
f91d10c831 | |||
3f18c6f8de | |||
bf1e1b73fc | |||
3eac65036c | |||
85f9ec6b9a | |||
5230616a9d | |||
8e0e318df1 | |||
701c0e1e94 | |||
71f6a8d4d6 | |||
1cace1e81d | |||
3030cda47e | |||
2946e0dc56 | |||
da90ca8b74 | |||
17e5cc1147 | |||
d02ac24de8 | |||
64794e14cd | |||
f39da4d7f2 | |||
af70c3d660 |
12
.cirrus.yml
Normal file
12
.cirrus.yml
Normal file
@ -0,0 +1,12 @@
|
||||
---
|
||||
bazel-opt_task:
|
||||
container:
|
||||
image: toxchat/toktok-stack:latest-release
|
||||
cpu: 2
|
||||
memory: 2G
|
||||
configure_script:
|
||||
- /src/workspace/tools/inject-repo toxic
|
||||
test_all_script:
|
||||
- cd /src/workspace && bazel test -k
|
||||
--remote_http_cache=http://$CIRRUS_HTTP_CACHE_HOST
|
||||
//toxic/...
|
8
.github/settings.yml
vendored
8
.github/settings.yml
vendored
@ -11,7 +11,9 @@ branches:
|
||||
protection:
|
||||
required_status_checks:
|
||||
contexts:
|
||||
- Codacy/PR Quality Review
|
||||
- CodeFactor
|
||||
- Travis CI - Pull Request
|
||||
- build
|
||||
- build-static
|
||||
- bazel-opt
|
||||
- Codacy Static Code Analysis
|
||||
- code-review/reviewable
|
||||
- infer
|
||||
|
125
.github/workflows/ci.yml
vendored
Normal file
125
.github/workflows/ci.yml
vendored
Normal file
@ -0,0 +1,125 @@
|
||||
name: ci
|
||||
|
||||
on:
|
||||
push:
|
||||
branches: [master]
|
||||
pull_request:
|
||||
branches: [master]
|
||||
|
||||
jobs:
|
||||
build:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- uses: actions/checkout@v2
|
||||
- name: Install dependencies
|
||||
run:
|
||||
sudo apt-get update &&
|
||||
sudo apt-get install -y --no-install-recommends
|
||||
libalut-dev
|
||||
libconfig-dev
|
||||
libcurl4-gnutls-dev
|
||||
libmsgpack-dev
|
||||
libnotify-dev
|
||||
libopenal-dev
|
||||
libopus-dev
|
||||
libqrencode-dev
|
||||
libsodium-dev
|
||||
libvpx-dev
|
||||
libx11-dev
|
||||
python3-dev
|
||||
pkg-config &&
|
||||
git clone --depth=1 https://github.com/TokTok/c-toxcore &&
|
||||
cd c-toxcore &&
|
||||
cmake . -B_build -DBOOTSTRAP_DAEMON=OFF &&
|
||||
cd _build &&
|
||||
make -j4 &&
|
||||
sudo make install
|
||||
|
||||
- name: Build toxic
|
||||
run: make -j4
|
||||
|
||||
build-static:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- name: Checkout code
|
||||
uses: actions/checkout@v2
|
||||
- name: Build minimal static toxic binary
|
||||
run: docker run --rm
|
||||
-v /tmp/artifact:/artifact
|
||||
-v $PWD:/toxic
|
||||
amd64/alpine:latest
|
||||
sh -c 'yes | /toxic/script/build-minimal-static-toxic.sh'
|
||||
- name: Display binary checksum
|
||||
run: |
|
||||
tar Jxf /tmp/artifact/toxic-minimal-static-musl_linux_x86-64.tar.xz
|
||||
sha256sum toxic-minimal-static-musl_linux_x86-64/toxic
|
||||
|
||||
infer:
|
||||
runs-on: ubuntu-latest
|
||||
container: toxchat/infer
|
||||
steps:
|
||||
- name: Install git
|
||||
run:
|
||||
apt-get update &&
|
||||
DEBIAN_FRONTEND=noninteractive
|
||||
apt-get install -y --no-install-recommends
|
||||
git
|
||||
- name: Install dependencies
|
||||
run:
|
||||
apt-get update &&
|
||||
apt-get install -y --no-install-recommends
|
||||
cmake
|
||||
g++
|
||||
libalut-dev
|
||||
libconfig-dev
|
||||
libcurl4-gnutls-dev
|
||||
libmsgpack-dev
|
||||
libncurses-dev
|
||||
libnotify-dev
|
||||
libopenal-dev
|
||||
libopus-dev
|
||||
libqrencode-dev
|
||||
libsodium-dev
|
||||
libvpx-dev
|
||||
libx11-dev
|
||||
make
|
||||
python3-dev
|
||||
pkg-config &&
|
||||
git clone --depth=1 https://github.com/TokTok/c-toxcore &&
|
||||
cd c-toxcore &&
|
||||
cmake . -B_build -DBOOTSTRAP_DAEMON=OFF &&
|
||||
cd _build &&
|
||||
make -j4 &&
|
||||
make install
|
||||
- uses: actions/checkout@v2
|
||||
|
||||
- name: Run infer
|
||||
run:
|
||||
infer --no-progress-bar -- cc src/*.c
|
||||
-fsyntax-only
|
||||
$(python3-config --includes --ldflags)
|
||||
$(pkg-config --cflags --libs
|
||||
freealut
|
||||
libconfig
|
||||
libcurl
|
||||
libnotify
|
||||
libpng
|
||||
libqrencode
|
||||
msgpack
|
||||
ncurses
|
||||
openal
|
||||
python3
|
||||
toxcore
|
||||
vpx
|
||||
x11)
|
||||
-DAUDIO
|
||||
-DBOX_NOTIFY
|
||||
-DGAMES
|
||||
-DPACKAGE_DATADIR='""'
|
||||
-DPYTHON
|
||||
-DQRCODE
|
||||
-DSOUND_NOTIFY
|
||||
-DVIDEO
|
||||
- name: Print log
|
||||
run:
|
||||
cat /__w/toxic/toxic/infer-out/report.txt
|
60
.travis.yml
60
.travis.yml
@ -1,60 +0,0 @@
|
||||
---
|
||||
language: python
|
||||
python: nightly
|
||||
dist: xenial
|
||||
os: linux
|
||||
|
||||
jobs:
|
||||
include:
|
||||
- env: JOB=linux
|
||||
|
||||
addons:
|
||||
apt:
|
||||
packages:
|
||||
- libalut-dev
|
||||
- libconfig-dev
|
||||
- libnotify-dev
|
||||
- libopenal-dev
|
||||
- libopus-dev
|
||||
- libqrencode-dev
|
||||
- libvpx-dev
|
||||
|
||||
cache:
|
||||
directories:
|
||||
- $HOME/cache
|
||||
|
||||
install:
|
||||
# Where to find libraries.
|
||||
- export LD_LIBRARY_PATH=$HOME/cache/usr/lib
|
||||
- export PKG_CONFIG_PATH=$HOME/cache/usr/lib/pkgconfig
|
||||
# c-sodium
|
||||
- git clone --depth=1 --branch=stable https://github.com/jedisct1/libsodium ../libsodium
|
||||
- test -f $HOME/cache/usr/lib/libsodium.so || (cd ../libsodium && ./configure --prefix=$HOME/cache/usr && make install -j$(nproc))
|
||||
# c-toxcore
|
||||
- git clone --depth=1 https://github.com/TokTok/c-toxcore ../c-toxcore
|
||||
- test -f $HOME/cache/usr/lib/libtoxcore.so || (cd ../c-toxcore && cmake -B_build -H. -DCMAKE_INSTALL_PREFIX:PATH=$HOME/cache/usr && make -C_build install -j$(nproc))
|
||||
|
||||
script:
|
||||
- make ENABLE_PYTHON=1 -j$(nproc)
|
||||
|
||||
- env: JOB=macos
|
||||
os: macos
|
||||
language: c
|
||||
|
||||
cache:
|
||||
directories:
|
||||
- $HOME/cache
|
||||
|
||||
install:
|
||||
- brew install
|
||||
freealut
|
||||
libconfig
|
||||
libqrencode
|
||||
libsodium
|
||||
openal-soft
|
||||
- export LDFLAGS="-L/usr/local/Cellar/openal-soft/1.21.0/lib"
|
||||
- git clone --depth=1 https://github.com/TokTok/c-toxcore ../c-toxcore
|
||||
- test -f /usr/local/lib/libtoxcore.dylib || (cd ../c-toxcore && cmake -B_build -H. && make -C_build install -j$(nproc))
|
||||
|
||||
script:
|
||||
- make ENABLE_PYTHON=1 DISABLE_DESKTOP_NOTIFY=1 DISABLE_X11=1 DISABLE_AV=1 DISABLE_SOUND_NOTIFY=1 -j$(nproc)
|
10
BUILD.bazel
10
BUILD.bazel
@ -1,6 +1,8 @@
|
||||
load("@rules_cc//cc:defs.bzl", "cc_binary")
|
||||
load("//tools/project:build_defs.bzl", "project")
|
||||
|
||||
package(features = ["layering_check"])
|
||||
|
||||
project()
|
||||
|
||||
cc_binary(
|
||||
@ -18,6 +20,7 @@ cc_binary(
|
||||
copts = [
|
||||
"-std=gnu99",
|
||||
"-DAUDIO",
|
||||
"-DGAMES",
|
||||
"-DPACKAGE_DATADIR='\"data\"'",
|
||||
"-DPYTHON",
|
||||
"-DQRCODE",
|
||||
@ -39,3 +42,10 @@ cc_binary(
|
||||
"//tools/config:osx": [],
|
||||
}),
|
||||
)
|
||||
|
||||
sh_test(
|
||||
name = "toxic_test",
|
||||
size = "small",
|
||||
srcs = [":toxic"],
|
||||
args = ["--help"],
|
||||
)
|
||||
|
2
Makefile
2
Makefile
@ -14,7 +14,7 @@ LDFLAGS += ${USER_LDFLAGS}
|
||||
|
||||
OBJ = autocomplete.o avatars.o bootstrap.o chat.o chat_commands.o configdir.o curl_util.o execute.o
|
||||
OBJ += file_transfers.o friendlist.o global_commands.o conference_commands.o conference.o help.o input.o line_info.o
|
||||
OBJ += log.o message_queue.o misc_tools.o name_lookup.o notify.o prompt.o qr_code.o settings.o
|
||||
OBJ += log.o message_queue.o misc_tools.o name_lookup.o netprof.o notify.o prompt.o qr_code.o settings.o
|
||||
OBJ += term_mplex.o toxic.o toxic_strings.o windows.o
|
||||
|
||||
# Check if debug build is enabled
|
||||
|
@ -55,9 +55,9 @@ author = 'Jakob Kreuze'
|
||||
# built documents.
|
||||
#
|
||||
# The short X.Y version.
|
||||
version = '0.11.2'
|
||||
version = '0.11.3'
|
||||
# The full version, including alpha/beta/rc tags.
|
||||
release = '0.11.2'
|
||||
release = '0.11.3'
|
||||
|
||||
# The language for content autogenerated by Sphinx. Refer to documentation
|
||||
# for a list of supported languages.
|
||||
@ -151,4 +151,4 @@ texinfo_documents = [
|
||||
(master_doc, 'toxic_api', 'toxic_api Documentation',
|
||||
author, 'toxic_api', 'One line description of project.',
|
||||
'Miscellaneous'),
|
||||
]
|
||||
]
|
||||
|
@ -1,5 +1,5 @@
|
||||
# Version
|
||||
TOXIC_VERSION = 0.11.2
|
||||
TOXIC_VERSION = 0.11.3
|
||||
REV = $(shell git rev-list HEAD --count 2>/dev/null || echo -n "error")
|
||||
ifneq (, $(findstring error, $(REV)))
|
||||
VERSION = $(TOXIC_VERSION)
|
||||
|
@ -138,6 +138,11 @@ Show welcome message on startup\&. true or false
|
||||
Enable friend connection change notifications\&. true or false
|
||||
.RE
|
||||
.PP
|
||||
\fBshow_network_info\fR
|
||||
.RS 4
|
||||
Show network information in the UI home window\&. true or false
|
||||
.RE
|
||||
.PP
|
||||
\fBnodelist_update_freq\fR
|
||||
.RS 4
|
||||
How often in days to update the DHT nodes list\&. (integer; 0 to disable)
|
||||
|
@ -87,6 +87,9 @@ OPTIONS
|
||||
*show_connection_msg*;;
|
||||
Enable friend connection change notifications. true or false
|
||||
|
||||
*show_network_info*;;
|
||||
Show network information in the UI home window. true or false
|
||||
|
||||
*nodelist_update_freq*;;
|
||||
How often in days to update the DHT nodes list. (integer; 0 to disable)
|
||||
|
||||
|
@ -56,6 +56,9 @@ ui = {
|
||||
// true to show friend connection change messages on the home screen
|
||||
show_connection_msg=true;
|
||||
|
||||
// true to show network information in the UI home window
|
||||
show_network_info=true;
|
||||
|
||||
// How often in days to update the DHT nodes list. (0 to disable updates)
|
||||
nodeslist_update_freq=7;
|
||||
|
||||
|
@ -2,7 +2,7 @@
|
||||
|
||||
# MIT License
|
||||
#
|
||||
# Copyright (c) 2021 Maxim Biro <nurupo.contributions@gmail.com>
|
||||
# Copyright (c) 2021-2022 Maxim Biro <nurupo.contributions@gmail.com>
|
||||
#
|
||||
# Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
# of this software and associated documentation files (the "Software"), to deal
|
||||
@ -36,8 +36,19 @@
|
||||
#
|
||||
# that would use Toxic code from /home/jfreegman/git/toxic and place the build
|
||||
# artifact at /tmp/artifact.
|
||||
# You can change between amd64/alpine:latest and i386/alpine:latest, for 64-bit
|
||||
# and 32-bit builds.
|
||||
#
|
||||
# You can change between:
|
||||
# amd64/alpine:latest,
|
||||
# i386/alpine:latest,
|
||||
# arm64v8/alpine:latest,
|
||||
# arm32v7/alpine:latest,
|
||||
# arm32v6/alpine:latest,
|
||||
# ppc64le/alpine:latest,
|
||||
# s390x/alpine:latest,
|
||||
# etc.
|
||||
# as long as your system can run foreign architecture binaries, e.g. via qemu
|
||||
# static bins and binfmt (install qemu-user-static package on Debian/Ubuntu).
|
||||
#
|
||||
#
|
||||
# To debug, run:
|
||||
#
|
||||
@ -53,13 +64,6 @@ set -eu
|
||||
ARTIFACT_DIR="/artifact"
|
||||
TOXIC_SRC_DIR="/toxic"
|
||||
|
||||
# Make sure we run in the expected environment
|
||||
if ! grep -q 'docker' /proc/1/cgroup
|
||||
then
|
||||
echo "Error: This script should be run inside a disposable Docker container as it might modify system files in ways that would break a real system."
|
||||
exit 1
|
||||
fi
|
||||
|
||||
if [ ! -f /etc/os-release ] || ! grep -qi 'Alpine Linux' /etc/os-release
|
||||
then
|
||||
echo "Error: This script expects to be run on Alpine Linux."
|
||||
@ -110,6 +114,7 @@ apk add \
|
||||
libsodium-dev \
|
||||
libsodium-static \
|
||||
linux-headers \
|
||||
msgpack-c-dev \
|
||||
ncurses-dev \
|
||||
ncurses-static \
|
||||
ncurses-terminfo \
|
||||
@ -132,10 +137,10 @@ mkdir -p "$BUILD_DIR"
|
||||
cd "$BUILD_DIR"
|
||||
|
||||
# The git hash of the c-toxcore version we're using
|
||||
TOXCORE_VERSION="af1848ed13d2aa3a7fc218de1d0633e99814efec"
|
||||
TOXCORE_VERSION="v0.2.16"
|
||||
|
||||
# The sha256sum of the c-toxcore tarball for TOXCORE_VERSION
|
||||
TOXCORE_HASH="acd1117b752583eb7d97aabc1053275ffa5f92591e166687a17c7267201a2e18"
|
||||
TOXCORE_HASH="653aa42654b607f0940cecfac873e9ce55605119a90d1dc454d1090ff6ca29c0"
|
||||
|
||||
TOXCORE_FILENAME="c-toxcore-$TOXCORE_VERSION.tar.gz"
|
||||
|
||||
@ -164,8 +169,8 @@ cmake --build _build --target install
|
||||
# location with SSL_CERT_FILE env variable.
|
||||
cd "$BUILD_DIR"
|
||||
|
||||
CURL_VERSION="7.80.0"
|
||||
CURL_HASH="dab997c9b08cb4a636a03f2f7f985eaba33279c1c52692430018fae4a4878dc7"
|
||||
CURL_VERSION="7.81.0"
|
||||
CURL_HASH="ac8e1087711084548d788ef18b9b732c8de887457b81f616fc681d1044b32f98"
|
||||
CURL_FILENAME="curl-$CURL_VERSION.tar.gz"
|
||||
|
||||
wget --timeout=10 -O "$CURL_FILENAME" "https://curl.haxx.se/download/$CURL_FILENAME"
|
||||
@ -186,7 +191,8 @@ cd curl*
|
||||
--with-openssl
|
||||
make
|
||||
make install
|
||||
sed -i 's|-lbrotlidec |-lbrotlidec-static -lbrotlicommon-static |g' $BUILD_DIR/prefix-curl/lib/pkgconfig/libcurl.pc
|
||||
sed -i 's|-lbrotlidec |-lbrotlidec -lbrotlicommon |g' $BUILD_DIR/prefix-curl/lib/pkgconfig/libcurl.pc
|
||||
|
||||
|
||||
# Build Toxic
|
||||
cd "$BUILD_DIR"
|
||||
@ -301,4 +307,3 @@ mv "$PREPARE_ARTIFACT_DIR" "$PREPARE_ARTIFACT_DIR/../$ARTIFACT_NAME"
|
||||
tar -cJf "$ARTIFACT_NAME.tar.xz" "$ARTIFACT_NAME"
|
||||
mv "$ARTIFACT_NAME.tar.xz" "$ARTIFACT_DIR"
|
||||
chmod 777 -R "$ARTIFACT_DIR"
|
||||
|
||||
|
@ -41,9 +41,6 @@ Tox *user_tox;
|
||||
static WINDOW *cur_window;
|
||||
static ToxWindow *self_window;
|
||||
|
||||
extern FriendsList Friends;
|
||||
extern struct user_settings *user_settings;
|
||||
|
||||
void api_display(const char *const msg)
|
||||
{
|
||||
if (msg == NULL) {
|
||||
|
@ -60,14 +60,8 @@
|
||||
#endif /* ALC_ALL_DEVICES_SPECIFIER */
|
||||
#endif /* __APPLE__ */
|
||||
|
||||
extern FriendsList Friends;
|
||||
extern ToxWindow *windows[MAX_WINDOWS_NUM];
|
||||
|
||||
struct CallControl CallControl;
|
||||
|
||||
extern struct user_settings *user_settings;
|
||||
extern struct Winthread Winthread;
|
||||
|
||||
void on_call(ToxAV *av, uint32_t friend_number, bool audio_enabled, bool video_enabled,
|
||||
void *user_data);
|
||||
void on_call_state(ToxAV *av, uint32_t friend_number, uint32_t state, void *user_data);
|
||||
|
@ -530,7 +530,7 @@ static DeviceError open_device(DeviceType type, uint32_t *device_idx, DataHandle
|
||||
device->cb_data = cb_data;
|
||||
#ifdef AUDIO
|
||||
|
||||
if (user_settings->VAD_threshold >= 0.0f) {
|
||||
if (user_settings->VAD_threshold >= 0.0) {
|
||||
device->VAD_threshold = user_settings->VAD_threshold;
|
||||
}
|
||||
|
||||
|
@ -56,7 +56,7 @@ static void print_ac_matches(ToxWindow *self, Tox *m, char **list, size_t n_matc
|
||||
*
|
||||
* Returns the length of the match.
|
||||
*/
|
||||
static size_t get_str_match(ToxWindow *self, char *match, size_t match_sz, const char **matches, size_t n_items,
|
||||
static size_t get_str_match(ToxWindow *self, char *match, size_t match_sz, const char *const *matches, size_t n_items,
|
||||
size_t max_size)
|
||||
{
|
||||
UNUSED_VAR(self);
|
||||
@ -96,7 +96,7 @@ static size_t get_str_match(ToxWindow *self, char *match, size_t match_sz, const
|
||||
*
|
||||
* Note: This function should not be called directly. Use complete_line() and complete_path() instead.
|
||||
*/
|
||||
static int complete_line_helper(ToxWindow *self, const char **list, const size_t n_items, bool dir_search)
|
||||
static int complete_line_helper(ToxWindow *self, const char *const *list, const size_t n_items, bool dir_search)
|
||||
{
|
||||
ChatContext *ctx = self->chatwin;
|
||||
|
||||
@ -181,7 +181,7 @@ static int complete_line_helper(ToxWindow *self, const char **list, const size_t
|
||||
}
|
||||
|
||||
char match[MAX_STR_SIZE];
|
||||
size_t match_len = get_str_match(self, match, sizeof(match), (const char **) matches, n_matches, MAX_STR_SIZE);
|
||||
size_t match_len = get_str_match(self, match, sizeof(match), (const char *const *) matches, n_matches, MAX_STR_SIZE);
|
||||
|
||||
free_ptr_array((void **) matches);
|
||||
|
||||
@ -259,12 +259,12 @@ static int complete_line_helper(ToxWindow *self, const char **list, const size_t
|
||||
return diff;
|
||||
}
|
||||
|
||||
int complete_line(ToxWindow *self, const char **list, size_t n_items)
|
||||
int complete_line(ToxWindow *self, const char *const *list, size_t n_items)
|
||||
{
|
||||
return complete_line_helper(self, list, n_items, false);
|
||||
}
|
||||
|
||||
static int complete_path(ToxWindow *self, const char **list, const size_t n_items)
|
||||
static int complete_path(ToxWindow *self, const char *const *list, const size_t n_items)
|
||||
{
|
||||
return complete_line_helper(self, list, n_items, true);
|
||||
}
|
||||
@ -385,7 +385,7 @@ int dir_match(ToxWindow *self, Tox *m, const wchar_t *line, const wchar_t *cmd)
|
||||
print_ac_matches(self, m, dirnames, dircount);
|
||||
}
|
||||
|
||||
int ret = complete_path(self, (const char **) dirnames, dircount);
|
||||
int ret = complete_path(self, (const char *const *) dirnames, dircount);
|
||||
|
||||
free_ptr_array((void **) dirnames);
|
||||
|
||||
|
@ -39,9 +39,7 @@
|
||||
#include "settings.h"
|
||||
#include "windows.h"
|
||||
|
||||
extern struct arg_opts arg_opts;
|
||||
extern struct user_settings *user_settings;
|
||||
extern struct Winthread Winthread;
|
||||
|
||||
/* URL that we get the JSON encoded nodes list from. */
|
||||
#define NODES_LIST_URL "https://nodes.tox.chat/json"
|
||||
@ -59,7 +57,6 @@ extern struct Winthread Winthread;
|
||||
|
||||
#define IP_MAX_SIZE 45
|
||||
#define IP_MIN_SIZE 7
|
||||
#define PORT_MAX_SIZE 5
|
||||
|
||||
#define LAST_SCAN_JSON_KEY "\"last_scan\":"
|
||||
#define LAST_SCAN_JSON_KEY_LEN (sizeof(LAST_SCAN_JSON_KEY) - 1)
|
||||
|
91
src/chat.c
91
src/chat.c
@ -58,12 +58,6 @@
|
||||
#endif /* VIDEO */
|
||||
#endif /* AUDIO */
|
||||
|
||||
extern char *DATA_FILE;
|
||||
extern FriendsList Friends;
|
||||
|
||||
extern struct Winthread Winthread;
|
||||
extern struct user_settings *user_settings;
|
||||
|
||||
#ifdef AUDIO
|
||||
static void init_infobox(ToxWindow *self);
|
||||
static void kill_infobox(ToxWindow *self);
|
||||
@ -136,7 +130,7 @@ static void set_self_typingstatus(ToxWindow *self, Tox *m, bool is_typing)
|
||||
|
||||
ChatContext *ctx = self->chatwin;
|
||||
|
||||
TOX_ERR_SET_TYPING err;
|
||||
Tox_Err_Set_Typing err;
|
||||
tox_self_set_typing(m, self->num, is_typing, &err);
|
||||
|
||||
if (err != TOX_ERR_SET_TYPING_OK) {
|
||||
@ -254,6 +248,7 @@ static void chat_onConnectionChange(ToxWindow *self, Tox *m, uint32_t num, Tox_C
|
||||
|
||||
if (prev_status == TOX_CONNECTION_NONE) {
|
||||
chat_resume_file_senders(self, m, num);
|
||||
file_send_queue_check(self, m, self->num);
|
||||
|
||||
msg = "has come online";
|
||||
line_info_add(self, true, nick, NULL, CONNECTION, 0, GREEN, msg);
|
||||
@ -681,8 +676,10 @@ static void chat_onFileRecv(ToxWindow *self, Tox *m, uint32_t friendnum, uint32_
|
||||
FILE *filecheck = NULL;
|
||||
int count = 1;
|
||||
|
||||
while ((filecheck = fopen(file_path, "r"))) {
|
||||
fclose(filecheck);
|
||||
while ((filecheck = fopen(file_path, "r")) || file_transfer_recv_path_exists(file_path)) {
|
||||
if (filecheck) {
|
||||
fclose(filecheck);
|
||||
}
|
||||
|
||||
file_path[path_len] = '\0';
|
||||
char d[5];
|
||||
@ -798,12 +795,7 @@ void chat_onGameInvite(ToxWindow *self, Tox *m, uint32_t friend_number, const ui
|
||||
return;
|
||||
}
|
||||
|
||||
Friends.list[friend_number].game_invite.type = type;
|
||||
Friends.list[friend_number].game_invite.id = id;
|
||||
Friends.list[friend_number].game_invite.pending = true;
|
||||
|
||||
uint32_t data_length = length - GAME_PACKET_HEADER_SIZE;
|
||||
Friends.list[friend_number].game_invite.data_length = data_length;
|
||||
|
||||
if (data_length > 0) {
|
||||
free(Friends.list[friend_number].game_invite.data);
|
||||
@ -818,6 +810,11 @@ void chat_onGameInvite(ToxWindow *self, Tox *m, uint32_t friend_number, const ui
|
||||
Friends.list[friend_number].game_invite.data = buf;
|
||||
}
|
||||
|
||||
Friends.list[friend_number].game_invite.type = type;
|
||||
Friends.list[friend_number].game_invite.id = id;
|
||||
Friends.list[friend_number].game_invite.pending = true;
|
||||
Friends.list[friend_number].game_invite.data_length = data_length;
|
||||
|
||||
char name[TOX_MAX_NAME_LENGTH];
|
||||
get_nick_truncate(m, name, friend_number);
|
||||
|
||||
@ -1270,9 +1267,16 @@ static void chat_onDraw(ToxWindow *self, Tox *m)
|
||||
}
|
||||
|
||||
ChatContext *ctx = self->chatwin;
|
||||
StatusBar *statusbar = self->stb;
|
||||
|
||||
pthread_mutex_lock(&Winthread.lock);
|
||||
|
||||
line_info_print(self);
|
||||
|
||||
Tox_Connection connection = statusbar->connection;
|
||||
Tox_User_Status status = statusbar->status;
|
||||
const bool is_typing = Friends.list[self->num].is_typing;
|
||||
|
||||
pthread_mutex_unlock(&Winthread.lock);
|
||||
|
||||
wclear(ctx->linewin);
|
||||
@ -1283,14 +1287,6 @@ static void chat_onDraw(ToxWindow *self, Tox *m)
|
||||
|
||||
curs_set(1);
|
||||
|
||||
/* Draw status bar */
|
||||
StatusBar *statusbar = self->stb;
|
||||
|
||||
pthread_mutex_lock(&Winthread.lock);
|
||||
Tox_Connection connection = statusbar->connection;
|
||||
Tox_User_Status status = statusbar->status;
|
||||
pthread_mutex_unlock(&Winthread.lock);
|
||||
|
||||
wmove(statusbar->topline, 0, 0);
|
||||
|
||||
wattron(statusbar->topline, COLOR_PAIR(BAR_ACCENT));
|
||||
@ -1318,13 +1314,13 @@ static void chat_onDraw(ToxWindow *self, Tox *m)
|
||||
}
|
||||
|
||||
wattron(statusbar->topline, COLOR_PAIR(BAR_ACCENT));
|
||||
wprintw(statusbar->topline, "]");
|
||||
wprintw(statusbar->topline, "] ");
|
||||
wattroff(statusbar->topline, COLOR_PAIR(BAR_ACCENT));
|
||||
|
||||
if (status != TOX_USER_STATUS_NONE) {
|
||||
const char *status_text = "ERROR";
|
||||
int colour = MAGENTA;
|
||||
const char *status_text = "ERROR";
|
||||
int colour = BAR_TEXT;
|
||||
|
||||
if (connection != TOX_CONNECTION_NONE) {
|
||||
switch (status) {
|
||||
case TOX_USER_STATUS_AWAY:
|
||||
colour = STATUS_AWAY;
|
||||
@ -1339,9 +1335,11 @@ static void chat_onDraw(ToxWindow *self, Tox *m)
|
||||
default:
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (colour != BAR_TEXT) {
|
||||
wattron(statusbar->topline, COLOR_PAIR(BAR_ACCENT));
|
||||
wprintw(statusbar->topline, " [");
|
||||
wprintw(statusbar->topline, "[");
|
||||
wattroff(statusbar->topline, COLOR_PAIR(BAR_ACCENT));
|
||||
|
||||
wattron(statusbar->topline, COLOR_PAIR(colour) | A_BOLD);
|
||||
@ -1351,30 +1349,23 @@ static void chat_onDraw(ToxWindow *self, Tox *m)
|
||||
wattron(statusbar->topline, COLOR_PAIR(BAR_ACCENT));
|
||||
wprintw(statusbar->topline, "] ");
|
||||
wattroff(statusbar->topline, COLOR_PAIR(BAR_ACCENT));
|
||||
}
|
||||
|
||||
pthread_mutex_lock(&Winthread.lock);
|
||||
const bool is_typing = Friends.list[self->num].is_typing;
|
||||
pthread_mutex_unlock(&Winthread.lock);
|
||||
|
||||
if (is_typing) {
|
||||
wattron(statusbar->topline, A_BOLD | COLOR_PAIR(BAR_NOTIFY));
|
||||
} else {
|
||||
wattron(statusbar->topline, COLOR_PAIR(BAR_TEXT));
|
||||
}
|
||||
|
||||
wprintw(statusbar->topline, "%s", statusbar->nick);
|
||||
|
||||
if (is_typing) {
|
||||
wattroff(statusbar->topline, A_BOLD | COLOR_PAIR(BAR_NOTIFY));
|
||||
} else {
|
||||
wattroff(statusbar->topline, A_BOLD | COLOR_PAIR(BAR_TEXT));
|
||||
}
|
||||
if (is_typing) {
|
||||
wattron(statusbar->topline, A_BOLD | COLOR_PAIR(BAR_NOTIFY));
|
||||
} else {
|
||||
wattron(statusbar->topline, COLOR_PAIR(BAR_TEXT));
|
||||
wprintw(statusbar->topline, " %s", statusbar->nick);
|
||||
wattroff(statusbar->topline, COLOR_PAIR(BAR_TEXT));
|
||||
}
|
||||
|
||||
wprintw(statusbar->topline, "%s", statusbar->nick);
|
||||
|
||||
if (is_typing) {
|
||||
wattroff(statusbar->topline, A_BOLD | COLOR_PAIR(BAR_NOTIFY));
|
||||
} else {
|
||||
wattroff(statusbar->topline, A_BOLD | COLOR_PAIR(BAR_TEXT));
|
||||
}
|
||||
|
||||
|
||||
/* Reset statusbar->statusmsg on window resize */
|
||||
if (x2 != self->x) {
|
||||
char statusmsg[TOX_MAX_STATUS_MESSAGE_LENGTH] = {'\0'};
|
||||
@ -1394,7 +1385,7 @@ static void chat_onDraw(ToxWindow *self, Tox *m)
|
||||
self->x = x2;
|
||||
|
||||
/* Truncate note if it doesn't fit in statusbar */
|
||||
size_t maxlen = x2 - getcurx(statusbar->topline) - (KEY_IDENT_DIGITS * 2) - 6;
|
||||
size_t maxlen = x2 - getcurx(statusbar->topline) - KEY_IDENT_BYTES - 6;
|
||||
|
||||
pthread_mutex_lock(&Winthread.lock);
|
||||
size_t statusmsg_len = statusbar->statusmsg_len;
|
||||
@ -1425,10 +1416,10 @@ static void chat_onDraw(ToxWindow *self, Tox *m)
|
||||
int s_x;
|
||||
getyx(statusbar->topline, s_y, s_x);
|
||||
|
||||
mvwhline(statusbar->topline, s_y, s_x, ' ', x2 - s_x - (KEY_IDENT_DIGITS * 2) - 3);
|
||||
mvwhline(statusbar->topline, s_y, s_x, ' ', x2 - s_x - KEY_IDENT_BYTES - 3);
|
||||
wattroff(statusbar->topline, COLOR_PAIR(BAR_TEXT));
|
||||
|
||||
wmove(statusbar->topline, 0, x2 - (KEY_IDENT_DIGITS * 2) - 3);
|
||||
wmove(statusbar->topline, 0, x2 - KEY_IDENT_BYTES - 3);
|
||||
|
||||
wattron(statusbar->topline, COLOR_PAIR(BAR_ACCENT));
|
||||
wprintw(statusbar->topline, "{");
|
||||
@ -1436,7 +1427,7 @@ static void chat_onDraw(ToxWindow *self, Tox *m)
|
||||
|
||||
wattron(statusbar->topline, COLOR_PAIR(BAR_TEXT));
|
||||
|
||||
for (size_t i = 0; i < KEY_IDENT_DIGITS; ++i) {
|
||||
for (size_t i = 0; i < KEY_IDENT_BYTES / 2; ++i) {
|
||||
wprintw(statusbar->topline, "%02X", Friends.list[self->num].pub_key[i] & 0xff);
|
||||
}
|
||||
|
||||
|
@ -54,7 +54,13 @@ void cmd_cancelfile(WINDOW *window, ToxWindow *self, Tox *m, int argc, char (*ar
|
||||
return;
|
||||
}
|
||||
|
||||
struct FileTransfer *ft = NULL;
|
||||
// first check transfer queue
|
||||
if (file_send_queue_remove(self->num, idx) == 0) {
|
||||
line_info_add(self, false, NULL, NULL, SYS_MSG, 0, 0, "Pending file transfer removed from queue");
|
||||
return;
|
||||
}
|
||||
|
||||
FileTransfer *ft = NULL;
|
||||
|
||||
/* cancel an incoming file transfer */
|
||||
if (strcasecmp(inoutstr, "in") == 0) {
|
||||
@ -239,7 +245,7 @@ void cmd_savefile(WINDOW *window, ToxWindow *self, Tox *m, int argc, char (*argv
|
||||
return;
|
||||
}
|
||||
|
||||
struct FileTransfer *ft = get_file_transfer_struct_index(self->num, idx, FILE_TRANSFER_RECV);
|
||||
FileTransfer *ft = get_file_transfer_struct_index(self->num, idx, FILE_TRANSFER_RECV);
|
||||
|
||||
if (!ft) {
|
||||
line_info_add(self, false, NULL, NULL, SYS_MSG, 0, 0, "No pending file transfers with that ID.");
|
||||
@ -324,7 +330,7 @@ void cmd_sendfile(WINDOW *window, ToxWindow *self, Tox *m, int argc, char (*argv
|
||||
FILE *file_to_send = fopen(path, "r");
|
||||
|
||||
if (file_to_send == NULL) {
|
||||
line_info_add(self, false, NULL, NULL, SYS_MSG, 0, 0, "File not found.");
|
||||
line_info_add(self, false, NULL, NULL, SYS_MSG, 0, 0, "File `%s` not found.", path);
|
||||
return;
|
||||
}
|
||||
|
||||
@ -347,7 +353,7 @@ void cmd_sendfile(WINDOW *window, ToxWindow *self, Tox *m, int argc, char (*argv
|
||||
goto on_send_error;
|
||||
}
|
||||
|
||||
struct FileTransfer *ft = new_file_transfer(self, self->num, filenum, FILE_TRANSFER_SEND, TOX_FILE_KIND_DATA);
|
||||
FileTransfer *ft = new_file_transfer(self, self->num, filenum, FILE_TRANSFER_SEND, TOX_FILE_KIND_DATA);
|
||||
|
||||
if (!ft) {
|
||||
err = TOX_ERR_FILE_SEND_TOO_MANY;
|
||||
@ -367,29 +373,62 @@ void cmd_sendfile(WINDOW *window, ToxWindow *self, Tox *m, int argc, char (*argv
|
||||
|
||||
on_send_error:
|
||||
|
||||
fclose(file_to_send);
|
||||
|
||||
switch (err) {
|
||||
case TOX_ERR_FILE_SEND_FRIEND_NOT_FOUND:
|
||||
case TOX_ERR_FILE_SEND_FRIEND_NOT_FOUND: {
|
||||
errmsg = "File transfer failed: Invalid friend.";
|
||||
break;
|
||||
}
|
||||
|
||||
case TOX_ERR_FILE_SEND_FRIEND_NOT_CONNECTED:
|
||||
errmsg = "File transfer failed: Friend is offline.";
|
||||
break;
|
||||
case TOX_ERR_FILE_SEND_FRIEND_NOT_CONNECTED: {
|
||||
int queue_idx = file_send_queue_add(self->num, path, path_len);
|
||||
|
||||
case TOX_ERR_FILE_SEND_NAME_TOO_LONG:
|
||||
char msg[MAX_STR_SIZE];
|
||||
|
||||
switch (queue_idx) {
|
||||
case -1: {
|
||||
snprintf(msg, sizeof(msg), "Invalid file name: path is null or length is zero.");
|
||||
break;
|
||||
}
|
||||
|
||||
case -2: {
|
||||
snprintf(msg, sizeof(msg), "File name is too long.");
|
||||
break;
|
||||
}
|
||||
|
||||
case -3: {
|
||||
snprintf(msg, sizeof(msg), "File send queue is full.");
|
||||
break;
|
||||
}
|
||||
|
||||
default: {
|
||||
snprintf(msg, sizeof(msg), "File transfer queued. Type \"/cancel out %d\" to cancel.", queue_idx);
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
line_info_add(self, false, NULL, NULL, SYS_MSG, 0, 0, "%s", msg);
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
case TOX_ERR_FILE_SEND_NAME_TOO_LONG: {
|
||||
errmsg = "File transfer failed: Filename is too long.";
|
||||
break;
|
||||
}
|
||||
|
||||
case TOX_ERR_FILE_SEND_TOO_MANY:
|
||||
case TOX_ERR_FILE_SEND_TOO_MANY: {
|
||||
errmsg = "File transfer failed: Too many concurrent file transfers.";
|
||||
break;
|
||||
}
|
||||
|
||||
default:
|
||||
default: {
|
||||
errmsg = "File transfer failed.";
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
line_info_add(self, false, NULL, NULL, SYS_MSG, 0, 0, "%s", errmsg);
|
||||
tox_file_control(m, self->num, filenum, TOX_FILE_CONTROL_CANCEL, NULL);
|
||||
fclose(file_to_send);
|
||||
}
|
||||
|
@ -63,8 +63,6 @@
|
||||
#include "toxic_strings.h"
|
||||
#include "windows.h"
|
||||
|
||||
extern char *DATA_FILE;
|
||||
|
||||
#define MAX_CONFERENCE_NUM (MAX_WINDOWS_NUM - 2)
|
||||
#define CONFERENCE_EVENT_WAIT 30
|
||||
|
||||
|
@ -117,15 +117,8 @@ static struct cmd_func conference_commands[] = {
|
||||
{ NULL, NULL },
|
||||
};
|
||||
|
||||
|
||||
#ifdef PYTHON
|
||||
#define SPECIAL_COMMANDS 8
|
||||
#else
|
||||
#define SPECIAL_COMMANDS 7
|
||||
#endif /* PYTHON */
|
||||
|
||||
/* Special commands are commands that only take one argument even if it contains spaces */
|
||||
static const char special_commands[SPECIAL_COMMANDS][MAX_CMDNAME_SIZE] = {
|
||||
static const char special_commands[][MAX_CMDNAME_SIZE] = {
|
||||
"/add",
|
||||
"/avatar",
|
||||
"/nick",
|
||||
@ -136,6 +129,7 @@ static const char special_commands[SPECIAL_COMMANDS][MAX_CMDNAME_SIZE] = {
|
||||
"/sendfile",
|
||||
"/title",
|
||||
"/mute",
|
||||
"",
|
||||
};
|
||||
|
||||
/* Returns true if input command is in the special_commands array. */
|
||||
@ -143,7 +137,7 @@ static bool is_special_command(const char *input)
|
||||
{
|
||||
const int s = char_find(0, input, ' ');
|
||||
|
||||
for (int i = 0; i < SPECIAL_COMMANDS; ++i) {
|
||||
for (int i = 0; special_commands[i][0] != '\0'; ++i) {
|
||||
if (strncmp(input, special_commands[i], s) == 0) {
|
||||
return true;
|
||||
}
|
||||
|
@ -25,6 +25,7 @@
|
||||
#include <time.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#include "execute.h"
|
||||
#include "file_transfers.h"
|
||||
#include "friendlist.h"
|
||||
#include "line_info.h"
|
||||
@ -44,9 +45,8 @@ extern FriendsList Friends;
|
||||
void init_progress_bar(char *progline)
|
||||
{
|
||||
strcpy(progline, "0% [");
|
||||
int i;
|
||||
|
||||
for (i = 0; i < NUM_PROG_MARKS; ++i) {
|
||||
for (size_t i = 0; i < NUM_PROG_MARKS; ++i) {
|
||||
strcat(progline, "-");
|
||||
}
|
||||
|
||||
@ -98,7 +98,7 @@ void print_progress_bar(ToxWindow *self, double bps, double pct_done, uint32_t l
|
||||
free(full_line);
|
||||
}
|
||||
|
||||
static void refresh_progress_helper(ToxWindow *self, struct FileTransfer *ft)
|
||||
static void refresh_progress_helper(ToxWindow *self, FileTransfer *ft)
|
||||
{
|
||||
if (ft->state == FILE_TRANSFER_INACTIVE) {
|
||||
return;
|
||||
@ -126,8 +126,8 @@ bool refresh_file_transfer_progress(ToxWindow *self, uint32_t friendnumber)
|
||||
bool active = false;
|
||||
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
struct FileTransfer *ft_r = &Friends.list[friendnumber].file_receiver[i];
|
||||
struct FileTransfer *ft_s = &Friends.list[friendnumber].file_sender[i];
|
||||
FileTransfer *ft_r = &Friends.list[friendnumber].file_receiver[i];
|
||||
FileTransfer *ft_s = &Friends.list[friendnumber].file_sender[i];
|
||||
|
||||
refresh_progress_helper(self, ft_r);
|
||||
refresh_progress_helper(self, ft_s);
|
||||
@ -140,9 +140,9 @@ bool refresh_file_transfer_progress(ToxWindow *self, uint32_t friendnumber)
|
||||
return active;
|
||||
}
|
||||
|
||||
static void clear_file_transfer(struct FileTransfer *ft)
|
||||
static void clear_file_transfer(FileTransfer *ft)
|
||||
{
|
||||
*ft = (struct FileTransfer) {
|
||||
*ft = (FileTransfer) {
|
||||
0
|
||||
};
|
||||
}
|
||||
@ -150,16 +150,16 @@ static void clear_file_transfer(struct FileTransfer *ft)
|
||||
/* Returns a pointer to friendnumber's FileTransfer struct associated with filenumber.
|
||||
* Returns NULL if filenumber is invalid.
|
||||
*/
|
||||
struct FileTransfer *get_file_transfer_struct(uint32_t friendnumber, uint32_t filenumber)
|
||||
FileTransfer *get_file_transfer_struct(uint32_t friendnumber, uint32_t filenumber)
|
||||
{
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
struct FileTransfer *ft_send = &Friends.list[friendnumber].file_sender[i];
|
||||
FileTransfer *ft_send = &Friends.list[friendnumber].file_sender[i];
|
||||
|
||||
if (ft_send->state != FILE_TRANSFER_INACTIVE && ft_send->filenumber == filenumber) {
|
||||
return ft_send;
|
||||
}
|
||||
|
||||
struct FileTransfer *ft_recv = &Friends.list[friendnumber].file_receiver[i];
|
||||
FileTransfer *ft_recv = &Friends.list[friendnumber].file_receiver[i];
|
||||
|
||||
if (ft_recv->state != FILE_TRANSFER_INACTIVE && ft_recv->filenumber == filenumber) {
|
||||
return ft_recv;
|
||||
@ -172,7 +172,7 @@ struct FileTransfer *get_file_transfer_struct(uint32_t friendnumber, uint32_t fi
|
||||
/* Returns a pointer to the FileTransfer struct associated with index with the direction specified.
|
||||
* Returns NULL on failure.
|
||||
*/
|
||||
struct FileTransfer *get_file_transfer_struct_index(uint32_t friendnumber, uint32_t index,
|
||||
FileTransfer *get_file_transfer_struct_index(uint32_t friendnumber, uint32_t index,
|
||||
FILE_TRANSFER_DIRECTION direction)
|
||||
{
|
||||
if (direction != FILE_TRANSFER_RECV && direction != FILE_TRANSFER_SEND) {
|
||||
@ -180,9 +180,9 @@ struct FileTransfer *get_file_transfer_struct_index(uint32_t friendnumber, uint3
|
||||
}
|
||||
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
struct FileTransfer *ft = direction == FILE_TRANSFER_SEND ?
|
||||
&Friends.list[friendnumber].file_sender[i] :
|
||||
&Friends.list[friendnumber].file_receiver[i];
|
||||
FileTransfer *ft = direction == FILE_TRANSFER_SEND ?
|
||||
&Friends.list[friendnumber].file_sender[i] :
|
||||
&Friends.list[friendnumber].file_receiver[i];
|
||||
|
||||
if (ft->state != FILE_TRANSFER_INACTIVE && ft->index == index) {
|
||||
return ft;
|
||||
@ -195,10 +195,10 @@ struct FileTransfer *get_file_transfer_struct_index(uint32_t friendnumber, uint3
|
||||
/* Returns a pointer to an unused file sender.
|
||||
* Returns NULL if all file senders are in use.
|
||||
*/
|
||||
static struct FileTransfer *new_file_sender(ToxWindow *window, uint32_t friendnumber, uint32_t filenumber, uint8_t type)
|
||||
static FileTransfer *new_file_sender(ToxWindow *window, uint32_t friendnumber, uint32_t filenumber, uint8_t type)
|
||||
{
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
struct FileTransfer *ft = &Friends.list[friendnumber].file_sender[i];
|
||||
FileTransfer *ft = &Friends.list[friendnumber].file_sender[i];
|
||||
|
||||
if (ft->state == FILE_TRANSFER_INACTIVE) {
|
||||
clear_file_transfer(ft);
|
||||
@ -218,11 +218,11 @@ static struct FileTransfer *new_file_sender(ToxWindow *window, uint32_t friendnu
|
||||
/* Returns a pointer to an unused file receiver.
|
||||
* Returns NULL if all file receivers are in use.
|
||||
*/
|
||||
static struct FileTransfer *new_file_receiver(ToxWindow *window, uint32_t friendnumber, uint32_t filenumber,
|
||||
uint8_t type)
|
||||
static FileTransfer *new_file_receiver(ToxWindow *window, uint32_t friendnumber, uint32_t filenumber,
|
||||
uint8_t type)
|
||||
{
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
struct FileTransfer *ft = &Friends.list[friendnumber].file_receiver[i];
|
||||
FileTransfer *ft = &Friends.list[friendnumber].file_receiver[i];
|
||||
|
||||
if (ft->state == FILE_TRANSFER_INACTIVE) {
|
||||
clear_file_transfer(ft);
|
||||
@ -242,8 +242,8 @@ static struct FileTransfer *new_file_receiver(ToxWindow *window, uint32_t friend
|
||||
/* Initializes an unused file transfer and returns its pointer.
|
||||
* Returns NULL on failure.
|
||||
*/
|
||||
struct FileTransfer *new_file_transfer(ToxWindow *window, uint32_t friendnumber, uint32_t filenumber,
|
||||
FILE_TRANSFER_DIRECTION direction, uint8_t type)
|
||||
FileTransfer *new_file_transfer(ToxWindow *window, uint32_t friendnumber, uint32_t filenumber,
|
||||
FILE_TRANSFER_DIRECTION direction, uint8_t type)
|
||||
{
|
||||
if (direction == FILE_TRANSFER_RECV) {
|
||||
return new_file_receiver(window, friendnumber, filenumber, type);
|
||||
@ -256,13 +256,83 @@ struct FileTransfer *new_file_transfer(ToxWindow *window, uint32_t friendnumber,
|
||||
return NULL;
|
||||
}
|
||||
|
||||
int file_send_queue_add(uint32_t friendnumber, const char *file_path, size_t length)
|
||||
{
|
||||
if (length == 0 || file_path == NULL) {
|
||||
return -1;
|
||||
}
|
||||
|
||||
if (length > TOX_MAX_FILENAME_LENGTH) {
|
||||
return -2;
|
||||
}
|
||||
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
PendingFileTransfer *pending_slot = &Friends.list[friendnumber].file_send_queue[i];
|
||||
|
||||
if (pending_slot->pending) {
|
||||
continue;
|
||||
}
|
||||
|
||||
pending_slot->pending = true;
|
||||
|
||||
memcpy(pending_slot->file_path, file_path, length);
|
||||
pending_slot->file_path[length] = 0;
|
||||
pending_slot->length = length;
|
||||
|
||||
return i;
|
||||
}
|
||||
|
||||
return -3;
|
||||
}
|
||||
|
||||
#define FILE_TRANSFER_SEND_CMD "/sendfile "
|
||||
#define FILE_TRANSFER_SEND_LEN (sizeof(FILE_TRANSFER_SEND_CMD) - 1)
|
||||
|
||||
void file_send_queue_check(ToxWindow *self, Tox *m, uint32_t friendnumber)
|
||||
{
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
PendingFileTransfer *pending_slot = &Friends.list[friendnumber].file_send_queue[i];
|
||||
|
||||
if (!pending_slot->pending) {
|
||||
continue;
|
||||
}
|
||||
|
||||
char command[TOX_MAX_FILENAME_LENGTH + FILE_TRANSFER_SEND_LEN + 1];
|
||||
snprintf(command, sizeof(command), "%s%s", FILE_TRANSFER_SEND_CMD, pending_slot->file_path);
|
||||
|
||||
execute(self->window, self, m, command, CHAT_COMMAND_MODE);
|
||||
|
||||
*pending_slot = (PendingFileTransfer) {
|
||||
0,
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
int file_send_queue_remove(uint32_t friendnumber, size_t index)
|
||||
{
|
||||
if (index >= MAX_FILES) {
|
||||
return -1;
|
||||
}
|
||||
|
||||
PendingFileTransfer *pending_slot = &Friends.list[friendnumber].file_send_queue[index];
|
||||
|
||||
if (!pending_slot->pending) {
|
||||
return -1;
|
||||
}
|
||||
|
||||
*pending_slot = (PendingFileTransfer) {
|
||||
0,
|
||||
};
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
/* Closes file transfer ft.
|
||||
*
|
||||
* Set CTRL to -1 if we don't want to send a control signal.
|
||||
* Set message or self to NULL if we don't want to display a message.
|
||||
*/
|
||||
void close_file_transfer(ToxWindow *self, Tox *m, struct FileTransfer *ft, int CTRL, const char *message,
|
||||
void close_file_transfer(ToxWindow *self, Tox *m, FileTransfer *ft, int CTRL, const char *message,
|
||||
Notification sound_type)
|
||||
{
|
||||
if (!ft) {
|
||||
@ -278,7 +348,11 @@ void close_file_transfer(ToxWindow *self, Tox *m, struct FileTransfer *ft, int C
|
||||
}
|
||||
|
||||
if (CTRL >= 0) {
|
||||
tox_file_control(m, ft->friendnumber, ft->filenumber, (Tox_File_Control) CTRL, NULL);
|
||||
Tox_Err_File_Control err;
|
||||
|
||||
if (!tox_file_control(m, ft->friendnumber, ft->filenumber, (Tox_File_Control) CTRL, &err)) {
|
||||
fprintf(stderr, "Failed to cancel file transfer: %d\n", err);
|
||||
}
|
||||
}
|
||||
|
||||
if (message && self) {
|
||||
@ -298,7 +372,7 @@ void close_file_transfer(ToxWindow *self, Tox *m, struct FileTransfer *ft, int C
|
||||
void kill_avatar_file_transfers_friend(Tox *m, uint32_t friendnumber)
|
||||
{
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
struct FileTransfer *ft = &Friends.list[friendnumber].file_sender[i];
|
||||
FileTransfer *ft = &Friends.list[friendnumber].file_sender[i];
|
||||
|
||||
if (ft->file_type == TOX_FILE_KIND_AVATAR) {
|
||||
close_file_transfer(NULL, m, ft, TOX_FILE_CONTROL_CANCEL, NULL, silent);
|
||||
@ -312,6 +386,7 @@ void kill_all_file_transfers_friend(Tox *m, uint32_t friendnumber)
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
close_file_transfer(NULL, m, &Friends.list[friendnumber].file_sender[i], TOX_FILE_CONTROL_CANCEL, NULL, silent);
|
||||
close_file_transfer(NULL, m, &Friends.list[friendnumber].file_receiver[i], TOX_FILE_CONTROL_CANCEL, NULL, silent);
|
||||
file_send_queue_remove(friendnumber, i);
|
||||
}
|
||||
}
|
||||
|
||||
@ -321,3 +396,26 @@ void kill_all_file_transfers(Tox *m)
|
||||
kill_all_file_transfers_friend(m, Friends.list[i].num);
|
||||
}
|
||||
}
|
||||
|
||||
bool file_transfer_recv_path_exists(const char *path)
|
||||
{
|
||||
for (size_t friendnumber = 0; friendnumber < Friends.max_idx; ++friendnumber) {
|
||||
if (!Friends.list[friendnumber].active) {
|
||||
continue;
|
||||
}
|
||||
|
||||
for (size_t i = 0; i < MAX_FILES; ++i) {
|
||||
FileTransfer *ft = &Friends.list[friendnumber].file_receiver[i];
|
||||
|
||||
if (ft->state == FILE_TRANSFER_INACTIVE) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if (strcmp(path, ft->file_path) == 0) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
@ -29,9 +29,9 @@
|
||||
#include "toxic.h"
|
||||
#include "windows.h"
|
||||
|
||||
#define KiB 1024
|
||||
#define MiB 1048576 /* 1024^2 */
|
||||
#define GiB 1073741824 /* 1024^3 */
|
||||
#define KiB (uint32_t) 1024
|
||||
#define MiB (uint32_t) (1024 << 10) /* 1024^2 */
|
||||
#define GiB (uint32_t) (1024 << 20) /* 1024^3 */
|
||||
|
||||
#define MAX_FILES 32
|
||||
|
||||
@ -47,7 +47,7 @@ typedef enum FILE_TRANSFER_DIRECTION {
|
||||
FILE_TRANSFER_RECV
|
||||
} FILE_TRANSFER_DIRECTION;
|
||||
|
||||
struct FileTransfer {
|
||||
typedef struct FileTransfer {
|
||||
ToxWindow *window;
|
||||
FILE *file;
|
||||
FILE_TRANSFER_STATE state;
|
||||
@ -63,7 +63,15 @@ struct FileTransfer {
|
||||
time_t last_line_progress; /* The last time we updated the progress bar */
|
||||
uint32_t line_id;
|
||||
uint8_t file_id[TOX_FILE_ID_LENGTH];
|
||||
};
|
||||
} FileTransfer;
|
||||
|
||||
typedef struct PendingFileTransfer {
|
||||
char file_path[TOX_MAX_FILENAME_LENGTH + 1];
|
||||
size_t length;
|
||||
uint32_t friendnumber;
|
||||
bool pending;
|
||||
} PendingFileTransfer;
|
||||
|
||||
|
||||
/* creates initial progress line that will be updated during file transfer.
|
||||
progline must be at lesat MAX_STR_SIZE bytes */
|
||||
@ -96,6 +104,31 @@ struct FileTransfer *get_file_transfer_struct_index(uint32_t friendnumber, uint3
|
||||
struct FileTransfer *new_file_transfer(ToxWindow *window, uint32_t friendnumber, uint32_t filenumber,
|
||||
FILE_TRANSFER_DIRECTION direction, uint8_t type);
|
||||
|
||||
/* Adds a file designated by `file_path` of length `length` to the file transfer queue.
|
||||
*
|
||||
* Items in this queue will be automatically sent to the contact designated by `friendnumber`
|
||||
* as soon as they appear online. The item will then be removed from the queue whether
|
||||
* or not the transfer successfully initiates.
|
||||
*
|
||||
* If the ToxWindow associated with this friend is closed, all queued items will be
|
||||
* discarded.
|
||||
*
|
||||
* Return the queue index on success.
|
||||
* Return -1 if the length is invalid.
|
||||
* Return -2 if the send queue is full.
|
||||
*/
|
||||
int file_send_queue_add(uint32_t friendnumber, const char *file_path, size_t length);
|
||||
|
||||
/* Initiates all file transfers from the file send queue for friend designated by `friendnumber`. */
|
||||
void file_send_queue_check(ToxWindow *self, Tox *m, uint32_t friendnumber);
|
||||
|
||||
/* Removes the `index`-th item from the file send queue for `friendnumber`.
|
||||
*
|
||||
* Return 0 if a pending transfer was successfully removed
|
||||
* Return -1 if index does not designate a pending file transfer.
|
||||
*/
|
||||
int file_send_queue_remove(uint32_t friendnumber, size_t index);
|
||||
|
||||
/* Closes file transfer ft.
|
||||
*
|
||||
* Set CTRL to -1 if we don't want to send a control signal.
|
||||
@ -112,4 +145,7 @@ void kill_all_file_transfers_friend(Tox *m, uint32_t friendnumber);
|
||||
|
||||
void kill_all_file_transfers(Tox *m);
|
||||
|
||||
/* Return true if any pending or active file receiver has the path `path`. */
|
||||
bool file_transfer_recv_path_exists(const char *path);
|
||||
|
||||
#endif /* FILE_TRANSFERS_H */
|
||||
|
@ -37,6 +37,7 @@
|
||||
#include "log.h"
|
||||
#include "misc_tools.h"
|
||||
#include "notify.h"
|
||||
#include "prompt.h"
|
||||
#include "settings.h"
|
||||
#include "toxic.h"
|
||||
#include "windows.h"
|
||||
@ -46,13 +47,6 @@
|
||||
#endif
|
||||
|
||||
|
||||
extern char *DATA_FILE;
|
||||
extern char *BLOCK_FILE;
|
||||
extern ToxWindow *prompt;
|
||||
extern struct Winthread Winthread;
|
||||
extern struct user_settings *user_settings;
|
||||
extern struct arg_opts arg_opts;
|
||||
|
||||
static uint8_t blocklist_view = 0; /* 0 if we're in friendlist view, 1 if we're in blocklist view */
|
||||
|
||||
FriendsList Friends;
|
||||
@ -321,11 +315,11 @@ int load_blocklist(char *path)
|
||||
#define S_WEIGHT 100000
|
||||
static int index_name_cmp(const void *n1, const void *n2)
|
||||
{
|
||||
int res = qsort_strcasecmp_hlpr(Friends.list[*(int *) n1].name, Friends.list[*(int *) n2].name);
|
||||
int res = qsort_strcasecmp_hlpr(Friends.list[*(const int *) n1].name, Friends.list[*(const int *) n2].name);
|
||||
|
||||
/* Use weight to make qsort always put online friends before offline */
|
||||
res = Friends.list[*(int *) n1].connection_status ? (res - S_WEIGHT) : (res + S_WEIGHT);
|
||||
res = Friends.list[*(int *) n2].connection_status ? (res + S_WEIGHT) : (res - S_WEIGHT);
|
||||
res = Friends.list[*(const int *) n1].connection_status ? (res - S_WEIGHT) : (res + S_WEIGHT);
|
||||
res = Friends.list[*(const int *) n2].connection_status ? (res + S_WEIGHT) : (res - S_WEIGHT);
|
||||
|
||||
return res;
|
||||
}
|
||||
@ -349,7 +343,7 @@ void sort_friendlist_index(void)
|
||||
|
||||
static int index_name_cmp_block(const void *n1, const void *n2)
|
||||
{
|
||||
return qsort_strcasecmp_hlpr(Blocked.list[*(int *) n1].name, Blocked.list[*(int *) n2].name);
|
||||
return qsort_strcasecmp_hlpr(Blocked.list[*(const int *) n1].name, Blocked.list[*(const int *) n2].name);
|
||||
}
|
||||
|
||||
static void sort_blocklist_index(void)
|
||||
@ -698,6 +692,9 @@ static void select_friend(wint_t key, int *selected, int num)
|
||||
|
||||
static void delete_friend(Tox *m, uint32_t f_num)
|
||||
{
|
||||
kill_all_file_transfers_friend(m, f_num);
|
||||
kill_avatar_file_transfers_friend(m, f_num);
|
||||
|
||||
Tox_Err_Friend_Delete err;
|
||||
|
||||
if (tox_friend_delete(m, f_num, &err) != true) {
|
||||
@ -846,9 +843,7 @@ void block_friend(Tox *m, uint32_t fnum)
|
||||
realloc_blocklist(Blocked.max_idx + 1);
|
||||
clear_blocklist_index(Blocked.max_idx);
|
||||
|
||||
int i;
|
||||
|
||||
for (i = 0; i <= Blocked.max_idx; ++i) {
|
||||
for (int i = 0; i <= Blocked.max_idx; ++i) {
|
||||
if (Blocked.list[i].active) {
|
||||
continue;
|
||||
}
|
||||
@ -1113,14 +1108,14 @@ static void friendlist_onDraw(ToxWindow *self, Tox *m)
|
||||
|
||||
/* Determine which portion of friendlist to draw based on current position */
|
||||
pthread_mutex_lock(&Winthread.lock);
|
||||
int page = Friends.num_selected / (y2 - FLIST_OFST);
|
||||
const int page = Friends.num_selected / (y2 - FLIST_OFST);
|
||||
pthread_mutex_unlock(&Winthread.lock);
|
||||
|
||||
int start = (y2 - FLIST_OFST) * page;
|
||||
int end = y2 - FLIST_OFST + start;
|
||||
const int start = (y2 - FLIST_OFST) * page;
|
||||
const int end = y2 - FLIST_OFST + start;
|
||||
|
||||
pthread_mutex_lock(&Winthread.lock);
|
||||
size_t num_friends = Friends.num_friends;
|
||||
const size_t num_friends = Friends.num_friends;
|
||||
pthread_mutex_unlock(&Winthread.lock);
|
||||
|
||||
int i;
|
||||
|
@ -79,8 +79,9 @@ typedef struct {
|
||||
struct GameInvite game_invite;
|
||||
#endif
|
||||
|
||||
struct FileTransfer file_receiver[MAX_FILES];
|
||||
struct FileTransfer file_sender[MAX_FILES];
|
||||
FileTransfer file_receiver[MAX_FILES];
|
||||
FileTransfer file_sender[MAX_FILES];
|
||||
PendingFileTransfer file_send_queue[MAX_FILES];
|
||||
} ToxicFriend;
|
||||
|
||||
typedef struct {
|
||||
@ -101,6 +102,8 @@ typedef struct {
|
||||
ToxicFriend *list;
|
||||
} FriendsList;
|
||||
|
||||
extern FriendsList Friends;
|
||||
|
||||
ToxWindow *new_friendlist(void);
|
||||
void friendlist_onInit(ToxWindow *self, Tox *m);
|
||||
void disable_chatwin(uint32_t f_num);
|
||||
|
@ -517,10 +517,10 @@ static void game_draw_help_bar(const GameData *game, WINDOW *win)
|
||||
{
|
||||
int max_x;
|
||||
int max_y;
|
||||
UNUSED_VAR(max_x);
|
||||
|
||||
getmaxyx(win, max_y, max_x);
|
||||
|
||||
UNUSED_VAR(max_x);
|
||||
|
||||
wmove(win, max_y - 1, 1);
|
||||
|
||||
if (!game->is_multiplayer) {
|
||||
@ -937,10 +937,10 @@ int game_y_bottom_bound(const GameData *game)
|
||||
{
|
||||
int max_x;
|
||||
int max_y;
|
||||
UNUSED_VAR(max_x);
|
||||
|
||||
getmaxyx(game->window, max_y, max_x);
|
||||
|
||||
UNUSED_VAR(max_x);
|
||||
|
||||
return ((max_y + game->game_max_y) / 2) - 1;
|
||||
}
|
||||
|
||||
@ -948,10 +948,10 @@ int game_y_top_bound(const GameData *game)
|
||||
{
|
||||
int max_x;
|
||||
int max_y;
|
||||
UNUSED_VAR(max_x);
|
||||
|
||||
getmaxyx(game->window, max_y, max_x);
|
||||
|
||||
UNUSED_VAR(max_x);
|
||||
|
||||
return ((max_y - game->game_max_y) / 2) + 1;
|
||||
}
|
||||
|
||||
@ -959,10 +959,10 @@ int game_x_right_bound(const GameData *game)
|
||||
{
|
||||
int max_x;
|
||||
int max_y;
|
||||
UNUSED_VAR(max_y);
|
||||
|
||||
getmaxyx(game->window, max_y, max_x);
|
||||
|
||||
UNUSED_VAR(max_y);
|
||||
|
||||
return ((max_x + game->game_max_x) / 2) - 1;
|
||||
}
|
||||
|
||||
@ -970,10 +970,10 @@ int game_x_left_bound(const GameData *game)
|
||||
{
|
||||
int max_x;
|
||||
int max_y;
|
||||
UNUSED_VAR(max_y);
|
||||
|
||||
getmaxyx(game->window, max_y, max_x);
|
||||
|
||||
UNUSED_VAR(max_y);
|
||||
|
||||
return ((max_x - game->game_max_x) / 2) + 1;
|
||||
}
|
||||
|
||||
@ -1129,7 +1129,7 @@ int game_packet_send(const GameData *game, const uint8_t *data, size_t length, G
|
||||
memcpy(packet + 1 + GAME_PACKET_HEADER_SIZE, data, length);
|
||||
packet_length += length;
|
||||
|
||||
TOX_ERR_FRIEND_CUSTOM_PACKET err;
|
||||
Tox_Err_Friend_Custom_Packet err;
|
||||
|
||||
if (!tox_friend_send_lossless_packet(game->tox, game->friend_number, packet, packet_length, &err)) {
|
||||
fprintf(stderr, "failed to send game packet: error %d\n", err);
|
||||
|
@ -436,7 +436,11 @@ static bool chess_path_line_clear(Board *board, const Tile *from, const Tile *to
|
||||
return false;
|
||||
}
|
||||
|
||||
ChessCoords chess_coords;
|
||||
ChessCoords chess_coords = (ChessCoords) {
|
||||
0,
|
||||
0
|
||||
};
|
||||
|
||||
size_t start;
|
||||
size_t end;
|
||||
|
||||
@ -800,11 +804,13 @@ static bool chess_mock_move_valid(ChessState *state, const Player *player, Tile
|
||||
{
|
||||
Board *board = &state->board;
|
||||
|
||||
const bool en_passant = player->en_passant_move_number == -1;
|
||||
bool in_check = false;
|
||||
Tile *ep_tile = NULL;
|
||||
Piece ep_piece;
|
||||
memset(&ep_piece, 0, sizeof(ep_piece));
|
||||
|
||||
if (player->en_passant_move_number == -1) { // remove piece that was captured via en passant
|
||||
if (en_passant) { // remove piece that was captured via en passant
|
||||
ChessCoords ep_coords;
|
||||
ep_coords.N = player->colour == White ? to->chess_coords.N - 1 : to->chess_coords.N + 1;
|
||||
ep_coords.L = to->chess_coords.L;
|
||||
@ -815,7 +821,7 @@ static bool chess_mock_move_valid(ChessState *state, const Player *player, Tile
|
||||
}
|
||||
|
||||
chess_copy_piece(&ep_piece, &ep_tile->piece);
|
||||
ep_tile->piece.type = NoPiece;
|
||||
ep_tile->piece.type = NoPiece; // temporarily remove piece
|
||||
}
|
||||
|
||||
Piece from_piece;
|
||||
@ -831,8 +837,8 @@ static bool chess_mock_move_valid(ChessState *state, const Player *player, Tile
|
||||
from->piece.type = from_piece.type;
|
||||
chess_copy_piece(&to->piece, &to_piece);
|
||||
|
||||
if (player->en_passant_move_number == -1) {
|
||||
ep_tile->piece.type = ep_piece.type;
|
||||
if (en_passant) {
|
||||
ep_tile->piece.type = ep_piece.type; // reset piece to original state
|
||||
}
|
||||
|
||||
return !in_check;
|
||||
|
@ -42,11 +42,6 @@
|
||||
#include "game_base.h"
|
||||
#endif
|
||||
|
||||
extern char *DATA_FILE;
|
||||
extern ToxWindow *prompt;
|
||||
extern FriendsList Friends;
|
||||
extern FriendRequests FrndRequests;
|
||||
|
||||
/* command functions */
|
||||
void cmd_accept(WINDOW *window, ToxWindow *self, Tox *m, int argc, char (*argv)[MAX_STR_SIZE])
|
||||
{
|
||||
|
144
src/line_info.c
144
src/line_info.c
@ -20,6 +20,10 @@
|
||||
*
|
||||
*/
|
||||
|
||||
#ifndef _GNU_SOURCE
|
||||
#define _GNU_SOURCE /* needed for wcswidth() */
|
||||
#endif
|
||||
|
||||
#include <stdarg.h>
|
||||
#include <stdbool.h>
|
||||
#include <stdlib.h>
|
||||
@ -137,20 +141,24 @@ static struct line_info *line_info_ret_queue(struct history *hst)
|
||||
* Return 0 if string does not contain a newline byte.
|
||||
* Return -1 if printing was aborted.
|
||||
*/
|
||||
static int print_n_chars(WINDOW *win, const char *s, size_t n, int max_y)
|
||||
static int print_n_chars(WINDOW *win, const wchar_t *s, size_t n, int max_y)
|
||||
{
|
||||
// we use an array to represent a single wchar in order to get around an ncurses
|
||||
// bug with waddnwstr() that overreads the memory address by one byte when
|
||||
// supplied with a single wchar.
|
||||
wchar_t ch[2] = {0};
|
||||
bool newline = false;
|
||||
char ch;
|
||||
|
||||
for (size_t i = 0; i < n && (ch = s[i]); ++i) {
|
||||
if (ch == '\n') {
|
||||
for (size_t i = 0; i < n && (ch[0] = s[i]); ++i) {
|
||||
if (ch[0] == L'\n') {
|
||||
newline = true;
|
||||
|
||||
int x;
|
||||
int y;
|
||||
UNUSED_VAR(x);
|
||||
getyx(win, y, x);
|
||||
|
||||
UNUSED_VAR(x);
|
||||
|
||||
// make sure cursor will wrap correctly after newline to prevent display bugs
|
||||
if (y + 1 >= max_y) {
|
||||
return -1;
|
||||
@ -158,7 +166,17 @@ static int print_n_chars(WINDOW *win, const char *s, size_t n, int max_y)
|
||||
}
|
||||
|
||||
if (win) {
|
||||
wprintw(win, "%c", ch);
|
||||
#ifdef HAVE_WIDECHAR
|
||||
waddnwstr(win, ch, 1);
|
||||
#else
|
||||
char b;
|
||||
|
||||
if (wcstombs(&b, ch, sizeof(char)) != 1) {
|
||||
continue;
|
||||
}
|
||||
|
||||
wprintw(win, "%c", b);
|
||||
#endif // HAVE_WIDECHAR
|
||||
}
|
||||
}
|
||||
|
||||
@ -168,10 +186,10 @@ static int print_n_chars(WINDOW *win, const char *s, size_t n, int max_y)
|
||||
/* Returns the index of the last space character in `s` found before `limit`.
|
||||
* Returns -1 if no space is found.
|
||||
*/
|
||||
static int rspace_index(const char *s, int limit)
|
||||
static int rspace_index(const wchar_t *s, int limit)
|
||||
{
|
||||
for (int i = limit; i >= 0; --i) {
|
||||
if (s[i] == ' ') {
|
||||
if (s[i] == L' ') {
|
||||
return i;
|
||||
}
|
||||
}
|
||||
@ -182,12 +200,12 @@ static int rspace_index(const char *s, int limit)
|
||||
/* Returns the first index in `s` containing a newline byte found before `limit`.
|
||||
* Returns -1 if no newline is found.
|
||||
*/
|
||||
static int newline_index(const char *s, int limit)
|
||||
static int newline_index(const wchar_t *s, int limit)
|
||||
{
|
||||
char ch;
|
||||
wchar_t ch;
|
||||
|
||||
for (int i = 0; i < limit && (ch = s[i]); ++i) {
|
||||
if (ch == '\n') {
|
||||
if (ch == L'\n') {
|
||||
return i;
|
||||
}
|
||||
}
|
||||
@ -196,13 +214,13 @@ static int newline_index(const char *s, int limit)
|
||||
}
|
||||
|
||||
/* Returns the number of newline bytes in `s` */
|
||||
static unsigned int newline_count(const char *s)
|
||||
static unsigned int newline_count(const wchar_t *s)
|
||||
{
|
||||
char ch;
|
||||
wchar_t ch;
|
||||
unsigned int count = 0;
|
||||
|
||||
for (size_t i = 0; (ch = s[i]); ++i) {
|
||||
if (ch == '\n') {
|
||||
if (ch == L'\n') {
|
||||
++count;
|
||||
}
|
||||
}
|
||||
@ -225,10 +243,10 @@ static int print_wrap(WINDOW *win, struct line_info *line, int max_x, int max_y)
|
||||
int y;
|
||||
UNUSED_VAR(y);
|
||||
|
||||
const char *msg = line->msg;
|
||||
uint16_t length = line->msg_len;
|
||||
const wchar_t *msg = line->msg;
|
||||
uint16_t length = line->msg_width;
|
||||
uint16_t lines = 0;
|
||||
const int x_start = line->len - line->msg_len - 1; // manually keep track of x position because ncurses sucks
|
||||
const int x_start = line->len - line->msg_width - 1; // manually keep track of x position because ncurses sucks
|
||||
int x_limit = max_x - x_start;
|
||||
|
||||
if (x_limit <= 1) {
|
||||
@ -245,7 +263,7 @@ static int print_wrap(WINDOW *win, struct line_info *line, int max_x, int max_y)
|
||||
}
|
||||
|
||||
if (length < x_limit) {
|
||||
int p_ret = print_n_chars(win, msg, length, max_y);
|
||||
const int p_ret = print_n_chars(win, msg, length, max_y);
|
||||
|
||||
if (p_ret == 1) {
|
||||
lines += newline_count(msg);
|
||||
@ -257,7 +275,7 @@ static int print_wrap(WINDOW *win, struct line_info *line, int max_x, int max_y)
|
||||
break;
|
||||
}
|
||||
|
||||
int newline_idx = newline_index(msg, x_limit - 1);
|
||||
const int newline_idx = newline_index(msg, x_limit - 1);
|
||||
|
||||
if (newline_idx >= 0) {
|
||||
if (print_n_chars(win, msg, newline_idx + 1, max_y) == -1) {
|
||||
@ -271,7 +289,7 @@ static int print_wrap(WINDOW *win, struct line_info *line, int max_x, int max_y)
|
||||
continue;
|
||||
}
|
||||
|
||||
int space_idx = rspace_index(msg, x_limit - 1);
|
||||
const int space_idx = rspace_index(msg, x_limit - 1);
|
||||
|
||||
if (space_idx >= 1) {
|
||||
if (print_n_chars(win, msg, space_idx, max_y) == -1) {
|
||||
@ -320,14 +338,45 @@ static int print_wrap(WINDOW *win, struct line_info *line, int max_x, int max_y)
|
||||
return 0;
|
||||
}
|
||||
|
||||
/* Converts `msg` into a widechar string and puts the result in `buf`.
|
||||
*
|
||||
* Returns the widechar width of the string.
|
||||
*/
|
||||
static uint16_t line_info_add_msg(wchar_t *buf, size_t buf_size, const char *msg)
|
||||
{
|
||||
if (msg == NULL || msg[0] == '\0') {
|
||||
return 0;
|
||||
}
|
||||
|
||||
const wint_t wc_msg_len = mbs_to_wcs_buf(buf, msg, buf_size);
|
||||
|
||||
if (wc_msg_len > 0 && wc_msg_len < buf_size) {
|
||||
buf[wc_msg_len] = L'\0';
|
||||
int width = wcswidth(buf, wc_msg_len);
|
||||
|
||||
if (width == -1) { // the best we can do on failure is to fall back to strlen
|
||||
width = strlen(msg);
|
||||
}
|
||||
|
||||
return (uint16_t)width;
|
||||
} else {
|
||||
fprintf(stderr, "Failed to convert string '%s' to widechar\n", msg);
|
||||
const wchar_t *err = L"Failed to parse message";
|
||||
uint16_t width = (uint16_t)wcslen(err);
|
||||
wmemcpy(buf, err, width);
|
||||
buf[width] = L'\0';
|
||||
return width;
|
||||
}
|
||||
}
|
||||
|
||||
static void line_info_init_line(ToxWindow *self, struct line_info *line)
|
||||
{
|
||||
int y2;
|
||||
int x2;
|
||||
UNUSED_VAR(y2);
|
||||
|
||||
getmaxyx(self->window, y2, x2);
|
||||
|
||||
UNUSED_VAR(y2);
|
||||
|
||||
const int max_y = y2 - CHATBOX_HEIGHT - WINDOW_BAR_HEIGHT;
|
||||
const int max_x = self->show_peerlist ? x2 - 1 - SIDEBAR_WIDTH : x2;
|
||||
|
||||
@ -408,13 +457,8 @@ int line_info_add(ToxWindow *self, bool show_timestamp, const char *name1, const
|
||||
break;
|
||||
}
|
||||
|
||||
uint16_t msg_len = 0;
|
||||
|
||||
if (frmt_msg[0]) {
|
||||
snprintf(new_line->msg, sizeof(new_line->msg), "%s", frmt_msg);
|
||||
msg_len = strlen(new_line->msg);
|
||||
len += msg_len;
|
||||
}
|
||||
const uint16_t msg_width = line_info_add_msg(new_line->msg, sizeof(new_line->msg), frmt_msg);
|
||||
len += msg_width;
|
||||
|
||||
if (show_timestamp) {
|
||||
get_time_str(new_line->timestr, sizeof(new_line->timestr));
|
||||
@ -433,7 +477,7 @@ int line_info_add(ToxWindow *self, bool show_timestamp, const char *name1, const
|
||||
|
||||
new_line->id = (hst->line_end->id + 1 + hst->queue_size) % INT_MAX;
|
||||
new_line->len = len;
|
||||
new_line->msg_len = msg_len;
|
||||
new_line->msg_width = msg_width;
|
||||
new_line->type = type;
|
||||
new_line->bold = bold;
|
||||
new_line->colour = colour;
|
||||
@ -517,15 +561,14 @@ void line_info_print(ToxWindow *self)
|
||||
const int max_y = y2 - CHATBOX_HEIGHT - WINDOW_BAR_HEIGHT;
|
||||
const int max_x = self->show_peerlist ? x2 - 1 - SIDEBAR_WIDTH : x2;
|
||||
uint16_t numlines = line->format_lines;
|
||||
int print_ret = 0;
|
||||
|
||||
while (line && numlines++ <= max_y && print_ret == 0) {
|
||||
while (line && numlines++ <= max_y) {
|
||||
int y;
|
||||
int x;
|
||||
UNUSED_VAR(y);
|
||||
|
||||
getyx(win, y, x);
|
||||
|
||||
UNUSED_VAR(y);
|
||||
|
||||
if (x > 0) { // Prevents us from printing off the screen
|
||||
break;
|
||||
}
|
||||
@ -556,22 +599,22 @@ void line_info_print(ToxWindow *self)
|
||||
wprintw(win, "%s %s: ", user_settings->line_normal, line->name1);
|
||||
wattroff(win, COLOR_PAIR(nameclr));
|
||||
|
||||
if (line->msg[0] == 0) {
|
||||
if (line->msg[0] == L'\0') {
|
||||
waddch(win, '\n');
|
||||
break;
|
||||
}
|
||||
|
||||
if (line->msg[0] == '>') {
|
||||
if (line->msg[0] == L'>') {
|
||||
wattron(win, COLOR_PAIR(GREEN));
|
||||
} else if (line->msg[0] == '<') {
|
||||
} else if (line->msg[0] == L'<') {
|
||||
wattron(win, COLOR_PAIR(RED));
|
||||
}
|
||||
|
||||
print_ret = print_wrap(win, line, max_x, max_y);
|
||||
print_wrap(win, line, max_x, max_y);
|
||||
|
||||
if (line->msg[0] == '>') {
|
||||
if (line->msg[0] == L'>') {
|
||||
wattroff(win, COLOR_PAIR(GREEN));
|
||||
} else if (line->msg[0] == '<') {
|
||||
} else if (line->msg[0] == L'<') {
|
||||
wattroff(win, COLOR_PAIR(RED));
|
||||
}
|
||||
|
||||
@ -591,7 +634,7 @@ void line_info_print(ToxWindow *self)
|
||||
|
||||
wattron(win, COLOR_PAIR(YELLOW));
|
||||
wprintw(win, "%s %s ", user_settings->line_normal, line->name1);
|
||||
print_ret = print_wrap(win, line, max_x, max_y);
|
||||
print_wrap(win, line, max_x, max_y);
|
||||
wattroff(win, COLOR_PAIR(YELLOW));
|
||||
|
||||
waddch(win, '\n');
|
||||
@ -612,7 +655,7 @@ void line_info_print(ToxWindow *self)
|
||||
wattron(win, COLOR_PAIR(line->colour));
|
||||
}
|
||||
|
||||
print_ret = print_wrap(win, line, max_x, max_y);
|
||||
print_wrap(win, line, max_x, max_y);
|
||||
waddch(win, '\n');
|
||||
|
||||
if (line->bold) {
|
||||
@ -630,8 +673,8 @@ void line_info_print(ToxWindow *self)
|
||||
wprintw(win, "$ ");
|
||||
wattroff(win, COLOR_PAIR(GREEN));
|
||||
|
||||
if (line->msg[0]) {
|
||||
print_ret = print_wrap(win, line, max_x, max_y);
|
||||
if (line->msg[0] != L'\0') {
|
||||
print_wrap(win, line, max_x, max_y);
|
||||
}
|
||||
|
||||
waddch(win, '\n');
|
||||
@ -649,7 +692,7 @@ void line_info_print(ToxWindow *self)
|
||||
wprintw(win, "%s ", line->name1);
|
||||
wattroff(win, A_BOLD);
|
||||
|
||||
print_ret = print_wrap(win, line, max_x, max_y);
|
||||
print_wrap(win, line, max_x, max_y);
|
||||
waddch(win, '\n');
|
||||
|
||||
wattroff(win, COLOR_PAIR(line->colour));
|
||||
@ -668,7 +711,7 @@ void line_info_print(ToxWindow *self)
|
||||
wprintw(win, "%s ", line->name1);
|
||||
wattroff(win, A_BOLD);
|
||||
|
||||
print_ret = print_wrap(win, line, max_x, max_y);
|
||||
print_wrap(win, line, max_x, max_y);
|
||||
waddch(win, '\n');
|
||||
|
||||
wattroff(win, COLOR_PAIR(line->colour));
|
||||
@ -686,7 +729,7 @@ void line_info_print(ToxWindow *self)
|
||||
wprintw(win, "%s", line->name1);
|
||||
wattroff(win, A_BOLD);
|
||||
|
||||
print_ret = print_wrap(win, line, max_x, max_y);
|
||||
print_wrap(win, line, max_x, max_y);
|
||||
|
||||
wattron(win, A_BOLD);
|
||||
wprintw(win, "%s\n", line->name2);
|
||||
@ -748,10 +791,9 @@ void line_info_set(ToxWindow *self, uint32_t id, char *msg)
|
||||
|
||||
while (line) {
|
||||
if (line->id == id) {
|
||||
size_t new_len = strlen(msg);
|
||||
line->len = line->len - line->msg_len + new_len;
|
||||
line->msg_len = new_len;
|
||||
snprintf(line->msg, sizeof(line->msg), "%s", msg);
|
||||
const uint16_t new_width = line_info_add_msg(line->msg, sizeof(line->msg), msg);
|
||||
line->len = line->len - line->msg_width + new_width;
|
||||
line->msg_width = new_width;
|
||||
return;
|
||||
}
|
||||
|
||||
|
@ -46,11 +46,11 @@ typedef enum LINE_TYPE {
|
||||
} LINE_TYPE;
|
||||
|
||||
struct line_info {
|
||||
char timestr[TIME_STR_SIZE];
|
||||
char name1[TOXIC_MAX_NAME_LENGTH + 1];
|
||||
char name2[TOXIC_MAX_NAME_LENGTH + 1];
|
||||
char msg[MAX_LINE_INFO_MSG_SIZE];
|
||||
time_t timestamp;
|
||||
char timestr[TIME_STR_SIZE];
|
||||
char name1[TOXIC_MAX_NAME_LENGTH + 1];
|
||||
char name2[TOXIC_MAX_NAME_LENGTH + 1];
|
||||
wchar_t msg[MAX_LINE_INFO_MSG_SIZE];
|
||||
time_t timestamp;
|
||||
uint8_t type;
|
||||
uint8_t bold;
|
||||
uint8_t colour;
|
||||
@ -58,7 +58,7 @@ struct line_info {
|
||||
bool read_flag; /* true if a message has been flagged as read */
|
||||
uint32_t id;
|
||||
uint16_t len; /* combined length of entire line */
|
||||
uint16_t msg_len; /* length of the message */
|
||||
uint16_t msg_width; /* width of the message */
|
||||
uint16_t format_lines; /* number of lines the combined string takes up (dynamically set) */
|
||||
|
||||
struct line_info *prev;
|
||||
|
@ -62,21 +62,21 @@ static int get_log_path(char *dest, int destsize, const char *name, const char *
|
||||
|
||||
/* first 6 bytes of selfkey */
|
||||
char self_id[32] = {0};
|
||||
path_len += KEY_IDENT_DIGITS * 2;
|
||||
path_len += KEY_IDENT_BYTES;
|
||||
sprintf(&self_id[0], "%02X", selfkey[0] & 0xff);
|
||||
sprintf(&self_id[2], "%02X", selfkey[1] & 0xff);
|
||||
sprintf(&self_id[4], "%02X", selfkey[2] & 0xff);
|
||||
self_id[KEY_IDENT_DIGITS * 2] = '\0';
|
||||
self_id[KEY_IDENT_BYTES] = '\0';
|
||||
|
||||
char other_id[32] = {0};
|
||||
|
||||
if (otherkey) {
|
||||
/* first 6 bytes of otherkey */
|
||||
path_len += KEY_IDENT_DIGITS * 2;
|
||||
path_len += KEY_IDENT_BYTES;
|
||||
sprintf(&other_id[0], "%02X", otherkey[0] & 0xff);
|
||||
sprintf(&other_id[2], "%02X", otherkey[1] & 0xff);
|
||||
sprintf(&other_id[4], "%02X", otherkey[2] & 0xff);
|
||||
other_id[KEY_IDENT_DIGITS * 2] = '\0';
|
||||
other_id[KEY_IDENT_BYTES] = '\0';
|
||||
}
|
||||
|
||||
if (path_len >= destsize) {
|
||||
|
@ -48,7 +48,7 @@ void cqueue_add(struct chat_queue *q, const char *msg, size_t len, uint8_t type,
|
||||
return;
|
||||
}
|
||||
|
||||
struct cqueue_msg *new_m = malloc(sizeof(struct cqueue_msg));
|
||||
struct cqueue_msg *new_m = calloc(1, sizeof(struct cqueue_msg));
|
||||
|
||||
if (new_m == NULL) {
|
||||
exit_toxic_err("failed in cqueue_message", FATALERR_MEMORY);
|
||||
@ -62,6 +62,7 @@ void cqueue_add(struct chat_queue *q, const char *msg, size_t len, uint8_t type,
|
||||
new_m->time_added = get_unix_time();
|
||||
new_m->receipt = -1;
|
||||
new_m->next = NULL;
|
||||
new_m->noread_flag = false;
|
||||
|
||||
if (q->root == NULL) {
|
||||
new_m->prev = NULL;
|
||||
@ -203,7 +204,7 @@ void cqueue_try_send(ToxWindow *self, Tox *m)
|
||||
return;
|
||||
}
|
||||
|
||||
TOX_ERR_FRIEND_SEND_MESSAGE err;
|
||||
Tox_Err_Friend_Send_Message err;
|
||||
Tox_Message_Type type = msg->type == OUT_MSG ? TOX_MESSAGE_TYPE_NORMAL : TOX_MESSAGE_TYPE_ACTION;
|
||||
uint32_t receipt = tox_friend_send_message(m, self->num, type, (uint8_t *) msg->message, msg->len, &err);
|
||||
|
||||
|
@ -148,7 +148,7 @@ void get_elapsed_time_str(char *buf, int bufsize, time_t secs)
|
||||
*/
|
||||
int tox_pk_string_to_bytes(const char *hex_string, size_t hex_len, char *output, size_t output_size)
|
||||
{
|
||||
if (output_size != TOX_PUBLIC_KEY_SIZE || hex_len > output_size * 2) {
|
||||
if (output_size != TOX_PUBLIC_KEY_SIZE || hex_len != output_size * 2) {
|
||||
return -1;
|
||||
}
|
||||
|
||||
@ -288,7 +288,7 @@ int qsort_strcasecmp_hlpr(const void *str1, const void *str2)
|
||||
/* case-insensitive string compare function for use with qsort */
|
||||
int qsort_ptr_char_array_helper(const void *str1, const void *str2)
|
||||
{
|
||||
return strcasecmp(*(char **)str1, *(char **)str2);
|
||||
return strcasecmp(*(const char *const *)str1, *(const char *const *)str2);
|
||||
}
|
||||
|
||||
static const char invalid_chars[] = {'/', '\n', '\t', '\v', '\r', '\0'};
|
||||
@ -477,10 +477,9 @@ on_error:
|
||||
returns length of msg, which will be no larger than size-1 */
|
||||
size_t copy_tox_str(char *msg, size_t size, const char *data, size_t length)
|
||||
{
|
||||
size_t i;
|
||||
size_t j = 0;
|
||||
|
||||
for (i = 0; (i < length) && (j < size - 1); ++i) {
|
||||
for (size_t i = 0; (i < length) && (j < size - 1); ++i) {
|
||||
if (data[i] != '\r') {
|
||||
msg[j++] = data[i];
|
||||
}
|
||||
|
@ -33,9 +33,6 @@
|
||||
#include "toxic.h"
|
||||
#include "windows.h"
|
||||
|
||||
extern struct arg_opts arg_opts;
|
||||
extern struct Winthread Winthread;
|
||||
|
||||
#define NAMESERVER_API_PATH "api"
|
||||
#define SERVER_KEY_SIZE 32
|
||||
#define MAX_SERVERS 50
|
||||
@ -111,14 +108,15 @@ static int load_nameserver_list(const char *path)
|
||||
char line[MAX_SERVER_LINE];
|
||||
|
||||
while (fgets(line, sizeof(line), fp) && Nameservers.lines < MAX_SERVERS) {
|
||||
int linelen = strlen(line);
|
||||
size_t linelen = strlen(line);
|
||||
|
||||
if (linelen < SERVER_KEY_SIZE * 2 + 5) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if (line[linelen - 1] == '\n') {
|
||||
line[--linelen] = '\0';
|
||||
--linelen;
|
||||
line[linelen] = '\0';
|
||||
}
|
||||
|
||||
const char *name = strtok(line, " ");
|
||||
|
299
src/netprof.c
Normal file
299
src/netprof.c
Normal file
@ -0,0 +1,299 @@
|
||||
/* netprof.c
|
||||
*
|
||||
*
|
||||
* Copyright (C) 2022 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/>.
|
||||
*
|
||||
*/
|
||||
|
||||
#include <stdint.h>
|
||||
#include <stdio.h>
|
||||
|
||||
#include "netprof.h"
|
||||
|
||||
#include "../../toxcore/toxcore/tox_private.h" // set this to your local toxcore source directory
|
||||
|
||||
static void log_tcp_packet_id(FILE *fp, unsigned int id, uint64_t total, uint64_t TCP_id_sent, uint64_t TCP_id_recv)
|
||||
{
|
||||
switch (id) {
|
||||
case TOX_NETPROF_PACKET_ID_ZERO:
|
||||
case TOX_NETPROF_PACKET_ID_ONE:
|
||||
case TOX_NETPROF_PACKET_ID_TWO:
|
||||
case TOX_NETPROF_PACKET_ID_TCP_DISCONNECT:
|
||||
case TOX_NETPROF_PACKET_ID_FOUR:
|
||||
case TOX_NETPROF_PACKET_ID_TCP_PONG:
|
||||
case TOX_NETPROF_PACKET_ID_TCP_OOB_SEND:
|
||||
case TOX_NETPROF_PACKET_ID_TCP_OOB_RECV:
|
||||
case TOX_NETPROF_PACKET_ID_TCP_ONION_REQUEST:
|
||||
case TOX_NETPROF_PACKET_ID_TCP_ONION_RESPONSE:
|
||||
case TOX_NETPROF_PACKET_ID_TCP_DATA: {
|
||||
if (TCP_id_recv || TCP_id_sent) {
|
||||
fprintf(fp, "0x%02x (total): %lu (%.2f%%)\n", id, TCP_id_sent + TCP_id_recv,
|
||||
((float)TCP_id_recv + TCP_id_sent) / total * 100.0);
|
||||
}
|
||||
|
||||
if (TCP_id_sent) {
|
||||
fprintf(fp, "0x%02x (sent): %lu (%.2f%%)\n", id, TCP_id_sent, (float)TCP_id_sent / total * 100.0);
|
||||
}
|
||||
|
||||
if (TCP_id_recv) {
|
||||
fprintf(fp, "0x%02x (recv): %lu (%.2f%%)\n", id, TCP_id_recv, (float)TCP_id_recv / total * 100.0);
|
||||
}
|
||||
|
||||
break;
|
||||
}
|
||||
|
||||
default:
|
||||
return;
|
||||
}
|
||||
}
|
||||
static void log_udp_packet_id(FILE *fp, unsigned int id, uint64_t total, uint64_t UDP_id_sent, uint64_t UDP_id_recv)
|
||||
{
|
||||
switch (id) {
|
||||
case TOX_NETPROF_PACKET_ID_ZERO:
|
||||
case TOX_NETPROF_PACKET_ID_ONE:
|
||||
case TOX_NETPROF_PACKET_ID_TWO:
|
||||
case TOX_NETPROF_PACKET_ID_FOUR:
|
||||
case TOX_NETPROF_PACKET_ID_COOKIE_REQUEST:
|
||||
case TOX_NETPROF_PACKET_ID_COOKIE_RESPONSE:
|
||||
case TOX_NETPROF_PACKET_ID_CRYPTO_HS:
|
||||
case TOX_NETPROF_PACKET_ID_CRYPTO_DATA:
|
||||
case TOX_NETPROF_PACKET_ID_CRYPTO:
|
||||
case TOX_NETPROF_PACKET_ID_LAN_DISCOVERY:
|
||||
case TOX_NETPROF_PACKET_ID_ONION_SEND_INITIAL:
|
||||
case TOX_NETPROF_PACKET_ID_ONION_SEND_1:
|
||||
case TOX_NETPROF_PACKET_ID_ONION_SEND_2:
|
||||
case TOX_NETPROF_PACKET_ID_ANNOUNCE_REQUEST:
|
||||
case TOX_NETPROF_PACKET_ID_ANNOUNCE_RESPONSE:
|
||||
case TOX_NETPROF_PACKET_ID_ONION_DATA_REQUEST:
|
||||
case TOX_NETPROF_PACKET_ID_ONION_DATA_RESPONSE:
|
||||
case TOX_NETPROF_PACKET_ID_ONION_RECV_3:
|
||||
case TOX_NETPROF_PACKET_ID_ONION_RECV_2:
|
||||
case TOX_NETPROF_PACKET_ID_ONION_RECV_1:
|
||||
case TOX_NETPROF_PACKET_ID_BOOTSTRAP_INFO: {
|
||||
if (UDP_id_recv || UDP_id_sent) {
|
||||
fprintf(fp, "0x%02x (total): %lu (%.2f%%)\n", id, UDP_id_sent + UDP_id_recv,
|
||||
((float)UDP_id_recv + UDP_id_sent) / total * 100.0);
|
||||
}
|
||||
|
||||
if (UDP_id_sent) {
|
||||
fprintf(fp, "0x%02x (sent): %lu (%.2f%%)\n", id, UDP_id_sent, (float)UDP_id_sent / total * 100.0);
|
||||
}
|
||||
|
||||
if (UDP_id_recv) {
|
||||
fprintf(fp, "0x%02x (recv): %lu (%.2f%%)\n", id, UDP_id_recv, (float)UDP_id_recv / total * 100.0);
|
||||
}
|
||||
|
||||
break;
|
||||
}
|
||||
|
||||
default:
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
static void dump_packet_id_counts(const Tox *m, FILE *fp, uint64_t total_count, Tox_Netprof_Packet_Type packet_type)
|
||||
{
|
||||
if (packet_type == TOX_NETPROF_PACKET_TYPE_TCP) {
|
||||
fprintf(fp, "--- TCP packet counts by packet ID --- \n");
|
||||
} else {
|
||||
fprintf(fp, "--- UDP packet counts by packet ID --- \n");
|
||||
}
|
||||
|
||||
for (unsigned long i = TOX_NETPROF_PACKET_ID_ZERO; i <= TOX_NETPROF_PACKET_ID_BOOTSTRAP_INFO; ++i) {
|
||||
const uint64_t id_count_sent = tox_netprof_get_packet_id_count(m, packet_type, i, TOX_NETPROF_DIRECTION_SENT);
|
||||
const uint64_t id_count_recv = tox_netprof_get_packet_id_count(m, packet_type, i, TOX_NETPROF_DIRECTION_RECV);
|
||||
|
||||
if (packet_type == TOX_NETPROF_PACKET_TYPE_TCP) {
|
||||
log_tcp_packet_id(fp, i, total_count, id_count_sent, id_count_recv);
|
||||
} else {
|
||||
log_udp_packet_id(fp, i, total_count, id_count_sent, id_count_recv);
|
||||
}
|
||||
}
|
||||
|
||||
fprintf(fp, "\n\n");
|
||||
}
|
||||
|
||||
static void dump_packet_id_bytes(const Tox *m, FILE *fp, uint64_t total_bytes, Tox_Netprof_Packet_Type packet_type)
|
||||
{
|
||||
if (packet_type == TOX_NETPROF_PACKET_TYPE_TCP) {
|
||||
fprintf(fp, "--- TCP byte counts by packet ID --- \n");
|
||||
} else {
|
||||
fprintf(fp, "--- UDP byte counts by packet ID --- \n");
|
||||
}
|
||||
|
||||
for (unsigned long i = TOX_NETPROF_PACKET_ID_ZERO; i <= TOX_NETPROF_PACKET_ID_BOOTSTRAP_INFO; ++i) {
|
||||
const uint64_t id_bytes_sent = tox_netprof_get_packet_id_bytes(m, packet_type, i, TOX_NETPROF_DIRECTION_SENT);
|
||||
const uint64_t id_bytes_recv = tox_netprof_get_packet_id_bytes(m, packet_type, i, TOX_NETPROF_DIRECTION_RECV);
|
||||
|
||||
if (packet_type == TOX_NETPROF_PACKET_TYPE_TCP) {
|
||||
log_tcp_packet_id(fp, i, total_bytes, id_bytes_sent, id_bytes_recv);
|
||||
} else {
|
||||
log_udp_packet_id(fp, i, total_bytes, id_bytes_sent, id_bytes_recv);
|
||||
}
|
||||
}
|
||||
|
||||
fprintf(fp, "\n\n");
|
||||
}
|
||||
|
||||
static void dump_packet_count_totals(const Tox *m, FILE *fp, uint64_t total_packet_count,
|
||||
uint64_t UDP_count_sent, uint64_t UDP_count_recv,
|
||||
uint64_t TCP_count_sent, uint64_t TCP_count_recv)
|
||||
{
|
||||
const uint64_t total_UDP_count = UDP_count_sent + UDP_count_recv;
|
||||
const uint64_t total_TCP_count = TCP_count_sent + TCP_count_recv;
|
||||
const uint64_t total_packet_count_sent = UDP_count_sent + TCP_count_sent;
|
||||
const uint64_t total_packet_count_recv = UDP_count_recv + TCP_count_recv;
|
||||
|
||||
fprintf(fp, "--- Total packet counts --- \n");
|
||||
|
||||
fprintf(fp, "Total packets: %lu\n", total_packet_count);
|
||||
|
||||
fprintf(fp, "Total packets sent: %lu (%.2f%%)\n", total_packet_count_sent,
|
||||
(float)total_packet_count_sent / total_packet_count * 100.0);
|
||||
|
||||
fprintf(fp, "Total packets recv: %lu (%.2f%%)\n", total_packet_count_recv,
|
||||
(float)total_packet_count_recv / total_packet_count * 100.0);
|
||||
|
||||
fprintf(fp, "total UDP packets: %lu (%.2f%%)\n", total_UDP_count,
|
||||
(float)total_UDP_count / total_packet_count * 100.0);
|
||||
|
||||
fprintf(fp, "UDP packets sent: %lu (%.2f%%)\n", UDP_count_sent,
|
||||
(float)UDP_count_sent / total_packet_count * 100.0);
|
||||
|
||||
fprintf(fp, "UDP packets recv: %lu (%.2f%%)\n", UDP_count_recv,
|
||||
(float)UDP_count_recv / total_packet_count * 100.0);
|
||||
|
||||
fprintf(fp, "Total TCP packets: %lu (%.2f%%)\n", total_TCP_count,
|
||||
(float)total_TCP_count / total_packet_count * 100.0);
|
||||
|
||||
fprintf(fp, "TCP packets sent: %lu (%.2f%%)\n", TCP_count_sent,
|
||||
(float)TCP_count_sent / total_packet_count * 100.0);
|
||||
|
||||
fprintf(fp, "TCP packets recv: %lu (%.2f%%)\n", TCP_count_recv,
|
||||
(float)TCP_count_recv / total_packet_count * 100.0);
|
||||
|
||||
fprintf(fp, "\n\n");
|
||||
}
|
||||
|
||||
void dump_packet_bytes_totals(const Tox *m, FILE *fp, const uint64_t total_bytes,
|
||||
const uint64_t UDP_bytes_sent, const uint64_t UDP_bytes_recv,
|
||||
const uint64_t TCP_bytes_sent, const uint64_t TCP_bytes_recv)
|
||||
{
|
||||
const uint64_t total_UDP_bytes = UDP_bytes_sent + UDP_bytes_recv;
|
||||
const uint64_t total_TCP_bytes = TCP_bytes_sent + TCP_bytes_recv;
|
||||
const uint64_t total_bytes_sent = UDP_bytes_sent + TCP_bytes_sent;
|
||||
const uint64_t total_bytes_recv = UDP_bytes_recv + TCP_bytes_recv;
|
||||
|
||||
fprintf(fp, "--- Total byte counts --- \n");
|
||||
|
||||
fprintf(fp, "Total bytes: %lu\n", total_bytes);
|
||||
|
||||
fprintf(fp, "Total bytes sent: %lu (%.2f%%)\n", total_bytes_sent,
|
||||
(float)total_bytes_sent / total_bytes * 100.0);
|
||||
|
||||
fprintf(fp, "Total bytes recv: %lu (%.2f%%)\n", total_bytes_recv,
|
||||
(float)total_bytes_recv / total_bytes * 100.0);
|
||||
|
||||
fprintf(fp, "Total UDP bytes: %lu (%.2f%%)\n", total_UDP_bytes,
|
||||
(float)total_UDP_bytes / total_bytes * 100.0);
|
||||
|
||||
fprintf(fp, "UDP bytes sent: %lu (%.2f%%)\n", UDP_bytes_sent,
|
||||
(float)UDP_bytes_sent / total_bytes * 100.0);
|
||||
|
||||
fprintf(fp, "UDP bytes recv: %lu (%.2f%%)\n", UDP_bytes_recv,
|
||||
(float)UDP_bytes_recv / total_bytes * 100.0);
|
||||
|
||||
fprintf(fp, "Total TCP bytes: %lu (%.2f%%)\n", total_TCP_bytes,
|
||||
(float)total_TCP_bytes / total_bytes * 100.0);
|
||||
|
||||
fprintf(fp, "TCP bytes sent: %lu (%.2f%%)\n", TCP_bytes_sent,
|
||||
(float)TCP_bytes_sent / total_bytes * 100.0);
|
||||
|
||||
fprintf(fp, "TCP bytes recv: %lu (%.2f%%)\n", TCP_bytes_recv,
|
||||
(float)TCP_bytes_recv / total_bytes * 100.0);
|
||||
|
||||
fprintf(fp, "\n\n");
|
||||
}
|
||||
|
||||
void netprof_log_dump(const Tox *m, FILE *fp, time_t run_time)
|
||||
{
|
||||
if (fp == NULL) {
|
||||
fprintf(stderr, "Failed to dump network statistics: null file pointer\n");
|
||||
return;
|
||||
}
|
||||
|
||||
const uint64_t UDP_count_sent = tox_netprof_get_packet_total_count(m, TOX_NETPROF_PACKET_TYPE_UDP,
|
||||
TOX_NETPROF_DIRECTION_SENT);
|
||||
const uint64_t UDP_count_recv = tox_netprof_get_packet_total_count(m, TOX_NETPROF_PACKET_TYPE_UDP,
|
||||
TOX_NETPROF_DIRECTION_RECV);
|
||||
const uint64_t TCP_count_sent = tox_netprof_get_packet_total_count(m, TOX_NETPROF_PACKET_TYPE_TCP,
|
||||
TOX_NETPROF_DIRECTION_SENT);
|
||||
const uint64_t TCP_count_recv = tox_netprof_get_packet_total_count(m, TOX_NETPROF_PACKET_TYPE_TCP,
|
||||
TOX_NETPROF_DIRECTION_RECV);
|
||||
const uint64_t UDP_bytes_sent = tox_netprof_get_packet_total_bytes(m, TOX_NETPROF_PACKET_TYPE_UDP,
|
||||
TOX_NETPROF_DIRECTION_SENT);
|
||||
const uint64_t UDP_bytes_recv = tox_netprof_get_packet_total_bytes(m, TOX_NETPROF_PACKET_TYPE_UDP,
|
||||
TOX_NETPROF_DIRECTION_RECV);
|
||||
const uint64_t TCP_bytes_sent = tox_netprof_get_packet_total_bytes(m, TOX_NETPROF_PACKET_TYPE_TCP,
|
||||
TOX_NETPROF_DIRECTION_SENT);
|
||||
const uint64_t TCP_bytes_recv = tox_netprof_get_packet_total_bytes(m, TOX_NETPROF_PACKET_TYPE_TCP,
|
||||
TOX_NETPROF_DIRECTION_RECV);
|
||||
|
||||
const uint64_t total_count = UDP_count_sent + UDP_count_recv + TCP_count_sent + TCP_count_recv;
|
||||
const uint64_t total_bytes = UDP_bytes_sent + UDP_bytes_recv + TCP_bytes_sent + TCP_bytes_recv;
|
||||
|
||||
fprintf(fp, "--- Tox network profile log dump ---\n");
|
||||
fprintf(fp, "Run time: %lu seconds\n", run_time);
|
||||
|
||||
if (run_time && total_count && total_bytes) {
|
||||
fprintf(fp, "Average kilobytes per second: %.2f\n", ((float)total_bytes / run_time) / 1000.0);
|
||||
fprintf(fp, "Average packets per second: %lu\n", total_count / run_time);
|
||||
fprintf(fp, "Average packet size: %lu bytes\n", total_bytes / total_count);
|
||||
fprintf(fp, "\n");
|
||||
}
|
||||
|
||||
dump_packet_count_totals(m, fp, total_count, UDP_count_sent, UDP_count_recv, TCP_count_sent, TCP_count_recv);
|
||||
dump_packet_bytes_totals(m, fp, total_bytes, UDP_bytes_sent, UDP_bytes_recv, TCP_bytes_sent, TCP_bytes_recv);
|
||||
dump_packet_id_counts(m, fp, total_count, TOX_NETPROF_PACKET_TYPE_TCP);
|
||||
dump_packet_id_counts(m, fp, total_count, TOX_NETPROF_PACKET_TYPE_UDP);
|
||||
dump_packet_id_bytes(m, fp, total_bytes, TOX_NETPROF_PACKET_TYPE_TCP);
|
||||
dump_packet_id_bytes(m, fp, total_bytes, TOX_NETPROF_PACKET_TYPE_UDP);
|
||||
|
||||
fflush(fp);
|
||||
}
|
||||
|
||||
uint64_t netprof_get_bytes_up(const Tox *m)
|
||||
{
|
||||
const uint64_t UDP_bytes_sent = tox_netprof_get_packet_total_bytes(m, TOX_NETPROF_PACKET_TYPE_UDP,
|
||||
TOX_NETPROF_DIRECTION_SENT);
|
||||
const uint64_t TCP_bytes_sent = tox_netprof_get_packet_total_bytes(m, TOX_NETPROF_PACKET_TYPE_TCP,
|
||||
TOX_NETPROF_DIRECTION_SENT);
|
||||
|
||||
return UDP_bytes_sent + TCP_bytes_sent;
|
||||
|
||||
}
|
||||
|
||||
uint64_t netprof_get_bytes_down(const Tox *m)
|
||||
{
|
||||
const uint64_t UDP_bytes_recv = tox_netprof_get_packet_total_bytes(m, TOX_NETPROF_PACKET_TYPE_UDP,
|
||||
TOX_NETPROF_DIRECTION_RECV);
|
||||
const uint64_t TCP_bytes_recv = tox_netprof_get_packet_total_bytes(m, TOX_NETPROF_PACKET_TYPE_TCP,
|
||||
TOX_NETPROF_DIRECTION_RECV);
|
||||
|
||||
return UDP_bytes_recv + TCP_bytes_recv;
|
||||
}
|
35
src/netprof.h
Normal file
35
src/netprof.h
Normal file
@ -0,0 +1,35 @@
|
||||
/* netprof.h
|
||||
*
|
||||
*
|
||||
* Copyright (C) 2022 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 TOXIC_NETPROF
|
||||
#define TOXIC_NETPROF
|
||||
|
||||
#include <stdio.h>
|
||||
#include <time.h>
|
||||
#include <tox/tox.h>
|
||||
|
||||
void netprof_log_dump(const Tox *m, FILE *fp, time_t run_time);
|
||||
|
||||
uint64_t netprof_get_bytes_down(const Tox *m);
|
||||
uint64_t netprof_get_bytes_up(const Tox *m);
|
||||
|
||||
#endif // TOXIC_NETPROF
|
15
src/notify.c
15
src/notify.c
@ -489,16 +489,27 @@ void terminate_notify(void)
|
||||
}
|
||||
|
||||
#ifdef SOUND_NOTIFY
|
||||
int set_sound(Notification sound, const char *value)
|
||||
|
||||
/*
|
||||
* Sets notification sound designated by `sound` to file path `value`.
|
||||
*
|
||||
* Return true if the sound is successfully set.
|
||||
*/
|
||||
bool set_sound(Notification sound, const char *value)
|
||||
{
|
||||
if (sound == silent) {
|
||||
return 0;
|
||||
return false;
|
||||
}
|
||||
|
||||
free(Control.sounds[sound]);
|
||||
|
||||
size_t len = strlen(value) + 1;
|
||||
Control.sounds[sound] = calloc(len, 1);
|
||||
|
||||
if (Control.sounds[sound] == NULL) {
|
||||
return false;
|
||||
}
|
||||
|
||||
memcpy(Control.sounds[sound], value, len);
|
||||
|
||||
struct stat buf;
|
||||
|
@ -77,7 +77,7 @@ int box_silent_notify(ToxWindow *self, uint64_t flags, int *id_indicator, const
|
||||
int box_silent_notify2(ToxWindow *self, uint64_t flags, int id, const char *format, ...);
|
||||
|
||||
#ifdef SOUND_NOTIFY
|
||||
int set_sound(Notification sound, const char *value);
|
||||
bool set_sound(Notification sound, const char *value);
|
||||
#endif /* SOUND_NOTIFY */
|
||||
|
||||
#endif /* NOTIFY_H */
|
||||
|
107
src/prompt.c
107
src/prompt.c
@ -36,6 +36,7 @@
|
||||
#include "line_info.h"
|
||||
#include "log.h"
|
||||
#include "misc_tools.h"
|
||||
#include "netprof.h"
|
||||
#include "notify.h"
|
||||
#include "prompt.h"
|
||||
#include "settings.h"
|
||||
@ -175,9 +176,7 @@ static int add_friend_request(const char *public_key, const char *data)
|
||||
return -1;
|
||||
}
|
||||
|
||||
int i;
|
||||
|
||||
for (i = 0; i <= FrndRequests.max_idx; ++i) {
|
||||
for (int i = 0; i <= FrndRequests.max_idx; ++i) {
|
||||
if (!FrndRequests.request[i].active) {
|
||||
FrndRequests.request[i].active = true;
|
||||
memcpy(FrndRequests.request[i].key, public_key, TOX_PUBLIC_KEY_SIZE);
|
||||
@ -307,6 +306,77 @@ static bool prompt_onKey(ToxWindow *self, Tox *m, wint_t key, bool ltr)
|
||||
return input_ret;
|
||||
}
|
||||
|
||||
#define NET_INFO_REFRESH_INTERVAL 1
|
||||
static void draw_network_info(const Tox *m, StatusBar *stb)
|
||||
{
|
||||
WINDOW *win = stb->topline;
|
||||
|
||||
wattron(win, COLOR_PAIR(BAR_TEXT));
|
||||
wprintw(win, "%s", stb->network_info);
|
||||
wattroff(win, COLOR_PAIR(BAR_TEXT));
|
||||
|
||||
if (!timed_out(stb->time_last_refreshed, NET_INFO_REFRESH_INTERVAL)) {
|
||||
return;
|
||||
}
|
||||
|
||||
stb->time_last_refreshed = get_unix_time();
|
||||
|
||||
const uint64_t up_bytes = netprof_get_bytes_up(m);
|
||||
const uint64_t down_bytes = netprof_get_bytes_down(m);
|
||||
|
||||
const uint64_t up_delta = (up_bytes - stb->up_bytes) / NET_INFO_REFRESH_INTERVAL;
|
||||
const uint64_t down_delta = (down_bytes - stb->down_bytes) / NET_INFO_REFRESH_INTERVAL;
|
||||
|
||||
stb->up_bytes = up_bytes;
|
||||
stb->down_bytes = down_bytes;
|
||||
|
||||
float up = up_bytes;
|
||||
float down = down_bytes;
|
||||
const char *up_unit = "bytes";
|
||||
const char *down_unit = "bytes";
|
||||
|
||||
if (up_bytes > MiB) {
|
||||
up /= (float)MiB;
|
||||
up_unit = "MiB";
|
||||
} else if (up_bytes > KiB) {
|
||||
up /= (float)KiB;
|
||||
up_unit = "KiB";
|
||||
}
|
||||
|
||||
if (down_bytes > MiB) {
|
||||
down /= (float)MiB;
|
||||
down_unit = "MiB";
|
||||
} else if (down_bytes > KiB) {
|
||||
down /= (float)KiB;
|
||||
down_unit = "KiB";
|
||||
}
|
||||
|
||||
float up_bps = up_delta;
|
||||
float down_bps = down_delta;
|
||||
const char *up_bps_unit = "b/s";
|
||||
const char *down_bps_unit = "b/s";
|
||||
|
||||
if (up_bps > MiB) {
|
||||
up_bps /= (float)MiB;
|
||||
up_bps_unit = "MiB/s";
|
||||
} else if (up_bps > KiB) {
|
||||
up_bps /= (float)KiB;
|
||||
up_bps_unit = "KiB/s";
|
||||
}
|
||||
|
||||
if (down_bps > MiB) {
|
||||
down_bps /= (float)MiB;
|
||||
down_bps_unit = "MiB/s";
|
||||
} else if (down_bps > KiB) {
|
||||
down_bps /= (float)KiB;
|
||||
down_bps_unit = "KiB/s";
|
||||
}
|
||||
|
||||
snprintf(stb->network_info, sizeof(stb->network_info),
|
||||
" | [Up: %.1f%s (%.1f%s) | Down: %.1f%s (%.1f%s)]", up, up_unit, up_bps, up_bps_unit,
|
||||
down, down_unit, down_bps, down_bps_unit);
|
||||
}
|
||||
|
||||
static void prompt_onDraw(ToxWindow *self, Tox *m)
|
||||
{
|
||||
int x2;
|
||||
@ -464,6 +534,10 @@ static void prompt_onDraw(ToxWindow *self, Tox *m)
|
||||
wattroff(statusbar->topline, COLOR_PAIR(BAR_TEXT));
|
||||
}
|
||||
|
||||
if (user_settings->show_network_info) {
|
||||
draw_network_info(m, statusbar);
|
||||
}
|
||||
|
||||
int y;
|
||||
int x;
|
||||
getyx(self->window, y, x);
|
||||
@ -526,6 +600,26 @@ static void prompt_onConnectionChange(ToxWindow *self, Tox *m, uint32_t friendnu
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Return true is the first 3 bytes of `key` are identical to any other contact in the contact list.
|
||||
*/
|
||||
static bool key_is_similar(const char *key)
|
||||
{
|
||||
for (size_t i = 0; i < Friends.max_idx; ++i) {
|
||||
const ToxicFriend *friend = &Friends.list[i];
|
||||
|
||||
if (!friend->active) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if (memcmp(friend->pub_key, key, KEY_IDENT_BYTES / 2) == 0) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
static void prompt_onFriendRequest(ToxWindow *self, Tox *m, const char *key, const char *data, size_t length)
|
||||
{
|
||||
UNUSED_VAR(m);
|
||||
@ -536,6 +630,13 @@ static void prompt_onFriendRequest(ToxWindow *self, Tox *m, const char *key, con
|
||||
line_info_add(self, true, NULL, NULL, SYS_MSG, 0, 0, "Friend request with the message '%s'", data);
|
||||
write_to_log("Friend request with the message '%s'", "", ctx->log, true);
|
||||
|
||||
if (key_is_similar(key)) {
|
||||
line_info_add(self, false, NULL, NULL, SYS_MSG, 0, RED,
|
||||
"WARNING: This contact's public key is suspiciously similar to that of another contact ");
|
||||
line_info_add(self, false, NULL, NULL, SYS_MSG, 0, RED,
|
||||
"in your list. This may be an impersonation attempt, or it may have occurred by chance.");
|
||||
}
|
||||
|
||||
int n = add_friend_request(key, data);
|
||||
|
||||
if (n == -1) {
|
||||
|
@ -40,6 +40,9 @@ typedef struct FriendRequests {
|
||||
struct friend_request request[MAX_FRIEND_REQUESTS];
|
||||
} FriendRequests;
|
||||
|
||||
extern ToxWindow *prompt;
|
||||
extern FriendRequests FrndRequests;
|
||||
|
||||
ToxWindow *new_prompt(void);
|
||||
|
||||
void prep_prompt_win(void);
|
||||
|
@ -20,9 +20,10 @@
|
||||
*
|
||||
*/
|
||||
|
||||
#include "api.h"
|
||||
|
||||
#ifdef PYTHON
|
||||
#include <Python.h>
|
||||
#include "api.h"
|
||||
|
||||
#include "execute.h"
|
||||
|
||||
|
@ -63,6 +63,7 @@ static struct ui_strings {
|
||||
const char *show_typing_other;
|
||||
const char *show_welcome_msg;
|
||||
const char *show_connection_msg;
|
||||
const char *show_network_info;
|
||||
const char *nodeslist_update_freq;
|
||||
const char *autosave_freq;
|
||||
|
||||
@ -97,6 +98,7 @@ static struct ui_strings {
|
||||
"show_typing_other",
|
||||
"show_welcome_msg",
|
||||
"show_connection_msg",
|
||||
"show_network_info",
|
||||
"nodeslist_update_freq",
|
||||
"autosave_freq",
|
||||
"line_join",
|
||||
@ -130,6 +132,7 @@ static void ui_defaults(struct user_settings *settings)
|
||||
settings->show_typing_other = SHOW_TYPING_ON;
|
||||
settings->show_welcome_msg = SHOW_WELCOME_MSG_ON;
|
||||
settings->show_connection_msg = SHOW_CONNECTION_MSG_ON;
|
||||
settings->show_network_info = SHOW_NETWORK_INFO_OFF;
|
||||
settings->nodeslist_update_freq = 7;
|
||||
settings->autosave_freq = 600;
|
||||
|
||||
@ -398,6 +401,7 @@ int settings_load(struct user_settings *s, const char *patharg)
|
||||
config_setting_lookup_bool(setting, ui_strings.show_typing_other, &s->show_typing_other);
|
||||
config_setting_lookup_bool(setting, ui_strings.show_welcome_msg, &s->show_welcome_msg);
|
||||
config_setting_lookup_bool(setting, ui_strings.show_connection_msg, &s->show_connection_msg);
|
||||
config_setting_lookup_bool(setting, ui_strings.show_network_info, &s->show_network_info);
|
||||
|
||||
config_setting_lookup_int(setting, ui_strings.history_size, &s->history_size);
|
||||
config_setting_lookup_int(setting, ui_strings.notification_timeout, &s->notification_timeout);
|
||||
|
@ -54,6 +54,7 @@ struct user_settings {
|
||||
int show_typing_other; /* boolean */
|
||||
int show_welcome_msg; /* boolean */
|
||||
int show_connection_msg; /* boolean */
|
||||
int show_network_info; /* boolean */
|
||||
int nodeslist_update_freq; /* int (<= 0 to disable updates) */
|
||||
int autosave_freq; /* int (<= 0 to disable autosave) */
|
||||
|
||||
@ -96,6 +97,8 @@ struct user_settings {
|
||||
#endif
|
||||
};
|
||||
|
||||
extern struct user_settings *user_settings;
|
||||
|
||||
enum settings_values {
|
||||
AUTOLOG_OFF = 0,
|
||||
AUTOLOG_ON = 1,
|
||||
@ -118,6 +121,9 @@ enum settings_values {
|
||||
SHOW_CONNECTION_MSG_OFF = 0,
|
||||
SHOW_CONNECTION_MSG_ON = 1,
|
||||
|
||||
SHOW_NETWORK_INFO_OFF = 0,
|
||||
SHOW_NETWORK_INFO_ON = 1,
|
||||
|
||||
DFLT_HST_SIZE = 700,
|
||||
|
||||
MPLEX_OFF = 0,
|
||||
|
74
src/toxic.c
74
src/toxic.c
@ -58,6 +58,7 @@
|
||||
#include "message_queue.h"
|
||||
#include "misc_tools.h"
|
||||
#include "name_lookup.h"
|
||||
#include "netprof.h"
|
||||
#include "notify.h"
|
||||
#include "prompt.h"
|
||||
#include "settings.h"
|
||||
@ -74,7 +75,7 @@
|
||||
#ifdef VIDEO
|
||||
#include "video_call.h"
|
||||
#endif /* VIDEO */
|
||||
ToxAV *av;
|
||||
static ToxAV *av;
|
||||
#endif /* AUDIO */
|
||||
|
||||
#ifdef PYTHON
|
||||
@ -98,10 +99,13 @@ ToxWindow *prompt = NULL;
|
||||
#define MAX_PASSWORD_LEN 64
|
||||
|
||||
struct Winthread Winthread;
|
||||
struct cqueue_thread cqueue_thread;
|
||||
struct av_thread av_thread;
|
||||
static struct cqueue_thread cqueue_thread;
|
||||
struct arg_opts arg_opts;
|
||||
|
||||
#ifdef AUDIO
|
||||
static struct av_thread av_thread;
|
||||
#endif
|
||||
|
||||
// This struct is not thread safe. It should only ever be written to from the main thread
|
||||
// before any other thread that uses it is initialized.
|
||||
struct user_settings *user_settings = NULL;
|
||||
@ -140,6 +144,22 @@ static void catch_SIGSEGV(int sig)
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
void cb_toxcore_logger(Tox *m, TOX_LOG_LEVEL level, const char *file, uint32_t line, const char *func,
|
||||
const char *message, void *user_data)
|
||||
{
|
||||
UNUSED_VAR(user_data);
|
||||
UNUSED_VAR(file);
|
||||
UNUSED_VAR(m);
|
||||
|
||||
if (user_data) {
|
||||
FILE *fp = (FILE *)user_data;
|
||||
fprintf(fp, "[%d] %u:%s() - %s\n", level, line, func, message);
|
||||
fflush(fp);
|
||||
} else {
|
||||
fprintf(stderr, "[%d] %u:%s() - %s\n", level, line, func, message);
|
||||
}
|
||||
}
|
||||
|
||||
static void flag_window_resize(int sig)
|
||||
{
|
||||
UNUSED_VAR(sig);
|
||||
@ -174,6 +194,10 @@ void free_global_data(void)
|
||||
|
||||
void exit_toxic_success(Tox *m)
|
||||
{
|
||||
if (arg_opts.netprof_log_dump) {
|
||||
netprof_log_dump(m, arg_opts.netprof_fp, get_unix_time() - arg_opts.netprof_start_time);
|
||||
}
|
||||
|
||||
store_data(m, DATA_FILE);
|
||||
|
||||
user_password = (struct user_password) {
|
||||
@ -204,6 +228,11 @@ void exit_toxic_success(Tox *m)
|
||||
arg_opts.log_fp = NULL;
|
||||
}
|
||||
|
||||
if (arg_opts.netprof_fp != NULL) {
|
||||
fclose(arg_opts.netprof_fp);
|
||||
arg_opts.netprof_fp = NULL;
|
||||
}
|
||||
|
||||
endwin();
|
||||
curl_global_cleanup();
|
||||
|
||||
@ -226,22 +255,6 @@ void exit_toxic_err(const char *errmsg, int errcode)
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
void cb_toxcore_logger(Tox *m, TOX_LOG_LEVEL level, const char *file, uint32_t line, const char *func,
|
||||
const char *message, void *user_data)
|
||||
{
|
||||
UNUSED_VAR(user_data);
|
||||
UNUSED_VAR(file);
|
||||
UNUSED_VAR(m);
|
||||
|
||||
if (user_data) {
|
||||
FILE *fp = (FILE *)user_data;
|
||||
fprintf(fp, "[%d] %u:%s() - %s\n", level, line, func, message);
|
||||
fflush(fp);
|
||||
} else {
|
||||
fprintf(stderr, "[%d] %u:%s() - %s\n", level, line, func, message);
|
||||
}
|
||||
}
|
||||
|
||||
/* Sets ncurses refresh rate. Lower values make it refresh more often. */
|
||||
void set_window_refresh_rate(size_t refresh_rate)
|
||||
{
|
||||
@ -1196,6 +1209,7 @@ static void print_usage(void)
|
||||
fprintf(stderr, " -p, --SOCKS5-proxy Use SOCKS5 proxy: Requires [IP] [port]\n");
|
||||
fprintf(stderr, " -P, --HTTP-proxy Use HTTP proxy: Requires [IP] [port]\n");
|
||||
fprintf(stderr, " -r, --namelist Use specified name lookup server list\n");
|
||||
fprintf(stderr, " -s, --netstats Dump network statistic to log on exit: Requires [path]\n");
|
||||
fprintf(stderr, " -t, --force-tcp Force toxic to use a TCP connection (use with proxies)\n");
|
||||
fprintf(stderr, " -T, --tcp-server Act as a TCP relay server: Requires [port]\n");
|
||||
fprintf(stderr, " -u, --unencrypt-data Unencrypt an encrypted data file\n");
|
||||
@ -1235,6 +1249,7 @@ static void parse_args(int argc, char *argv[])
|
||||
{"help", no_argument, 0, 'h'},
|
||||
{"noconnect", no_argument, 0, 'o'},
|
||||
{"namelist", required_argument, 0, 'r'},
|
||||
{"netstats", required_argument, 0, 's'},
|
||||
{"force-tcp", no_argument, 0, 't'},
|
||||
{"tcp-server", required_argument, 0, 'T'},
|
||||
{"SOCKS5-proxy", required_argument, 0, 'p'},
|
||||
@ -1244,7 +1259,7 @@ static void parse_args(int argc, char *argv[])
|
||||
{NULL, no_argument, NULL, 0},
|
||||
};
|
||||
|
||||
const char *opts_str = "4bdehLotuxvc:f:l:n:r:p:P:T:";
|
||||
const char *opts_str = "4bdehLotuxvc:f:l:n:r:s:p:P:T:";
|
||||
int opt = 0;
|
||||
int indexptr = 0;
|
||||
|
||||
@ -1440,6 +1455,25 @@ static void parse_args(int argc, char *argv[])
|
||||
break;
|
||||
}
|
||||
|
||||
case 's': {
|
||||
if (optarg == NULL) {
|
||||
queue_init_message("Invalid argument for option: %d", opt);
|
||||
break;
|
||||
}
|
||||
|
||||
arg_opts.netprof_fp = fopen(optarg, "w");
|
||||
|
||||
if (arg_opts.netprof_fp != NULL) {
|
||||
queue_init_message("Network profile logging enabled. Logging to file: '%s'", optarg);
|
||||
arg_opts.netprof_log_dump = true;
|
||||
arg_opts.netprof_start_time = time(NULL);
|
||||
} else {
|
||||
queue_init_message("Failed to open file '%s' for network profile logging.", optarg);
|
||||
}
|
||||
|
||||
break;
|
||||
}
|
||||
|
||||
case 'u': {
|
||||
arg_opts.unencrypt_data = 1;
|
||||
break;
|
||||
|
@ -23,6 +23,10 @@
|
||||
#ifndef TOXIC_H
|
||||
#define TOXIC_H
|
||||
|
||||
#ifndef NCURSES_WIDECHAR
|
||||
#define NCURSES_WIDECHAR 1
|
||||
#endif
|
||||
|
||||
#ifndef TOXICVER
|
||||
#define TOXICVER "NOVERS" /* Use the -D flag to set this */
|
||||
#endif
|
||||
@ -46,7 +50,7 @@
|
||||
#define MAX_STR_SIZE TOX_MAX_MESSAGE_LENGTH /* must be >= TOX_MAX_MESSAGE_LENGTH */
|
||||
#define MAX_CMDNAME_SIZE 64
|
||||
#define TOXIC_MAX_NAME_LENGTH 32 /* Must be <= TOX_MAX_NAME_LENGTH */
|
||||
#define KEY_IDENT_DIGITS 3 /* number of hex digits to display for the pub-key based identifier */
|
||||
#define KEY_IDENT_BYTES 6 /* number of hex digits to display for the public key identifier */
|
||||
#define TIME_STR_SIZE 32
|
||||
#define COLOR_STR_SIZE 10 /* should fit every color option */
|
||||
|
||||
@ -145,5 +149,7 @@ void on_friend_typing(Tox *m, uint32_t friendnumber, bool is_typing, void *userd
|
||||
void on_friend_read_receipt(Tox *m, uint32_t friendnumber, uint32_t receipt, void *userdata);
|
||||
void on_lossless_custom_packet(Tox *m, uint32_t friendnumber, const uint8_t *data, size_t length, void *userdata);
|
||||
|
||||
extern char *DATA_FILE;
|
||||
extern char *BLOCK_FILE;
|
||||
|
||||
#endif /* TOXIC_H */
|
||||
|
@ -92,21 +92,21 @@ typedef struct VideoDevice {
|
||||
|
||||
} VideoDevice;
|
||||
|
||||
const char *dvideo_device_names[2]; /* Default device */
|
||||
const char *video_devices_names[2][MAX_DEVICES]; /* Container of available devices */
|
||||
static int size[2]; /* Size of above containers */
|
||||
VideoDevice *video_devices_running[2][MAX_DEVICES] = {{NULL}}; /* Running devices */
|
||||
uint32_t primary_video_device[2]; /* Primary device */
|
||||
static const char *dvideo_device_names[2]; /* Default device */
|
||||
static char *video_devices_names[2][MAX_DEVICES]; /* Container of available devices */
|
||||
static int size[2]; /* Size of above containers */
|
||||
static VideoDevice *video_devices_running[2][MAX_DEVICES] = {{NULL}}; /* Running devices */
|
||||
static uint32_t primary_video_device[2]; /* Primary device */
|
||||
|
||||
static ToxAV *av = NULL;
|
||||
|
||||
/* q_mutex */
|
||||
#define lock pthread_mutex_lock(&video_mutex)
|
||||
#define unlock pthread_mutex_unlock(&video_mutex)
|
||||
pthread_mutex_t video_mutex;
|
||||
static pthread_mutex_t video_mutex;
|
||||
|
||||
bool video_thread_running = true,
|
||||
video_thread_paused = true; /* Thread control */
|
||||
static bool video_thread_running = true;
|
||||
static bool video_thread_paused = true; /* Thread control */
|
||||
|
||||
void *video_thread_poll(void *);
|
||||
|
||||
@ -187,7 +187,7 @@ VideoDeviceError init_video_devices(void)
|
||||
|
||||
#if defined(__OSX__) || defined(__APPLE__)
|
||||
|
||||
if (osx_video_init((char **)video_devices_names[vdt_input], &size[vdt_input]) != 0) {
|
||||
if (osx_video_init(&video_devices_names[vdt_input][0], &size[vdt_input]) != 0) {
|
||||
return vde_InternalError;
|
||||
}
|
||||
|
||||
@ -209,12 +209,24 @@ VideoDeviceError init_video_devices(void)
|
||||
/* Query V4L for capture capabilities */
|
||||
if (-1 != ioctl(fd, VIDIOC_QUERYCAP, &cap)) {
|
||||
video_input_name = (char *)malloc(strlen((const char *)cap.card) + strlen(device_address) + 4);
|
||||
|
||||
if (video_input_name == NULL) {
|
||||
close(fd);
|
||||
return vde_InternalError;
|
||||
}
|
||||
|
||||
strcpy(video_input_name, (char *)cap.card);
|
||||
strcat(video_input_name, " (");
|
||||
strcat(video_input_name, (char *)device_address);
|
||||
strcat(video_input_name, ")");
|
||||
} else {
|
||||
video_input_name = (char *)malloc(strlen(device_address) + 3);
|
||||
|
||||
if (video_input_name == NULL) {
|
||||
close(fd);
|
||||
return vde_InternalError;
|
||||
}
|
||||
|
||||
strcpy(video_input_name, "(");
|
||||
strcat(video_input_name, device_address);
|
||||
strcat(video_input_name, ")");
|
||||
@ -229,6 +241,9 @@ VideoDeviceError init_video_devices(void)
|
||||
#endif
|
||||
|
||||
size[vdt_output] = 1;
|
||||
// TODO(iphydf): String literals are const char *. This may need to be
|
||||
// copied, or if we're not owning any output device names, it should be
|
||||
// const and video_devices_names needs to be split.
|
||||
char *video_output_name = "Toxic Video Receiver";
|
||||
video_devices_names[vdt_output][0] = video_output_name;
|
||||
|
||||
@ -262,7 +277,7 @@ VideoDeviceError terminate_video_devices(void)
|
||||
int i;
|
||||
|
||||
for (i = 0; i < size[vdt_input]; ++i) {
|
||||
free((void *)video_devices_names[vdt_input][i]);
|
||||
free(video_devices_names[vdt_input][i]);
|
||||
}
|
||||
|
||||
if (pthread_mutex_destroy(&video_mutex) != 0) {
|
||||
|
@ -41,16 +41,10 @@
|
||||
#include "game_base.h"
|
||||
#endif
|
||||
|
||||
extern char *DATA_FILE;
|
||||
extern struct Winthread Winthread;
|
||||
|
||||
ToxWindow *windows[MAX_WINDOWS_NUM];
|
||||
static uint8_t active_window_index;
|
||||
static int num_active_windows;
|
||||
|
||||
extern ToxWindow *prompt;
|
||||
extern struct user_settings *user_settings;
|
||||
|
||||
/* CALLBACKS START */
|
||||
void on_friend_request(Tox *m, const uint8_t *public_key, const uint8_t *data, size_t length, void *userdata)
|
||||
{
|
||||
@ -196,7 +190,7 @@ void on_conference_invite(Tox *m, uint32_t friendnumber, Tox_Conference_Type typ
|
||||
|
||||
for (uint8_t i = 0; i < MAX_WINDOWS_NUM; ++i) {
|
||||
if (windows[i] != NULL && windows[i]->onConferenceInvite != NULL) {
|
||||
windows[i]->onConferenceInvite(windows[i], m, friendnumber, type, (char *) conference_pub_key, length);
|
||||
windows[i]->onConferenceInvite(windows[i], m, friendnumber, type, (const char *) conference_pub_key, length);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -250,7 +244,7 @@ void on_file_chunk_request(Tox *m, uint32_t friendnumber, uint32_t filenumber, u
|
||||
{
|
||||
UNUSED_VAR(userdata);
|
||||
|
||||
struct FileTransfer *ft = get_file_transfer_struct(friendnumber, filenumber);
|
||||
FileTransfer *ft = get_file_transfer_struct(friendnumber, filenumber);
|
||||
|
||||
if (!ft) {
|
||||
return;
|
||||
@ -273,7 +267,7 @@ void on_file_recv_chunk(Tox *m, uint32_t friendnumber, uint32_t filenumber, uint
|
||||
{
|
||||
UNUSED_VAR(userdata);
|
||||
|
||||
struct FileTransfer *ft = get_file_transfer_struct(friendnumber, filenumber);
|
||||
FileTransfer *ft = get_file_transfer_struct(friendnumber, filenumber);
|
||||
|
||||
if (!ft) {
|
||||
return;
|
||||
@ -281,7 +275,7 @@ void on_file_recv_chunk(Tox *m, uint32_t friendnumber, uint32_t filenumber, uint
|
||||
|
||||
for (uint8_t i = 0; i < MAX_WINDOWS_NUM; ++i) {
|
||||
if (windows[i] != NULL && windows[i]->onFileRecvChunk != NULL) {
|
||||
windows[i]->onFileRecvChunk(windows[i], m, friendnumber, filenumber, position, (char *) data, length);
|
||||
windows[i]->onFileRecvChunk(windows[i], m, friendnumber, filenumber, position, (const char *) data, length);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -291,7 +285,7 @@ void on_file_recv_control(Tox *m, uint32_t friendnumber, uint32_t filenumber, To
|
||||
{
|
||||
UNUSED_VAR(userdata);
|
||||
|
||||
struct FileTransfer *ft = get_file_transfer_struct(friendnumber, filenumber);
|
||||
FileTransfer *ft = get_file_transfer_struct(friendnumber, filenumber);
|
||||
|
||||
if (!ft) {
|
||||
return;
|
||||
@ -322,7 +316,7 @@ void on_file_recv(Tox *m, uint32_t friendnumber, uint32_t filenumber, uint32_t k
|
||||
|
||||
for (uint8_t i = 0; i < MAX_WINDOWS_NUM; ++i) {
|
||||
if (windows[i] != NULL && windows[i]->onFileRecv != NULL) {
|
||||
windows[i]->onFileRecv(windows[i], m, friendnumber, filenumber, file_size, (char *) filename,
|
||||
windows[i]->onFileRecv(windows[i], m, friendnumber, filenumber, file_size, (const char *) filename,
|
||||
filename_length);
|
||||
}
|
||||
}
|
||||
@ -691,10 +685,10 @@ void draw_window_bar(ToxWindow *self)
|
||||
|
||||
int cur_x;
|
||||
int cur_y;
|
||||
UNUSED_VAR(cur_y);
|
||||
|
||||
getyx(win, cur_y, cur_x);
|
||||
|
||||
UNUSED_VAR(cur_y);
|
||||
|
||||
wattron(win, COLOR_PAIR(BAR_TEXT));
|
||||
mvwhline(win, 0, cur_x, ' ', COLS - cur_x);
|
||||
wattroff(win, COLOR_PAIR(BAR_TEXT));
|
||||
|
@ -114,6 +114,8 @@ struct Winthread {
|
||||
volatile sig_atomic_t last_refresh_flag;
|
||||
};
|
||||
|
||||
extern struct Winthread Winthread;
|
||||
|
||||
struct cqueue_thread {
|
||||
pthread_t tid;
|
||||
};
|
||||
@ -140,6 +142,10 @@ struct arg_opts {
|
||||
bool logging;
|
||||
FILE *log_fp;
|
||||
|
||||
bool netprof_log_dump;
|
||||
time_t netprof_start_time;
|
||||
FILE *netprof_fp;
|
||||
|
||||
char proxy_address[256];
|
||||
uint8_t proxy_type;
|
||||
uint16_t proxy_port;
|
||||
@ -147,6 +153,8 @@ struct arg_opts {
|
||||
uint16_t tcp_port;
|
||||
};
|
||||
|
||||
extern struct arg_opts arg_opts;
|
||||
|
||||
typedef struct ToxWindow ToxWindow;
|
||||
typedef struct StatusBar StatusBar;
|
||||
typedef struct PromptBuf PromptBuf;
|
||||
@ -233,6 +241,8 @@ struct ToxWindow {
|
||||
WINDOW *window_bar;
|
||||
};
|
||||
|
||||
extern ToxWindow *windows[MAX_WINDOWS_NUM];
|
||||
|
||||
/* statusbar info holder */
|
||||
struct StatusBar {
|
||||
WINDOW *topline;
|
||||
@ -242,6 +252,12 @@ struct StatusBar {
|
||||
size_t nick_len;
|
||||
Tox_User_Status status;
|
||||
Tox_Connection connection;
|
||||
|
||||
/* network info */
|
||||
uint64_t up_bytes;
|
||||
uint64_t down_bytes;
|
||||
uint64_t time_last_refreshed;
|
||||
char network_info[MAX_STR_SIZE];
|
||||
};
|
||||
|
||||
#ifdef AUDIO
|
||||
|
Reference in New Issue
Block a user