Adding validations...

Author: Felipe Rodrigues Michetti

api/app.rb

@@ -60,15 +60,14 @@ class App < Sinatra::Application
   }
 
   helpers {
-    ClassMap = create_classes(DATABASE, Dynamics)
-    Classes = get_classes(Dynamics)
-
-    require 'extensions/models/dynamics_common'
-    include Extensions::DynamicsCommon
-
     def sample_method
       'sample method'
     end
   }
 
+  ClassMap = create_classes(DATABASE, Dynamics, false)
+  Classes = get_classes(Dynamics)
+
+  require 'extensions/models/dynamics_common'
+  include Extensions::DynamicsCommon
 end

lib/controllers/mini_controller.rb

@@ -54,7 +54,7 @@ def included(controller)
             c.post('/:table_name') {|table_name|
               make_default_json_api(self, request.body.read, table_name) {|params, _status_code, _mapped_class, klass|
 
-                {status: 201, response: klass.create(params)&.values}
+                {status: _status_code, response: klass.create(params)&.values}
               }
             }
 

lib/helpers/api_helper.rb

@@ -24,6 +24,7 @@ def make_default_json_api(api_instance, payload = {}, table_name = nil)
           my_yield = table_name.nil? ? yield : yield(mapped_class, klass)
           block_given? ? response = my_yield : response = {msg: 'Api not implemented yet.'}
         rescue ModelException => e
+          status = 400
           response = prepare_error_response(e)
         end
         [status, response.to_json.delete("\n")]
@@ -42,7 +43,8 @@ def make_default_json_api(api_instance, payload = {}, table_name = nil)
             response = {msg: 'Api not implemented yet.'}
           end
         rescue ModelException, ConstraintViolation, UniqueConstraintViolation, CheckConstraintViolation,
-            NotNullConstraintViolation, ForeignKeyConstraintViolation, MassAssignmentRestriction => e
+            NotNullConstraintViolation, ForeignKeyConstraintViolation, MassAssignmentRestriction, ValidationFailed => e
+          status = 400
           response = prepare_error_response(e)
         end
         [status, response.to_json.delete("\n")]

lib/utils/class_factory.rb

@@ -13,21 +13,22 @@ def create_classes(connection, module_constant, name_conflicts = true)
     table_info.each {|t|
       next if t[:table_name].eql?('configurations')
 
-      table_name = t[:table_name]
-      table_schema = t[:schema]
-
-      table_constraints = table_constraints(connection, table_name)
-      table_fks = table_foreign_keys(connection, table_name)
-      t[:constraints] = table_constraints.map {|tc| {type: tc[:constraint_type], name: tc[:constraint_name]}}
-      t[:foreign_keys] = table_fks
+      name = t[:table_name]
+      schema = t[:schema]
+
+      constraints = table_constraints(connection, name)
+      foreign_keys = table_foreign_keys(connection, name)
+      fields = scan_fields(connection, name)
+      t[:constraints] = constraints.map {|tc| {type: tc[:constraint_type], name: tc[:constraint_name]}}
+      t[:foreign_keys] = foreign_keys
       primary_key_name = t[:constraints].detect {|tc| tc[:type].eql?('PRIMARY KEY')}[:name] rescue nil
-
-      t[:columns_n_types] = table_columns(connection, table_name)
+      t[:scanned_fields] = fields
+      t[:columns_n_types] = table_columns(connection, name)
 
       if name_conflicts
-        fixed_name = underscore(table_name)
+        fixed_name = underscore(name)
       else
-        fixed_name = underscore(singularize(table_name))
+        fixed_name = underscore(singularize(name))
       end
 
       dynamic_name = pascalize(fixed_name)
@@ -36,12 +37,8 @@ def create_classes(connection, module_constant, name_conflicts = true)
 
       begin
         Object.const_set(dynamic_name, Class.new(Sequel::Model) {|klass|
-          set_dataset(connection[table_name.to_sym], inherited: false, require_valid_table: false)
-          reset_fast_pk_lookup_sql
-
-          if table_fks
-
-          end
+          set_dataset(connection[name.to_sym], inherited: false, require_valid_table: false)
+          %i[validation_helpers column_conflicts dirty json_serializer auto_validations].each {|sym| plugin sym}
 
           class << self
             define_method('find_by_id') {|id| self[id]}
@@ -90,7 +87,7 @@ def scan_classes(connection)
   end
 
   def scan_fields(connection, table_name)
-    query = SHOW_COLUMNS.gsub('?', table_name)
+    query = SHOW_FIELDS.gsub('?', table_name)
     ConnectionFactory.execute_query(connection, query, false)
   end
 
@@ -108,4 +105,7 @@ def scan_fields(connection, table_name)
 
   # --EXIBINDO AS FOREIGN KEYS DAS TABELAS:
   SHOW_FOREIGN_KEYS = "SELECT tc.constraint_name , tc.table_name as source_table, kcu.column_name as source_column, ccu.table_name AS target_table, ccu.column_name AS target_column FROM information_schema.table_constraints AS tc JOIN information_schema.key_column_usage AS kcu ON tc.constraint_name = kcu.constraint_name JOIN information_schema.constraint_column_usage AS ccu ON ccu.constraint_name = tc.constraint_name WHERE constraint_type = 'FOREIGN KEY' AND tc.table_name='?';".freeze
+
+  # -- QUERY PARA VALIDAÇÃO DE CAMPOS
+  SHOW_FIELDS = "SELECT column_name, is_nullable, character_maximum_length, is_updatable FROM information_schema.columns WHERE table_name = '?';".freeze
 end