module JSONiCal class CreateOrUpdateVEVENTService def initialize(message) @version = message[:version] || 'v1' @data = message[:data] || message end def call JSONiCal::VEVENTSchema.validate!(@data, version: @version) JSONiCal::VEVENTRepo.insert(JSONiCal::VEVENTModel.new(@data)) end end end