љi v S SK r S SKrS SKJrJrJr S SKJrJrJrJ r S SK
J r SSK J
r
JrJr SSKJrJrJrJrJr " S S
\
5 r " S S \5 r " S
S\5 rg) N)datetimetimezonedate)DictAnyOptionalList)uuid4 )CharacterRepositoryBaseActivityRepositoryBaseUserRepository ) CharacterWeeklySchedule
DailyScheduleDiaryUserc \ rS rSrSrS\4S jrSS jrSS.S \S
\S \\ \\
4 S\ 4S jjr S
\S\\ 4S jr
SSSS.S
\S \\ S
\\ S \\ \\
4 S\\ 4
S jjrS
\S\4S jrSrg)SQLiteCharacterRepository
charactersdb_pathc 0 Xl U R 5 g Nr init_dbselfr s ^/home/james-whalen/.local/lib/python3.13/site-packages/aiavatar/character/repository/sqlite.py__init__"SQLiteCharacterRepository.__init__
returnNc [ R " U R 5 n U UR SU R S35 S S S 5 UR 5 g ! , ( d f N = f! UR 5 f = f)N0
CREATE TABLE IF NOT EXISTS a^ (
id TEXT PRIMARY KEY,
created_at TIMESTAMP NOT NULL,
updated_at TIMESTAMP NOT NULL,
name TEXT NOT NULL,
prompt TEXT NOT NULL,
metadata JSON NOT NULL DEFAULT '{}'
)
sqlite3connectr execute
TABLE_NAMEcloser conns r r !SQLiteCharacterRepository.init_db sf t||, 004/@ A
JJL
JJL" A. A A.
A+'A. .B metadatanamepromptr3 c
# [ R " [ R 5 n[ [ 5 5 n[ R " U=( d 0 5 n[ R " U R 5 n U UR SU R S3XTR 5 UR 5 XU45 S S S 5 UR 5 [ UUUUUUS9$ ! , ( d f N,= f! UR 5 f = f7f)N!
INSERT INTO zx (id, created_at, updated_at, name, prompt, metadata)
VALUES (?, ?, ?, ?, ?, ?)
id
created_at
updated_atr4 r5 r3 )r nowr utcstrr
jsondumpsr) r* r r+ r, isoformatr- r )r r4 r5 r3 r< character_id
metadata_jsonr/ s r create SQLiteCharacterRepository.create$ s ll8<<(57|
8>r2
t||,
!!% 1 2 "==?CMMOTS`a
JJL
JJLs7 A7D :C4 r? loadsr r
fromisoformat)r rB r/ rJ rowr3 s r get SQLiteCharacterRepository.getE s t||,";; [[]F NNoo& '
//#C JJL ;z? h $ $zz(+H4y --c,.?@ --c,.?@Vx=
JJLs 6DAD :B DDD)r4 r5 r3 c z # [ R " [ R 5 nS/nUR 5 /nUb" UR S5 UR U5 Ub" UR S5 UR U5 Ub6 UR S5 UR [ R " U5 5 UR U5 [ R " U R 5 n[ R Ul U UR SU R SSR U5 S3[! U5 5 UR# 5 n U R S U R S3U45 U R% 5 n
S S S 5 UR' 5 W
c g U
S
n [) U [* 5 ( a [ R, " U 5 n [/ U
S [ R0 " U
S 5 [ R0 " U
S
5 U
S U
S U S9$ ! , ( d f N= f! UR' 5 f = f7f)Nupdated_at = ?name = ?z
prompt = ? metadata = ?
UPDATE
SET , 6
WHERE id = ?
zh
SELECT id, created_at, updated_at, name, prompt, metadata
FROM r3 r9 r: r; r4 r5 r8 )r r< r r= rA appendr? r@ r) r* r rH rI r+ r, jointuplerJ rK r- rL r> rM r rN ) r rB r4 r5 r3 r< updatesparamsr/ rJ rO row_metadatas r update SQLiteCharacterRepository.updatef s ll8<<(#$ ]]_ - NN: & MM$ NN< ( MM& ! NN> * MM$**X. /
l#t||,";; OO, - 7+, -
&M
//* +
"O
oo'% (
JJL ;: lC ( ( ::l3L4y --c,.?@ --c,.?@Vx=!
; (
JJLs8 DH;H& A=HH& B H;
H# H& &H88H;c T # [ R " U R 5 n U UR SU R S3U45 nUR
S:H sS S S 5 UR
5 $ ! , ( d f O= f UR
5 g ! UR
5 f = f7fN!
DELETE FROM rY r r) r* r r+ r, rowcountr- r rB r/ rJ s r delete SQLiteCharacterRepository.delete s t||, !!% 1 2 "O !+
JJL
JJLDJJL9 !B(B 0A0 B B(0
A>:B B(B%%B(r r% N)__name__
__module__ __qualname____firstlineno__r, r> r! r r r r r rD rP r` boolrh __static_attributes__ r$ r r r
s J 0 .2
4S>*
B
)1D
J # $-1
B
B
sm B
B
4S>*
B
) B
H
C
D
r$ r c \ rS rSrSrSrSrS\4S jrS"S jr S
\S \S\
4S jr S
\S\ \
4S
jr
S
\S \S\ \
4S jrS
\S\4S jrSS.S
\S\S \S\ \\\4 S\4
S jjrS
\S\S\ \ 4S jrS
\S\S \S\ \ 4S jrS
\S\S\S\\ 4S jrS
\S\S\4S jrSS.S
\S\S \S\ \\\4 S\4
S jjrS
\S\S\ \ 4S jr SSS .S
\S\S \ \ S\ \\\4 S\ \ 4
S jjr S
\S\S\S\\ 4S jr S
\S\S\4S jr S!r g)#SQLiteActivityRepository weekly_schedulesdaily_schedulesdiariesr c 0 Xl U R 5 g r r r s r r! !SQLiteActivityRepository.__init__ r# r$ r% Nc [ R " U R 5 n U UR SU R S35 UR SU R
S35 UR SU R S35 S S S 5 UR 5 g ! , ( d f N = f! UR 5 f = f)Nr' a1 (
id TEXT PRIMARY KEY,
created_at TIMESTAMP NOT NULL,
updated_at TIMESTAMP NOT NULL,
character_id TEXT NOT NULL UNIQUE,
content TEXT NOT NULL
)
a (
id TEXT PRIMARY KEY,
created_at TIMESTAMP NOT NULL,
updated_at TIMESTAMP NOT NULL,
character_id TEXT NOT NULL,
schedule_date DATE NOT NULL,
content TEXT NOT NULL,
content_context JSON NOT NULL DEFAULT '{}',
UNIQUE (character_id, schedule_date)
)
a (
id TEXT PRIMARY KEY,
created_at TIMESTAMP NOT NULL,
updated_at TIMESTAMP NOT NULL,
character_id TEXT NOT NULL,
diary_date DATE NOT NULL,
content TEXT NOT NULL,
content_context JSON NOT NULL DEFAULT '{}',
UNIQUE (character_id, diary_date)
)
)r) r* r r+ WEEKLY_SCHEDULES_TABLEDAILY_SCHEDULES_TABLE
DIARIES_TABLEr- r. s r r SQLiteActivityRepository.init_db s t||,* 0040K0K/L M
0040J0J/K
L
0040B0B/C
D
5 R
JJLS R
JJLs# B, A BB,
B)%B, ,B>rB contentc # [ R " [ R 5 n[ [ 5 5 n[ R " U R 5 n U UR SU R S3XCR 5 UR 5 X45 S S S 5 UR 5 [ UUUUUS9$ ! , ( d f N+= f! UR 5 f = f7f)Nr7 zt (id, created_at, updated_at, character_id, content)
VALUES (?, ?, ?, ?, ?)
r9 r: r; rB r )r r< r r= r> r
r) r* r r+ r} rA r- r )r rB r r< schedule_idr/ s r create_weekly_schedule/SQLiteActivityRepository.create_weekly_schedule s ll8<<(%'l t||,
!!%! !--/3==?LZ
JJL %
JJLs7 AC(C A C C % C(
C C C%%C(c # [ R " U R 5 n[ R Ul UR 5 nUR
SU R S3U45 UR 5 nUR 5 Uc g [ US [ R " US 5 [ R " US 5 US US S9$ ! UR 5 f = f7f) Nz_
SELECT id, created_at, updated_at, character_id, content
FROM z8
WHERE character_id = ?
r9 r: r; rB r r )
r) r* r rH rI rJ r+ r} rK r- r r rN )r rB r/ rJ rO s r get_weekly_schedule,SQLiteActivityRepository.get_weekly_schedule s t||,";; [[]F NN112 3
//#C JJL ; 4y --c,.?@ --c,.?@ ^, N
JJLs 6C'AC :AC'C$$C'c # [ R " [ R 5 n[ R
" U R 5 n[ R Ul U UR SU R S3X#R 5 U45 UR 5 nUR SU R S3U45 UR 5 nS S S 5 UR 5 Wc g [ US [ R " US 5 [ R " US 5 US US S
9$ ! , ( d f Nf= f! UR 5 f = f7f) NrV zt
SET content = ?, updated_at = ?
WHERE character_id = ?
zg
SELECT id, created_at, updated_at, character_id, content
FROM @
WHERE character_id = ?
r9 r: r; rB r r )r r< r r= r) r* r rH rI r+ r} rA rJ rK r- r rN )r rB r r< r/ rJ rO s r update_weekly_schedule/SQLiteActivityRepository.update_weekly_schedule- s3 ll8<<(t||,";; 7 78 9
mmo|<
556 7
"O
oo'% (
JJL ; 4y --c,.?@ --c,.?@ ^, N
3 (
JJLs8 AE E A2D1E AE1
D?;E EEc T # [ R " U R 5 n U UR SU R S3U45 nUR
S:H sS S S 5 UR
5 $ ! , ( d f O= f UR
5 g ! UR
5 f = f7f)Nrd r r )r) r* r r+ r} rf r- rg s r delete_weekly_schedule/SQLiteActivityRepository.delete_weekly_scheduleY s t||, !!%! "O !+
JJL
JJLDJJLrj )content_context
schedule_dater c 4 # [ R " [ R 5 n[ [ 5 5 n[ R " U=( d 0 5 n[ R " U R 5 n U UR SU R S3XeR 5 UR 5 XR 5 X745 S S S 5 UR 5 [ UUUUUUUS9$ ! , ( d f N-= f! UR 5 f = f7f)Nr7 z (id, created_at, updated_at, character_id, schedule_date, content, content_context)
VALUES (?, ?, ?, ?, ?, ?, ?)
r9 r: r; rB r r r )r r< r r= r> r
r? r@ r) r* r r+ r~ rA r- r ) r rB r r r r< r content_context_jsonr/ s r create_daily_schedule.SQLiteActivityRepository.create_daily_schedulej s ll8<<(%'l #zz/*?R @ t||,
!!%!;!; < = !--/3==?LRiRiRkmt L
JJL %' +
JJLs7 A7D:D r? rM r r rN r )r rB r r/ rJ rO r s r get_daily_schedule+SQLiteActivityRepository.get_daily_schedule s t||,";; [[]F NN001 2
6 6 89
//#C JJL ; /0 os + + "jj 9O 4y --c,.?@ --c,.?@ ^, ,,S -AB N +
JJL 6D>AD) B!D>)D;;D>c
| # [ R " [ R 5 n[ R
" U R 5 n[ R Ul U UR SU R S3X4R 5 XR 5 45 UR 5 nUR SU R S3XR 5 45 UR 5 nS S S 5 UR 5 Wc g US n[ U[ 5 ( a [" R$ " U5 n[' US [ R( " US 5 [ R( " US 5 US [* R( " US
5 US US 9$ ! , ( d f N= f! UR 5 f = f7f)
NrV z
SET content = ?, updated_at = ?
WHERE character_id = ? AND schedule_date = ?
z
SELECT id, created_at, updated_at, character_id, schedule_date, content, content_context
FROM V
WHERE character_id = ? AND schedule_date = ?
r r9 r: r; rB r r r )r r< r r= r) r* r rH rI r+ r~ rA rJ rK r- rL r> r? rM r rN r ) r rB r r r< r/ rJ rO r s r update_daily_schedule.SQLiteActivityRepository.update_daily_schedule s ll8<<(t||,";; 6 67 8
mmo|=T=T=VW
445 6
"#:#:#<=
oo'% (
JJL ; /0 os + + "jj 9O 4y --c,.?@ --c,.?@ ^, ,,S -AB N +
; (
JJLs8 AF< F' BF-F' 5B!F<
F$ F' 'F99F<
start_dateend_datec
# [ R " U R 5 n[ R Ul UR 5 nUR
SU R S3XR 5 UR 5 45 UR 5 nUR 5 / nU H nUS n [ U [ 5 ( a [ R " U 5 n UR [! US [" R$ " US 5 [" R$ " US 5 US [& R$ " US 5 US U S
95 M U$ ! UR 5 f = f7f) Nr z
WHERE character_id = ? AND schedule_date BETWEEN ? AND ?
ORDER BY schedule_date
r r9 r: r; rB r r r )r) r* r rH rI rJ r+ r~ rA fetchallr- rL r> r? rM rZ r r rN r
r rB r r r/ rJ rowsresultrO r s
r list_daily_schedules-SQLiteActivityRepository.list_daily_schedules s< t||,";;
[[]F NN001 2 3 3 5x7I7I7KL
??$D JJLC !"3 4O/3//"&**_"= MM-t9#11#l2CD#11#l2CD 0 " 0 0_1E FI /
!
JJL 6E%A E B9E%E""E%c p # [ R " U R 5 n U UR SU R S3XR 5 45 nUR S:H sS S S 5 UR 5 $ ! , ( d f O= f UR 5 g ! UR 5 f = f7f)Nrd r r )r) r* r r+ r~ rA rf r- )r rB r r/ rJ s r delete_daily_schedule.SQLiteActivityRepository.delete_daily_schedule s t||, !!%!;!; < = "#:#:#<= !+
JJL
JJLDJJL9 !B6B! >A>$ B! -B6>
B B! B6!B33B6
diary_datec F # [ R " [ R 5 n[ [ 5 5 n[ R " U=( d 0 5 n[ R " U R 5 n U UR SU R S3XeR 5 UR 5 XR 5 X745 S S S 5 UR 5 [ UUUUUUU=( d 0 S9$ ! , ( d f N6= f! UR 5 f = f7f)Nr7 z (id, created_at, updated_at, character_id, diary_date, content, content_context)
VALUES (?, ?, ?, ?, ?, ?, ?)
r9 r: r; rB r r r )r r< r r= r> r
r? r@ r) r* r r+ r rA r- r ) r rB r r r r< diary_idr r/ s r create_diary%SQLiteActivityRepository.create_diary% s ll8<<(uw< #zz/*?R @ t||,
!!%!3!3 4 5 }}
OcOcOegn F
JJL%! + 1r
JJLs7 A7D!:D r? rM r r rN r )r rB r r/ rJ rO r s r get_diary"SQLiteActivityRepository.get_diaryH s t||,";; [[]F NN(() *
3 3 56
//#C JJL ; /0 os + + "jj 9O4y --c,.?@ --c,.?@ ^,))#l*;< N +
JJLr )r r c
# [ R " [ R 5 nS/nUR 5 /nUb" UR S5 UR U5 Ub6 UR S5 UR [ R " U5 5 UR U5 UR UR 5 5 [ R " U R 5 n[ R Ul U UR SU R SSR U5 S3[! U5 5 UR# 5 n U R SU R S3XR 5 45 U R% 5 n
S S S 5 UR' 5 W
c g U
S n [) U [* 5 ( a [ R, " U 5 n [/ U
S
[ R0 " U
S 5 [ R0 " U
S 5 U
S
[2 R0 " U
S 5 U
S U S9$ ! , ( d f N= f! UR' 5 f = f7f)NrS z content = ?zcontent_context = ?rV rW rX S
WHERE character_id = ? AND diary_date = ?
z
SELECT id, created_at, updated_at, character_id, diary_date, content, content_context
FROM r r9 r: r; rB r r r )r r< r r= rA rZ r? r@ r) r* r rH rI r+ r r[ r\ rJ rK r- rL r> rM r rN r ) r rB r r r r< r] r^ r/ rJ rO row_content_contexts r update_diary%SQLiteActivityRepository.update_diaryo s ll8<<(#$ ]]_ - NN= ) MM' " & NN0 1 MM$**_5 6
l#
j**,-t||,";; . ./ 0 7+, -
&M
,,- .
"#7#7#9:
oo'% (
JJL ; !"3 4 )3 / /"&**-@"A 4y --c,.?@ --c,.?@ ^,))#l*;< N /
; (
JJLs8 C r? rM rZ r r rN r r s
r list_diaries%SQLiteActivityRepository.list_diaries s< t||,";;
[[]F NN(() * 3 3 5x7I7I7KL
??$D JJLC !"3 4O/3//"&**_"= MM%t9#11#l2CD#11#l2CD 0 --c,.?@I /
!
JJLr c p # [ R " U R 5 n U UR SU R S3XR 5 45 nUR S:H sS S S 5 UR 5 $ ! , ( d f O= f UR 5 g ! UR 5 f = f7f)Nrd r r )r) r* r r+ r rA rf r- )r rB r r/ rJ s r delete_diary%SQLiteActivityRepository.delete_diary s t||, !!%!3!3 4 5 "#7#7#9: !+
JJL
JJLDJJLr rk rl )!rm rn ro rp r} r~ r r> r! r r r r r r rq r r r r r r r r r r r r r r r r rr rs r$ r ru ru s / - M ,`
<
.AY
8*
*
*
. ! *
X
C
D
. 59
!
!
!
!
"$sCx.1
!
!
F%
%
%
- %
N1
1
1
1
-
1
f& & &
&
m
&P
8 59
!
!
!
!
"$sCx.1
!
!
F%
%
%
% %
X "&48
@
@
@
# @
"$sCx.1
@
% @
D& & &
&
e
&P
r$ ru c
\ rS rSrSrS\4S jrSS jrSS.S \S
\\ \\
4 S\ 4S jjr S \S\\ 4S
jr
SSS.S \S \\ S
\\ \\
4 S\\ 4S jjrSSS.S\S\S\\ 4S jjrS \S\4S jrSrg)SQLiteUserRepositoryi usersr c 0 Xl U R 5 g r r r s r r! SQLiteUserRepository.__init__ r# r$ r% Nc [ R " U R 5 n U UR SU R S35 S S S 5 UR 5 g ! , ( d f N = f! UR 5 f = f)Nr' a0 (
id TEXT PRIMARY KEY,
created_at TIMESTAMP NOT NULL,
updated_at TIMESTAMP NOT NULL,
name TEXT NOT NULL,
metadata JSON NOT NULL DEFAULT '{}'
)
r( r. s r r SQLiteUserRepository.init_db sf t||, 004/@ A
JJL
JJLr1 r2 r4 r3 c # [ R " [ R 5 n[ [ 5 5 n[ R " U=( d 0 5 n[ R " U R 5 n U UR SU R S3XCR 5 UR 5 X45 S S S 5 UR 5 [ UUUUUS9$ ! , ( d f N+= f! UR 5 f = f7f)Nr7 zm (id, created_at, updated_at, name, metadata)
VALUES (?, ?, ?, ?, ?)
r9 r: r; r4 r3 )r r< r r= r> r
r? r@ r) r* r r+ r, rA r- r )r r4 r3 r< user_idrC r/ s r rD SQLiteUserRepository.create s ll8<<(eg,
8>r2
t||,
!!% 1 2 mmos}}T
JJL
JJLs7 A7D:C2 r? rM r r rN )r r r/ rJ rO r3 s r rP SQLiteUserRepository.get& s t||,";; [[]F NNoo& '
//#C JJL ;z? h $ $zz(+H4y --c,.?@ --c,.?@V
JJLs 6DAC? :BD?DD)r4 r3 c ( # [ R " [ R 5 nS/nUR 5 /nUb" UR S5 UR U5 Ub6 UR S5 UR [ R " U5 5 UR U5 [ R " U R 5 n[ R Ul U UR SU R SSR U5 S3[! U5 5 UR# 5 nUR SU R S3U45 UR% 5 n S S S 5 UR' 5 W c g U S n
[) U
[* 5 ( a [ R, " U
5 n
[/ U S
[ R0 " U S 5 [ R0 " U S 5 U S
U
S9$ ! , ( d f N= f! UR' 5 f = f7f)NrS rT rU rV rW rX rY z`
SELECT id, created_at, updated_at, name, metadata
FROM r3 r9 r: r; r4 r )r r< r r= rA rZ r? r@ r) r* r rH rI r+ r, r[ r\ rJ rK r- rL r> rM r rN ) r r r4 r3 r< r] r^ r/ rJ rO r_ s r r` SQLiteUserRepository.updateF s ll8<<(#$ ]]_ - NN: & MM$ NN> * MM$**X. /
g t||,";; OO, - 7+, -
&M
//* +
J
oo'% (
JJL ;: lC ( ( ::l3L4y --c,.?@ --c,.?@V!
; (
JJLs8 C H G= "A=G, G= 'BH,
G:6G= =HHd r )limitoffsetr r c \ # [ R " U R 5 n[ R Ul UR 5 nUR
SU R S3X45 UR 5 nUR 5 / nU H nUS n[ U[ 5 ( a [ R " U5 nUR [ US [ R" " US 5 [ R" " US 5 US US95 M U$ ! UR 5 f = f7f) Nr z[
ORDER BY updated_at DESC
LIMIT ? OFFSET ?
r3 r9 r: r; r4 r )r) r* r rH rI rJ r+ r, r r- rL r> r? rM rZ r r rN ) r r r r/ rJ r r rO r3 s r listSQLiteUserRepository.list s t||,";;
[[]F NNoo& '
??$D JJLC:H(C(( ::h/ MM$t9#11#l2CD#11#l2CD[!
JJLs 6D,AD :B D,D))D,c T # [ R " U R 5 n U UR SU R S3U45 nUR
S:H sS S S 5 UR
5 $ ! , ( d f O= f UR
5 g ! UR
5 f = f7frc re )r r r/ rJ s r rh SQLiteUserRepository.delete s t||, !!% 1 2 J !+
JJL
JJLDJJLrj rk rl )rm rn ro rp r, r> r! r r r r r rD rP r` intr r rq rh rr rs r$ r r r s J , .2
4S>*
>
C
HTN
H #-1 <
<
sm <
4S>* <
$
<
| *-A 3 c $t* @
s
t
r$ r )r? r) r r r typingr r r r uuidr
baser r
r modelsr r r r r r ru r rs r$ r r sT - - , , Q Q J Jm 7 m`q 5 qhC> Cr$