pool creation allmost done

1 files changed, 209 insertions, 3 deletions

diff --git a/lib/RHRD/rddb.pm b/lib/RHRD/rddb.pm
index 81ca9be..b576ad4 100755
--- a/lib/RHRD/rddb.pm
+++ b/lib/RHRD/rddb.pm
@@ -436,6 +436,133 @@ sub drop_logevent_table
   return (1, 'OK', 'success');
 }
 
+sub get_clock_table_name
+{
+  my ($clockname) = @_;
+  $clockname=~s/ /_/g;
+  return $clockname . '_CLK';
+}
+
+sub get_clock_table_name_escaped
+{
+  my ($ctx, $clockname) = @_;
+  return $ctx->{'dbh'}->quote_identifier(get_clock_table_name($clockname));
+}
+
+sub create_clock_table
+{
+  my ($ctx, $clockname) = @_;
+
+  $clockname = get_clock_table_name_escaped($ctx, $clockname);
+  my $sql = qq{
+    create table if not exists $clockname
+    (ID int unsigned auto_increment not null primary key,
+    EVENT_NAME char(64) not null,
+    START_TIME int not null,
+    LENGTH int not null,
+    INDEX EVENT_NAME_IDX (EVENT_NAME));
+  };
+
+  my $sth = $ctx->{'dbh'}->prepare($sql)
+    or return (undef, 'ERROR', "Database Error: " . $ctx->{'dbh'}->errstr);
+
+  $sth->execute()
+    or return (undef, 'ERROR', "Database Error: " . $sth->errstr);
+
+  $sth->finish();
+
+  return (1, 'OK', 'success');
+}
+
+sub fill_clock_table
+{
+  my $ctx = shift;
+  my $clockname = shift;
+  my @events = @_;
+
+  $clockname = get_clock_table_name_escaped($ctx, $clockname);
+  my $sql = qq{insert into $clockname (ID, EVENT_NAME, START_TIME, LENGTH) values (?, ?, ?, ?, ?);};
+
+  my $sth = $ctx->{'dbh'}->prepare($sql)
+    or return (undef, 'ERROR', "Database Error: " . $ctx->{'dbh'}->errstr);
+
+  my $cnt = 0;
+  for my $event (@events) {
+    $sth->execute($cnt + 1, $event->{'NAME'}, $event->{'START_TIME'}, $event->{'LENGTH'})
+      or return (undef, 'ERROR', "Database Error: " . $sth->errstr);
+    $sth->finish();
+
+    $cnt++;
+  }
+
+  return ($cnt+1, 'OK', 'success');
+}
+
+sub drop_clock_table
+{
+  my ($ctx, $clockname) = @_;
+
+  $clockname = get_clock_table_name_escaped($ctx, $clockname);
+  my $sql = qq{drop table $clockname;};
+
+  $ctx->{'dbh'}->do($sql)
+    or return (undef, 'ERROR', "Database Error: " . $ctx->{'dbh'}->errstr);
+
+  return (1, 'OK', 'success');
+}
+
+sub get_clockrules_table_name
+{
+  my ($clockname) = @_;
+  $clockname=~s/ /_/g;
+  return $clockname . '_RULES';
+}
+
+sub get_clockrules_table_name_escaped
+{
+  my ($ctx, $clockname) = @_;
+  return $ctx->{'dbh'}->quote_identifier(get_clockrules_table_name($clockname));
+}
+
+sub create_clockrules_table
+{
+  my ($ctx, $clockname) = @_;
+
+  $clockname = get_clockrules_table_name_escaped($ctx, $clockname);
+  my $sql = qq{
+    create table if not exists $clockname
+    (CODE varchar(10) not null primary key,
+    MAX_ROW int unsigned,
+    MIN_WAIT int unsigned,
+    NOT_AFTER varchar(10),
+    OR_AFTER varchar(10),
+    OR_AFTER_II varchar(10));
+  };
+
+  my $sth = $ctx->{'dbh'}->prepare($sql)
+    or return (undef, 'ERROR', "Database Error: " . $ctx->{'dbh'}->errstr);
+
+  $sth->execute()
+    or return (undef, 'ERROR', "Database Error: " . $sth->errstr);
+
+  $sth->finish();
+
+  return (1, 'OK', 'success');
+}
+
+sub drop_clockrules_table
+{
+  my ($ctx, $clockname) = @_;
+
+  $clockname = get_clockrules_table_name_escaped($ctx, $clockname);
+  my $sql = qq{drop table $clockname;};
+
+  $ctx->{'dbh'}->do($sql)
+    or return (undef, 'ERROR', "Database Error: " . $ctx->{'dbh'}->errstr);
+
+  return (1, 'OK', 'success');
+}
+
 ###########################  TOKEN handling  ###########################
 
 sub get_token
@@ -1882,6 +2009,7 @@ sub get_musicpool_group
   unless(defined($groupname)) {
     return (undef, 'ERROR', "Pool not found");
   }
+
   return ($groupname, 'OK', 'success');
 }
 
