diff --git a/.sqlx/query-039d134f0d1b681b55b1394a710b44a630eb066846c777c462b8c9341e26b696.json b/.sqlx/query-039d134f0d1b681b55b1394a710b44a630eb066846c777c462b8c9341e26b696.json
new file mode 100644
index 0000000..f91446a
--- /dev/null
+++ b/.sqlx/query-039d134f0d1b681b55b1394a710b44a630eb066846c777c462b8c9341e26b696.json
@@ -0,0 +1,38 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n                INSERT INTO datastore.objects (\n                    owner, size, name, data_type, meta_binary,\n                    permission, permission_recipients,\n                    delete_permission, delete_permission_recipients,\n                    flag, period, refer_data_id, tags,\n                    persistence_slot_id, extra_data, creation_date, update_date\n                ) VALUES (\n                    $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17\n                ) RETURNING data_id\n                ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "data_id",
+        "type_info": "Int8"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int4",
+        "Int4",
+        "Text",
+        "Int4",
+        "Bytea",
+        "Int4",
+        "Int4Array",
+        "Int4",
+        "Int4Array",
+        "Int4",
+        "Int4",
+        "Int8",
+        "TextArray",
+        "Int4",
+        "TextArray",
+        "Timestamp",
+        "Timestamp"
+      ]
+    },
+    "nullable": [
+      false
+    ]
+  },
+  "hash": "039d134f0d1b681b55b1394a710b44a630eb066846c777c462b8c9341e26b696"
+}
diff --git a/.sqlx/query-164708b549c483a041d2e54065ed3ffbd9f8d5304f6aa6d785dbddbb1626c0e9.json b/.sqlx/query-164708b549c483a041d2e54065ed3ffbd9f8d5304f6aa6d785dbddbb1626c0e9.json
new file mode 100644
index 0000000..abf5c03
--- /dev/null
+++ b/.sqlx/query-164708b549c483a041d2e54065ed3ffbd9f8d5304f6aa6d785dbddbb1626c0e9.json
@@ -0,0 +1,28 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT owner, under_review FROM datastore.objects WHERE data_id = $1",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "owner",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 1,
+        "name": "under_review",
+        "type_info": "Bool"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      true,
+      false
+    ]
+  },
+  "hash": "164708b549c483a041d2e54065ed3ffbd9f8d5304f6aa6d785dbddbb1626c0e9"
+}
diff --git a/.sqlx/query-18fb671d9d97353420446413b74077f9b06ffe11cab2693e4e365c265f8e2418.json b/.sqlx/query-18fb671d9d97353420446413b74077f9b06ffe11cab2693e4e365c265f8e2418.json
new file mode 100644
index 0000000..7471873
--- /dev/null
+++ b/.sqlx/query-18fb671d9d97353420446413b74077f9b06ffe11cab2693e4e365c265f8e2418.json
@@ -0,0 +1,125 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT data_id, owner, size, name, data_type, meta_binary,\n                  permission, permission_recipients, delete_permission, delete_permission_recipients,\n                  period, refer_data_id, flag, tags, creation_date, update_date,\n                  access_password, under_review\n           FROM datastore.objects\n           WHERE owner = $1 AND persistence_slot_id = $2\n           AND upload_completed = TRUE AND deleted = FALSE",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 1,
+        "name": "owner",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 2,
+        "name": "size",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 3,
+        "name": "name",
+        "type_info": "Text"
+      },
+      {
+        "ordinal": 4,
+        "name": "data_type",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 5,
+        "name": "meta_binary",
+        "type_info": "Bytea"
+      },
+      {
+        "ordinal": 6,
+        "name": "permission",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 7,
+        "name": "permission_recipients",
+        "type_info": "Int4Array"
+      },
+      {
+        "ordinal": 8,
+        "name": "delete_permission",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 9,
+        "name": "delete_permission_recipients",
+        "type_info": "Int4Array"
+      },
+      {
+        "ordinal": 10,
+        "name": "period",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 11,
+        "name": "refer_data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 12,
+        "name": "flag",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 13,
+        "name": "tags",
+        "type_info": "TextArray"
+      },
+      {
+        "ordinal": 14,
+        "name": "creation_date",
+        "type_info": "Timestamp"
+      },
+      {
+        "ordinal": 15,
+        "name": "update_date",
+        "type_info": "Timestamp"
+      },
+      {
+        "ordinal": 16,
+        "name": "access_password",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 17,
+        "name": "under_review",
+        "type_info": "Bool"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int4",
+        "Int4"
+      ]
+    },
+    "nullable": [
+      false,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      false,
+      false
+    ]
+  },
+  "hash": "18fb671d9d97353420446413b74077f9b06ffe11cab2693e4e365c265f8e2418"
+}
diff --git a/.sqlx/query-29e18f241dc860dca12c03cabb788d2d26f7644e85bfd65423e6e32c469e3695.json b/.sqlx/query-29e18f241dc860dca12c03cabb788d2d26f7644e85bfd65423e6e32c469e3695.json
new file mode 100644
index 0000000..5411a38
--- /dev/null
+++ b/.sqlx/query-29e18f241dc860dca12c03cabb788d2d26f7644e85bfd65423e6e32c469e3695.json
@@ -0,0 +1,16 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n                    INSERT INTO datastore.object_custom_rankings (data_id, application_id, value)\n                    VALUES ($1, $2, $3)\n                    ON CONFLICT (data_id, application_id)\n                    DO UPDATE SET value = datastore.object_custom_rankings.value + EXCLUDED.value\n                    ",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Int8",
+        "Int8",
+        "Int8"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "29e18f241dc860dca12c03cabb788d2d26f7644e85bfd65423e6e32c469e3695"
+}
diff --git a/.sqlx/query-2ff34379bbc32276c3b78ef1283b8158ea907d36588e1e59f6cbe752d89361bb.json b/.sqlx/query-2ff34379bbc32276c3b78ef1283b8158ea907d36588e1e59f6cbe752d89361bb.json
new file mode 100644
index 0000000..83246ca
--- /dev/null
+++ b/.sqlx/query-2ff34379bbc32276c3b78ef1283b8158ea907d36588e1e59f6cbe752d89361bb.json
@@ -0,0 +1,22 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT EXISTS(SELECT 1 FROM datastore.objects WHERE data_id = $1)",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "exists",
+        "type_info": "Bool"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      null
+    ]
+  },
+  "hash": "2ff34379bbc32276c3b78ef1283b8158ea907d36588e1e59f6cbe752d89361bb"
+}
diff --git a/.sqlx/query-48d94383f1a261f19060f5c75d9f7803ee88233c53efaa2df9966a6c72c8c763.json b/.sqlx/query-48d94383f1a261f19060f5c75d9f7803ee88233c53efaa2df9966a6c72c8c763.json
new file mode 100644
index 0000000..7a1cc6f
--- /dev/null
+++ b/.sqlx/query-48d94383f1a261f19060f5c75d9f7803ee88233c53efaa2df9966a6c72c8c763.json
@@ -0,0 +1,23 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT buffer\n        FROM datastore.buffer_queues\n        WHERE data_id = $1 AND slot = $2\n        ORDER BY creation_date ASC\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "buffer",
+        "type_info": "Bytea"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8",
+        "Int4"
+      ]
+    },
+    "nullable": [
+      false
+    ]
+  },
+  "hash": "48d94383f1a261f19060f5c75d9f7803ee88233c53efaa2df9966a6c72c8c763"
+}
diff --git a/.sqlx/query-60d8ebcf914d887439096df400fa4beaf37e879c28c81c22abeddb3d030535df.json b/.sqlx/query-60d8ebcf914d887439096df400fa4beaf37e879c28c81c22abeddb3d030535df.json
new file mode 100644
index 0000000..4f07b49
--- /dev/null
+++ b/.sqlx/query-60d8ebcf914d887439096df400fa4beaf37e879c28c81c22abeddb3d030535df.json
@@ -0,0 +1,28 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT under_review, access_password\n        FROM datastore.objects\n        WHERE data_id = $1 AND upload_completed = TRUE AND deleted = FALSE\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "under_review",
+        "type_info": "Bool"
+      },
+      {
+        "ordinal": 1,
+        "name": "access_password",
+        "type_info": "Int8"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      false,
+      false
+    ]
+  },
+  "hash": "60d8ebcf914d887439096df400fa4beaf37e879c28c81c22abeddb3d030535df"
+}
diff --git a/.sqlx/query-8909f81fbf26a9b559d26e138568be8946430d93821dbccb6dc9324ef0544c17.json b/.sqlx/query-8909f81fbf26a9b559d26e138568be8946430d93821dbccb6dc9324ef0544c17.json
new file mode 100644
index 0000000..867701f
--- /dev/null
+++ b/.sqlx/query-8909f81fbf26a9b559d26e138568be8946430d93821dbccb6dc9324ef0544c17.json
@@ -0,0 +1,29 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT\n            rankings.data_id,\n            rankings.value\n        FROM datastore.object_custom_rankings rankings\n        JOIN UNNEST($1::bigint[]) WITH ORDINALITY AS rows(data_id, ord)\n            ON rankings.data_id = rows.data_id\n            AND rankings.application_id = $2\n        ORDER BY rows.ord\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 1,
+        "name": "value",
+        "type_info": "Int8"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8Array",
+        "Int8"
+      ]
+    },
+    "nullable": [
+      false,
+      true
+    ]
+  },
+  "hash": "8909f81fbf26a9b559d26e138568be8946430d93821dbccb6dc9324ef0544c17"
+}
diff --git a/.sqlx/query-a5e86d7e66d0e16e5f35df883e11d9f4ef96adbdab7ca7d008acf596af91fc2b.json b/.sqlx/query-a5e86d7e66d0e16e5f35df883e11d9f4ef96adbdab7ca7d008acf596af91fc2b.json
new file mode 100644
index 0000000..539fdeb
--- /dev/null
+++ b/.sqlx/query-a5e86d7e66d0e16e5f35df883e11d9f4ef96adbdab7ca7d008acf596af91fc2b.json
@@ -0,0 +1,112 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT data_id, owner, size, name, data_type, meta_binary,\n                  permission, permission_recipients, delete_permission, delete_permission_recipients,\n                  period, refer_data_id, flag, tags, creation_date, update_date\n           FROM datastore.objects WHERE data_id = $1",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 1,
+        "name": "owner",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 2,
+        "name": "size",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 3,
+        "name": "name",
+        "type_info": "Text"
+      },
+      {
+        "ordinal": 4,
+        "name": "data_type",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 5,
+        "name": "meta_binary",
+        "type_info": "Bytea"
+      },
+      {
+        "ordinal": 6,
+        "name": "permission",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 7,
+        "name": "permission_recipients",
+        "type_info": "Int4Array"
+      },
+      {
+        "ordinal": 8,
+        "name": "delete_permission",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 9,
+        "name": "delete_permission_recipients",
+        "type_info": "Int4Array"
+      },
+      {
+        "ordinal": 10,
+        "name": "period",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 11,
+        "name": "refer_data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 12,
+        "name": "flag",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 13,
+        "name": "tags",
+        "type_info": "TextArray"
+      },
+      {
+        "ordinal": 14,
+        "name": "creation_date",
+        "type_info": "Timestamp"
+      },
+      {
+        "ordinal": 15,
+        "name": "update_date",
+        "type_info": "Timestamp"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      false,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true
+    ]
+  },
+  "hash": "a5e86d7e66d0e16e5f35df883e11d9f4ef96adbdab7ca7d008acf596af91fc2b"
+}
diff --git a/.sqlx/query-c2a0ca72fdcb060a7fb1c670b25e1efdbf3cef31e4b6cea4adbd51ee0218f5aa.json b/.sqlx/query-c2a0ca72fdcb060a7fb1c670b25e1efdbf3cef31e4b6cea4adbd51ee0218f5aa.json
new file mode 100644
index 0000000..095ca6f
--- /dev/null
+++ b/.sqlx/query-c2a0ca72fdcb060a7fb1c670b25e1efdbf3cef31e4b6cea4adbd51ee0218f5aa.json
@@ -0,0 +1,40 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT slot, total_value, count, initial_value\n        FROM datastore.object_ratings\n        WHERE data_id = $1\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "slot",
+        "type_info": "Int2"
+      },
+      {
+        "ordinal": 1,
+        "name": "total_value",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 2,
+        "name": "count",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 3,
+        "name": "initial_value",
+        "type_info": "Int8"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      false,
+      true,
+      false,
+      true
+    ]
+  },
+  "hash": "c2a0ca72fdcb060a7fb1c670b25e1efdbf3cef31e4b6cea4adbd51ee0218f5aa"
+}
diff --git a/.sqlx/query-e28d8776cc49b55fe76cf33ac12fe18e500d243f1b55fd18e7d96d281605bcf9.json b/.sqlx/query-e28d8776cc49b55fe76cf33ac12fe18e500d243f1b55fd18e7d96d281605bcf9.json
new file mode 100644
index 0000000..552f92a
--- /dev/null
+++ b/.sqlx/query-e28d8776cc49b55fe76cf33ac12fe18e500d243f1b55fd18e7d96d281605bcf9.json
@@ -0,0 +1,14 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "UPDATE datastore.objects SET upload_completed = true WHERE data_id = $1",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "e28d8776cc49b55fe76cf33ac12fe18e500d243f1b55fd18e7d96d281605bcf9"
+}
diff --git a/build-edition.sh b/build-edition.sh
index ede64d3..d2c0750 100755
--- a/build-edition.sh
+++ b/build-edition.sh
@@ -11,4 +11,5 @@ echo ENV SETTINGS:
 env
 
 #OPENSSL_LIB_DIR=/usr/lib OPENSSL_INCLUDE_DIR=/usr/include/openssl OPENSSL_STATIC=1 RUSTFLAGS="-C relocation-model=static -C linker=ld.lld" cargo build --release --features "$EDITION_FEATURES" --target x86_64-unknown-linux-musl
