added bulk insert and increased the default max upload to 150mb

Author: dstpierre

db.go

@@ -25,7 +25,11 @@ type Database struct {
 
 func (database *Database) dbreq(w http.ResponseWriter, r *http.Request) {
 	if r.Method == http.MethodPost {
-		database.add(w, r)
+		if len(r.URL.Query().Get("bulk")) > 0 {
+			database.bulkAdd(w, r)
+		} else {
+			database.add(w, r)
+		}
 	} else if r.Method == http.MethodPut {
 		database.update(w, r)
 	} else if r.Method == http.MethodDelete {
@@ -81,6 +85,32 @@ func (database *Database) add(w http.ResponseWriter, r *http.Request) {
 	respond(w, http.StatusCreated, doc)
 }
 
+func (database *Database) bulkAdd(w http.ResponseWriter, r *http.Request) {
+	conf, auth, err := middleware.Extract(r, true)
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+
+	curDB := database.client.Database(conf.Name)
+
+	_, r.URL.Path = ShiftPath(r.URL.Path)
+	col, _ := ShiftPath(r.URL.Path)
+
+	var v []interface{}
+	if err := json.NewDecoder(r.Body).Decode(&v); err != nil {
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	if err := database.base.BulkAdd(auth, curDB, col, v); err != nil {
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	respond(w, http.StatusCreated, true)
+}
+
 func (database *Database) list(w http.ResponseWriter, r *http.Request) {
 	page, size := getPagination(r.URL)
 

db/base.go

@@ -39,6 +39,31 @@ func (b *Base) Add(auth internal.Auth, db *mongo.Database, col string, doc map[s
 	return doc, nil
 }
 
+func (b *Base) BulkAdd(auth internal.Auth, db *mongo.Database, col string, docs []interface{}) error {
+	for _, item := range docs {
+		doc, ok := item.(map[string]interface{})
+		if !ok {
+			return fmt.Errorf("unable to cast docs to map")
+		}
+
+		delete(doc, "id")
+		delete(doc, internal.FieldID)
+		delete(doc, internal.FieldAccountID)
+		delete(doc, internal.FieldOwnerID)
+
+		doc[internal.FieldID] = primitive.NewObjectID()
+		doc[internal.FieldAccountID] = auth.AccountID
+		doc[internal.FieldOwnerID] = auth.UserID
+	}
+
+	ctx := context.Background()
+	if _, err := db.Collection(col).InsertMany(ctx, docs); err != nil {
+		return err
+	}
+
+	return nil
+}
+
 type PagedResult struct {
 	Page    int64    `json:"page"`
 	Size    int64    `json:"size"`

storage.go

@@ -35,7 +35,7 @@ func upload(w http.ResponseWriter, r *http.Request) {
 
 	// check for file size
 	// TODO: This should be based on current plan
-	if h.Size/(1000*1000) > 64 {
+	if h.Size/(1000*1000) > 150 {
 		http.Error(w, "file size exeeded your limit", http.StatusBadRequest)
 		return
 	}