Function getDeviceId

packages/core/src/db/db-core.ts:222–279

()

/** Get or create device ID for sync tracking */
export async function getDeviceId(): Promise<string> {
  if (cachedDeviceId) return cachedDeviceId;

  const platform = getPlatformService();
  let kvAvailable = true;

  try {
    const storedDeviceId = await platform.kvGetItem(DEVICE_ID_STORAGE_KEY);
    if (storedDeviceId) {
      cachedDeviceId = storedDeviceId;
      try {
        const database = await getDB();
        await database.execute(
          "INSERT OR REPLACE INTO sync_metadata (key, value) VALUES ('device_id', ?)",
          [storedDeviceId],
        );
      } catch {
        // Table might not exist yet during init
      }
      return storedDeviceId;
    }
  } catch {
    kvAvailable = false;
  }

  const database = await getDB();
  if (!kvAvailable) {
    try {
      const rows = await database.select<{ value: string }>(
        "SELECT value FROM sync_metadata WHERE key = 'device_id'",
      );
      if (rows.length > 0 && rows[0].value) {
        cachedDeviceId = rows[0].value;
        return rows[0].value;
      }
    } catch {
      // Table might not exist yet
    }
  }

  // Generate new device ID
  const id = generateId();
  try {
    await database.execute(
      "INSERT OR REPLACE INTO sync_metadata (key, value) VALUES ('device_id', ?)",
      [id],
    );
  } catch {
    // Table might not exist yet during init
  }
  try {
    await platform.kvSetItem(DEVICE_ID_STORAGE_KEY, id);
  } catch {
    // Ignore KV persistence errors; DB copy will still exist.
  }
  cachedDeviceId = id;
  return id;
}