Added sqlite to track owners of plugins.

Author: scottgonzalez

.gitignore

@@ -1,2 +1,3 @@
 config.json
+plugins.db
 node_modules

package.json

@@ -12,7 +12,8 @@
   "dependencies": {
     "mkdirp": "0.2.1",
     "mysql": "0.9.5",
-    "semver": "1.0.12"
+    "semver": "1.0.12",
+    "sqlite3": "2.1.1"
   },
   "engines": {
     "node": "0.6.5"

src/config-sample.json

@@ -1,6 +1,6 @@
 {
 	"repoDir": "/tmp/plugin-repos",
-	"pluginsDir": "/tmp/plugin-data",
+	"pluginsDb": "plugins.db",
 	"dbHost": "localhost",
 	"dbPort": 3306,
 	"dbName": "mysql",

src/main.js

@@ -1,9 +1,10 @@
 var exec = require( "child_process" ).exec,
 	fs = require( "fs" ),
 	mkdirp = require( "mkdirp" ),
-	template = require( "./template" ),
 	semver = require( "semver" ),
-	wordpress = require( "./wordpress" )
+	template = require( "./template" ),
+	wordpress = require( "./wordpress" ),
+	pluginsDb = require( "./pluginsdb" ),
 	config = require( "./config" );
 
 
@@ -234,8 +235,6 @@ function validatePackageJson( package, version ) {
 		errors.push( "Missing required dependency: jquery." );
 	}
 
-	// TODO: validate repo (must match actual GitHub repo)
-
 	return errors;
 }
 
@@ -284,11 +283,12 @@ function processPlugin( repo, fn ) {
 		}
 
 		if ( !versions.length ) {
-			return fn( createError( "No semver tags.", "NO_SEMVER_TAGS" ) );
+			return fn( null );
 		}
 
-		// TODO: add plugin to database
 		var allErrors = [],
+			// TODO: track our actions so we can process metadata in done()
+			plugins = {},
 			waiting = versions.length;
 
 		function progress() {
@@ -314,26 +314,43 @@ function processPlugin( repo, fn ) {
 					return progress();
 				}
 
+				var package = data.package;
+
 				if ( data.errors.length ) {
 					allErrors.concat( data.errors );
 					return progress();
 				}
 
-				// TODO: verify user is owner of plugin
-
-				data.package._downloadUrl = repoDetails.downloadUrl( version );
-				_generatePage( data.package, function( error, data ) {
+				// find out who owns this plugin
+				// if there is no owner, then set the user as the owner
+				pluginsDb.getOrSetOwner( package.name, repoDetails.userName, function( error, owner ) {
 					if ( error ) {
 						// TODO: log failure for retry
 						return progress();
 					}
 
-					wordpress.addVersionedPlugin( data, function( error ) {
+					// the plugin is owned by someone else
+					if ( owner !== repoDetails.userName ) {
+						return progress();
+					}
+
+					// TODO: track action in sqlite
+
+					// add additional metadata and generate the plugin page
+					package._downloadUrl = repoDetails.downloadUrl( version );
+					_generatePage( package, function( error, data ) {
 						if ( error ) {
 							// TODO: log failure for retry
+							return progress();
 						}
-						console.log( "Added " + data.pluginName + " " + data.version );
-						progress();
+
+						wordpress.addVersionedPlugin( data, function( error ) {
+							if ( error ) {
+								// TODO: log failure for retry
+							}
+							console.log( "Added " + data.pluginName + " " + data.version );
+							progress();
+						});
 					});
 				});
 			});

src/pluginsdb.js

@@ -0,0 +1,71 @@
+var sqlite = require( "sqlite3" ),
+	config = require( "./config" );
+
+var db;
+
+function connect( fn ) {
+	db = new sqlite.Database( config.pluginsDb, fn );
+}
+
+function auto( fn ) {
+	return function() {
+		var that = this,
+			args = arguments;
+
+		if ( db ) {
+			return fn.apply( that, args );
+		}
+
+		connect(function( error ) {
+			if ( error ) {
+				return fn( error );
+			}
+
+			fn.apply( that, args );
+		});
+	};
+}
+
+var pluginsDb = module.exports = {
+	getOwner: auto(function( plugin, fn ) {
+		db.get( "SELECT owner FROM owners WHERE plugin = ?",
+			[ plugin ], function( error, row ) {
+				if ( error ) {
+					return fn( error );
+				}
+
+				if ( !row ) {
+					return fn( null, null );
+				}
+
+				return fn( null, row.owner );
+			});
+	}),
+
+	setOwner: auto(function( plugin, owner, fn ) {
+		db.run( "INSERT INTO owners( plugin, owner ) VALUES( ?, ? )",
+			[ plugin, owner ], function( error ) {
+				if ( error ) {
+					return fn( error );
+				}
+
+				fn( null );
+			});
+	}),
+
+	getOrSetOwner: auto(function( plugin, owner, fn ) {
+		pluginsDb.setOwner( plugin, owner, function( error ) {
+			// successfully set owner (new plugin)
+			if ( !error ) {
+				return fn( null, owner );
+			}
+
+			// there is already an owner
+			if ( error.code === "SQLITE_CONSTRAINT" ) {
+				return pluginsDb.getOwner( plugin, fn );
+			}
+
+			fn( error );
+		});
+	})
+};

src/setup.js

@@ -0,0 +1,67 @@
+var fs = require( "fs" ),
+	sqlite = require( "sqlite3" ),
+	config = require( "./config" ),
+	success = true;
+
+try {
+	fs.unlinkSync( config.pluginsDb );
+} catch( error ) {
+	if ( error.code !== "ENOENT" ) {
+		return logError( "Could not check status of, or delete, plugin.db " );
+	}
+}
+
+var db = new sqlite.Database( config.pluginsDb, function( error ) {
+	if ( error ) {
+		return logError( error, "Could not open database." );
+	}
+
+	setup();
+});
+
+function setup() {
+	createOwnersTable(function( error ) {
+		if ( error ) {
+			return logError( error, "Could not create owners table." );
+		}
+
+		console.log( "Created owners table." );
+	});
+
+	createActionsTable(function( error ) {
+		if ( error ) {
+			return logError( error, "Could not create actions table." );
+		}
+
+		console.log( "Created actions table." );
+	});
+}
+
+function logError( error, msg ) {
+	console.log( "ERROR!", msg );
+	console.log( error );
+	success = false;
+}
+
+function createOwnersTable( fn ) {
+	db.run( "CREATE TABLE owners (" +
+		"plugin TEXT PRIMARY KEY, " +
+		"owner TEXT " +
+	");", fn );
+}
+
+function createActionsTable( fn ) {
+	db.run( "CREATE TABLE actions (" +
+		"id INTEGER PRIMARY KEY AUTOINCREMENT, " +
+		"action TEXT, " +
+		"data TEXT " +
+	");", fn );
+}
+
+process.on( "exit", function() {
+	if ( success ) {
+		console.log( "SUCCESS!", "Setup complete." );
+	} else {
+		console.log( "ERROR!", "Setup failed." );
+	}
+});

src/wordpress.js

@@ -110,6 +110,10 @@ function getMeta( plugin, key, fn ) {
 					return fn( error );
 				}
 
+				if ( !rows.length ) {
+					return fn( null, null );
+				}
+
 				fn( null, rows[ 0 ].meta_value );
 			});
 	});
@@ -132,10 +136,12 @@ module.exports = {
 			data.pluginTitle, data.content, fn );
 	}),
 
+	// TODO: check if this is needed in the end
 	getOwner: auto(function( plugin, fn ) {
 		getMeta( plugin, "owner", fn );
 	}),
 
+	// TODO: check if this is needed in the end
 	setOwner: auto(function( plugin, owner, fn ) {
 		createOrUpdateMeta( plugin, "owner", owner, fn );
 	}),