gluster-web-interface/app/controllers/volume_controller.rb

class VolumeController < ApplicationController

    def index
        file_directory("/mnt")
        get_conf
        info = get_volume_info.split("\n")
        if info.blank?
            flash[:danger] = "Check Server"
        else
            parse_info(info)
        end
    end

    def parse_info(info)
        @volumes = Array.new
        volume = Hash.new
        df = get_df
        info << "\n"
        info.each do |t|
            next if t.equal? info.first
            if t.include? ":"
                temp = t.split(":")
                volume[temp[0]] = temp[1]
            else
                String state = (df.include? volume['Volume Name'].delete(' ')) ? "mounted" : "unmounted"
                volume['Mount State'] = state

                if state.eql? "mounted"
                    s = df.split("\n")
                    s.each do |t|
                        if t.include? volume['Volume Name'].delete(' ')
                            mnt_point = t.split(" ")[5]
                            volume['Mount Point'] = mnt_point
                        end
                    end
                end

                @volumes << volume
                volume = Hash.new
            end
        end
    end

    def get_df
        return `df -P`
    end

    def get_volume_info
        command = String.new
        command << "sshpass -p" + @config["host_password"].to_s
        command << " ssh "
        if !@config["host_port"].nil?
            command << "-p " + @config["host_port"].to_s + " "
        end
        command << @config["host_user"].to_s + "@" + @config["host_ip"].to_s
        command << " gluster volume info"
        puts command
        return `#{command}`
    end

    def file_upload
        df = get_df
        mnt_dir = String.new
        mnt_dest = String.new
        file = params[:file]
        s = df.split("\n")
        s.each do |t|
            if t.include? params[:volume_name]
                mnt_dir = t.split(" ")[5]
            end
        end
        mnt_dest = mnt_dir + "/" + file.original_filename

        puts "upload start"
        # get permission
#        dir_left = mnt_dir[0..mnt_dir.rindex('/')]
#        dir_right = mnt_dir.split(dir_left)[1]
#        pe = `ls -al #{dir_left} | grep #{dir_right}`.split(" ")[0]

#        puts "111" + dir_left
#        puts "222" + dir_right
#        puts "333" + pe

        u = AvatarUploader.new(mnt_dir)
        u.store!(file)
        puts "upload end"

        redirect_to '/volume/index'
    end

    def volume_mount
        get_conf
        volume_name = params[:volume_name]
        mount_point = params[:mount_point]
        # make command string
        command = String.new
        command << "sudo mount -t glusterfs " + @config["host_ip"].to_s + ":/" + volume_name + " " + mount_point
        puts command
        `#{command}`
        redirect_to '/volume/index'
    end

    def volume_unmount
        get_conf
        volume_name = params[:volume_name]
        # make command string
        command = String.new
        command << "sudo umount " + @config["host_ip"].to_s + ":/" + volume_name
        puts command
        `#{command}`
        redirect_to '/volume/index'
    end

    def volume_create
        get_conf
        volume_name = params[:volume_name]
        volume_type = params[:volume_type]
        num_of_brick = params[:num_of_brick]
        bricks = params[:bricks]
        # make command string
        command = String.new
        command << "sshpass -p" + @config["host_password"].to_s
        command << " ssh "
        if !@config["host_port"].nil?
            command << "-p " + @config["host_port"].to_s + " "
        end
        command << @config["host_user"].to_s + "@" + @config["host_ip"].to_s
        command << " gluster volume create " + volume_name + " "
        if !volume_type.include? "Distribute"
            command << volume_type.downcase + " " + num_of_brick + " "
        end
        bricks.each do |t|
            command << t + " "
        end
        command << "force"
        puts command
        `#{command}`
        redirect_to '/volume/index'
    end

    def volume_stop
        get_conf
        volume_name = params[:volume_name]
        # make command string
        command = String.new
        command << "yes | sshpass -p" + @config["host_password"].to_s
        command << " ssh "
        if !@config["host_port"].nil?
            command << "-p " + @config["host_port"].to_s + " "
        end
        command << @config["host_user"].to_s + "@" + @config["host_ip"].to_s
        command << " gluster volume stop " + volume_name
        puts command
        `#{command}`
        redirect_to '/volume/index'
    end

    def volume_start
        get_conf
        volume_name = params[:volume_name]
        # make command string
        command = String.new
        command << "sshpass -p" + @config["host_password"].to_s
        command << " ssh "
        if !@config["host_port"].nil?
            command << "-p " + @config["host_port"].to_s + " "
        end
        command << @config["host_user"].to_s + "@" + @config["host_ip"].to_s
        command << " gluster volume start " + volume_name.to_s
        puts command
        `#{command}`
        redirect_to '/volume/index'
    end

    def volume_delete
        get_conf
        volume_name = params[:volume_name]
        # make command string
        command = String.new
        command << "yes | sshpass -p" + @config["host_password"].to_s
        command << " ssh "
        if !@config["host_port"].nil?
            command << "-p " + @config["host_port"].to_s + " "
        end
        command << @config["host_user"].to_s + "@" + @config["host_ip"].to_s
        command << " gluster volume delete " + volume_name
        puts command
        `#{command}`
        redirect_to '/volume/index'
    end
end