Class: CopyTunerClient::Cache

Inherits:
Object
  • Object
show all
Defined in:
lib/copy_tuner_client/cache.rb

Overview

Manages synchronization of copy between I18nBackend and Client. Acts like a Hash. Applications using the client will not need to interact with this class directly.

Responsible for locking down access to data used by both threads.

Constant Summary collapse

STATUS_NOT_READY =

rubocop:disable Metrics/ClassLength

:not_ready
STATUS_PENDING = 
:pending
STATUS_READY = 
:ready

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(client, options) ⇒ Cache

Usually instantiated when CopyTunerClient::Configuration#apply is invoked.

Parameters:

  • client (Client) —

    the client used to fetch and upload data

  • options (Hash)

Options Hash (options):

  • :logger (Logger) —

    where errors should be logged



19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/copy_tuner_client/cache.rb', line 19

def initialize(client, options)
  @client = client
  @logger = options[:logger]
  @mutex = Mutex.new
  @local_first_key_regexp = options[:local_first_key_regexp]
  @upload_disabled = options[:upload_disabled]
  @ignored_keys = options.fetch(:ignored_keys, [])
  @ignored_key_handler = options.fetch(:ignored_key_handler, -> (e) { raise e })
  @locales = Array(options[:locales]).map(&:to_s)
  # mutable states
  @blurbs = {}
  @blank_keys = Set.new
  @queued = {}
  @status = STATUS_NOT_READY
end

Instance Attribute Details

#blank_keys ⇒ Object (readonly)

blank_keys を公開しているのは、MCP ツール等の外部利用者が「キーは登録済みだが翻訳なし」と「キー未登録」を区別するため（このリポジトリ内では参照箇所がない）。



37
38
39
 
# File 'lib/copy_tuner_client/cache.rb', line 37

def blank_keys
  @blank_keys
end

#blurbs ⇒ Object (readonly)

blank_keys を公開しているのは、MCP ツール等の外部利用者が「キーは登録済みだが翻訳なし」と「キー未登録」を区別するため（このリポジトリ内では参照箇所がない）。



37
38
39
 
# File 'lib/copy_tuner_client/cache.rb', line 37

def blurbs
  @blurbs
end

#last_downloaded_at ⇒ Object (readonly)

blank_keys を公開しているのは、MCP ツール等の外部利用者が「キーは登録済みだが翻訳なし」と「キー未登録」を区別するため（このリポジトリ内では参照箇所がない）。



37
38
39
 
# File 'lib/copy_tuner_client/cache.rb', line 37

def last_downloaded_at
  @last_downloaded_at
end

#last_uploaded_at ⇒ Object (readonly)

blank_keys を公開しているのは、MCP ツール等の外部利用者が「キーは登録済みだが翻訳なし」と「キー未登録」を区別するため（このリポジトリ内では参照箇所がない）。



37
38
39
 
# File 'lib/copy_tuner_client/cache.rb', line 37

def last_uploaded_at
  @last_uploaded_at
end

#queued ⇒ Object (readonly)

blank_keys を公開しているのは、MCP ツール等の外部利用者が「キーは登録済みだが翻訳なし」と「キー未登録」を区別するため（このリポジトリ内では参照箇所がない）。



37
38
39
 
# File 'lib/copy_tuner_client/cache.rb', line 37

def queued
  @queued
end

Instance Method Details

#[](key) ⇒ String

Returns content for the given blurb.

Parameters:

  • key (String) —

    the key of the desired blurb

Returns:

  • (String) —

    the contents of the blurb



42
43
44
 
# File 'lib/copy_tuner_client/cache.rb', line 42

def [](key)
  lock { @blurbs[key] }
end

#[]=(key, value) ⇒ Object

Sets content for the given blurb. The content will be pushed to the server on the next flush.

Parameters:

  • key (String) —

    the key of the blurb to update

  • value (String) —

    the new contents of the blurb



50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
 
# File 'lib/copy_tuner_client/cache.rb', line 50

