#!/usr/bin/env perl

use strict;

use warnings;

use FindBin;

use lib "$FindBin::Bin/../extlib/lib/perl5";

use DBIx::Custom;

my $database_file = shift;

# New DBI

my %dbi_args = (

  dsn => "dbi:SQLite:database=$database_file",

  connector => 1,

  option => {sqlite_unicode => 1, sqlite_use_immediate_transaction => 1}

);

my $dbi = DBIx::Custom->connect(%dbi_args);

# Copy pull_request data to issue

my $pull_requests = $dbi->select(table => 'pull_request')->all;

my $issue_project_numbers = {};

for my $pull_request (@$pull_requests) {

  my $project = $pull_request->{base_project};

  $issue_project_numbers->{$project}++;

  my $new_issue = {

    row_id => $pull_request->{row_id},

    title => $pull_request->{title},

    open => $pull_request->{open},

    open_time => $pull_request->{open_time},

    open_user => $pull_request->{open_user},

    pull_request => $pull_request->{row_id},

    project => $project,

    number => $issue_project_numbers->{$project}

  };

  my $issue = $dbi->select(

    table => 'issue',

    where => {row_id => $new_issue->{row_id}}

  )->one;

  unless ($issue) {

    $dbi->insert($new_issue, table => 'issue');

  }

}

my $pull_request_messages = $dbi->select(table => 'pull_request_message')->all;

for my $pull_request_message (@$pull_request_messages) {

  my $new_issue_message = {

    row_id => $pull_request_message->{row_id},

    issue => $pull_request_message->{pull_request},

    number => $pull_request_message->{number},

    message => $pull_request_message->{message},

    create_time => $pull_request_message->{create_time},

    update_time => $pull_request_message->{update_time},

    user => $pull_request_message->{user}

  };

  my $issue_message = $dbi->select(

    table => 'issue_message',

    where => {row_id => $new_issue_message->{row_id}}

  )->one;

  unless ($issue_message) {

    $dbi->insert($new_issue_message, table => 'issue_message');

  }

}