WIP

Author: ursm

api/Gemfile

@@ -6,11 +6,14 @@ gem 'rails', '~> 7.1.3'
 
 gem 'aws-sdk-s3'
 gem 'base62-rb'
+gem 'bcrypt_pbkdf'
 gem 'bootsnap', require: false
+gem 'ed25519'
 gem 'faraday'
 gem 'faraday-multipart'
 gem 'jb'
 gem 'metabobank_tools', github: 'ddbj/metabobank_tools'
+gem 'net-ssh'
 gem 'noodles_gff', path: '../noodles_gff-rb'
 gem 'openid_connect'
 gem 'pagy'

api/Gemfile.lock

@@ -123,6 +123,8 @@ GEM
       aws-eventstream (~> 1, >= 1.0.2)
     base62-rb (0.3.1)
     base64 (0.2.0)
+    bcrypt_pbkdf (1.1.1)
+    bcrypt_pbkdf (1.1.1-arm64-darwin)
     bigdecimal (3.1.8)
     bindata (2.5.0)
     bootsnap (1.18.3)
@@ -142,6 +144,7 @@ GEM
       reline (>= 0.3.8)
     diff-lcs (1.5.1)
     drb (2.2.1)
+    ed25519 (1.3.0)
     email_validator (2.2.4)
       activemodel
     erubi (1.13.0)
@@ -213,6 +216,7 @@ GEM
       timeout
     net-smtp (0.5.0)
       net-protocol
+    net-ssh (7.2.3)
     nio4r (2.7.3)
     nokogiri (1.16.6-aarch64-linux)
       racc (~> 1.4)
@@ -398,14 +402,17 @@ PLATFORMS
 DEPENDENCIES
   aws-sdk-s3
   base62-rb
+  bcrypt_pbkdf
   bootsnap
   climate_control
   debug
+  ed25519
   factory_bot_rails
   faraday
   faraday-multipart
   jb
   metabobank_tools!
+  net-ssh
   noodles_gff!
   openid_connect
   pagy

api/app/models/database/dra.rb

@@ -50,7 +50,54 @@ def validate(validation)
 
   class Submitter
     def submit(submission)
-      # do nothing
+      submitter_db = Dway.submitter_db
+      drmdb        = Dway.drmdb
+
+      submitter_id = submission.validation.user.uid
+      user_id      = submitter_db[:login].where(submitter_id:).get(:usr_id)
+
+      drmdb.transaction isolation: :serializable do
+        serial = (drmdb[:submission].where(submitter_id:).max(:serial) || 0) + 1
+
+        sub_id = drmdb[:submission].insert(
+          usr_id:       user_id,
+          submitter_id: ,
+          serial:       ,
+          create_date:  Date.current
+        )
+
+        submission_id = "#{submitter_id}-#{serial.to_s.rjust(4, '0')}"
+
+        drmdb[:status_history].insert(
+          sub_id: ,
+          status: 100 # SubmissionStatus.NEW
+        )
+
+        drmdb[:operation_history].insert(
+          type:         3, # LogLevel.INFO
+          summary:      'Status update to new',
+          usr_id:       user_id,
+          serial:       ,
+          submitter_id:
+        )
+
+        ext_id = drmdb[:ext_entity].insert(
+          acc_type: 'DRA',
+          ref_name: submission_id,
+          status:   0 # ExtStatus.INPUTTING
+        )
+
+        drmdb[:ext_permit].insert(
+          ext_id:       ,
+          submitter_id:
+        )
+
+        host, user, key_data = ENV.values_at('DRA_SSH_HOST', 'DRA_SSH_USER', 'DRA_SSH_KEY_DATA')
+
+        Net::SSH.start host, user, key_data: [key_data] do |ssh|
+          ssh.exec! "sudo /usr/local/sbin/chroot-createdir.sh #{submitter_id} #{submission_id}"
+        end
+      end
     end
   end
 end

api/spec/models/database/dra/submitter_spec.rb

