diff --git a/source/repositories/member.ts b/source/repositories/member.ts index 60f0e90..fe67b14 100644 --- a/source/repositories/member.ts +++ b/source/repositories/member.ts @@ -88,7 +88,7 @@ namespace _espe.repository.member { "database_implementation": _espe.helpers.database_implementation(), "table_name": "member_groups", - "key_names": ["member_id","group"], + "key_names": ["member_id","group_name"], } ); } @@ -135,7 +135,7 @@ namespace _espe.repository.member object.groups .map( group => ({ - "group": group, + "group_name": group, }) ) ) @@ -155,8 +155,8 @@ namespace _espe.repository.member "name_real_index": dispersal.core_row["name_real_index"], "email_address_private": dispersal.core_row["email_address_private"], "groups": lib_plankton.list.sorted( - dispersal.group_rows.map(row => row["group"]), - (group1, group2) => ((group1 <= group2) ? 1 : 0) + dispersal.group_rows.map(row => row["group_name"]), + (group1, group2) => ((group1 <= group2) ? 0 : 1) ), "registered": (dispersal.core_row["registered"] > 0), "enabled": (dispersal.core_row["enabled"] > 0), @@ -238,7 +238,7 @@ namespace _espe.repository.member "core_row": core_row, "group_rows": group_hits.map( hit => ({ - "group": hit.preview["group"] + "group_name": hit.preview["group_name"] }) ), }; @@ -255,13 +255,15 @@ namespace _espe.repository.member { const dispersal : type_dispersal = encode(value); + // core const id : _espe.type.member_id = await get_core_store().create(dispersal.core_row); + // groups for await (const group_row of dispersal.group_rows) { await get_group_chest().write( [ id, - group_row["group"], + group_row["group_name"], ], { "_dummy": null, @@ -293,14 +295,15 @@ namespace _espe.repository.member "arguments": {"member_id": id} } ); + lib_plankton.log.info("update_hit", hits); for (const hit of hits) { - await get_group_chest().delete([hit.key]); + await get_group_chest().delete(hit.key); } for await (const group_row of dispersal.group_rows) { await get_group_chest().write( [ id, - group_row["group"], + group_row["group_name"], ], { "_dummy": null, @@ -324,7 +327,7 @@ namespace _espe.repository.member } ); for (const hit of hits) { - await get_group_chest().delete([hit.key]); + await get_group_chest().delete(hit.key); } // core