Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3312c357f3 | ||
|
|
fb6091bb83 | ||
|
|
16f88a1336 | ||
|
|
e0fcd058df | ||
|
|
9e37bd27f1 | ||
|
|
6b0b0244d1 | ||
|
|
c6ece21133 | ||
|
|
4919407228 | ||
|
|
1c3c82de18 | ||
|
|
06d73805a8 | ||
|
|
74e8482f96 | ||
|
|
79d8afc715 | ||
|
|
9a5df8487a | ||
|
|
3fb87562ed | ||
|
|
6a52fea44a | ||
|
|
e3085a44ba | ||
|
|
4ce11c039e | ||
|
|
70f62feec8 | ||
|
|
266a516076 | ||
|
|
2e8800150e | ||
|
|
8413681db0 | ||
|
|
ed8a581ff2 | ||
|
|
302aa1d85b | ||
|
|
f5f78eb32e | ||
|
|
e6df3d19fa | ||
|
|
08b1ea71e7 | ||
|
|
7fe302ed7c | ||
|
|
bcd170ab74 | ||
|
|
e63945ee71 | ||
|
|
487e2820f4 | ||
|
|
a716093236 | ||
|
|
f8bfe2de56 | ||
|
|
136b2a6942 | ||
|
|
c2c69e032c | ||
|
|
3ff70b916f | ||
|
|
22eb352180 | ||
|
|
3a32f531a0 | ||
|
|
63f1150056 | ||
|
|
40f582d1ea | ||
|
|
cf86131808 | ||
|
|
f3d6d9d73e | ||
|
|
1b03d78800 | ||
|
|
6489f6a800 | ||
|
|
36436f3aa7 | ||
|
|
db05989d07 | ||
|
|
3b2bec68ef | ||
|
|
9717d3a132 | ||
|
|
f4e7643e22 | ||
|
|
605c483d5b | ||
|
|
8a8b9f07fb | ||
|
|
7ee3c61e38 | ||
|
|
408e23adb3 | ||
|
|
e560f07de6 | ||
|
|
fe5039d17a | ||
|
|
f810c0227b | ||
|
|
10c90bcd01 | ||
|
|
f3a6ce4636 |
@@ -3,7 +3,7 @@ name: checks
|
||||
on:
|
||||
push:
|
||||
branches:
|
||||
- master
|
||||
- main
|
||||
paths-ignore:
|
||||
- '**.md'
|
||||
pull_request:
|
||||
@@ -15,7 +15,7 @@ on:
|
||||
|
||||
|
||||
env:
|
||||
GO_VERSION: "1.20"
|
||||
GO_VERSION: "1.25"
|
||||
|
||||
concurrency:
|
||||
group: ${{ github.workflow }}-${{ github.ref }}
|
||||
@@ -28,7 +28,7 @@ jobs:
|
||||
timeout-minutes: 40
|
||||
strategy:
|
||||
matrix:
|
||||
pg_version: [9.6, 10, 11, 12, 13, 14, 15, 16]
|
||||
pg_version: [9.6, 10, 11, 12, 13, 14, 15, 16, 17, 18]
|
||||
|
||||
services:
|
||||
postgres:
|
||||
@@ -50,7 +50,7 @@ jobs:
|
||||
sudo rm -f /etc/apt/sources.list.d/pgdg.list
|
||||
curl --silent https://www.postgresql.org/media/keys/ACCC4CF8.asc | sudo apt-key add
|
||||
echo "deb http://apt.postgresql.org/pub/repos/apt/ `lsb_release -cs`-pgdg main" | sudo tee /etc/apt/sources.list.d/pgdg.list
|
||||
sudo apt-get update && sudo apt-get install -y postgresql-client-16
|
||||
sudo apt-get update && sudo apt-get install -y postgresql-client-18
|
||||
|
||||
- uses: actions/checkout@v3
|
||||
with:
|
||||
@@ -95,9 +95,9 @@ jobs:
|
||||
fetch-depth: 0
|
||||
|
||||
- name: golangci-lint
|
||||
uses: golangci/golangci-lint-action@v3
|
||||
uses: golangci/golangci-lint-action@v8
|
||||
with:
|
||||
version: v1.51.2
|
||||
version: v2.7.2
|
||||
|
||||
fmt:
|
||||
name: fmt
|
||||
|
||||
@@ -3,7 +3,7 @@ name: demo deploy
|
||||
on:
|
||||
push:
|
||||
branches:
|
||||
- master
|
||||
- main
|
||||
|
||||
env:
|
||||
FLY_API_TOKEN: ${{ secrets.FLY_TOKEN }}
|
||||
|
||||
@@ -3,10 +3,10 @@ name: docker
|
||||
on:
|
||||
push:
|
||||
branches:
|
||||
- master
|
||||
- main
|
||||
|
||||
env:
|
||||
GO_VERSION: "1.20"
|
||||
GO_VERSION: "1.25"
|
||||
CGO_ENABLED: 0
|
||||
IMAGE_REPOSITORY: sosedoff/pgweb
|
||||
|
||||
@@ -32,4 +32,6 @@ jobs:
|
||||
context: .
|
||||
push: false
|
||||
tags: pgweb:latest
|
||||
platforms: linux/amd64,linux/arm64,linux/arm/v5,linux/arm/v7
|
||||
platforms: linux/amd64,linux/arm64,linux/arm/v7
|
||||
build-args: |
|
||||
"CGO_ENABLED=${{ env.CGO_ENABLED }}"
|
||||
|
||||
@@ -6,7 +6,7 @@ on:
|
||||
- "v*"
|
||||
|
||||
env:
|
||||
GO_VERSION: "1.20"
|
||||
GO_VERSION: "1.25"
|
||||
CGO_ENABLED: 0
|
||||
DOCKER_REPOSITORY: sosedoff/pgweb
|
||||
GHCR_REPOSITORY: sosedoff/pgweb
|
||||
@@ -57,4 +57,4 @@ jobs:
|
||||
${{ env.DOCKER_REPOSITORY }}:latest
|
||||
ghcr.io/${{ env.GHCR_REPOSITORY }}:${{ steps.refs.outputs.SOURCE_TAG }}
|
||||
ghcr.io/${{ env.GHCR_REPOSITORY }}:latest
|
||||
platforms: linux/amd64,linux/arm64,linux/arm/v5,linux/arm/v7
|
||||
platforms: linux/amd64,linux/arm64,linux/arm/v7
|
||||
|
||||
@@ -0,0 +1,7 @@
|
||||
version: "2"
|
||||
linters:
|
||||
disable:
|
||||
- errcheck
|
||||
settings:
|
||||
staticcheck:
|
||||
checks: ["all", "-ST1000", "-ST1003", "-ST1016", "-ST1020", "-ST1021", "-ST1022", "-ST1005", "-QF1004"]
|
||||
+77
-23
@@ -1,28 +1,82 @@
|
||||
# 0.14.1 - 2023-06-17
|
||||
## Changelog
|
||||
|
||||
- NEW: Add process start time metric, GH-675
|
||||
- NEW: Configure pgweb user for docker container, GH-674
|
||||
- NEW: Updated dockerfile, GH-645
|
||||
- FIX: Fix typo in the healthy metric, GH-657
|
||||
- NEW: Use entrypoint instead of cmd in in dockerfile, GH-654
|
||||
Current [release](https://github.com/sosedoff/pgweb/releases) is `0.17.0`.
|
||||
|
||||
# 0.14.0 - 2023-02-21
|
||||
## 0.17.0 - 2025-11-22
|
||||
|
||||
- FIX: History page query loading fixup, GH-632
|
||||
- NEW: Display cell content via context menu, GH-634
|
||||
- NEW: Handle support/permissions errors in info call, GH-635
|
||||
- NEW: Show error message when API calls fail, GH-636
|
||||
- NEW: Add bookmark options to load username/password from env vars, GH-638
|
||||
- NEW: Add context menu to display database tables stats, GH-639
|
||||
- NEW: Added Local Queries feature, GH-641
|
||||
- FIX: Ensure that objects are sorted by schema and name, GH-648
|
||||
- FIX: Fetch local queries on db connect, GH-650
|
||||
- `NEW` Update Dockerfile to use Golang 1.24 image, GH-821
|
||||
- `NEW` Bump go crypto package to 0.44.x, GH-820, GH-823
|
||||
- `NEW` Add PostgreSQL 18 support to Github Actions, GH-816
|
||||
- `NEW` Connect backend refactor, GH-801
|
||||
- `NEW` Add server settings view, GH-768
|
||||
- `NEW` Add exec time of empty queries, GH-763
|
||||
- `FIX` Minor typos, GH-764, GH-786
|
||||
- `FIX` Shorten git revision printed in the --version output, GH-770
|
||||
|
||||
# 0.13.1 - 2022-12-27
|
||||
## 0.16.2 - 2024-11-02
|
||||
|
||||
- `FIX` Build a new Docker image with PostgreSQL 17 support
|
||||
- `FIX` Run CI against PostgreSQL 17, GH-758
|
||||
- `FIX` Rename master to main branch, GH-750
|
||||
|
||||
## 0.16.1 - 2024-09-07
|
||||
|
||||
- `FIX` Remove linux/arm/v5 from docker release action, GH-742
|
||||
|
||||
## 0.16.0 - 2024-06-04
|
||||
|
||||
- `NEW` Allow database stats downloads, GH-738
|
||||
- `NEW` Add analyze table action, GH-737
|
||||
- `NEW` Bump postgres version used in docker compose to 15, GH-729
|
||||
- `NEW` Build on Go 1.22, GH-726
|
||||
- `FIX` SSH tunnel cleanup and parse fixup, GH-731
|
||||
- `FIX` Drop linux/arm/v5 from docker build, GH-728
|
||||
- `FIX` Propagate CGO_ENABLED environment variable to docker build, GH-724
|
||||
|
||||
## 0.15.0 - 2024-03-14
|
||||
|
||||
- `NEW` Add support for a bookmarks-only mode, GH-716
|
||||
- `FIX` Fix missing indexes by quoting schema/table name to ::regclass, GH-711
|
||||
- `FIX` Continue on parseJSON error, GH-708
|
||||
|
||||
## 0.14.3 - 2024-01-28
|
||||
|
||||
- `NEW` Allow retrying a connection on startup, GH-695
|
||||
- `NEW` Allow setting readonly mode in bookmarks, GH-707
|
||||
- `FIX` Add UPDATE to list of restricted keywords in read-only mode, GH-697
|
||||
|
||||
## 0.14.2 - 2023-10-29
|
||||
|
||||
- `NEW` Execute tests using PostgreSQL 16, GH-691
|
||||
- `FIX` Unclosed database sessions and tunnels, GH-688
|
||||
- `FIX` Use pg_table_size for table stats query, GH-685
|
||||
- `FIX` Use `HasSuffix` to correctly determine URL prefix, GH-684
|
||||
|
||||
## 0.14.1 - 2023-06-17
|
||||
|
||||
- `NEW` Add process start time metric, GH-675
|
||||
- `NEW` Configure pgweb user for docker container, GH-674
|
||||
- `NEW` Updated dockerfile, GH-645
|
||||
- `FIX` Fix typo in the healthy metric, GH-657
|
||||
- `NEW` Use entrypoint instead of cmd in in dockerfile, GH-654
|
||||
|
||||
## 0.14.0 - 2023-02-21
|
||||
|
||||
- `FIX` History page query loading fixup, GH-632
|
||||
- `NEW` Display cell content via context menu, GH-634
|
||||
- `NEW` Handle support/permissions errors in info call, GH-635
|
||||
- `NEW` Show error message when API calls fail, GH-636
|
||||
- `NEW` Add bookmark options to load username/password from env vars, GH-638
|
||||
- `NEW` Add context menu to display database tables stats, GH-639
|
||||
- `NEW` Added Local Queries feature, GH-641
|
||||
- `FIX` Ensure that objects are sorted by schema and name, GH-648
|
||||
- `FIX` Fetch local queries on db connect, GH-650
|
||||
|
||||
## 0.13.1 - 2022-12-27
|
||||
|
||||
- Fix connect flow when `~/.pgweb/bookmarks` directory is not available, GH-631
|
||||
|
||||
# 0.13.0 - 2022-12-25
|
||||
## 0.13.0 - 2022-12-25
|
||||
|
||||
- Add support for .pgpass file, GH-617
|
||||
- Request logging additions (request id, forwarded user), GH-618
|
||||
@@ -34,7 +88,7 @@
|
||||
- Add duration_ms to log entries, GH-628
|
||||
- Add query execution stats to api endpoint, GH-629
|
||||
|
||||
# 0.12.0 - 2022-12-13
|
||||
## 0.12.0 - 2022-12-13
|
||||
|
||||
- Deprecate usage of Gox for binary builds, GH-571
|
||||
- Add netcat install in dockerfile to provide a way to healthcheck, GH-572
|
||||
@@ -61,12 +115,12 @@
|
||||
- Switch windows tests from Appveyor to Github Actions, GH-611
|
||||
- Fix activity endpoint panic when server version is not detected, GH-612
|
||||
|
||||
# 0.11.12 - 2022-07-05
|
||||
## 0.11.12 - 2022-07-05
|
||||
|
||||
- Update base docker image (alpine), update deps, GH-558
|
||||
- Refactor docker images building, include ARM, GH-568
|
||||
|
||||
# 0.11.11 - 2022-03-29
|
||||
## 0.11.11 - 2022-03-29
|
||||
|
||||
- Auto-detect the query from the query source based on user selection, GH-547
|
||||
- Added binary codec base58 as well as improving the help for --binary-codec flag, GH-548
|
||||
@@ -331,7 +385,7 @@
|
||||
## 0.6.0 - 2015-05-31
|
||||
|
||||
- Adds ability to execute only selected SQL query in run command view, [GH-85]
|
||||
- Adds ability to delete/truncate table via context meny on sidebar view
|
||||
- Adds ability to delete/truncate table via context many on sidebar view
|
||||
- Adds ability to export table contents to CSV via context menu on sidebar view
|
||||
- Changes sidebar color scheme to a lighter and better looking one
|
||||
|
||||
@@ -345,7 +399,7 @@
|
||||
|
||||
## 0.5.2 - 2015-04-13
|
||||
|
||||
- Adds a new endpoint /activity that retuns active queries
|
||||
- Adds a new endpoint /activity that returns active queries
|
||||
- Adds tab to view active queries
|
||||
- Adds column sorting when browsing table contents
|
||||
- Fixes SQL query view when switching to table structure view
|
||||
|
||||
+1
-1
@@ -2,6 +2,6 @@
|
||||
- Create a new git branch
|
||||
- Make changes
|
||||
- Run tests: `make test`
|
||||
- Run tests agains all supported PostreSQL versions: `make test-all` (optional)
|
||||
- Run tests against all supported PostreSQL versions: `make test-all` (optional)
|
||||
- If you change frontend code (js/css) make sure to rebuild assets: `make assets`
|
||||
- Open a new pull request
|
||||
+8
-4
@@ -1,7 +1,11 @@
|
||||
# ------------------------------------------------------------------------------
|
||||
# Builder Stage
|
||||
# ------------------------------------------------------------------------------
|
||||
FROM golang:1.20-bullseye AS build
|
||||
FROM golang:1.25-trixie AS build
|
||||
|
||||
# Set default build argument for CGO_ENABLED
|
||||
ARG CGO_ENABLED=0
|
||||
ENV CGO_ENABLED=${CGO_ENABLED}
|
||||
|
||||
WORKDIR /build
|
||||
|
||||
@@ -17,7 +21,7 @@ RUN make build
|
||||
# ------------------------------------------------------------------------------
|
||||
# Fetch signing key
|
||||
# ------------------------------------------------------------------------------
|
||||
FROM debian:bullseye-slim AS keyring
|
||||
FROM debian:trixie-slim AS keyring
|
||||
ADD https://www.postgresql.org/media/keys/ACCC4CF8.asc keyring.asc
|
||||
RUN apt-get update && \
|
||||
apt-get install -qq --no-install-recommends gpg
|
||||
@@ -26,14 +30,14 @@ RUN gpg -o keyring.pgp --dearmor keyring.asc
|
||||
# ------------------------------------------------------------------------------
|
||||
# Release Stage
|
||||
# ------------------------------------------------------------------------------
|
||||
FROM debian:bullseye-slim
|
||||
FROM debian:trixie-slim
|
||||
|
||||
ARG keyring=/usr/share/keyrings/postgresql-archive-keyring.pgp
|
||||
COPY --from=keyring /keyring.pgp $keyring
|
||||
RUN . /etc/os-release && \
|
||||
echo "deb [signed-by=${keyring}] http://apt.postgresql.org/pub/repos/apt/ ${VERSION_CODENAME}-pgdg main" > /etc/apt/sources.list.d/pgdg.list && \
|
||||
apt-get update && \
|
||||
apt-get install -qq --no-install-recommends ca-certificates openssl netcat curl postgresql-client
|
||||
apt-get install -qq --no-install-recommends ca-certificates openssl netcat-openbsd curl postgresql-client
|
||||
|
||||
COPY --from=build /build/pgweb /usr/bin/pgweb
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
The MIT License (MIT)
|
||||
|
||||
Copyright (c) 2014-2023 Dan Sosedoff <dan.sosedoff@gmail.com>
|
||||
Copyright (c) 2014-2024 Dan Sosedoff <dan.sosedoff@gmail.com>
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy of
|
||||
this software and associated documentation files (the "Software"), to deal in
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
PKG = github.com/sosedoff/pgweb
|
||||
GIT_COMMIT ?= $(shell git rev-parse HEAD)
|
||||
GIT_COMMIT ?= $(shell git rev-parse --short=8 HEAD)
|
||||
BUILD_TIME ?= $(shell date -u +"%Y-%m-%dT%H:%M:%SZ" | tr -d '\n')
|
||||
GO_VERSION ?= $(shell go version | awk {'print $$3'})
|
||||
|
||||
|
||||
@@ -3,7 +3,7 @@
|
||||
Simple web-based and cross platform PostgreSQL database explorer.
|
||||
|
||||
[](https://github.com/sosedoff/pgweb/releases)
|
||||
[](https://github.com/sosedoff/pgweb/actions?query=branch%3Amaster)
|
||||
[](https://github.com/sosedoff/pgweb/actions?query=branch%3Amain)
|
||||
[](https://goreportcard.com/report/github.com/sosedoff/pgweb)
|
||||
[](https://godoc.org/github.com/sosedoff/pgweb)
|
||||
[](https://hub.docker.com/r/sosedoff/pgweb/)
|
||||
|
||||
@@ -1,27 +0,0 @@
|
||||
{
|
||||
"name": "pgweb",
|
||||
"description": "A web-based frontend to your Postgres database.",
|
||||
"website": "https://github.com/sosedoff/pgweb",
|
||||
"repository": "https://github.com/sosedoff/pgweb",
|
||||
"logo": "https://raw.githubusercontent.com/sosedoff/pgweb/master/static/img/icon.png",
|
||||
"success_url": "/",
|
||||
"keywords": [
|
||||
"postgres",
|
||||
"database",
|
||||
"golang",
|
||||
"frontend"
|
||||
],
|
||||
"addons": [
|
||||
"heroku-postgresql"
|
||||
],
|
||||
"env": {
|
||||
"AUTH_USER": {
|
||||
"description": "A username to log into pgweb.",
|
||||
"value": "admin"
|
||||
},
|
||||
"AUTH_PASS": {
|
||||
"description": "The login password. Please change this.",
|
||||
"generator": "secret"
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -3,3 +3,4 @@ source "https://rubygems.org"
|
||||
gem "sinatra"
|
||||
gem "json"
|
||||
gem "puma"
|
||||
gem "rackup"
|
||||
|
||||
@@ -1,30 +1,43 @@
|
||||
GEM
|
||||
remote: https://rubygems.org/
|
||||
specs:
|
||||
json (2.6.2)
|
||||
mustermann (3.0.0)
|
||||
base64 (0.3.0)
|
||||
json (2.12.2)
|
||||
logger (1.7.0)
|
||||
mustermann (3.0.3)
|
||||
ruby2_keywords (~> 0.0.1)
|
||||
nio4r (2.5.8)
|
||||
puma (6.0.0)
|
||||
nio4r (2.7.4)
|
||||
puma (6.6.0)
|
||||
nio4r (~> 2.0)
|
||||
rack (2.2.6.2)
|
||||
rack-protection (3.0.4)
|
||||
rack
|
||||
rack (3.1.16)
|
||||
rack-protection (4.1.1)
|
||||
base64 (>= 0.1.0)
|
||||
logger (>= 1.6.0)
|
||||
rack (>= 3.0.0, < 4)
|
||||
rack-session (2.1.1)
|
||||
base64 (>= 0.1.0)
|
||||
rack (>= 3.0.0)
|
||||
rackup (2.2.1)
|
||||
rack (>= 3)
|
||||
ruby2_keywords (0.0.5)
|
||||
sinatra (3.0.4)
|
||||
sinatra (4.1.1)
|
||||
logger (>= 1.6.0)
|
||||
mustermann (~> 3.0)
|
||||
rack (~> 2.2, >= 2.2.4)
|
||||
rack-protection (= 3.0.4)
|
||||
rack (>= 3.0.0, < 4)
|
||||
rack-protection (= 4.1.1)
|
||||
rack-session (>= 2.0.0, < 3)
|
||||
tilt (~> 2.0)
|
||||
tilt (2.0.11)
|
||||
tilt (2.6.0)
|
||||
|
||||
PLATFORMS
|
||||
arm64-darwin-21
|
||||
arm64-darwin-24
|
||||
x86_64-linux
|
||||
|
||||
DEPENDENCIES
|
||||
json
|
||||
puma
|
||||
rackup
|
||||
sinatra
|
||||
|
||||
BUNDLED WITH
|
||||
|
||||
@@ -1,9 +1,10 @@
|
||||
require "bundler/setup"
|
||||
require "sinatra"
|
||||
|
||||
# Authentication token
|
||||
$token = "test"
|
||||
|
||||
# List of all availble resources
|
||||
# List of all available resources
|
||||
$resources = {
|
||||
"id1" => "postgres://localhost:5432/db1?sslmode=disable",
|
||||
"id2" => "postgres://localhost:5432/db2?sslmode=disable",
|
||||
|
||||
@@ -0,0 +1,12 @@
|
||||
host = "localhost"
|
||||
port = 5432
|
||||
user = "postgres"
|
||||
database = "mydatabase"
|
||||
ssl = "disable"
|
||||
|
||||
[SSH]
|
||||
host = "ssh-host"
|
||||
user = "ssh-user"
|
||||
password = "ssh-password"
|
||||
key = "/path/to/key-file"
|
||||
keypassword = "key-file-password"
|
||||
+10
-2
@@ -1,6 +1,4 @@
|
||||
---
|
||||
version: "3.9"
|
||||
|
||||
x-base: &base
|
||||
environment: &env
|
||||
POSTGRES_DB: pgweb
|
||||
@@ -11,6 +9,16 @@ x-base: &base
|
||||
interval: 5s
|
||||
|
||||
services:
|
||||
postgres18:
|
||||
<<: *base
|
||||
image: postgres:18
|
||||
ports:
|
||||
- 5433:5432
|
||||
postgres17:
|
||||
<<: *base
|
||||
image: postgres:17
|
||||
ports:
|
||||
- 5433:5432
|
||||
postgres16:
|
||||
<<: *base
|
||||
image: postgres:16
|
||||
|
||||
+1
-3
@@ -1,10 +1,8 @@
|
||||
---
|
||||
version: "3.9"
|
||||
|
||||
services:
|
||||
postgres:
|
||||
container_name: pgweb-postgres
|
||||
image: postgres:14
|
||||
image: postgres:15
|
||||
ports:
|
||||
- 5433:5432
|
||||
volumes:
|
||||
|
||||
@@ -1,59 +1,64 @@
|
||||
module github.com/sosedoff/pgweb
|
||||
|
||||
go 1.20
|
||||
go 1.25
|
||||
|
||||
// +heroku goVersion go1.20
|
||||
toolchain go1.25.4
|
||||
|
||||
require (
|
||||
github.com/BurntSushi/toml v1.1.0
|
||||
github.com/ScaleFT/sshkeys v0.0.0-20200327173127-6142f742bca5
|
||||
github.com/gin-gonic/gin v1.9.1
|
||||
github.com/gin-gonic/gin v1.11.0
|
||||
github.com/jackc/pgpassfile v1.0.0
|
||||
github.com/jessevdk/go-flags v1.5.0
|
||||
github.com/jmoiron/sqlx v1.3.5
|
||||
github.com/lib/pq v1.10.5
|
||||
github.com/mitchellh/go-homedir v1.1.0
|
||||
github.com/mr-tron/base58 v1.2.0
|
||||
github.com/prometheus/client_golang v1.14.0
|
||||
github.com/sirupsen/logrus v1.9.0
|
||||
github.com/stretchr/testify v1.8.3
|
||||
github.com/prometheus/client_golang v1.19.1
|
||||
github.com/sirupsen/logrus v1.9.1
|
||||
github.com/stretchr/testify v1.11.1
|
||||
github.com/tuvistavie/securerandom v0.0.0-20140719024926-15512123a948
|
||||
golang.org/x/crypto v0.9.0
|
||||
go.balki.me/anyhttp v0.5.0
|
||||
golang.org/x/crypto v0.46.0
|
||||
)
|
||||
|
||||
require (
|
||||
github.com/beorn7/perks v1.0.1 // indirect
|
||||
github.com/bytedance/sonic v1.9.1 // indirect
|
||||
github.com/bytedance/gopkg v0.1.3 // indirect
|
||||
github.com/bytedance/sonic v1.14.2 // indirect
|
||||
github.com/bytedance/sonic/loader v0.4.0 // indirect
|
||||
github.com/cespare/xxhash/v2 v2.2.0 // indirect
|
||||
github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311 // indirect
|
||||
github.com/cloudwego/base64x v0.1.6 // indirect
|
||||
github.com/davecgh/go-spew v1.1.1 // indirect
|
||||
github.com/dchest/bcrypt_pbkdf v0.0.0-20150205184540-83f37f9c154a // indirect
|
||||
github.com/gabriel-vasile/mimetype v1.4.2 // indirect
|
||||
github.com/gin-contrib/sse v0.1.0 // indirect
|
||||
github.com/gabriel-vasile/mimetype v1.4.12 // indirect
|
||||
github.com/gin-contrib/sse v1.1.0 // indirect
|
||||
github.com/go-playground/locales v0.14.1 // indirect
|
||||
github.com/go-playground/universal-translator v0.18.1 // indirect
|
||||
github.com/go-playground/validator/v10 v10.14.0 // indirect
|
||||
github.com/goccy/go-json v0.10.2 // indirect
|
||||
github.com/golang/protobuf v1.5.2 // indirect
|
||||
github.com/go-playground/validator/v10 v10.30.1 // indirect
|
||||
github.com/goccy/go-json v0.10.5 // indirect
|
||||
github.com/goccy/go-yaml v1.19.1 // indirect
|
||||
github.com/json-iterator/go v1.1.12 // indirect
|
||||
github.com/klauspost/cpuid/v2 v2.2.4 // indirect
|
||||
github.com/kr/pretty v0.3.1 // indirect
|
||||
github.com/leodido/go-urn v1.2.4 // indirect
|
||||
github.com/mattn/go-isatty v0.0.19 // indirect
|
||||
github.com/matttproud/golang_protobuf_extensions v1.0.4 // indirect
|
||||
github.com/klauspost/cpuid/v2 v2.3.0 // indirect
|
||||
github.com/kr/text v0.2.0 // indirect
|
||||
github.com/leodido/go-urn v1.4.0 // indirect
|
||||
github.com/mattn/go-isatty v0.0.20 // indirect
|
||||
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
|
||||
github.com/modern-go/reflect2 v1.0.2 // indirect
|
||||
github.com/pelletier/go-toml/v2 v2.0.8 // indirect
|
||||
github.com/pelletier/go-toml/v2 v2.2.4 // indirect
|
||||
github.com/pmezard/go-difflib v1.0.0 // indirect
|
||||
github.com/prometheus/client_model v0.3.0 // indirect
|
||||
github.com/prometheus/common v0.39.0 // indirect
|
||||
github.com/prometheus/procfs v0.8.0 // indirect
|
||||
github.com/prometheus/client_model v0.5.0 // indirect
|
||||
github.com/prometheus/common v0.48.0 // indirect
|
||||
github.com/prometheus/procfs v0.12.0 // indirect
|
||||
github.com/quic-go/qpack v0.6.0 // indirect
|
||||
github.com/quic-go/quic-go v0.58.0 // indirect
|
||||
github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
|
||||
github.com/ugorji/go/codec v1.2.11 // indirect
|
||||
golang.org/x/arch v0.3.0 // indirect
|
||||
golang.org/x/net v0.10.0 // indirect
|
||||
golang.org/x/sys v0.8.0 // indirect
|
||||
golang.org/x/text v0.9.0 // indirect
|
||||
google.golang.org/protobuf v1.30.0 // indirect
|
||||
github.com/ugorji/go/codec v1.3.1 // indirect
|
||||
go.uber.org/mock v0.6.0 // indirect
|
||||
golang.org/x/arch v0.23.0 // indirect
|
||||
golang.org/x/net v0.48.0 // indirect
|
||||
golang.org/x/sys v0.39.0 // indirect
|
||||
golang.org/x/text v0.32.0 // indirect
|
||||
google.golang.org/protobuf v1.36.11 // indirect
|
||||
gopkg.in/yaml.v3 v3.0.1 // indirect
|
||||
)
|
||||
|
||||
@@ -4,44 +4,44 @@ github.com/ScaleFT/sshkeys v0.0.0-20200327173127-6142f742bca5 h1:VauE2GcJNZFun2O
|
||||
github.com/ScaleFT/sshkeys v0.0.0-20200327173127-6142f742bca5/go.mod h1:gxOHeajFfvGQh/fxlC8oOKBe23xnnJTif00IFFbiT+o=
|
||||
github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=
|
||||
github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=
|
||||
github.com/bytedance/sonic v1.5.0/go.mod h1:ED5hyg4y6t3/9Ku1R6dU/4KyJ48DZ4jPhfY1O2AihPM=
|
||||
github.com/bytedance/sonic v1.9.1 h1:6iJ6NqdoxCDr6mbY8h18oSO+cShGSMRGCEo7F2h0x8s=
|
||||
github.com/bytedance/sonic v1.9.1/go.mod h1:i736AoUSYt75HyZLoJW9ERYxcy6eaN6h4BZXU064P/U=
|
||||
github.com/bytedance/gopkg v0.1.3 h1:TPBSwH8RsouGCBcMBktLt1AymVo2TVsBVCY4b6TnZ/M=
|
||||
github.com/bytedance/gopkg v0.1.3/go.mod h1:576VvJ+eJgyCzdjS+c4+77QF3p7ubbtiKARP3TxducM=
|
||||
github.com/bytedance/sonic v1.14.2 h1:k1twIoe97C1DtYUo+fZQy865IuHia4PR5RPiuGPPIIE=
|
||||
github.com/bytedance/sonic v1.14.2/go.mod h1:T80iDELeHiHKSc0C9tubFygiuXoGzrkjKzX2quAx980=
|
||||
github.com/bytedance/sonic/loader v0.4.0 h1:olZ7lEqcxtZygCK9EKYKADnpQoYkRQxaeY2NYzevs+o=
|
||||
github.com/bytedance/sonic/loader v0.4.0/go.mod h1:AR4NYCk5DdzZizZ5djGqQ92eEhCCcdf5x77udYiSJRo=
|
||||
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
||||
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
||||
github.com/chenzhuoyu/base64x v0.0.0-20211019084208-fb5309c8db06/go.mod h1:DH46F32mSOjUmXrMHnKwZdA8wcEefY7UVqBKYGjpdQY=
|
||||
github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311 h1:qSGYFH7+jGhDF8vLC+iwCD4WpbV1EBDSzWkJODFLams=
|
||||
github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311/go.mod h1:b583jCggY9gE99b6G5LEC39OIiVsWj+R97kbl5odCEk=
|
||||
github.com/cloudwego/base64x v0.1.6 h1:t11wG9AECkCDk5fMSoxmufanudBtJ+/HemLstXDLI2M=
|
||||
github.com/cloudwego/base64x v0.1.6/go.mod h1:OFcloc187FXDaYHvrNIjxSe8ncn0OOM8gEHfghB2IPU=
|
||||
github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
|
||||
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/dchest/bcrypt_pbkdf v0.0.0-20150205184540-83f37f9c154a h1:saTgr5tMLFnmy/yg3qDTft4rE5DY2uJ/cCxCe3q0XTU=
|
||||
github.com/dchest/bcrypt_pbkdf v0.0.0-20150205184540-83f37f9c154a/go.mod h1:Bw9BbhOJVNR+t0jCqx2GC6zv0TGBsShs56Y3gfSCvl0=
|
||||
github.com/gabriel-vasile/mimetype v1.4.2 h1:w5qFW6JKBz9Y393Y4q372O9A7cUSequkh1Q7OhCmWKU=
|
||||
github.com/gabriel-vasile/mimetype v1.4.2/go.mod h1:zApsH/mKG4w07erKIaJPFiX0Tsq9BFQgN3qGY5GnNgA=
|
||||
github.com/gin-contrib/sse v0.1.0 h1:Y/yl/+YNO8GZSjAhjMsSuLt29uWRFHdHYUb5lYOV9qE=
|
||||
github.com/gin-contrib/sse v0.1.0/go.mod h1:RHrZQHXnP2xjPF+u1gW/2HnVO7nvIa9PG3Gm+fLHvGI=
|
||||
github.com/gin-gonic/gin v1.9.1 h1:4idEAncQnU5cB7BeOkPtxjfCSye0AAm1R0RVIqJ+Jmg=
|
||||
github.com/gin-gonic/gin v1.9.1/go.mod h1:hPrL7YrpYKXt5YId3A/Tnip5kqbEAP+KLuI3SUcPTeU=
|
||||
github.com/gabriel-vasile/mimetype v1.4.12 h1:e9hWvmLYvtp846tLHam2o++qitpguFiYCKbn0w9jyqw=
|
||||
github.com/gabriel-vasile/mimetype v1.4.12/go.mod h1:d+9Oxyo1wTzWdyVUPMmXFvp4F9tea18J8ufA774AB3s=
|
||||
github.com/gin-contrib/sse v1.1.0 h1:n0w2GMuUpWDVp7qSpvze6fAu9iRxJY4Hmj6AmBOU05w=
|
||||
github.com/gin-contrib/sse v1.1.0/go.mod h1:hxRZ5gVpWMT7Z0B0gSNYqqsSCNIJMjzvm6fqCz9vjwM=
|
||||
github.com/gin-gonic/gin v1.11.0 h1:OW/6PLjyusp2PPXtyxKHU0RbX6I/l28FTdDlae5ueWk=
|
||||
github.com/gin-gonic/gin v1.11.0/go.mod h1:+iq/FyxlGzII0KHiBGjuNn4UNENUlKbGlNmc+W50Dls=
|
||||
github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
|
||||
github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
|
||||
github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
|
||||
github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY=
|
||||
github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY=
|
||||
github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY=
|
||||
github.com/go-playground/validator/v10 v10.14.0 h1:vgvQWe3XCz3gIeFDm/HnTIbj6UGmg/+t63MyGU2n5js=
|
||||
github.com/go-playground/validator/v10 v10.14.0/go.mod h1:9iXMNT7sEkjXb0I+enO7QXmzG6QCsPWY4zveKFVRSyU=
|
||||
github.com/go-playground/validator/v10 v10.30.1 h1:f3zDSN/zOma+w6+1Wswgd9fLkdwy06ntQJp0BBvFG0w=
|
||||
github.com/go-playground/validator/v10 v10.30.1/go.mod h1:oSuBIQzuJxL//3MelwSLD5hc2Tu889bF0Idm9Dg26cM=
|
||||
github.com/go-sql-driver/mysql v1.6.0 h1:BCTh4TKNUYmOmMUcQ3IipzF5prigylS7XXjEkfCHuOE=
|
||||
github.com/go-sql-driver/mysql v1.6.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg=
|
||||
github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU=
|
||||
github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=
|
||||
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
|
||||
github.com/golang/protobuf v1.3.5/go.mod h1:6O5/vntMXwX2lRkT1hjjk0nAC1IDOTvTlVgjlRvqsdk=
|
||||
github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
|
||||
github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw=
|
||||
github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
|
||||
github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
|
||||
github.com/google/go-cmp v0.5.8 h1:e6P7q2lk1O+qJJb4BtCQXlK8vWEO8V1ZeuEdJNOqZyg=
|
||||
github.com/goccy/go-json v0.10.5 h1:Fq85nIqj+gXn/S5ahsiTlK3TmC85qgirsdTP/+DeaC4=
|
||||
github.com/goccy/go-json v0.10.5/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M=
|
||||
github.com/goccy/go-yaml v1.19.1 h1:3rG3+v8pkhRqoQ/88NYNMHYVGYztCOCIZ7UQhu7H+NE=
|
||||
github.com/goccy/go-yaml v1.19.1/go.mod h1:XBurs7gK8ATbW4ZPGKgcbrY1Br56PdM69F7LkFRi1kA=
|
||||
github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
|
||||
github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
|
||||
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
|
||||
github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
|
||||
github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
|
||||
@@ -51,24 +51,21 @@ github.com/jmoiron/sqlx v1.3.5 h1:vFFPA71p1o5gAeqtEAwLU4dnX2napprKtHr7PYIcN3g=
|
||||
github.com/jmoiron/sqlx v1.3.5/go.mod h1:nRVWtLre0KfCLJvgxzCsLVMogSvQ1zNJtpYr2Ccp0mQ=
|
||||
github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
|
||||
github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
|
||||
github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
|
||||
github.com/klauspost/cpuid/v2 v2.2.4 h1:acbojRNwl3o09bUq+yDCtZFc1aiwaAAxtcn8YkZXnvk=
|
||||
github.com/klauspost/cpuid/v2 v2.2.4/go.mod h1:RVVoqg1df56z8g3pUjL/3lE5UfnlrJX8tyFgg4nqhuY=
|
||||
github.com/klauspost/cpuid/v2 v2.3.0 h1:S4CRMLnYUhGeDFDqkGriYKdfoFlDnMtqTiI/sFzhA9Y=
|
||||
github.com/klauspost/cpuid/v2 v2.3.0/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
|
||||
github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
|
||||
github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
|
||||
github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
|
||||
github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
|
||||
github.com/leodido/go-urn v1.2.4 h1:XlAE/cm/ms7TE/VMVoduSpNBoyc2dOxHs5MZSwAN63Q=
|
||||
github.com/leodido/go-urn v1.2.4/go.mod h1:7ZrI8mTSeBSHl/UaRyKQW1qZeMgak41ANeCNaVckg+4=
|
||||
github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
|
||||
github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
|
||||
github.com/lib/pq v1.2.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo=
|
||||
github.com/lib/pq v1.10.5 h1:J+gdV2cUmX7ZqL2B0lFcW0m+egaHC2V3lpO8nWxyYiQ=
|
||||
github.com/lib/pq v1.10.5/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
|
||||
github.com/mattn/go-isatty v0.0.19 h1:JITubQf0MOLdlGRuRq+jtsDlekdYPia9ZFsB8h/APPA=
|
||||
github.com/mattn/go-isatty v0.0.19/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
|
||||
github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
|
||||
github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
|
||||
github.com/mattn/go-sqlite3 v1.14.6 h1:dNPt6NO46WmLVt2DLNpwczCmdV5boIZ6g/tlDrlRUbg=
|
||||
github.com/mattn/go-sqlite3 v1.14.6/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=
|
||||
github.com/matttproud/golang_protobuf_extensions v1.0.4 h1:mmDVorXM7PCGKw94cs5zkfA9PSy5pEvNWRP0ET0TIVo=
|
||||
github.com/matttproud/golang_protobuf_extensions v1.0.4/go.mod h1:BSXmuO+STAnVfrANrmjBb36TMTDstsz7MSK+HVaYKv4=
|
||||
github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG+4E0Y=
|
||||
github.com/mitchellh/go-homedir v1.1.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0=
|
||||
github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
|
||||
@@ -78,74 +75,77 @@ github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9G
|
||||
github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
|
||||
github.com/mr-tron/base58 v1.2.0 h1:T/HDJBh4ZCPbU39/+c3rRvE0uKBQlU27+QI8LJ4t64o=
|
||||
github.com/mr-tron/base58 v1.2.0/go.mod h1:BinMc/sQntlIE1frQmRFPUoPA1Zkr8VRgBdjWI2mNwc=
|
||||
github.com/pelletier/go-toml/v2 v2.0.8 h1:0ctb6s9mE31h0/lhu+J6OPmVeDxJn+kYnJc2jZR9tGQ=
|
||||
github.com/pelletier/go-toml/v2 v2.0.8/go.mod h1:vuYfssBdrU2XDZ9bYydBu6t+6a6PYNcZljzZR9VXg+4=
|
||||
github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA=
|
||||
github.com/pelletier/go-toml/v2 v2.2.4 h1:mye9XuhQ6gvn5h28+VilKrrPoQVanw5PMw/TB0t5Ec4=
|
||||
github.com/pelletier/go-toml/v2 v2.2.4/go.mod h1:2gIqNv+qfxSVS7cM2xJQKtLSTLUE9V8t9Stt+h56mCY=
|
||||
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
|
||||
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
|
||||
github.com/prometheus/client_golang v1.14.0 h1:nJdhIvne2eSX/XRAFV9PcvFFRbrjbcTUj0VP62TMhnw=
|
||||
github.com/prometheus/client_golang v1.14.0/go.mod h1:8vpkKitgIVNcqrRBWh1C4TIUQgYNtG/XQE4E/Zae36Y=
|
||||
github.com/prometheus/client_model v0.3.0 h1:UBgGFHqYdG/TPFD1B1ogZywDqEkwp3fBMvqdiQ7Xew4=
|
||||
github.com/prometheus/client_model v0.3.0/go.mod h1:LDGWKZIo7rky3hgvBe+caln+Dr3dPggB5dvjtD7w9+w=
|
||||
github.com/prometheus/common v0.39.0 h1:oOyhkDq05hPZKItWVBkJ6g6AtGxi+fy7F4JvUV8uhsI=
|
||||
github.com/prometheus/common v0.39.0/go.mod h1:6XBZ7lYdLCbkAVhwRsWTZn+IN5AB9F/NXd5w0BbEX0Y=
|
||||
github.com/prometheus/procfs v0.8.0 h1:ODq8ZFEaYeCaZOJlZZdJA2AbQR98dSHSM1KW/You5mo=
|
||||
github.com/prometheus/procfs v0.8.0/go.mod h1:z7EfXMXOkbkqb9IINtpCn86r/to3BnA0uaxHdg830/4=
|
||||
github.com/rogpeppe/go-internal v1.9.0 h1:73kH8U+JUqXU8lRuOHeVHaa/SZPifC7BkcraZVejAe8=
|
||||
github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
|
||||
github.com/sirupsen/logrus v1.9.0 h1:trlNQbNUG3OdDrDil03MCb1H2o9nJ1x4/5LYw7byDE0=
|
||||
github.com/sirupsen/logrus v1.9.0/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
|
||||
github.com/prometheus/client_golang v1.19.1 h1:wZWJDwK+NameRJuPGDhlnFgx8e8HN3XHQeLaYJFJBOE=
|
||||
github.com/prometheus/client_golang v1.19.1/go.mod h1:mP78NwGzrVks5S2H6ab8+ZZGJLZUq1hoULYBAYBw1Ho=
|
||||
github.com/prometheus/client_model v0.5.0 h1:VQw1hfvPvk3Uv6Qf29VrPF32JB6rtbgI6cYPYQjL0Qw=
|
||||
github.com/prometheus/client_model v0.5.0/go.mod h1:dTiFglRmd66nLR9Pv9f0mZi7B7fk5Pm3gvsjB5tr+kI=
|
||||
github.com/prometheus/common v0.48.0 h1:QO8U2CdOzSn1BBsmXJXduaaW+dY/5QLjfB8svtSzKKE=
|
||||
github.com/prometheus/common v0.48.0/go.mod h1:0/KsvlIEfPQCQ5I2iNSAWKPZziNCvRs5EC6ILDTlAPc=
|
||||
github.com/prometheus/procfs v0.12.0 h1:jluTpSng7V9hY0O2R9DzzJHYb2xULk9VTR1V1R/k6Bo=
|
||||
github.com/prometheus/procfs v0.12.0/go.mod h1:pcuDEFsWDnvcgNzo4EEweacyhjeA9Zk3cnaOZAZEfOo=
|
||||
github.com/quic-go/qpack v0.6.0 h1:g7W+BMYynC1LbYLSqRt8PBg5Tgwxn214ZZR34VIOjz8=
|
||||
github.com/quic-go/qpack v0.6.0/go.mod h1:lUpLKChi8njB4ty2bFLX2x4gzDqXwUpaO1DP9qMDZII=
|
||||
github.com/quic-go/quic-go v0.58.0 h1:ggY2pvZaVdB9EyojxL1p+5mptkuHyX5MOSv4dgWF4Ug=
|
||||
github.com/quic-go/quic-go v0.58.0/go.mod h1:upnsH4Ju1YkqpLXC305eW3yDZ4NfnNbmQRCMWS58IKU=
|
||||
github.com/rogpeppe/go-internal v1.10.0 h1:TMyTOH3F/DB16zRVcYyreMH6GnZZrwQVAoYjRBZyWFQ=
|
||||
github.com/rogpeppe/go-internal v1.10.0/go.mod h1:UQnix2H7Ngw/k4C5ijL5+65zddjncjaFoBhdsK/akog=
|
||||
github.com/sirupsen/logrus v1.9.1 h1:Ou41VVR3nMWWmTiEUnj0OlsgOSCUFgsPAOl6jRIcVtQ=
|
||||
github.com/sirupsen/logrus v1.9.1/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
|
||||
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
|
||||
github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
|
||||
github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
|
||||
github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA=
|
||||
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
|
||||
github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
|
||||
github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
|
||||
github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
|
||||
github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
|
||||
github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
|
||||
github.com/stretchr/testify v1.8.2/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
|
||||
github.com/stretchr/testify v1.8.3 h1:RP3t2pwF7cMEbC1dqtB6poj3niw/9gnV4Cjg5oW5gtY=
|
||||
github.com/stretchr/testify v1.8.3/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
|
||||
github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
|
||||
github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
|
||||
github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
|
||||
github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
|
||||
github.com/tuvistavie/securerandom v0.0.0-20140719024926-15512123a948 h1:yL0l/u242MzDP6D0B5vGC+wxm5WRY+alQZy+dJk3bFI=
|
||||
github.com/tuvistavie/securerandom v0.0.0-20140719024926-15512123a948/go.mod h1:a06d/M1pxWi51qiSrfGMHaEydtuXT06nha8N2aNQuXk=
|
||||
github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=
|
||||
github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
|
||||
github.com/ugorji/go/codec v1.2.11 h1:BMaWp1Bb6fHwEtbplGBGJ498wD+LKlNSl25MjdZY4dU=
|
||||
github.com/ugorji/go/codec v1.2.11/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg=
|
||||
golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8=
|
||||
golang.org/x/arch v0.3.0 h1:02VY4/ZcO/gBOH6PUaoiptASxtXU10jazRCP865E97k=
|
||||
golang.org/x/arch v0.3.0/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8=
|
||||
github.com/ugorji/go/codec v1.3.1 h1:waO7eEiFDwidsBN6agj1vJQ4AG7lh2yqXyOXqhgQuyY=
|
||||
github.com/ugorji/go/codec v1.3.1/go.mod h1:pRBVtBSKl77K30Bv8R2P+cLSGaTtex6fsA2Wjqmfxj4=
|
||||
go.balki.me/anyhttp v0.5.0 h1:uys0oRciBpZfwtxXAevScKy6amIQBXyDrcV0EtGF5zo=
|
||||
go.balki.me/anyhttp v0.5.0/go.mod h1:JhfekOIjgVODoVqUCficjpIgmB3wwlB7jhN0eN2EZ/s=
|
||||
go.uber.org/mock v0.6.0 h1:hyF9dfmbgIX5EfOdasqLsWD6xqpNZlXblLB/Dbnwv3Y=
|
||||
go.uber.org/mock v0.6.0/go.mod h1:KiVJ4BqZJaMj4svdfmHM0AUx4NJYO8ZNpPnZn1Z+BBU=
|
||||
golang.org/x/arch v0.23.0 h1:lKF64A2jF6Zd8L0knGltUnegD62JMFBiCPBmQpToHhg=
|
||||
golang.org/x/arch v0.23.0/go.mod h1:dNHoOeKiyja7GTvF9NJS1l3Z2yntpQNzgrjh1cU103A=
|
||||
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
|
||||
golang.org/x/crypto v0.0.0-20200323165209-0ec3e9974c59/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
|
||||
golang.org/x/crypto v0.9.0 h1:LF6fAI+IutBocDJ2OT0Q1g8plpYljMZ4+lty+dsqw3g=
|
||||
golang.org/x/crypto v0.9.0/go.mod h1:yrmDGqONDYtNj3tH8X9dzUun2m2lzPa9ngI6/RUPGR0=
|
||||
golang.org/x/crypto v0.46.0 h1:cKRW/pmt1pKAfetfu+RCEvjvZkA9RimPbh7bhFjGVBU=
|
||||
golang.org/x/crypto v0.46.0/go.mod h1:Evb/oLKmMraqjZ2iQTwDwvCtJkczlDuTmdJXoZVzqU0=
|
||||
golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
|
||||
golang.org/x/net v0.10.0 h1:X2//UzNDwYmtCLn7To6G58Wr6f5ahEAQgKNzv9Y951M=
|
||||
golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg=
|
||||
golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/net v0.48.0 h1:zyQRTTrjc33Lhh0fBgT/H3oZq9WuvRR5gPC70xpDiQU=
|
||||
golang.org/x/net v0.48.0/go.mod h1:+ndRgGjkh8FGtu1w1FGbEC31if4VrNVMuKTgcAAnQRY=
|
||||
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||
golang.org/x/sys v0.0.0-20200219091948-cb0a6d8edb6c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||
golang.org/x/sys v0.0.0-20210320140829-1e4c9ba3b0c4/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||
golang.org/x/sys v0.0.0-20220704084225-05e143d24a9e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||
golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||
golang.org/x/sys v0.8.0 h1:EBmGv8NaZBZTWvrbjNoL6HVt+IVy3QDQpJs7VRIw3tU=
|
||||
golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||
golang.org/x/term v0.8.0 h1:n5xxQn2i3PC0yLAbjTpNT85q/Kgzcr2gIoX9OrJUols=
|
||||
golang.org/x/sys v0.39.0 h1:CvCKL8MeisomCi6qNZ+wbb0DN9E5AATixKsvNtMoMFk=
|
||||
golang.org/x/sys v0.39.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
|
||||
golang.org/x/term v0.38.0 h1:PQ5pkm/rLO6HnxFR7N2lJHOZX6Kez5Y1gDSJla6jo7Q=
|
||||
golang.org/x/term v0.38.0/go.mod h1:bSEAKrOT1W+VSu9TSCMtoGEOUcKxOKgl3LE5QEF/xVg=
|
||||
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
|
||||
golang.org/x/text v0.9.0 h1:2sjJmO8cDvYveuX97RDLsxlyUxLl+GHoLxBiRdHllBE=
|
||||
golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
|
||||
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
|
||||
google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
|
||||
google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
|
||||
google.golang.org/protobuf v1.30.0 h1:kPPoIgf3TsEvrm0PFe15JQ+570QVxYzEvvHqChK+cng=
|
||||
google.golang.org/protobuf v1.30.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
|
||||
golang.org/x/text v0.32.0 h1:ZD01bjUt1FQ9WJ0ClOL5vxgxOI/sVCNgX1YtKwcY0mU=
|
||||
golang.org/x/text v0.32.0/go.mod h1:o/rUWzghvpD5TXrTIBuJU77MTaN0ljMWE47kxGJQ7jY=
|
||||
google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
|
||||
google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
|
||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
|
||||
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
|
||||
gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
|
||||
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
||||
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||
rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4=
|
||||
|
||||
+56
-11
@@ -15,6 +15,7 @@ import (
|
||||
"github.com/sosedoff/pgweb/pkg/bookmarks"
|
||||
"github.com/sosedoff/pgweb/pkg/client"
|
||||
"github.com/sosedoff/pgweb/pkg/command"
|
||||
"github.com/sosedoff/pgweb/pkg/connect"
|
||||
"github.com/sosedoff/pgweb/pkg/connection"
|
||||
"github.com/sosedoff/pgweb/pkg/metrics"
|
||||
"github.com/sosedoff/pgweb/pkg/queries"
|
||||
@@ -92,18 +93,18 @@ func GetSessions(c *gin.Context) {
|
||||
|
||||
// ConnectWithBackend creates a new connection based on backend resource
|
||||
func ConnectWithBackend(c *gin.Context) {
|
||||
// Setup a new backend client
|
||||
backend := Backend{
|
||||
Endpoint: command.Opts.ConnectBackend,
|
||||
Token: command.Opts.ConnectToken,
|
||||
PassHeaders: strings.Split(command.Opts.ConnectHeaders, ","),
|
||||
backend := connect.NewBackend(command.Opts.ConnectBackend, command.Opts.ConnectToken)
|
||||
backend.SetLogger(logger)
|
||||
|
||||
if command.Opts.ConnectHeaders != "" {
|
||||
backend.SetPassHeaders(strings.Split(command.Opts.ConnectHeaders, ","))
|
||||
}
|
||||
|
||||
ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
|
||||
defer cancel()
|
||||
|
||||
// Fetch connection credentials
|
||||
cred, err := backend.FetchCredential(ctx, c.Param("resource"), c)
|
||||
cred, err := backend.FetchCredential(ctx, c.Param("resource"), c.Request.Header)
|
||||
if err != nil {
|
||||
badRequest(c, err)
|
||||
return
|
||||
@@ -154,6 +155,8 @@ func Connect(c *gin.Context) {
|
||||
|
||||
if bookmarkID := c.Request.FormValue("bookmark_id"); bookmarkID != "" {
|
||||
cl, err = ConnectWithBookmark(bookmarkID)
|
||||
} else if command.Opts.BookmarksOnly {
|
||||
err = errNotPermitted
|
||||
} else {
|
||||
cl, err = ConnectWithURL(c)
|
||||
}
|
||||
@@ -484,6 +487,12 @@ func GetConnectionInfo(c *gin.Context) {
|
||||
successResponse(c, info)
|
||||
}
|
||||
|
||||
// GetServerSettings renders a list of all server settings
|
||||
func GetServerSettings(c *gin.Context) {
|
||||
res, err := DB(c).ServerSettings()
|
||||
serveResult(c, res, err)
|
||||
}
|
||||
|
||||
// GetActivity renders a list of running queries
|
||||
func GetActivity(c *gin.Context) {
|
||||
res, err := DB(c).Activity()
|
||||
@@ -504,8 +513,43 @@ func GetTableConstraints(c *gin.Context) {
|
||||
|
||||
// GetTablesStats renders data sizes and estimated rows for all tables in the database
|
||||
func GetTablesStats(c *gin.Context) {
|
||||
res, err := DB(c).TablesStats()
|
||||
serveResult(c, res, err)
|
||||
db := DB(c)
|
||||
|
||||
connCtx, err := db.GetConnContext()
|
||||
if err != nil {
|
||||
badRequest(c, err)
|
||||
return
|
||||
}
|
||||
|
||||
res, err := db.TablesStats()
|
||||
if err != nil {
|
||||
badRequest(c, err)
|
||||
return
|
||||
}
|
||||
|
||||
format := getQueryParam(c, "format")
|
||||
if format == "" {
|
||||
format = "json"
|
||||
}
|
||||
|
||||
// Save as attachment if exporting parameter is set
|
||||
if getQueryParam(c, "export") == "true" {
|
||||
ts := time.Now().Format(time.DateOnly)
|
||||
|
||||
filename := fmt.Sprintf("pgweb-dbstats-%s-%s.%s", connCtx.Database, ts, format)
|
||||
c.Writer.Header().Set("Content-disposition", "attachment;filename="+filename)
|
||||
}
|
||||
|
||||
switch format {
|
||||
case "json":
|
||||
c.JSON(http.StatusOK, res)
|
||||
case "csv":
|
||||
c.Data(http.StatusOK, "text/csv", res.CSV())
|
||||
case "xml":
|
||||
c.XML(200, res)
|
||||
default:
|
||||
badRequest(c, "invalid format")
|
||||
}
|
||||
}
|
||||
|
||||
// HandleQuery runs the database query
|
||||
@@ -558,9 +602,10 @@ func GetInfo(c *gin.Context) {
|
||||
successResponse(c, gin.H{
|
||||
"app": command.Info,
|
||||
"features": gin.H{
|
||||
"session_lock": command.Opts.LockSession,
|
||||
"query_timeout": command.Opts.QueryTimeout,
|
||||
"local_queries": QueryStore != nil,
|
||||
"session_lock": command.Opts.LockSession,
|
||||
"query_timeout": command.Opts.QueryTimeout,
|
||||
"local_queries": QueryStore != nil,
|
||||
"bookmarks_only": command.Opts.BookmarksOnly,
|
||||
},
|
||||
})
|
||||
}
|
||||
|
||||
@@ -1,87 +0,0 @@
|
||||
package api
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"context"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"net/http"
|
||||
"strings"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
)
|
||||
|
||||
// Backend represents a third party configuration source
|
||||
type Backend struct {
|
||||
Endpoint string
|
||||
Token string
|
||||
PassHeaders []string
|
||||
}
|
||||
|
||||
// BackendRequest represents a payload sent to the third-party source
|
||||
type BackendRequest struct {
|
||||
Resource string `json:"resource"`
|
||||
Token string `json:"token"`
|
||||
Headers map[string]string `json:"headers"`
|
||||
}
|
||||
|
||||
// BackendCredential represents the third-party response
|
||||
type BackendCredential struct {
|
||||
DatabaseURL string `json:"database_url"`
|
||||
}
|
||||
|
||||
// FetchCredential sends an authentication request to a third-party service
|
||||
func (be Backend) FetchCredential(ctx context.Context, resource string, c *gin.Context) (*BackendCredential, error) {
|
||||
logger.WithField("resource", resource).Debug("fetching database credential")
|
||||
|
||||
request := BackendRequest{
|
||||
Resource: resource,
|
||||
Token: be.Token,
|
||||
Headers: map[string]string{},
|
||||
}
|
||||
|
||||
// Pass white-listed client headers to the backend request
|
||||
for _, name := range be.PassHeaders {
|
||||
request.Headers[strings.ToLower(name)] = c.Request.Header.Get(name)
|
||||
}
|
||||
|
||||
body, err := json.Marshal(request)
|
||||
if err != nil {
|
||||
logger.WithField("resource", resource).Error("backend request serialization error:", err)
|
||||
return nil, err
|
||||
}
|
||||
|
||||
req, err := http.NewRequestWithContext(ctx, http.MethodPost, be.Endpoint, bytes.NewReader(body))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
req.Header.Set("content-type", "application/json")
|
||||
|
||||
resp, err := http.DefaultClient.Do(req)
|
||||
if err != nil {
|
||||
logger.WithField("resource", resource).Error("backend credential fetch failed:", err)
|
||||
return nil, errBackendConnectError
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
if resp.StatusCode != 200 {
|
||||
err = fmt.Errorf("backend credential fetch received HTTP status code %v", resp.StatusCode)
|
||||
|
||||
logger.
|
||||
WithField("resource", resource).
|
||||
WithField("status", resp.StatusCode).
|
||||
Error(err)
|
||||
|
||||
return nil, err
|
||||
}
|
||||
|
||||
cred := &BackendCredential{}
|
||||
if err := json.NewDecoder(resp.Body).Decode(cred); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if cred.DatabaseURL == "" {
|
||||
return nil, errConnStringRequired
|
||||
}
|
||||
|
||||
return cred, nil
|
||||
}
|
||||
@@ -7,12 +7,10 @@ import (
|
||||
var (
|
||||
errNotConnected = errors.New("Not connected")
|
||||
errNotPermitted = errors.New("Not permitted")
|
||||
errConnStringRequired = errors.New("Connection string is required")
|
||||
errInvalidConnString = errors.New("Invalid connection string")
|
||||
errSessionRequired = errors.New("Session ID is required")
|
||||
errSessionLocked = errors.New("Session is locked")
|
||||
errURLRequired = errors.New("URL parameter is required")
|
||||
errQueryRequired = errors.New("Query parameter is required")
|
||||
errDatabaseNameRequired = errors.New("Database name is required")
|
||||
errBackendConnectError = errors.New("Unable to connect to the auth backend")
|
||||
)
|
||||
|
||||
+4
-3
@@ -155,11 +155,12 @@ func assetContentType(name string) string {
|
||||
|
||||
// Send a query result to client
|
||||
func serveResult(c *gin.Context, result interface{}, err interface{}) {
|
||||
if err == nil {
|
||||
successResponse(c, result)
|
||||
} else {
|
||||
if err != nil {
|
||||
badRequest(c, err)
|
||||
return
|
||||
}
|
||||
|
||||
successResponse(c, result)
|
||||
}
|
||||
|
||||
// Send successful response back to client
|
||||
|
||||
@@ -35,6 +35,7 @@ func SetupRoutes(router *gin.Engine) {
|
||||
api.POST("/switchdb", SwitchDb)
|
||||
api.GET("/databases", GetDatabases)
|
||||
api.GET("/connection", GetConnectionInfo)
|
||||
api.GET("/server_settings", GetServerSettings)
|
||||
api.GET("/activity", GetActivity)
|
||||
api.GET("/schemas", GetSchemas)
|
||||
api.GET("/objects", GetObjects)
|
||||
|
||||
@@ -43,18 +43,21 @@ func (m *SessionManager) IDs() []string {
|
||||
|
||||
func (m *SessionManager) Sessions() map[string]*client.Client {
|
||||
m.mu.Lock()
|
||||
sessions := m.sessions
|
||||
m.mu.Unlock()
|
||||
defer m.mu.Unlock()
|
||||
|
||||
sessions := make(map[string]*client.Client, len(m.sessions))
|
||||
for k, v := range m.sessions {
|
||||
sessions[k] = v
|
||||
}
|
||||
|
||||
return sessions
|
||||
}
|
||||
|
||||
func (m *SessionManager) Get(id string) *client.Client {
|
||||
m.mu.Lock()
|
||||
c := m.sessions[id]
|
||||
m.mu.Unlock()
|
||||
defer m.mu.Unlock()
|
||||
|
||||
return c
|
||||
return m.sessions[id]
|
||||
}
|
||||
|
||||
func (m *SessionManager) Add(id string, conn *client.Client) {
|
||||
@@ -81,10 +84,9 @@ func (m *SessionManager) Remove(id string) bool {
|
||||
|
||||
func (m *SessionManager) Len() int {
|
||||
m.mu.Lock()
|
||||
sz := len(m.sessions)
|
||||
m.mu.Unlock()
|
||||
defer m.mu.Unlock()
|
||||
|
||||
return sz
|
||||
return len(m.sessions)
|
||||
}
|
||||
|
||||
func (m *SessionManager) Cleanup() int {
|
||||
@@ -118,7 +120,7 @@ func (m *SessionManager) RunPeriodicCleanup() {
|
||||
}
|
||||
|
||||
func (m *SessionManager) staleSessions() []string {
|
||||
m.mu.TryLock()
|
||||
m.mu.Lock()
|
||||
defer m.mu.Unlock()
|
||||
|
||||
now := time.Now()
|
||||
|
||||
@@ -20,6 +20,7 @@ type Bookmark struct {
|
||||
Database string // Database name
|
||||
SSLMode string // Connection SSL mode
|
||||
SSH *shared.SSHInfo // SSH tunnel config
|
||||
ReadOnly bool // Enable read-only transaction mode
|
||||
}
|
||||
|
||||
// SSHInfoIsEmpty returns true if ssh configuration is not provided
|
||||
@@ -40,12 +41,13 @@ func (b Bookmark) ConvertToOptions() command.Options {
|
||||
}
|
||||
|
||||
return command.Options{
|
||||
URL: b.URL,
|
||||
Host: b.Host,
|
||||
Port: b.Port,
|
||||
User: user,
|
||||
Pass: pass,
|
||||
DbName: b.Database,
|
||||
SSLMode: b.SSLMode,
|
||||
URL: b.URL,
|
||||
Host: b.Host,
|
||||
Port: b.Port,
|
||||
User: user,
|
||||
Pass: pass,
|
||||
DbName: b.Database,
|
||||
SSLMode: b.SSLMode,
|
||||
ReadOnly: b.ReadOnly,
|
||||
}
|
||||
}
|
||||
|
||||
@@ -68,6 +68,7 @@ func TestBookmarkWithVarsConvertToOptions(t *testing.T) {
|
||||
|
||||
t.Setenv("DB_USER", "user123")
|
||||
t.Setenv("DB_PASSWORD", "password123")
|
||||
|
||||
opt := b.ConvertToOptions()
|
||||
assert.Equal(t, expOpt, opt)
|
||||
})
|
||||
@@ -87,6 +88,7 @@ func TestBookmarkWithVarsConvertToOptions(t *testing.T) {
|
||||
|
||||
t.Setenv("DB_USER", "user123")
|
||||
t.Setenv("DB_PASSWORD", "password123")
|
||||
|
||||
opt := b.ConvertToOptions()
|
||||
assert.Equal(t, expOpt, opt)
|
||||
})
|
||||
@@ -101,16 +103,18 @@ func TestBookmarkConvertToOptions(t *testing.T) {
|
||||
Password: "password",
|
||||
Database: "mydatabase",
|
||||
SSLMode: "disable",
|
||||
ReadOnly: true,
|
||||
}
|
||||
|
||||
expOpt := command.Options{
|
||||
URL: "postgres://username:password@host:port/database?sslmode=disable",
|
||||
Host: "localhost",
|
||||
Port: 5432,
|
||||
User: "postgres",
|
||||
Pass: "password",
|
||||
DbName: "mydatabase",
|
||||
SSLMode: "disable",
|
||||
URL: "postgres://username:password@host:port/database?sslmode=disable",
|
||||
Host: "localhost",
|
||||
Port: 5432,
|
||||
User: "postgres",
|
||||
Pass: "password",
|
||||
DbName: "mydatabase",
|
||||
SSLMode: "disable",
|
||||
ReadOnly: true,
|
||||
}
|
||||
|
||||
opt := b.ConvertToOptions()
|
||||
|
||||
@@ -12,7 +12,7 @@ func TestManagerList(t *testing.T) {
|
||||
num int
|
||||
err string
|
||||
}{
|
||||
{"../../data", 3, ""},
|
||||
{"../../data", 4, ""},
|
||||
{"../../data/bookmark.toml", 0, "is not a directory"},
|
||||
{"../../data2", 0, ""},
|
||||
{"", 0, ""},
|
||||
@@ -32,7 +32,12 @@ func TestManagerList(t *testing.T) {
|
||||
func TestManagerListIDs(t *testing.T) {
|
||||
ids, err := NewManager("../../data").ListIDs()
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, []string{"bookmark", "bookmark_invalid_ssl", "bookmark_url"}, ids)
|
||||
assert.Equal(t, []string{
|
||||
"bookmark",
|
||||
"bookmark_invalid_ssl",
|
||||
"bookmark_url",
|
||||
"bookmark_with_ssh",
|
||||
}, ids)
|
||||
}
|
||||
|
||||
func TestManagerGet(t *testing.T) {
|
||||
@@ -80,6 +85,19 @@ func Test_readBookmark(t *testing.T) {
|
||||
assert.Equal(t, "", b.Password)
|
||||
})
|
||||
|
||||
t.Run("with ssh options", func(t *testing.T) {
|
||||
b, err := readBookmark("../../data/bookmark_with_ssh.toml")
|
||||
assert.NoError(t, err)
|
||||
assert.NotNil(t, b.SSH)
|
||||
|
||||
sshc := b.SSH
|
||||
assert.Equal(t, "ssh-host", sshc.Host)
|
||||
assert.Equal(t, "ssh-user", sshc.User)
|
||||
assert.Equal(t, "ssh-password", sshc.Password)
|
||||
assert.Equal(t, "/path/to/key-file", sshc.Key)
|
||||
assert.Equal(t, "key-file-password", sshc.KeyPassword)
|
||||
})
|
||||
|
||||
t.Run("invalid ssl", func(t *testing.T) {
|
||||
b, err := readBookmark("../../data/bookmark_invalid_ssl.toml")
|
||||
assert.NoError(t, err)
|
||||
|
||||
+72
-48
@@ -1,12 +1,12 @@
|
||||
package cli
|
||||
|
||||
import (
|
||||
"context"
|
||||
"errors"
|
||||
"fmt"
|
||||
"os"
|
||||
"os/exec"
|
||||
"os/signal"
|
||||
"regexp"
|
||||
"strings"
|
||||
"syscall"
|
||||
"time"
|
||||
@@ -23,6 +23,7 @@ import (
|
||||
"github.com/sosedoff/pgweb/pkg/metrics"
|
||||
"github.com/sosedoff/pgweb/pkg/queries"
|
||||
"github.com/sosedoff/pgweb/pkg/util"
|
||||
"go.balki.me/anyhttp"
|
||||
)
|
||||
|
||||
var (
|
||||
@@ -35,9 +36,6 @@ SECURITY WARNING: You are running Pgweb in read-only mode.
|
||||
This mode is designed for environments where users could potentially delete or change data.
|
||||
For proper read-only access please follow PostgreSQL role management documentation.
|
||||
--------------------------------------------------------------------------------`
|
||||
|
||||
regexErrConnectionRefused = regexp.MustCompile(`(connection|actively) refused`)
|
||||
regexErrAuthFailed = regexp.MustCompile(`authentication failed`)
|
||||
)
|
||||
|
||||
func init() {
|
||||
@@ -77,35 +75,20 @@ func initClient() {
|
||||
}
|
||||
|
||||
if command.Opts.Debug {
|
||||
fmt.Println("Server connection string:", cl.ConnectionString)
|
||||
fmt.Println("Opening database connection using string:", cl.ConnectionString)
|
||||
}
|
||||
|
||||
retryCount := command.Opts.RetryCount
|
||||
retryDelay := time.Second * time.Duration(command.Opts.RetryDelay)
|
||||
|
||||
fmt.Println("Connecting to server...")
|
||||
if err := cl.Test(); err != nil {
|
||||
msg := err.Error()
|
||||
|
||||
// Check if we're trying to connect to the default database.
|
||||
if command.Opts.DbName == "" && command.Opts.URL == "" {
|
||||
// If database does not exist, allow user to connect from the UI.
|
||||
if strings.Contains(msg, "database") && strings.Contains(msg, "does not exist") {
|
||||
fmt.Println("Error:", msg)
|
||||
return
|
||||
}
|
||||
|
||||
// Do not bail if local server is not running.
|
||||
if regexErrConnectionRefused.MatchString(msg) {
|
||||
fmt.Println("Error:", msg)
|
||||
return
|
||||
}
|
||||
|
||||
// Do not bail if local auth is invalid
|
||||
if regexErrAuthFailed.MatchString(msg) {
|
||||
fmt.Println("Error:", msg)
|
||||
return
|
||||
}
|
||||
abort, err := testClient(cl, int(retryCount), retryDelay)
|
||||
if err != nil {
|
||||
if abort {
|
||||
exitWithMessage(err.Error())
|
||||
} else {
|
||||
return
|
||||
}
|
||||
|
||||
exitWithMessage(msg)
|
||||
}
|
||||
|
||||
if !command.Opts.Sessions {
|
||||
@@ -213,7 +196,7 @@ func printVersion() {
|
||||
fmt.Println(command.VersionString())
|
||||
}
|
||||
|
||||
func startServer() {
|
||||
func startServer() *anyhttp.ServerCtx {
|
||||
router := gin.New()
|
||||
router.Use(api.RequestLogger(logger))
|
||||
router.Use(gin.Recovery())
|
||||
@@ -229,18 +212,22 @@ func startServer() {
|
||||
api.SetupMetrics(router)
|
||||
|
||||
fmt.Println("Starting server...")
|
||||
go func() {
|
||||
metrics.SetHealthy(true)
|
||||
address := fmt.Sprintf("%v:%v", options.HTTPHost, options.HTTPPort)
|
||||
if options.HTTPAddr != "" {
|
||||
address = options.HTTPAddr
|
||||
}
|
||||
|
||||
err := router.Run(fmt.Sprintf("%v:%v", options.HTTPHost, options.HTTPPort))
|
||||
if err != nil {
|
||||
fmt.Println("Cant start server:", err)
|
||||
if strings.Contains(err.Error(), "address already in use") {
|
||||
openPage()
|
||||
}
|
||||
os.Exit(1)
|
||||
metrics.SetHealthy(true)
|
||||
|
||||
ctx, err := anyhttp.Serve(address, router.Handler())
|
||||
if err != nil {
|
||||
fmt.Println("Can't start server:", err)
|
||||
if strings.Contains(err.Error(), "address already in use") {
|
||||
openPage()
|
||||
}
|
||||
}()
|
||||
os.Exit(1)
|
||||
}
|
||||
return ctx
|
||||
}
|
||||
|
||||
func startMetricsServer() {
|
||||
@@ -255,12 +242,6 @@ func startMetricsServer() {
|
||||
}
|
||||
}
|
||||
|
||||
func handleSignals() {
|
||||
c := make(chan os.Signal, 1)
|
||||
signal.Notify(c, os.Interrupt, syscall.SIGTERM)
|
||||
<-c
|
||||
}
|
||||
|
||||
func openPage() {
|
||||
url := fmt.Sprintf("http://%v:%v/%s", options.HTTPHost, options.HTTPPort, options.Prefix)
|
||||
fmt.Println("To view database open", url, "in browser")
|
||||
@@ -280,6 +261,39 @@ func openPage() {
|
||||
}
|
||||
}
|
||||
|
||||
// testClient attempts to establish a database connection until it succeeds or
|
||||
// give up after certain number of retries. Retries only available when database
|
||||
// name or a connection string is provided.
|
||||
func testClient(cl *client.Client, retryCount int, retryDelay time.Duration) (abort bool, err error) {
|
||||
usingDefaultDB := command.Opts.DbName == "" && command.Opts.URL == ""
|
||||
|
||||
for {
|
||||
err = cl.Test()
|
||||
if err == nil {
|
||||
return false, nil
|
||||
}
|
||||
|
||||
// Continue normal start up if can't connect locally without database details.
|
||||
if usingDefaultDB {
|
||||
if errors.Is(err, client.ErrConnectionRefused) ||
|
||||
errors.Is(err, client.ErrAuthFailed) ||
|
||||
errors.Is(err, client.ErrDatabaseNotExist) {
|
||||
return false, err
|
||||
}
|
||||
}
|
||||
|
||||
// Only retry if can't establish connection to the server.
|
||||
if errors.Is(err, client.ErrConnectionRefused) && retryCount > 0 {
|
||||
fmt.Printf("Connection error: %v, retrying in %v (%d remaining)\n", err, retryDelay, retryCount)
|
||||
retryCount--
|
||||
<-time.After(retryDelay)
|
||||
continue
|
||||
}
|
||||
|
||||
return true, err
|
||||
}
|
||||
}
|
||||
|
||||
func Run() {
|
||||
initOptions()
|
||||
initClient()
|
||||
@@ -313,7 +327,17 @@ func Run() {
|
||||
go startMetricsServer()
|
||||
}
|
||||
|
||||
startServer()
|
||||
serverCtx := startServer()
|
||||
|
||||
openPage()
|
||||
handleSignals()
|
||||
|
||||
c := make(chan os.Signal, 1)
|
||||
signal.Notify(c, os.Interrupt, syscall.SIGTERM)
|
||||
select {
|
||||
case doneErr := <-serverCtx.Done:
|
||||
logger.Infoln("idle server. shutting down error: ", doneErr)
|
||||
case <-c:
|
||||
logger.Infoln("received signal. shutting down")
|
||||
serverCtx.Shutdown(context.TODO())
|
||||
}
|
||||
}
|
||||
|
||||
+51
-3
@@ -7,6 +7,7 @@ import (
|
||||
"log"
|
||||
neturl "net/url"
|
||||
"reflect"
|
||||
"regexp"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
@@ -21,6 +22,18 @@ import (
|
||||
"github.com/sosedoff/pgweb/pkg/statements"
|
||||
)
|
||||
|
||||
var (
|
||||
regexErrAuthFailed = regexp.MustCompile(`(authentication failed|role "(.*)" does not exist)`)
|
||||
regexErrConnectionRefused = regexp.MustCompile(`(connection|actively) refused`)
|
||||
regexErrDatabaseNotExist = regexp.MustCompile(`database "(.*)" does not exist`)
|
||||
)
|
||||
|
||||
var (
|
||||
ErrAuthFailed = errors.New("authentication failed")
|
||||
ErrConnectionRefused = errors.New("connection refused")
|
||||
ErrDatabaseNotExist = errors.New("database does not exist")
|
||||
)
|
||||
|
||||
type Client struct {
|
||||
db *sqlx.DB
|
||||
tunnel *Tunnel
|
||||
@@ -28,6 +41,7 @@ type Client struct {
|
||||
serverType string
|
||||
lastQueryTime time.Time
|
||||
queryTimeout time.Duration
|
||||
readonly bool
|
||||
closed bool
|
||||
External bool `json:"external"`
|
||||
History []history.Record `json:"history"`
|
||||
@@ -153,7 +167,16 @@ func NewFromBookmark(bookmark *bookmarks.Bookmark) (*Client, error) {
|
||||
sshInfo = bookmark.SSH
|
||||
}
|
||||
|
||||
return NewFromUrl(connStr, sshInfo)
|
||||
client, err := NewFromUrl(connStr, sshInfo)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if bookmark.ReadOnly {
|
||||
client.readonly = true
|
||||
}
|
||||
|
||||
return client, nil
|
||||
}
|
||||
|
||||
func (client *Client) init() {
|
||||
@@ -179,7 +202,28 @@ func (client *Client) setServerVersion() {
|
||||
}
|
||||
|
||||
func (client *Client) Test() error {
|
||||
return client.db.Ping()
|
||||
// NOTE: This is a different timeout defined in CLI OpenTimeout
|
||||
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
||||
defer cancel()
|
||||
|
||||
err := client.db.PingContext(ctx)
|
||||
if err == nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
errMsg := err.Error()
|
||||
|
||||
if regexErrConnectionRefused.MatchString(errMsg) {
|
||||
return ErrConnectionRefused
|
||||
}
|
||||
if regexErrAuthFailed.MatchString(errMsg) {
|
||||
return ErrAuthFailed
|
||||
}
|
||||
if regexErrDatabaseNotExist.MatchString(errMsg) {
|
||||
return ErrDatabaseNotExist
|
||||
}
|
||||
|
||||
return err
|
||||
}
|
||||
|
||||
func (client *Client) TestWithTimeout(timeout time.Duration) (result error) {
|
||||
@@ -342,6 +386,10 @@ func (client *Client) TablesStats() (*Result, error) {
|
||||
return client.query(statements.TablesStats)
|
||||
}
|
||||
|
||||
func (client *Client) ServerSettings() (*Result, error) {
|
||||
return client.query(statements.Settings)
|
||||
}
|
||||
|
||||
// Returns all active queriers on the server
|
||||
func (client *Client) Activity() (*Result, error) {
|
||||
if client.serverType == cockroachType {
|
||||
@@ -442,7 +490,7 @@ func (client *Client) query(query string, args ...interface{}) (*Result, error)
|
||||
|
||||
// We're going to force-set transaction mode on every query.
|
||||
// This is needed so that default mode could not be changed by user.
|
||||
if command.Opts.ReadOnly {
|
||||
if command.Opts.ReadOnly || client.readonly {
|
||||
if err := client.SetReadOnlyMode(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
@@ -11,9 +11,10 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/sosedoff/pgweb/pkg/command"
|
||||
|
||||
"github.com/stretchr/testify/assert"
|
||||
"github.com/stretchr/testify/require"
|
||||
|
||||
"github.com/sosedoff/pgweb/pkg/command"
|
||||
)
|
||||
|
||||
var (
|
||||
@@ -56,7 +57,9 @@ func assertMatches(t *testing.T, expected, src []string) {
|
||||
|
||||
func pgVersion() (int, int) {
|
||||
var major, minor int
|
||||
fmt.Sscanf(os.Getenv("PGVERSION"), "%d.%d", &major, &minor)
|
||||
if _, err := fmt.Sscanf(os.Getenv("PGVERSION"), "%d.%d", &major, &minor); err != nil {
|
||||
log.Println("[warn] unable to read value of PGVERSION env var")
|
||||
}
|
||||
return major, minor
|
||||
}
|
||||
|
||||
@@ -199,7 +202,46 @@ func testClientIdleTime(t *testing.T) {
|
||||
}
|
||||
|
||||
func testTest(t *testing.T) {
|
||||
assert.NoError(t, testClient.Test())
|
||||
examples := []struct {
|
||||
name string
|
||||
input string
|
||||
err error
|
||||
}{
|
||||
{
|
||||
name: "success",
|
||||
input: fmt.Sprintf("postgres://%s@%s:%s/%s?sslmode=disable", serverUser, serverHost, serverPort, serverDatabase),
|
||||
err: nil,
|
||||
},
|
||||
{
|
||||
name: "connection refused",
|
||||
input: "postgresql://localhost:5433/dbname",
|
||||
err: ErrConnectionRefused,
|
||||
},
|
||||
{
|
||||
name: "invalid user",
|
||||
input: fmt.Sprintf("postgres://%s:%s@%s:%s/%s?sslmode=disable", "foo", serverPassword, serverHost, serverPort, serverDatabase),
|
||||
err: ErrAuthFailed,
|
||||
},
|
||||
{
|
||||
name: "invalid password",
|
||||
input: fmt.Sprintf("postgres://%s:%s@%s:%s/%s?sslmode=disable", serverUser, "foo", serverHost, serverPort, serverDatabase),
|
||||
err: ErrAuthFailed,
|
||||
},
|
||||
{
|
||||
name: "invalid database",
|
||||
input: fmt.Sprintf("postgres://%s@%s:%s/%s?sslmode=disable", serverUser, serverHost, serverPort, "foo"),
|
||||
err: ErrDatabaseNotExist,
|
||||
},
|
||||
}
|
||||
|
||||
for _, ex := range examples {
|
||||
t.Run(ex.name, func(t *testing.T) {
|
||||
conn, err := NewFromUrl(ex.input, nil)
|
||||
require.NoError(t, err)
|
||||
|
||||
require.Equal(t, ex.err, conn.Test())
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
func testInfo(t *testing.T) {
|
||||
@@ -639,6 +681,14 @@ func testReadOnlyMode(t *testing.T) {
|
||||
|
||||
_, err = client.Query("/* CREATE TABLE foobar(id integer); */ SELECT 'foo';")
|
||||
assert.NoError(t, err)
|
||||
|
||||
t.Run("with local readonly flag", func(t *testing.T) {
|
||||
command.Opts.ReadOnly = false
|
||||
client.readonly = true
|
||||
|
||||
_, err := client.Query("INSERT INTO foobar(id) VALUES(1)")
|
||||
assert.Error(t, err, "query contains keywords not allowed in read-only mode")
|
||||
})
|
||||
}
|
||||
|
||||
func testTablesStats(t *testing.T) {
|
||||
@@ -669,6 +719,32 @@ func testConnContext(t *testing.T) {
|
||||
assert.Equal(t, "default", result.Mode)
|
||||
}
|
||||
|
||||
func testServerSettings(t *testing.T) {
|
||||
expectedColumns := []string{
|
||||
"name",
|
||||
"setting",
|
||||
"unit",
|
||||
"category",
|
||||
"short_desc",
|
||||
"extra_desc",
|
||||
"context",
|
||||
"vartype",
|
||||
"source",
|
||||
"min_val",
|
||||
"max_val",
|
||||
"enumvals",
|
||||
"boot_val",
|
||||
"reset_val",
|
||||
"sourcefile",
|
||||
"sourceline",
|
||||
"pending_restart",
|
||||
}
|
||||
|
||||
result, err := testClient.ServerSettings()
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, expectedColumns, result.Columns)
|
||||
}
|
||||
|
||||
func TestAll(t *testing.T) {
|
||||
if onWindows() {
|
||||
t.Log("Unit testing on Windows platform is not supported.")
|
||||
@@ -708,6 +784,7 @@ func TestAll(t *testing.T) {
|
||||
testDumpExport(t)
|
||||
testTablesStats(t)
|
||||
testConnContext(t)
|
||||
testServerSettings(t)
|
||||
|
||||
teardownClient()
|
||||
teardown(t, true)
|
||||
|
||||
@@ -8,6 +8,7 @@ import (
|
||||
"net"
|
||||
"net/url"
|
||||
"os"
|
||||
"path/filepath"
|
||||
"strings"
|
||||
"sync"
|
||||
"time"
|
||||
@@ -35,8 +36,8 @@ type Tunnel struct {
|
||||
Listener *net.TCPListener
|
||||
}
|
||||
|
||||
func privateKeyPath() string {
|
||||
return os.Getenv("HOME") + "/.ssh/id_rsa"
|
||||
func defaultKeyPath() string {
|
||||
return filepath.Join(os.Getenv("HOME"), ".ssh/id_rsa")
|
||||
}
|
||||
|
||||
func expandKeyPath(path string) string {
|
||||
@@ -61,7 +62,7 @@ func parsePrivateKey(keyPath string, keyPass string) (ssh.Signer, error) {
|
||||
signer, err := ssh.ParsePrivateKey(buff)
|
||||
if _, ok := err.(*ssh.PassphraseMissingError); ok {
|
||||
if keyPass == "" {
|
||||
return nil, errors.New("SSH key password is not provided")
|
||||
return nil, errors.New("ssh key password is not provided")
|
||||
}
|
||||
return sshkeys.ParseEncryptedPrivateKey(buff, []byte(keyPass))
|
||||
}
|
||||
@@ -75,13 +76,13 @@ func makeConfig(info *shared.SSHInfo) (*ssh.ClientConfig, error) {
|
||||
// Try to use user-provided key, fallback to system default key
|
||||
keyPath := info.Key
|
||||
if keyPath == "" {
|
||||
keyPath = privateKeyPath()
|
||||
keyPath = defaultKeyPath()
|
||||
} else {
|
||||
keyPath = expandKeyPath(keyPath)
|
||||
}
|
||||
|
||||
if !fileExists(keyPath) {
|
||||
return nil, errors.New("ssh public key not found at " + keyPath)
|
||||
return nil, fmt.Errorf("ssh public key not found at path %q", keyPath)
|
||||
}
|
||||
|
||||
// Append public key authentication method
|
||||
@@ -129,11 +130,11 @@ func (tunnel *Tunnel) handleConnection(local net.Conn) {
|
||||
return
|
||||
}
|
||||
|
||||
wg := sync.WaitGroup{}
|
||||
wg := &sync.WaitGroup{}
|
||||
wg.Add(2)
|
||||
|
||||
go tunnel.copy(&wg, local, remote)
|
||||
go tunnel.copy(&wg, remote, local)
|
||||
go tunnel.copy(wg, local, remote)
|
||||
go tunnel.copy(wg, remote, local)
|
||||
|
||||
wg.Wait()
|
||||
local.Close()
|
||||
|
||||
+3
-3
@@ -8,7 +8,7 @@ import (
|
||||
|
||||
var (
|
||||
// List of keywords that are not allowed in read-only mode
|
||||
reRestrictedKeywords = regexp.MustCompile(`(?mi)\s?(CREATE|INSERT|DROP|DELETE|TRUNCATE|GRANT|OPEN|IMPORT|COPY)\s`)
|
||||
reRestrictedKeywords = regexp.MustCompile(`(?mi)\s?(CREATE|INSERT|UPDATE|DROP|DELETE|TRUNCATE|GRANT|OPEN|IMPORT|COPY)\s`)
|
||||
|
||||
// Comment regular expressions
|
||||
reSlashComment = regexp.MustCompile(`(?m)/\*.+\*/`)
|
||||
@@ -28,9 +28,9 @@ var (
|
||||
// Example: 10.2.3.1 -> 10.2
|
||||
func getMajorMinorVersion(str string) (major int, minor int) {
|
||||
chunks := strings.Split(str, ".")
|
||||
fmt.Sscanf(chunks[0], "%d", &major)
|
||||
fmt.Sscanf(chunks[0], "%d", &major) //nolint
|
||||
if len(chunks) > 1 {
|
||||
fmt.Sscanf(chunks[1], "%d", &minor)
|
||||
fmt.Sscanf(chunks[1], "%d", &minor) //nolint
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
+23
-3
@@ -36,7 +36,10 @@ type Options struct {
|
||||
SSLRootCert string `long:"ssl-rootcert" description:"SSL certificate authority file"`
|
||||
SSLCert string `long:"ssl-cert" description:"SSL client certificate file"`
|
||||
SSLKey string `long:"ssl-key" description:"SSL client certificate key file"`
|
||||
OpenTimeout int `long:"open-timeout" description:" Maximum wait for connection, in seconds" default:"30"`
|
||||
OpenTimeout int `long:"open-timeout" description:"Maximum wait time for connection, in seconds" default:"30"`
|
||||
RetryDelay uint `long:"open-retry-delay" description:"Number of seconds to wait before retrying the connection" default:"3"`
|
||||
RetryCount uint `long:"open-retry" description:"Number of times to retry establishing connection" default:"0"`
|
||||
HTTPAddr string `long:"address" description:"anyhttp address. See https://pkg.go.dev/go.balki.me/anyhttp#readme-address-syntax" default:""`
|
||||
HTTPHost string `long:"bind" description:"HTTP server host" default:"localhost"`
|
||||
HTTPPort uint `long:"listen" description:"HTTP server listen port" default:"8081"`
|
||||
AuthUser string `long:"auth-user" description:"HTTP basic auth user"`
|
||||
@@ -48,6 +51,7 @@ type Options struct {
|
||||
LockSession bool `long:"lock-session" description:"Lock session to a single database connection"`
|
||||
Bookmark string `short:"b" long:"bookmark" description:"Bookmark to use for connection. Bookmark files are stored under $HOME/.pgweb/bookmarks/*.toml" default:""`
|
||||
BookmarksDir string `long:"bookmarks-dir" description:"Overrides default directory for bookmark files to search" default:""`
|
||||
BookmarksOnly bool `long:"bookmarks-only" description:"Allow only connections from bookmarks"`
|
||||
QueriesDir string `long:"queries-dir" description:"Overrides default directory for local queries"`
|
||||
DisablePrettyJSON bool `long:"no-pretty-json" description:"Disable JSON formatting feature for result export"`
|
||||
DisableSSH bool `long:"no-ssh" description:"Disable database connections via SSH"`
|
||||
@@ -116,6 +120,10 @@ func ParseOptions(args []string) (Options, error) {
|
||||
}
|
||||
}
|
||||
|
||||
if getPrefixedEnvVar("BOOKMARKS_ONLY") != "" {
|
||||
opts.BookmarksOnly = true
|
||||
}
|
||||
|
||||
if getPrefixedEnvVar("SESSIONS") != "" {
|
||||
opts.Sessions = true
|
||||
}
|
||||
@@ -160,9 +168,21 @@ func ParseOptions(args []string) (Options, error) {
|
||||
}
|
||||
}
|
||||
|
||||
if opts.BookmarksOnly {
|
||||
if opts.URL != "" {
|
||||
return opts, errors.New("--url not supported in bookmarks-only mode")
|
||||
}
|
||||
if opts.Host != "" && opts.Host != "localhost" {
|
||||
return opts, errors.New("--host not supported in bookmarks-only mode")
|
||||
}
|
||||
if opts.ConnectBackend != "" {
|
||||
return opts, errors.New("--connect-backend not supported in bookmarks-only mode")
|
||||
}
|
||||
}
|
||||
|
||||
homePath, err := homedir.Dir()
|
||||
if err != nil {
|
||||
fmt.Fprintf(os.Stderr, "[WARN] cant detect home dir: %v", err)
|
||||
fmt.Fprintf(os.Stderr, "[WARN] can't detect home dir: %v", err)
|
||||
homePath = os.Getenv("HOME")
|
||||
}
|
||||
|
||||
@@ -218,7 +238,7 @@ func AvailableEnvVars() string {
|
||||
return strings.Join([]string{
|
||||
" " + envVarPrefix + "DATABASE_URL Database connection string",
|
||||
" " + envVarPrefix + "URL_PREFIX HTTP server path prefix",
|
||||
" " + envVarPrefix + "SESSIONS: Enable multiple database sessions",
|
||||
" " + envVarPrefix + "SESSIONS Enable multiple database sessions",
|
||||
" " + envVarPrefix + "LOCK_SESSION Lock session to a single database connection",
|
||||
" " + envVarPrefix + "AUTH_USER HTTP basic auth username",
|
||||
" " + envVarPrefix + "AUTH_PASS HTTP basic auth password",
|
||||
|
||||
@@ -80,4 +80,18 @@ func TestParseOptions(t *testing.T) {
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, "../../data/passfile", opts.Passfile)
|
||||
})
|
||||
|
||||
t.Run("bookmarks only mode", func(t *testing.T) {
|
||||
_, err := ParseOptions([]string{"--bookmarks-only"})
|
||||
assert.NoError(t, err)
|
||||
|
||||
_, err = ParseOptions([]string{"--bookmarks-only", "--url", "test"})
|
||||
assert.EqualError(t, err, "--url not supported in bookmarks-only mode")
|
||||
|
||||
_, err = ParseOptions([]string{"--bookmarks-only", "--host", "test", "--port", "5432"})
|
||||
assert.EqualError(t, err, "--host not supported in bookmarks-only mode")
|
||||
|
||||
_, err = ParseOptions([]string{"--bookmarks-only", "--connect-backend", "test", "--sessions", "--connect-token", "token", "--url", "127.0.0.2"})
|
||||
assert.EqualError(t, err, "--connect-backend not supported in bookmarks-only mode")
|
||||
})
|
||||
}
|
||||
|
||||
@@ -8,7 +8,7 @@ import (
|
||||
|
||||
const (
|
||||
// Version is the current Pgweb application version
|
||||
Version = "0.14.2"
|
||||
Version = "0.17.0"
|
||||
)
|
||||
|
||||
var (
|
||||
|
||||
@@ -0,0 +1,92 @@
|
||||
package connect
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"context"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"net/http"
|
||||
"strings"
|
||||
|
||||
"github.com/sirupsen/logrus"
|
||||
)
|
||||
|
||||
type Backend struct {
|
||||
Endpoint string
|
||||
Token string
|
||||
PassHeaders []string
|
||||
|
||||
logger *logrus.Logger
|
||||
}
|
||||
|
||||
func NewBackend(endpoint string, token string) Backend {
|
||||
return Backend{
|
||||
Endpoint: endpoint,
|
||||
Token: token,
|
||||
logger: logrus.StandardLogger(),
|
||||
}
|
||||
}
|
||||
|
||||
func (be *Backend) SetLogger(logger *logrus.Logger) {
|
||||
be.logger = logger
|
||||
}
|
||||
|
||||
func (be *Backend) SetPassHeaders(headers []string) {
|
||||
be.PassHeaders = headers
|
||||
}
|
||||
|
||||
func (be *Backend) FetchCredential(ctx context.Context, resource string, headers http.Header) (*Credential, error) {
|
||||
be.logger.WithField("resource", resource).Debug("fetching database credential")
|
||||
|
||||
request := Request{
|
||||
Resource: resource,
|
||||
Token: be.Token,
|
||||
Headers: map[string]string{},
|
||||
}
|
||||
|
||||
// Pass allow-listed client headers to the backend request
|
||||
for _, name := range be.PassHeaders {
|
||||
request.Headers[strings.ToLower(name)] = headers.Get(name)
|
||||
}
|
||||
|
||||
body, err := json.Marshal(request)
|
||||
if err != nil {
|
||||
be.logger.WithField("resource", resource).Error("backend request serialization error:", err)
|
||||
return nil, err
|
||||
}
|
||||
|
||||
req, err := http.NewRequestWithContext(ctx, http.MethodPost, be.Endpoint, bytes.NewReader(body))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
req.Header.Set("content-type", "application/json")
|
||||
|
||||
resp, err := http.DefaultClient.Do(req)
|
||||
if err != nil {
|
||||
be.logger.WithField("resource", resource).Error("backend credential fetch failed:", err)
|
||||
return nil, errBackendConnectError
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
if resp.StatusCode != 200 {
|
||||
err = fmt.Errorf("backend credential fetch received HTTP status code %v", resp.StatusCode)
|
||||
|
||||
be.logger.
|
||||
WithField("resource", request.Resource).
|
||||
WithField("status", resp.StatusCode).
|
||||
Error(err)
|
||||
|
||||
return nil, err
|
||||
}
|
||||
|
||||
cred := &Credential{}
|
||||
if err := json.NewDecoder(resp.Body).Decode(cred); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if cred.DatabaseURL == "" {
|
||||
return nil, errConnStringRequired
|
||||
}
|
||||
|
||||
return cred, nil
|
||||
}
|
||||
@@ -1,4 +1,4 @@
|
||||
package api
|
||||
package connect
|
||||
|
||||
import (
|
||||
"context"
|
||||
@@ -9,6 +9,7 @@ import (
|
||||
"time"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
"github.com/sirupsen/logrus"
|
||||
"github.com/stretchr/testify/assert"
|
||||
)
|
||||
|
||||
@@ -17,8 +18,8 @@ func TestBackendFetchCredential(t *testing.T) {
|
||||
name string
|
||||
backend Backend
|
||||
resourceName string
|
||||
cred *BackendCredential
|
||||
reqCtx *gin.Context
|
||||
cred *Credential
|
||||
headers http.Header
|
||||
ctx func() (context.Context, context.CancelFunc)
|
||||
err error
|
||||
}{
|
||||
@@ -33,12 +34,12 @@ func TestBackendFetchCredential(t *testing.T) {
|
||||
ctx: func() (context.Context, context.CancelFunc) {
|
||||
return context.WithTimeout(context.Background(), time.Millisecond*100)
|
||||
},
|
||||
err: errors.New("Unable to connect to the auth backend"),
|
||||
err: errors.New("unable to connect to the auth backend"),
|
||||
},
|
||||
{
|
||||
name: "Empty response",
|
||||
backend: Backend{Endpoint: "http://localhost:5555/empty-response"},
|
||||
err: errors.New("Connection string is required"),
|
||||
err: errors.New("connection string is required"),
|
||||
},
|
||||
{
|
||||
name: "Missing header",
|
||||
@@ -51,19 +52,15 @@ func TestBackendFetchCredential(t *testing.T) {
|
||||
Endpoint: "http://localhost:5555/pass-header",
|
||||
PassHeaders: []string{"x-foo"},
|
||||
},
|
||||
reqCtx: &gin.Context{
|
||||
Request: &http.Request{
|
||||
Header: http.Header{
|
||||
"X-Foo": []string{"bar"},
|
||||
},
|
||||
},
|
||||
headers: http.Header{
|
||||
"X-Foo": []string{"bar"},
|
||||
},
|
||||
cred: &BackendCredential{DatabaseURL: "postgres://hostname/bar"},
|
||||
cred: &Credential{DatabaseURL: "postgres://hostname/bar"},
|
||||
},
|
||||
{
|
||||
name: "Success",
|
||||
backend: Backend{Endpoint: "http://localhost:5555/success"},
|
||||
cred: &BackendCredential{DatabaseURL: "postgres://hostname/dbname"},
|
||||
cred: &Credential{DatabaseURL: "postgres://hostname/dbname"},
|
||||
},
|
||||
}
|
||||
|
||||
@@ -73,6 +70,8 @@ func TestBackendFetchCredential(t *testing.T) {
|
||||
startTestBackend(srvCtx, "localhost:5555")
|
||||
|
||||
for _, ex := range examples {
|
||||
ex.backend.logger = logrus.StandardLogger()
|
||||
|
||||
t.Run(ex.name, func(t *testing.T) {
|
||||
ctx, cancel := context.WithCancel(context.Background())
|
||||
if ex.ctx != nil {
|
||||
@@ -80,14 +79,7 @@ func TestBackendFetchCredential(t *testing.T) {
|
||||
}
|
||||
defer cancel()
|
||||
|
||||
reqCtx := ex.reqCtx
|
||||
if reqCtx == nil {
|
||||
reqCtx = &gin.Context{
|
||||
Request: &http.Request{},
|
||||
}
|
||||
}
|
||||
|
||||
cred, err := ex.backend.FetchCredential(ctx, ex.resourceName, reqCtx)
|
||||
cred, err := ex.backend.FetchCredential(ctx, ex.resourceName, ex.headers)
|
||||
assert.Equal(t, ex.err, err)
|
||||
assert.Equal(t, ex.cred, cred)
|
||||
})
|
||||
@@ -117,7 +109,7 @@ func startTestBackend(ctx context.Context, listenAddr string) {
|
||||
})
|
||||
|
||||
router.POST("/pass-header", func(c *gin.Context) {
|
||||
req := BackendRequest{}
|
||||
req := Request{}
|
||||
if err := c.BindJSON(&req); err != nil {
|
||||
panic(err)
|
||||
}
|
||||
@@ -0,0 +1,20 @@
|
||||
package connect
|
||||
|
||||
import "errors"
|
||||
|
||||
var (
|
||||
errBackendConnectError = errors.New("unable to connect to the auth backend")
|
||||
errConnStringRequired = errors.New("connection string is required")
|
||||
)
|
||||
|
||||
// Request holds the resource request details
|
||||
type Request struct {
|
||||
Resource string `json:"resource"`
|
||||
Token string `json:"token"`
|
||||
Headers map[string]string `json:"headers,omitempty"`
|
||||
}
|
||||
|
||||
// Credential holds the database connection string
|
||||
type Credential struct {
|
||||
DatabaseURL string `json:"database_url"`
|
||||
}
|
||||
@@ -178,7 +178,7 @@ func lookupPassword(opts command.Options, url *neturl.URL) string {
|
||||
|
||||
if url != nil {
|
||||
var dbName string
|
||||
fmt.Sscanf(url.Path, "/%s", &dbName)
|
||||
fmt.Sscanf(url.Path, "/%s", &dbName) //nolint
|
||||
|
||||
return passfile.FindPassword(
|
||||
url.Hostname(),
|
||||
|
||||
@@ -47,6 +47,9 @@ var (
|
||||
//go:embed sql/function.sql
|
||||
Function string
|
||||
|
||||
//go:embed sql/settings.sql
|
||||
Settings string
|
||||
|
||||
// Activity queries for specific PG versions
|
||||
Activity = map[string]string{
|
||||
"default": "SELECT * FROM pg_stat_activity WHERE datname = current_database()",
|
||||
|
||||
@@ -0,0 +1 @@
|
||||
SELECT * FROM pg_settings
|
||||
@@ -10,5 +10,6 @@ JOIN
|
||||
WHERE
|
||||
n.nspname = $1
|
||||
AND relname = $2
|
||||
AND contype != 'n'
|
||||
ORDER BY
|
||||
contype DESC
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
SELECT
|
||||
indexname AS index_name,
|
||||
pg_size_pretty(pg_table_size((schemaname || '.' || indexname)::regclass)) AS index_size,
|
||||
pg_size_pretty(pg_table_size(('"' || schemaname || '"."' || indexname || '"')::regclass)) AS index_size,
|
||||
indexdef AS index_definition
|
||||
FROM
|
||||
pg_indexes
|
||||
|
||||
+9
-2
@@ -189,14 +189,16 @@
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="connection-standard-group">
|
||||
<div class="connection-bookmarks-group">
|
||||
<div class="form-group bookmarks">
|
||||
<label class="col-sm-3 control-label">Bookmark</label>
|
||||
<div class="col-sm-9">
|
||||
<select class="form-control" id="connection_bookmarks"></select>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="connection-standard-group">
|
||||
<div class="form-group">
|
||||
<label class="col-sm-3 control-label">Host</label>
|
||||
<div class="col-sm-9">
|
||||
@@ -296,6 +298,7 @@
|
||||
<div id="tables_context_menu">
|
||||
<ul class="dropdown-menu" role="menu">
|
||||
<li><a href="#" data-action="copy">Copy Table Name</a></li>
|
||||
<li><a href="#" data-action="analyze">Analyze Table</a></li>
|
||||
<li class="divider"></li>
|
||||
<li><a href="#" data-action="export" data-format="json">Export to JSON</a></li>
|
||||
<li><a href="#" data-action="export" data-format="csv">Export to CSV</a></li>
|
||||
@@ -321,7 +324,11 @@
|
||||
</div>
|
||||
<div id="current_database_context_menu">
|
||||
<ul class="dropdown-menu" role="menu">
|
||||
<li><a href="#" data-action="show_tables_stats">Show Tables Stats</a></li>
|
||||
<li><a href="#" data-action="show_db_stats">Show Database Stats</a></li>
|
||||
<li><a href="#" data-action="download_db_stats">Download Database Stats</a></li>
|
||||
<li class="divider"></li>
|
||||
<li><a href="#" data-action="server_settings">Show Server Settings</a></li>
|
||||
<li class="divider"></li>
|
||||
<li><a href="#" data-action="export">Export SQL dump</a></li>
|
||||
</ul>
|
||||
</div>
|
||||
|
||||
+69
-9
@@ -85,13 +85,21 @@ function apiCall(method, path, params, cb) {
|
||||
return cb({ error: "Query timeout after " + timeout + "s" });
|
||||
}
|
||||
|
||||
cb(jQuery.parseJSON(xhr.responseText));
|
||||
var responseText;
|
||||
try {
|
||||
responseText = jQuery.parseJSON(xhr.responseText);
|
||||
}
|
||||
catch {
|
||||
responseText = { error: "Failed to parse the JSON response." };
|
||||
}
|
||||
cb(responseText);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
function getInfo(cb) { apiCall("get", "/info", {}, cb); }
|
||||
function getConnection(cb) { apiCall("get", "/connection", {}, cb); }
|
||||
function getServerSettings(cb) { apiCall("get", "/server_settings", {}, cb); }
|
||||
function getSchemas(cb) { apiCall("get", "/schemas", {}, cb); }
|
||||
function getObjects(cb) { apiCall("get", "/objects", {}, cb); }
|
||||
function getTables(cb) { apiCall("get", "/tables", {}, cb); }
|
||||
@@ -333,6 +341,12 @@ function performTableAction(table, action, el) {
|
||||
case "copy":
|
||||
copyToClipboard(table.split('.')[1]);
|
||||
break;
|
||||
case "analyze":
|
||||
executeQuery("ANALYZE " + table, function(data) {
|
||||
if (data.error) alert(data.error);
|
||||
resetTable();
|
||||
});
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -417,7 +431,11 @@ function buildTable(results, sortColumn, sortOrder, options) {
|
||||
if (results.rows.length == 0) {
|
||||
$("#results_header").html("");
|
||||
$("#results_body").html("<tr><td>No records found</td></tr>");
|
||||
$("#result-rows-count").html("");
|
||||
if (results.stats) {
|
||||
$("#result-rows-count").html(results.stats.query_duration_ms + " ms");
|
||||
} else {
|
||||
$("#result-rows-count").html("");
|
||||
}
|
||||
$("#results").addClass("empty");
|
||||
return;
|
||||
}
|
||||
@@ -427,9 +445,8 @@ function buildTable(results, sortColumn, sortOrder, options) {
|
||||
|
||||
results.columns.forEach(function(col) {
|
||||
if (col === sortColumn) {
|
||||
cols += "<th class='table-header-col active' data-name='" + col + "'" + "data-order=" + sortOrder + ">" + col + " " + sortArrow(sortOrder) + "</th>";
|
||||
}
|
||||
else {
|
||||
cols += "<th class='table-header-col active' data-name='" + col + "' data-order=" + sortOrder + ">" + col + " " + sortArrow(sortOrder) + "</th>";
|
||||
} else {
|
||||
cols += "<th class='table-header-col' data-name='" + col + "'>" + col + "</th>";
|
||||
}
|
||||
});
|
||||
@@ -647,7 +664,7 @@ function showPaginatedTableContent() {
|
||||
showTableContent(sortColumn, sortOrder);
|
||||
}
|
||||
|
||||
function showTablesStats() {
|
||||
function showDatabaseStats() {
|
||||
getTablesStats(function(data) {
|
||||
buildTable(data);
|
||||
|
||||
@@ -658,6 +675,21 @@ function showTablesStats() {
|
||||
});
|
||||
}
|
||||
|
||||
function downloadDatabaseStats() {
|
||||
openInNewWindow("api/tables_stats", { format: "csv", export: "true" });
|
||||
}
|
||||
|
||||
function showServerSettings() {
|
||||
getServerSettings(function(data) {
|
||||
buildTable(data);
|
||||
|
||||
setCurrentTab("table_content");
|
||||
$("#input").hide();
|
||||
$("#body").prop("class", "full");
|
||||
$("#results").addClass("no-crop");
|
||||
});
|
||||
}
|
||||
|
||||
function showTableStructure() {
|
||||
var name = getCurrentObject().name;
|
||||
|
||||
@@ -1084,6 +1116,7 @@ function showConnectionSettings() {
|
||||
// Show the current postgres version
|
||||
$(".connection-settings .version").text("v" + appInfo.version).show();
|
||||
$("#connection_window").show();
|
||||
initConnectionWindow();
|
||||
|
||||
// Check github release page for updates
|
||||
getLatestReleaseInfo(appInfo);
|
||||
@@ -1112,11 +1145,32 @@ function showConnectionSettings() {
|
||||
$(".bookmarks").show();
|
||||
}
|
||||
else {
|
||||
$(".bookmarks").hide();
|
||||
if (appFeatures.bookmarks_only) {
|
||||
$("#connection_error").html("Running in <b>bookmarks-only</b> mode but <b>NO</b> bookmarks configured.").show();
|
||||
$(".open-connection").hide();
|
||||
} else {
|
||||
$(".bookmarks").hide();
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
function initConnectionWindow() {
|
||||
if (appFeatures.bookmarks_only) {
|
||||
$(".connection-group-switch").hide();
|
||||
$(".connection-scheme-group").hide();
|
||||
$(".connection-bookmarks-group").show();
|
||||
$(".connection-standard-group").hide();
|
||||
$(".connection-ssh-group").hide();
|
||||
} else {
|
||||
$(".connection-group-switch").show();
|
||||
$(".connection-scheme-group").hide();
|
||||
$(".connection-bookmarks-group").show();
|
||||
$(".connection-standard-group").show();
|
||||
$(".connection-ssh-group").hide();
|
||||
}
|
||||
}
|
||||
|
||||
function getConnectionString() {
|
||||
var url = $.trim($("#connection_url").val());
|
||||
var mode = $(".connection-group-switch button.active").attr("data");
|
||||
@@ -1232,8 +1286,14 @@ function bindCurrentDatabaseMenu() {
|
||||
var menuItem = $(e.target);
|
||||
|
||||
switch(menuItem.data("action")) {
|
||||
case "show_tables_stats":
|
||||
showTablesStats();
|
||||
case "show_db_stats":
|
||||
showDatabaseStats();
|
||||
break;
|
||||
case "download_db_stats":
|
||||
downloadDatabaseStats();
|
||||
break;
|
||||
case "server_settings":
|
||||
showServerSettings();
|
||||
break;
|
||||
case "export":
|
||||
openInNewWindow("api/export");
|
||||
|
||||
Reference in New Issue
Block a user