graph2: Added logging changes for Channel, Log, Post and Character.

models/changes/db.go

@@ -0,0 +1,31 @@
+package changes
+
+import (
+	"log"
+	"sync"
+	"time"
+
+	"git.aiterp.net/rpdata/api/internal/store"
+	"github.com/globalsign/mgo"
+)
+
+var collection *mgo.Collection
+var submitMutex sync.Mutex
+
+func init() {
+	store.HandleInit(func(db *mgo.Database) {
+		collection = db.C("common.changes")
+
+		collection.EnsureIndexKey("date")
+		collection.EnsureIndexKey("author")
+
+		err := collection.EnsureIndex(mgo.Index{
+			Name:        "expiry",
+			Key:         []string{"date"},
+			ExpireAfter: time.Hour * 2400, // 100 days
+		})
+		if err != nil {
+			log.Fatalln(err)
+		}
+	})
+}

models/changes/submit.go

@@ -0,0 +1,48 @@
+package changes
+
+import (
+	"strconv"
+	"time"
+
+	"git.aiterp.net/rpdata/api/internal/counter"
+	"git.aiterp.net/rpdata/api/models"
+)
+
+// Submit a change to the database
+func Submit(model, op, author string, objects ...interface{}) (models.Change, error) {
+	submitMutex.Lock()
+	defer submitMutex.Unlock()
+
+	id, err := counter.Next("auto_increment", "Change")
+	if err != nil {
+		return models.Change{}, err
+	}
+
+	change := models.Change{
+		ID:     "Change_" + strconv.Itoa(id),
+		Model:  model,
+		Date:   time.Now(),
+		Op:     op,
+		Author: author,
+	}
+
+	for _, object := range objects {
+		switch object := object.(type) {
+		case models.Log:
+			change.Logs = append(change.Logs, object)
+		case models.Character:
+			change.Characters = append(change.Characters, object)
+		case models.Post:
+			change.Posts = append(change.Posts, object)
+		}
+	}
+
+	// TODO: Push to subscribers
+
+	err = collection.Insert(&change)
+	if err != nil {
+		return models.Change{}, err
+	}
+
+	return change, nil
+}