ake

src/base/bang-routing.c

@@ -2,6 +2,7 @@
 #include"bang-module.h"
 #include"bang-module-api.h"
 #include"bang-types.h"
+#include<stdio.h>
 #include<stdlib.h>
 /* I am really reeling in those external libraries! */
 #include<sqlite3.h>
@@ -51,15 +52,60 @@ void BANG_route_finished_job(uuid_t uuid, BANG_job *job) {
 	}
 }
 
+void BANG_route_assertion_of_authority(uuid_t authority, uuid_t peer) {
+	sqlite3_stmt *get_peer_route = prepare_select_statement(peer);
+
+	if (sqlite3_step(get_peer_route) == SQLITE_ROW) {
+		if (sqlite3_column_int(get_peer_route,1) == REMOTE_ROUTE) {
+			/* TODO: Make a request to peer. */
+		} else {
+			const BANG_module *module = sqlite3_column_blob(get_peer_route,2);
+			BANG_module_callback_jobs_available(module,authority,peer);
+		}
+	}
+}
+
+
+void BANG_route_send_message(uuid_t uuid, char *message) {
+	sqlite3_stmt *get_peer_route = prepare_select_statement(uuid);
+
+	if (sqlite3_step(get_peer_route) == SQLITE_ROW) {
+		if (sqlite3_column_int(get_peer_route,1) == REMOTE_ROUTE) {
+			/* TODO: Make a request to peer. */
+		} else {
+			/* Might as well print it out here, no reason to
+			 * do stuipd contorions like making a call back
+			 * function */
+			fprintf(stderr,"%s",message);
+		}
+	}
+}
+
+int BANG_route_get_peer_id(uuid_t uuid) {
+	sqlite3_stmt *get_peer_route = prepare_select_statement(uuid);
+
+	if (sqlite3_step(get_peer_route) == SQLITE_ROW) {
+		if (sqlite3_column_int(get_peer_route,1) == REMOTE_ROUTE) {
+			/* TODO: Make a request to peer. */
+			return sqlite3_column_int(get_peer_route,3);
+		}
+	}
+
+	return - 1;
+}
+
 void BANG_register_module_route(BANG_module *module) {
 
-	/* MORE DEREFENCES THAN YOU CAN HANDLE! */
+	/* MORE DEREFENCES THAN YOU CAN HANDLE!
+	 * Create a uuid and insert into the module.
+	 */
 	module->info->peers_info->uuids = calloc(1,sizeof(uuid_t));
 	module->info->my_id = 0;
 	uuid_generate(module->info->peers_info->uuids[module->info->my_id]);
 	module->info->peers_info->peer_number = 1;
 	module->info->peers_info->validity[module->info->my_id] = 1;
 
+	/* Insert the route in the database. */
 	sqlite3_stmt *insert_module;
 	sqlite3_prepare_v2(db,"INSERT INTO mappings (route_uuid,remote,module,name,text) VALUES (?,1,?,?,?)",80,&insert_module,NULL);
 	sqlite3_bind_blob(insert_module,1,module->info->peers_info->uuids[module->info->my_id],sizeof(uuid_t),SQLITE_STATIC);
@@ -72,18 +118,14 @@ void BANG_register_module_route(BANG_module *module) {
 }
 
 
-void BANG_route_assertion_of_authority(uuid_t authority, uuid_t peer) {
-	sqlite3_stmt *get_peer_route = prepare_select_statement(peer);
-	sqlite3_bind_blob(get_peer_route,1,peer,sizeof(uuid_t),SQLITE_STATIC);
-
-	if (sqlite3_step(get_peer_route) == SQLITE_ROW) {
-		if (sqlite3_column_int(get_peer_route,1) == REMOTE_ROUTE) {
-			/* TODO: Make a request to peer. */
-		} else {
-			const BANG_module *module = sqlite3_column_blob(get_peer_route,2);
-			BANG_module_callback_jobs_available(module,authority,peer);
-		}
-	}
+void BANG_register_peer_route(uuid_t uuid, int peer, char *module_name, char* module_version) {
+	sqlite3_stmt *insert_peer_route;
+	sqlite3_prepare_v2(db,"INSERT INTO mappings (route_uuid,remote,peer_id,name,text) VALUES (?,2,?,?,?)",80,&insert_module,NULL);
+	sqlite3_bind_int(insert_module,2,peer);
+	sqlite3_bind_text(insert_module,3,module_name,-1,SQLITE_STATIC);
+	sqlite3_bind_blob(insert_module,4,module_version,LENGTH_OF_VERSION,SQLITE_STATIC);
+	sqlite3_step(insert_module);
+	sqlite3_finalize(insert_module);
 }
 
 void BANG_route_init() {