initial commit

Author: jamescarr

.gitignore

@@ -0,0 +1 @@
+node_modules

app.js

@@ -0,0 +1,61 @@
+var express  = require('express')
+    , gridfs   = require('./gridfs')
+    , mongoose = require('mongoose')
+
+mongoose.connect('mongodb://localhost/test')
+
+var app = module.exports = express.createServer();
+
+// Configuration
+
+app.configure(function(){
+  app.set('views', __dirname + '/views');
+  app.set('view engine', 'jade');
+  app.use(express.bodyParser());
+  app.use(express.methodOverride());
+  app.use(app.router);
+  app.use(express.static(__dirname + '/public'));
+  app.use(express.errorHandler({ dumpExceptions: true, showStack: true })); 
+});
+
+// model
+
+var DudeSchema = new mongoose.Schema({
+    name: String
+  , files: [mongoose.Schema.Mixed]
+});
+DudeSchema.methods.addFile = function(file, options, fn){
+    var dude = this;
+    console.log(file)
+    gridfs.putFile(file.path, file.filename, options, function(err, result){
+      dude.files.push(result);
+      dude.save(fn);
+    });
+
+}
+var Dude = mongoose.model('Dude',DudeSchema);
+
+// Routes
+
+app.get('/', function(req, res){
+  Dude.find({}, function(err, dudes){
+    res.render('index', { title: 'Express', dudes:dudes })
+  });
+});
+
+app.post('/new', function(req, res){
+  var dude = new Dude();
+
+  dude.name = req.body.name
+  dude.addFile(req.files.file, {content_type:req.files.file.type}, function(err, result){
+    res.redirect('/');
+  });
+});
+
+app.get('/file/:id', function(req, res){
+  gridfs.pipe(req.params.id, process.stdout);
+});
+
+
+app.listen(3000);
+console.log("Express server listening on port %d in %s mode", app.address().port, app.settings.env);

gridfs.coffee

@@ -0,0 +1,44 @@
+mongoose = require("mongoose")
+debug    = require("debug")("gridfs")
+assert   = require("better-assert")
+
+GridStore = mongoose.mongo.GridStore
+Grid = mongoose.mongo.Grid
+
+exports.get = (id, fn) ->
+  ##debug "fetching %s", id
+  db = mongoose.connection.db
+  id = new mongoose.mongo.BSONPure.ObjectID(id)
+  store = new GridStore(db, id, "r",{root: "fs"})
+  store.open (err, store) ->
+    assert not err
+    return fn(err)  if err
+    store.readBuffer fn
+
+exports.put = (buf, name, fn) ->
+  db = mongoose.connection.db
+  ##debug "saving %d bytes as %s", buf.length, name
+  new GridStore(db, name, "w").open (err, file) ->
+    assert not err
+    return fn(err)  if err
+    file.write buf, true, fn
+
+exports.putFile = (path, name, fn) ->
+  db = mongoose.connection.db
+  ##debug "saving %s as %s", path, name
+  new GridStore(db, name, "w").open (err, file) ->
+    assert not err
+    return fn(err)  if err
+    file.writeFile path, fn
+
+exports.deleteFile = (id, fn) ->
+  console.log "deleting " + id
+  db = mongoose.connection.db
+  id = new mongoose.mongo.BSONPure.ObjectID(id)
+  store = new GridStore(db, id, "r",{root: "fs"})
+  store.unlink (err, result) ->
+    if err
+      console.log err
+      return fn(err)  if err
+    return true
+

gridfs.js

@@ -0,0 +1,61 @@
+var mongoose = require("mongoose")
+    , request = require('request')
+
+var GridStore = mongoose.mongo.GridStore;
+var Grid = mongoose.mongo.Grid;
+
+  exports.get = function(id, fn) {
+    var db, store;
+    db = mongoose.connection.db;
+    id = new mongoose.mongo.BSONPure.ObjectID(id);
+    store = new GridStore(db, id, "r", {
+      root: "fs"
+    });
+    return store.open(function(err, store) {
+      if (err) return fn(err);
+      return store.readBuffer(fn);
+    });
+  };
+  exports.pipe = function(id, outstream) {
+    var db, store;
+    db = mongoose.connection.db;
+    id = new mongoose.mongo.BSONPure.ObjectID(id);
+    store = new GridStore(db, id, "r", {
+      root: "fs"
+    });
+    store.stream(true).pipe(outstream)
+  };
+
+  exports.put = function(buf, name, fn) {
+    var db;
+    db = mongoose.connection.db;
+    return new GridStore(db, name, "w").open(function(err, file) {
+      if (err) return fn(err);
+      return file.write(buf, true, fn);
+    });
+  };
+
+  exports.putFile = function(path, name, options, fn) {
+    var db = mongoose.connection.db;
+    return new GridStore(db, name, "w", options).open(function(err, file) {
+      if (err) return fn(err);
+      return file.writeFile(path, fn);
+    });
+  };
+
+  exports.deleteFile = function(id, fn) {
+    var db, store;
+    console.log("deleting " + id);
+    db = mongoose.connection.db;
+    id = new mongoose.mongo.BSONPure.ObjectID(id);
+    store = new GridStore(db, id, "r", {
+      root: "fs"
+    });
+    return store.unlink(function(err, result) {
+      if (err) {
+        console.log(err);
+        if (err) return fn(err);
+      }
+      return true;
+    });
+  };

package.json

@@ -0,0 +1,11 @@
+{
+    "name": "application-name"
+  , "version": "0.0.1"
+  , "private": true
+  , "dependencies": {
+      "express": "2.5.4"
+    , "jade": ">= 0.0.1"
+    , "mongoose": "2.4.1"
+    , "request": "2.9.3"
+  }
+}