def []=(key, value)
  return unless key.include?('.')
  return if @locales.present? && !@locales.member?(key.split('.').first)
  return if @upload_disabled

  # NOTE: config/locales以下のファイルに除外キーが残っていた場合の対応
  key_without_locale = key.split('.')[1..].join('.')
  # NOTE: local_first キー（組み込みの Rails number.*.format + ユーザー設定）は copy_tuner と完全分離するためアップロードしない
  return if local_first_key?(key_without_locale)

  if @ignored_keys.include?(key_without_locale)
    @ignored_key_handler.call(IgnoredKey.new("Ignored key: #{key_without_locale}"))
  end

  lock do
    return if @blank_keys.member?(key) || @blurbs.key?(key)

    @queued[key] = value
  end
end

#download ⇒ Object 



122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
 
# File 'lib/copy_tuner_client/cache.rb', line 122

def download
  @status = STATUS_PENDING unless ready?

  res = client.download(cache_fallback: pending?) do |downloaded_blurbs|
    blank_keys = Set.new
    blurbs = {}
    downloaded_blurbs.each { |key, value| value == '' ? blank_keys << key : blurbs[key] = value }
    lock do
      @blank_keys = blank_keys
      @blurbs = blurbs
    end
  end

  @last_downloaded_at = Time.now.utc
  @status = STATUS_READY unless ready?

  res
rescue ConnectionError => e
  logger.error e.message
  raise e unless ready?
end

#export ⇒ String

Yaml representation of all blurbs

Returns:

  • (String) —

    yaml



79
80
81
82
 
# File 'lib/copy_tuner_client/cache.rb', line 79

def export
  tree_hash = to_tree_hash
  tree_hash.present? ? tree_hash.to_yaml : nil
end

#flush ⇒ Object 



110
111
112
113
114
115
116
117
118
119
120
 
# File 'lib/copy_tuner_client/cache.rb', line 110

def flush
  res = with_queued_changes do |queued|
    client.upload queued
  end

  @last_uploaded_at = Time.now.utc

  res
rescue ConnectionError => e
  logger.error e.message
end

#inspect ⇒ Object 



150
151
152
 
# File 'lib/copy_tuner_client/cache.rb', line 150

def inspect
  "#<CopyTunerClient::Cache:#{object_id}>"
end

#keys ⇒ Array<String>

Keys for all blurbs stored on the server.

Returns:

  • (Array<String>) —

    keys



73
74
75
 
# File 'lib/copy_tuner_client/cache.rb', line 73

def keys
  lock { @blurbs.keys }
end

#pending? ⇒ Boolean

Returns:

  • (Boolean) 


154
155
156
 
# File 'lib/copy_tuner_client/cache.rb', line 154

def pending?
  @status == STATUS_PENDING
end

#ready? ⇒ Boolean

Returns:

  • (Boolean) 


158
159
160
 
# File 'lib/copy_tuner_client/cache.rb', line 158

def ready?
  @status == STATUS_READY
end

#sync ⇒ Object

Downloads and then flushes



145
146
147
148
 
# File 'lib/copy_tuner_client/cache.rb', line 145

def sync
  download
  flush
end

#to_tree_hash ⇒ Hash

ツリー構造のハッシュを返す（I18nBackend用）

Returns:

  • (Hash) —

    ツリー構造に変換されたblurbs



86
87
88
 
# File 'lib/copy_tuner_client/cache.rb', line 86

def to_tree_hash
  lock { @blurbs.present? ? DottedHash.to_h(@blurbs) : {} }
end

#version ⇒ String?

キャッシュの更新バージョンを返す（ツリーキャッシュの無効化判定用）ETags を使用してサーバーサイドの更新を検知

Returns:

  • (String, nil) —

    現在のETag値



93
94
95
 
# File 'lib/copy_tuner_client/cache.rb', line 93

def version
  client.etag
end

#wait_for_download ⇒ Object

Waits until the first download has finished.



98
99
100
101
102
103
104
105
106
107
108
 
# File 'lib/copy_tuner_client/cache.rb', line 98

def wait_for_download
  return unless pending?

  logger.info 'Waiting for first download'

  if logger.respond_to? :flush
    logger.flush
  end

  sleep 0.1 while pending?
end