--- /dev/null
+/* notmuch - Not much of an email program, (just index and search)
+ *
+ * Copyright © 2023 Felipe Contreras
+ * Copyright © 2024 David Bremner
+ *
+ * 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 https://www.gnu.org/licenses/ .
+ *
+ * Authors: David Bremner <david@tethera.net>
+ * Felipe Contreras (prototype in ruby)
+ */
+
+#include <assert.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include <notmuch.h>
+#include "notmuch-client.h"
+#include "path-util.h"
+#include "hex-escape.h"
+#include "string-util.h"
+#include "tag-util.h"
+
+#define ASSERT(x) assert ((x))
+
+/* File scope globals */
+const char *debug_flags = NULL;
+FILE *log_file = NULL;
+
+/* For use with getline. */
+char *buffer = NULL;
+size_t buffer_len = 0;
+
+static inline bool
+equal_lastmod (const char *uuid1, unsigned long counter1,
+ const char *uuid2, unsigned long counter2)
+{
+ return (strcmp_null (uuid1, uuid2) == 0) && (counter1 == counter2);
+}
+
+/* Error handling */
+static void
+ensure (bool condition, const char *format, ...)
+{
+ va_list va_args;
+
+ if (! condition) {
+ va_start (va_args, format);
+ vfprintf (stderr, format, va_args);
+ va_end (va_args);
+ fprintf (stderr, "\n");
+ exit (EXIT_FAILURE);
+ }
+}
+
+/* It is a (protocol) error to call this at/after EOF */
+static void
+buffer_line (FILE *stream)
+{
+ ssize_t nread;
+
+ nread = getline (&buffer, &buffer_len, stream);
+ ensure (nread >= 0, "getline %s", strerror (errno));
+ chomp_newline (buffer);
+}
+
+static GStrv
+tokenize_buffer ()
+{
+ char *tok = buffer;
+ size_t tok_len = 0;
+
+ g_autoptr (GStrvBuilder) builder = g_strv_builder_new ();
+
+ while ((tok = strtok_len (tok + tok_len, " \t\n", &tok_len))) {
+ g_autofree char *null_terminated = g_strndup (tok, tok_len);
+ g_strv_builder_add (builder, null_terminated);
+ }
+
+ return g_strv_builder_end (builder);
+}
+
+static void
+flog (const char *format, ...)
+{
+ va_list va_args;
+
+ if (log_file) {
+ va_start (va_args, format);
+ vfprintf (log_file, format, va_args);
+ fflush (log_file);
+ va_end (va_args);
+ }
+}
+
+static const char *
+gmessage (GError *err)
+{
+ if (err)
+ return err->message;
+ else
+ return NULL;
+}
+
+static void
+str2ul (const char *str, unsigned long int *num_p)
+{
+ gboolean ret;
+
+ g_autoptr (GError) gerror = NULL;
+
+ ret = g_ascii_string_to_unsigned (str, 10, 0, G_MAXUINT64, num_p, &gerror);
+ ensure (ret, "converting %s to unsigned long: %s", str, gmessage (gerror));
+}
+
+static void
+read_lastmod (const char *dir, char **uuid_out, unsigned long *counter_out)
+{
+ g_autoptr (GString) filename = g_string_new (dir);
+ unsigned long num = 0;
+ FILE *in;
+
+ assert (uuid_out);
+ assert (counter_out);
+
+ g_string_append (filename, "/lastmod");
+
+ in = fopen (filename->str, "r");
+ if (! in) {
+ ensure (errno == ENOENT, "error opening lastmod file");
+ *uuid_out = NULL;
+ *counter_out = 0;
+ } else {
+ g_auto (GStrv) tokens = NULL;
+ buffer_line (in);
+
+ tokens = tokenize_buffer ();
+
+ *uuid_out = tokens[0];
+ str2ul (tokens[1], &num);
+
+ flog ("loaded uuid = %s\tlastmod = %zu\n", tokens[0], num);
+ }
+
+ *counter_out = num;
+
+}
+
+static void
+cmd_capabilities ()
+{
+ fputs ("import\nexport\nrefspec refs/heads/*:refs/notmuch/*\n\n", stdout);
+ fflush (stdout);
+}
+
+static void
+cmd_list (notmuch_database_t *db, const char *uuid, unsigned long lastmod)
+{
+ unsigned long db_lastmod;
+ const char *db_uuid;
+
+ db_lastmod = notmuch_database_get_revision (db, &db_uuid);
+
+ printf ("? refs/heads/master%s\n\n",
+ equal_lastmod (uuid, lastmod, db_uuid, db_lastmod) ? " unchanged" : "");
+}
+
+/* stubs since we cannot link with notmuch.o */
+const notmuch_opt_desc_t notmuch_shared_options[] = {
+ { }
+};
+
+const char *notmuch_requested_db_uuid = NULL;
+
+void
+notmuch_process_shared_options (unused (notmuch_database_t *notmuch),
+ unused (const char *dummy))
+{
+}
+
+int
+notmuch_minimal_options (unused (const char *subcommand),
+ unused (int argc),
+ unused (char **argv))
+{
+ return 0;
+}
+
+static notmuch_database_t *
+open_database (const char *arg)
+{
+ notmuch_status_t status;
+ notmuch_database_t *notmuch;
+ const char *path = NULL;
+ const char *config = NULL;
+ const char *profile = NULL;
+ const char *scheme = NULL;
+ const char *uriquery = NULL;
+ g_autofree char *status_string = NULL;
+
+ g_autoptr (GUri) uri = NULL;
+ g_autoptr (GHashTable) params = NULL;
+ g_autoptr (GError) gerror = NULL;
+ g_autoptr (GString) address = NULL;
+
+ address = g_string_new (arg);
+
+ scheme = g_uri_peek_scheme (address->str);
+ if (! scheme || (strcmp (scheme, "notmuch") != 0)) {
+ ASSERT (g_string_prepend (address, "notmuch://"));
+ }
+
+ uri = g_uri_parse (address->str, G_URI_FLAGS_ENCODED_QUERY, &gerror);
+ ensure (uri, "unable to parse URL/address %s: %s\n", address->str, gmessage (gerror));
+
+ uriquery = g_uri_get_query (uri);
+ if (uriquery) {
+ flog ("uriquery = %s\n", uriquery);
+ params = g_uri_parse_params (uriquery, -1, "&", G_URI_PARAMS_NONE, &gerror);
+ ensure (params, "unable to parse parameters %s: %s\n", uriquery, gmessage (gerror));
+ }
+
+ if (strlen (g_uri_get_path (uri)) > 0) {
+ path = g_uri_get_path (uri);
+ config = "";
+ }
+
+ if (params) {
+ if (! path)
+ path = g_hash_table_lookup (params, "path");
+ config = g_hash_table_lookup (params, "config");
+ profile = g_hash_table_lookup (params, "profile");
+ }
+
+ flog ("url = %s\npath = %s\nconfig = %s\nprofile = %s\n",
+ address->str, path, config, profile);
+
+ status = notmuch_database_open_with_config (path,
+ NOTMUCH_DATABASE_MODE_READ_WRITE,
+ config,
+ profile,
+ ¬much,
+ &status_string);
+
+ ensure (status == 0, "open database: %s", status_string);
+
+ return notmuch;
+}
+
+int
+main (int argc, char *argv[])
+{
+ notmuch_status_t status;
+ notmuch_database_t *db;
+ unsigned long lastmod = 0;
+ char *uuid = NULL;
+ const char *nm_dir = NULL;
+ g_autofree char *status_string = NULL;
+ const char *git_dir;
+ ssize_t nread;
+ const char *log_file_name;
+
+ debug_flags = getenv ("GIT_REMOTE_NM_DEBUG");
+ log_file_name = getenv ("GIT_REMOTE_NM_LOG");
+
+ if (log_file_name)
+ log_file = fopen (log_file_name, "w");
+
+ ensure (argc >= 3, "usage: %s ALIAS URL\n", argv[0]);
+
+ db = open_database (argv[2]);
+
+ git_dir = getenv ("GIT_DIR");
+ ensure (git_dir, "GIT_DIR not set");
+ flog ("GIT_DIR=%s\n", git_dir);
+
+ ASSERT (nm_dir = talloc_asprintf (db, "%s/%s", git_dir, "notmuch"));
+
+ status = mkdir_recursive (db, nm_dir, 0700, &status_string);
+ ensure (status == 0, "mkdir: %s", status_string);
+
+ read_lastmod (nm_dir, &uuid, &lastmod);
+
+ while ((nread = getline (&buffer, &buffer_len, stdin)) != -1) {
+ char *s = buffer;
+ flog ("command = %s\n", buffer);
+
+ /* skip leading space */
+ while (*s && isspace (*s)) s++;
+
+ if (! *s)
+ break;
+
+ if (STRNCMP_LITERAL (s, "capabilities") == 0)
+ cmd_capabilities ();
+ else if (STRNCMP_LITERAL (s, "list") == 0)
+ cmd_list (db, uuid, lastmod);
+
+ fflush (stdout);
+ flog ("finished command = %s\n", buffer);
+ }
+ flog ("finished loop\n");
+
+ notmuch_database_destroy (db);
+}
projects / notmuch / commitdiff