commit 8b71ec2e3ff92084c05e0f7589b2a92d7a643326 Author: LittleSheep Date: Fri May 17 15:59:51 2024 +0800 :tada: Initial Commit diff --git a/.air.toml b/.air.toml new file mode 100644 index 0000000..c3d0898 --- /dev/null +++ b/.air.toml @@ -0,0 +1,46 @@ +root = "." +testdata_dir = "testdata" +tmp_dir = "dist" + +[build] + args_bin = [] + bin = "./dist/server" + cmd = "go build -o ./dist/server ./pkg/cmd/main.go" + delay = 1000 + exclude_dir = ["assets", "tmp", "vendor", "testdata", "pkg/views"] + exclude_file = [] + exclude_regex = ["_test.go"] + exclude_unchanged = false + follow_symlink = false + full_bin = "" + include_dir = [] + include_ext = ["go", "tpl", "tmpl", "html"] + include_file = [] + kill_delay = "0s" + log = "build-errors.log" + poll = false + poll_interval = 0 + post_cmd = [] + pre_cmd = [] + rerun = false + rerun_delay = 500 + send_interrupt = false + stop_on_error = false + +[color] + app = "" + build = "yellow" + main = "magenta" + runner = "green" + watcher = "cyan" + +[log] + main_only = false + time = false + +[misc] + clean_on_exit = false + +[screen] + clear_on_rebuild = false + keep_scroll = true diff --git a/.github/workflows/nightly.yml b/.github/workflows/nightly.yml new file mode 100644 index 0000000..d88d757 --- /dev/null +++ b/.github/workflows/nightly.yml @@ -0,0 +1,28 @@ +name: release-nightly + +on: + push: + branches: [master] + +jobs: + build-docker: + runs-on: ubuntu-latest + steps: + - name: Checkout + uses: actions/checkout@v4 + - name: Set up QEMU + uses: docker/setup-qemu-action@v3 + - name: Set up Docker Buildx + uses: docker/setup-buildx-action@v3 + - name: Login to Docker Hub + uses: docker/login-action@v3 + with: + username: ${{ secrets.DOCKER_REGISTRY_USERNAME }} + password: ${{ secrets.DOCKER_REGISTRY_TOKEN }} + - name: Build and push + uses: docker/build-push-action@v5 + with: + context: . + file: ./Dockerfile + push: true + tags: xsheep2010/paperclip:nightly diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..b9bcb4e --- /dev/null +++ b/.gitignore @@ -0,0 +1,4 @@ +/uploads +/dist + +.DS_Store diff --git a/.idea/.gitignore b/.idea/.gitignore new file mode 100644 index 0000000..35410ca --- /dev/null +++ b/.idea/.gitignore @@ -0,0 +1,8 @@ +# 默认忽略的文件 +/shelf/ +/workspace.xml +# 基于编辑器的 HTTP 客户端请求 +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/.idea/Interactive.iml b/.idea/Interactive.iml new file mode 100644 index 0000000..5e764c4 --- /dev/null +++ b/.idea/Interactive.iml @@ -0,0 +1,9 @@ + + + + + + + + + \ No newline at end of file diff --git a/.idea/dataSources.xml b/.idea/dataSources.xml new file mode 100644 index 0000000..dfd9603 --- /dev/null +++ b/.idea/dataSources.xml @@ -0,0 +1,12 @@ + + + + + postgresql + true + org.postgresql.Driver + jdbc:postgresql://localhost:5432/hy_paperclip + $ProjectFileDir$ + + + \ No newline at end of file diff --git a/.idea/inspectionProfiles/Project_Default.xml b/.idea/inspectionProfiles/Project_Default.xml new file mode 100644 index 0000000..03d9549 --- /dev/null +++ b/.idea/inspectionProfiles/Project_Default.xml @@ -0,0 +1,6 @@ + + + + \ No newline at end of file diff --git a/.idea/modules.xml b/.idea/modules.xml new file mode 100644 index 0000000..76b5056 --- /dev/null +++ b/.idea/modules.xml @@ -0,0 +1,8 @@ + + + + + + + + \ No newline at end of file diff --git a/.idea/vcs.xml b/.idea/vcs.xml new file mode 100644 index 0000000..35eb1dd --- /dev/null +++ b/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/Dockerfile b/Dockerfile new file mode 100644 index 0000000..9fb6309 --- /dev/null +++ b/Dockerfile @@ -0,0 +1,17 @@ +# Building Backend +FROM golang:alpine as paperclip-server + +RUN apk add nodejs npm + +WORKDIR /source +COPY . . +RUN CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -buildvcs -o /dist ./pkg/cmd/main.go + +# Runtime +FROM golang:alpine + +COPY --from=paperclip-server /dist /paperclip/server + +EXPOSE 8445 + +CMD ["/paperclip/server"] diff --git a/README.md b/README.md new file mode 100644 index 0000000..f09d89d --- /dev/null +++ b/README.md @@ -0,0 +1,11 @@ +# Hydrogen.Paperclip + +Paperclip is the unified attachment service for all hydrogen services. +It contains file metadata compute, instant upload, calculating hashing, multi destination, media info and more features! + +## Features + +### Supported Destinations + +- Local filesystem +- S3 compilable bucket \ No newline at end of file diff --git a/go.mod b/go.mod new file mode 100644 index 0000000..4c8b3c1 --- /dev/null +++ b/go.mod @@ -0,0 +1,78 @@ +module git.solsynth.dev/hydrogen/paperclip + +go 1.21.6 + +require ( + git.solsynth.dev/hydrogen/passport v0.0.0-20240504085931-7c418a3cd32f + github.com/go-playground/validator/v10 v10.17.0 + github.com/gofiber/fiber/v2 v2.52.4 + github.com/golang-jwt/jwt/v5 v5.2.0 + github.com/google/uuid v1.6.0 + github.com/json-iterator/go v1.1.12 + github.com/minio/minio-go/v7 v7.0.70 + github.com/robfig/cron/v3 v3.0.1 + github.com/rs/zerolog v1.31.0 + github.com/samber/lo v1.39.0 + github.com/spf13/viper v1.18.2 + google.golang.org/grpc v1.61.1 + gorm.io/datatypes v1.2.0 + gorm.io/driver/postgres v1.5.4 + gorm.io/gorm v1.25.6 +) + +require ( + github.com/andybalholm/brotli v1.1.0 // indirect + github.com/dustin/go-humanize v1.0.1 // indirect + github.com/fsnotify/fsnotify v1.7.0 // indirect + github.com/gabriel-vasile/mimetype v1.4.2 // indirect + github.com/go-playground/locales v0.14.1 // indirect + github.com/go-playground/universal-translator v0.18.1 // indirect + github.com/go-sql-driver/mysql v1.7.1 // indirect + github.com/goccy/go-json v0.10.2 // indirect + github.com/golang/protobuf v1.5.3 // indirect + github.com/hashicorp/hcl v1.0.0 // indirect + github.com/jackc/pgpassfile v1.0.0 // indirect + github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9 // indirect + github.com/jackc/pgx/v5 v5.5.1 // indirect + github.com/jackc/puddle/v2 v2.2.1 // indirect + github.com/jinzhu/inflection v1.0.0 // indirect + github.com/jinzhu/now v1.1.5 // indirect + github.com/klauspost/compress v1.17.8 // indirect + github.com/klauspost/cpuid/v2 v2.2.7 // indirect + github.com/leodido/go-urn v1.2.4 // indirect + github.com/magiconair/properties v1.8.7 // indirect + github.com/mattn/go-colorable v0.1.13 // indirect + github.com/mattn/go-isatty v0.0.20 // indirect + github.com/mattn/go-runewidth v0.0.15 // indirect + github.com/minio/md5-simd v1.1.2 // indirect + github.com/mitchellh/mapstructure v1.5.0 // 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.1.1 // indirect + github.com/philhofer/fwd v1.1.2 // indirect + github.com/rivo/uniseg v0.4.7 // indirect + github.com/rs/xid v1.5.0 // indirect + github.com/sagikazarmark/locafero v0.4.0 // indirect + github.com/sagikazarmark/slog-shim v0.1.0 // indirect + github.com/sourcegraph/conc v0.3.0 // indirect + github.com/spf13/afero v1.11.0 // indirect + github.com/spf13/cast v1.6.0 // indirect + github.com/spf13/pflag v1.0.5 // indirect + github.com/subosito/gotenv v1.6.0 // indirect + github.com/tinylib/msgp v1.1.8 // indirect + github.com/valyala/bytebufferpool v1.0.0 // indirect + github.com/valyala/fasthttp v1.52.0 // indirect + github.com/valyala/tcplisten v1.0.0 // indirect + go.uber.org/multierr v1.11.0 // indirect + golang.org/x/crypto v0.23.0 // indirect + golang.org/x/exp v0.0.0-20231219180239-dc181d75b848 // indirect + golang.org/x/net v0.25.0 // indirect + golang.org/x/sync v0.6.0 // indirect + golang.org/x/sys v0.20.0 // indirect + golang.org/x/text v0.15.0 // indirect + google.golang.org/genproto/googleapis/rpc v0.0.0-20240221002015-b0ce06bbee7c // indirect + google.golang.org/protobuf v1.32.0 // indirect + gopkg.in/ini.v1 v1.67.0 // indirect + gopkg.in/yaml.v3 v3.0.1 // indirect + gorm.io/driver/mysql v1.5.2 // indirect +) diff --git a/go.sum b/go.sum new file mode 100644 index 0000000..9200ed3 --- /dev/null +++ b/go.sum @@ -0,0 +1,233 @@ +git.solsynth.dev/hydrogen/passport v0.0.0-20240504085931-7c418a3cd32f h1:sKrQrKZc5C+dwefRsnc0uAGttzpSUWXUBoFaCXLkaTo= +git.solsynth.dev/hydrogen/passport v0.0.0-20240504085931-7c418a3cd32f/go.mod h1:3JRFPtf0dXRk2UQ1yVIgIspNfytM2yLBeBePJChgLZE= +github.com/andybalholm/brotli v1.1.0 h1:eLKJA0d02Lf0mVpIDgYnqXcUn0GqVmEFny3VuID1U3M= +github.com/andybalholm/brotli v1.1.0/go.mod h1:sms7XGricyQI9K10gOSf56VKKWS4oLer58Q+mhRPtnY= +github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc= +github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM= +github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY= +github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto= +github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8= +github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0= +github.com/fsnotify/fsnotify v1.7.0 h1:8JEhPFa5W2WU7YfeZzPNqzMP6Lwt7L2715Ggo0nosvA= +github.com/fsnotify/fsnotify v1.7.0/go.mod h1:40Bi/Hjc2AVfZrqy+aj+yEI+/bRxZnMJyTJwOpGvigM= +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/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.17.0 h1:SmVVlfAOtlZncTxRuinDPomC2DkXJ4E5T9gDA0AIH74= +github.com/go-playground/validator/v10 v10.17.0/go.mod h1:9iXMNT7sEkjXb0I+enO7QXmzG6QCsPWY4zveKFVRSyU= +github.com/go-sql-driver/mysql v1.7.0/go.mod h1:OXbVy3sEdcQ2Doequ6Z5BW6fXNQTmx+9S1MCJN5yJMI= +github.com/go-sql-driver/mysql v1.7.1 h1:lUIinVbN1DY0xBg0eMOzmmtGoHwWBbvnWubQUrtU8EI= +github.com/go-sql-driver/mysql v1.7.1/go.mod h1:OXbVy3sEdcQ2Doequ6Z5BW6fXNQTmx+9S1MCJN5yJMI= +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/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA= +github.com/gofiber/fiber/v2 v2.52.4 h1:P+T+4iK7VaqUsq2PALYEfBBo6bJZ4q3FP8cZ84EggTM= +github.com/gofiber/fiber/v2 v2.52.4/go.mod h1:KEOE+cXMhXG0zHc9d8+E38hoX+ZN7bhOtgeF2oT6jrQ= +github.com/golang-jwt/jwt/v5 v5.2.0 h1:d/ix8ftRUorsN+5eMIlF4T6J8CAt9rch3My2winC1Jw= +github.com/golang-jwt/jwt/v5 v5.2.0/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk= +github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA= +github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0= +github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A= +github.com/golang-sql/sqlexp v0.1.0/go.mod h1:J4ad9Vo8ZCWQ2GMrC4UCQy1JpCbwU9m3EOqtpKwwwHI= +github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= +github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg= +github.com/golang/protobuf v1.5.3/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.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI= +github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= +github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= +github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= +github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/hashicorp/hcl v1.0.0 h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4= +github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ= +github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM= +github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg= +github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9 h1:L0QtFUgDarD7Fpv9jeVMgy/+Ec0mtnmYuImjTz6dtDA= +github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM= +github.com/jackc/pgx/v5 v5.5.1 h1:5I9etrGkLrN+2XPCsi6XLlV5DITbSL/xBZdmAxFcXPI= +github.com/jackc/pgx/v5 v5.5.1/go.mod h1:Ig06C2Vu0t5qXC60W8sqIthScaEnFvojjj9dSljmHRA= +github.com/jackc/puddle/v2 v2.2.1 h1:RhxXJtFG022u4ibrCSMSiu5aOq1i77R3OHKNJj77OAk= +github.com/jackc/puddle/v2 v2.2.1/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4= +github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E= +github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc= +github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ= +github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8= +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/compress v1.17.8 h1:YcnTYrq7MikUT7k0Yb5eceMmALQPYBW/Xltxn0NAMnU= +github.com/klauspost/compress v1.17.8/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw= +github.com/klauspost/cpuid/v2 v2.0.1/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg= +github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM= +github.com/klauspost/cpuid/v2 v2.2.7/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZYpaMropDUws= +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/magiconair/properties v1.8.7 h1:IeQXZAiQcpL9mgcAe1Nu6cX9LLw6ExEHKjN0VQdvPDY= +github.com/magiconair/properties v1.8.7/go.mod h1:Dhd985XPs7jluiymwWYZ0G4Z61jb3vdS329zhj2hYo0= +github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA= +github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg= +github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM= +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-runewidth v0.0.15 h1:UNAjwbU9l54TA3KzvqLGxwWjHmMgBUVhBiTjelZgg3U= +github.com/mattn/go-runewidth v0.0.15/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w= +github.com/mattn/go-sqlite3 v1.14.15 h1:vfoHhTN1af61xCRSWzFIWzx2YskyMTwHLrExkBOjvxI= +github.com/mattn/go-sqlite3 v1.14.15/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg= +github.com/microsoft/go-mssqldb v0.17.0 h1:Fto83dMZPnYv1Zwx5vHHxpNraeEaUlQ/hhHLgZiaenE= +github.com/microsoft/go-mssqldb v0.17.0/go.mod h1:OkoNGhGEs8EZqchVTtochlXruEhEOaO4S0d2sB5aeGQ= +github.com/minio/md5-simd v1.1.2 h1:Gdi1DZK69+ZVMoNHRXJyNcxrMA4dSxoYHZSQbirFg34= +github.com/minio/md5-simd v1.1.2/go.mod h1:MzdKDxYpY2BT9XQFocsiZf/NKVtR7nkE4RoEpN+20RM= +github.com/minio/minio-go/v7 v7.0.70 h1:1u9NtMgfK1U42kUxcsl5v0yj6TEOPR497OAQxpJnn2g= +github.com/minio/minio-go/v7 v7.0.70/go.mod h1:4yBA8v80xGA30cfM3fz0DKYMXunWl/AV/6tWEs9ryzo= +github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY= +github.com/mitchellh/mapstructure v1.5.0/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo= +github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= +github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= +github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= +github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M= +github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk= +github.com/pelletier/go-toml/v2 v2.1.1 h1:LWAJwfNvjQZCFIDKWYQaM62NcYeYViCmWIwmOStowAI= +github.com/pelletier/go-toml/v2 v2.1.1/go.mod h1:tJU2Z3ZkXwnxa4DPO899bsyIoywizdUvyaeZurnPPDc= +github.com/philhofer/fwd v1.1.2 h1:bnDivRJ1EWPjUIRXV5KfORO897HTbpFAQddBdE8t7Gw= +github.com/philhofer/fwd v1.1.2/go.mod h1:qkPdfjR2SIEbspLqpe1tO4n5yICnr2DY7mqEx2tUTP0= +github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U= +github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc= +github.com/rivo/uniseg v0.4.7 h1:WUdvkW8uEhrYfLC4ZzdpI2ztxP1I582+49Oc5Mq64VQ= +github.com/rivo/uniseg v0.4.7/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88= +github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs= +github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro= +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/rs/xid v1.5.0 h1:mKX4bl4iPYJtEIxp6CYiUuLQ/8DYMoz0PUdtGgMFRVc= +github.com/rs/xid v1.5.0/go.mod h1:trrq9SKmegXys3aeAKXMUTdJsYXVwGY3RLcfgqegfbg= +github.com/rs/zerolog v1.31.0 h1:FcTR3NnLWW+NnTwwhFWiJSZr4ECLpqCm6QsEnyvbV4A= +github.com/rs/zerolog v1.31.0/go.mod h1:/7mN4D5sKwJLZQ2b/znpjC3/GQWY/xaDXUM0kKWRHss= +github.com/sagikazarmark/locafero v0.4.0 h1:HApY1R9zGo4DBgr7dqsTH/JJxLTTsOt7u6keLGt6kNQ= +github.com/sagikazarmark/locafero v0.4.0/go.mod h1:Pe1W6UlPYUk/+wc/6KFhbORCfqzgYEpgQ3O5fPuL3H4= +github.com/sagikazarmark/slog-shim v0.1.0 h1:diDBnUNK9N/354PgrxMywXnAwEr1QZcOr6gto+ugjYE= +github.com/sagikazarmark/slog-shim v0.1.0/go.mod h1:SrcSrq8aKtyuqEI1uvTDTK1arOWRIczQRv+GVI1AkeQ= +github.com/samber/lo v1.39.0 h1:4gTz1wUhNYLhFSKl6O+8peW0v2F4BCY034GRpU9WnuA= +github.com/samber/lo v1.39.0/go.mod h1:+m/ZKRl6ClXCE2Lgf3MsQlWfh4bn1bz6CXEOxnEXnEA= +github.com/sourcegraph/conc v0.3.0 h1:OQTbbt6P72L20UqAkXXuLOj79LfEanQ+YQFNpLA9ySo= +github.com/sourcegraph/conc v0.3.0/go.mod h1:Sdozi7LEKbFPqYX2/J+iBAM6HpqSLTASQIKqDmF7Mt0= +github.com/spf13/afero v1.11.0 h1:WJQKhtpdm3v2IzqG8VMqrr6Rf3UYpEF239Jy9wNepM8= +github.com/spf13/afero v1.11.0/go.mod h1:GH9Y3pIexgf1MTIWtNGyogA5MwRIDXGUr+hbWNoBjkY= +github.com/spf13/cast v1.6.0 h1:GEiTHELF+vaR5dhz3VqZfFSzZjYbgeKDpBxQVS4GYJ0= +github.com/spf13/cast v1.6.0/go.mod h1:ancEpBxwJDODSW/UG4rDrAqiKolqNNh2DX3mk86cAdo= +github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA= +github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg= +github.com/spf13/viper v1.18.2 h1:LUXCnvUvSM6FXAsj6nnfc8Q2tp1dIgUfY9Kc8GsSOiQ= +github.com/spf13/viper v1.18.2/go.mod h1:EKmWIqdnk5lOcmR72yw6hS+8OPYcwD0jteitLMVB+yk= +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/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= +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.2/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= +github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk= +github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= +github.com/subosito/gotenv v1.6.0 h1:9NlTDc1FTs4qu0DDq7AEtTPNw6SVm7uBMsUCUjABIf8= +github.com/subosito/gotenv v1.6.0/go.mod h1:Dk4QP5c2W3ibzajGcXpNraDfq2IrhjMIvMSWPKKo0FU= +github.com/tinylib/msgp v1.1.8 h1:FCXC1xanKO4I8plpHGH2P7koL/RzZs12l/+r7vakfm0= +github.com/tinylib/msgp v1.1.8/go.mod h1:qkpG+2ldGg4xRFmx+jfTvZPxfGFhi64BcnL9vkCm/Tw= +github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6KllzawFIhcdPw= +github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc= +github.com/valyala/fasthttp v1.52.0 h1:wqBQpxH71XW0e2g+Og4dzQM8pk34aFYlA1Ga8db7gU0= +github.com/valyala/fasthttp v1.52.0/go.mod h1:hf5C4QnVMkNXMspnsUlfM3WitlgYflyhHYoKol/szxQ= +github.com/valyala/tcplisten v1.0.0 h1:rBHj/Xf+E1tRGZyWIWwJDiRY0zc1Js+CV5DqwacVSA8= +github.com/valyala/tcplisten v1.0.0/go.mod h1:T0xQ8SeCZGxckz9qRXTfG43PvQ/mcWh7FwZEA7Ioqkc= +github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= +go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0= +go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y= +golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= +golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= +golang.org/x/crypto v0.23.0 h1:dIJU/v2J8Mdglj/8rJ6UUOM3Zc9zLZxVZwwxMooUSAI= +golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8= +golang.org/x/exp v0.0.0-20231219180239-dc181d75b848 h1:+iq7lrkxmFNBM7xx+Rae2W6uyPfhPeDWD+n+JgppptE= +golang.org/x/exp v0.0.0-20231219180239-dc181d75b848/go.mod h1:iRJReGqOEeBhDZGkGbynYwcHlctCvnjTYIamk7uXpHI= +golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= +golang.org/x/mod v0.7.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs= +golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= +golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= +golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= +golang.org/x/net v0.3.0/go.mod h1:MBQ8lrhLObU/6UmLb4fmbmk5OcyYmqtbGd/9yIeKjEE= +golang.org/x/net v0.25.0 h1:d/OCCoBEUq33pjydKrGQhw7IlUPI2Oylr+8qLx49kac= +golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM= +golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.6.0 h1:5BMeUDZ7vkXGfEr1x9B4bRcTH4lpkTkpdh0T/J+qjbQ= +golang.org/x/sync v0.6.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= +golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.3.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.20.0 h1:Od9JTbYCk261bKm4M/mw7AklTlFYIa0bIp9BgSm1S8Y= +golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= +golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= +golang.org/x/term v0.3.0/go.mod h1:q750SLmJuPmVoN1blW3UFBPREJfb1KmY3vwxfr+nFDA= +golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= +golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= +golang.org/x/text v0.5.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= +golang.org/x/text v0.15.0 h1:h1V/4gjBv8v9cjcR6+AR5+/cIYK5N/WAgiv4xlsEtAk= +golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= +golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= +golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc= +golang.org/x/tools v0.4.0/go.mod h1:UE5sM2OK9E/d67R0ANs2xJizIymRP5gJU295PvKXxjQ= +golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240221002015-b0ce06bbee7c h1:NUsgEN92SQQqzfA+YtqYNqYmB3DMMYLlIwUZAQFVFbo= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240221002015-b0ce06bbee7c/go.mod h1:H4O17MA/PE9BsGx3w+a+W2VOLLD1Qf7oJneAoU6WktY= +google.golang.org/grpc v1.61.1 h1:kLAiWrZs7YeDM6MumDe7m3y4aM6wacLzM1Y/wiLP9XY= +google.golang.org/grpc v1.61.1/go.mod h1:VUbo7IFqmF1QtCAstipjG0GIoq49KvMe9+h1jFLBNJs= +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.32.0 h1:pPC6BG5ex8PDFnkbrGU3EixyhKcQ2aDuBS36lqK/C7I= +google.golang.org/protobuf v1.32.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos= +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/ini.v1 v1.67.0 h1:Dgnx+6+nfE+IfzjUEISNeydPJh9AXNNsWbGP9KzCsOA= +gopkg.in/ini.v1 v1.67.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= +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= +gorm.io/datatypes v1.2.0 h1:5YT+eokWdIxhJgWHdrb2zYUimyk0+TaFth+7a0ybzco= +gorm.io/datatypes v1.2.0/go.mod h1:o1dh0ZvjIjhH/bngTpypG6lVRJ5chTBxE09FH/71k04= +gorm.io/driver/mysql v1.5.2 h1:QC2HRskSE75wBuOxe0+iCkyJZ+RqpudsQtqkp+IMuXs= +gorm.io/driver/mysql v1.5.2/go.mod h1:pQLhh1Ut/WUAySdTHwBpBv6+JKcj+ua4ZFx1QQTBzb8= +gorm.io/driver/postgres v1.5.4 h1:Iyrp9Meh3GmbSuyIAGyjkN+n9K+GHX9b9MqsTL4EJCo= +gorm.io/driver/postgres v1.5.4/go.mod h1:Bgo89+h0CRcdA33Y6frlaHHVuTdOf87pmyzwW9C/BH0= +gorm.io/driver/sqlite v1.4.3 h1:HBBcZSDnWi5BW3B3rwvVTc510KGkBkexlOg0QrmLUuU= +gorm.io/driver/sqlite v1.4.3/go.mod h1:0Aq3iPO+v9ZKbcdiz8gLWRw5VOPcBOPUQJFLq5e2ecI= +gorm.io/driver/sqlserver v1.4.1 h1:t4r4r6Jam5E6ejqP7N82qAJIJAht27EGT41HyPfXRw0= +gorm.io/driver/sqlserver v1.4.1/go.mod h1:DJ4P+MeZbc5rvY58PnmN1Lnyvb5gw5NPzGshHDnJLig= +gorm.io/gorm v1.25.2-0.20230530020048-26663ab9bf55/go.mod h1:L4uxeKpfBml98NYqVqwAdmV1a2nBtAec/cf3fpucW/k= +gorm.io/gorm v1.25.6 h1:V92+vVda1wEISSOMtodHVRcUIOPYa2tgQtyF+DfFx+A= +gorm.io/gorm v1.25.6/go.mod h1:hbnx/Oo0ChWMn1BIhpy1oYozzpM15i4YPuHDmfYtwg8= diff --git a/license b/license new file mode 100644 index 0000000..266647c --- /dev/null +++ b/license @@ -0,0 +1,661 @@ + GNU AFFERO GENERAL PUBLIC LICENSE + Version 3, 19 November 2007 + + Copyright (C) 2007 Free Software Foundation, Inc. + Everyone is permitted to copy and distribute verbatim copies + of this license document, but changing it is not allowed. + + Preamble + + The GNU Affero General Public License is a free, copyleft license for +software and other kinds of works, specifically designed to ensure +cooperation with the community in the case of network server software. + + The licenses for most software and other practical works are designed +to take away your freedom to share and change the works. By contrast, +our General Public Licenses are intended to guarantee your freedom to +share and change all versions of a program--to make sure it remains free +software for all its users. + + When we speak of free software, we are referring to freedom, not +price. Our General Public Licenses are designed to make sure that you +have the freedom to distribute copies of free software (and charge for +them if you wish), that you receive source code or can get it if you +want it, that you can change the software or use pieces of it in new +free programs, and that you know you can do these things. + + Developers that use our General Public Licenses protect your rights +with two steps: (1) assert copyright on the software, and (2) offer +you this License which gives you legal permission to copy, distribute +and/or modify the software. + + A secondary benefit of defending all users' freedom is that +improvements made in alternate versions of the program, if they +receive widespread use, become available for other developers to +incorporate. Many developers of free software are heartened and +encouraged by the resulting cooperation. However, in the case of +software used on network servers, this result may fail to come about. +The GNU General Public License permits making a modified version and +letting the public access it on a server without ever releasing its +source code to the public. + + The GNU Affero General Public License is designed specifically to +ensure that, in such cases, the modified source code becomes available +to the community. It requires the operator of a network server to +provide the source code of the modified version running there to the +users of that server. Therefore, public use of a modified version, on +a publicly accessible server, gives the public access to the source +code of the modified version. + + An older license, called the Affero General Public License and +published by Affero, was designed to accomplish similar goals. This is +a different license, not a version of the Affero GPL, but Affero has +released a new version of the Affero GPL which permits relicensing under +this license. + + The precise terms and conditions for copying, distribution and +modification follow. + + TERMS AND CONDITIONS + + 0. Definitions. + + "This License" refers to version 3 of the GNU Affero General Public License. + + "Copyright" also means copyright-like laws that apply to other kinds of +works, such as semiconductor masks. + + "The Program" refers to any copyrightable work licensed under this +License. Each licensee is addressed as "you". "Licensees" and +"recipients" may be individuals or organizations. + + To "modify" a work means to copy from or adapt all or part of the work +in a fashion requiring copyright permission, other than the making of an +exact copy. The resulting work is called a "modified version" of the +earlier work or a work "based on" the earlier work. + + A "covered work" means either the unmodified Program or a work based +on the Program. + + To "propagate" a work means to do anything with it that, without +permission, would make you directly or secondarily liable for +infringement under applicable copyright law, except executing it on a +computer or modifying a private copy. Propagation includes copying, +distribution (with or without modification), making available to the +public, and in some countries other activities as well. + + To "convey" a work means any kind of propagation that enables other +parties to make or receive copies. Mere interaction with a user through +a computer network, with no transfer of a copy, is not conveying. + + An paperclip user interface displays "Appropriate Legal Notices" +to the extent that it includes a convenient and prominently visible +feature that (1) displays an appropriate copyright notice, and (2) +tells the user that there is no warranty for the work (except to the +extent that warranties are provided), that licensees may convey the +work under this License, and how to view a copy of this License. If +the interface presents a list of user commands or options, such as a +menu, a prominent item in the list meets this criterion. + + 1. Source Code. + + The "source code" for a work means the preferred form of the work +for making modifications to it. "Object code" means any non-source +form of a work. + + A "Standard Interface" means an interface that either is an official +standard defined by a recognized standards body, or, in the case of +interfaces specified for a particular programming language, one that +is widely used among developers working in that language. + + The "System Libraries" of an executable work include anything, other +than the work as a whole, that (a) is included in the normal form of +packaging a Major Component, but which is not part of that Major +Component, and (b) serves only to enable use of the work with that +Major Component, or to implement a Standard Interface for which an +implementation is available to the public in source code form. A +"Major Component", in this context, means a major essential component +(kernel, window system, and so on) of the specific operating system +(if any) on which the executable work runs, or a compiler used to +produce the work, or an object code interpreter used to run it. + + The "Corresponding Source" for a work in object code form means all +the source code needed to generate, install, and (for an executable +work) run the object code and to modify the work, including scripts to +control those activities. However, it does not include the work's +System Libraries, or general-purpose tools or generally available free +programs which are used unmodified in performing those activities but +which are not part of the work. For example, Corresponding Source +includes interface definition files associated with source files for +the work, and the source code for shared libraries and dynamically +linked subprograms that the work is specifically designed to require, +such as by intimate data communication or control flow between those +subprograms and other parts of the work. + + The Corresponding Source need not include anything that users +can regenerate automatically from other parts of the Corresponding +Source. + + The Corresponding Source for a work in source code form is that +same work. + + 2. Basic Permissions. + + All rights granted under this License are granted for the term of +copyright on the Program, and are irrevocable provided the stated +conditions are met. This License explicitly affirms your unlimited +permission to run the unmodified Program. The output from running a +covered work is covered by this License only if the output, given its +content, constitutes a covered work. This License acknowledges your +rights of fair use or other equivalent, as provided by copyright law. + + You may make, run and propagate covered works that you do not +convey, without conditions so long as your license otherwise remains +in force. You may convey covered works to others for the sole purpose +of having them make modifications exclusively for you, or provide you +with facilities for running those works, provided that you comply with +the terms of this License in conveying all material for which you do +not control copyright. Those thus making or running the covered works +for you must do so exclusively on your behalf, under your direction +and control, on terms that prohibit them from making any copies of +your copyrighted material outside their relationship with you. + + Conveying under any other circumstances is permitted solely under +the conditions stated below. Sublicensing is not allowed; section 10 +makes it unnecessary. + + 3. Protecting Users' Legal Rights From Anti-Circumvention Law. + + No covered work shall be deemed part of an effective technological +measure under any applicable law fulfilling obligations under article +11 of the WIPO copyright treaty adopted on 20 December 1996, or +similar laws prohibiting or restricting circumvention of such +measures. + + When you convey a covered work, you waive any legal power to forbid +circumvention of technological measures to the extent such circumvention +is effected by exercising rights under this License with respect to +the covered work, and you disclaim any intention to limit operation or +modification of the work as a means of enforcing, against the work's +users, your or third parties' legal rights to forbid circumvention of +technological measures. + + 4. Conveying Verbatim Copies. + + You may convey verbatim copies of the Program's source code as you +receive it, in any medium, provided that you conspicuously and +appropriately publish on each copy an appropriate copyright notice; +keep intact all notices stating that this License and any +non-permissive terms added in accord with section 7 apply to the code; +keep intact all notices of the absence of any warranty; and give all +recipients a copy of this License along with the Program. + + You may charge any price or no price for each copy that you convey, +and you may offer support or warranty protection for a fee. + + 5. Conveying Modified Source Versions. + + You may convey a work based on the Program, or the modifications to +produce it from the Program, in the form of source code under the +terms of section 4, provided that you also meet all of these conditions: + + a) The work must carry prominent notices stating that you modified + it, and giving a relevant date. + + b) The work must carry prominent notices stating that it is + released under this License and any conditions added under section + 7. This requirement modifies the requirement in section 4 to + "keep intact all notices". + + c) You must license the entire work, as a whole, under this + License to anyone who comes into possession of a copy. This + License will therefore apply, along with any applicable section 7 + additional terms, to the whole of the work, and all its parts, + regardless of how they are packaged. This License gives no + permission to license the work in any other way, but it does not + invalidate such permission if you have separately received it. + + d) If the work has paperclip user interfaces, each must display + Appropriate Legal Notices; however, if the Program has paperclip + interfaces that do not display Appropriate Legal Notices, your + work need not make them do so. + + A compilation of a covered work with other separate and independent +works, which are not by their nature extensions of the covered work, +and which are not combined with it such as to form a larger program, +in or on a volume of a storage or distribution medium, is called an +"aggregate" if the compilation and its resulting copyright are not +used to limit the access or legal rights of the compilation's users +beyond what the individual works permit. Inclusion of a covered work +in an aggregate does not cause this License to apply to the other +parts of the aggregate. + + 6. Conveying Non-Source Forms. + + You may convey a covered work in object code form under the terms +of sections 4 and 5, provided that you also convey the +machine-readable Corresponding Source under the terms of this License, +in one of these ways: + + a) Convey the object code in, or embodied in, a physical product + (including a physical distribution medium), accompanied by the + Corresponding Source fixed on a durable physical medium + customarily used for software interchange. + + b) Convey the object code in, or embodied in, a physical product + (including a physical distribution medium), accompanied by a + written offer, valid for at least three years and valid for as + long as you offer spare parts or customer support for that product + model, to give anyone who possesses the object code either (1) a + copy of the Corresponding Source for all the software in the + product that is covered by this License, on a durable physical + medium customarily used for software interchange, for a price no + more than your reasonable cost of physically performing this + conveying of source, or (2) access to copy the + Corresponding Source from a network server at no charge. + + c) Convey individual copies of the object code with a copy of the + written offer to provide the Corresponding Source. This + alternative is allowed only occasionally and noncommercially, and + only if you received the object code with such an offer, in accord + with subsection 6b. + + d) Convey the object code by offering access from a designated + place (gratis or for a charge), and offer equivalent access to the + Corresponding Source in the same way through the same place at no + further charge. You need not require recipients to copy the + Corresponding Source along with the object code. If the place to + copy the object code is a network server, the Corresponding Source + may be on a different server (operated by you or a third party) + that supports equivalent copying facilities, provided you maintain + clear directions next to the object code saying where to find the + Corresponding Source. Regardless of what server hosts the + Corresponding Source, you remain obligated to ensure that it is + available for as long as needed to satisfy these requirements. + + e) Convey the object code using peer-to-peer transmission, provided + you inform other peers where the object code and Corresponding + Source of the work are being offered to the general public at no + charge under subsection 6d. + + A separable portion of the object code, whose source code is excluded +from the Corresponding Source as a System Library, need not be +included in conveying the object code work. + + A "User Product" is either (1) a "consumer product", which means any +tangible personal property which is normally used for personal, family, +or household purposes, or (2) anything designed or sold for incorporation +into a dwelling. In determining whether a product is a consumer product, +doubtful cases shall be resolved in favor of coverage. For a particular +product received by a particular user, "normally used" refers to a +typical or common use of that class of product, regardless of the status +of the particular user or of the way in which the particular user +actually uses, or expects or is expected to use, the product. A product +is a consumer product regardless of whether the product has substantial +commercial, industrial or non-consumer uses, unless such uses represent +the only significant mode of use of the product. + + "Installation Information" for a User Product means any methods, +procedures, authorization keys, or other information required to install +and execute modified versions of a covered work in that User Product from +a modified version of its Corresponding Source. The information must +suffice to ensure that the continued functioning of the modified object +code is in no case prevented or interfered with solely because +modification has been made. + + If you convey an object code work under this section in, or with, or +specifically for use in, a User Product, and the conveying occurs as +part of a transaction in which the right of possession and use of the +User Product is transferred to the recipient in perpetuity or for a +fixed term (regardless of how the transaction is characterized), the +Corresponding Source conveyed under this section must be accompanied +by the Installation Information. But this requirement does not apply +if neither you nor any third party retains the ability to install +modified object code on the User Product (for example, the work has +been installed in ROM). + + The requirement to provide Installation Information does not include a +requirement to continue to provide support service, warranty, or updates +for a work that has been modified or installed by the recipient, or for +the User Product in which it has been modified or installed. Access to a +network may be denied when the modification itself materially and +adversely affects the operation of the network or violates the rules and +protocols for communication across the network. + + Corresponding Source conveyed, and Installation Information provided, +in accord with this section must be in a format that is publicly +documented (and with an implementation available to the public in +source code form), and must require no special password or key for +unpacking, reading or copying. + + 7. Additional Terms. + + "Additional permissions" are terms that supplement the terms of this +License by making exceptions from one or more of its conditions. +Additional permissions that are applicable to the entire Program shall +be treated as though they were included in this License, to the extent +that they are valid under applicable law. If additional permissions +apply only to part of the Program, that part may be used separately +under those permissions, but the entire Program remains governed by +this License without regard to the additional permissions. + + When you convey a copy of a covered work, you may at your option +remove any additional permissions from that copy, or from any part of +it. (Additional permissions may be written to require their own +removal in certain cases when you modify the work.) You may place +additional permissions on material, added by you to a covered work, +for which you have or can give appropriate copyright permission. + + Notwithstanding any other provision of this License, for material you +add to a covered work, you may (if authorized by the copyright holders of +that material) supplement the terms of this License with terms: + + a) Disclaiming warranty or limiting liability differently from the + terms of sections 15 and 16 of this License; or + + b) Requiring preservation of specified reasonable legal notices or + author attributions in that material or in the Appropriate Legal + Notices displayed by works containing it; or + + c) Prohibiting misrepresentation of the origin of that material, or + requiring that modified versions of such material be marked in + reasonable ways as different from the original version; or + + d) Limiting the use for publicity purposes of names of licensors or + authors of the material; or + + e) Declining to grant rights under trademark law for use of some + trade names, trademarks, or service marks; or + + f) Requiring indemnification of licensors and authors of that + material by anyone who conveys the material (or modified versions of + it) with contractual assumptions of liability to the recipient, for + any liability that these contractual assumptions directly impose on + those licensors and authors. + + All other non-permissive additional terms are considered "further +restrictions" within the meaning of section 10. If the Program as you +received it, or any part of it, contains a notice stating that it is +governed by this License along with a term that is a further +restriction, you may remove that term. If a license document contains +a further restriction but permits relicensing or conveying under this +License, you may add to a covered work material governed by the terms +of that license document, provided that the further restriction does +not survive such relicensing or conveying. + + If you add terms to a covered work in accord with this section, you +must place, in the relevant source files, a statement of the +additional terms that apply to those files, or a notice indicating +where to find the applicable terms. + + Additional terms, permissive or non-permissive, may be stated in the +form of a separately written license, or stated as exceptions; +the above requirements apply either way. + + 8. Termination. + + You may not propagate or modify a covered work except as expressly +provided under this License. Any attempt otherwise to propagate or +modify it is void, and will automatically terminate your rights under +this License (including any patent licenses granted under the third +paragraph of section 11). + + However, if you cease all violation of this License, then your +license from a particular copyright holder is reinstated (a) +provisionally, unless and until the copyright holder explicitly and +finally terminates your license, and (b) permanently, if the copyright +holder fails to notify you of the violation by some reasonable means +prior to 60 days after the cessation. + + Moreover, your license from a particular copyright holder is +reinstated permanently if the copyright holder notifies you of the +violation by some reasonable means, this is the first time you have +received notice of violation of this License (for any work) from that +copyright holder, and you cure the violation prior to 30 days after +your receipt of the notice. + + Termination of your rights under this section does not terminate the +licenses of parties who have received copies or rights from you under +this License. If your rights have been terminated and not permanently +reinstated, you do not qualify to receive new licenses for the same +material under section 10. + + 9. Acceptance Not Required for Having Copies. + + You are not required to accept this License in order to receive or +run a copy of the Program. Ancillary propagation of a covered work +occurring solely as a consequence of using peer-to-peer transmission +to receive a copy likewise does not require acceptance. However, +nothing other than this License grants you permission to propagate or +modify any covered work. These actions infringe copyright if you do +not accept this License. Therefore, by modifying or propagating a +covered work, you indicate your acceptance of this License to do so. + + 10. Automatic Licensing of Downstream Recipients. + + Each time you convey a covered work, the recipient automatically +receives a license from the original licensors, to run, modify and +propagate that work, subject to this License. You are not responsible +for enforcing compliance by third parties with this License. + + An "entity transaction" is a transaction transferring control of an +organization, or substantially all assets of one, or subdividing an +organization, or merging organizations. If propagation of a covered +work results from an entity transaction, each party to that +transaction who receives a copy of the work also receives whatever +licenses to the work the party's predecessor in interest had or could +give under the previous paragraph, plus a right to possession of the +Corresponding Source of the work from the predecessor in interest, if +the predecessor has it or can get it with reasonable efforts. + + You may not impose any further restrictions on the exercise of the +rights granted or affirmed under this License. For example, you may +not impose a license fee, royalty, or other charge for exercise of +rights granted under this License, and you may not initiate litigation +(including a cross-claim or counterclaim in a lawsuit) alleging that +any patent claim is infringed by making, using, selling, offering for +sale, or importing the Program or any portion of it. + + 11. Patents. + + A "contributor" is a copyright holder who authorizes use under this +License of the Program or a work on which the Program is based. The +work thus licensed is called the contributor's "contributor version". + + A contributor's "essential patent claims" are all patent claims +owned or controlled by the contributor, whether already acquired or +hereafter acquired, that would be infringed by some manner, permitted +by this License, of making, using, or selling its contributor version, +but do not include claims that would be infringed only as a +consequence of further modification of the contributor version. For +purposes of this definition, "control" includes the right to grant +patent sublicenses in a manner consistent with the requirements of +this License. + + Each contributor grants you a non-exclusive, worldwide, royalty-free +patent license under the contributor's essential patent claims, to +make, use, sell, offer for sale, import and otherwise run, modify and +propagate the contents of its contributor version. + + In the following three paragraphs, a "patent license" is any express +agreement or commitment, however denominated, not to enforce a patent +(such as an express permission to practice a patent or covenant not to +sue for patent infringement). To "grant" such a patent license to a +party means to make such an agreement or commitment not to enforce a +patent against the party. + + If you convey a covered work, knowingly relying on a patent license, +and the Corresponding Source of the work is not available for anyone +to copy, free of charge and under the terms of this License, through a +publicly available network server or other readily accessible means, +then you must either (1) cause the Corresponding Source to be so +available, or (2) arrange to deprive yourself of the benefit of the +patent license for this particular work, or (3) arrange, in a manner +consistent with the requirements of this License, to extend the patent +license to downstream recipients. "Knowingly relying" means you have +actual knowledge that, but for the patent license, your conveying the +covered work in a country, or your recipient's use of the covered work +in a country, would infringe one or more identifiable patents in that +country that you have reason to believe are valid. + + If, pursuant to or in connection with a single transaction or +arrangement, you convey, or propagate by procuring conveyance of, a +covered work, and grant a patent license to some of the parties +receiving the covered work authorizing them to use, propagate, modify +or convey a specific copy of the covered work, then the patent license +you grant is automatically extended to all recipients of the covered +work and works based on it. + + A patent license is "discriminatory" if it does not include within +the scope of its coverage, prohibits the exercise of, or is +conditioned on the non-exercise of one or more of the rights that are +specifically granted under this License. You may not convey a covered +work if you are a party to an arrangement with a third party that is +in the business of distributing software, under which you make payment +to the third party based on the extent of your activity of conveying +the work, and under which the third party grants, to any of the +parties who would receive the covered work from you, a discriminatory +patent license (a) in connection with copies of the covered work +conveyed by you (or copies made from those copies), or (b) primarily +for and in connection with specific products or compilations that +contain the covered work, unless you entered into that arrangement, +or that patent license was granted, prior to 28 March 2007. + + Nothing in this License shall be construed as excluding or limiting +any implied license or other defenses to infringement that may +otherwise be available to you under applicable patent law. + + 12. No Surrender of Others' Freedom. + + If conditions are imposed on you (whether by court order, agreement or +otherwise) that contradict the conditions of this License, they do not +excuse you from the conditions of this License. If you cannot convey a +covered work so as to satisfy simultaneously your obligations under this +License and any other pertinent obligations, then as a consequence you may +not convey it at all. For example, if you agree to terms that obligate you +to collect a royalty for further conveying from those to whom you convey +the Program, the only way you could satisfy both those terms and this +License would be to refrain entirely from conveying the Program. + + 13. Remote Network Interaction; Use with the GNU General Public License. + + Notwithstanding any other provision of this License, if you modify the +Program, your modified version must prominently offer all users +interacting with it remotely through a computer network (if your version +supports such interaction) an opportunity to receive the Corresponding +Source of your version by providing access to the Corresponding Source +from a network server at no charge, through some standard or customary +means of facilitating copying of software. This Corresponding Source +shall include the Corresponding Source for any work covered by version 3 +of the GNU General Public License that is incorporated pursuant to the +following paragraph. + + Notwithstanding any other provision of this License, you have +permission to link or combine any covered work with a work licensed +under version 3 of the GNU General Public License into a single +combined work, and to convey the resulting work. The terms of this +License will continue to apply to the part which is the covered work, +but the work with which it is combined will remain governed by version +3 of the GNU General Public License. + + 14. Revised Versions of this License. + + The Free Software Foundation may publish revised and/or new versions of +the GNU Affero General Public License from time to time. Such new versions +will be similar in spirit to the present version, but may differ in detail to +address new problems or concerns. + + Each version is given a distinguishing version number. If the +Program specifies that a certain numbered version of the GNU Affero General +Public License "or any later version" applies to it, you have the +option of following the terms and conditions either of that numbered +version or of any later version published by the Free Software +Foundation. If the Program does not specify a version number of the +GNU Affero General Public License, you may choose any version ever published +by the Free Software Foundation. + + If the Program specifies that a proxy can decide which future +versions of the GNU Affero General Public License can be used, that proxy's +public statement of acceptance of a version permanently authorizes you +to choose that version for the Program. + + Later license versions may give you additional or different +permissions. However, no additional obligations are imposed on any +author or copyright holder as a result of your choosing to follow a +later version. + + 15. Disclaimer of Warranty. + + THERE IS NO WARRANTY FOR THE PROGRAM, TO THE EXTENT PERMITTED BY +APPLICABLE LAW. EXCEPT WHEN OTHERWISE STATED IN WRITING THE COPYRIGHT +HOLDERS AND/OR OTHER PARTIES PROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY +OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, BUT NOT LIMITED TO, +THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR +PURPOSE. THE ENTIRE RISK AS TO THE QUALITY AND PERFORMANCE OF THE PROGRAM +IS WITH YOU. SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF +ALL NECESSARY SERVICING, REPAIR OR CORRECTION. + + 16. Limitation of Liability. + + IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING +WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS +THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY +GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF THE +USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED TO LOSS OF +DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY YOU OR THIRD +PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER PROGRAMS), +EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE POSSIBILITY OF +SUCH DAMAGES. + + 17. Interpretation of Sections 15 and 16. + + If the disclaimer of warranty and limitation of liability provided +above cannot be given local legal effect according to their terms, +reviewing courts shall apply local law that most closely approximates +an absolute waiver of all civil liability in connection with the +Program, unless a warranty or assumption of liability accompanies a +copy of the Program in return for a fee. + + END OF TERMS AND CONDITIONS + + How to Apply These Terms to Your New Programs + + If you develop a new program, and you want it to be of the greatest +possible use to the public, the best way to achieve this is to make it +free software which everyone can redistribute and change under these terms. + + To do so, attach the following notices to the program. It is safest +to attach them to the start of each source file to most effectively +state the exclusion of warranty; and each file should have at least +the "copyright" line and a pointer to where the full notice is found. + + + Copyright (C) + + This program is free software: you can redistribute it and/or modify + it under the terms of the GNU Affero General Public License as published + by the Free Software Foundation, either version 3 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU Affero General Public License for more details. + + You should have received a copy of the GNU Affero General Public License + along with this program. If not, see . + +Also add information on how to contact you by electronic and paper mail. + + If your software can interact with users remotely through a computer +network, you should also make sure that it provides a way for users to +get its source. For example, if your program is a web application, its +interface could display a "Source" link that leads users to an archive +of the code. There are many ways you could offer source, and different +solutions will be better for different programs; see section 13 for the +specific requirements. + + You should also get your employer (if you work as a programmer) or school, +if any, to sign a "copyright disclaimer" for the program, if necessary. +For more information on this, and how to apply and follow the GNU AGPL, see +. diff --git a/pkg/cmd/main.go b/pkg/cmd/main.go new file mode 100644 index 0000000..8fe6365 --- /dev/null +++ b/pkg/cmd/main.go @@ -0,0 +1,75 @@ +package main + +import ( + "os" + "os/signal" + "syscall" + + "git.solsynth.dev/hydrogen/paperclip/pkg/grpc" + "git.solsynth.dev/hydrogen/paperclip/pkg/server" + "git.solsynth.dev/hydrogen/paperclip/pkg/services" + "github.com/robfig/cron/v3" + + paperclip "git.solsynth.dev/hydrogen/paperclip/pkg" + "git.solsynth.dev/hydrogen/paperclip/pkg/database" + "github.com/rs/zerolog" + "github.com/rs/zerolog/log" + "github.com/spf13/viper" +) + +func init() { + zerolog.TimeFieldFormat = zerolog.TimeFormatUnix + log.Logger = log.Output(zerolog.ConsoleWriter{Out: os.Stdout}) +} + +func main() { + // Configure settings + viper.AddConfigPath(".") + viper.AddConfigPath("..") + viper.SetConfigName("settings") + viper.SetConfigType("toml") + + // Load settings + if err := viper.ReadInConfig(); err != nil { + log.Panic().Err(err).Msg("An error occurred when loading settings.") + } + + // Connect to database + if err := database.NewSource(); err != nil { + log.Fatal().Err(err).Msg("An error occurred when connect to database.") + } else if err := database.RunMigration(database.C); err != nil { + log.Fatal().Err(err).Msg("An error occurred when running database auto migration.") + } + + // Connect other services + if err := grpc.ConnectPassport(); err != nil { + log.Fatal().Err(err).Msg("An error occurred when connecting to passport grpc endpoint...") + } + + // Configure timed tasks + quartz := cron.New(cron.WithLogger(cron.VerbosePrintfLogger(&log.Logger))) + quartz.AddFunc("@every 60m", services.DoAutoDatabaseCleanup) + quartz.Start() + + // Server + server.NewServer() + go server.Listen() + + // Grpc Server + go func() { + if err := grpc.StartGrpc(); err != nil { + log.Fatal().Err(err).Msg("An message occurred when starting grpc server.") + } + }() + + // Messages + log.Info().Msgf("Paperclip v%s is started...", paperclip.AppVersion) + + quit := make(chan os.Signal, 1) + signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM) + <-quit + + log.Info().Msgf("Paperclip v%s is quitting...", paperclip.AppVersion) + + quartz.Stop() +} diff --git a/pkg/database/migrator.go b/pkg/database/migrator.go new file mode 100644 index 0000000..ba77083 --- /dev/null +++ b/pkg/database/migrator.go @@ -0,0 +1,21 @@ +package database + +import ( + "git.solsynth.dev/hydrogen/paperclip/pkg/models" + "gorm.io/gorm" +) + +var AutoMaintainRange = []any{ + &models.Account{}, + &models.Attachment{}, +} + +func RunMigration(source *gorm.DB) error { + if err := source.AutoMigrate( + AutoMaintainRange..., + ); err != nil { + return err + } + + return nil +} diff --git a/pkg/database/source.go b/pkg/database/source.go new file mode 100644 index 0000000..7602278 --- /dev/null +++ b/pkg/database/source.go @@ -0,0 +1,28 @@ +package database + +import ( + "github.com/rs/zerolog/log" + "github.com/samber/lo" + "github.com/spf13/viper" + "gorm.io/driver/postgres" + "gorm.io/gorm" + "gorm.io/gorm/logger" + "gorm.io/gorm/schema" +) + +var C *gorm.DB + +func NewSource() error { + var err error + + dialector := postgres.Open(viper.GetString("database.dsn")) + C, err = gorm.Open(dialector, &gorm.Config{NamingStrategy: schema.NamingStrategy{ + TablePrefix: viper.GetString("database.prefix"), + }, Logger: logger.New(&log.Logger, logger.Config{ + Colorful: true, + IgnoreRecordNotFoundError: true, + LogLevel: lo.Ternary(viper.GetBool("debug.database"), logger.Info, logger.Silent), + })}) + + return err +} diff --git a/pkg/grpc/attachments.go b/pkg/grpc/attachments.go new file mode 100644 index 0000000..437550b --- /dev/null +++ b/pkg/grpc/attachments.go @@ -0,0 +1,43 @@ +package grpc + +import ( + "context" + + "git.solsynth.dev/hydrogen/paperclip/pkg/database" + "git.solsynth.dev/hydrogen/paperclip/pkg/grpc/proto" + "git.solsynth.dev/hydrogen/paperclip/pkg/models" + jsoniter "github.com/json-iterator/go" +) + +func (v *Server) GetAttachment(ctx context.Context, request *proto.AttachmentLookupRequest) (*proto.Attachment, error) { + var attachment models.Attachment + + tx := database.C.Model(&models.Attachment{}) + if request.Id != nil { + tx = tx.Where("id = ?", request.GetId()) + } + if request.Uuid != nil { + tx = tx.Where("uuid = ?", request.GetUuid()) + } + + if err := tx.First(&attachment).Error; err != nil { + return nil, err + } + + rawMetadata, _ := jsoniter.Marshal(attachment.Metadata) + + return &proto.Attachment{ + Id: uint64(attachment.ID), + Uuid: attachment.Uuid, + Size: attachment.Size, + Name: attachment.Name, + Alt: attachment.Alternative, + Usage: attachment.Usage, + Mimetype: attachment.MimeType, + Hash: attachment.HashCode, + Destination: attachment.Destination, + Metadata: rawMetadata, + IsMature: attachment.IsMature, + AccountId: uint64(attachment.AccountID), + }, nil +} diff --git a/pkg/grpc/client.go b/pkg/grpc/client.go new file mode 100644 index 0000000..dd300e0 --- /dev/null +++ b/pkg/grpc/client.go @@ -0,0 +1,28 @@ +package grpc + +import ( + idpb "git.solsynth.dev/hydrogen/passport/pkg/grpc/proto" + "google.golang.org/grpc/credentials/insecure" + + "github.com/spf13/viper" + "google.golang.org/grpc" +) + +var Realms idpb.RealmsClient +var Friendships idpb.FriendshipsClient +var Notify idpb.NotifyClient +var Auth idpb.AuthClient + +func ConnectPassport() error { + addr := viper.GetString("passport.grpc_endpoint") + if conn, err := grpc.Dial(addr, grpc.WithTransportCredentials(insecure.NewCredentials())); err != nil { + return err + } else { + Realms = idpb.NewRealmsClient(conn) + Friendships = idpb.NewFriendshipsClient(conn) + Notify = idpb.NewNotifyClient(conn) + Auth = idpb.NewAuthClient(conn) + } + + return nil +} diff --git a/pkg/grpc/proto/attachments.pb.go b/pkg/grpc/proto/attachments.pb.go new file mode 100644 index 0000000..fc69a49 --- /dev/null +++ b/pkg/grpc/proto/attachments.pb.go @@ -0,0 +1,328 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.33.0 +// protoc v5.26.1 +// source: attachments.proto + +package proto + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type Attachment struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` + Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` + Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` + Alt string `protobuf:"bytes,5,opt,name=alt,proto3" json:"alt,omitempty"` + Usage string `protobuf:"bytes,6,opt,name=usage,proto3" json:"usage,omitempty"` + Mimetype string `protobuf:"bytes,7,opt,name=mimetype,proto3" json:"mimetype,omitempty"` + Hash string `protobuf:"bytes,8,opt,name=hash,proto3" json:"hash,omitempty"` + Destination string `protobuf:"bytes,9,opt,name=destination,proto3" json:"destination,omitempty"` + Metadata []byte `protobuf:"bytes,10,opt,name=metadata,proto3" json:"metadata,omitempty"` + IsMature bool `protobuf:"varint,11,opt,name=is_mature,json=isMature,proto3" json:"is_mature,omitempty"` + AccountId uint64 `protobuf:"varint,12,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"` +} + +func (x *Attachment) Reset() { + *x = Attachment{} + if protoimpl.UnsafeEnabled { + mi := &file_attachments_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *Attachment) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*Attachment) ProtoMessage() {} + +func (x *Attachment) ProtoReflect() protoreflect.Message { + mi := &file_attachments_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use Attachment.ProtoReflect.Descriptor instead. +func (*Attachment) Descriptor() ([]byte, []int) { + return file_attachments_proto_rawDescGZIP(), []int{0} +} + +func (x *Attachment) GetId() uint64 { + if x != nil { + return x.Id + } + return 0 +} + +func (x *Attachment) GetUuid() string { + if x != nil { + return x.Uuid + } + return "" +} + +func (x *Attachment) GetSize() int64 { + if x != nil { + return x.Size + } + return 0 +} + +func (x *Attachment) GetName() string { + if x != nil { + return x.Name + } + return "" +} + +func (x *Attachment) GetAlt() string { + if x != nil { + return x.Alt + } + return "" +} + +func (x *Attachment) GetUsage() string { + if x != nil { + return x.Usage + } + return "" +} + +func (x *Attachment) GetMimetype() string { + if x != nil { + return x.Mimetype + } + return "" +} + +func (x *Attachment) GetHash() string { + if x != nil { + return x.Hash + } + return "" +} + +func (x *Attachment) GetDestination() string { + if x != nil { + return x.Destination + } + return "" +} + +func (x *Attachment) GetMetadata() []byte { + if x != nil { + return x.Metadata + } + return nil +} + +func (x *Attachment) GetIsMature() bool { + if x != nil { + return x.IsMature + } + return false +} + +func (x *Attachment) GetAccountId() uint64 { + if x != nil { + return x.AccountId + } + return 0 +} + +type AttachmentLookupRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id *uint64 `protobuf:"varint,1,opt,name=id,proto3,oneof" json:"id,omitempty"` + Uuid *string `protobuf:"bytes,2,opt,name=uuid,proto3,oneof" json:"uuid,omitempty"` +} + +func (x *AttachmentLookupRequest) Reset() { + *x = AttachmentLookupRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_attachments_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *AttachmentLookupRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*AttachmentLookupRequest) ProtoMessage() {} + +func (x *AttachmentLookupRequest) ProtoReflect() protoreflect.Message { + mi := &file_attachments_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use AttachmentLookupRequest.ProtoReflect.Descriptor instead. +func (*AttachmentLookupRequest) Descriptor() ([]byte, []int) { + return file_attachments_proto_rawDescGZIP(), []int{1} +} + +func (x *AttachmentLookupRequest) GetId() uint64 { + if x != nil && x.Id != nil { + return *x.Id + } + return 0 +} + +func (x *AttachmentLookupRequest) GetUuid() string { + if x != nil && x.Uuid != nil { + return *x.Uuid + } + return "" +} + +var File_attachments_proto protoreflect.FileDescriptor + +var file_attachments_proto_rawDesc = []byte{ + 0x0a, 0x11, 0x61, 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x70, 0x72, + 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xaa, 0x02, 0x0a, 0x0a, 0x41, + 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x02, 0x69, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, + 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x12, 0x0a, + 0x04, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x73, 0x69, 0x7a, + 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x61, 0x6c, 0x74, 0x18, 0x05, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x03, 0x61, 0x6c, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x75, 0x73, 0x61, 0x67, 0x65, + 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x75, 0x73, 0x61, 0x67, 0x65, 0x12, 0x1a, 0x0a, + 0x08, 0x6d, 0x69, 0x6d, 0x65, 0x74, 0x79, 0x70, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x08, 0x6d, 0x69, 0x6d, 0x65, 0x74, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x68, 0x61, 0x73, + 0x68, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x68, 0x61, 0x73, 0x68, 0x12, 0x20, 0x0a, + 0x0b, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x09, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, + 0x1a, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x0a, 0x20, 0x01, 0x28, + 0x0c, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1b, 0x0a, 0x09, 0x69, + 0x73, 0x5f, 0x6d, 0x61, 0x74, 0x75, 0x72, 0x65, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, + 0x69, 0x73, 0x4d, 0x61, 0x74, 0x75, 0x72, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x61, 0x63, 0x63, 0x6f, + 0x75, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x04, 0x52, 0x09, 0x61, 0x63, + 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x64, 0x22, 0x57, 0x0a, 0x17, 0x41, 0x74, 0x74, 0x61, 0x63, + 0x68, 0x6d, 0x65, 0x6e, 0x74, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x12, 0x13, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x48, 0x00, + 0x52, 0x02, 0x69, 0x64, 0x88, 0x01, 0x01, 0x12, 0x17, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x09, 0x48, 0x01, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x88, 0x01, 0x01, + 0x42, 0x05, 0x0a, 0x03, 0x5f, 0x69, 0x64, 0x42, 0x07, 0x0a, 0x05, 0x5f, 0x75, 0x75, 0x69, 0x64, + 0x32, 0x53, 0x0a, 0x0b, 0x41, 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, 0x65, 0x6e, 0x74, 0x73, 0x12, + 0x44, 0x0a, 0x0d, 0x47, 0x65, 0x74, 0x41, 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, 0x65, 0x6e, 0x74, + 0x12, 0x1e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x41, 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, + 0x65, 0x6e, 0x74, 0x4c, 0x6f, 0x6f, 0x6b, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, + 0x1a, 0x11, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x41, 0x74, 0x74, 0x61, 0x63, 0x68, 0x6d, + 0x65, 0x6e, 0x74, 0x22, 0x00, 0x42, 0x09, 0x5a, 0x07, 0x2e, 0x3b, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_attachments_proto_rawDescOnce sync.Once + file_attachments_proto_rawDescData = file_attachments_proto_rawDesc +) + +func file_attachments_proto_rawDescGZIP() []byte { + file_attachments_proto_rawDescOnce.Do(func() { + file_attachments_proto_rawDescData = protoimpl.X.CompressGZIP(file_attachments_proto_rawDescData) + }) + return file_attachments_proto_rawDescData +} + +var file_attachments_proto_msgTypes = make([]protoimpl.MessageInfo, 2) +var file_attachments_proto_goTypes = []interface{}{ + (*Attachment)(nil), // 0: proto.Attachment + (*AttachmentLookupRequest)(nil), // 1: proto.AttachmentLookupRequest +} +var file_attachments_proto_depIdxs = []int32{ + 1, // 0: proto.Attachments.GetAttachment:input_type -> proto.AttachmentLookupRequest + 0, // 1: proto.Attachments.GetAttachment:output_type -> proto.Attachment + 1, // [1:2] is the sub-list for method output_type + 0, // [0:1] is the sub-list for method input_type + 0, // [0:0] is the sub-list for extension type_name + 0, // [0:0] is the sub-list for extension extendee + 0, // [0:0] is the sub-list for field type_name +} + +func init() { file_attachments_proto_init() } +func file_attachments_proto_init() { + if File_attachments_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_attachments_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Attachment); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_attachments_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*AttachmentLookupRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + file_attachments_proto_msgTypes[1].OneofWrappers = []interface{}{} + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_attachments_proto_rawDesc, + NumEnums: 0, + NumMessages: 2, + NumExtensions: 0, + NumServices: 1, + }, + GoTypes: file_attachments_proto_goTypes, + DependencyIndexes: file_attachments_proto_depIdxs, + MessageInfos: file_attachments_proto_msgTypes, + }.Build() + File_attachments_proto = out.File + file_attachments_proto_rawDesc = nil + file_attachments_proto_goTypes = nil + file_attachments_proto_depIdxs = nil +} diff --git a/pkg/grpc/proto/attachments.proto b/pkg/grpc/proto/attachments.proto new file mode 100644 index 0000000..8c4ed17 --- /dev/null +++ b/pkg/grpc/proto/attachments.proto @@ -0,0 +1,29 @@ +syntax = "proto3"; + +option go_package = ".;proto"; + +package proto; + +service Attachments { + rpc GetAttachment(AttachmentLookupRequest) returns (Attachment) {} +} + +message Attachment { + uint64 id = 1; + string uuid = 2; + int64 size = 3; + string name = 4; + string alt = 5; + string usage = 6; + string mimetype = 7; + string hash = 8; + string destination = 9; + bytes metadata = 10; + bool is_mature = 11; + uint64 account_id = 12; +} + +message AttachmentLookupRequest { + optional uint64 id = 1; + optional string uuid = 2; +} diff --git a/pkg/grpc/proto/attachments_grpc.pb.go b/pkg/grpc/proto/attachments_grpc.pb.go new file mode 100644 index 0000000..6f00fa9 --- /dev/null +++ b/pkg/grpc/proto/attachments_grpc.pb.go @@ -0,0 +1,109 @@ +// Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.3.0 +// - protoc v5.26.1 +// source: attachments.proto + +package proto + +import ( + context "context" + grpc "google.golang.org/grpc" + codes "google.golang.org/grpc/codes" + status "google.golang.org/grpc/status" +) + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the grpc package it is being compiled against. +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 + +const ( + Attachments_GetAttachment_FullMethodName = "/proto.Attachments/GetAttachment" +) + +// AttachmentsClient is the client API for Attachments service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. +type AttachmentsClient interface { + GetAttachment(ctx context.Context, in *AttachmentLookupRequest, opts ...grpc.CallOption) (*Attachment, error) +} + +type attachmentsClient struct { + cc grpc.ClientConnInterface +} + +func NewAttachmentsClient(cc grpc.ClientConnInterface) AttachmentsClient { + return &attachmentsClient{cc} +} + +func (c *attachmentsClient) GetAttachment(ctx context.Context, in *AttachmentLookupRequest, opts ...grpc.CallOption) (*Attachment, error) { + out := new(Attachment) + err := c.cc.Invoke(ctx, Attachments_GetAttachment_FullMethodName, in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// AttachmentsServer is the server API for Attachments service. +// All implementations must embed UnimplementedAttachmentsServer +// for forward compatibility +type AttachmentsServer interface { + GetAttachment(context.Context, *AttachmentLookupRequest) (*Attachment, error) + mustEmbedUnimplementedAttachmentsServer() +} + +// UnimplementedAttachmentsServer must be embedded to have forward compatible implementations. +type UnimplementedAttachmentsServer struct { +} + +func (UnimplementedAttachmentsServer) GetAttachment(context.Context, *AttachmentLookupRequest) (*Attachment, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetAttachment not implemented") +} +func (UnimplementedAttachmentsServer) mustEmbedUnimplementedAttachmentsServer() {} + +// UnsafeAttachmentsServer may be embedded to opt out of forward compatibility for this service. +// Use of this interface is not recommended, as added methods to AttachmentsServer will +// result in compilation errors. +type UnsafeAttachmentsServer interface { + mustEmbedUnimplementedAttachmentsServer() +} + +func RegisterAttachmentsServer(s grpc.ServiceRegistrar, srv AttachmentsServer) { + s.RegisterService(&Attachments_ServiceDesc, srv) +} + +func _Attachments_GetAttachment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(AttachmentLookupRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(AttachmentsServer).GetAttachment(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Attachments_GetAttachment_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(AttachmentsServer).GetAttachment(ctx, req.(*AttachmentLookupRequest)) + } + return interceptor(ctx, in, info, handler) +} + +// Attachments_ServiceDesc is the grpc.ServiceDesc for Attachments service. +// It's only intended for direct use with grpc.RegisterService, +// and not to be introspected or modified (even as a copy) +var Attachments_ServiceDesc = grpc.ServiceDesc{ + ServiceName: "proto.Attachments", + HandlerType: (*AttachmentsServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "GetAttachment", + Handler: _Attachments_GetAttachment_Handler, + }, + }, + Streams: []grpc.StreamDesc{}, + Metadata: "attachments.proto", +} diff --git a/pkg/grpc/server.go b/pkg/grpc/server.go new file mode 100644 index 0000000..33d84a2 --- /dev/null +++ b/pkg/grpc/server.go @@ -0,0 +1,29 @@ +package grpc + +import ( + "net" + + "git.solsynth.dev/hydrogen/paperclip/pkg/grpc/proto" + "github.com/spf13/viper" + "google.golang.org/grpc" + "google.golang.org/grpc/reflection" +) + +type Server struct { + proto.UnimplementedAttachmentsServer +} + +func StartGrpc() error { + listen, err := net.Listen("tcp", viper.GetString("grpc_bind")) + if err != nil { + return err + } + + server := grpc.NewServer() + + proto.RegisterAttachmentsServer(server, &Server{}) + + reflection.Register(server) + + return server.Serve(listen) +} diff --git a/pkg/meta.go b/pkg/meta.go new file mode 100644 index 0000000..e0251b4 --- /dev/null +++ b/pkg/meta.go @@ -0,0 +1,5 @@ +package pkg + +const ( + AppVersion = "1.0.0" +) diff --git a/pkg/models/accounts.go b/pkg/models/accounts.go new file mode 100644 index 0000000..39702cb --- /dev/null +++ b/pkg/models/accounts.go @@ -0,0 +1,18 @@ +package models + +// Account profiles basically fetched from Hydrogen.Passport +// But cache at here for better usage +// At the same time this model can make relations between local models +type Account struct { + BaseModel + + Name string `json:"name"` + Nick string `json:"nick"` + Avatar string `json:"avatar"` + Banner string `json:"banner"` + Description string `json:"description"` + EmailAddress string `json:"email_address"` + PowerLevel int `json:"power_level"` + Attachments []Attachment `json:"attachments"` + ExternalID uint `json:"external_id"` +} diff --git a/pkg/models/attachments.go b/pkg/models/attachments.go new file mode 100644 index 0000000..70c4628 --- /dev/null +++ b/pkg/models/attachments.go @@ -0,0 +1,22 @@ +package models + +import "gorm.io/datatypes" + +type Attachment struct { + BaseModel + + Uuid string `json:"uuid" gorm:"uniqueIndex"` + Size int64 `json:"size"` + Name string `json:"name"` + Alternative string `json:"alt"` + Usage string `json:"usage"` + MimeType string `json:"mimetype"` + HashCode string `json:"hash"` + Destination string `json:"destination"` + + Metadata datatypes.JSONMap `json:"metadata"` + IsMature bool `json:"is_mature"` + + Account Account `json:"account"` + AccountID uint `json:"account_id"` +} diff --git a/pkg/models/base.go b/pkg/models/base.go new file mode 100644 index 0000000..0052acd --- /dev/null +++ b/pkg/models/base.go @@ -0,0 +1,17 @@ +package models + +import ( + "time" + + "gorm.io/datatypes" + "gorm.io/gorm" +) + +type JSONMap = datatypes.JSONType[map[string]any] + +type BaseModel struct { + ID uint `json:"id" gorm:"primaryKey"` + CreatedAt time.Time `json:"created_at"` + UpdatedAt time.Time `json:"updated_at"` + DeletedAt gorm.DeletedAt `json:"deleted_at" gorm:"index"` +} diff --git a/pkg/models/destination.go b/pkg/models/destination.go new file mode 100644 index 0000000..88750fc --- /dev/null +++ b/pkg/models/destination.go @@ -0,0 +1,27 @@ +package models + +const ( + DestinationTypeLocal = "local" + DestinationTypeS3 = "s3" +) + +type BaseDestination struct { + Type string `json:"type"` +} + +type LocalDestination struct { + BaseDestination + + Path string `json:"path"` +} + +type S3Destination struct { + BaseDestination + + Path string `json:"path"` + Bucket string `json:"bucket"` + Endpoint string `json:"endpoint"` + SecretID string `json:"secret_id"` + SecretKey string `json:"secret_key"` + EnableSSL bool `json:"enable_ssl"` +} diff --git a/pkg/models/metadata.go b/pkg/models/metadata.go new file mode 100644 index 0000000..f448291 --- /dev/null +++ b/pkg/models/metadata.go @@ -0,0 +1,4 @@ +package models + +type MediaMetadata struct { +} diff --git a/pkg/server/attachments_api.go b/pkg/server/attachments_api.go new file mode 100644 index 0000000..f8a30a6 --- /dev/null +++ b/pkg/server/attachments_api.go @@ -0,0 +1,135 @@ +package server + +import ( + "fmt" + "net/url" + "path/filepath" + + "git.solsynth.dev/hydrogen/paperclip/pkg/database" + "git.solsynth.dev/hydrogen/paperclip/pkg/models" + "git.solsynth.dev/hydrogen/paperclip/pkg/services" + "github.com/gofiber/fiber/v2" + jsoniter "github.com/json-iterator/go" + "github.com/samber/lo" + "github.com/spf13/viper" + "gorm.io/datatypes" +) + +func openAttachment(c *fiber.Ctx) error { + id := c.Params("id") + + metadata, err := services.GetAttachmentByUUID(id) + if err != nil { + return fiber.NewError(fiber.StatusNotFound) + } + + destMap := viper.GetStringMap("destinations") + dest, destOk := destMap[metadata.Destination] + if !destOk { + return fiber.NewError(fiber.StatusInternalServerError, "invalid destination: destination configuration was not found") + } + + var destParsed models.BaseDestination + rawDest, _ := jsoniter.Marshal(dest) + _ = jsoniter.Unmarshal(rawDest, &destParsed) + + switch destParsed.Type { + case models.DestinationTypeLocal: + var destConfigured models.LocalDestination + _ = jsoniter.Unmarshal(rawDest, &destConfigured) + return c.SendFile(filepath.Join(destConfigured.Path, metadata.Uuid)) + case models.DestinationTypeS3: + var destConfigured models.S3Destination + _ = jsoniter.Unmarshal(rawDest, &destConfigured) + protocol := lo.Ternary(destConfigured.EnableSSL, "https", "http") + return c.Redirect(fmt.Sprintf( + "%s://%s.%s/%s", + protocol, + destConfigured.Bucket, + destConfigured.Endpoint, + url.QueryEscape(filepath.Join(destConfigured.Path, metadata.Uuid)), + )) + default: + return fmt.Errorf("invalid destination: unsupported protocol %s", destParsed.Type) + } +} + +func getAttachmentMeta(c *fiber.Ctx) error { + id := c.Params("id") + + metadata, err := services.GetAttachmentByUUID(id) + if err != nil { + return fiber.NewError(fiber.StatusNotFound) + } + + return c.JSON(metadata) +} + +func createAttachment(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + + destName := c.Query("destination", viper.GetString("preferred_destination")) + + hash := c.FormValue("hash") + if len(hash) != 64 { + return fiber.NewError(fiber.StatusBadRequest, "please provide a sha-256 hash code, length should be 64 characters") + } + usage := c.FormValue("usage") + if !lo.Contains(viper.GetStringSlice("accepts_usage"), usage) { + return fiber.NewError(fiber.StatusBadRequest, fmt.Sprintf("disallowed usage: %s", usage)) + } + + // TODO Add file size check with user permissions (BLOCKED BY Passport#3) + + file, err := c.FormFile("file") + if err != nil { + return err + } + + var usermeta = make(map[string]any) + _ = jsoniter.UnmarshalFromString(c.FormValue("metadata"), &usermeta) + + tx := database.C.Begin() + metadata, linked, err := services.NewAttachmentMetadata(tx, user, file, models.Attachment{ + Usage: usage, + HashCode: hash, + Alternative: c.FormValue("alt"), + MimeType: c.FormValue("mimetype"), + Metadata: datatypes.JSONMap(usermeta), + IsMature: len(c.FormValue("mature")) > 0, + Destination: destName, + }) + if err != nil { + tx.Rollback() + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + + if !linked { + if err := services.UploadFile(destName, c, file, metadata); err != nil { + tx.Rollback() + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + } + + tx.Commit() + + return c.JSON(metadata) +} + +func deleteAttachment(c *fiber.Ctx) error { + id, _ := c.ParamsInt("id", 0) + user := c.Locals("principal").(models.Account) + + attachment, err := services.GetAttachmentByID(uint(id)) + if err != nil { + return fiber.NewError(fiber.StatusNotFound, err.Error()) + } else if attachment.AccountID != user.ID { + return fiber.NewError(fiber.StatusNotFound, "record not created by you") + } + + if err := services.DeleteAttachment(attachment); err != nil { + return fiber.NewError(fiber.StatusInternalServerError, err.Error()) + } else { + return c.SendStatus(fiber.StatusOK) + } +} diff --git a/pkg/server/auth.go b/pkg/server/auth.go new file mode 100644 index 0000000..1ac802b --- /dev/null +++ b/pkg/server/auth.go @@ -0,0 +1,50 @@ +package server + +import ( + "git.solsynth.dev/hydrogen/paperclip/pkg/services" + "github.com/gofiber/fiber/v2" + "strings" +) + +func authMiddleware(c *fiber.Ctx) error { + var token string + if cookie := c.Cookies(services.CookieAccessKey); len(cookie) > 0 { + token = cookie + } + if header := c.Get(fiber.HeaderAuthorization); len(header) > 0 { + tk := strings.Replace(header, "Bearer", "", 1) + token = strings.TrimSpace(tk) + } + + c.Locals("token", token) + + if err := authFunc(c); err != nil { + return err + } + + return c.Next() +} + +func authFunc(c *fiber.Ctx, overrides ...string) error { + var token string + if len(overrides) > 0 { + token = overrides[0] + } else { + if tk, ok := c.Locals("token").(string); !ok { + return fiber.NewError(fiber.StatusUnauthorized) + } else { + token = tk + } + } + + rtk := c.Cookies(services.CookieRefreshKey) + if user, atk, rtk, err := services.Authenticate(token, rtk); err == nil { + if atk != token { + services.SetJwtCookieSet(c, atk, rtk) + } + c.Locals("principal", user) + return nil + } else { + return fiber.NewError(fiber.StatusUnauthorized, err.Error()) + } +} diff --git a/pkg/server/startup.go b/pkg/server/startup.go new file mode 100644 index 0000000..8ac111f --- /dev/null +++ b/pkg/server/startup.go @@ -0,0 +1,68 @@ +package server + +import ( + "strings" + + "github.com/gofiber/fiber/v2" + "github.com/gofiber/fiber/v2/middleware/cors" + "github.com/gofiber/fiber/v2/middleware/idempotency" + "github.com/gofiber/fiber/v2/middleware/logger" + jsoniter "github.com/json-iterator/go" + "github.com/rs/zerolog/log" + "github.com/spf13/viper" +) + +var A *fiber.App + +func NewServer() { + A = fiber.New(fiber.Config{ + DisableStartupMessage: true, + EnableIPValidation: true, + ServerHeader: "Hydrogen.Paperclip", + AppName: "Hydrogen.Paperclip", + ProxyHeader: fiber.HeaderXForwardedFor, + JSONEncoder: jsoniter.ConfigCompatibleWithStandardLibrary.Marshal, + JSONDecoder: jsoniter.ConfigCompatibleWithStandardLibrary.Unmarshal, + BodyLimit: 512 * 1024 * 1024 * 1024, // 512 TiB + EnablePrintRoutes: viper.GetBool("debug.print_routes"), + }) + + A.Use(idempotency.New()) + A.Use(cors.New(cors.Config{ + AllowCredentials: true, + AllowMethods: strings.Join([]string{ + fiber.MethodGet, + fiber.MethodPost, + fiber.MethodHead, + fiber.MethodOptions, + fiber.MethodPut, + fiber.MethodDelete, + fiber.MethodPatch, + }, ","), + AllowOriginsFunc: func(origin string) bool { + return true + }, + })) + + A.Use(logger.New(logger.Config{ + Format: "${status} | ${latency} | ${method} ${path}\n", + Output: log.Logger, + })) + + A.Get("/.well-known", getMetadata) + A.Get("/.well-known/destinations", getDestinations) + + api := A.Group("/api").Name("API") + { + api.Get("/attachments/i/:id", getAttachmentMeta) + api.Get("/attachments/:id", openAttachment) + api.Post("/attachments", authMiddleware, createAttachment) + api.Delete("/attachments/:id", authMiddleware, deleteAttachment) + } +} + +func Listen() { + if err := A.Listen(viper.GetString("bind")); err != nil { + log.Fatal().Err(err).Msg("An error occurred when starting server...") + } +} diff --git a/pkg/server/utils.go b/pkg/server/utils.go new file mode 100644 index 0000000..8502c7f --- /dev/null +++ b/pkg/server/utils.go @@ -0,0 +1,18 @@ +package server + +import ( + "github.com/go-playground/validator/v10" + "github.com/gofiber/fiber/v2" +) + +var validation = validator.New(validator.WithRequiredStructEnabled()) + +func BindAndValidate(c *fiber.Ctx, out any) error { + if err := c.BodyParser(out); err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } else if err := validation.Struct(out); err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + + return nil +} diff --git a/pkg/server/well_known_api.go b/pkg/server/well_known_api.go new file mode 100644 index 0000000..bbb6339 --- /dev/null +++ b/pkg/server/well_known_api.go @@ -0,0 +1,28 @@ +package server + +import ( + "github.com/gofiber/fiber/v2" + "github.com/spf13/viper" +) + +func getMetadata(c *fiber.Ctx) error { + return c.JSON(fiber.Map{ + "name": viper.GetString("name"), + "domain": viper.GetString("domain"), + "components": fiber.Map{ + "passport": viper.GetString("passport.endpoint"), + }, + }) +} + +func getDestinations(c *fiber.Ctx) error { + var data []string + for key := range viper.GetStringMap("destinations") { + data = append(data, key) + } + + return c.JSON(fiber.Map{ + "data": data, + "preferred": viper.GetString("preferred_destination"), + }) +} diff --git a/pkg/services/accounts.go b/pkg/services/accounts.go new file mode 100644 index 0000000..fdbb154 --- /dev/null +++ b/pkg/services/accounts.go @@ -0,0 +1,56 @@ +package services + +import ( + "context" + "time" + + "git.solsynth.dev/hydrogen/paperclip/pkg/database" + "git.solsynth.dev/hydrogen/paperclip/pkg/grpc" + "git.solsynth.dev/hydrogen/paperclip/pkg/models" + "git.solsynth.dev/hydrogen/passport/pkg/grpc/proto" + "github.com/rs/zerolog/log" + "github.com/spf13/viper" +) + +func GetAccountFriend(userId, relatedId uint, status int) (*proto.FriendshipResponse, error) { + var user models.Account + if err := database.C.Where("id = ?", userId).First(&user).Error; err != nil { + return nil, err + } + var related models.Account + if err := database.C.Where("id = ?", relatedId).First(&related).Error; err != nil { + return nil, err + } + + ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) + defer cancel() + + return grpc.Friendships.GetFriendship(ctx, &proto.FriendshipTwoSideLookupRequest{ + AccountId: uint64(user.ExternalID), + RelatedId: uint64(related.ExternalID), + Status: uint32(status), + }) +} + +func NotifyAccount(user models.Account, subject, content string, realtime bool, links ...*proto.NotifyLink) error { + ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) + defer cancel() + + _, err := grpc.Notify.NotifyUser(ctx, &proto.NotifyRequest{ + ClientId: viper.GetString("passport.client_id"), + ClientSecret: viper.GetString("passport.client_secret"), + Subject: subject, + Content: content, + Links: links, + RecipientId: uint64(user.ExternalID), + IsRealtime: realtime, + IsImportant: false, + }) + if err != nil { + log.Warn().Err(err).Msg("An error occurred when notify account...") + } else { + log.Debug().Uint("external", user.ExternalID).Msg("Notified account.") + } + + return err +} diff --git a/pkg/services/attachments.go b/pkg/services/attachments.go new file mode 100644 index 0000000..4cd7785 --- /dev/null +++ b/pkg/services/attachments.go @@ -0,0 +1,110 @@ +package services + +import ( + "fmt" + "mime" + "mime/multipart" + "net/http" + "path/filepath" + + "git.solsynth.dev/hydrogen/paperclip/pkg/database" + "git.solsynth.dev/hydrogen/paperclip/pkg/models" + "github.com/google/uuid" + "gorm.io/gorm" +) + +func GetAttachmentByID(id uint) (models.Attachment, error) { + var attachment models.Attachment + if err := database.C.Where(models.Attachment{ + BaseModel: models.BaseModel{ID: id}, + }).First(&attachment).Error; err != nil { + return attachment, err + } + return attachment, nil +} + +func GetAttachmentByUUID(id string) (models.Attachment, error) { + var attachment models.Attachment + if err := database.C.Where(models.Attachment{ + Uuid: id, + }).First(&attachment).Error; err != nil { + return attachment, err + } + return attachment, nil +} + +func GetAttachmentByHash(hash string) (models.Attachment, error) { + var attachment models.Attachment + if err := database.C.Where(models.Attachment{ + HashCode: hash, + }).First(&attachment).Error; err != nil { + return attachment, err + } + return attachment, nil +} + +func NewAttachmentMetadata(tx *gorm.DB, user models.Account, file *multipart.FileHeader, attachment models.Attachment) (models.Attachment, bool, error) { + linked := false + exists, pickupErr := GetAttachmentByHash(attachment.HashCode) + if pickupErr == nil { + linked = true + attachment = exists + attachment.ID = 0 + attachment.AccountID = user.ID + } else { + // Upload the new file + attachment.Uuid = uuid.NewString() + attachment.Size = file.Size + attachment.Name = file.Filename + attachment.AccountID = user.ID + + // If user didn't provide file mimetype manually, we gotta to detect it + if len(attachment.MimeType) == 0 { + if ext := filepath.Ext(attachment.Name); len(ext) > 0 { + // Detect mimetype by file extensions + attachment.MimeType = mime.TypeByExtension(ext) + } else { + // Detect mimetype by file header + // This method as a fallback method, because this isn't pretty accurate + header, err := file.Open() + if err != nil { + return attachment, false, fmt.Errorf("failed to read file header: %v", err) + } + defer header.Close() + + fileHeader := make([]byte, 512) + _, err = header.Read(fileHeader) + if err != nil { + return attachment, false, err + } + attachment.MimeType = http.DetectContentType(fileHeader) + } + } + } + + if err := tx.Save(&attachment).Error; err != nil { + return attachment, linked, fmt.Errorf("failed to save attachment record: %v", err) + } + + return attachment, linked, nil +} + +func DeleteAttachment(item models.Attachment) error { + var dupeCount int64 + if err := database.C. + Where(&models.Attachment{HashCode: item.HashCode}). + Model(&models.Attachment{}). + Count(&dupeCount).Error; err != nil { + dupeCount = -1 + } + + if err := database.C.Delete(&item).Error; err != nil { + return err + } + + if dupeCount != -1 && dupeCount <= 1 { + return DeleteFile(item) + } + + return nil +} diff --git a/pkg/services/auth.go b/pkg/services/auth.go new file mode 100644 index 0000000..1e91dd1 --- /dev/null +++ b/pkg/services/auth.go @@ -0,0 +1,76 @@ +package services + +import ( + "context" + "errors" + "fmt" + "reflect" + "time" + + "git.solsynth.dev/hydrogen/paperclip/pkg/database" + "git.solsynth.dev/hydrogen/paperclip/pkg/grpc" + "git.solsynth.dev/hydrogen/paperclip/pkg/models" + "git.solsynth.dev/hydrogen/passport/pkg/grpc/proto" + "gorm.io/gorm" +) + +func LinkAccount(userinfo *proto.Userinfo) (models.Account, error) { + var account models.Account + if userinfo == nil { + return account, fmt.Errorf("remote userinfo was not found") + } + if err := database.C.Where(&models.Account{ + ExternalID: uint(userinfo.Id), + }).First(&account).Error; err != nil { + if errors.Is(err, gorm.ErrRecordNotFound) { + account = models.Account{ + Name: userinfo.Name, + Nick: userinfo.Nick, + Avatar: userinfo.Avatar, + Banner: userinfo.Banner, + Description: userinfo.GetDescription(), + EmailAddress: userinfo.Email, + PowerLevel: 0, + ExternalID: uint(userinfo.Id), + } + return account, database.C.Save(&account).Error + } + return account, err + } + + prev := account + account.Name = userinfo.Name + account.Nick = userinfo.Nick + account.Avatar = userinfo.Avatar + account.Banner = userinfo.Banner + account.Description = userinfo.GetDescription() + account.EmailAddress = userinfo.Email + + var err error + if !reflect.DeepEqual(prev, account) { + err = database.C.Save(&account).Error + } + + return account, err +} + +func Authenticate(atk, rtk string) (models.Account, string, string, error) { + ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) + defer cancel() + + var err error + var user models.Account + reply, err := grpc.Auth.Authenticate(ctx, &proto.AuthRequest{ + AccessToken: atk, + RefreshToken: &rtk, + }) + if err != nil { + return user, reply.GetAccessToken(), reply.GetRefreshToken(), err + } else if !reply.IsValid { + return user, reply.GetAccessToken(), reply.GetRefreshToken(), fmt.Errorf("invalid authorization context") + } + + user, err = LinkAccount(reply.Userinfo) + + return user, reply.GetAccessToken(), reply.GetRefreshToken(), err +} diff --git a/pkg/services/cleaner.go b/pkg/services/cleaner.go new file mode 100644 index 0000000..f746132 --- /dev/null +++ b/pkg/services/cleaner.go @@ -0,0 +1,24 @@ +package services + +import ( + "time" + + "git.solsynth.dev/hydrogen/paperclip/pkg/database" + "github.com/rs/zerolog/log" +) + +func DoAutoDatabaseCleanup() { + deadline := time.Now().Add(60 * time.Minute) + log.Debug().Time("deadline", deadline).Msg("Now cleaning up entire database...") + + var count int64 + for _, model := range database.AutoMaintainRange { + tx := database.C.Unscoped().Delete(model, "deleted_at >= ?", deadline) + if tx.Error != nil { + log.Error().Err(tx.Error).Msg("An error occurred when running auth context cleanup...") + } + count += tx.RowsAffected + } + + log.Debug().Int64("affected", count).Msg("Clean up entire database accomplished.") +} diff --git a/pkg/services/jwt.go b/pkg/services/jwt.go new file mode 100644 index 0000000..40cfef0 --- /dev/null +++ b/pkg/services/jwt.go @@ -0,0 +1,81 @@ +package services + +import ( + "fmt" + "github.com/gofiber/fiber/v2" + "time" + + "github.com/golang-jwt/jwt/v5" + "github.com/spf13/viper" +) + +type PayloadClaims struct { + jwt.RegisteredClaims + + Type string `json:"typ"` +} + +const ( + JwtAccessType = "access" + JwtRefreshType = "refresh" +) + +const ( + CookieAccessKey = "passport_auth_key" + CookieRefreshKey = "passport_refresh_key" +) + +func EncodeJwt(id string, typ, sub string, aud []string, exp time.Time) (string, error) { + tk := jwt.NewWithClaims(jwt.SigningMethodHS512, PayloadClaims{ + jwt.RegisteredClaims{ + Subject: sub, + Audience: aud, + Issuer: fmt.Sprintf("https://%s", viper.GetString("domain")), + ExpiresAt: jwt.NewNumericDate(exp), + NotBefore: jwt.NewNumericDate(time.Now()), + IssuedAt: jwt.NewNumericDate(time.Now()), + ID: id, + }, + typ, + }) + + return tk.SignedString([]byte(viper.GetString("secret"))) +} + +func DecodeJwt(str string) (PayloadClaims, error) { + var claims PayloadClaims + tk, err := jwt.ParseWithClaims(str, &claims, func(token *jwt.Token) (interface{}, error) { + if _, ok := token.Method.(*jwt.SigningMethodHMAC); !ok { + return nil, fmt.Errorf("unexpected signing method: %v", token.Header["alg"]) + } + return []byte(viper.GetString("secret")), nil + }) + if err != nil { + return claims, err + } + + if data, ok := tk.Claims.(*PayloadClaims); ok { + return *data, nil + } else { + return claims, fmt.Errorf("unexpected token payload: not payload claims type") + } +} + +func SetJwtCookieSet(c *fiber.Ctx, access, refresh string) { + c.Cookie(&fiber.Cookie{ + Name: CookieAccessKey, + Value: access, + Domain: viper.GetString("security.cookie_domain"), + SameSite: viper.GetString("security.cookie_samesite"), + Expires: time.Now().Add(60 * time.Minute), + Path: "/", + }) + c.Cookie(&fiber.Cookie{ + Name: CookieRefreshKey, + Value: refresh, + Domain: viper.GetString("security.cookie_domain"), + SameSite: viper.GetString("security.cookie_samesite"), + Expires: time.Now().Add(24 * 30 * time.Hour), + Path: "/", + }) +} diff --git a/pkg/services/recycler.go b/pkg/services/recycler.go new file mode 100644 index 0000000..bc86509 --- /dev/null +++ b/pkg/services/recycler.go @@ -0,0 +1,61 @@ +package services + +import ( + "context" + "fmt" + "os" + "path/filepath" + + "git.solsynth.dev/hydrogen/paperclip/pkg/models" + jsoniter "github.com/json-iterator/go" + "github.com/minio/minio-go/v7" + "github.com/minio/minio-go/v7/pkg/credentials" + "github.com/spf13/viper" +) + +func DeleteFile(meta models.Attachment) error { + destMap := viper.GetStringMap("destinations") + dest, destOk := destMap[meta.Destination] + if !destOk { + return fmt.Errorf("invalid destination: destination configuration was not found") + } + + var destParsed models.BaseDestination + rawDest, _ := jsoniter.Marshal(dest) + _ = jsoniter.Unmarshal(rawDest, &destParsed) + + switch destParsed.Type { + case models.DestinationTypeLocal: + var destConfigured models.LocalDestination + _ = jsoniter.Unmarshal(rawDest, &destConfigured) + return DeleteFileFromLocal(destConfigured, meta) + case models.DestinationTypeS3: + var destConfigured models.S3Destination + _ = jsoniter.Unmarshal(rawDest, &destConfigured) + return DeleteFileFromS3(destConfigured, meta) + default: + return fmt.Errorf("invalid destination: unsupported protocol %s", destParsed.Type) + } +} + +func DeleteFileFromLocal(config models.LocalDestination, meta models.Attachment) error { + fullpath := filepath.Join(config.Path, meta.Uuid) + return os.Remove(fullpath) +} + +func DeleteFileFromS3(config models.S3Destination, meta models.Attachment) error { + client, err := minio.New(config.Endpoint, &minio.Options{ + Creds: credentials.NewStaticV4(config.SecretID, config.SecretKey, ""), + Secure: config.EnableSSL, + }) + if err != nil { + return fmt.Errorf("unable to configure s3 client: %v", err) + } + + err = client.RemoveObject(context.Background(), config.Bucket, filepath.Join(config.Path, meta.Uuid), minio.RemoveObjectOptions{}) + if err != nil { + return fmt.Errorf("unable to upload file to s3: %v", err) + } + + return nil +} diff --git a/pkg/services/uploader.go b/pkg/services/uploader.go new file mode 100644 index 0000000..9bf61a4 --- /dev/null +++ b/pkg/services/uploader.go @@ -0,0 +1,76 @@ +package services + +import ( + "bytes" + "context" + "fmt" + "io" + "mime/multipart" + "path/filepath" + + "git.solsynth.dev/hydrogen/paperclip/pkg/models" + "github.com/gofiber/fiber/v2" + jsoniter "github.com/json-iterator/go" + "github.com/minio/minio-go/v7" + "github.com/minio/minio-go/v7/pkg/credentials" + "github.com/spf13/viper" +) + +func UploadFile(destName string, ctx *fiber.Ctx, file *multipart.FileHeader, meta models.Attachment) error { + destMap := viper.GetStringMap("destinations") + dest, destOk := destMap[destName] + if !destOk { + return fmt.Errorf("invalid destination: destination configuration was not found") + } + + var destParsed models.BaseDestination + rawDest, _ := jsoniter.Marshal(dest) + _ = jsoniter.Unmarshal(rawDest, &destParsed) + + switch destParsed.Type { + case models.DestinationTypeLocal: + var destConfigured models.LocalDestination + _ = jsoniter.Unmarshal(rawDest, &destConfigured) + return UploadFileToLocal(destConfigured, ctx, file, meta) + case models.DestinationTypeS3: + var destConfigured models.S3Destination + _ = jsoniter.Unmarshal(rawDest, &destConfigured) + return UploadFileToS3(destConfigured, file, meta) + default: + return fmt.Errorf("invalid destination: unsupported protocol %s", destParsed.Type) + } +} + +func UploadFileToLocal(config models.LocalDestination, ctx *fiber.Ctx, file *multipart.FileHeader, meta models.Attachment) error { + return ctx.SaveFile(file, filepath.Join(config.Path, meta.Uuid)) +} + +func UploadFileToS3(config models.S3Destination, file *multipart.FileHeader, meta models.Attachment) error { + header, err := file.Open() + if err != nil { + return fmt.Errorf("read upload file: %v", err) + } + defer header.Close() + + buffer := bytes.NewBuffer(nil) + if _, err := io.Copy(buffer, header); err != nil { + return fmt.Errorf("create io reader for upload file: %v", err) + } + + client, err := minio.New(config.Endpoint, &minio.Options{ + Creds: credentials.NewStaticV4(config.SecretID, config.SecretKey, ""), + Secure: config.EnableSSL, + }) + if err != nil { + return fmt.Errorf("unable to configure s3 client: %v", err) + } + + _, err = client.PutObject(context.Background(), config.Bucket, filepath.Join(config.Path, meta.Uuid), buffer, -1, minio.PutObjectOptions{ + ContentType: meta.MimeType, + }) + if err != nil { + return fmt.Errorf("unable to upload file to s3: %v", err) + } + + return nil +} diff --git a/settings.toml b/settings.toml new file mode 100644 index 0000000..e93b134 --- /dev/null +++ b/settings.toml @@ -0,0 +1,42 @@ +name = "Solar Attachments" +maintainer = "SmartSheep Studio" + +bind = "0.0.0.0:8443" +grpc_bind = "0.0.0.0:7443" +domain = "usercontent.solsynth.dev" +secret = "LtTjzAGFLshwXhN4ZD4nG5KlMv1MWcsvfv03TSZYnT1VhiAnLIZFTnHUwR0XhGgi" + +preferred_destination = "local" +accepts_usage = ["p.avatar", "p.banner", "i.attachment", "m.attachment"] + +[debug] +database = true +print_routes = false + +[passport] +client_id = "solarplaza" +client_secret = "Z9k9AFTj^p" +endpoint = "http://localhost:8444" +grpc_endpoint = "localhost:7444" + +[security] +cookie_domain = "localhost" +cookie_samesite = "Lax" +access_token_duration = 300 +refresh_token_duration = 2592000 + +[database] +dsn = "host=localhost dbname=hy_paperclip port=5432 sslmode=disable" +prefix = "paperclip_" + +[destinations.local] +type = "local" +path = "uploads" + +[destinations.s3] +type = "s3" +bucket = "bucket" +endpoint = "s3.ap-east-1.amazonaws.com" +secret_id = "secret" +secret_key = "secret" +enable_ssl = true \ No newline at end of file