mirror of
https://github.com/cmur2/openvpn-status-web.git
synced 2025-09-28 21:52:05 +02:00
Compare commits
21 Commits
Author | SHA1 | Date | |
---|---|---|---|
64ec5e1e56 | |||
![]() |
7597c17e93 | ||
ac647a4f21 | |||
78f45f5080 | |||
9aeb1a9ad5 | |||
88c22a6504 | |||
![]() |
289535d753 | ||
![]() |
8d42bdafc1 | ||
f8666fdfc2 | |||
41f5d4ed62 | |||
92ee01e5de | |||
bf3ba8f7cd | |||
140c60c753 | |||
d959e7fe62 | |||
4cde78fe96 | |||
23dd4aa63f | |||
1547db7bc6 | |||
b1aa38059f | |||
17054794da | |||
ab81c8975e | |||
1804693c15 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -1,3 +1,4 @@
|
||||
.DS_Store
|
||||
*.lock
|
||||
pkg/*
|
||||
.yardoc
|
||||
|
88
.rubocop.yml
Normal file
88
.rubocop.yml
Normal file
@@ -0,0 +1,88 @@
|
||||
AllCops:
|
||||
TargetRubyVersion: '2.5'
|
||||
NewCops: enable
|
||||
|
||||
Layout/EmptyLineAfterGuardClause:
|
||||
Enabled: false
|
||||
|
||||
# allows nicer usage of private_class_method
|
||||
Layout/EmptyLinesAroundArguments:
|
||||
Enabled: false
|
||||
|
||||
Layout/HashAlignment:
|
||||
Enabled: false
|
||||
|
||||
Layout/LeadingEmptyLines:
|
||||
Enabled: false
|
||||
|
||||
Layout/LineLength:
|
||||
Max: 200
|
||||
|
||||
Layout/SpaceInsideHashLiteralBraces:
|
||||
Enabled: false
|
||||
|
||||
Metrics/AbcSize:
|
||||
Enabled: false
|
||||
|
||||
Metrics/BlockLength:
|
||||
Enabled: false
|
||||
|
||||
Metrics/ClassLength:
|
||||
Enabled: false
|
||||
|
||||
Metrics/CyclomaticComplexity:
|
||||
Enabled: false
|
||||
|
||||
Metrics/MethodLength:
|
||||
Enabled: false
|
||||
|
||||
Metrics/PerceivedComplexity:
|
||||
Enabled: false
|
||||
|
||||
Naming/MethodParameterName:
|
||||
Enabled: false
|
||||
|
||||
Naming/MemoizedInstanceVariableName:
|
||||
Enabled: false
|
||||
|
||||
Style/AccessorGrouping:
|
||||
Enabled: false
|
||||
|
||||
Style/ConditionalAssignment:
|
||||
Enabled: false
|
||||
|
||||
Style/Documentation:
|
||||
Enabled: false
|
||||
|
||||
Style/FormatStringToken:
|
||||
Enabled: false
|
||||
|
||||
Style/GuardClause:
|
||||
Enabled: false
|
||||
|
||||
Style/HashEachMethods:
|
||||
Enabled: true
|
||||
|
||||
Style/HashTransformKeys:
|
||||
Enabled: true
|
||||
|
||||
Style/HashTransformValues:
|
||||
Enabled: true
|
||||
|
||||
Style/IdenticalConditionalBranches:
|
||||
Enabled: false
|
||||
|
||||
Style/InverseMethods:
|
||||
Enabled: false
|
||||
|
||||
Style/NegatedIf:
|
||||
Enabled: false
|
||||
|
||||
Style/RescueModifier:
|
||||
Enabled: false
|
||||
|
||||
Style/Semicolon:
|
||||
AllowAsExpressionSeparator: true
|
||||
|
||||
Style/SymbolArray:
|
||||
Enabled: false
|
16
.solargraph.yml
Normal file
16
.solargraph.yml
Normal file
@@ -0,0 +1,16 @@
|
||||
---
|
||||
include:
|
||||
- "**/*.rb"
|
||||
- "bin/openvpn-status-web"
|
||||
exclude:
|
||||
- spec/**/*
|
||||
- test/**/*
|
||||
- vendor/**/*
|
||||
- ".bundle/**/*"
|
||||
require: []
|
||||
domains: []
|
||||
reporters:
|
||||
- rubocop
|
||||
- require_not_found
|
||||
require_paths: []
|
||||
max_files: 5000
|
11
.travis.yml
11
.travis.yml
@@ -1,7 +1,10 @@
|
||||
---
|
||||
sudo: false
|
||||
os: linux
|
||||
language: ruby
|
||||
rvm:
|
||||
- 2.5
|
||||
- 2.4
|
||||
- 2.3
|
||||
- 2.7
|
||||
- 2.6
|
||||
- 2.5
|
||||
|
||||
script:
|
||||
- bundle exec rake travis
|
||||
|
2
Gemfile
2
Gemfile
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
source 'https://rubygems.org'
|
||||
|
||||
gemspec
|
||||
|
10
README.md
10
README.md
@@ -1,6 +1,6 @@
|
||||
# openvpn-status-web
|
||||
|
||||
[](https://travis-ci.org/cmur2/openvpn-status-web)
|
||||
[](https://travis-ci.org/cmur2/openvpn-status-web) [](https://depfu.com/github/cmur2/openvpn-status-web?project_id=6194)
|
||||
|
||||
## Description
|
||||
|
||||
@@ -57,10 +57,12 @@ For more information about OpenVPN status file and version, see their [man page]
|
||||
|
||||
If the information exposed is important to you serve it via the VPN or use a webserver as a proxy to handle SSL and/or HTTP authentication.
|
||||
|
||||
### Init scripts
|
||||
### Startup
|
||||
|
||||
The [Debian 6 init.d script](init.d/debian-6-openvpn-status-web) assumes that openvpn-status-web is installed into the system ruby (no RVM support) and the config.yaml is at /opt/openvpn-status-web/config.yaml. Modify to your needs.
|
||||
There is a [Dockerfile](docs/Dockerfile) that can be used to build a Docker image for running openvpn-status-web.
|
||||
|
||||
The [Debian 6 init script](docs/debian-init-openvpn-status-web) assumes that openvpn-status-web is installed into the system ruby (no RVM support) and the config.yaml is at `/opt/openvpn-status-web/config.yaml`. Modify to your needs.
|
||||
|
||||
## License
|
||||
|
||||
openvpn-statsu-web is licensed under the Apache License, Version 2.0. See LICENSE for more information.
|
||||
openvpn-status-web is licensed under the Apache License, Version 2.0. See LICENSE for more information.
|
||||
|
20
Rakefile
20
Rakefile
@@ -1,6 +1,24 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'bundler/gem_tasks'
|
||||
require 'rspec/core/rake_task'
|
||||
require 'rubocop/rake_task'
|
||||
require 'bundler/audit/task'
|
||||
|
||||
RSpec::Core::RakeTask.new(:spec)
|
||||
RuboCop::RakeTask.new
|
||||
Bundler::Audit::Task.new
|
||||
|
||||
task :default => :spec
|
||||
desc 'Should be run by developer once to prepare initial solargraph usage (fill caches etc.)'
|
||||
task :'solargraph:init' do
|
||||
sh 'solargraph download-core'
|
||||
end
|
||||
|
||||
desc 'Run experimental solargraph type checker'
|
||||
task :'solargraph:tc' do
|
||||
sh 'solargraph typecheck'
|
||||
end
|
||||
|
||||
task default: [:rubocop, :spec, 'bundle:audit']
|
||||
|
||||
task travis: [:default, :'solargraph:tc']
|
||||
|
15
docs/Dockerfile
Normal file
15
docs/Dockerfile
Normal file
@@ -0,0 +1,15 @@
|
||||
FROM alpine:3.12
|
||||
|
||||
EXPOSE 8080
|
||||
|
||||
ENV VERSION=3.0.0
|
||||
|
||||
RUN apk --no-cache add openssl ca-certificates && \
|
||||
apk --no-cache add ruby ruby-etc ruby-webrick && \
|
||||
apk --no-cache add --virtual .build-deps ruby-dev build-base tzdata && \
|
||||
gem install --no-document openvpn-status-web -v ${VERSION} && \
|
||||
# set timezone to Berlin
|
||||
cp /usr/share/zoneinfo/Europe/Berlin /etc/localtime && \
|
||||
apk del .build-deps
|
||||
|
||||
ENTRYPOINT ["openvpn-status-web", "/etc/openvpn-status-web/config.yml"]
|
@@ -1,3 +1,5 @@
|
||||
#!/usr/bin/env ruby
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'openvpn-status-web'
|
||||
|
71
lib/openvpn-status-web.rb
Normal file → Executable file
71
lib/openvpn-status-web.rb
Normal file → Executable file
@@ -1,4 +1,5 @@
|
||||
#!/usr/bin/env ruby
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'date'
|
||||
require 'etc'
|
||||
@@ -8,7 +9,7 @@ require 'yaml'
|
||||
require 'rack'
|
||||
require 'erb'
|
||||
require 'metriks'
|
||||
require 'better_errors' if ENV['RACK_ENV'] == "development"
|
||||
require 'better_errors' if ENV['RACK_ENV'] == 'development'
|
||||
|
||||
require 'openvpn-status-web/status'
|
||||
require 'openvpn-status-web/parser/v1'
|
||||
@@ -18,17 +19,25 @@ require 'openvpn-status-web/int_patch'
|
||||
require 'openvpn-status-web/version'
|
||||
|
||||
module OpenVPNStatusWeb
|
||||
# @return [Logger]
|
||||
def self.logger
|
||||
@logger
|
||||
end
|
||||
|
||||
# @param logger [Logger]
|
||||
# @return [Logger]
|
||||
def self.logger=(logger)
|
||||
@logger = logger
|
||||
end
|
||||
|
||||
class LogFormatter
|
||||
def call(lvl, time, progname, msg)
|
||||
"[%s] %-5s %s\n" % [Time.now.strftime('%Y-%m-%d %H:%M:%S'), lvl, msg.to_s]
|
||||
# @param lvl [Object]
|
||||
# @param _time [DateTime]
|
||||
# @param _progname [String]
|
||||
# @param msg [Object]
|
||||
# @return [String]
|
||||
def call(lvl, _time, _progname, msg)
|
||||
format("[%s] %-5s %s\n", Time.now.strftime('%Y-%m-%d %H:%M:%S'), lvl, msg.to_s)
|
||||
end
|
||||
end
|
||||
|
||||
@@ -40,29 +49,29 @@ module OpenVPNStatusWeb
|
||||
end
|
||||
|
||||
def call(env)
|
||||
return [405, {"Content-Type" => "text/plain"}, ["Method Not Allowed"]] if env["REQUEST_METHOD"] != "GET"
|
||||
return [404, {"Content-Type" => "text/plain"}, ["Not Found"]] if env["PATH_INFO"] != "/"
|
||||
return [405, {'Content-Type' => 'text/plain'}, ['Method Not Allowed']] if env['REQUEST_METHOD'] != 'GET'
|
||||
return [404, {'Content-Type' => 'text/plain'}, ['Not Found']] if env['PATH_INFO'] != '/'
|
||||
|
||||
# variables for template
|
||||
vpns = @vpns
|
||||
stati = {}
|
||||
@vpns.each do |name,config|
|
||||
@vpns.each do |name, config|
|
||||
stati[name] = parse_status_log(config)
|
||||
end
|
||||
# eval
|
||||
html = @main_tmpl.result(binding)
|
||||
|
||||
[200, {"Content-Type" => "text/html"}, [html]]
|
||||
[200, {'Content-Type' => 'text/html'}, [html]]
|
||||
end
|
||||
|
||||
def read_template(file)
|
||||
text = File.open(file, 'rb') do |f| f.read end
|
||||
|
||||
text = File.read(file, mode: 'rb')
|
||||
|
||||
ERB.new(text)
|
||||
end
|
||||
|
||||
|
||||
def parse_status_log(vpn)
|
||||
text = File.open(vpn['status_file'], 'rb') do |f| f.read end
|
||||
text = File.read(vpn['status_file'], mode: 'rb')
|
||||
|
||||
case vpn['version']
|
||||
when 1
|
||||
@@ -76,23 +85,24 @@ module OpenVPNStatusWeb
|
||||
end
|
||||
end
|
||||
|
||||
# @return [void]
|
||||
def self.run!
|
||||
if ARGV.length != 1
|
||||
puts "Usage: openvpn-status-web config_file"
|
||||
puts 'Usage: openvpn-status-web config_file'
|
||||
exit 1
|
||||
end
|
||||
|
||||
config_file = ARGV[0]
|
||||
|
||||
if not File.file?(config_file)
|
||||
puts "Config file not found!"
|
||||
if !File.file?(config_file)
|
||||
puts 'Config file not found!'
|
||||
exit 1
|
||||
end
|
||||
|
||||
|
||||
puts "openvpn-status-web version #{OpenVPNStatusWeb::VERSION}"
|
||||
puts "Using config file #{config_file}"
|
||||
|
||||
config = YAML::load(File.open(config_file, 'r') { |f| f.read })
|
||||
config = YAML.safe_load(File.read(config_file, mode: 'r'))
|
||||
|
||||
if config['logfile']
|
||||
OpenVPNStatusWeb.logger = Logger.new(config['logfile'])
|
||||
@@ -100,32 +110,39 @@ module OpenVPNStatusWeb
|
||||
OpenVPNStatusWeb.logger = Logger.new(STDOUT)
|
||||
end
|
||||
|
||||
OpenVPNStatusWeb.logger.progname = "openvpn-status-web"
|
||||
OpenVPNStatusWeb.logger.progname = 'openvpn-status-web'
|
||||
OpenVPNStatusWeb.logger.formatter = LogFormatter.new
|
||||
|
||||
OpenVPNStatusWeb.logger.info "Starting..."
|
||||
OpenVPNStatusWeb.logger.info 'Starting...'
|
||||
|
||||
# drop privs (first change group than user)
|
||||
Process::Sys.setgid(Etc.getgrnam(config['group']).gid) if config['group']
|
||||
Process::Sys.setuid(Etc.getpwnam(config['user']).uid) if config['user']
|
||||
# drop priviliges as soon as possible
|
||||
# NOTE: first change group than user
|
||||
if config['group']
|
||||
group = Etc.getgrnam(config['group'])
|
||||
Process::Sys.setgid(group.gid) if group
|
||||
end
|
||||
if config['user']
|
||||
user = Etc.getpwnam(config['user'])
|
||||
Process::Sys.setuid(user.uid) if user
|
||||
end
|
||||
|
||||
# configure rack
|
||||
app = Daemon.new(config['vpns'])
|
||||
if ENV['RACK_ENV'] == "development"
|
||||
if ENV['RACK_ENV'] == 'development'
|
||||
app = BetterErrors::Middleware.new(app)
|
||||
BetterErrors.application_root = File.expand_path("..", __FILE__)
|
||||
BetterErrors.application_root = File.expand_path(__dir__)
|
||||
end
|
||||
|
||||
Signal.trap('INT') do
|
||||
OpenVPNStatusWeb.logger.info "Quitting..."
|
||||
OpenVPNStatusWeb.logger.info 'Quitting...'
|
||||
Rack::Handler::WEBrick.shutdown
|
||||
end
|
||||
Signal.trap('TERM') do
|
||||
OpenVPNStatusWeb.logger.info "Quitting..."
|
||||
OpenVPNStatusWeb.logger.info 'Quitting...'
|
||||
Rack::Handler::WEBrick.shutdown
|
||||
end
|
||||
|
||||
Rack::Handler::WEBrick.run app, :Host => config['host'], :Port => config['port']
|
||||
|
||||
Rack::Handler::WEBrick.run app, Host: config['host'], Port: config['port']
|
||||
end
|
||||
end
|
||||
end
|
||||
|
@@ -1,16 +1,17 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
class Integer
|
||||
def as_bytes
|
||||
return "1 Byte" if self == 1
|
||||
|
||||
label = ["Bytes", "KiB", "MiB", "GiB", "TiB"]
|
||||
return '1 Byte' if self == 1
|
||||
|
||||
label = %w[Bytes KiB MiB GiB TiB]
|
||||
i = 0
|
||||
num = self.to_f
|
||||
while num >= 1024 do
|
||||
num = num / 1024
|
||||
num = to_f
|
||||
while num >= 1024
|
||||
num /= 1024
|
||||
i += 1
|
||||
end
|
||||
|
||||
|
||||
"#{format('%.2f', num)} #{label[i]}"
|
||||
end
|
||||
end
|
||||
|
@@ -1,3 +1,4 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module OpenVPNStatusWeb
|
||||
module Parser
|
||||
@@ -10,29 +11,27 @@ module OpenVPNStatusWeb
|
||||
|
||||
text.lines.each do |line|
|
||||
parts = line.strip.split(sep)
|
||||
status.client_list << parse_client(parts[1..5]) if parts[0] == "CLIENT_LIST"
|
||||
status.routing_table << parse_route(parts[1..4]) if parts[0] == "ROUTING_TABLE"
|
||||
status.global_stats << parse_global(parts[1..2]) if parts[0] == "GLOBAL_STATS"
|
||||
status.client_list << parse_client(parts[1..5]) if parts[0] == 'CLIENT_LIST'
|
||||
status.routing_table << parse_route(parts[1..4]) if parts[0] == 'ROUTING_TABLE'
|
||||
status.global_stats << parse_global(parts[1..2]) if parts[0] == 'GLOBAL_STATS'
|
||||
end
|
||||
|
||||
status
|
||||
end
|
||||
|
||||
private
|
||||
|
||||
def self.parse_client(client)
|
||||
private_class_method def self.parse_client(client)
|
||||
client[2] = client[2].to_i
|
||||
client[3] = client[3].to_i
|
||||
client[4] = DateTime.strptime(client[4], '%a %b %d %k:%M:%S %Y')
|
||||
client
|
||||
end
|
||||
|
||||
def self.parse_route(route)
|
||||
private_class_method def self.parse_route(route)
|
||||
route[3] = DateTime.strptime(route[3], '%a %b %d %k:%M:%S %Y')
|
||||
route
|
||||
end
|
||||
|
||||
def self.parse_global(global)
|
||||
private_class_method def self.parse_global(global)
|
||||
global[1] = global[1].to_i
|
||||
global
|
||||
end
|
||||
|
@@ -1,3 +1,4 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module OpenVPNStatusWeb
|
||||
module Parser
|
||||
@@ -13,7 +14,7 @@ module OpenVPNStatusWeb
|
||||
(current_section = :rt; next) if line == "ROUTING TABLE\n"
|
||||
(current_section = :gs; next) if line == "GLOBAL STATS\n"
|
||||
(current_section = :end; next) if line == "END\n"
|
||||
|
||||
|
||||
case current_section
|
||||
when :cl
|
||||
client_list << line.strip.split(',')
|
||||
|
@@ -1,5 +1,6 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'openvpn-status-web/parser/modern_stateless'
|
||||
require_relative 'modern_stateless'
|
||||
|
||||
module OpenVPNStatusWeb
|
||||
module Parser
|
||||
|
@@ -1,5 +1,6 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'openvpn-status-web/parser/modern_stateless'
|
||||
require_relative 'modern_stateless'
|
||||
|
||||
module OpenVPNStatusWeb
|
||||
module Parser
|
||||
|
@@ -1,3 +1,4 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module OpenVPNStatusWeb
|
||||
class Status
|
||||
|
@@ -1,4 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module OpenVPNStatusWeb
|
||||
VERSION = "2.0.0"
|
||||
VERSION = '3.0.0'
|
||||
end
|
||||
|
@@ -1,32 +1,41 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
$LOAD_PATH.push File.expand_path('lib', __dir__)
|
||||
|
||||
require 'openvpn-status-web/version'
|
||||
require_relative 'lib/openvpn-status-web/version'
|
||||
|
||||
Gem::Specification.new do |s|
|
||||
s.name = 'openvpn-status-web'
|
||||
s.name = 'openvpn-status-web'
|
||||
s.version = OpenVPNStatusWeb::VERSION
|
||||
s.summary = 'openvpn-status-web'
|
||||
s.description = 'Small Rack (Ruby) application serving OpenVPN status file.'
|
||||
s.author = 'Christian Nicolai'
|
||||
s.email = 'chrnicolai@gmail.com'
|
||||
s.homepage = 'https://github.com/cmur2/dyndnsd'
|
||||
|
||||
s.homepage = 'https://github.com/cmur2/openvpn-status-web'
|
||||
s.license = 'Apache-2.0'
|
||||
s.metadata = {
|
||||
'bug_tracker_uri' => "#{s.homepage}/issues",
|
||||
'source_code_uri' => s.homepage
|
||||
}
|
||||
|
||||
s.files = `git ls-files`.split($INPUT_RECORD_SEPARATOR)
|
||||
s.test_files = s.files.grep(%r{^(test|spec|features)/})
|
||||
s.files = `git ls-files -z`.split("\x0").select do |f|
|
||||
f.match(%r{^(init.d|lib)/})
|
||||
end
|
||||
s.require_paths = ['lib']
|
||||
s.bindir = 'exe'
|
||||
s.executables = ['openvpn-status-web']
|
||||
s.extra_rdoc_files = Dir['README.md', 'LICENSE']
|
||||
|
||||
s.required_ruby_version = '>= 2.3'
|
||||
s.required_ruby_version = '>= 2.5'
|
||||
|
||||
s.add_runtime_dependency 'rack', '~> 2.0'
|
||||
s.add_runtime_dependency 'metriks'
|
||||
s.add_runtime_dependency 'rack', '~> 2.0'
|
||||
|
||||
s.add_development_dependency 'bundler'
|
||||
s.add_development_dependency 'rake'
|
||||
s.add_development_dependency 'rspec'
|
||||
s.add_development_dependency 'rack-test'
|
||||
s.add_development_dependency 'better_errors'
|
||||
s.add_development_dependency 'binding_of_caller'
|
||||
s.add_development_dependency 'bundler'
|
||||
s.add_development_dependency 'bundler-audit', '~> 0.7.0'
|
||||
s.add_development_dependency 'rack-test'
|
||||
s.add_development_dependency 'rake'
|
||||
s.add_development_dependency 'rspec'
|
||||
s.add_development_dependency 'rubocop', '~> 0.88.0'
|
||||
s.add_development_dependency 'solargraph'
|
||||
end
|
||||
|
@@ -1,4 +1,6 @@
|
||||
require 'spec_helper'
|
||||
# frozen_string_literal: true
|
||||
|
||||
require_relative '../spec_helper'
|
||||
|
||||
describe OpenVPNStatusWeb::Parser::ModernStateless do
|
||||
{
|
||||
@@ -8,47 +10,56 @@ describe OpenVPNStatusWeb::Parser::ModernStateless do
|
||||
context "for status-version #{version}" do
|
||||
context 'for client list' do
|
||||
it 'parses common names' do
|
||||
expect(status.client_list.map { |client| client[0] }).to eq(["foo", "bar"])
|
||||
expect(status.client_list.map { |client| client[0] }).to eq(%w[foo bar])
|
||||
end
|
||||
|
||||
it 'parses real addresses' do
|
||||
expect(status.client_list.map { |client| client[1] }).to eq(["1.2.3.4:1234", "1.2.3.5:1235"])
|
||||
expect(status.client_list.map { |client| client[1] }).to eq(['1.2.3.4:1234', '1.2.3.5:1235'])
|
||||
end
|
||||
|
||||
it 'parses received bytes' do
|
||||
expect(status.client_list.map { |client| client[2] }).to eq([11811160064, 512])
|
||||
expect(status.client_list.map { |client| client[2] }).to eq([11_811_160_064, 512])
|
||||
end
|
||||
|
||||
it 'parses sent bytes' do
|
||||
expect(status.client_list.map { |client| client[3] }).to eq([4194304, 2048])
|
||||
expect(status.client_list.map { |client| client[3] }).to eq([4_194_304, 2048])
|
||||
end
|
||||
|
||||
it 'parses connected since date' do
|
||||
expect(status.client_list.map { |client| client[4] }).to eq([DateTime.new(2012,1,1,23,42,0), DateTime.new(2012,1,1,23,42,0)])
|
||||
expect(status.client_list.map { |client| client[4] }).to eq(
|
||||
[
|
||||
DateTime.new(2012, 1, 1, 23, 42, 0), DateTime.new(2012, 1, 1, 23, 42, 0)
|
||||
]
|
||||
)
|
||||
end
|
||||
end
|
||||
|
||||
context 'for routing table' do
|
||||
it 'parses virtual addresses' do
|
||||
expect(status.routing_table.map { |route| route[0] }).to eq(["192.168.0.0/24", "192.168.66.2", "192.168.66.3", "2001:db8:0:0::1000"])
|
||||
expect(status.routing_table.map { |route| route[0] }).to eq(['192.168.0.0/24', '192.168.66.2', '192.168.66.3', '2001:db8:0:0::1000'])
|
||||
end
|
||||
|
||||
it 'parses common names' do
|
||||
expect(status.routing_table.map { |route| route[1] }).to eq(["foo", "bar", "foo", "bar"])
|
||||
expect(status.routing_table.map { |route| route[1] }).to eq(%w[foo bar foo bar])
|
||||
end
|
||||
|
||||
it 'parses real addresses' do
|
||||
expect(status.routing_table.map { |route| route[2] }).to eq(["1.2.3.4:1234", "1.2.3.5:1235", "1.2.3.4:1234", "1.2.3.5:1235"])
|
||||
expect(status.routing_table.map { |route| route[2] }).to eq(['1.2.3.4:1234', '1.2.3.5:1235', '1.2.3.4:1234', '1.2.3.5:1235'])
|
||||
end
|
||||
|
||||
it 'parses last ref date' do
|
||||
expect(status.routing_table.map { |route| route[3] }).to eq([DateTime.new(2012,1,1,23,42,0), DateTime.new(2012,1,1,23,42,0), DateTime.new(2012,1,1,23,42,0), DateTime.new(2012,1,1,23,42,0)])
|
||||
expect(status.routing_table.map { |route| route[3] }).to eq(
|
||||
[
|
||||
DateTime.new(2012, 1, 1, 23, 42, 0), DateTime.new(2012, 1, 1, 23, 42, 0),
|
||||
DateTime.new(2012, 1, 1, 23, 42, 0), DateTime.new(2012, 1, 1, 23, 42, 0)
|
||||
]
|
||||
)
|
||||
end
|
||||
end
|
||||
|
||||
it 'parses global stats' do
|
||||
expect(status.global_stats.size).to eq(1)
|
||||
expect(status.global_stats.first).to eq(["Max bcast/mcast queue length", 42])
|
||||
expect(status.global_stats.first).to eq(['Max bcast/mcast queue length', 42])
|
||||
end
|
||||
end
|
||||
end
|
||||
|
@@ -1,50 +1,63 @@
|
||||
require 'spec_helper'
|
||||
# frozen_string_literal: true
|
||||
|
||||
require_relative '../spec_helper'
|
||||
|
||||
describe OpenVPNStatusWeb::Parser::V1 do
|
||||
def status; status_v1; end
|
||||
def status
|
||||
status_v1
|
||||
end
|
||||
|
||||
context 'for client list' do
|
||||
it 'parses common names' do
|
||||
expect(status.client_list.map { |client| client[0] }).to eq(["foo", "bar"])
|
||||
expect(status.client_list.map { |client| client[0] }).to eq(%w[foo bar])
|
||||
end
|
||||
|
||||
it 'parses real addresses' do
|
||||
expect(status.client_list.map { |client| client[1] }).to eq(["1.2.3.4:1234", "1.2.3.5:1235"])
|
||||
expect(status.client_list.map { |client| client[1] }).to eq(['1.2.3.4:1234', '1.2.3.5:1235'])
|
||||
end
|
||||
|
||||
it 'parses received bytes' do
|
||||
expect(status.client_list.map { |client| client[2] }).to eq([11811160064, 512])
|
||||
expect(status.client_list.map { |client| client[2] }).to eq([11_811_160_064, 512])
|
||||
end
|
||||
|
||||
it 'parses sent bytes' do
|
||||
expect(status.client_list.map { |client| client[3] }).to eq([4194304, 2048])
|
||||
expect(status.client_list.map { |client| client[3] }).to eq([4_194_304, 2048])
|
||||
end
|
||||
|
||||
it 'parses connected since date' do
|
||||
expect(status.client_list.map { |client| client[4] }).to eq([DateTime.new(2012,1,1,23,42,0), DateTime.new(2012,1,1,23,42,0)])
|
||||
expect(status.client_list.map { |client| client[4] }).to eq(
|
||||
[
|
||||
DateTime.new(2012, 1, 1, 23, 42, 0), DateTime.new(2012, 1, 1, 23, 42, 0)
|
||||
]
|
||||
)
|
||||
end
|
||||
end
|
||||
|
||||
context 'for routing table' do
|
||||
it 'parses virtual addresses' do
|
||||
expect(status.routing_table.map { |route| route[0] }).to eq(["192.168.0.0/24", "192.168.66.2", "192.168.66.3", "2001:db8:0:0::1000"])
|
||||
expect(status.routing_table.map { |route| route[0] }).to eq(['192.168.0.0/24', '192.168.66.2', '192.168.66.3', '2001:db8:0:0::1000'])
|
||||
end
|
||||
|
||||
it 'parses common names' do
|
||||
expect(status.routing_table.map { |route| route[1] }).to eq(["foo", "bar", "foo", "bar"])
|
||||
expect(status.routing_table.map { |route| route[1] }).to eq(%w[foo bar foo bar])
|
||||
end
|
||||
|
||||
it 'parses real addresses' do
|
||||
expect(status.routing_table.map { |route| route[2] }).to eq(["1.2.3.4:1234", "1.2.3.5:1235", "1.2.3.4:1234", "1.2.3.5:1235"])
|
||||
expect(status.routing_table.map { |route| route[2] }).to eq(['1.2.3.4:1234', '1.2.3.5:1235', '1.2.3.4:1234', '1.2.3.5:1235'])
|
||||
end
|
||||
|
||||
it 'parses last ref date' do
|
||||
expect(status.routing_table.map { |route| route[3] }).to eq([DateTime.new(2012,1,1,23,42,0), DateTime.new(2012,1,1,23,42,0), DateTime.new(2012,1,1,23,42,0), DateTime.new(2012,1,1,23,42,0)])
|
||||
expect(status.routing_table.map { |route| route[3] }).to eq(
|
||||
[
|
||||
DateTime.new(2012, 1, 1, 23, 42, 0), DateTime.new(2012, 1, 1, 23, 42, 0),
|
||||
DateTime.new(2012, 1, 1, 23, 42, 0), DateTime.new(2012, 1, 1, 23, 42, 0)
|
||||
]
|
||||
)
|
||||
end
|
||||
end
|
||||
|
||||
it 'parses global stats' do
|
||||
expect(status.global_stats.size).to eq(1)
|
||||
expect(status.global_stats.first).to eq(["Max bcast/mcast queue length", 42])
|
||||
expect(status.global_stats.first).to eq(['Max bcast/mcast queue length', 42])
|
||||
end
|
||||
end
|
||||
|
@@ -1,3 +1,4 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'rubygems'
|
||||
require 'bundler/setup'
|
||||
@@ -6,16 +7,16 @@ require 'rack/test'
|
||||
require 'openvpn-status-web'
|
||||
|
||||
def status_v1
|
||||
text = File.open('examples/status.v1', 'rb') do |f| f.read end
|
||||
text = File.open('examples/status.v1', 'rb', &:read)
|
||||
OpenVPNStatusWeb::Parser::V1.new.parse_status_log text
|
||||
end
|
||||
|
||||
def status_v2
|
||||
text = File.open('examples/status.v2', 'rb') do |f| f.read end
|
||||
text = File.open('examples/status.v2', 'rb', &:read)
|
||||
OpenVPNStatusWeb::Parser::V2.new.parse_status_log text
|
||||
end
|
||||
|
||||
def status_v3
|
||||
text = File.open('examples/status.v3', 'rb') do |f| f.read end
|
||||
text = File.open('examples/status.v3', 'rb', &:read)
|
||||
OpenVPNStatusWeb::Parser::V3.new.parse_status_log text
|
||||
end
|
||||
|
Reference in New Issue
Block a user