20130627140642_add_authentication_auditor_tables.rb

# frozen_string_literal: true

#
# Copyright (C) 2013 - present Instructure, Inc.
#
# This file is part of Canvas.
#
# Canvas is free software: you can redistribute it and/or modify it under
# the terms of the GNU Affero General Public License as published by the Free
# Software Foundation, version 3 of the License.
#
# Canvas is distributed in the hope that it will be useful, but WITHOUT ANY
# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
# A PARTICULAR PURPOSE. See the GNU Affero General Public License for more
# details.
#
# You should have received a copy of the GNU Affero General Public License along
# with this program. If not, see <http://www.gnu.org/licenses/>.

class AddAuthenticationAuditorTables < ActiveRecord::Migration[4.2]
  tag :predeploy

  include Canvas::Cassandra::Migration

  def self.cassandra_cluster
    'auditors'
  end

  def self.indexes
    %w(
      authentications_by_pseudonym
      authentications_by_account
      authentications_by_user
      courses_by_course
      grade_changes_by_assignment
      grade_changes_by_course
      grade_changes_by_root_account_student
      grade_changes_by_root_account_grader
    )
  end

  def self.up
    compression_params = cassandra.db.use_cql3? ?
        "WITH compression = { 'sstable_compression' : 'DeflateCompressor' }" :
        "WITH compression_parameters:sstable_compression='DeflateCompressor'"

    cassandra.execute %{
      CREATE TABLE authentications (
        id                    text PRIMARY KEY,
        created_at            timestamp,
        pseudonym_id          bigint,
        account_id            bigint,
        user_id               bigint,
        event_type            text,
        request_id            text
      ) #{compression_params}}

    cassandra.execute %{
      CREATE TABLE courses (
        id                    text PRIMARY KEY,
        created_at            timestamp,
        request_id            text,
        course_id             bigint,
        event_type            text,
        user_id               bigint,
        data                  text,
        event_source          text,
        sis_batch_id          bigint
      ) #{compression_params}}

    cassandra.execute %{
      CREATE TABLE grade_changes (
        id                     text PRIMARY KEY,
        created_at             timestamp,
        request_id             text,
        account_id             bigint,
        submission_id          bigint,
        version_number         int,
        grader_id              bigint,
        student_id             bigint,
        assignment_id          bigint,
        context_id             bigint,
        context_type           text,
        event_type             text,
        grade_before           text,
        grade_after            text,
        graded_anonymously     boolean,
        excused_before         boolean,
        excused_after          boolean,
        score_before           double,
        score_after            double,
        points_possible_before double,
        points_possible_after  double
      ) #{compression_params}}

    indexes.each do |index_name|
      cassandra.execute %{
        CREATE TABLE #{index_name} (
          key text,
          ordered_id text,
          id text,
          PRIMARY KEY (key, ordered_id)
        ) #{compression_params}}
    end
  end

  def self.down
    indexes.each do |index_name|
      cassandra.execute %{DROP TABLE #{index_name};}
    end

    cassandra.execute %{DROP TABLE authentications;}
    cassandra.execute %{DROP TABLE courses;}
    cassandra.execute %{DROP TABLE grade_changes;}
  end
end