diff --git a/app/lib/express.js b/app/lib/express.js
index 0cef611..0a4f237 100644
--- a/app/lib/express.js
+++ b/app/lib/express.js
@@ -50,14 +50,18 @@ router.get("/", async (_req, res) => {
   }
 
   const [posts, friends] = await Promise.all([
-    queries.getPosts(ssbServer),
+    queries.getPosts(ssbServer, profile.id),
     queries.getFriends(profile, ssbServer),
   ]);
   res.render("index", { profile, posts, friends });
 });
 
 router.post("/publish", async (req, res) => {
-  await promisify(ssbServer.publish, { type: "post", text: req.body.message });
+  await promisify(ssbServer.publish, {
+    type: "post",
+    text: req.body.message,
+    wall: profile.id,
+  });
 
   res.redirect("/");
 });
diff --git a/app/lib/queries.js b/app/lib/queries.js
index 19b8242..bf82e0b 100644
--- a/app/lib/queries.js
+++ b/app/lib/queries.js
@@ -66,7 +66,7 @@ const mapAuthorName = (ssbServer) => (data, callback) => {
     .catch((err) => callback(err, null));
 };
 
-const getPosts = (ssbServer) =>
+const getPosts = (ssbServer, userId) =>
   new Promise((resolve, reject) => {
     pull(
       ssbServer.query.read({
@@ -75,12 +75,12 @@ const getPosts = (ssbServer) =>
           {
             $filter: {
               value: {
-                content: { type: "post" },
+                content: { type: "post", wall: userId },
               },
             },
           },
         ],
-        limit: 500,
+        limit: 100,
       }),
       pull.asyncMap(mapAuthorName(ssbServer)),
       pull.collect((err, msgs) => {