/* * Claws Mail -- a GTK based, lightweight, and fast e-mail client * Copyright (C) 1999-2022 the Claws Mail team and Hiroyuki Yamamoto * * This program 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. * * This program 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 this program. If not, see . * */ #ifdef HAVE_CONFIG_H # include "config.h" #include "claws-features.h" #endif #include "defs.h" #include #include #include #include #include #include #include #ifndef G_OS_WIN32 #include #endif #include "send_message.h" #include "session.h" #include "ssl.h" #include "smtp.h" #include "prefs_common.h" #include "prefs_account.h" #include "procheader.h" #include "account.h" #include "progressdialog.h" #include "statusbar.h" #include "inputdialog.h" #include "alertpanel.h" #include "manage_window.h" #include "logwindow.h" #include "proxy.h" #include "socket.h" #include "utils.h" #include "gtkutils.h" #include "inc.h" #include "log.h" #include "passwordstore.h" #include "file-utils.h" #ifdef USE_OAUTH2 #include "oauth2.h" #endif typedef struct _SendProgressDialog SendProgressDialog; struct _SendProgressDialog { ProgressDialog *dialog; Session *session; gboolean cancelled; }; static SendProgressDialog *send_dialog = NULL; static gint send_recv_message (Session *session, const gchar *msg, gpointer data); static gint send_send_data_progressive (Session *session, guint cur_len, guint total_len, gpointer data); static gint send_send_data_finished (Session *session, guint len, gpointer data); static SendProgressDialog *send_progress_dialog_create(void); static void send_progress_dialog_destroy(SendProgressDialog *dialog); static void send_showlog_button_cb (GtkWidget *widget, gpointer data); static void send_cancel_button_cb (GtkWidget *widget, gpointer data); static void send_put_error (Session *session); void send_cancel(void) { if (send_dialog) send_cancel_button_cb(NULL, send_dialog); } gboolean send_is_active(void) { return (send_dialog != NULL); } gint send_message(const gchar *file, PrefsAccount *ac_prefs, GSList *to_list) { FILE *fp; gint val; cm_return_val_if_fail(file != NULL, -1); cm_return_val_if_fail(ac_prefs != NULL, -1); cm_return_val_if_fail(to_list != NULL, -1); if ((fp = claws_fopen(file, "rb")) == NULL) { FILE_OP_ERROR(file, "claws_fopen"); return -1; } inc_lock(); if (ac_prefs->use_mail_command && ac_prefs->mail_command && (*ac_prefs->mail_command)) { val = send_message_local(ac_prefs->mail_command, fp); claws_fclose(fp); inc_unlock(); return val; } else { val = send_message_smtp(ac_prefs, to_list, fp); claws_fclose(fp); inc_unlock(); return val; } } enum { Q_SENDER = 0, Q_SMTPSERVER = 1, Q_RECIPIENTS = 2, Q_ACCOUNT_ID = 3 }; gint send_message_local(const gchar *command, FILE *fp) { gchar **argv; GPid pid; gint child_stdin; gchar buf[BUFFSIZE]; gboolean err = FALSE; cm_return_val_if_fail(command != NULL, -1); cm_return_val_if_fail(fp != NULL, -1); log_message(LOG_PROTOCOL, _("Sending message using command: %s\n"), command); argv = strsplit_with_quote(command, " ", 0); if (g_spawn_async_with_pipes(NULL, argv, NULL, #ifdef G_OS_WIN32 0, #else G_SPAWN_DO_NOT_REAP_CHILD, #endif NULL, NULL, &pid, &child_stdin, NULL, NULL, NULL) == FALSE) { g_snprintf(buf, sizeof(buf), _("Couldn't execute command: %s"), command); log_warning(LOG_PROTOCOL, "%s\n", buf); alertpanel_error("%s", buf); g_strfreev(argv); return -1; } g_strfreev(argv); while (claws_fgets(buf, sizeof(buf), fp) != NULL) { strretchomp(buf); if (buf[0] == '.' && buf[1] == '\0') { if (fd_write_all(child_stdin, ".", 1) < 0) { err = TRUE; break; } } if (fd_write_all(child_stdin, buf, strlen(buf)) < 0 || fd_write_all(child_stdin, "\n", 1) < 0) { err = TRUE; break; } } fd_close(child_stdin); #ifndef G_OS_WIN32 gint status; waitpid(pid, &status, 0); if (!WIFEXITED(status) || WEXITSTATUS(status) != 0) err = TRUE; #endif g_spawn_close_pid(pid); if (err) { g_snprintf(buf, sizeof(buf), _("Error occurred while executing command: %s"), command); log_warning(LOG_PROTOCOL, "%s\n", buf); alertpanel_error("%s", buf); return -1; } return 0; } gint send_message_smtp_full(PrefsAccount *ac_prefs, GSList *to_list, FILE *fp, gboolean keep_session) { Session *session; SMTPSession *smtp_session; gushort port = 0; gchar buf[BUFFSIZE]; gint ret = 0; gboolean was_inited = FALSE; MsgInfo *tmp_msginfo = NULL; MsgFlags flags = {0, 0}; long fp_pos = 0; gchar spec_from[BUFFSIZE]; ProxyInfo *proxy_info = NULL; cm_return_val_if_fail(ac_prefs != NULL, -1); cm_return_val_if_fail(ac_prefs->address != NULL, -1); cm_return_val_if_fail(ac_prefs->smtp_server != NULL, -1); cm_return_val_if_fail(to_list != NULL, -1); cm_return_val_if_fail(fp != NULL, -1); /* get the From address used, not necessarily the ac_prefs', * because it's editable. */ fp_pos = ftell(fp); if (fp_pos < 0) { perror("ftell"); return -1; } tmp_msginfo = procheader_parse_stream(fp, flags, TRUE, FALSE); if (fseek(fp, fp_pos, SEEK_SET) < 0) { perror("fseek"); return -1; } if (tmp_msginfo && tmp_msginfo->extradata && tmp_msginfo->extradata->resent_from) { strncpy2(spec_from, tmp_msginfo->extradata->resent_from, BUFFSIZE-1); extract_address(spec_from); } else if (tmp_msginfo && tmp_msginfo->from) { strncpy2(spec_from, tmp_msginfo->from, BUFFSIZE-1); extract_address(spec_from); } else { strncpy2(spec_from, ac_prefs->address, BUFFSIZE-1); } if (tmp_msginfo) { procmsg_msginfo_free(&tmp_msginfo); } if (!ac_prefs->session) { /* we can't reuse a previously initialised session */ session = smtp_session_new(ac_prefs); session->ssl_cert_auto_accept = ac_prefs->ssl_certs_auto_accept; smtp_session = SMTP_SESSION(session); if (ac_prefs->set_domain && ac_prefs->domain && strlen(ac_prefs->domain)) { smtp_session->hostname = g_strdup(ac_prefs->domain); } else { smtp_session->hostname = NULL; } #ifdef USE_GNUTLS port = ac_prefs->set_smtpport ? ac_prefs->smtpport : ac_prefs->ssl_smtp == SSL_TUNNEL ? SSMTP_PORT : SMTP_PORT; session->ssl_type = ac_prefs->ssl_smtp; if (ac_prefs->ssl_smtp != SSL_NONE) session->nonblocking = ac_prefs->use_nonblocking_ssl; if (ac_prefs->set_gnutls_priority && ac_prefs->gnutls_priority && strlen(ac_prefs->gnutls_priority)) session->gnutls_priority = g_strdup(ac_prefs->gnutls_priority); session->use_tls_sni = ac_prefs->use_tls_sni; #ifdef USE_OAUTH2 if (ac_prefs->use_smtp_auth && ac_prefs->smtp_auth_type == SMTPAUTH_OAUTH2) oauth2_check_passwds(ac_prefs); #endif #else if (ac_prefs->ssl_smtp != SSL_NONE) { if (alertpanel_full(_("Insecure connection"), _("This connection is configured to be secured " "using TLS, but TLS is not available " "in this build of Claws Mail. \n\n" "Do you want to continue connecting to this " "server? The communication would not be " "secure."), NULL, _("_Cancel"), NULL, _("Con_tinue connecting"), NULL, NULL, ALERTFOCUS_FIRST, FALSE, NULL, ALERT_WARNING) != G_ALERTALTERNATE) { session_destroy(session); return -1; } } port = ac_prefs->set_smtpport ? ac_prefs->smtpport : SMTP_PORT; #endif if (ac_prefs->use_smtp_auth) { smtp_session->forced_auth_type = ac_prefs->smtp_auth_type; if (ac_prefs->smtp_userid && strlen(ac_prefs->smtp_userid)) { smtp_session->user = g_strdup(ac_prefs->smtp_userid); if (password_get(smtp_session->user, ac_prefs->smtp_server, "smtp", port, &(smtp_session->pass))) { /* NOP */; } else if ((smtp_session->pass = passwd_store_get_account(ac_prefs->account_id, PWS_ACCOUNT_SEND)) == NULL) { smtp_session->pass = input_dialog_query_password_keep (ac_prefs->smtp_server, smtp_session->user, &(ac_prefs->session_smtp_passwd)); if (!smtp_session->pass) { session_destroy(session); return -1; } } } else { smtp_session->user = g_strdup(ac_prefs->userid); if (password_get(smtp_session->user, ac_prefs->smtp_server, "smtp", port, &(smtp_session->pass))) { /* NOP */; } else if ((smtp_session->pass = passwd_store_get_account( ac_prefs->account_id, PWS_ACCOUNT_RECV)) == NULL) { smtp_session->pass = input_dialog_query_password_keep (ac_prefs->smtp_server, smtp_session->user, &(ac_prefs->session_smtp_passwd)); if (!smtp_session->pass) { session_destroy(session); return -1; } } } } else { smtp_session->user = NULL; smtp_session->pass = NULL; } send_dialog = send_progress_dialog_create(); send_dialog->session = session; smtp_session->dialog = send_dialog; progress_dialog_list_set(send_dialog->dialog, 0, NULL, ac_prefs->smtp_server, _("Connecting")); if (ac_prefs->pop_before_smtp && (ac_prefs->protocol == A_POP3) && (time(NULL) - ac_prefs->last_pop_login_time) > (60 * ac_prefs->pop_before_smtp_timeout)) { g_snprintf(buf, sizeof(buf), _("Doing POP before SMTP...")); log_message(LOG_PROTOCOL, "%s\n", buf); progress_dialog_set_label(send_dialog->dialog, buf); progress_dialog_list_set_status(send_dialog->dialog, 0, _("POP before SMTP")); GTK_EVENTS_FLUSH(); inc_pop_before_smtp(ac_prefs); } g_snprintf(buf, sizeof(buf), _("Account '%s': Connecting to SMTP server: %s:%d..."), ac_prefs->account_name, ac_prefs->smtp_server, port); progress_dialog_set_label(send_dialog->dialog, buf); log_message(LOG_PROTOCOL, "%s\n", buf); session_set_recv_message_notify(session, send_recv_message, send_dialog); session_set_send_data_progressive_notify (session, send_send_data_progressive, send_dialog); session_set_send_data_notify(session, send_send_data_finished, send_dialog); } else { /* everything is ready to start at MAIL FROM:, just * reinit useful variables. */ session = SESSION(ac_prefs->session); ac_prefs->session = NULL; smtp_session = SMTP_SESSION(session); smtp_session->state = SMTP_HELO; send_dialog = (SendProgressDialog *)smtp_session->dialog; was_inited = TRUE; } /* This has to be initialised for every mail sent */ smtp_session->from = g_strdup(spec_from); smtp_session->to_list = to_list; smtp_session->cur_to = to_list; smtp_session->send_data = (guchar *)get_outgoing_rfc2822_str(fp); smtp_session->send_data_len = strlen((gchar *)smtp_session->send_data); if (ac_prefs->use_proxy && ac_prefs->use_proxy_for_send) { if (ac_prefs->use_default_proxy) { proxy_info = (ProxyInfo *)&(prefs_common.proxy_info); if (proxy_info->use_proxy_auth) proxy_info->proxy_pass = passwd_store_get(PWS_CORE, PWS_CORE_PROXY, PWS_CORE_PROXY_PASS); } else { proxy_info = (ProxyInfo *)&(ac_prefs->proxy_info); if (proxy_info->use_proxy_auth) proxy_info->proxy_pass = passwd_store_get_account(ac_prefs->account_id, PWS_ACCOUNT_PROXY_PASS); } } SESSION(smtp_session)->proxy_info = proxy_info; session_set_timeout(session, prefs_common.io_timeout_secs * 1000); /* connect if necessary */ if (!was_inited && session_connect(session, ac_prefs->smtp_server, port) < 0) { session_destroy(session); send_progress_dialog_destroy(send_dialog); ac_prefs->session = NULL; return -1; } debug_print("send_message_smtp(): begin event loop\n"); if (was_inited) { /* as the server is quiet, start sending ourselves */ smtp_from(smtp_session); } while (session_is_running(session) && send_dialog->cancelled == FALSE && SMTP_SESSION(session)->state != SMTP_MAIL_SENT_OK) gtk_main_iteration(); if (SMTP_SESSION(session)->error_val == SM_AUTHFAIL) { if (ac_prefs->session_smtp_passwd) { g_free(ac_prefs->session_smtp_passwd); ac_prefs->session_smtp_passwd = NULL; } ret = -1; } else if (SMTP_SESSION(session)->state == SMTP_MAIL_SENT_OK) { log_message(LOG_PROTOCOL, "%s\n", _("Mail sent successfully.")); ret = 0; } else if (session->state == SESSION_EOF && SMTP_SESSION(session)->state == SMTP_QUIT) { /* consider EOF right after QUIT successful */ log_warning(LOG_PROTOCOL, "%s\n", _("Connection closed by the remote host.")); ret = 0; } else if (session->state == SESSION_ERROR || session->state == SESSION_EOF || session->state == SESSION_TIMEOUT || SMTP_SESSION(session)->state == SMTP_ERROR || SMTP_SESSION(session)->error_val != SM_OK) ret = -1; else if (send_dialog->cancelled == TRUE) ret = -1; if (ret == -1) { manage_window_focus_in(send_dialog->dialog->window, NULL, NULL); send_put_error(session); manage_window_focus_out(send_dialog->dialog->window, NULL, NULL); } /* if we should close the connection, let's do it. * Close it in case of error, too, as it helps reinitializing things * easier. */ if (!keep_session || ret != 0) { if (session_is_connected(session)) smtp_quit(smtp_session); while (session_is_connected(session) && !send_dialog->cancelled) gtk_main_iteration(); session_destroy(session); ac_prefs->session = NULL; send_progress_dialog_destroy(send_dialog); } else { g_free(smtp_session->from); g_free(smtp_session->send_data); g_free(smtp_session->error_msg); } if (keep_session && ret == 0 && ac_prefs->session == NULL) ac_prefs->session = SMTP_SESSION(session); statusbar_pop_all(); statusbar_verbosity_set(FALSE); return ret; } gint send_message_smtp(PrefsAccount *ac_prefs, GSList *to_list, FILE *fp) { return send_message_smtp_full(ac_prefs, to_list, fp, FALSE); } static gint send_recv_message(Session *session, const gchar *msg, gpointer data) { gchar buf[BUFFSIZE]; SMTPSession *smtp_session = SMTP_SESSION(session); SendProgressDialog *dialog = (SendProgressDialog *)data; gchar *state_str = NULL; cm_return_val_if_fail(dialog != NULL, -1); switch (smtp_session->state) { case SMTP_READY: return 0; case SMTP_HELO: g_snprintf(buf, sizeof(buf), _("Sending HELO...")); state_str = _("Authenticating"); statusbar_print_all(_("Sending message...")); break; case SMTP_EHLO: g_snprintf(buf, sizeof(buf), _("Sending EHLO...")); state_str = _("Authenticating"); statusbar_print_all(_("Sending message...")); break; case SMTP_AUTH: g_snprintf(buf, sizeof(buf), _("Authenticating...")); state_str = _("Authenticating"); break; case SMTP_FROM: g_snprintf(buf, sizeof(buf), _("Sending MAIL FROM...")); state_str = _("Sending"); break; case SMTP_RCPT: g_snprintf(buf, sizeof(buf), _("Sending RCPT TO...")); state_str = _("Sending"); break; case SMTP_DATA: case SMTP_EOM: g_snprintf(buf, sizeof(buf), _("Sending DATA...")); state_str = _("Sending"); break; case SMTP_QUIT: g_snprintf(buf, sizeof(buf), _("Quitting...")); state_str = _("Quitting"); break; case SMTP_ERROR: g_warning("send: error: %s", msg); return 0; default: return 0; } progress_dialog_set_label(dialog->dialog, buf); progress_dialog_list_set_status(dialog->dialog, 0, state_str); return 0; } static gint send_send_data_progressive(Session *session, guint cur_len, guint total_len, gpointer data) { gchar buf[BUFFSIZE]; SendProgressDialog *dialog = (SendProgressDialog *)data; MainWindow *mainwin = mainwindow_get_mainwindow(); cm_return_val_if_fail(dialog != NULL, -1); if (SMTP_SESSION(session)->state != SMTP_SEND_DATA && SMTP_SESSION(session)->state != SMTP_EOM) return 0; g_snprintf(buf, sizeof(buf), _("Sending message (%d / %d bytes)"), cur_len, total_len); progress_dialog_set_label(dialog->dialog, buf); progress_dialog_set_fraction (dialog->dialog, (total_len == 0) ? 0 : (gfloat)cur_len / (gfloat)total_len); if (mainwin) { if (!gtk_widget_get_visible(mainwin->progressbar)) gtk_widget_show(mainwin->progressbar); gtk_progress_bar_set_fraction (GTK_PROGRESS_BAR(mainwin->progressbar), (total_len == 0) ? 0 : (gfloat)cur_len / (gfloat)total_len); } return 0; } static gint send_send_data_finished(Session *session, guint len, gpointer data) { SendProgressDialog *dialog = (SendProgressDialog *)data; MainWindow *mainwin = mainwindow_get_mainwindow(); cm_return_val_if_fail(dialog != NULL, -1); send_send_data_progressive(session, len, len, dialog); if (mainwin) { gtk_widget_hide(mainwin->progressbar); gtk_progress_bar_set_fraction (GTK_PROGRESS_BAR(mainwin->progressbar),(gfloat)0); } return 0; } static void send_progress_dialog_size_allocate_cb(GtkWidget *widget, GtkAllocation *allocation) { cm_return_if_fail(allocation != NULL); gtk_window_get_size(GTK_WINDOW(widget), &prefs_common.sendwin_width, &prefs_common.sendwin_height); } static SendProgressDialog *send_progress_dialog_create(void) { SendProgressDialog *dialog; ProgressDialog *progress; static GdkGeometry geometry; dialog = g_new0(SendProgressDialog, 1); progress = progress_dialog_create(); gtk_window_set_title(GTK_WINDOW(progress->window), _("Sending message")); g_signal_connect(G_OBJECT(progress->showlog_btn), "clicked", G_CALLBACK(send_showlog_button_cb), dialog); g_signal_connect(G_OBJECT(progress->cancel_btn), "clicked", G_CALLBACK(send_cancel_button_cb), dialog); g_signal_connect(G_OBJECT(progress->window), "delete_event", G_CALLBACK(gtk_true), NULL); gtk_window_set_modal(GTK_WINDOW(progress->window), TRUE); g_signal_connect(G_OBJECT(progress->window), "size_allocate", G_CALLBACK(send_progress_dialog_size_allocate_cb), NULL); manage_window_set_transient(GTK_WINDOW(progress->window)); progress_dialog_get_fraction(progress); if (!geometry.min_height) { geometry.min_width = 460; geometry.min_height = 250; } gtk_window_set_geometry_hints(GTK_WINDOW(progress->window), NULL, &geometry, GDK_HINT_MIN_SIZE); gtk_widget_set_size_request(progress->window, prefs_common.sendwin_width, prefs_common.sendwin_height); if (!prefs_common.send_dialog_invisible) { gtk_widget_show_now(progress->window); } dialog->dialog = progress; return dialog; } static void send_progress_dialog_destroy(SendProgressDialog *dialog) { cm_return_if_fail(dialog != NULL); if (!prefs_common.send_dialog_invisible) { progress_dialog_destroy(dialog->dialog); } g_free(dialog); send_dialog = NULL; } static void send_showlog_button_cb(GtkWidget *widget, gpointer data) { MainWindow *mainwin = mainwindow_get_mainwindow(); log_window_show(mainwin->logwin); } static void send_cancel_button_cb(GtkWidget *widget, gpointer data) { SendProgressDialog *dialog = (SendProgressDialog *)data; statusbar_progress_all(0,0,0); dialog->cancelled = TRUE; } static void send_put_error(Session *session) { gchar *msg; gchar *log_msg = NULL; gchar *err_msg = NULL; msg = SMTP_SESSION(session)->error_msg; switch (SMTP_SESSION(session)->error_val) { case SM_ERROR: case SM_UNRECOVERABLE: log_msg = _("Error occurred while sending the message."); if (msg) err_msg = g_strdup_printf (_("Error occurred while sending the message:\n%s"), msg); else err_msg = g_strdup(log_msg); break; case SM_AUTHFAIL: log_msg = _("Authentication failed."); if (msg) err_msg = g_strdup_printf (_("Authentication failed:\n%s"), msg); else err_msg = g_strdup(log_msg); break; default: switch (session->state) { case SESSION_ERROR: log_msg = _("Error occurred while sending the message."); err_msg = g_strdup(log_msg); break; case SESSION_EOF: log_msg = _("Connection closed by the remote host."); err_msg = g_strdup(log_msg); break; case SESSION_TIMEOUT: log_msg = _("Session timed out. You may be able to " "recover by increasing the timeout value in " "Preferences/Other/Miscellaneous."); err_msg = g_strdup(log_msg); break; default: break; } break; } if (err_msg) { log_error(LOG_PROTOCOL, "%s\n", err_msg); g_free(err_msg); } else { if (log_msg) log_warning(LOG_PROTOCOL, "%s\n", log_msg); } }