5 files changed, 143 insertions, 0 deletions
diff --git a/src/db/rest/follow/api_follow.sql b/src/db/rest/follow/api_follow.sql
new file mode 100644
index 0000000..c0a07e5
--- /dev/null
+++ b/src/db/rest/follow/api_follow.sql
@@ -0,0 +1,15 @@
+CREATE VIEW api.follow AS
+	SELECT
+		f.id,
+		f.follower_id,
+		f.followee_id,
+		f.value,
+		f.created,
+		f.modified
+	FROM
+		admin.follow f;
+
+GRANT SELECT ON TABLE api.follow
+	TO rest_anon, rest_user;
+GRANT SELECT ON TABLE admin.follow
+	TO rest_anon, rest_user;
diff --git a/src/db/rest/follow/api_follow_delete.sql b/src/db/rest/follow/api_follow_delete.sql
new file mode 100644
index 0000000..46454cf
--- /dev/null
+++ b/src/db/rest/follow/api_follow_delete.sql
@@ -0,0 +1,32 @@
+CREATE FUNCTION _api.follow_delete()
+RETURNS TRIGGER
+LANGUAGE plpgsql VOLATILE
+AS $BODY$
+DECLARE
+	_user_id INTEGER;
+BEGIN
+	_user_id = _api.get_user_id();
+
+	IF OLD.follower_id <> _user_id THEN
+		PERFORM _api.raise_deny();
+	END IF;
+
+	UPDATE admin.follow SET
+		value = FALSE,
+		modified = clock_timestamp()
+		WHERE id = OLD.id;
+END
+$BODY$;
+
+GRANT EXECUTE ON FUNCTION _api.follow_delete()
+	TO rest_user;
+GRANT DELETE ON TABLE api.follow
+	TO rest_user;
+GRANT UPDATE ON TABLE admin.follow
+	TO rest_user;
+
+CREATE TRIGGER api_follow_delete_trgr
+	INSTEAD OF DELETE
+			ON api.follow
+			FOR EACH ROW
+				EXECUTE PROCEDURE _api.follow_delete();
diff --git a/src/db/rest/follow/api_follow_insert.sql b/src/db/rest/follow/api_follow_insert.sql
new file mode 100644
index 0000000..6351855
--- /dev/null
+++ b/src/db/rest/follow/api_follow_insert.sql
@@ -0,0 +1,46 @@
+CREATE FUNCTION _api.follow_insert()
+RETURNS TRIGGER
+LANGUAGE plpgsql VOLATILE
+AS $BODY$
+DECLARE
+	_user_id INTEGER;
+BEGIN
+	_user_id = _api.get_user_id();
+
+	IF NEW.followee_id IS NULL THEN
+		-- for now
+		PERFORM _api.raise_deny();
+	END IF;
+
+	NEW.value := COALESCE(NEW.value, TRUE);
+
+	INSERT INTO admin.follow (
+		follower_id,
+		followee_id,
+		value
+	) VALUES (
+		_user_id,
+		NEW.followee_id,
+		NEW.value
+	)
+	RETURNING id
+	INTO NEW.id;
+
+	RETURN NEW;
+END
+$BODY$;
+
+GRANT EXECUTE ON FUNCTION _api.follow_insert()
+	TO rest_user;
+GRANT INSERT ON TABLE api.follow
+	TO rest_user;
+GRANT INSERT ON TABLE admin.follow
+	TO rest_user;
+GRANT UPDATE ON TABLE sys.follow_id_seq
+	TO rest_user;
+
+CREATE TRIGGER api_follow_insert_trgr
+	INSTEAD OF INSERT
+			ON api.follow
+			FOR EACH ROW
+				EXECUTE PROCEDURE _api.follow_insert();
diff --git a/src/db/rest/follow/api_follow_update.sql b/src/db/rest/follow/api_follow_update.sql
new file mode 100644
index 0000000..2164829
--- /dev/null
+++ b/src/db/rest/follow/api_follow_update.sql
@@ -0,0 +1,44 @@
+CREATE FUNCTION _api.follow_update()
+RETURNS TRIGGER
+LANGUAGE plpgsql VOLATILE
+AS $BODY$
+DECLARE
+	_user_id INTEGER;
+	_changed BOOLEAN;
+BEGIN
+	_user_id = _api.get_user_id();
+	_changed = FALSE;
+
+	IF OLD.follower_id <> _user_id THEN
+		PERFORM _api.raise_deny();
+	END IF;
+
+	NEW.value = COALESCE(NEW.value, OLD.value);
+
+	IF NEW.value IS DISTINCT FROM OLD.value THEN
+		_changed = TRUE;
+	END IF;
+
+	IF _changed THEN
+		UPDATE admin.follow SET
+			value = NEW.value,
+			modified = clock_timestamp()
+			WHERE id = OLD.id;
+	END IF;
+
+	RETURN NEW;
+END
+$BODY$;
+
+GRANT EXECUTE ON FUNCTION _api.follow_update()
+	TO rest_user;
+GRANT UPDATE ON TABLE api.follow
+	TO rest_user;
+GRANT UPDATE ON TABLE admin.follow
+	TO rest_user;
+
+CREATE TRIGGER api_follow_update_trgr
+	INSTEAD OF UPDATE
+			ON api.follow
+			FOR EACH ROW
+				EXECUTE PROCEDURE _api.follow_update();
diff --git a/src/db/rest/rest.sql b/src/db/rest/rest.sql
index 783866a..3db77a2 100644
--- a/src/db/rest/rest.sql
+++ b/src/db/rest/rest.sql
@@ -45,6 +45,12 @@ GRANT USAGE ON SCHEMA _api TO rest_anon, rest_user;
 \i /db/rest/like/api_like_update.sql;
 \i /db/rest/like/api_like_delete.sql;
 
+-- follow
+\i /db/rest/follow/api_follow.sql;
+\i /db/rest/follow/api_follow_insert.sql;
+\i /db/rest/follow/api_follow_update.sql;
+\i /db/rest/follow/api_follow_delete.sql;
+
 -- media
 \i /db/rest/media/_api_serve_user_media.sql;
 \i /db/rest/media/_api_serve_system_media.sql;