File tree Expand file tree Collapse file tree 8 files changed +39
-17
lines changed
apps/desktop/src/store/tinybase/persister Expand file tree Collapse file tree 8 files changed +39
-17
lines changed Original file line number Diff line number Diff line change @@ -58,7 +58,9 @@ describe("createCalendarPersister", () => {
5858 } ;
5959 vi . mocked ( readTextFile ) . mockResolvedValue ( JSON . stringify ( mockData ) ) ;
6060
61- const persister = createCalendarPersister < Schemas > ( store ) ;
61+ const persister = createCalendarPersister < Schemas > ( store , {
62+ mode : "load-and-save" ,
63+ } ) ;
6264 await persister . load ( ) ;
6365
6466 expect ( readTextFile ) . toHaveBeenCalledWith (
@@ -74,7 +76,9 @@ describe("createCalendarPersister", () => {
7476 new Error ( "No such file or directory" ) ,
7577 ) ;
7678
77- const persister = createCalendarPersister < Schemas > ( store ) ;
79+ const persister = createCalendarPersister < Schemas > ( store , {
80+ mode : "load-and-save" ,
81+ } ) ;
7882 await persister . load ( ) ;
7983
8084 expect ( store . getTable ( "calendars" ) ) . toEqual ( { } ) ;
Original file line number Diff line number Diff line change @@ -75,8 +75,8 @@ export function createChatPersister<Schemas extends OptionalSchemas>(
7575 const saveFn =
7676 config . mode === "load-only"
7777 ? async ( ) => { }
78- : async ( getContent : ( ) => unknown ) => {
79- const [ tables ] = getContent ( ) as [ TablesContent | undefined , unknown ] ;
78+ : async ( ) => {
79+ const tables = store . getTables ( ) as TablesContent | undefined ;
8080 const dataDir = await getDataDir ( ) ;
8181
8282 const messagesByChatGroup = collectMessagesByChatGroup ( tables ) ;
Original file line number Diff line number Diff line change @@ -63,7 +63,9 @@ describe("createEventPersister", () => {
6363 } ;
6464 vi . mocked ( readTextFile ) . mockResolvedValue ( JSON . stringify ( mockData ) ) ;
6565
66- const persister = createEventPersister < Schemas > ( store ) ;
66+ const persister = createEventPersister < Schemas > ( store , {
67+ mode : "load-and-save" ,
68+ } ) ;
6769 await persister . load ( ) ;
6870
6971 expect ( readTextFile ) . toHaveBeenCalledWith (
@@ -79,7 +81,9 @@ describe("createEventPersister", () => {
7981 new Error ( "No such file or directory" ) ,
8082 ) ;
8183
82- const persister = createEventPersister < Schemas > ( store ) ;
84+ const persister = createEventPersister < Schemas > ( store , {
85+ mode : "load-and-save" ,
86+ } ) ;
8387 await persister . load ( ) ;
8488
8589 expect ( store . getTable ( "events" ) ) . toEqual ( { } ) ;
Original file line number Diff line number Diff line change @@ -58,7 +58,9 @@ describe("createHumanPersister", () => {
5858 } ;
5959 vi . mocked ( readTextFile ) . mockResolvedValue ( JSON . stringify ( mockData ) ) ;
6060
61- const persister = createHumanPersister < Schemas > ( store ) ;
61+ const persister = createHumanPersister < Schemas > ( store , {
62+ mode : "load-and-save" ,
63+ } ) ;
6264 await persister . load ( ) ;
6365
6466 expect ( readTextFile ) . toHaveBeenCalledWith (
@@ -74,7 +76,9 @@ describe("createHumanPersister", () => {
7476 new Error ( "No such file or directory" ) ,
7577 ) ;
7678
77- const persister = createHumanPersister < Schemas > ( store ) ;
79+ const persister = createHumanPersister < Schemas > ( store , {
80+ mode : "load-and-save" ,
81+ } ) ;
7882 await persister . load ( ) ;
7983
8084 expect ( store . getTable ( "humans" ) ) . toEqual ( { } ) ;
Original file line number Diff line number Diff line change @@ -29,8 +29,8 @@ export function createNotePersister<Schemas extends OptionalSchemas>(
2929 const saveFn =
3030 config . mode === "load-only"
3131 ? async ( ) => { }
32- : async ( getContent : ( ) => unknown ) => {
33- const [ tables ] = getContent ( ) as [ TablesContent | undefined , unknown ] ;
32+ : async ( ) => {
33+ const tables = store . getTables ( ) as TablesContent | undefined ;
3434 const dataDir = await getDataDir ( ) ;
3535
3636 const enhancedNotes = collectEnhancedNoteBatchItems (
Original file line number Diff line number Diff line change @@ -53,7 +53,9 @@ describe("createOrganizationPersister", () => {
5353 } ;
5454 vi . mocked ( readTextFile ) . mockResolvedValue ( JSON . stringify ( mockData ) ) ;
5555
56- const persister = createOrganizationPersister < Schemas > ( store ) ;
56+ const persister = createOrganizationPersister < Schemas > ( store , {
57+ mode : "load-and-save" ,
58+ } ) ;
5759 await persister . load ( ) ;
5860
5961 expect ( readTextFile ) . toHaveBeenCalledWith (
@@ -69,7 +71,9 @@ describe("createOrganizationPersister", () => {
6971 new Error ( "No such file or directory" ) ,
7072 ) ;
7173
72- const persister = createOrganizationPersister < Schemas > ( store ) ;
74+ const persister = createOrganizationPersister < Schemas > ( store , {
75+ mode : "load-and-save" ,
76+ } ) ;
7377 await persister . load ( ) ;
7478
7579 expect ( store . getTable ( "organizations" ) ) . toEqual ( { } ) ;
Original file line number Diff line number Diff line change @@ -228,7 +228,9 @@ describe("createSessionPersister", () => {
228228 } ;
229229 vi . mocked ( readTextFile ) . mockResolvedValue ( JSON . stringify ( mockMeta ) ) ;
230230
231- const persister = createSessionPersister < Schemas > ( store ) ;
231+ const persister = createSessionPersister < Schemas > ( store , {
232+ mode : "load-and-save" ,
233+ } ) ;
232234 await persister . load ( ) ;
233235
234236 expect ( store . getTable ( "sessions" ) ) . toEqual ( {
@@ -277,7 +279,9 @@ describe("createSessionPersister", () => {
277279 } ;
278280 vi . mocked ( readTextFile ) . mockResolvedValue ( JSON . stringify ( mockMeta ) ) ;
279281
280- const persister = createSessionPersister < Schemas > ( store ) ;
282+ const persister = createSessionPersister < Schemas > ( store , {
283+ mode : "load-and-save" ,
284+ } ) ;
281285 await persister . load ( ) ;
282286
283287 expect ( store . getTable ( "tags" ) ) . toEqual ( { } ) ;
@@ -324,7 +328,9 @@ describe("createSessionPersister", () => {
324328 } ) ,
325329 ) ;
326330
327- const persister = createSessionPersister < Schemas > ( store ) ;
331+ const persister = createSessionPersister < Schemas > ( store , {
332+ mode : "load-and-save" ,
333+ } ) ;
328334 await persister . load ( ) ;
329335
330336 const tags = store . getTable ( "tags" ) ;
Original file line number Diff line number Diff line change @@ -86,8 +86,8 @@ export function createTranscriptPersister<Schemas extends OptionalSchemas>(
8686 const saveFn =
8787 config . mode === "load-only"
8888 ? async ( ) => { }
89- : async ( getContent : ( ) => unknown ) => {
90- const [ tables ] = getContent ( ) as [ TablesContent | undefined , unknown ] ;
89+ : async ( ) => {
90+ const tables = store . getTables ( ) as TablesContent | undefined ;
9191 const dataDir = await getDataDir ( ) ;
9292
9393 const transcriptsBySession = collectTranscriptsBySession ( tables ) ;
You can’t perform that action at this time.
0 commit comments