Iddisinja sync offline għal app tal-apprendiment: kif tirriżolvi l-konflitti?

Question

IT Interview Practice · Accepted Answer

Ittratta l-app bħala **offline-first**: kull apparat huwa **replica** lokali. L-azzjonijiet tal-istudju jinkitbu f'**local DB** flimkien ma' **op log** (outbox) li jżid biss; mal-konnessjoni mill-ġdid l-apparat **jibgħat l-ops tiegħu** u **jiġbed il-bidliet mis-server** minn meta sar l-aħħar sync. Il-konflitti jiġu riżolti **mhux** b'regola globali waħda iżda bis-**semantika ta' kull data field**.

**Mudell mentali:** aħseb fih bħal **git** — kull apparat "jikkommittja" lokalment waqt li huwa offline, u s-sync huwa **merge**, mhux overwrite.

## Arkitettura

```text
Device (offline)                        Server = source of truth
┌──────────────────┐   on reconnect     ┌───────────────────────────┐
│ Local DB (SQLite)│  push ops (delta)  │ Sync API  /sync           │
│ + Op log (outbox)│ ─────────────────▶ │  • idempotent by op.id    │
│ cursor = lastSeen│ ◀───────────────── │  • merge by semantics     │
└──────────────────┘  pull changes>cursor└───────────────────────────┘
                                         Progress DB (Postgres)
```

- **Local DB + op log:** kull bidla hija **op immutabbli b'id iġġenerat mill-klijent** + verżjoni, imqiegħda fil-queue waqt li offline. L-UI jaqra/jikteb lokalment biex jibqa' bla intoppi mingħajr network.
- **Sync service:** sync **delta bbażat fuq cursor** — jibgħat l-ops minn meta kien il-cursor tal-klijent, jiġbed il-bidliet li huma aktar riċenti minnu. Kull sync jiċċaqlaq biss id-**delta**, mhux id-dataset kollu → 5M utent jibqa' rħis.
- **Conflict resolver:** jgħaqqad skont it-tifsira ta' kull field (hawn taħt). Is-**server huwa s-source of truth**; il-klijent jirriżolvi l-ewwel għall-fluwidità, imbagħad is-server jerġa' japplika l-**istess** merge deterministiku.

## Riżoluzzjoni tal-konflitti (il-qalba)

L-arloġġi tat-telefowns huma **mhux affidabbli** u żewġ apparati jistgħu jeditjaw l-istess record offline, għalhekk **"last write wins" (LWW) jitlef id-data fis-skiet**. Irriżolvi bis-semantika:

- **Fields monotoniċi** (progress tal-lezzjoni) → ħu l-**max**.
- **Counters additivi** (ħin totali tal-istudju) → **żid id-delta** (grow-only counter fl-istil CRDT).
- **"Latest state" veru** (pożizzjoni tal-iscroll) → LWW huwa aċċettabbli.

```js
// op għandu id -> applika b'mod idempotent (ir-retries ma jgħoddux darbtejn). clientTs MHUX fdat.
function mergeProgress(server, op) {
  return {
    // il-progress jiżdied biss -> max: op qadim li jasal tard qatt ma jġibu lura
    progress: Math.max(server.progress ?? 0, op.progress),
    // studiedMs huwa counter additiv -> żid id-delta, tagħmilx overwrite
    studiedMs: (server.studiedMs ?? 0) + op.studiedMs,
    completedAt: server.completedAt ?? (op.progress >= 1 ? op.clientTs : null),
  };
}
```

Hawnhekk, LWW sempliċi kien iħalli apparat stale li jissinkronizza tard b'`progress: 0.3` **jagħmel overwrite** tal-`0.9` tas-server → progress mitluf. Meta tieħu `max` u tgħodd `studiedMs` is-sync isir **indipendenti mill-ordni** — sikur meta miljuni ta' apparati jissinkronizzaw b'arloġġi skjuwati.

## Lenti tal-intervista

L-intervistatur qed jittestja jekk tafx li **l-arloġġi tal-klijent ma jistgħux jiġu fdati** (allura mhux LWW puru b'timestamp), jekk tagħmilx is-**sync idempotent** (op ids), u jekk **tgħaqqadx skont it-tifsira tad-data**. Tweġiba **dgħajfa**: "uża timestamps, last write wins." Tweġiba **b'saħħitha**: replica + op log + idempotency + merge għal kull field + server bħala source of truth — u ssemmi b'mod espliċitu l-falliment ta' **telf ta' data** ta' LWW.

## Trade-offs

LWW huwa rħis iżda jitlef id-data; merge semantiku jeħtieġ ħsieb għal kull field iżda **ma jitlef xejn**. Uża **CRDT/OT** sħiħ biss meta jkollok bżonn editjar kollaborattiv veru (noti, dokumenti) — huwa għali, allura tużahx għal kollox.

Arkitettura

Riżoluzzjoni tal-konflitti (il-qalba)

Lenti tal-intervista

Trade-offs

Mistoqsijiet relatati