Add realtime envelope and dispatch presence events. (heroiclabs#143)

main.go

@@ -30,6 +30,7 @@ import (
 	"net/url"
 
 	_ "github.com/lib/pq"
+	"github.com/golang/protobuf/jsonpb"
 )
 
 var (
@@ -69,12 +70,23 @@ func main() {
 	// Check migration status and log if the schema has diverged.
 	cmd.MigrationStartupCheck(multiLogger, db)
 
+	// Shared utility components.
+	jsonpbMarshaler := &jsonpb.Marshaler{
+		EnumsAsInts:  true,
+		EmitDefaults: false,
+		Indent:       "",
+		OrigName:     false,
+	}
+	jsonpbUnmarshaler := &jsonpb.Unmarshaler{
+		AllowUnknownFields: false,
+	}
+
 	// Start up server components.
 	registry := server.NewSessionRegistry()
-	tracker := server.StartLocalTracker(jsonLogger, registry, config.GetName())
-	router := server.NewLocalMessageRouter(registry, tracker)
+	tracker := server.StartLocalTracker(jsonLogger, registry, jsonpbMarshaler, config.GetName())
+	router := server.NewLocalMessageRouter(registry, tracker, jsonpbMarshaler)
 	pipeline := server.NewPipeline(config, db, tracker, router, registry)
-	apiServer := server.StartApiServer(jsonLogger, db, config, tracker, registry, pipeline)
+	apiServer := server.StartApiServer(jsonLogger, db, config, tracker, registry, pipeline, jsonpbMarshaler, jsonpbUnmarshaler)
 
 	// Respect OS stop signals.
 	c := make(chan os.Signal, 2)

migrations/20180103142000_initial_schema.sql

@@ -37,7 +37,6 @@ CREATE TABLE IF NOT EXISTS users (
     edge_count     INT           DEFAULT 0 CHECK (edge_count >= 0) NOT NULL,
     created_at     BIGINT        CHECK (created_at > 0) NOT NULL,
     updated_at     BIGINT        CHECK (updated_at > 0) NOT NULL,
-    verified_at    BIGINT        CHECK (verified_at >= 0) DEFAULT 0 NOT NULL,
     disabled_at    BIGINT        CHECK (disabled_at >= 0) DEFAULT 0 NOT NULL
 );