@@ -1945,9 +2073,9 @@ sub get_musicpool_info
 
 sub create_musicpool_group
 {
-  my ($ctx, $groupname) = @_;
+  my ($ctx, $groupname, $title) = @_;
 
-  my ($cnt, $status, $errorstring) = add_group($ctx, $groupname);
+  my ($cnt, $status, $errorstring) = add_group($ctx, $groupname, $title);
   unless(defined $cnt) {
     return (undef, $status, $errorstring);
   }
@@ -1999,7 +2127,7 @@ sub create_musicpool_event
   my $sth = $ctx->{'dbh'}->prepare($sql)
     or return (undef, 'ERROR', "Database Error: " . $ctx->{'dbh'}->errstr);
 
-  $sth->execute($shortname, 'SEGUE, Scheduler', 3, 1, 1, '#' . $color, $groupname, 25)    # TODO: make title seperartion configurable !?!?
+  $sth->execute($shortname, 'SEGUE, Scheduler', 3, 1, 1, $color, $groupname, 25)    # TODO: make title seperartion configurable !?!?
     or return (undef, 'ERROR', "Database Error: " . $sth->errstr);
   $sth->finish();
 
@@ -2024,6 +2152,59 @@ sub create_musicpool_event
   return (1, 'OK', 'success');
 }
 
+sub create_musicpool_clock
+{
+  my ($ctx, $shortname, $color) = @_;
+
+  my $sql = qq{insert into CLOCKS (NAME, SHORT_NAME, ARTISTSEP, COLOR, REMARKS) values (?, ?, ?, ?, '');};
+  my $sth = $ctx->{'dbh'}->prepare($sql)
+    or return (undef, 'ERROR', "Database Error: " . $ctx->{'dbh'}->errstr);
+
+  $sth->execute($shortname, $shortname, 15, $color) # TODO: make artist seperation configurable !?!?
+    or return (undef, 'ERROR', "Database Error: " . $sth->errstr);
+  $sth->finish();
+
+  $sql = qq{insert into CLOCK_PERMS (CLOCK_NAME, SERVICE_NAME) values (?, ?);};
+  $sth = $ctx->{'dbh'}->prepare($sql)
+    or return (undef, 'ERROR', "Database Error: " . $ctx->{'dbh'}->errstr);
+
+  $sth->execute($shortname, $ctx->{'config'}{'shows'}{'service'})
+    or return (undef, 'ERROR', "Database Error: " . $sth->errstr);
+  $sth->finish();
+
+  my ($cnt, $status, $errorstring) = create_clock_table($ctx, $shortname);
+  unless(defined $cnt) {
+    return (undef, $status, $errorstring);
+  }
+
+  ## TODO: fill clock table!!!!
+
+  ($cnt, $status, $errorstring) = create_clockrules_table($ctx, $shortname);
+  unless(defined $cnt) {
+    return (undef, $status, $errorstring);
+  }
+
+  return (1, 'OK', 'success');
+}
+
+sub create_musicpool_dropbox
+{
+  my ($ctx, $groupname, $shortname) = @_;
+  my $param = 'M;';
+
+  my $sql = qq{insert into DROPBOXES (STATION_NAME, GROUP_NAME, NORMALIZATION_LEVEL, AUTOTRIM_LEVEL, PATH, FIX_BROKEN_FORMATS, SET_USER_DEFINED) values (?, ?, ?, ?, ?, 'Y', ?)};
+
+  my $sth = $ctx->{'dbh'}->prepare($sql)
+    or return (undef, 'ERROR', "Database Error: " . $ctx->{'dbh'}->errstr);
+
+  my $cnt = $sth->execute($ctx->{'config'}{'dropboxes'}{'dropbox-pseudo-station'}, $groupname, $ctx->{'config'}{'dropboxes'}{'norm-level'}, $ctx->{'config'}{'dropboxes'}{'trim-level'}, $shortname, $param)
+    or return (undef, 'ERROR', "Database Error: " . $sth->errstr);
+
+  $sth->finish();
+
+  return ($cnt, 'OK', 'success');
+}
+
 sub remove_musicpool
 {
   my ($ctx, $shortname) = @_;
@@ -2033,7 +2214,20 @@ sub remove_musicpool
     return (undef, $status, $errorstring);
   }
 
+  # TODO: remove grid/clock entries!
   my @actions = ({
+      # Delete Clock Permissions
+      sql => qq{delete from CLOCK_PERMS where CLOCK_NAME = ?;},
+      param => $shortname,
+      name => 'clock permissions',
+      cnt => 0
+    }, {
+      # Delete Event
+      sql => qq{delete from CLOCKS where NAME = ?;},
+      param => $shortname,
+      name => 'clocks',
+      cnt => 0
+    }, {
       # Delete Event Permissions
       sql => qq{delete from EVENT_PERMS where EVENT_NAME = ?;},
       param => $shortname,
@@ -2069,6 +2263,18 @@ sub remove_musicpool
   }
   push @actions, { name => 'log-event tables', cnt => ($cnt_pre + $cnt_post) };
 
+  (my $cnt_clk, $status, $errorstring) = drop_clock_table($ctx, $shortname);
+  unless (defined $cnt_pre) {
+    return (undef, $status, $errorstring);
+  }
+
+  (my $cnt_rules, $status, $errorstring) = drop_clockrules_table($ctx, $shortname);
+  unless (defined $cnt_post) {
+    return (undef, $status, $errorstring);
+  }
+  push @actions, { name => 'clock tables', cnt => ($cnt_clk + $cnt_rules) };
+
+
   my @group_results = remove_group($ctx, $groupname);
   if(!defined $group_results[0] && defined $group_results[2]) {
     return (undef, $group_results[1], $group_results[2]);