File: data_controller.cc

package info (click to toggle)
chromium 138.0.7204.183-1~deb12u1
  • links: PTS, VCS
  • area: main
  • in suites: bookworm-proposed-updates
  • size: 6,080,960 kB
  • sloc: cpp: 34,937,079; ansic: 7,176,967; javascript: 4,110,704; python: 1,419,954; asm: 946,768; xml: 739,971; pascal: 187,324; sh: 89,623; perl: 88,663; objc: 79,944; sql: 50,304; cs: 41,786; fortran: 24,137; makefile: 21,811; php: 13,980; tcl: 13,166; yacc: 8,925; ruby: 7,485; awk: 3,720; lisp: 3,096; lex: 1,327; ada: 727; jsp: 228; sed: 36
file content (99 lines) | stat: -rw-r--r-- 2,908 bytes parent folder | download | duplicates (6)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
// Copyright 2022 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "chrome/browser/ash/arc/input_overlay/db/data_controller.h"

#include "base/files/file.h"
#include "base/files/file_util.h"
#include "base/functional/bind.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/task_runner.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "chrome/browser/ash/arc/input_overlay/db/proto/app_data.pb.h"
#include "chrome/browser/profiles/profile.h"
#include "chrome/browser/profiles/profile_key.h"

namespace arc::input_overlay {
namespace {

// Base directory for saving customized data in the user profile.
constexpr char kPath[] = "google_gio";

std::optional<base::FilePath> CreateOrGetDirectory(
    const base::FilePath& storage_dir) {
  if (base::PathExists(storage_dir)) {
    return storage_dir;
  }
  if (base::CreateDirectory(storage_dir)) {
    return storage_dir;
  }

  LOG(ERROR) << "Failed to create the base storage directory: "
             << storage_dir.value();
  return std::nullopt;
}

bool ProtoFileExists(const base::FilePath& file_path) {
  return base::PathExists(file_path);
}

void CreateEmptyFile(const base::FilePath& file_path) {
  if (FILE* file = base::OpenFile(file_path, "wb+")) {
    base::CloseFile(file);
    return;
  }

  LOG(ERROR) << "Failed to create file: " << file_path.value();
}

}  // namespace

DataController::DataController(
    content::BrowserContext& browser_context,
    scoped_refptr<base::SequencedTaskRunner> task_runner) {
  task_runner_ = task_runner;
  Profile* profile = Profile::FromBrowserContext(&browser_context);
  ProfileKey* profile_key = profile->GetProfileKey();
  storage_dir_ = profile_key->GetPath().Append(kPath);
}

DataController::~DataController() = default;

base::FilePath DataController::GetFilePathFromPackageName(
    const std::string& package_name) {
  base::FilePath file_path(storage_dir_);
  return file_path.Append(package_name);
}

std::unique_ptr<AppDataProto> DataController::ReadProtoFromFile(
    base::FilePath file_path) {
  if (auto base_path = CreateOrGetDirectory(file_path.DirName()); !base_path) {
    return nullptr;
  }

  if (!ProtoFileExists(file_path)) {
    CreateEmptyFile(file_path);
    return nullptr;
  }

  std::string out;
  std::unique_ptr<AppDataProto> proto = std::make_unique<AppDataProto>();
  if (!base::ReadFileToString(file_path, &out) ||
      !(proto->ParseFromString(out))) {
    return nullptr;
  }
  return proto;
}

bool DataController::WriteProtoToFile(std::unique_ptr<AppDataProto> proto,
                                      base::FilePath file_path) {
  std::string proto_str;
  if (!proto->SerializeToString(&proto_str)) {
    return false;
  }
  return base::WriteFile(file_path, proto_str);
}

}  // namespace arc::input_overlay