X-Git-Url: https://git.sommitrealweird.co.uk/onak.git/blobdiff_plain/2eed640f944a24204fa4ed0dbbc80004a800b1eb..567528bebc2dd1a8ccb672d11b22cbe71b292deb:/keydb_fs.c?ds=sidebyside

diff --git a/keydb_fs.c b/keydb_fs.c
index 01101f0..14220d1 100644
--- a/keydb_fs.c
+++ b/keydb_fs.c
@@ -19,6 +19,7 @@
 #include <dirent.h>
 
 #include "charfuncs.h"
+#include "decodekey.h"
 #include "keydb.h"
 #include "keyid.h"
 #include "keystructs.h"
@@ -106,6 +107,25 @@ void worddir(char *buffer, char *word, uint32_t hash)
 		 (uint8_t) ((hash >> 16) & 0xFF), hash, word);
 }
 
+void subkeypath(char *buffer, uint64_t subkey, uint64_t keyid)
+{
+	snprintf(buffer, PATH_MAX, "%s/subkeys/%02X/%02X/%08X/%016llX",
+		 config.db_dir,
+		 (uint8_t) ((subkey >> 24) & 0xFF),
+		 (uint8_t) ((subkey >> 16) & 0xFF),
+		 (uint32_t) (subkey & 0xFFFFFFFF),
+		 keyid);
+}
+
+void subkeydir(char *buffer, uint64_t subkey)
+{
+	snprintf(buffer, PATH_MAX, "%s/subkeys/%02X/%02X/%08X",
+		 config.db_dir,
+		 (uint8_t) ((subkey >> 24) & 0xFF),
+		 (uint8_t) ((subkey >> 16) & 0xFF),
+		 (uint32_t) (subkey & 0xFFFFFFFF));
+}
+
 /*****************************************************************************/
 
 /**
@@ -240,6 +260,8 @@ int store_key(struct openpgp_publickey *publickey, bool intrans,
 	struct openpgp_publickey *next = NULL;
 	uint64_t keyid = get_keyid(publickey);
 	struct ll *wordlist = NULL, *wl = NULL;
+	uint64_t *subkeyids = NULL;
+	int i = 0;
 
 
 	if (!intrans)
@@ -276,8 +298,24 @@ int store_key(struct openpgp_publickey *publickey, bool intrans,
 
 			wl = wl->next;
 		}
-
 		llfree(wordlist, free);
+		
+		subkeyids = keysubkeys(publickey);
+		i = 0;
+		while (subkeyids != NULL && subkeyids[i] != 0) {
+			prove_path_to(subkeyids[i], "subkeys");
+
+			subkeydir(wbuffer, subkeyids[i]);
+			mkdir(wbuffer, 0777);
+			subkeypath(wbuffer, subkeyids[i], keyid);
+			link(buffer, wbuffer);
+
+			i++;
+		}
+		if (subkeyids != NULL) {
+			free(subkeyids);
+			subkeyids = NULL;
+		}
 	}
 
 	if (!intrans)
@@ -296,6 +334,8 @@ int delete_key(uint64_t keyid, bool intrans)
 	int ret;
 	struct openpgp_publickey *pk = NULL;
 	struct ll *wordlist = NULL, *wl = NULL;
+	uint64_t *subkeyids = NULL;
+	int i = 0;
 
 	if ((keyid >> 32) == 0)
 		keyid = getfullkeyid(keyid);
@@ -306,10 +346,10 @@ int delete_key(uint64_t keyid, bool intrans)
 	ret = fetch_key(keyid, &pk, true);
 
 	if (ret) {
-		logthing(LOGTHING_CRITICAL, "Wordlist for key %016llX",
+		logthing(LOGTHING_DEBUG, "Wordlist for key %016llX",
 			 keyid);
 		wl = wordlist = makewordlistfromkey(wordlist, pk);
-		logthing(LOGTHING_CRITICAL,
+		logthing(LOGTHING_DEBUG,
 			 "Wordlist for key %016llX done", keyid);
 		while (wl) {
 			uint32_t hash = calchash((uint8_t *) (wl->object));
@@ -320,6 +360,22 @@ int delete_key(uint64_t keyid, bool intrans)
 
 			wl = wl->next;
 		}
+
+		subkeyids = keysubkeys(pk);
+		i = 0;
+		while (subkeyids != NULL && subkeyids[i] != 0) {
+			prove_path_to(subkeyids[i], "subkeys");
+
+			subkeypath(buffer, subkeyids[i], keyid);
+			unlink(buffer);
+
+			i++;
+		}
+		if (subkeyids != NULL) {
+			free(subkeyids);
+			subkeyids = NULL;
+		}
+
 	}
 
 	keypath(buffer, keyid);
@@ -340,7 +396,7 @@ static struct ll *internal_get_key_by_word(char *word, struct ll *mct)
 
 	worddir(buffer, word, hash);
 	d = opendir(buffer);
-	logthing(LOGTHING_CRITICAL, "Scanning for word %s in dir %s", word,
+	logthing(LOGTHING_DEBUG, "Scanning for word %s in dir %s", word,
 		 buffer);
 	if (d)
 		do {
@@ -351,7 +407,7 @@ static struct ll *internal_get_key_by_word(char *word, struct ll *mct)
 					(int (*)(const void *, const void *))
 						    strcmp) !=
 					NULL)) {
-					logthing(LOGTHING_CRITICAL,
+					logthing(LOGTHING_DEBUG,
 						 "Found %s // %s", word,
 						 de->d_name);
 					keys =
@@ -378,7 +434,7 @@ int fetch_key_text(const char *search,
 	char      *searchtext = NULL;
 	int addedkeys = 0;
 
-	logthing(LOGTHING_CRITICAL, "Search was '%s'", search);
+	logthing(LOGTHING_DEBUG, "Search was '%s'", search);
 
 	searchtext = strdup(search);
 	wl = wordlist = makewordlist(wordlist, searchtext);
@@ -413,7 +469,7 @@ int fetch_key_text(const char *search,
 	/* Now add the keys... */
 	wl = keylist;
 	while (wl) {
-		logthing(LOGTHING_CRITICAL, "Adding key: %s", wl->object);
+		logthing(LOGTHING_DEBUG, "Adding key: %s", wl->object);
 		addedkeys +=
 		    fetch_key(strtoull(wl->object, NULL, 16), publickey,
 			      false);
@@ -429,39 +485,65 @@ int fetch_key_text(const char *search,
 	return addedkeys;
 }
 
-/*
- *	dumpdb - dump the key database
- *	@filenamebase: The base filename to use for the dump.
- */
-int dumpdb(char *filenamebase)
-{
-	return 0;
-}
-
 uint64_t getfullkeyid(uint64_t keyid)
 {
 	static char buffer[PATH_MAX];
-	DIR *d;
-	struct dirent *de;
+	DIR *d = NULL;
+	struct dirent *de = NULL;
 	uint64_t ret = 0;
 
 	keydir(buffer, keyid);
 
 	d = opendir(buffer);
-	do {
-		de = readdir(d);
-		if (de)
+	if (d) {
+		do {
+			de = readdir(d);
 			if (de && de->d_name[0] != '.') {
 				ret = strtoull(de->d_name, NULL, 16);
 			}
-	} while (de && de->d_name[0] == '.');
-	closedir(d);
+		} while (de && de->d_name[0] == '.');
+		closedir(d);	
+	}
+
+	if (ret == 0) {
+		subkeydir(buffer, keyid);
+
+		d = opendir(buffer);
+		if (d) {
+			do {
+				de = readdir(d);
+				if (de && de->d_name[0] != '.') {
+					ret = strtoull(de->d_name, NULL, 16);
+				}
+			} while (de && de->d_name[0] == '.');
+			closedir(d);
+		}
+	}
+	
 	return ret;
 }
 
+/**
+ *	iterate_keys - call a function once for each key in the db.
+ *	@iterfunc: The function to call.
+ *	@ctx: A context pointer
+ *
+ *	Calls iterfunc once for each key in the database. ctx is passed
+ *	unaltered to iterfunc. This function is intended to aid database dumps
+ *	and statistic calculations.
+ *
+ *	Returns the number of keys we iterated over.
+ */
+int iterate_keys(void (*iterfunc)(void *ctx, struct openpgp_publickey *key),
+		void *ctx)
+{
+	return 0;
+}
+
 /*
  * Include the basic keydb routines.
  */
 #define NEED_KEYID2UID 1
 #define NEED_GETKEYSIGS 1
+#define NEED_UPDATEKEYS 1
 #include "keydb.c"