Module: Arcade::Api::Primitives

Included in:
Arcade::Api
Defined in:
lib/arcade/api/primitives.rb

Instance Method Summary collapse

Instance Method Details

#begin_transaction(database) ⇒ Object

—————————— transaction ————————————————- #

The payload, optional as a JSON, accepts the following parameters: isolationLevel: READ_COMMITTED (default) or REPEATABLE_READ. (not implemented)



87
88
89
90
91
 
# File 'lib/arcade/api/primitives.rb', line 87

def begin_transaction database
  result  = http.post Config.base_uri + "begin/#{database}"
  # returns the session-id
  result.headers["arcadedb-session-id"] 
end

#commit(database, session_id:) ⇒ Object

—————————— commit ————————————————- #



114
115
116
117
118
119
120
121
 
# File 'lib/arcade/api/primitives.rb', line 114

def commit database, session_id:
  http_a = http.with(  headers: { "arcadedb-session-id" => session_id } , debug_level: 1)
  response = http_a.post( Config.base_uri + "commit/#{database}" )
  response.status  #  returns 204 --> success
                   #          403 --> invalid credentials
                   #          500 --> Transaction  not begun

end

#get_data(command) ⇒ Object

—————————— get data ——————————————————– #



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
 
# File 'lib/arcade/api/primitives.rb', line 25

def get_data command
  case response = http.get( Config.base_uri + command )
    in {status: 200..299}
      # success
    JSON.parse( response.body, symbolize_names: true )[:result]
     in {status: 400..}
     raise Arcade::QueryError.new **response.json( symbolize_names: true  )
  else
    #   # http error
         raise   response
  end

  JSON.parse( response.body, symbolize_names: true )[:result]
  #      alternative to `raise for status `
#      case response = http.basic_auth(auth[:username], auth[:password]).get( Config.base_uri + command )
#      in { status: 200..203, body:  }
#        puts "success: #{JSON.parse(body, symbolize_names: true)[:result]}"
#      in { status: 400..499, body:  }
#        puts "client error: #{body.json}"
#      in { status: 500.., body:  }
#          puts "server error: #{body.to_s}"
#      in { error: error  }
#          puts "error: #{error.message}"
#      else
#          raise "unexpected: #{response}"
#      end
#      puts "result : #{response}"
#      puts "code: #{response.status}"
#      analyse_result(response, command)
end

#http ⇒ Object

—————————— http ———————————————————— # persistent http handle to the database



10
11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/arcade/api/primitives.rb', line 10

def http
#     break_on = -> (response) { response.status == 500  }
  #     Version 23.12: Persistent connection are inactive after 3 sec.
  #     Implemented a walk around, that renews the connection after 2 sec. of inactivity
  t = Time.now
  @t ||= Time.now
  @http = nil if t-@t > 2
  @t = t
  @http ||= HTTPX.plugin(:basic_auth).basic_auth(auth[:username], auth[:password])
              .plugin(:persistent)
              .plugin(:circuit_breaker)
   #               .plugin(:circuit_breaker, circuit_breaker_break_on: break_on)
end

#post_data(command, payload) ⇒ Object

—————————— post data ——————————————————– #



57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/arcade/api/primitives.rb', line 57

def post_data command,  payload
    case response = http.post( Config.base_uri + command, json:  payload )
    in {status: 200..299}
      # success
    JSON.parse( response.body, symbolize_names: true )[:result]
     in {status: 400..}
       detail = response.json( symbolize_names: true )[:detail]
       if  detail =~ /Please retry the operation/ 
         logger.error "--------------------------------"
         logger.error " ----> Operation repeated <---- "
         logger.error detail
         logger.error "The query --> #{payload.inspect}"
         logger.error "--------------------------------"
         sleep 1
         post_data command,  payload
       else
         raise Arcade::QueryError.new **response.json( symbolize_names: true  )
       end
  else
    #   # http error
         raise   response
  end
  #    response.raise_for_status
end

#post_transaction(command, params, session_id:) ⇒ Object

—————————— post transaction ————————————————- #



94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
 
# File 'lib/arcade/api/primitives.rb', line 94

def post_transaction command, params, session_id:
  http_a = http.with(  headers: { "arcadedb-session-id" => session_id } , debug_level: 1)
  puts "params #{params.inspect}"
  case response = http_a.post( Config.base_uri + command, json:  params )
    in {status: 200..299}
      # success
    JSON.parse( response.body, symbolize_names: true )[:result]
     in {status: 400..}
       ## debug
#          puts "Command: #{command}"
#           puts "params: #{params}"
#           puts response.json( symbolize_names: true  )
       raise Arcade::QueryError.new **response.json( symbolize_names: true  )
  else
    #   # http error
         raise   response
  end
end

#rollback(database, session_id:, log: true) ⇒ Object

—————————— rollback ————————————————- #



124
125
126
127
128
129
 
# File 'lib/arcade/api/primitives.rb', line 124

def rollback database, session_id: , log: true
  http_a = http.with(  headers: { "arcadedb-session-id" => session_id } , debug_level: 1)
  response = http_a.post( Config.base_uri + "rollback/#{database}" )
  logger.info  "A Transaction has been rolled back"   if log
  response.status    # returns 500 !
end