Class: Fiona7::Controllers::RestAPI::ObjController

Inherits:
Object
  • Object
show all
Defined in:
lib/fiona7/controllers/rest_api/obj_controller.rb

Instance Method Summary collapse

Instance Method Details

#create(workspace_id, values) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/fiona7/controllers/rest_api/obj_controller.rb', line 25

def create(workspace_id, values)
  assert_writable(workspace_id)

  # some stupid creators give us an id. fck them
  values[:obj].delete("_id")
  values[:obj].delete(:_id)
  path = values[:obj][:_path]  || values[:obj]["_path"]
  # This is a hack to make it seem as if the root obj does not exist
  if (path == "/") || ( obj = Fiona7::WriteObj.where(obj_class: 'X_Container', path: path).first )
    obj = Builder::ObjUpdater.new(values[:obj].merge(_id: ((obj && obj.id) || 2001))).build
  else
    obj = Builder::ObjBuilder.new(values[:obj].dup).build
  end

  klass = EditedObj
  decorated = Fiona7::JSON::ReverseObjDecorator.new(klass, obj)

  ::Fiona7.run_callbacks(:create_obj, obj.id)
  
  return ::JSON.parse(::ActiveSupport::JSON.encode(decorated))
end

#destroy(workspace_id, obj_id) ⇒ Object 



211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
 
# File 'lib/fiona7/controllers/rest_api/obj_controller.rb', line 211

def destroy(workspace_id, obj_id)
  # TODO: cleanup /_widgets and /_uploads
  obj = WriteObj.find(obj_id)
  if !obj.children.empty?
    if obj.children.all? {|c| c.name == '_widgets' || c.name == '_uploads' }
      remove_obj_tree(obj)
    else
      Assert.input(
        false,
        "Cannot remove object #{obj_id} because it has children objects"
      )
    end
  else
    obj.destroy
  end
  return {}
end

#fetch_by_id(workspace_id, obj_id) ⇒ Object 



84
85
86
87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/fiona7/controllers/rest_api/obj_controller.rb', line 84

def fetch_by_id(workspace_id, obj_id)
  klass = matching_class(workspace_id)
  obj = klass.where(obj_id: obj_id).first

  Assert.input(
    !obj.nil?,
    "Obj with id #{obj_id} not found in workspace #{workspace_id}",
    404
  )

  decorated = Fiona7::JSON::ReverseObjDecorator.new(klass, obj)
  response = ::JSON.parse(::ActiveSupport::JSON.encode(decorated))
  return response
end

#fetch_by_id_from_revision(revision_id, obj_id) ⇒ Object 



99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
 
# File 'lib/fiona7/controllers/rest_api/obj_controller.rb', line 99

def fetch_by_id_from_revision(revision_id, obj_id)
  # TODO: use implementation from ContentService controller
  # FIXME: code duplication with fetch_by_id
  klass = revision_id.start_with?('f') ? ReleasedObj : EditedObj
  obj = klass.where(obj_id: obj_id).first

  Assert.input(
    !obj.nil?,
    "Obj with id #{obj_id} not found in revision #{revision_id}",
    404
  )

  decorated = Fiona7::JSON::ReverseObjDecorator.new(klass, obj)
  return ::JSON.parse(::ActiveSupport::JSON.encode(decorated))
end

#fetch_by_path(workspace_id, path) ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/fiona7/controllers/rest_api/obj_controller.rb', line 47

def fetch_by_path(workspace_id, path)
  klass = matching_class(workspace_id)

  path = path.gsub('.', '_')
  obj = klass.find_by_path(path)

  Assert.input(
    !obj.nil?,
    "Obj with path #{path} not found in workspace #{workspace_id}",
    404
  )

  decorated = Fiona7::JSON::ReverseObjDecorator.new(klass, obj)
  return ::JSON.parse(::ActiveSupport::JSON.encode(decorated))
end

#fetch_multiple(revision_id, payload) ⇒ Object 



63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/fiona7/controllers/rest_api/obj_controller.rb', line 63

