try res.write(
\\<a href="/quotes/{x}">🔁 {}</a>
, .{ @intFromEnum(post.id), quotes_view.len() });
- try res.write(
- \\<br />
- , .{});
// Save to List
if (logged_in) |login| {
// Comment field
// TODO: maybe always show comment field and prompt for login
if (options.show_comment_field and logged_in != null) {
- try res.write("<br />", .{});
+ try res.write("<br /><br />", .{});
try html_form(res, "/comment", .{}, .{
.{ "type=\"hidden\" value=\"{x}\" name=\"post_id\"", .{@intFromEnum(post.id)} },
"type=\"text\" name=\"text\" placeholder=\"Text\"",
while (true) {
var newest_post: ?Post = null;
- var it = following.iterator();
- while (it.next()) |following_id| {
+ var following_it = following.iterator();
+ while (following_it.next()) |following_id| {
const followed_user = try users.get(following_id);
const followed_posts = try followed_user.posts.open(txn);
var followed_posts_it = followed_posts.reverse_iterator();
while (followed_posts_it.next()) |followed_post_id| {
- const last_post = try posts.get(followed_post_id);
+ const p = try posts.get(followed_post_id);
- if ((prev_newest_post == null or last_post.time < prev_newest_post.?.time) and (newest_post == null or newest_post.?.time < last_post.time)) {
- newest_post = last_post;
+ if ((prev_newest_post == null or p.time < prev_newest_post.?.time) and (newest_post == null or newest_post.?.time < p.time)) {
+ newest_post = p;
+ break;
}
}
}
user.name.constSlice(), user.display_name.constSlice(),
});
if (self.logged_in != null and user_id != self.logged_in.?.user.id) {
- if (try followers.has(self.logged_in.?.user.id)) {
+ const login = self.logged_in.?;
+
+ // follow/unfollow
+ if (try followers.has(login.user.id)) {
try html_form(self.res, "/follow", .{}, .{
.{ "type=\"hidden\" name=\"user_id\" value=\"{x}\"", .{@intFromEnum(user_id)} },
\\type="submit" value="Unfollow"
\\type="submit" value="Follow"
});
}
+
+ // add to feed
+ const feeds_view = try login.user.feeds.open(self.txn);
+ try self.res.write("<form action=\"/feed_add\" method=\"post\">", .{});
+ try self.res.write("<select name=\"feed_id\">", .{});
+ var it = feeds_view.iterator();
+ while (it.next()) |kv| {
+ const name = kv.val.name;
+ const id = kv.val.list.idx.?;
+ try self.res.write("<option value=\"{x}\">{s}</option>", .{ id, name.constSlice() });
+ }
+ try self.res.write("</select>", .{});
+ try self.res.write("<input type=\"hidden\" name=\"user_id\" value=\"{x}\"></input>", .{@intFromEnum(user_id)});
+ try self.res.write("<input type=\"submit\" value=\"Add to feed\"></input>", .{});
+ try self.res.write("</form>", .{});
}
try self.res.write(
\\ <a href="/following/{s}">{} following</a>
const referer = if (self.req.get_header("Referer")) |ref| ref else self.req.target;
- try html_form(self.res, "/quote", .{}, .{
- .{ "type=\"hidden\" name=\"referer\" value=\"{s}\"", .{referer} },
- .{ "type=\"hidden\" name=\"post_id\" value=\"{x}\"", .{@intFromEnum(post.id)} },
- "type=\"text\" name=\"text\" placeholder=\"Text\"",
- "type=\"submit\" value=\"Quote\"",
- });
- try self.res.write("<br />", .{});
+ if (self.logged_in != null) {
+ try html_form(self.res, "/quote", .{}, .{
+ .{ "type=\"hidden\" name=\"referer\" value=\"{s}\"", .{referer} },
+ .{ "type=\"hidden\" name=\"post_id\" value=\"{x}\"", .{@intFromEnum(post.id)} },
+ "type=\"text\" name=\"text\" placeholder=\"Text\"",
+ "type=\"submit\" value=\"Quote\"",
+ });
+ try self.res.write("<br />", .{});
+ }
const quotes_view = try post.quotes.open(self.txn);
var it = quotes_view.iterator();
try self.res.write("<br />", .{});
}
}
- pub fn @"/list/"(self: Self, args: struct { list_id: PostListList.Index }) !void {
+ pub fn @"/list/"(self: Self, args: struct { list_id: PostList.Index }) !void {
try write_posts(self.res, self.txn, self.logged_in, PostList{ .idx = args.list_id });
}
pub fn @"/lists"(self: Self) !void {
try self.res.write("not logged in", .{});
}
}
+ pub fn @"/feed/"(self: Self, args: struct { feed_id: UserList.Index }) !void {
+ try write_timeline(self.res, self.txn, self.logged_in, UserList{ .idx = args.feed_id });
+ }
+ pub fn @"/feeds"(self: Self) !void {
+ if (self.logged_in) |login| {
+ const feeds_view = try login.user.feeds.open(self.txn);
+
+ try html_form(self.res, "/new_feed", .{}, .{
+ "type=\"text\" name=\"name\"",
+ "type=\"submit\" value=\"Add\"",
+ });
+
+ try self.res.write("<br /><br />", .{});
+
+ var it = feeds_view.iterator();
+ while (it.next()) |kv| {
+ const name = kv.val.name;
+ const user_list = kv.val.list;
+ try self.res.write(
+ \\<a href="/feed/{x}">{s}</a><br />
+ , .{ user_list.idx.?, name.constSlice() });
+ }
+ } else {
+ try self.res.write("not logged in", .{});
+ }
+ }
pub fn @"/post"(self: Self) !void {
if (self.logged_in) |login| {
_ = login;
}
}
}
+ // TODO: add arguments instead of parsing manually
pub fn @"/new_list"(self: Self) !void {
if (self.logged_in) |login| {
const name_str = self.req.get_value("name") orelse return error.NoName;
const name = try Name.fromSlice(name_str);
+ // TODO: decode name
var txn = try self.env.txn();
const post_list = PostList{ .idx = list_id };
var post_list_view = try post_list.open(txn);
- std.debug.print("adding {x} to {x}\n", .{ post_id, list_id });
if (try post_list_view.has(post_id)) {
try post_list_view.del(post_id);
} else {
}
}
}
+ pub fn @"/new_feed"(self: Self) !void {
+ if (self.logged_in) |login| {
+ const name_str = self.req.get_value("name") orelse return error.NoName;
+ const name = try Name.fromSlice(name_str);
+
+ var txn = try self.env.txn();
+
+ const userlist = try UserList.init(txn);
+ try txn.commit();
+
+ txn = try self.env.txn();
+ var feeds_view = try login.user.feeds.open(txn);
+ _ = try feeds_view.append(.{ .name = name, .list = userlist });
+ try txn.commit();
+ }
+ }
+ pub fn @"/feed_add"(self: Self) !void {
+ if (self.logged_in) |login| {
+ _ = login;
+
+ const list_id_str = self.req.get_value("feed_id") orelse return error.NoListId;
+ const user_id_str = self.req.get_value("user_id") orelse return error.NoUserId;
+ const list_id = try std.fmt.parseUnsigned(UserList.Index, list_id_str, 16);
+ const user_id = try parse_enum(UserId, user_id_str, 16);
+
+ const txn = try self.env.txn();
+ defer txn.commit() catch {};
+
+ const user_list = UserList{ .idx = list_id };
+ var user_list_view = try user_list.open(txn);
+ if (try user_list_view.has(user_id)) {
+ try user_list_view.del(user_id);
+ } else {
+ try user_list_view.append(user_id);
+ }
+ }
+ }
pub fn @"/upvote"(self: Self) !void {
const login = self.logged_in orelse return error.NotLoggedIn;
while (try server.next_request(&req_buffer)) |*_req| {
var req: *http.Request = @constCast(_req);
// std.debug.print("[{}]: {s}\n", .{ req.method, req.target });
+ // std.debug.print("[{}]: {s}\n", .{ req.method, req.head.? });
// reponse
var res = http.Response.init(req.fd, &res_head_buffer, &res_body_buffer);
projects / chirp / blobdiff