commit 99f85a8b769f23135e778ab92aa6b28b49101cbc Author: LittleSheep Date: Tue Mar 26 23:05:13 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..9c6f441 --- /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/messaging: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/Dockerfile b/Dockerfile new file mode 100644 index 0000000..d7a62c7 --- /dev/null +++ b/Dockerfile @@ -0,0 +1,21 @@ +# Building Backend +FROM golang:alpine as messaging-server + +RUN apk add nodejs npm + +WORKDIR /source +COPY . . +WORKDIR /source/pkg/views +RUN npm install +RUN npm run build +WORKDIR /source +RUN CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -buildvcs -o /dist ./pkg/cmd/main.go + +# Runtime +FROM golang:alpine + +COPY --from=messaging-server /dist /messaging/server + +EXPOSE 8447 + +CMD ["/messaging/server"] diff --git a/go.mod b/go.mod new file mode 100644 index 0000000..66cbd9d --- /dev/null +++ b/go.mod @@ -0,0 +1,72 @@ +module git.solsynth.dev/hydrogen/messaging + +go 1.21.6 + +require ( + git.solsynth.dev/hydrogen/identity v0.0.0-20240320131628-6ac77f36957f + github.com/go-playground/validator/v10 v10.17.0 + github.com/gofiber/fiber/v2 v2.52.0 + github.com/golang-jwt/jwt/v5 v5.2.0 + github.com/google/uuid v1.5.0 + github.com/jordan-wright/email v4.0.1-0.20210109023952-943e75fe5223+incompatible + github.com/json-iterator/go v1.1.12 + github.com/rs/zerolog v1.31.0 + github.com/samber/lo v1.39.0 + github.com/spf13/viper v1.18.2 + golang.org/x/crypto v0.19.0 + 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.0.5 // 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/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.0 // 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/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.2.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.51.0 // indirect + github.com/valyala/tcplisten v1.0.0 // indirect + go.uber.org/multierr v1.11.0 // indirect + golang.org/x/exp v0.0.0-20231219180239-dc181d75b848 // indirect + golang.org/x/net v0.21.0 // indirect + golang.org/x/sync v0.5.0 // indirect + golang.org/x/sys v0.17.0 // indirect + golang.org/x/text v0.14.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..0232238 --- /dev/null +++ b/go.sum @@ -0,0 +1,219 @@ +git.solsynth.dev/hydrogen/identity v0.0.0-20240320131628-6ac77f36957f h1:6vRGU5bSb7Za6HUhpX1bYMsKElRbUyL/qB5fAs5IDE0= +git.solsynth.dev/hydrogen/identity v0.0.0-20240320131628-6ac77f36957f/go.mod h1:rmh5biOQLvoIE2iRFbOfD0TITMP1orYpqzhUw50Z4ck= +github.com/andybalholm/brotli v1.0.5 h1:8uQZIdzKmjc/iuPu7O2ioW48L81FgatrcpfFmiq/cCs= +github.com/andybalholm/brotli v1.0.5/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig= +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/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/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA= +github.com/gofiber/fiber/v2 v2.52.0 h1:S+qXi7y+/Pgvqq4DrSmREGiFwtB7Bu6+QFLuIHYw/UE= +github.com/gofiber/fiber/v2 v2.52.0/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.5.0 h1:1p67kYwdtXjb0gL0BPiP1Av9wiZPo5A8z2cWkTZ+eyU= +github.com/google/uuid v1.5.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/jordan-wright/email v4.0.1-0.20210109023952-943e75fe5223+incompatible h1:jdpOPRN1zP63Td1hDQbZW73xKmzDvZHzVdNYxhnTMDA= +github.com/jordan-wright/email v4.0.1-0.20210109023952-943e75fe5223+incompatible/go.mod h1:1c7szIrayyPPB/987hsnvNzLushdWf4o/79s3P08L8A= +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.0 h1:Rnbp4K9EjcDuVuHtd0dgA4qNuv9yKDYKK1ulpJwgrqM= +github.com/klauspost/compress v1.17.0/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE= +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/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 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY= +github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc= +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/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.51.0 h1:8b30A5JlZ6C7AS81RsWjYMQmrZG6feChmgAolCl1SqA= +github.com/valyala/fasthttp v1.51.0/go.mod h1:oI2XroL+lI7vdXyYoQk03bXBThfFl2cVdIA3Xl7cH8g= +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.19.0 h1:ENy+Az/9Y1vSrlrvBSyna3PITt4tiZLf7sgCjZBX7Wo= +golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDfU= +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.21.0 h1:AQyQV4dYCvJ7vGmJyKki9+PBdyvhkSd8EIx/qb0AYv4= +golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44= +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.5.0 h1:60k92dhOjHxJkrqnwsfl8KuaHbn/5dl0lUPUklKo3qE= +golang.org/x/sync v0.5.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.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.17.0 h1:25cE3gD+tdBA7lp7QfhuV+rJiE9YXTcS3VG1SqssI/Y= +golang.org/x/sys v0.17.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.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ= +golang.org/x/text v0.14.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..e1d11a5 --- /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 messaging 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 messaging user interfaces, each must display + Appropriate Legal Notices; however, if the Program has messaging + 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..7c3bc59 --- /dev/null +++ b/pkg/cmd/main.go @@ -0,0 +1,61 @@ +package main + +import ( + "os" + "os/signal" + "syscall" + + "git.solsynth.dev/hydrogen/messaging/pkg/grpc" + "git.solsynth.dev/hydrogen/messaging/pkg/server" + + messaging "git.solsynth.dev/hydrogen/messaging/pkg" + "git.solsynth.dev/hydrogen/messaging/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 + go func() { + if err := grpc.ConnectPassport(); err != nil { + log.Fatal().Err(err).Msg("An error occurred when connecting to identity grpc endpoint...") + } + }() + + // Server + server.NewServer() + go server.Listen() + + // Messages + log.Info().Msgf("Messaging v%s is started...", messaging.AppVersion) + + quit := make(chan os.Signal, 1) + signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM) + <-quit + + log.Info().Msgf("Messaging v%s is quitting...", messaging.AppVersion) +} diff --git a/pkg/database/migrator.go b/pkg/database/migrator.go new file mode 100644 index 0000000..4f02fa8 --- /dev/null +++ b/pkg/database/migrator.go @@ -0,0 +1,19 @@ +package database + +import ( + "git.solsynth.dev/hydrogen/messaging/pkg/models" + "gorm.io/gorm" +) + +func RunMigration(source *gorm.DB) error { + if err := source.AutoMigrate( + &models.Account{}, + &models.Channel{}, + &models.ChannelMember{}, + &models.Attachment{}, + ); 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/client.go b/pkg/grpc/client.go new file mode 100644 index 0000000..ca3f014 --- /dev/null +++ b/pkg/grpc/client.go @@ -0,0 +1,24 @@ +package grpc + +import ( + idpb "git.solsynth.dev/hydrogen/identity/pkg/grpc/proto" + "google.golang.org/grpc/credentials/insecure" + + "github.com/spf13/viper" + "google.golang.org/grpc" +) + +var Notify idpb.NotifyClient +var Auth idpb.AuthClient + +func ConnectPassport() error { + addr := viper.GetString("identity.grpc_endpoint") + if conn, err := grpc.Dial(addr, grpc.WithTransportCredentials(insecure.NewCredentials())); err != nil { + return err + } else { + Notify = idpb.NewNotifyClient(conn) + Auth = idpb.NewAuthClient(conn) + } + + return nil +} 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..cf03c69 --- /dev/null +++ b/pkg/models/accounts.go @@ -0,0 +1,19 @@ +package models + +// Account profiles basically fetched from Hydrogen.Identity +// 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" gorm:"foreignKey:AuthorID"` + Channels []Channel `json:"channels"` + ExternalID uint `json:"external_id"` +} diff --git a/pkg/models/attachments.go b/pkg/models/attachments.go new file mode 100644 index 0000000..e2e3e67 --- /dev/null +++ b/pkg/models/attachments.go @@ -0,0 +1,43 @@ +package models + +import ( + "fmt" + "path/filepath" + + "github.com/spf13/viper" +) + +type AttachmentType = uint8 + +const ( + AttachmentOthers = AttachmentType(iota) + AttachmentPhoto + AttachmentVideo + AttachmentAudio +) + +type Attachment struct { + BaseModel + + FileID string `json:"file_id"` + Filesize int64 `json:"filesize"` + Filename string `json:"filename"` + Mimetype string `json:"mimetype"` + Hashcode string `json:"hashcode"` + Type AttachmentType `json:"type"` + ExternalUrl string `json:"external_url"` + Author Account `json:"author"` + ArticleID *uint `json:"article_id"` + MomentID *uint `json:"moment_id"` + CommentID *uint `json:"comment_id"` + AuthorID uint `json:"author_id"` +} + +func (v Attachment) GetStoragePath() string { + basepath := viper.GetString("content") + return filepath.Join(basepath, v.FileID) +} + +func (v Attachment) GetAccessPath() string { + return fmt.Sprintf("/api/attachments/o/%s", v.FileID) +} 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/channels.go b/pkg/models/channels.go new file mode 100644 index 0000000..dd39b12 --- /dev/null +++ b/pkg/models/channels.go @@ -0,0 +1,19 @@ +package models + +type Channel struct { + BaseModel + + Name string `json:"name"` + Description string `json:"description"` + Members []ChannelMember `json:"members"` + AccountID uint `json:"account_id"` +} + +type ChannelMember struct { + BaseModel + + ChannelID uint `json:"channel_id"` + AccountID uint `json:"account_id"` + Channel Channel `json:"channel"` + Account Account `json:"account"` +} diff --git a/pkg/security/encryptor.go b/pkg/security/encryptor.go new file mode 100644 index 0000000..6cebde0 --- /dev/null +++ b/pkg/security/encryptor.go @@ -0,0 +1,12 @@ +package security + +import "golang.org/x/crypto/bcrypt" + +func HashPassword(raw string) string { + data, _ := bcrypt.GenerateFromPassword([]byte(raw), 12) + return string(data) +} + +func VerifyPassword(text string, password string) bool { + return bcrypt.CompareHashAndPassword([]byte(password), []byte(text)) == nil +} diff --git a/pkg/security/jwt.go b/pkg/security/jwt.go new file mode 100644 index 0000000..450a16e --- /dev/null +++ b/pkg/security/jwt.go @@ -0,0 +1,81 @@ +package security + +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 = "identity_auth_key" + CookieRefreshKey = "identity_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/server/attachments_api.go b/pkg/server/attachments_api.go new file mode 100644 index 0000000..d1c8daa --- /dev/null +++ b/pkg/server/attachments_api.go @@ -0,0 +1,61 @@ +package server + +import ( + "path/filepath" + + "git.solsynth.dev/hydrogen/messaging/pkg/models" + "git.solsynth.dev/hydrogen/messaging/pkg/services" + "github.com/gofiber/fiber/v2" + "github.com/spf13/viper" +) + +func readAttachment(c *fiber.Ctx) error { + id := c.Params("fileId") + basepath := viper.GetString("content") + + return c.SendFile(filepath.Join(basepath, id)) +} + +func uploadAttachment(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + hashcode := c.FormValue("hashcode") + if len(hashcode) != 64 { + return fiber.NewError(fiber.StatusBadRequest, "please provide a SHA256 hashcode, length should be 64 characters") + } + file, err := c.FormFile("attachment") + if err != nil { + return err + } + + attachment, err := services.NewAttachment(user, file, hashcode) + if err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + + if err := c.SaveFile(file, attachment.GetStoragePath()); err != nil { + return err + } + + return c.JSON(fiber.Map{ + "info": attachment, + "url": attachment.GetAccessPath(), + }) +} + +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.AuthorID != 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..bad3a14 --- /dev/null +++ b/pkg/server/auth.go @@ -0,0 +1,52 @@ +package server + +import ( + "strings" + + "git.solsynth.dev/hydrogen/messaging/pkg/security" + "git.solsynth.dev/hydrogen/messaging/pkg/services" + "github.com/gofiber/fiber/v2" +) + +func authMiddleware(c *fiber.Ctx) error { + var token string + if cookie := c.Cookies(security.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(security.CookieRefreshKey) + if user, atk, rtk, err := services.Authenticate(token, rtk); err == nil { + if atk != token { + security.SetJwtCookieSet(c, atk, rtk) + } + c.Locals("principal", user) + return nil + } else { + return fiber.NewError(fiber.StatusUnauthorized, err.Error()) + } +} diff --git a/pkg/server/channel_members_api.go b/pkg/server/channel_members_api.go new file mode 100644 index 0000000..744359d --- /dev/null +++ b/pkg/server/channel_members_api.go @@ -0,0 +1,86 @@ +package server + +import ( + "git.solsynth.dev/hydrogen/messaging/pkg/database" + "git.solsynth.dev/hydrogen/messaging/pkg/models" + "git.solsynth.dev/hydrogen/messaging/pkg/services" + "github.com/gofiber/fiber/v2" +) + +func listChannelMembers(c *fiber.Ctx) error { + channelId, _ := c.ParamsInt("channelId", 0) + + if members, err := services.ListChannelMember(uint(channelId)); err != nil { + return fiber.NewError(fiber.StatusInternalServerError, err.Error()) + } else { + return c.JSON(members) + } +} + +func inviteChannel(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + channelId, _ := c.ParamsInt("channelId", 0) + + var data struct { + AccountName string `json:"account_name" validate:"required"` + } + + if err := BindAndValidate(c, &data); err != nil { + return err + } + + var channel models.Channel + if err := database.C.Where(&models.Channel{ + BaseModel: models.BaseModel{ID: uint(channelId)}, + AccountID: user.ID, + }).First(&channel).Error; err != nil { + return fiber.NewError(fiber.StatusNotFound, err.Error()) + } + + var account models.Account + if err := database.C.Where(&models.Account{ + Name: data.AccountName, + }).First(&account).Error; err != nil { + return fiber.NewError(fiber.StatusNotFound, err.Error()) + } + + if err := services.InviteChannelMember(account, channel); err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } else { + return c.SendStatus(fiber.StatusOK) + } +} + +func kickChannel(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + channelId, _ := c.ParamsInt("channelId", 0) + + var data struct { + AccountName string `json:"account_name" validate:"required"` + } + + if err := BindAndValidate(c, &data); err != nil { + return err + } + + var channel models.Channel + if err := database.C.Where(&models.Channel{ + BaseModel: models.BaseModel{ID: uint(channelId)}, + AccountID: user.ID, + }).First(&channel).Error; err != nil { + return fiber.NewError(fiber.StatusNotFound, err.Error()) + } + + var account models.Account + if err := database.C.Where(&models.Account{ + Name: data.AccountName, + }).First(&account).Error; err != nil { + return fiber.NewError(fiber.StatusNotFound, err.Error()) + } + + if err := services.KickChannelMember(account, channel); err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } else { + return c.SendStatus(fiber.StatusOK) + } +} diff --git a/pkg/server/channels_api.go b/pkg/server/channels_api.go new file mode 100644 index 0000000..7007f93 --- /dev/null +++ b/pkg/server/channels_api.go @@ -0,0 +1,123 @@ +package server + +import ( + "git.solsynth.dev/hydrogen/messaging/pkg/database" + "git.solsynth.dev/hydrogen/messaging/pkg/models" + "git.solsynth.dev/hydrogen/messaging/pkg/services" + "github.com/gofiber/fiber/v2" +) + +func getChannel(c *fiber.Ctx) error { + id, _ := c.ParamsInt("channelId", 0) + + var channel models.Channel + if err := database.C.Where(&models.Channel{ + BaseModel: models.BaseModel{ID: uint(id)}, + }).First(&channel).Error; err != nil { + return fiber.NewError(fiber.StatusNotFound, err.Error()) + } + + return c.JSON(channel) +} + +func listChannel(c *fiber.Ctx) error { + channels, err := services.ListChannel() + if err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + + return c.JSON(channels) +} + +func listOwnedChannel(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + + channels, err := services.ListChannelWithUser(user) + if err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + + return c.JSON(channels) +} + +func listAvailableChannel(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + + channels, err := services.ListChannelIsAvailable(user) + if err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + + return c.JSON(channels) +} + +func createChannel(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + if user.PowerLevel < 10 { + return fiber.NewError(fiber.StatusForbidden, "require power level 10 to create channels") + } + + var data struct { + Name string `json:"name" validate:"required"` + Description string `json:"description"` + } + + if err := BindAndValidate(c, &data); err != nil { + return err + } + + channel, err := services.NewChannel(user, data.Name, data.Description) + if err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + + return c.JSON(channel) +} + +func editChannel(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + id, _ := c.ParamsInt("channelId", 0) + + var data struct { + Name string `json:"name" validate:"required"` + Description string `json:"description"` + } + + if err := BindAndValidate(c, &data); err != nil { + return err + } + + var channel models.Channel + if err := database.C.Where(&models.Channel{ + BaseModel: models.BaseModel{ID: uint(id)}, + AccountID: user.ID, + }).First(&channel).Error; err != nil { + return fiber.NewError(fiber.StatusNotFound, err.Error()) + } + + channel, err := services.EditChannel(channel, data.Name, data.Description) + if err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + + return c.JSON(channel) +} + +func deleteChannel(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + id, _ := c.ParamsInt("channelId", 0) + + var channel models.Channel + if err := database.C.Where(&models.Channel{ + BaseModel: models.BaseModel{ID: uint(id)}, + AccountID: user.ID, + }).First(&channel).Error; err != nil { + return fiber.NewError(fiber.StatusNotFound, err.Error()) + } + + if err := services.DeleteChannel(channel); err != nil { + return fiber.NewError(fiber.StatusBadRequest, err.Error()) + } + + return c.SendStatus(fiber.StatusOK) +} diff --git a/pkg/server/startup.go b/pkg/server/startup.go new file mode 100644 index 0000000..b31b456 --- /dev/null +++ b/pkg/server/startup.go @@ -0,0 +1,101 @@ +package server + +import ( + "net/http" + "strings" + "time" + + "git.solsynth.dev/hydrogen/messaging/pkg/views" + "github.com/gofiber/fiber/v2" + "github.com/gofiber/fiber/v2/middleware/cache" + "github.com/gofiber/fiber/v2/middleware/cors" + "github.com/gofiber/fiber/v2/middleware/filesystem" + "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.Messaging", + AppName: "Hydrogen.Messaging", + ProxyHeader: fiber.HeaderXForwardedFor, + JSONEncoder: jsoniter.ConfigCompatibleWithStandardLibrary.Marshal, + JSONDecoder: jsoniter.ConfigCompatibleWithStandardLibrary.Unmarshal, + BodyLimit: 50 * 1024 * 1024, + 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) + + api := A.Group("/api").Name("API") + { + api.Get("/users/me", authMiddleware, getUserinfo) + api.Get("/users/:accountId", getOthersInfo) + + api.Get("/attachments/o/:fileId", cache.New(cache.Config{ + Expiration: 365 * 24 * time.Hour, + CacheControl: true, + }), readAttachment) + api.Post("/attachments", authMiddleware, uploadAttachment) + api.Delete("/attachments/:id", authMiddleware, deleteAttachment) + + channels := api.Group("/channels").Name("Channels API") + { + channels.Get("/", listChannel) + channels.Get("/me", authMiddleware, listOwnedChannel) + channels.Get("/me/available", authMiddleware, listAvailableChannel) + channels.Get("/:channelId", getChannel) + channels.Get("/:channelId/members", listChannelMembers) + channels.Post("/", authMiddleware, createChannel) + channels.Post("/:channelId/invite", authMiddleware, inviteChannel) + channels.Post("/:channelId/kick", authMiddleware, kickChannel) + channels.Put("/:channelId", authMiddleware, editChannel) + channels.Delete("/:channelId", authMiddleware, deleteChannel) + } + } + + A.Use("/", cache.New(cache.Config{ + Expiration: 24 * time.Hour, + CacheControl: true, + }), filesystem.New(filesystem.Config{ + Root: http.FS(views.FS), + PathPrefix: "dist", + Index: "index.html", + NotFoundFile: "dist/index.html", + })) +} + +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/users_api.go b/pkg/server/users_api.go new file mode 100644 index 0000000..5ad9a10 --- /dev/null +++ b/pkg/server/users_api.go @@ -0,0 +1,33 @@ +package server + +import ( + "git.solsynth.dev/hydrogen/messaging/pkg/database" + "git.solsynth.dev/hydrogen/messaging/pkg/models" + "github.com/gofiber/fiber/v2" +) + +func getUserinfo(c *fiber.Ctx) error { + user := c.Locals("principal").(models.Account) + + var data models.Account + if err := database.C. + Where(&models.Account{BaseModel: models.BaseModel{ID: user.ID}}). + First(&data).Error; err != nil { + return fiber.NewError(fiber.StatusInternalServerError, err.Error()) + } + + return c.JSON(data) +} + +func getOthersInfo(c *fiber.Ctx) error { + accountId := c.Params("accountId") + + var data models.Account + if err := database.C. + Where(&models.Account{Name: accountId}). + First(&data).Error; err != nil { + return fiber.NewError(fiber.StatusInternalServerError, err.Error()) + } + + return c.JSON(data) +} 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..e320daa --- /dev/null +++ b/pkg/server/well_known_api.go @@ -0,0 +1,16 @@ +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{ + "identity": viper.GetString("identity.endpoint"), + }, + }) +} diff --git a/pkg/services/accounts.go b/pkg/services/accounts.go new file mode 100644 index 0000000..d1996b3 --- /dev/null +++ b/pkg/services/accounts.go @@ -0,0 +1,28 @@ +package services + +import ( + "context" + "time" + + "git.solsynth.dev/hydrogen/identity/pkg/grpc/proto" + "git.solsynth.dev/hydrogen/messaging/pkg/grpc" + "git.solsynth.dev/hydrogen/messaging/pkg/models" + "github.com/spf13/viper" +) + +func NotifyAccount(user models.Account, subject, content string, 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("identity.client_id"), + ClientSecret: viper.GetString("identity.client_secret"), + Subject: subject, + Content: content, + Links: links, + RecipientId: uint64(user.ID), + IsImportant: false, + }) + + return err +} diff --git a/pkg/services/attachments.go b/pkg/services/attachments.go new file mode 100644 index 0000000..9abcf9b --- /dev/null +++ b/pkg/services/attachments.go @@ -0,0 +1,127 @@ +package services + +import ( + "mime/multipart" + "net/http" + "os" + "path/filepath" + "strings" + + "git.solsynth.dev/hydrogen/messaging/pkg/database" + "git.solsynth.dev/hydrogen/messaging/pkg/models" + "github.com/google/uuid" + "github.com/spf13/viper" +) + +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(fileId string) (models.Attachment, error) { + var attachment models.Attachment + if err := database.C.Where(models.Attachment{ + FileID: fileId, + }).First(&attachment).Error; err != nil { + return attachment, err + } + return attachment, nil +} + +func GetAttachmentByHashcode(hashcode string) (models.Attachment, error) { + var attachment models.Attachment + if err := database.C.Where(models.Attachment{ + Hashcode: hashcode, + }).First(&attachment).Error; err != nil { + return attachment, err + } + return attachment, nil +} + +func NewAttachment(user models.Account, header *multipart.FileHeader, hashcode string) (models.Attachment, error) { + var attachment models.Attachment + existsAttachment, err := GetAttachmentByHashcode(hashcode) + if err != nil { + // Upload the new file + attachment = models.Attachment{ + FileID: uuid.NewString(), + Filesize: header.Size, + Filename: header.Filename, + Hashcode: hashcode, + Mimetype: "unknown/unknown", + Type: models.AttachmentOthers, + AuthorID: user.ID, + } + + // Open file + file, err := header.Open() + if err != nil { + return attachment, err + } + defer file.Close() + + // Detect mimetype + fileHeader := make([]byte, 512) + _, err = file.Read(fileHeader) + if err != nil { + return attachment, err + } + attachment.Mimetype = http.DetectContentType(fileHeader) + + switch strings.Split(attachment.Mimetype, "/")[0] { + case "image": + attachment.Type = models.AttachmentPhoto + case "video": + attachment.Type = models.AttachmentVideo + case "audio": + attachment.Type = models.AttachmentAudio + default: + attachment.Type = models.AttachmentOthers + } + } else { + // Instant upload, build link with the exists file + attachment = models.Attachment{ + FileID: existsAttachment.FileID, + Filesize: header.Size, + Filename: header.Filename, + Hashcode: hashcode, + Mimetype: existsAttachment.Mimetype, + Type: existsAttachment.Type, + AuthorID: user.ID, + } + } + + // Save into database + err = database.C.Save(&attachment).Error + + return attachment, err +} + +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 { + // Safe for deletion the physics file + basepath := viper.GetString("content") + fullpath := filepath.Join(basepath, item.FileID) + + os.Remove(fullpath) + } + + return nil +} diff --git a/pkg/services/auth.go b/pkg/services/auth.go new file mode 100644 index 0000000..cd57803 --- /dev/null +++ b/pkg/services/auth.go @@ -0,0 +1,71 @@ +package services + +import ( + "context" + "errors" + "fmt" + "time" + + "git.solsynth.dev/hydrogen/identity/pkg/grpc/proto" + "git.solsynth.dev/hydrogen/messaging/pkg/database" + "git.solsynth.dev/hydrogen/messaging/pkg/grpc" + "git.solsynth.dev/hydrogen/messaging/pkg/models" + "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 + } + + account.Name = userinfo.Name + account.Nick = userinfo.Nick + account.Avatar = userinfo.Avatar + account.Banner = userinfo.Banner + account.Description = userinfo.GetDescription() + account.EmailAddress = userinfo.Email + + 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/channels.go b/pkg/services/channels.go new file mode 100644 index 0000000..6115862 --- /dev/null +++ b/pkg/services/channels.go @@ -0,0 +1,110 @@ +package services + +import ( + "git.solsynth.dev/hydrogen/messaging/pkg/database" + "git.solsynth.dev/hydrogen/messaging/pkg/models" + "github.com/samber/lo" +) + +func ListChannel() ([]models.Channel, error) { + var channels []models.Channel + if err := database.C.Find(&channels).Error; err != nil { + return channels, err + } + + return channels, nil +} + +func ListChannelWithUser(user models.Account) ([]models.Channel, error) { + var channels []models.Channel + if err := database.C.Where(&models.Channel{AccountID: user.ID}).Find(&channels).Error; err != nil { + return channels, err + } + + return channels, nil +} + +func ListChannelIsAvailable(user models.Account) ([]models.Channel, error) { + var channels []models.Channel + var members []models.ChannelMember + if err := database.C.Where(&models.ChannelMember{ + AccountID: user.ID, + }).Find(&members).Error; err != nil { + return channels, err + } + + idx := lo.Map(members, func(item models.ChannelMember, index int) uint { + return item.ChannelID + }) + + if err := database.C.Where("id IN ?", idx).Find(&channels).Error; err != nil { + return channels, err + } + + return channels, nil +} + +func NewChannel(user models.Account, name, description string) (models.Channel, error) { + channel := models.Channel{ + Name: name, + Description: description, + AccountID: user.ID, + Members: []models.ChannelMember{ + {AccountID: user.ID}, + }, + } + + err := database.C.Save(&channel).Error + + return channel, err +} + +func ListChannelMember(channelId uint) ([]models.ChannelMember, error) { + var members []models.ChannelMember + + if err := database.C. + Where(&models.ChannelMember{ChannelID: channelId}). + Preload("Account"). + Find(&members).Error; err != nil { + return members, err + } + + return members, nil +} + +func InviteChannelMember(user models.Account, target models.Channel) error { + member := models.ChannelMember{ + ChannelID: target.ID, + AccountID: user.ID, + } + + err := database.C.Save(&member).Error + + return err +} + +func KickChannelMember(user models.Account, target models.Channel) error { + var member models.ChannelMember + + if err := database.C.Where(&models.ChannelMember{ + ChannelID: target.ID, + AccountID: user.ID, + }).First(&member).Error; err != nil { + return err + } + + return database.C.Delete(&member).Error +} + +func EditChannel(channel models.Channel, name, description string) (models.Channel, error) { + channel.Name = name + channel.Description = description + + err := database.C.Save(&channel).Error + + return channel, err +} + +func DeleteChannel(channel models.Channel) error { + return database.C.Delete(&channel).Error +} diff --git a/pkg/services/mailer.go b/pkg/services/mailer.go new file mode 100644 index 0000000..74301fe --- /dev/null +++ b/pkg/services/mailer.go @@ -0,0 +1,51 @@ +package services + +import ( + "crypto/tls" + "fmt" + "net/smtp" + "net/textproto" + + "github.com/jordan-wright/email" + "github.com/spf13/viper" +) + +func SendMail(target string, subject string, content string) error { + mail := &email.Email{ + To: []string{target}, + From: viper.GetString("mailer.name"), + Subject: subject, + Text: []byte(content), + Headers: textproto.MIMEHeader{}, + } + return mail.SendWithTLS( + fmt.Sprintf("%s:%d", viper.GetString("mailer.smtp_host"), viper.GetInt("mailer.smtp_port")), + smtp.PlainAuth( + "", + viper.GetString("mailer.username"), + viper.GetString("mailer.password"), + viper.GetString("mailer.smtp_host"), + ), + &tls.Config{ServerName: viper.GetString("mailer.smtp_host")}, + ) +} + +func SendMailHTML(target string, subject string, content string) error { + mail := &email.Email{ + To: []string{target}, + From: viper.GetString("mailer.name"), + Subject: subject, + HTML: []byte(content), + Headers: textproto.MIMEHeader{}, + } + return mail.SendWithTLS( + fmt.Sprintf("%s:%d", viper.GetString("mailer.smtp_host"), viper.GetInt("mailer.smtp_port")), + smtp.PlainAuth( + "", + viper.GetString("mailer.username"), + viper.GetString("mailer.password"), + viper.GetString("mailer.smtp_host"), + ), + &tls.Config{ServerName: viper.GetString("mailer.smtp_host")}, + ) +} diff --git a/pkg/views/.eslintrc.cjs b/pkg/views/.eslintrc.cjs new file mode 100644 index 0000000..94744c3 --- /dev/null +++ b/pkg/views/.eslintrc.cjs @@ -0,0 +1,20 @@ +/* eslint-env node */ +require("@rushstack/eslint-patch/modern-module-resolution") + +module.exports = { + root: true, + extends: [ + "plugin:vue/vue3-essential", + "eslint:recommended", + "@vue/eslint-config-typescript", + "@vue/eslint-config-prettier/skip-formatting" + ], + parserOptions: { + ecmaVersion: "latest" + }, + rules: { + "vue/multi-word-component-names": "off", + "vue/valid-v-for": "off", + "vue/require-v-for-key": "off" + } +} diff --git a/pkg/views/.gitignore b/pkg/views/.gitignore new file mode 100644 index 0000000..a2e7c9e --- /dev/null +++ b/pkg/views/.gitignore @@ -0,0 +1,33 @@ +# Logs +logs +*.log +npm-debug.log* +yarn-debug.log* +yarn-error.log* +pnpm-debug.log* +lerna-debug.log* + +node_modules +.DS_Store +dist +dist-ssr +coverage +*.local + +/cypress/videos/ +/cypress/screenshots/ + +# Editor directories and files +.vscode/* +!.vscode/extensions.json +.idea +*.suo +*.ntvs* +*.njsproj +*.sln +*.sw? + +*.tsbuildinfo + +*.lockb +*.lock \ No newline at end of file diff --git a/pkg/views/.prettierrc.json b/pkg/views/.prettierrc.json new file mode 100644 index 0000000..88cdad7 --- /dev/null +++ b/pkg/views/.prettierrc.json @@ -0,0 +1,8 @@ +{ + "$schema": "https://json.schemastore.org/prettierrc", + "semi": false, + "tabWidth": 2, + "singleQuote": false, + "printWidth": 120, + "trailingComma": "none" +} diff --git a/pkg/views/.vscode/extensions.json b/pkg/views/.vscode/extensions.json new file mode 100644 index 0000000..009a534 --- /dev/null +++ b/pkg/views/.vscode/extensions.json @@ -0,0 +1,8 @@ +{ + "recommendations": [ + "Vue.volar", + "Vue.vscode-typescript-vue-plugin", + "dbaeumer.vscode-eslint", + "esbenp.prettier-vscode" + ] +} diff --git a/pkg/views/README.md b/pkg/views/README.md new file mode 100644 index 0000000..a164f21 --- /dev/null +++ b/pkg/views/README.md @@ -0,0 +1,46 @@ +# views + +This template should help get you started developing with Vue 3 in Vite. + +## Recommended IDE Setup + +[VSCode](https://code.visualstudio.com/) + [Volar](https://marketplace.visualstudio.com/items?itemName=Vue.volar) (and disable Vetur) + [TypeScript Vue Plugin (Volar)](https://marketplace.visualstudio.com/items?itemName=Vue.vscode-typescript-vue-plugin). + +## Type Support for `.vue` Imports in TS + +TypeScript cannot handle type information for `.vue` imports by default, so we replace the `tsc` CLI with `vue-tsc` for type checking. In editors, we need [TypeScript Vue Plugin (Volar)](https://marketplace.visualstudio.com/items?itemName=Vue.vscode-typescript-vue-plugin) to make the TypeScript language service aware of `.vue` types. + +If the standalone TypeScript plugin doesn't feel fast enough to you, Volar has also implemented a [Take Over Mode](https://github.com/johnsoncodehk/volar/discussions/471#discussioncomment-1361669) that is more performant. You can enable it by the following steps: + +1. Disable the built-in TypeScript Extension + 1. Run `Extensions: Show Built-in Extensions` from VSCode's command palette + 2. Find `TypeScript and JavaScript Language Features`, right click and select `Disable (Workspace)` +2. Reload the VSCode window by running `Developer: Reload Window` from the command palette. + +## Customize configuration + +See [Vite Configuration Reference](https://vitejs.dev/config/). + +## Project Setup + +```sh +npm install +``` + +### Compile and Hot-Reload for Development + +```sh +npm run dev +``` + +### Type-Check, Compile and Minify for Production + +```sh +npm run build +``` + +### Lint with [ESLint](https://eslint.org/) + +```sh +npm run lint +``` diff --git a/pkg/views/embed.go b/pkg/views/embed.go new file mode 100644 index 0000000..bc04fa4 --- /dev/null +++ b/pkg/views/embed.go @@ -0,0 +1,6 @@ +package views + +import "embed" + +//go:embed all:dist +var FS embed.FS diff --git a/pkg/views/env.d.ts b/pkg/views/env.d.ts new file mode 100644 index 0000000..11f02fe --- /dev/null +++ b/pkg/views/env.d.ts @@ -0,0 +1 @@ +/// diff --git a/pkg/views/index.html b/pkg/views/index.html new file mode 100644 index 0000000..87c2281 --- /dev/null +++ b/pkg/views/index.html @@ -0,0 +1,13 @@ + + + + + + + Solarplaza + + +
+ + + diff --git a/pkg/views/package.json b/pkg/views/package.json new file mode 100644 index 0000000..f466f41 --- /dev/null +++ b/pkg/views/package.json @@ -0,0 +1,48 @@ +{ + "name": "views", + "version": "0.0.0", + "private": true, + "type": "module", + "scripts": { + "dev": "vite", + "build": "run-p type-check \"build-only {@}\" --", + "preview": "vite preview", + "build-only": "vite build", + "type-check": "vue-tsc --build --force", + "lint": "eslint . --ext .vue,.js,.jsx,.cjs,.mjs,.ts,.tsx,.cts,.mts --fix --ignore-path .gitignore", + "format": "prettier --write src/" + }, + "dependencies": { + "@fontsource/roboto": "^5.0.8", + "@mdi/font": "^7.4.47", + "@unocss/reset": "^0.58.5", + "dompurify": "^3.0.9", + "marked": "^12.0.0", + "pinia": "^2.1.7", + "universal-cookie": "^7.1.0", + "unocss": "^0.58.5", + "vue": "^3.4.15", + "vue-easy-lightbox": "next", + "vue-router": "^4.2.5", + "vuetify": "^3.5.7" + }, + "devDependencies": { + "@rushstack/eslint-patch": "^1.3.3", + "@tsconfig/node20": "^20.1.2", + "@types/dompurify": "^3.0.5", + "@types/node": "^20.11.10", + "@unocss/preset-typography": "^0.58.5", + "@vitejs/plugin-vue": "^5.0.3", + "@vitejs/plugin-vue-jsx": "^3.1.0", + "@vue/eslint-config-prettier": "^8.0.0", + "@vue/eslint-config-typescript": "^12.0.0", + "@vue/tsconfig": "^0.5.1", + "eslint": "^8.49.0", + "eslint-plugin-vue": "^9.17.0", + "npm-run-all2": "^6.1.1", + "prettier": "^3.0.3", + "typescript": "~5.3.0", + "vite": "^5.0.11", + "vue-tsc": "^1.8.27" + } +} diff --git a/pkg/views/src/assets/utils.css b/pkg/views/src/assets/utils.css new file mode 100644 index 0000000..840e4ee --- /dev/null +++ b/pkg/views/src/assets/utils.css @@ -0,0 +1,15 @@ +html, +body, +#app, +.v-application { + overflow: auto !important; + font-family: "Roboto Sans", ui-sans-serif, system-ui, sans-serif; +} + +.no-scrollbar { + scrollbar-width: none; +} + +.no-scrollbar::-webkit-scrollbar { + width: 0; +} diff --git a/pkg/views/src/index.vue b/pkg/views/src/index.vue new file mode 100644 index 0000000..4f21c35 --- /dev/null +++ b/pkg/views/src/index.vue @@ -0,0 +1,5 @@ + diff --git a/pkg/views/src/layouts/master.vue b/pkg/views/src/layouts/master.vue new file mode 100644 index 0000000..7673d74 --- /dev/null +++ b/pkg/views/src/layouts/master.vue @@ -0,0 +1,108 @@ + + + + + diff --git a/pkg/views/src/main.ts b/pkg/views/src/main.ts new file mode 100644 index 0000000..233d23b --- /dev/null +++ b/pkg/views/src/main.ts @@ -0,0 +1,54 @@ +import "virtual:uno.css" + +import "./assets/utils.css" + +import { createApp } from "vue" +import { createPinia } from "pinia" + +import "vuetify/styles" +import { createVuetify } from "vuetify" +import { md3 } from "vuetify/blueprints" +import * as components from "vuetify/components" +import * as labsComponents from "vuetify/labs/components" +import * as directives from "vuetify/directives" + +import "@mdi/font/css/materialdesignicons.min.css" +import "@fontsource/roboto/latin.css" +import "@unocss/reset/tailwind.css" + +import index from "./index.vue" +import router from "./router" + +const app = createApp(index) + +app.use( + createVuetify({ + directives, + components: { + ...components, + ...labsComponents + }, + blueprint: md3, + theme: { + defaultTheme: "original", + themes: { + original: { + colors: { + primary: "#4a5099", + secondary: "#2196f3", + accent: "#009688", + error: "#f44336", + warning: "#ff9800", + info: "#03a9f4", + success: "#4caf50" + } + } + } + } + }) +) + +app.use(createPinia()) +app.use(router) + +app.mount("#app") diff --git a/pkg/views/src/router/index.ts b/pkg/views/src/router/index.ts new file mode 100644 index 0000000..52728d8 --- /dev/null +++ b/pkg/views/src/router/index.ts @@ -0,0 +1,21 @@ +import { createRouter, createWebHistory } from "vue-router" +import MasterLayout from "@/layouts/master.vue" + +const router = createRouter({ + history: createWebHistory(import.meta.env.BASE_URL), + routes: [ + { + path: "/", + component: MasterLayout, + children: [ + { + path: "/", + name: "landing", + component: () => import("@/views/landing.vue") + }, + ] + } + ] +}) + +export default router diff --git a/pkg/views/src/scripts/request.ts b/pkg/views/src/scripts/request.ts new file mode 100644 index 0000000..5540ff2 --- /dev/null +++ b/pkg/views/src/scripts/request.ts @@ -0,0 +1,10 @@ +declare global { + interface Window { + __LAUNCHPAD_TARGET__?: string + } +} + +export async function request(input: string, init?: RequestInit) { + const prefix = window.__LAUNCHPAD_TARGET__ ?? "" + return await fetch(prefix + input, init) +} diff --git a/pkg/views/src/stores/userinfo.ts b/pkg/views/src/stores/userinfo.ts new file mode 100644 index 0000000..386a857 --- /dev/null +++ b/pkg/views/src/stores/userinfo.ts @@ -0,0 +1,56 @@ +import Cookie from "universal-cookie" +import { defineStore } from "pinia" +import { ref } from "vue" +import { request } from "@/scripts/request" + +export interface Userinfo { + isReady: boolean + isLoggedIn: boolean + displayName: string + data: any +} + +const defaultUserinfo: Userinfo = { + isReady: false, + isLoggedIn: false, + displayName: "Citizen", + data: null +} + +export function getAtk(): string { + return new Cookie().get("identity_auth_key") +} + +export function checkLoggedIn(): boolean { + return new Cookie().get("identity_auth_key") +} + +export const useUserinfo = defineStore("userinfo", () => { + const userinfo = ref(defaultUserinfo) + const isReady = ref(false) + + async function readProfiles() { + if (!checkLoggedIn()) { + isReady.value = true + } + + const res = await request("/api/users/me", { + headers: { Authorization: `Bearer ${getAtk()}` } + }) + + if (res.status !== 200) { + return + } + + const data = await res.json() + + userinfo.value = { + isReady: true, + isLoggedIn: true, + displayName: data["nick"], + data: data + } + } + + return { userinfo, isReady, readProfiles } +}) diff --git a/pkg/views/src/stores/wellKnown.ts b/pkg/views/src/stores/wellKnown.ts new file mode 100644 index 0000000..498f838 --- /dev/null +++ b/pkg/views/src/stores/wellKnown.ts @@ -0,0 +1,14 @@ +import { request } from "@/scripts/request" +import { defineStore } from "pinia" +import { ref } from "vue" + +export const useWellKnown = defineStore("well-known", () => { + const wellKnown = ref(null) + + async function readWellKnown() { + const res = await request("/.well-known") + wellKnown.value = await res.json() + } + + return { wellKnown, readWellKnown } +}) diff --git a/pkg/views/src/views/landing.vue b/pkg/views/src/views/landing.vue new file mode 100644 index 0000000..21b9463 --- /dev/null +++ b/pkg/views/src/views/landing.vue @@ -0,0 +1,3 @@ + diff --git a/pkg/views/tsconfig.app.json b/pkg/views/tsconfig.app.json new file mode 100644 index 0000000..292c91d --- /dev/null +++ b/pkg/views/tsconfig.app.json @@ -0,0 +1,16 @@ +{ + "extends": "@vue/tsconfig/tsconfig.dom.json", + "include": ["env.d.ts", "src/**/*", "src/**/*.vue"], + "exclude": ["src/**/__tests__/*"], + "compilerOptions": { + "composite": true, + "allowJs": true, + "checkJs": true, + "tsBuildInfoFile": "./node_modules/.tmp/tsconfig.app.tsbuildinfo", + + "baseUrl": ".", + "paths": { + "@/*": ["./src/*"] + } + } +} diff --git a/pkg/views/tsconfig.json b/pkg/views/tsconfig.json new file mode 100644 index 0000000..66b5e57 --- /dev/null +++ b/pkg/views/tsconfig.json @@ -0,0 +1,11 @@ +{ + "files": [], + "references": [ + { + "path": "./tsconfig.node.json" + }, + { + "path": "./tsconfig.app.json" + } + ] +} diff --git a/pkg/views/tsconfig.node.json b/pkg/views/tsconfig.node.json new file mode 100644 index 0000000..2c669ee --- /dev/null +++ b/pkg/views/tsconfig.node.json @@ -0,0 +1,13 @@ +{ + "extends": "@tsconfig/node20/tsconfig.json", + "include": ["vite.config.*", "vitest.config.*", "cypress.config.*", "nightwatch.conf.*", "playwright.config.*"], + "compilerOptions": { + "composite": true, + "noEmit": true, + "tsBuildInfoFile": "./node_modules/.tmp/tsconfig.node.tsbuildinfo", + + "module": "ESNext", + "moduleResolution": "Bundler", + "types": ["node"] + } +} diff --git a/pkg/views/uno.config.ts b/pkg/views/uno.config.ts new file mode 100644 index 0000000..d0bf10d --- /dev/null +++ b/pkg/views/uno.config.ts @@ -0,0 +1,5 @@ +import { defineConfig, presetAttributify, presetTypography, presetUno } from "unocss" + +export default defineConfig({ + presets: [presetAttributify(), presetTypography(), presetUno({ preflight: false })] +}) diff --git a/pkg/views/vite.config.ts b/pkg/views/vite.config.ts new file mode 100644 index 0000000..d86038d --- /dev/null +++ b/pkg/views/vite.config.ts @@ -0,0 +1,22 @@ +import { fileURLToPath, URL } from "node:url" + +import { defineConfig } from "vite" +import vue from "@vitejs/plugin-vue" +import vueJsx from "@vitejs/plugin-vue-jsx" +import unocss from "unocss/vite" + +// https://vitejs.dev/config/ +export default defineConfig({ + plugins: [vue(), vueJsx(), unocss()], + resolve: { + alias: { + "@": fileURLToPath(new URL("./src", import.meta.url)) + } + }, + server: { + proxy: { + "/.well-known": "http://localhost:8447", + "/api": "http://localhost:8447" + } + } +}) diff --git a/settings.toml b/settings.toml new file mode 100644 index 0000000..ae5bd2e --- /dev/null +++ b/settings.toml @@ -0,0 +1,35 @@ +name = "Solarplaza" +maintainer = "SmartSheep Studio" + +bind = "0.0.0.0:8447" +domain = "feed.smartsheep.studio" +secret = "LtTjzAGFLshwXhN4ZD4nG5KlMv1MWcsvfv03TSZYnT1VhiAnLIZFTnHUwR0XhGgi" + +content = "uploads" + +[debug] +database = true +print_routes = false + +[identity] +client_id = "solarecho" +client_secret = "Z9k9AFTj^p" +endpoint = "http://localhost:8444" +grpc_endpoint = "127.0.0.1:7444" + +[mailer] +name = "Alphabot " +smtp_host = "smtp.exmail.qq.com" +smtp_port = 465 +username = "alphabot@smartsheep.studio" +password = "gz937Zxxzfcd9SeH" + +[security] +cookie_domain = "localhost" +cookie_samesite = "Lax" +access_token_duration = 300 +refresh_token_duration = 2592000 + +[database] +dsn = "host=localhost dbname=hy_messaging port=5432 sslmode=disable" +prefix = "messaging_"