src/Room.c

@@ -23,12 +23,12 @@
  * SOFTWARE.
  */
 
-#include <Cytoplasm/HashMap.h>
 #include <Cytoplasm/Array.h>
 #include <Cytoplasm/Json.h>
-#include <Parser.h>
-#include <Config.h>
-#include <User.h>
+/*#include "Cytoplasm/Stream.h"*/
+#include "Cytoplasm/HashMap.h"
+#include "Parser.h"
+#include "User.h"
 #include <Room.h>
 
 #include <Cytoplasm/Memory.h>
@@ -87,7 +87,6 @@ RoomPopulate(Room *room, User *user, RoomCreateRequest *req, ServerPart s)
     HashMap *content, *event, *override, *pl_content;
     Array *initial_states;
     JsonValue *val;
-    int64_t pl = 100;
     size_t i;
 
     char *join_rules_preset = NULL;
@@ -138,7 +137,7 @@ RoomPopulate(Room *room, User *user, RoomCreateRequest *req, ServerPart s)
     content = HashMapCreate();
     JsonSet(
             content,
-            JsonValueInteger(pl), 
+            JsonValueInteger(100), 
             2, "users", sender_str);
     override = req->power_level_content_override;
     while (override && HashMapIterate(override, &key, (void **) &val))
@@ -151,6 +150,7 @@ RoomPopulate(Room *room, User *user, RoomCreateRequest *req, ServerPart s)
         }
         HashMapSet(content, key, JsonValueDuplicate(val));
     }
+    pl_content = JsonDuplicate(content);
     event = RoomEventCreate(sender_str, "m.room.power_levels", "", content);
     JsonFree(RoomEventSend(room, event));
     JsonFree(event);
@@ -273,8 +273,6 @@ RoomPopulate(Room *room, User *user, RoomCreateRequest *req, ServerPart s)
         Free(serverStr);
     }
     /* Invites */
-    pl_content = HashMapCreate();
-    JsonSet(pl_content, JsonValueInteger(pl), 2, "users", sender_str);
     for (i = 0; i < ArraySize(req->invite); i++)
     {
         char *user_id = ArrayGet(req->invite, i);
@@ -285,25 +283,33 @@ RoomPopulate(Room *room, User *user, RoomCreateRequest *req, ServerPart s)
             break;
         }
 
-        RoomSendInvite(user, req->is_direct, user_id, room);
+        content = HashMapCreate();
+        if (req->is_direct)
+        {
+            JsonSet(content, JsonValueBoolean(true), 1, "is_direct");
+        }
+        JsonSet(content, JsonValueString("invite"), 1, "membership");
+        event = RoomEventCreate(sender_str, "m.room.member", user_id, content);
+        JsonFree(RoomEventSend(room, event));
+        JsonFree(event);
         
         if (trusted_room)
         {
-            JsonValue *own = JsonValueInteger(pl);
-            JsonSet(pl_content, own, 2, "users", user_id);
+            JsonValue *own = JsonGet(pl_content, 2, "users", sender_str);
+            JsonValueFree(JsonSet(
+                pl_content, JsonValueDuplicate(own),
+                2, "users", user_id));
         }
         
     }
+    JsonValueFree(JsonSet(
+        DbJson(room->leaves_ref), 
+        JsonValueBoolean(req->is_direct), 1, "is_direct"));
 
     event = RoomEventCreate(sender_str, "m.room.power_levels", "", pl_content);
     JsonFree(RoomEventSend(room, event));
     JsonFree(event);
 
-    JsonValueFree(JsonSet(
-        DbJson(room->leaves_ref), 
-        JsonValueBoolean(req->is_direct), 1, "is_direct"));
-    /* TODO: The rest of the events mandated by the specification on 
-     * POST /createRoom, and error management. */
     Free(sender_str);
 
     /* TODO: Error management (and invite_3pid, later) */
@@ -1287,8 +1293,8 @@ AuthorisePowerLevelsV1(Room * room, PduV1 pdu, HashMap *state)
          \
         new = JsonGet(pdu.content, 2, prop, ev_type); \
         old_pl = ParsePL(new, INT64_MAX); \
-        if (((new_pl = ParsePL(new, INT64_MAX)) != INT64_MAX) &&  \
-            ((new_pl != old_pl) && old_pl > userpl)) \
+        if (((new_pl = ParsePL(new, INT64_MAX)) == INT64_MAX ||  \
+            new_pl != old_pl) && old_pl > userpl) \
         { \
             flag = false; \
         } \
@@ -1296,6 +1302,7 @@ AuthorisePowerLevelsV1(Room * room, PduV1 pdu, HashMap *state)
     if (!flag) \
     { \
         JsonFree(prev_plevent); \
+        StateFree(state); \
         return false; \
     } \
     flag = true
@@ -1315,7 +1322,7 @@ AuthorisePowerLevelsV1(Room * room, PduV1 pdu, HashMap *state)
          \
         old = JsonGet(prev_plevent, 3, "content", prop, ev_type); \
         new_pl = ParsePL(ev_obj, INT64_MAX); \
-        if (((old_pl = ParsePL(old, INT64_MAX)) != INT64_MAX &&  \
+        if (((old_pl = ParsePL(old, INT64_MAX)) == INT64_MAX ||  \
             new_pl != old_pl) && new_pl > userpl) \
         { \
             flag = false; \
@@ -1324,6 +1331,7 @@ AuthorisePowerLevelsV1(Room * room, PduV1 pdu, HashMap *state)
     if (!flag) \
     { \
         JsonFree(prev_plevent); \
+        StateFree(state); \
         return false; \
     } \
     flag = true
@@ -1637,7 +1645,7 @@ RoomEventSendV1(Room * room, HashMap * event)
 finish:
     if (state)
     {
-        StateFree(state);
+        JsonFree(state);
     }
     if (pdu_object)
     {
@@ -1997,29 +2005,3 @@ RoomFreeReverse(Array *arr)
     }
     ArrayFree(arr);
 }
-void
-RoomSendInvite(User *sender, bool direct, char *user, Room *room)
-{
-    HashMap *content, *event;
-    CommonID *senderID;
-    char *senderStr;
-    Config conf;
-    if (!sender || !user || !room)
-    {
-        return;
-    }
-    ConfigLock(room->db, &conf);
-    senderID = UserIdParse(UserGetName(sender), conf.serverName);
-    senderStr = ParserRecomposeCommonID(*senderID);
-    UserIdFree(senderID);
-
-    content = HashMapCreate();
-    JsonSet(content, JsonValueBoolean(direct), 1, "is_direct");
-    JsonSet(content, JsonValueString("invite"), 1, "membership");
-    event = RoomEventCreate(senderStr, "m.room.member", user, content);
-    JsonFree(RoomEventSend(room, event));
-    JsonFree(event);
-
-    ConfigUnlock(&conf);
-    Free(senderStr);
-}

src/include/Room.h

@@ -138,12 +138,6 @@ extern int RoomPrevEventsSet(Room *, Array *);
  */
 extern HashMap * RoomEventSend(Room *, HashMap *);
 
-/** 
- * Sends an invite to a user in a room, and tries 
- * to notify such user of it.
- */
-extern void RoomSendInvite(User *, bool, char *, Room *);
-
 /** 
  * Fetch a single event's PDU in a room into an 
  * hashmap, given an event ID, from the database