WIP

Author: maimux2x

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-sftp', require: 'net/sftp'
 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)
@@ -210,8 +213,11 @@ GEM
       net-protocol
     net-protocol (0.2.2)
       timeout
+    net-sftp (4.0.0)
+      net-ssh (>= 5.0.0, < 8.0.0)
     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)
@@ -396,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-sftp
   noodles_gff!
   openid_connect
   pagy

api/app/models/database/dra.rb

@@ -95,6 +95,26 @@ def submit(submission)
           ext_id:       ,
           submitter_id:
         )
+
+        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
+      end
+
+      private
+
+      def mkdir_p!(sftp, path)
+        components = path.split('/')
+        
+        components.size.times.map {|i|
+          components[0..i].join('/')
+        }.each do |sub_path|
+          begin
+            sftp.mkdir! sub_path
+          rescue Net::SFTP::StatusException => e
+            raise unless e.code == 4
+          end
+        end
       end
     end
   end

dra_validator/Gemfile

@@ -2,6 +2,6 @@ source 'https://rubygems.org'
 
 gem 'bcrypt_pbkdf'
 gem 'ed25519'
-gem 'net-ssh'
+gem 'net-sftp', require: 'net/sftp'
 gem 'pg'
 gem 'sequel'

dra_validator/Gemfile.lock

@@ -4,6 +4,8 @@ GEM
     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)
@@ -16,7 +18,7 @@ PLATFORMS
 DEPENDENCIES
   bcrypt_pbkdf
   ed25519
-  net-ssh
+  net-sftp
   pg
   sequel
 

dra_validator/main.rb

@@ -8,6 +8,24 @@
 
 # submissions.insert usr_id: 42, submitter_id: '42', serial: 42
 
-Net::SSH.start 'localhost', 'ursm', key_data: [File.read('/home/ursm/.ssh/id_25519_no_passphrase')] do |ssh|
-  puts ssh.exec!('uname -a')
+# ディレクトリ名を引数で受け取れるようにする
+# 受け取った引数を元に再帰的にディレクトリを作成するメソッドを一つ用意する
+# そのメソッドの中で例外処理をする
+
+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