From 8040825daac4a5ba24e947c4c657d169d7763543 Mon Sep 17 00:00:00 2001
From: KushBlazingJudah <59340248+KushBlazingJudah@users.noreply.github.com>
Date: Sat, 30 Oct 2021 00:28:51 -0300
Subject: restructuring, part 3 of many

---
 db/local.go | 42 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 db/local.go

(limited to 'db/local.go')

diff --git a/db/local.go b/db/local.go
new file mode 100644
index 0000000..7cb46d1
--- /dev/null
+++ b/db/local.go
@@ -0,0 +1,42 @@
+package db
+
+func IsIDLocal(id string) (bool, error) {
+	activity, err := GetActivityFromDB(id)
+	return len(activity.OrderedItems) > 0, err
+}
+
+func IsActorLocal(id string) (bool, error) {
+	actor, err := GetActorFromDB(id)
+	return actor.Id != "", err
+}
+
+func IsObjectLocal(id string) (bool, error) {
+	query := `select id from activitystream where id=$1`
+
+	rows, err := db.Query(query, id)
+	if err != nil {
+		return false, err
+	}
+
+	var nID string
+	defer rows.Close()
+
+	rows.Next()
+	err = rows.Scan(&nID)
+	return nID != "", err
+}
+
+func IsObjectCached(id string) (bool, error) {
+	query := `select id from cacheactivitystream where id=$1`
+	rows, err := db.Query(query, id)
+	if err != nil {
+		return false, err
+	}
+
+	var nID string
+	defer rows.Close()
+
+	rows.Next()
+	err = rows.Scan(&nID)
+	return nID != "", err
+}
-- 
cgit v1.2.3