@@ -0,0 +1,45 @@
+require 'rails_helper'
+
+RSpec.describe Database::DRA::Submitter, type: :model do
+  example do
+    submission = create(:submission, {
+      validation: build(:validation, :valid, {
+        user: build(:user, uid: 'alice')
+      })
+    })
+
+    user_id = Dway.submitter_db[:login].insert(
+      submitter_id: 'alice',
+      password:     'password',
+    )
+
+    expect(Net::SSH).to receive(:start)
+
+    Database::DRA::Submitter.new.submit submission
+
+    expect(Dway.drmdb[:submission].count).to eq(1)
+
+    dway_submission = Dway.drmdb[:submission].first
+    expect(dway_submission).to include(usr_id: user_id, submitter_id: 'alice', serial: 1)
+
+    expect(Dway.drmdb[:status_history].count).to eq(1)
+    
+    status_history = Dway.drmdb[:status_history].first
+    expect(status_history).to include(sub_id: dway_submission[:sub_id], status: 100)
+
+    expect(Dway.drmdb[:operation_history].count).to eq(1)
+
+    operation_history = Dway.drmdb[:operation_history].first
+    expect(operation_history).to include(type: 3, summary: 'Status update to new', usr_id: user_id, serial: 1, submitter_id: 'alice')
+
+    expect(Dway.drmdb[:ext_entity].count).to eq(1)
+
+    ext_entity = Dway.drmdb[:ext_entity].first
+    expect(ext_entity).to include(acc_type: 'DRA', ref_name: 'alice-0001', status: 0)
+
+    expect(Dway.drmdb[:ext_permit].count).to eq(1)
+
+    ext_permit = Dway.drmdb[:ext_permit].first
+    expect(ext_permit).to include(ext_id: ext_entity[:ext_id], submitter_id: 'alice') 
+  end
+end

dra_validator/Gemfile

@@ -0,0 +1,7 @@
+source 'https://rubygems.org'
+
+gem 'bcrypt_pbkdf'
+gem 'ed25519'
+gem 'net-sftp', require: 'net/sftp'
+gem 'pg'
+gem 'sequel'

dra_validator/Gemfile.lock

@@ -0,0 +1,26 @@
+GEM
+  remote: https://rubygems.org/
+  specs:
+    bcrypt_pbkdf (1.1.1)
+    bigdecimal (3.1.8)
+    ed25519 (1.3.0)
+    net-sftp (4.0.0)
+      net-ssh (>= 5.0.0, < 8.0.0)
+    net-ssh (7.2.3)
+    pg (1.5.6)
+    sequel (5.81.0)
+      bigdecimal
+
+PLATFORMS
+  ruby
+  x86_64-linux
+
+DEPENDENCIES
+  bcrypt_pbkdf
+  ed25519
+  net-sftp
+  pg
+  sequel
+
+BUNDLED WITH
+   2.5.13

dra_validator/Rakefile

@@ -0,0 +1,12 @@
+namespace :db do
+  desc 'Run migrations'
+  task :migrate, [:version] do |t, args|
+    require 'sequel/core'
+
+    Sequel.extension :migration
+
+    Sequel.connect ENV.fetch('DATABASE_URL') do |db|
+      Sequel::Migrator.run db, 'db/migrations', target: args[:version]&.to_i
+    end
+  end
+end

dra_validator/db/migrations/001_init.rb

@@ -0,0 +1,18 @@
+Sequel.migration do
+  change do
+    create_table :submission do
+      primary_key :sub_id, type: :bigint
+
+      bigint  :usr_id, null: false
+      text    :submitter_id, null: false
+      integer :serial, null: false
+      integer :charge
+      date    :create_date
+      date    :submit_date
+      date    :hold_date
+      date    :dist_date
+      date    :finish_date
+      text    :note
+    end
+  end
+end

dra_validator/main.rb

@@ -0,0 +1,31 @@
+require 'bundler/setup'
+
+Bundler.require
+
+# DB = Sequel.connect(ENV.fetch('DATABASE_URL'))
+
+# submissions = DB[:submission]
+
+# submissions.insert usr_id: 42, submitter_id: '42', serial: 42
+
+# ディレクトリ名を引数で受け取れるようにする
+# 受け取った引数を元に再帰的にディレクトリを作成するメソッドを一つ用意する
+# そのメソッドの中で例外処理をする
+
+def mkdir_p!(sftp, dir)
+  dir_names = dir.split('/')
+  
+  dir_names.size.times.map {|i|
+    dir_names[0..i].join('/')
+  }.each do |dir_name|
+    begin
+      sftp.mkdir! dir_name
+    rescue Net::SFTP::StatusException => e
+      raise unless e.code == 4
+    end
+  end
+end
+
+Net::SFTP.start 'localhost', 'maimu', key_data: [File.read('/Users/maimu/.ssh/id_ed25519_no_passphrase')] do |sftp|
+  mkdir_p!(sftp, 'Documents/upload/foo/bar')
+end