dev: [+] DataAccessModule > AppService > select()

This commit adds the DataAccessModule, which is where replacement
"flatter" implementations for what is currently implemented via
EntityStorage/OM will be developed.

This commit also adds AppService, which is where the `crud-q`
implementor for apps will be implemented.

This commit adds the `select()` implementation for AppService. Currently
it is missing many behaviors for parity with the current ES/OM
implementation including:
- coercion of boolean values
- nested objects and their properties
- `icon_size` parameter support

Author: KernelDeimos

src/backend/exports.js

@@ -27,6 +27,7 @@ import { AppsModule } from './src/modules/apps/AppsModule.js';
 import { BroadcastModule } from './src/modules/broadcast/BroadcastModule.js';
 import { CaptchaModule } from './src/modules/captcha/CaptchaModule.js';
 import { Core2Module } from './src/modules/core/Core2Module.js';
+import { DataAccessModule } from './src/modules/data-access/DataAccessModule.js';
 import { DevelopmentModule } from './src/modules/development/DevelopmentModule.js';
 import { DNSModule } from './src/modules/dns/DNSModule.js';
 import { DomainModule } from './src/modules/domain/DomainModule.js';
@@ -85,6 +86,7 @@ export default {
     KVStoreModule,
     DNSModule,
     DomainModule,
+    DataAccessModule,
 
     // Development modules
     PerfMonModule,

src/backend/src/data/hardcoded-permissions.js

@@ -112,6 +112,7 @@ const hardcoded_user_group_permissions = {
             'service:puter-notifications:ii:crud-q': policy_perm('temp.es'),
             'service:puter-apps:ii:crud-q': policy_perm('temp.es'),
             'service:puter-subdomains:ii:crud-q': policy_perm('temp.es'),
+            'service:apps:ii:crud-q': policy_perm('temp.es'),
             'service:es\\Cnotification:ii:crud-q': policy_perm('user.es'),
             'service:es\\Capp:ii:crud-q': policy_perm('user.es'),
             'service:es\\Csubdomain:ii:crud-q': policy_perm('user.es'),
@@ -123,6 +124,7 @@ const hardcoded_user_group_permissions = {
             'service:es\\Cnotification:ii:crud-q': policy_perm('user.es'),
             'service:es\\Capp:ii:crud-q': policy_perm('user.es'),
             'service:es\\Csubdomain:ii:crud-q': policy_perm('user.es'),
+            'service:apps:ii:crud-q': policy_perm('user.es'),
         },
     },
 };

src/backend/src/modules/data-access/AppRepository.js

@@ -0,0 +1,3 @@
+export default class AppRepository {
+    //
+}

src/backend/src/modules/data-access/AppService.js

@@ -0,0 +1,85 @@
+import BaseService from '../../services/BaseService.js';
+import { DB_READ } from '../../services/database/consts.js';
+import { Context } from '../../util/context.js';
+import AppRepository from './AppRepository.js';
+
+/**
+ * AppService contains an instance using the repository pattern
+ */
+export default class AppService extends BaseService {
+    async _init () {
+        this.repository = new AppRepository();
+        this.db = this.services.get('database').get(DB_READ, 'apps');
+    }
+
+    static IMPLEMENTS = {
+        ['crud-q']: {
+            async create ({ object, options }) {
+                // TODO
+            },
+            async update ({ object, id, options }) {
+                // TODO
+            },
+            async upsert ({ object, id, options }) {
+                // TODO
+            },
+            async read ({ uid, id, params = {} }) {
+                // TODO
+            },
+            async select (options) {
+                return this.#select(options);
+            },
+            async delete ({ uid, id }) {
+                // TODO
+            },
+        },
+    };
+
+    async #select ({ predicate, ...rest }) {
+        const db = this.db;
+
+        if ( ! Array.isArray(predicate) ) throw new Error('predicate must be an array');
+
+        const userCanEditOnly = Array.prototype.includes.call(predicate, 'user-can-edit');
+
+        const stmt = `SELECT * FROM apps ${userCanEditOnly ? 'WHERE owner_user_id=?' : ''} LIMIT 5000`;
+        const values = userCanEditOnly ? [Context.get('user').id] : [];
+        const rows = await db.read(stmt, values);
+
+        const client_safe_apps = [];
+        for ( const row of rows ) {
+            const app = {};
+
+            // FROM ROW
+            app.approved_for_incentive_program = row.approved_for_incentive_program;
+            app.approved_for_listing = row.approved_for_listing;
+            app.approved_for_opening_items = row.approved_for_opening_items;
+            app.background = row.background;
+            app.created_at = row.created_at;
+            app.created_from_origin = row.created_from_origin;
+            app.description = row.description;
+            app.godmode = row.godmode;
+            app.icon = row.icon;
+            app.index_url = row.index_url;
+            app.maximize_on_start = row.maximize_on_start;
+            app.metadata = row.metadata;
+            app.name = row.name;
+            app.protected = row.protected;
+            app.stats = row.stats;
+            app.title = row.title;
+            app.uid = row.uid;
+
+            // REQURIES OTHER DATA
+            // app.app_owner;
+            // app.filetype_associations = row.filetype_associations;
+            // app.owner = row.owner;
+
+            // REFINED BY OTHER DATA
+            // app.icon;
+
+            client_safe_apps.push(app);
+        }
+
+        return client_safe_apps;
+    }
+}