# v2 git bundle d86f5f6c17160ab07b6320bea1ad426679259156 refs/heads/bundle d86f5f6c17160ab07b6320bea1ad426679259156 HEAD PACK#x7tree 3ade6385fdbd698d232ead16c80e43dfad3fe2d6 author R3D347HR4Y 1779458573 +0200 committer R3D347HR4Y 1779458573 +0200 Initialize Ulti Backend project with Docker setup, environment configuration, and core services. Added .dockerignore, .env.example, Dockerfile, and docker-compose files for PostgreSQL, KeyDB, RustFS, Authentik, Nextcloud, Jitsi, and Immich. Implemented main application structure in Go with API handlers and environment variable expansion. Included README for project overview and setup instructions. gxK100644 .dockerignore!S#cU|.-U100644 .env.example(laS"5W100644 .gitignore91oF*qse` 100644 DockerfileEtkJ>WdtY100644 README.mdѴaY 3N2s40000 cmdsa{q0:jEhq40000 deploy1qb8֬O©100644 go.mod ȧI fjL100644 go.sum|$AZmPO5240000 internalxDLm#*_)40000 migrations ڌ˵R}==40000 project-plan(/XI7[T L d᫟xO.git .env project-plan README.md .gitignore .dockerignore .idea .vscode deploy &xYn<S: $j-˕ KDR0W}>Gdd$ˇO hQ 9o|zS{aJPqH[2/%qhc?)E][:7u^DQ!}&`J6a Cğ,%!-CpdKm; `y|)g9z(|%.D{tՃoF4v ,t_w޼ۘ*nX6[$l62st U e($(oNsrixSNŨ>Et6;<7Hp7w/= @2FHIBhC#?O::2!vߵZMJʲ\Ĕmj׶[/xs.tsh{4mU(yEH|K1yiO: %jLD}Xݼ)ڡb 6bB@MTMJ)W|{-8J=Y_żuȏ>%kӕjOͯ\'hx³<+^քLbҝ+^v>2{mDnx,\$kx"d-hJǵ (|St'|uRje`U+^&ݷ"<먎VݍT-dY4Yc*^W?E ۮ' 6`w fU0x*(@P,< OxTR6d$5݉<)݆-H{b-Yy}M uV]@WiWqB M R }HT[Ȅ?V>hNo0"|<'΂|i؟$esK`]կ%1>N0zXU_;8c 2CkޱU:G&=dzŚ-0րR1ͭr8,va]{4͢f؜4/uZc8Λ>i_u|Bnry +x%<-\(ă)\4n&TE/Q&e~YΜ*GvmP jyR7h`ʪ;0a^PL=aju0G e@s:W 8K(;_.zڎ#+3LSΘ o\co~ZX*$8`! b y$ن3B&?S$kvB1P6N^ e.pIНx~?N@{=fʟ;ȃbM( 0b?9Y~]ExS~LUIĵMwa>ƘY#{S ^tOJHHP. :$fTH[Jy 2ېN{'Wz׭ٓ*^SmzVuuV~5{NtnNy)Bj%ڜcSA Q͛VkxY.B?;;x5j1 D A$?!Æ^w-Sl\]zy#fF$q`(( < N!(/U3Wfive LYg)ܵhuȪ.$]D;(ݱ-`'g<'V:jf/J"8eO-dީ-Pށg,DSxuPn0+V9pۄ!@! 6EmU;V8cQP5;;;>A?"SrXdprRc`'0!ȡ p<7'ͷ` W:za3贯pW2A<]#Κ@iTp>a6zNhlk?e/5yШB1Sg@RU%XG!NDʐDzĕDK_!;y$F.&:?Zǧa稹wi9Q&1;ۧ^|&7)B(ڨT҃d7 ljORun(HO&dH٘GmT4N >1E2"v 3:9Y"<-XţgX)bfIc ;ZDo@aIщȲ+"9d.4Pvxϒ6\edo\8͆٨E\\K۷_ 6LY83TȬc㭜\{=<}C(BZ2Bn2qb*u1fAy]Ga:003yt7j8S [, a!Hp5p{^L[j:v3.0q a) hh|FU:|89ܝN&P*givA{oyȾ| 7T.ݷOQk4MiW5a7QVnۗMl0%ũ p| V-tAhk8lt|qN{u[uCy)q7˸N)z4];{ڹ'GO#ƪFF#]G$O,egYfI`v UV8}&_rFJeh5eW7ڡ=Ym&FC+g* Pv>c}_f1qTkkzwގW*zMzFM [cIYWPRʮe7"H2MQIL&V޳=s4솴s=|L`ҠiVv4w$6=W 'ncD_dzU~y3ymF)wm#~l52oCtЅmӕ<k}m(gXwp+r扸X;%F2 WtW2zvYێNfReu"9_n^O%ʸ8Kd26ƭDKƛBܒ@W^nWrrѦm_/}c:fq>U&٘zw7oݥCs^LP#4΢_yM0@.դxD40000 envexpand-u2& Q:f540000 ultidR`x=CyBGe9X~'x#100644 main.go'p u]8pm ȶ xpackage main import ( "flag" "fmt" "os" "github.com/ultisuite/ulti-backend/internal/envexpand" ) func main() { in := flag.String("in", ".env", "input .env file") out := flag.String("out", "", "output file (default: stdout)") flag.Parse() if err := run(*in, *out); err != nil { fmt.Fprintf(os.Stderr, "envexpand: %v\n", err) os.Exit(1) } } func run(inPath, outPath string) error { if outPath == "" { return envexpand.RenderToWriter(inPath, os.Stdout) } return envexpand.Render(inPath, outPath) } gx#100644 main.goulmmzCrȇ ٹxkoH3^K7213;.7;n^ da@o&agWU6!ɒHg׫+ p*i-VTgpO"= ?8N-p,iH'z0+afςHz y-EI;Q/[<~2)ƑH [^E<5"L$aChdmJ'F\NӸ'@w t 3 c .Lkz(\}2hsJ`ΎG8ܼ JqŸBgKi~u y,,ő@<],Lcw;?JPmxXޤxH9NpǛF /Jd .;Pc=1ѷUk X @C ?|210Y ,"_s%悫1Ԣ@Xs{ˌއ*=< Z,k~3$Q\ڜq4颳/Öh!c}dGx9'4kgP5@֙r"1&R=V˻xa<܍n4;h0\GW֡Jv vTjbկmWiqvTEZElmnV^PEiqDD-yx9`{lO4gb/!(]0΅z;B6m/5\d% 1FjC!0݃JmJwrܢ,,-3^]:Gc1`^5evR ])D5J $-@pjp2}|Q@(UPNq:W"URUNG %TJN/ɋ``'8tgaJY>'8 t?.έ-4i;$Ub:UpN޸P[jgV"ZVA;$PyU"A[5H|6P`?%25Φ!VmIGt()|[Ec%!6E' ]9T턘V {Hq:73  YY;쩂 a j-K-p&[Wx!%pRI"x|BX$_FAx%7K7|M"o'{g?+tjR m#VR$Ss:dXVT-O-CG *ueƋGBI*g~63Tέ[EMUɕAtp awcvg5w(8wnYp0.7m UMDV%{cAZ'4 \5=l[[EYYGPvYmBSt溬UE~UPtUq;kyU5eevA<{ kӊZOiz'|eI}K7Rz:gLum(0X2LՓ]ɦ$rήBI[i1㸂{Ur |BC1ݨ?|(f$V:z:O:P"WDŽV ۢQl>tt{isx *|gn|J\!OQxmT j)ejV*PДi\R(d&_X]s"v!+Y5au=j e ^phmȲK@ l~窏{! C.8>2l YF2?5x100755 compose-up.shGC9zqgIj↋100644 docker-compose.ymlu `:aI&W240000 immich&XKf0fXDy100644 init-db.shI *Z*Q K40000 jitsii!%ɛ8sOu40000 nextcloudOħ2X^/໘UC40000 nginx%8f>9 i2]DגGRhZxSN0S k$Ju &UrQVm=ĞpO2'iRZ&vM䜿>{nw"")L>g1mk,2sqy6ail%bZ)zFY L³7qX]B+D*_e&lM/K~80E%0Ʉ:d6؎ʬ.c?f_~=(%[, TI2yFv^Q8QCnS),!M9dqIgR=g+oL\firz"k}prRT>3fY<@l"{k}lVYqGs;dr}!Qw[f2} Xfy()U1Fm3U]}ecWԢV-nk 9Yʥʼ]u`cUm<8 Aېa(xˢ>3PUΧ9: %|xV[o0~WXK uyjm)2I,BچUىC%ЮB w9vsHB<tB)MHs"$$&BXB4%8K`EùhԳ9gSR0s 1Y,%c[i#IHd` LTr$ɜrLI" M'fe,@qĄ\6j mfݱxnN-g&)IYR(h1.^Pyb*gTtbi92h $yz;,ﱳZ,eD$|*zS!zY?2u \GE~'TQsQSfYp"9U**!iŝdFeBx}>r?@ [+@Ѷ&c$Ø`?P JK*-νG䖘Sݮ`)IV:?Ɋ[VOx5100644 docker-compose.immich.ymlÿZ{zEKWxwservices: immich-postgres: image: tensorchord/pgvecto-rs:pg16-v0.3.0 restart: unless-stopped environment: POSTGRES_USER: ${POSTGRES_USER} POSTGRES_PASSWORD: ${POSTGRES_PASSWORD} POSTGRES_DB: ${IMMICH_DB_NAME:-immich} volumes: - immich_postgres_data:/var/lib/postgresql/data networks: - ulti-net healthcheck: test: ["CMD-SHELL", "pg_isready -U $${POSTGRES_USER} -d $${POSTGRES_DB}"] interval: 10s timeout: 5s retries: 5 start_period: 20s immich-server: image: ghcr.io/immich-app/immich-server:v1.120.0 restart: unless-stopped environment: - DB_HOSTNAME=immich-postgres - DB_USERNAME=${POSTGRES_USER} - DB_PASSWORD=${POSTGRES_PASSWORD} - DB_DATABASE_NAME=${IMMICH_DB_NAME:-immich} - REDIS_HOSTNAME=keydb - REDIS_PORT=6379 - IMMICH_MACHINE_LEARNING_URL=http://immich-ml:3003 - UPLOAD_LOCATION=/upload volumes: - immich_upload:/upload networks: - ulti-net depends_on: immich-postgres: condition: service_healthy keydb: condition: service_started immich-ml: image: ghcr.io/immich-app/immich-machine-learning:v1.120.0 restart: unless-stopped volumes: - immich_model_cache:/cache networks: - ulti-net volumes: immich_upload: immich_model_cache: immich_postgres_data: ˤ x6#!/bin/bash set -e psql -v ON_ERROR_STOP=1 --username "$POSTGRES_USER" --dbname "$POSTGRES_DB" <<-EOSQL CREATE DATABASE authentik; CREATE DATABASE nextcloud; CREATE DATABASE immich; EOSQL :8Ӥx4100644 docker-compose.jitsi.ymlN cw8.\g݀wux_x-jitsi-env: &jitsi-env JWT_APP_ID: ${JITSI_APP_ID:-ulti} JWT_APP_SECRET: ${JITSI_APP_SECRET:-changeme-jwt-secret} JICOFO_AUTH_PASSWORD: ${JICOFO_AUTH_PASSWORD:-changeme} JVB_AUTH_PASSWORD: ${JVB_AUTH_PASSWORD:-changeme} TZ: Europe/Paris services: jitsi-web: image: jitsi/web:stable-9823 restart: unless-stopped environment: <<: *jitsi-env ENABLE_AUTH: "1" AUTH_TYPE: jwt JWT_ACCEPTED_ISSUERS: ulti JWT_ACCEPTED_AUDIENCES: ulti PUBLIC_URL: https://${DOMAIN:-localhost}/meet XMPP_DOMAIN: meet.jitsi XMPP_MUC_DOMAIN: muc.meet.jitsi XMPP_BOSH_URL_BASE: http://jitsi-prosody:5280 networks: - ulti-net depends_on: jitsi-prosody: condition: service_started jitsi-prosody: image: jitsi/prosody:stable-9823 restart: unless-stopped environment: <<: *jitsi-env ENABLE_AUTH: "1" AUTH_TYPE: jwt JWT_ACCEPTED_ISSUERS: ulti JWT_ACCEPTED_AUDIENCES: ulti XMPP_DOMAIN: meet.jitsi XMPP_MUC_DOMAIN: muc.meet.jitsi XMPP_INTERNAL_MUC_DOMAIN: internal-muc.meet.jitsi networks: - ulti-net jitsi-jicofo: image: jitsi/jicofo:stable-9823 restart: unless-stopped environment: <<: *jitsi-env XMPP_DOMAIN: meet.jitsi XMPP_MUC_DOMAIN: muc.meet.jitsi XMPP_INTERNAL_MUC_DOMAIN: internal-muc.meet.jitsi networks: - ulti-net depends_on: - jitsi-prosody jitsi-jvb: image: jitsi/jvb:stable-9823 restart: unless-stopped ports: - "10000:10000/udp" environment: <<: *jitsi-env XMPP_DOMAIN: meet.jitsi XMPP_INTERNAL_MUC_DOMAIN: internal-muc.meet.jitsi JVB_PORT: "10000" JVB_STUN_SERVERS: stun.l.google.com:19302 PUBLIC_URL: https://${DOMAIN:-localhost}/meet networks: - ulti-net depends_on: - jitsi-prosody ,x~100644 docker-compose.nextcloud.ymlpJ߰iBiyyӢ100755 init.sht>&IJ100644 nginx.conf}~ϤU Ůw2 6¹xUmo0_ai2Z_2Q am5MQb1jکj%w<'w9%bAG0r/C8Nf:'XGV# B?N(#9DTB`b0&dF]g]zu?*Ae~®iv;2]p+3\^1O8=rh4НҖi"3AmVQ e c?N!jŰ^zؽP[rn}%tخmVѴ~FR&{7ض֞UVG]oz.Vi*ʽnzjg@?mЛ@?Ϭ< g! }r"9+P]`eTBL긋S&a4Zv!ej:ű $xb!cK ;wS%H0-R:=/e>Z% pL1x|J~xJU~lVՒtzD >mQҺ‘7K<,[7l ʞ a-[[7rYyaxT]k0}B-c58 `d&%Mu}ndMs=HGoRUOqcS.MI+_T3GF'3m A$!@8ZJ A)`+Bq12FpRS=6>+w7aE5׋zkPh\h v Io`8Puu? ڌgUFeh)V3Ӓ= צgsfb,hX{೮2mI2@?> R7EFBсJ8z^f^ I64"I ޏnr4-F,i?=:?f?% 6KXEjء[ez v|u8^M.diJ&8R7"Bt,=i@dt (q 8v ")Z;k'Լ 3xiEk؃AMw{5HjykxkPwIf͞Hġ7/:WА :@BheKĶURix hyP`9(ƺ0VPXc:J'ݻ#Xh݈8Ѿ;ФnqHZqxn:>J1D(xeQEϳ8 -r:xRKo1a *͡P P*豊+m<<`oyB3=<ڀ)hXpBd? B拃yַLMˢv7`^ɝhAE"V٬nf5oĜZp4߁t$kǭ:gKwںX,l*{]lTu./ƭ`BiS5czU1-r V>)D7#JG ܂ k#&!/%(;4@jW-ivv`MA 7N{6_1N{-{BbaQK|x{׷_wf5+mU2( iqҶ ~gĿ)!t¸QBV}wO7/W"#Nkjz 5i&5i+d<\ 6L9 <6ȭzlY'x1100644 default.conf.template0MLNyM#R.HxVˊ0+./Eb{ 4!2c: tQu#KBG %r& 4JW Fstu>bp#Xg+x up+FOZKpɅX=%gpc4+y&)QހJ hH r*#jKzBK.GI}&4WWAJ%)iV%b^~A(۰2%)Cƭ̶i,f!~*HѿQw`bQq͐ }>v? Wݫ[HV& 7-(b Xl&m(P֙` +pև[_{;uԠEN_llѝ ^Cw_/Uax?E/(`Ε" L&hhH?%k>htr#Q*SC;/4.Czԋ=Fvr9zvEoLp XXY@Vd P<ϡsO2'iͤ[x}TI \`ٵt㐀JGڬ7CgO(USQc|;]=:o`2^"T41̳$q{2NɯJ;G_FG %IP0ct;,8Ӌ.t()?1)xe饬\~\))֐eok~s6]t2j9.6Ϩ$c3ߣzocoߴ$(=ʬ694i2ϭsT̠"A7j-ɠO(Ni3NeV纤)E^Uv`~l:^F/ꀳi0$UpB!vXK8E?F= tvyA`Q9`-ʧ{%'_2q'%u%U|wy%JqF.o{Lf.' Gſq^kLuOWF?1z1W:u~GwC|B+]hdSB h@n{ XpO"EhYfcJp=]l0‘-!Рvۆ<'np96Ιi&nEeh.ð?b>ɽoFDn$S3 f(5Gonmi l) HZ(=G-=?\s#]*1o^[!Yt/1*}i [kp%=85OlįD':]x#F7MV'DK>oB3`uW#nu؁oU{;S?@[آ_a]Zm~wɏ@ʶ\|HԶ+b%xN 4-ti5;Nʘwxrˑ_)3 L2:7>#s:]\ 7a(9zfOOo($LxG\z-O!W} 1L|IܮxJN E<A%v 4êP>ڥp Lb_gjs#S}?4S19?F+n`Vʮ_[-a`zcP9ZШO< LPZ&˒AX$O'Ng. r3Er1wfQI(WOR9FGgqI8&. sN-AY~{wwDӵp/I WQ2P/u} .|8bz : -@N oόzMohO;3YȥvFEDrWIynY?IL>LǕpZSp슸8zǘqOՊEǪ-D0=WcBIAA=$'wNBY;@IbVw_G۸;h9t0ic-#hVke9{?> T1׶Zt*^ QNzckR"rWWzG[5͌xl?W.#'ϰe2[g$a F$ 1E|Ce+>K x(M!O:.>|< 1;~1t-Y2XCFfw)9R?ddp)rVss5cR6W 2<0GZyѕyU2*8cňזYX[ 9NО$rrBLc< a T|5g`7nEi /0jt T“TԚ{o:IXN;_Sˉ3K zr@ .le "`mk.DK+優CRLnubqvǔb{5OcJOccaFèBc嬯Y!NuG & ;6|qhϫf vIdHj!-+UwDJDu:cɼwQju-/2~TNU Ae6qk!\d:?m 7q\pe(};ஹk#AQ;tM[*v>֏~*bVRvX#Ryd9+ҭˋ'эEcT~ - @HCCNlj (Ӯp$פBx*zlz@TҧIMZ>\yT$qU,.9k |$Ja8WAKܾKjZ / w}~҂ V6 hT&Z? ܶ׉n&aV_chyF_*nI ', RTqωG\/S #bwjqmV.gtC7@ߒsUSL@D(c8([{c1;Ob[$`!BNN.xrQ (ΕqSS,?rQd'N3,O/-S}M ޻B~Յ[u3Kq`B! A`|}Av}A.TR /ޢMuL0Q8A,njLF̪6{p`o;oA8>6:A P"|LV@#du~/Q(b7qد OY73:dhgNCad_z? q lD=#0)9+W4KF&H\e /;ib eԖ4B+-<_޴i._!Zc*LJ](xkj{,ۼO0Nl=q֘o!.m;E Pes~0ZsWJ<195=x( f_8 ߂ Qs W# lO)>Yش_TOwn'$(w[]9kw`l/.E'toeTnn0j(-9 #{ϡgXDw"ݼU3[*%!Co08ۉV8ׇm[w|4c Bڧ^2H#-]ŧLB8׈U8Wygl=Ʒ-o[@men;Gm[m?D 7/5mOk3+4Y84*{R. I}.}8k/]vjZ@JPMI JY3=,ä}.c=SYWk='ZϪ]\fGF45~Xw>s$HI=3.i䯄:!Kru_*[D=0jXΤi}u79yk)G;KƦukA EaO8x?G{5>]93 99@Tpw:қ(ltܚIqG:R?A2eJƝ:7nrKsxn*DÏRE E.A!>ᓱfzh@yk Pj40000 auth|6Ûu40000 configsU%vhnH.40000 envexpand#lROt}rOLv40000 maild5׭'?Fm40000 meetLx?hZad^r:40000 nextcloud)g$|ob Y:n40000 permission e%Pu("S1@޳40000 photosCW^dA4[40000 realtimeUcN ¡|`o40000 search[vbvbΰܕ_7q40000 secrets1rG햄"!u40000 securityaudit>qVlnq} 1WMxf40000 admin8cq>ަh9`p40000 apiresponse*ܖG V{40000 apivalidateSU5[w\Tps40000 calendar?N>-40000 contactsVpoHh]䪞^24]40000 drive}6 #eۅ`ָ40000 mailW`.VȔR40000 meetc?(igD40000 middleware .G5pSot40000 paginate!Q8[+ã*m40000 photosHIza40000 query{pY"dpv_cdxt100644 handlers.goYT͹Ӿ݈59!2i100644 service.go32$Q=hЅ:|100644 validate.go"[c+tp KB+KKPٸeC-K:uxųK@=-W (O=!xt%Rz&y$7v3ٯֱ IsO㶹+;c{i;7;= fst2|2KŚ\Ez%E)z%J@=]jSRJ\\̒TMbtMeHkBLeQ;kC$ĜbԢ"+[dTO-1هU3.0YKckV~(&ɲA<4HPk5}h>B$R7 c}fMPIcK?p4{fbċghfCnn0d7qhקv)Z#!4TXIs3$q6\Œo(˹ԣV=0P( zK׎ 5vUehp'M|Inu9eˏq׺Wo\1#'-'$hZY_;Sa6%~n>%NJr,˂x t9C ZN_YT R6dzz;.HoeDRlyrSJWF(peYUZje~{2ԅjFt(bq]Qǂm(b6u.(jSDLgzlH}ܑHqVȊF2'n&5d uN\}.)MYh޶ [])]b4(Ir9N|#=9PNPa(bXTOG۽ڻGW#+瓵 hebWoU|lokMdZ2xXmsF~E!RFvڤ-2Ctlp nȇt% I߻w6vI}}voWK3x#82jGR\InEA8"BIwxHe7P~XM\?^4>]522WsP {1-" !D|˰y%kaRᯒP^Ua| % * X)#݁(lt`#| }R|ɾ`\ßQ# @-ItL$FmNWx 70g X uJ6{)Z%B5 (h4 &'% sŨwYgx:[mvp2"ӳbi -Ka@R<(Ȝ jGN[pʋp{3W{+ЫL8f걶ZK["}3`饊3ٜW?_bOJ@f{T-W'cx<}WuyeUE0A0u_Whz\KCNXJr37ezѢN9ti+[ڔW d6E@sVݳ+8UM:@}>&J[UQ=D>1(ڋ̬\-^^Y)ZȲo|] ձP*N/6!+xMO1@_1iࢉ`Mbx5; Ncva1&:~׶J%v 5 d`OvHxv(q-m5"2#R7>J1n[\6.VRBC֏1`W0Źun=vqN0EV˗]By<|jgOS4,3W 0#Go;#r~=#4Yv~ NWrB?y0"ۈ}MKFl^b6^\;i?],xz 19;1=U!1%73o@h&Wr~^qBnbE`i~IbPjaijqS~JWIeABqj ⒢j.NĊ"N% y%f& YyVJ@!I iZ.Ҽd5Ĝ̔Ē`E Zh6M~Ǩ*CF`: @Rn)бI yyy%e72yhؠL[0soXx100644 codes.go&F*qHL0100644 errors.gogG #\TaŁ100644 errors_test.gof"@K 5],c100644 response.goEq/88^jHlƘ100644 trace.go6O'vEmYM100644 trace_test.goׂ= {^P0$[@&xn E+v|AQH}L\¸cBF*+axPA eZ ^˷veM'[qכ>|~x8uw(q/D/P]"OoҔ~C)C %-;g;iv Dc94N8"%[c]aJK[03HLga=Ϯ^v L)q,*A# 2mfwTam{5 Ym..8$]3ԧm4z(8'=2*Z膇Eoraӂf"2Knү}uhKFKa [^w5[ZuK944)T'֦-0j'ZCĐ:58na%猪l1lAN;!2x1/)NhSL&N62ԛ%vgĞ8u'pT1duv ԡV S-j4UaG,god*>Hss#1tQw(Ǒɦvy"o LmM4=+֐2ֈb 1L-G {'+cOjǡp焳k秴`&L!KAygl-žuԪΰ)M%~.50?]oL: xSAkA&ِdWlE!nՃH `1 Iilζܽ՟ ͣB7MVZ1}oõք/D4Z7mlNy),|{"VWztÆu_ՇC}H.ٮ.K`ھ&"T2$nBOl4&_,Tsuc[9 s 8?{N5Mz]t,Sc Hp#\@F!o1Z2ߔKvX@u; I|-^{8L>V.f ח-2n^)hnm<ȏ'yYl$D@ Nm7+ LV_4 WjZ3RW!c}YCFh. G %?RntcN(o^.KsF݂㨓=% $Q.]`{1'wzC<%7b>OSY1Agx:C 19;1=U!91'5/%hrf#S;e\RJ4RAV^jEIrN~iXx;F%"Ԓ̜bč:Kss*5lm89ajm i@tz%2SsR!:t|Sf(jrqւ1ZSXTB%pK@X5/x aeř qf`RKJ2s@&{0sCiN> ~؋ޠ x_100644 handlers.goۿ F u>qx 100644 service.goԴem<AV100644 validate.go7-yrHxvqf100644 validate_test.got;cِCa.>xJ@ S9H+ޅ=GOWΤ58)3YXՓ^Oߗ!NAjyI(g0y}+y(^%QJNJ )X`,⡒^ȋ#ė [Ż?txFF_W}f~@Ȭ0p[ç۸UM?]ϒs-c}5ԿSi3 |xt100644 handlers.goej-ei_fHuAq100644 service.go/W{(100644 validate.go9}PUtr<;Yq93-i/"XxTJAI(V.JZ(H"jԴR f'ffg$H\P)^'(}_333*xg|̞岑[bã~ #7"Ba!y%es$OSc^ ?}:۸'`#SŮg;1՚xuugۏ٦x/zRu6gvHj^CJyW29G>Y2}r{b7ĩ&Ĺ~2(y Qgz }A2BtA#[4\$2E\rw"'MJޭߊX]>=xuSMo@U׍-! )LU*EPT=n]ww]Z+8s7pC•?]QSvv{3o?|t.B!xu76kCy\ l]"$D[߳5߳d2LyD3/^ F{Lշm\VSZ:a 9g<0$>t:UGމBa냈hKMQ@>۬NtvV'FzzOũj[]+&t7,=¢CHHcm +1*L~!{CROOI/3ș0RVq%cVbJP?n-ol[,כMcUv;˂<RXF/7M,xN`^-ٻ)ߴ.}"F Tj֧pmi}Z(O|?+i:>4JbnC8{%wB"va'dTt[_̢En=0oZ-S+ THsxmJ@`WE/< jQ`"BlvlM|A}wC"vO7|.'< dv Ts#*qM;A{!5 )AL WpH UƇ0x2SjƱb9^)iB'gaE/J䖠c)wH}K9?_:vn T+@:M\DPrGX,`5X/Ԋ 5ޘA+c,`aCϤxY6Qd|5[uLTYͺ jx51=+xt100644 handlers.go_Du*5'100644 service.go G6F"ϋbf100644 validate.go:7g_ q{C8.0xr6|dԗta4ݴl4݇Nl46ėIf8G~81M 9=01U CuJD8"wR1*(m4|6$0#/ϲdHD]!Ma)NBSϳw- Nh:c bׂ=ˆℯIT0*pS:㈇81@NO"?G7MhDzGqgP$Sߡ#c "x6eAՒ|)V,裣C`Q1K"=#a`Đn!G t@dAc|ez. >r߂\TI*|tpGꁺѼwj 8ӫǂGQVQpAxo| s9FS ?ShO& `IvxS$Jpmg 2m@0CeE c.NZcǼIL+8Q6{ @}4zVcId}02uH9䙊(Ո|AH]ঀlymeelhn"+oVͱ~n bsϪOPF`QOoj#om۬NoUٶR i+DY\ },~7ì ,yS|dCh^5iq+ϸT`O)Nl|{WD$+==Ox0<a帿9>[:^(NY^(LԂׇ&QHq Kjg:Ho3ۍ;~h^ARJ_ϠzPYگ2{ƾi,='Y{ߪoA0JOu_qiQjQǎqt$A^I54bs]ׅo4s 8l@U gc? \%ivSG4 W#23'Ō5Yv`oFdA߲ <7| T5 m'(4IR*[؍t!8x6TDGX˙?w@U-#h1H+;a8,TNՂ*Db#?>wLǿ  QZ0\[Z=ÚF5xɎ:,4Q hqߛc'3꘰n /;͕IANl@90X ux4f wOؚX"ygPqZDL@Xdr$a/Kg3''i^=XWڅsY:[W#Tm;ZZ{^*i$JR:'vG ׼Q,xnX(Br8ijqu@J8W D+Es) TMxP-,[Yjs{ @ 7",SY `: nIirS'%o䤾e{">q~1{tp6d܇һRE@9@-|>'>T<"vo%~֘P_:ͼ-70<=@d[;i|Prak%]T|p)A* m8{O74 MACb^(jֿnĕÜ ⛦i,4xAg!P=|?/'`# ^pPc|u/ɧ K>MNa|61nOԐ4ގ"U$*Ow4E3d/ِR-vfwX76B;<~"9xg 8:D8>ۜsSVM_;2! W+=(N7(F"-J|Wh1/QImf5aC#plow>]XJ!CFb)1”:8L֍ }"p S҈$ukzS^Q&it Qelg~@ލIH$Zx|{AnN;?Y%[f"E+9X4+H,P`ΡZ0Oqa~CB_S3)^ ;|N€aXمfu͗=^i%88;< vki=SrH6'ga37]Y+oX fi39(YPDdbvv*0U;F,"ۂKNֳ_bqG˩y1>1K=mN¹w *8K,} 6Lơ'd鿡5Gn lJQXi7b%(g%)! KK#NkS_&vƒ@]-GQˠkh" (qi(iRu wJO4Ble㮀dB6W2{|6%w-AF%m۠| -8`@ T L, 7ppY,\wte|}-wс7z$_ԭA hk\QS :23쪍.=J$]TEU. YLarv8AT)OaǴpEW?)Z<ܤE/FK쑱mDb,1 c ,Hz(sGF/ *eoذEsI I\{=:=׭xsy5R5Qͱ҉j¹nLq65[ )MLΥl)ȿ8B-ͅ,v"GD4:f+qY>++lq[QϐgS*|)sJE#_J6|kչJR{I&7œ٘zKxG3I7xofi6JM;vHnڮ"$Z>E+ ߮ۿ(˥3R35߬0HME-1dq .G Jaa.Tz{X9dS(56.[Z8ѝ1QD5F3H6"'7΂}!\wSC6?.ڄ , o{pￃ.zwZO{):Ewƹv7#4tQi[Nc7%δ+8|nW .Z'Ҫ]8U!GKRR~J$ 8牄|y1#Dbbk …iIy4B?T'7!blG9D3S,e?BwO1K~80cb@P.C}K'uo}c}t" ,WP,n8OėfU%";ewH.=./ye>-9gCݼŧ'@rD')h. WoDLUzOc0xdLUa=yCÁw\g<|cФEbMmB,u-Iw:^ǥo0zUWWB$8a-m%Fjh`_q˰5Cn ya-~Ư> 5 \ṷ=sNdy{Y^ YZ踚;(8)JPRbx>f'9xoM2RH\nAenm[fd=e:3p3%!7߀Wm8RџDoGVo|>f/HJ!1y}H 1EoL&c<ӛ3~TYy#Uɿa2[ ԐRJuR0];Ț2 0F[="V3 3ebGt1RN/JS;bI)q x A3坞4{hrtZ Ooq]MA<@Q5t$pbThIMw`$ȥi69[1u/t1XC ?xRCb'$d 9 j!KaP0@o3޹@(¿Il\j]I[#ՒZq9R /.0\\h =\,A&j ; -KfF4 +1@6x*L:n8XNDũJ$^/2U(peg+I"`Á}u4H_w#xV6$|ba>K]"յ `0bmu\{Ι㜏:mN/C_akx2иVhQ~qrO"[\mio4O&ol,YI#W,L`R e$pCo|Ba m-Cyzi/OG1*EagY % x^4Epʉ}\^ gxR7M>ol q{Ƨ#z0O;Owi PQAE^*Xh-R @$;Ek5h2|.Ht Mt[8eȟY&!Af+Z\PW+ |d[o fd_1Mш>T$!eɈw֌i$a(0ȩ)NCC$NKXQ$6G;8 K_0 $\䋱&&RS\Л sR"Ÿj&U6IZY*pFpj-=IJ H"d,bhVPwQ0`+'OmqXVG!b>ɱag7ޓ ~͈ . dوiW(Qu-+\ۂ_>w5BF~ S 8/Vxx| + D9.P;|:SgInR\E E-DknCeI9Dᕂ>i>QΞ/10H͆A601uABRcH!L )aR&/Jyd@Y6< 5擟U4T<;* >E8:8UL#g^=<RS0z;S"*j"Fc'&; &l/ܨ4%cztXy(g)&V(hg<ϑQMD͏YQx2]6g99zTZ|O~, ;u8\Աn%CI wNX3p;QpɀnP`N-K饾N3jS'q3,]y5XB͎-Z*%J 5VQq >z H-y8 qX@( ,Л1yOLS f ~ vg7 j zoc$`st ͆Lj^!=6&2\lEȝ@;>9"yWl {fcJ`B/*EK׳1?/0_RYMUJm5ǑM5 lrL[)QQbBOlD[U6z¥[6ZQ*.5).q=;6[fU H wlqO|\_?#p5g|U/طYmi檡A=QjWD*T ِ( OHb7-h>E050%0ܢ]%=:㡱Kuk8A!| f9K L_o$hCg֚s=Q‰pu&\RHLsmT~K!Q,M8Q5m2ji Ŗ$R4OwcEvv5f;Le"Rwx|Dϳ=3iemRz9b-}潲pR`t=E~kj=8N@̀ kj~QEſC2R|%cKuN, +ר]ǥ/|ܲo;ci-5޴_Z"ekXX5-M>١5UR+zNT͠NCRl>._- KDJ:y[MeK=FY36Wݕ*F]WU'29[S2ڶͺZG ”Y47ЧR^SkwA_! U2NzH KO9*GD3DuqL~}vlޤ?O$lVZ CbzP ז0~y|rv{k=,LM9$zb1f4S '$r=ytu9FzbjzW,:`xJcb6"Ay "2.'ۂg;DYړȦ67CИxt100644 handlers.gon0yT72'`pIT100644 service.go=mP714$'If/100644 validate.go;WT,.*! j֝YV՚aw!0 Cq.s7~x~t=3]JT1eȚ|@f TJw':3-RxYfNc$exȯ*;ܣ)685$H"j_;2<Ă#r Gpw n<f?dLY(¨-h-^_c֎,goQJ0-b\x/` H xG?!["X.fɩ @/7Ng>׭zN hK% ?ݣ2*;`Viuj%+ċZ7e hR F[=^7DY9O'*x^package meet import ( "strings" "time" "github.com/google/uuid" meetpkg "github.com/ultisuite/ulti-backend/internal/meet" ) type Service struct { cfg *meetpkg.Config } func NewService(cfg *meetpkg.Config) *Service { return &Service{cfg: cfg} } func (s *Service) CreateRoom(name string, user *meetpkg.UserInfo) (*meetpkg.RoomToken, error) { roomID := uuid.New().String()[:8] if strings.TrimSpace(name) != "" { roomID = strings.TrimSpace(name) } return s.cfg.GenerateToken(roomID, user, 24*time.Hour) } func (s *Service) GetToken(roomID string, user *meetpkg.UserInfo) (*meetpkg.RoomToken, error) { return s.cfg.GenerateToken(roomID, user, 4*time.Hour) } z,xeOKA٠d.u䆬I:TIa}IwFO XX}?A[EO7j?фbDp!ՒV}z[FӋB$j wqnPiPZHÇ>oJ:x̆pI2^k ${YE}e#}aK]HM=wlk8{9hs>4z]K+;wyܣR'ԁh!`*26}ڂkʸjE*)eηp)BJ%4JMQ#u{k:+_0r xF100644 auth.go))h 0VMtv4!100644 logging.gocd^N:>&100644 rbac.go~n#ӽX>s@<8.100644 trace.goɅ2ʁk75100644 trace_test.go!)Ãl2 j}6>%[\=DxVKO1>gi;R-R$U9#$;~vSTZ8$V|e 5/ $u#!i2ֆR-iZB nvpmz3 Jj> t#hkO PXْ͆cYM0돰!$&!Ex= 6lsnEA"t9(rq;$9)TF\|Ϙ@ߑ@JO[~CD#o|^US(%UzakP+^`++6y;.Ё<=#t KfTop5&|@9$5k>;ML< ڲ25 !D7W%nRx 'wK`%Jp4ƨ3߃IN*D(YF(}^CLhاy٩LXhLHϤ[9݁9ma~t*)[s`itbXȃaoP07={[]?rnX'/x0֧sP\[~m~mg.hB81ˉGP[xݵs* ۤ] `8L. @̝9GWolc'8Uu-mS׬Ci?$5lV{&xmQN0 =7_ai!L- KA'E\Z=Mg4't@!ٻ@ EQ\SrmG"k2g,E%}yw`t"x\m'(:w`, JB`k0ިjԨq HE\x]Jiwv߱:r!l{12?⻩'7Ȋ!hﱉ4ea92R"&Q; 7rQ{{p yrpQ)zLec_k&ٞQ~\A&>h22QUD/xcBHuH; ?? mms>r 8OB6p9IkMIٔʲ+(Yuџt[;+3J8$_!Κ>vH\LбO}O,0cc˯Ix:aE~Cىħ^goX0Czbq۶ l,ۏRW;*b*|*ǿ~_|ʾx[[gWx"package middleware import ( "net/http" "github.com/ultisuite/ulti-backend/internal/api/apiresponse" ) func TraceID(next http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { id := r.Header.Get(apiresponse.TraceIDHeader) if id == "" { id = apiresponse.GenerateTraceID() } w.Header().Set(apiresponse.TraceIDHeader, id) ctx := apiresponse.WithTraceID(r.Context(), id) next.ServeHTTP(w, r.WithContext(ctx)) }) } C Yxkpackage middleware import ( "net/http" "net/http/httptest" "testing" "github.com/ultisuite/ulti-backend/internal/api/apiresponse" ) func TestTraceIDMiddlewareUsesRequestHeader(t *testing.T) { var gotTraceID string handler := TraceID(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { gotTraceID = apiresponse.TraceIDFromContext(r.Context()) })) req := httptest.NewRequest(http.MethodGet, "/", nil) req.Header.Set(apiresponse.TraceIDHeader, "client-trace") rec := httptest.NewRecorder() handler.ServeHTTP(rec, req) if gotTraceID != "client-trace" { t.Fatalf("context trace_id = %q, want client-trace", gotTraceID) } if rec.Header().Get(apiresponse.TraceIDHeader) != "client-trace" { t.Fatalf("response header = %q, want client-trace", rec.Header().Get(apiresponse.TraceIDHeader)) } } func TestTraceIDMiddlewareGeneratesWhenMissing(t *testing.T) { var gotTraceID string handler := TraceID(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { gotTraceID = apiresponse.TraceIDFromContext(r.Context()) })) req := httptest.NewRequest(http.MethodGet, "/", nil) rec := httptest.NewRecorder() handler.ServeHTTP(rec, req) if gotTraceID == "" { t.Fatal("expected generated trace id in context") } if rec.Header().Get(apiresponse.TraceIDHeader) != gotTraceID { t.Fatalf("response header = %q, context = %q", rec.Header().Get(apiresponse.TraceIDHeader), gotTraceID) } } (bףxS100644 paginate.go*{-;6?"100644 paginate_test.go]n䶠A[i4+"cxLpackage paginate // Slice returns a page of items and the total count before paging. func Slice[T any](items []T, offset, limit int) ([]T, int64) { total := int64(len(items)) if offset >= len(items) { return []T{}, total } end := offset + limit if end > len(items) { end = len(items) } return items[offset:end], total } lx xpackage paginate import "testing" func TestSlice(t *testing.T) { items := []int{1, 2, 3, 4, 5} page, total := Slice(items, 0, 2) if total != 5 || len(page) != 2 || page[0] != 1 || page[1] != 2 { t.Fatalf("first page = %#v total=%d", page, total) } page, total = Slice(items, 4, 10) if total != 5 || len(page) != 1 || page[0] != 5 { t.Fatalf("last page = %#v total=%d", page, total) } page, total = Slice(items, 10, 5) if total != 5 || len(page) != 0 { t.Fatalf("past end = %#v total=%d", page, total) } } xt100644 handlers.go>7I%v1p100644 service.gos.]c$*fN{g100644 validate.goNZ sN0½O-@!xRMo@Uč7!*EHR2!%EJQh+coUYoEUc=V/zI7N3f߼cdvh;v#D^H(:P5Lo#RxЅ_JO2:>F /f*Id,O-7:HClm*5_cٮa>GL׬jsksl1k6eynM'! fD\v\zyYD>b(sJ6\J.Vw~0y*xg@n"J#z4p $ï 5wT|!!l WF! ~Z}+vyCi_,=;|18԰A:q4rnSt˷xX1$qtuxUQԧ,7$pƔ):7e#l+kk.=Ijv\u'VxVKo@>ǿb+r@"Z !B٤K]g6}nbx:%蜑VjY/J4AI/#[iż xs}[OLGuyUs ddbz!Z ђt,|yfj qay7'/` ,3g@/uC0r΄&MXUjsvm19!bV8Ӄ{_ab}U1]JwX#1G%0- Hkһ\0;2 fik8cvܝ5(L8&؁eqI=!'$V> )Ec1$jT1NĶj,d8"Uj~`Om'1`g&ѫ< `09(M}v5=*W3Rwoȇ4otWB$d=0l :һCC Ɏ \eG+|R=ic_hJӸO'Z3Zk*;ԤFM6QKq!H")YF]PAfS2S%eDN S/M޹uPV=0f<߅Z8emVR_B[Ql_֖sh^TG2qa5r%}I63S`t">5+Np2 Q*뢲ý \TEfXBgbjRX JVjsBp*_?`tF\u"]b"Y`(↑ZiAK[܀pv:gЅKVWȊ4N)?3, VUx{QL)gvobp*S}4l0 `%9EY- O DZ>VҸp.ꁣ/)1dѣ"F6I2Š5G >e,- tOfFI 8] fF ͔.+en]:4҈-zSf?k ZgoY96ޱJcT֠RDVJR5Qxw,^.6<\'NvV%T-d2PbX[ie_ 1 r *ܠf,K;\-\nԧ e_V{Q[oLכaK' !,FoMtَ-$o gɭmk.64W- ^l_ۉǡ:;gCGI…8[H*.vEr7?/*)?,H|H㎧8Kxf~g#H29Zav+nA^C2Zk mKl B7Щɦu~om 3hB?B܄|'EvR\To $*S9<_,^'}+4[gYP;}ut kr2<{MCx;S'_͓S2q3]7KE܍ _ɑ-Tl,2O PFY|åW2y!D|.j,#9lb;ʚ5s7 d>)ey{P )xXmoF bR"cL8IޗBX~5;37ֆ(R癙gg'Vk!_ Z&R1ݲL-x=+̟2G%RODjw: ,q UӹXuR[l;mGÀƬbknwv+Xʻ17{Un0"PغݚȽCGZ[D&`O'pR8)Ql5>[oiŽS5odGROc-TZ* b \ okL5>pa_ F#5TŘ'J7*N\YH0PWu[볐 eyU 6~!Mi fgE.jS %J9:VE[~խo;o~!ma/nx >b\$KVV.TܝW0$\>\uԋ ^o=1P sٱO+] d@@{7-Sa b E #]1S[n.LuP רf=lvh!_B 2K U6|ǯy'蒁ZR nȶW >yG>edd0K4tte1<> ֏Na:.XŅ/Iqmz-{9zi_@,XIDbuc/l8lh2TF<Ѷ"f(Crb~0ZOuZxy|饨ެGLڔfv7]6|`[Ь^#6>*m)1,*.,jaWCL?M x%100644 config.go6b kaxȘ/kWt οxXmsH b)eM!Ab@IT1串 hܺ\t?2==ڇ]xQg7ɭ'}^5E^<$pc2*Iv6!æ廋CJ̞7gE\dazQM]'{L;CD7][P# ]s]d5{wckhoI KZNZ<35eq_ɨ,"nS4|`OF_$F Q;t䔾*O6mL"\m S9A8}) 54$~ۤ>s,ZꆳYfI0$MJ&LJQoY&yL{b-Ӥ uQk^^t-AGw3Vs֋20_`!2 *I J۷II!ʒ1sECGu p(2Eh7Y{＀, ߄Ц{38CFGajw\Kx_|^ A7b|ib&SkMT:5R=ou+چ-6[{uu?21IIKSK<W?0BOl-Xؾit$)gdPmg*<2R\[,,hf0p՝Gic=h}@='tEf GM;b+]~%DAg=OB~,u9KrCUOj=_Kn|NZȌ'; ֞RIvV '.{4qp&%&Us#,yK'"CB*vތ֒"%K B!!!U(U8Ǿ%'{/=U@'\m;I 1i6:ǥi󘱴媽VH=rOyHTmjM~AqlM0R2yө7VQoNzN%L <)7.}"PD8Lv)x`_RUusjyG~ $;\õ.i*?ˀ? 8"l|5b{2[m!Br8gOh[77xƁ m;?kۭJ5Y`9:zj^\0+P3ƵsOwRs%)Q@)cAdal&w%w̕'yՒOMooŷ\!W100644 expand_test.god}!3%e93xNpackage envexpand import ( "bufio" "fmt" "os" "regexp" "strings" ) var placeholderRE = regexp.MustCompile(`\{\{([A-Za-z_][A-Za-z0-9_]*)\}\}`) const maxIterations = 32 // ExpandString replaces {{NAME}} placeholders using vars. func ExpandString(s string, vars map[string]string) string { return placeholderRE.ReplaceAllStringFunc(s, func(match string) string { name := match[2 : len(match)-2] if v, ok := vars[name]; ok { return v } return match }) } // ExpandMap resolves {{VAR}} references until stable or maxIterations is reached. func ExpandMap(vars map[string]string) (map[string]string, error) { out := make(map[string]string, len(vars)) for k, v := range vars { out[k] = v } for i := 0; i < maxIterations; i++ { changed := false for k, v := range out { next := ExpandString(v, out) if next != v { changed = true out[k] = next } } if !changed { if unresolved := findUnresolved(out); len(unresolved) > 0 { return nil, fmt.Errorf("envexpand: unresolved placeholders: %s", strings.Join(unresolved, ", ")) } return out, nil } } return nil, fmt.Errorf("envexpand: expansion did not converge after %d iterations", maxIterations) } func findUnresolved(vars map[string]string) []string { seen := make(map[string]bool) for _, v := range vars { for _, name := range placeholderRE.FindAllStringSubmatch(v, -1) { seen[name[1]] = true } } names := make([]string, 0, len(seen)) for n := range seen { names = append(names, "{{"+n+"}}") } for i := 0; i < len(names); i++ { for j := i + 1; j < len(names); j++ { if names[j] < names[i] { names[i], names[j] = names[j], names[i] } } } return names } // ParseLines reads KEY=VALUE pairs from dotenv-style content (no expansion). func ParseLines(lines []string) (map[string]string, error) { vars := make(map[string]string) for i, line := range lines { line = strings.TrimSpace(line) if line == "" || strings.HasPrefix(line, "#") { continue } key, value, ok := strings.Cut(line, "=") if !ok { return nil, fmt.Errorf("envexpand: invalid line %d: missing '='", i+1) } key = strings.TrimSpace(key) if key == "" { return nil, fmt.Errorf("envexpand: invalid line %d: empty key", i+1) } value = strings.TrimSpace(value) if len(value) >= 2 { if (value[0] == '"' && value[len(value)-1] == '"') || (value[0] == '\'' && value[len(value)-1] == '\'') { value = value[1 : len(value)-1] } } vars[key] = value } return vars, nil } // LoadFile parses a .env file without expanding placeholders. func LoadFile(path string) (map[string]string, error) { data, err := os.ReadFile(path) if err != nil { return nil, err } lines := strings.Split(strings.ReplaceAll(string(data), "\r\n", "\n"), "\n") return ParseLines(lines) } // LoadExpandFile parses and expands a .env file. func LoadExpandFile(path string) (map[string]string, error) { vars, err := LoadFile(path) if err != nil { return nil, err } return ExpandMap(vars) } // WriteFile writes KEY=VALUE lines (no quoting; values are used as-is). func WriteFile(path string, vars map[string]string) error { var keys []string for k := range vars { keys = append(keys, k) } // Stable output: sort keys for i := 0; i < len(keys); i++ { for j := i + 1; j < len(keys); j++ { if keys[j] < keys[i] { keys[i], keys[j] = keys[j], keys[i] } } } var b strings.Builder for _, k := range keys { b.WriteString(k) b.WriteByte('=') b.WriteString(vars[k]) b.WriteByte('\n') } return os.WriteFile(path, []byte(b.String()), 0o600) } // ApplyFile loads and expands a .env file, then sets variables in the process // environment. Existing environment variables are not overwritten. func ApplyFile(path string) error { vars, err := LoadExpandFile(path) if err != nil { return err } ApplyMap(vars, false) return nil } // ApplyMap sets variables in the process environment. // When override is false, existing environment variables are kept. func ApplyMap(vars map[string]string, override bool) { for k, v := range vars { if !override { if _, exists := os.LookupEnv(k); exists { continue } } _ = os.Setenv(k, v) } } // Render reads an input .env, expands placeholders, and writes the result. func Render(inPath, outPath string) error { vars, err := LoadExpandFile(inPath) if err != nil { return err } return WriteFile(outPath, vars) } // RenderToWriter expands and writes dotenv format to w. func RenderToWriter(inPath string, w interface{ Write([]byte) (int, error) }) error { vars, err := LoadExpandFile(inPath) if err != nil { return err } var keys []string for k := range vars { keys = append(keys, k) } for i := 0; i < len(keys); i++ { for j := i + 1; j < len(keys); j++ { if keys[j] < keys[i] { keys[i], keys[j] = keys[j], keys[i] } } } for _, k := range keys { if _, err := fmt.Fprintf(w, "%s=%s\n", k, vars[k]); err != nil { return err } } return nil } // ParseReader is a helper for tests and stdin. func ParseReader(r interface { ReadString(byte) (string, error) }) (map[string]string, error) { var lines []string for { line, err := r.ReadString('\n') lines = append(lines, strings.TrimSuffix(line, "\n")) if err != nil { break } } return ParseLines(lines) } // ParseFileLines loads via bufio for large files (alias to LoadFile). func ParseFile(path string) (map[string]string, error) { f, err := os.Open(path) if err != nil { return nil, err } defer f.Close() var lines []string sc := bufio.NewScanner(f) for sc.Scan() { lines = append(lines, sc.Text()) } if err := sc.Err(); err != nil { return nil, err } return ParseLines(lines) } D"XZxTpackage envexpand import "testing" func TestExpandMap(t *testing.T) { vars := map[string]string{ "POSTGRES_PASSWORD": "s3cret", "POSTGRES_USER": "ulti", "POSTGRES_DB": "ultidb", "ULTID_DB_URL": "postgres://{{POSTGRES_USER}}:{{POSTGRES_PASSWORD}}@postgres:5432/{{POSTGRES_DB}}?sslmode=disable", "RUSTFS_SECRET_KEY": "key123", "NC_S3_SECRET": "{{RUSTFS_SECRET_KEY}}", } out, err := ExpandMap(vars) if err != nil { t.Fatal(err) } want := "postgres://ulti:s3cret@postgres:5432/ultidb?sslmode=disable" if out["ULTID_DB_URL"] != want { t.Fatalf("ULTID_DB_URL = %q, want %q", out["ULTID_DB_URL"], want) } if out["NC_S3_SECRET"] != "key123" { t.Fatalf("NC_S3_SECRET = %q", out["NC_S3_SECRET"]) } } func TestExpandMap_nested(t *testing.T) { vars := map[string]string{ "A": "1", "B": "{{A}}2", "C": "x{{B}}y", } out, err := ExpandMap(vars) if err != nil { t.Fatal(err) } if out["C"] != "x12y" { t.Fatalf("C = %q", out["C"]) } } func TestExpandMap_cycle(t *testing.T) { vars := map[string]string{ "A": "{{B}}", "B": "{{A}}", } _, err := ExpandMap(vars) if err == nil { t.Fatal("expected cycle error") } } func TestParseLines(t *testing.T) { lines := []string{ "# comment", "", `FOO=bar`, `QUOTED="hello"`, } vars, err := ParseLines(lines) if err != nil { t.Fatal(err) } if vars["FOO"] != "bar" || vars["QUOTED"] != "hello" { t.Fatalf("vars = %#v", vars) } } ̧ xX40000 credentialsw$Dos ӂf}40000 imapWY]fc40000 rulesA6\Fpy'40000 smtp>d^lq,)bb40000 webhooks npwy,` jIxQ100644 manager.govZw\֚BgM100644 manager_test.go,vbf\w i"xW[o6~~+ 4JfCm]4XiN8KJQq&"ѷ4YH>T4]FR2&yJHT*UQV[ʫ[&IELeьxmߺzARjy/w$8RԊT2&> 9KTA߱l-10AoV5?z:[)f'OtxbG;P"Ac"xGzF |'ރޕ3d<&v턔$@7 P]5H*sa=Upjy)o . r56py&]ÃcO ީl(47 <#( Z&OfxF>|Cn#We:]GBm DqəjjLnHt(FЛehxS*'ؒeQmdnҢ5b?N#Mfoˆ(Eʴt@L,cW /~o}Xi=e&\@+2{=B0~qh}2QٙD?DE&Oyn QqlLQD#v ٓ`>qFUIsehѱOĘcrO).8fq4~CHk˰w|1"%Wn*s+`Z5YX6TՑ+ Q.Ne OImڞّvH&PN]2 BvϤ,n.{Gtz]R]唋آ|'|sqJ߲~G%\[NDԹcyX vW6 a7=Ch^qPE3LC;j߳37+Kr'/6mhBk@ekUU=}ObkpGXYuS176d)0pl̮6S=Cq03 G͡26}7;wp{eZ< -3[-c /6ｓ EfRY=O=vÊ';mi\ivaa6Ls408!qx>N 9R4og/G_GßO%ݕ MiU3- `,xMO@_1lBURDăx ܌vJm|ENB qygJ!( j2UipԪL2=ϩ:p2.)5ZM垰y^MCd70%d썣i9q#8w}ӿ?X%y›1^-!$l$F:Sgd ql%oifXe|$xQ\G\ˢ1ReA5{`=zBE/2ePL5v֮Jq` ~n>nQT}/ lmK(;exG100644 parse.go8Aڶ?wO]100644 sync.goV N4@w(o~&ֱtxSQO0~D c>4 M*CoӸGD;Nj0*|-T| D7$c `!o^׿m1 {URVɁ-\pmC2pl-fT^B ceuό8Ȥ_mv_]r%(|8Gb3!I'LqQ UJ0p$cGpf!~j6U1 yƖ62Լ ٱc(XXrY;WaֆNj6,){2P#8mmB'i/7?pѱj{O o KE@ zGdq3@9o>/HSDBc(;a=lcB$,Լelt:l%hE}QW:R.sAC𔫀kDw@L+ʋXmiNui_ЗF Dċ/>`4Xr!#(SBYGF%LZ!Xap5`5s/+%K3%)l`yZKc&s* ct4U@xL A/Sii xK>,6T5@]JtB%l4Ņ9HnnLa"Jb(̼#J)7))Y@"۲ W yP--u*xmJW(JEyij'ڻ9g]m,"/3R L `&^E3j001U_eu/k )C;)͈/OSZU*[R9'@䡞m<'S(M/:PB>08~vc}g3Znr,`P(SŊWW#r҂Gc!VRD F$V&PTy쉂4J |.>wBq @b^k} ,t 9o5f0Z-n-:82N.!+qkjqc-@_1&kbD sꌃxG|6nil:9P¹#4bXxsQշj/Qϖ-P&cN]Üƙ~(݈ҎWa1&\n[~]@IJA:.&|S-tp5cl| !%_Տ*a&LD>Bp!` ?G׃)ޜٛ|ɘ&ƥ-9'LV3W"37PаKa+ Cظ̮o0h=оl<g}\/\aQ>Tbcgg "l%KVwTg´aB2ɻDh*0if{H#Kýh0 ScQSe3O[4nZ\p\2[LfyTE0g]ՃO g=-Smx'@9K>1q'B/@X}}c" W8y.ǏS/˜t\Jvv|yzjF۽uT(:)[{[[M\U½3, X>ްӊ2':U@)|ivNSMg:I*c$Fwm%>:[ _`@mB(5C"AP $ծM TA[i9M92wJ~}EcǠetKKTV9e>I/Ƀ-CיɆ|":?0݂bE`5Ւ?sOŮ;?G.vRa J'WtpWA gV-lqn PafY)nu`f[$m(謩,c<ȗ1lcfix$:-`]s}!+d z#*,(zaDfav9Ct}€p YWsxr,oyw.3nkVfzgQ-"dn2|'|ZiLKkNNײ)'<|~O|~ AS$=EQp$Ǔ`D[gvmAh0y Fj[G~RkY +jC?b-or2nߋx&7u*Đe75k!{uo߸oׇb5F 4LEq\$1l`b^:3 %6eJ%"-q(D :΂LasLWIaW!m-qS}_Șʱc8 oe7rCf߲SS_>}[_iZlѴF<u^s" ˙!q<$\MWQ܂AVx%100644 engine.gojBܘY9f.w&ExXmo6, VR)ddd7qi+Zm52JTݑ䗤Y-K`e]RJjq2UY.gO(.H^Y/t U,zjio9?K|_?,Y.:e}\—3Q}\+9Oks2(!خElp)t]Jg$ ilÝY'bBQr HR1 (S "P8W ss}Y< ,sHxZe\?\j-S|lnfTly5ZtR\rMY1粊\~+K]WP,].N@ko^b;w9ht512Q2NČ<NjLB \g1rKX\[NwdG"yq*;Ư5Wa321aq*BFt #%0D6@IZ&3yё .H28L 13shpiQ?6Db ; *S]?K20Ȅlh&l|j&'k:8&MQ*!d9!yFslj[Mf;{'2dw5ڜ#kO?ITFȚMMS_.Ěz;=#d 4d9Y/+PʘhJAZ 2 !`QiGM*0n0hRs#yUGDb9°S='.@y儔yK-0-!` ۰`rtz W@w1yɨ5]jh:'*M!Fd A*fkKoGC;l_m Vf{`^.1k؂F]|z+FS{: c1iKI>rVZmΐy=Hl Ȩ- cuRYsZסq0qEGeR'RyQWljl 4AiviؐXݔpG vFr.G7 e3 JpכkG<ƃ |y̖8M /^#[[x:?ONHL>򾋭C+f\k.% P+m©; d=4g-mHBh:1 `Zlez@d{S-:9˶wa@t\%Q`LL!J?p O8)PK'AmbfzrYzByHZ ۑX1\[*ҥBx/j:/Lճ'-ޣf/i=7jg̚gCŸ]E1 .QRvNmbPų'&Si؁\'C_M轢V=l2kxКTKJIo0b*}:٦" G:1yq"2o!(.ߘ&l_Y0awNl#K6\W~xWO6+|%qaӤN(cmoH$n]b&g;mZzش Q}Nɒl*tyYQJ?hd4/ !xVBpf uMΕ-1P::&fKɈd)oG]&3ӄ`Ϛس,t8ȡ:y3 "\aeq= HX[^tBKJԽRԆdÕ/ <KM֪{|1bRAM:jq+@ O2Z`*g4%]st&o0YpSӀ2\#T$UʈLoLJ`Sm90GP="Jau㘁1s Ikj KвEc~t{ 1M8y yH>+5\9AQ;驘اb&ml~S8`t$7&<ٶY#z̰xb:1`N̓`c8+тA!5-/2k:090qޡ|R>LZʟvtAp n-A9s!=Ut`(w>Oǣw{mCz`TjAKa9ւȅЯw`yXfbr܂2%;U V? ]hW>)z GXn:H`pKw5-&|h]UW~Gܓzav`+ޛ^=]䯇JXQXkߡBu36%z~q׽X6{2D'\+ \9u}E вߴ4NHO/6ȵ,+;ϖ6+ :#!5޼٢NSf^u'˄ux'100644 executor.gouo֠p6FKE(6xVYo6~~TI@ @I8>,V"H@-q>AVQr9Q3kv ЋqO{ ,0ZѠ@9G:SL?ƿhN*jr+#y!xm=SK.%GҜ)Q+?}vad,Ed[Z>O`KzL&,ŋ*GQQB!'6^צZi%%Zp 0wn\u[A[0giix4@ȇ3\LN[m.k _̮.ӭK|=&0C8B'*縄 lD{[?u?򦶴͌MѕQ|xmY"62LD] }3mʈ8">EwZ!gѪT6Æ6,„>nV+^uGcKjNɭWQ-Yo@EξETMT7Դ¼ ϔVꎝw'Nd\N7/<-%@QUYLx\VaN 6ӥl uvy&̖~`BjH9UY#+YH$:[iۂ$2yK1=cmͻMZBXZll幏Yf{> Zغwv,8'OW ptRշc4.񪁝zzfmYοG_&sC#~?sbʺr2&pkմ Ffs?o&OA ¶S(9umc0_t3cL{;`Dеމ.u[ #䭓t2B3q{UNz{DbkLGH/c!VlތOvzXL{]DWw#Y^2VL`*%f?řx#100644 meet.go(o̗aVi--Q) xrpackage meet import ( "crypto/hmac" "crypto/sha256" "encoding/base64" "encoding/json" "fmt" "time" ) type Config struct { AppID string AppSecret string Domain string } type RoomToken struct { Token string `json:"token"` Room string `json:"room"` Domain string `json:"domain"` MeetURL string `json:"meet_url"` } type UserInfo struct { ID string `json:"id"` Name string `json:"name"` Email string `json:"email"` Avatar string `json:"avatar,omitempty"` IsMod bool `json:"is_moderator"` } func NewConfig(appID, appSecret, domain string) *Config { return &Config{ AppID: appID, AppSecret: appSecret, Domain: domain, } } func (c *Config) GenerateToken(room string, user *UserInfo, ttl time.Duration) (*RoomToken, error) { now := time.Now() exp := now.Add(ttl) header := map[string]string{ "alg": "HS256", "typ": "JWT", } payload := map[string]any{ "iss": c.AppID, "sub": "meet.jitsi", "aud": "ulti", "iat": now.Unix(), "exp": exp.Unix(), "room": room, "context": map[string]any{ "user": map[string]any{ "id": user.ID, "name": user.Name, "email": user.Email, "avatar": user.Avatar, "moderator": user.IsMod, }, }, } token, err := signJWT(header, payload, c.AppSecret) if err != nil { return nil, err } return &RoomToken{ Token: token, Room: room, Domain: "meet.jitsi", MeetURL: fmt.Sprintf("https://%s/meet/%s?jwt=%s", c.Domain, room, token), }, nil } func signJWT(header map[string]string, payload map[string]any, secret string) (string, error) { headerJSON, err := json.Marshal(header) if err != nil { return "", err } payloadJSON, err := json.Marshal(payload) if err != nil { return "", err } headerB64 := base64URLEncode(headerJSON) payloadB64 := base64URLEncode(payloadJSON) signingInput := headerB64 + "." + payloadB64 mac := hmac.New(sha256.New, []byte(secret)) mac.Write([]byte(signingInput)) signature := base64URLEncode(mac.Sum(nil)) return signingInput + "." + signature, nil } func base64URLEncode(data []byte) string { return base64.RawURLEncoding.EncodeToString(data) } 3 xh100644 calendar.goJ͋&-4_G100644 client.goyVPsuvF+J8M?100644 contacts.goi5|5+V1*.GERғ100644 drive.godv\M_8iv 9xX[o~K u$guz x ɹlFU6 gf$Q/qprH7ù| wq'Y"EqYDGi&wc:0_sRXLd5;0WʱTx< M7 U|P|N` 4J|A\݋e0/2-+Zfve"P "dӗf/-fhM- 1R8i򀀳(lv">^r\<|}5HP8Oe E3gߎiP:#V(CK6>~LyۘF ,3\ƩNvJryn oe_d #~ 9)=W?No/lBA Q^0⓳kW"OP굗\ʃD@e{3uM}ƪ^*#j$cbkr"%rFߺ }9{(ߙg 0>_|?M zABL"X> [=>l, ?'x,G’TQoF, #L?X!J Z qށM8JlА%k6!-.ݳ :T]JlatVC&}mBהl&QH(?Izw'Vk@hA.H˼qv\1d_.ق}t2Basa6G CЃk-ۃ8Tt'7ei m߆'׫71Lb:X.yvvoq..ԟ%qMh8"mFt,`!4iWz9\n[9 ^D:$\%L$Iưtm%:LhE }ؚ4=*J!>0Mti Q {j0~SL&'T^0ǎʆ2 ewm"#"5O"]'l2ݜ5_ `@>v7og[CwƭK3ϔ__noAdr>] %[0x,ᯫ]6wH~V_Շݶ]"&xq>_a6tU6eWŋָ0>۵@p&lڊ6p{+]MA9(+^v^M K]MZW֩PM>/LحPS||ᾋ?)Ǧ@mގmb"X!z+ }gPe,~[g&(gWT&J*ҌE%kl;a B3𨇇?RLNуӺ(iܛzG Ƃ-!3xPP6w"`d7y"ȊZ67B̘1tE}F|?u8aַ$Nm ,0ԢDs g<9?LV{ 3` =\#O,x qfHR4,1j z;ҵVHl4*AtYRTn4Pg7}$д1jtuK7 xסɈ䭴UύN@yNtY ׆3#Ug(O]s?S2$ ?g&uĐ2K>G&.''G1OKnTDm0ӿ#f_9 շxجlI~k܏g…ZYL۪]㢔G4/$xXo6 @ dàTRi8ن4hrk wGR2e;nH(f$0Ҽ vziR#Oy!=r_Q@X1m.3N}?BIOJ [CR(MCC^[Pd{/}E 9']) p|֎ NW^4JQEk\,V5p\ݦ _.#4 H%j?yMqV<02H#/Qȓ"'(W<]Q{wI)xPF,ҹ2dy[/L(q\2.+XQAsTyb=&o5y)uwȎyYҤ Z yķDYҪP{nh6Z.Svx$?'3Lq{_6D톃Ճb ¨)Z&xqј*3ًYB~HpeB1Ќ3+,L=zL-h(>=t)7[?ƴҧ{W,'7u2ޠ/ns8}3z{+ |KpT*A}jaW3D\EڌG/[;hSXcgz_Ш품'vH?K7InUƑQI5nu^z% بV(̂RhW+,]Z„/vPOFd6$DfbdQ&$Ou%`f(7_3V {m>~1<{CaiȻs\2%[Ԏ)[X娒T{(852S#şB(%R= 2_ķ5ʇDBh^0)$}/F7RT2ro:`xJzgKY>b%hWqBnc!5xqqtz]vu6eUD1XPQ6@(*GWZף᰺))J^FQ6>$v1?ip5saH@gjMfF.yy إ˔U:XY0BC;Pl_tU :є?<{7̚f`Mw=O2EsCI}f0l'|1ڊ8=1GDju.D={R)q=%ig\2n;-P80XQu5첇ZYОADOO[{mVj"yng'Y~S|NSZB %#<>׃z JWh2]G$8?&嫜 laVJ 1(8FB~KI6O&7,/FuW/§fVb-G9A\ _ /w"|I1OKZ8:<'*V^WI5X}@X'^o I,t1uX֮I`7onn6Q&\T@9uo2bQ)lF{H`.Tq8‰VA.3MA &\Q`i=j"X!}ӔĽ|)h)G&!fa1}m @ν騁VC w7 )`7DhQf@EfPf{ 6hSc}:42Wء,g:%ap}I9rH^a3E35nLruDyR*[VPcrJVt6/TV5Gr[\xsijOW` g\#> EGcf :(ꓨL*)& otKHrcd+))lc)l&n{s,i @PjOyT&"-٥BqqE9YvG`1`hKnr_$hQ29]   HJݲ!Z8^3>ڣ 57$M.jXzl/$;'qJZ^k)ixi-(;ӥ4i0V>0V=wJpuX,hAdB͗H5ְ]X!5]0A{?VՠGD[lt@~ 5AH[)|k-!m\LOV4ki\BCK}rJtGW-$Tulaځ"B0l ^1oWܐwۗ=gJs˔j_p5YJg?|c%Ou=~Ʀg`Tkjg{Vx *h6m#kWӥP>Oii$afm0-PhEbWHzԇ|5C̊M%lb j`Bm #wM!O$*$) i!,ɩ5 S?osrܴۿ ɖ\SOyi|W'Upa_];hͧmkg/._1nUD;FNƭ1uV.y9܋X|]m%!*7[u6h)#t0>ښ"[.'wW²\&OŢRӗGGurEt: r0tQ8u`Bi|1$R< .p"9qxUMo0 =ǿ5  9CPdvADmy.'ʑ۸ml7S~|Z{EєH*TYkc!HVU8pkA]›mhj 5|8ԟ9;1.E.Ӻfg3t%RUqwKOSq!4#l. zvVI(OwdyFTnH)V7첟 ,Y&y1Wk>s̙]~V"6O9oc3L1 |ϛkF?hdO'3ՃQco H)| SȀU8\p |c) }t:*ghP49k'|4 ~"iLu!岯74rkr^, w(/M/3) 2a.1>i6l$ҒWmer/9v^n}&\gi& ii7ѣc ȗY Yn ߡ6!%Ұ/jx%100644 client.gonF,"# { !侼xUN@]_qk d#tQ*HDm.L x=I{C>T"ǹs$aLeY"Sղ+>W6.yPķϙ`2BwU{TBk%fܶ\RC7ctCjWhl3-HtO=uW8g Xʪ'?v*/G u+"s5Bs~z/ $U2G᣶L]*;O#J&h&ukp=R"5.iރOJKuxsBM)ia`b[("},d/$|"%:s +y= t$&!9JV.[!ȝ,Zfܡ,S9ZD CycNe5&nn+45MX4 kk]hƌ61ۙN"B|#1_y+Vu./YC@]Sž~lvS<@oz[ *%BJDDxFUH{1,6T[D7]c|ÏgEkng#΋o{)ui՘~^԰x"100644 hub.goݯʶLoBB0n"\ 9vxo0ǟaJӐ@ i@{944UUw)@cߏ}T Y k_-!MXϲ4h6Zk+ZV~Fȑ^ M7!V9a?S笈;Fv% jc߱T}$˷xWs7 r$-@ZR;viqȶ$={w%q>$j~`8牴ȥkkCyi _eNFd>DLb$.Dƴ30F[ ׬/*&羪28X߂h`C/Sca!PԄ]4B(dr !S$e. *)!QT'/u(lQ@糩X-$e+ =%PbK!,Z _ NH=ܶh{I,OG!jZ! -ܜ}ЇL$V fL7Wͷ>0,loi!̋(8vc/_M Jӻ]-0ؚnu% X2|gYq+<u% |g:)X-kˈl fܖ w܆60*±@@U)*z!VC2#@ Dtwk$Up>"\h&؍h&E:-6 wCm+[Z ԙcPdyH0Lr|k-ȓ@ 9[[dl)r\V#nAY'HY MöZ*0lt[)8kPn ]yfZšQgFOH;5h$}mDn^RZ}=~WvpT4{῏~Tl#6vBa>7qh?ó'iֶpH1=jk:: fFb}6Rk Z ɬkO]g\RZ7#iSTWRb^Aק7Yl="-rT D~MF[).-wn'+XfJ>|G^Ž'=3hmh:@di8+100644 000003_admin.down.sql"A z8JFSLZ100644 000003_admin.up.sqlٟw# NȔZN":100644 000004_mail_credentials_encryption.down.sql՛b)[˭<i3'100644 000004_mail_credentials_encryption.up.sqlY~u->K~,100644 000005_data_integrity.down.sql[t!"\" 4100644 000005_data_integrity.up.sqlqjTbD-_ \OɶxyDROP TABLE IF EXISTS settings; DROP TABLE IF EXISTS users; DROP EXTENSION IF EXISTS "pgcrypto"; DROP EXTENSION IF EXISTS "uuid-ossp"; J';)xN0= 0) NOT VALID; ALTER TABLE messages ADD CONSTRAINT messages_raw_size_nonnegative_chk CHECK (raw_size >= 0) NOT VALID; ALTER TABLE webhook_logs ADD CONSTRAINT webhook_logs_duration_nonnegative_chk CHECK (duration_ms >= 0) NOT VALID; ALTER TABLE outbox ADD CONSTRAINT outbox_retry_count_nonnegative_chk CHECK (retry_count >= 0) NOT VALID; Vx 100644 README.md]y@n,,100644 administration.md}g[g-7I100644 agenda.md桂` zNi_100644 checklist-execution.md3kAp9G?;o2100644 contacts.md>M[NK%`^)100644 definition-of-done.mdr٦%?nG\V \100644 roadmap-3-phases.md0,K4<B100644 ultidrive.md%F(9s,!x+Y 100644 ultimail.mdn£EONe+ 100644 ultimaps.mdsKHrP6v100644 ultimeet.mdH(j%pSxf100644 ultiphotos.mdHk-Gt-4Qxw# Ulti Suite — Plan projet Alternative souveraine et open-source à Google Suite. Chaque service est conçu pour être aussi fonctionnel et compatible avec les outils Google existants, en s'appuyant sur des technologies open-source éprouvées quand un acteur fiable existe déjà (ex: Nextcloud pour le stockage). ## Principes directeurs - **Parité fonctionnelle** avec Google Suite, puis dépassement sur les features avancées (IA, webhooks, automatisations) - **Compatibilité** — import/export natif des formats Google, migration progressive sans friction - **Souveraineté** — hébergeable en propre, données sous contrôle de l'utilisateur - **UX uniforme** — même expérience web, desktop (Tauri) et mobile - **Interopérabilité interne** — tous les services communiquent entre eux nativement - **Open-source first** — s'appuyer sur des briques existantes fiables plutôt que tout réinventer ## Services | Service | Équivalent Google | Fichier plan | Statut | |---------|-------------------|--------------|--------| | Ultimail | Gmail | [ultimail.md](ultimail.md) | Partiel (backend avancé, incomplet) | | Contacts | Google Contacts | [contacts.md](contacts.md) | Partiel (API proxy CardDAV) | | Agenda | Google Calendar | [agenda.md](agenda.md) | Partiel (API proxy CalDAV) | | Ultidrive | Google Drive | [ultidrive.md](ultidrive.md) | Partiel (API proxy WebDAV/OCS) | | Ultimeet | Google Meet | [ultimeet.md](ultimeet.md) | Partiel (JWT Jitsi minimal) | | Administration | Google Admin | [administration.md](administration.md) | Partiel (squelette API) | | Ultiphotos | Google Photos | [ultiphotos.md](ultiphotos.md) | Partiel (proxy Immich minimal) | | Ultimaps | Google Maps | [ultimaps.md](ultimaps.md) | Non commencé | ## Architecture commune ``` ┌─────────────────────────────────────────────┐ │ Clients (web / Tauri / mobile) │ ├─────────────────────────────────────────────┤ │ API Gateway / Auth unifiée │ ├──────┬──────┬──────┬──────┬──────┬──────────┤ │ Mail │Drive │Meet │Agenda│Photos│ ... │ │ │ │ │ │ │ │ ├──────┴──────┴──────┴──────┴──────┴──────────┤ │ Services partagés │ │ ├─ Auth & comptes (SSO, 2FA, OIDC) │ │ ├─ Contacts (carnet unifié) │ │ ├─ Notifications (push, mail, webhooks) │ │ ├─ Recherche transversale │ │ └─ Administration & quotas │ ├─────────────────────────────────────────────┤ │ Stockage │ │ ├─ PostgreSQL (métadonnées, config, auth) │ │ ├─ Object storage (fichiers, médias) │ │ └─ Cache (Redis) │ └─────────────────────────────────────────────┘ ``` ## Exécution - Checklist opérationnelle complète: [checklist-execution.md](checklist-execution.md) - Roadmap officielle 3 phases: [roadmap-3-phases.md](roadmap-3-phases.md) - Definition of Done (backend/frontend/sécurité/tests/observabilité): [definition-of-done.md](definition-of-done.md) A+﹚x V# Administration **Équivalent** : Google Admin Console **Statut** : Partiel (squelette API) --- ## Résumé Console d'administration centralisée pour gérer utilisateurs, organisations, quotas, sécurité et politiques de tous les services Ulti Suite. ## État d'implémentation réel (mai 2026) ### Déjà implémenté - API backend montée sous `/api/v1/admin`. - Endpoints list/get users, set quota, delete user, list audit, stats globales. - Table `audit_logs` et logs de base disponibles. ### Partiel / incomplet - RBAC admin strict non finalisé. - Gestion utilisateurs limitée (pas de create/invite/disable/reactivate). - Quotas essentiellement orientés mail, pas multi-service complet. ### Non commencé - Groupes, unités organisationnelles et politiques avancées. - Provisioning SCIM. - Gouvernance sécurité complète (sessions actives, revocation, politiques avancées). ## Points de différenciation vs Google Admin - Interface unifiée pour tous les services (pas de consoles séparées) - Politiques granulaires par groupe/utilisateur/service - Audit log complet avec export et alertes - Auto-hébergeable avec support multi-tenant - API admin complète (automatisation de la gestion) ## Fonctionnalités ### Utilisateurs & organisations - [ ] CRUD utilisateurs - [ ] Groupes et unités organisationnelles - [ ] Rôles et permissions (RBAC) - [ ] SSO (SAML, OIDC) - [ ] 2FA obligatoire / optionnel par groupe - [ ] Provisioning SCIM ### Quotas & stockage - [ ] Quotas par utilisateur / groupe / service - [ ] Dashboard utilisation (mail, drive, meet) - [ ] Alertes de dépassement - [ ] Politiques de rétention ### Sécurité - [ ] Audit log (qui a fait quoi, quand) - [ ] Alertes sécurité (connexions suspectes, brute force) - [ ] Sessions actives et révocation - [ ] Politiques de mot de passe - [ ] IP whitelist / blacklist ### Services - [ ] Activation / désactivation de services par groupe - [ ] Configuration globale par service - [ ] Domaines mail et DNS (SPF, DKIM, DMARC) - [ ] Gestion des tokens API et webhooks - [ ] Monitoring et health checks ### Multi-tenant - [ ] Organisations isolées - [ ] Branding personnalisé par organisation - [ ] Facturation et plans ## Briques technologiques envisagées | Besoin | Option open-source | |--------|--------------------| | Auth / SSO | Keycloak, Authentik, Zitadel | | RBAC | Casbin, OPA | | Audit | Temporal, custom event store | | Monitoring | Prometheus + Grafana | gxXˎWŐc+,ʡ1bf$LHjUu13 Z0EA^^$VUcedAd[yzK<߿r3 Re&=IeK_θ.Xo$(Ġ\KxʒOʌa;[: 7-;3 [ 7x2Ye"!5,Ӿ}2Hð $jǐ ?qbbCAaj ޜ}`ifKVo׉.UWJ2,xSH| ']_5]ỵQu:#%S _}|LB2_ZN G_)%"VDGBϳR6K:7w[|)u:PV7e aQ?vߡ#v >/#Ձ(:9h"C)#;<& WSij)گ=jJ^!My7JUNI֔[ʸPQv0%,f$He@GD#%BjEw]U*D:1t)]l =:PEtR(6a>.R0@2ILz݉襇:]* J*W<0Z)ߐ_  ,rp͕C SHpTȪ0 :T$+S.&PE@d $ VyN'@2#M\f /19Ya90gڋ춁}TAV!NUYk~Yύ "Ll:ivY8IjZM_n粴)]s76/m3K xf-0v vS z@T M+ {Il`^.m}19P8N ҌOQx`XQFFV[]Dv"^?: Ji.U|ϕ/ 95DRXfCkW虣2pmr=o;$:.Mv:²K7\ ;%?uBz-tf#4VGmCц!L Ezi }i=4+cf[x✼ӞA[cc1l{Xi_T|KBxG yeW7 M&q? l[H&0E `!d3AFĕNEyD@ؕ+s53fh;l>{ !NTb- %ٳ1^Oq,鹉P~_pndv~qâ!"ozRmA݂L}~EFG52:up aVrt&_K*;Ǔդ^D2Dq)&++^f KyTt}.5D8cny좈6. ~l {>T˫}n\\׃Ê*{$-F3ٰ J)HI&8Q_]MΎ'9^fũSұa 49̝Mڑ؞@_ ([-A"Ϗ.NDx["J0G#piTI Ns81?4H%>2Re7{f :ӠF7`;ù'p"6vڳg@1Հha1 SE8[H>*=]FM}ʜk"nO\;^G4't#lVsuDQI2ZiGB!wOt&AT0-cS4?gE\g7W%:z вDX4>ku>Ŭ}>Uk0_[T޿Ro4qZ,TzxlNUszC.4&jPϧ=#ah`_]:\Zqՙ[ %(`4kP^& '~*" ʒ&`[hpXFaU-&k={mI =J+McܽԪ;I$I&xbɻċ}),4ԆMmhM-fz' ODۆK1K΁BXY|z|쨽3Gj&+ Vطx}Zr#Gv+2ءPl) RddJ.TUgVB 1 o+ğ̗ܛ*-B>=f>yŤѵJ?"RnӦe!rUϵ;ZϿfײ2^%MU*j==nb)3)ezʦ'OW}}٠C!TBzQA2{{Co.T]%6?Kij+2,OL1-xXH.gǣU6VؘcP, [̔JTycJO nz7Khn!%Ϙ >8R&{l\jKKŔ&ı gP]9={6/GR8={JÌ\Sl%+Q:e^j)ߊ]yRLX`z> %+0M]͆!ߚ2V4',b\j_`Yk7GUd17eQ%k2$끨q;:șfYOMA6R+] ULjfU7į{.n?_O0 j-E~XEMJXvޏGumurZt]Xӭ1[//qfЯνVk9Oowws#!ZWdϝ77u|wƬ/^(p{5mYd^ ʊ^9ʺK߹eNM {Tʬ4TpUUb'#ڈL4+ؖ%[S[a+'t~+l~i&]$ fLYE\3:DV:Y?O4 }VNZ/6-u o*&*ğ4s`>R6,u-˅.a%XbqJv{kl-C;n;m>E:`j уf *>!)bBzPŲK.`һy~J=jۀ̣ڏ'89;H&gW!zǓGg@|Tw0y"m]-J:.Q{& 6d  NGXO`u+EQ(SkkAwU;+ Ȩ5 _Ga* míE袢׻< *y#B~Qqvrv<9=tmMMT]|$HR?\A#@ܕ5TPa$ejqS( - B֘Ega *Jwp , C b(.g4&\*zKJP0~?/>5<&2X%wQ.2uK҄mv!a?uQ!~?TyID&`p,A`3*VxuVpbtYSKtꥂT{ 0~WPFYy۱&M!,xLT2;-*?hKiIˏp4/ TCΠYIȹ,$|O* 'a581">,/?5oC׷Bh*(T1­ejT7ke{3Mi>qϮ/ $lec_*qꔒkϋ b])3KFARސȠ!O~V˲9Iت,-;i:49G1[FO(R `Me[X EO~ž627k+ٸnL{mh {}͒q" 0K߿_*W:s~oʧmsַ569!L$߱:F,@tH$A?8M5;LycGT[Na!tű1Frr%%vө{ZhL抛u@~S]NS>!*'sH$h % !X %q[7C^SQTJ2?肠'I!k$h;HVabmD.Ǡ2;>T {Iec#Kpâ6P%5LֈpKD#{\31ε*.Ĝ =Ú#Q?D3HT4caBƟ%j"M$嘿Wg"F./cVbC9O٣#r6w HnI))ADO2\sI<~p煘P`<T]&/#]g1`̕{''㓫3;OߑF,qQ`5>ǕMKSwFH1=cՄKǭ&7kEt-aL4?aa&{ &0.Jta&-cהuHWzJe i$+QTUaЏ#=@2%x$DIFd D%Ed3مDL\L B(iF$rbD- >$^Z;|yzY lyAG0؇mћZ1 38gUGUzdG ny}߲AO,Ve tD%Fͼl5Omx8b&6:fFnm{CDEa!cU5\ۺZvд{r)H!w$״8Azlw >ME="j:j M摵xnpvx3ji|n{E3 ?FǒS0ZB;?.l\A A+r$Ze_ E5 }F-;hsjtz|\9i'D1nہS:q8{>p3]ryȠY(B#6fXR/9(g F+|ə"rK h;%JY1ꮫo!A[:SeC.yrG@w\HdY1@ SFwe۝N lKyI> ScɟS*wl)k:JDF R-뀰?_Er2QޞZk_ذ ]]C)0- O8ʀlqK^gKʱƎ)o?!j< e܄v C6cm`|b9! ^Fkv kje?\a6D6`ȢUevsx^fH3Sb0):[DX\Mv{[vNJV2H ?1\̡WLRBEeWtBnDd&?"* SrGKNyxe>kv 9\uH=R!$3=D۶{<|`bbv~ uE`CG|<\lҤb?&9R$X$K kger7] C90ѪP=z9zXQN,hƑYx$j4vIUOdB$LVPX;9_|c2Vdʳj&QqtxR\@X%^TxGԾϬ*I%=&.ĕ,&5w1ETW 2fp AHͫs婁DFU먀7Fd.;B||+4OKȈKJwpP}(س%:'>l1ыlyKPa`8 6hPj>2h@β6%W<ݪ\=Rzῌ1PZH;v%Bk%'z+:x_'M&w|(,`esd&6p7q:{fH<qYU]c,BMGm*ҕo] c#O Ra%W< SqXwDh*5(.%ȠnOd;g[/ILJ#|kfrnAV'`НŴYHf+u| +`}ޕ1+ I[tvf:u\A5uj+q_C>>  0qw5τהc@ ݣӷe "s )*"\-(!?,+Q|T<:vl* n2 p|t\XYP\C~hr 2v iٙ뾠To;B ̼X]A:VNw!s̏""L VP!-JJ 实zypEp`b&q,$tXM%u5( lOxn&|~s^WM-ܑ=|^ذ jiKr7-;"./ywܴs}F0 z~ĻJLw |!t%T"Xs:%]O:>wjE&R]tk;s1ds$W:/8V":W}͒…W2j1-^LCN:̆o S5g[0zt|Մ(๭>pˮxa_pKJO=E.\}ZA+tn,a@;';g=A sync inbox -> lecture -> envoi immédiat -> planifié/replanifié/send-now. - Règle simple + webhook exécutés réellement sur mail entrant. - Frontend principal mail ne dépend plus des mocks pour ces parcours. ## Phase 2 — Hardening (production-ready, `duration+`) ### Objectif Sécuriser, fiabiliser et observer la plateforme pour exploitation continue. ### Livrables - Chiffrement credentials au repos, validation inputs stricte, RBAC admin. - WS sécurisé par token (suppression `user_id` en query). - Retries/backoff + DLQ pour outbox et webhooks. - Observabilité complète (request-id, métriques, dashboards, alerting). - Normalisation erreurs API + pagination cross endpoints. - Couverture tests backend/CI (intégration handlers, workers, migrations) + tests e2e front parcours critiques. ### Critères de sortie - SLO minimaux atteints en staging. - CI bloque les regressions sur flux critiques. - Aucun secret sensible en clair en base. ## Phase 3 — Différenciation (IA + automatisations avancées, `duration+++`) ### Objectif Dépasser la parité Gmail/Google par les fonctions différenciantes Ulti Suite. ### Livrables - Rules engine avancé (simulation, priorités, conflits, actions composables). - Webhooks templates versionnés (preview, signature HMAC, retries et observabilité fine). - Tri IA configurable par règle (provider, prompt, garde-fous coût/latence). - Recherche globale multi-services (mail + contacts + agenda + drive). - APIs fine-grained pour agents externes (tokens/scopes). ### Critères de sortie - Un utilisateur peut configurer automatisations et IA sans code. - Résultats traçables et monitorés en production. - Recherche cross-services opérationnelle avec pertinence acceptable. ## Règle de priorisation 1. Corriger ce qui casse le produit (blocants/sécurité/cohérence). 2. Stabiliser le coeur Ultimail en réel. 3. Étendre puis différencier. TXxL# Ultidrive **Équivalent** : Google Drive **Statut** : Partiel (API proxy WebDAV/OCS) --- ## Résumé Frontend reproduisant à l'identique le comportement et l'interface de Google Drive, potentiellement comme frontend pour Nextcloud ou solution similaire déjà fonctionnelle. ## État d'implémentation réel (mai 2026) ### Déjà implémenté - API backend montée sous `/api/v1/drive` (si Nextcloud activé). - Endpoints list/upload/download/delete, create folder, move, create share. - Client Nextcloud WebDAV/OCS intégré côté serveur. ### Partiel / incomplet - Pas d'upload chunked gros fichiers. - Couverture incomplète des cas drive (copy, corbeille, favoris, récents). - Gestion quotas/permissions simplifiée non finalisée. ### Non commencé - UX frontend Drive de production branchée backend réel. - Édition collaborative docs/feuilles/présentations. - Sync offline-first complète (résolution de conflits). ## Approche technique L'idée est simple : on ne réinvente pas le stockage. On fournit une UX identique à Google Drive mais le backend de stockage est interchangeable : | Mode de stockage | Description | |------------------|-------------| | **WebDAV** | Connecté à un serveur WebDAV (Nextcloud, ownCloud, etc.) | | **S3-compatible** | Bucket S3, MinIO, Backblaze, etc. | | **Nextcloud natif** | Ultidrive = frontend custom pour Nextcloud (API OCS/WebDAV) | ### Contrainte clé : montage local Peu importe le backend, le stockage **doit pouvoir être monté comme un disque local** sur l'appareil de l'utilisateur (comme Google Drive ou Dropbox le permettent). Cela implique un client sync desktop (via Tauri ou en exploitant le client Nextcloud existant). ### Gestion des permissions Les permissions doivent être **simples à gérer** — pas d'ACL complexes. Modèle inspiré de Google Drive : - Propriétaire / Éditeur / Lecteur - Partage par lien (public, restreint, expiration) - Héritage des permissions parent (dossier → contenu) ### Option "frontend Nextcloud" Si c'est plus simple, Ultidrive peut être **purement un frontend** pour Nextcloud : - Nextcloud gère le stockage, la sync, les permissions, le versioning - Ultidrive = interface custom (même codebase/stack que le reste de la suite) - Avantage : on profite de l'écosystème Nextcloud (apps, clients, WebDAV) sans tout recoder ## Points de différenciation vs Google Drive - Auto-hébergeable, stockage sous contrôle total - Backend interchangeable (WebDAV / S3 / Nextcloud) - Montage local natif comme un vrai disque - Interface identique à Google Drive (migration sans friction) - Chiffrement côté client optionnel (zero-knowledge) - Automatisations à l'upload (OCR, classification IA, webhooks) ## Fonctionnalités ### Core - [ ] Upload / download fichiers et dossiers - [ ] Arborescence, favoris, récents, corbeille - [ ] Recherche full-text (contenu des documents) - [ ] Prévisualisation (images, PDF, vidéos, docs) - [ ] Versioning (historique des versions) ### Partage & collaboration - [ ] Partage par lien (public, protégé par mot de passe, expiration) - [ ] Partage avec utilisateurs/groupes (lecture / écriture / admin) - [ ] Édition collaborative temps réel (docs, tableurs, présentations) - [ ] Commentaires sur fichiers ### Sync & montage - [ ] Montage local comme disque (type Google Drive / Dropbox) - [ ] Client desktop sync (Tauri ou Nextcloud client natif) - [ ] WebDAV natif - [ ] Sync sélective (dossiers choisis) - [ ] Offline-first avec résolution de conflits ### Intégration suite - [ ] Pièces jointes Ultimail sauvegardées dans Drive - [ ] Fichiers joints aux événements Agenda - [ ] Stockage médias Ultiphotos - [ ] Partage dans Ultimeet (présentation) ## Intégration Nextcloud — étude technique ### APIs disponibles (confirmé) | Opération | API Nextcloud | Endpoint | |-----------|---------------|----------| | Lister fichiers | WebDAV PROPFIND | `/remote.php/dav/files/{user}/` | | Upload | WebDAV PUT | `/remote.php/dav/files/{user}/{path}` | | Upload gros fichiers | Chunked v2 | `/remote.php/dav/uploads/{user}/` (chunks 5MB-5GB) | | Download | WebDAV GET | `/remote.php/dav/files/{user}/{path}` | | Créer dossier | WebDAV MKCOL | `/remote.php/dav/files/{user}/{path}` | | Déplacer/copier | WebDAV MOVE/COPY | Headers Destination | | Supprimer | WebDAV DELETE | Standard | | Créer un partage | OCS POST | `/ocs/v2.php/apps/files_sharing/api/v1/shares` | | Modifier partage | OCS PUT | `.../shares/{id}` | | Partage public | WebDAV | `/public.php/dav` (depuis NC 29) | ### Permissions — mapping simple confirmé Nextcloud utilise un système bitwise simple qui mappe directement sur notre modèle : | Permission | Bit | Mapping Ultidrive | |------------|-----|-------------------| | Read | 1 | Lecteur | | Update | 2 | Éditeur | | Create | 4 | Éditeur | | Delete | 8 | Éditeur | | Share | 16 | Propriétaire | | All | 31 | Propriétaire | Types de partage supportés : user (0), group (1), public link (3), email (4), federated (6). Options : `password`, `expireDate` (YYYY-MM-DD), `publicUpload`. ### Montage local — solution retenue : rclone | Plateforme | Méthode | Dépendance | |------------|---------|------------| | Linux | `rclone mount` via FUSE | libfuse3 | | macOS | `rclone mount` via macFUSE | macFUSE | | Windows | `rclone mount` via WinFsp | WinFsp | Avantages de rclone vs client Nextcloud Desktop : - Plus stable (le VFS Nextcloud est expérimental sur Linux) - Supporte WebDAV ET S3 avec la même commande - VFS caching configurable (mode off/minimal/writes/full) - Bundlable dans l'app Tauri comme sidecar Stratégie pour Tauri : rclone embarqué en sidecar, lancé/arrêté par l'app, configuration gérée programmatiquement. ### Déploiement Nextcloud headless (API-only) Nextcloud peut tourner en mode backend pur : - Image Docker FPM (pas d'interface web servie directement) - Reverse proxy qui route uniquement `/remote.php/dav`, `/ocs/`, `/public.php/dav` - L'UI Nextcloud n'est jamais exposée aux utilisateurs — seul Ultidrive est le frontend ``` ┌──────────────┐ ┌──────────────────┐ ┌──────────────┐ │ Ultidrive │────▶│ Reverse Proxy │────▶│ Nextcloud │ │ (frontend) │ │ (nginx) │ │ (PHP-FPM) │ └──────────────┘ └──────────────────┘ └──────────────┘ │ │ │ ┌────┴────┐ Routes exposées : │ Storage │ /remote.php/dav/* │ (S3/local) /ocs/v2.php/* └─────────┘ /public.php/dav/* ``` ## Briques technologiques envisagées | Besoin | Option retenue | Alternatives | |--------|----------------|--------------| | Backend fichiers | Nextcloud (PHP-FPM headless) | ownCloud Infinite Scale | | Protocole sync | WebDAV (natif NC) | — | | Object storage | MinIO / S3-compatible (via NC external storage) | Stockage local | | Montage local | rclone (sidecar Tauri) | client NC Desktop | | Édition collaborative | OnlyOffice, Collabora Online | — | | Recherche contenu | Meilisearch (indexation custom) | NC full-text search app | | Auth | Partagée via Ulti Suite (OIDC → NC) | — | Gtx<# Ultimail **Équivalent** : Gmail **Statut** : Partiel (backend avancé, incomplet) --- ## Résumé Client mail unifié multi-comptes avec backend de synchronisation. Un compte Ultimail gère plusieurs comptes mail (SMTP/IMAP/POP3) avec identités d'envoi/réception distinctes, catch-all, et libellés unifiés. ## État d'implémentation réel (mai 2026) ### Déjà implémenté - API `/api/v1/mail` avec endpoints comptes, messages, threads, envoi, règles, webhooks. - Workers backend IMAP sync et SMTP outbox démarrés au boot. - Schéma SQL principal mail en place (accounts, messages, folders, rules, outbox, webhooks, attachments). ### Partiel / incomplet - Outbox planifiée: incohérence de statuts `scheduled`/`queued`. - Règles et webhooks: briques présentes mais pas entièrement branchées au pipeline réel de réception. - Threading, pièces jointes et identités d'envoi encore incomplets. - Realtime WS non finalisé côté auth/events. ### Non commencé - Tri IA en production. - Tokens API fine-grained pour agents externes. - Expérience desktop Tauri/mobile branchée au backend réel. ## Points de différenciation vs Gmail - Webhooks avancés avec système de templates personnalisables (Slack, Discord, custom) - Connectivité contrôlée avec agents IA via tokens API fine-grained - Tri intelligent par LLM (fournisseurs OpenAI-compatibles, prompt personnalisé par règle) - Hébergement souverain, données sous contrôle - Multi-comptes natif avec unification complète (libellés, dossiers, recherche cross-comptes) ## Fonctionnalités ### Core - [ ] Réception / envoi de mails (IMAP/SMTP) - [ ] Multi-comptes avec identités d'envoi/réception - [ ] Catch-all (envoi et réception) - [ ] Conversations / threads - [ ] Libellés et dossiers unifiés - [ ] Recherche avancée - [ ] Pièces jointes - [ ] Brouillons, envoi programmé - [ ] Contacts intégrés ### Automatisations - [ ] Règles de tri à la réception - [ ] Forward automatique - [ ] Réponses automatiques - [ ] Webhooks avec templates - [ ] Tri IA (LLM + prompt personnalisé) - [ ] Tokens API fine-grained pour agents ### UX - [ ] Interface inspirée Gmail (migration sans friction) - [ ] Desktop web + Tauri + mobile — UX uniforme - [ ] Thèmes, densité, préférences par compte - [ ] Raccourcis clavier complets - [ ] Offline-first avec sync backend ## Intégration avec la suite (Nextcloud) Ultimail utilise sa **propre stack mail** (pas le module mail de Nextcloud qui est insuffisant) mais s'intègre avec l'instance Nextcloud partagée pour les services complémentaires : ### Ce qu'Ultimail utilise de Nextcloud | Service | Usage dans Ultimail | API | |---------|--------------------|----| | **Ultidrive (WebDAV)** | Sauvegarder les pièces jointes dans Drive | PUT `/remote.php/dav/files/{user}/` | | **Ultidrive (WebDAV)** | Insérer des fichiers Drive dans un mail | GET + lien de partage OCS | | **Agenda (CalDAV)** | Détecter les invitations .ics et créer des événements | PUT `.../calendars/{user}/{cal}/{uid}.ics` | | **Agenda (CalDAV)** | Afficher les événements du jour dans la sidebar mail | REPORT calendar-query | | **Contacts (CardDAV)** | Autocomplétion destinataires depuis le carnet | REPORT addressbook-query | | **Contacts (CardDAV)** | Enrichir les fiches contact avec l'historique mail | Sync bidirectionnelle | ### Ce qu'Ultimail NE délègue PAS à Nextcloud - **IMAP/SMTP** — client mail custom (stalwart-mail, maddy, ou implémentation propre) - **Stockage des mails** — PostgreSQL + object storage propre (pas la DB Nextcloud) - **Règles de tri, automatisations, webhooks** — moteur custom dans le backend Ultimail - **Recherche mail** — index dédié (Meilisearch/Typesense) distinct de la recherche NC - **Auth mail** — OAuth2/App passwords gérés par le backend Ultimail, pas par NC ### Flux d'interaction ``` ┌──────────────────────────────────────────────────────────┐ │ Frontend Ultimail │ └────────────┬─────────────────────────────┬───────────────┘ │ │ ▼ ▼ ┌────────────────────────┐ ┌────────────────────────────┐ │ Backend Ultimail │ │ Nextcloud (headless) │ │ ├─ IMAP/SMTP client │ │ ├─ WebDAV (pièces jointes) │ ├─ Moteur de règles │───▶│ ├─ CalDAV (invitations) │ │ ├─ Stockage mails │ │ └─ CardDAV (contacts) │ │ ├─ Webhooks/IA │ └────────────────────────────┘ │ └─ API sync clients │ └────────────────────────┘ ``` Le backend Ultimail communique avec Nextcloud **côté serveur** pour : - Créer un événement quand un mail contient une invitation .ics - Résoudre les contacts pour l'affichage (photo, nom complet) - Proposer "Sauvegarder dans Drive" pour les pièces jointes ## Briques technologiques envisagées | Besoin | Option retenue | Alternatives | |--------|----------------|--------------| | IMAP/SMTP | stalwart-mail, maddy, ou client custom | — | | Recherche full-text | Meilisearch, Typesense | — | | Stockage mails | PostgreSQL + object storage (attachments) | — | | Push/sync temps réel | WebSocket, SSE | — | | Pièces jointes → Drive | Nextcloud WebDAV (même instance) | — | | Calendrier (invitations) | Nextcloud CalDAV (même instance) | — | | Contacts (autocomplétion) | Nextcloud CardDAV (même instance) | — | | Auth | OIDC partagé Ulti Suite | — | ## Voir aussi - [CLAUDE.md](../CLAUDE.md) — contexte technique détaillé du frontend actuel - [ultidrive.md](ultidrive.md) — détails intégration Nextcloud fichiers - [agenda.md](agenda.md) — détails intégration Nextcloud calendrier - [contacts.md](contacts.md) — détails intégration Nextcloud contacts - `components/gmail/README.md` — arborescence composants - `lib/stores/README.md` — architecture stores ޹zxQ# Ultimaps **Équivalent** : Google Maps **Statut** : Non commencé --- ## Résumé Service de cartographie et navigation avec données OpenStreetMap, itinéraires, points d'intérêt et intégration avec les autres services (agenda, contacts, drive). ## État d'implémentation réel (mai 2026) ### Déjà implémenté - Aucun composant backend/service dédié dans ce repository. ### Partiel / incomplet - N/A à ce stade (pas de base de code maps existante). ### Non commencé - API géocodage. - API routing. - Intégrations Agenda/Contacts/Photos. - UI maps et capacité offline. ## Points de différenciation vs Google Maps - Basé sur OpenStreetMap (données libres, contributives) - Aucun tracking publicitaire ou profiling de déplacements - Cartes offline complètes - POI personnalisés et listes partagées entre utilisateurs - API de géocodage auto-hébergeable ## Fonctionnalités ### Core - [ ] Carte interactive (tuiles OSM) - [ ] Recherche d'adresses et POI (géocodage) - [ ] Itinéraires (voiture, transports, vélo, piéton) - [ ] Navigation turn-by-turn - [ ] Vue satellite (si source disponible) ### Organisation - [ ] Lieux enregistrés / favoris - [ ] Listes de lieux personnalisées - [ ] Historique des lieux visités (opt-in) - [ ] Partage de position temps réel (opt-in) ### Offline - [ ] Téléchargement de zones pour usage hors-ligne - [ ] Navigation offline - [ ] Sync des lieux sauvegardés ### Intégration suite - [ ] Lieu des événements Agenda (carte intégrée) - [ ] Adresses des Contacts sur la carte - [ ] Géolocalisation des photos (Ultiphotos) - [ ] Partage de lieu via Ultimail / Ultimeet ## Briques technologiques envisagées | Besoin | Option open-source | |--------|--------------------| | Données cartographiques | OpenStreetMap | | Rendu tuiles | MapLibre GL, Protomaps | | Géocodage | Nominatim, Pelias | | Routing | OSRM, Valhalla, GraphHopper | | Tuiles serveur | Tileserver GL, Martin | \3xu# Ultimeet **Équivalent** : Google Meet **Statut** : Partiel (JWT Jitsi minimal) --- ## Résumé Visioconférence et appels audio/vidéo intégrés à la suite, avec partage d'écran, chat, enregistrement et transcription. ## État d'implémentation réel (mai 2026) ### Déjà implémenté - API backend montée sous `/api/v1/meet` (si Jitsi activé). - Endpoints create room + token d'accès salle. - Génération JWT côté serveur pour Jitsi. ### Partiel / incomplet - Gestion modérateur basique seulement. - Pas de persistance sessions/participants. - Pas d'intégration complète agenda/mail sur le cycle de vie des réunions. ### Non commencé - Enregistrement et stockage automatique dans Drive. - Transcription et résumé IA. - Tableau blanc, sondages et collaboration avancée. ## Points de différenciation vs Google Meet - Basé sur Jitsi ou LiveKit (open-source, auto-hébergeable) - Transcription et résumé automatique par IA - Enregistrement stocké dans Ultidrive - Salles persistantes avec historique - Intégration profonde agenda + mail (rappels, notes, follow-up auto) ## Fonctionnalités ### Core - [ ] Appels audio/vidéo (1:1 et groupe) - [ ] Partage d'écran - [ ] Chat en réunion - [ ] Réactions et lever la main - [ ] Arrière-plans virtuels - [ ] Réduction de bruit ### Enregistrement & IA - [ ] Enregistrement vidéo (stocké dans Ultidrive) - [ ] Transcription temps réel - [ ] Résumé automatique post-réunion - [ ] Détection des actions items ### Collaboration - [ ] Tableau blanc partagé - [ ] Notes collaboratives en réunion - [ ] Sondages en direct - [ ] Sous-titres multi-langues ### Intégration suite - [ ] Lien auto dans les événements Agenda - [ ] Invitation par Ultimail - [ ] Fichiers partagés depuis Ultidrive pendant l'appel - [ ] Résumé envoyé par mail post-réunion - [ ] Participants depuis Contacts ## Briques technologiques envisagées | Besoin | Option open-source | |--------|--------------------| | WebRTC / SFU | Jitsi, LiveKit, mediasoup | | Transcription | Whisper (OpenAI), Vosk | | Résumé IA | LLM OpenAI-compatible | | Stockage enregistrements | Ultidrive / MinIO |  xx n# Ultiphotos **Équivalent** : Google Photos **Statut** : Partiel (proxy Immich minimal) --- ## Résumé Gestion de photos et vidéos avec stockage cloud, organisation intelligente (IA), partage et albums collaboratifs. Stockage sur Ultidrive. ## État d'implémentation réel (mai 2026) ### Déjà implémenté - API backend montée sous `/api/v1/photos` (si Immich activé). - Endpoints list assets, upload, thumbnail, delete asset, list albums. - Client Immich côté serveur intégré. ### Partiel / incomplet - Gestion albums incomplète (list seulement). - Mapping auth/api key à fiabiliser selon intégration Immich cible. - Pas de chaînage complet quota/storage avec Drive. ### Non commencé - Fonctions IA photos (visages, scènes, souvenirs) côté produit Ulti. - Partage avancé albums avec permissions granulaires finalisées. - Expérience frontend photos de production branchée backend réel. ## Points de différenciation vs Google Photos - Stockage sur infrastructure propre (pas de compression forcée) - Classification IA auto-hébergeable (pas d'envoi à un tiers) - Albums partagés avec permissions granulaires - Export complet sans perte (original toujours conservé) - Intégration native Ultidrive (même quota, même stockage) ## Fonctionnalités ### Core - [ ] Upload photos / vidéos (originaux conservés) - [ ] Galerie chronologique - [ ] Albums manuels et albums intelligents (auto-générés) - [ ] Recherche par date, lieu, personnes, objets - [ ] Favoris, archive, corbeille ### Organisation IA - [ ] Détection de visages et regroupement par personne - [ ] Classification par scène / objet - [ ] Géolocalisation et carte - [ ] Souvenirs / "Ce jour-là" automatiques - [ ] Suggestions de partage ### Édition - [ ] Retouche basique (crop, rotation, filtres, luminosité) - [ ] Suggestions d'amélioration IA ### Partage - [ ] Albums partagés (lecture / contribution) - [ ] Lien de partage (public, protégé, expiration) - [ ] Partage vers Ultimail, Ultimeet ### Sync - [ ] Sync automatique depuis mobile (app) - [ ] Sync depuis desktop - [ ] Dossiers Ultidrive comme source ## Briques technologiques envisagées | Besoin | Option open-source | |--------|--------------------| | Gestion photos | Immich, LibrePhotos, PhotoPrism | | Reconnaissance faciale | InsightFace, dlib | | Classification | CLIP, BLIP | | Stockage | Ultidrive / MinIO | | Métadonnées | PostgreSQL + EXIF parsing | mWfqB̿q2+ž9