import type { key_val } from '$lib/ae_stores'; import { api } from '$lib/api'; import { db_save_ae_obj_li__ae_obj } from "$lib/ae_core/core__idb_dexie"; import { db_posts } from "$lib/ae_posts/db_posts"; import { load_ae_obj_li__post_comment } from "$lib/ae_posts/ae_posts__post_comment"; let ae_promises: key_val = {}; // Updated 2025-06-23 export async function load_ae_obj_id__post( { api_cfg, post_id, enabled = 'enabled', hidden = 'not_hidden', limit = 99, offset = 0, inc_comment_li = false, params = {}, try_cache = true, log_lvl = 0 }: { api_cfg: any, post_id: string, enabled?: string, hidden?: string, limit?: number, offset?: number, inc_comment_li?: boolean, params?: key_val, try_cache?: boolean, log_lvl?: number } ) { if (log_lvl) { console.log(`*** load_ae_obj_id__post() *** post_id=${post_id}`); } ae_promises.load__post_obj = await api.get_ae_obj_id_crud({ api_cfg: api_cfg, obj_type: 'post', obj_id: post_id, use_alt_table: true, use_alt_base: false, params: params, log_lvl: log_lvl }) .then(async function (post_obj_get_result) { if (post_obj_get_result) { if (try_cache) { // Process the results first let processed_obj_li = await process_ae_obj__post_props({ obj_li: [post_obj_get_result], log_lvl: log_lvl, }); if (log_lvl) { console.log('Processed object list:', processed_obj_li); } // Save the updated results list to the database if (log_lvl) { console.log('Saving to DB...'); } await db_save_ae_obj_li__ae_obj({ db_instance: db_posts, table_name: 'post', obj_li: processed_obj_li, properties_to_save: properties_to_save, log_lvl: log_lvl, }); if (log_lvl) { console.log('DB save completed.'); } // // This is expecting a list // db_save_ae_obj_li__post({ // obj_type: 'post', // obj_li: [post_obj_get_result], // log_lvl: log_lvl // }); } return post_obj_get_result; } else { console.log('No results returned.'); return null; } }) .catch(function (error) { console.log('No results returned or failed.', error); }); if (log_lvl) { console.log('ae_promises.load__post_obj:', ae_promises.load__post_obj); } if (!ae_promises.load__post_obj) { console.log(`ERROR: Posts - Post - The post with ID ${post_id} was not found.`); return ae_promises.load__post_obj; // Return null if the post was not found } if (inc_comment_li) { // Load the comments for the post if (log_lvl) { console.log(`Need to load the comment list for the post now`); } let load_post_comment_obj_li = load_ae_obj_li__post_comment({ api_cfg: api_cfg, for_obj_type: 'post', for_obj_id: post_id, enabled: enabled, // all, disabled, enabled hidden: hidden, // all, hidden, not_hidden limit: limit, // Limit for the comments offset: offset, params: params, try_cache: try_cache, log_lvl: log_lvl }) .then((post_comment_obj_li) => { if (log_lvl) { console.log(`post_comment_obj_li = `, post_comment_obj_li); } return post_comment_obj_li; }); if (log_lvl) { console.log(`post_comment_obj_li = `, load_post_comment_obj_li); } ae_promises.load__post_obj.post_comment_li = load_post_comment_obj_li; } return ae_promises.load__post_obj; } // Updated 2025-06-23 export async function load_ae_obj_li__post( { api_cfg, for_obj_type = 'account', for_obj_id, qry_archive_on = null, inc_comment_li = false, enabled = 'enabled', hidden = 'not_hidden', limit = 99, offset = 0, order_by_li = {'priority': 'DESC', 'sort': 'DESC', 'updated_on': 'DESC', 'created_on': 'DESC', 'title': 'ASC'}, params = {}, params_json = null, try_cache = true, log_lvl = 0 }: { api_cfg: any, for_obj_type: string, for_obj_id: string, qry_archive_on?: boolean|null|string, inc_comment_li?: boolean, enabled?: string, hidden?: string, limit?: number, offset?: number, order_by_li?: key_val, params_json?: null|key_val, params?: key_val, try_cache?: boolean, log_lvl?: number } ) { if (log_lvl) { console.log(`*** load_ae_obj_li__post() *** for_obj_type=${for_obj_type} for_obj_id=${for_obj_id}`); } // There is probably a better way to handle this. I don't want to just start a new object if it is not passed. However, the qry_conference and qry_str are sort of a special case. -2024-10-01 if (!params_json) { params_json = {}; } params_json['qry'] = []; if (qry_archive_on) { // let qry_param = // { // type: "AND", // field: "archive_on", // operator: ">", // value: qry_archive_on // }; // params_json['qry'].push(qry_param); } // if (qry_archive_on) { // if (!params_json['and_qry']) { // params_json['and_qry'] = {}; // } // params_json['and_qry']['archive_on'] = qry_archive_on; // } else if (qry_archive_on === false) { // if (!params_json['and_qry']) { // params_json['and_qry'] = {}; // } // if (log_lvl) { // console.log('qry_archive_on is false!'); // } // params_json['and_qry']['conference'] = qry_archive_on; // } if (log_lvl) { console.log('params_json:', params_json); } ae_promises.load__post_obj_li = await api.get_ae_obj_li_for_obj_id_crud_v2({ api_cfg: api_cfg, obj_type: 'post', for_obj_type: for_obj_type, for_obj_id: for_obj_id, use_alt_tbl: false, use_alt_mdl: false, use_alt_exp: false, enabled: enabled, hidden: hidden, order_by_li: order_by_li, limit: limit, offset: offset, params_json: params_json, params: params, log_lvl: log_lvl }) .then(async function (post_obj_li_get_result) { if (post_obj_li_get_result) { if (try_cache) { // Process the results first let processed_obj_li = await process_ae_obj__post_props({ obj_li: post_obj_li_get_result, log_lvl: log_lvl, }); if (log_lvl) { console.log('Processed object list:', processed_obj_li); } // Save the updated results list to the database if (log_lvl) { console.log('Saving to DB...'); } await db_save_ae_obj_li__ae_obj({ db_instance: db_posts, table_name: 'post', obj_li: processed_obj_li, properties_to_save: properties_to_save, log_lvl: log_lvl, }); if (log_lvl) { console.log('DB save completed.'); } // db_save_ae_obj_li__post({ // obj_type: 'post', // obj_li: post_obj_li_get_result, // log_lvl: log_lvl // }); } return post_obj_li_get_result; } else { return []; } }) .catch(function (error) { console.log('No results returned or failed.', error); }); if (log_lvl) { console.log('ae_promises.load__post_obj_li:', ae_promises.load__post_obj_li); } if (inc_comment_li) { // Load the comments for the posts if (log_lvl) { console.log(`Need to load the comment list for each post now`); } for (let i = 0; i < ae_promises.load__post_obj_li.length; i++) { let post_obj = ae_promises.load__post_obj_li[i]; let post_id = post_obj.post_id_random; let load_post_comment_obj_li = load_ae_obj_li__post_comment({ api_cfg: api_cfg, for_obj_type: 'post', for_obj_id: post_id, enabled: enabled, hidden: hidden, limit: limit, offset: offset, params: params, try_cache: try_cache, log_lvl: log_lvl }) .then((post_comment_obj_li) => { if (log_lvl) { console.log(`post_comment_obj_li = `, post_comment_obj_li); } return post_comment_obj_li; }); if (log_lvl) { console.log(`load_post_comment_obj_li = `, load_post_comment_obj_li); } } } return ae_promises.load__post_obj_li; } // Updated 2025-06-23 export async function create_ae_obj__post( { api_cfg, account_id, data_kv, params = {}, try_cache = true, log_lvl = 0 }: { api_cfg: any, account_id: string, data_kv: key_val, params?: key_val, try_cache?: boolean, log_lvl?: number } ) { if (log_lvl) { console.log(`*** create_ae_obj__post() *** account_id=${account_id}`); } if (!account_id) { console.log(`ERROR: Posts - Post - account_id required to create`); return false; } ae_promises.create__post = await api.create_ae_obj_crud({ api_cfg: api_cfg, obj_type: 'post', fields: { account_id_random: account_id, ...data_kv }, key: api_cfg.api_crud_super_key, params: params, return_obj: true, log_lvl: log_lvl }) .then(async function (post_obj_create_result) { if (post_obj_create_result) { if (try_cache) { // Process the results first let processed_obj_li = await process_ae_obj__post_props({ obj_li: [post_obj_create_result], log_lvl: log_lvl, }); if (log_lvl) { console.log('Processed object list:', processed_obj_li); } // Save the updated results list to the database if (log_lvl) { console.log('Saving to DB...'); } await db_save_ae_obj_li__ae_obj({ db_instance: db_posts, table_name: 'post', obj_li: processed_obj_li, properties_to_save: properties_to_save, log_lvl: log_lvl, }); if (log_lvl) { console.log('DB save completed.'); } // db_save_ae_obj_li__post( // { // obj_type: 'post', // obj_li: [post_obj_create_result], // log_lvl: log_lvl // }); } return post_obj_create_result; } else { return null; } }) .catch(function (error) { console.log('No results returned or failed.', error); }) .finally(function () { }); if (log_lvl) { console.log('ae_promises.create__post:', ae_promises.create__post); } return ae_promises.create__post; } // Updated 2024-11-08 export async function delete_ae_obj_id__post( { api_cfg, post_id, method = 'delete', // 'delete', 'disable', 'hide' params = {}, try_cache = true, log_lvl = 0 }: { api_cfg: any, post_id: string, method?: string, params?: key_val, try_cache?: boolean, log_lvl?: number } ) { if (log_lvl) { console.log(`*** delete_ae_obj_id__post() *** post_id=${post_id}`); } ae_promises.delete__post_obj = await api.delete_ae_obj_id_crud({ api_cfg: api_cfg, obj_type: 'post', obj_id: post_id, key: api_cfg.api_crud_super_key, params: params, method: method, log_lvl: log_lvl }) .catch(function (error) { console.log('No results returned or failed.', error); }) .finally(function () { if (try_cache) { if (log_lvl) { console.log(`Attempting to remove IDB entry for post_id=${post_id}`); } db_posts.post.delete(post_id); // Delete from the DB no matter what. } }); if (log_lvl) { console.log('ae_promises.delete__post_obj:', ae_promises.delete__post_obj); } return ae_promises.delete__post_obj; } // Updated 2025-06-23 export async function update_ae_obj__post( { api_cfg, post_id, data_kv, params = {}, try_cache = true, log_lvl = 0 }: { api_cfg: any, post_id: string, data_kv: key_val, params?: key_val, try_cache?: boolean, log_lvl?: number } ) { if (log_lvl) { console.log(`*** update_ae_obj__post() *** post_id=${post_id}`, data_kv); } // Perform the API update const result = await api.update_ae_obj_id_crud({ api_cfg: api_cfg, obj_type: 'post', obj_id: post_id, fields: data_kv, key: api_cfg.api_crud_super_key, params: params, return_obj: true, log_lvl: log_lvl, }); // Handle the result if (result) { if (try_cache) { // Process the results first let processed_obj_li = await process_ae_obj__post_props({ obj_li: [result], log_lvl: log_lvl, }); if (log_lvl) { console.log('Processed object list:', processed_obj_li); } // Save the updated results list to the database if (log_lvl) { console.log('Saving to DB...'); } await db_save_ae_obj_li__ae_obj({ db_instance: db_posts, table_name: 'post', obj_li: processed_obj_li, properties_to_save: properties_to_save, log_lvl: log_lvl, }); if (log_lvl) { console.log('DB save completed.'); } // await db_save_ae_obj_li__post({ // obj_type: 'post', // obj_li: [result], // log_lvl: log_lvl, // }); } return result; } else { console.error('Failed to update post.'); return null; } } // This new function is using CRUD v2. This should allow for more flexibility in the queries. // Updated 2024-09-25 export async function qry__post( { api_cfg, account_id, qry_str, qry_files, qry_start_datetime, // Example greater than: '2024-10-24' enabled = 'enabled', hidden = 'not_hidden', limit = 50, offset = 0, params = {}, try_cache = true, log_lvl = 0 }: { api_cfg: any, account_id: any, qry_str?: string, qry_files?: null|boolean, qry_start_datetime?: null|string, // Greater than this datetime enabled?: string, // all, disabled, enabled hidden?: string, // all, hidden, not_hidden limit?: number, offset?: number, params?: any, try_cache?: boolean, log_lvl?: number } ) { console.log(`*** qry__post() *** account_id=${account_id} qry_str=${qry_str}`); // let enabled: string = (params.qry__enabled ?? 'enabled'); // all, disabled, enabled // let hidden: string = (params.qry__hidden ?? 'not_hidden'); // all, hidden, not_hidden // let limit: number = (params.qry__limit ?? 25); // 99 // let offset: number = (params.qry__offset ?? 0); // 0 let params_json: key_val = {}; // if (qry_str && qry_str.length > 2) { // params_json['ft_qry'] = {}; // params_json['ft_qry']['default_qry_str'] = qry_str; // } params_json['qry'] = []; if (qry_files === true) { let qry_param = { type: "AND", field: "file_count_all", operator: ">", value: 0 }; params_json['qry'].push(qry_param); } else if (qry_files === false) { let qry_param = { type: "AND", field: "file_count_all", operator: "IS", value: null }; params_json['qry'].push(qry_param); } if (qry_start_datetime) { let qry_param = { type: "AND", field: "start_datetime", operator: ">", value: qry_start_datetime }; params_json['qry'].push(qry_param); } let order_by_li = {'priority': 'DESC', 'sort': 'DESC', 'updated_on': 'DESC', 'created_on': 'DESC', 'title': 'ASC'}; ae_promises.load__post_obj_li = await api.get_ae_obj_li_for_obj_id_crud_v2({ api_cfg: api_cfg, obj_type: 'post', for_obj_type: 'account', for_obj_id: account_id, use_alt_tbl: true, // NOTE: We want to use the alt table for post searching use_alt_mdl: false, use_alt_exp: false, enabled: enabled, hidden: hidden, order_by_li: order_by_li, limit: limit, offset: offset, params_json: params_json, params: params, log_lvl: log_lvl }) .then(function (post_obj_li_get_result) { if (post_obj_li_get_result) { db_save_ae_obj_li__post({ obj_type: 'post', obj_li: post_obj_li_get_result, log_lvl: log_lvl }); return post_obj_li_get_result; } else { return []; } }); if (log_lvl) { console.log('ae_promises.load__post_obj_li:', ae_promises.load__post_obj_li); } return ae_promises.load__post_obj_li; } // Updated 2024-09-25 // export async function search__post( // { // api_cfg, // account_id, // poc_agree = null, // fulltext_search_qry_str, // ft_comment_search_qry_str, // like_search_qry_str = null, // file_count = false, // If true then only show those that have a file count // person_name = null, // params = {}, // try_cache = true, // log_lvl = 0 // }: { // api_cfg: any, // account_id: any, // poc_agree?: null|boolean, // fulltext_search_qry_str?: null|string, // ft_comment_search_qry_str?: null|string, // like_search_qry_str?: null|string, // file_count?: boolean, // person_name?: null|string, // params?: any, // try_cache?: boolean, // log_lvl?: number // } // ) { // console.log(`*** search__post() *** account_id=${account_id}`); // let enabled: string = (params.qry__enabled ?? 'enabled'); // all, disabled, enabled // let hidden: string = (params.qry__hidden ?? 'not_hidden'); // all, hidden, not_hidden // let limit: number = (params.qry__limit ?? 25); // 99 // let offset: number = (params.qry__offset ?? 0); // 0 // let params_json: key_val = {}; // // if (!fulltext_search_qry_str && !like_search_qry_str) { // // console.log('No search string provided!!!'); // // return false; // Returning false instead of [] because no search was performed. // // } // if (fulltext_search_qry_str || ft_comment_search_qry_str) { // params_json['ft_qry'] = {}; // if (fulltext_search_qry_str && fulltext_search_qry_str.length > 2) { // params_json['ft_qry']['default_qry_str'] = fulltext_search_qry_str; // } // if (ft_comment_search_qry_str && ft_comment_search_qry_str.length > 2) { // params_json['ft_qry']['post_comment_li_qry_str'] = ft_comment_search_qry_str; // } // } // // Use the AND (AND LIKE) query // // if (like_search_qry_str || like_comment_search_qry_str) { // // params_json['and_like'] = {}; // // if (like_search_qry_str && like_search_qry_str.length > 2) { // // params_json['and_like']['default_qry_str'] = like_search_qry_str; // // } // // if (like_comment_search_qry_str && like_comment_search_qry_str.length > 2) { // // params_json['and_like']['post_comment_li_qry_str'] = like_comment_search_qry_str; // // } // // } // // Use the AND (OR LIKE) query // if (like_search_qry_str || like_comment_search_qry_str || like_comment_search_qry_str) { // params_json['or_like'] = {}; // if (like_search_qry_str && like_search_qry_str.length > 2) { // params_json['or_like']['default_qry_str'] = like_search_qry_str; // } // if (like_comment_search_qry_str && like_comment_search_qry_str.length > 2) { // params_json['or_like']['post_comment_li_qry_str'] = like_comment_search_qry_str; // } // if (like_comment_search_qry_str && like_comment_search_qry_str.length > 2) { // params_json['or_like']['post_comment_li_qry_str'] = like_comment_search_qry_str; // } // } // params_json['and_qry'] = {}; // if (poc_agree) { // params_json['and_qry']['poc_agree'] = poc_agree; // } // if (file_count) { // params_json['and_qry']['file_count'] = file_count; // } // // This should be using a like with surrounded by %'s // if (person_name) { // params_json['and_qry']['post_full_name'] = person_name; // } // let order_by_li = {'priority': 'DESC', 'sort': 'DESC', 'name': 'ASC', 'updated_on': 'DESC', 'created_on': 'DESC'}; // ae_promises.load__post_obj_li = await api.get_ae_obj_li_for_obj_id_crud({ // api_cfg: api_cfg, // obj_type: 'post', // for_obj_type: 'account', // for_obj_id: account_id, // use_alt_table: true, // NOTE: We want to use the alt table for post searching // use_alt_base: false, // enabled: enabled, // hidden: hidden, // order_by_li: order_by_li, // limit: limit, // offset: offset, // params_json: params_json, // params: params, // log_lvl: log_lvl // }) // .then(function (post_obj_li_get_result) { // if (post_obj_li_get_result) { // if (try_cache) { // db_save_ae_obj_li__post({ // obj_type: 'post', // obj_li: post_obj_li_get_result // }); // } // return post_obj_li_get_result; // } else { // return []; // } // }) // .catch(function (error) { // console.log('No results returned or failed.', error); // }) // .finally(function () { // }); // if (log_lvl) { // console.log('ae_promises.load__post_obj_li:', ae_promises.load__post_obj_li); // } // return ae_promises.load__post_obj_li; // } // This function will loop through the post_obj_li and save each one to the DB. // Updated 2024-09-25 export function db_save_ae_obj_li__post( { obj_type, obj_li, log_lvl = 0 }: { obj_type: string, obj_li: any, log_lvl?: number } ) { if (log_lvl) { console.log(`*** db_save_ae_obj_li__post() ***`); } if (obj_li && obj_li.length) { obj_li.forEach(async function (obj: any) { if (log_lvl) { console.log(`ae_obj ${obj_type}:`, obj); } try { const id_random = await db_posts.post.put({ id: obj.post_id_random, post_id: obj.post_id_random, account_id: obj.account_id_random, external_person_id: obj.external_person_id, topic_id: obj.topic_id, topic: obj.topic, topic_name: obj.topic_name, name: obj.title, title: obj.title, // Switching to name instead of title // summary: obj.summary, content: obj.content, anonymous: obj.anonymous, full_name: obj.full_name, email: obj.email, notify: obj.notify, enable_comments: obj.enable_comments, archive: obj.archive, archive_on: obj.archive_on, linked_li_json: obj.linked_li_json, cfg_json: obj.cfg_json, enable: obj.enable, hide: obj.hide, priority: obj.priority, sort: obj.sort, group: obj.group, notes: obj.notes, created_on: obj.created_on, updated_on: obj.updated_on, tmp_sort_1: `${obj.group ?? ''}_${obj.priority ? '1' : '0'}_${obj.sort?.toString().padStart(3, '0') ?? ''}_${obj.updated_on ?? obj.created_on}`, tmp_sort_2: `${obj.group ?? ''}_${obj.priority ? '1' : '0'}_${obj.sort?.toString().padStart(3, '0') ?? ''}_${obj.updated_on}_${obj.created_on}`, // From SQL view post_comment_count: obj.post_comment_count, // A key value list of the comments // post_comment_kv: obj.post_comment_kv, // post_comment_li: obj.post_comment_li, }); if (log_lvl) { console.log(`Put obj with ID: ${obj.post_id_random} or ${id_random}`); } } catch (error) { let status = `Failed to put ${obj.post_id_random}: ${error}`; console.log(status); return false; } }); return true; } } // Updated 2025-06-04 export const properties_to_save = [ 'id', 'post_id', // 'post_id_random', 'account_id', // 'account_id_random', 'external_person_id', 'topic_id', 'topic', 'topic_name', 'name', 'title', 'content', 'anonymous', 'full_name', 'email', 'notify', 'enable_comments', 'archive', 'archive_on', 'linked_li_json', 'cfg_json', 'enable', 'hide', 'priority', 'sort', 'group', 'notes', 'created_on', 'updated_on', // Generated fields for sorting locally only 'tmp_sort_1', 'tmp_sort_2', // 'tmp_sort_a', // 'tmp_sort_b', // From SQL view 'post_comment_count', // A key value list of the comments // 'post_comment_kv', // 'post_comment_li', ]; /** * NON-EXPORTED LOCAL HELPER * Processes a list of Aether objects by applying common and specific transformations. */ async function _process_generic_props>({ obj_li, obj_type, log_lvl = 0, specific_processor }: { obj_li: T[]; obj_type: string; log_lvl?: number; specific_processor?: (obj: T) => Promise | T; }): Promise { if (log_lvl > 0) { console.log( `*** _process_generic_props: Processing ${obj_li.length} objects of type "${obj_type}" ***` ); } if (!obj_li || obj_li.length === 0) { if (log_lvl > 0) console.log('No objects to process.'); return []; } const processed_obj_li: T[] = []; for (const original_obj of obj_li) { let processed_obj = { ...original_obj }; // --- Common Transformations --- // 1. Standardize ID and other '_random' fields // The API often returns fields like 'person_id_random', which need to be aliased to 'person_id'. for (const key in processed_obj) { if (key.endsWith('_random')) { const newKey = key.slice(0, -7); // Remove '_random' suffix processed_obj[newKey] = processed_obj[key]; } } // Ensure 'id' is set from '[obj_type]_id_random' const randomIdKey = `${obj_type}_id_random`; if (processed_obj[randomIdKey]) { processed_obj.id = processed_obj[randomIdKey]; } // 2. Create common computed properties for client-side sorting. const group = processed_obj.group ?? '0'; const priority = processed_obj.priority ? 1 : 0; const sort = processed_obj.sort ?? '0'; const updated = processed_obj.updated_on ?? processed_obj.created_on; const name = processed_obj.name ?? ''; processed_obj.tmp_sort_1 = `${group}_${priority}_${sort}_${updated}`; processed_obj.tmp_sort_2 = `${group}_${priority}_${sort}_${name}_${updated}`; // --- Specific Transformations --- if (specific_processor) { processed_obj = await Promise.resolve(specific_processor(processed_obj)); } processed_obj_li.push(processed_obj as T); } return processed_obj_li; } // Updated 2025-06-04 export async function process_ae_obj__post_props({ obj_li, log_lvl = 0 }: { obj_li: any[]; log_lvl?: number; }) { return _process_generic_props({ obj_li, obj_type: 'post', log_lvl, specific_processor: (obj) => { // Post-specific aliasing and computed sort fields, overriding generic ones if needed obj.name = obj.title; // Map title to name obj.tmp_sort_1 = `${obj.group ?? ''}_${obj.priority ? '1' : '0'}_${ obj.sort?.toString().padStart(3, '0') ?? '' }_${obj.updated_on ?? obj.created_on}`; obj.tmp_sort_2 = `${obj.group ?? ''}_${obj.priority ? '1' : '0'}_${ obj.sort?.toString().padStart(3, '0') ?? '' }_${obj.updated_on}_${obj.created_on}`; return obj; } }); }