def fetch_multiple(revision_id, payload)
  # TODO: use implementation from ContentService controller
  # FIXME: code duplication with fetch_by_id
  obj_ids = payload.with_indifferent_access[:ids]
  klass = revision_id.start_with?('f') ? ReleasedObj : EditedObj

  # preloads all objects in one query
  objs_arr = Prefetch::ObjPrefetch.new(klass, obj_ids).find_many(obj_ids)
  # preloads all widgets in one query
  widget_prefetch = Prefetch::WidgetResolverPrefetch.new(klass, objs_arr.compact)

  decorated = objs_arr.map {|obj| obj ? Fiona7::JSON::ReverseObjDecorator.new(klass, obj, widget_prefetch.widget_resolver(obj)) : nil }
  response = ::JSON.parse(::ActiveSupport::JSON.encode({"results" => decorated}))
  return response
end

#fetch_multiple2(workspace_id, payload) ⇒ Object 



79
80
81
82
 
# File 'lib/fiona7/controllers/rest_api/obj_controller.rb', line 79

def fetch_multiple2(workspace_id, payload)
  revision_id = workspace_id == 'published' ? 'f' : 'b'
  return fetch_multiple(revision_id, payload)
end

#search(workspace_id, params) ⇒ Object 



115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
 
# File 'lib/fiona7/controllers/rest_api/obj_controller.rb', line 115

def search(workspace_id, params)
  klass = matching_class(workspace_id)
  params = params.symbolize_keys

  facets = params[:facets] || []

  if params[:continuation]
    conti  = ::JSON.parse(Base64.decode64(params[:continuation])).symbolize_keys #rescue {}
  else
    conti = {}
  end

  # This simulates the behavior of the backend:
  # In absence of other input backend always sorts by ID
  # or SCORE if an elastic search for such request would
  # produce a score.
  if (params[:query]||[]).any?{|op| (op[:operator]||op["operator"]).to_s =~ /search/ }
    default_sort_order = :desc
    default_sort_by = :_score
  else
    default_sort_order = :asc
    default_sort_by = :id
  end

  offset = conti[:offset]      || params[:offset]     || 0
  # 10 is the default value in original implementation
  size   = conti[:size]        || params[:size]       || 10
  order  = (conti[:sort_order] || params[:sort_order] || default_sort_order).to_sym
  sort   = (conti[:sort_by]    || params[:sort_by]    || default_sort_by).to_sym

  if params[:query].present?
    query = normalize_query_params(params[:query])

    Rails.logger.debug "Executing search for: #{query.inspect}"
    if use_naive_search_engine?(query)
      Rails.logger.debug "Using DB-native lookup for search"
      search = NaiveSearchEngine.new(klass, query, offset, size, sort, order)
    else
      Rails.logger.debug "Using configured search engine: #{::Fiona7.search_engine.name}"
      search = ::Fiona7.search_engine.new(klass, query, offset, size, sort, order)
    end
    result = search.results.map {|o_id| {id: o_id} }
    total  = search.total

    response = {
      total: total,
      results: result
    }
  else
    query = []

    response = {
      total: 0,
      results: []
    }
  end

  if response[:total] > offset + size
    response[:continuation] = Base64.encode64({
      size: size,
      offset: (offset+size),
      sort_order: order,
      sort_by: sort,
    }.to_json)
  end

  if !facets.empty?
    if Fiona7.facetting_enabled?
      response[:facets] = facets.map {|facet| FacetBuilder.new(facet.symbolize_keys, query, klass).build }
    else
      response[:facets] = []
    end
  end

  return ::JSON.parse(::ActiveSupport::JSON.encode(response))
end

#update(workspace_id, values) ⇒ Object 



192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
 
# File 'lib/fiona7/controllers/rest_api/obj_controller.rb', line 192

def update(workspace_id, values)
  assert_writable(workspace_id)

  klass = EditedObj
  id = (values[:obj]["_id"] || values[:obj][:_id]).to_s.to_i
  # Scrivito SDK does not understand the difference
  # between create and update
  if (id < 2001 || id >= 2**31 || !klass.exists?(id))
    return self.create(workspace_id, values)
  end


  obj = Builder::ObjUpdater.new(values[:obj].dup.with_indifferent_access).build
  decorated = Fiona7::JSON::ReverseObjDecorator.new(klass, obj)

  ::Fiona7.run_callbacks(:update_obj, obj.id)
  return ::JSON.parse(::ActiveSupport::JSON.encode(decorated))
end