Compare commits
3 Commits
fix/data-a
...
feat/cons-
| Author | SHA1 | Date | |
|---|---|---|---|
|
a878b1e629
|
|||
|
d914e42ff6
|
|||
|
964f73d0ad
|
@@ -87,6 +87,7 @@ theme_init(const char* const theme_name)
|
||||
g_hash_table_insert(defaults, strdup("main.help.header"), strdup("default"));
|
||||
g_hash_table_insert(defaults, strdup("main.trackbar"), strdup("default"));
|
||||
g_hash_table_insert(defaults, strdup("error"), strdup("red"));
|
||||
g_hash_table_insert(defaults, strdup("warning"), strdup("yellow"));
|
||||
g_hash_table_insert(defaults, strdup("incoming"), strdup("yellow"));
|
||||
g_hash_table_insert(defaults, strdup("mention"), strdup("yellow"));
|
||||
g_hash_table_insert(defaults, strdup("trigger"), strdup("yellow"));
|
||||
@@ -703,6 +704,9 @@ theme_attrs(theme_item_t attrs)
|
||||
case THEME_ERROR:
|
||||
_theme_prep_fgnd("error", lookup_str, &bold);
|
||||
break;
|
||||
case THEME_WARNING:
|
||||
_theme_prep_fgnd("warning", lookup_str, &bold);
|
||||
break;
|
||||
case THEME_INCOMING:
|
||||
_theme_prep_fgnd("incoming", lookup_str, &bold);
|
||||
break;
|
||||
|
||||
@@ -23,6 +23,7 @@ typedef enum {
|
||||
THEME_SPLASH,
|
||||
THEME_HELP_HEADER,
|
||||
THEME_ERROR,
|
||||
THEME_WARNING,
|
||||
THEME_INCOMING,
|
||||
THEME_MENTION,
|
||||
THEME_TRIGGER,
|
||||
|
||||
@@ -25,6 +25,8 @@
|
||||
#include "ui/ui.h"
|
||||
#include "xmpp/xmpp.h"
|
||||
|
||||
extern char** environ;
|
||||
|
||||
typedef struct EditorContext
|
||||
{
|
||||
gchar* filename;
|
||||
@@ -140,6 +142,22 @@ launch_editor(gchar* initial_content, void (*callback)(gchar* content, void* dat
|
||||
GSource* sigchld_warmup = g_child_watch_source_new(getpid());
|
||||
g_source_unref(sigchld_warmup);
|
||||
|
||||
// Build the editor's env without LINES/COLUMNS pre-fork, so the child only
|
||||
// reassigns environ instead of calling unsetenv() between fork and exec.
|
||||
// The editor's (n)curses then reads the live window via ioctl(TIOCGWINSZ).
|
||||
gsize env_len = 0;
|
||||
while (environ[env_len]) {
|
||||
env_len++;
|
||||
}
|
||||
gchar** editor_env = g_new0(gchar*, env_len + 1);
|
||||
gsize env_kept = 0;
|
||||
for (gsize i = 0; i < env_len; i++) {
|
||||
if (g_str_has_prefix(environ[i], "LINES=") || g_str_has_prefix(environ[i], "COLUMNS=")) {
|
||||
continue;
|
||||
}
|
||||
editor_env[env_kept++] = environ[i];
|
||||
}
|
||||
|
||||
pid_t pid = fork();
|
||||
if (pid == -1) {
|
||||
log_error("[Editor] Failed to fork: %s", strerror(errno));
|
||||
@@ -148,12 +166,14 @@ launch_editor(gchar* initial_content, void (*callback)(gchar* content, void* dat
|
||||
ui_resize();
|
||||
cons_show_error("Failed to start editor: %s", strerror(errno));
|
||||
g_strfreev(editor_argv);
|
||||
g_free(ctx->filename);
|
||||
g_free(editor_env);
|
||||
g_free(ctx);
|
||||
return TRUE;
|
||||
} else if (pid == 0) {
|
||||
// Child process: Inherits TTY from parent
|
||||
|
||||
environ = editor_env; // live TIOCGWINSZ size, not the inherited LINES/COLUMNS
|
||||
|
||||
// SIGTSTP=SIG_DFL lets vim's :stop / Ctrl-Z work; profanity catches
|
||||
// the STOPPED state via editor_check_stopped() and drops to the shell.
|
||||
signal(SIGINT, SIG_DFL);
|
||||
@@ -170,6 +190,7 @@ launch_editor(gchar* initial_content, void (*callback)(gchar* content, void* dat
|
||||
editor_pid = pid;
|
||||
g_child_watch_add((GPid)pid, _editor_exit_cb, ctx);
|
||||
g_strfreev(editor_argv);
|
||||
g_free(editor_env); // array only; strings are borrowed from environ
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
|
||||
@@ -155,6 +155,20 @@ cons_show_error(const char* const msg, ...)
|
||||
cons_alert(NULL);
|
||||
}
|
||||
|
||||
void
|
||||
cons_show_warning(const char* const msg, ...)
|
||||
{
|
||||
va_list arg;
|
||||
va_start(arg, msg);
|
||||
GString* fmt_msg = g_string_new(NULL);
|
||||
g_string_vprintf(fmt_msg, msg, arg);
|
||||
win_println(wins_get_console(), THEME_WARNING, "-", "Warning: %s", fmt_msg->str);
|
||||
g_string_free(fmt_msg, TRUE);
|
||||
va_end(arg);
|
||||
|
||||
cons_alert(NULL);
|
||||
}
|
||||
|
||||
void
|
||||
cons_show_tlscert_summary(const TLSCertificate* cert)
|
||||
{
|
||||
|
||||
@@ -252,6 +252,8 @@ G_GNUC_PRINTF(1, 2)
|
||||
void cons_debug(const char* const msg, ...);
|
||||
G_GNUC_PRINTF(1, 2)
|
||||
void cons_show_error(const char* const cmd, ...);
|
||||
G_GNUC_PRINTF(1, 2)
|
||||
void cons_show_warning(const char* const msg, ...);
|
||||
void cons_show_contacts(GSList* list);
|
||||
void cons_show_roster(GSList* list);
|
||||
void cons_show_roster_group(const char* const group, GSList* list);
|
||||
|
||||
@@ -749,11 +749,22 @@ connection_get_user(void)
|
||||
return connection_get_jid()->localpart;
|
||||
}
|
||||
|
||||
// NULL 'from' means the server (RFC 6120 §8.1.2.1)
|
||||
static const char*
|
||||
_get_from_via_jid(const char* const jid)
|
||||
{
|
||||
return jid ? jid : conn.domain;
|
||||
}
|
||||
|
||||
void
|
||||
connection_features_received(const char* const jid)
|
||||
{
|
||||
log_info("[CONNECTION] connection_features_received %s", jid);
|
||||
if (g_hash_table_remove(conn.requested_features, jid) && g_hash_table_size(conn.requested_features) == 0) {
|
||||
const char* key = _get_from_via_jid(jid);
|
||||
if (!key) {
|
||||
return;
|
||||
}
|
||||
log_info("[CONNECTION] connection_features_received %s", key);
|
||||
if (g_hash_table_remove(conn.requested_features, key) && g_hash_table_size(conn.requested_features) == 0) {
|
||||
sv_ev_connection_features_received();
|
||||
}
|
||||
}
|
||||
@@ -761,7 +772,11 @@ connection_features_received(const char* const jid)
|
||||
GHashTable*
|
||||
connection_get_features(const char* const jid)
|
||||
{
|
||||
return g_hash_table_lookup(conn.features_by_jid, jid);
|
||||
const char* key = _get_from_via_jid(jid);
|
||||
if (!key || !conn.features_by_jid) {
|
||||
return NULL;
|
||||
}
|
||||
return g_hash_table_lookup(conn.features_by_jid, key);
|
||||
}
|
||||
|
||||
GList*
|
||||
|
||||
@@ -2314,6 +2314,7 @@ _disco_info_response_id_handler(xmpp_stanza_t* const stanza, void* const userdat
|
||||
log_debug("Received disco#info response from: %s", from);
|
||||
} else {
|
||||
log_debug("Received disco#info response");
|
||||
from = connection_get_domain(); // RFC 6120 §8.1.2.1: no 'from' means the server itself
|
||||
}
|
||||
|
||||
// handle error responses
|
||||
@@ -2397,6 +2398,7 @@ _disco_info_response_id_handler_onconnect(xmpp_stanza_t* const stanza, void* con
|
||||
log_debug("Received disco#info response from: %s", from);
|
||||
} else {
|
||||
log_debug("Received disco#info response");
|
||||
from = connection_get_domain(); // RFC 6120 §8.1.2.1: no 'from' means the server itself
|
||||
}
|
||||
|
||||
// handle error responses
|
||||
|
||||
@@ -173,6 +173,7 @@ main(int argc, char* argv[])
|
||||
PROF_FUNC_TEST(disco_info_without_name),
|
||||
PROF_FUNC_TEST(disco_items_without_name),
|
||||
PROF_FUNC_TEST(disco_info_service_unavailable),
|
||||
PROF_FUNC_TEST(disco_info_result_no_from),
|
||||
|
||||
/* Roster management - add/remove/rename contacts */
|
||||
PROF_FUNC_TEST(sends_new_item),
|
||||
|
||||
@@ -396,6 +396,35 @@ disco_items_without_name(void **state)
|
||||
prof_timeout_reset();
|
||||
}
|
||||
|
||||
void
|
||||
disco_info_result_no_from(void **state)
|
||||
{
|
||||
/*
|
||||
* Test that a disco#info result without a 'from' attribute is treated as
|
||||
* coming from the server itself (RFC 6120 §8.1.2.1). The on-connect
|
||||
* disco#info handler used to crash on such responses (issue #168).
|
||||
*/
|
||||
stbbr_for_query("http://jabber.org/protocol/disco#info",
|
||||
"<iq to='stabber@localhost/profanity' type='result'>"
|
||||
"<query xmlns='http://jabber.org/protocol/disco#info'>"
|
||||
"<identity category='server' type='im' name='NoFromServer'/>"
|
||||
"<feature var='urn:xmpp:ping'/>"
|
||||
"</query>"
|
||||
"</iq>"
|
||||
);
|
||||
|
||||
/* the on-connect disco#info gets the same from-less response */
|
||||
prof_connect();
|
||||
|
||||
prof_input("/disco info");
|
||||
|
||||
prof_timeout(10);
|
||||
/* client survived and attributed the response to the server */
|
||||
assert_true(prof_output_exact("Service discovery info for localhost"));
|
||||
assert_true(prof_output_regex("NoFromServer.*im.*server"));
|
||||
prof_timeout_reset();
|
||||
}
|
||||
|
||||
void
|
||||
disco_info_service_unavailable(void **state)
|
||||
{
|
||||
|
||||
@@ -17,3 +17,4 @@ void disco_info_multiple_identities(void **state);
|
||||
void disco_info_without_name(void **state);
|
||||
void disco_items_without_name(void **state);
|
||||
void disco_info_service_unavailable(void **state);
|
||||
void disco_info_result_no_from(void **state);
|
||||
|
||||
@@ -49,6 +49,18 @@ expect_any_cons_show_error(void)
|
||||
expect_any(cons_show_error, output);
|
||||
}
|
||||
|
||||
void
|
||||
expect_cons_show_warning(char* expected)
|
||||
{
|
||||
expect_string(cons_show_warning, output, expected);
|
||||
}
|
||||
|
||||
void
|
||||
expect_any_cons_show_warning(void)
|
||||
{
|
||||
expect_any(cons_show_warning, output);
|
||||
}
|
||||
|
||||
void
|
||||
expect_win_println(char* message)
|
||||
{
|
||||
@@ -845,6 +857,16 @@ cons_show_error(const char* const cmd, ...)
|
||||
va_end(args);
|
||||
}
|
||||
|
||||
void
|
||||
cons_show_warning(const char* const msg, ...)
|
||||
{
|
||||
va_list args;
|
||||
va_start(args, msg);
|
||||
vsnprintf(output, sizeof(output), msg, args);
|
||||
check_expected(output);
|
||||
va_end(args);
|
||||
}
|
||||
|
||||
void
|
||||
cons_show_contacts(GSList* list)
|
||||
{
|
||||
|
||||
@@ -10,4 +10,6 @@ void expect_cons_show(char* expected);
|
||||
void expect_any_cons_show(void);
|
||||
void expect_cons_show_error(char* expected);
|
||||
void expect_any_cons_show_error(void);
|
||||
void expect_cons_show_warning(char* expected);
|
||||
void expect_any_cons_show_warning(void);
|
||||
void expect_win_println(char* message);
|
||||
|
||||
Reference in New Issue
Block a user