From 0aff34d2f991a7a5fbe919061b4ffd43213e8168 Mon Sep 17 00:00:00 2001 From: Kirill Solomko Date: Sat, 15 Aug 2015 18:47:03 +0200 Subject: [PATCH] MT#12707 - add malicious_calls schema Change-Id: I7353bf1f415f11d1567938bc6f69ca79b40111f2 --- lib/NGCP/Schema/Result/malicious_calls.pm | 69 +++++++++++++++++++++++ 1 file changed, 69 insertions(+) create mode 100644 lib/NGCP/Schema/Result/malicious_calls.pm diff --git a/lib/NGCP/Schema/Result/malicious_calls.pm b/lib/NGCP/Schema/Result/malicious_calls.pm new file mode 100644 index 00000000..b7859b31 --- /dev/null +++ b/lib/NGCP/Schema/Result/malicious_calls.pm @@ -0,0 +1,69 @@ +package NGCP::Schema::Result::malicious_calls; +use Scalar::Util qw(blessed); +use parent 'DBIx::Class::Core'; + +our $VERSION = '2.007'; + +__PACKAGE__->load_components("InflateColumn::DateTime", + "Helper::Row::ToJSON", + "+NGCP::Schema::InflateColumn::DateTime::EpochMilli"); + +__PACKAGE__->table("accounting.malicious_calls"); + +__PACKAGE__->add_columns( + "id", + { + data_type => "integer", + extra => { unsigned => 1 }, + is_auto_increment => 1, + is_nullable => 0, + }, + "callee_uuid", + { data_type => "varchar", is_nullable => 0, size => 255 }, + "call_id", + { data_type => "varchar", is_nullable => 0, size => 255 }, + "caller", + { data_type => "varchar", is_nullable => 0, size => 255 }, + "callee", + { data_type => "varchar", is_nullable => 0, size => 255 }, + "start_time", + { data_type => "decimal", is_nullable => 0, size => [13,3] }, + "duration", + { data_type => "decimal", is_nullable => 0, size => [13,3] }, + "reported_at", + { + data_type => "timestamp", + datetime_undef_if_invalid => 1, + default_value => \"current_timestamp", + is_nullable => 0, + }, +); + +__PACKAGE__->set_primary_key("id"); + +for my $col (qw/start_time/) { + if(__PACKAGE__->has_column($col)) { + __PACKAGE__->remove_column($col); + __PACKAGE__->add_column($col => + { data_type => "decimal", is_nullable => 0, size => [13, 3], inflate_datetime => 'epoch_milli' } + ); + } +} + +__PACKAGE__->add_unique_constraint("mcid_callid_idx", ["call_id"]); + +__PACKAGE__->belongs_to( + "subscriber", + "NGCP::Schema::Result::voip_subscribers", + { uuid => "callee_uuid" }, + { cascade_copy => 0, cascade_delete => 0 }, +); + +sub TO_JSON { + my ($self) = @_; + return { + map { blessed($_) && $_->isa('DateTime') ? $_->datetime : $_ } %{ $self->next::method } + }; +} + +1;