+OPENSSL_LIB_DIR=/usr/lib OPENSSL_INCLUDE_DIR=/usr/include/openssl OPENSSL_STATIC=1 cargo sqlx prepare --workspace -- --features "$EDITION_FEATURES"
 OPENSSL_LIB_DIR=/usr/lib OPENSSL_INCLUDE_DIR=/usr/include/openssl OPENSSL_STATIC=1 cargo build --release --features "$EDITION_FEATURES"
diff --git a/rnex-core/.sqlx/query-164708b549c483a041d2e54065ed3ffbd9f8d5304f6aa6d785dbddbb1626c0e9.json b/rnex-core/.sqlx/query-164708b549c483a041d2e54065ed3ffbd9f8d5304f6aa6d785dbddbb1626c0e9.json
new file mode 100644
index 0000000..abf5c03
--- /dev/null
+++ b/rnex-core/.sqlx/query-164708b549c483a041d2e54065ed3ffbd9f8d5304f6aa6d785dbddbb1626c0e9.json
@@ -0,0 +1,28 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT owner, under_review FROM datastore.objects WHERE data_id = $1",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "owner",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 1,
+        "name": "under_review",
+        "type_info": "Bool"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      true,
+      false
+    ]
+  },
+  "hash": "164708b549c483a041d2e54065ed3ffbd9f8d5304f6aa6d785dbddbb1626c0e9"
+}
diff --git a/rnex-core/.sqlx/query-18fb671d9d97353420446413b74077f9b06ffe11cab2693e4e365c265f8e2418.json b/rnex-core/.sqlx/query-18fb671d9d97353420446413b74077f9b06ffe11cab2693e4e365c265f8e2418.json
new file mode 100644
index 0000000..7471873
--- /dev/null
+++ b/rnex-core/.sqlx/query-18fb671d9d97353420446413b74077f9b06ffe11cab2693e4e365c265f8e2418.json
@@ -0,0 +1,125 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT data_id, owner, size, name, data_type, meta_binary,\n                  permission, permission_recipients, delete_permission, delete_permission_recipients,\n                  period, refer_data_id, flag, tags, creation_date, update_date,\n                  access_password, under_review\n           FROM datastore.objects\n           WHERE owner = $1 AND persistence_slot_id = $2\n           AND upload_completed = TRUE AND deleted = FALSE",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 1,
+        "name": "owner",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 2,
+        "name": "size",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 3,
+        "name": "name",
+        "type_info": "Text"
+      },
+      {
+        "ordinal": 4,
+        "name": "data_type",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 5,
+        "name": "meta_binary",
+        "type_info": "Bytea"
+      },
+      {
+        "ordinal": 6,
+        "name": "permission",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 7,
+        "name": "permission_recipients",
+        "type_info": "Int4Array"
+      },
+      {
+        "ordinal": 8,
+        "name": "delete_permission",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 9,
+        "name": "delete_permission_recipients",
+        "type_info": "Int4Array"
+      },
+      {
+        "ordinal": 10,
+        "name": "period",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 11,
+        "name": "refer_data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 12,
+        "name": "flag",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 13,
+        "name": "tags",
+        "type_info": "TextArray"
+      },
+      {
+        "ordinal": 14,
+        "name": "creation_date",
+        "type_info": "Timestamp"
+      },
+      {
+        "ordinal": 15,
+        "name": "update_date",
+        "type_info": "Timestamp"
+      },
+      {
+        "ordinal": 16,
+        "name": "access_password",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 17,
+        "name": "under_review",
+        "type_info": "Bool"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int4",
+        "Int4"
+      ]
+    },
+    "nullable": [
+      false,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      false,
+      false
+    ]
+  },
+  "hash": "18fb671d9d97353420446413b74077f9b06ffe11cab2693e4e365c265f8e2418"
+}
diff --git a/rnex-core/.sqlx/query-29e18f241dc860dca12c03cabb788d2d26f7644e85bfd65423e6e32c469e3695.json b/rnex-core/.sqlx/query-29e18f241dc860dca12c03cabb788d2d26f7644e85bfd65423e6e32c469e3695.json
new file mode 100644
index 0000000..5411a38
--- /dev/null
+++ b/rnex-core/.sqlx/query-29e18f241dc860dca12c03cabb788d2d26f7644e85bfd65423e6e32c469e3695.json
@@ -0,0 +1,16 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n                    INSERT INTO datastore.object_custom_rankings (data_id, application_id, value)\n                    VALUES ($1, $2, $3)\n                    ON CONFLICT (data_id, application_id)\n                    DO UPDATE SET value = datastore.object_custom_rankings.value + EXCLUDED.value\n                    ",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Int8",
+        "Int8",
+        "Int8"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "29e18f241dc860dca12c03cabb788d2d26f7644e85bfd65423e6e32c469e3695"
+}
diff --git a/rnex-core/.sqlx/query-2ff34379bbc32276c3b78ef1283b8158ea907d36588e1e59f6cbe752d89361bb.json b/rnex-core/.sqlx/query-2ff34379bbc32276c3b78ef1283b8158ea907d36588e1e59f6cbe752d89361bb.json
new file mode 100644
index 0000000..83246ca
--- /dev/null
+++ b/rnex-core/.sqlx/query-2ff34379bbc32276c3b78ef1283b8158ea907d36588e1e59f6cbe752d89361bb.json
@@ -0,0 +1,22 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT EXISTS(SELECT 1 FROM datastore.objects WHERE data_id = $1)",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "exists",
+        "type_info": "Bool"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      null
+    ]
+  },
+  "hash": "2ff34379bbc32276c3b78ef1283b8158ea907d36588e1e59f6cbe752d89361bb"
+}
diff --git a/rnex-core/.sqlx/query-48d94383f1a261f19060f5c75d9f7803ee88233c53efaa2df9966a6c72c8c763.json b/rnex-core/.sqlx/query-48d94383f1a261f19060f5c75d9f7803ee88233c53efaa2df9966a6c72c8c763.json
new file mode 100644
index 0000000..7a1cc6f
--- /dev/null
+++ b/rnex-core/.sqlx/query-48d94383f1a261f19060f5c75d9f7803ee88233c53efaa2df9966a6c72c8c763.json
@@ -0,0 +1,23 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT buffer\n        FROM datastore.buffer_queues\n        WHERE data_id = $1 AND slot = $2\n        ORDER BY creation_date ASC\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "buffer",
+        "type_info": "Bytea"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8",
+        "Int4"
+      ]
+    },
+    "nullable": [
+      false
+    ]
+  },
+  "hash": "48d94383f1a261f19060f5c75d9f7803ee88233c53efaa2df9966a6c72c8c763"
+}
diff --git a/rnex-core/.sqlx/query-60d8ebcf914d887439096df400fa4beaf37e879c28c81c22abeddb3d030535df.json b/rnex-core/.sqlx/query-60d8ebcf914d887439096df400fa4beaf37e879c28c81c22abeddb3d030535df.json
new file mode 100644
index 0000000..4f07b49
--- /dev/null
+++ b/rnex-core/.sqlx/query-60d8ebcf914d887439096df400fa4beaf37e879c28c81c22abeddb3d030535df.json
@@ -0,0 +1,28 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT under_review, access_password\n        FROM datastore.objects\n        WHERE data_id = $1 AND upload_completed = TRUE AND deleted = FALSE\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "under_review",
+        "type_info": "Bool"
+      },
+      {
+        "ordinal": 1,
+        "name": "access_password",
+        "type_info": "Int8"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      false,
+      false
+    ]
+  },
+  "hash": "60d8ebcf914d887439096df400fa4beaf37e879c28c81c22abeddb3d030535df"
+}
diff --git a/rnex-core/.sqlx/query-8909f81fbf26a9b559d26e138568be8946430d93821dbccb6dc9324ef0544c17.json b/rnex-core/.sqlx/query-8909f81fbf26a9b559d26e138568be8946430d93821dbccb6dc9324ef0544c17.json
new file mode 100644
index 0000000..867701f
--- /dev/null
+++ b/rnex-core/.sqlx/query-8909f81fbf26a9b559d26e138568be8946430d93821dbccb6dc9324ef0544c17.json
@@ -0,0 +1,29 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT\n            rankings.data_id,\n            rankings.value\n        FROM datastore.object_custom_rankings rankings\n        JOIN UNNEST($1::bigint[]) WITH ORDINALITY AS rows(data_id, ord)\n            ON rankings.data_id = rows.data_id\n            AND rankings.application_id = $2\n        ORDER BY rows.ord\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 1,
+        "name": "value",
+        "type_info": "Int8"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8Array",
+        "Int8"
+      ]
+    },
+    "nullable": [
+      false,
+      true
+    ]
+  },
+  "hash": "8909f81fbf26a9b559d26e138568be8946430d93821dbccb6dc9324ef0544c17"
+}
diff --git a/rnex-core/.sqlx/query-a5e86d7e66d0e16e5f35df883e11d9f4ef96adbdab7ca7d008acf596af91fc2b.json b/rnex-core/.sqlx/query-a5e86d7e66d0e16e5f35df883e11d9f4ef96adbdab7ca7d008acf596af91fc2b.json
new file mode 100644
index 0000000..539fdeb
--- /dev/null
+++ b/rnex-core/.sqlx/query-a5e86d7e66d0e16e5f35df883e11d9f4ef96adbdab7ca7d008acf596af91fc2b.json
@@ -0,0 +1,112 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT data_id, owner, size, name, data_type, meta_binary,\n                  permission, permission_recipients, delete_permission, delete_permission_recipients,\n                  period, refer_data_id, flag, tags, creation_date, update_date\n           FROM datastore.objects WHERE data_id = $1",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 1,
+        "name": "owner",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 2,
+        "name": "size",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 3,
+        "name": "name",
+        "type_info": "Text"
+      },
+      {
+        "ordinal": 4,
+        "name": "data_type",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 5,
+        "name": "meta_binary",
+        "type_info": "Bytea"
+      },
+      {
+        "ordinal": 6,
+        "name": "permission",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 7,
+        "name": "permission_recipients",
+        "type_info": "Int4Array"
+      },
+      {
+        "ordinal": 8,
+        "name": "delete_permission",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 9,
+        "name": "delete_permission_recipients",
+        "type_info": "Int4Array"
+      },
+      {
+        "ordinal": 10,
+        "name": "period",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 11,
+        "name": "refer_data_id",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 12,
+        "name": "flag",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 13,
+        "name": "tags",
+        "type_info": "TextArray"
+      },
+      {
+        "ordinal": 14,
+        "name": "creation_date",
+        "type_info": "Timestamp"
+      },
+      {
+        "ordinal": 15,
+        "name": "update_date",
+        "type_info": "Timestamp"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      false,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true,
+      true
+    ]
+  },
+  "hash": "a5e86d7e66d0e16e5f35df883e11d9f4ef96adbdab7ca7d008acf596af91fc2b"
+}
diff --git a/rnex-core/.sqlx/query-c2a0ca72fdcb060a7fb1c670b25e1efdbf3cef31e4b6cea4adbd51ee0218f5aa.json b/rnex-core/.sqlx/query-c2a0ca72fdcb060a7fb1c670b25e1efdbf3cef31e4b6cea4adbd51ee0218f5aa.json
new file mode 100644
index 0000000..095ca6f
--- /dev/null
+++ b/rnex-core/.sqlx/query-c2a0ca72fdcb060a7fb1c670b25e1efdbf3cef31e4b6cea4adbd51ee0218f5aa.json
@@ -0,0 +1,40 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT slot, total_value, count, initial_value\n        FROM datastore.object_ratings\n        WHERE data_id = $1\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "slot",
+        "type_info": "Int2"
+      },
+      {
+        "ordinal": 1,
+        "name": "total_value",
+        "type_info": "Int8"
+      },
+      {
+        "ordinal": 2,
+        "name": "count",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 3,
+        "name": "initial_value",
+        "type_info": "Int8"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": [
+      false,
+      true,
+      false,
+      true
+    ]
+  },
+  "hash": "c2a0ca72fdcb060a7fb1c670b25e1efdbf3cef31e4b6cea4adbd51ee0218f5aa"
+}
diff --git a/rnex-core/.sqlx/query-e28d8776cc49b55fe76cf33ac12fe18e500d243f1b55fd18e7d96d281605bcf9.json b/rnex-core/.sqlx/query-e28d8776cc49b55fe76cf33ac12fe18e500d243f1b55fd18e7d96d281605bcf9.json
new file mode 100644
index 0000000..552f92a
--- /dev/null
+++ b/rnex-core/.sqlx/query-e28d8776cc49b55fe76cf33ac12fe18e500d243f1b55fd18e7d96d281605bcf9.json
@@ -0,0 +1,14 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "UPDATE datastore.objects SET upload_completed = true WHERE data_id = $1",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Int8"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "e28d8776cc49b55fe76cf33ac12fe18e500d243f1b55fd18e7d96d281605bcf9"
+}
diff --git a/rnex-core/src/kerberos/mod.rs b/rnex-core/src/kerberos/mod.rs
index 205c62a..00f775d 100644
--- a/rnex-core/src/kerberos/mod.rs
+++ b/rnex-core/src/kerberos/mod.rs
@@ -51,6 +51,23 @@ pub fn derive_key(pid: PID, password: &[u8]) -> [u8; 16] {
 pub struct KerberosDateTime(pub u64);
 
 impl KerberosDateTime {
+    pub fn from_u64(val: u64) -> Self {
+        Self(val)
+    }
+
+    pub fn from_naive(dt: chrono::NaiveDateTime) -> Self {
+        use chrono::Datelike;
+        use chrono::Timelike;
+        Self::new(
+            dt.second() as u64,
+            dt.minute() as u64,
+            dt.hour() as u64,
+            dt.day() as u64,
+            dt.month() as u64,
+            dt.year() as u64,
+        )
+    }
+
     pub fn new(second: u64, minute: u64, hour: u64, day: u64, month: u64, year: u64) -> Self {
         Self(second | (minute << 6) | (hour << 12) | (day << 17) | (month << 22) | (year << 26))
     }
diff --git a/rnex-core/src/nex/datastore.rs b/rnex-core/src/nex/datastore.rs
index 57635a7..19db2b4 100644
--- a/rnex-core/src/nex/datastore.rs
+++ b/rnex-core/src/nex/datastore.rs
@@ -10,22 +10,360 @@ use rnex_core::nex::remote_console::RemoteConsole;
 use rnex_core::nex::s3presigner::S3Presigner;
 use rnex_core::rmc::response::ErrorCode;
 use rnex_core::rmc::protocols::secure::{Secure, RawSecure, RawSecureInfo, RemoteSecure};
-use rnex_core::rmc::protocols::datastore::{CompletePostParam, GetMetaInfo, GetMetaParam, KeyValue, RateCustomRankingParam};
+use rnex_core::rmc::protocols::datastore::{BufferQueueParam, CompletePostParam, DataStoreCustomRankingResult, DataStoreGetCustomRankingByDataIDParam, GetMetaInfo, GetMetaParam, KeyValue, Permission, PersistenceTarget, RateCustomRankingParam, RatingInfo, RatingInfoWithSlot};
 use rnex_core::rmc::protocols::datastore::{DataStore, RawDataStore, RawDataStoreInfo, RemoteDataStore, PreparePostParam, ReqPostInfo};
 use crate::nex::user::User;
 use rnex_core::executables::common::{RNEX_DATASTORE_S3_BUCKET, RNEX_DATASTORE_S3_ENDPOINT, get_db};
+use rnex_core::rmc::structures::qbuffer::QBuffer;
+use sqlx::types::chrono::DateTime;
+use rnex_core::kerberos::KerberosDateTime;
+use rnex_core::rmc::structures::qresult::QResult;
+
+fn map_row_to_meta_info(
+    row_data_id: i64,
+    row_owner: i32,
+    row_size: i32,
+    row_name: String,
+    row_data_type: i16,
+    row_meta_binary: Vec<u8>,
+    row_permission: i16,
+    row_permission_recipients: Vec<i64>,
+    row_delete_permission: i16,
+    row_delete_permission_recipients: Vec<i64>,
+    row_period: i16,
+    row_refer_data_id: i64,
+    row_flag: i32,
+    row_tags: Vec<String>,
+    row_creation_date: chrono::NaiveDateTime,
+    row_update_date: chrono::NaiveDateTime,
+    ratings: Vec<RatingInfoWithSlot>
+) -> GetMetaInfo {
+    GetMetaInfo {
+        dataid: row_data_id as u64,
+        owner: row_owner as u32,
+        size: row_size as u32,
+        name: row_name,
+        data_type: row_data_type as u16,
+        meta_binary: QBuffer(row_meta_binary),
+        permission: Permission {
+            permission: row_permission as u8,
+            recipient_ids: row_permission_recipients.into_iter().map(|id| id as u32).collect(),
+        },
+        del_permission: Permission {
+            permission: row_delete_permission as u8,
+            recipient_ids: row_delete_permission_recipients.into_iter().map(|id| id as u32).collect(),
+        },
+        period: row_period as u16,
+        status: 0,
+        referred_count: 0,
+        refer_dat_id: row_refer_data_id as u32,
+        flag: row_flag as u32,
+        tags: row_tags,
+        expire_time: KerberosDateTime::from_u64(0x9C3F3E0000),
+        created_time: KerberosDateTime::from_naive(row_creation_date),
+        updated_time: KerberosDateTime::from_naive(row_update_date),
+        referred_time: KerberosDateTime::from_naive(row_creation_date),
+        ratings,
+    }
+}
+
+async fn check_object_availability(data_id: u64, password: u64) -> Result<(), ErrorCode> {
+    let row = sqlx::query!(
+        r#"
+        SELECT under_review, access_password
+        FROM datastore.objects
+        WHERE data_id = $1 AND upload_completed = TRUE AND deleted = FALSE
+        "#,
+        data_id as i64
+    )
+        .fetch_optional(get_db())
+        .await
+        .map_err(|e| {
+            eprintln!("Availability check DB error: {:?}", e);
+            ErrorCode::DataStore_SystemFileError
+        })?
+        .ok_or(ErrorCode::DataStore_NotFound)?;
+
+    let access_password = row.access_password as u64;
+    if access_password != 0 && access_password != password {
+        return Err(ErrorCode::DataStore_InvalidPassword);
+    }
+
+    if row.under_review {
+        return Err(ErrorCode::DataStore_UnderReviewing);
+    }
+
+    Ok(())
+}
+
+async fn get_object_ratings(data_id: u64, password: u64) -> Result<Vec<RatingInfoWithSlot>, ErrorCode> {
+    check_object_availability(data_id, password).await?;
+
+    let rows = sqlx::query!(
+        r#"
+        SELECT slot, total_value, count, initial_value
+        FROM datastore.object_ratings
+        WHERE data_id = $1
+        "#,
+        data_id as i64
+    )
+        .fetch_all(get_db())
+        .await
+        .map_err(|e| {
+            eprintln!("Ratings fetch error: {:?}", e);
+            ErrorCode::DataStore_SystemFileError
+        })?;
+
+    let ratings = rows.into_iter().map(|row| {
+        RatingInfoWithSlot {
+            slot: row.slot as i8,
+            rating: RatingInfo {
+                total_value: row.total_value.unwrap_or(0),
+                count: row.count as u32,
+                initial_value: row.initial_value.unwrap_or(0),
+            },
+        }
+    }).collect();
+
+    Ok(ratings)
+}
+
+async fn get_object_info_by_data_id(data_id: u64, password: u64) -> Result<GetMetaInfo, ErrorCode> {
+    check_object_availability(data_id, password).await?;
+
+    let row = sqlx::query!(
+        r#"SELECT data_id, owner, size, name, data_type, meta_binary,
+                  permission, permission_recipients, delete_permission, delete_permission_recipients,
+                  period, refer_data_id, flag, tags, creation_date, update_date
+           FROM datastore.objects WHERE data_id = $1"#,
+        data_id as i64
+    )
+        .fetch_optional(get_db())
+        .await
+        .map_err(|_| ErrorCode::DataStore_SystemFileError)?
+        .ok_or(ErrorCode::DataStore_NotFound)?;
+
+    let ratings = get_object_ratings(data_id, password).await?;
+
+    Ok(map_row_to_meta_info(
+        row.data_id,
+        row.owner.unwrap_or(0),
+        row.size.unwrap_or(0),
+        row.name.unwrap_or_default(),
+        row.data_type.unwrap_or(0) as i16,
+        row.meta_binary.unwrap_or_default(),
+        row.permission.unwrap_or(0) as i16,
+        row.permission_recipients.unwrap_or_default().into_iter().map(|id| id as i64).collect(),
+        row.delete_permission.unwrap_or(0) as i16,
+        row.delete_permission_recipients.unwrap_or_default().into_iter().map(|id| id as i64).collect(),
+        row.period.unwrap_or(0) as i16,
+        row.refer_data_id.unwrap_or(0),
+        row.flag.unwrap_or(0),
+        row.tags.unwrap_or_default(),
+        row.creation_date.map(|dt| chrono::NaiveDateTime::new(
+            chrono::NaiveDate::from_ymd_opt(dt.year(), dt.month() as u32, dt.day() as u32).unwrap(),
+            chrono::NaiveTime::from_hms_opt(dt.hour() as u32, dt.minute() as u32, dt.second() as u32).unwrap()
+        )).unwrap_or_default(),
+        row.update_date.map(|dt| chrono::NaiveDateTime::new(
+            chrono::NaiveDate::from_ymd_opt(dt.year(), dt.month() as u32, dt.day() as u32).unwrap(),
+            chrono::NaiveTime::from_hms_opt(dt.hour() as u32, dt.minute() as u32, dt.second() as u32).unwrap()
+        )).unwrap_or_default(),
+        ratings
+    ))
+}
+
+async fn get_object_info_by_persistence_target(target: PersistenceTarget, password: u64) -> Result<GetMetaInfo, ErrorCode> {
+    let row = sqlx::query!(
+        r#"SELECT data_id, owner, size, name, data_type, meta_binary,
+                  permission, permission_recipients, delete_permission, delete_permission_recipients,
+                  period, refer_data_id, flag, tags, creation_date, update_date,
+                  access_password, under_review
+           FROM datastore.objects
+           WHERE owner = $1 AND persistence_slot_id = $2
+           AND upload_completed = TRUE AND deleted = FALSE"#,
+        target.owner as i32,
+        target.persistence_slot_id as i16
+    )
+        .fetch_optional(get_db())
+        .await
+        .map_err(|_| ErrorCode::DataStore_SystemFileError)?
+        .ok_or(ErrorCode::DataStore_NotFound)?;
+
+    let db_password = row.access_password as u64;
+    if db_password != 0 && db_password != password {
+        return Err(ErrorCode::DataStore_InvalidPassword);
+    }
+
+    if row.under_review {
+        return Err(ErrorCode::DataStore_UnderReviewing);
+    }
+
+    let ratings = get_object_ratings(row.data_id as u64, password).await?;
+
+    Ok(map_row_to_meta_info(
+        row.data_id,
+        row.owner.unwrap_or(0),
+        row.size.unwrap_or(0),
+        row.name.unwrap_or_default(),
+        row.data_type.unwrap_or(0) as i16,
+        row.meta_binary.unwrap_or_default(),
+        row.permission.unwrap_or(0) as i16,
+        row.permission_recipients.unwrap_or_default().into_iter().map(|id| id as i64).collect(),
+        row.delete_permission.unwrap_or(0) as i16,
+        row.delete_permission_recipients.unwrap_or_default().into_iter().map(|id| id as i64).collect(),
+        row.period.unwrap_or(0) as i16,
+        row.refer_data_id.unwrap_or(0),
+        row.flag.unwrap_or(0),
+        row.tags.unwrap_or_default(),
+        row.creation_date.map(|dt| chrono::NaiveDateTime::new(
+            chrono::NaiveDate::from_ymd_opt(dt.year(), dt.month() as u32, dt.day() as u32).unwrap(),
+            chrono::NaiveTime::from_hms_opt(dt.hour() as u32, dt.minute() as u32, dt.second() as u32).unwrap()
+        )).unwrap_or_default(),
+        row.update_date.map(|dt| chrono::NaiveDateTime::new(
+            chrono::NaiveDate::from_ymd_opt(dt.year(), dt.month() as u32, dt.day() as u32).unwrap(),
+            chrono::NaiveTime::from_hms_opt(dt.hour() as u32, dt.minute() as u32, dt.second() as u32).unwrap()
+        )).unwrap_or_default(),
+        ratings
+    ))
+}
+
+async fn get_buffer_queues_by_data_id_and_slot(
+    data_id: u64,
+    slot: u32
+) -> Result<Vec<QBuffer>, ErrorCode> {
+    check_object_availability(data_id, 0).await?;
+
+    let rows = sqlx::query!(
+        r#"
+        SELECT buffer
+        FROM datastore.buffer_queues
+        WHERE data_id = $1 AND slot = $2
+        ORDER BY creation_date ASC
+        "#,
+        data_id as i64,
+        slot as i32
+    )
+        .fetch_all(get_db())
+        .await
+        .map_err(|e| {
+            log::error!("Buffer queue fetch error: {:?}", e);
+            ErrorCode::DataStore_SystemFileError
+        })?;
+
+    let buffer_queues = rows
+        .into_iter()
+        .map(|row| QBuffer(row.buffer))
+        .collect();
+
+    Ok(buffer_queues)
+}
+
+fn verify_object_permission(
+    owner_id: u32,
+    viewer_id: u32,
+    permission: &Permission,
+) -> Result<(), ErrorCode> {
+    if owner_id == viewer_id {
+        return Ok(());
+    }
+
+    match permission.permission {
+        0 => Ok(()), // All can read
+        1 => Err(ErrorCode::DataStore_PermissionDenied), // Friends only, unimplemented
+        2 => {
+            // Recipient IDs can read
+            if permission.recipient_ids.contains(&viewer_id) {
+                Ok(())
+            } else {
+                Err(ErrorCode::DataStore_PermissionDenied)
+            }
+        }
+        3 => Err(ErrorCode::DataStore_PermissionDenied), // Owner only, redundant
+        _ => Err(ErrorCode::DataStore_InvalidArgument), // ??? haxx0r
+    }
+}
+
+fn filter_properties_by_result_option(
+    meta_info: &mut GetMetaInfo,
+    result_option: u8,
+) {
+    if (result_option & 0x01) == 0 {
+        meta_info.meta_binary = QBuffer(Vec::new());
+    }
+
+    if (result_option & 0x04) == 0 {
+        meta_info.ratings = Vec::new();
+    }
+
+    // No idea what the other things do. :shrug:
+}
+
+// Dawg...
+async fn get_custom_rankings_by_data_ids(
+    application_id: u32,
+    data_ids: Vec<u64>
+) -> Vec<DataStoreCustomRankingResult> {
+    let mut results = Vec::with_capacity(data_ids.len());
+
+    let rows = sqlx::query!(
+        r#"
+        SELECT
+            rankings.data_id,
+            rankings.value
+        FROM datastore.object_custom_rankings rankings
+        JOIN UNNEST($1::bigint[]) WITH ORDINALITY AS rows(data_id, ord)
+            ON rankings.data_id = rows.data_id
+            AND rankings.application_id = $2
+        ORDER BY rows.ord
+        "#,
+        &data_ids.iter().map(|&id| id as i64).collect::<Vec<i64>>(),
+        application_id as i32
+    )
+        .fetch_all(get_db())
+        .await;
+
+    let rows = match rows {
+        Ok(r) => r,
+        Err(e) => {
+            log::error!("Custom ranking query error: {:?}", e);
+            return results;
+        }
+    };
+
+    for row in rows {
+        let data_id = row.data_id as u64;
+        let score = row.value.unwrap_or(0) as u32;
+
+        if let Ok(meta) = get_object_info_by_data_id(data_id, 0).await {
+            results.push(DataStoreCustomRankingResult {
+                score,
+                meta_info: meta,
+            });
+        } else {
+            log::warn!("Could not find metadata for ranked object {}", data_id);
+        }
+    }
+
+    results
+}
 
 impl DataStore for User {
-    async fn get_meta(&self, metaparam: GetMetaParam) -> Result<GetMetaInfo, ErrorCode> {
-        println!("dataid: {}", metaparam.dataid);
-        println!("access password: {}", metaparam.access_password);
+    async fn get_meta(&self, mut metaparam: GetMetaParam) -> Result<GetMetaInfo, ErrorCode> {
+        let mut meta_info = if metaparam.dataid != 0 {
+            get_object_info_by_data_id(metaparam.dataid, metaparam.access_password).await?
+        } else {
+            get_object_info_by_persistence_target(metaparam.persistence_target, metaparam.access_password).await?
+        };
 
-        // just trying to see what methods it tries to use
-        Err(ErrorCode::DataStore_NotFound)
+        let current_pid = self.pid;
+        verify_object_permission(meta_info.owner, current_pid, &meta_info.permission)?;
+
+        filter_properties_by_result_option(&mut meta_info, metaparam.result_option);
+
+        Ok(meta_info)
     }
 
     async fn prepare_post_object(&self, postparam: PreparePostParam) -> Result<ReqPostInfo, ErrorCode> {
-        // Prepare your arrays first (Postgres needs i32, not u32)
         let recipient_ids: Vec<i32> = postparam.permission.recipient_ids.iter().map(|&id| id as i32).collect();
         let del_recipient_ids: Vec<i32> = postparam.del_permission.recipient_ids.iter().map(|&id| id as i32).collect();
         let now = time::OffsetDateTime::now_utc();
@@ -46,7 +384,7 @@ impl DataStore for User {
                 postparam.size as i32,
                 postparam.name,
                 postparam.data_type as i32,
-                &postparam.meta_binary.0, // unwrap QBuffer to &[u8]
+                &postparam.meta_binary.0,
                 postparam.permission.permission as i32,
                 &recipient_ids,
                 postparam.del_permission.permission as i32,
@@ -91,15 +429,78 @@ impl DataStore for User {
     }
 
     async fn complete_post_object(&self, completeparam: CompletePostParam) -> Result<(), ErrorCode> {
-        // whatever
-        println!("dataid: {}", completeparam.dataid);
-        println!("succeeded?: {}", completeparam.success);
+        let record = sqlx::query!(
+                r#"SELECT owner, under_review FROM datastore.objects WHERE data_id = $1"#,
+                completeparam.dataid as i64
+            )
+            .fetch_optional(get_db())
+            .await
+            .map_err(|e| {
+                eprintln!("select error: {:?}", e);
+                ErrorCode::DataStore_SystemFileError
+            })?;
+
+        let record = record.ok_or(ErrorCode::DataStore_NotFound)?;
+
+        if record.under_review {
+            return Err(ErrorCode::DataStore_UnderReviewing);
+        }
+
+        if record.owner.unwrap_or(0) as u32 != self.pid {
+            return Err(ErrorCode::DataStore_PermissionDenied);
+        }
+
+        if completeparam.success {
+            sqlx::query!(
+            r#"UPDATE datastore.objects SET upload_completed = true WHERE data_id = $1"#,
+            completeparam.dataid as i64
+        )
+                .execute(get_db())
+                .await
+                .map_err(|e| {
+                    eprintln!("update error: {:?}", e);
+                    ErrorCode::DataStore_SystemFileError
+                })?;
+        } else {
+            return Err(ErrorCode::Transport_TemporaryServerError);
+        }
 
         Ok(())
     }
 
     async fn rate_custom_ranking(&self, rankingparam: Vec<RateCustomRankingParam>) -> Result<(), ErrorCode> {
-        // this returns nothing
+        for param in rankingparam {
+            let exists = sqlx::query_scalar!(
+            r#"SELECT EXISTS(SELECT 1 FROM datastore.objects WHERE data_id = $1)"#,
+            param.dataid as i64
+            )
+                .fetch_one(get_db())
+                .await
+                .map_err(|_| ErrorCode::DataStore_SystemFileError)?;
+
+            if !exists.unwrap_or(false) {
+                return Err(ErrorCode::DataStore_NotFound);
+            }
+
+            sqlx::query!(
+                    r#"
+                    INSERT INTO datastore.object_custom_rankings (data_id, application_id, value)
+                    VALUES ($1, $2, $3)
+                    ON CONFLICT (data_id, application_id)
+                    DO UPDATE SET value = datastore.object_custom_rankings.value + EXCLUDED.value
+                    "#,
+                    param.dataid as i64,
+                    param.appid as i32,
+                    param.score as i32
+                )
+                .execute(get_db())
+                .await
+                .map_err(|e| {
+                    log::error!("update/insert error: {:?}", e);
+                    ErrorCode::DataStore_SystemFileError
+                })?;
+        }
+
         Ok(())
     }
 
@@ -138,4 +539,44 @@ impl DataStore for User {
 
         Ok(config)
     }
+
+    async fn get_custom_ranking_by_data_id(
+        &self,
+        param: DataStoreGetCustomRankingByDataIDParam
+    ) -> Result<(Vec<DataStoreCustomRankingResult>, Vec<QResult>), ErrorCode> {
+
+        let mut ranking_results = get_custom_rankings_by_data_ids(param.application_id, param.data_id_list).await;
+
+        let mut q_results = Vec::with_capacity(ranking_results.len());
+
+        for result in &mut ranking_results {
+            if (param.result_option & 0x01) == 0 {
+                result.meta_info.tags = Vec::new();
+            }
+
+            if (param.result_option & 0x02) == 0 {
+                result.meta_info.ratings = Vec::new();
+            }
+
+            if (param.result_option & 0x04) == 0 {
+                result.meta_info.meta_binary = QBuffer(Vec::new());
+            }
+
+            if (param.result_option & 0x20) == 0 {
+                result.score = 0;
+            }
+
+            q_results.push(QResult::success(ErrorCode::Core_Unknown));
+        }
+
+        Ok((ranking_results, q_results))
+    }
+
+    async fn get_buffer_queue(&self, param: BufferQueueParam) -> Result<Vec<QBuffer>, ErrorCode> {
+        // log::info!("GetBufferQueue: dataid={}, slot={}", param.dataid, param.slot);
+
+        let buffers = get_buffer_queues_by_data_id_and_slot(param.dataid, param.slot).await?;
+
+        Ok(buffers)
+    }
 }
\ No newline at end of file
diff --git a/rnex-core/src/rmc/protocols/datastore.rs b/rnex-core/src/rmc/protocols/datastore.rs
index 3899f93..00e522f 100644
--- a/rnex-core/src/rmc/protocols/datastore.rs
+++ b/rnex-core/src/rmc/protocols/datastore.rs
@@ -1,11 +1,11 @@
 use macros::{method_id, rmc_proto, RmcSerialize, rmc_struct};
 use rnex_core::rmc::structures::qbuffer::QBuffer;
 use rnex_core::rmc::response::ErrorCode;
-
+use rnex_core::rmc::structures::qresult::QResult;
 use rnex_core::kerberos::KerberosDateTime;
 use rnex_core::PID;
 
-#[derive(RmcSerialize, Clone)]
+#[derive(RmcSerialize, Clone, Debug)]
 #[rmc_struct(0)]
 pub struct PersistenceTarget {
     pub owner: PID,
@@ -152,6 +152,23 @@ pub struct BufferQueueParam {
     pub slot: u32,
 }
 
+// I just realized I forgot to add "DataStore" in front of the structs. I can't be assed to change it, sucks to be you lol.
+
+#[derive(RmcSerialize, Clone)]
+#[rmc_struct(0)]
+pub struct DataStoreGetCustomRankingByDataIDParam {
+    pub application_id: u32,
+    pub data_id_list: Vec<u64>,
+    pub result_option: u8,
+}
+
+#[derive(RmcSerialize, Clone)]
+#[rmc_struct(0)]
+pub struct DataStoreCustomRankingResult {
+    pub score: u32,
+    pub meta_info: GetMetaInfo,
+}
+
 #[rmc_proto(115)]
 pub trait DataStore{
     #[method_id(8)]
@@ -164,4 +181,8 @@ pub trait DataStore{
     async fn rate_custom_ranking(&self, rankingparam: Vec<RateCustomRankingParam>) -> Result<(), ErrorCode>;
     #[method_id(61)]
     async fn get_application_config(&self, appid: u32) -> Result<Vec<i32>, ErrorCode>;
+    #[method_id(50)]
+    async fn get_custom_ranking_by_data_id(&self, param: DataStoreGetCustomRankingByDataIDParam) -> Result<(Vec<DataStoreCustomRankingResult>, Vec<QResult>), ErrorCode>;
+    #[method_id(54)]
+    async fn get_buffer_queue(&self, param: BufferQueueParam) -> Result<Vec<QBuffer>, ErrorCode>;
 }
\ No newline at end of file