aboutsummaryrefslogtreecommitdiff
path: root/src/guff
diff options
context:
space:
mode:
Diffstat (limited to 'src/guff')
-rw-r--r--src/guff/api-handler.cr1
-rw-r--r--src/guff/api-methods.cr55
-rw-r--r--src/guff/post-model.cr76
3 files changed, 128 insertions, 4 deletions
diff --git a/src/guff/api-handler.cr b/src/guff/api-handler.cr
index 19b6aa5..370c8f6 100644
--- a/src/guff/api-handler.cr
+++ b/src/guff/api-handler.cr
@@ -89,6 +89,7 @@ module Guff
post: [
get_posts,
add_post,
+ update_post,
remove_posts,
set_tags,
],
diff --git a/src/guff/api-methods.cr b/src/guff/api-methods.cr
index 14c71c2..334be88 100644
--- a/src/guff/api-methods.cr
+++ b/src/guff/api-methods.cr
@@ -77,6 +77,41 @@ module Guff
},
},
+ "update_post": {
+ text: "Update existing post.",
+ args: {
+ "name": {
+ text: "Post title.",
+ type: :text,
+ required: false,
+ },
+
+ "slug": {
+ text: "Post slug.",
+ type: :slug,
+ required: false,
+ },
+
+ "body": {
+ text: "Post body.",
+ type: :text,
+ required: false,
+ },
+
+ "tags": {
+ text: "Post tags.",
+ type: :json,
+ required: false,
+ },
+
+ "posted": {
+ text: "Is this post posted?",
+ type: :bool,
+ required: false,
+ },
+ },
+ },
+
"remove_posts": {
text: "Remove existing posts.",
@@ -353,7 +388,7 @@ module Guff
site_id: get_site(context),
slug: args["slug"],
name: args["name"],
- body: args["name"],
+ body: args["body"],
tags: get_tags(args["tags"]?),
)
@@ -361,6 +396,24 @@ module Guff
{ post_id: post_id }.to_json
end
+ private def do_post_update_post(
+ context : HTTP::Server::Context,
+ args : Hash(String, String)
+ )
+ post_id = @models.post.update_post(
+ site_id: get_site(context),
+ post_id: args["post_id"].to_i,
+ slug: args["slug"]?,
+ name: args["name"],
+ body: args["body"],
+ tags: args.has_key?("tags") ? get_tags(args["tags"]?) : nil,
+ posted: args["posted"]?,
+ )
+
+ # return json
+ { ok: true }.to_json
+ end
+
private def do_post_remove_posts(
context : HTTP::Server::Context,
args : Hash(String, String)
diff --git a/src/guff/post-model.cr b/src/guff/post-model.cr
index 40e92fb..9200ccb 100644
--- a/src/guff/post-model.cr
+++ b/src/guff/post-model.cr
@@ -43,8 +43,15 @@ module Guff
LIMIT :limit OFFSET :offset
",
+ update_post: "
+ UPDATE posts
+ SET %{sets}
+ WHERE site_id = :site_id
+ AND post_id = :post_id
+ ",
+
add_post: "
- INSERT INTO posts(site_id, slug, name, raw_body, body)
+ INSERT INTO posts(site_id, slug, name, raw_body, body)
VALUES (:site_id, :slug, :name, :raw_body, :body)
",
@@ -273,6 +280,67 @@ module Guff
post_id
end
+ def update_post(
+ site_id = nil : Int?,
+ post_id = nil : Int?,
+ slug = nil : String?,
+ name = nil : String?,
+ body = nil : String?,
+ tags = nil : Array(String)?,
+ posted = nil : Bool?
+ )
+ raise "null post_id" if post_id.nil?
+
+ sets = [] of String
+ args = {
+ "site_id": (site_id || @models.site.get_default).to_s,
+ "post_id": post_id.to_s,
+ }
+
+ if slug
+ sets << "slug = :slug"
+ args["slug"] = slug
+ end
+
+ if name
+ sets << "name = :name"
+ args["name"] = name
+ end
+
+ if body
+ sets << "body = :body, raw_body = :body"
+ args["body"] = body
+ end
+
+ unless posted.nil?
+ val = posted ? "CURRENT_TIMESTAMP" : "NULL"
+ sets << "posted_at = %s" % [val]
+ end
+
+ if sets.size > 0 || tags
+ transaction do
+ if sets.size > 0
+ # update post
+ query(:update_post, args, {
+ "sets": sets.join(','),
+ })
+ end
+
+ # TODO: post history
+
+ if tags
+ # update tags
+ set_tags(
+ site_id: site_id,
+ post_id: post_id,
+ tags: tags,
+ use_transaction: false,
+ )
+ end
+ end
+ end
+ end
+
def remove_posts(
site_id = nil : Int?,
post_ids = [] of Int : Array(Int)
@@ -292,7 +360,7 @@ module Guff
def set_tags(
site_id = nil : Int?,
post_id = nil : Int?,
- tags = [] of String : Array(String),
+ tags = [] of String : Array(String)?,
use_transaction = true : Bool
)
if use_transaction
@@ -309,8 +377,10 @@ module Guff
private def raw_set_tags(
site_id = nil : Int?,
post_id = nil : Int?,
- tags = [] of String : Array(String),
+ tags = [] of String : Array(String)?,
)
+ return unless post_id && tags
+
# build sql args
args = {
"site_id": (site_id || @models.site.get_default).to_s,