#!/usr/bin/env perl

use strict;

use warnings;

use FindBin;

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

use DBIx::Custom;

my ($old_database_file, $new_database_file) = @ARGV;

# Old DBI

my %old_dbi_args = (

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

  connector => 1,

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

);

my $old_dbi = DBIx::Custom->connect(%old_dbi_args);

# New DBI

my %new_dbi_args = (

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

  connector => 1,

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

);

my $new_dbi = DBIx::Custom->connect(%new_dbi_args);

# Copy user data

my $old_users = $old_dbi->select(table => 'user')->all;

my $new_user_count = $new_dbi->select('count(*)', table => 'user')->value;

unless ($new_user_count) {

  for my $old_user (@$old_users) {

    my @new_user_columns = qw(

      row_id

      id

      email

      admin

      password

      salt

      name

    );

    my $new_user = {};

    for my $new_user_column (@new_user_columns) {

      if (exists $old_user->{$new_user_column}) {

        $new_user->{$new_user_column} = $old_user->{$new_user_column};

      }

    }

    unless (exists $new_user->{email}) {

      $new_user->{email} = $old_user->{id} . '@gitprep.example';

    }

    $new_dbi->insert($new_user, table => 'user');

  }

}

# Copy project data

my $old_projects = $old_dbi->select(table => 'project')->all;

my $new_project_count = $new_dbi->select('count(*)', table => 'project')->value;

unless ($new_project_count) {

  for my $old_project (@$old_projects) {

    my @new_project_columns = qw(

      row_id

      id

      default_branch

      private integer

      ignore_space_change

      guess_encoding

    );

    my $new_project = {};

    for my $new_project_column (@new_project_columns) {

      if (exists $old_project->{$new_project_column}) {

        $new_project->{$new_project_column} = $old_project->{$new_project_column};

      }

    }

    # name is copied to id

    if (exists $old_project->{name}) {

      $new_project->{id} = $old_project->{name};

    }

    # original_pid is copied to original_project, which is converted to project.row_id

    if (exists $old_project->{original_pid}) {

      my $project_row_id = $old_dbi->select(

        'row_id',

        table => 'project',

        where => {

          original_pid => $old_project->{original_pid}

        },

        append => 'order by row_id'

      )->value;

      if ($project_row_id && $project_row_id ne $new_project->{row_id}) {

        $new_project->{original_project} = $project_row_id;

      }

    }

    # user_id is copied to user, which is converted to user.row_id

    my $user_row_id = $old_dbi->select(

      'row_id',

      table => 'user',

      where => {id => $old_project->{user_id}}

    )->value;

    if (defined $user_row_id) {

      $new_project->{user} = $user_row_id;

    }

    else {

      next;

    }

    $new_dbi->insert($new_project, table => 'project');

  }

}

# Copy ssh_public_key data

my $old_ssh_public_keys = $old_dbi->select(table => 'ssh_public_key')->all;

my $new_ssh_public_key_count = $new_dbi->select('count(*)', table => 'ssh_public_key')->value;

unless ($new_ssh_public_key_count) {

  for my $old_ssh_public_key (@$old_ssh_public_keys) {

    my @new_ssh_public_key_columns = qw(

      row_id

      key

      title

    );

    my $new_ssh_public_key = {};

    for my $new_ssh_public_key_column (@new_ssh_public_key_columns) {

      if (exists $old_ssh_public_key->{$new_ssh_public_key_column}) {

        $new_ssh_public_key->{$new_ssh_public_key_column} = $old_ssh_public_key->{$new_ssh_public_key_column};

      }

    }

    # user_id is copied to user, which is converted to user.row_id

    my $user_row_id = $old_dbi->select(

      'row_id',

      table => 'user',

      where => {id => $old_ssh_public_key->{user_id}}

    )->value;

    if (defined $user_row_id) {

      $new_ssh_public_key->{user} = $user_row_id;

    }

    else {

      next;

    }

    $new_dbi->insert($new_ssh_public_key, table => 'ssh_public_key');

  }

}

# Copy collaboration data

my $old_collaborations = $old_dbi->select(table => 'collaboration')->all;

my $new_collaboration_count = $new_dbi->select('count(*)', table => 'collaboration')->value;

unless ($new_collaboration_count) {

  for my $old_collaboration (@$old_collaborations) {

    my @new_collaboration_columns = qw(

      row_id

    );

    my $new_collaboration = {};

    for my $new_collaboration_column (@new_collaboration_columns) {

      if (exists $old_collaboration->{$new_collaboration_column}) {

        $new_collaboration->{$new_collaboration_column} = $old_collaboration->{$new_collaboration_column};

      }

    }

    # collaborator_id is copied to collaborator, which is converted to user.row_id

    my $user_row_id = $old_dbi->select(

      'row_id',

      table => 'user',

      where => {id => $old_collaboration->{collaborator_id}}

    )->value;

    if (defined $user_row_id) {

      $new_collaboration->{user} = $user_row_id;

    }

    else {

      next;

    }

    my $project_row_id = $old_dbi->select(

      'row_id',

      table => 'project',

      where => {name => $old_collaboration->{project_name}}

    )->value;

    if (defined $project_row_id) {

      $new_collaboration->{project} = $project_row_id;

    }

    else {

      next;

    }

    $new_dbi->insert($new_collaboration, table => 'collaboration');

  }

}

=pod

collaboration

=cut