Compare commits
10 Commits
fix/delay-
...
b90dec5be3
| Author | SHA1 | Date | |
|---|---|---|---|
|
b90dec5be3
|
|||
|
3f91cbc8b0
|
|||
|
e4422ac7a1
|
|||
|
bb0af8b7c8
|
|||
|
a51afa53f6
|
|||
|
b1ffc750a2
|
|||
|
2da2449777
|
|||
|
394df6d391
|
|||
|
b282b12497
|
|||
|
|
562bd28cff
|
14
src/common.c
14
src/common.c
@@ -748,17 +748,17 @@ call_external(gchar** argv)
|
||||
*
|
||||
* This function constructs an argument vector (argv) based on the provided template string, replacing placeholders ("%u" and "%p") with the provided URL and filename, respectively.
|
||||
*
|
||||
* @param template_fmt The template string with placeholders.
|
||||
* @param url The URL to replace "%u" (or NULL to skip).
|
||||
* @param filename The filename to replace "%p" (or NULL to skip).
|
||||
* @return The constructed argument vector (argv) as a null-terminated array of strings.
|
||||
* @param template The template string with placeholders.
|
||||
* @param url The URL to replace "%u" (or NULL to skip).
|
||||
* @param filename The filename to replace "%p" (or NULL to skip).
|
||||
* @return The constructed argument vector (argv) as a null-terminated array of strings.
|
||||
*
|
||||
* @note Remember to free the returned argument vector using `auto_gcharv` or `g_strfreev()`.
|
||||
*/
|
||||
gchar**
|
||||
format_call_external_argv(const char* template_fmt, const char* url, const char* filename)
|
||||
format_call_external_argv(const char* template, const char* url, const char* filename)
|
||||
{
|
||||
gchar** argv = g_strsplit(template_fmt, " ", 0);
|
||||
gchar** argv = g_strsplit(template, " ", 0);
|
||||
|
||||
guint num_args = 0;
|
||||
while (argv[num_args]) {
|
||||
@@ -767,7 +767,7 @@ format_call_external_argv(const char* template_fmt, const char* url, const char*
|
||||
argv[num_args] = g_strdup(url);
|
||||
} else if (0 == g_strcmp0(argv[num_args], "%p") && filename != NULL) {
|
||||
g_free(argv[num_args]);
|
||||
argv[num_args] = g_strdup(filename);
|
||||
argv[num_args] = strdup(filename);
|
||||
}
|
||||
num_args++;
|
||||
}
|
||||
|
||||
@@ -181,7 +181,7 @@ void get_file_paths_recursive(const char* directory, GSList** contents);
|
||||
gchar* get_random_string(int length);
|
||||
|
||||
gboolean call_external(gchar** argv);
|
||||
gchar** format_call_external_argv(const char* template_fmt, const char* url, const char* filename);
|
||||
gchar** format_call_external_argv(const char* template, const char* url, const char* filename);
|
||||
|
||||
gchar* unique_filename_from_url(const char* url, const char* path);
|
||||
gchar* get_expanded_path(const char* path);
|
||||
|
||||
@@ -10,8 +10,6 @@
|
||||
#ifndef EVENT_COMMON_H
|
||||
#define EVENT_COMMON_H
|
||||
|
||||
#include "glib.h"
|
||||
|
||||
void ev_disconnect_cleanup(void);
|
||||
void ev_inc_connection_counter(void);
|
||||
void ev_reset_connection_counter(void);
|
||||
|
||||
@@ -10,8 +10,6 @@
|
||||
#ifndef PGP_GPG_H
|
||||
#define PGP_GPG_H
|
||||
|
||||
#include "glib.h"
|
||||
|
||||
typedef struct pgp_key_t
|
||||
{
|
||||
gchar* id;
|
||||
|
||||
@@ -70,38 +70,12 @@ static void _connect_default(const char* const account);
|
||||
pthread_mutex_t lock;
|
||||
static gboolean force_quit = FALSE;
|
||||
|
||||
// Signal-driven flags consumed by the main loop. SIGTSTP and a STOPPED editor
|
||||
// child → drop the process group to the shell (mutt-style). SIGCONT →
|
||||
// refresh curses on return.
|
||||
static volatile sig_atomic_t suspend_requested = FALSE;
|
||||
static volatile sig_atomic_t cont_requested = FALSE;
|
||||
|
||||
static void
|
||||
_handle_suspend_signals(void)
|
||||
{
|
||||
if (cont_requested) {
|
||||
cont_requested = FALSE;
|
||||
if (!editor_is_active()) {
|
||||
clearok(stdscr, TRUE);
|
||||
ui_resize();
|
||||
}
|
||||
}
|
||||
|
||||
if (editor_check_stopped()) {
|
||||
log_info("[Editor] stopped; aborting back to profanity");
|
||||
suspend_requested = FALSE;
|
||||
editor_emergency_kill();
|
||||
} else if (suspend_requested) {
|
||||
suspend_requested = FALSE;
|
||||
if (editor_is_active()) {
|
||||
log_info("[Editor] SIGTSTP from vim group; deferring to next poll");
|
||||
} else {
|
||||
log_info("[Suspend] dropping to shell");
|
||||
if (!isendwin()) {
|
||||
endwin();
|
||||
}
|
||||
kill(0, SIGSTOP);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
void
|
||||
prof_run(gchar* log_level, gchar* account_name, gchar* config_file, gchar* log_file, gchar* theme_name, gchar** commands)
|
||||
{
|
||||
@@ -125,7 +99,36 @@ prof_run(gchar* log_level, gchar* account_name, gchar* config_file, gchar* log_f
|
||||
int waittime = 0;
|
||||
while (cont && !force_quit) {
|
||||
log_stderr_handler();
|
||||
_handle_suspend_signals();
|
||||
|
||||
// Resume from fg after SIGSTOP. Vim handles its own refresh.
|
||||
if (cont_requested) {
|
||||
cont_requested = FALSE;
|
||||
if (!editor_is_active()) {
|
||||
clearok(stdscr, TRUE);
|
||||
ui_resize();
|
||||
}
|
||||
}
|
||||
|
||||
// Editor STOPPED → abort. Plain Ctrl-Z → drop to shell. While editor
|
||||
// is active, swallow suspend_requested (race: vim's kill(0,SIGTSTP)
|
||||
// beats waitpid seeing STOPPED) — next poll catches it.
|
||||
if (editor_check_stopped()) {
|
||||
log_info("[Editor] stopped; aborting back to profanity");
|
||||
suspend_requested = FALSE;
|
||||
editor_emergency_kill();
|
||||
} else if (suspend_requested) {
|
||||
suspend_requested = FALSE;
|
||||
if (editor_is_active()) {
|
||||
log_info("[Editor] SIGTSTP from vim group; deferring to next poll");
|
||||
} else {
|
||||
log_info("[Suspend] dropping to shell");
|
||||
if (!isendwin()) {
|
||||
endwin();
|
||||
}
|
||||
kill(0, SIGSTOP);
|
||||
}
|
||||
}
|
||||
|
||||
session_check_autoaway();
|
||||
|
||||
line = commands ? *commands : inp_readline();
|
||||
|
||||
@@ -10,10 +10,8 @@
|
||||
#ifndef BOOKMARK_IGNORE_H
|
||||
#define BOOKMARK_IGNORE_H
|
||||
|
||||
#include "xmpp/xmpp.h"
|
||||
|
||||
void bookmark_ignore_on_connect(const char* const barejid);
|
||||
void bookmark_ignore_on_disconnect();
|
||||
void bookmark_ignore_on_disconnect(void);
|
||||
gboolean bookmark_ignored(Bookmark* bookmark);
|
||||
gchar** bookmark_ignore_list(gsize* len);
|
||||
void bookmark_ignore_add(const char* const barejid);
|
||||
|
||||
@@ -32,7 +32,9 @@ typedef struct EditorContext
|
||||
void* user_data;
|
||||
} EditorContext;
|
||||
|
||||
static gboolean editor_active = FALSE; // re-entrancy guard
|
||||
// Re-entrancy guard (lost in the async-editor rewrite). Prevents a plugin
|
||||
// from spawning a second editor that would fight the first for the terminal.
|
||||
static gboolean editor_active = FALSE;
|
||||
static pid_t editor_pid = 0;
|
||||
|
||||
static void
|
||||
|
||||
@@ -399,6 +399,8 @@ chatwin_outgoing_msg(ProfChatWin* chatwin, const char* const message, const char
|
||||
win_print_outgoing((ProfWin*)chatwin, enc_char, id, replace_id, display_message);
|
||||
}
|
||||
|
||||
plugins_post_chat_message_display(myjid->barejid, myjid->resourcepart, display_message);
|
||||
|
||||
// Save last id and message for LMC
|
||||
// Note: if the same message is to be corrected several times, the id of the original message is used in each case
|
||||
// https://xmpp.org/extensions/xep-0308.html#rules
|
||||
@@ -432,6 +434,7 @@ chatwin_outgoing_carbon(ProfChatWin* chatwin, ProfMessage* message)
|
||||
|
||||
win_print_outgoing(window, enc_char, message->id, message->replace_id, message->plain);
|
||||
|
||||
plugins_post_chat_message_display(message->from_jid->barejid, message->from_jid->resourcepart, message->plain);
|
||||
message->plain = old_plain;
|
||||
|
||||
int num = wins_get_num(window);
|
||||
@@ -558,6 +561,7 @@ _chatwin_history(ProfChatWin* chatwin, const char* const contact_barejid)
|
||||
if (plugin_msg)
|
||||
msg->plain = plugin_msg;
|
||||
win_print_history((ProfWin*)chatwin, msg);
|
||||
plugins_post_chat_message_display(msg->from_jid->barejid, msg->from_jid->resourcepart, msg->plain);
|
||||
msg->plain = old_plain;
|
||||
curr = g_slist_next(curr);
|
||||
}
|
||||
@@ -597,6 +601,7 @@ chatwin_db_history(ProfChatWin* chatwin, const gchar* start_time, const gchar* e
|
||||
} else {
|
||||
win_print_history((ProfWin*)chatwin, msg);
|
||||
}
|
||||
plugins_post_chat_message_display(msg->from_jid->barejid, msg->from_jid->resourcepart, msg->plain);
|
||||
msg->plain = old_plain;
|
||||
curr = g_slist_next(curr);
|
||||
}
|
||||
|
||||
@@ -320,7 +320,9 @@ inp_get_line(void)
|
||||
while (!line) {
|
||||
line = inp_readline();
|
||||
ui_update();
|
||||
while (g_main_context_iteration(NULL, FALSE)) // non-blocking; bounded by ready sources
|
||||
// Let the editor child watch dispatch — otherwise a prompt raised
|
||||
// mid-editor-session deadlocks here.
|
||||
while (g_main_context_iteration(NULL, FALSE))
|
||||
;
|
||||
}
|
||||
status_bar_clear_prompt();
|
||||
@@ -350,7 +352,9 @@ inp_get_password(void)
|
||||
while (!password) {
|
||||
password = inp_readline();
|
||||
ui_update();
|
||||
while (g_main_context_iteration(NULL, FALSE)) // non-blocking; bounded by ready sources
|
||||
// Let the editor child watch dispatch — otherwise a prompt raised
|
||||
// mid-editor-session deadlocks here.
|
||||
while (g_main_context_iteration(NULL, FALSE))
|
||||
;
|
||||
}
|
||||
get_password = FALSE;
|
||||
|
||||
@@ -10,8 +10,6 @@
|
||||
#ifndef UI_TITLEBAR_H
|
||||
#define UI_TITLEBAR_H
|
||||
|
||||
#include "glib.h"
|
||||
|
||||
void create_title_bar(void);
|
||||
void free_title_bar(void);
|
||||
void title_bar_update_virtual(void);
|
||||
|
||||
@@ -43,7 +43,7 @@
|
||||
#include "ai/ai_client.h"
|
||||
|
||||
static const int PAD_MIN_HEIGHT = 100;
|
||||
static const int PAD_THRESHOLD = 12000; // above buffer cap (~9000): reclaims dead pad space, never fires while scrolling
|
||||
static const int PAD_THRESHOLD = 3000;
|
||||
static gboolean _in_redraw = FALSE;
|
||||
|
||||
static void
|
||||
@@ -2172,10 +2172,9 @@ win_redraw(ProfWin* window)
|
||||
unsigned int size = buffer_size(window->layout->buffer);
|
||||
_in_redraw = TRUE;
|
||||
|
||||
// size the pad to fit the whole buffer (plus headroom) and erase it
|
||||
// shrink pad back to minimum size and erase it
|
||||
int cols = getmaxx(window->layout->win);
|
||||
int needed = window->layout->buffer->lines + 100;
|
||||
wresize(window->layout->win, MAX(needed, PAD_MIN_HEIGHT), cols);
|
||||
wresize(window->layout->win, PAD_MIN_HEIGHT, cols);
|
||||
werase(window->layout->win);
|
||||
|
||||
for (unsigned int i = 0; i < size; i++) {
|
||||
|
||||
@@ -10,8 +10,6 @@
|
||||
#ifndef XMPP_BLOCKING_H
|
||||
#define XMPP_BLOCKING_H
|
||||
|
||||
#include <strophe.h>
|
||||
|
||||
void blocking_request(void);
|
||||
int blocked_set_handler(xmpp_stanza_t* stanza);
|
||||
int reporting_set_handler(xmpp_stanza_t* stanza);
|
||||
|
||||
@@ -10,8 +10,6 @@
|
||||
#ifndef XMPP_IQ_H
|
||||
#define XMPP_IQ_H
|
||||
|
||||
#include <strophe.h>
|
||||
|
||||
typedef int (*ProfIqCallback)(xmpp_stanza_t* const stanza, void* const userdata);
|
||||
typedef void (*ProfIqFreeCallback)(void* userdata);
|
||||
|
||||
|
||||
@@ -1132,17 +1132,12 @@ _handle_groupchat(xmpp_stanza_t* const stanza)
|
||||
message->timestamp = NULL;
|
||||
}
|
||||
|
||||
// XEP-0203 §4: trust <delay> only from the room or our server, not a client-forged stamp
|
||||
message->timestamp = stanza_get_oldest_delay_from(stanza, from_jid->barejid);
|
||||
if (!message->timestamp && from_jid->domainpart) {
|
||||
message->timestamp = stanza_get_oldest_delay_from(stanza, from_jid->domainpart);
|
||||
}
|
||||
if (!message->timestamp) {
|
||||
const char* my_domain = connection_get_domain();
|
||||
if (my_domain) {
|
||||
message->timestamp = stanza_get_oldest_delay_from(stanza, my_domain);
|
||||
}
|
||||
}
|
||||
// we want to display the oldest delay
|
||||
message->timestamp = stanza_get_oldest_delay(stanza);
|
||||
|
||||
// now this has nothing to do with MUC history
|
||||
// it's just setting the time to the received time so upon displaying we can use this time
|
||||
// for example in win_println_incoming_muc_msg()
|
||||
if (!message->timestamp) {
|
||||
message->timestamp = g_date_time_new_now_local();
|
||||
}
|
||||
@@ -1273,15 +1268,7 @@ _handle_muc_private_message(xmpp_stanza_t* const stanza)
|
||||
_receive_omemo(stanza, message);
|
||||
#endif
|
||||
|
||||
// XEP-0203 §4: trust <delay> only from a server domain, not a client-forged stamp
|
||||
const char* my_domain = connection_get_domain();
|
||||
message->timestamp = stanza_get_delay_from(stanza, my_domain);
|
||||
if (!message->timestamp && message->from_jid->domainpart) {
|
||||
message->timestamp = stanza_get_delay_from(stanza, message->from_jid->domainpart);
|
||||
}
|
||||
if (!message->timestamp) {
|
||||
message->timestamp = g_date_time_new_now_local();
|
||||
}
|
||||
message->timestamp = stanza_get_delay(stanza);
|
||||
message->body = xmpp_message_get_body(stanza);
|
||||
|
||||
if (!message->plain && !message->body) {
|
||||
@@ -1432,12 +1419,8 @@ _handle_chat(xmpp_stanza_t* const stanza, gboolean is_mam, gboolean is_carbon, c
|
||||
// timestamp provided outside like in a <forwarded> by MAM
|
||||
message->timestamp = timestamp;
|
||||
} else {
|
||||
// XEP-0203 §4: trust <delay> only from a server domain, not a client-forged stamp
|
||||
const char* my_domain = connection_get_domain();
|
||||
message->timestamp = stanza_get_delay_from(stanza, my_domain);
|
||||
if (!message->timestamp && jid->domainpart) {
|
||||
message->timestamp = stanza_get_delay_from(stanza, jid->domainpart);
|
||||
}
|
||||
// timestamp in the message stanza or use time of receival (now)
|
||||
message->timestamp = stanza_get_delay(stanza);
|
||||
if (!message->timestamp) {
|
||||
message->timestamp = g_date_time_new_now_local();
|
||||
}
|
||||
|
||||
@@ -7,8 +7,6 @@
|
||||
* SPDX-License-Identifier: GPL-3.0-or-later WITH OpenSSL-exception
|
||||
*/
|
||||
|
||||
#include "glib.h"
|
||||
|
||||
/*!
|
||||
* \page OX OX Implementation
|
||||
*
|
||||
|
||||
@@ -10,9 +10,6 @@
|
||||
#ifndef XMPP_ROSTER_H
|
||||
#define XMPP_ROSTER_H
|
||||
|
||||
#include "glib.h"
|
||||
#include <strophe.h>
|
||||
|
||||
void roster_request(void);
|
||||
void roster_set_handler(xmpp_stanza_t* const stanza);
|
||||
void roster_result_handler(xmpp_stanza_t* const stanza);
|
||||
|
||||
@@ -1163,7 +1163,7 @@ _stanza_get_delay_timestamp_xep0091(xmpp_stanza_t* const x_stanza)
|
||||
}
|
||||
|
||||
GDateTime*
|
||||
stanza_get_delay_from(xmpp_stanza_t* const stanza, const char* const from)
|
||||
stanza_get_delay_from(xmpp_stanza_t* const stanza, gchar* from)
|
||||
{
|
||||
xmpp_stanza_t* delay = NULL;
|
||||
|
||||
@@ -1195,12 +1195,6 @@ stanza_get_delay_from(xmpp_stanza_t* const stanza, const char* const from)
|
||||
|
||||
GDateTime*
|
||||
stanza_get_oldest_delay(xmpp_stanza_t* const stanza)
|
||||
{
|
||||
return stanza_get_oldest_delay_from(stanza, NULL);
|
||||
}
|
||||
|
||||
GDateTime*
|
||||
stanza_get_oldest_delay_from(xmpp_stanza_t* const stanza, const char* const from)
|
||||
{
|
||||
xmpp_stanza_t* child;
|
||||
const char* child_name;
|
||||
@@ -1211,37 +1205,27 @@ stanza_get_oldest_delay_from(xmpp_stanza_t* const stanza, const char* const from
|
||||
child_name = xmpp_stanza_get_name(child);
|
||||
|
||||
if (child_name && g_strcmp0(child_name, STANZA_NAME_DELAY) == 0) {
|
||||
if (from) {
|
||||
const char* child_from = xmpp_stanza_get_attribute(child, STANZA_ATTR_FROM);
|
||||
if (!child_from || g_strcmp0(child_from, from) != 0)
|
||||
continue;
|
||||
}
|
||||
GDateTime* tmp = _stanza_get_delay_timestamp_xep0203(child);
|
||||
|
||||
if (oldest == NULL) {
|
||||
oldest = tmp;
|
||||
} else if (tmp && g_date_time_compare(oldest, tmp) == 1) {
|
||||
} else if (g_date_time_compare(oldest, tmp) == 1) {
|
||||
g_date_time_unref(oldest);
|
||||
oldest = tmp;
|
||||
} else if (tmp) {
|
||||
} else {
|
||||
g_date_time_unref(tmp);
|
||||
}
|
||||
}
|
||||
|
||||
if (child_name && g_strcmp0(child_name, STANZA_NAME_X) == 0) {
|
||||
if (from) {
|
||||
const char* child_from = xmpp_stanza_get_attribute(child, STANZA_ATTR_FROM);
|
||||
if (!child_from || g_strcmp0(child_from, from) != 0)
|
||||
continue;
|
||||
}
|
||||
GDateTime* tmp = _stanza_get_delay_timestamp_xep0091(child);
|
||||
|
||||
if (oldest == NULL) {
|
||||
oldest = tmp;
|
||||
} else if (tmp && g_date_time_compare(oldest, tmp) == 1) {
|
||||
} else if (g_date_time_compare(oldest, tmp) == 1) {
|
||||
g_date_time_unref(oldest);
|
||||
oldest = tmp;
|
||||
} else if (tmp) {
|
||||
} else {
|
||||
g_date_time_unref(tmp);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -305,9 +305,8 @@ xmpp_stanza_t* stanza_create_mediated_invite(xmpp_ctx_t* ctx, const char* const
|
||||
gboolean stanza_contains_chat_state(xmpp_stanza_t* stanza);
|
||||
|
||||
GDateTime* stanza_get_delay(xmpp_stanza_t* const stanza);
|
||||
GDateTime* stanza_get_delay_from(xmpp_stanza_t* const stanza, const char* const from);
|
||||
GDateTime* stanza_get_delay_from(xmpp_stanza_t* const stanza, gchar* from);
|
||||
GDateTime* stanza_get_oldest_delay(xmpp_stanza_t* const stanza);
|
||||
GDateTime* stanza_get_oldest_delay_from(xmpp_stanza_t* const stanza, const char* const from);
|
||||
|
||||
gboolean stanza_is_muc_presence(xmpp_stanza_t* const stanza);
|
||||
gboolean stanza_is_muc_self_presence(xmpp_stanza_t* const stanza,
|
||||
|
||||
@@ -12,7 +12,6 @@
|
||||
|
||||
#include "ui/win_types.h"
|
||||
#include "xmpp/vcard.h"
|
||||
#include <strophe.h>
|
||||
|
||||
vCard* vcard_new();
|
||||
void vcard_free(vCard* vcard);
|
||||
|
||||
Reference in New Issue
Block a user